4.1 KiB
4.1 KiB
项目长期记忆 — 企业微信 RPA 自动化
项目背景
- 企业微信（WeCom）消息自动回复，核心：红点检测 → 会话定位 → 提取文本 → AI 回复 → GUI 发送。
- 企微用自定义 GPU 渲染（UIA 节点=0），无法用 UIAutomation/win32gui 内部控件查询，只能截图 + 坐标。
- 本地库（message.db 等）为 wxSQLite3 加密（文件头
4fa4c7db855d54ad），需内存提密钥 + 解密，普通 sqlite3 打不开。 - 主 GUI：
wechat_gui_qt.py（PySide6），后台运行时：gui_runtime.py（BotThread），核心：wechat_bot.py（13664 行，WeChatBot 类）。 - AI 统一入口：
ai_chat.get_ai_reply(chat_text, image_bytes, history, *, force_vision, media_types)，Dify 提供商（gpt-5.6-sol），ai_settings.json配置。
双引擎架构（2026-08-21 落地）
- 引擎 A（截图 RPA）：红点识别 → 打开会话 → 视觉提取 →
_generate_ai_reply→send_reply。发送收敛点。 - 引擎 B（数据直读，
engine_b.py）：两路并行双跑、互为兜底——① DB 直读（升级数据源）②conversations.json（引擎 A 视觉回写档案）每轮都独立检测；任一数据源有盲区另一路补漏，同一条消息靠 dedup_key 去重（fp_hex:时间戳，300s 防抖+队列级去重）只投一次 →bot.enqueue_detected()投共享队列 → 由引擎 A 的_resume_orphaned_pending_reply统一处理。B 不碰窗口。两路游标独立：_seen（JSON）/_seen_db（DB），DB 失败仅停 DB 路（db_active=False）。 - DB 直读（
wxwork_db.py，Phase 2 主线，密钥已验证）：密钥在wxwork_keys.json（2 账号：1688856770803435→db7288a302bfbe66563d81f025bde977、1688855555743233→d18e7f9a222665389989066f929ece19，其余 9 账号无密钥/未登录）。解密缓存wxwork_decrypted/，WAL 感知（帧同算法加密，可合并拿 checkpoint 前最新消息）。get_new_messages(since_ts)秒级 send_time 增量查询，is_personal_chat只留 M:/S: 单聊。fp_hex =session_fp_from_name（md5+blake2b 40 字节，与引擎 A identity_by_name 模式一致）。 - 共享队列
pending_replies.json：字段白名单读写（_load_pending_replies/_persist_pending_replies_unlocked）。新字段必须两处透传！现有 44 字段含：dedup_key（去重）、detected_by（engine_a/engine_b）、detection_ts、sending_owner、send_lock_ts。 - 发送互斥
send_lock.py：Windows 命名互斥量Global\WeChatBotSendLock+ 线程持有者跟踪。send_reply()入口抢占，拿不到即让出。 - 引擎开关（
app_settings.json，GUI「检测引擎」卡片可改）：engine_a_enabled（默认 true，注意键名不是 enable_engine_a！）、enable_engine_b（默认 true）、engine_b_poll_interval（2.0）、engine_b_data_source（parallel/db/json，非法回落 parallel）。运行时在 BotThread 启动时读取，GUI 改后本轮结束重启生效。 - 引擎 A 关闭（
engine_a_enabled=false）≠ 不回复：_poll_once(scan_unread=False)跳过红点截图扫描，但队列恢复照常，B 投递的消息仍被定位发送。
关键约定
- 队列任务 stage 状态机：queued→opening→reading→collecting→generating→ready_to_send→sending→sent，另有 manual_review/retry_wait/call_paused/uncertain。
- 发送频率限制：
MAX_SENDS_PER_MINUTE=4、MAX_SENDS_PER_HOUR=60（_send_gate）。 - 测试注意：wechat_bot.py 依赖 win32gui/mss/numpy/pyautogui，只能用系统 Python 3.11 跑（
C:\Users\pc\AppData\Local\Programs\Python\Python311\python.exe），managed python 3.13 无这些包。 - 构造最小 bot 对象用
WeChatBot.__new__(WeChatBot)+ 手工补_pending_lock/_pending_reply_sessions/_pending_reply_path/_cancelled_reply_sessions。
待办/未来方向
- Phase 2 DB 直读主线已打通（密钥就位 + WAL 合并 + 指纹对齐 + 引擎 B 集成），回归 31 项通过。剩余：长稳联跑验证（企微运行中轮询 WAL 增量 → 引擎 A 回复闭环）。
- 机器人对接口子：ai_chat（已用）/ MCP 增强（AI_MCP_ENABLED + mcp_bridge）/ 外部 Agent（mcp_server.py）。