From e31fc732b89baf27f7f999b6c89013b83066e513 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 10 七月 2025 10:42:11 +0800
Subject: [PATCH] 真实下单位获取位置调整
---
l2/l2_data_manager_new.py | 43 +++++++++++++++++++++++--------------------
1 files changed, 23 insertions(+), 20 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index b3234c6..4e09c6e 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -559,26 +559,7 @@
logger_debug.exception(e)
finally:
# 鎵ц鏈�鍚庡啀鑾峰彇鐪熷疄涓嬪崟浣嶇疆锛岄槻姝笅鍗曚綅缃偅鎵规暟鎹湁澶ф壒閲忕殑鎾ゅ崟
- # ======鑾峰彇涓嬪崟浣嶇疆
- if constant.IS_NEW_VERSION_PLACE_ORDER:
- place_order_index, order_info, compute_type = huaxin_delegate_postion_manager.RealDelegateOrderPositionManager.compute_l2_place_order_position(
- code, add_datas)
- else:
- place_order_index, order_info, compute_type = huaxin_delegate_postion_manager.get_l2_place_order_position(
- code, float(
- gpcode_manager.get_limit_up_price(code)), add_datas)
-
- if place_order_index:
- order_begin_pos = cls.__get_order_begin_pos(
- code)
- cls.set_real_place_order_index(code, place_order_index, order_begin_pos, order_info[1])
- try:
- cls.__re_compute_threading_pool.submit(
- cls.__recompute_real_order_index, code, place_order_index, order_info,
- compute_type)
- except:
- pass
- async_log_util.info(logger_l2_process, f"code:{code} 鑾峰彇鍒颁笅鍗曠湡瀹炰綅缃細{place_order_index}")
+ pass
except:
async_log_util.error(logger_l2_error, f"{code} 澶勭悊鐪熷疄涓嬪崟浣嶇疆鍑洪敊")
# 绗�1鏉℃暟鎹槸鍚︿负09:30:00
@@ -654,6 +635,28 @@
# 宸叉寕鍗�
place_ordered_desc = "宸蹭笅鍗�"
cls.__process_order(code, start_index, end_index, capture_timestamp, is_first_code)
+ # ======鑾峰彇涓嬪崟浣嶇疆
+ state = cls.__CodesTradeStateManager.get_trade_state_cache(code)
+ if trade_util.is_delegated(state):
+ if constant.IS_NEW_VERSION_PLACE_ORDER:
+ place_order_index, order_info, compute_type = huaxin_delegate_postion_manager.RealDelegateOrderPositionManager.compute_l2_place_order_position(
+ code, add_datas)
+ else:
+ place_order_index, order_info, compute_type = huaxin_delegate_postion_manager.get_l2_place_order_position(
+ code, float(
+ gpcode_manager.get_limit_up_price(code)), add_datas)
+
+ if place_order_index:
+ order_begin_pos = cls.__get_order_begin_pos(
+ code)
+ cls.set_real_place_order_index(code, place_order_index, order_begin_pos, order_info[1])
+ try:
+ cls.__re_compute_threading_pool.submit(
+ cls.__recompute_real_order_index, code, place_order_index, order_info,
+ compute_type)
+ except:
+ pass
+ async_log_util.info(logger_l2_process, f"code:{code} 鑾峰彇鍒颁笅鍗曠湡瀹炰綅缃細{place_order_index}")
else:
place_ordered_desc = "鏈笅鍗�"
# 鏈寕鍗�,鏃堕棿鐩稿樊涓嶅ぇ鎵嶈兘鎸傚崟
--
Gitblit v1.8.0