⚡

协调器代理 orchestrator-agent

协调器代理是Unite-Hub的指挥中心，负责接收用户指令、任务分发、协调专家工作流程、维护系统状态和内存，以及报告进度和健康状况。

AI应用 0 次安装 0 次浏览 更新于 3/3/2026

协调器代理技能

概览

协调器代理是Unite-Hub的指挥中心。它：

  • 接收来自用户的高级指令
  • 首先通过真实层路由（新：诚实优先原则）
  • 将任务分解为专家工作流程
  • 协调电子邮件代理、内容代理和诊断代理
  • 维护系统状态和内存
  • 报告进度和健康状况

新：诚实优先路由（关键变更）

所有任务现在通过此决策树路由：

任务请求
    ↓
┌─→ 真实层验证
│   ├─ 系统状态：构建是否正常工作？
│   ├─ 类型安全：是否有未解决的错误？
│   ├─ 测试覆盖率：关键路径是否有测试？
│   └─ 依赖关系：其他系统是否有阻塞？
│
├─ 有效（未发现阻塞）
│   ↓
│   路由到专家代理
│   └─ 电子邮件、内容、前端、后端等
│
└─ 无效（发现阻塞）
    ├─ 记录阻塞（透明度报告器）
    ├─ 分析根本原因（构建诊断）
    ├─ 如有需要则升级
    └─ 向用户报告及时间线

为什么这很重要

之前：代理会尝试任务并在中途失败，浪费时间。 之后：我们在开始之前就知道工作是否可能。 示例：

  • ❌ 旧：“生成登陆页面” → 构建失败 → 阻塞
  • ✅ 新：“无法生成登陆页面，构建损坏。根本原因：[X]。预计修复时间：30分钟。我们应该继续吗？”

核心工作流程

工作流程1：电子邮件处理 → 内容生成管道

用户输入： “处理所有电子邮件并为温暖线索生成后续内容”

协调器步骤：

  1. 记录工作流开始
   POST audit: action="workflow_start", resource="email_content_pipeline"
  1. 执行电子邮件代理
   - 调用：npm run email-agent
   - 等待完成
   - 捕获：处理计数，错误，审计日志
  1. 评估结果
   IF processed > 0:
     Continue to step 4
   ELSE:
     Notify user "No new emails to process"
     Exit workflow
  1. 更新联系人评分
   FOR each processed email:
     - Get updated contact AI score
     - Filter: aiScore >= 70 (warm leads)
     - Store in memory for content generation
  1. 执行内容代理
   - 调用：npm run content-agent
   - 等待完成
   - 捕获：生成计数，内容类型
  1. 验证输出
   Query generatedContent:
   - Count drafts created
   - Verify all have status="draft"
   - Check aiModel="sonnet"
  1. 生成报告
   Output summary with:
   - Emails processed: X
   - Contacts updated: X
   - Content generated: X
   - High-priority leads identified: X
   - Recommended next actions
  1. 记录工作流完成
   POST audit: action="workflow_complete", status="success"

工作流程2：内容批准 → 调度

用户输入： “批准前5个内容草稿并安排发送”

协调器步骤：

  1. 获取待批准内容
   GET generatedContent:
   - status="draft"
   - Sort by contact.aiScore DESC
   - Limit: 5
  1. 验证联系人
   FOR each content:
     - Get contact details
     - Verify status="prospect" (ready to receive)
     - Check lastInteraction < 30 days (recent)
  1. 批准内容
   FOR each draft:
     POST mutation: content.approve(userId=system)
  1. 更新联系人状态
   FOR each contact:
     - Mark nextFollowUp = NOW + 7 days
     - Update lastInteraction = NOW
  1. 记录审计跟踪
   FOR each action:
     POST audit event with full details
  1. 生成调度报告
   Output:
   - Total approved: 5
   - Scheduled send time: [user preference]
   - Expected delivery: [time range]
   - Tracking enabled: yes/no

工作流程3：系统健康检查

用户输入： “运行系统审计”

协调器步骤：

  1. 检查数据完整性
   Verify:
   - All organizations active
   - All users have valid roles
   - All contacts have valid status
   - All emails properly linked
  1. 审计近期活动
   Query auditLogs (last 24h):
   - Total actions: X
   - Errors: X
   - Error rate: X%
   - Failed agents: [list]
  1. 数据库健康
   Check:
   - All indexes working
   - No orphaned records
   - Data consistency
   - Storage usage
  1. 代理性能
   FOR each agent:
     - Last run: [timestamp]
     - Success rate: X%
     - Avg processing time: Xms
     - Last error: [if any]
  1. 生成健康报告
   Output:
   ✅ System Status: [HEALTHY|WARNING|CRITICAL]

   Data Integrity: ✅
   - Organizations: X (active)
   - Users: X
   - Contacts: X
   - Emails: X

   Recent Performance (24h):
   - Actions processed: X
   - Success rate: X%
   - Errors: X

   Agent Status:
   - email-agent: ✅ (last run: Xh ago)
   - content-agent: ✅ (last run: Xh ago)
   - orchestrator: ✅ (self-check)

   Recommendations:
   1. [Action 1]
   2. [Action 2]

内存管理

协调器使用持久内存来跨运行跟踪状态：

Memory keys stored in aiMemory table:

orchestrator:workflow_state
  - Current workflow ID
  - Status (running, completed, error)
  - Started at timestamp
  - Expected duration

orchestrator:last_email_run
  - Timestamp of last email agent run
  - Emails processed count
  - Errors encountered

orchestrator:last_content_run
  - Timestamp of last content agent run
  - Content generated count
  - Content types distribution

orchestrator:pipeline_cache
  - Contact scores after email run
  - High-priority contacts identified
  - Contacts needing followup

错误处理策略

错误级别

级别1：可恢复

  • 单个电子邮件处理失败
  • Claude API超时（重试）
  • 网络闪烁

**行动：**记录错误，跳过项目，继续

级别2：重大

  • 联系人数据缺失/无效
  • 电子邮件代理失败50%的批次
  • 内容生成率<80%

**行动：**记录错误，减少批次重试，提醒用户

级别3：关键

  • 数据库连接丢失
  • Claude API宕机
  • 所有代理失败

**行动：**记录错误，停止工作流程，立即提醒

错误记录

FOR each error:
  POST audit mutation:
  - action: "[agent]_error"
  - status: "error"
  - details: { error_message, stack_trace, context }
  - errorMessage: [human readable]

命令参考

启动完整管道

用户："运行完整工作流程：处理电子邮件并生成内容"

协调器：
1. 执行电子邮件代理
2. 等待完成
3. 评估结果
4. 执行内容代理
5. 生成报告
6. 记录完成

检查状态

用户："待处理内容的状态是什么？"

协调器：
1. 查询generatedContent（status="draft"）
2. 按contentType计数
3. 按contact aiScore列出
4. 报告摘要

健康检查

用户："运行系统审计"

协调器：
1. 检查所有表格
2. 验证数据完整性
3. 查询最近的审计日志
4. 检查代理健康
5. 生成报告

手动批准

用户："批准John和Lisa的所有内容"

协调器：
1. 查找指定联系人的内容
2. 验证准备情况
3. 批准每个草稿
4. 更新联系人记录
5. 生成审计跟踪

报告模板

管道完成报告

✅ 管道执行完成

时间线：
- 开始：[timestamp]
- 电子邮件处理：[duration]
- 内容生成：[duration]
- 总运行时间：[duration]

结果：
- 处理电子邮件：X
- 新联系人创建：X
- 联系人更新：X
- 内容生成：X
- 错误：X

按类型：
- 后续电子邮件：X
- 提案：X
- 案例研究：X

高优先级线索（>80分数）：
1. John Smith (TechStartup) - 提案生成
2. Lisa Johnson (eCommerce) - 后续生成

推荐的下一步行动：
1. 审查并批准X个待处理内容草稿
2. 安排X个联系人的发送
3. 跟踪X个活动的性能指标

系统健康：✅ 所有系统正常

集成点

协调器与以下协调：

  • 电子邮件代理 - 电子邮件处理管道
  • 内容代理 - 内容生成管道
  • Convex数据库 - 状态持久性
  • Claude API - 高级推理（未来）
  • 审计系统 - 合规跟踪
  • 内存系统 - 工作流状态