From 2598f02b60d26264986881e5368515ed3d6a1f36 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期日, 14 九月 2025 23:15:47 +0800
Subject: [PATCH] 新版激进下单（抛压消耗完之后300w后挂单）
---
output/l2_output_util.py | 13 +++++++++++--
1 files changed, 11 insertions(+), 2 deletions(-)
diff --git a/output/l2_output_util.py b/output/l2_output_util.py
index 458aa0e..00a693a 100644
--- a/output/l2_output_util.py
+++ b/output/l2_output_util.py
@@ -1,16 +1,20 @@
"""
L2鏁版嵁杈撳嚭宸ュ叿
"""
+from code_attribute import gpcode_manager
from l2 import l2_data_util, l2_data_source_util
from l2.l2_data_util import L2DataUtil, local_today_canceled_buyno_map
from l2.l2_transaction_data_manager import HuaXinBuyOrderManager
from l2.transaction_progress import TradeBuyQueue
+from utils import tool
def __get_trade_queue(code, start_index, end_index, real_place_order_index, max_count, step=1):
fresults = []
# 姝ｅ湪鎴愪氦鐨勬暟鎹�
dealing_info = HuaXinBuyOrderManager.get_dealing_order_info(code)
+ dealing_active_info = HuaXinBuyOrderManager.get_dealing_active_order_info(code)
+
total_datas = l2_data_util.local_today_datas.get(code)
for i in range(start_index, end_index, step):
# 鐪熷疄涓嬪崟浣嶇疆涓嶇鏄惁鎾ゅ崟閮介渶瑕佸姞鍏ラ槦鍒�
@@ -34,13 +38,18 @@
dealing_info[0]):
# 鍑忓幓褰撳墠姝ｅ湪鎴愪氦鐨勬暟鎹腑宸茬粡鎴愪氦浜嗙殑鏁版嵁
num -= dealing_info[1] // 100
+ # 鍒ゆ柇褰撳墠鍗曠殑涓诲姩涔扮殑鏁伴噺
+ if dealing_active_info and str(total_datas[i]["val"]["orderNo"]) == str(
+ dealing_active_info[0]):
+ if tool.is_sh_code(code):
+ # 涓婅瘉鐨勭エ闇�瑕佸姞涓婁富鍔ㄤ拱鐨勬暟鎹�
+ num += dealing_active_info[1] // 100
if i == real_place_order_index:
type_ = 1
has_real_order_index = True
elif num * float(val['price']) >= 29900:
type_ = 2
-
- fresults.append((num, type_))
+ fresults.append((num, type_, int(num * float(val['price']) * 100)))
if len(fresults) > max_count:
break
return fresults
--
Gitblit v1.8.0