|
|
@@ -1,748 +1,748 @@
|
|
|
-# # -*- 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 ''
|
|
|
+# -*- 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 ''
|
