09 - 通道集成架构

飞书流式卡片回复 (2秒刷新):

  用户发消息 → FeishuChannelService
       │
       ▼
  创建"思考中"卡片 (显示动画)
       │
       ▼
  调用Agent编排器 → 获取SSE流
       │
       ▼
  Flux.buffer(Duration.ofSeconds(2))  ← 每2秒批量刷新
       │
       ├── 0s: "正在分析中..." (思考卡片)
       ├── 2s: "我来帮你看看这份简历，首先..." (更新卡片)
       ├── 4s: "其次，你的项目经验可以这样优化..." (继续更新)
       ├── 6s: "最后，建议你..." (最终卡片)
       └── 完成: 完整回复 + 推荐追问气泡

  技术要点:
  · 使用飞书卡片API的PATCH更新
  · 每2秒批量聚合SSE事件，减少API调用
  · 添加"继续对话"推荐气泡
  · 支持交互按钮: 重新生成/切换Agent/帮助

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

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

AbstractBotRegistry<C> 模板方法:

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

FeishuChannelService 消息处理流程:

  飞书Webhook事件
    │
    ▼
  FeishuBotController（接收Webhook）
    │
    ▼
  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