From d1df4e77d2188ff3ad84b66fb2ba7f9bc738031d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 12 八月 2025 14:48:13 +0800
Subject: [PATCH] 记录L1的最大价格信息
---
servers/huaxin_trade_server.py | 11 +++++++++++
1 files changed, 11 insertions(+), 0 deletions(-)
diff --git a/servers/huaxin_trade_server.py b/servers/huaxin_trade_server.py
index 8544e1d..f227183 100644
--- a/servers/huaxin_trade_server.py
+++ b/servers/huaxin_trade_server.py
@@ -19,6 +19,7 @@
from code_attribute.code_l1_data_manager import L1DataManager
from code_attribute.gpcode_manager import CodePrePriceManager, CodesNameManager, \
WantBuyCodesManager
+from code_attribute.today_max_price_manager import MaxPriceInfoManager
from huaxin_client import l2_data_transform_protocol, l1_subscript_codes_manager
from huaxin_client.trade_transform_protocol import TradeResponse
from l2 import l2_data_manager_new, l2_log, code_price_manager, l2_data_util, transaction_progress, \
@@ -399,6 +400,16 @@
datas = data["data"]
cls.__save_l1_current_price(datas)
cls.__process_buy_open_limit_up_datas(datas)
+
+ try:
+ # 璁板綍浠婃棩鏈�楂樹环
+ # 09:25涔嬪悗鎵嶅紑濮嬭褰�
+ if datas and tool.get_now_time_str() > '09:25:00':
+ for d in datas:
+ MaxPriceInfoManager().set_price_info(d[0], price=d[1], time=l2_huaxin_util.convert_time(d[9]))
+ except Exception as e:
+ logger_debug.exception(e)
+
# 鏍规嵁楂樻爣鐨勫疄鏃舵定骞呰绠楁媺榛戞澘鍧�
rate_dict = {d[0]: d[2] for d in datas}
cls.__process_l1_data_thread_pool.submit(
--
Gitblit v1.8.0