| | |
| | | import time |
| | | |
| | | from log_module.log import logger_common |
| | | from strategy import data_cache, index_market_trend_strategy |
| | | from strategy import data_cache, market_sentiment_analysis |
| | | from strategy import kpl_api |
| | | from utils import tool |
| | | |
| | |
| | | # 本地数据更新时间 |
| | | if data_cache.UPDATE_DATA_TIME < now_time and data_cache.index_K_line_write_execution is False: |
| | | # 写入所有指数K线 |
| | | index_market_trend_strategy.all_index_k_line_dict_write() |
| | | market_sentiment_analysis.all_index_k_line_dict_write() |
| | | logger.info(f"写入所有带属性指数K线 已经运行完成") |
| | | # 完成了后将是否执行的开个标记为真 |
| | | data_cache.index_K_line_write_execution = True |