| | |
|---|
| | | |
|---|
| | | try: |
|---|
| | | # 新题材 |
|---|
| | | new_block_processor.process_limit_up_list({x[0]: x[5] for x in result_list_}) |
|---|
| | | new_block_codes = new_block_processor.screen_new_blocks_with_limit_up_datas([(x[0], x[5]) for x in result_list_]) |
|---|
| | | if new_block_codes: |
|---|
| | | # 统计板块的代码 |
|---|
| | |
|---|
| | | # 需要获取板块下的代码 |
|---|
| | | self.__new_blocks_codes_request_thread_pool.submit( |
|---|
| | | lambda: request_new_blocks_codes(update_new_block_plates, new_block_codes.keys())) |
|---|
| | | except: |
|---|
| | | pass |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
| | | self.__kplDataManager.save_data(type_, result_list_) |
|---|
| | | except Exception as e: |
|---|
| | | logger_debug.exception(e) |
|---|
