diff --git a/bsp_monitor/main.py b/bsp_monitor/main.py index 74e159b..fb997f5 100644 --- a/bsp_monitor/main.py +++ b/bsp_monitor/main.py @@ -52,7 +52,7 @@ def _bi_id(bi) -> Optional[tuple]: class SymbolState: symbol: str pivot_monitor: ChanPivotMonitor = field(default_factory=ChanPivotMonitor) - last_bi_id: Optional[tuple] = None # 上次检查过的最后一笔 ID + last_bi_id: Optional[tuple] = None # 上次检查过的最后一笔确认 ID last_df_ts: object = None # 最新已处理的 K 线时间戳 first_run: bool = True @@ -145,11 +145,11 @@ class BSPMonitor: # 7. 检查刚被分型确认这笔的终点是否为 BSP bsp = engine.get_bsp_for_bi(last_confirmed) if bsp: - key = f"{symbol}_{bsp.type}_{bsp.klc.end_time}" - msg = engine.format_bsp_detail(bsp, symbol) - msg = _escape_html(msg) - if send_bsp_alert(msg, bsp_key=key): - logger.info(f"[{name}] ✅ BSP: {key}") + key = f"{symbol}_{bsp.type}_{bsp.klc.end_time}" + msg = engine.format_bsp_detail(bsp, symbol) + msg = _escape_html(msg) + if send_bsp_alert(msg, bsp_key=key): + logger.info(f"[{name}] ✅ BSP: {key}") # 8. 中枢特征更新 pivot_state = st.pivot_monitor.update(engine.bi_zs_list)