Compare commits

...
+2 -2
View File
@@ -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'])