diff --git a/xiaobai-datahub/datahub/realtime_serve.py b/xiaobai-datahub/datahub/realtime_serve.py index e2e8196..b3cfb71 100644 --- a/xiaobai-datahub/datahub/realtime_serve.py +++ b/xiaobai-datahub/datahub/realtime_serve.py @@ -488,7 +488,12 @@ def warm_realtime(db: HubDB) -> dict[str, Any]: sector_rows: list[dict[str, Any]] = [] try: masters = db.fetchall( - "SELECT ts_code FROM sector_master WHERE family = 'sw' ORDER BY ts_code" + """ + SELECT ts_code FROM sector_master WHERE family = 'sw' + UNION + SELECT ts_code FROM eod_sector_daily WHERE family = 'sw' + ORDER BY ts_code + """ ) codes = [str(row.get("ts_code") or "") for row in masters if row.get("ts_code")] sector_rows = _eastmoney_sector_quotes(codes)