loocam新增查询所有设备接口

Controller/SensorGateway/SubDeviceController.py

@@ -51,6 +51,8 @@ class GatewaySubDeviceView(View):
             return self.update_emergency_status(request_dict, response)
         elif operation == 'list':  # 获取子设备信息
             return self.get_sensor_list(request_dict, response)
+        elif operation == 'device-list':  # 获取设备信息
+            return self.get_device_list(request_dict, response)
         else:
             return response.json(414)
 
@@ -570,6 +572,58 @@ class GatewaySubDeviceView(View):
         except Exception as e:
             return response.json(500, repr(e))
 
+    @staticmethod
+    def get_device_list(request_dict, response):
+        """
+        获取设备信息
+        @param request_dict: 请求参数
+        @request_dict familyId: 家庭id
+        @param response: 响应对象
+        @return: response
+        """
+        family_id = request_dict.get('familyId', None)
+        room_id = request_dict.get('roomId', None)
+        if not family_id:
+            return response.json(444, {'error param': 'familyId'})
+
+        try:
+            family_room_device_qs = FamilyRoomDevice.objects.filter(family_id=family_id, sub_device=0).values(
+                'device_id', 'device__Type', 'device__NickName').order_by('-device__data_joined')
+            if room_id:
+                family_room_device_qs = family_room_device_qs.filter(room_id=room_id)
+            device_list = []
+            for item in family_room_device_qs:
+                device_dict = {
+                    'deviceId': item['device_id'],
+                    'deviceType': item['device__Type'],
+                    'deviceNickName': item['device__NickName'],
+                }
+                sub_device = []
+                family_room_sub_device_qs = FamilyRoomDevice.objects.filter(Q(family_id=family_id), ~Q(sub_device=0),
+                                                                            Q(device_id=item['device_id'])).values(
+                    'sub_device', 'room_id').order_by('sort')
+                for each in family_room_sub_device_qs:
+                    room_qs = FamilyRoom.objects.filter(id=each['room_id']).values('name')
+                    room_name = room_qs[0]['name'] if room_qs.exists() else ''
+                    device_qs = GatewaySubDevice.objects.filter(id=each['sub_device']).values('id', 'nickname',
+                                                                                              'device_type', 'src_addr',
+                                                                                              'status', 'created_time')
+                    if device_qs.exists():
+                        sub_device.append({
+                            'gatewaySubId': device_qs[0]['id'],
+                            'nickName': device_qs[0]['nickname'],
+                            'deviceType': device_qs[0]['device_type'],
+                            'srcAddr': device_qs[0]['src_addr'],
+                            'status': device_qs[0]['status'],
+                            'createdTime': device_qs[0]['created_time'],
+                            'roomName': room_name,
+                            'familyId': family_id
+                        })
+                device_dict['sub_device'] = sub_device
+                device_list.append(device_dict)
+            return response.json(0, device_list)
+        except Exception as e:
+            return response.json(500, repr(e))
 #
 #                   ___====-_  _-====___
 #             _--^^^#####//      \\#####^^^--_