实现会议任务自动流转协同的待办集成派单技巧

# 伪代码：统一验签中间件设计模式
class PlatformVerifier:
    STRATEGIES = {
        "lark": LarkSignVerifier,      # Header: X-Lark-Signature, X-Lark-Request-Timestamp
        "dingtalk": DingTalkSignVerifier, # Header: X-Dingtalk-Signature, Timestamp
        "wework": WeWorkSignVerifier,    # Query: msg_signature, timestamp, nonce
        "slack": SlackSignVerifier,      # Header: X-Slack-Signature, X-Slack-Request-Timestamp
    }

    @classmethod
    def verify(cls, platform: str, headers: dict, body: bytes, secret: str) -> bool:
        verifier = cls.STRATEGIES.get(platform)
        if not verifier: raise ValueError(f"Unsupported platform: {platform}")
        # 关键：校验时间戳偏移（防重放），建议容忍 ±5分钟
        return verifier(secret).verify(headers, body)

# FastAPI/Flask 集成示例
@app.post("/webhook/{platform}")
async def webhook_entry(platform: str, request: Request):
    body = await request.body()
    if not PlatformVerifier.verify(platform, request.headers, body, get_secret(platform)):
        raise HTTPException(401, "Signature verification failed")
    # 交由异步队列处理，快速返回 200 OK 避免平台侧超时重试
    await task_queue.enqueue(process_event, platform, body)
    return {"status": "accepted"}

-- Lua 脚本保证原子性
local key = "idempotent:" .. KEYS[1] -- idempotency_key
local version = ARGV[1] -- content_version
local existing = redis.call('HGET', key, 'version')
if existing and tonumber(existing) >= tonumber(version) then
    return 0 -- 旧版本或同版本，拒绝处理
end
redis.call('HSET', key, 'version', version, 'task_id', ARGV[2], 'created_at', ARGV[3])
redis.call('EXPIRE', key, 86400 * 90) -- 保留 90 天
return 1 -- 新版本，允许处理

{
  "name": "dispatch_task",
  "description": "将会议行动项派发至目标任务系统，支持多系统路由",
  "parameters": {
    "type": "object",
    "properties": {
      "routing_key": { "type": "string", "enum": ["RD_JIRA", "DESIGN_TRELLO", "OPS_FEISHU", "SALES_CRM"], "description": "路由键，由规则引擎或模型根据标签/关键词推断" },
      "title": { "type": "string", "maxLength": 200 },
      "description": { "type": "string", "description": "支持 Markdown，必须包含原文引用块 > 原文: ..." },
      "assignee_identifier": { "type": "string", "description": "工号/邮箱/手机号/用户ID，优先匹配工号" },
      "due_at": { "type": "string", "format": "date-time", "description": "ISO8601 格式，含时区" },
      "priority": { "type": "string", "enum": ["P0", "P1", "P2", "P3"] },
      "labels": { "type": "array", "items": { "type": "string" }, "maxItems": 10 },
      "custom_fields": { "type": "object", "description": "下游系统特有字段，如 Jira 的 Epic Link, Story Points" },
      "context_links": { "type": "array", "items": { "type": "string", "format": "uri" }, "description": "会议录播时间戳、文档块链接、设计稿链接" }
    },
    "required": ["routing_key", "title", "assignee_identifier", "due_at"]
  }
}

System: 你是资深项目经理助手。请根据会议纪要拆解任务。
Context:
- 当前会议参会人技能表: {retrieved_skills}
- 相关项目映射表: {retrieved_projects}
- 任务拆解规范: {retrieved_naming_rules}
- 3个相似历史案例: {retrieved_examples}
User: 会议纪要全文: {transcript}
Instruction: 请逐条拆解 Action Items，调用 dispatch_task 函数。若责任人模糊，推荐技能最匹配者并标注 needs_confirmation=true。

{
  "card_type": "task_dispatch_v2",
  "header": { "title": "📋 会议任务派单", "subtitle": "Q3 营销页重构启动会 · 3 个待办", "template": "blue" },
  "modules": [
    { "type": "section", "text": "您有 **3** 项新任务来自会议《Q3 营销页重构启动会》，请确认处理。" },
    { "type": "divider" },
    {
      "type": "task_list",
      "tasks": [
        {
          "task_local_id": "tmp_001",
          "title": "输出重构技术方案 v1.0",
          "meta": "🗓 DDL: 06/15 | 🏷 P1 | #后端 #架构",
          "evidence": { "type": "meeting_clip", "label": "查看原文片段 (12:30-14:10)", "url": "https://meet.xxx/clip/abc" },
          "actions": [
            { "type": "button", "text": "✅ 认领", "style": "primary", "action": "claim", "value": "tmp_001" },
            { "type": "button", "text": "📅 延期 3 天", "style": "default", "action": "defer", "value": "tmp_001|3d" },
            { "type": "button", "text": "↩️ 指派他人", "style": "default", "action": "reassign", "value": "tmp_001" }
          ]
        }
      ]
    },
    { "type": "action_group", "buttons": [
      { "text": "全部认领", "style": "primary", "action": "claim_all" },
      { "text": "稍后处理", "style": "default", "action": "snooze_1h" }
    ]}
  ],
  "card_link": { "url": "https://todo.xxx/meeting/123", "text": "在网页端查看完整详情" }
}

erDiagram
    MEETING ||--o{ ACTION_ITEM : produces
    ACTION_ITEM ||--|| TASK : materializes
    TASK }|--|| USER : assignee
    TASK }|--o{ TASK : depends_on / blocks / duplicates
    TASK ||--|| PROJECT : belongs_to
    TASK ||--o{ DOCUMENT : references / generates
    TASK ||--o{ CODE_COMMIT : implements
    TASK ||--o{ MEETING : discussed_in
    USER }|--o{ SKILL : has
    PROJECT ||--o{ OKR : aligns_to

{
  "audit_id": "uuid_v7",
  "timestamp": "2024-05-20T10:30:00.123Z",
  "actor": { "id": "U_1001", "type": "INTERNAL_USER", "ip": "10.0.0.1", "device_id": "mobile_xxx" },
  "action": "TASK_UPDATE",
  "resource": { "type": "TASK", "id": "TASK_999", "owner_dept": "RD_01" },
  "changes": [
    { "field": "due_at", "old": "2024-06-15T18:00:00Z", "new": "2024-06-20T18:00:00Z", "reason": "依赖上游接口延期" },
    { "field": "assignee", "old": "U_1001", "new": "U_1002", "reason": "人员调整" }
  ],
  "context": { "meeting_id": "MEET_888", "trigger": "MANUAL_UI" },
  "compliance_tags": ["PII_FREE", "FINANCIAL_DATA_FREE"],
  "signature": "ed25519_signature..." // 防篡改签名
}

meeting-task-gateway/
├── cmd/
│   ├── gateway/          # HTTP 入口 (Webhook 接收, 管理后台 API)
│   ├── worker/           # 异步任务消费者 (派单, 同步, 通知, AI 解析)
│   └── scheduler/        # 定时任务 (超期扫描, 统计聚合, 归档)
├── internal/
│   ├── adapter/          # 【核心】下游系统适配器接口与实现
│   │   ├── interfaces.go # TaskSystemAdapter 接口定义
│   │   ├── feishu/       # 飞书实现
│   │   ├── jira/         # Jira 实现
│   │   ├── dingtalk/     # 钉钉实现
│   │   └── mock/         # 单测/本地开发用 Mock 实现
│   ├── parser/           # 会议内容解析
│   │   ├── llm/          # LLM Prompt, Function Calling 定义, RAG 检索器
│   │   ├── rule/         # 正则/规则引擎兜底
│   │   └── pipeline.go   # 解析编排管线
│   ├── router/           # 派单路由规则引擎 (标签->Adapter, 技能->人)
│   ├── idempotent/       # 幂等校验组件 (Redis Lua 脚本)
│   ├── notifier/         # 统一通知发送 (卡片渲染器适配各平台)
│   ├── audit/            # 审计日志写入
│   └── domain/           # 核心领域模型 (Task, Meeting, User, Mapping)
├── pkg/
│   ├── config/           # 配置中心客户端
│   ├── logger/           # 结构化日志
│   ├── tracer/           # OpenTelemetry 链路追踪
│   └── errors/           # 统一错误码定义
├── deploy/
│   ├── docker-compose.yml # 本地全栈启动
│   ├── k8s/              # K8s 部署清单
│   └── helm/             # Helm Chart
├── scripts/
│   ├── migrate/          # 数据库迁移脚本
│   └── benchmark/        # 压测脚本
└── api/
    └── openapi.yaml      # 对外/内部 API 契约

# 本地一键启动 (含 PostgreSQL, Redis, Kafka, MinIO, Mock Jira/Feishu)
docker-compose -f deploy/docker-compose.yml up -d

# 运行网关
go run cmd/gateway/main.go -config=configs/local.yaml

# 运行 Worker (可横向扩展)
go run cmd/worker/main.go -config=configs/local.yaml