From cf89766b43b7e5601220e5144edab8ee9307a8ad Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 26 三月 2025 17:29:03 +0800
Subject: [PATCH] 新题材拉黑机制修改
---
l2/l2_transaction_data_processor.py | 21 ++++++---------------
1 files changed, 6 insertions(+), 15 deletions(-)
diff --git a/l2/l2_transaction_data_processor.py b/l2/l2_transaction_data_processor.py
index 4a9ce1b..da273ab 100644
--- a/l2/l2_transaction_data_processor.py
+++ b/l2/l2_transaction_data_processor.py
@@ -116,7 +116,7 @@
limit_up_price = gpcode_manager.get_limit_up_price_as_num(code)
- if len(fdatas) > 100:
+ if False and len(fdatas) > 100:
# 骞惰澶勭悊涔板崟涓庡崠鍗�
# 瓒呰繃100鏉℃暟鎹墠闇�瑕佸苟琛屽鐞�
f1 = dask.delayed(statistic_big_buy_data)()
@@ -187,21 +187,12 @@
_start_time = time.time()
try:
+ last_data = fdatas[-1]
# 缁熻涓婃澘鏃堕棿
- try:
- for d in fdatas:
- if d[1]:
- # 涓诲姩涔�
- if d[2]:
- # 娑ㄥ仠
- current_price_process_manager.set_latest_not_limit_up_time(code, d[5])
- else:
- # 涓诲姩鍗栵紙鏉夸笂锛�
- if d[2]:
- L2LimitUpSellDataManager.clear_data(code)
- break
- except:
- pass
+ if last_data[1] and last_data[2]:
+ current_price_process_manager.set_latest_not_limit_up_time(code, last_data[5])
+ if not last_data[1] and last_data[2]:
+ L2LimitUpSellDataManager.clear_data(code)
big_sell_order_info = None
# 缁熻鍗栧崟
big_sell_order_info = HuaXinSellOrderStatisticManager.statistic_continue_limit_up_sell_transaction_datas(
--
Gitblit v1.8.0