From d2aefca018e8a66f7aed54e7cf03f1cb54d65926 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 24 三月 2025 10:38:12 +0800
Subject: [PATCH] bug修复
---
l2/l2_data_manager_new.py | 16 ++++++----------
1 files changed, 6 insertions(+), 10 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index 5940243..eaba884 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -181,6 +181,7 @@
num_splites = [round(5000 / limit_up_price), round(10000 / limit_up_price), round(20000 / limit_up_price),
round(30000 / limit_up_price)]
total_num = 0
+ buyno_map = local_today_buyno_map.get(code)
for i in range(max(start_index, processed_index), end_index + 1):
data = total_datas[i]
if not L2DataUtil.is_limit_up_price_buy_cancel(data["val"]) and not L2DataUtil.is_limit_up_price_buy(
@@ -189,9 +190,7 @@
# 濡傛灉鏄定鍋滀拱鎾や俊鍙烽渶瑕佺湅鏁版嵁浣嶇疆鏄惁姣斿紑濮嬪鐞嗘椂闂存棭
if L2DataUtil.is_limit_up_price_buy_cancel(data["val"]):
# 鑾峰彇涔板叆淇″彿
- buy_index = l2_data_source_util.L2DataSourceUtils.get_buy_index_with_cancel_data_v2(total_datas[i],
- local_today_buyno_map.get(
- code))
+ buy_index = l2_data_source_util.L2DataSourceUtils.get_buy_index_with_cancel_data_v2(total_datas[i], buyno_map)
if buy_index is not None and buy_index < begin_pos:
continue
@@ -2196,6 +2195,7 @@
if place_order_count is None:
place_order_count = 0
is_ge_code = tool.is_ge_code(code)
+ buy_no_map = local_today_buyno_map.get(code)
for i in range(compute_start_index, compute_end_index + 1):
data = total_datas[i]
_val = total_datas[i]["val"]
@@ -2230,11 +2230,8 @@
f"{code}鑾峰彇鍒颁拱鍏ユ墽琛岀偣(蹇�熶拱鍏�)锛歿i} 缁熻绾拱鎵嬫暟锛歿buy_nums} 鐩爣绾拱鎵嬫暟锛歿threshold_num} 缁熻绾拱鍗曟暟锛歿buy_count}")
elif L2DataUtil.is_limit_up_price_buy_cancel(_val):
# 鍒ゆ柇涔板叆浣嶇疆鏄惁鍦ㄤ拱鍏ヤ俊鍙蜂箣鍓�
- buy_index = l2_data_source_util.L2DataSourceUtils.get_buy_index_with_cancel_data_v2(total_datas[i],
- local_today_buyno_map.get(
- code))
+ buy_index = l2_data_source_util.L2DataSourceUtils.get_buy_index_with_cancel_data_v2(total_datas[i], buy_no_map)
if buy_index is not None:
-
# 鎵惧埌涔版挙鏁版嵁鐨勪拱鍏ョ偣
if buy_index >= buy_single_index:
max_buy_num_set.discard(buy_index)
@@ -2335,6 +2332,7 @@
max_buy_num_set = set(max_num_set)
active_buy_blocks = cls.get_active_buy_blocks(code)
is_ge_code = tool.is_ge_code(code)
+ buyno_map = local_today_buyno_map.get(code)
for i in range(compute_start_index, compute_end_index + 1):
data = total_datas[i]
_val = total_datas[i]["val"]
@@ -2372,9 +2370,7 @@
f"{code}鑾峰彇鍒颁拱鍏ユ墽琛岀偣(绉瀬涓嬪崟)锛歿i} 缁熻绾拱鎵嬫暟锛歿buy_nums} 鐩爣绾拱鎵嬫暟锛歿threshold_num} 缁熻绾拱鍗曟暟锛歿buy_count}")
elif L2DataUtil.is_limit_up_price_buy_cancel(_val):
# 鍒ゆ柇涔板叆浣嶇疆鏄惁鍦ㄤ拱鍏ヤ俊鍙蜂箣鍓�
- buy_index = l2_data_source_util.L2DataSourceUtils.get_buy_index_with_cancel_data_v2(total_datas[i],
- local_today_buyno_map.get(
- code))
+ buy_index = l2_data_source_util.L2DataSourceUtils.get_buy_index_with_cancel_data_v2(total_datas[i], buyno_map)
if buy_index is not None:
# 鎵惧埌涔版挙鏁版嵁鐨勪拱鍏ョ偣
--
Gitblit v1.8.0