| | |
| | | self.__kplDataManager.save_data(type_, result_list) |
| | | elif type_ == KPLDataType.LIMIT_UP.value: |
| | | result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_LIMIT_UP) |
| | | threading.Thread(target=lambda :do_limit_up(result_list),daemon=True).start() |
| | | threading.Thread(target=lambda: do_limit_up(result_list), daemon=True).start() |
| | | elif type_ == KPLDataType.OPEN_LIMIT_UP.value: |
| | | result_list = kpl_util.parseDaBanData(data["data"], kpl_util.DABAN_TYPE_OPEN_LIMIT_UP) |
| | | if result_list: |
| | |
| | | import json |
| | | import logging |
| | | import os |
| | | import threading |
| | | import time |
| | |
| | | __upload_data("limit_up", result) |
| | | logger_kpl_limit_up_reason_change.info("上传耗时:{}", time.time() - start_time) |
| | | except Exception as e: |
| | | pass |
| | | logging.exception(e) |
| | | time.sleep(3) |
| | | |
| | | def get_bidding_money(): |