From 37189a90d98e17c57a29fbe18ffae3331e3d000d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期日, 17 十一月 2024 18:52:38 +0800
Subject: [PATCH] 取消测试
---
l2/l2_transaction_data_processor.py | 23 ++++++++++++++---------
1 files changed, 14 insertions(+), 9 deletions(-)
diff --git a/l2/l2_transaction_data_processor.py b/l2/l2_transaction_data_processor.py
index 100703b..a2c6934 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.buy_radical.radical_buy_data_manager import RadicalBuyDataManager, EveryLimitupBigDealOrderManager
from utils import tool
@@ -51,7 +51,7 @@
@param datas:
@return:
"""
- limit_up_price = round(float(gpcode_manager.get_limit_up_price(code)), 2)
+ limit_up_price = gpcode_manager.get_limit_up_price_as_num(code)
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)
@@ -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,13 +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)
- cls.statistic_big_order_infos(code, datas, order_begin_pos)
- 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