feat(wechat-auto-reply): 环节4 策略引擎 + wechat-viewer 审批/白名单 UI

wechat_reply_policy.py：确定性安全闸 decide()→skip|auto|review，default-deny +敏感词硬override(钱/承诺/约时间白名单也拉回)，demo 8/8 过。配置与审批 UI 落在手机端 ~/wechat-viewer(Flask)：新表 reply_whitelist/reply_queue、/whitelist 白名单页、/approvals 审批页(可编辑草稿+发送/取消)，发送复用 send_text_via_hook。真机验证白名单增删查、发送到 filehelper(sent)、取消(cancelled) 全通。viewer 改动全文见 wechat-viewer-changes.md + viewer_templates/（不复制用户整个 app）。 Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

feat(wechat-auto-reply): 环节4 策略引擎 + wechat-viewer 审批/白名单 UI
wechat_reply_policy.py：确定性安全闸 decide()→skip|auto|review，default-deny +敏感词硬override(钱/承诺/约时间白名单也拉回)，demo 8/8 过。配置与审批 UI 落在手机端 ~/wechat-viewer(Flask)：新表 reply_whitelist/reply_queue、/whitelist 白名单页、/approvals 审批页(可编辑草稿+发送/取消)，发送复用 send_text_via_hook。真机验证白名单增删查、发送到 filehelper(sent)、取消(cancelled) 全通。viewer 改动全文见 wechat-viewer-changes.md + viewer_templates/（不复制用户整个 app）。 Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
yibo
1 parent 252f05f4
Showing 5 changed files with 417 additions and 1 deletions
md/wechat-auto-reply-requirements.md
wechat_plain/scripts/auto-reply/viewer_templates/approvals.html
wechat_plain/scripts/auto-reply/viewer_templates/whitelist.html
wechat_plain/scripts/auto-reply/wechat-viewer-changes.md
wechat_plain/scripts/auto-reply/wechat_reply_policy.py
@@ -77,7 +77,17 @@
 - ⚠️ 观察：SOUL.md 那句「约时间交本人确认」是**软约束**，约饭案例里模型仍主动接话——真正的自动/审核安全门必须落在**环节4 策略层**，不能只靠人设。
 - 待办：一次结构化调用同时出 `{should_reply, confidence, draft, risk_flags}` 留给环节4 一起做。
-### 环节 4 · 自动 vs 审核 —— **白名单直发，其余进 viewer 待回复**
+### 环节 4 · 自动 vs 审核 —— ✅ **确定性策略引擎 + viewer 审批/白名单 UI（2026-07-10）**
+- **策略引擎**（代码，非 LLM 判）`wechat_plain/scripts/auto-reply/wechat_reply_policy.py`：`decide(event,draft,confidence)` → `skip|auto|review`。default-deny + 硬安全 override：群未@我/公众号/系统消息/自己发的/模型说别回 → skip；命中敏感词(钱/承诺/约时间/隐私,白名单也拉回)或低置信 → review；仅白名单+总开关开 → auto；其余 → review。demo 8/8 通过。
+- **配置 + 审批 UI 落在手机端 `~/wechat-viewer`（Flask）**，非独立文件（详见 `wechat-viewer-changes.md`）：
+  - 新表 `reply_whitelist` + `reply_queue`（`local_db.py`）。
+  - `/whitelist` 白名单管理页；`/approvals` 审批页（待审列表 + **可编辑草稿** + 【发送】【取消】）。
+  - 发送复用 `send_text_via_hook`（LSPosed 内部 API）。
+  - 真机验证：白名单增删查、审批发送到 filehelper(status=sent)、取消(cancelled) 全通。
+- ⚠️ 印证环节3 的发现：安全门是**确定性代码**（敏感词硬拦），不靠人设软约束。
+- 待接：编排器把环节1 队列串到策略+队列（见环节5）。
+
+### （原）环节 4 · 自动 vs 审核 —— **白名单直发，其余进 viewer 待回复**
 - **白名单**（联系人 / 群 / 群里某发言人）+ 生成成功 → **直接发送**。
 - **非白名单** → 写入 **Pixel 本地 wechat viewer 的"待回复列表"**，人工点击"发送"才真正发出。
 - 落地新增：①「待回复队列」存储（sqlite/json）；② wechat viewer 的"发送"按钮接到发送链路。
+{% extends "base.html" %}
+{% block title %}自动回复审批 - WeChat Viewer{% endblock %}
+{% block body %}
+<style>
+body{overflow-y:auto!important;height:auto!important;}
+.ap-container{max-width:960px;margin:0 auto;padding:20px;}
+.ap-header{display:flex;align-items:center;justify-content:space-between;margin-bottom:16px;}
+.ap-header h1{font-size:20px;color:#2c3e50;}
+.btn-refresh{background:#95a5a6;color:white;padding:6px 14px;border:none;border-radius:6px;cursor:pointer;font-size:13px;}
+.tabs{display:flex;gap:8px;margin-bottom:16px;flex-wrap:wrap;}
+.tab{padding:6px 14px;border-radius:6px;cursor:pointer;font-size:13px;border:1px solid #ddd;background:white;}
+.tab.active{background:#2c3e50;color:white;border-color:#2c3e50;}
+.ap-card{background:white;border-radius:8px;padding:14px 18px;margin-bottom:10px;box-shadow:0 1px 2px rgba(0,0,0,0.05);}
+.ap-card.pending{border-left:3px solid #e67e22;}
+.ap-card.sent{border-left:3px solid #27ae60;opacity:.75;}
+.ap-card.auto_sent{border-left:3px solid #3498db;opacity:.8;}
+.ap-card.cancelled,.ap-card.failed{border-left:3px solid #95a5a6;opacity:.65;}
+.ap-top{display:flex;align-items:center;gap:8px;margin-bottom:8px;flex-wrap:wrap;}
+.ap-name{font-weight:600;font-size:14px;}
+.kind-badge{font-size:10px;padding:2px 8px;border-radius:10px;font-weight:600;background:#eef;color:#3a51c6;}
+.kind-badge.group_at_me{background:#fdebd0;color:#b9770e}.kind-badge.group_quote_me{background:#e8daef;color:#6c3483}
+.status-badge{font-size:10px;padding:2px 8px;border-radius:10px;margin-left:auto;}
+.status-badge.sent{background:#d5f5e3;color:#1e8449}.status-badge.auto_sent{background:#d6eaf8;color:#1a5276}
+.status-badge.cancelled,.status-badge.failed{background:#f2f3f4;color:#7f8c8d}
+.reason{font-size:10px;color:#e67e22;margin-bottom:6px;}
+.incoming{background:#f7f7f8;border-radius:6px;padding:8px 10px;font-size:12px;color:#444;margin-bottom:8px;white-space:pre-wrap;word-break:break-word;}
+.incoming .lbl{color:#999;font-size:10px;display:block;margin-bottom:2px;}
+.draft-box{width:100%;box-sizing:border-box;border:1px solid #cfd8e3;border-radius:6px;padding:8px 10px;font-size:13px;resize:vertical;min-height:44px;font-family:inherit;}
+.ap-actions{display:flex;gap:8px;margin-top:8px;}
+.ap-actions button{cursor:pointer;padding:7px 16px;border:none;border-radius:6px;font-size:13px;}
+.btn-send{background:#27ae60;color:white}.btn-send:hover{background:#219a52}
+.btn-cancel{background:#e74c3c;color:white}.btn-cancel:hover{background:#c0392b}
+.sent-reply{font-size:13px;color:#1e8449;margin-top:4px;}
+.ts{font-size:10px;color:#aaa;}
+.empty-state{text-align:center;padding:60px 20px;color:#999;}
+.loading{text-align:center;padding:40px;color:#999;}
+</style>
+<div class="ap-container">
+<div class="ap-header">
+<h1>✅ 自动回复审批</h1>
+<button class="btn-refresh" onclick="load()">🔄 刷新</button>
+</div>
+<div class="tabs">
+<div class="tab active" data-s="pending" onclick="switchTab('pending',this)">待审批</div>
+<div class="tab" data-s="" onclick="switchTab('',this)">全部</div>
+<div class="tab" data-s="sent" onclick="switchTab('sent',this)">已发送</div>
+<div class="tab" data-s="auto_sent" onclick="switchTab('auto_sent',this)">自动已发</div>
+<div class="tab" data-s="cancelled" onclick="switchTab('cancelled',this)">已取消</div>
+</div>
+<div id="list"></div>
+</div>
+<script>
+var curStatus='pending';
+function esc(s){return String(s==null?'':s).replace(/&/g,'&amp;').replace(/</g,'&lt;').replace(/>/g,'&gt;');}
+var STATUS_CN={pending:'待审批',sent:'已发送',auto_sent:'自动已发',cancelled:'已取消',failed:'发送失败'};
+var KIND_CN={private:'私聊',group_at_me:'群@我',group_quote_me:'群引用我'};
+
+function switchTab(s,el){curStatus=s;document.querySelectorAll('.tabs .tab').forEach(function(t){t.classList.remove('active')});el.classList.add('active');load();}
+
+function load(){
+  var el=document.getElementById('list');
+  el.innerHTML='<div class="loading">加载中...</div>';
+  fetch('/api/replies?status='+encodeURIComponent(curStatus)).then(function(r){return r.json()}).then(function(j){
+    if(!j.ok){el.innerHTML='<div class="empty-state">加载失败: '+esc(j.error)+'</div>';return;}
+    if(!j.data.length){el.innerHTML='<div class="empty-state"><p>暂无</p></div>';return;}
+    var h='';
+    for(var i=0;i<j.data.length;i++){
+      var t=j.data[i];
+      var pending=t.status==='pending';
+      h+='<div class="ap-card '+t.status+'">';
+      h+='<div class="ap-top"><span class="ap-name">'+esc(t.sender_name||t.sender||t.talker)+'</span>';
+      h+='<span class="kind-badge '+t.kind+'">'+(KIND_CN[t.kind]||t.kind)+'</span>';
+      if(!pending)h+='<span class="status-badge '+t.status+'">'+(STATUS_CN[t.status]||t.status)+'</span>';
+      h+='</div>';
+      if(pending&&t.reason)h+='<div class="reason">判定：'+esc(t.reason)+'</div>';
+      h+='<div class="incoming"><span class="lbl">对方说：</span>'+esc(t.incoming)+'</div>';
+      if(pending){
+        h+='<textarea class="draft-box" id="d'+t.id+'">'+esc(t.draft)+'</textarea>';
+        h+='<div class="ap-actions">';
+        h+='<button class="btn-send" onclick="send('+t.id+')">✅ 发送</button>';
+        h+='<button class="btn-cancel" onclick="cancel('+t.id+')">🗑 取消</button>';
+        h+='</div>';
+      }else{
+        h+='<div class="sent-reply">回复：'+esc(t.draft)+'</div>';
+        h+='<div class="ts">'+esc(t.sent_at||t.created_at)+'</div>';
+      }
+      h+='</div>';
+    }
+    el.innerHTML=h;
+  }).catch(function(e){el.innerHTML='<div class="empty-state">加载失败: '+e.message+'</div>';});
+}
+
+function send(id){
+  var txt=document.getElementById('d'+id).value;
+  if(!txt.trim()){alert('回复内容为空');return;}
+  fetch('/api/reply/'+id+'/send',{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({text:txt})})
+    .then(function(r){return r.json()}).then(function(j){
+      if(j.ok){load();}else{alert('发送失败: '+(j.error||JSON.stringify(j.data||{})));load();}
+    });
+}
+function cancel(id){
+  fetch('/api/reply/'+id+'/cancel',{method:'POST'}).then(function(r){return r.json()}).then(function(j){
+    if(j.ok){load();}else{alert('失败: '+(j.error||''));}
+  });
+}
+load();
+</script>
+{% endblock %}
+{% extends "base.html" %}
+{% block title %}回复白名单 - WeChat Viewer{% endblock %}
+{% block body %}
+<style>
+body{overflow-y:auto!important;height:auto!important;}
+.wl-container{max-width:760px;margin:0 auto;padding:20px;}
+.wl-header h1{font-size:20px;color:#2c3e50;margin-bottom:6px;}
+.wl-hint{font-size:12px;color:#888;margin-bottom:16px;line-height:1.5;}
+.add-box{background:white;border-radius:8px;padding:14px 16px;margin-bottom:18px;box-shadow:0 1px 2px rgba(0,0,0,0.05);display:flex;gap:8px;flex-wrap:wrap;align-items:center;}
+.add-box input{border:1px solid #cfd8e3;border-radius:6px;padding:8px 10px;font-size:13px;}
+.add-box input.wxid{flex:1;min-width:180px;}
+.add-box input.name{width:140px;}
+.btn-add{background:#27ae60;color:white;border:none;border-radius:6px;padding:8px 16px;font-size:13px;cursor:pointer;}
+.wl-card{background:white;border-radius:8px;padding:12px 16px;margin-bottom:8px;box-shadow:0 1px 2px rgba(0,0,0,0.05);display:flex;align-items:center;gap:10px;}
+.kb{font-size:10px;padding:2px 8px;border-radius:10px;font-weight:600;}
+.kb.contact{background:#d6eaf8;color:#1a5276}.kb.group{background:#fdebd0;color:#b9770e}
+.wl-name{font-weight:600;font-size:14px;}
+.wl-wxid{font-size:11px;color:#999;}
+.btn-del{margin-left:auto;background:#e74c3c;color:white;border:none;border-radius:6px;padding:6px 12px;font-size:12px;cursor:pointer;}
+.empty-state{text-align:center;padding:50px 20px;color:#999;}
+</style>
+<div class="wl-container">
+<div class="wl-header"><h1>⭐ 回复白名单</h1></div>
+<div class="wl-hint">在白名单里的联系人 / 群，其消息可被<b>自动回复</b>（仍受敏感词等安全规则拦截，命中会转人工审批）。不在名单里的一律进「自动回复审批」等你手动发。<br>群 id 以 <code>@chatroom</code> 结尾会自动识别为群。</div>
+<div class="add-box">
+<input class="wxid" id="wxid" placeholder="wxid 或 群id(xxx@chatroom)">
+<input class="name" id="name" placeholder="备注名(可选)">
+<button class="btn-add" onclick="add()">➕ 添加</button>
+</div>
+<div id="list"></div>
+</div>
+<script>
+function esc(s){return String(s==null?'':s).replace(/&/g,'&amp;').replace(/</g,'&lt;').replace(/>/g,'&gt;');}
+function load(){
+  var el=document.getElementById('list');
+  fetch('/api/whitelist').then(function(r){return r.json()}).then(function(j){
+    if(!j.ok){el.innerHTML='<div class="empty-state">加载失败</div>';return;}
+    if(!j.data.length){el.innerHTML='<div class="empty-state"><p>白名单为空 — 当前所有回复都会进人工审批</p></div>';return;}
+    var h='';
+    for(var i=0;i<j.data.length;i++){
+      var t=j.data[i];
+      h+='<div class="wl-card">';
+      h+='<span class="kb '+t.kind+'">'+(t.kind==='group'?'群':'联系人')+'</span>';
+      h+='<span class="wl-name">'+esc(t.name||'(未命名)')+'</span>';
+      h+='<span class="wl-wxid">'+esc(t.wxid)+'</span>';
+      h+='<button class="btn-del" onclick="del('+t.id+')">删除</button>';
+      h+='</div>';
+    }
+    el.innerHTML=h;
+  });
+}
+function add(){
+  var wxid=document.getElementById('wxid').value.trim();
+  var name=document.getElementById('name').value.trim();
+  if(!wxid){alert('请输入 wxid 或群id');return;}
+  fetch('/api/whitelist',{method:'POST',headers:{'Content-Type':'application/json'},body:JSON.stringify({wxid:wxid,name:name})})
+    .then(function(r){return r.json()}).then(function(j){
+      if(j.ok){document.getElementById('wxid').value='';document.getElementById('name').value='';load();}
+      else{alert('失败: '+(j.error||''));}
+    });
+}
+function del(id){
+  fetch('/api/whitelist/'+id+'/delete',{method:'POST'}).then(function(r){return r.json()}).then(function(j){
+    if(j.ok){load();}else{alert('失败: '+(j.error||''));}
+  });
+}
+load();
+</script>
+{% endblock %}
+# wechat-viewer 集成改动（环节4 策略 + 审批/白名单 UI）
+
+> 落地在手机端 Flask 应用 `~/wechat-viewer`（该 app 有自己的 git 工作树，本文件只记录本次为
+> 微信自动回复新增的部分；两个新模板全文见同目录 `viewer_templates/`）。
+
+## 新增数据表（`local_db.py` init_db）
+
+```sql
+CREATE TABLE reply_whitelist (   -- 自动回复白名单
+    id INTEGER PK, kind TEXT,     -- 'contact'|'group'
+    wxid TEXT UNIQUE, name TEXT, added_at TEXT);
+
+CREATE TABLE reply_queue (        -- 策略判定后落地
+    id INTEGER PK, msg_id INTEGER, talker TEXT, sender TEXT, sender_name TEXT,
+    kind TEXT, incoming TEXT, draft TEXT,
+    action TEXT,                  -- 'auto'|'review'
+    reason TEXT,
+    status TEXT,                  -- pending|sent|cancelled|auto_sent|failed
+    created_at TEXT, sent_at TEXT);
+```
+
+`local_db.py` 新增辅助函数：`whitelist_list/add/remove/wxids`、`reply_add/list/get/update`。
+
+## 新增路由（`app.py`）
+
+| 路由 | 作用 |
+|---|---|
+| `GET /whitelist` | 白名单管理页 |
+| `GET /api/whitelist` / `POST /api/whitelist` / `POST /api/whitelist/<id>/delete` | 白名单增删查（`xxx@chatroom` 自动识别为群） |
+| `GET /approvals` | 自动回复审批页 |
+| `GET /api/replies?status=` | 队列列表（pending / sent / auto_sent / cancelled / 全部） |
+| `POST /api/reply/<id>/send` | 用（可编辑的）草稿发到会话 → `send_text_via_hook(talker,text)` → 标 sent/failed |
+| `POST /api/reply/<id>/cancel` | 标 cancelled |
+
+发送复用 `~/.hermes/event_bus/wechat_hook_send.py` 的 `send_text_via_hook`（LSPosed 内部 API 广播 `SEND_MSG_INTERNAL`）。
+
+## 新增页面（`templates/`，见 viewer_templates/）
+- `approvals.html`：待审批列表，每条含对方原文 + **可编辑草稿框** + 【✅发送】【🗑取消】；另有已发送/自动已发/已取消筛选 tab。
+- `whitelist.html`：白名单增删列表。
+
+`base.html` 抽屉导航加两个入口：✅自动回复审批 / ⭐回复白名单。
+
+## 真机验证（2026-07-10）
+- 页面 `/whitelist` `/approvals` 均 200。
+- 白名单：加「测试好友」→ 列表可见 → 删除 OK。
+- 审批：插入 pending → `/api/replies` 返回 → 点发送 → `send_text_via_hook` 广播到 filehelper（result=0, status=sent）→ 草稿按编辑后内容更新、状态转 sent、sent_at 记录。
+- 取消：pending → cancel → status=cancelled。
+- 测试数据已清空。
+
+## 待接（环节5 / 编排）
+- **编排器**：把环节1 队列 `incoming.jsonl` → 上下文 → Hermes 生成 → 策略 `decide()`（白名单读 `reply_whitelist`）→ auto 直接 `send_text_via_hook` 并 `reply_add(status=auto_sent)` / review 写 `reply_add(status=pending)`。
+- 群 @回复的 `@昵称` 前缀、原生引用气泡（A11y）。
+#!/usr/bin/env python3
+"""环节4 · 策略判定 —— 确定性安全闸（自动发 / 进审核 / 跳过）
+
+为什么是代码不是让 LLM 判：环节3 已验证「SOUL.md 里写的软约束会漏」(约饭案例模型仍
+主动接话)。真正的自动/审核安全门必须是确定性、可审计、LLM 说服不动的硬规则。
+
+输入：watcher 事件 + Hermes 生成的草稿 + (可选)模型置信/should_reply 信号
+输出：{action: auto|review|skip, reason}
+  skip   —— 压根不该回（群里没@我、公众号、系统消息、自己发的、模型说别回）
+  auto   —— 白名单 + 文本 + 无敏感词 + 总开关开 → 直接发（环节5）
+  review —— 其余一律进审核队列 pending.jsonl，人工在 wechat viewer 里点发送
+
+设计=default-deny：不在白名单、命中敏感词、低置信、拿不准 → 全部 review。
+先保守起步（auto_send_enabled 默认 False = 全审核），跑顺了再对白名单放开自动。
+
+配置 ~/.hermes/wechat_reply/policy_config.json（首次自动生成默认值）。
+"""
+import json
+import os
+import time
+
+WORK_DIR = os.environ.get(
+    "WECHAT_REPLY_DIR",
+    "/data/data/com.termux/files/home/.hermes/wechat_reply")
+CONFIG_FILE = f"{WORK_DIR}/policy_config.json"
+PENDING_FILE = f"{WORK_DIR}/pending.jsonl"   # 审核队列（环节5 viewer 读）
+DECISION_LOG = f"{WORK_DIR}/decisions.jsonl"
+
+DEFAULT_CONFIG = {
+    "auto_send_enabled": False,      # 总开关：False = 一切都进审核（保守起步）
+    "whitelist_contacts": [],        # 允许自动发的 wxid（私聊）
+    "whitelist_groups": [],          # 允许 @我 时自动发的 chatroom id
+    "min_confidence": 0.75,          # 低于此→审核（模型给了置信才生效）
+    # 命中即强制 review（即使白名单也拉回人工）——钱/承诺/约时间/隐私
+    "block_keywords": [
+        "钱", "转账", "红包", "借", "还款", "付款", "打款", "汇款", "定金", "报价",
+        "价格", "多少钱", "合同", "签", "承诺", "保证", "担保",
+        "几点", "明天", "后天", "周末", "约", "见面", "面基", "碰头", "地址在",
+        "身份证", "银行卡", "验证码", "密码", "手机号", "住址",
+    ],
+}
+
+# 非文本消息类型（草稿通常无意义）
+NON_TEXT_TYPES = {3, 34, 43, 47, 42, 48, 49, 62, 10000}
+SYSTEM_MARKERS = ("撤回了一条消息", "拍了拍", "拍一拍", "添加到通讯录", "以上是打招呼的内容")
+
+
+def load_config():
+    try:
+        with open(CONFIG_FILE) as f:
+            cfg = json.load(f)
+        return {**DEFAULT_CONFIG, **cfg}
+    except (OSError, ValueError):
+        os.makedirs(WORK_DIR, exist_ok=True)
+        with open(CONFIG_FILE, "w") as f:
+            json.dump(DEFAULT_CONFIG, f, ensure_ascii=False, indent=2)
+        return dict(DEFAULT_CONFIG)
+
+
+def _hit_keyword(text, keywords):
+    for k in keywords:
+        if k and k in text:
+            return k
+    return None
+
+
+def decide(event, draft, confidence=None, should_reply=True, self_wxid="", cfg=None):
+    """核心判定。返回 {action, reason, hit?}。纯函数、无副作用（写队列在 route()）。"""
+    cfg = cfg or load_config()
+    kind = event.get("kind", "")
+    sender = event.get("sender") or event.get("talker") or ""
+    talker = event.get("talker", "")
+    body = event.get("body", "") or ""
+    mtype = event.get("type", 0)
+
+    # ── skip 区：压根不回 ──
+    if sender and self_wxid and sender == self_wxid:
+        return {"action": "skip", "reason": "self:自己发的"}
+    if kind == "group_other":
+        return {"action": "skip", "reason": "group:群里没@我也没引用我"}
+    if str(talker).startswith("gh_") or str(sender).startswith("gh_"):
+        return {"action": "skip", "reason": "official:公众号/服务号推送"}
+    if any(m in body for m in SYSTEM_MARKERS):
+        return {"action": "skip", "reason": "system:系统消息(撤回/拍一拍/加好友)"}
+    if not should_reply:
+        return {"action": "skip", "reason": "model:模型判定无需回复"}
+    if not (draft or "").strip():
+        if mtype in NON_TEXT_TYPES:
+            return {"action": "skip", "reason": f"nontext:非文本(type={mtype})且无草稿"}
+        return {"action": "skip", "reason": "empty:草稿为空"}
+
+    # ── 硬安全override：命中敏感词一律 review（白名单也拉回）──
+    hit = _hit_keyword(body + "\n" + (draft or ""), cfg["block_keywords"])
+    if hit:
+        return {"action": "review", "reason": f"sensitive:命中敏感词「{hit}」", "hit": hit}
+
+    # ── 低置信 → review ──
+    if confidence is not None and confidence < cfg["min_confidence"]:
+        return {"action": "review", "reason": f"lowconf:置信{confidence}<{cfg['min_confidence']}"}
+
+    # ── 白名单 + 总开关 → auto ──
+    is_group = event.get("isGroup") or str(talker).endswith("@chatroom")
+    whitelisted = (
+        (not is_group and sender in cfg["whitelist_contacts"]) or
+        (is_group and talker in cfg["whitelist_groups"])
+    )
+    if whitelisted and cfg["auto_send_enabled"]:
+        return {"action": "auto", "reason": "whitelist:白名单+总开关开→直接发"}
+
+    # ── default-deny：其余全部人工审核 ──
+    if not cfg["auto_send_enabled"]:
+        return {"action": "review", "reason": "conservative:总开关关(全审核)"}
+    return {"action": "review", "reason": "notwhitelist:不在白名单→人工"}
+
+
+def route(event, draft, decision, meta=None):
+    """按判定落地：review→写审核队列 pending.jsonl；一切→记 decisions.jsonl 审计。"""
+    os.makedirs(WORK_DIR, exist_ok=True)
+    rec = {
+        "ts": int(time.time()),
+        "msgId": event.get("msgId"),
+        "talker": event.get("talker"),
+        "sender": event.get("sender"),
+        "kind": event.get("kind"),
+        "action": decision["action"],
+        "reason": decision["reason"],
+        "draft": draft,
+        **(meta or {}),
+    }
+    with open(DECISION_LOG, "a") as f:
+        f.write(json.dumps(rec, ensure_ascii=False) + "\n")
+    if decision["action"] == "review":
+        item = {**rec, "status": "pending"}
+        with open(PENDING_FILE, "a") as f:
+            f.write(json.dumps(item, ensure_ascii=False) + "\n")
+    return rec
+
+
+# ── 自检 demo（lazy 规则：留一个可跑的检查）──
+def _demo():
+    cfg = dict(DEFAULT_CONFIG)
+    cfg["whitelist_contacts"] = ["wxid_friend"]
+    cfg["auto_send_enabled"] = True
+    cases = [
+        ("陌生猎头(非白名单)", {"kind": "private", "talker": "wxid_x", "sender": "wxid_x",
+          "body": "有急招岗位吗", "type": 1}, "暂不考虑，谢谢", None, "review"),
+        ("白名单好友闲聊", {"kind": "private", "talker": "wxid_friend", "sender": "wxid_friend",
+          "body": "在干嘛", "type": 1}, "摸鱼呢哈哈", None, "auto"),
+        ("白名单好友约饭(敏感词)", {"kind": "private", "talker": "wxid_friend", "sender": "wxid_friend",
+          "body": "明天中午一起吃饭？", "type": 1}, "可以啊几点", None, "review"),
+        ("白名单好友谈钱", {"kind": "private", "talker": "wxid_friend", "sender": "wxid_friend",
+          "body": "借我5000周转下", "type": 1}, "行", None, "review"),
+        ("群里没@我", {"kind": "group_other", "talker": "x@chatroom", "sender": "wxid_a",
+          "isGroup": True, "body": "哈哈", "type": 1}, "草稿", None, "skip"),
+        ("公众号推送", {"kind": "private", "talker": "gh_abc", "sender": "gh_abc",
+          "body": "<msg>文章</msg>", "type": 49}, "", None, "skip"),
+        ("撤回系统消息", {"kind": "group_at_me", "talker": "x@chatroom", "sender": "wxid_a",
+          "body": "\"张三\" 撤回了一条消息", "type": 10000}, "", None, "skip"),
+        ("低置信", {"kind": "private", "talker": "wxid_friend", "sender": "wxid_friend",
+          "body": "你觉得呢", "type": 1}, "嗯", 0.4, "review"),
+    ]
+    ok = True
+    for name, ev, draft, conf, expect in cases:
+        d = decide(ev, draft, confidence=conf, cfg=cfg)
+        flag = "OK " if d["action"] == expect else "FAIL"
+        if d["action"] != expect:
+            ok = False
+        print(f"[{flag}] {name}: 期望={expect} 实得={d['action']} ({d['reason']})")
+    print("=== ALL PASS ===" if ok else "=== 有 FAIL ===")
+    return ok
+
+
+if __name__ == "__main__":
+    import sys
+    if "--demo" in sys.argv:
+        sys.exit(0 if _demo() else 1)
+    print("用法: wechat_reply_policy.py --demo   (或作为库 import decide/route)")