"""
涨停数据管理
"""
import threading
import time

from local_api.util import kpl_api, kpl_util, tool
from local_api.log_module import log, log_export


class KPLLimitUpDataManager:
    __update_time = 0
    """
    开盘啦涨停数据管理
    """
    __current_limit_up_info = None

    __instance = None

    def __new__(cls, *args, **kwargs):
        if not cls.__instance:
            cls.__instance = super(KPLLimitUpDataManager, cls).__new__(cls, *args, **kwargs)
            cls.__load_datas()
        return cls.__instance

    @classmethod
    def __load_datas(cls):
        lists = log_export.load_limit_up()
        if lists:
            cls.__current_limit_up_info = lists[-1]

    def get_current_limitup_info(self):
        return self.__current_limit_up_info

    def request_limit_up_list(self):
        """
        请求涨停数据
        :return: [(代码, 名称, 首次涨停时间, 最近涨停时间, 几板, 涨停原因, 板块, 实际流通, 主力净额, 涨停原因代码, 涨停原因代码数量)]
        """
        results = kpl_api.getLimitUpInfo()
        return kpl_util.parseLimitUpData(results)

    def start_task(self):
        def update():
            while True:
                try:
                    datas = self.request_limit_up_list()
                    self.__current_limit_up_info = (tool.get_now_time_str(), datas)
                    # 将数据保存到日志
                    log.logger_kpl_limit_up.info(f"{datas}")
                except:
                    pass
                finally:
                    time.sleep(3)
                    self.__update_time = time.time()

        threading.Thread(target=update, daemon=True).start()

    def repaire_task(self):
        """
        修复任务
        :return:
        """
        if time.time() - self.__update_time < 20:
            return
        self.start_task()


if __name__ == "__main__":
    datas = KPLLimitUpDataManager().get_current_limitup_info()
    print(datas)