From 60d02096d9dc4bc9cb54f8cf81becd10a9dd0c61 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 24 十月 2023 16:22:47 +0800
Subject: [PATCH] L前3s囊括一次/增加L2数据接口/接口输出交易信息
---
l2/l2_transaction_data_manager.py | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/l2/l2_transaction_data_manager.py b/l2/l2_transaction_data_manager.py
index c9f38c5..389bc76 100644
--- a/l2/l2_transaction_data_manager.py
+++ b/l2/l2_transaction_data_manager.py
@@ -72,10 +72,9 @@
rate = round(total_deal_nums / (thresh_hold_money // (float(limit_up_price) * 100)), 2)
LCancelRateManager().set_big_num_deal_rate(code, rate)
+ # 鑾峰彇鎵ц浣嶆椂闂�
+ buy_single_index, buy_exec_index, compute_index, num, count, max_num_set, volume_rate = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(code)
if buy_progress_index is not None:
- # 鑾峰彇鎵ц浣嶆椂闂�
- buy_single_index, buy_exec_index, compute_index, num, count, max_num_set, volume_rate = l2_data_manager.TradePointManager().get_buy_compute_start_data_cache(
- code)
cls.__TradeBuyQueue.set_traded_index(code, buy_progress_index)
async_log_util.info(logger_l2_trade_buy_queue, "鑾峰彇鎴愪氦浣嶇疆鎴愬姛锛� code-{} index-{}", code,
buy_progress_index)
@@ -100,6 +99,10 @@
HourCancelBigNumComputer().set_transaction_index(code, buy_progress_index)
else:
pass
+ if buy_exec_index and buy_exec_index > -1:
+ # 瑙﹀彂L鎾や笂閲嶆柊璁＄畻
+ LCancelBigNumComputer().re_compute_l_up_watch_indexes(code)
+
except Exception as e:
hx_logger_l2_transaction.exception(e)
finally:
--
Gitblit v1.8.0