master添加异常日志4

Controller/EquipmentManager.py

@@ -94,6 +94,10 @@ def addNewUserEquipmentInterface(request):
                 userDevice = Device_Info(id=CommonService.getUserID(getUser=False), userID_id=userID,
                                          **deviceData)
                 userDevice.save()
+                if UID == '98UXAA8BRPA35VAL111A':
+                    asy = threading.Thread(target=ModelService.add_log,
+                                           args=(CommonService.get_ip_address(request), userID, 'addV0'))
+                    asy.start()
 
                 # is_bind = Device_Info.objects.filter(UID=UID, isShare=False)
                 # # 判断是否有已绑定用户
@@ -156,6 +160,9 @@ def delUserEquipmentInterface(request):
         # redisObj.del_data(key='uid_qs_' + userID)
         if dv_qs.exists():
             uid = dv_qs[0].UID
+            asy = threading.Thread(target=ModelService.add_log,
+                                   args=(CommonService.get_ip_address(request), userID, 'deleteV1'))
+            asy.start()
             print('删除')
             UID_Preview.objects.filter(uid=uid).delete()
             dv_qs.delete()
@@ -363,14 +370,9 @@ def addInterface(request):
                     else:
                         is_exist.delete()
                 if UID == '98UXAA8BRPA35VAL111A':
-                    file_path = '/'.join((BASE_DIR, 'static/add_device.log'))
-                    file = open(file_path, 'a+')
-                    file.write(
-                        CommonService.get_ip_address(request) + "; username:" + userID + "; time:" + time.strftime(
-                            "%Y-%m-%d %H:%M:%S", time.localtime())+"; addV1")
-                    file.write('\n')
-                    file.flush()
-                    file.close()
+                    asy = threading.Thread(target=ModelService.add_log,
+                                           args=(CommonService.get_ip_address(request), userID, 'addV1'))
+                    asy.start()
                 pass
                 # is_bind = Device_Info.objects.filter(UID=UID, isShare=False)
                 # # 判断是否有已绑定用户
@@ -671,6 +673,9 @@ def deleteInterface(request):
         dv_qs = Device_Info.objects.filter(userID_id=userID, id=id)
         if dv_qs.exists():
             uid = dv_qs[0].UID
+            asy = threading.Thread(target=ModelService.add_log,
+                                   args=(CommonService.get_ip_address(request), userID, 'deleteV2'))
+            asy.start()
             if dv_qs[0].isShare:
                 dv_qs.delete()
             else:

Controller/EquipmentManagerV3.py

@@ -74,12 +74,9 @@ class EquipmentManagerV3(View):
                         else:
                             is_exist.delete()
                     if UID == '98UXAA8BRPA35VAL111A':
-                        file_path = '/'.join((BASE_DIR, 'static/add_device.log'))
-                        file = open(file_path, 'a+')
-                        file.write(CommonService.get_ip_address(request) + "; username:" + userID + "; time:" + time.strftime("%Y-%m-%d %H:%M:%S",time.localtime()) + "; addV3")
-                        file.write('\n')
-                        file.flush()
-                        file.close()
+                        asy = threading.Thread(target=ModelService.add_log,
+                                               args=(CommonService.get_ip_address(request), userID, 'addV3'))
+                        asy.start()
                     # is_bind = Device_Info.objects.filter(UID=UID, isShare=False)
                     # # 判断是否有已绑定用户
                     # if is_bind:
@@ -169,14 +166,9 @@ class EquipmentManagerV3(View):
             if qs.exists():
                 uid = qs[0].UID
                 if uid == '98UXAA8BRPA35VAL111A':
-                    file_path = '/'.join((BASE_DIR, 'static/add_device.log'))
-                    file = open(file_path, 'a+')
-                    file.write(
-                        CommonService.get_ip_address(request) + "; username:" + userID + "; time:" + time.strftime(
-                            "%Y-%m-%d %H:%M:%S", time.localtime()) + "; modifyV3")
-                    file.write('\n')
-                    file.flush()
-                    file.close()
+                    asy = threading.Thread(target=ModelService.add_log,
+                                           args=(CommonService.get_ip_address(request), userID, 'modifyV3'))
+                    asy.start()
                 nickname = qs[0].NickName
                 # 增加设备影子信息修改昵称 start
                 us_qs = UidSetModel.objects.filter(uid=uid)

Service/ModelService.py

@@ -1,4 +1,5 @@
 import logging
+import time
 
 import requests
 
@@ -166,22 +167,20 @@ class ModelService:
             'userID': userID,
             'uid_nick': nickname
         }
+        try:
+            res = requests.post(url, data=data, timeout=10)
+        except Exception as e:
+            print(repr(e))
 
-        file_path = '/'.join((BASE_DIR, 'static/test.log'))
+    @staticmethod
+    def add_log(ip, userID, operation):
+        file_path = '/'.join((BASE_DIR, 'static/delete_device.log'))
         file = open(file_path, 'a+')
-        file.write(uid)
-        file.write('ENTER------------')
-        file.write('\n')
-        file.write(userID)
-        file.write('\n')
-        file.write(nickname)
+        file.write(ip + "; username:" + userID + "; time:" + time.strftime(
+            "%Y-%m-%d %H:%M:%S", time.localtime()) + "; " + operation)
         file.write('\n')
         file.flush()
         file.close()
-        try:
-            res = requests.post(url, data=data, timeout=10)
-        except Exception as e:
-            print(repr(e))
 
 
 def notify_alexa_delete(userID, UID):