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