Pipeline 并行化 Plan

当前问题

hermes chat (单进程，300s timeout)
  ├─ 查询微信消息 → 发现 N 篇文章
  ├─ check-summaries → 发现 M 篇未缓存
  ├─ 对第 1 篇: curl POST /summarize → 等 60s
  ├─ 对第 2 篇: curl POST /summarize → 等 60s
  ├─ ... (串行！)
  ├─ 对第 M 篇: curl POST /summarize → 等 60s
  └─ 编撰日报

瓶颈: M 篇未缓存文章 → 串行等待 M×60s → 超过 300s timeout → 部分文章丢失或超时

改进方案：两阶段流水线

Phase 1: 并行摘要 (Flask 编排)
  hermes chat (collector)
    └─ 查询消息 → 返回文章列表
  ↓
  Flask: 对每篇未缓存文章并行 POST /summarize
  ├─ hermes job: 文章 1 摘要  ─┐
  ├─ hermes job: 文章 2 摘要  ─┤ 并行!
  └─ hermes job: 文章 M 摘要  ─┘
  ↓ 所有完成
Phase 2: 日报编撰 (单个 hermes)
  hermes chat (compiler)
    └─ 读取所有缓存摘要 → 编撰日报

改进点:

• M 篇文章摘要并行执行，总耗时 ≈ max(单篇耗时) 而非 sum
• Phase 1 collector 不需要处理摘要，只收集 URL → 快速完成
• Phase 2 compiler 只读缓存 → 不需要网络抓取 → 快速完成
• 每阶段独立追踪（任务监控可见）

实现步骤

Step 1: app.py 新增 /api/reports/generate-v2

• 接收 chatroom_id + date
• Phase 1a: spawn collector job → 返回文章列表
• Phase 1b: 并行 spawn summarize jobs
• Phase 1c: 轮询等待全部完成
• Phase 2: spawn compiler job → 生成日报

Step 2: 前端 reports.html 使用新 API

• "生成日报"按钮改为调用 generate-v2
• 显示流水线进度（X/Y 篇文章摘要完成）

Step 3: 任务监控可见

• 每个子任务独立显示在 /jobs
• 可看到 collector / summarizer×N / compiler 的完整链路

涉及文件

• app.py: 新增 /api/reports/generate-v2 + 并行编排逻辑
• wechat-group-digest skill: 拆分为 collector / compiler 两个子 prompt
• templates/reports.html: 进度展示
• test_jobs_integration.py: 新增流水线测试

风险

• 并行摘要受限于 hermes 并发数（同一用户可同时跑多个 hermes chat？）
• Phase 1c 轮询需要非阻塞实现（用 threading + sleep poll）