diff --git a/src/realtime/collector.py b/src/realtime/collector.py
index 23febff..b8a88bc 100644
--- a/src/realtime/collector.py
+++ b/src/realtime/collector.py
@@ -181,9 +181,10 @@ class TimelineCollector:
 
     def save_lhb_today(self, conn):
         try:
-            from src.fetcher.lhb_fetcher import fetch_lhb
+            from src.fetcher.lhb_fetcher import fetch_lhb_date
             from src.storage.db import upsert_rows
-            df = fetch_lhb()
+            today = datetime.now().strftime('%Y-%m-%d')
+            df = fetch_lhb_date(today)
             if df is not None and not df.empty:
                 return upsert_rows(df, 'lhb_daily',
                                    conflict_cols=['trade_date', 'ts_code', 'reason'])