| | |
| | | # 原始数据 |
| | | __radical_buy_reasons_origin_data_dict = {} |
| | | |
| | | # 所有的涨停原因 |
| | | __all_limit_up_reasons = set() |
| | | |
| | | # 今日的新概念 |
| | | __new_blocks = set() |
| | | |
| | |
| | | |
| | | for r in kpl_results: |
| | | # 取60个交易日之内的题材 |
| | | if r[1] in days: |
| | | cls.__all_limit_up_reasons.add(kpl_util.filter_block(r[2])) |
| | | code = r[0] |
| | | if code not in limit_up_reasons_dict: |
| | | limit_up_reasons_dict[code] = [] |
| | |
| | | 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): |
| | | """ |
| | | 获取所有之前的板块 |
| | | @return: |
| | | """ |
| | | return self.__all_limit_up_reasons |
| | | |
| | | def get_new_blocks(self): |
| | | """ |