From 44591a3c9dafc63e4b9b6dedc44f26d47a3efbf6 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期四, 27 三月 2025 15:41:35 +0800
Subject: [PATCH] 板块强度数据日志修改
---
data_server.py | 8 ++------
1 files changed, 2 insertions(+), 6 deletions(-)
diff --git a/data_server.py b/data_server.py
index 6d846e7..a51f28e 100644
--- a/data_server.py
+++ b/data_server.py
@@ -15,6 +15,7 @@
from log_module import log_export
from log_module.log import hx_logger_l2_transaction, logger_debug, logger_request_api
from strategy import data_cache
+from strategy.kpl_data_manager import KPLStockOfMarketsPlateLogManager
from strategy.trade_setting import TradeSetting
from trade import huaxin_trade_api, huaxin_trade_data_update
from trade.huaxin_trade_record_manager import DelegateRecordManager, DealRecordManager, MoneyManager, PositionManager
@@ -182,12 +183,7 @@
time_str = params_dict.get("time")
if not time_str:
time_str = tool.get_now_time_str()
- datas = log_export.load_stock_of_markets_plate()
- fdatas = []
- for data in datas:
- # (鍙戠敓鏃堕棿,[鍑�娴佸叆鏉垮潡], {"鏉垮潡":(浠ｇ爜, 鍚嶇О, 娑ㄥ箙)})
- fdatas.append((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]}))
+ fdatas = KPLStockOfMarketsPlateLogManager().get_filter_log_datas()
response_data = json.dumps({"code": 1, "msg": "鏆傛棤鍐呭"})
for i in range(len(fdatas) - 1, -1, -1):
if fdatas[i][0] <= time_str:
--
Gitblit v1.8.0