zeromq集成测试

Administrator

2024-02-27 64acc2bcd5e531f02be2da919e97b7af6bc86e4a

 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: