Parcourir la source

删除设备数据序列号加入重置状态redis列表

locky il y a 2 ans
Parent
commit
a25f669ae3
1 fichiers modifiés avec 8 ajouts et 1 suppressions
  1. 8 1
      AdminController/DeviceManagementController.py

+ 8 - 1
AdminController/DeviceManagementController.py

@@ -11,12 +11,13 @@ from django.db.models import Q, F
 from django.views.generic.base import View
 
 from Ansjer.config import OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET, AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY, \
-    AWS_SES_ACCESS_REGION
+    AWS_SES_ACCESS_REGION, UNUSED_SERIAL_REDIS_LIST
 from Model.models import Device_Info, UidSetModel, LogModel, UID_Bucket, Unused_Uid_Meal, Order_Model, StsCrdModel, \
     VodHlsModel, ExperienceContextModel, DeviceTypeModel, Equipment_Info, UidUserModel, ExperienceAiModel, AiService, \
     AppBundle, App_Info, AppDeviceType, DeviceNameLanguage, AppVersionNumber, UIDCompanySerialModel, UIDModel, \
     CompanySerialModel
 from Object.AWS.AmazonS3Util import AmazonS3Util
+from Object.RedisObject import RedisObject
 from Object.ResponseObject import ResponseObject
 from Object.TokenObject import TokenObject
 from Service.CommonService import CommonService
@@ -491,6 +492,12 @@ class DeviceManagement(View):
                     ExperienceContextModel.objects.filter(uid__in=uidList).delete()
                     Order_Model.objects.filter(UID__in=uidList, order_type=0).delete()
                     Device_Info.objects.filter(UID__in=uidList).update(vodPrimaryUserID='', vodPrimaryMaster='')
+
+                # 序列号加入重置状态redis列表
+                if serialNumberList is not None:
+                    redis_obj = RedisObject()
+                    for serial in serial_number_list:
+                        redis_obj.rpush(UNUSED_SERIAL_REDIS_LIST, serial)
             return response.json(0)
         except Exception as e:
             print(e)