| | |
| | | from log_module.log import logger_debug |
| | | from third_data import kpl_util |
| | | from third_data.third_blocks_manager import BlockMapManager |
| | | from trade import trade_record_log_util |
| | | |
| | | from utils import tool |
| | | from utils.kpl_data_db_util import KPLLimitUpDataUtil |
| | |
| | | 添加新题材的板块 |
| | | @param code: |
| | | @param block: |
| | | @return: |
| | | @return: 返回增加新题材是否成功 |
| | | """ |
| | | if block in constant.KPL_INVALID_BLOCKS: |
| | | return |
| | | return False |
| | | old_blocks = self.__radical_buy_reasons_dict.get(code) |
| | | if old_blocks is None: |
| | | old_blocks = set() |
| | | if block in old_blocks: |
| | | return |
| | | return False |
| | | self.__new_blocks.add(block) |
| | | old_blocks.add(block) |
| | | trade_record_log_util.add_temp_special_codes(code, f"新题材辨识度:{block}") |
| | | async_log_util.info(logger_debug, f"今日新增概念:{code} - {block}") |
| | | self.__radical_buy_reasons_dict[code] = old_blocks |
| | | return True |
| | | |
| | | def get_total_before_blocks(self): |
| | | """ |