From 64acc2bcd5e531f02be2da919e97b7af6bc86e4a Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期二, 27 二月 2024 16:52:21 +0800 Subject: [PATCH] zeromq集成测试 --- l2/l2_transaction_data_processor.py | 8 +++++--- 1 files changed, 5 insertions(+), 3 deletions(-) diff --git a/l2/l2_transaction_data_processor.py b/l2/l2_transaction_data_processor.py index 836c138..14b94b3 100644 --- a/l2/l2_transaction_data_processor.py +++ b/l2/l2_transaction_data_processor.py @@ -109,6 +109,9 @@ if order_begin_pos and order_begin_pos.buy_exec_index and order_begin_pos.buy_exec_index > -1: HourCancelBigNumComputer().set_transaction_index(code, order_begin_pos.buy_single_index, buy_progress_index) + cresult = FCancelBigNumComputer().need_cancel_for_deal_fast(code,buy_progress_index) + if cresult[0]: + L2TradeDataProcessor.cancel_buy(code, f"涓嬪崟5鍒嗛挓鍐呮帓鍗曚笉瓒�:{cresult[1]}") # ---------------------------------鍒ゆ柇鏉垮潡鏄惁璺熶笂鏉ヤ簡------------------------------- try: pass @@ -130,10 +133,9 @@ if real_order_index and real_order_index >= buy_progress_index: # 鍙戦�佷笅鍗曟秷鎭� try: - buy_order_msg_manager.almost_deal(code, real_order_index, buy_progress_index, - total_datas) + buy_order_msg_manager.almost_deal(code, real_order_index, buy_progress_index) buy_order_msg_manager.follow_not_enough(code, order_begin_pos.buy_exec_index, - real_order_index, total_datas) + real_order_index) except Exception as e: logger_debug.exception(e) else: -- Gitblit v1.8.0