tanghongbin 4 жил өмнө
parent
commit
b902dbba77

+ 2 - 0
Controller/EquipmentManagerV3.py

@@ -96,6 +96,8 @@ class EquipmentManagerV3(View):
                                                  NickName=NickName, View_Account=View_Account,
                                                  View_Password=View_Password, Type=Type, ChannelIndex=ChannelIndex)
                         userDevice.save()
+                        asy = threading.Thread(target=ModelService.notify_alexa_add, args=(UID, userID, NickName))
+                        asy.start()
                         # redisObj = RedisObject(db=8)
                         # redisObj.del_data(key='uid_qs_' + userID)
                     except Exception as e:

+ 27 - 0
Service/ModelService.py

@@ -1,3 +1,5 @@
+import requests
+
 from Model.models import *
 from Service.CommonService import CommonService
 import json
@@ -138,6 +140,7 @@ class ModelService:
 
     @staticmethod
     def del_eq_info(userID, uid):
+        notify_alexa_delete(uid)
         ei_qs = Equipment_Info.objects.filter(userID_id=userID, devUid=uid)
         ei_qs.delete()
         # ei_count = ei_qs.count()
@@ -151,3 +154,27 @@ class ModelService:
     def get_uid_list(userID):
         uid_list = Device_Info.objects.filter(userID_id=userID).values_list('UID', flat=True)
         return list(uid_list)
+
+    @staticmethod
+    def notify_alexa_add(uid, userID, nickname):
+        url = 'https://www.zositech.xyz/deviceStatus/addOrupdate'
+        data = {
+            'UID': uid,
+            'userID': userID,
+            'uid_nick': nickname
+        }
+        try:
+            requests.post(url, data=data, timeout=5)
+        except Exception as e:
+            print(repr(e))
+
+
+def notify_alexa_delete(UID):
+    url = 'https://www.zositech.xyz/deviceStatus/delete'
+    data = {
+        'UID': UID
+    }
+    try:
+        requests.post(url=url, data=data, timeout=5)
+    except Exception as e:
+        print(repr(e))