From e311e55bc80e39349448d19b1461aef37ed31ab5 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期四, 27 三月 2025 18:40:00 +0800
Subject: [PATCH] 板块强度数据日志修改

---
 strategy/kpl_data_manager.py |   22 ++++++++++++----------
 1 files changed, 12 insertions(+), 10 deletions(-)

diff --git a/strategy/kpl_data_manager.py b/strategy/kpl_data_manager.py
index 9a682af..dbcc3c6 100644
--- a/strategy/kpl_data_manager.py
+++ b/strategy/kpl_data_manager.py
@@ -12,23 +12,25 @@
     def __init__(self):
         # 杩囨护鍚庣殑鏃ュ織鏁版嵁
         self.__filter_log_datas = []
-        self.__load_data()
 
     def __load_data(self):
-        logger_debug.info("KPLStockOfMarketsPlateLogManager 寮�濮嬪姞杞芥暟鎹�")
-        datas = log_export.load_stock_of_markets_plate()
-        for data in datas:
-            # (鍙戠敓鏃堕棿,[鍑�娴佸叆鏉垮潡], {"鏉垮潡":(浠g爜, 鍚嶇О, 娑ㄥ箙)})
-            self.__filter_log_datas.append(self.__filter_origin_data(data))
-        logger_debug.info("KPLStockOfMarketsPlateLogManager 鏁版嵁鍔犺浇瀹屾垚锛歿}", len(self.__filter_log_datas))
+        if tool.get_now_time_str() > '15:00:00':
+            logger_debug.info("KPLStockOfMarketsPlateLogManager 寮�濮嬪姞杞芥暟鎹�")
+            datas = log_export.load_stock_of_markets_plate()
+            for data in datas:
+                # (鍙戠敓鏃堕棿,[鍑�娴佸叆鏉垮潡], {"鏉垮潡":(浠g爜, 鍚嶇О, 娑ㄥ箙)})
+                self.__filter_log_datas.append(self.__filter_origin_data(data))
+            logger_debug.info("KPLStockOfMarketsPlateLogManager 鏁版嵁鍔犺浇瀹屾垚锛歿}", len(self.__filter_log_datas))
+
+    def load_data(self):
+        self.__load_data()
 
     def __filter_origin_data(self, data):
         return (data[0], [x[1] for x in data[1][0]],
-                           {p: [(xx[0], xx[1], xx[6]) for xx in data[1][1][p]] for p in data[1][1]})
+                {p: [(xx[0], xx[1], xx[6]) for xx in data[1][1][p]] for p in data[1][1]})
 
     def add_log(self, in_plates_info, plate_codes_info):
         oringin_data = (tool.get_now_time_str(), in_plates_info, plate_codes_info)
-        self.__filter_log_datas.append(self.__filter_origin_data(oringin_data))
         async_log_util.info(logger_stock_of_markets_plate, f"{(oringin_data[1], oringin_data[2])}")
 
     def get_filter_log_datas(self):
@@ -36,4 +38,4 @@
 
 
 if __name__ == '__main__':
-    KPLStockOfMarketsPlateLogManager()
\ No newline at end of file
+    KPLStockOfMarketsPlateLogManager()

--
Gitblit v1.8.0