新增pc工具获取iot数据接口

Controller/IotCoreController.py

@@ -51,6 +51,8 @@ class IotCoreView(View):
             return self.get_s3_pull_key(request_dict, response, request)
         elif operation == 'thingRegroup':
             return self.thing_regroup(request_dict, response, request)
+        elif operation == 'pcGetIotInfo':
+            return self.pcGetIotInfo(request_dict, response)
         else:
             token = TokenObject(request_dict.get('token', None))
             if token.code != 0:
@@ -363,3 +365,29 @@ class IotCoreView(View):
             return response.json(0, res)
         except Exception as e:
             return response.json(500, repr(e))
+
+    def pcGetIotInfo(self, request_dict, response):
+        # PC工具获取IoT数据
+        serial_number = request_dict.get('serial_number', None)
+        uid = request_dict.get('uid', None)
+        if not uid and not serial_number:
+            return response.json(444)
+
+        try:
+            if serial_number:
+                serial_number = serial_number[0:6]
+                iot_info_qs = iotdeviceInfoModel.objects.filter(serial_number=serial_number).\
+                    values('endpoint', 'token_iot_number')
+            else:
+                iot_info_qs = iotdeviceInfoModel.objects.filter(uid=uid).\
+                    values('endpoint', 'token_iot_number')
+
+            if not iot_info_qs.exists():
+                return response.json(173)
+
+            endpoint = iot_info_qs[0]['endpoint']
+            token_iot_number = iot_info_qs[0]['token_iot_number']
+            res = {'endpoint': endpoint, 'token_iot_number': token_iot_number}
+            return response.json(0, res)
+        except Exception as e:
+            return response.json(500, repr(e))