chenjunkai 6 жил өмнө
parent
commit
f35dfc5f33

+ 16 - 13
Controller/DetectController.py

@@ -26,6 +26,7 @@ from Object.UidTokenObject import UidTokenObject
 from Ansjer.config import SERVER_DOMAIN
 import json
 import requests
+from Model.models import Equipment_Info
 
 
 class DetectControllerView(View):
@@ -108,7 +109,7 @@ class NotificationView(View):
         uidToken = request_dict.get('uidToken', None)
         utko = UidTokenObject(uidToken)
         uid = utko.UID
-        uaqs = UID_App.objects.filter(uid=uid).\
+        uaqs = UID_App.objects.filter(uid=uid). \
             values('token_val', 'app_type', 'appBundleId', 'push_type', 'uid')
         if uaqs.exists():
             push_type = uaqs[0]['push_type']
@@ -123,15 +124,6 @@ class NotificationView(View):
                 return self.do_jpush(request_dict, uaqs[0], response)
         else:
             return response.json(173)
-        # # 设备主键uid
-        # if pushType == 'jpush':
-        #     return self.do_jpush(request_dict)
-        # elif pushType == 'gcm':
-        #     return
-        # elif pushType == 'apns':
-        #     return
-        # else:
-        #     return response.json(414)
 
     def do_jpush(self, request_dict, uaql, response):
         jpush_config = {
@@ -202,9 +194,7 @@ class NotificationView(View):
         appBundleId = uaql['appBundleId']
         token_val = uaql['token_val']
         uid = uaql['uid']
-        gcm_config = {
-            'xxx': 'key'
-        }
+        gcm_config = {'xxx': 'key'}
         serverKey = gcm_config[appBundleId]
 
         msg = {'n_time': n_time, 'uid': uid}
@@ -249,3 +239,16 @@ class NotificationView(View):
                 return response.json(404, res.reason)
         except Exception as e:
             return response.json(10, repr(e))
+
+    def do_save_equipment_info(self):
+        Equipment_Info.objects.create(
+            userID_id='',
+            eventTime='',
+            eventType='',
+            devUid='',
+            devNickName='',
+            Channel='',
+            alarm='',
+            receiveTime='',
+        )
+        return

+ 34 - 0
Controller/DeviceShare.py

@@ -47,6 +47,8 @@ class DeviceShareView(View):
                 userID = tko.userID
                 if operation == 'generateTokenUrl':
                     return self.do_generate_token_url(userID, request_dict, response)
+                elif operation == 'showShareInfo':
+                    return self.do_show_share_info(request_dict, response)
                 elif operation == 'confirm':
                     return self.do_confirm(userID, request_dict, response)
                 elif operation == 'queryUser':
@@ -92,6 +94,38 @@ class DeviceShareView(View):
         else:
             return response.json(173)
 
+    def do_show_share_info(self, request_dict, response):
+        shareToken = request_dict.get('shareToken', None)
+        if shareToken is not None:
+            redisObj = RedisObject()
+            data_str = redisObj.get_data(key=shareToken)
+            if data_str:
+                data = json.loads(data_str)
+                # 分享者userID
+                sharer = data.get('sharer', None)
+                # 分享的uid
+                UID = data.get('UID', None)
+                sharerDvqs = Device_Info.objects.filter(userID_id=sharer, UID=UID, isShare=False).\
+                    values('NickName','Type')
+                sharerDuqs = Device_User.objects.filter(userID=sharer).values('username', 'userEmail', 'phone')
+                if sharerDuqs[0]['username']:
+                    share_user = sharerDuqs[0]['username']
+                elif sharerDuqs[0]['userEmail']:
+                    share_user = sharerDuqs[0]['userEmail']
+                elif sharerDuqs[0]['phone']:
+                    share_user = sharerDuqs[0]['phone']
+                else:
+                    share_user = ''
+                return response.json(0, {
+                    'deviceName': sharerDvqs[0]['NickName'],
+                    'deviceType': sharerDvqs[0]['Type'],
+                    'shareUser': share_user,
+                })
+            else:
+                return response.json(404)
+        else:
+            return response.json(414)
+
     def do_confirm(self, userID, request_dict, response):
         shareToken = request_dict.get('shareToken', None)
         if shareToken is not None: