From 3be964f68aab1128f6a96894a92e73130b516d97 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 22 十月 2024 18:12:25 +0800
Subject: [PATCH] 扫入策略修改

---
 l2/l2_transaction_data_processor.py |    7 +++++++
 1 files changed, 7 insertions(+), 0 deletions(-)

diff --git a/l2/l2_transaction_data_processor.py b/l2/l2_transaction_data_processor.py
index 011267e..74cc3e7 100644
--- a/l2/l2_transaction_data_processor.py
+++ b/l2/l2_transaction_data_processor.py
@@ -21,6 +21,7 @@
 from trade import current_price_process_manager, trade_constant
 import concurrent.futures
 
+from trade.radical_buy_data_manager import RedicalBuyDataManager
 from utils import tool
 
 
@@ -54,6 +55,7 @@
         buy_datas, bigger_buy_datas = HuaXinBuyOrderManager.statistic_big_buy_data(code, datas, limit_up_price)
         if buy_datas:
             BigOrderDealManager().add_buy_datas(code, buy_datas)
+            RedicalBuyDataManager.big_order_deal(code)
         try:
             is_placed_order = l2_data_manager.TradePointManager.is_placed_order(order_begin_pos)
             if is_placed_order and bigger_buy_datas:
@@ -109,6 +111,11 @@
                                 current_price_process_manager.set_latest_not_limit_up_time(code,
                                                                                            l2_huaxin_util.convert_time(
                                                                                                d[3], with_ms=True))
+                        else:
+                            # 涓诲姩鍗栵紙鏉夸笂锛�
+                            if d[1] == limit_up_price:
+                                L2LimitUpSellDataManager.clear_data(code)
+                                break
                 except:
                     pass
 

--
Gitblit v1.8.0