From a3c05bddc4c61d63b804ee541cf6dd01717ba94d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 02 八月 2023 16:39:08 +0800
Subject: [PATCH] redis封装
---
ths/l2_code_operate.py | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/ths/l2_code_operate.py b/ths/l2_code_operate.py
index 0203945..f594ef0 100644
--- a/ths/l2_code_operate.py
+++ b/ths/l2_code_operate.py
@@ -7,6 +7,7 @@
import logging
import threading
+from db.redis_manager import RedisUtils
from ths import client_manager
from code_attribute import gpcode_manager
from l2 import l2_data_manager
@@ -222,7 +223,7 @@
# 璁剧疆浠ｇ爜鎿嶄綔鐘舵�侊紝鏈嶅姟鍣ㄤ繚瀛樼殑浠ｇ爜鏄惁涓庡疄闄呰缃殑浠ｇ爜淇濇寔涓�鑷�
@classmethod
def set_operate_code_state(cls, client_id, channel, state):
- cls.getRedis().setex("code-operate_state-{}-{}".format(client_id, channel), 10, state)
+ RedisUtils.setex(cls.getRedis(),"code-operate_state-{}-{}".format(client_id, channel), 10, state)
def get_operate_code_state(self, client_id, channel):
value = self.getRedis().get("code-operate_state-{}-{}".format(client_id, channel))
@@ -234,7 +235,7 @@
@classmethod
def set_read_queue_valid(cls):
redis = cls.getRedis()
- redis.setex("operate_queue_read_state", 20, 1)
+ RedisUtils.setex( redis,"operate_queue_read_state", 20, 1)
@classmethod
def is_read_queue_valid(cls):
--
Gitblit v1.8.0