微信自动应答 Pipeline
执行流程图
┌──────────────────────────────────┐
│ 定时触发 (每10秒) │
└───────────────┬──────────────────┘
│
▼
┌──────────────────────────────────┐
│ Stage 1: 检查在线状态 │
│ skill: wechat-check-online │
│ → data=true → 继续 │
│ → data=false → 停止等待重连 │
└───────────────┬──────────────────┘
│
▼
┌──────────────────────────────────┐
│ Stage 2: 增量拉取新消息 │
│ skill: wechat-get-messages │
│ input: since=上次检查时间 │
│ direction=received │
│ → 返回新消息数组 │
└───────────────┬──────────────────┘
│
▼
┌──────────────────────────────────┐
│ Stage 3: 遍历每条新消息 │
│ 过滤: 跳过系统消息/表情/自己发的 │
│ 过滤: 跳过 weixin/fmessage 等 │
└───────┬───────────────┬──────────┘
│ │
▼ ▼
┌──────────────┐ ┌──────────────┐
│ 个人私聊 │ │ 群聊 │
│ fromWxid │ │ @chatroom │
│ 不含@chatroom│ │ │
└──────┬───────┘ └──────┬───────┘
│ │
▼ ▼
┌──────────────┐ ┌──────────────────┐
│ AI生成回复 │ │ 检查是否被@或关键词│
│ 友好个性化 │ │ 触发才回复 │
└──────┬───────┘ └──────┬───────────┘
│ │
▼ ▼
┌──────────────────────────────────┐
│ Stage 4: 发送回复 │
│ skill: wechat-send-text │
│ input: toWxid, content │
└──────────────────────────────────┘
消息来源分类规则
| fromWxid 格式 |
来源类型 |
存储目录 |
回复策略 |
wxid_xxx |
个人私聊 |
personal/{wxid}.jsonl |
每条消息都回复 |
xxx@chatroom |
群聊 |
group/{chatroom}.jsonl |
仅被@或关键词触发时回复 |
gh_xxx |
公众号 |
忽略 |
不回复 |
weixin/fmessage |
系统 |
忽略 |
不回复 |
回复策略
个人私聊
- 文字消息 → AI生成个性化回复
- 图片/语音/视频 → 回复确认（"收到图片~"）
- 名片/位置/链接 → 回复确认
群聊
- 被@时 → AI生成回复
- 包含关键词（"帮我"/"请问"）→ AI生成回复
- 其他消息 → 不回复，避免刷屏
忽略列表
- 消息类型: system, emoji, location, video, voice
- 来源wxid: weixin, fmessage, medianote, gh_* (公众号)
状态管理
| 状态变量 |
说明 |
lastCheckTime |
上次轮询时间(ISO)，用于 since 增量拉取 |
每次轮询完成后更新 lastCheckTime = 当前时间，下次只拉新消息。
