From 1471480f5307d9f75b6e87e246cc14c131fb4639 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 14 六月 2024 15:36:21 +0800
Subject: [PATCH] L2订阅接口更新
---
l2/l2_data_manager_new.py | 33 ++++++++++++++++++++-------------
1 files changed, 20 insertions(+), 13 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index eda3a57..975d6d4 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -954,6 +954,9 @@
@classmethod
def __can_buy_first(cls, code):
+ if code.find("60") == 0:
+ return False, True, f"涓婅瘉鏆備笉浜ゆ槗"
+
if not cls.__TradeStateManager.is_can_buy_cache():
return False, True, f"浠婃棩宸茬姝氦鏄�"
@@ -1064,13 +1067,15 @@
limit_up_price = round(float(gpcode_manager.get_limit_up_price(code)), 2)
# 浠庢垚浜よ繘搴︿綅鍒版埅鑷充綅缃绠楀ぇ鍗�
min_money = l2_data_util.get_big_money_val(limit_up_price)
- left_count, left_money = cancel_buy_strategy.L2DataComputeUtil.compute_left_buy_order(code, trade_index, total_data[-1]["index"],
- limit_up_price,
- min_money=min_money)
+ left_count, left_money = cancel_buy_strategy.L2DataComputeUtil.compute_left_buy_order(code,
+ trade_index,
+ total_data[
+ -1][
+ "index"],
+ limit_up_price,
+ min_money=min_money)
if left_count < 1:
return False, False, f"娌℃湁宸叉寕鎴栬�呮垚浜ょ殑澶у崟"
-
-
# 鏆傛椂娉ㄩ噴鎯充拱鍗曞姛鑳�
if not cls.__WantBuyCodesManager.is_in_cache(code):
@@ -1509,7 +1514,8 @@
threshold_money = threshold_money_new
order_begin_pos.threshold_money = threshold_money
- l2_log.debug(code, "鑼冨洿锛歿}-{} m鍊�-{} 閲忔瘮:{} rebegin_buy_pos:{} clear_buy_single:{}", compute_start_index, compute_end_index,
+ l2_log.debug(code, "鑼冨洿锛歿}-{} m鍊�-{} 閲忔瘮:{} rebegin_buy_pos:{} clear_buy_single:{}", compute_start_index,
+ compute_end_index,
threshold_money, cls.volume_rate_info[code][0],
rebegin_buy_pos, clear_buy_single)
@@ -1555,13 +1561,14 @@
# 璁板綍涔板叆淇″彿浣嶇疆
if not clear_buy_single:
# 娌℃湁娓呴櫎淇″彿浣嶇疆灏变繚瀛樹笅鍗曚綅缃俊鎭�
- cls.__save_order_begin_data(code, OrderBeginPosInfo(buy_single_index=buy_single_index, buy_exec_index=-1,
- buy_compute_index=compute_end_index, num=buy_nums,
- count=buy_count,
- mode_desc=order_begin_pos.mode_desc,
- max_num_set=max_num_set_new, mode=order_begin_pos.mode,
- sell_info=order_begin_pos.sell_info,
- threshold_money=threshold_money))
+ cls.__save_order_begin_data(code,
+ OrderBeginPosInfo(buy_single_index=buy_single_index, buy_exec_index=-1,
+ buy_compute_index=compute_end_index, num=buy_nums,
+ count=buy_count,
+ mode_desc=order_begin_pos.mode_desc,
+ max_num_set=max_num_set_new, mode=order_begin_pos.mode,
+ sell_info=order_begin_pos.sell_info,
+ threshold_money=threshold_money))
# 璁板綍娌′笅鍗曞師鍥�
async_log_util.info(logger_l2_not_buy_reasons, f"{code}#{not_buy_msg}")
_start_time = t.time()
--
Gitblit v1.8.0