redis连接池归还

Administrator

2023-08-03 4d321ae069fce2c0f6f7884bec8fa6c4ec534d1a

 code_attribute/big_money_num_manager.py

@@ -19,24 +19,20 @@


def add_num(code, num):
    redis = __redisManager.getRedis()
    RedisUtils.incrby(redis,"big_money-{}".format(code), num)
    RedisUtils.incrby(__redisManager.getRedis(), "big_money-{}".format(code), num)


# 设置过期时间
def expire(code):
    redis = __redisManager.getRedis()
    RedisUtils.expire(redis, "big_money-{}".format(code), tool.get_expire())
    RedisUtils.expire(__redisManager.getRedis(), "big_money-{}".format(code), tool.get_expire())


def reset(code):
    redis = __redisManager.getRedis()
    RedisUtils.set(redis,"big_money-{}".format(code), 0)
    RedisUtils.set(__redisManager.getRedis(), "big_money-{}".format(code), 0)


def get_num(code):
    redis = __redisManager.getRedis()
    num = RedisUtils.get(redis, "big_money-{}".format(code))
    num = RedisUtils.get(__redisManager.getRedis(), "big_money-{}".format(code))
    if num is None:
        return 0
    return round(int(num) / 1000 / 4)
@@ -44,9 +40,12 @@

def reset_all():
    redis = __redisManager.getRedis()
    keys = RedisUtils.keys(redis, "big_money-*")
    try:
        keys = RedisUtils.keys(redis, "big_money-*", auto_free=False)
    for k in keys:
        RedisUtils.setex(redis, k, tool.get_expire(), 0)
            RedisUtils.setex(redis, k, tool.get_expire(), 0, auto_free=False)
    finally:
        redis.connection_pool.disconnect()


if __name__ == "__main__":