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