From 93ec042ae730c8e4cad1562d7ee579941847397c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 07 十一月 2024 18:37:44 +0800
Subject: [PATCH] 扫入整改
---
l2/l2_transaction_data_processor.py | 24 +++++++++++++-----------
1 files changed, 13 insertions(+), 11 deletions(-)
diff --git a/l2/l2_transaction_data_processor.py b/l2/l2_transaction_data_processor.py
index 03fa75a..15d865e 100644
--- a/l2/l2_transaction_data_processor.py
+++ b/l2/l2_transaction_data_processor.py
@@ -21,7 +21,7 @@
from trade import current_price_process_manager, trade_constant
import concurrent.futures
-from trade.radical_buy_data_manager import RedicalBuyDataManager, EveryLimitupBigDealOrderManager
+from trade.radical_buy_data_manager import RadicalBuyDataManager, EveryLimitupBigDealOrderManager
from utils import tool
@@ -60,7 +60,7 @@
is_placed_order = l2_data_manager.TradePointManager.is_placed_order(order_begin_pos)
if is_placed_order:
if order_begin_pos and order_begin_pos.mode == OrderBeginPosInfo.MODE_RADICAL:
- RedicalBuyDataManager.big_order_deal(code)
+ RadicalBuyDataManager.big_order_deal(code)
if is_placed_order and bigger_buy_datas:
# 鏈夊ぇ浜�50w鐨勫ぇ鍗曟垚浜�
@@ -106,6 +106,17 @@
order_begin_pos = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(code)
# 鏄惁宸茬粡涓嬪崟
is_placed_order = l2_data_manager.TradePointManager.is_placed_order(order_begin_pos)
+
+ _start_time = time.time()
+ L2LimitUpSellDataManager.set_deal_datas(code, datas)
+ # 澶у崟缁熻
+ # cls.__statistic_thread_pool.submit(cls.statistic_big_order_infos, code, datas, order_begin_pos)
+ try:
+ cls.statistic_big_order_infos(code, datas, order_begin_pos)
+ except Exception as e:
+ hx_logger_l2_debug.error(f"缁熻澶у崟鍑洪敊锛歿str(e)}")
+ use_time_list.append(("缁熻涔板崟鏁版嵁", time.time() - _start_time))
+ _start_time = time.time()
big_sell_order_info = None
try:
@@ -163,16 +174,7 @@
except Exception as e:
async_log_util.error(logger_debug, f"鍗栧崟缁熻寮傚父锛歿big_sell_order_info}")
logger_debug.exception(e)
- _start_time = time.time()
- L2LimitUpSellDataManager.set_deal_datas(code, datas)
- # 澶у崟缁熻
- # cls.__statistic_thread_pool.submit(cls.statistic_big_order_infos, code, datas, order_begin_pos)
- try:
- cls.statistic_big_order_infos(code, datas, order_begin_pos)
- except Exception as e:
- hx_logger_l2_debug.error(f"缁熻澶у崟鍑洪敊锛歿str(e)}")
- use_time_list.append(("缁熻涔板崟鏁版嵁", time.time() - _start_time))
_start_time = time.time()
# if big_money_count > 0:
# LCancelRateManager.compute_big_num_deal_rate(code)
--
Gitblit v1.8.0