clean: 移除盘中自检/早上健康检查/系统审计中的小果残留引用

This commit is contained in:
知微
2026-07-21 12:03:21 +08:00
parent 945941d3d0
commit 9d3cab2306
+7 -14
View File
@@ -42,15 +42,12 @@ HERMES_CRON_DIR = Path("/home/hmo/.hermes/profiles/position-analyst/cron")
def derive_fix_action(detail, msg):
"""根据issue信息推导可执行的修复命令"""
# 小果扫描 error → 验证脚本是否存在
if "xiaoguo_scanner" in msg or "小果扫描" in msg:
return f"ls -la /home/hmo/.hermes/profiles/position-analyst/scripts/xiaoguo_scanner.py 2>&1 && echo 'ok'"
# system-audit error → 验证拷贝
if "system_audit" in msg or "系统审计" in msg:
return f"ls -la /home/hmo/.hermes/profiles/position-analyst/scripts/system_audit.py 2>&1"
# cron errorslast_status=error)→ 验证文件存在,等下次cron运行自动恢复
if "cron" in msg.lower() and "error" in msg.lower() and ("小果" in msg or "系统审计" in msg):
return f"ls -la /home/hmo/.hermes/profiles/position-analyst/scripts/xiaoguo_scanner.py /home/hmo/.hermes/profiles/position-analyst/scripts/system_audit.py 2>&1"
if "cron" in msg.lower() and "error" in msg.lower() and "系统审计" in msg:
return f"ls -la /home/hmo/.hermes/profiles/position-analyst/scripts/system_audit.py 2>&1"
# 港股汇率 → 刷新
if "港股汇率" in msg:
return f"cd {BASE} && python3 hk_rate.py 2>&1"
@@ -60,9 +57,9 @@ def derive_fix_action(detail, msg):
# delivery目标缺失 → 改为local
if "deliver" in msg.lower() or "delivery" in msg.lower():
return f"cd {BASE} && echo '需手动设置: cronjob action=update deliver=local'"
# 小果→知微桥不通
# 小果→知微桥不通(小果已归档,不再自动修复)
if "信号桥" in msg:
return f"cd {BASE} && python3 scripts/xiaoguo_signal_consumer.py 2>&1"
return None
return None
@@ -319,8 +316,6 @@ def check_db_table_count(table, field, value, op="today", threshold=0):
cols = [r[1] for r in cur.execute(f"PRAGMA table_info({table})").fetchall()]
if "processed" in cols:
sql = f"SELECT COUNT(*) FROM {table} WHERE (processed = 0 OR processed IS NULL)"
elif "source" in cols:
sql = f"SELECT COUNT(*) FROM {table} WHERE source LIKE '%xiaoguo%'"
else:
sql = f"SELECT COUNT(*) FROM {table}"
cur.execute(sql)
@@ -400,7 +395,6 @@ def check_cron_paused():
"""检查不应暂停的cron是否被误暂停"""
should_run = [
("3a9fb3300a6a", "价格监控"),
("0851c7838ca3", "小果扫描"),
("e13323928f3a", "自选提醒"),
("b809fcabfa5b", "分支评估"),
]
@@ -604,10 +598,9 @@ def run_check(item):
elif check_spec == "meta:checklist_completeness":
ok, detail = check_meta_checklist_completeness()
elif check_spec == "pipeline:xiaoguo_signal_flow":
today_xiaoguo, d1 = check_db_table_count("signal_news", "created_at", None, "today", 0)
unproc, d2 = check_db_table_count("signal_news", None, None, "unprocessed", 30)
ok = today_xiaoguo or unproc
detail = f"today_xiaoguo={d1}, unprocessed={d2}"
# 小果已归档,该管道不再检查
ok = True
detail = "skipped (xiaoguo archived)"
elif check_spec == "pipeline:registry_audit":
ok = True
gaps = []