From bda4216d608a12db7132c97083c19ecdad48d78f Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 28 八月 2024 18:29:21 +0800
Subject: [PATCH] 激进买入
---
servers/huaxin_trade_server.py | 5 ++---
1 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/servers/huaxin_trade_server.py b/servers/huaxin_trade_server.py
index 8f24066..88a6b17 100644
--- a/servers/huaxin_trade_server.py
+++ b/servers/huaxin_trade_server.py
@@ -37,7 +37,7 @@
from log_module.log import hx_logger_contact_debug, hx_logger_trade_callback, \
hx_logger_l2_orderdetail, hx_logger_l2_market_data, logger_l2_g_cancel, logger_debug, \
logger_system, logger_trade, logger_local_huaxin_l1_trade_info, logger_l2_codes_subscript
-from third_data import block_info, kpl_data_manager, history_k_data_manager
+from third_data import block_info, kpl_data_manager, history_k_data_manager, huaxin_l1_data_manager
from third_data.code_plate_key_manager import KPLCodeJXBlockManager, CodePlateKeyBuyManager
from third_data.history_k_data_util import JueJinApi
from trade import trade_manager, l2_trade_util, \
@@ -277,7 +277,6 @@
__GCancelBigNumComputer = GCancelBigNumComputer()
__sell_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=10)
__process_l1_data_thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=10)
- current_buy1_dict = {}
__updating_jx_blocks_codes = set()
@classmethod
@@ -341,7 +340,7 @@
# 鏍煎紡 (浠ｇ爜,鐜颁环,娑ㄥ箙,閲�,鏇存柊鏃堕棿,涔�1浠锋牸,涔�1閲�)
price = d[1]
L1DataManager.set_l1_current_price(code, price)
- cls.current_buy1_dict[code] = (d[5], d[6])
+ huaxin_l1_data_manager.set_buy1_data(code,d[5], d[6])
# 鑾峰彇L1鐜颁环
@classmethod
--
Gitblit v1.8.0