37c 多维表格自动化

# setup-bitable
 
初始化 HackQuest 项目管理多维表格，创建需求表、缺陷表、迭代表、人员表。
 
## 触发条件
用户消息包含"初始化表格"、"创建项目表格"、"setup bitable"。
 
## 执行步骤
1. 调用 lark-mcp 创建一个新的多维表格应用，名称为"HackQuest 项目管理"
2. 在该应用中依次创建 4 张表：需求表、缺陷表、迭代表、人员表
3. 为每张表按照预定义 Schema 创建字段
4. 在需求表和缺陷表之间建立关联关系
5. 在需求表和迭代表之间建立关联关系
6. 创建完成后，将多维表格的 app_token 写入记忆，供后续 Skill 使用
7. 在飞书群发送创建成功的通知，附上多维表格链接
 
## 字段定义
 
### 需求表字段
- 标题（文本）
- 描述（多行文本）
- 优先级（单选：P0, P1, P2, P3）
- 状态（单选：待评审, 已通过, 设计中, 开发中, 测试中, 待部署, 已上线, 已关闭）
- 负责人（人员）
- 所属模块（单选：课程, Hackathon, 社区, 基础设施, 运营）
- PRD 链接（超链接）
- 预计工时（数字）
- 实际工时（数字）
 
### 缺陷表字段
- 标题（文本）
- 描述（多行文本）
- 严重程度（单选：S0-致命, S1-严重, S2-一般, S3-轻微）
- 状态（单选：待确认, 已确认, 修复中, 待验证, 已关闭）
- 负责人（人员）
- 环境（多选：生产, 预发, 测试）
 
### 迭代表字段
- 迭代名称（文本）
- 开始日期（日期）
- 结束日期（日期）
- 状态（单选：规划中, 进行中, 已完成）
- 目标（多行文本）
 
### 人员表字段
- 姓名（文本）
- 角色（单选：前端, 后端, 产品, 设计, 测试, 运维, 运营）
- 部门（单选：产品部, 工程部, 运营部, 人事部）
- 飞书 ID（文本）
- GitHub ID（文本）
- 入职日期（日期）
- 状态（单选：在职, 离职, 试用期）
 
## 输出格式
创建成功后回复：
✅ 项目管理表格已创建完成
- 需求表：[链接]
- 缺陷表：[链接]
- 迭代表：[链接]
- 人员表：[链接]
 
## 权限要求
- 飞书多维表格写入权限（bitable:app）

{
  "tool": "create_bitable_record",
  "arguments": {
    "app_token": "bascnxxxxxxxxxx",
    "table_id": "tblxxxxxxxxxx",
    "fields": {
      "标题": "新增 Solana 课程模块",
      "描述": "背景：用户对 Solana 生态学习需求增长，需要新增完整的 Solana 开发课程。\n验收标准：包含 Solana 基础、智能合约、DApp 开发三个阶段。",
      "优先级": "P1",
      "状态": "待评审",
      "所属模块": "课程"
    }
  }
}

{
  "tool": "list_bitable_records",
  "arguments": {
    "app_token": "bascnxxxxxxxxxx",
    "table_id": "tblxxxxxxxxxx",
    "filter": {
      "conjunction": "and",
      "conditions": [
        { "field_name": "状态", "operator": "is", "value": ["开发中"] },
        { "field_name": "迭代", "operator": "is", "value": ["Sprint 2026-W28"] }
      ]
    },
    "sort": [
      { "field_name": "优先级", "order": "asc" }
    ]
  }
}

{
  "tool": "update_bitable_record",
  "arguments": {
    "app_token": "bascnxxxxxxxxxx",
    "table_id": "tblxxxxxxxxxx",
    "record_id": "recxxxxxxxxxx",
    "fields": {
      "状态": "测试中"
    }
  }
}

{
  "tool": "batch_create_bitable_records",
  "arguments": {
    "app_token": "bascnxxxxxxxxxx",
    "table_id": "tblxxxxxxxxxx",
    "records": [
      {
        "fields": {
          "标题": "Solana 基础概念课程",
          "优先级": "P1",
          "状态": "待评审",
          "所属模块": "课程"
        }
      },
      {
        "fields": {
          "标题": "Solana 智能合约开发课程",
          "优先级": "P1",
          "状态": "待评审",
          "所属模块": "课程"
        }
      }
    ]
  }
}

# requirement-status-change
 
监听需求表状态变更事件，自动触发对应的下一步操作。
 
## 触发条件
飞书多维表格记录变更事件（drive.file.bitable_record_changed_v1），
且变更的表为需求表，且变更的字段包含"状态"。
 
## 执行步骤
 
### 状态：待评审 → 已通过
1. 在需求评审群发送通知："需求 [标题] 已通过评审，负责人 [负责人]"
2. 自动创建设计任务（如果需要设计）
3. 更新记忆中的需求状态
 
### 状态：已通过 → 开发中
1. 通知开发负责人
2. 检查是否有关联的 GitHub Issue，如果没有则自动创建
 
### 状态：开发中 → 测试中
1. 通知测试负责人
2. 关联相关 PR 信息
 
### 状态：测试中 → 待部署
1. 通知运维团队
2. 生成部署清单
 
### 状态：待部署 → 已上线
1. 在项目群发送上线通知
2. 更新迭代完成率
 
## 权限要求
- 飞书消息发送权限
- 飞书多维表格读取权限
- GitHub MCP（创建 Issue）

## 事件过滤
- 只处理需求表和缺陷表的变更，忽略人员表和迭代表的变更
- 只处理"状态"字段的变更，忽略其他字段的修改
- 忽略 Agent 自身触发的变更（通过操作人 ID 判断），避免循环触发

-- 需求表
CREATE TABLE requirements (
  id SERIAL PRIMARY KEY,
  bitable_record_id VARCHAR(50) UNIQUE NOT NULL,  -- 多维表格记录 ID
  title VARCHAR(200) NOT NULL,
  description TEXT,
  priority VARCHAR(10),  -- P0/P1/P2/P3
  status VARCHAR(20),
  assignee VARCHAR(100),
  module VARCHAR(50),
  sprint_name VARCHAR(50),
  prd_link TEXT,
  estimated_hours DECIMAL(5,1),
  actual_hours DECIMAL(5,1),
  created_at TIMESTAMP DEFAULT NOW(),
  updated_at TIMESTAMP DEFAULT NOW(),
  synced_at TIMESTAMP DEFAULT NOW()  -- 最后同步时间
);
 
-- 缺陷表
CREATE TABLE bugs (
  id SERIAL PRIMARY KEY,
  bitable_record_id VARCHAR(50) UNIQUE NOT NULL,
  title VARCHAR(200) NOT NULL,
  description TEXT,
  severity VARCHAR(20),  -- S0/S1/S2/S3
  status VARCHAR(20),
  assignee VARCHAR(100),
  requirement_id INTEGER REFERENCES requirements(id),
  environment TEXT[],  -- PostgreSQL 数组类型
  created_at TIMESTAMP DEFAULT NOW(),
  fixed_at TIMESTAMP,
  synced_at TIMESTAMP DEFAULT NOW()
);
 
-- 迭代表
CREATE TABLE sprints (
  id SERIAL PRIMARY KEY,
  bitable_record_id VARCHAR(50) UNIQUE NOT NULL,
  name VARCHAR(50) NOT NULL,
  start_date DATE,
  end_date DATE,
  status VARCHAR(20),
  goal TEXT,
  synced_at TIMESTAMP DEFAULT NOW()
);
 
-- 人员表
CREATE TABLE team_members (
  id SERIAL PRIMARY KEY,
  bitable_record_id VARCHAR(50) UNIQUE NOT NULL,
  name VARCHAR(100) NOT NULL,
  role VARCHAR(50),
  department VARCHAR(50),
  feishu_id VARCHAR(100),
  github_id VARCHAR(100),
  join_date DATE,
  status VARCHAR(20),
  synced_at TIMESTAMP DEFAULT NOW()
);
 
-- 索引
CREATE INDEX idx_requirements_status ON requirements(status);
CREATE INDEX idx_requirements_sprint ON requirements(sprint_name);
CREATE INDEX idx_requirements_assignee ON requirements(assignee);
CREATE INDEX idx_bugs_status ON bugs(status);
CREATE INDEX idx_bugs_severity ON bugs(severity);

# sync-bitable-to-pg
 
定时将飞书多维表格数据同步到 PostgreSQL 分析层。
 
## 触发条件
- 定时触发：每小时执行一次
- 手动触发：用户消息包含"同步数据"、"sync data"
 
## 执行步骤
1. 从记忆中读取多维表格 app_token 和各表 table_id
2. 通过 lark-mcp 读取需求表全部记录
3. 对比 PostgreSQL 中已有记录（通过 bitable_record_id 匹配）
4. 执行 UPSERT 操作：新记录插入，已有记录更新
5. 对缺陷表、迭代表、人员表重复步骤 2-4
6. 记录同步结果到记忆（同步时间、记录数、变更数）
7. 如果同步失败，在飞书群发送告警
 
## 同步策略
- 使用 bitable_record_id 作为唯一标识进行 UPSERT
- 只同步最近 24 小时有变更的记录（增量同步）
- 每周日凌晨执行一次全量同步
- 同步过程中不阻塞其他 Skill 执行
 
## 错误处理
- 单条记录同步失败不影响其他记录
- 连续 3 次同步失败后发送告警到运维群

-- 需求表 UPSERT
INSERT INTO requirements (
  bitable_record_id, title, description, priority, status,
  assignee, module, sprint_name, prd_link,
  estimated_hours, actual_hours, updated_at, synced_at
) VALUES (
  $1, $2, $3, $4, $5, $6, $7, $8, $9, $10, $11, NOW(), NOW()
)
ON CONFLICT (bitable_record_id) DO UPDATE SET
  title = EXCLUDED.title,
  description = EXCLUDED.description,
  priority = EXCLUDED.priority,
  status = EXCLUDED.status,
  assignee = EXCLUDED.assignee,
  module = EXCLUDED.module,
  sprint_name = EXCLUDED.sprint_name,
  prd_link = EXCLUDED.prd_link,
  estimated_hours = EXCLUDED.estimated_hours,
  actual_hours = EXCLUDED.actual_hours,
  updated_at = NOW(),
  synced_at = NOW();

-- 当前迭代需求完成率
SELECT
  s.name AS sprint,
  COUNT(*) AS total,
  COUNT(*) FILTER (WHERE r.status = '已上线') AS completed,
  ROUND(COUNT(*) FILTER (WHERE r.status = '已上线') * 100.0 / COUNT(*), 1) AS completion_rate
FROM requirements r
JOIN sprints s ON r.sprint_name = s.name
WHERE s.status = '进行中'
GROUP BY s.name;
 
-- 各模块缺陷密度
SELECT
  r.module,
  COUNT(DISTINCT r.id) AS requirement_count,
  COUNT(DISTINCT b.id) AS bug_count,
  ROUND(COUNT(DISTINCT b.id) * 1.0 / NULLIF(COUNT(DISTINCT r.id), 0), 2) AS bug_density
FROM requirements r
LEFT JOIN bugs b ON b.requirement_id = r.id
GROUP BY r.module
ORDER BY bug_density DESC;
 
-- 团队成员工作负载
SELECT
  tm.name,
  tm.role,
  COUNT(r.id) FILTER (WHERE r.status IN ('开发中', '测试中')) AS active_tasks,
  SUM(r.estimated_hours) FILTER (WHERE r.status IN ('开发中', '测试中')) AS estimated_hours
FROM team_members tm
LEFT JOIN requirements r ON r.assignee = tm.name
WHERE tm.status = '在职'
GROUP BY tm.name, tm.role
ORDER BY active_tasks DESC;