企微数据中转 MCP Gateway

企微数据中转 MCP Gateway

将企业微信审批 / 汇报 / 打卡数据读取能力，通过 MCP 协议暴露给 WorkBuddy/CodeBuddy。

解决痛点：WorkBuddy 的企业微信连接器只支持 MCP，且只能"新建/写入"，不支持读取历史业务数据。本服务作为数据中转层，主动从企微 OpenAPI 拉取落库，再以 MCP Server 形态暴露给 WorkBuddy 读取。

✨ 功能特性

• MCP Gateway（Streamable HTTP + Bearer Token，远程多客户连接）
• 三类数据读取：审批、汇报、打卡（智能表格一期搁置：见下方说明）
• 多租户物理隔离：每客户独立 MySQL schema（wbd_{corpid_hash}），凭证 AES 加密
• 租户级功能开关：每客户可选 report/approval/checkin 模块组合
• 打卡自动拉通讯录：配通讯录同步 secret → 自动调 user/list_id 拉全员 userid
• 增量同步：游标驱动 + 断点续传 + 幂等 UPSERT + APScheduler 定时
• 管理后台：React + Ant Design，租户 CRUD、模块开关、手动同步、单密码登录
• CI/CD：GitHub Actions 自动构建镜像推 GHCR，服务器 docker pull 免本机编译
• 生产就绪：Dockerfile + Nginx/HTTPS + systemd + 健康检查 + 日志轮转

🏗 架构

┌─ 企微 OpenAPI ──────────────────────────────────────────┐
│   审批 oa/getapprovalinfo+getapprovaldetail              │
│   汇报 oa/journal/get_record_list+get_record_detail     │
│   打卡 checkin/getcheckindata                            │
│   通讯录 user/list_id                                    │
└──────────────────────────────────────────────────────────┘
        │  ① 同步层（APScheduler 按租户调度，游标增量）
        ▼
┌─ MySQL（多租户分 schema 物理隔离）────────────────────────┐
│  中心库 websysc: tenant_config (secret AES加密)          │
│  各租户 wbd_{hash}: wecom_report/approval/checkin +     │
│                     sync_cursor + audit_log              │
└──────────────────────────────────────────────────────────┘
        │  ② MCP Gateway 暴露层（Streamable HTTP）
        ▼
   WorkBuddy / CodeBuddy
   (Bearer Token → 租户强绑定 → 读该租户 schema)
        ▲  ③ 管理后台（独立 session 鉴权）
        │
   浏览器 http://server/admin/ui/  (React+AntD)

• 生产 transport：HTTP (Streamable HTTP)，路径 /mcp
• 鉴权：MCP 用 Bearer Token（每租户独立，token→租户强绑定，不信任客户端 tenant_id）；管理后台用单密码 session
• 同步策略：一期定时轮询（增量游标），预留 Webhook 位，不引 MQ

🚀 快速开始

方式一：Docker（生产推荐，用 CI 构建的镜像）

git clone https://github.com/hkxiaoyao/wbsysc.git && cd wbsysc
cp .env.prod.example .env && vim .env    # 填 DB_PASSWORD + ADMIN_PASSWORD

docker pull ghcr.io/hkxiaoyao/wbsysc:latest
docker compose up -d
curl http://localhost:8001/health        # 期望 {"status":"ok"}

# 接入第一个租户
docker compose exec wbsysc python -m app.tenant_init \
  --tenant-id tenant1 --corpid wwXXX --secret XXX \
  --token $(openssl rand -hex 24) --contact-secret XXXX \
  --modules report,approval,checkin --display "测试客户1"

方式二：本地开发

python -m venv .venv && .venv/Scripts/activate    # Windows
pip install -r requirements.txt
cp .env.example .env                                 # 默认 mock 模式
python -m app.main                                   # 启动 (http://localhost:8001)

# 另开终端：MCP 客户端真实协议冒烟测试
python tests/test_smoke_client.py

📋 配置（.env）

租户企微凭证（corpid/secret）不进 .env，通过管理后台或 tenant_init 写入 tenant_config（AES 加密）。

🔧 MCP 工具（6 个）

WorkBuddy 连接配置

{
  "mcpServers": {
    "wecom-gateway": {
      "type": "http",
      "url": "https://<your-server>/mcp",
      "headers": { "Authorization": "Bearer ${WORKBUDDY_MCP_TOKEN}" }
    }
  }
}

代理坑点（必读）：httpx 在 Windows 会读系统级代理，localhost/内网可能被错误代理致 502。WorkBuddy 机器若有系统代理，需 NO_PROXY=mcp.example.com。

🎛 管理后台

访问 http://<server>:8001/admin/ui/，单密码登录（.env 的 ADMIN_PASSWORD）。

前端开发：cd admin-ui && pnpm install && pnpm dev（:5178 跨域代理后端）；pnpm build 产出 app/static/dist。

🏢 多租户

物理 schema 隔离：每租户独立 wbd_{corpid_md5} schema，凭证 AES-Fernet 加密存中心库。

# 接入新租户（自动建schema+5张表+刷缓存）
python -m app.tenant_init \
  --tenant-id customerA --corpid wwXXX --secret XXXX \
  --token $(openssl rand -hex 24) \
  --modules report,approval,checkin \
  --contact-secret XXXX      # 可选：通讯录同步secret，自动拉userid喂打卡
  --checkin-userids "userA"  # 可选：无通讯录secret时手动兜底

模块开关 --modules：可选 report/approval/checkin 任意组合。

打卡 userid（二选一）：自动优先（--contact-secret 调 list_id 拉全员，10分钟缓存），失败回退手动配置。

隔离保证：token→租户→schema 服务端强绑定，SQL 带 schema 前缀防连接池竞态，审计日志按租户物理分离。

🔄 同步任务

• APScheduler 启动立即首同步 + 周期遍历所有启用租户
• 增量游标存各租户 sync_cursor，断点续传
• 线程池执行不阻塞 MCP 事件循环
• 单租户/单条失败不中断整体；MAX_DETAIL_PER_RUN=500 防爆
• 打卡逐人拉取 + 容错：越权人员(301021)静默跳过不影响他人

📦 CI/CD

push 到 main 自动触发 GitHub Actions（.github/workflows/build-push.yml）：

1. 构建多阶段镜像（node 构前端 → python 运行）
2. 推到 ghcr.io/hkxiaoyao/wbsysc:latest（按 commit sha + latest 双标签）
3. 服务器 docker pull 即可，无需本机 Node/Python 编译

GHCR 私有 package 访问：公开镜像（GitHub package 页 → Package settings → Public，匿名拉取）或服务器 docker login ghcr.io。

🔐 企微接入前置（真实模式必看）

切 WECOM_USE_MOCK=false 前需在企微管理后台配置（详见 docs/企微接入配置清单.md）：

⚠️ 智能表格读取一期搁置：企微 docid 仅通过 API 创建文档可得，成员手工存量表无法获取 docid，故读取受限。

🛡 安全红线

• 凭证（corpid/secret/DB密码/ADMIN_PASSWORD）禁止硬编码，全走 .env 或 AES 加密入 DB
• .env 在 .gitignore，永不提交（仓库内只有 .env.example/.env.prod.example 模板）
• 客户授权完成前：仅 mock/脱敏数据，不长期保存客户原始数据，不接生产库
• 上线必做：DB 强密码 / CREDENTIAL_KEY 强随机 / 企微 secret 重签 / ADMIN_PASSWORD 改强

📁 项目结构

app/
  config.py / auth.py / db.py / main.py        # 配置/鉴权/数据层/入口
  admin.py                                       # 管理后台 API
  crypto.py / tenant.py / tenant_init.py        # 凭证加解密/租户查询/接入脚本
  mcp_server.py                                  # 6 个 MCP 工具
  wecom/
    client.py                                    # 企微API客户端(token缓存隔离双secret)
    sync.py / approval_sync.py / checkin_sync.py # 三类同步(分段+游标+去重)
    contact.py                                   # 通讯录userid自动拉
    dispatch.py                                  # 多租户调度遍历
    mock.py                                      # 脱敏mock数据
admin-ui/                                        # React+Vite+Ant Design 管理前端
sql/                                             # 建表脚本
deploy/                                          # nginx.conf / server_deploy.sh / wbsysc.service
.github/workflows/                               # CI 构建镜像
docs/                                            # 架构计划/企微接入清单/部署指南
tests/test_smoke_client.py                       # MCP 客户端冒烟测试

📚 文档

• 完整架构计划：docs/PLAN-wecom-mcp-gateway.md
• 企微接入配置清单：docs/企微接入配置清单.md
• 部署指南：docs/部署指南.md

🔧 技术栈

• 后端：Python 3.11 + FastAPI + 官方 MCP Python SDK + SQLAlchemy + APScheduler + httpx
• 前端：React 18 + Vite + Ant Design 5
• 存储：MySQL 5.7+（多租户分 schema）+ 可选 Redis（token缓存）
• 部署：Docker + docker-compose + Nginx/HTTPS + systemd
• CI：GitHub Actions → GHCR