diff --git a/AGENTS.md b/AGENTS.md
new file mode 100644
index 0000000..35d285e
--- /dev/null
+++ b/AGENTS.md
@@ -0,0 +1,43 @@
+# Repository Guidelines
+
+## Project Structure & Module Organization
+- `app/`: FastAPI backend. Key areas: `routers/` (HTTP routes), `services/` (business logic), `models/` (DB entities), `schemas/` (request/response models), `prompts/` (LLM prompt templates), `utils/` (helpers).
+- `admin-ui/`: React + TypeScript admin frontend (`src/components`, `src/lib`, `src/api.ts`). Build output is `admin-ui/dist` and is served by backend routes (`/admin`, `/setup`).
+- `tests/`: Python test suite for API and services (`test_*.py`).
+- `scripts/`: cross-platform bootstrap/run/stop scripts (`*.sh`, `*.ps1`, `stop.bat`).
+
+## Build, Test, and Development Commands
+- Windows quick start:
+  - `./scripts/check-env.ps1 -Mode Bootstrap` checks required tools.
+  - `./scripts/bootstrap.ps1` creates `.venv`, installs Python deps, installs/builds frontend.
+  - `./scripts/dev-up.ps1` starts backend on `:8000`.
+  - `./scripts/dev-up.ps1 -DevUI` also starts Vite dev server on `:5173`.
+  - `./scripts/stop.ps1` stops started processes.
+- Frontend only (from repo root):
+  - `npm --prefix admin-ui run dev` for UI development.
+  - `npm --prefix admin-ui run build` for production build.
+- Tests:
+  - `python -m pytest tests -q` runs backend tests.
+
+## Coding Style & Naming Conventions
+- Python: PEP 8, 4-space indentation, `snake_case` for functions/modules, `PascalCase` for classes, explicit type hints on new/changed public functions.
+- TypeScript/React: follow existing style (2-space indentation, double quotes, trailing commas). Components use `PascalCase` file names (for example `SetupWizard.tsx`); utilities use lower camel/snake consistent with existing files.
+- Keep routers thin; put logic in `app/services/`.
+
+## Testing Guidelines
+- Add tests in `tests/` with names `test_<feature>.py` and functions `test_<behavior>()`.
+- Prefer deterministic service/unit tests; mock external HTTP/LLM calls.
+- For route changes, include FastAPI `TestClient` coverage for success and error paths.
+
+## Commit & Pull Request Guidelines
+- Current history mixes plain summaries and Conventional Commit prefixes (for example `feat: ...`, `fix: ...`). Prefer Conventional Commits for new work: `feat(scope): ...`, `fix(scope): ...`, `chore: ...`.
+- Keep commits focused and runnable.
+- PRs should include:
+  - purpose and scope
+  - test evidence (commands run + results)
+  - screenshots/GIFs for `admin-ui` changes
+  - config/env changes (update `.env.example` when needed)
+
+## Security & Configuration Tips
+- Never commit real secrets. Use `.env` locally and keep `.env.example` in sync with required keys.
+- Validate callback/public URL settings via the setup flow before enabling external integrations.
diff --git a/admin-ui/src/App.tsx b/admin-ui/src/App.tsx
index 4bba5e0..a16e1c6 100644
--- a/admin-ui/src/App.tsx
+++ b/admin-ui/src/App.tsx
@@ -1,4 +1,4 @@
-import { FormEvent, startTransition, useDeferredValue, useEffect, useState } from "react";
+import { FormEvent, startTransition, useDeferredValue, useEffect, useState } from "react";
 
 import { api } from "./api";
 import { LoginShell } from "./components/LoginShell";
@@ -46,6 +46,7 @@ function App() {
   const deferredUserQuery = useDeferredValue(userQuery);
   const [users, setUsers] = useState<UserSummary[]>([]);
   const [usersLoading, setUsersLoading] = useState(false);
+  const [selectedChannel, setSelectedChannel] = useState<string>("wecom");
   const [selectedUserId, setSelectedUserId] = useState<string>("");
   const [memoryDraft, setMemoryDraft] = useState<UserMemory>(EMPTY_MEMORY);
   const [memoryLoading, setMemoryLoading] = useState(false);
@@ -99,7 +100,8 @@ function App() {
         setProactiveConfig(proactive);
         setUsers(userPayload.items);
         if (userPayload.items[0] && !selectedUserId) {
-          setSelectedUserId(userPayload.items[0].wecom_user_id);
+          setSelectedChannel(userPayload.items[0].channel);
+          setSelectedUserId(userPayload.items[0].external_user_id);
         }
       })
       .catch((error: Error) => {
@@ -123,9 +125,10 @@ function App() {
           return;
         }
 
-        const stillExists = payload.items.some((item) => item.wecom_user_id === selectedUserId);
+        const stillExists = payload.items.some((item) => item.channel === selectedChannel && item.external_user_id === selectedUserId);
         if (!stillExists) {
-          setSelectedUserId(payload.items[0].wecom_user_id);
+          setSelectedChannel(payload.items[0].channel);
+          setSelectedUserId(payload.items[0].external_user_id);
         }
       })
       .catch((error: Error) => {
@@ -134,7 +137,7 @@ function App() {
       .finally(() => {
         setUsersLoading(false);
       });
-  }, [authenticated, deferredUserQuery, selectedUserId, setupStatus?.setup_completed]);
+  }, [authenticated, deferredUserQuery, selectedChannel, selectedUserId, setupStatus?.setup_completed]);
 
   useEffect(() => {
     if (!authenticated || !setupStatus?.setup_completed || !selectedUserId) {
@@ -143,7 +146,7 @@ function App() {
 
     setMemoryLoading(true);
     void api
-      .getUserMemory(selectedUserId)
+      .getUserMemory(selectedChannel, selectedUserId)
       .then((payload) => {
         setMemoryDraft(normalizeUserMemory(payload));
       })
@@ -153,7 +156,7 @@ function App() {
       .finally(() => {
         setMemoryLoading(false);
       });
-  }, [authenticated, selectedUserId, setupStatus?.setup_completed]);
+  }, [authenticated, selectedChannel, selectedUserId, setupStatus?.setup_completed]);
 
   async function handleLogin(event: FormEvent<HTMLFormElement>) {
     event.preventDefault();
@@ -204,7 +207,8 @@ function App() {
     try {
       const payload = {
         user_message: previewMessage,
-        wecom_user_id: selectedUserId || undefined,
+        channel: selectedChannel || undefined,
+        external_user_id: selectedUserId || undefined,
         draft_config: personaConfig,
       };
       const response = mode === "prompt" ? await api.previewPrompt(payload) : await api.previewReply(payload);
@@ -228,7 +232,7 @@ function App() {
 
     setMemorySaving(true);
     try {
-      const saved = await api.saveUserMemory(selectedUserId, memoryDraft);
+      const saved = await api.saveUserMemory(selectedChannel, selectedUserId, memoryDraft);
       setMemoryDraft(normalizeUserMemory(saved));
       setStatusMessage("用户记忆已保存。");
     } catch (error) {
@@ -259,8 +263,8 @@ function App() {
 
       const response =
         mode === "preview"
-          ? await api.previewProactiveChat(saved.target_wecom_user_id)
-          : await api.runProactiveChatOnce(saved.target_wecom_user_id);
+          ? await api.previewProactiveChat(saved.target_channel, saved.target_external_user_id)
+          : await api.runProactiveChatOnce(saved.target_channel, saved.target_external_user_id);
 
       setProactivePrompt(response.prompt);
       setProactiveReply(response.reply);
@@ -366,7 +370,7 @@ function App() {
   }
 
   function updateProactiveField(
-    field: "enabled" | "target_wecom_user_id" | "tone_hint",
+    field: "enabled" | "target_channel" | "target_external_user_id" | "tone_hint",
     value: boolean | string,
   ) {
     setProactiveConfig((current) =>
@@ -424,7 +428,7 @@ function App() {
   function handleEnterAdmin() {
     window.history.replaceState({}, "", ADMIN_PATH);
     if (!authenticated) {
-      setStatusMessage("请先登录管理员后台后再继续编辑配置。");
+      setStatusMessage("请先登录管理员后台。");
       return;
     }
     setStatusMessage("环境校验完成，已进入管理后台。");
@@ -444,45 +448,20 @@ function App() {
   }
 
   if (!setupStatus.setup_completed) {
-    return (
-      <SetupWizard
-        initialStatus={setupStatus}
-        authenticated={authenticated}
-        onStatusChange={handleSetupStatusChange}
-        onEnterAdmin={handleEnterAdmin}
-      />
-    );
+    return <SetupWizard initialStatus={setupStatus} authenticated={authenticated} onStatusChange={handleSetupStatusChange} onEnterAdmin={handleEnterAdmin} />;
   }
 
   if (window.location.pathname === SETUP_PATH) {
-    return (
-      <SetupWizard
-        initialStatus={setupStatus}
-        authenticated={authenticated}
-        onStatusChange={handleSetupStatusChange}
-        onEnterAdmin={handleEnterAdmin}
-      />
-    );
+    return <SetupWizard initialStatus={setupStatus} authenticated={authenticated} onStatusChange={handleSetupStatusChange} onEnterAdmin={handleEnterAdmin} />;
   }
 
   if (!authenticated) {
-    return (
-      <LoginShell
-        loginPassword={loginPassword}
-        loginError={loginError}
-        onPasswordChange={setLoginPassword}
-        onSubmit={handleLogin}
-      />
-    );
+    return <LoginShell loginPassword={loginPassword} loginError={loginError} onPasswordChange={setLoginPassword} onSubmit={handleLogin} />;
   }
 
   return (
     <main className="shell">
-      <StudioTopbar
-        statusMessage={statusMessage}
-        onOpenSetup={handleOpenSetup}
-        onLogout={() => void handleLogout()}
-      />
+      <StudioTopbar statusMessage={statusMessage} onOpenSetup={handleOpenSetup} onLogout={() => void handleLogout()} />
       <StudioTabs
         activeTab={activeTab}
         onChange={(tab) => {
@@ -503,7 +482,10 @@ function App() {
               setUserQuery(value);
             });
           }}
-          onSelectUser={setSelectedUserId}
+          onSelectUser={(channel, externalUserId) => {
+            setSelectedChannel(channel);
+            setSelectedUserId(externalUserId);
+          }}
         />
 
         <section className="main-panel">
@@ -563,7 +545,10 @@ function App() {
               previewReply={proactiveReply}
               deliveryStatus={proactiveDeliveryStatus}
               onToggleEnabled={(value) => updateProactiveField("enabled", value)}
-              onTargetUserChange={(value) => updateProactiveField("target_wecom_user_id", value)}
+              onTargetUserChange={(channel, externalUserId) => {
+                updateProactiveField("target_channel", channel);
+                updateProactiveField("target_external_user_id", externalUserId);
+              }}
               onWindowToggle={(key, enabled) => updateProactiveWindow(key, { enabled })}
               onWindowTimeChange={(key, value) => updateProactiveWindow(key, { time: value })}
               onQuietHoursToggle={(value) => updateQuietHours("enabled", value)}
diff --git a/admin-ui/src/api.ts b/admin-ui/src/api.ts
index 9b336f2..f8afd9f 100644
--- a/admin-ui/src/api.ts
+++ b/admin-ui/src/api.ts
@@ -55,7 +55,8 @@ export const api = {
   },
   previewPrompt(payload: {
     user_message: string;
-    wecom_user_id?: string | null;
+    channel?: string | null;
+    external_user_id?: string | null;
     draft_config?: PersonaConfig;
   }): Promise<PreviewResponse> {
     return request<PreviewResponse>("/admin-api/persona/preview-prompt", {
@@ -68,7 +69,8 @@ export const api = {
   },
   previewReply(payload: {
     user_message: string;
-    wecom_user_id?: string | null;
+    channel?: string | null;
+    external_user_id?: string | null;
     draft_config?: PersonaConfig;
   }): Promise<PreviewResponse> {
     return request<PreviewResponse>("/admin-api/persona/preview-reply", {
@@ -87,11 +89,11 @@ export const api = {
     params.set("limit", "30");
     return request(`/admin-api/users?${params.toString()}`);
   },
-  getUserMemory(wecomUserId: string): Promise<UserMemory> {
-    return request(`/admin-api/users/${encodeURIComponent(wecomUserId)}/memory`);
+  getUserMemory(channel: string, externalUserId: string): Promise<UserMemory> {
+    return request(`/admin-api/users/${encodeURIComponent(channel)}/${encodeURIComponent(externalUserId)}/memory`);
   },
-  saveUserMemory(wecomUserId: string, payload: UserMemory): Promise<UserMemory> {
-    return request(`/admin-api/users/${encodeURIComponent(wecomUserId)}/memory`, {
+  saveUserMemory(channel: string, externalUserId: string, payload: UserMemory): Promise<UserMemory> {
+    return request(`/admin-api/users/${encodeURIComponent(channel)}/${encodeURIComponent(externalUserId)}/memory`, {
       method: "PUT",
       body: JSON.stringify(payload),
     });
@@ -105,19 +107,25 @@ export const api = {
       body: JSON.stringify(payload),
     }).then(normalizeProactiveChatConfig);
   },
-  previewProactiveChat(wecomUserId?: string): Promise<ProactiveChatResponse> {
+  previewProactiveChat(channel?: string, externalUserId?: string): Promise<ProactiveChatResponse> {
     return request<ProactiveChatResponse>("/admin-api/proactive-chat/preview", {
       method: "POST",
-      body: JSON.stringify({ wecom_user_id: wecomUserId || undefined }),
+      body: JSON.stringify({
+        channel: channel || undefined,
+        external_user_id: externalUserId || undefined,
+      }),
     }).then((response) => ({
       ...response,
       config: normalizeProactiveChatConfig(response.config),
     }));
   },
-  runProactiveChatOnce(wecomUserId?: string): Promise<ProactiveChatResponse> {
+  runProactiveChatOnce(channel?: string, externalUserId?: string): Promise<ProactiveChatResponse> {
     return request<ProactiveChatResponse>("/admin-api/proactive-chat/run-once", {
       method: "POST",
-      body: JSON.stringify({ wecom_user_id: wecomUserId || undefined }),
+      body: JSON.stringify({
+        channel: channel || undefined,
+        external_user_id: externalUserId || undefined,
+      }),
     }).then((response) => ({
       ...response,
       config: normalizeProactiveChatConfig(response.config),
diff --git a/admin-ui/src/components/MemoryDesk.tsx b/admin-ui/src/components/MemoryDesk.tsx
index 59665fe..6088d58 100644
--- a/admin-ui/src/components/MemoryDesk.tsx
+++ b/admin-ui/src/components/MemoryDesk.tsx
@@ -1,4 +1,4 @@
-import type { UserMemory } from "../types";
+import type { UserMemory } from "../types";
 import { KeyValueEditor, TextListEditor } from "./Editors";
 
 type MemoryDeskProps = {
@@ -17,15 +17,17 @@ type MemoryDeskProps = {
 export function MemoryDesk(props: MemoryDeskProps) {
   const { draft, loading, saving, onMemoryFieldChange, onKeyValueChange, onMilestonesChange, onSave } = props;
 
+  const userLabel = draft.external_user_id ? `${draft.channel}:${draft.external_user_id}` : "未选择用户";
+
   return (
     <div className="memory-grid">
       <section className="panel">
         <div className="section-header">
           <div>
             <p className="section-kicker">Selected User</p>
-            <h2>{draft.wecom_user_id || "未选择用户"}</h2>
+            <h2>{userLabel}</h2>
           </div>
-          <button className="primary-button" onClick={onSave} disabled={saving || !draft.wecom_user_id}>
+          <button className="primary-button" onClick={onSave} disabled={saving || !draft.external_user_id}>
             {saving ? "保存中..." : "保存记忆"}
           </button>
         </div>
@@ -35,52 +37,21 @@ export function MemoryDesk(props: MemoryDeskProps) {
         <div className="field-grid">
           <label className="field">
             <span>昵称</span>
-            <input
-              value={draft.nickname}
-              onChange={(event) => onMemoryFieldChange("nickname", event.target.value)}
-              placeholder="比如：阿李"
-            />
+            <input value={draft.nickname} onChange={(event) => onMemoryFieldChange("nickname", event.target.value)} placeholder="比如：阿杰" />
           </label>
           <label className="field">
             <span>头像链接</span>
-            <input
-              value={draft.avatar_url}
-              onChange={(event) => onMemoryFieldChange("avatar_url", event.target.value)}
-              placeholder="可选"
-            />
+            <input value={draft.avatar_url} onChange={(event) => onMemoryFieldChange("avatar_url", event.target.value)} placeholder="可选" />
           </label>
         </div>
 
         <div className="editor-grid memory-editors">
-          <KeyValueEditor
-            label="基础信息"
-            items={draft.basic_info}
-            keyPlaceholder="字段名"
-            valuePlaceholder="字段值"
-            onChange={(nextValue) => onKeyValueChange("basic_info", nextValue)}
-          />
-          <KeyValueEditor
-            label="情感模式"
-            items={draft.emotional_patterns}
-            keyPlaceholder="情绪场景"
-            valuePlaceholder="描述"
-            onChange={(nextValue) => onKeyValueChange("emotional_patterns", nextValue)}
-          />
-          <KeyValueEditor
-            label="偏好"
-            items={draft.preferences}
-            keyPlaceholder="偏好类型"
-            valuePlaceholder="偏好内容"
-            onChange={(nextValue) => onKeyValueChange("preferences", nextValue)}
-          />
+          <KeyValueEditor label="基础信息" items={draft.basic_info} keyPlaceholder="字段名" valuePlaceholder="字段值" onChange={(nextValue) => onKeyValueChange("basic_info", nextValue)} />
+          <KeyValueEditor label="情感模式" items={draft.emotional_patterns} keyPlaceholder="情绪场景" valuePlaceholder="描述" onChange={(nextValue) => onKeyValueChange("emotional_patterns", nextValue)} />
+          <KeyValueEditor label="偏好" items={draft.preferences} keyPlaceholder="偏好类型" valuePlaceholder="偏好内容" onChange={(nextValue) => onKeyValueChange("preferences", nextValue)} />
         </div>
 
-        <TextListEditor
-          label="关系里程碑"
-          items={draft.relationship_milestones}
-          placeholder="新增一个里程碑，比如：第一次说想你"
-          onChange={onMilestonesChange}
-        />
+        <TextListEditor label="关系里程碑" items={draft.relationship_milestones} placeholder="新增一个里程碑，比如：第一次说想你" onChange={onMilestonesChange} />
       </section>
 
       <section className="panel contrast-panel">
@@ -99,9 +70,7 @@ export function MemoryDesk(props: MemoryDeskProps) {
               <p>{conversation.agent_message}</p>
             </article>
           ))}
-          {!draft.recent_conversations?.length ? (
-            <p className="empty-state">这个用户还没有历史对话，保存记忆后可直接用于回复预览。</p>
-          ) : null}
+          {!draft.recent_conversations?.length ? <p className="empty-state">这个用户还没有历史对话。</p> : null}
         </div>
       </section>
     </div>
diff --git a/admin-ui/src/components/ProactiveStudio.tsx b/admin-ui/src/components/ProactiveStudio.tsx
index 0b453fc..b9edb2b 100644
--- a/admin-ui/src/components/ProactiveStudio.tsx
+++ b/admin-ui/src/components/ProactiveStudio.tsx
@@ -1,4 +1,4 @@
-import type { ProactiveChatConfig, UserSummary } from "../types";
+import type { ProactiveChatConfig, UserSummary } from "../types";
 
 type ProactiveStudioProps = {
   config: ProactiveChatConfig;
@@ -9,7 +9,7 @@ type ProactiveStudioProps = {
   previewReply: string;
   deliveryStatus: string;
   onToggleEnabled: (value: boolean) => void;
-  onTargetUserChange: (value: string) => void;
+  onTargetUserChange: (channel: string, externalUserId: string) => void;
   onWindowToggle: (key: string, enabled: boolean) => void;
   onWindowTimeChange: (key: string, value: string) => void;
   onQuietHoursToggle: (value: boolean) => void;
@@ -43,6 +43,8 @@ export function ProactiveStudio(props: ProactiveStudioProps) {
     onRunOnce,
   } = props;
 
+  const targetValue = config.target_external_user_id ? `${config.target_channel}::${config.target_external_user_id}` : "";
+
   return (
     <div className="studio-grid">
       <section className="panel aurora-panel">
@@ -64,11 +66,22 @@ export function ProactiveStudio(props: ProactiveStudioProps) {
 
           <label className="field">
             <span>目标用户</span>
-            <select value={config.target_wecom_user_id} onChange={(event) => onTargetUserChange(event.target.value)}>
+            <select
+              value={targetValue}
+              onChange={(event) => {
+                const value = event.target.value;
+                if (!value) {
+                  onTargetUserChange("wecom", "");
+                  return;
+                }
+                const [channel, externalUserId] = value.split("::", 2);
+                onTargetUserChange(channel || "wecom", externalUserId || "");
+              }}
+            >
               <option value="">请选择用户</option>
               {users.map((user) => (
-                <option key={user.wecom_user_id} value={user.wecom_user_id}>
-                  {user.nickname || user.wecom_user_id}
+                <option key={`${user.channel}:${user.external_user_id}`} value={`${user.channel}::${user.external_user_id}`}>
+                  {user.nickname || user.external_user_id} ({user.channel})
                 </option>
               ))}
             </select>
@@ -109,11 +122,7 @@ export function ProactiveStudio(props: ProactiveStudioProps) {
 
           <label className="toggle-field">
             <span>启用免打扰</span>
-            <input
-              type="checkbox"
-              checked={config.quiet_hours.enabled}
-              onChange={(event) => onQuietHoursToggle(event.target.checked)}
-            />
+            <input type="checkbox" checked={config.quiet_hours.enabled} onChange={(event) => onQuietHoursToggle(event.target.checked)} />
           </label>
 
           <label className="field">
@@ -135,7 +144,7 @@ export function ProactiveStudio(props: ProactiveStudioProps) {
         <section className="response-preferences">
           <div className="tag-editor-header">
             <h3>固定时段窗口</h3>
-            <span>每个窗口当天最多主动发起一次，仍受免打扰与间隔约束</span>
+            <span>每个窗口当天最多主动发起一次，仍受免打扰与间隔约束。</span>
           </div>
           <div className="editor-grid">
             {config.scheduled_windows.map((window) => (
@@ -165,10 +174,10 @@ export function ProactiveStudio(props: ProactiveStudioProps) {
         <p className="panel-chip">当前发送状态：{deliveryStatus || "尚未触发"}</p>
 
         <div className="preview-actions">
-          <button className="secondary-button" onClick={onPreview} disabled={busy || !config.target_wecom_user_id}>
+          <button className="secondary-button" onClick={onPreview} disabled={busy || !config.target_external_user_id}>
             {busy ? "处理中..." : "预览主动开场"}
           </button>
-          <button className="primary-button" onClick={onRunOnce} disabled={busy || !config.target_wecom_user_id}>
+          <button className="primary-button" onClick={onRunOnce} disabled={busy || !config.target_external_user_id}>
             {busy ? "处理中..." : "立即发一条"}
           </button>
         </div>
diff --git a/admin-ui/src/components/UserSidebar.tsx b/admin-ui/src/components/UserSidebar.tsx
index 11189c7..90167f9 100644
--- a/admin-ui/src/components/UserSidebar.tsx
+++ b/admin-ui/src/components/UserSidebar.tsx
@@ -1,4 +1,4 @@
-import type { UserSummary } from "../types";
+import type { UserSummary } from "../types";
 
 type UserSidebarProps = {
   userQuery: string;
@@ -6,7 +6,7 @@ type UserSidebarProps = {
   usersLoading: boolean;
   selectedUserId: string;
   onQueryChange: (value: string) => void;
-  onSelectUser: (wecomUserId: string) => void;
+  onSelectUser: (channel: string, externalUserId: string) => void;
 };
 
 export function UserSidebar(props: UserSidebarProps) {
@@ -27,25 +27,23 @@ export function UserSidebar(props: UserSidebarProps) {
           className="search-input"
           value={userQuery}
           onChange={(event) => onQueryChange(event.target.value)}
-          placeholder="搜索企业微信 ID 或昵称"
+          placeholder="搜索用户 ID 或昵称"
         />
 
         <div className="user-list">
           {users.map((user) => (
             <button
-              key={user.wecom_user_id}
-              className={user.wecom_user_id === selectedUserId ? "user-card active" : "user-card"}
-              onClick={() => onSelectUser(user.wecom_user_id)}
+              key={`${user.channel}:${user.external_user_id}`}
+              className={user.external_user_id === selectedUserId ? "user-card active" : "user-card"}
+              onClick={() => onSelectUser(user.channel, user.external_user_id)}
             >
-              <strong>{user.nickname || user.wecom_user_id}</strong>
-              <span>{user.wecom_user_id}</span>
+              <strong>{user.nickname || user.external_user_id}</strong>
+              <span>{user.channel}:{user.external_user_id}</span>
               <em>{user.total_conversations} 次对话</em>
             </button>
           ))}
 
-          {!users.length ? (
-            <p className="empty-state">还没有可编辑的用户，先从企业微信收一条消息。</p>
-          ) : null}
+          {!users.length ? <p className="empty-state">还没有可编辑用户，先收一条消息。</p> : null}
         </div>
       </section>
     </aside>
diff --git a/admin-ui/src/lib/proactiveChat.ts b/admin-ui/src/lib/proactiveChat.ts
index db70cdd..2b3390a 100644
--- a/admin-ui/src/lib/proactiveChat.ts
+++ b/admin-ui/src/lib/proactiveChat.ts
@@ -14,7 +14,8 @@ const DEFAULT_QUIET_HOURS: QuietHours = {
 
 export const DEFAULT_PROACTIVE_CHAT_CONFIG: ProactiveChatConfig = {
   enabled: false,
-  target_wecom_user_id: "",
+  target_channel: "wecom",
+  target_external_user_id: "",
   scheduled_windows: DEFAULT_WINDOWS,
   inactivity_trigger_hours: 6,
   quiet_hours: DEFAULT_QUIET_HOURS,
diff --git a/admin-ui/src/lib/userMemory.ts b/admin-ui/src/lib/userMemory.ts
index e1c3b40..c568b4f 100644
--- a/admin-ui/src/lib/userMemory.ts
+++ b/admin-ui/src/lib/userMemory.ts
@@ -1,7 +1,8 @@
 import type { UserMemory } from "../types";
 
 export const EMPTY_MEMORY: UserMemory = {
-  wecom_user_id: "",
+  channel: "",
+  external_user_id: "",
   nickname: "",
   avatar_url: "",
   basic_info: {},
diff --git a/admin-ui/src/types.ts b/admin-ui/src/types.ts
index 9231ba4..f97bfc6 100644
--- a/admin-ui/src/types.ts
+++ b/admin-ui/src/types.ts
@@ -31,7 +31,8 @@ export type PersonaConfig = {
 };
 
 export type UserSummary = {
-  wecom_user_id: string;
+  channel: string;
+  external_user_id: string;
   nickname: string;
   avatar_url: string;
   total_conversations: number;
@@ -50,7 +51,8 @@ export type ConversationItem = {
 };
 
 export type UserMemory = {
-  wecom_user_id: string;
+  channel: string;
+  external_user_id: string;
   nickname: string;
   avatar_url: string;
   basic_info: Record<string, string>;
@@ -83,7 +85,8 @@ export type QuietHours = {
 
 export type ProactiveChatConfig = {
   enabled: boolean;
-  target_wecom_user_id: string;
+  target_channel: string;
+  target_external_user_id: string;
   scheduled_windows: ScheduledWindow[];
   inactivity_trigger_hours: number;
   quiet_hours: QuietHours;
@@ -96,7 +99,8 @@ export type ProactiveChatConfig = {
 export type ProactiveChatResponse = {
   prompt: string;
   reply: string;
-  target_wecom_user_id: string;
+  target_channel: string;
+  target_external_user_id: string;
   user_memory: UserMemory | null;
   config: ProactiveChatConfig;
   delivery?: {
diff --git a/app/config.py b/app/config.py
index 970c133..9e3c8c5 100644
--- a/app/config.py
+++ b/app/config.py
@@ -20,6 +20,8 @@ class Settings(BaseSettings):
     wecom_secret: str = os.getenv("WECOM_SECRET", "")
     wecom_token: str = os.getenv("WECOM_TOKEN", "")
     wecom_encoding_aes_key: str = os.getenv("WECOM_ENCODING_AES_KEY", "")
+    napcat_ws_url: str = os.getenv("NAPCAT_WS_URL", "")
+    napcat_ws_token: str = os.getenv("NAPCAT_WS_TOKEN", "")
 
     # 智谱 API 配置
     zhipu_api_key: str = os.getenv("ZHIPU_API_KEY", "")
diff --git a/app/graph/executors/conversation.py b/app/graph/executors/conversation.py
index 23a3538..2cd91a5 100644
--- a/app/graph/executors/conversation.py
+++ b/app/graph/executors/conversation.py
@@ -11,7 +11,8 @@
 
 async def save_conversation(
     *,
-    user_id: str,
+    channel: str,
+    external_user_id: str,
     user_message: str,
     agent_message: str,
     user_emotion: Dict,
@@ -19,7 +20,8 @@ async def save_conversation(
     memories_used: Optional[Dict] = None,
 ) -> Optional[int]:
     return await memory_service.save_conversation(
-        user_id=user_id,
+        channel=channel,
+        external_user_id=external_user_id,
         user_message=user_message,
         agent_message=agent_message,
         user_emotion=user_emotion,
@@ -30,7 +32,8 @@ async def save_conversation(
 
 def schedule_memory_processing(
     *,
-    wecom_user_id: str,
+    channel: str,
+    external_user_id: str,
     conversation_id: Optional[int],
     user_message: str,
     agent_message: str,
@@ -38,7 +41,8 @@ def schedule_memory_processing(
     agent_emotion: Dict,
 ) -> None:
     memory_service.schedule_memory_processing(
-        wecom_user_id=wecom_user_id,
+        channel=channel,
+        external_user_id=external_user_id,
         conversation_id=conversation_id,
         user_message=user_message,
         agent_message=agent_message,
diff --git a/app/graph/executors/delivery.py b/app/graph/executors/delivery.py
index 0488adb..8c01957 100644
--- a/app/graph/executors/delivery.py
+++ b/app/graph/executors/delivery.py
@@ -5,27 +5,31 @@
 from __future__ import annotations
 
 from datetime import datetime
+import logging
 from typing import Dict, Optional
 
 from app.models.admin import ProactiveChatLog
 from app.models.database import SessionLocal
 from app.models.user import Conversation, User
-from app.services.wecom_service import wecom_service
+from app.services.channel_dispatcher import channel_dispatcher
 
+logger = logging.getLogger(__name__)
 
-async def deliver_incoming_reply(*, to_user: str, content: str) -> Dict[str, object]:
+
+async def deliver_incoming_reply(*, channel: str, external_user_id: str, content: str) -> Dict[str, object]:
     delivery_result: Dict[str, object] = {"attempted": True, "status": "sent"}
     try:
-        await wecom_service.send_text_message(to_user, content)
+        await channel_dispatcher.send_text(channel, external_user_id, content)
     except Exception as exc:
-        print(f"发送企业微信消息失败: {exc}")
+        logger.warning("Send message failed: %s", exc)
         delivery_result = {"attempted": True, "status": "failed", "error_message": str(exc)}
     return delivery_result
 
 
 async def deliver_proactive_outreach(
     *,
-    target_wecom_user_id: str,
+    target_channel: str,
+    target_external_user_id: str,
     trigger_type: str,
     window_key: Optional[str],
     content: str,
@@ -35,15 +39,21 @@ async def deliver_proactive_outreach(
     error_message = None
 
     try:
-        await wecom_service.send_text_message(target_wecom_user_id, content)
+        await channel_dispatcher.send_text(target_channel, target_external_user_id, content)
         status = "sent"
-        _save_proactive_conversation(target_wecom_user_id=target_wecom_user_id, content=content, sent_at=sent_at)
+        _save_proactive_conversation(
+            target_channel=target_channel,
+            target_external_user_id=target_external_user_id,
+            content=content,
+            sent_at=sent_at,
+        )
     except Exception as exc:
         error_message = str(exc)
-        print(f"主动聊天发送失败: {exc}")
+        logger.warning("Proactive delivery failed: %s", exc)
     finally:
         _save_proactive_log(
-            target_wecom_user_id=target_wecom_user_id,
+            target_channel=target_channel,
+            target_external_user_id=target_external_user_id,
             trigger_type=trigger_type,
             window_key=window_key,
             content=content,
@@ -60,10 +70,20 @@ async def deliver_proactive_outreach(
     }
 
 
-def _save_proactive_conversation(*, target_wecom_user_id: str, content: str, sent_at: datetime) -> None:
+def _save_proactive_conversation(
+    *,
+    target_channel: str,
+    target_external_user_id: str,
+    content: str,
+    sent_at: datetime,
+) -> None:
     db = SessionLocal()
     try:
-        user = db.query(User).filter(User.wecom_user_id == target_wecom_user_id).first()
+        user = (
+            db.query(User)
+            .filter(User.channel == target_channel, User.external_user_id == target_external_user_id)
+            .first()
+        )
         if not user:
             return
 
@@ -86,7 +106,8 @@ def _save_proactive_conversation(*, target_wecom_user_id: str, content: str, sen
 
 def _save_proactive_log(
     *,
-    target_wecom_user_id: str,
+    target_channel: str,
+    target_external_user_id: str,
     trigger_type: str,
     window_key: Optional[str],
     content: str,
@@ -97,7 +118,8 @@ def _save_proactive_log(
     db = SessionLocal()
     try:
         log = ProactiveChatLog(
-            target_wecom_user_id=target_wecom_user_id,
+            target_channel=target_channel,
+            target_external_user_id=target_external_user_id,
             trigger_type=trigger_type,
             window_key=window_key,
             content=content,
@@ -109,3 +131,4 @@ def _save_proactive_log(
         db.commit()
     finally:
         db.close()
+
diff --git a/app/graph/executors/memory.py b/app/graph/executors/memory.py
index ecd3d25..3cbd3f2 100644
--- a/app/graph/executors/memory.py
+++ b/app/graph/executors/memory.py
@@ -11,10 +11,10 @@
 from app.services.memory_service import memory_service
 
 
-async def load_memory_update_context(wecom_user_id: str) -> Tuple[Dict, List[Dict[str, str]]]:
+async def load_memory_update_context(channel: str, external_user_id: str) -> Tuple[Dict, List[Dict[str, str]]]:
     db = SessionLocal()
     try:
-        user = memory_service._get_user_by_wecom_id(db, wecom_user_id)
+        user = memory_service._get_user_by_channel_external_id(db, channel, external_user_id)
         if not user:
             return {}, []
 
@@ -38,7 +38,8 @@ async def load_memory_update_context(wecom_user_id: str) -> Tuple[Dict, List[Dic
 
 async def persist_memory_update(
     *,
-    wecom_user_id: str,
+    channel: str,
+    external_user_id: str,
     conversation_id: int,
     user_message: str,
     agent_message: str,
@@ -47,7 +48,7 @@ async def persist_memory_update(
 ) -> None:
     db = SessionLocal()
     try:
-        user = memory_service._get_user_by_wecom_id(db, wecom_user_id)
+        user = memory_service._get_user_by_channel_external_id(db, channel, external_user_id)
         if not user:
             return
 
diff --git a/app/graph/graphs/incoming.py b/app/graph/graphs/incoming.py
index 817f03b..7dd543f 100644
--- a/app/graph/graphs/incoming.py
+++ b/app/graph/graphs/incoming.py
@@ -16,7 +16,8 @@
 
 async def _save_conversation_node(state: IncomingGraphState) -> IncomingGraphState:
     conversation_id = await save_conversation(
-        user_id=state["user_id"],
+        channel=state["channel"],
+        external_user_id=state["external_user_id"],
         user_message=state["user_content"],
         agent_message=state["agent_response"],
         user_emotion=state["user_emotion"],
@@ -30,7 +31,8 @@ async def _save_conversation_node(state: IncomingGraphState) -> IncomingGraphSta
 
 async def _schedule_memory_node(state: IncomingGraphState) -> IncomingGraphState:
     schedule_memory_processing(
-        wecom_user_id=state["user_id"],
+        channel=state["channel"],
+        external_user_id=state["external_user_id"],
         conversation_id=state["conversation_id"],
         user_message=state["user_content"],
         agent_message=state["agent_response"],
@@ -46,7 +48,8 @@ async def _deliver_reply_node(state: IncomingGraphState) -> IncomingGraphState:
     delivery_result = await message_delivery_tool.ainvoke(
         {
             "delivery_kind": "incoming_reply",
-            "to_user": state["user_id"],
+            "channel": state["channel"],
+            "external_user_id": state["external_user_id"],
             "content": state["agent_response"],
         }
     )
diff --git a/app/graph/graphs/memory_update.py b/app/graph/graphs/memory_update.py
index 16a6e57..2febef8 100644
--- a/app/graph/graphs/memory_update.py
+++ b/app/graph/graphs/memory_update.py
@@ -15,7 +15,8 @@
 
 async def _persist_node(state: MemoryUpdateGraphState) -> MemoryUpdateGraphState:
     await persist_memory_update(
-        wecom_user_id=state["wecom_user_id"],
+        channel=state["channel"],
+        external_user_id=state["external_user_id"],
         conversation_id=state["conversation_id"],
         user_message=state["user_message"],
         agent_message=state["agent_message"],
diff --git a/app/graph/graphs/proactive.py b/app/graph/graphs/proactive.py
index 70c2179..a3dd6c0 100644
--- a/app/graph/graphs/proactive.py
+++ b/app/graph/graphs/proactive.py
@@ -26,7 +26,8 @@ async def _deliver_node(state: ProactiveChatGraphState) -> ProactiveChatGraphSta
     delivery = await message_delivery_tool.ainvoke(
         {
             "delivery_kind": "proactive_outreach",
-            "to_user": state["target_wecom_user_id"],
+            "channel": state["target_channel"],
+            "external_user_id": state["target_external_user_id"],
             "content": state["reply"],
             "trigger_type": state["trigger_type"],
             "window_key": state["window_key"],
diff --git a/app/graph/state.py b/app/graph/state.py
index f1f9cf7..a40590f 100644
--- a/app/graph/state.py
+++ b/app/graph/state.py
@@ -12,7 +12,8 @@
 
 
 class IncomingGraphState(TypedDict):
-    user_id: str
+    channel: str
+    external_user_id: str
     user_content: str
     persona_config: Dict
     response_constraints: Dict
@@ -34,7 +35,8 @@ class IncomingGraphState(TypedDict):
 class PreviewGraphState(TypedDict):
     preview_mode: Literal["prompt", "reply"]
     user_message: str
-    wecom_user_id: Optional[str]
+    channel: Optional[str]
+    external_user_id: Optional[str]
     draft_config: Optional[Dict]
     persona_config: Dict
     user_memory: Optional[Dict]
@@ -52,7 +54,8 @@ class PreviewGraphState(TypedDict):
 
 
 class ProactiveChatGraphState(TypedDict):
-    target_wecom_user_id: str
+    target_channel: str
+    target_external_user_id: str
     trigger_type: str
     window_key: Optional[str]
     send_delivery: bool
@@ -70,7 +73,8 @@ class ProactiveChatGraphState(TypedDict):
 
 
 class MemoryUpdateGraphState(TypedDict):
-    wecom_user_id: str
+    channel: str
+    external_user_id: str
     conversation_id: int
     user_message: str
     agent_message: str
@@ -95,7 +99,8 @@ def append_tool_trace(state: Dict, name: str) -> List[str]:
 
 def build_incoming_initial_state(payload: Dict[str, object]) -> IncomingGraphState:
     return {
-        "user_id": str(payload.get("user_id") or ""),
+        "channel": str(payload.get("channel") or "wecom").strip() or "wecom",
+        "external_user_id": str(payload.get("external_user_id") or ""),
         "user_content": str(payload.get("user_content") or ""),
         "persona_config": {},
         "response_constraints": {},
@@ -119,7 +124,8 @@ def build_preview_initial_state(payload: Dict[str, object]) -> PreviewGraphState
     return {
         "preview_mode": payload.get("preview_mode", "prompt"),  # type: ignore[typeddict-item]
         "user_message": str(payload.get("user_message") or ""),
-        "wecom_user_id": str(payload.get("wecom_user_id") or "").strip() or None,
+        "channel": str(payload.get("channel") or "").strip() or None,
+        "external_user_id": str(payload.get("external_user_id") or "").strip() or None,
         "draft_config": payload.get("draft_config") if isinstance(payload.get("draft_config"), dict) else None,
         "persona_config": {},
         "user_memory": None,
@@ -139,7 +145,8 @@ def build_preview_initial_state(payload: Dict[str, object]) -> PreviewGraphState
 
 def build_proactive_initial_state(payload: Dict[str, object]) -> ProactiveChatGraphState:
     return {
-        "target_wecom_user_id": str(payload.get("target_wecom_user_id") or ""),
+        "target_channel": str(payload.get("target_channel") or "wecom").strip() or "wecom",
+        "target_external_user_id": str(payload.get("target_external_user_id") or ""),
         "trigger_type": str(payload.get("trigger_type") or ""),
         "window_key": str(payload.get("window_key") or "").strip() or None,
         "send_delivery": bool(payload.get("send_delivery")),
@@ -159,7 +166,8 @@ def build_proactive_initial_state(payload: Dict[str, object]) -> ProactiveChatGr
 
 def build_memory_initial_state(payload: Dict[str, object]) -> MemoryUpdateGraphState:
     return {
-        "wecom_user_id": str(payload.get("wecom_user_id") or ""),
+        "channel": str(payload.get("channel") or "wecom").strip() or "wecom",
+        "external_user_id": str(payload.get("external_user_id") or ""),
         "conversation_id": int(payload.get("conversation_id") or 0),
         "user_message": str(payload.get("user_message") or ""),
         "agent_message": str(payload.get("agent_message") or ""),
diff --git a/app/graph/subgraphs/context_loading.py b/app/graph/subgraphs/context_loading.py
index e04e143..0bdc8a3 100644
--- a/app/graph/subgraphs/context_loading.py
+++ b/app/graph/subgraphs/context_loading.py
@@ -6,6 +6,7 @@
 
 from datetime import datetime
 from functools import lru_cache
+import logging
 
 from langgraph.graph import END, START, StateGraph
 
@@ -22,16 +23,19 @@
 from app.services.proactive_chat_service import proactive_chat_service
 from app.utils.helpers import get_response_constraints
 
+logger = logging.getLogger(__name__)
+
 
 async def _incoming_load_context(state: IncomingGraphState) -> IncomingGraphState:
-    await memory_service.get_or_create_user(state["user_id"])
+    await memory_service.get_or_create_user(state["channel"], state["external_user_id"])
     persona_config = persona_service.get_persona_config()
     response_constraints = get_response_constraints(state["user_content"], persona_config.get("response_preferences"))
-    context = await memory_service.get_conversation_context(state["user_id"])
-    user_memory = await memory_service.get_user_memory(state["user_id"], query_text=state["user_content"])
-    recent_agent_replies = await memory_service.get_recent_agent_replies(state["user_id"], limit=3)
+    context = await memory_service.get_conversation_context(state["channel"], state["external_user_id"])
+    user_memory = await memory_service.get_user_memory(state["channel"], state["external_user_id"], query_text=state["user_content"])
+    recent_agent_replies = await memory_service.get_recent_agent_replies(state["channel"], state["external_user_id"], limit=3)
     context_messages = await memory_service.get_recent_messages(
-        state["user_id"],
+        state["channel"],
+        state["external_user_id"],
         limit=int(response_constraints["context_limit"]),
     )
     return {
@@ -49,10 +53,14 @@ async def _incoming_analyze_emotion(state: IncomingGraphState) -> IncomingGraphS
     try:
         user_emotion = await glm_service.analyze_emotion(state["user_content"])
     except Exception as exc:
-        print(f"图执行情绪分析失败，回退到默认情绪: {exc}")
+        logger.warning("图执行情绪分析失败，回退到默认情绪: %s", exc)
         user_emotion = {"neutral": 1.0}
 
-    agent_emotion = await emotion_engine.update_state(state["user_id"], state["user_content"], user_emotion)
+    agent_emotion = await emotion_engine.update_state(
+        memory_service.build_user_key(state["channel"], state["external_user_id"]),
+        state["user_content"],
+        user_emotion,
+    )
     return {
         "user_emotion": user_emotion,
         "agent_emotion": agent_emotion,
@@ -61,18 +69,19 @@ async def _incoming_analyze_emotion(state: IncomingGraphState) -> IncomingGraphS
 
 
 async def _preview_load_context(state: PreviewGraphState) -> PreviewGraphState:
-    wecom_user_id = str(state.get("wecom_user_id") or "").strip()
+    channel = str(state.get("channel") or "").strip()
+    external_user_id = str(state.get("external_user_id") or "").strip()
     user_memory = None
     context = {}
     recent_agent_replies = []
     context_messages = []
 
-    if wecom_user_id:
-        user_memory = await memory_service.get_user_memory(wecom_user_id, query_text=state["user_message"])
+    if channel and external_user_id:
+        user_memory = await memory_service.get_user_memory(channel, external_user_id, query_text=state["user_message"])
         if user_memory:
-            context = await memory_service.get_conversation_context(wecom_user_id)
-            recent_agent_replies = await memory_service.get_recent_agent_replies(wecom_user_id, limit=3)
-            context_messages = await memory_service.get_recent_messages(wecom_user_id, limit=4)
+            context = await memory_service.get_conversation_context(channel, external_user_id)
+            recent_agent_replies = await memory_service.get_recent_agent_replies(channel, external_user_id, limit=3)
+            context_messages = await memory_service.get_recent_messages(channel, external_user_id, limit=4)
 
     persona_config = state["draft_config"] or persona_service.get_persona_config()
     response_constraints = get_response_constraints(state["user_message"], persona_config.get("response_preferences"))
@@ -90,8 +99,10 @@ async def _preview_load_context(state: PreviewGraphState) -> PreviewGraphState:
 
 async def _preview_analyze_emotion(state: PreviewGraphState) -> PreviewGraphState:
     user_emotion = await glm_service.analyze_emotion(state["user_message"])
+    channel = str(state.get("channel") or "").strip()
+    external_user_id = str(state.get("external_user_id") or "").strip()
     agent_emotion = await emotion_engine.update_state(
-        state.get("wecom_user_id") or "__preview__",
+        memory_service.build_user_key(channel or "__preview__", external_user_id or "__preview__"),
         state["user_message"],
         user_emotion,
     )
@@ -105,9 +116,13 @@ async def _preview_analyze_emotion(state: PreviewGraphState) -> PreviewGraphStat
 async def _proactive_load_context(state: ProactiveChatGraphState) -> ProactiveChatGraphState:
     persona_config = persona_service.get_persona_config()
     proactive_config = proactive_chat_service.get_config()
-    user_memory = await memory_service.get_user_memory(state["target_wecom_user_id"])
-    context = await memory_service.get_conversation_context(state["target_wecom_user_id"])
-    recent_agent_replies = await memory_service.get_recent_agent_replies(state["target_wecom_user_id"], limit=3)
+    user_memory = await memory_service.get_user_memory(state["target_channel"], state["target_external_user_id"])
+    context = await memory_service.get_conversation_context(state["target_channel"], state["target_external_user_id"])
+    recent_agent_replies = await memory_service.get_recent_agent_replies(
+        state["target_channel"],
+        state["target_external_user_id"],
+        limit=3,
+    )
     response_constraints = get_response_constraints(
         "我想主动开启一段自然微信聊天",
         persona_config.get("response_preferences"),
diff --git a/app/graph/subgraphs/generation.py b/app/graph/subgraphs/generation.py
index e531d9e..7767afb 100644
--- a/app/graph/subgraphs/generation.py
+++ b/app/graph/subgraphs/generation.py
@@ -6,6 +6,7 @@
 
 from datetime import datetime
 from functools import lru_cache
+import logging
 from typing import Dict, List
 
 from langgraph.graph import END, START, StateGraph
@@ -27,6 +28,8 @@
     is_response_too_similar,
 )
 
+logger = logging.getLogger(__name__)
+
 
 ANTI_REPEAT_RETRY_INSTRUCTION = """
 
@@ -57,7 +60,7 @@ async def _chat_with_retry(
             max_tokens=max_tokens,
         )
     except Exception as exc:
-        print(f"图执行生成失败，尝试轻量重试: {exc}")
+        logger.warning("图执行生成失败，尝试轻量重试: %s", exc)
         try:
             return await glm_service.chat_with_context(
                 system_prompt=system_prompt,
@@ -68,7 +71,7 @@ async def _chat_with_retry(
                 max_tokens=max_tokens,
             )
         except Exception as retry_exc:
-            print(f"图执行轻量重试失败: {retry_exc}")
+            logger.warning("图执行轻量重试失败: %s", retry_exc)
             return ""
 
 
@@ -133,7 +136,7 @@ async def _incoming_retry_similar(state: IncomingGraphState) -> IncomingGraphSta
             max_tokens=int(state["response_constraints"]["max_tokens"]),
         )
     except Exception as exc:
-        print(f"图执行重复抑制重试失败: {exc}")
+        logger.warning("图执行重复抑制重试失败: %s", exc)
 
     return {
         "agent_response": regenerated or state["agent_response"],
@@ -238,7 +241,7 @@ async def _proactive_generate_reply(state: ProactiveChatGraphState) -> Proactive
             task_type="proactive",
         )
     except Exception as exc:
-        print(f"生成主动聊天文案失败，使用兜底: {exc}")
+        logger.warning("生成主动聊天文案失败，使用兜底: %s", exc)
 
     return {
         "reply": reply,
@@ -249,7 +252,8 @@ async def _proactive_generate_reply(state: ProactiveChatGraphState) -> Proactive
 async def _proactive_finalize_reply(state: ProactiveChatGraphState) -> ProactiveChatGraphState:
     return {
         "reply": state["reply"] or proactive_chat_service._build_fallback_message(
-            state["target_wecom_user_id"],
+            state["target_channel"],
+            state["target_external_user_id"],
             state["trigger_type"],
             state["user_memory"],
         ),
diff --git a/app/graph/subgraphs/memory_extraction.py b/app/graph/subgraphs/memory_extraction.py
index ca4b746..c2502a8 100644
--- a/app/graph/subgraphs/memory_extraction.py
+++ b/app/graph/subgraphs/memory_extraction.py
@@ -15,7 +15,7 @@
 
 
 async def _prepare_context(state: MemoryUpdateGraphState) -> MemoryUpdateGraphState:
-    existing_memory, recent_messages = await load_memory_update_context(state["wecom_user_id"])
+    existing_memory, recent_messages = await load_memory_update_context(state["channel"], state["external_user_id"])
     return {
         "existing_memory": existing_memory,
         "recent_messages": recent_messages,
diff --git a/app/graph/tools/delivery.py b/app/graph/tools/delivery.py
index 414e8fb..a7e2b76 100644
--- a/app/graph/tools/delivery.py
+++ b/app/graph/tools/delivery.py
@@ -14,7 +14,8 @@
 
 class MessageDeliveryToolInput(BaseModel):
     delivery_kind: Literal["incoming_reply", "proactive_outreach"] = Field(..., description="Delivery scenario")
-    to_user: str = Field(..., description="Target WeCom user id")
+    channel: str = Field(..., description="Target channel")
+    external_user_id: str = Field(..., description="Target external user id")
     content: str = Field(..., description="Message content")
     trigger_type: Optional[str] = Field(default=None, description="Proactive trigger type")
     window_key: Optional[str] = Field(default=None, description="Scheduled window key")
@@ -23,17 +24,19 @@ class MessageDeliveryToolInput(BaseModel):
 @tool("message_delivery_tool", args_schema=MessageDeliveryToolInput)
 async def message_delivery_tool(
     delivery_kind: Literal["incoming_reply", "proactive_outreach"],
-    to_user: str,
+    channel: str,
+    external_user_id: str,
     content: str,
     trigger_type: Optional[str] = None,
     window_key: Optional[str] = None,
 ) -> Dict[str, object]:
     """Deliver a message through the configured executor boundary."""
     if delivery_kind == "incoming_reply":
-        return await deliver_incoming_reply(to_user=to_user, content=content)
+        return await deliver_incoming_reply(channel=channel, external_user_id=external_user_id, content=content)
 
     return await deliver_proactive_outreach(
-        target_wecom_user_id=to_user,
+        target_channel=channel,
+        target_external_user_id=external_user_id,
         trigger_type=trigger_type or "",
         window_key=window_key,
         content=content,
diff --git a/app/main.py b/app/main.py
index b04cb9f..5534b3c 100644
--- a/app/main.py
+++ b/app/main.py
@@ -1,21 +1,24 @@
-"""
+"""
 FastAPI 应用入口
 """
 
 import asyncio
+import logging
 from contextlib import asynccontextmanager
 from pathlib import Path
+
 from fastapi import FastAPI
-from fastapi.responses import FileResponse, JSONResponse
 from fastapi.middleware.cors import CORSMiddleware
+from fastapi.responses import FileResponse, JSONResponse
 from starlette.middleware.sessions import SessionMiddleware
 from starlette.staticfiles import StaticFiles
 
 from app.config import settings
 from app.models.database import init_db
 from app.routers import admin, setup, wecom
-from app.services.public_media_service import PUBLIC_MEDIA_DIR, PUBLIC_MEDIA_ROUTE
+from app.services.napcat_service import napcat_service
 from app.services.proactive_chat_service import proactive_chat_service
+from app.services.public_media_service import PUBLIC_MEDIA_DIR, PUBLIC_MEDIA_ROUTE
 from app.services.tunnel_service import (
     is_invalid_autodetected_tunnel_url,
     is_quick_tunnel_url,
@@ -27,38 +30,46 @@
 ADMIN_DIST_DIR = BASE_DIR / "admin-ui" / "dist"
 ADMIN_INDEX_PATH = ADMIN_DIST_DIR / "index.html"
 
+logging.basicConfig(
+    level=logging.INFO,
+    format="%(asctime)s %(levelname)s [%(name)s] %(message)s",
+)
+logger = logging.getLogger(__name__)
+
 
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     """应用生命周期管理"""
-    # 启动时的初始化逻辑
     init_db()
     tunnel_service.ensure_started()
     tunnel_status = tunnel_service.get_status()
     callback_base_url = tunnel_status["public_url"]
     configured_public_base_url = settings.public_base_url.strip().rstrip("/")
     if not callback_base_url and configured_public_base_url:
-        if not is_quick_tunnel_url(configured_public_base_url) and not is_invalid_autodetected_tunnel_url(configured_public_base_url):
+        if not is_quick_tunnel_url(configured_public_base_url) and not is_invalid_autodetected_tunnel_url(
+            configured_public_base_url
+        ):
             callback_base_url = configured_public_base_url
     callback_url = (
         f"{callback_base_url}/wecom/callback"
         if callback_base_url
         else f"http://{settings.server_host}:{settings.server_port}/wecom/callback"
     )
-    print(f"🚀 恋爱 Agent 启动中...")
-    print(f"📍 服务地址: http://{settings.server_host}:{settings.server_port}")
-    print(f"🔗 企业微信回调地址: {callback_url}")
+    logger.info("恋爱 Agent 启动中...")
+    logger.info("服务地址: http://%s:%s", settings.server_host, settings.server_port)
+    logger.info("企业微信回调地址: %s", callback_url)
+    await napcat_service.start()
     proactive_scheduler_task = asyncio.create_task(proactive_chat_service.scheduler_loop())
 
     yield
 
-    # 关闭时的清理逻辑
     proactive_scheduler_task.cancel()
     try:
         await proactive_scheduler_task
     except asyncio.CancelledError:
         pass
-    print("👋 恋爱 Agent 关闭中...")
+    await napcat_service.stop()
+    logger.info("恋爱 Agent 关闭中...")
 
 
 app = FastAPI(
@@ -68,7 +79,6 @@ async def lifespan(app: FastAPI):
     lifespan=lifespan,
 )
 
-# CORS 中间件配置
 app.add_middleware(
     CORSMiddleware,
     allow_origins=settings.admin_dev_origins,
@@ -85,7 +95,6 @@ async def lifespan(app: FastAPI):
     same_site="lax",
 )
 
-# 注册路由
 app.include_router(wecom.router, prefix="/wecom", tags=["企业微信"])
 app.include_router(admin.router)
 app.include_router(setup.router)
diff --git a/app/models/admin.py b/app/models/admin.py
index e312127..84f571b 100644
--- a/app/models/admin.py
+++ b/app/models/admin.py
@@ -5,6 +5,7 @@
 from datetime import datetime
 
 from sqlalchemy import Boolean, Column, DateTime, Integer, JSON, String, Text
+from sqlalchemy.ext.hybrid import hybrid_property
 
 from app.models.user import Base
 
@@ -40,7 +41,8 @@ class ProactiveChatConfig(Base):
     id = Column(Integer, primary_key=True, autoincrement=True)
     config_key = Column(String(64), unique=True, nullable=False, comment="配置键")
     enabled = Column(Boolean, nullable=False, default=False, comment="是否启用主动聊天")
-    target_wecom_user_id = Column(String(64), comment="目标企业微信用户 ID")
+    target_channel = Column(String(32), nullable=False, default="wecom", comment="目标渠道")
+    target_external_user_id = Column(String(128), comment="目标渠道用户 ID")
     scheduled_windows = Column(JSON, nullable=False, default=list, comment="固定时段窗口")
     inactivity_trigger_hours = Column(Integer, nullable=False, default=6, comment="多久未互动后主动发起")
     quiet_hours = Column(JSON, nullable=False, default=dict, comment="免打扰时段")
@@ -54,6 +56,19 @@ class ProactiveChatConfig(Base):
     def __repr__(self):
         return f"<ProactiveChatConfig(id={self.id}, config_key={self.config_key})>"
 
+    @hybrid_property
+    def target_wecom_user_id(self):
+        return self.target_external_user_id if self.target_channel == "wecom" else None
+
+    @target_wecom_user_id.setter
+    def target_wecom_user_id(self, value):
+        self.target_channel = "wecom"
+        self.target_external_user_id = value
+
+    @target_wecom_user_id.expression
+    def target_wecom_user_id(cls):  # type: ignore[no-redef]
+        return cls.target_external_user_id
+
 
 class ProactiveChatLog(Base):
     """主动聊天发送日志。"""
@@ -61,7 +76,8 @@ class ProactiveChatLog(Base):
     __tablename__ = "proactive_chat_logs"
 
     id = Column(Integer, primary_key=True, autoincrement=True)
-    target_wecom_user_id = Column(String(64), nullable=False, comment="目标企业微信用户 ID")
+    target_channel = Column(String(32), nullable=False, default="wecom", comment="目标渠道")
+    target_external_user_id = Column(String(128), nullable=False, comment="目标渠道用户 ID")
     trigger_type = Column(String(32), nullable=False, comment="触发类型")
     window_key = Column(String(32), comment="固定窗口 key")
     content = Column(Text, comment="发送内容")
@@ -72,7 +88,23 @@ class ProactiveChatLog(Base):
     created_at = Column(DateTime, default=datetime.now, comment="创建时间")
 
     def __repr__(self):
-        return f"<ProactiveChatLog(id={self.id}, target={self.target_wecom_user_id}, trigger={self.trigger_type})>"
+        return (
+            f"<ProactiveChatLog(id={self.id}, target={self.target_channel}:{self.target_external_user_id}, "
+            f"trigger={self.trigger_type})>"
+        )
+
+    @hybrid_property
+    def target_wecom_user_id(self):
+        return self.target_external_user_id if self.target_channel == "wecom" else None
+
+    @target_wecom_user_id.setter
+    def target_wecom_user_id(self, value):
+        self.target_channel = "wecom"
+        self.target_external_user_id = value
+
+    @target_wecom_user_id.expression
+    def target_wecom_user_id(cls):  # type: ignore[no-redef]
+        return cls.target_external_user_id
 
 
 class RuntimeConfig(Base):
diff --git a/app/models/database.py b/app/models/database.py
index 4ef9c6a..4bdd281 100644
--- a/app/models/database.py
+++ b/app/models/database.py
@@ -1,8 +1,10 @@
-"""
+"""
 数据库初始化
 """
 
-from sqlalchemy import create_engine
+import logging
+
+from sqlalchemy import create_engine, inspect, text
 from sqlalchemy.orm import sessionmaker
 
 from app.config import settings
@@ -11,6 +13,8 @@
 import app.models.emotion  # noqa: F401
 from app.models.user import Base
 
+logger = logging.getLogger(__name__)
+
 
 # 创建数据库引擎
 if settings.database_type == "sqlite":
@@ -34,7 +38,71 @@
 def init_db():
     """初始化数据库，创建所有表"""
     Base.metadata.create_all(bind=engine)
-    print("✅ 数据库表创建完成")
+    _run_compat_migrations()
+    logger.info("数据库表创建完成")
+
+
+def _run_compat_migrations() -> None:
+    inspector = inspect(engine)
+    with engine.begin() as conn:
+        _ensure_users_channel_columns(inspector, conn)
+        _ensure_proactive_channel_columns(inspector, conn)
+
+
+def _ensure_users_channel_columns(inspector, conn) -> None:
+    tables = inspector.get_table_names()
+    if "users" not in tables:
+        return
+    columns = {item["name"] for item in inspector.get_columns("users")}
+    if "channel" not in columns:
+        conn.execute(text("ALTER TABLE users ADD COLUMN channel VARCHAR(32) DEFAULT 'wecom' NOT NULL"))
+    has_legacy_wecom_id = "wecom_user_id" in columns
+    if "external_user_id" not in columns:
+        conn.execute(text("ALTER TABLE users ADD COLUMN external_user_id VARCHAR(128)"))
+        if has_legacy_wecom_id:
+            conn.execute(text("UPDATE users SET external_user_id = wecom_user_id WHERE external_user_id IS NULL"))
+    conn.execute(text("UPDATE users SET channel = 'wecom' WHERE channel IS NULL OR channel = ''"))
+    if has_legacy_wecom_id:
+        conn.execute(
+            text("UPDATE users SET external_user_id = wecom_user_id WHERE external_user_id IS NULL OR external_user_id = ''")
+        )
+
+
+def _ensure_proactive_channel_columns(inspector, conn) -> None:
+    tables = inspector.get_table_names()
+    if "proactive_chat_configs" in tables:
+        columns = {item["name"] for item in inspector.get_columns("proactive_chat_configs")}
+        has_legacy_target = "target_wecom_user_id" in columns
+        if "target_channel" not in columns:
+            conn.execute(text("ALTER TABLE proactive_chat_configs ADD COLUMN target_channel VARCHAR(32) DEFAULT 'wecom' NOT NULL"))
+        if "target_external_user_id" not in columns:
+            conn.execute(text("ALTER TABLE proactive_chat_configs ADD COLUMN target_external_user_id VARCHAR(128)"))
+            if has_legacy_target:
+                conn.execute(
+                    text(
+                        "UPDATE proactive_chat_configs "
+                        "SET target_external_user_id = target_wecom_user_id "
+                        "WHERE target_external_user_id IS NULL"
+                    )
+                )
+        conn.execute(text("UPDATE proactive_chat_configs SET target_channel = 'wecom' WHERE target_channel IS NULL OR target_channel = ''"))
+
+    if "proactive_chat_logs" in tables:
+        columns = {item["name"] for item in inspector.get_columns("proactive_chat_logs")}
+        has_legacy_target = "target_wecom_user_id" in columns
+        if "target_channel" not in columns:
+            conn.execute(text("ALTER TABLE proactive_chat_logs ADD COLUMN target_channel VARCHAR(32) DEFAULT 'wecom' NOT NULL"))
+        if "target_external_user_id" not in columns:
+            conn.execute(text("ALTER TABLE proactive_chat_logs ADD COLUMN target_external_user_id VARCHAR(128)"))
+            if has_legacy_target:
+                conn.execute(
+                    text(
+                        "UPDATE proactive_chat_logs "
+                        "SET target_external_user_id = target_wecom_user_id "
+                        "WHERE target_external_user_id IS NULL"
+                    )
+                )
+        conn.execute(text("UPDATE proactive_chat_logs SET target_channel = 'wecom' WHERE target_channel IS NULL OR target_channel = ''"))
 
 
 def get_db():
diff --git a/app/models/user.py b/app/models/user.py
index 99698d4..60760c7 100644
--- a/app/models/user.py
+++ b/app/models/user.py
@@ -4,8 +4,9 @@
 
 from datetime import datetime
 
-from sqlalchemy import Boolean, Column, DateTime, ForeignKey, Integer, JSON, String, Text
+from sqlalchemy import Boolean, Column, DateTime, ForeignKey, Integer, JSON, String, Text, UniqueConstraint
 from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy.ext.hybrid import hybrid_property
 from sqlalchemy.orm import relationship
 
 Base = declarative_base()
@@ -15,9 +16,13 @@ class User(Base):
     """用户模型"""
 
     __tablename__ = "users"
+    __table_args__ = (
+        UniqueConstraint("channel", "external_user_id", name="uq_users_channel_external_user_id"),
+    )
 
     id = Column(Integer, primary_key=True, autoincrement=True)
-    wecom_user_id = Column(String(64), unique=True, nullable=False, comment="企业微信用户ID")
+    channel = Column(String(32), nullable=False, default="wecom", comment="渠道")
+    external_user_id = Column(String(128), nullable=False, comment="渠道侧用户 ID")
     nickname = Column(String(100), comment="用户昵称")
     avatar_url = Column(String(255), comment="头像URL")
 
@@ -47,7 +52,20 @@ class User(Base):
     memory_items = relationship("MemoryItem", back_populates="user", cascade="all, delete-orphan")
 
     def __repr__(self):
-        return f"<User(id={self.id}, wecom_user_id={self.wecom_user_id})>"
+        return f"<User(id={self.id}, channel={self.channel}, external_user_id={self.external_user_id})>"
+
+    @hybrid_property
+    def wecom_user_id(self):
+        return self.external_user_id if self.channel == "wecom" else None
+
+    @wecom_user_id.setter
+    def wecom_user_id(self, value):
+        self.channel = "wecom"
+        self.external_user_id = value
+
+    @wecom_user_id.expression
+    def wecom_user_id(cls):  # type: ignore[no-redef]
+        return cls.external_user_id
 
 
 class Conversation(Base):
diff --git a/app/routers/admin.py b/app/routers/admin.py
index 650d455..cebdd99 100644
--- a/app/routers/admin.py
+++ b/app/routers/admin.py
@@ -1,15 +1,13 @@
-"""
-管理后台 API
+"""
+Admin backend API.
 """
 
 from hmac import compare_digest
 
 from fastapi import APIRouter, Depends, HTTPException, Query, Request, Response
 
-from app.graph import run_preview_graph
 from app.config import settings
-from app.services.emotion_engine import emotion_engine  # 兼容测试 patch
-from app.services.llm_service import glm_service  # 兼容测试 patch
+from app.graph import run_preview_graph
 from app.schemas.admin import (
     AgentPersonaPayload,
     LoginRequest,
@@ -18,6 +16,8 @@
     ProactiveChatPayload,
     UserMemoryPayload,
 )
+from app.services.emotion_engine import emotion_engine  # test patch compatibility
+from app.services.llm_service import glm_service  # test patch compatibility
 from app.services.memory_service import memory_service
 from app.services.persona_service import persona_service
 from app.services.proactive_chat_service import proactive_chat_service
@@ -26,6 +26,18 @@
 router = APIRouter(prefix="/admin-api", tags=["管理后台"])
 
 
+def _resolve_channel_identity(
+    channel: str | None,
+    external_user_id: str | None,
+    wecom_user_id: str | None,
+) -> tuple[str | None, str | None]:
+    if channel and external_user_id:
+        return channel, external_user_id
+    if wecom_user_id:
+        return "wecom", wecom_user_id
+    return channel, external_user_id
+
+
 def require_admin(request: Request) -> bool:
     if not request.session.get("is_admin"):
         raise HTTPException(status_code=401, detail="Admin authentication required")
@@ -70,13 +82,18 @@ async def get_proactive_chat(_: bool = Depends(require_admin)):
 
 @router.put("/proactive-chat")
 async def update_proactive_chat(payload: ProactiveChatPayload, _: bool = Depends(require_admin)):
-    return proactive_chat_service.save_config(payload.model_dump())
+    body = payload.model_dump()
+    if payload.target_wecom_user_id and not payload.target_external_user_id:
+        body["target_channel"] = "wecom"
+        body["target_external_user_id"] = payload.target_wecom_user_id
+    return proactive_chat_service.save_config(body)
 
 
 @router.post("/proactive-chat/preview")
 async def preview_proactive_chat(payload: ProactiveChatActionRequest, _: bool = Depends(require_admin)):
     try:
-        return await proactive_chat_service.preview_outreach(payload.wecom_user_id)
+        channel, external_user_id = _resolve_channel_identity(payload.channel, payload.external_user_id, payload.wecom_user_id)
+        return await proactive_chat_service.preview_outreach(channel, external_user_id)
     except ValueError as exc:
         raise HTTPException(status_code=400, detail=str(exc))
 
@@ -84,18 +101,21 @@ async def preview_proactive_chat(payload: ProactiveChatActionRequest, _: bool =
 @router.post("/proactive-chat/run-once")
 async def run_proactive_chat(payload: ProactiveChatActionRequest, _: bool = Depends(require_admin)):
     try:
-        return await proactive_chat_service.run_outreach_once(payload.wecom_user_id)
+        channel, external_user_id = _resolve_channel_identity(payload.channel, payload.external_user_id, payload.wecom_user_id)
+        return await proactive_chat_service.run_outreach_once(channel, external_user_id)
     except ValueError as exc:
         raise HTTPException(status_code=400, detail=str(exc))
 
 
 @router.post("/persona/preview-prompt")
 async def preview_prompt(payload: PreviewRequest, _: bool = Depends(require_admin)):
+    channel, external_user_id = _resolve_channel_identity(payload.channel, payload.external_user_id, payload.wecom_user_id)
     preview = await run_preview_graph(
         {
             "preview_mode": "prompt",
             "user_message": payload.user_message,
-            "wecom_user_id": payload.wecom_user_id,
+            "channel": channel,
+            "external_user_id": external_user_id,
             "draft_config": payload.draft_config.model_dump() if payload.draft_config else None,
         }
     )
@@ -111,11 +131,13 @@ async def preview_prompt(payload: PreviewRequest, _: bool = Depends(require_admi
 
 @router.post("/persona/preview-reply")
 async def preview_reply(payload: PreviewRequest, _: bool = Depends(require_admin)):
+    channel, external_user_id = _resolve_channel_identity(payload.channel, payload.external_user_id, payload.wecom_user_id)
     preview = await run_preview_graph(
         {
             "preview_mode": "reply",
             "user_message": payload.user_message,
-            "wecom_user_id": payload.wecom_user_id,
+            "channel": channel,
+            "external_user_id": external_user_id,
             "draft_config": payload.draft_config.model_dump() if payload.draft_config else None,
         }
     )
@@ -132,34 +154,62 @@ async def preview_reply(payload: PreviewRequest, _: bool = Depends(require_admin
 
 @router.get("/users")
 async def list_users(
-    query: str = Query("", description="按企业微信用户 ID 或昵称搜索"),
+    query: str = Query("", description="按用户 ID 或昵称搜索"),
     limit: int = Query(20, ge=1, le=50),
     _: bool = Depends(require_admin),
 ):
     return {"items": await memory_service.list_users(query=query, limit=limit)}
 
 
+@router.get("/users/{channel}/{external_user_id}/memory")
+async def get_user_memory(channel: str, external_user_id: str, _: bool = Depends(require_admin)):
+    payload = await memory_service.get_user_memory(channel, external_user_id)
+    if not payload:
+        raise HTTPException(status_code=404, detail="User not found")
+    return payload
+
+
+@router.put("/users/{channel}/{external_user_id}/memory")
+async def update_user_memory(
+    channel: str,
+    external_user_id: str,
+    payload: UserMemoryPayload,
+    _: bool = Depends(require_admin),
+):
+    return await memory_service.upsert_user_memory(channel, external_user_id, payload.model_dump())
+
+
+@router.get("/users/{channel}/{external_user_id}/conversations")
+async def get_user_conversations(
+    channel: str,
+    external_user_id: str,
+    limit: int = Query(8, ge=1, le=20),
+    _: bool = Depends(require_admin),
+):
+    return {"items": await memory_service.get_recent_conversations(channel, external_user_id, limit=limit)}
+
+
 @router.get("/users/{wecom_user_id}/memory")
-async def get_user_memory(wecom_user_id: str, _: bool = Depends(require_admin)):
-    payload = await memory_service.get_user_memory(wecom_user_id)
+async def get_user_memory_legacy(wecom_user_id: str, _: bool = Depends(require_admin)):
+    payload = await memory_service.get_user_memory("wecom", wecom_user_id)
     if not payload:
         raise HTTPException(status_code=404, detail="User not found")
     return payload
 
 
 @router.put("/users/{wecom_user_id}/memory")
-async def update_user_memory(
+async def update_user_memory_legacy(
     wecom_user_id: str,
     payload: UserMemoryPayload,
     _: bool = Depends(require_admin),
 ):
-    return await memory_service.upsert_user_memory(wecom_user_id, payload.model_dump())
+    return await memory_service.upsert_user_memory("wecom", wecom_user_id, payload.model_dump())
 
 
 @router.get("/users/{wecom_user_id}/conversations")
-async def get_user_conversations(
+async def get_user_conversations_legacy(
     wecom_user_id: str,
     limit: int = Query(8, ge=1, le=20),
     _: bool = Depends(require_admin),
 ):
-    return {"items": await memory_service.get_recent_conversations(wecom_user_id, limit=limit)}
+    return {"items": await memory_service.get_recent_conversations("wecom", wecom_user_id, limit=limit)}
diff --git a/app/routers/setup.py b/app/routers/setup.py
index 989d821..041e80a 100644
--- a/app/routers/setup.py
+++ b/app/routers/setup.py
@@ -4,8 +4,7 @@
 
 from fastapi import APIRouter, HTTPException, Request
 
-from app.schemas.admin import SetupAdminPayload, SetupModelPayload, SetupWeComPayload
-from app.services.provider_catalog import get_provider_preset
+from app.schemas.admin import SetupAdminPayload, SetupModelPayload, SetupNapCatPayload, SetupWeComPayload
 from app.services.runtime_config_service import runtime_config_service
 from app.services.setup_service import setup_service
 from app.services.tunnel_service import tunnel_service
@@ -20,21 +19,37 @@ def _require_setup_write_access(request: Request) -> None:
 
 
 def _validate_model_payload(payload: SetupModelPayload) -> None:
-    provider_id = payload.provider_id.strip().lower() or "zhipu"
-    preset = get_provider_preset(provider_id)
-    if provider_id != preset.provider_id:
+    provider = payload.model_provider.strip().lower() or "glm"
+    if provider not in {"glm", "openai", "openai_compatible"}:
         raise HTTPException(status_code=400, detail="不支持的模型供应商")
 
-    if not payload.provider_api_key.strip():
-        raise HTTPException(status_code=400, detail=f"{preset.label} 模式下必须填写 API Key")
+    if provider == "glm":
+        if not payload.zhipu_api_key.strip():
+            raise HTTPException(status_code=400, detail="GLM 模式下必须填写 API Key")
+        if not payload.zhipu_model.strip():
+            raise HTTPException(status_code=400, detail="GLM 模式下必须填写模型名称")
+        return
 
-    base_url = payload.provider_base_url.strip().rstrip("/") or preset.default_base_url
-    if not base_url:
-        raise HTTPException(status_code=400, detail=f"{preset.label} 模式下必须填写 Base URL")
+    if not payload.openai_api_key.strip():
+        raise HTTPException(status_code=400, detail="OpenAI-compatible 模式下必须填写 API Key")
+    if not payload.openai_base_url.strip():
+        raise HTTPException(status_code=400, detail="OpenAI-compatible 模式下必须填写 Base URL")
 
-    search_mode = payload.search_provider_mode.strip() or "tavily_primary_exa_fallback"
-    if search_mode not in {"disabled", "tavily_primary_exa_fallback", "tavily", "exa"}:
-        raise HTTPException(status_code=400, detail="不支持的搜索模式")
+    mode = payload.openai_model_mode.strip().lower() or "manual"
+    if mode not in {"manual", "auto"}:
+        raise HTTPException(status_code=400, detail="不支持的模型模式")
+
+    if mode == "manual":
+        if not payload.openai_model.strip():
+            raise HTTPException(status_code=400, detail="手动模式下必须填写模型名称")
+        return
+
+    if not payload.openai_models.chat_model.strip():
+        raise HTTPException(status_code=400, detail="Auto 模式下必须填写聊天模型")
+    if not payload.openai_models.memory_model.strip():
+        raise HTTPException(status_code=400, detail="Auto 模式下必须填写记忆模型")
+    if not payload.openai_models.proactive_model.strip():
+        raise HTTPException(status_code=400, detail="Auto 模式下必须填写主动消息模型")
 
 
 @router.get("/status")
@@ -46,28 +61,18 @@ async def get_setup_status():
 async def save_setup_model(payload: SetupModelPayload, request: Request):
     _require_setup_write_access(request)
     _validate_model_payload(payload)
-    preset = get_provider_preset(payload.provider_id.strip().lower() or "zhipu")
     runtime_config_service.save_section(
         "model",
         {
-            "provider_id": payload.provider_id.strip().lower(),
-            "provider_api_key": payload.provider_api_key.strip(),
-            "provider_base_url": payload.provider_base_url.strip().rstrip("/"),
-            "text_model_override": "",
-            "multimodal_model_override": "",
-            "document_model_override": "",
-            "tavily_api_key": payload.tavily_api_key.strip(),
-            "exa_api_key": payload.exa_api_key.strip(),
-            "search_provider_mode": payload.search_provider_mode.strip() or "tavily_primary_exa_fallback",
-            "model_provider": preset.transport,
-            "zhipu_api_key": payload.zhipu_api_key.strip() or (payload.provider_api_key.strip() if preset.provider_id == "zhipu" else ""),
+            "model_provider": payload.model_provider.strip(),
+            "zhipu_api_key": payload.zhipu_api_key.strip(),
             "zhipu_model": payload.zhipu_model.strip(),
             "zhipu_thinking_type": payload.zhipu_thinking_type.strip(),
-            "multimodal_api_key": payload.multimodal_api_key.strip() or (payload.provider_api_key.strip() if preset.supports_multimodal else ""),
+            "multimodal_api_key": payload.multimodal_api_key.strip(),
             "multimodal_model": payload.multimodal_model.strip(),
-            "openai_api_key": payload.openai_api_key.strip() or (payload.provider_api_key.strip() if preset.transport == "openai_compatible" else ""),
-            "openai_base_url": payload.openai_base_url.strip().rstrip("/") or payload.provider_base_url.strip().rstrip("/"),
-            "openai_model_mode": "auto",
+            "openai_api_key": payload.openai_api_key.strip(),
+            "openai_base_url": payload.openai_base_url.strip().rstrip("/"),
+            "openai_model_mode": payload.openai_model_mode.strip(),
             "openai_model": payload.openai_model.strip(),
             "openai_models": {
                 "chat_model": payload.openai_models.chat_model.strip(),
@@ -100,6 +105,19 @@ async def save_setup_wecom(payload: SetupWeComPayload, request: Request):
     return setup_service.get_status()
 
 
+@router.put("/config/napcat")
+async def save_setup_napcat(payload: SetupNapCatPayload, request: Request):
+    _require_setup_write_access(request)
+    runtime_config_service.save_section(
+        "napcat",
+        {
+            "ws_url": payload.ws_url.strip(),
+            "ws_token": payload.ws_token.strip(),
+        },
+    )
+    return setup_service.get_status()
+
+
 @router.put("/config/admin")
 async def save_setup_admin(payload: SetupAdminPayload, request: Request):
     _require_setup_write_access(request)
diff --git a/app/routers/wecom.py b/app/routers/wecom.py
index 217d2e3..cb5104a 100644
--- a/app/routers/wecom.py
+++ b/app/routers/wecom.py
@@ -1,20 +1,23 @@
-"""
+"""
 企业微信回调路由
 """
 
-from fastapi import APIRouter, Request, Query, HTTPException
+import logging
+
+from fastapi import APIRouter, HTTPException, Query, Request
 from fastapi.responses import PlainTextResponse
 from wechatpy.exceptions import InvalidSignatureException
 
-from app.services.llm_service import glm_service  # 兼容测试 patch
 from app.services.emotion_engine import emotion_engine  # 兼容测试 patch
 from app.services.incoming_aggregation_service import incoming_aggregation_service
+from app.services.llm_service import glm_service  # 兼容测试 patch
 from app.services.memory_service import memory_service  # 兼容测试 patch
 from app.services.multimodal_chat_service import multimodal_chat_service
 from app.services.persona_service import persona_service  # 兼容测试 patch
 from app.services.wecom_service import wecom_service
 
 router = APIRouter()
+logger = logging.getLogger(__name__)
 
 
 @router.get("/callback")
@@ -28,7 +31,13 @@ async def wecom_callback_verify(
     企业微信回调 URL 验证
     企业微信会发送 GET 请求来验证回调 URL
     """
-    print(f"收到验证请求: msg_signature={msg_signature}, timestamp={timestamp}, nonce={nonce}, echostr={echostr}")
+    logger.info(
+        "收到验证请求: msg_signature=%s, timestamp=%s, nonce=%s, echostr=%s",
+        msg_signature,
+        timestamp,
+        nonce,
+        echostr,
+    )
 
     if not echostr:
         raise HTTPException(status_code=400, detail="Missing echostr")
@@ -40,14 +49,14 @@ async def wecom_callback_verify(
             nonce=nonce,
             echostr=echostr,
         )
-        print(f"企业微信回调验证成功，返回明文 echostr: {decrypted_echostr}")
+        logger.info("企业微信回调验证成功，返回明文 echostr")
         return PlainTextResponse(content=decrypted_echostr)
     except InvalidSignatureException as exc:
-        print(f"企业微信回调验签失败: {exc}")
-        raise HTTPException(status_code=403, detail="Invalid callback signature")
+        logger.warning("企业微信回调验签失败: %s", exc)
+        raise HTTPException(status_code=403, detail="Invalid callback signature") from exc
     except Exception as exc:
-        print(f"企业微信回调解密失败: {exc}")
-        raise HTTPException(status_code=403, detail=f"Callback verification failed: {exc}")
+        logger.exception("企业微信回调解密失败")
+        raise HTTPException(status_code=403, detail=f"Callback verification failed: {exc}") from exc
 
 
 @router.post("/callback")
@@ -61,26 +70,21 @@ async def wecom_callback_handler(
     企业微信消息回调处理
     接收用户发送的消息并处理
     """
-    # 读取请求体
     body = await request.body()
     xml_content = body.decode("utf-8")
-    print(f"收到消息回调: msg_signature={msg_signature}, xml={xml_content[:200]}...")
+    logger.info("收到消息回调: msg_signature=%s, xml_size=%s", msg_signature, len(xml_content))
 
-    # 解密消息
     try:
-        decrypted_xml = wecom_service.decrypt_message(
-            xml_content, msg_signature, timestamp, nonce
-        )
+        decrypted_xml = wecom_service.decrypt_message(xml_content, msg_signature, timestamp, nonce)
     except InvalidSignatureException as exc:
-        print(f"企业微信消息回调验签失败: {exc}")
-        raise HTTPException(status_code=403, detail="Invalid message signature")
-    except Exception as e:
-        print(f"解密消息失败: {e}")
-        raise HTTPException(status_code=400, detail=f"Failed to decrypt message: {e}")
+        logger.warning("企业微信消息回调验签失败: %s", exc)
+        raise HTTPException(status_code=403, detail="Invalid message signature") from exc
+    except Exception as exc:
+        logger.exception("解密消息失败")
+        raise HTTPException(status_code=400, detail=f"Failed to decrypt message: {exc}") from exc
 
-    # 解析消息
     message = wecom_service.parse_message(decrypted_xml)
-    print(f"收到消息: {message}")
+    logger.debug("收到消息: %s", message)
 
     registration = await incoming_aggregation_service.register_event(message)
     if not registration.get("duplicate"):
diff --git a/app/schemas/admin.py b/app/schemas/admin.py
index 23e7541..94bc88c 100644
--- a/app/schemas/admin.py
+++ b/app/schemas/admin.py
@@ -35,6 +35,8 @@ class AgentPersonaPayload(BaseModel):
 
 class PreviewRequest(BaseModel):
     user_message: str
+    channel: Optional[str] = None
+    external_user_id: Optional[str] = None
     wecom_user_id: Optional[str] = None
     draft_config: Optional[AgentPersonaPayload] = None
 
@@ -63,6 +65,8 @@ class QuietHoursPayload(BaseModel):
 
 class ProactiveChatPayload(BaseModel):
     enabled: bool = False
+    target_channel: str = "wecom"
+    target_external_user_id: str = ""
     target_wecom_user_id: str = ""
     scheduled_windows: List[ScheduledWindowPayload] = Field(default_factory=list)
     inactivity_trigger_hours: int = 6
@@ -73,6 +77,8 @@ class ProactiveChatPayload(BaseModel):
 
 
 class ProactiveChatActionRequest(BaseModel):
+    channel: Optional[str] = None
+    external_user_id: Optional[str] = None
     wecom_user_id: Optional[str] = None
 
 
@@ -111,5 +117,10 @@ class SetupWeComPayload(BaseModel):
     public_base_url: str = ""
 
 
+class SetupNapCatPayload(BaseModel):
+    ws_url: str = ""
+    ws_token: str = ""
+
+
 class SetupAdminPayload(BaseModel):
     password: str = ""
diff --git a/app/services/__init__.py b/app/services/__init__.py
index 20cc404..a45bed6 100644
--- a/app/services/__init__.py
+++ b/app/services/__init__.py
@@ -19,6 +19,10 @@
     "runtime_config_service",
     "IncomingAggregationService",
     "incoming_aggregation_service",
+    "NapCatService",
+    "napcat_service",
+    "ChannelDispatcher",
+    "channel_dispatcher",
     "TunnelService",
     "tunnel_service",
 ]
@@ -39,6 +43,10 @@
     "runtime_config_service": ("app.services.runtime_config_service", "runtime_config_service"),
     "IncomingAggregationService": ("app.services.incoming_aggregation_service", "IncomingAggregationService"),
     "incoming_aggregation_service": ("app.services.incoming_aggregation_service", "incoming_aggregation_service"),
+    "NapCatService": ("app.services.napcat_service", "NapCatService"),
+    "napcat_service": ("app.services.napcat_service", "napcat_service"),
+    "ChannelDispatcher": ("app.services.channel_dispatcher", "ChannelDispatcher"),
+    "channel_dispatcher": ("app.services.channel_dispatcher", "channel_dispatcher"),
     "TunnelService": ("app.services.tunnel_service", "TunnelService"),
     "tunnel_service": ("app.services.tunnel_service", "tunnel_service"),
 }
diff --git a/app/services/channel_dispatcher.py b/app/services/channel_dispatcher.py
new file mode 100644
index 0000000..91cee46
--- /dev/null
+++ b/app/services/channel_dispatcher.py
@@ -0,0 +1,29 @@
+"""
+Channel-aware outbound dispatcher.
+"""
+
+from __future__ import annotations
+
+from typing import Dict
+
+from app.services.wecom_service import wecom_service
+
+
+class ChannelDispatcher:
+    async def send_text(self, channel: str, external_user_id: str, content: str) -> Dict[str, object]:
+        lowered = (channel or "").strip().lower()
+        if lowered == "wecom":
+            await wecom_service.send_text_message(external_user_id, content)
+            return {"channel": "wecom", "status": "sent"}
+
+        if lowered == "napcat":
+            from app.services.napcat_service import napcat_service
+
+            await napcat_service.send_private_text(external_user_id, content)
+            return {"channel": "napcat", "status": "sent"}
+
+        raise ValueError(f"Unsupported channel: {channel}")
+
+
+channel_dispatcher = ChannelDispatcher()
+
diff --git a/app/services/incoming_aggregation_service.py b/app/services/incoming_aggregation_service.py
index 75ca5c4..91187f0 100644
--- a/app/services/incoming_aggregation_service.py
+++ b/app/services/incoming_aggregation_service.py
@@ -5,6 +5,7 @@
 from __future__ import annotations
 
 import asyncio
+import logging
 from datetime import datetime, timedelta
 import hashlib
 from typing import Dict, List
@@ -16,6 +17,7 @@
 
 
 MERGE_WINDOW_SECONDS = 5
+logger = logging.getLogger(__name__)
 
 
 class IncomingAggregationService:
@@ -203,7 +205,7 @@ def _on_task_done(self, user_id: str, task: asyncio.Task) -> None:
         try:
             task.result()
         except Exception as exc:
-            print(f"入站消息聚合处理失败: user={user_id}, error={exc}")
+            logger.exception("入站消息聚合处理失败: user=%s", user_id)
 
     def _get_open_batch(self, db, user_id: str, now: datetime) -> InboundAggregateBatch | None:
         batch = (
diff --git a/app/services/llm_service.py b/app/services/llm_service.py
index 20e450b..60dc50f 100644
--- a/app/services/llm_service.py
+++ b/app/services/llm_service.py
@@ -1,19 +1,23 @@
 """
-统一大模型调用服务。
+智谱 GLM-5 API 服务
 """
 
 from collections import defaultdict
 import json
+import logging
 import re
-from typing import Dict, List, Optional
+from typing import Dict, List, Optional, Tuple
+
+import httpx
 
 from app.providers.model_provider import get_chat_provider
-from app.services.web_search_service import web_search_service
 from app.services.runtime_config_service import runtime_config_service
 
+logger = logging.getLogger(__name__)
+
 
 class GLMService:
-    """统一对话与多模态调用入口。"""
+    """智谱对话模型服务"""
 
     def __init__(self):
         pass
@@ -22,16 +26,76 @@ def _current_config(self) -> Dict:
         return runtime_config_service.get_effective_model_config()
 
     def _current_provider_name(self) -> str:
-        return str(self._current_config().get("provider_transport") or "glm").strip().lower()
+        return str(self._current_config().get("model_provider") or "glm").strip().lower()
 
     def _resolve_chat_model(self, config: Dict, task_type: str) -> str:
-        routed = config.get("text_models") or {}
-        task_key = {
-            "chat": "chat_model",
-            "memory": "memory_model",
-            "proactive": "proactive_model",
-        }.get(task_type, "chat_model")
-        return str(routed.get(task_key) or config.get("text_model") or "").strip()
+        provider_name = str(config.get("model_provider") or "glm").strip().lower()
+        if provider_name in {"", "glm"}:
+            return str(config.get("zhipu_model") or "").strip()
+
+        mode = str(config.get("openai_model_mode") or "manual").strip().lower()
+        if mode == "auto":
+            routed = config.get("openai_models") or {}
+            task_key = {
+                "chat": "chat_model",
+                "memory": "memory_model",
+                "proactive": "proactive_model",
+            }.get(task_type, "chat_model")
+            return str(routed.get(task_key) or config.get("openai_model") or "").strip()
+
+        return str(config.get("openai_model") or "").strip()
+
+    async def _request_completion(self, payload: Dict, api_key: Optional[str] = None) -> Dict:
+        """请求对话补全接口并返回 JSON 结果。"""
+        config = self._current_config()
+        url = f"{config['zhipu_base_url']}/chat/completions"
+
+        headers = {
+            "Authorization": f"Bearer {api_key or config['zhipu_api_key']}",
+            "Content-Type": "application/json",
+        }
+
+        async with httpx.AsyncClient(timeout=60.0, trust_env=False) as client:
+            response = await client.post(url, headers=headers, json=payload)
+            response.raise_for_status()
+            return response.json()
+
+    async def _request_web_search(self, payload: Dict) -> Dict:
+        """请求智谱 Web Search 接口并返回 JSON 结果。"""
+        config = self._current_config()
+        url = f"{config['zhipu_base_url']}/web_search"
+
+        headers = {
+            "Authorization": f"Bearer {config['zhipu_api_key']}",
+            "Content-Type": "application/json",
+        }
+
+        async with httpx.AsyncClient(timeout=30.0, trust_env=False) as client:
+            response = await client.post(url, headers=headers, json=payload)
+            response.raise_for_status()
+            return response.json()
+
+    def _extract_message(self, result: Dict) -> Tuple[str, str, str]:
+        """提取回复正文、思考内容和结束原因。"""
+        choices = result.get("choices") or []
+        if not choices:
+            return "", "", ""
+
+        choice = choices[0]
+        message = choice.get("message") or {}
+        content = message.get("content") or ""
+        if isinstance(content, list):
+            fragments: List[str] = []
+            for item in content:
+                if not isinstance(item, dict):
+                    continue
+                text = item.get("text")
+                if isinstance(text, str) and text.strip():
+                    fragments.append(text.strip())
+            content = "\n".join(fragments)
+        reasoning_content = message.get("reasoning_content") or ""
+        finish_reason = choice.get("finish_reason") or ""
+        return content, reasoning_content, finish_reason
 
     async def chat_completion(
         self,
@@ -55,32 +119,40 @@ async def chat_completion(
         """
         config = self._current_config()
         provider_name = self._current_provider_name()
-        provider = get_chat_provider(config)
-        if provider is None:
-            raise ValueError(f"Unsupported model provider: {provider_name}")
 
-        result = await provider.generate(
-            messages,
-            model=self._resolve_chat_model(config, task_type),
-            temperature=temperature,
-            top_p=top_p,
-            max_tokens=max_tokens,
-        )
-        content = result.content or ""
-        reasoning_content = result.reasoning_content or ""
-        finish_reason = result.finish_reason or ""
+        if provider_name not in {"", "glm"}:
+            provider = get_chat_provider(config)
+            if provider is None:
+                raise ValueError(f"Unsupported model provider: {provider_name}")
 
-        # 部分模型会先生成 reasoning_content。token 太小时，正文可能为空但 finish_reason=length。
-        # 这时提升 token 再重试一次，避免返回空白回复。
-        if not content and reasoning_content and finish_reason == "length":
-            retry_result = await provider.generate(
+            result = await provider.generate(
                 messages,
                 model=self._resolve_chat_model(config, task_type),
                 temperature=temperature,
                 top_p=top_p,
-                max_tokens=max(max_tokens * 4, 512),
+                max_tokens=max_tokens,
             )
-            retry_content = retry_result.content or ""
+            return result.content or ""
+
+        payload = {
+            "model": config["zhipu_model"],
+            "messages": messages,
+            "temperature": temperature,
+            "top_p": top_p,
+            "max_tokens": max_tokens,
+        }
+        if config["zhipu_thinking_type"] in {"enabled", "disabled"}:
+            payload["thinking"] = {"type": config["zhipu_thinking_type"]}
+
+        result = await self._request_completion(payload)
+        content, reasoning_content, finish_reason = self._extract_message(result)
+
+        # glm-5 会先生成 reasoning_content。token 太小时，正文可能为空但 finish_reason=length。
+        # 这时提升 token 再重试一次，避免返回空白回复。
+        if not content and reasoning_content and finish_reason == "length":
+            retry_payload = {**payload, "max_tokens": max(max_tokens * 4, 512)}
+            retry_result = await self._request_completion(retry_payload)
+            retry_content, _, _ = self._extract_message(retry_result)
             if retry_content:
                 return retry_content
 
@@ -100,15 +172,11 @@ async def chat_multimodal(
         top_p: float = 0.9,
         max_tokens: int = 1500,
     ) -> str:
-        """按当前供应商能力调用多模态模型处理图片或 PDF。"""
+        """调用 GLM 多模态模型处理图片或 PDF。"""
         config = self._current_config()
-        provider = get_chat_provider(config)
-        if provider is None:
-            raise ValueError("Multimodal provider is not available")
-
         multimodal_api_key = str(config.get("multimodal_api_key") or "").strip()
         multimodal_model = str(config.get("multimodal_model") or "").strip()
-        if not config.get("supports_multimodal") or not multimodal_api_key or not multimodal_model:
+        if not multimodal_api_key or not multimodal_model:
             raise ValueError("Multimodal model is not configured")
 
         messages: List[Dict[str, object]] = [{"role": "system", "content": system_prompt}]
@@ -124,27 +192,20 @@ async def chat_multimodal(
             }
         )
 
-        result = await provider.generate(
-            messages,
-            model=multimodal_model,
-            temperature=temperature,
-            top_p=top_p,
-            max_tokens=max_tokens,
-            api_key_override=multimodal_api_key,
-        )
-        content = result.content or ""
-        reasoning_content = result.reasoning_content or ""
-        finish_reason = result.finish_reason or ""
+        payload = {
+            "model": multimodal_model,
+            "messages": messages,
+            "temperature": temperature,
+            "top_p": top_p,
+            "max_tokens": max_tokens,
+        }
+
+        result = await self._request_completion(payload, api_key=multimodal_api_key)
+        content, reasoning_content, finish_reason = self._extract_message(result)
         if not content and reasoning_content and finish_reason == "length":
-            retry_result = await provider.generate(
-                messages,
-                model=multimodal_model,
-                temperature=temperature,
-                top_p=top_p,
-                max_tokens=max(max_tokens * 2, 1024),
-                api_key_override=multimodal_api_key,
-            )
-            retry_content = retry_result.content or ""
+            retry_payload = {**payload, "max_tokens": max(max_tokens * 2, 1024)}
+            retry_result = await self._request_completion(retry_payload, api_key=multimodal_api_key)
+            retry_content, _, _ = self._extract_message(retry_result)
             if retry_content:
                 return retry_content
 
@@ -197,19 +258,151 @@ async def web_search(
         search_count: Optional[int] = None,
         content_size: Optional[str] = None,
     ) -> List[Dict[str, str]]:
-        del search_engine, content_size
-        return await web_search_service.search(query, count=search_count)
+        """调用智谱 Web Search 接口。"""
+        cleaned_query = self._build_search_query(query)
+        if not cleaned_query:
+            return []
+
+        config = self._current_config()
+        provider_name = self._current_provider_name()
+        if provider_name not in {"", "glm"}:
+            return []
+
+        payload = {
+            "search_query": cleaned_query,
+            "search_engine": search_engine or config["zhipu_web_search_engine"],
+            "search_intent": False,
+            "count": search_count or config["zhipu_web_search_count"],
+            "content_size": content_size or config["zhipu_web_search_content_size"],
+        }
+        result = await self._request_web_search(payload)
+        items = result.get("search_result") or result.get("results") or []
+        if not isinstance(items, list):
+            return []
+
+        normalized: List[Dict[str, str]] = []
+        for item in items:
+            if not isinstance(item, dict):
+                continue
+
+            title = str(item.get("title") or "").strip()
+            link = str(item.get("link") or item.get("url") or "").strip()
+            content = str(item.get("content") or item.get("snippet") or item.get("text") or "").strip()
+            media = str(item.get("media") or item.get("site_name") or "").strip()
+            publish_date = str(item.get("publish_date") or item.get("date") or "").strip()
+
+            if not any([title, content, link]):
+                continue
+
+            normalized.append(
+                {
+                    "title": title,
+                    "link": link,
+                    "content": content,
+                    "media": media,
+                    "publish_date": publish_date,
+                }
+            )
+
+        return normalized
 
     async def maybe_collect_web_context(self, user_message: str) -> Dict[str, object]:
         """根据用户消息判断是否需要联网检索，并返回搜索结果。"""
-        return await web_search_service.maybe_collect_web_context(user_message)
+        config = self._current_config()
+        if not config["zhipu_web_search_enabled"] or not self.should_use_web_search(user_message):
+            return {"enabled": config["zhipu_web_search_enabled"], "triggered": False, "query": "", "results": []}
+
+        query = self._build_search_query(user_message)
+        if not query:
+            return {"enabled": config["zhipu_web_search_enabled"], "triggered": False, "query": "", "results": []}
+
+        try:
+            results = await self.web_search(query)
+        except Exception as exc:
+            logger.warning("web search unavailable, fallback to no-search context: %s", exc)
+            results = []
+        return {
+            "enabled": config["zhipu_web_search_enabled"],
+            "triggered": bool(results),
+            "query": query,
+            "results": results,
+        }
 
     def should_use_web_search(self, text: str) -> bool:
         """启发式判断当前消息是否需要联网检索。"""
-        return web_search_service.should_use_web_search(text)
+        cleaned = text.strip()
+        if len(cleaned) < 2:
+            return False
+
+        explicit_markers = (
+            "查一下",
+            "搜一下",
+            "搜索",
+            "帮我查",
+            "帮我搜",
+            "是什么",
+            "什么意思",
+            "科普",
+            "介绍一下",
+            "解释一下",
+            "这个词",
+            "这个概念",
+            "这个人",
+            "这个公司",
+            "这个品牌",
+            "这是什么",
+            "谁是",
+            "谁啊",
+        )
+        freshness_markers = (
+            "最新",
+            "最近",
+            "今天",
+            "刚刚",
+            "新闻",
+            "发布",
+            "价格",
+            "汇率",
+            "股价",
+            "比赛",
+            "比分",
+            "天气",
+        )
+        emotional_chat_markers = (
+            "想你",
+            "爱你",
+            "抱抱",
+            "亲亲",
+            "在吗",
+            "晚安",
+            "早安",
+            "宝贝",
+            "陪我",
+        )
+        question_markers = ("?", "？", "吗", "呢", "么", "怎么", "为什么")
+
+        if any(marker in cleaned for marker in explicit_markers):
+            return True
+        if any(marker in cleaned for marker in emotional_chat_markers):
+            return False
+        if any(marker in cleaned for marker in freshness_markers):
+            return True
+
+        ascii_tokens = re.findall(r"[A-Za-z][A-Za-z0-9.+_/-]{1,24}", cleaned)
+        if ascii_tokens and (any(marker in cleaned for marker in question_markers) or len(cleaned) <= 32):
+            return True
+
+        concept_patterns = (
+            r".{0,12}叫.{0,18}吗",
+            r".{0,18}啥意思",
+            r".{0,18}是什么梗",
+            r".{0,18}是什么东西",
+        )
+        return any(re.search(pattern, cleaned) for pattern in concept_patterns)
 
     def _build_search_query(self, text: str) -> str:
-        return web_search_service._build_search_query(text)
+        cleaned = " ".join(text.strip().split())
+        return cleaned[:80]
 
     async def analyze_emotion(self, text: str) -> Dict[str, float]:
         """
diff --git a/app/services/memory_service.py b/app/services/memory_service.py
index db05c22..85771cc 100644
--- a/app/services/memory_service.py
+++ b/app/services/memory_service.py
@@ -4,6 +4,7 @@
 
 import asyncio
 from datetime import datetime
+import logging
 import re
 from typing import Dict, Iterable, List, Optional
 
@@ -12,6 +13,8 @@
 from app.models.user import Conversation, MemoryItem, ShortTermMemory, User
 from app.utils.helpers import sanitize_input, summarize_recent_agent_replies
 
+logger = logging.getLogger(__name__)
+
 
 MEMORY_ITEM_SALIENCE = {
     "identity": 70,
@@ -31,12 +34,18 @@ def __init__(self):
         self._background_tasks: set[asyncio.Task] = set()
         self._user_locks: Dict[str, asyncio.Lock] = {}
 
-    async def get_or_create_user(self, wecom_user_id: str) -> Dict:
+    def _resolve_identity(self, channel: str, external_user_id: Optional[str] = None) -> tuple[str, str]:
+        if external_user_id is None:
+            return "wecom", channel
+        return channel, external_user_id
+
+    async def get_or_create_user(self, channel: str, external_user_id: Optional[str] = None) -> Dict:
+        channel, external_user_id = self._resolve_identity(channel, external_user_id)
         db = SessionLocal()
         try:
-            user = self._get_user_by_wecom_id(db, wecom_user_id)
+            user = self._get_user_by_channel_external_id(db, channel, external_user_id)
             if not user:
-                user = self._create_user(db, wecom_user_id)
+                user = self._create_user(db, channel, external_user_id)
 
             user.last_interaction = datetime.now()
             user.total_conversations += 1
@@ -49,10 +58,11 @@ async def get_or_create_user(self, wecom_user_id: str) -> Dict:
         finally:
             db.close()
 
-    async def get_conversation_context(self, user_id: str) -> Dict:
+    async def get_conversation_context(self, channel: str, external_user_id: Optional[str] = None) -> Dict:
+        channel, external_user_id = self._resolve_identity(channel, external_user_id)
         db = SessionLocal()
         try:
-            user = self._get_user_by_wecom_id(db, user_id)
+            user = self._get_user_by_channel_external_id(db, channel, external_user_id)
             if not user:
                 return {}
 
@@ -90,10 +100,11 @@ async def get_conversation_context(self, user_id: str) -> Dict:
         finally:
             db.close()
 
-    async def get_recent_messages(self, user_id: str, limit: int = 10) -> List[Dict]:
+    async def get_recent_messages(self, channel: str, external_user_id: Optional[str] = None, limit: int = 10) -> List[Dict]:
+        channel, external_user_id = self._resolve_identity(channel, external_user_id)
         db = SessionLocal()
         try:
-            user = self._get_user_by_wecom_id(db, user_id)
+            user = self._get_user_by_channel_external_id(db, channel, external_user_id)
             if not user:
                 return []
 
@@ -110,10 +121,11 @@ async def get_recent_messages(self, user_id: str, limit: int = 10) -> List[Dict]
         finally:
             db.close()
 
-    async def get_recent_agent_replies(self, user_id: str, limit: int = 3) -> List[str]:
+    async def get_recent_agent_replies(self, channel: str, external_user_id: Optional[str] = None, limit: int = 3) -> List[str]:
+        channel, external_user_id = self._resolve_identity(channel, external_user_id)
         db = SessionLocal()
         try:
-            user = self._get_user_by_wecom_id(db, user_id)
+            user = self._get_user_by_channel_external_id(db, channel, external_user_id)
             if not user:
                 return []
 
@@ -125,16 +137,23 @@ async def get_recent_agent_replies(self, user_id: str, limit: int = 3) -> List[s
 
     async def save_conversation(
         self,
-        user_id: str,
+        *,
+        channel: Optional[str] = None,
+        external_user_id: Optional[str] = None,
         user_message: str,
         agent_message: str,
         user_emotion: Dict,
         agent_emotion: Dict,
         memories_used: Optional[Dict] = None,
+        user_id: Optional[str] = None,
     ) -> Optional[int]:
+        if user_id and not external_user_id:
+            channel, external_user_id = "wecom", user_id
+        if not channel or not external_user_id:
+            return None
         db = SessionLocal()
         try:
-            user = self._get_user_by_wecom_id(db, user_id)
+            user = self._get_user_by_channel_external_id(db, channel, external_user_id)
             if not user:
                 return None
 
@@ -159,10 +178,17 @@ async def save_conversation(
         finally:
             db.close()
 
-    async def update_user_profile(self, user_id: str, profile_update: Dict) -> None:
+    async def update_user_profile(
+        self,
+        channel: str,
+        external_user_id: Optional[str] = None,
+        profile_update: Optional[Dict] = None,
+    ) -> None:
+        channel, external_user_id = self._resolve_identity(channel, external_user_id)
+        profile_update = profile_update or {}
         db = SessionLocal()
         try:
-            user = self._get_user_by_wecom_id(db, user_id)
+            user = self._get_user_by_channel_external_id(db, channel, external_user_id)
             if not user:
                 return
 
@@ -183,7 +209,7 @@ async def list_users(self, query: str = "", limit: int = 20) -> List[Dict]:
             if cleaned_query:
                 like_value = f"%{cleaned_query}%"
                 user_query = user_query.filter(
-                    (User.wecom_user_id.ilike(like_value)) | (User.nickname.ilike(like_value))
+                    (User.external_user_id.ilike(like_value)) | (User.nickname.ilike(like_value))
                 )
 
             users = (
@@ -195,7 +221,8 @@ async def list_users(self, query: str = "", limit: int = 20) -> List[Dict]:
 
             return [
                 {
-                    "wecom_user_id": user.wecom_user_id,
+                    "channel": user.channel,
+                    "external_user_id": user.external_user_id,
                     "nickname": user.nickname or "",
                     "avatar_url": user.avatar_url or "",
                     "total_conversations": user.total_conversations,
@@ -207,10 +234,11 @@ async def list_users(self, query: str = "", limit: int = 20) -> List[Dict]:
         finally:
             db.close()
 
-    async def get_user_memory(self, wecom_user_id: str, query_text: str = "") -> Optional[Dict]:
+    async def get_user_memory(self, channel: str, external_user_id: Optional[str] = None, query_text: str = "") -> Optional[Dict]:
+        channel, external_user_id = self._resolve_identity(channel, external_user_id)
         db = SessionLocal()
         try:
-            user = self._get_user_by_wecom_id(db, wecom_user_id)
+            user = self._get_user_by_channel_external_id(db, channel, external_user_id)
             if not user:
                 return None
 
@@ -228,12 +256,14 @@ async def get_user_memory(self, wecom_user_id: str, query_text: str = "") -> Opt
         finally:
             db.close()
 
-    async def upsert_user_memory(self, wecom_user_id: str, payload: Dict) -> Dict:
+    async def upsert_user_memory(self, channel: str, external_user_id: Optional[str] = None, payload: Dict = None) -> Dict:
+        channel, external_user_id = self._resolve_identity(channel, external_user_id)
+        payload = payload or {}
         db = SessionLocal()
         try:
-            user = self._get_user_by_wecom_id(db, wecom_user_id)
+            user = self._get_user_by_channel_external_id(db, channel, external_user_id)
             if not user:
-                user = self._create_user(db, wecom_user_id)
+                user = self._create_user(db, channel, external_user_id)
 
             user.nickname = str(payload.get("nickname") or "").strip() or None
             user.avatar_url = str(payload.get("avatar_url") or "").strip() or None
@@ -251,13 +281,14 @@ async def upsert_user_memory(self, wecom_user_id: str, payload: Dict) -> Dict:
         finally:
             db.close()
 
-        memory = await self.get_user_memory(wecom_user_id)
-        return memory or self._empty_user_memory(wecom_user_id)
+        memory = await self.get_user_memory(channel, external_user_id)
+        return memory or self._empty_user_memory(channel, external_user_id)
 
-    async def get_recent_conversations(self, wecom_user_id: str, limit: int = 8) -> List[Dict]:
+    async def get_recent_conversations(self, channel: str, external_user_id: Optional[str] = None, limit: int = 8) -> List[Dict]:
+        channel, external_user_id = self._resolve_identity(channel, external_user_id)
         db = SessionLocal()
         try:
-            user = self._get_user_by_wecom_id(db, wecom_user_id)
+            user = self._get_user_by_channel_external_id(db, channel, external_user_id)
             if not user:
                 return []
             conversations = self._get_recent_conversations_rows(db, user.id, limit=limit)
@@ -267,13 +298,20 @@ async def get_recent_conversations(self, wecom_user_id: str, limit: int = 8) ->
 
     def schedule_memory_processing(
         self,
-        wecom_user_id: str,
+        *,
+        channel: str = "wecom",
+        external_user_id: Optional[str] = None,
         conversation_id: Optional[int],
         user_message: str,
         agent_message: str,
         user_emotion: Dict,
         agent_emotion: Dict,
+        wecom_user_id: Optional[str] = None,
     ) -> None:
+        if wecom_user_id and not external_user_id:
+            channel, external_user_id = "wecom", wecom_user_id
+        else:
+            channel, external_user_id = self._resolve_identity(channel, external_user_id)
         if not conversation_id:
             return
 
@@ -284,7 +322,8 @@ def schedule_memory_processing(
 
         task = loop.create_task(
             self.process_memory_update(
-                wecom_user_id=wecom_user_id,
+                channel=channel,
+                external_user_id=external_user_id,
                 conversation_id=conversation_id,
                 user_message=user_message,
                 agent_message=agent_message,
@@ -297,20 +336,29 @@ def schedule_memory_processing(
 
     async def process_memory_update(
         self,
-        wecom_user_id: str,
+        *,
+        channel: str = "wecom",
+        external_user_id: Optional[str] = None,
         conversation_id: int,
         user_message: str,
         agent_message: str,
         user_emotion: Dict,
         agent_emotion: Dict,
+        wecom_user_id: Optional[str] = None,
     ) -> None:
-        lock = self._user_locks.setdefault(wecom_user_id, asyncio.Lock())
+        if wecom_user_id and not external_user_id:
+            channel, external_user_id = "wecom", wecom_user_id
+        else:
+            channel, external_user_id = self._resolve_identity(channel, external_user_id)
+        user_key = self.build_user_key(channel, external_user_id)
+        lock = self._user_locks.setdefault(user_key, asyncio.Lock())
         async with lock:
             from app.graph import run_memory_update_graph
 
             await run_memory_update_graph(
                 {
-                    "wecom_user_id": wecom_user_id,
+                    "channel": channel,
+                    "external_user_id": external_user_id,
                     "conversation_id": conversation_id,
                     "user_message": user_message,
                     "agent_message": agent_message,
@@ -324,14 +372,19 @@ def _on_background_task_done(self, task: asyncio.Task) -> None:
         try:
             task.result()
         except Exception as exc:
-            print(f"记忆异步提炼失败: {exc}")
+            logger.exception("记忆异步提炼失败")
 
-    def _get_user_by_wecom_id(self, db, wecom_user_id: str) -> Optional[User]:
-        return db.query(User).filter(User.wecom_user_id == wecom_user_id).first()
+    def _get_user_by_channel_external_id(self, db, channel: str, external_user_id: str) -> Optional[User]:
+        return (
+            db.query(User)
+            .filter(User.channel == channel, User.external_user_id == external_user_id)
+            .first()
+        )
 
-    def _create_user(self, db, wecom_user_id: str) -> User:
+    def _create_user(self, db, channel: str, external_user_id: str) -> User:
         user = User(
-            wecom_user_id=wecom_user_id,
+            channel=channel,
+            external_user_id=external_user_id,
             profile=self._get_default_profile(),
             basic_info={},
             emotional_patterns={},
@@ -345,6 +398,9 @@ def _create_user(self, db, wecom_user_id: str) -> User:
         db.refresh(user)
         return user
 
+    def build_user_key(self, channel: str, external_user_id: str) -> str:
+        return f"{channel}:{external_user_id}"
+
     def _get_or_create_short_term_memory(self, db, user_id: int) -> ShortTermMemory:
         memory = db.query(ShortTermMemory).filter(ShortTermMemory.user_id == user_id).first()
         if not memory:
@@ -421,7 +477,8 @@ def _build_profile_snapshot(
     ) -> Dict:
         profile = user.profile or self._get_default_profile()
         return {
-            "wecom_user_id": user.wecom_user_id,
+            "channel": user.channel,
+            "external_user_id": user.external_user_id,
             "nickname": user.nickname or "",
             "avatar_url": user.avatar_url or "",
             "profile": profile,
@@ -462,9 +519,10 @@ def _serialize_memory_item(self, item: MemoryItem) -> Dict:
             "source_conversation_id": item.source_conversation_id,
         }
 
-    def _empty_user_memory(self, wecom_user_id: str) -> Dict:
+    def _empty_user_memory(self, channel: str, external_user_id: str) -> Dict:
         return {
-            "wecom_user_id": wecom_user_id,
+            "channel": channel,
+            "external_user_id": external_user_id,
             "nickname": "",
             "avatar_url": "",
             "basic_info": {},
diff --git a/app/services/multimodal_chat_service.py b/app/services/multimodal_chat_service.py
index 305e23c..3e3d014 100644
--- a/app/services/multimodal_chat_service.py
+++ b/app/services/multimodal_chat_service.py
@@ -6,6 +6,7 @@
 
 import base64
 import mimetypes
+import logging
 from pathlib import Path
 from typing import Dict, List
 
@@ -22,6 +23,8 @@
 from app.services.wecom_service import wecom_service
 from app.utils.helpers import choose_natural_fallback_reply, get_current_time, get_response_constraints, is_response_too_similar
 
+logger = logging.getLogger(__name__)
+
 
 ANTI_REPEAT_RETRY_INSTRUCTION = """
 
@@ -150,7 +153,7 @@ async def _run_multimodal_turn(
         try:
             user_emotion = await glm_service.analyze_emotion(user_message)
         except Exception as exc:
-            print(f"多模态消息情绪分析失败，回退到默认情绪: {exc}")
+            logger.warning("多模态消息情绪分析失败，回退到默认情绪: %s", exc)
             user_emotion = {"neutral": 1.0}
 
         agent_emotion = await emotion_engine.update_state(user_id, user_message, user_emotion)
@@ -189,7 +192,7 @@ async def _run_multimodal_turn(
                 )
                 reply = retried_reply or reply
         except Exception as exc:
-            print(f"多模态回复生成失败: {exc}")
+            logger.warning("多模态回复生成失败: %s", exc)
 
         final_reply = reply or choose_natural_fallback_reply(user_message, user_emotion)
         conversation_id = await save_conversation(
diff --git a/app/services/napcat_service.py b/app/services/napcat_service.py
new file mode 100644
index 0000000..9ae0820
--- /dev/null
+++ b/app/services/napcat_service.py
@@ -0,0 +1,134 @@
+"""
+NapCat OneBot11 forward WebSocket client service.
+"""
+
+from __future__ import annotations
+
+import asyncio
+import json
+import logging
+import random
+from typing import Optional
+
+from app.config import settings
+from app.services.runtime_config_service import runtime_config_service
+
+try:
+    import websockets
+except Exception:  # pragma: no cover
+    websockets = None  # type: ignore[assignment]
+
+logger = logging.getLogger(__name__)
+
+class NapCatService:
+    def __init__(self) -> None:
+        self._task: Optional[asyncio.Task] = None
+        self._ws = None
+        self._send_lock = asyncio.Lock()
+        self._stop_event = asyncio.Event()
+
+    def _config(self) -> dict:
+        runtime = runtime_config_service.get_effective_napcat_config()
+        return {
+            "ws_url": runtime.get("ws_url") or settings.napcat_ws_url,
+            "ws_token": runtime.get("ws_token") or settings.napcat_ws_token,
+        }
+
+    async def start(self) -> None:
+        if websockets is None:
+            logger.warning("NapCat disabled: websockets is unavailable")
+            return
+        if self._task and not self._task.done():
+            return
+        cfg = self._config()
+        if not str(cfg["ws_url"]).strip():
+            logger.warning("NapCat disabled: NAPCAT_WS_URL is empty")
+            return
+        self._stop_event.clear()
+        self._task = asyncio.create_task(self._run_loop())
+
+    async def stop(self) -> None:
+        self._stop_event.set()
+        task = self._task
+        self._task = None
+        if task:
+            task.cancel()
+            try:
+                await task
+            except asyncio.CancelledError:
+                pass
+        if self._ws:
+            try:
+                await self._ws.close()
+            except Exception:
+                pass
+            self._ws = None
+
+    async def _run_loop(self) -> None:
+        delay = 1.0
+        while not self._stop_event.is_set():
+            cfg = self._config()
+            ws_url = str(cfg["ws_url"]).strip()
+            if not ws_url:
+                return
+            headers = {}
+            token = str(cfg.get("ws_token") or "").strip()
+            if token:
+                headers["Authorization"] = f"Bearer {token}"
+            try:
+                async with websockets.connect(ws_url, additional_headers=headers) as ws:
+                    self._ws = ws
+                    delay = 1.0
+                    async for message in ws:
+                        await self._handle_message(message)
+            except asyncio.CancelledError:
+                raise
+            except Exception as exc:
+                logger.warning("NapCat connection error: %s", exc)
+            finally:
+                self._ws = None
+
+            sleep_seconds = min(30.0, delay + random.uniform(0, 0.8))
+            await asyncio.sleep(sleep_seconds)
+            delay = min(30.0, delay * 2)
+
+    async def _handle_message(self, message: str) -> None:
+        try:
+            payload = json.loads(message)
+        except json.JSONDecodeError:
+            return
+
+        if payload.get("post_type") != "message":
+            return
+        if payload.get("message_type") != "private":
+            return
+
+        content = str(payload.get("raw_message") or "").strip()
+        external_user_id = str(payload.get("user_id") or "").strip()
+        if not content or not external_user_id:
+            return
+
+        from app.graph import run_incoming_message_graph
+
+        await run_incoming_message_graph(
+            {
+                "channel": "napcat",
+                "external_user_id": external_user_id,
+                "user_content": content,
+            }
+        )
+
+    async def send_private_text(self, external_user_id: str, content: str) -> None:
+        if not self._ws:
+            raise RuntimeError("NapCat websocket is not connected")
+        payload = {
+            "action": "send_private_msg",
+            "params": {"user_id": int(external_user_id) if external_user_id.isdigit() else external_user_id, "message": content},
+            "echo": f"lovagent-{int(asyncio.get_running_loop().time() * 1000)}",
+        }
+        async with self._send_lock:
+            await self._ws.send(json.dumps(payload, ensure_ascii=False))
+
+
+napcat_service = NapCatService()
+
diff --git a/app/services/proactive_chat_service.py b/app/services/proactive_chat_service.py
index 3c1c2a3..d20a096 100644
--- a/app/services/proactive_chat_service.py
+++ b/app/services/proactive_chat_service.py
@@ -1,27 +1,20 @@
-"""
-主动聊天服务
+"""
+Proactive chat service.
 """
 
 import asyncio
 from datetime import datetime, timedelta
-from typing import Dict, List, Optional
+import logging
+from typing import Dict, List, Optional, Tuple
 
 from sqlalchemy.exc import OperationalError
 
 from app.config import settings
 from app.models.admin import ProactiveChatConfig, ProactiveChatLog
 from app.models.database import SessionLocal
-from app.models.user import Conversation, User
-from app.prompts.templates import (
-    build_morning_greeting,
-    build_night_greeting,
-    build_proactive_prompt,
-)
-from app.services.llm_service import glm_service
-from app.services.memory_service import memory_service
-from app.services.persona_service import persona_service
-from app.services.wecom_service import wecom_service
-from app.utils.helpers import get_response_constraints, get_time_period
+from app.models.user import User
+
+logger = logging.getLogger(__name__)
 
 
 DEFAULT_PROACTIVE_CHAT_CONFIG_KEY = "default_proactive_chat"
@@ -33,7 +26,8 @@
 DEFAULT_QUIET_HOURS = {"enabled": True, "start": "23:00", "end": "09:00"}
 DEFAULT_PROACTIVE_CHAT_CONFIG = {
     "enabled": False,
-    "target_wecom_user_id": "",
+    "target_channel": "wecom",
+    "target_external_user_id": "",
     "scheduled_windows": DEFAULT_SCHEDULED_WINDOWS,
     "inactivity_trigger_hours": 6,
     "quiet_hours": DEFAULT_QUIET_HOURS,
@@ -44,7 +38,7 @@
 
 
 class ProactiveChatService:
-    """主动聊天配置、调度和发送服务。"""
+    """Proactive chat config, scheduling and dispatch."""
 
     def __init__(self):
         self.scheduler_interval_seconds = max(30, settings.proactive_scheduler_interval_seconds)
@@ -67,7 +61,8 @@ def get_config(self) -> Dict:
             return self._build_payload(
                 {
                     "enabled": record.enabled,
-                    "target_wecom_user_id": record.target_wecom_user_id or "",
+                    "target_channel": record.target_channel or "wecom",
+                    "target_external_user_id": record.target_external_user_id or "",
                     "scheduled_windows": record.scheduled_windows or [],
                     "inactivity_trigger_hours": record.inactivity_trigger_hours,
                     "quiet_hours": record.quiet_hours or {},
@@ -99,7 +94,8 @@ def save_config(self, config: Dict) -> Dict:
                 db.add(record)
 
             record.enabled = normalized["enabled"]
-            record.target_wecom_user_id = normalized["target_wecom_user_id"] or None
+            record.target_channel = normalized["target_channel"]
+            record.target_external_user_id = normalized["target_external_user_id"] or None
             record.scheduled_windows = normalized["scheduled_windows"]
             record.inactivity_trigger_hours = normalized["inactivity_trigger_hours"]
             record.quiet_hours = normalized["quiet_hours"]
@@ -113,13 +109,14 @@ def save_config(self, config: Dict) -> Dict:
         finally:
             db.close()
 
-    async def preview_outreach(self, wecom_user_id: Optional[str] = None) -> Dict:
-        target_wecom_user_id = self._resolve_target_user_id(wecom_user_id)
+    async def preview_outreach(self, channel: Optional[str] = None, external_user_id: Optional[str] = None) -> Dict:
+        target_channel, target_external_user_id = self._resolve_target_user(channel, external_user_id)
         from app.graph import run_proactive_chat_graph
 
         payload = await run_proactive_chat_graph(
             {
-                "target_wecom_user_id": target_wecom_user_id,
+                "target_channel": target_channel,
+                "target_external_user_id": target_external_user_id,
                 "trigger_type": "manual",
                 "window_key": None,
                 "send_delivery": False,
@@ -127,13 +124,14 @@ async def preview_outreach(self, wecom_user_id: Optional[str] = None) -> Dict:
         )
         return self._format_graph_payload(payload)
 
-    async def run_outreach_once(self, wecom_user_id: Optional[str] = None) -> Dict:
-        target_wecom_user_id = self._resolve_target_user_id(wecom_user_id)
+    async def run_outreach_once(self, channel: Optional[str] = None, external_user_id: Optional[str] = None) -> Dict:
+        target_channel, target_external_user_id = self._resolve_target_user(channel, external_user_id)
         from app.graph import run_proactive_chat_graph
 
         payload = await run_proactive_chat_graph(
             {
-                "target_wecom_user_id": target_wecom_user_id,
+                "target_channel": target_channel,
+                "target_external_user_id": target_external_user_id,
                 "trigger_type": "manual",
                 "window_key": None,
                 "send_delivery": True,
@@ -151,7 +149,8 @@ async def dispatch_due_messages(self) -> Optional[Dict]:
 
         payload = await run_proactive_chat_graph(
             {
-                "target_wecom_user_id": config["target_wecom_user_id"],
+                "target_channel": config["target_channel"],
+                "target_external_user_id": config["target_external_user_id"],
                 "trigger_type": due["trigger_type"],
                 "window_key": due.get("window_key"),
                 "send_delivery": True,
@@ -164,22 +163,27 @@ async def scheduler_loop(self) -> None:
             try:
                 result = await self.dispatch_due_messages()
                 if result and result.get("delivery", {}).get("status") == "sent":
-                    print(f"主动聊天发送成功: {result['target_wecom_user_id']}")
+                    logger.info("主动聊天发送成功: %s:%s", result["target_channel"], result["target_external_user_id"])
             except asyncio.CancelledError:
                 raise
             except Exception as exc:
-                print(f"主动聊天调度异常: {exc}")
+                logger.exception("主动聊天调度异常")
 
             await asyncio.sleep(self.scheduler_interval_seconds)
 
     def _build_payload(self, config: Dict, updated_at: Optional[str] = None) -> Dict:
         normalized = self._normalize_config(config)
         normalized["updated_at"] = updated_at
+        normalized["target_wecom_user_id"] = (
+            normalized["target_external_user_id"] if normalized["target_channel"] == "wecom" else ""
+        )
         return normalized
 
     def _format_graph_payload(self, payload: Dict) -> Dict:
         return {
-            "target_wecom_user_id": payload["target_wecom_user_id"],
+            "target_channel": payload["target_channel"],
+            "target_external_user_id": payload["target_external_user_id"],
+            "target_wecom_user_id": payload["target_external_user_id"] if payload["target_channel"] == "wecom" else "",
             "trigger_type": payload["trigger_type"],
             "window_key": payload.get("window_key"),
             "prompt": payload.get("prompt", ""),
@@ -199,7 +203,9 @@ def _normalize_config(self, config: Optional[Dict]) -> Dict:
             return merged
 
         merged["enabled"] = bool(config.get("enabled", merged["enabled"]))
-        merged["target_wecom_user_id"] = str(config.get("target_wecom_user_id") or "").strip()
+        legacy_target = str(config.get("target_wecom_user_id") or "").strip()
+        merged["target_channel"] = str(config.get("target_channel") or "wecom").strip() or "wecom"
+        merged["target_external_user_id"] = str(config.get("target_external_user_id") or legacy_target).strip()
         merged["scheduled_windows"] = self._normalize_scheduled_windows(config.get("scheduled_windows"))
         merged["quiet_hours"] = self._normalize_quiet_hours(config.get("quiet_hours"))
         merged["tone_hint"] = str(config.get("tone_hint") or merged["tone_hint"]).strip() or merged["tone_hint"]
@@ -275,176 +281,34 @@ def _coerce_int(self, value: object, fallback: int, minimum: int, maximum: int)
             number = fallback
         return max(minimum, min(maximum, number))
 
-    def _resolve_target_user_id(self, wecom_user_id: Optional[str]) -> str:
-        target_wecom_user_id = str(wecom_user_id or "").strip()
-        if target_wecom_user_id:
-            return target_wecom_user_id
+    def _resolve_target_user(self, channel: Optional[str], external_user_id: Optional[str]) -> Tuple[str, str]:
+        target_channel = str(channel or "").strip()
+        target_external_user_id = str(external_user_id or "").strip()
+        if target_channel and target_external_user_id:
+            return target_channel, target_external_user_id
 
         config = self.get_config()
-        target_wecom_user_id = config["target_wecom_user_id"]
-        if not target_wecom_user_id:
+        target_channel = config["target_channel"]
+        target_external_user_id = config["target_external_user_id"]
+        if not target_external_user_id:
             raise ValueError("请先配置主动聊天目标用户")
-        return target_wecom_user_id
-
-    async def _build_outreach_payload(
-        self,
-        target_wecom_user_id: str,
-        trigger_type: str,
-        window_key: Optional[str] = None,
-    ) -> Dict:
-        persona_config = persona_service.get_persona_config()
-        proactive_config = self.get_config()
-        user_memory = await memory_service.get_user_memory(target_wecom_user_id)
-        context = await memory_service.get_conversation_context(target_wecom_user_id)
-        recent_agent_replies = await memory_service.get_recent_agent_replies(target_wecom_user_id, limit=3)
-        prompt = build_proactive_prompt(
-            trigger_type=trigger_type,
-            current_time=datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
-            persona_config=persona_config,
-            user_profile=user_memory,
-            context=context,
-            recent_agent_replies=recent_agent_replies,
-            tone_hint=proactive_config["tone_hint"],
-        )
-
-        response_constraints = get_response_constraints(
-            "我想主动开启一段自然微信聊天",
-            persona_config.get("response_preferences"),
-        )
-
-        reply = ""
-        try:
-            reply = await glm_service.chat_with_context(
-                system_prompt=prompt,
-                user_message="请直接输出一条现在要主动发给他的微信消息。",
-                context_messages=[],
-                temperature=0.92,
-                top_p=0.95,
-                max_tokens=int(response_constraints["max_tokens"]),
-                task_type="proactive",
-            )
-        except Exception as exc:
-            print(f"生成主动聊天文案失败，使用兜底: {exc}")
-
-        if not reply:
-            reply = self._build_fallback_message(target_wecom_user_id, trigger_type, user_memory)
-
-        return {
-            "target_wecom_user_id": target_wecom_user_id,
-            "trigger_type": trigger_type,
-            "window_key": window_key,
-            "prompt": prompt,
-            "reply": reply,
-            "persona_config": persona_config,
-            "user_memory": user_memory,
-            "config": proactive_config,
-        }
+        return target_channel, target_external_user_id
 
     def _build_fallback_message(
         self,
-        target_wecom_user_id: str,
+        target_channel: str,
+        target_external_user_id: str,
         trigger_type: str,
         user_memory: Optional[Dict],
     ) -> str:
-        nickname = str((user_memory or {}).get("nickname") or "").strip()
-        prefix = f"{nickname}，" if nickname else ""
-        time_period = get_time_period()
-
-        if trigger_type == "scheduled" and time_period == "早晨":
-            return build_morning_greeting()
-        if trigger_type == "scheduled" and time_period in {"夜晚", "深夜"}:
-            return build_night_greeting()
+        _ = (target_channel, target_external_user_id, user_memory)
         if trigger_type == "inactivity":
-            return f"{prefix}刚刚突然想到你了，今天过得怎么样呀？"
-        return f"{prefix}刚刚想起你，想来和你说句话，在忙吗？"
-
-    async def _deliver_outreach(
-        self,
-        target_wecom_user_id: str,
-        trigger_type: str,
-        window_key: Optional[str],
-        content: str,
-    ) -> Dict:
-        sent_at = datetime.now()
-        status = "failed"
-        error_message = None
-
-        try:
-            await wecom_service.send_text_message(target_wecom_user_id, content)
-            status = "sent"
-            self._save_proactive_conversation(target_wecom_user_id, content, sent_at)
-        except Exception as exc:
-            error_message = str(exc)
-            print(f"主动聊天发送失败: {exc}")
-        finally:
-            self._save_log(
-                target_wecom_user_id=target_wecom_user_id,
-                trigger_type=trigger_type,
-                window_key=window_key,
-                content=content,
-                status=status,
-                error_message=error_message,
-                sent_at=sent_at,
-            )
-
-        return {
-            "attempted": True,
-            "status": status,
-            "error_message": error_message,
-            "sent_at": sent_at.isoformat(),
-        }
-
-    def _save_proactive_conversation(self, target_wecom_user_id: str, content: str, sent_at: datetime) -> None:
-        db = SessionLocal()
-        try:
-            user = db.query(User).filter(User.wecom_user_id == target_wecom_user_id).first()
-            if not user:
-                return
-
-            conversation = Conversation(
-                user_id=user.id,
-                user_message="",
-                agent_message=content,
-                user_emotion=None,
-                agent_emotion="happy",
-                agent_emotion_intensity=40,
-                context_used=True,
-                memories_used={"source": "proactive"},
-                created_at=sent_at,
-            )
-            db.add(conversation)
-            db.commit()
-        finally:
-            db.close()
-
-    def _save_log(
-        self,
-        target_wecom_user_id: str,
-        trigger_type: str,
-        window_key: Optional[str],
-        content: str,
-        status: str,
-        error_message: Optional[str],
-        sent_at: datetime,
-    ) -> None:
-        db = SessionLocal()
-        try:
-            log = ProactiveChatLog(
-                target_wecom_user_id=target_wecom_user_id,
-                trigger_type=trigger_type,
-                window_key=window_key,
-                content=content,
-                status=status,
-                error_message=error_message,
-                sent_at=sent_at,
-            )
-            db.add(log)
-            db.commit()
-        finally:
-            db.close()
+            return "刚刚突然想到你了，今天过得怎么样呀？"
+        return "刚刚想起你，想来和你说句话，在忙吗？"
 
     def _resolve_due_trigger(self, config: Dict) -> Optional[Dict]:
-        if not config.get("enabled") or not config.get("target_wecom_user_id"):
+        config = self._normalize_config(config)
+        if not config.get("enabled") or not config.get("target_external_user_id"):
             return None
 
         now = datetime.now()
@@ -453,7 +317,14 @@ def _resolve_due_trigger(self, config: Dict) -> Optional[Dict]:
 
         db = SessionLocal()
         try:
-            user = db.query(User).filter(User.wecom_user_id == config["target_wecom_user_id"]).first()
+            user = (
+                db.query(User)
+                .filter(
+                    User.channel == config["target_channel"],
+                    User.external_user_id == config["target_external_user_id"],
+                )
+                .first()
+            )
             if not user:
                 return None
 
@@ -463,10 +334,10 @@ def _resolve_due_trigger(self, config: Dict) -> Optional[Dict]:
                 if minutes_since_last_interaction < config["min_interval_minutes"]:
                     return None
 
-            if self._count_sent_today(db, config["target_wecom_user_id"], now) >= config["max_messages_per_day"]:
+            if self._count_sent_today(db, config["target_channel"], config["target_external_user_id"], now) >= config["max_messages_per_day"]:
                 return None
 
-            last_sent = self._get_last_success_log(db, config["target_wecom_user_id"])
+            last_sent = self._get_last_success_log(db, config["target_channel"], config["target_external_user_id"])
             if last_sent and (now - last_sent.sent_at).total_seconds() / 60 < config["min_interval_minutes"]:
                 return None
 
@@ -475,7 +346,8 @@ def _resolve_due_trigger(self, config: Dict) -> Optional[Dict]:
                     continue
                 if self._is_window_due(now, window["time"]) and not self._window_sent_today(
                     db,
-                    config["target_wecom_user_id"],
+                    config["target_channel"],
+                    config["target_external_user_id"],
                     window["key"],
                     now,
                 ):
@@ -484,7 +356,12 @@ def _resolve_due_trigger(self, config: Dict) -> Optional[Dict]:
             if (
                 last_interaction
                 and now - last_interaction >= timedelta(hours=config["inactivity_trigger_hours"])
-                and not self._already_sent_inactivity_since(db, config["target_wecom_user_id"], last_interaction)
+                and not self._already_sent_inactivity_since(
+                    db,
+                    config["target_channel"],
+                    config["target_external_user_id"],
+                    last_interaction,
+                )
             ):
                 return {"trigger_type": "inactivity", "window_key": None}
         finally:
@@ -510,13 +387,14 @@ def _is_in_quiet_hours(self, now: datetime, quiet_hours: Dict) -> bool:
             return start <= current < end
         return current >= start or current < end
 
-    def _count_sent_today(self, db, target_wecom_user_id: str, now: datetime) -> int:
+    def _count_sent_today(self, db, target_channel: str, target_external_user_id: str, now: datetime) -> int:
         start_of_day = now.replace(hour=0, minute=0, second=0, microsecond=0)
         end_of_day = start_of_day + timedelta(days=1)
         return (
             db.query(ProactiveChatLog)
             .filter(
-                ProactiveChatLog.target_wecom_user_id == target_wecom_user_id,
+                ProactiveChatLog.target_channel == target_channel,
+                ProactiveChatLog.target_external_user_id == target_external_user_id,
                 ProactiveChatLog.status == "sent",
                 ProactiveChatLog.sent_at >= start_of_day,
                 ProactiveChatLog.sent_at < end_of_day,
@@ -524,13 +402,14 @@ def _count_sent_today(self, db, target_wecom_user_id: str, now: datetime) -> int
             .count()
         )
 
-    def _window_sent_today(self, db, target_wecom_user_id: str, window_key: str, now: datetime) -> bool:
+    def _window_sent_today(self, db, target_channel: str, target_external_user_id: str, window_key: str, now: datetime) -> bool:
         start_of_day = now.replace(hour=0, minute=0, second=0, microsecond=0)
         end_of_day = start_of_day + timedelta(days=1)
         return (
             db.query(ProactiveChatLog)
             .filter(
-                ProactiveChatLog.target_wecom_user_id == target_wecom_user_id,
+                ProactiveChatLog.target_channel == target_channel,
+                ProactiveChatLog.target_external_user_id == target_external_user_id,
                 ProactiveChatLog.status == "sent",
                 ProactiveChatLog.trigger_type == "scheduled",
                 ProactiveChatLog.window_key == window_key,
@@ -541,11 +420,12 @@ def _window_sent_today(self, db, target_wecom_user_id: str, window_key: str, now
             is not None
         )
 
-    def _already_sent_inactivity_since(self, db, target_wecom_user_id: str, since: datetime) -> bool:
+    def _already_sent_inactivity_since(self, db, target_channel: str, target_external_user_id: str, since: datetime) -> bool:
         return (
             db.query(ProactiveChatLog)
             .filter(
-                ProactiveChatLog.target_wecom_user_id == target_wecom_user_id,
+                ProactiveChatLog.target_channel == target_channel,
+                ProactiveChatLog.target_external_user_id == target_external_user_id,
                 ProactiveChatLog.status == "sent",
                 ProactiveChatLog.trigger_type == "inactivity",
                 ProactiveChatLog.sent_at >= since,
@@ -554,11 +434,12 @@ def _already_sent_inactivity_since(self, db, target_wecom_user_id: str, since: d
             is not None
         )
 
-    def _get_last_success_log(self, db, target_wecom_user_id: str) -> Optional[ProactiveChatLog]:
+    def _get_last_success_log(self, db, target_channel: str, target_external_user_id: str) -> Optional[ProactiveChatLog]:
         return (
             db.query(ProactiveChatLog)
             .filter(
-                ProactiveChatLog.target_wecom_user_id == target_wecom_user_id,
+                ProactiveChatLog.target_channel == target_channel,
+                ProactiveChatLog.target_external_user_id == target_external_user_id,
                 ProactiveChatLog.status == "sent",
             )
             .order_by(ProactiveChatLog.sent_at.desc(), ProactiveChatLog.id.desc())
diff --git a/app/services/runtime_config_service.py b/app/services/runtime_config_service.py
index 522d184..52e21fb 100644
--- a/app/services/runtime_config_service.py
+++ b/app/services/runtime_config_service.py
@@ -50,6 +50,10 @@
         "token": "",
         "encoding_aes_key": "",
     },
+    "napcat": {
+        "ws_url": "",
+        "ws_token": "",
+    },
     "deployment": {
         "public_base_url": "",
     },
@@ -300,6 +304,13 @@ def get_effective_wecom_config(self) -> Dict:
             "encoding_aes_key": config["encoding_aes_key"] or settings.wecom_encoding_aes_key,
         }
 
+    def get_effective_napcat_config(self) -> Dict:
+        config = self.get_config()["napcat"]
+        return {
+            "ws_url": str(config.get("ws_url") or settings.napcat_ws_url).strip(),
+            "ws_token": str(config.get("ws_token") or settings.napcat_ws_token).strip(),
+        }
+
     def get_effective_public_base_url(self) -> str:
         deployment = self.get_config()["deployment"]
         return str(deployment.get("public_base_url") or settings.public_base_url).strip()
@@ -335,6 +346,7 @@ def get_status_payload(self) -> Dict:
         raw = self.get_config()
         effective_model = self.get_effective_model_config()
         effective_wecom = self.get_effective_wecom_config()
+        effective_napcat = self.get_effective_napcat_config()
         effective_public_base_url = self.get_effective_public_base_url()
         effective_admin_password = self.get_effective_admin_password()
 
@@ -352,6 +364,7 @@ def get_status_payload(self) -> Dict:
                         effective_wecom["encoding_aes_key"],
                     ]
                 ),
+                "napcat_configured": bool(effective_napcat["ws_url"]),
                 "admin_configured": bool(effective_admin_password),
                 "deployment_configured": bool(effective_public_base_url),
             },
@@ -393,6 +406,8 @@ def get_status_payload(self) -> Dict:
                 "has_wecom_secret": bool(effective_wecom["secret"]),
                 "has_wecom_token": bool(effective_wecom["token"]),
                 "has_wecom_encoding_aes_key": bool(effective_wecom["encoding_aes_key"]),
+                "napcat_ws_url": effective_napcat["ws_url"],
+                "has_napcat_ws_token": bool(effective_napcat["ws_token"]),
                 "has_admin_password": bool(effective_admin_password),
             },
             "raw": {
@@ -421,6 +436,10 @@ def get_status_payload(self) -> Dict:
                     "has_token": bool(raw["wecom"]["token"]),
                     "has_encoding_aes_key": bool(raw["wecom"]["encoding_aes_key"]),
                 },
+                "napcat": {
+                    "ws_url": raw["napcat"]["ws_url"],
+                    "has_ws_token": bool(raw["napcat"]["ws_token"]),
+                },
                 "deployment": {
                     "public_base_url": raw["deployment"]["public_base_url"],
                 },
diff --git a/app/services/tunnel_service.py b/app/services/tunnel_service.py
index f120d24..c338ee2 100644
--- a/app/services/tunnel_service.py
+++ b/app/services/tunnel_service.py
@@ -2,6 +2,7 @@
 Cloudflare Tunnel 管理服务
 """
 
+import logging
 import re
 import shutil
 import subprocess
@@ -21,6 +22,7 @@
     "developers.cloudflare.com",
     "www.cloudflare.com",
 }
+logger = logging.getLogger(__name__)
 
 
 def extract_quick_tunnel_url(text: str) -> str:
@@ -129,7 +131,7 @@ def _consume_output(self) -> None:
                 continue
 
             self._public_url = public_url
-            print(f"🌐 Cloudflare Quick Tunnel: {public_url}")
+            logger.info("Cloudflare Quick Tunnel: %s", public_url)
 
             configured_public_base_url = runtime_config_service.get_effective_public_base_url()
             if (
diff --git a/requirements.txt b/requirements.txt
index a60ad79..31b707e 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -12,3 +12,4 @@ pydantic-settings>=2.0.0
 itsdangerous>=2.2.0
 langchain-core>=0.3.0,<0.4.0
 langgraph>=0.2.0,<0.4.0
+websockets>=12.0
diff --git a/tests/conftest.py b/tests/conftest.py
new file mode 100644
index 0000000..8f468fe
--- /dev/null
+++ b/tests/conftest.py
@@ -0,0 +1,16 @@
+import asyncio
+import inspect
+
+
+def pytest_pyfunc_call(pyfuncitem):
+    test_func = pyfuncitem.obj
+    if inspect.iscoroutinefunction(test_func):
+        signature = inspect.signature(test_func)
+        kwargs = {
+            name: value
+            for name, value in pyfuncitem.funcargs.items()
+            if name in signature.parameters
+        }
+        asyncio.run(test_func(**kwargs))
+        return True
+    return None