refactor: 归档stale_push_wlin(price_monitor已覆盖其功能)+清理残留引用+禁用cron job

- stale_push_wlin归档(price_monitor每2分钟监控所有持仓+自选的买入/止损/止盈区间,已完全覆盖)
- market_config/mofin_health/signal_ledger注释引用更新
- jobs.json禁用stale_push_wlin cron job
This commit is contained in:
xxm
2026-08-20 17:33:04 +08:00
parent 9899be4bcd
commit 6396d6fe86
4 changed files with 6 additions and 1090 deletions
+2 -2
View File
@@ -3,7 +3,7 @@
"""market_config.py — 市场抽象层(阶段1:港股接入核心结构件)
市场判断 / 行情符号 / 市场配置的**唯一事实源**,收敛散落在
market_data / price_monitor / stale_push_wlin / technical_analysis /
market_data / price_monitor / technical_analysis /
strategy_lab 中的 6 处重复实现。
铁律:
@@ -30,7 +30,7 @@ def market_for_code(code):
return 'hk' if is_hk_stock(code) else 'a'
# ── 行情符号映射(收敛 market_data/price_monitor/stale_push_wlin/technical_analysis 处)──
# ── 行情符号映射(收敛 market_data/price_monitor/technical_analysis 处)──
def _normalize_code(code):
"""归一化代码:去市场前缀(sh/sz/hk/SH...)与 '_' 后缀,返回大写纯代码"""
+3 -3
View File
@@ -357,7 +357,7 @@ FLOW_DETAIL = {
"import_holding_xls": "从券商holding.xls导入最新持仓数量/成本/市值",
},
"readers": {
"stale_push_wlin": "读取持仓列表+最新价格,检查是否进入买入区/触发止损",
"price_monitor": "高频价格监控+操作区间触发重评",
"mofin_db": "内部读取(get_price_from_db等函数)",
"system_audit": "读取持仓总数/品种分布,审计持仓完整性",
"server": "读取持仓数据供Web Dashboard展示",
@@ -391,7 +391,7 @@ FLOW_DETAIL = {
"data_governance": "读取所有活跃策略,检查缺失和异常",
"per_stock_reassess": "读取个股策略配置,判断是否需要重评",
"mo_data": "通过read_decisions()读取策略数据",
"stale_push_wlin": "读取买入/止损/止盈配置,检查价格触发",
"price_monitor": "检测操作区间(买入/止损/止盈)并触发重评",
},
},
"live_prices": {
@@ -471,7 +471,7 @@ FLOW_DETAIL = {
"refresh_macro_context": "每30分钟采集上证/深证/创业板/恒指等指数+情绪指标",
},
"readers": {
"stale_push_wlin": "读取大盘情绪用于策略推送的宏观背景",
"market_regime": "温区判断(替代原detect_scenario)",
"divergence_detector": "读取多市场指数数据做背离检测",
"system_audit": "审计数据采集是否正常",
},
+1 -1
View File
@@ -13,7 +13,7 @@
用法:
from signal_ledger import record_signal, get_resonance
record_signal(code="300750", name="宁德时代", strategy="v_oversold", version="v_oversold",
regime="trend_down", temp_band="panic", reason="进买入区+重评买入", source_module="stale_push_wlin")
regime="trend_down", temp_band="panic", reason="进买入区+重评买入", source_module="price_monitor")
res = get_resonance("300750") # 返回该股票近24h共振信息
"""
import json
File diff suppressed because it is too large Load Diff