ASJServer/Controller/EquipmentManager.py

import re
import time
import traceback
import threading
import logging

import requests
import simplejson as json
from django.utils import timezone
from Model.models import Device_User, Device_Info, UID_Bucket, UID_Preview, UidSetModel, UidPushModel, \
    UIDCompanySerialModel, iotdeviceInfoModel, UIDMainUser, UidChannelSetModel, LogModel
from django.db.models import Q
from Object.ResponseObject import ResponseObject
from Object.TokenObject import TokenObject
from Service.CommonService import CommonService
from Service.ModelService import ModelService
from Ansjer.config import OSS_STS_ACCESS_SECRET, OSS_STS_ACCESS_KEY, BASE_DIR
from Object.ETkObject import ETkObject
import oss2
from django.http import JsonResponse
from Object.RedisObject import RedisObject
from Controller.DetectController import DetectControllerView
from Ansjer.config import PUSH_REDIS_ADDRESS

#     查询用户设备
def queryUserEquipmentInterface(request):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code != 0:
        return response.json(tko.code)
    userID = tko.userID
    if not userID:
        return response.json(309)
    dvqs = Device_Info.objects.filter(userID_id=userID)
    dvdict = CommonService.qs_to_dict(dvqs)
    uid_list = Device_Info.objects.filter(userID_id=userID, isShare=False). \
        values_list('UID', flat=True)
    ubqs = UID_Bucket.objects.filter(uid__in=uid_list). \
        values('bucket__content', 'status', 'channel', 'endTime', 'uid')
    res = []
    nowTime = int(time.time())
    for p in dvdict['datas']:
        p['fields']['vod'] = []
        for dm in ubqs:
            if p['fields']['UID'] == dm['uid']:
                if dm['endTime'] > nowTime:
                    p['fields']['vod'].append(dm)
                    # dm['valid'] = 1
                # else:
                #     dm['valid'] = 0
        # p['fields']['primaryUserID'] = ''
        res.append(p)
    return response.json(0, {'datas': res})


def addNewUserEquipmentInterface(request):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    deviceContent = request_dict.get('content', None)
    if not deviceContent:
        return response.json(444, 'content')
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code != 0:
        return response.json(tko.code)
    userID = tko.userID

    try:
        deviceData = json.loads(deviceContent)
        UID = deviceData.get('UID', None)
        if not UID:
            return response.json(444, 'content')
        dValid = Device_Info.objects.filter(userID_id=userID, UID=UID)
        if dValid:
            return response.json(174)
        else:
            # redisObj = RedisObject(db=8)
            # redisObj.del_data(key='uid_qs_' + userID)
            UID = deviceData.get('UID', '')
            re_uid = re.compile(r'^[A-Za-z0-9]{20}$')
            if re_uid.match(UID):
                userDevice = Device_Info(id=CommonService.getUserID(getUser=False), userID_id=userID,
                                         **deviceData)
                userDevice.save()
                if UID == '98UXAA8BRPA35VAL111A':
                    asy = threading.Thread(target=ModelService.add_log,
                                           args=(CommonService.get_ip_address(request), userID, 'addV0'))
                    asy.start()

                # is_bind = Device_Info.objects.filter(UID=UID, isShare=False)
                # # 判断是否有已绑定用户
                # if not is_bind.exists():
                #     userDevice = Device_Info(id=CommonService.getUserID(getUser=False), userID_id=userID,
                #                              **deviceData)
                #     userDevice.save()
                # else:
                #     # 分享添加
                #     if 'isShare' in deviceData:
                #         deviceData['isShare'] = True
                #     else:
                #         deviceData['isShare'] = True
                #     bind_userID = is_bind[0].userID_id
                #     userDevice = Device_Info(id=CommonService.getUserID(getUser=False),
                #                              userID_id=userID,
                #                              primaryUserID=bind_userID,
                #                              primaryMaster=ModelService.get_user_name(bind_userID),
                #                              **deviceData)
                #     userDevice.save()
            else:
                return response.json(444, 'UID')

    except Exception as e:
        errorInfo = traceback.format_exc()
        print('添加设备错误: %s ' % errorInfo)
        return response.json(178, repr(e))
    else:
        sqlDict = CommonService.qs_to_dict([userDevice])
        return response.json(0, sqlDict)


def delUserEquipmentInterface(request):
    '''
    删除用户设备
    :param request:
    :return:
    '''
    response = ResponseObject()
    request.encoding = 'utf-8'
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    id = request_dict.get('id', None)
    if not id:
        return response.json(444, 'id')
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code != 0:
        return response.json(tko.code)
    userID = tko.userID
    # 主用户删除设备全部删除
    try:
        dv_qs = Device_Info.objects.filter(userID_id=userID, id=id)
        # redisObj = RedisObject(db=8)
        # redisObj.del_data(key='uid_qs_' + userID)

        if dv_qs.exists():
            uid = dv_qs[0].UID
            asy = threading.Thread(target=ModelService.add_log, args=(CommonService.get_ip_address(request), userID, 'deleteV1'))
            asy.start()

            print('删除')
            UID_Preview.objects.filter(uid=uid).delete()
            dv_qs.delete()
            Device_Info.objects.filter(UID=uid).update(vodPrimaryUserID='', vodPrimaryMaster='')
            asy = threading.Thread(target=ModelService.del_eq_info, args=(userID, uid))
            asy.start()

    except Exception as e:
        errorInfo = traceback.format_exc()
        print('删除数据库记录错误: %s' % errorInfo)
        return response.json(176, repr(e))
    else:
        return response.json(0)


def modifyUserEquipmentInterface(request):
    '''
    修改用户设备
    :param request:
    :return:
    '''
    response = ResponseObject()
    if request.method == 'POST':
        request.encoding = 'utf-8'
        request_dict = request.POST
    elif request.method == 'GET':
        request.encoding = 'utf-8'
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    deviceContent = request_dict.get('content', None)
    id = request_dict.get('id', None)
    if not deviceContent or not id:
        return response.json(444, 'content,id')
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code != 0:
        return response.json(tko.code)
    userID = tko.userID
    if userID is None:
        return response.json(309)
    try:
        deviceData = json.loads(deviceContent)

        if deviceData.__contains__('userID_id'):
            asy = threading.Thread(target=ModelService.update_log,
                                   args=(CommonService.get_ip_address(request), userID, 'modifyV0', deviceData, id))
            asy.start()
            return response.json(10, '110')

        if deviceData.__contains__('UID'):
            del deviceData['UID']

        dev_info_qs = Device_Info.objects.filter(userID_id=userID, id=id)
        dev_info_qs.update(**deviceData)
    except Exception as e:
        return response.json(177, repr(e))
    else:
        qs = Device_Info.objects.filter(userID_id=userID, id=id)
        res = CommonService.qs_to_dict(qs)
        if qs.exists():
            uid = qs[0].UID
            if uid == '98UXAA8BRPA35VAL111A':
                asy = threading.Thread(target=ModelService.update_log,
                                       args=(CommonService.get_ip_address(request), userID, 'modifyV0', deviceContent, id))
                asy.start()
            nickname = qs[0].NickName
            # 增加设备影子信息修改昵称 start
            us_qs = UidSetModel.objects.filter(uid=uid)
            if us_qs.exists():
                us_qs.update(nickname=nickname)
            else:
                ChannelIndex = qs[0].ChannelIndex
                nowTime = int(time.time())
                uid_set_create_dict = {
                    'uid': uid,
                    'addTime': nowTime,
                    'updTime': nowTime,
                    'ip': CommonService.get_ip_address(request),
                    'channel': ChannelIndex,
                    'nickname': nickname,
                }
                UidSetModel.objects.create(**uid_set_create_dict)
            Device_Info.objects.filter(UID=uid).update(NickName=nickname)
            if deviceData.__contains__('NickName') and us_qs[0].is_alexa == 1:
                encrypt_pwd = ''
                if deviceData.__contains__('View_Password'):
                    encrypt_pwd = deviceData['View_Password']
                # 请求Alexa服务器更新事件网关
                url = 'https://www.zositech.xyz/deviceStatus/addOrUpdateV2'
                data_list = [{'userID': userID, 'UID': uid, 'uid_nick': nickname, 'password': encrypt_pwd}]
                data_list = json.dumps(data_list)
                data = {'data_list': data_list}
                requests.post(url, data=data, timeout=2)
        return response.json(0, res)


def showAllUserEquipmentInterface(request, *callback_args, **callback_kwargs):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'POST':
        fieldDict = request.POST
    elif request.method == 'GET':
        fieldDict = request.GET
    else:
        return response.json(444)
    token = request.POST.get('token', None)
    type = request.POST.get('type', None)
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code != 0:
        return response.json(tko.code)
    userID = tko.userID
    if not userID:
        return response.json(309)
    own_perm = ModelService.check_perm(userID=userID, permID=30)
    if not own_perm:
        return response.json(404)
    if type == 'PC':
        page = int(fieldDict['page'])
        line = int(fieldDict['line'])
        qs = Device_Info.objects.all()
        count = qs.count()
        res = qs[(page - 1) * line:page * line]
        sqlDict = CommonService.qs_to_dict(query_set=res)
        sqlDict['count'] = count
        return response.json(0, sqlDict)
    else:
        qs = Device_Info.objects.all()
        res = CommonService.qs_to_dict(qs)
        return response.json(0, res)


def findEquipmentInfoInterface(request, *callback_args, **callback_kwargs):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'GET':
        fieldDict = request.GET
    elif request.method == 'POST':
        fieldDict = request.POST
    else:
        return response.json(444)
    deviceContent = fieldDict.get('content', None)
    token = fieldDict.get('token', None)
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code != 0:
        return response.json(tko.code)
    if deviceContent:
        try:
            searchCondition = json.loads(deviceContent)
        except Exception as e:
            print(repr(e))
            return response.json(10, repr(e))
        else:
            kwargs = CommonService.get_kwargs(data=searchCondition)
            qs = Device_Info.objects.filter(**kwargs)
            page = int(fieldDict['page'])
            line = int(fieldDict['line'])
            count = qs.count()
            res = qs[(page - 1) * line:page * line]
            send_dict = CommonService.qs_to_dict(query_set=res)
            for k, v in enumerate(send_dict["datas"]):
                for val in res:
                    if v['pk'] == val.id:
                        send_dict["datas"][k]['fields']['username'] = \
                            ModelService.get_user_mark(send_dict["datas"][k]['fields']['userID'])
                        send_dict["datas"][k]['fields']['primaryusername'] = \
                            ModelService.get_user_mark(send_dict["datas"][k]['fields']['primaryUserID'])
            send_dict['count'] = count
            return response.json(0, send_dict)
    else:
        qs = Device_Info.objects.all()
        page = int(fieldDict['page'])
        line = int(fieldDict['line'])
        count = qs.count()
        res = qs[(page - 1) * line:page * line]
        send_dict = CommonService.qs_to_dict(query_set=res)
        for k, v in enumerate(send_dict["datas"]):
            for val in res:
                if v['pk'] == val.id:
                    username = ModelService.get_user_name(send_dict["datas"][k]['fields']['userID'])
                    send_dict["datas"][k]['fields']['username'] = username
                    send_dict["datas"][k]['fields']['primaryusername'] = \
                        ModelService.get_user_mark(send_dict["datas"][k]['fields']['primaryUserID'])
        send_dict['count'] = count
        return response.json(0, send_dict)


# 添加设备字段
def addInterface(request):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    UID = request_dict.get('UID', None)
    NickName = request_dict.get('NickName', None)
    View_Account = request_dict.get('View_Account', None)
    View_Password = request_dict.get('View_Password', '')
    Type = request_dict.get('Type', None)
    ChannelIndex = request_dict.get('ChannelIndex', None)
    version = request_dict.get('version', '')
    isCheckMainUser = request_dict.get('isCheckMainUser', None)
    isMainUserExists = False
    if all([UID, NickName, View_Account, Type, ChannelIndex]):
        tko = TokenObject(token)
        response.lang = tko.lang
        if tko.code == 0:
            userID = tko.userID
            re_uid = re.compile(r'^[A-Za-z0-9]{20}$')
            if re_uid.match(UID):
                is_exist = Device_Info.objects.filter(UID=UID, userID_id=userID)
                if is_exist:
                    # 判断设备是否已存在
                    if is_exist[0].isExist == 1:
                        return response.json(174)
                    else:
                        is_exist.delete()
                if UID == '98UXAA8BRPA35VAL111A':
                    asy = threading.Thread(target=ModelService.add_log,
                                           args=(CommonService.get_ip_address(request), userID, 'addV1'))
                    asy.start()
                    return response.json(10, 'illegal uid: {uid}'.format(uid=UID))
                pass

                pk = CommonService.getUserID(getUser=False)
                userName = Device_User.objects.get(userID=userID).username
                main_exist = Device_Info.objects.filter(UID=UID)
                main_exist = main_exist.filter(~Q(vodPrimaryUserID='')).values('vodPrimaryUserID', 'vodPrimaryMaster')

                vodPrimaryUserID = userID
                vodPrimaryMaster = userName
                primaryUserID = ''
                primaryMaster = ''
                isShare = False

                is_bind = Device_Info.objects.filter(UID=UID, isShare=False).values('userID__userID', 'primaryUserID', 'primaryMaster')

                if main_exist.exists():
                    vodPrimaryUserID = main_exist[0]['vodPrimaryUserID']
                    vodPrimaryMaster = main_exist[0]['vodPrimaryMaster']

                if is_bind.exists():
                    primaryUserID = is_bind[0]['primaryUserID']
                    primaryMaster = is_bind[0]['primaryMaster']
                    isShare = True

                isusermain = False
                if (vodPrimaryUserID != userID and vodPrimaryUserID != '') or (primaryUserID != userID and primaryUserID != ''):
                    isusermain = True

                # 判断是否有已绑定用户
                if isCheckMainUser == '1' and isusermain:
                    res = {
                        'id': pk,
                        'userID': userID,
                        'NickName': NickName,
                        'UID': UID,
                        'View_Account': View_Account,
                        'View_Password': View_Password,
                        'ChannelIndex': ChannelIndex,
                        'Type': Type,
                        'isShare': isShare,
                        'primaryUserID': primaryUserID,
                        'primaryMaster': primaryMaster,
                        'vodPrimaryUserID': vodPrimaryUserID,
                        'vodPrimaryMaster': vodPrimaryMaster,
                        'data_joined': '',
                        'version': version,
                        'isVod': 0,
                        'isExist': 1,
                        'userID__userEmail': ''
                    }
                    res['vod'] = [
                        {
                            "status": 1,
                            "channel": ChannelIndex,
                            "endTime": '',
                            "bucket__content": '',
                            "uid": UID
                        }
                    ]
                    res['isMainUserExists'] = 1
                    return response.json(0, res)

                try:
                    # 判断是否有用户绑定
                    nowTime = int(time.time())
                    us_qs = UidSetModel.objects.filter(uid=UID)
                    if not us_qs.exists():
                        uid_set_create_dict = {
                            'uid': UID,
                            'addTime': nowTime,
                            'updTime': nowTime,
                            'ip': CommonService.get_ip_address(request),
                            'channel': ChannelIndex,
                            'nickname': NickName,
                            'version': version,
                        }
                        UidSetModel.objects.create(**uid_set_create_dict)
                    else:
                        us_qs.update(nickname=NickName)

                    userDevice = Device_Info(id=pk, userID_id=userID, UID=UID,
                                             NickName=NickName, View_Account=View_Account,
                                             View_Password=View_Password, Type=Type, ChannelIndex=ChannelIndex,
                                             version=version, vodPrimaryUserID=vodPrimaryUserID, vodPrimaryMaster=vodPrimaryMaster)
                    userDevice.save()
                    uid_serial_qs = UIDCompanySerialModel.objects.filter(
                        uid__uid=UID)
                    if uid_serial_qs.exists():
                        uid_serial = uid_serial_qs[0]
                        Device_Info.objects.filter(UID=UID).update(vodPrimaryUserID=vodPrimaryUserID,
                                                                   vodPrimaryMaster=vodPrimaryMaster,
                                                                   serial_number=uid_serial.company_serial.serial_number + uid_serial.company_serial.company.mark)
                    else:
                        Device_Info.objects.filter(UID=UID).update(vodPrimaryUserID=vodPrimaryUserID,
                                                                   vodPrimaryMaster=vodPrimaryMaster)
                    if not us_qs.exists():
                        us_qs = UidSetModel.objects.filter(uid=UID)

                    if us_qs.exists() and us_qs[0].is_alexa == 1:
                        if us_qs[0].channel > 1:
                            data_list = []
                            uid_channel_set_qs = UidChannelSetModel.objects.filter(uid_id=us_qs[0].id). \
                                values('channel', 'channel_name')
                            if uid_channel_set_qs.exists():
                                # 多通道设备名为 UidChannelSetModel 的 channel_name
                                for uid_channel_set in uid_channel_set_qs:
                                    data_list.append(
                                        {'userID': userID, 'UID': UID, 'uid_nick': uid_channel_set['channel_name'],
                                         'channel': uid_channel_set['channel'], 'password': View_Password})
                        else:
                            data_list = [{'userID': userID, 'UID': UID, 'uid_nick': NickName, 'password': View_Password}]

                        # 请求Alexa服务器更新事件网关
                        data_list = json.dumps(data_list)
                        data = {'data_list': data_list}
                        url = 'https://www.zositech.xyz/deviceStatus/addOrUpdateV2'
                        requests.post(url, data=data, timeout=2)
                except Exception as e:
                    return response.json(10, repr(e))
                else:
                    dvqs = Device_Info.objects.filter(id=pk).values('id', 'userID', 'NickName', 'UID',
                                                                    'View_Account',
                                                                    'View_Password', 'ChannelIndex', 'Type',
                                                                    'isShare',
                                                                    'primaryUserID', 'primaryMaster', 'vodPrimaryUserID', 'vodPrimaryMaster', 'userID__userEmail',
                                                                    'data_joined', 'version',
                                                                    'isVod', 'isExist', 'isCameraOpenCloud', 'serial_number')
                    dvql = CommonService.qs_to_list(dvqs)
                    ubqs = UID_Bucket.objects.filter(uid=UID). \
                        values('bucket__content', 'status', 'channel', 'endTime', 'uid')
                    res = dvql[0]
                    res['vod'] = list(ubqs)


                    # 新增获取IOT证书内容
                    iotqs = iotdeviceInfoModel.objects.filter(serial_number=dvql[0]['serial_number'])
                    if iotqs.exists():
                        res['iot'] = {
                                'endpoint': iotqs[0].endpoint,
                                'token_iot_number': iotqs[0].endpoint
                        }

                    if isMainUserExists:
                        res['isMainUserExists'] = 1
                    return response.json(0, res)


            else:
                return response.json(444, {'param': 'UID'})
        else:
            return response.json(tko.code)
    else:
        return response.json(444, {'param': 'UID,NickName,View_Account,View_Password,Type,ChannelIndex,version'})


# 添加设备字段
def judgeInterface(request):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    uid = request_dict.get('uid', None)
    if all([uid, token]):
        tko = TokenObject(token)
        response.lang = tko.lang
        if tko.code == 0:
            re_uid = re.compile(r'^[A-Za-z0-9]{20}$')
            if re_uid.match(uid):
                is_bind = Device_Info.objects.filter(UID=uid, isShare=False)
                # 判断是否有已绑定用户
                if is_bind:
                    qs = is_bind.values('userID__NickName', 'NickName')
                    nickname = qs[0]['NickName']
                    us_qs = UidSetModel.objects.filter(uid=uid).values('nickname')
                    if us_qs.exists():
                        nickname = us_qs[0]['NickName']
                    res = {
                        'bind_user': qs[0]['userID__NickName'],
                        'bind_device_name': nickname,
                    }
                    return response.json(15, res=res)
                else:
                    return response.json(0, 'no bind user')
            else:
                return response.json(444, {'param': 'UID'})
        else:
            return response.json(tko.code)
    else:
        return response.json(444, {'param': 'UID,NickName,View_Account,View_Password,Type,ChannelIndex'})


# 管理员添加
def admin_addInterface(request):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    deviceContent = request_dict.get('content', None)
    ipdizhi = request_dict.get('ipdizhi', None)
    username = request_dict.get('username', None)
    if not username:
        return response.json(444, 'username')
    if not deviceContent:
        return response.json(444, 'content')
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code != 0:
        return response.json(tko.code)
    userID = tko.userID
    own_perm = ModelService.check_perm(userID, 40)
    # 权限判断
    if own_perm is not True:
        return response.json(404)
    # 查询id
    user = Device_User.objects.filter(Q(username=username) | Q(phone=username) | Q(userEmail=username))

    if user.exists():
        user_dict = CommonService.qs_to_dict(user)
        userID = user_dict.get('datas')[0].get('pk')
    else:
        return response.json(104)
    print(deviceContent)
    try:
        deviceData = json.loads(deviceContent)
        UID = deviceData.get('UID', None)
        if not UID:
            return response.json(444, 'content')
        dValid = Device_Info.objects.filter(userID_id=userID, UID=UID)
        if dValid:
            return response.json(174)
        else:
            UID = deviceData.get('UID', '')
            re_uid = re.compile(r'^[A-Za-z0-9]{20}$')
            # redisObj = RedisObject(db=8)
            # redisObj.del_data(key='uid_qs_' + userID)
            if re_uid.match(UID):
                userDevice = Device_Info(id=CommonService.getUserID(getUser=False), userID_id=userID,
                                         **deviceData)
                userDevice.save()
                file_path = '/'.join((BASE_DIR, 'static/test.log'))

                file = open(file_path, 'a+')
                file.write(ipdizhi + "; username:" + username + "; time:" + time.strftime("%Y-%m-%d %H:%M:%S",
                                                                                          time.localtime()))
                file.write('\n')
                file.flush()
                file.close()

                # is_bind = Device_Info.objects.filter(UID=UID, isShare=False)
                # # 判断是否有已绑定用户
                # if not is_bind.exists():
                #     userDevice = Device_Info(id=CommonService.getUserID(getUser=False), userID_id=userID,
                #                              **deviceData)
                #     userDevice.save()
                # else:
                #     # 分享添加
                #     if 'isShare' in deviceData:
                #         deviceData['isShare'] = True
                #     else:
                #         deviceData['isShare'] = True
                #     bind_userID = is_bind[0].userID_id
                #     userDevice = Device_Info(id=CommonService.getUserID(getUser=False),
                #                              userID_id=userID,
                #                              primaryUserID=bind_userID,
                #                              primaryMaster=ModelService.get_user_name(bind_userID),
                #                              **deviceData)
                #     userDevice.save()
            else:
                return response.json(444, 'UID')

    except Exception as e:
        errorInfo = traceback.format_exc()
        print('添加设备错误: %s ' % errorInfo)
        return response.json(178, repr(e))
    else:
        sqlDict = CommonService.qs_to_dict([userDevice])
        return response.json(0, sqlDict)


# 超级管理员修改设备
def admin_modifyInterface(request):
    response = ResponseObject()
    if request.method == 'POST':
        request.encoding = 'utf-8'
        request_dict = request.POST
    elif request.method == 'GET':
        request.encoding = 'utf-8'
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    deviceContent = request_dict.get('content', None)
    username = request_dict.get('username', None)
    if not username:
        return response.json(444, 'username')
    id = request_dict.get('id', None)
    print(deviceContent)

    if not deviceContent or not id:
        return response.json(444, 'content,id')
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code != 0:
        return response.json(tko.code)
    userID = tko.userID
    if userID is None:
        return response.json(309)
    own_perm = ModelService.check_perm(userID, 50)

    # 权限判断
    if own_perm is not True:
        return response.json(404)

    deviceData = json.loads(deviceContent)
    print(deviceData['UID'])
    # redisObj = RedisObject(db=8)
    # redisObj.del_data(key='uid_qs_' + userID)
    dValid = Device_Info.objects.filter(userID_id=userID, UID=deviceData['UID'])
    if dValid.exists():
        dValid_dict = CommonService.qs_to_dict(dValid)
        print(dValid_dict.get('datas')[0].get('pk'))
        if dValid_dict.get('datas')[0].get('pk') == id:
            print('可以编辑')
        else:
            return response.json(174)
        # 查询id
        user = Device_User.objects.filter(Q(username=username) | Q(phone=username) | Q(userEmail=username))
        if user.exists():
            user_dict = CommonService.qs_to_dict(user)
            userID = user_dict.get('datas')[0].get('pk')
        try:

            # 更改的时间
            update_time = timezone.localtime(timezone.now())
            Device_Info.objects.filter(userID_id=userID, id=id).update(update_time=update_time, **deviceData)
        except Exception as e:
            return response.json(177, repr(e))
        else:
            qs = Device_Info.objects.filter(userID_id=userID, id=id)
            res = CommonService.qs_to_dict(qs)
            return response.json(0, res)
    else:
        # 查询id
        user = Device_User.objects.filter(Q(username=username) | Q(phone=username) | Q(userEmail=username))
        if user.exists():
            user_dict = CommonService.qs_to_dict(user)
            userID = user_dict.get('datas')[0].get('pk')
        try:

            # 更改的时间
            update_time = timezone.localtime(timezone.now())
            Device_Info.objects.filter(userID_id=userID, id=id).update(update_time=update_time, **deviceData)
        except Exception as e:
            return response.json(177, repr(e))
        else:
            qs = Device_Info.objects.filter(userID_id=userID, id=id)
            res = CommonService.qs_to_dict(qs)
            return response.json(0, res)


# 新删除设备
def deleteInterface(request):
    '''
    删除用户设备
    :param request:
    :return:
    '''
    response = ResponseObject()
    request.encoding = 'utf-8'
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    id = request_dict.get('id', None)
    if not id:
        return response.json(444, 'id')
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code != 0:
        return response.json(tko.code)
    userID = tko.userID
    # 主用户删除设备全部删除
    if not userID:
        return response.json(309)
    try:
        dv_qs = Device_Info.objects.filter(userID_id=userID, id=id)
        if not dv_qs.exists():
            return response.json(14)
        uid = dv_qs[0].UID
        if userID == dv_qs[0].vodPrimaryUserID:
            Device_Info.objects.filter(UID=uid).update(vodPrimaryUserID='', vodPrimaryMaster='')

        if dv_qs[0].isShare:
            dv_qs.delete()
        else:
            # a.主用户删除设备
            dv_qs.delete()
            # 删除设备影子信息uid_set   外键关联删除设备推送配置信息 uid_push
            up_qs = UidPushModel.objects.filter(uid_set__uid=uid)
            DetectControllerView().do_delete_redis(uid)
            if up_qs.count() > 1:
                UidPushModel.objects.filter(uid_set__uid=uid, userID_id=userID).delete()
                redisObj = RedisObject(db=6, SERVER_HOST=PUSH_REDIS_ADDRESS)
                ykey = '{uid}_redis_qs'.format(uid=uid)
                if ykey:
                    redisObj.del_data(key=ykey)
            else:
                up_qs.delete()
            # b.删除次用户设备
            Device_Info.objects.filter(UID=uid, isShare=True, primaryUserID=userID).delete()
            # 异步删除推送消息
        asy = threading.Thread(target=ModelService.del_eq_info, args=(userID, uid))
        asy.start()

        # 记录操作日志
        now_time = int(time.time())
        ip = CommonService.get_ip_address(request)
        content = json.loads(json.dumps(request_dict))
        log = {
            'ip': ip,
            'user_id': 1,
            'status': 200,
            'time': now_time,
            'content': json.dumps(content),
            'url': 'equipment/delete',
            'operation': '{}删除设备,uid:{}'.format(userID, uid),
        }
        LogModel.objects.create(**log)

    except Exception as e:
        errorInfo = traceback.format_exc()
        print('删除数据库记录错误: %s' % errorInfo)
        return response.json(176, repr(e))
    else:
        return response.json(0)

# 批量删除设备
def batchDeleteInterface(request):
    '''
    批量删除用户设备
    :param request: token,ids
    :return:
    '''
    response = ResponseObject()
    request.encoding = 'utf-8'
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    ids = request_dict.get('ids', None)
    if not ids:
        return response.json(444, 'ids')
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code != 0:
        return response.json(tko.code)
    userID = tko.userID
    # userID = request_dict.get('userID', None)   # 调试
    # 主用户删除设备全部删除
    if not userID:
        return response.json(309)
    try:
        deviceInfo_qs = Device_Info.objects.filter(userID_id=userID, id__in=ids.split(','))
        if not deviceInfo_qs.exists():
            return response.json(14)
        uid_list = []
        for deviceInfo in deviceInfo_qs:
            uid = deviceInfo.UID
            uid_list.append(uid)
            if userID == deviceInfo.vodPrimaryUserID:
                Device_Info.objects.filter(UID=uid).update(vodPrimaryUserID='', vodPrimaryMaster='')

            deviceInfo.delete()
            if not deviceInfo.isShare:
                # a.主用户删除设备
                # 删除设备影子信息uid_set   外键关联删除设备推送配置信息 uid_push
                up_qs = UidPushModel.objects.filter(uid_set__uid=uid)
                DetectControllerView().do_delete_redis(uid)
                if up_qs.count() > 1:
                    UidPushModel.objects.filter(uid_set__uid=uid, userID_id=userID).delete()
                    redisObj = RedisObject(db=6, SERVER_HOST=PUSH_REDIS_ADDRESS)
                    ykey = '{uid}_redis_qs'.format(uid=uid)
                    if ykey:
                        redisObj.del_data(key=ykey)
                else:
                    up_qs.delete()
                # b.删除次用户设备
                Device_Info.objects.filter(UID=uid, isShare=True, primaryUserID=userID).delete()
                # 异步删除推送消息
            asy = threading.Thread(target=ModelService.del_eq_info, args=(userID, uid))
            asy.start()

        # 记录操作日志
        now_time = int(time.time())
        ip = CommonService.get_ip_address(request)
        content = json.loads(json.dumps(request_dict))
        log = {
            'ip': ip,
            'user_id': 1,
            'status': 200,
            'time': now_time,
            'content': json.dumps(content),
            'url': 'equipment/batchDelete',
            'operation': '{}批量删除设备,uid:{}'.format(userID, uid_list),
        }
        LogModel.objects.create(**log)
    except Exception as e:
        errorInfo = traceback.format_exc()
        print('删除数据库记录错误: %s' % errorInfo)
        return response.json(176, repr(e))
    else:
        return response.json(0)

# 新查询设备字段
def queryInterface(request):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    page = request_dict.get('page', None)
    line = request_dict.get('line', None)
    NickName = request_dict.get('NickName', None)
    uid = request_dict.get('uid', None)
    page = int(page)
    line = int(line)
    tko = TokenObject(token)
    response.lang = tko.lang
    if page <= 0:
        return response.json(0)
    if tko.code == 0:
        userID = tko.userID
        dvqs = Device_Info.objects.filter(userID_id=userID)
        # # 已重置的设备
        # dvqs = dvqs.filter(~Q(isExist=2))
        if NickName:
            dvqs = dvqs.filter(NickName__icontains=NickName)
        if uid:
            dvqs = dvqs.filter(UID=uid)
        # count = dvqs.count()
        dvql = dvqs[(page - 1) * line:page * line].values('id', 'userID', 'NickName', 'UID', 'View_Account',
                                                          'View_Password', 'ChannelIndex', 'Type', 'isShare',
                                                          'primaryUserID', 'primaryMaster', 'data_joined', 'version', 'vodPrimaryUserID', 'vodPrimaryMaster', 'userID__userEmail',
                                                          'isVod', 'isExist', 'NotificationMode', 'isCameraOpenCloud', 'serial_number')
        dvls = CommonService.qs_to_list(dvql)
        uid_list = []
        serial_number_list = []
        for dvl in dvls:
            if dvl['primaryUserID'] and dvl['id'] == dvl['primaryUserID']:
                dvl['isPrimaryUser'] = 1
            else:
                dvl['isPrimaryUser'] = 0
            uid_list.append(dvl['UID'])
            serial_number_list.append(dvl['serial_number'][0:6])


        #新增获取IOT证书内容
        iotqs = iotdeviceInfoModel.objects.filter(serial_number__in=serial_number_list)

        ubqs = UID_Bucket.objects.filter(uid__in=uid_list). \
            values('bucket__content', 'status', 'channel', 'endTime', 'uid')
        upqs = UID_Preview.objects.filter(uid__in=uid_list).order_by('channel').values('id', 'uid', 'channel')
        auth = oss2.Auth(OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET)
        bucket = oss2.Bucket(auth, 'oss-cn-hongkong.aliyuncs.com', 'statres')
        nowTime = int(time.time())
        data = []
        # 设备拓展信息表
        us_qs = UidSetModel.objects.filter(uid__in=uid_list).\
            values('uid', 'version', 'nickname', 'detect_interval', 'is_ptz')
        uv_dict = {}
        for us in us_qs:
            uv_dict[us['uid']] = {'version': us['version'],
                                  'nickname': us['nickname'],
                                  'is_ptz': us['is_ptz'],
                                  'detect_interval': us['detect_interval']}

        for p in dvls:
            #新增IOT
            p['iot'] = []
            for iot in iotqs:
                if p['serial_number'][0:6] == iot.serial_number:
                        p['iot'].append(
                            {
                                'endpoint':iot.endpoint,
                                'token_iot_number':iot.token_iot_number

                            }
                        )

            p['vod'] = []
            for dm in ubqs:
                if p['UID'] == dm['uid']:
                    if dm['endTime'] > nowTime:
                        p['vod'].append(dm)
            p['preview'] = []
            for up in upqs:
                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']
            if p_uid in uv_dict:
                # 设备版本号
                p['uid_version'] = uv_dict[p_uid]['version']
                p['detect_interval'] = uv_dict[p_uid]['detect_interval']
                # 设备昵称 调用影子信息昵称，先阶段不可
                if uv_dict[p_uid]['nickname']:
                    p['NickName'] = uv_dict[p_uid]['nickname']
            else:
                # 设备版本号
                p['uid_version'] = ''
            data.append(p)
        return response.json(0, data)
    else:
        return response.json(tko.code)


def uid_status(request):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    uid = request_dict.get('uid', None)
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code != 0:
        return response.json(tko.code)
    userID = tko.userID

    # 调试
    logger = logging.getLogger('django')
    debugOne = int(time.time())

    # 判断用户是否绑定设备
    qs = UidSetModel.objects.filter(uid=uid).values('uid', 'detect_status', 'detect_interval', 'version', 'ucode',
                                                    'p2p_region', 'tz', 'video_code', 'channel', 'cloud_vod', 'id',
                                                    'detect_group', 'is_alexa', 'region_alexa','is_ptz')

    # 调试
    debugOnes = int(time.time())
    logger.error('————————debugOne_sec：', debugOnes - debugOne)

    # 判断uid配置表信息是否存在
    if qs.exists():
        # 获取uid推送是否添加过
        us_id = qs[0]['id']

        # 调试
        debugTwo = int(time.time())

        if UidPushModel.objects.filter(uid_set_id=us_id, userID_id=userID).exists():
            detect_status = qs[0]['detect_status']
        else:
            detect_status = 0
        data = {
            'push_status': detect_status,  # 推送状态
            'push_interval': qs[0]['detect_interval'],  # 推送间隔
            'ucode': qs[0]['ucode'],
            'version': qs[0]['version'],
            'p2p_region': qs[0]['p2p_region'],
            'tz': qs[0]['tz'],
            'video_code': qs[0]['video_code'],
            'channel': qs[0]['channel'],
            'cloud_vod': qs[0]['cloud_vod'],
            'detect_group': qs[0]['detect_group'],  # 推送组
            'is_alexa': qs[0]['is_alexa'],  # 推送组
            'region_alexa': qs[0]['region_alexa'],  # 推送组
            'is_ptz': qs[0]['is_ptz']
        }

        # 调试
        debugTwos = int(time.time())
        logger.error('————————debugTwo_sec：', debugTwos - debugTwo)

        # 调试
        debugThere = int(time.time())

        # 查询云存储相关信息
        ubqs = UID_Bucket.objects.filter(uid=uid). \
            values('bucket__content', 'status', 'channel', 'endTime', 'uid')

        # 调试
        debugTheres = int(time.time())
        logger.error('————————debugTheres_sec：', debugTheres - debugThere)

        nowTime = int(time.time())
        if ubqs.exists():
            if ubqs[0]['endTime'] > nowTime:
                data['vod'] = list(ubqs)
        return response.json(0, data)
    else:
        return response.json(0)

def uid_status_test(request):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    uid = request_dict.get('uid', None)
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code != 0:
        return response.json(tko.code)
    userID = tko.userID
    # 判断用户是否绑定设备
    print(100000000000)
    qs = UidSetModel.objects.filter(uid=uid).values('uid', 'detect_status', 'detect_interval', 'version', 'ucode',
                                                    'p2p_region', 'tz', 'video_code', 'channel', 'cloud_vod', 'id',
                                                    'detect_group', 'is_alexa', 'region_alexa')
    # 判断uid配置表信息是否存在
    if qs.exists():
        # 获取uid推送是否添加过
        print(1111111111111)
        us_id = qs[0]['id']
        if UidPushModel.objects.filter(uid_set_id=us_id, userID_id=userID).exists():
            detect_status = qs[0]['detect_status']
        else:
            detect_status = 0
        data = {
            'push_status': detect_status,  # 推送状态
            'push_interval': qs[0]['detect_interval'],  # 推送间隔
            'ucode': qs[0]['ucode'],
            'version': qs[0]['version'],
            'p2p_region': qs[0]['p2p_region'],
            'tz': qs[0]['tz'],
            'video_code': qs[0]['video_code'],
            'channel': qs[0]['channel'],
            'cloud_vod': qs[0]['cloud_vod'],
            'detect_group': qs[0]['detect_group'],  # 推送组
            'is_alexa': qs[0]['is_alexa'],  # 推送组
            'region_alexa': qs[0]['region_alexa'],  # 推送组
        }
        print(22222222222)
        # 查询云存储相关信息
        ubqs = UID_Bucket.objects.filter(uid=uid). \
            values('bucket__content', 'status', 'channel', 'endTime', 'uid')
        nowTime = int(time.time())
        if ubqs.exists():
            if ubqs[0]['endTime'] > nowTime:
                data['vod'] = list(ubqs)
        print(3333333333333)
        return response.json(0, data)
    else:
        return response.json(0)



def update_uid_set(request):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    token = request_dict.get('token', None)
    uid = request_dict.get('uid', None)
    version = request_dict.get('version', '')
    ucode = request_dict.get('ucode', '')
    tko = TokenObject(token)
    response.lang = tko.lang
    if tko.code == 0:
        userID = tko.userID
        nowTime = int(time.time())
        dvqs = Device_Info.objects.filter(userID_id=userID)
        # redisObj = RedisObject(db=8)
        # redisObj.del_data(key='uid_qs_' + userID)
        if dvqs.exists():
            us_qs = UidSetModel.objects.filter(uid=uid)
            if us_qs.exists():
                uid_set_update_dict = {
                    'updTime': nowTime,
                    'version': version,
                    'ucode': ucode,
                }
                us_qs.update(**uid_set_update_dict)
            else:
                uid_set_create_dict = {
                    'uid': uid,
                    'addTime': nowTime,
                    'updTime': nowTime,
                    'version': version,
                    'ucode': ucode,
                }
                UidSetModel.objects.create(**uid_set_create_dict)
            return response.json(0)
        else:
            return response.json(14)
    else:
        return response.json(tko.code)


# 测试环境
# test.shadow.dvema.com
# 生产环境
# shadow.dvema.com
# http://test.dvema.com/deviceShadow/update?etk=JVJWbFpFU0VOV1FsbEVTMFpOU2xKWFFURXhNVUU9Xz0=&ucode=1234&version=1324&p2p_region=CN
# 设备影子更新
def update_device_shadow(request):
    request.encoding = 'utf-8'
    response = ResponseObject()
    if request.method == 'POST':
        request_dict = request.POST
    elif request.method == 'GET':
        request_dict = request.GET
    else:
        return response.json(444)
    etk = request_dict.get('etk', None)
    eto = ETkObject(etk)
    uid = eto.uid
    if uid:
        # 重置按钮
        is_reset = request_dict.get('is_reset', None)
        # 传1则重置设备信息
        if is_reset == '1':

            UidSetModel.objects.filter(uid=uid).delete()
            # 重置设备，判断设备为已删除
            nowTime = int(time.time())
            uid_bucket = UID_Bucket.objects.filter(uid=uid, endTime__gte=nowTime).values('id', 'has_unused').order_by('addTime')
            if not uid_bucket.exists():
                di_qs = Device_Info.objects.filter(UID=uid)
                di_qs.update(isExist=2)

            # 清除redis缓存
            # data = di_qs.values()
            # redisObj = RedisObject(db=8)
            # for di in data:
            #     key = 'uid_qs_' + di['userID_id']
            #     redis_value = redisObj.get_data(key=key)
            #     if redis_value is not False:
            #         redisObj.del_data(key)

        ucode = request_dict.get('ucode', None)
        version = request_dict.get('version', None)
        p2p_region = request_dict.get('p2p_region', None)
        tz = request_dict.get('tz', None)
        video_code = request_dict.get('video_code', None)
        ip = CommonService.get_ip_address(request)
        channel = request_dict.get('channel', None)
        cloud_vod = request_dict.get('cloud_vod', None)
        push_status = request_dict.get('push_status', None)
        pwd = request_dict.get('pwd', None)
        resetTime = request_dict.get('resetTime', None)
        is_ptz = request_dict.get('is_ptz', None)
        is_alexa = request_dict.get('is_alexa', None)
        is_ai = request_dict.get('is_ai', None)

        us_qs = UidSetModel.objects.filter(uid=uid)
        # 更新
        nowTime = int(time.time())

        print('-------')
        print(resetTime)
        print('-------')
        qs_dict = {
            'updTime': nowTime,
            'ip': ip
        }
        if channel:
            qs_dict['channel'] = channel
        if p2p_region:
            qs_dict['p2p_region'] = p2p_region
        if ucode:
            qs_dict['ucode'] = ucode
        if version:
            qs_dict['version'] = version
        if tz:
            qs_dict['tz'] = tz
        if video_code:
            qs_dict['video_code'] = video_code
        if cloud_vod:
            qs_dict['cloud_vod'] = cloud_vod
        if push_status:
            qs_dict['detect_status'] = push_status
        if pwd:
            qs_dict['pwd'] = pwd
        if is_ptz:
            qs_dict['is_ptz'] = is_ptz
        if is_alexa:
            qs_dict['is_alexa'] = is_alexa
        if is_ai:
            qs_dict['is_ai'] = is_ai
        if us_qs.exists():
            us_qs.update(**qs_dict)
            # 如果推送状态开启，返回推送url
            return JsonResponse(status=200, data={'code': 0, 'msg': 'success', 'data': {}})
        # 新增
        else:
            qs_dict['uid'] = uid
            qs_dict['addTime'] = nowTime
            UidSetModel.objects.create(**qs_dict)
            # 如果推送状态开启，返回推送url
            return JsonResponse(status=200, data={'code': 0, 'msg': 'success', 'data': {}})
    else:
        return JsonResponse(status=200, data={'code': 403, 'msg': 'error etk'})