diff --git a/backend/app/services/future_service.py b/backend/app/services/future_service.py index 7028dd1..9a7c4cd 100644 --- a/backend/app/services/future_service.py +++ b/backend/app/services/future_service.py @@ -89,7 +89,7 @@ class FutureService: if adapter: sdk_data = adapter.get_kline([code], start_date, end_date, "daily") - if code in sdk_data and not sdk_data[code].empty: + if code in sdk_data and sdk_data[code] is not None and not sdk_data[code].empty: self._save_daily_kline(code, sdk_data[code]) cached_records = self.db.query(FutureKlineDaily).filter( @@ -145,7 +145,7 @@ class FutureService: if adapter: sdk_data = adapter.get_kline([code], start_date, end_date, period) - if code in sdk_data and not sdk_data[code].empty: + if code in sdk_data and sdk_data[code] is not None and not sdk_data[code].empty: self._save_min_kline(code, sdk_data[code], period) cached_records = self.db.query(FutureKlineMin).filter( diff --git a/backend/app/services/stock_service.py b/backend/app/services/stock_service.py index 6096086..f9a88b0 100644 --- a/backend/app/services/stock_service.py +++ b/backend/app/services/stock_service.py @@ -95,7 +95,7 @@ class StockService: if adapter: sdk_data = adapter.get_kline([code], start_date, end_date, "daily") - if code in sdk_data and not sdk_data[code].empty: + if code in sdk_data and sdk_data[code] is not None and not sdk_data[code].empty: # 保存到数据库 self._save_daily_kline(code, sdk_data[code]) @@ -154,7 +154,7 @@ class StockService: if adapter: sdk_data = adapter.get_kline([code], start_date, end_date, period) - if code in sdk_data and not sdk_data[code].empty: + if code in sdk_data and sdk_data[code] is not None and not sdk_data[code].empty: self._save_min_kline(code, sdk_data[code], period) # 重新查询