From 3da6b577db3dcec38a3a3ed6a6230d0598ca072a Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期一, 04 十一月 2024 15:28:42 +0800 Subject: [PATCH] 触发扫入的成交比例阈值修改 --- code_attribute/first_target_code_data_processor.py | 40 +++++++++++++++++++++++++--------------- 1 files changed, 25 insertions(+), 15 deletions(-) diff --git a/code_attribute/first_target_code_data_processor.py b/code_attribute/first_target_code_data_processor.py index e14eb1a..5d7369b 100644 --- a/code_attribute/first_target_code_data_processor.py +++ b/code_attribute/first_target_code_data_processor.py @@ -11,7 +11,7 @@ from code_attribute.code_nature_analyse import HighIncreaseCodeManager from code_attribute.gpcode_manager import WantBuyCodesManager from log_module import async_log_util -from log_module.log import logger_first_code_record, logger_l2_codes_subscript +from log_module.log import logger_first_code_record, logger_l2_codes_subscript, logger_debug from third_data import history_k_data_manager from third_data.code_plate_key_manager import CodesHisReasonAndBlocksManager from third_data.history_k_data_manager import HistoryKDataManager @@ -119,8 +119,10 @@ code, limit_up_price, volumes_data[:90])) + max_volume_in_5_days = init_data_util.parse_max_volume_in_days(volumes_data, 5) + async_log_util.info(logger_first_code_record, f"{code} 鑾峰彇鍒伴鏉�60澶╂渶澶ч噺锛歿volumes}") - code_volumn_manager.set_histry_volumn(code, volumes[0], volumes[1], volumes[2], volumes[3]) + code_volumn_manager.CodeVolumeManager().set_histry_volumn(code, volumes[0], volumes[1], volumes[2], volumes[3], max_volume_in_5_days) # 淇濆瓨K绾垮舰鎬� k_format = code_nature_analyse.get_k_format(code, limit_up_price, volumes_data) @@ -128,7 +130,8 @@ # 鏄惁鍏锋湁杈ㄨ瘑搴� is_special = True if k_format and k_format[8][0] else False - if not WantBuyCodesManager().is_in_cache(code): + if not WantBuyCodesManager().is_in_cache(code) and not gpcode_manager.BuyOpenLimitUpCodeManager().is_in_cache(code): + # 涓嶆槸鎯充拱鍗曪紝涔熶笉鏄帓涓�鐨勪唬鐮� if not is_special: situation = MarketSituationManager().get_situation_cache() zylt_threshold_as_yi = buy_condition_util.get_zyltgb_threshold(situation) @@ -137,25 +140,32 @@ l2_trade_util.forbidden_trade(code, f"鏃犺鲸璇嗗害锛岃嚜鐢辨祦閫氬競鍊�({global_util.zyltgb_map.get(code) // 100000000})>{zylt_threshold_as_yi[1]}浜�") continue - elif limit_up_price and float(limit_up_price) >= 50: + elif limit_up_price and float(limit_up_price) >= constant.MAX_CODE_PRICE: l2_trade_util.forbidden_trade(code, - f"鏃犺鲸璇嗗害锛屾定鍋滀环({limit_up_price})>50") + f"鏃犺鲸璇嗗害锛屾定鍋滀环({limit_up_price})>{constant.MAX_CODE_PRICE}") continue - # if code_nature_analyse.is_price_too_high_in_days(code, volumes_data, limit_up_price)[ - # 0] and code.find("30") != 0: - # # 鍒ゆ柇鏄惁澶珮 - # l2_trade_util.forbidden_trade(code, "6澶╁唴鑲′环闀垮緱澶珮") - # continue - # pass + if code_nature_analyse.is_price_too_high_in_days(code, volumes_data, limit_up_price)[ + 0] and code.find("30") != 0: + # 鍒ゆ柇鏄惁澶珮 + l2_trade_util.forbidden_trade(code, "6澶╁唴鑲′环闀垮緱澶珮") + continue + pass + + if len(k_format) > 14 and k_format[14]: + l2_trade_util.forbidden_trade(code, "鏄ㄦ棩鐐告澘") + continue if code_nature_analyse.is_continue_limit_up_not_enough_fall_dwon(code, volumes_data): # 鍒ゆ柇鏄惁澶珮 l2_trade_util.forbidden_trade(code, "鍥炶俯涓嶅") continue - - if not __is_normal_in_5d(code): - l2_trade_util.forbidden_trade(code, "鏈�杩�5澶╂湁ST/闈炴甯哥姸鎬�") - continue + try: + if not __is_normal_in_5d(code): + l2_trade_util.forbidden_trade(code, "鏈�杩�5澶╂湁ST/闈炴甯哥姸鎬�") + continue + except Exception as e: + logger_debug.error(f"{code}鍑洪敊__is_normal_in_5d") + logger_debug.exception(e) if code_nature_analyse.is_up_too_high_in_10d_with_limit_up(code, volumes_data): # 鍒ゆ柇鏄惁澶珮 -- Gitblit v1.8.0