redis批量提交数据

Administrator

2023-08-07 e0ca7b43c17ebe25e718d5ca229c989f48340015

 trade/trade_manager.py

@@ -23,6 +23,7 @@

trade_gui = import_util.import_lib("trade.trade_gui")

__db = 2
__redis_manager = redis_manager.RedisManager(2)

# 未交易
@@ -196,7 +197,7 @@
def set_trade_state(code, state):
    logger_trade.info("set_trade_state {}-{}".format(code, state))
    tool.CodeDataCacheUtil.set_cache(__trade_state_cache, code, state)
    RedisUtils.setex_async(__redis_manager.getRedis(), "trade-state-{}".format(code), tool.get_expire(), state)
    RedisUtils.setex_async(__db, "trade-state-{}".format(code), tool.get_expire(), state)


def get_codes_by_trade_state(state):