From 045a5aa6434da6e83c3d850b17e7e58cd7b55ef5 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 15 五月 2023 15:46:32 +0800
Subject: [PATCH] 开盘啦板块影响交易逻辑

---
 third_data/block_info.py |   24 +++++++++++++-----------
 1 files changed, 13 insertions(+), 11 deletions(-)

diff --git a/third_data/block_info.py b/third_data/block_info.py
index f9f2c11..9b2dc17 100644
--- a/third_data/block_info.py
+++ b/third_data/block_info.py
@@ -3,6 +3,7 @@
 """
 import datetime
 
+import constant
 import juejin
 import tool
 from third_data import kpl_util, kpl_data_manager
@@ -34,7 +35,7 @@
     for data in limit_up_datas:
         if data[0] == code:
             block = data[5]
-            if block in kpl_data_manager.INVALID_BLOCKS and filter:
+            if block in constant.KPL_INVALID_BLOCKS and filter:
                 continue
             blocks.append(block)
     return blocks
@@ -73,7 +74,7 @@
     return blocks
 
 
-def get_target_block(code, filter=False):
+def get_target_block_info(code, filter=False):
     latest_datas = __kplDataManager.get_data(kpl_util.KPLDataType.LIMIT_UP)
     blocks = __get_blocks(code, latest_datas, filter)
     if not blocks:
@@ -82,7 +83,7 @@
     target_block = None
     if blocks:
         for block in blocks:
-            if block in kpl_data_manager.INVALID_BLOCKS and filter:
+            if block in constant.KPL_INVALID_BLOCKS and filter:
                 continue
             target_block = block
             break
@@ -104,7 +105,7 @@
     target_block = None
     if blocks:
         for block in blocks:
-            if block in kpl_data_manager.INVALID_BLOCKS:
+            if block in constant.KPL_INVALID_BLOCKS:
                 continue
             target_block = block
             break
@@ -139,7 +140,7 @@
     # 鏄惁鍑虹幇杩囬珮浣嶆澘
     high_block_infos = []
     for block in blocks:
-        if block in kpl_data_manager.INVALID_BLOCKS:
+        if block in constant.KPL_INVALID_BLOCKS:
             continue
         if latest_datas:
             has_high, high_code_info = __is_has_high_code(block, latest_datas)
@@ -183,12 +184,13 @@
     re_limit_codes = set()
     # 鐐告澘锛�
     # (浠g爜,鍚嶇О,娑ㄥ箙,鏉垮潡,瀹為檯娴侀��)
-    for data in open_limit_up_datas:
-        blocks = set(data[3].split("銆�"))
-        if target_block not in blocks:
-            continue
-        code_ = data[0]
-        break_codes.add(code_)
+    if open_limit_up_datas:
+        for data in open_limit_up_datas:
+            blocks = set(data[3].split("銆�"))
+            if target_block not in blocks:
+                continue
+            code_ = data[0]
+            break_codes.add(code_)
     # 缁熻鍥炲皝
     for data in latest_datas:
         if data[5] != target_block:

--
Gitblit v1.8.0