"""
定义整个项目的定时器
"""
# import datetime
import time

from log_module.log import logger_common
from strategy import data_cache, market_sentiment_analysis
from strategy import kpl_api
from utils import tool

# from strategy import instant_time_market

# 获取logger实例
logger = logger_common


# 构建一个项目整体的定时器对象
# class CheckTimer:
#     def __init__(self):
#         pass

# 定时器函数
def check_time():
    while True:
        try:
            # 声明赋值实时时间
            now_time = tool.get_now_time_str()
            # print(f"now_time==={now_time}")
            if now_time > data_cache.AFTER_CLOSING_TIME and data_cache.execution is False:
                # 整理当日涨停信息并写入本地管理好本地数据
                kpl_api.get_arrange_limit_up_info()
                logger.info(f"整理当日涨停信息 已经运行完成")
                # # 获取所有个股的板块概念并写入文件【耗时较长应该放在 核心主线程 和 仓位管理 后面】
                kpl_api.get_all_stocks_plate_dict(data_cache.DataCache().filtered_stocks)
                logger.info(f"获取所有个股的板块概念 已经运行完成")
                # 完成了后将是否执行的开个标记为真
                data_cache.execution = True
            # 本地数据更新时间
            if data_cache.UPDATE_DATA_TIME < now_time and data_cache.index_K_line_write_execution is False:
                # 写入所有指数K线
                market_sentiment_analysis.all_index_k_line_dict_write()
                logger.info(f"写入所有带属性指数K线 已经运行完成")
                # 完成了后将是否执行的开个标记为真
                data_cache.index_K_line_write_execution = True
        except Exception as error:
            logger.error(f"实时检测定时器线程报错: {error}")
        finally:
            time.sleep(1)