From 10caef18532adbd29b6159d680f9187dd78b12b5 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=9F=A5=E5=BE=AE?= <zhiwei@mofin.local>
Date: Sat, 27 Jun 2026 02:16:46 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E7=AE=A1=E9=81=93=E5=AE=A1=E8=AE=A1?=
 =?UTF-8?q?=E6=94=B9=E4=B8=BA=E5=8A=A8=E6=80=81=E8=AF=BBjobs.json=EF=BC=8C?=
 =?UTF-8?q?=E6=97=A0=E9=9C=80=E6=89=8B=E5=8A=A8=E7=BB=B4=E6=8A=A4=E8=84=9A?=
 =?UTF-8?q?=E6=9C=AC=E5=88=97=E8=A1=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 scripts/morning_health_check.py | 38 ++++++++++++++++++---------------
 1 file changed, 21 insertions(+), 17 deletions(-)

diff --git a/scripts/morning_health_check.py b/scripts/morning_health_check.py
index 4e83bb5..b2e4b8e 100755
--- a/scripts/morning_health_check.py
+++ b/scripts/morning_health_check.py
@@ -619,26 +619,30 @@ def run_check(item):
                 if not p.get("verified"):
                     gaps.append(p["name"])
             
-            # 自动发现：对比cron脚本列表和注册表，漏登的报警
+            # 自动发现：从cron jobs.json读所有脚本，交叉比对注册表
             known_sources = set()
             for p in reg.get("pipelines", []):
                 src = p.get("source", "")
-                for s in ["morning_health_check", "intraday_health_check", "strategy_review",
-                          "xiaoguo_scanner", "xiaoguo_signal_consumer", "data_governance",
-                          "price_monitor", "stale_push_wlin", "per_stock_reassess",
-                          "macro_context_collector", "divergence_detector", "macro_signal_consumer",
-                          "self_todo_executor", "strategy_evaluator", "hk_rate"]:
-                    if s in src:
-                        known_sources.add(s)
-            # 检查是否有重要脚本未出现在任何管道定义中
-            all_scripts = ["morning_health_check", "intraday_health_check", "strategy_review",
-                          "xiaoguo_scanner", "xiaoguo_signal_consumer", "data_governance",
-                          "price_monitor", "stale_push_wlin", "per_stock_reassess",
-                          "macro_context_collector", "divergence_detector", "macro_signal_consumer",
-                          "self_todo_executor", "strategy_evaluator"]
-            for s in all_scripts:
-                if s not in known_sources:
-                    unregistered.append(s)
+                # 从source描述中提取脚本名
+                import re as rr
+                for m in rr.findall(r'[\w_-]+\.py', src):
+                    known_sources.add(m.replace('.py', ''))
+            
+            # 从jobs.json动态读取所有启用脚本
+            unregistered = []
+            try:
+                jobs_data = j2.loads(open(str(HERMES_CRON_DIR / "jobs.json")).read())
+                active_scripts = set()
+                for job in jobs_data.get("jobs", []):
+                    script = job.get("script", "") or ""
+                    if script and job.get("enabled", True):
+                        name = script.replace('.py', '')
+                        active_scripts.add(name)
+                for s in sorted(active_scripts):
+                    if s not in known_sources:
+                        unregistered.append(s)
+            except Exception:
+                pass
             
             if unregistered:
                 ok = False