feat(mcp): 修正局域网接入地址展示

Author: 2977094657

desktop/src/main.cjs

@@ -21,6 +21,7 @@ const crypto = require("crypto");
 const fs = require("fs");
 const http = require("http");
 const net = require("net");
+const os = require("os");
 const path = require("path");
 const { Worker } = require("worker_threads");
 const {
@@ -101,6 +102,84 @@ function getBackendAccessHost() {
   return host || "127.0.0.1";
 }
 
+function getInterfacePenalty(name) {
+  const lower = String(name || "").toLowerCase();
+  if (/(docker|hyper-v|loopback|npcap|tailscale|virtual|virtualbox|vmware|vethernet|wsl|zerotier)/i.test(lower)) {
+    return 30;
+  }
+  if (/(ethernet|wi-fi|wifi|wireless|wlan|以太|无线)/i.test(lower)) {
+    return 0;
+  }
+  return 10;
+}
+
+function isReachableClientIpv4(address) {
+  const text = String(address || "").trim();
+  const parts = text.split(".");
+  if (parts.length !== 4) return false;
+  const nums = parts.map((part) => Number(part));
+  if (!nums.every((n) => Number.isInteger(n) && n >= 0 && n <= 255)) return false;
+  if (nums[0] === 0 || nums[0] === 127 || nums[0] >= 224) return false;
+  if (nums[0] === 169 && nums[1] === 254) return false;
+  return true;
+}
+
+function isPrivateIpv4(address) {
+  const nums = String(address || "").trim().split(".").map((part) => Number(part));
+  if (nums.length !== 4 || !nums.every((n) => Number.isInteger(n))) return false;
+  return (
+    nums[0] === 10 ||
+    (nums[0] === 172 && nums[1] >= 16 && nums[1] <= 31) ||
+    (nums[0] === 192 && nums[1] === 168)
+  );
+}
+
+function getLanAccessHost(defaultHost = DEFAULT_BACKEND_HOST) {
+  const candidates = [];
+  const seen = new Set();
+  const addCandidate = (address, interfaceName = "", sourceOrder = 0) => {
+    const value = String(address || "").trim();
+    if (!isReachableClientIpv4(value) || seen.has(value)) return;
+    seen.add(value);
+    candidates.push([
+      isPrivateIpv4(value) ? 0 : 1,
+      getInterfacePenalty(interfaceName),
+      sourceOrder,
+      value,
+    ]);
+  };
+
+  try {
+    const interfaces = os.networkInterfaces();
+    for (const [name, addresses] of Object.entries(interfaces || {})) {
+      for (const item of addresses || []) {
+        if (!item || (item.family !== "IPv4" && item.family !== 4) || item.internal) continue;
+        addCandidate(item.address, name, 0);
+      }
+    }
+  } catch {}
+
+  candidates.sort((a, b) => a[0] - b[0] || a[1] - b[1] || a[2] - b[2]);
+  return candidates[0]?.[3] || defaultHost;
+}
+
+function getMcpAccessHost(bindHost = getBackendBindHost()) {
+  const host = String(bindHost || "").trim();
+  if (host === LAN_BACKEND_HOST || host === "::") return getLanAccessHost(DEFAULT_BACKEND_HOST);
+  return host || DEFAULT_BACKEND_HOST;
+}
+
+function getMcpAccessInfo(bindHost = getBackendBindHost(), port = getBackendPort()) {
+  const accessHost = getMcpAccessHost(bindHost);
+  const origin = `http://${formatHostForUrl(accessHost)}:${port}`;
+  return {
+    accessHost,
+    mcpEndpoint: `${origin}/mcp`,
+    skillBundleUrl: `${origin}/mcp/skill/bundle`,
+    skillMarkdownUrl: `${origin}/mcp/skill`,
+  };
+}
+
 function getBackendPort() {
   const envPort = parsePort(process.env.WECHAT_TOOL_PORT);
   if (envPort != null) return envPort;
@@ -2340,19 +2419,24 @@ function registerWindowIpc() {
 
   ipcMain.handle("backend:getMcpLanAccess", () => {
     try {
+      const host = getBackendBindHost();
+      const port = getBackendPort();
       return {
         enabled: getMcpLanAccessEnabled(),
-        host: getBackendBindHost(),
-        port: getBackendPort(),
+        host,
+        port,
         uiUrl: getDesktopUiUrl(),
+        ...getMcpAccessInfo(host, port),
       };
     } catch (err) {
       logMain(`[main] backend:getMcpLanAccess failed: ${err?.message || err}`);
+      const port = DEFAULT_BACKEND_PORT;
       return {
         enabled: false,
         host: DEFAULT_BACKEND_HOST,
-        port: DEFAULT_BACKEND_PORT,
+        port,
         uiUrl: getDesktopUiUrl(),
+        ...getMcpAccessInfo(DEFAULT_BACKEND_HOST, port),
       };
     }
   });
@@ -2363,13 +2447,16 @@ function registerWindowIpc() {
     const nextEnabled = !!enabled;
     const prevEnabled = getMcpLanAccessEnabled();
     if (nextEnabled === prevEnabled) {
+      const host = getBackendBindHost();
+      const port = getBackendPort();
       return {
         success: true,
         changed: false,
         enabled: prevEnabled,
-        host: getBackendBindHost(),
-        port: getBackendPort(),
+        host,
+        port,
         uiUrl: getDesktopUiUrl(),
+        ...getMcpAccessInfo(host, port),
       };
     }
 
@@ -2396,6 +2483,7 @@ function registerWindowIpc() {
         host: getBackendBindHost(),
         port: getBackendPort(),
         uiUrl,
+        ...getMcpAccessInfo(),
       };
     } finally {
       backendPortChangeInProgress = false;

frontend/components/SettingsDialog.vue

@@ -269,6 +269,7 @@
                   <div class="min-w-0 flex-1">
                     <div class="text-[13px] font-medium text-[#222]">允许手机局域网接入 MCP</div>
                     <div class="mt-0.5 text-[11px] leading-relaxed text-[#909090]">开启后后端监听 0.0.0.0，手机可通过接入提示词中的地址接入。</div>
+                    <div class="mt-0.5 text-[11px] leading-relaxed text-[#909090] break-all">当前地址：{{ mcpEndpoint }}</div>
                     <div v-if="mcpLanAccessMessage" class="mt-1 text-[11px] leading-relaxed text-[#1b6b43]">{{ mcpLanAccessMessage }}</div>
                     <div v-if="mcpLanAccessError" class="mt-1 text-[11px] leading-relaxed text-red-600">{{ mcpLanAccessError }}</div>
                   </div>
@@ -608,6 +609,8 @@ const mcpSkillBundleText = ref('')
 const mcpSkillBundleLoading = ref(false)
 const mcpSkillBundleError = ref('')
 const mcpCopiedKey = ref('')
+const mcpAccessHost = ref('')
+const mcpAccessEndpoint = ref('')
 let mcpCopiedTimer = null
 
 const mcpPortText = computed(() => {
@@ -617,6 +620,10 @@ const mcpPortText = computed(() => {
 })
 
 const mcpEndpoint = computed(() => {
+  const reported = String(mcpAccessEndpoint.value || '').trim()
+  if (/^https?:\/\//i.test(reported)) return reported
+  const reportedHost = String(mcpAccessHost.value || '').trim()
+  if (reportedHost) return `http://${reportedHost}:${mcpPortText.value}/mcp`
   if (!process.client || typeof window === 'undefined') return `http://127.0.0.1:${mcpPortText.value}/mcp`
   const apiBase = useApiBase()
   if (/^https?:\/\//i.test(apiBase)) {
@@ -630,6 +637,14 @@ const mcpEndpoint = computed(() => {
   return `${protocol}//${host}:${mcpPortText.value}/mcp`
 })
 
+const applyMcpAccessInfo = (resp) => {
+  if (!resp || typeof resp !== 'object') return
+  const accessHost = String(resp.accessHost || resp.access_host || '').trim()
+  const endpoint = String(resp.mcpEndpoint || resp.mcp_endpoint || '').trim()
+  if (accessHost) mcpAccessHost.value = accessHost
+  if (/^https?:\/\//i.test(endpoint)) mcpAccessEndpoint.value = endpoint
+}
+
 const mcpSkillFallback = [
   '# WeChat MCP Copilot',
   '',
@@ -800,10 +815,12 @@ const refreshMcpLanAccess = async () => {
     if (window.wechatDesktop?.getMcpLanAccess) {
       const resp = await window.wechatDesktop.getMcpLanAccess()
       mcpLanAccessEnabled.value = !!resp?.enabled
+      applyMcpAccessInfo(resp)
       return
     }
     const resp = await fetchAdminEndpoint('/admin/mcp-access')
     mcpLanAccessEnabled.value = !!resp?.enabled
+    applyMcpAccessInfo(resp)
   } catch (e) {
     mcpLanAccessError.value = e?.message || '读取 MCP 接入状态失败'
   } finally {
@@ -881,7 +898,9 @@ const setMcpLanAccess = async (enabled) => {
     if (window.wechatDesktop?.setMcpLanAccess) {
       const resp = await window.wechatDesktop.setMcpLanAccess(!!enabled)
       mcpLanAccessEnabled.value = !!resp?.enabled
+      applyMcpAccessInfo(resp)
       mcpLanAccessMessage.value = resp?.changed ? 'MCP 局域网接入已更新，后端已重启。' : 'MCP 局域网接入状态未变化。'
+      await refreshMcpSkillBundle()
       return
     }
 
@@ -890,11 +909,14 @@ const setMcpLanAccess = async (enabled) => {
       body: { enabled: !!enabled },
     })
     mcpLanAccessEnabled.value = !!resp?.enabled
+    applyMcpAccessInfo(resp)
     mcpLanAccessMessage.value = resp?.changed ? 'MCP 局域网接入已更新，正在等待后端重启。' : 'MCP 局域网接入状态未变化。'
     if (resp?.changed) {
       await waitForBackendHealth(30_000)
+      await refreshMcpLanAccess()
       mcpLanAccessMessage.value = 'MCP 局域网接入已更新，后端已恢复。'
     }
+    await refreshMcpSkillBundle()
   } catch (e) {
     mcpLanAccessEnabled.value = previous
     mcpLanAccessError.value = e?.message || '设置 MCP 接入状态失败'

main.py

@@ -11,13 +11,15 @@
 import uvicorn
 import os
 from pathlib import Path
+from wechat_decrypt_tool.network_access import get_lan_access_host
 from wechat_decrypt_tool.runtime_settings import read_effective_backend_host, read_effective_backend_port
 
 def main():
     """启动微信解密工具API服务"""
     host, host_source = read_effective_backend_host(default="127.0.0.1")
     port, port_source = read_effective_backend_port(default=10392)
     access_host = "127.0.0.1" if host in {"0.0.0.0", "::"} else host
+    lan_access_host = get_lan_access_host(default="127.0.0.1") if host in {"0.0.0.0", "::"} else access_host
 
     print("=" * 60)
     print("微信解密工具 API 服务")
@@ -38,6 +40,8 @@ def main():
     print(f"监听地址: {host}")
     print(f"API文档: http://{access_host}:{port}/docs")
     print(f"健康检查: http://{access_host}:{port}/api/health")
+    if lan_access_host != access_host:
+        print(f"局域网 MCP: http://{lan_access_host}:{port}/mcp")
     print("按 Ctrl+C 停止服务")
     print("=" * 60)