ASJServer/SensorGateway/EquipmentFamilyController.py

# # -*- encoding: utf-8 -*-
# """
# @File    : EquipmentFamilyController.py
# @Time    : 2022/5/13 15:50
# @Author  : stephen
# @Email   : zhangdongming@asj6.wecom.work
# @Software: PyCharm
# """
#
# import time
#
# import oss2
# from django.db import connection
# from django.db import transaction
# from django.db.models import Q
# from django.views.generic.base import View
#
# from Ansjer.config import OSS_STS_ACCESS_SECRET, OSS_STS_ACCESS_KEY
# from Controller.DeviceConfirmRegion import Device_Region
# from Model.models import Device_Info, UID_Bucket, UID_Preview, UidSetModel, UidChannelSetModel, \
#     iotdeviceInfoModel, UIDModel, Device_User, UserFamily, FamilyMember, FamilyMemberPermission, \
#     FamilyRoomDevice, FamilyRoom
# from Object.ResponseObject import ResponseObject
# from Object.TokenObject import TokenObject
# from Service.CommonService import CommonService
#
#
# # 家庭设备管理
# class EquipmentFamilyView(View):
#
#     def get(self, request, *args, **kwargs):
#         request.encoding = 'utf-8'
#         operation = kwargs.get('operation')
#         return self.validation(request.GET, request, operation)
#
#     def post(self, request, *args, **kwargs):
#         request.encoding = 'utf-8'
#
#         operation = kwargs.get('operation')
#         return self.validation(request.POST, request, operation)
#
#     def validation(self, request_dict, request, operation):
#
#         token = TokenObject(request.META.get('HTTP_AUTHORIZATION'))
#         lang = request_dict.get('lang', None)
#         if lang:
#             response = ResponseObject(lang)
#         else:
#             response = ResponseObject(token.lang) if token.lang else ResponseObject()
#
#         if token.code != 0:
#             return response.json(token.code)
#         user_id = token.userID
#
#         # 手机端添加设备，查询，修改
#         if operation == 'add':
#             return self.do_save(user_id, request_dict, response, request)
#         # 分页获取设备
#         if operation == 'page':
#             return self.do_device_page(user_id, request_dict, response)
#         # 条件查询设备列表
#         if operation == 'query':
#             return self.do_device_query(user_id, request_dict, response)
#         # 获取家庭列表
#         if operation == 'family-list':
#             return self.get_family_list(user_id, request_dict, response)
#         # 家庭保存
#         if operation == 'family-save':
#             return self.family_save(user_id, request_dict, response)
#         # 获取房间列表
#         if operation == 'room-list':
#             return self.get_family_room_list(request_dict, response)
#         # 房间保存
#         if operation == 'room-save':
#             return self.room_save(request_dict, response)
#         if operation == 'room-sort':
#             return self.room_sort_save(request_dict, response)
#         if operation == 'permission-list':
#             return self.get_member_permission_list(user_id, request_dict, response)
#         else:
#             return response.json(414)
#
#     @classmethod
#     def do_save(cls, user_id, request_dict, response, request):
#         """
#         添加设备
#         @param request:
#         @param user_id:
#         @param request_dict:
#         @param response:
#         @return:
#         """
#         nick_name = request_dict.get('nickName', None)
#         serial_number = request_dict.get('serialNumber', None)
#         device_type = request_dict.get('deviceType', None)
#         family_id = request_dict.get('familyId', None)
#         room_id = request_dict.get('roomId', None)
#         # type 可能为0
#         if not all([nick_name, serial_number, device_type]):
#             return response.json(444, {'param': 'nick_name, serial_number, device_type'})
#         device_info_qs = Device_Info.objects.filter(serial_number=serial_number, userID_id=user_id)
#         if device_info_qs:
#             # 判断设备是否已存在
#             if device_info_qs[0].isExist == 1:
#                 return response.json(174)
#             else:
#                 device_info_qs.delete()
#         try:
#             with transaction.atomic():
#                 # 格式化后的日期时间
#                 now_time = CommonService.timestamp_to_str(int(time.time()))
#                 device_id = CommonService.getUserID(getUser=False)
#                 Device_Info.objects.create(id=device_id, userID_id=user_id, NickName=nick_name,
#                                            Type=device_type,
#                                            UID=serial_number,
#                                            serial_number=serial_number, data_joined=now_time,
#                                            update_time=now_time)
#                 boole = cls.family_room_device_save(family_id, room_id, device_id)
#                 if not boole:
#                     return response.json(15)
#                 # 判断是否有用户绑定
#                 us_qs = UidSetModel.objects.filter(uid=serial_number)
#                 if not us_qs:
#                     n_time = int(time.time())
#                     ip = CommonService.get_ip_address(request)
#                     region_id = Device_Region().get_device_region(ip)
#                     region_alexa = 'CN' if region_id == 1 else 'ALL'
#                     uid_set_create_dict = {
#                         'uid': serial_number,
#                         'addTime': n_time,
#                         'updTime': n_time,
#                         'ip': CommonService.get_ip_address(request_dict),
#                         'nickname': nick_name,
#                         'region_alexa': region_alexa,
#                     }
#                     UidSetModel.objects.create(**uid_set_create_dict)
#                 return response.json(0)
#         except Exception as e:
#             print(e)
#             return response.json(177, repr(e))
#
#     @classmethod
#     def do_device_page(cls, user_id, request_dict, response):
#         """
#         查询设备列表
#         @param user_id:
#         @param request_dict:
#         @param response:
#         @return:
#         """
#         page_no = request_dict.get('pageNo', None)
#         page_size = request_dict.get('pageSize', None)
#         if not all([page_no, page_size]):
#             return response.json(444)
#
#         page = int(page_no)
#         line = int(page_size)
#         device_info_qs = Device_Info.objects.filter(userID=user_id)
#         device_info_qs = device_info_qs.filter(~Q(isExist=0))
#         total = device_info_qs.count()
#         device_info_qs = device_info_qs.values("id", "userID_id", "NickName", "Type", "serial_number",
#                                                "data_joined",
#                                                "update_time")[(page - 1) * line: page * line]
#         data = []
#         for item in device_info_qs:
#             data.append({
#                 'id': item['id'],
#                 'userId': item['userID_id'],
#                 'nickName': item['NickName'],
#                 'type': item['Type'],
#                 'serialNumber': item['serial_number'],
#                 'dataJoined': item['data_joined'].strftime("%Y-%m-%d %H:%M:%S"),
#                 'updateTime': item['update_time'].strftime("%Y-%m-%d %H:%M:%S")
#             })
#         return response.json(0, {'list': data, 'total': total})
#
#     @classmethod
#     def do_device_query(cls, user_id, request_dict, response):
#         """
#         查询用户设备信息
#         @param user_id: 用户id
#         @param request_dict: 请求参数
#         @param response: 响应对象
#         @return: response
#         """
#         page = request_dict.get('page', None)
#         line = request_dict.get('line', None)
#         nick_name = request_dict.get('NickName', None)
#         family_id = request_dict.get('familyId', None)
#         room_id = request_dict.get('roomId', None)
#
#         page = int(page)
#         line = int(line)
#         uid = request_dict.get('uid', None)
#         if family_id:
#             permission = cls.get_member_permission_details(user_id, int(family_id))
#             if not permission or permission == '003':
#                 return response.json(404)
#         # 获取设备信息列表
#         device_info_list = cls.get_device_info_list(user_id, nick_name, uid,
#                                                     page, line, family_id, room_id)
#         uid_list = []
#         # 判断是否是主用户 isPrimaryUser=0：否，1：是
#         for dvl in device_info_list:
#             if dvl['primaryUserID'] and dvl['id'] == dvl['primaryUserID']:
#                 dvl['isPrimaryUser'] = 1
#             else:
#                 dvl['isPrimaryUser'] = 0
#             uid_list.append(dvl['UID'])
#         # 设备关联套餐，设备预览图
#         uid_bucket_qs, uid_preview_qs = cls.get_bucket_and_preview_by_uid(uid_list)
#         # 设备配置信息
#         uid_set_dict = cls.get_uid_set_dict(uid_list)
#         # 设备详情信息
#         result = cls.get_device_details(device_info_list, uid_bucket_qs, uid_preview_qs, uid_set_dict)
#         items = []
#         for index, item in enumerate(result):
#             # 加密
#             if item['View_Password']:
#                 item['View_Password'] = CommonService.encode_data(item['View_Password'], 1, 4)
#             items.append(item)
#         return response.json(0, items)
#
#     @classmethod
#     def get_device_info_list(cls, user_id, nick_name, uid, page, line, family_id, room_id):
#         """
#         根据用户id获取设备信息
#         @param room_id: 家庭id
#         @param family_id: 房间id
#         @param uid: uid
#         @param nick_name: 设备名称
#         @param line: 条数
#         @param page: 页数
#         @param user_id: 用户id
#         @return: device_info_list 设备信息列表
#         """
#         # 获取用户设备信息
#         device_info_qs = Device_Info.objects.filter(userID_id=user_id)
#         # 过滤已重置的设备
#         device_info_qs = device_info_qs.filter(~Q(isExist=2))
#         if nick_name:
#             device_info_qs = device_info_qs.filter(NickName__icontains=nick_name)
#         if uid:
#             device_info_qs.filter(UID=uid)
#         if family_id or room_id:
#             # 根据家庭id获取房间id关联查询设备
#             return cls.get_family_device_list(user_id, page, line, family_id, room_id)
#         device_info_values = device_info_qs.values('id', 'userID', 'NickName', 'UID', 'View_Account', 'View_Password',
#                                                    'ChannelIndex',
#                                                    'Type', 'isShare', 'primaryUserID', 'primaryMaster', 'data_joined',
#                                                    'vodPrimaryUserID',
#                                                    'vodPrimaryMaster', 'userID__userEmail', 'version', 'isVod',
#                                                    'isExist', 'NotificationMode',
#                                                    'isCameraOpenCloud', 'serial_number')
#
#         device_info_values = device_info_values[(page - 1) * line:page * line]
#         device_info_list = CommonService.qs_to_list(device_info_values)
#         return device_info_list
#
#     @classmethod
#     def get_family_device_list(cls, user_id, page_no, page_size, family_id, room_id):
#         """
#         获取关联家庭设备列表
#         @param user_id: 用户id
#         @param page_no: 页数
#         @param page_size: 分页大小
#         @param family_id: 家庭id
#         @param room_id: 房间id
#         @return: result_list
#         """
#         cursor = connection.cursor()
#         sql = 'SELECT d.id,d.userID_id as userID,d.NickName,d.UID,d.View_Account,d.View_Password,d.ChannelIndex,' \
#               'd.Type,d.isShare,d.primaryUserID,d.primaryMaster,d.data_joined,d.vodPrimaryUserID,d.vodPrimaryMaster, ' \
#               'd.version,d.isVod,d.isExist,d.NotificationMode,d.isCameraOpenCloud,d.serial_number '
#         sql += 'FROM device_info d INNER JOIN loocam_family_room_device l ON d.id = l.device_id '
#         sql += 'WHERE d.userID_id = %s AND d.isExist != %s '
#         if family_id:
#             sql += ' AND l.family_id = %s '
#         if room_id:
#             sql += ' AND l.room_id = %s '
#         sql += ' order by d.data_joined DESC,d.id DESC LIMIT %s,%s '
#         cursor.execute(sql, [user_id, 2, int(family_id) if family_id else int(room_id), ((page_no - 1) * page_size),
#                              page_size, ])
#         data_obj = cursor.fetchall()
#         cursor.close()  # 执行完，关闭
#         connection.close()
#         result_list = []
#         col_names = [desc[0] for desc in cursor.description]
#         for item in data_obj:
#             val = dict(zip(col_names, item))
#             user_id = val['userID']
#             device_user_qs = Device_User.objects.filter(userID=user_id)
#             val['userID__userEmail'] = device_user_qs.first().userEmail
#             val['isShare'] = False if val['isShare'] == 0 else True
#             if 'data_joined' in val:
#                 if val['data_joined']:
#                     val['data_joined'] = val['data_joined'].strftime("%Y-%m-%d %H:%M:%S")
#                 else:
#                     val['data_joined'] = ''
#             result_list.append(val)
#         return result_list
#
#     @classmethod
#     def get_bucket_and_preview_by_uid(cls, uid_list):
#         """
#         根据uid列表查询套餐
#         @param uid_list: uid列表
#         @return: uid_bucket_qs
#         """
#         uid_bucket_qs = UID_Bucket.objects.filter(uid__in=uid_list).values('bucket__content', 'status', 'channel',
#                                                                            'endTime', 'uid')
#         uid_preview_qs = UID_Preview.objects.filter(uid__in=uid_list).order_by('channel').values('id', 'uid', 'channel')
#         return uid_bucket_qs, uid_preview_qs
#
#     @classmethod
#     def get_uid_set_dict(cls, uid_list):
#         """
#         获取uid配置信息
#         @param uid_list: uid列表
#         @return: uid_set_dict uid配置信息
#         """
#         uid_set_qs = UidSetModel.objects.filter(uid__in=uid_list) \
#             .values('id', 'uid', 'version', 'nickname', 'ucode',
#                     'detect_status', 'detect_group',
#                     'detect_interval',
#                     'region_alexa', 'is_alexa', 'deviceModel',
#                     'TimeZone', 'TimeStatus', 'SpaceUsable',
#                     'SpaceSum', 'MirrorType', 'RecordType',
#                     'OutdoorModel', 'WIFIName', 'isDetector',
#                     'DetectorRank', 'is_human', 'is_custom_voice',
#                     'is_ptz', 'double_wifi', 'is_ai')
#         uid_set_dict = {}
#         for us in uid_set_qs:
#             uid_set_dict[us['uid']] = {
#                 'version': us['version'],
#                 'nickname': us['nickname'],
#                 'ucode': us['ucode'],
#                 'detect_interval': us['detect_interval'],
#                 'detect_group': us['detect_group'],
#                 'detect_status': us['detect_status'],
#                 'region_alexa': us['region_alexa'],
#                 'is_alexa': us['is_alexa'],
#                 'deviceModel': us['deviceModel'],
#                 'TimeZone': us['TimeZone'],
#                 'TimeStatus': us['TimeStatus'],
#                 'SpaceUsable': us['SpaceUsable'],
#                 'SpaceSum': us['SpaceSum'],
#                 'MirrorType': us['MirrorType'],
#                 'RecordType': us['RecordType'],
#                 'OutdoorModel': us['OutdoorModel'],
#                 'WIFIName': us['WIFIName'],
#                 'isDetector': us['isDetector'],
#                 'DetectorRank': us['DetectorRank'],
#                 'is_human': us['is_human'],
#                 'is_custom_voice': us['is_custom_voice'],
#                 'is_ptz': us['is_ptz'],
#                 'double_wifi': us['double_wifi'],
#                 'is_ai': us['is_ai']
#             }
#             # 从uid_channel里面取出通道配置信息
#             uid_channel_set_qs = UidChannelSetModel.objects.filter(uid__id=us['id']) \
#                 .values('channel', 'channel_name',
#                         'pir_audio', 'mic_audio',
#                         'battery_status',
#                         'battery_level',
#                         'sleep_status',
#                         'sleep_time',
#                         'light_night_model',
#                         'light_alarm_type',
#                         'light_alarm_level',
#                         'light_alarm_man_en',
#                         'light_alarm_vol',
#                         'light_long_light'
#                         )
#             channels_list = []
#             for ucs in uid_channel_set_qs:
#                 channels_dict = {
#                     'channel': ucs['channel'],
#                     'channel_name': ucs['channel_name'],
#                     'pir_audio': ucs['pir_audio'],
#                     'mic_audio': ucs['mic_audio'],
#                     'battery_status': ucs['battery_status'],
#                     'battery_level': ucs['battery_level'],
#                     'sleep_status': ucs['sleep_status'],
#                     'sleep_time': ucs['sleep_time'],
#                     'light_night_model': ucs['light_night_model'],
#                     'light_alarm_type': ucs['light_alarm_type'],
#                     'light_alarm_level': ucs['light_alarm_level'],
#                     'light_alarm_man_en': ucs['light_alarm_man_en'],
#                     'light_alarm_vol': ucs['light_alarm_vol'],
#                     'light_long_light': ucs['light_long_light']
#                 }
#                 channels_list.append(channels_dict)
#             uid_set_dict[us['uid']]['channels'] = channels_list
#         return uid_set_dict
#
#     @classmethod
#     def get_device_details(cls, device_info_list, uid_bucket_qs, uid_preview_qs, uid_set_dict):
#         """
#         设备详情
#         @param device_info_list: 设备信息列表
#         @param uid_bucket_qs: 套餐对象
#         @param uid_preview_qs:
#         @param uid_set_dict:
#         @return:
#         """
#         now_time = int(time.time())
#         data = []
#         for p in device_info_list:
#             # 获取iotDeviceInfo表的endpoint和tokenIotNumber
#             p['iot'] = []
#             if p['serial_number']:  # 存在序列号根据序列号查询
#                 iot_device_info_qs = iotdeviceInfoModel.objects.filter(serial_number=p['serial_number'][0:6])
#             else:  # 根据uid查询
#                 iot_device_info_qs = iotdeviceInfoModel.objects.filter(uid=p['UID'])
#             if iot_device_info_qs.exists():
#                 iot_device_Info = iot_device_info_qs.values('endpoint', 'token_iot_number')
#                 p['iot'].append({
#                     'endpoint': iot_device_Info[0]['endpoint'],
#                     'token_iot_number': iot_device_Info[0]['token_iot_number']
#                 })
#
#             p['vod'] = []
#             for dm in uid_bucket_qs:
#                 if p['UID'] == dm['uid']:
#                     if dm['endTime'] > now_time:
#                         p['vod'].append(dm)
#             p['preview'] = []
#
#             auth = oss2.Auth(OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET)
#             bucket = oss2.Bucket(auth, 'oss-cn-hongkong.aliyuncs.com', 'statres')
#
#             for up in uid_preview_qs:
#                 if p['UID'] == up['uid']:
#                     obj = 'uid_preview/{uid}/channel_{channel}.png'.format(uid=up['uid'], channel=up['channel'])
#                     img_sign = bucket.sign_url('GET', obj, 300)
#                     p['preview'].append(img_sign)
#
#             p_uid = p['UID']
#
#             # 返回设备初始化字符
#             uid_qs = UIDModel.objects.filter(uid=p_uid).values('platform', 'init_string', 'init_string_app')
#             if uid_qs.exists():
#                 p['platform'] = uid_qs[0]['platform']
#                 p['initString'] = uid_qs[0]['init_string']
#                 p['initStringApp'] = uid_qs[0]['init_string_app']
#
#             if p_uid in uid_set_dict:
#                 # 设备版本号
#                 uidversion = uid_set_dict[p_uid]['version']
#                 if len(uidversion) > 6:
#                     uidversion = uidversion[0: uidversion.rfind('.')]
#                 p['uid_version'] = uidversion
#                 p['ucode'] = uid_set_dict[p_uid]['ucode']
#                 p['detect_interval'] = uid_set_dict[p_uid]['detect_interval']
#                 p['detect_status'] = uid_set_dict[p_uid]['detect_status']
#                 p['detect_group'] = uid_set_dict[p_uid]['detect_group']
#                 p['region_alexa'] = uid_set_dict[p_uid]['region_alexa']
#                 p['is_alexa'] = uid_set_dict[p_uid]['is_alexa']
#                 p['deviceModel'] = uid_set_dict[p_uid]['deviceModel']
#                 p['TimeZone'] = uid_set_dict[p_uid]['TimeZone']
#                 p['TimeStatus'] = uid_set_dict[p_uid]['TimeStatus']
#                 p['SpaceUsable'] = uid_set_dict[p_uid]['SpaceUsable']
#                 p['SpaceSum'] = uid_set_dict[p_uid]['SpaceSum']
#                 p['MirrorType'] = uid_set_dict[p_uid]['MirrorType']
#                 p['RecordType'] = uid_set_dict[p_uid]['RecordType']
#                 p['OutdoorModel'] = uid_set_dict[p_uid]['OutdoorModel']
#                 p['WIFIName'] = uid_set_dict[p_uid]['WIFIName']
#                 p['isDetector'] = uid_set_dict[p_uid]['isDetector']
#                 p['DetectorRank'] = uid_set_dict[p_uid]['DetectorRank']
#                 p['is_human'] = uid_set_dict[p_uid]['is_human']
#                 p['is_custom_voice'] = uid_set_dict[p_uid]['is_custom_voice']
#                 p['is_ptz'] = uid_set_dict[p_uid]['is_ptz']
#                 p['channels'] = uid_set_dict[p_uid]['channels']
#                 p['double_wifi'] = uid_set_dict[p_uid]['double_wifi']
#                 p['is_ai'] = uid_set_dict[p_uid]['is_ai']
#                 # 设备昵称 调用影子信息昵称，先阶段不可
#                 if uid_set_dict[p_uid]['nickname']:
#                     p['NickName'] = uid_set_dict[p_uid]['nickname']
#             else:
#                 # 设备版本号
#                 p['uid_version'] = ''
#                 p['ucode'] = ''
#             data.append(p)
#         return data
#
#     @classmethod
#     def get_family_list(cls, user_id, request_dict, response):
#         """
#         查询家庭列表
#         @param user_id: 用户id
#         @param request_dict: 请求
#         @param response: 响应
#         @return: 家庭列表items
#         """
#         lang = request_dict.get('lang', 'cn')
#         if user_id:
#             with transaction.atomic():
#                 user_family_qs = UserFamily.objects.filter(user_id=user_id)
#                 if not user_family_qs.exists():
#                     n_time = int(time.time())
#                     device_user = Device_User.objects.get(userID=user_id)
#                     # 创建默认家庭使用用户名或者邮箱作为名称
#                     family_name = device_user.username if device_user.username else device_user.userEmail
#                     family_name = family_name + "的家" if lang == 'cn' else family_name + " home"
#                     user_family = UserFamily.objects.create(user_id=user_id, name=family_name,
#                                                             updated_time=n_time,
#                                                             created_time=n_time)
#                     if user_family.id:
#                         member_permission_qs = FamilyMemberPermission.objects.filter(no='001').values('id')
#                         permission_id = member_permission_qs.first()['id']
#                         FamilyMember.objects.create(family_id=user_family.id, user_id=user_id,
#                                                     user_name=device_user.username, identity=1,
#                                                     permission_id=int(permission_id), sort=1, updated_time=n_time,
#                                                     created_time=n_time)
#                         cls.family_device_binding(user_id, family_id=user_family.id)
#
#             family_member_qs = FamilyMember.objects.filter(user_id=user_id) \
#                 .order_by('sort').values('identity', 'family_id', 'family__name', 'permission__no', 'family__location')
#             items = []
#             data = {}
#             for item in family_member_qs:
#                 data['familyId'] = item['family_id']
#                 data['identity'] = item['identity']
#                 data['familyName'] = item['family__name']
#                 data['permissionId'] = item['permission_id']
#                 data['permissionNo'] = item['permission__no']
#                 data['familyLocation'] = item['family__location']
#                 items.append(data)
#             return response.json(0, items)
#         return response.json(309)
#
#     @classmethod
#     def family_save(cls, user_id, request_dict, response):
#         """
#         家庭保存
#         @param user_id: 用户id
#         @param request_dict: 参数
#         @param response: 响应
#         @return:
#         """
#         family_id = request_dict.get('familyId', None)
#         family_name = request_dict.get('familyName', None)
#         location = request_dict.get('location', None)
#         with transaction.atomic():
#             now_time = int(time.time())
#             if family_id:
#                 family_member = FamilyMember.objects.filter(family_id=family_id, user_id=user_id)
#                 if family_member.exists():
#                     family_member = family_member.first()
#                     if family_member.identity == 0:
#                         return response.json(404)
#                     family_qs = UserFamily.objects.filter(id=family_id)
#                     if family_qs.exists():
#                         data = {
#                             'updated_time': now_time
#                         }
#                         if family_name:
#                             data['name'] = family_name
#                         if location:
#                             data['location'] = location
#                         family_qs.update(**data)
#                         return response.json(0)
#             data = {'user_id': user_id, 'updated_time': now_time, 'created_time': now_time}
#             if family_name:
#                 data['name'] = family_name
#                 if location:
#                     data['location'] = location
#                 UserFamily.objects.create(**data)
#                 return response.json(0)
#             return response.json(444)
#
#     @classmethod
#     def family_room_device_save(cls, family_id, room_id, device_id):
#         """
#         设备与家庭房间保存
#         @param family_id: 家庭id
#         @param room_id: 房间id
#         @param device_id: 设备id
#         @return: Boole
#         """
#         now_time = int(time.time())
#         family_room_device = FamilyRoomDevice.objects.filter(device_id=device_id)
#         if family_room_device.exists():
#             return False
#         data = {
#             'family_id': int(family_id),
#             'device_id': device_id,
#             'updated_time': now_time,
#             'created_time': now_time
#         }
#         if room_id:
#             room_id = int(room_id)
#             if FamilyRoom.objects.filter(id=room_id).exists():
#                 data['room_id'] = room_id
#         FamilyRoomDevice.objects.create(**data)
#         return True
#
#     @classmethod
#     def family_device_binding(cls, user_id, family_id):
#         """
#         用户旧设备与默认家庭进行绑定
#         @param user_id:
#         @param family_id:
#         @return: True
#         """
#         device_info_qs = Device_Info.objects.filter(userID=user_id)
#         device_info_qs = device_info_qs.filter(~Q(isExist=0)).values('id')
#         if device_info_qs.exists():
#             with transaction.atomic():
#                 not_time = time.time()
#                 device_list = []
#                 for item in device_info_qs:
#                     device_id = item['id']
#                     family_device_qs = FamilyRoomDevice.objects.filter(device_id=device_id)
#                     if not family_device_qs.exists():
#                         # 设备绑定家庭
#                         device_list.append(FamilyRoomDevice(family_id=family_id, device_id=device_id,
#                                                             created_time=not_time,
#                                                             updated_time=not_time))
#                 if device_list:
#                     FamilyRoomDevice.objects.bulk_create(device_list)
#         return True
#
#     @classmethod
#     def get_family_room_list(cls, request_dict, response):
#         """
#         获取房间列表并统计该房间下有几台设备
#         @param request_dict: 请求参数
#         @param response: 响应参数
#         @return: total；data
#         """
#         family_id = request_dict.get('familyId', None)
#         if not family_id:
#             return response.json(444)
#         page_no = request_dict.get('pageNo', None)
#         page_size = request_dict.get('pageSize', None)
#         if not all([page_no, page_size]):
#             return response.json(444)
#         page_no = int(page_no)
#         page_size = int(page_size)
#         room_qs = FamilyRoom.objects.filter(family_id=family_id).order_by('sort')
#         total = room_qs.count()
#         room_qs = room_qs.values('id', 'name', 'sort')[(page_no - 1) * page_size: page_no * page_size]
#         room_list = []
#         if not room_qs.exists():
#             return response.json(0, room_list)
#         for item in room_qs:
#             item['deviceCount'] = FamilyRoomDevice.objects.filter(family_id=family_id, room_id=item['id']).count()
#             room_list.append(item)
#         return response.json(0, {'total': total, 'data': room_list})
#
#     @classmethod
#     def room_save(cls, request_dict, response):
#         """
#         房间保存
#         @param request_dict: 请求参数
#         @param response: 响应参数
#         @return:
#         """
#         family_id = request_dict.get('familyId', None)
#         room_name = request_dict.get('roomName', None)
#         room_id = request_dict.get('roomId', None)
#         if not all([family_id, room_name]):
#             return response.json(444)
#         with transaction.atomic():
#             now_time = int(time.time())
#             if room_id:
#                 room_qs = FamilyRoom.objects.filter(id=int(room_id))
#                 if room_qs.exists():
#                     room_qs.update(name=room_name, updated_time=now_time)
#                     return response.json(0)
#             room_qs = FamilyRoom.objects.filter(family_id=family_id, name=room_name)
#
#             if room_qs.exists():
#                 room_dict = {'updated_time': now_time, 'name': room_name}
#                 room_qs.update(**room_dict)
#             FamilyRoom.objects.create(family_id=family_id, name=room_name, updated_time=now_time,
#                                       created_time=now_time)
#         return response.json(0)
#
#     @classmethod
#     def room_sort_save(cls, request_dict, response):
#         """
#         房间排序
#         @param request_dict: 请求参数
#         @param response: 响应参数
#         @return:
#         """
#         ids = request_dict.getlist('ids', None)
#         if not ids:
#             return response.json(444)
#         for i, item in ids:
#             id_sort = item[i]
#             print(id_sort)
#         return response.json(0)
#
#     @classmethod
#     def get_member_permission_list(cls, user_id, request_dict, response):
#         """
#         获取用户权限列表
#         @param user_id:
#         @param request_dict:
#         @param response:
#         @return:
#         """
#         family_id = request_dict.get('familyId')
#         user_id = request_dict.get('userId', user_id)
#         if not family_id:
#             return response.json(404)
#         result = cls.get_member_permission_by_family_id(user_id, family_id)
#         return response.json(0, result)
#
#     @classmethod
#     def get_member_permission_by_family_id(cls, user_id, family_id):
#         """
#         获取权限列表并返回当前user_id所在家庭中权限
#         @param user_id:
#         @param family_id:
#         @return:
#         """
#         member_qs = FamilyMember.objects.filter(family_id=family_id)
#         if user_id:
#             member_qs = member_qs.filter(user_id=user_id).values()
#             if member_qs.exists():
#                 member_qs = member_qs.first()
#         permission = FamilyMemberPermission.objects.all().values('id', 'no')
#         data_list = []
#         this_permission = {}
#         result = {}
#         for item in permission:
#             if item['id'] == member_qs['permission_id']:
#                 this_permission['id'] = item['id']
#                 this_permission['no'] = item['no']
#             data_list.append(item)
#         result['memberPermission'] = this_permission
#         result['permissionList'] = data_list
#         return result
#
#     @classmethod
#     def get_member_permission_details(cls, user_id, family_id):
#         member_qs = FamilyMember.objects.filter(family_id=family_id, user_id=user_id).values()
#         if member_qs.exists():
#             member_qs = member_qs.first()
#             permission_id = member_qs['permission_id']
#             permission_qs = FamilyMemberPermission.objects.filter(id=permission_id).values('no')
#             return permission_qs.first()['no']
#         return ''