15 - 通道集成架构

飞书卡片化回复:

  用户发消息 → Lark WebSocket Client
       │
       ▼
  FeishuBotRegistry 分发事件
       │
       ▼
  FeishuChannelService
       │
       ├── 先回复 "正在思考..."
       │
       ▼
  调用 Agent 编排器 → 获取 SSE 流
       │
       ▼
  ChannelServiceSupport.streamCollect()
       │
       ▼
  输出安全扫描 → 结果卡片 / 长回答分页 / 来源信息 / 推荐追问

  技术要点:
  · Lark WebSocket 长连接接收消息、菜单、P2P、卡片回调事件
  · ChannelServiceSupport 复用用户、会话、历史、安全扫描和 Agent 调用
  · 结果以飞书卡片呈现，支持长回答分页和推荐追问
  · 支持交互按钮: 重新生成/切换Agent/帮助

  当前边界:
  · 主链路不是逐 Token 更新卡片
  · 不是每 2 秒 PATCH 同一张卡片

每个通道的消息处理安全流程:

  入站消息
     │
     ├── 入站去重检查 (Redis SETNX)
     │   重复消息 → 丢弃
     │
     ├── 输入安全扫描 (InputScanner)
     │   危险 → 回复安全警告
     │
     ├── Agent执行
     │
     ├── 输出安全扫描 (OutputScanner)
     │   泄露 → 消毒后发送
     │
     └── 消息持久化 (数据库记录)

AbstractBotRegistry<C> 模板方法:

  ┌─────────────────────────────────────┐
  │ 通用逻辑 (父类)                     │
  │                                     │
  │ · 从数据库加载Bot配置               │
  │ · 校验配置完整性                    │
  │ · 运行状态管理                      │
  │ · saveAndRestart() 原子更新         │
  │ · 统一状态上报                      │
  └──────────────┬──────────────────────┘
                 │ 继承
  ┌──────────────▼──────────────────────┐
  │ 平台特定 (子类实现)                 │
  │                                     │
  │ FeishuBotRegistry:                  │
  │ · startBot(): 注册飞书事件回调      │
  │ · stopBot(): 取消回调注册           │
  │ · deserialize(): 解析飞书App配置    │
  │                                     │
  │ DingTalkBotRegistry:                │
  │ · startBot(): 注册钉钉Stream       │
  │ · stopBot(): 关闭Stream连接         │
  └─────────────────────────────────────┘

FeishuChannelService 消息处理流程:

  飞书 WebSocket 事件
    │
    ▼
  FeishuBotRegistry（Lark WS Client）
    │
    ▼
  FeishuChannelService
    ├─ 消息事件    → Agent执行 → 思考态文本 + 结果卡片
    ├─ P2P进入聊天 → 欢迎卡片
    ├─ 卡片动作回调 → 重新生成 / 切换Agent / 帮助
    ├─ 机器人菜单   → 菜单命令处理
    └─ 追问建议     → 推荐气泡展示

微信小程序架构:

  ┌──────────────────────────────────────────────┐
  │ hub-miniprogram (uni-app + Vue 3 + Pinia)    │
  │                                              │
  │  主包                         分包            │
  │  ├── 首页 (Agent卡片列表)    ├── 运维中心    │
  │  ├── 对话 (SSE流式)          │  ├── 数据统计  │
  │  ├── 任务 (看板)             │  ├── 系统监控  │
  │  ├── 我的 (个人中心)         │  └── 安全日志  │
  │  ├── 登录/注册               └── 管理后台    │
  │  └── 工具页面 (10+)             ├── 密钥管理  │
  │                                  └── 渠道管理  │
  └──────────────────┬───────────────────────────┘
                     │
                     ▼ HTTP + SSE (enableChunked)
  ┌──────────────────────────────────────────────┐
  │ hub-api (Spring Boot)                        │
  │                                              │
  │  AuthController       → 登录/注册/微信登录   │
  │  WxMiniAppController  → 小程序配置 CRUD      │
  │  ChatController       → 对话（共用）         │
  │  WeChatAuthService    → code2Session         │
  └──────────────────────────────────────────────┘

微信登录流程:

  用户点击"微信登录"
       │
       ▼
  wx.login() → 获取临时 code
       │
       ▼
  POST /api/auth/wx-login { appId, code }
       │
       ▼
  WeChatAuthService.code2Session(appId, code)
       │  → 查询 WxMiniAppEntity 获取 appSecret
       │  → 调用微信 API: /sns/jscode2session
       │
       ▼
  微信返回 { openid, session_key, unionid }
       │
       ├── 已绑定用户 → 直接签发 JWT
       │
       └── 未绑定 → 自动创建用户 (wx_{openid前12位})
                     → 创建 OAuth 关联
                     → 角色: wx-user, 自动审批
       │
       ▼
  返回 JWT Token → 小程序存储到 uni.setStorageSync