From 0b0d0e790fec8c7edfdbcab5c31d625e0c2eadd6 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期四, 19 六月 2025 16:54:49 +0800
Subject: [PATCH] 添加必要的数据日志
---
strategy/kpl_data_manager.py | 12 ++++++++++--
1 files changed, 10 insertions(+), 2 deletions(-)
diff --git a/strategy/kpl_data_manager.py b/strategy/kpl_data_manager.py
index 03e9229..db4e65a 100644
--- a/strategy/kpl_data_manager.py
+++ b/strategy/kpl_data_manager.py
@@ -1,5 +1,6 @@
from log_module import log_export, async_log_util
-from log_module.log import logger_stock_of_markets_plate, logger_debug, logger_kpl_market_sift_plate
+from log_module.log import logger_stock_of_markets_plate, logger_debug, logger_kpl_market_sift_plate, \
+ logger_stock_of_markets_plate_simple
from utils import tool
@@ -71,11 +72,18 @@
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_stock_of_markets_plate, f"{(oringin_data[1], oringin_data[2])}")
+ plate_codes_simple_info = {plate: [(s[1], s[0], s[6], s[9], s[4], s[2], s[40]) for s in oringin_data[2][plate]] for plate in oringin_data[2]}
+ async_log_util.info(logger_stock_of_markets_plate_simple, f"{(oringin_data[1], plate_codes_simple_info)}")
def get_filter_log_datas(self):
return self.__filter_log_datas
if __name__ == '__main__':
- KPLMarketsSiftPlateLogManager().load_data()
+ # KPLMarketsSiftPlateLogManager().load_data()
# KPLMarketStockHeatLogManager()
+ with open("D:/text.txt", encoding='utf-8', mode='r') as f:
+ line = f.readline()
+ res = eval(line)
+ KPLMarketStockHeatLogManager().add_log(res[0], res[1])
+ print(res)
\ No newline at end of file
--
Gitblit v1.8.0