trade/trade_manager.py
@@ -2,6 +2,8 @@ 交易管理 """ from db.redis_manager_delegate import RedisManager, RedisUtils from log_module import async_log_util from log_module.log import logger_trade from utils import constant, tool @@ -38,6 +40,7 @@ # 设置交易状态 def set_trade_state(self, code, strategy_type, state): async_log_util.info(logger_trade, f"set_trade_state: {code}-{strategy_type}-{state}") k = f"{code}-{strategy_type}" self.__trade_state_cache[k] = state RedisUtils.setex_async(constant.REDIS_DB, f"trade_state-{k}", tool.get_expire(), state)
