From 9e268c795a90112d9de79c59eabc3d57cf293a7d Mon Sep 17 00:00:00 2001 From: cfdaily Date: Sun, 24 May 2026 19:53:26 +0800 Subject: [PATCH] auto-sync: 2026-05-24 19:53:26 --- src/daemon/ticker.py | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) diff --git a/src/daemon/ticker.py b/src/daemon/ticker.py index 7dee58b..0f09603 100644 --- a/src/daemon/ticker.py +++ b/src/daemon/ticker.py @@ -848,6 +848,22 @@ class Ticker: return reclaimed + def _mail_check_reply(self, original_task_id: str, db_path: Path) -> bool: + """Mail 幻觉门控:检查是否有回复邮件""" + try: + conn = get_connection(db_path) + try: + row = conn.execute( + "SELECT id FROM tasks WHERE id != ? AND must_haves LIKE ? LIMIT 1", + (original_task_id, f'%{original_task_id}%'), + ).fetchone() + return row is not None + finally: + conn.close() + except Exception as e: + logger.error("Mail %s: ticker reply check error: %s", original_task_id, e) + return True # 保守:查询失败假设有回复 + def _check_recent_routing(self, db_path: Path, task_id: str, action_type: str) -> bool: """检查最近 5 分钟内是否已 dispatch 过指定类型的路由(防重复)"""