From 8595dc22aa9dde6aba6d0f8cdcf1656a8a59513b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 02 八月 2023 18:05:10 +0800
Subject: [PATCH] redis封装
---
code_attribute/gpcode_manager.py | 38 +++++++++++++++++++-------------------
1 files changed, 19 insertions(+), 19 deletions(-)
diff --git a/code_attribute/gpcode_manager.py b/code_attribute/gpcode_manager.py
index 766915d..21e84e0 100644
--- a/code_attribute/gpcode_manager.py
+++ b/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
# 璁剧疆姝ｅ湪鎿嶄綔鐨勪唬鐮�
--
Gitblit v1.8.0