优化序列号同步

Controller/Cron/CronTaskController.py

@@ -9,6 +9,7 @@
 # @Software: PyCharm
 import datetime
 import io
+import json
 import threading
 import time
 import zipfile
@@ -27,7 +28,7 @@ from Model.models import Device_User, Device_Info, UidSetModel, UID_Bucket, Unus
     CountryModel, DeviceTypeModel, OrdersSummary, DeviceInfoSummary, CompanySerialModel, \
     CloudLogModel, UidCloudStorageCount, UserExModel, DeviceDomainRegionModel, VodHlsTag, VodHlsTagType, \
     Store_Meal, Lang, VodBucketModel, UnicomComboOrderInfo, UnicomDeviceInfo, AbnormalOrder, DailyReconciliation, \
-    CustomizedPush
+    CustomizedPush, UIDCompanySerialModel, UIDModel, LogModel
 from Object.RedisObject import RedisObject
 from Object.ResponseObject import ResponseObject
 from Object.utils import LocalDateTimeUtil
@@ -643,6 +644,24 @@ class CronUpdateDataView(View):
             serial_redis_list = eval(serial_redis_list)
             CompanySerialModel.objects.filter(serial_number__in=serial_redis_list).update(status=int(status),
                                                                                           update_time=now_time)
+            uid_serial_qs = UIDCompanySerialModel.objects.filter(company_serial__serial_number__in=serial_redis_list)
+            if uid_serial_qs:
+                uid_list = list(uid_serial_qs.values_list('uid__uid', flat=True))
+                serial_list = list(uid_serial_qs.values_list('company_serial__serial_number', flat=True))
+                UIDModel.objects.filter(uid__in=uid_list).update(status=3, mac='', update_time=now_time)
+                uid_serial_qs.delete()
+                # 记录操作日志
+                content = json.loads(json.dumps(request_dict))
+                log = {
+                    'ip': '127.0.0.1',
+                    'user_id': 1,
+                    'status': 200,
+                    'time': now_time,
+                    'content': json.dumps(content),
+                    'url': 'cron/update/updateSerialStatus',
+                    'operation': '序列号{}解绑uid: {}'.format(serial_list, uid_list),
+                }
+                LogModel.objects.create(**log)
             return response.json(0)
         except Exception as e:
             LOGGER.info('---更新序列号状态异常---:{}'.format(repr(e)))