redis封装

Administrator

2023-08-02 8595dc22aa9dde6aba6d0f8cdcf1656a8a59513b

 code_attribute/gpcode_manager.py

@@ -100,7 +100,7 @@
    # 设置首板代码名称
    @classmethod
    def set_first_code_names(cls, datas):
        RedisUtils.set( cls.__get_redis(), "gp_list_names_first", json.dumps(datas))
        RedisUtils.set(cls.__get_redis(), "gp_list_names_first", json.dumps(datas))

    # 设置二板代码名称
    @classmethod
@@ -135,7 +135,7 @@

    @classmethod
    def is_in_first_record(cls, code):
        if RedisUtils.sismember( cls.__get_redis(), "first_code_record", code):
        if RedisUtils.sismember(cls.__get_redis(), "first_code_record", code):
            return True
        else:
            return False
@@ -150,7 +150,7 @@
    # 是否涨停过
    @classmethod
    def is_limited_up(cls, code):
        if RedisUtils.sismember( cls.__get_redis(), "first_code_limited_up_record", code):
        if RedisUtils.sismember(cls.__get_redis(), "first_code_limited_up_record", code):
            return True
        else:
            return False
@@ -176,11 +176,11 @@

    @classmethod
    def remove_code(cls, code):
        RedisUtils.srem( cls.__get_redis(),cls.__redis_key, code)
        RedisUtils.srem(cls.__get_redis(), cls.__redis_key, code)

    @classmethod
    def is_in(cls, code):
        return RedisUtils.sismember( cls.__get_redis(), cls.__redis_key, code)
        return RedisUtils.sismember(cls.__get_redis(), cls.__redis_key, code)

    @classmethod
    def list_code(cls):
@@ -212,7 +212,7 @@

    @classmethod
    def is_in(cls, code):
        return RedisUtils.sismember( cls.__get_redis(), cls.__redis_key, code)
        return RedisUtils.sismember(cls.__get_redis(), cls.__redis_key, code)

    @classmethod
    def list_code(cls):
@@ -281,7 +281,7 @@
    for code in add_codes:
        RedisUtils.sadd(redis_instance, "gp_list_first", code)
    for code in del_set:
        redis_instance.srem("gp_list_first", code)
        RedisUtils.srem(redis_instance, "gp_list_first", code)
    RedisUtils.expire(redis_instance, "gp_list_first", tool.get_expire())

    old_name_codes = CodesNameManager.list_first_code_name_dict()
@@ -297,7 +297,7 @@
def remove_first_gp_code(codes):
    redis_instance = __redisManager.getRedis()
    for code in codes:
        redis_instance.srem("gp_list_first", code)
        RedisUtils.srem(redis_instance, "gp_list_first", code)


# 获取首板代码
@@ -309,7 +309,7 @@
# 是否在首板里面
def is_in_first_gp_codes(code):
    redis_instance = __redisManager.getRedis()
    return redis_instance.sismember("gp_list_first", code)
    return RedisUtils.sismember(redis_instance, "gp_list_first", code)


# 获取名称对应的代码
@@ -366,13 +366,13 @@

def rm_gp(code):
    redis_instance = __redisManager.getRedis()
    redis_instance.srem("gp_list", code)
    RedisUtils.srem(redis_instance, "gp_list", code)
    remove_first_gp_code([code])


def is_in_gp_pool(code):
    redis_instance = __redisManager.getRedis()
    return redis_instance.sismember("gp_list", code) or is_in_first_gp_codes(code)
    return RedisUtils.sismember(redis_instance, "gp_list", code) or is_in_first_gp_codes(code)


def get_gp_list():
@@ -518,13 +518,13 @@
    keys = RedisUtils.keys(redis_instance, "listen_code-*-*")

    for key in keys:
        result = redis_instance.get(key)
        result = RedisUtils.get(redis_instance, key)
        if result:
            # 移除需要添加的代码
            codes_set.discard(result)
            client_id_, pos_, code_ = int(key.split("-")[1]), int(key.split("-")[2]), result
            key_ = "code_listen_pos-{}".format(code_)
            val = redis_instance.get(key_)
            val = RedisUtils.get(redis_instance, key_)
            if val is None:
                RedisUtils.setex(redis_instance, key_, tool.get_expire(), json.dumps((client_id_, pos_)))
            else:
@@ -541,7 +541,7 @@
def init_listen_code_by_pos(client_id, pos):
    redis_instance = __redisManager.getRedis()
    key = "listen_code-{}-{}".format(client_id, pos)
    redis_instance.setnx(key, "")
    RedisUtils.setnx(redis_instance, key, "")
    RedisUtils.expire(redis_instance, key, tool.get_expire())


@@ -580,7 +580,7 @@
            index = key.split("-")[-1]
            if int(index) + 1 > constant.L2_CODE_COUNT_PER_DEVICE:
                continue
            result = redis_instance.get(key)
            result = RedisUtils.get(redis_instance, key)
            if result is None or len(result) == 0:
                available_positions.append((client_id, int(key.replace("listen_code-{}-".format(client_id), ""))))
            else:
@@ -617,7 +617,7 @@
        k = "listen_code-{}-*".format(client_id)
        keys = RedisUtils.keys(redis_instance, k)
        for key in keys:
            code = redis_instance.get(key)
            code = RedisUtils.get(redis_instance, key)
            if not code:
                free_count += 1
    return free_count
@@ -626,7 +626,7 @@
# 获取正在监听的代码的位置
def get_listen_code_pos(code):
    redis_instance = __redisManager.getRedis()
    val = redis_instance.get("code_listen_pos-{}".format(code))
    val = RedisUtils.get(redis_instance, "code_listen_pos-{}".format(code))
    if val is None:
        return None, None
    val = json.loads(val)
@@ -642,7 +642,7 @@
# 是否正在监听
def is_listen(code):
    redis_instance = __redisManager.getRedis()
    val = redis_instance.get("code_listen_pos-{}".format(code))
    val = RedisUtils.get(redis_instance, "code_listen_pos-{}".format(code))
    if val is None:
        return False
    else:
@@ -666,7 +666,7 @@
# 是否正在操作
def is_operate(code):
    redis_instance = __redisManager.getRedis()
    return redis_instance.get("gp_operate-{}".format(code)) is not None
    return RedisUtils.get(redis_instance, "gp_operate-{}".format(code)) is not None


# 设置正在操作的代码