|
|
|
|
@ -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(
|
|
|
|
|
|