Copy# config/multi-channel.yaml
assistant:
  name: "小助"
  timezone: "Asia/Shanghai"
 
# ===== AI 引擎（所有通道共用） =====
ai:
  provider: "openai"
  model: "demo-model-v3"
  api_key: "${AI_API_KEY}"
  base_url: "${AI_BASE_URL}"
  system_prompt: |
    你是"小助"，一个跨平台个人 AI 助手。当前你在 {{channel_name}} 平台回复消息。
    
    不同平台的回复风格：
    - 微信/企业IM：简洁、正式，每句之间空一行
    - Telegram：可以用英文、技术术语、代码块
    - Email：完整段落，有称呼和落款
 
# ===== 多通道配置 =====
channels:
  # ────── 通道 1：微信（个人社交 + 客户群） ──────
  wechat:
    enabled: true
    login_method: "qrcode"
    # 各群的回复策略
    groups:
      "Demo项目群":
        strategy: "auto_reply"        # 自动回复，不需要 @
        knowledge: ["faq", "项目文档"]
      "Demo技术交流群":
        strategy: "mention_only"      # 只有被 @ 才回复
        knowledge: ["技术wiki"]
        ai_params:
          temperature: 0.3            # 技术问题要精确
      "Demo客户群":
        strategy: "auto_reply"
        knowledge: ["faq", "价格表"]
        ai_params:
          temperature: 0.5
          system_prompt_append: |
            你在客户群中，注意：
            - 语气亲和但不卑不亢
            - 价格可以直接说
            - 解决不了的问题，引导联系人工客服：400-demo-demo
    # 私聊策略
    private_chat:
      strategy: "auto_reply"
      knowledge: ["faq"]
      # 好友白名单——不是好友不回复
      friends_only: true
 
  # ────── 通道 2：企业 IM（内部办公） ──────
  dingtalk:
    enabled: true
    app_key: "${DINGTALK_APP_KEY}"
    app_secret: "${DINGTALK_APP_SECRET}"
    groups:
      "Demo团队群":
        strategy: "mention_only"
        listen_keywords: ["@小助", "小助", "/ai"]
        knowledge: ["技术wiki", "内部文档"]
        ai_params:
          system_prompt_append: |
            你在公司内部群，注意：
            - 回答准确优先，字数不限
            - 可以贴代码、贴链接
            - 可以说"不确定，建议问xxx"
        # 需要审批的操作
        approval_required:
          - "重启服务"
          - "清理缓存"
          - "执行部署"
 
  # ────── 通道 3：Telegram（开源社区） ──────
  telegram:
    enabled: true
    bot_token: "${TG_BOT_TOKEN}"
    groups:
      "Demo开源社区":
        strategy: "auto_reply"
        listen_keywords: ["/ask", "/help", "/docs"]
        knowledge: ["项目文档", "api文档", "贡献指南"]
        ai_params:
          temperature: 0.4
          system_prompt_append: |
            你在开源社区群，注意：
            - 支持中英文双语回复（根据用户消息的语言）
            - 不知道的问题可以请用户提 Issue
            - 可以贴 GitHub 链接
 
  # ────── 通道 4：邮件（客户通知） ──────
  email:
    enabled: true
    type: "imap"
    host: "imap.example.com"
    port: 993
    user: "assistant@example.com"
    password: "${EMAIL_PASSWORD}"
    # 只监控特定发件人
    watch_senders:
      - "*@client-company.com"
      - "support@example.com"
    # 自动回复模板
    auto_reply_template: |
      您好，
 
      感谢您的邮件。我是小助，已收到您的消息。
 
      {{ai_response}}
 
      此邮件由 AI 助手自动生成。如需人工服务，请回复"转人工"。
 
      祝好，
      小助

Copy# 跨通道通知规则
cross_channel:
  rules:
    # 规则 1：微信客户群提到"紧急" → 发到企业 IM
    - name: "客户紧急消息通知"
      source:
        channel: "wechat"
        group: "Demo客户群"
      trigger:
        keywords: ["紧急", "urgent", "线上出问题了"]
      action:
        type: "forward"
        target:
          channel: "dingtalk"
          group: "Demo团队群"
        template: |
          ⚠️ 客户紧急消息转发
          来自: 微信-Demo客户群
          消息: {{message.content.text}}
          时间: {{message.timestamp}}
          处理建议: 请相关同事关注
 
    # 规则 2：Telegram 社区有严重 Bug 报告 → 通知技术群
    - name: "严重Bug报告"
      source:
        channel: "telegram"
        group: "Demo开源社区"
      trigger:
        keywords: ["bug", "crash", "崩溃", "不能用了"]
      action:
        type: "forward"
        target:
          channel: "dingtalk"
          group: "Demo团队群"
        template: |
          🐛 社区 Bug 报告
          来自: Telegram开源社区
          用户: {{message.from.name}}
          内容: {{message.content.text}}
 
    # 规则 3：企业 IM 有"版本已发布" → 同步通知到所有通道
    - name: "版本发布公告"
      source:
        channel: "dingtalk"
        group: "Demo团队群"
      trigger:
        keywords: ["版本发布", "已上线", "release"]
      action:
        type: "broadcast"
        targets:
          - channel: "wechat"
            groups: ["Demo项目群", "Demo客户群"]
          - channel: "telegram"
            groups: ["Demo开源社区"]
        template: |
          📢 新版本已发布
          {{message.content.text}}

Copyrouting:
  # 处理顺序
  priority:
    1: "security_check"      # 安全检查最先
    2: "blacklist_check"      # 黑名单
    3: "cross_channel"        # 跨通道转发
    4: "plugin_match"         # 插件匹配
    5: "knowledge_match"      # 知识库匹配
    6: "ai_fallback"          # AI 兜底
  
  # 冷却时间——同一用户 30s 内不重复处理
  cooldown_seconds: 30

Copy// packages/ai/src/channel-style-resolver.ts
 
export class ChannelStyleResolver {
  /**
   * 根据通道类型，为 AI 请求注入不同的 system_prompt 和参数
   */
  resolve(params: AIParams, channel: ChannelMetadata): AIParams {
    const baseParams = { ...params };
    
    // 基础风格设定
    const styleProfiles: Record<string, Partial<AIParams>> = {
      wechat: {
        temperature: 0.7,
        max_tokens: 200,
        system_prompt_append: this.buildWeChatPrompt(),
      },
      dingtalk: {
        temperature: 0.3,
        max_tokens: 500,
        system_prompt_append: this.buildDingTalkPrompt(),
      },
      telegram: {
        temperature: 0.5,
        max_tokens: 800,
        system_prompt_append: this.buildTelegramPrompt(),
      },
      email: {
        temperature: 0.4,
        max_tokens: 1000,
        system_prompt_append: this.buildEmailPrompt(),
      },
    };
 
    const profile = styleProfiles[channel.name] ?? {};
    
    return {
      ...baseParams,
      ...profile,
      system_prompt: [
        baseParams.system_prompt ?? '',
        profile.system_prompt_append ?? '',
      ].filter(Boolean).join('\n'),
    };
  }
 
  private buildWeChatPrompt(): string {
    return `
你现在在微信上回复消息。
规则：
- 每句话不超过 30 字
- 不要发送超过 200 字的长文
- 两个自然段之间空一行
- 不要使用 Markdown 格式（微信不支持）
- 不要发送代码块，可以发 Gist 链接
- 适当的 emoji 可以增加亲和力（不超过 2 个/条）
`;
  }
 
  private buildDingTalkPrompt(): string {
    return `
你现在在企业通讯工具上回复消息。
规则：
- 准确优先，字数不限
- 可以使用 Markdown 格式
- 代码可以用代码块
- 可以贴内部 Wiki 链接
- 涉及敏感操作必须告知风险
- 回答来源要说清楚（来自 Wiki / 来自内部文档）
`;
  }
 
  private buildTelegramPrompt(): string {
    return `
你正在 Telegram 上回复开源社区的消息。
规则：
- 用用户使用的语言回复（中/英）
- 可以使用 Markdown、代码块
- 可以贴 GitHub issue/PR 链接
- 鼓励贡献者，感谢反馈
- 不确定的问题，请用户提 GitHub Issue
`;
  }
 
  private buildEmailPrompt(): string {
    return `
你正在回复一封电子邮件。
规则：
- 使用正式的段落格式
- 开头有称呼，结尾有落款
- 内容可以适当详细（500-2000 字）
- 如果有附件或链接，明确说明
- 结尾提供人工服务的联系方式
`;
  }
}

Copy// packages/core/src/routing/cross-channel-router.ts
 
export class CrossChannelRouter {
  constructor(
    private channelManager: ChannelManager,
    private ruleEngine: RuleEngine,
  ) {}
 
  async process(message: StandardMessage): Promise<CrossChannelResult> {
    const results: CrossChannelResult = { forwarded: false, actions: [] };
 
    // 1. 先处理消息来源通道的回复
    const sourceActions = await this.ruleEngine.match(message);
    
    for (const action of sourceActions) {
      switch (action.type) {
        case 'forward':
          // 转发到另一个通道
          await this.forwardToChannel(message, action);
          break;
        case 'broadcast':
          // 广播到多个通道
          await this.broadcastToChannels(message, action);
          break;
        case 'notify':
          // 通知我自己
          await this.notifyOwner(message, action);
          break;
      }
      results.actions.push(action);
      results.forwarded = true;
    }
 
    return results;
  }
 
  private async forwardToChannel(
    message: StandardMessage, 
    action: ForwardAction
  ): Promise<void> {
    const targetChannel = this.channelManager.getChannel(action.target.channel);
    if (!targetChannel || !targetChannel.isOnline()) {
      console.warn(`目标通道 ${action.target.channel} 不可用`);
      return;
    }
 
    // 组装转发消息
    const forwardContent = this.renderTemplate(action.template, {
      message,
      channelName: message.channel,
      timestamp: new Date(message.timestamp).toISOString(),
    });
 
    await targetChannel.send(
      { type: 'group', id: action.target.groupId },
      { type: 'text', text: forwardContent }
    );
 
    console.log(
      `[CrossChannel] ${message.channel} → ${action.target.channel}: ` +
      `"${message.content.text?.slice(0, 50)}..."`
    );
  }
 
  private async notifyOwner(
    message: StandardMessage,
    action: NotifyAction
  ): Promise<void> {
    // 找到任意在线通道，私聊通知我
    for (const channel of this.channelManager.getOnlineChannels()) {
      try {
        await channel.send(
          { type: 'individual', id: channel.getOwnerId() },
          { 
            type: 'text', 
            text: `🔔 ${action.message}\n来自: ${message.channel}\n内容: ${message.content.text}` 
          }
        );
        break; // 通知一次就够了
      } catch {
        continue; // 此通道不可用，试下一个
      }
    }
  }
 
  private renderTemplate(
    template: string, 
    context: Record<string, any>
  ): string {
    // 简单的模板渲染：{{xxx}} → 实际值
    return template.replace(/\{\{(\w+(\.\w+)*)\}\}/g, (_, key) => {
      const value = key.split('.').reduce((obj: any, k: string) => obj?.[k], context);
      return value ?? `{{${key}}}`;
    });
  }
}

Copy# 全局：默认 200 tokens
ai:
  default_params:
    max_tokens: 200
 
channels:
  wechat:
    # 微信通道覆盖：150 tokens
    max_tokens: 150
    groups:
      "Demo技术群":
        # 技术群再覆盖：无限制
        max_tokens: 0     # 0 表示不限制

Copychannels:
  wechat:
    groups:
      # 群 A：正式商务风格
      "Demo客户群":
        persona: "professional"
        system_prompt_append: |
          你的身份：Demo公司的客服助理，名字叫"小助"。
          语气：专业、亲切、不卑不亢。
          允许的事情：回答产品问题、提供报价、预约演示、转发技术支持。
          不允许的事情：承诺 SLA、随意降价、透露其他客户信息。
      
      # 群 B：技术极客风格
      "Demo技术交流群":
        persona: "geek"
        system_prompt_append: |
          你的身份：资深后端工程师，喜欢用代码和架构图说话。
          语气：直接、技术化、偶尔幽默。
          允许的回复方式：贴代码块、贴架构图链接、引用技术博客。
          口头禅："其实用 Rust 重写一下就好了" （开玩笑的时候用）
      
      # 群 C：朋友聊天风格
      "Demo朋友群":
        persona: "casual"
        system_prompt_append: |
          你的身份：小张的好朋友。
          语气：轻松、幽默、可以开玩笑。
          可以做的事情：闲聊、推荐电影、讲冷笑话。
          不可以做的事情：在工作时间闲聊超过 5 轮（提醒自己"先去干活！"）

Copy// packages/gateway/src/channel-health-monitor.ts
 
interface ChannelHealth {
  channel: string;
  online: boolean;
  lastMessageAt?: number;
  messageCount24h: number;
  errorCount24h: number;
  avgLatency: number;
  status: 'healthy' | 'degraded' | 'down';
}
 
export class ChannelHealthMonitor {
  private healthMap: Map<string, ChannelHealth> = new Map();
 
  checkAll(): ChannelHealth[] {
    const results: ChannelHealth[] = [];
 
    for (const [name, channel] of this.channelManager.getAll()) {
      const health: ChannelHealth = {
        channel: name,
        online: channel.isOnline(),
        lastMessageAt: channel.getLastActivity(),
        messageCount24h: this.get24hMessageCount(name),
        errorCount24h: this.get24hErrorCount(name),
        avgLatency: this.getAvgLatency(name),
        status: 'healthy',
      };
 
      // 状态判定
      if (!health.online) {
        health.status = 'down';
      } else if (health.errorCount24h > 10) {
        health.status = 'degraded';
      } else if (health.avgLatency > 5000) {
        health.status = 'degraded';
      }
 
      this.healthMap.set(name, health);
      results.push(health);
    }
 
    return results;
  }
 
  // 定期推送到监控面板
  async reportToDashboard(): Promise<void> {
    const health = this.checkAll();
    const downChannels = health.filter(h => h.status === 'down');
 
    if (downChannels.length > 0) {
      // 通过任一可用通道通知我
      const msg = downChannels.map(h => `❌ ${h.channel}: 离线`).join('\n');
      await this.alertManager.send(`通道离线告警:\n${msg}`);
    }
  }
}

Copy# 通过管理后台查看通道状态
curl -s http://localhost:3000/api/health/channels | python -m json.tool

Copy{
  "channels": [
    {
      "channel": "wechat",
      "online": true,
      "lastMessageAt": "2026-01-20T14:35:00Z",
      "messageCount24h": 85,
      "errorCount24h": 2,
      "avgLatency": 1200,
      "status": "healthy"
    },
    {
      "channel": "dingtalk",
      "online": true,
      "lastMessageAt": "2026-01-20T14:33:00Z",
      "messageCount24h": 42,
      "errorCount24h": 0,
      "avgLatency": 800,
      "status": "healthy"
    },
    {
      "channel": "telegram",
      "online": true,
      "lastMessageAt": "2026-01-20T14:30:00Z",
      "messageCount24h": 56,
      "errorCount24h": 1,
      "avgLatency": 450,
      "status": "healthy"
    },
    {
      "channel": "email",
      "online": true,
      "lastMessageAt": "2026-01-20T14:00:00Z",
      "messageCount24h": 5,
      "errorCount24h": 0,
      "avgLatency": 3500,
      "status": "healthy"
    }
  ],
  "summary": {
    "total_channels": 4,
    "online_channels": 4,
    "total_messages_24h": 188,
    "overall_status": "all_healthy"
  }
}