redis封装

Administrator

2023-08-02 8595dc22aa9dde6aba6d0f8cdcf1656a8a59513b

 trade/trade_manager.py

@@ -134,7 +134,7 @@
# 获取交易状态
def get_trade_state(code):
    redis = __redis_manager.getRedis()
    state = redis.get("trade-state-{}".format(code))
    state =RedisUtils.get(redis, "trade-state-{}".format(code))
    if state is None:
        return TRADE_STATE_NOT_TRADE
    return int(state)
@@ -164,7 +164,7 @@
    codes = []
    if keys is not None:
        for key in keys:
            if int(redis.get(key)) in states:
            if int(RedisUtils.get(redis, key)) in states:
                codes.append(key.replace("trade-state-", ''))
    return codes

@@ -172,13 +172,13 @@
# 设置交易账户的可用金额
def set_available_money(client_id, money):
    redis = __redis_manager.getRedis()
    redis.set("trade-account-canuse-money", money)
    RedisUtils.set(redis,"trade-account-canuse-money", money)


# 获取交易账户的可用金额
def get_available_money():
    redis = __redis_manager.getRedis()
    result = redis.get("trade-account-canuse-money")
    result = RedisUtils.get(redis, "trade-account-canuse-money")
    if result is None:
        return None
    return round(float(result), 2)
@@ -259,14 +259,14 @@
                "time": result[5], "trade_num": result[6], "type": result[7], "day": result[8],
                "create_time": result[9]}
        datas.append(data)
    return datas, redis.get("trade-success-latest-time")
    return datas, RedisUtils.get(redis,"trade-success-latest-time")


# 获取交易委托数据
def get_trade_delegate_data():
    redis = __redis_manager.getRedis()
    result = redis.get("trade-delegate-latest")
    time_str = redis.get("trade-delegate-latest-time")
    result = RedisUtils.get(redis, "trade-delegate-latest")
    time_str =RedisUtils.get(redis, "trade-delegate-latest-time")
    if result is None:
        return [], time_str
    else: