| | |
|---|
| | | # 引入瞬时分时行情模块 |
|---|
| | | # 引入账户管理模块【进行资金和仓位管理】 |
|---|
| | | from strategy import kpl_api, data_cache, check_timer, all_K_line, instant_time_market, account_management, \ |
|---|
| | | order_methods, local_data_management, kpl_data_manager |
|---|
| | | order_methods, local_data_management, kpl_data_manager, market_sentiment_analysis |
|---|
| | | from huaxin_client import l2_market_client |
|---|
| | | from log_module import async_log_util |
|---|
| | | from trade import huaxin_trade_data_update |
|---|
| | |
|---|
| | | # 实时运行定时器线程【定时器函数目前 只管理 15:00 后运行一次 整理当日涨停信息 和 获取所有个股的板块概念】 |
|---|
| | | threading.Thread(target=lambda: check_timer.check_time(), daemon=True).start() |
|---|
| | | # 获取实时大盘行情情绪综合强度 [分数] 线程 |
|---|
| | | threading.Thread(target=lambda: kpl_api.get_real_time_market_strong(), daemon=True).start() |
|---|
| | | threading.Thread(target=lambda: market_sentiment_analysis.get_real_time_market_strong(), daemon=True).start() |
|---|
| | | # 实时检测是否拉取K线线程 |
|---|
| | | threading.Thread(target=lambda: all_K_line.check_time_and_data_date(), daemon=True).start() |
|---|
| | | # print(f"all_stocks_all_K_line_property_dict== {type(data_cache.all_stocks_all_K_line_property_dict)}") |
|---|
