┌──────────────────── BullMQ ────────────────────────────┐
│                                                         │
│  Queue: wechatPoll                                      │
│  ┌──────┐   ┌──────┐   ┌──────┐                       │
│  │ poll │   │ poll │   │ poll │   ...                   │
│  │ ch_1 │   │ ch_2 │   │ ch_3 │                        │
│  └──┬───┘   └──┬───┘   └──┬───┘                       │
│     │          │          │                             │
│     └──────────┴──────────┘                             │
│                │                                        │
│         Worker (concurrency: 10)                        │
│                │                                        │
│     ┌──────────┴──────────┐                             │
│     │  1. getUpdates()    │                             │
│     │  2. 按用户分组合并   │                             │
│     │  3. outlinkInvokeChat│                            │
│     │  4. sendMessage()   │                             │
│     │  5. 更新 buf        │                             │
│     │  6. 自链: queue.add │  ←── 完成后立刻创建下一个    │
│     └─────────────────────┘                             │
│                                                         │
└─────────────────────────────────────────────────────────┘

多节点部署:
  Node A ──┐
  Node B ──┼── 同一个 Redis ── 同一个 Queue
  Node C ──┘    BullMQ 自动保证同一个 Job 只被一个 Worker 消费

渠道上线（扫码登录成功）
    │
    ▼
queue.add('poll', { shareId }, { jobId: `wechat-poll-${shareId}-${ts}` })
    │
    ▼
Worker 消费 Job
    │
    ├── 1. 从数据库读取 buf 和 token
    ├── 2. 检查渠道状态（离线 → 不续链，轮询自然停止）
    ├── 3. 调用 ilink getUpdates(buf)（长轮询，最多 35 秒）
    ├── 4. 收到消息 → groupMessagesByUser → 合并文本
    ├── 5. 对每组调用 outlinkInvokeChat → sendMessage 回复
    ├── 6. 更新 buf 到数据库
    └── 7. 自链: queue.add 创建下一个 Job

上线: 扫码成功 → status='online' → queue.add(首个 Job)
下线: 用户登出/删除 → status='offline' → Worker 检测后不续链
异常: 连续失败 ≥5 次 → status='error' → 不续链
重连: 用户重新扫码 → 清空 syncBuf → 同上线流程

// packages/global/support/outLink/type.ts
export const WechatAppSchema = z.object({
  token: z.string().default(''),
  baseUrl: z.string().default('https://ilinkai.weixin.qq.com'),
  accountId: z.string().default(''),
  userId: z.string().optional(),
  syncBuf: z.string().default(''),
  status: z.enum(['online', 'offline', 'error']).default('offline'),
  loginTime: z.string().optional(),
  lastError: z.string().optional()
});
export type WechatAppType = z.infer<typeof WechatAppSchema>;

// packages/service/support/outLink/wechat/type.ts
export type WechatPollJobData = { shareId: string };

// packages/service/support/outLink/schema.ts
OutLinkSchemaType.index({ shareId: -1 });
OutLinkSchemaType.index({ teamId: 1, tmbId: 1, appId: 1 });
// 条件索引: 仅索引 wechat online 渠道，用于服务重启恢复
OutLinkSchemaType.index(
  { type: 1, 'app.status': 1 },
  { partialFilterExpression: { type: 'wechat', 'app.status': 'online' } }
);