Jelajahi Sumber

向redis列表插入列表数据使用新函数

locky 10 bulan lalu
induk
melakukan
5e575cd550
2 mengubah file dengan 7 tambahan dan 3 penghapusan
  1. 2 2
      Controller/Cron/CronTaskController.py
  2. 5 1
      Object/RedisObject.py

+ 2 - 2
Controller/Cron/CronTaskController.py

@@ -787,13 +787,13 @@ class CronUpdateDataView(View):
                 AiService.objects.filter(uid__in=uid_list).delete()
 
                 # 写入未使用序列号redis列表
-                redis_obj.rpush(UNUSED_SERIAL_REDIS_LIST, serial_list)
+                redis_obj.rpush_list(UNUSED_SERIAL_REDIS_LIST, serial_list)
 
                 # 重置region_id,不为美洲服,则写入redis列表
                 if CONFIG_INFO == CONFIG_US:
                     DeviceDomainRegionModel.objects.filter(serial_number__in=serial_list).update(region_id=0)
                 else:
-                    redis_obj.rpush(RESET_REGION_ID_SERIAL_REDIS_LIST, serial_list)
+                    redis_obj.rpush_list(RESET_REGION_ID_SERIAL_REDIS_LIST, serial_list)
 
                 # 重置已使用的uid的使用状态为未使用,更新时间
                 UIDModel.objects.filter(uid__in=uid_list, status=2).update(status=0, mac='', update_time=now_time)

+ 5 - 1
Object/RedisObject.py

@@ -51,7 +51,11 @@ class RedisObject:
 
     # 向列表插入数据
     def rpush(self, name, val):
-        self.CONN.rpush(name, *val)
+        self.CONN.rpush(name, val)
+
+    # 向列表插入列表数据
+    def rpush_list(self, name, list_val):
+        self.CONN.rpush(name, *list_val)
 
     def lpop(self, name):
         val = self.CONN.lpop(name)