From 96f0ec293227e751902a73484e6f87b1e65a35fc Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期三, 19 三月 2025 16:15:24 +0800 Subject: [PATCH] 恢复为原来的下单方式 --- l2/l2_transaction_data_processor.py | 21 +++++++++------------ 1 files changed, 9 insertions(+), 12 deletions(-) diff --git a/l2/l2_transaction_data_processor.py b/l2/l2_transaction_data_processor.py index 8039651..96d0c9a 100644 --- a/l2/l2_transaction_data_processor.py +++ b/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 -- Gitblit v1.8.0