| | |
| | | from db import mysql_data_delegate as mysql_data, redis_manager_delegate as redis_manager |
| | | from log_module.log import logger_kpl_limit_up_reason_change, logger_debug, logger_kpl_limit_up, \ |
| | | logger_kpl_open_limit_up |
| | | from third_data import kpl_util, kpl_api |
| | | from third_data import kpl_util, kpl_api, kpl_data_constant |
| | | from third_data.code_plate_key_manager import LimitUpCodesPlateKeyManager, CodesHisReasonAndBlocksManager |
| | | |
| | | # 代码对应的涨停原因保存 |
| | |
| | | code_block_dict[code] = set() |
| | | code_block_dict[code].add(b) |
| | | # 设置涨停数据 |
| | | |
| | | if records: |
| | | cls.latest_origin_datas = records |
| | | cls.__LimitUpCodesPlateKeyManager.set_today_limit_up( |
| | | [(r[0], r[5], r[6].split('、') if r[6] else []) for r in records]) |
| | | kpl_data_constant.current_limit_up_datas = records |
| | | |
| | | code_reasons_dict = {} |
| | | reason_codes_dict = {} |