From 5efc4e481cbee9b2c02410ff9e5f92b5524c1e28 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期一, 26 五月 2025 18:16:35 +0800
Subject: [PATCH] 1. 2. 3.GUI新增及修改 行情板块强度模块，服务端解析日志数据及应答 4.
---
strategy/kpl_data_manager.py | 40 +++++++++++++++++++++++++++++++++++++---
1 files changed, 37 insertions(+), 3 deletions(-)
diff --git a/strategy/kpl_data_manager.py b/strategy/kpl_data_manager.py
index f2112c8..6e2cd55 100644
--- a/strategy/kpl_data_manager.py
+++ b/strategy/kpl_data_manager.py
@@ -1,8 +1,8 @@
from log_module import log_export, async_log_util
-from log_module.log import logger_stock_of_markets_plate, logger_debug
+from log_module.log import logger_stock_of_markets_plate, logger_debug, logger_kpl_market_sift_plate
from utils import tool
-
+# 寮�鐩樺暒涓偂寮哄害鏃ュ織绠＄悊
@tool.singleton
class KPLStockOfMarketsPlateLogManager:
"""
@@ -15,8 +15,42 @@
def __load_data(self):
if tool.get_now_time_str() > '13:10:00':
+ logger_debug.info("KPLMarketStockHeatLogManager 寮�濮嬪姞杞芥暟鎹�")
+ datas = log_export.load_market_stock_heat()
+ for data in datas:
+ # (鍙戠敓鏃堕棿,[鍑�娴佸叆鏉垮潡], {"鏉垮潡":(浠ｇ爜, 鍚嶇О, 娑ㄥ箙)})
+ self.__filter_log_datas.append(self.__filter_origin_data(data))
+ logger_debug.info("KPLMarketStockHeatLogManager 鏁版嵁鍔犺浇瀹屾垚锛歿}", 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 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)
+ async_log_util.info(logger_kpl_market_sift_plate, f"{(oringin_data[1], oringin_data[2])}")
+
+ def get_filter_log_datas(self):
+ return self.__filter_log_datas
+
+# 寮�鐩樺暒涓偂寮哄害鏃ュ織绠＄悊
+@tool.singleton
+class KPLMarketStockHeatLogManager:
+ """
+ 绮鹃�夋祦鍏ユ澘鍧椾笌鏉垮潡浠ｇ爜鏃ュ織绠＄悊
+ """
+
+ def __init__(self):
+ # 杩囨护鍚庣殑鏃ュ織鏁版嵁
+ self.__filter_log_datas = []
+
+ def __load_data(self):
+ if tool.get_now_time_str() > '13:10:00':
logger_debug.info("KPLStockOfMarketsPlateLogManager 寮�濮嬪姞杞芥暟鎹�")
- datas = log_export.load_stock_of_markets_plate()
+ datas = log_export.load_kpl_market_stock_heat()
for data in datas:
# (鍙戠敓鏃堕棿,[鍑�娴佸叆鏉垮潡], {"鏉垮潡":(浠ｇ爜, 鍚嶇О, 娑ㄥ箙)})
self.__filter_log_datas.append(self.__filter_origin_data(data))
--
Gitblit v1.8.0