恢复为原来的下单方式

Administrator

2025-03-19 96f0ec293227e751902a73484e6f87b1e65a35fc

 l2/l2_transaction_data_processor.py

@@ -242,11 +242,10 @@
            if buy_progress_index is not None:
                buy_progress_index_changed = cls.__TradeBuyQueue.set_traded_index(code, buy_progress_index,
                                                                                  total_datas)
                async_log_util.info(logger_l2_trade_buy_queue, "获取成交位置成功： code-{} index-{}", code,
                                    buy_progress_index)
                l2_log.info(code, logger_l2_trade_buy_queue, "获取成交位置成功： code-{} index-{}", code, buy_progress_index)
                if is_placed_order:
                    NewGCancelBigNumComputer().set_trade_progress(code, order_begin_pos.buy_single_index,
                                                                  buy_progress_index)
                    # NewGCancelBigNumComputer().set_trade_progress(code, order_begin_pos.buy_single_index,
                    #                                               buy_progress_index)
                    LCancelBigNumComputer().set_trade_progress(code, order_begin_pos.buy_single_index,
                                                               buy_progress_index,
                                                               total_datas)
@@ -271,11 +270,10 @@
                                                                cancel_type=trade_constant.CANCEL_TYPE_W)
                        except:
                            pass

                    SCancelBigNumComputer().set_transaction_index(code, order_begin_pos.buy_single_index,
                                                                  buy_progress_index)
                    HourCancelBigNumComputer().set_transaction_index(code, order_begin_pos.buy_single_index,
                                                                     buy_progress_index)
                    # SCancelBigNumComputer().set_transaction_index(code, order_begin_pos.buy_single_index,
                    #                                               buy_progress_index)
                    # HourCancelBigNumComputer().set_transaction_index(code, order_begin_pos.buy_single_index,
                    #                                                  buy_progress_index)
            else:
                pass
            if is_placed_order:
@@ -367,7 +365,7 @@
            # 设置成交价
            try:
                current_price_process_manager.set_trade_price(code, fdatas[-1][0][1])
                if limit_up_price > fdatas[-1][0][1]:
                if not fdatas[-1][2]:
                    # 没有涨停
                    EveryLimitupBigDealOrderManager.open_limit_up(code, f"最新成交价：{fdatas[-1][0][1]}")
                    radical_buy_strategy.clear_data(code)
@@ -382,8 +380,7 @@
                    current_price_process_manager.set_latest_not_limit_up_time(code, last_data[5])
                elif not last_data[1] and last_data[2]:
                    # 涨停主动卖
                    if last_data[2]:
                        L2LimitUpSellDataManager.clear_data(code)
                    L2LimitUpSellDataManager.clear_data(code)
            except:
                pass