From 2f2516749615da866e96d8d24e499b7ecbb63a3e Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 23 六月 2025 12:28:52 +0800
Subject: [PATCH] 默认交易模式变更/真实下单位置计算位置修改
---
trade/trade_manager.py | 2 +-
l2/l2_data_manager_new.py | 27 +++++++++++++--------------
2 files changed, 14 insertions(+), 15 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index 2f111da..63c53cd 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -547,9 +547,19 @@
logger_l2_error.exception(e)
finally:
buy_open_limit_up_strategy.BuyOpenLimitupDataManager().remove_place_order_info(code)
-
- # 鑾峰彇涓嬪崟浣嶇疆
-
+ # 澶勭悊娑ㄥ仠鍗栦笌娑ㄥ仠鍗栨挙
+ try:
+ for d in add_datas:
+ if L2DataUtil.is_limit_up_price_sell(d['val']):
+ L2TradeSingleDataProcessor.add_l2_delegate_limit_up_sell(code, d)
+ elif L2DataUtil.is_limit_up_price_sell_cancel(d['val']):
+ L2TradeSingleDataProcessor.add_l2_delegate_limit_up_sell_cancel(code,
+ d['val']['orderNo'])
+ except Exception as e:
+ 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)
@@ -569,17 +579,6 @@
except:
pass
async_log_util.info(logger_l2_process, f"code:{code} 鑾峰彇鍒颁笅鍗曠湡瀹炰綅缃細{place_order_index}")
-
- # 澶勭悊娑ㄥ仠鍗栦笌娑ㄥ仠鍗栨挙
- try:
- for d in add_datas:
- if L2DataUtil.is_limit_up_price_sell(d['val']):
- L2TradeSingleDataProcessor.add_l2_delegate_limit_up_sell(code, d)
- elif L2DataUtil.is_limit_up_price_sell_cancel(d['val']):
- L2TradeSingleDataProcessor.add_l2_delegate_limit_up_sell_cancel(code,
- d['val']['orderNo'])
- except Exception as e:
- logger_debug.exception(e)
except:
async_log_util.error(logger_l2_error, f"{code} 澶勭悊鐪熷疄涓嬪崟浣嶇疆鍑洪敊")
# 绗�1鏉℃暟鎹槸鍚︿负09:30:00
diff --git a/trade/trade_manager.py b/trade/trade_manager.py
index f2a467e..3f3bb35 100644
--- a/trade/trade_manager.py
+++ b/trade/trade_manager.py
@@ -130,7 +130,7 @@
# 榛樿璁剧疆涓哄彲浜ゆ槗
val = RedisUtils.get(cls.__get_redis(), "trade_buy_mode")
if val is None:
- return cls.MODE_BUY_ALL
+ return cls.MODE_ONLY_BUY_WANT_CODES
return int(val)
def get_mode_cache(self):
--
Gitblit v1.8.0