소스 검색

修改redis写入列表问题

locky 10 달 전
부모
커밋
c743729764
2개의 변경된 파일5개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      Controller/Cron/CronTaskController.py
  2. 4 0
      Object/RedisObject.py

+ 1 - 1
Controller/Cron/CronTaskController.py

@@ -787,7 +787,7 @@ class CronUpdateDataView(View):
                 AiService.objects.filter(uid__in=uid_list).delete()
                 AiService.objects.filter(uid__in=uid_list).delete()
 
 
                 # 写入未使用序列号redis列表
                 # 写入未使用序列号redis列表
-                redis_obj.rpush(UNUSED_SERIAL_REDIS_LIST, *serial_list)
+                redis_obj.rpush_list(UNUSED_SERIAL_REDIS_LIST, *serial_list)
 
 
                 # 重置region_id,不为美洲服,则写入redis列表
                 # 重置region_id,不为美洲服,则写入redis列表
                 if CONFIG_INFO == CONFIG_US:
                 if CONFIG_INFO == CONFIG_US:

+ 4 - 0
Object/RedisObject.py

@@ -53,6 +53,10 @@ class RedisObject:
     def rpush(self, name, val):
     def rpush(self, name, val):
         self.CONN.rpush(name, val)
         self.CONN.rpush(name, val)
 
 
+    # 向列表插入数据
+    def rpush_list(self, name, *val):
+        self.CONN.rpush(name, *val)
+
     def lpop(self, name):
     def lpop(self, name):
         val = self.CONN.lpop(name)
         val = self.CONN.lpop(name)
         if val:
         if val: