bug修复

Administrator

2023-10-30 fb47d36048e94b9a506d5c153e3dd19a01e37df1

 third_data/kpl_data_manager.py

@@ -1,4 +1,5 @@
import json
import logging
import os
import threading
import time
@@ -327,11 +328,13 @@
        while True:
            if tool.is_trade_time():
                try:
                    results = kpl_api.daBanList(kpl_api.DABAN_TYPE_LIMIT_UP)
                    results = kpl_api.getLimitUpInfo()
                    result = json.loads(results)
                    start_time = time.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():
@@ -370,8 +373,8 @@

    threading.Thread(target=get_limit_up, daemon=True).start()
    threading.Thread(target=get_bidding_money, daemon=True).start()
    threading.Thread(target=get_market_industry, daemon=True).start()
    threading.Thread(target=get_market_jingxuan, daemon=True).start()
    # threading.Thread(target=get_market_industry, daemon=True).start()
    # threading.Thread(target=get_market_jingxuan, daemon=True).start()


if __name__ == "__main__":