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