From 6ce0abb3c8c43b6ca1bb54537f8937b4a5155ad3 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期五, 21 三月 2025 15:57:19 +0800
Subject: [PATCH] bug修改
---
strategy/kpl_api.py | 14 ++++++++------
1 files changed, 8 insertions(+), 6 deletions(-)
diff --git a/strategy/kpl_api.py b/strategy/kpl_api.py
index ce1f6b7..fc65270 100644
--- a/strategy/kpl_api.py
+++ b/strategy/kpl_api.py
@@ -230,17 +230,19 @@
# 灏濊瘯杩囨护鎺夋棤鎰忎箟鐨勬蹇垫澘鍧�(plate_name not in ['绉戝垱鏉�', '鍖椾氦鎵�', '娆℃柊鑲�', '鏃�', 'ST鏉垮潡', 'ST鎽樺附', '骞惰喘閲嶇粍', '鍥戒紒鏀归潻','瓒呰穼', '澹宠祫婧�', '鑲℃潈杞', '閫佽浆濉潈']) and '澧為暱' in plate_name
if (plate_name not in ['绉戝垱鏉�', '鍖椾氦鎵�', '娆℃柊鑲�', '鏃�', 'ST鏉垮潡', 'ST鎽樺附', '骞惰喘閲嶇粍', '鍥戒紒鏀归潻', '瓒呰穼',
'澹宠祫婧�', '鑲℃潈杞', '閫佽浆濉潈']) or ('澧為暱' in plate_name):
+
# print(f"{i[1]} 寮哄害:{i[2]}")
# 閫氳繃鏉垮潡ID鑾峰彇鍏朵笅闈㈢殑涓偂寮哄害鍒楄〃
# print(f"======={i[0]}=======")
-
its_stock = json.loads(getCodesByPlate(i[0]))
# 鍙湪鐩樹腑鏃堕棿鑾峰彇
now_time = tool.get_now_time_str()
if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME:
- async_log_util.info(logger_stock_of_markets_plate, f"{its_stock['list']}")
- logger.info(f"its_stock['list'] ===銆嬨�� {its_stock['list']}")
+ log_data = {plate_name: its_stock['list']}
+ async_log_util.info(logger_stock_of_markets_plate, f"{log_data}")
+
+ # logger.info(f"its_stock['list'] ===銆嬨�� {log_data}")
# logger.info(f"its_stock['list'][0] === {its_stock['list'][0]}")
# its_stock_list_info = its_stock['list']
@@ -296,9 +298,9 @@
ds.append(request_plate_codes(d))
dask_result = batch_get_plate_codes(ds)
dask_result.compute()
- # now_time = tool.get_now_time_str()
- # if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME:
- # logger.info(f"绮鹃�夋澘鍧楄偂绁ㄥ己搴︽暟鎹洿鏂� == {market_sift_plate_stock_dict}")
+ now_time = tool.get_now_time_str()
+ if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME:
+ logger.info(f"绮鹃�夋澘鍧楄偂绁ㄥ己搴︽暟鎹洿鏂� == {market_sift_plate_stock_dict}")
return market_sift_plate_stock_dict
--
Gitblit v1.8.0