新增获取IoT数据接口

Controller/IotCoreController.py

@@ -59,6 +59,8 @@ class IotCoreView(View):
 
             if operation == 'clearIotCerm':
                 return self.clear_Iot_Cerm(request_dict, response)
+            elif operation == 'getIotInfo':
+                return self.getIotInfo(request_dict, response)
             else:
                 return response.json(404)
 
@@ -330,3 +332,21 @@ class IotCoreView(View):
         MSG['arn'] = arn
         MSG['region_name'] = region_name
         return MSG
+
+    def getIotInfo(self, request_dict, response):
+        # 获取IoT数据
+        serial_number = request_dict.get('serial_number', None)
+        if not serial_number:
+            return response.json(444)
+
+        try:
+            serial_number = serial_number[0:6]
+            iot_info_qs = iotdeviceInfoModel.objects.filter(serial_number=serial_number).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))