# # -*- 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 ''