| | |
|---|
| | | from db.redis_manager_delegate import RedisUtils |
|---|
| | | from huaxin_client import l2_market_client, trade_client, l1_subscript_codes_manager |
|---|
| | | from log_module import async_log_util |
|---|
| | | from log_module.log import logger_debug |
|---|
| | | from log_module.log import logger_debug, logger_system |
|---|
| | | from server import data_server |
|---|
| | | from strategy import strategy_manager |
|---|
| | | from strategy.env_info import RealTimeEnvInfo |
|---|
| | |
|---|
| | | |
|---|
| | | # ----初始化------------ |
|---|
| | | __init() |
|---|
| | | |
|---|
| | | # 初始化数据 |
|---|
| | | strategy_manager.low_suction_strtegy = strategy_manager.LowSuctionStrategy(tool.get_now_date_str()) |
|---|
| | | |
|---|
| | | |
|---|
| | | logger_system.info("初始化策略对象成功") |
|---|
| | | try: |
|---|
| | | strategy_manager.low_suction_strtegy.load_data() |
|---|
| | | logger_system.info("加载策略数据成功") |
|---|
| | | except Exception as e: |
|---|
| | | logger_system.error(f"加载策略数据失败：{str(e)}") |
|---|
| | | logger_system.exception(e) |
|---|
| | | |
|---|
| | | # -------启动L2 market订阅------ |
|---|
| | | __run_l2_market_subscript() |
|---|
| | | print("启动完成") |
|---|
| | | logger_system.info("系统结束") |
|---|
