| | |
| | | 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 |
| | |
| | | codes |= set([x.decode() for x in codes_sh]) |
| | | codes |= set([x.decode() for x in codes_sz]) |
| | | day = tool.get_now_date_str() |
| | | schedule.every().day.at("11:05:00").do(lambda: KPLCodeJXBlocksManager(day, codes).start_download_blocks()) |
| | | schedule.every().day.at("08:05:00").do(lambda: KPLCodeJXBlocksManager(day, codes).start_download_blocks()) |
| | | while True: |
| | | try: |
| | | schedule.run_pending() |
| | |
| | | |
| | | # 初始化数据 |
| | | strategy_manager.low_suction_strtegy = strategy_manager.LowSuctionStrategy(tool.get_now_date_str()) |
| | | logger_system.info("初始化策略对象成功") |
| | | |
| | | |
| | | |