| | |
|---|
| | | import time |
|---|
| | | |
|---|
| | | from log_module.log import logger_common |
|---|
| | | from strategy import data_cache, market_sentiment_analysis |
|---|
| | | from strategy import data_cache, market_sentiment_analysis, plate_strength_analysis |
|---|
| | | from strategy import kpl_api |
|---|
| | | from utils import tool |
|---|
| | | |
|---|
| | |
|---|
| | | # 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() |
|---|
| | | plate_strength_analysis.get_arrange_limit_up_info() |
|---|
| | | logger.info(f"整理当日涨停信息 已经运行完成") |
|---|
| | | # # 获取所有个股的板块概念并写入文件【耗时较长应该放在 核心主线程 和 仓位管理 后面】 |
|---|
| | | kpl_api.get_all_stocks_plate_dict(data_cache.DataCache().filtered_stocks) |
|---|
| | | plate_strength_analysis.get_all_stocks_plate_dict(data_cache.DataCache().filtered_stocks) |
|---|
| | | logger.info(f"获取所有个股的板块概念 已经运行完成") |
|---|
| | | # 完成了后将是否执行的开个标记为真 |
|---|
| | | data_cache.execution = True |
|---|
