diff --git a/src/realtime/realtime_analyzer.py b/src/realtime/realtime_analyzer.py index 91cfd41..626113e 100644 --- a/src/realtime/realtime_analyzer.py +++ b/src/realtime/realtime_analyzer.py @@ -168,8 +168,8 @@ def emit(kind, payload): def save_lhb_today(conn): """收盘后采集当日龙虎榜""" try: - from src.fetcher.lhb_fetcher import fetch_lhb # 项目内已有实现 - df = fetch_lhb() + from src.fetcher.lhb_fetcher import fetch_lhb_date # 项目内已有实现 + df = fetch_lhb_date(datetime.now().strftime('%Y-%m-%d')) if df is not None and not df.empty: from src.storage.db import upsert_rows upsert_rows(df, 'lhb_daily', conflict_cols=['trade_date', 'ts_code', 'reason'])