ASJServer/Service/UserDeviceService.py

# -*- encoding: utf-8 -*-
"""
@File    : UserDeviceService.py
@Time    : 2022/11/18 11:40
@Author  : stephen
@Email   : zhangdongming@asj6.wecom.work
@Software: PyCharm
"""
from django.db.models import Q

from Model.models import Device_Info, UID_Bucket, UID_Preview, UidSetModel, UidChannelSetModel, UnicomDeviceInfo, \
    UIDModel
from Service.CommonService import CommonService


class UserDeviceService:

    @classmethod
    def query_device_list(cls, user_id, uid, nickname, page, line):
        """
        查询设备列表
        @param user_id: 用户user_id
        @param uid: uid
        @param nickname: 昵称
        @param page: 页数
        @param line: 每页条数
        @return: dv_list, uid_list
        """
        dv_qs = Device_Info.objects.filter(userID_id=user_id)
        # 过滤已重置的设备
        dv_qs = dv_qs.filter(~Q(isExist=2))
        if nickname:
            dv_qs = dv_qs.filter(NickName=nickname)
        if uid:
            dv_qs = dv_qs.filter(UID=uid)
        dv_qs = dv_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')[(page - 1) * line:page * line]
        dv_list = CommonService.qs_to_list(dv_qs)
        uid_list = []
        for item in dv_list:
            if item['primaryUserID'] and item['id'] == item['primaryUserID']:
                item['isPrimaryUser'] = 1
            else:
                item['isPrimaryUser'] = 0
            uid_list.append(item['UID'])
        return dv_list, uid_list

    @classmethod
    def query_device_uid_bucket(cls, uid_list):
        """
        查询uid关联存储桶套餐
        @param uid_list: uid集合
        @return: UID_Bucket
        """
        return UID_Bucket.objects.filter(uid__in=uid_list). \
            values('bucket__content', 'status', 'channel', 'endTime', 'uid')

    @classmethod
    def query_device_preview(cls, uid_list):
        """
        查询设备uid预览图
        @param uid_list: uid集合
        @return: UID_Preview
        """
        return UID_Preview.objects.filter(uid__in=uid_list).order_by('channel') \
            .values('id', 'uid', 'channel')

    @classmethod
    def query_device_uid_set(cls, uid_list):
        """
        查询设备属性
        @return: UidSetModel
        """
        return UidSetModel.objects.filter(uid__in=uid_list) \
            .values('id', 'uid', 'version', 'nickname', 'ucode',
                    'detect_status', 'detect_group',
                    'detect_interval', 'isSupportFourPoint',
                    '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', 'mobile_4g',
                    'ai_type')

    @classmethod
    def query_device_channel(cls, uid_list):
        """
        获取设备通道配置属性
        @param uid_list: uid集合
        @return: uv_dict
        """
        us_qs = cls.query_device_uid_set(uid_list)
        uv_dict = {}
        for us in us_qs:
            uv_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'],
                'mobile4G': us['mobile_4g'],
                'is_ai': us['is_ai'],
                'ai_type': us['ai_type'],
                'isSupportFourPoint': us['isSupportFourPoint'],
            }
            uv_dict[us['uid']]['channels'] = cls.query_device_channel_set(us['id'])
        return uv_dict

    @classmethod
    def query_device_channel_set(cls, uid):
        """
        查询通道配置
        @param uid: 设备uid
        @return: channels
        """
        ucs_qs = UidChannelSetModel.objects.filter(uid__id=uid)
        ucs_qs = ucs_qs.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 = []
        for ucs in ucs_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.append(channels_dict)
        return channels

    @classmethod
    def get_sim_by_serial_number(cls, p_vo):
        """
        根据序列号获取SIM卡属性
        @param p_vo:
        @return:
        """
        if p_vo['serial_number']:
            u_device_info_qs = UnicomDeviceInfo.objects.filter(serial_no=p_vo['serial_number'])
            if u_device_info_qs.exists():
                p_vo['iccid'] = u_device_info_qs.first().iccid
                p_vo['iccidType'] = u_device_info_qs.first().card_type

    @classmethod
    def get_uid_info(cls, p_vo, uid):
        """
        获取uid信息
        @param p_vo: 设备对象
        @param uid: 设备uid
        @return:
        """
        uid_qs = UIDModel.objects.filter(uid=uid).values('platform', 'init_string', 'init_string_app')
        if uid_qs.exists():
            p_vo['platform'] = uid_qs[0]['platform']
            p_vo['initString'] = uid_qs[0]['init_string']
            p_vo['initStringApp'] = uid_qs[0]['init_string_app']

    @classmethod
    def get_device_info_dto(cls, p_vo, p_uid, uv_dict):
        """
        获取设备信息DTO
        @param p_vo: 设备对象
        @param p_uid: 设备uid
        @param uv_dict: 设备通道字典
        """
        uidversion = uv_dict[p_uid]['version']
        if len(uidversion) > 6:
            uidversion = uidversion[0: uidversion.rfind('.')]
        p_vo['uid_version'] = uidversion
        p_vo['ucode'] = '72V201233AA' if uv_dict[p_uid]['mobile4G'] == 1 else uv_dict[p_uid]['ucode']
        p_vo['detect_interval'] = uv_dict[p_uid]['detect_interval']
        p_vo['detect_status'] = uv_dict[p_uid]['detect_status']
        p_vo['detect_group'] = uv_dict[p_uid]['detect_group']
        p_vo['region_alexa'] = uv_dict[p_uid]['region_alexa']
        p_vo['is_alexa'] = uv_dict[p_uid]['is_alexa']
        p_vo['deviceModel'] = uv_dict[p_uid]['deviceModel']
        p_vo['TimeZone'] = uv_dict[p_uid]['TimeZone']
        p_vo['TimeStatus'] = uv_dict[p_uid]['TimeStatus']
        p_vo['SpaceUsable'] = uv_dict[p_uid]['SpaceUsable']
        p_vo['SpaceSum'] = uv_dict[p_uid]['SpaceSum']
        p_vo['MirrorType'] = uv_dict[p_uid]['MirrorType']
        p_vo['RecordType'] = uv_dict[p_uid]['RecordType']
        p_vo['OutdoorModel'] = uv_dict[p_uid]['OutdoorModel']
        p_vo['WIFIName'] = uv_dict[p_uid]['WIFIName']
        p_vo['isDetector'] = uv_dict[p_uid]['isDetector']
        p_vo['DetectorRank'] = uv_dict[p_uid]['DetectorRank']
        p_vo['is_human'] = uv_dict[p_uid]['is_human']
        p_vo['is_custom_voice'] = uv_dict[p_uid]['is_custom_voice']
        p_vo['is_ptz'] = uv_dict[p_uid]['is_ptz']
        p_vo['channels'] = uv_dict[p_uid]['channels']
        p_vo['double_wifi'] = uv_dict[p_uid]['double_wifi']
        p_vo['mobile4G'] = uv_dict[p_uid]['mobile4G']
        p_vo['isCameraOpenCloud'] = 0 if uv_dict[p_uid]['mobile4G'] == 1 else p_vo['isCameraOpenCloud']
        p_vo['is_ai'] = uv_dict[p_uid]['is_ai']
        p_vo['ai_type'] = uv_dict[p_uid]['ai_type']
        p_vo['isSupportFourPoint'] = uv_dict[p_uid]['isSupportFourPoint']
        # 设备昵称 调用影子信息昵称，先阶段不可
        if uv_dict[p_uid]['nickname']:
            p_vo['NickName'] = uv_dict[p_uid]['nickname']