From 1e64a42737bb6cc7192c68633d3c168ca150da97 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 22 十一月 2023 19:08:09 +0800
Subject: [PATCH] L下动态更新一次/加载订单是否成交
---
test/l2_trade_test.py | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/test/l2_trade_test.py b/test/l2_trade_test.py
index 591a364..34e575b 100644
--- a/test/l2_trade_test.py
+++ b/test/l2_trade_test.py
@@ -23,7 +23,7 @@
from third_data import kpl_util, kpl_data_manager, block_info
from third_data.code_plate_key_manager import LimitUpCodesPlateKeyManager, CodePlateKeyBuyManager, KPLCodeJXBlockManager
from third_data.kpl_data_manager import KPLDataManager
-from trade import trade_data_manager, current_price_process_manager, l2_trade_util
+from trade import trade_data_manager, current_price_process_manager, l2_trade_util, trade_manager
from trade.trade_queue_manager import THSBuy1VolumnManager
import l2.l2_data_manager_new, l2.l2_data_manager, l2.l2_data_util, l2.cancel_buy_strategy
@@ -85,10 +85,11 @@
except Exception as e:
pass
- @unittest.skip("璺宠繃姝ゅ崟鍏冩祴璇�")
+ # @unittest.skip("璺宠繃姝ゅ崟鍏冩祴璇�")
def test_trade(self):
+ trade_manager.TradeStateManager().open_buy()
threading.Thread(target=async_log_util.run_sync, daemon=True).start()
- code = "000026"
+ code = "002528"
clear_trade_data(code)
l2.l2_data_util.load_l2_data(code)
total_datas = deepcopy(l2.l2_data_util.local_today_datas[code])
@@ -151,7 +152,7 @@
current_price_process_manager.set_trade_price(code, round(float(gpcode_manager.get_limit_up_price(code)), 2))
pss_server, pss_strategy = multiprocessing.Pipe()
- huaxin_trade_api.run_pipe_trade(pss_server, None)
+ huaxin_trade_api.run_pipe_trade(pss_server, None, None)
for indexs in pos_list:
l2_log.threadIds[code] = mock.Mock(
--
Gitblit v1.8.0