| | |
| | | from third_data.history_k_data_util import HistoryKDatasUtils |
| | | from third_data.kpl_data_manager import KPLLimitUpDataRecordManager, KPLDataManager |
| | | |
| | | from third_data import kpl_data_manager |
| | | |
| | | __before_block_dict = {} |
| | | |
| | | __kplDataManager = KPLDataManager() |
| | |
| | | __before_block_dict[code] = blocks |
| | | |
| | | return __before_block_dict.get(code) |
| | | |
| | | |
| | | # 获取之前的板块 |
| | | def get_before_blocks(code): |
| | | return __before_block_dict.get(code) |
| | | |
| | | |
| | | # 获取之前的代码-板块字典 |
| | | def get_before_blocks_dict(): |
| | | return __before_block_dict |
| | | |
| | | |
| | | def __get_code_from_code_info(code_info): |
| | |
| | | code_ = d[3] |
| | | limit_up_codes_info_set.add((code_, d[5])) |
| | | block_codes_set.add(code_) |
| | | elif d[3]==code: |
| | | elif d[3] == code: |
| | | limit_up_codes_info_set.add((d[3], d[5])) |
| | | # 获取涨停的顺序 |
| | | limit_up_index = -1 |
| | |
| | | return fresult |
| | | |
| | | |
| | | # 初始化板块数据 |
| | | def init(): |
| | | # 加载数据到内存中 |
| | | kpl_data_manager.get_current_limit_up_data_records(10) |
| | | |
| | | |
| | | def init_code(code): |
| | | # 加载历史涨停原因 |
| | | __load_before_block(code) |
| | | |
| | | |
| | | if __name__ == "__main__": |
| | | get_info("603133") |