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