ASJServer/AdminController/UserManageController.py

import datetime
import time
import oss2
from django.contrib.auth.hashers import make_password, check_password  # 对密码加密模块
from django.db import transaction
from django.db.models import Q
from django.utils.decorators import method_decorator
from django.utils.timezone import utc
from django.views.decorators.csrf import csrf_exempt
from django.views.generic import TemplateView

from Ansjer.config import SERVER_DOMAIN, OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET, AWS_ACCESS_KEY_ID, \
    AWS_SECRET_ACCESS_KEY, AWS_SES_ACCESS_REGION
from Controller.CheckUserData import DataValid, RandomStr
from Model.models import Device_User, Role, UserExModel, CountryModel, MenuModel, FeedBackModel, StatResModel, \
    SysMassModel, App_Info, SysMsgModel, DeviceSuperPassword, CustomizedPush, DeviceTypeModel
from Object.AWS.AmazonS3Util import AmazonS3Util
from Object.RedisObject import RedisObject
from Object.ResponseObject import ResponseObject
from Object.TokenObject import TokenObject
from Service.CommonService import CommonService
from Service.ModelService import ModelService
from django.views.generic import View


# 登录
class LoginView(TemplateView):
    @method_decorator(csrf_exempt)  # @csrf_exempt
    def dispatch(self, *args, **kwargs):
        return super(LoginView, self).dispatch(*args, **kwargs)

    def post(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        request_dict = request.POST
        language = request_dict.get('language', 'en')
        response = ResponseObject(language, 'pc')

        return self.validates(request_dict, response)

    def validates(self, request_dict, response):
        username = request_dict.get('username', None)
        password = request_dict.get('password', None)
        password_version = request_dict.get('pwdVersion', 'V1')
        if not username or not password:
            return response.json(111)
        username = username.strip()
        password = password.strip()
        data_valid = DataValid()
        if data_valid.email_validate(username):
            return self.do_email_login(username, password, response, password_version)
        elif data_valid.mobile_validate(username):
            return self.do_phone_login(username, password, response, password_version)
        elif data_valid.name_validate(username):
            return self.do_name_login(username, password, response, password_version)
        else:
            return response.json(107)

    def do_email_login(self, email, password, response, password_version):
        user_qs = Device_User.objects.filter(Q(username=email) | Q(userEmail=email))
        return self.valid_login(user_qs, password, response, password_version)

    def do_phone_login(self, phone, password, response, password_version):
        user_qs = Device_User.objects.filter(Q(phone=phone) | Q(username=phone), is_active=True, user_isValid=True)
        return self.valid_login(user_qs, password, response, password_version)

    def do_name_login(self, username, password, response, password_version):
        user_qs = Device_User.objects.filter(Q(username=username) | Q(phone=username) | Q(userEmail=username),
                                             is_active=True, user_isValid=True)
        return self.valid_login(user_qs, password, response, password_version)

    def valid_login(self, user_qs, password, response, password_version):
        if not user_qs.exists():
            return response.json(104)
        # users = user_qs.values('role__rid', 'role__roleName', 'userID', 'role', 'NickName', 'username', 'userEmail',
        #                        'phone', 'password', 'userIconPath', 'user_isValid', 'is_active')[0]
        users = user_qs.values('role__rid', 'role__roleName', 'userID', 'NickName', 'username', 'userEmail',
                               'phone', 'password', 'userIconPath')[0]
        if password_version == 'V1':
            check_flag = check_password(password, users['password'])
        else:
            check_flag = CommonService.check_password(password, users['password'])
        if not check_flag:
            return response.json(111)
        userID = users['userID']
        tko = TokenObject(returntpye='pc')
        res = tko.generate(
            data={'userID': userID, 'lang': response.lang, 'user': users['username'], 'm_code': '123413243214'})
        if tko.code == 0:
            now_time = datetime.datetime.utcnow().replace(tzinfo=utc).astimezone(utc)
            user_qs.update(last_login=now_time, language=response.lang)
            res['rid'] = users['role__rid']
            res['roleName'] = users['role__roleName']
            res['permList'] = ModelService.own_permission(userID)
            res['userID'] = userID
            # 昵称，邮箱，电话，刷新，头像
            userIconPath = str(users['userIconPath'])
            if userIconPath and userIconPath.find('static/') != -1:
                userIconPath = userIconPath.replace('static/', '').replace('\\', '/')
                res['userIconUrl'] = SERVER_DOMAIN + 'account/getAvatar/' + userIconPath
            else:
                res['userIconUrl'] = ''
            res['NickName'] = users['NickName'] if users['NickName'] is not None else ''
            res['username'] = users['username'] if users['username'] is not None else ''
            res['userEmail'] = users['userEmail'] if users['userEmail'] is not None else ''
            res['phone'] = users['phone'] if users['phone'] is not None else ''
            return response.json(0, res)
        else:
            return response.json(tko.code)


# 获取登录权限
class GetPermissions(TemplateView):
    @method_decorator(csrf_exempt)  # @csrf_exempt
    def dispatch(self, *args, **kwargs):
        return super(GetPermissions, self).dispatch(*args, **kwargs)

    def get(self, request, *args, **kwargs):
        token = request.META.get('HTTP_AUTHORIZATION')
        request.encoding = 'utf-8'
        request_dict = request.GET
        language = request_dict.get('language', 'en')
        response = ResponseObject(language, 'pc')
        return self.validates(request_dict, token, response)

    def validates(self, request_dict, token, response):
        tko = TokenObject(token, returntpye='pc')
        response.lang = tko.lang
        if tko.code != 0:
            return response.json(tko.code)
        userID = tko.userID

        user_qs = Device_User.objects.filter(userID=userID)
        if not user_qs.exists():
            return response.json(104)
        # 待补充逻辑
        username = user_qs[0].username
        userIconPath = user_qs[0].userIconPath.url
        if userIconPath:
            if userIconPath.find('static/') != -1:
                userIconPath = userIconPath.replace('static/', '').replace('\\', '/')
                userIconUrl = SERVER_DOMAIN + 'account/getAvatar/' + userIconPath

        role_qs = Role.objects.filter(device_user=userID)
        menu_qs = MenuModel.objects.filter(role__in=role_qs, menutype=2);
        perms = []
        for menu in menu_qs:
            perms.append(menu.menu_code)
        res = {
            "code": 200,
            "msg": "success",
            "data": {
                "roles": ["admin"],  # 一个用户可包含多个角色如["admin","editor","XXXX"]，必须返回，如小项目用不到角色权限请返回 ["admin"]
                "ability": ["READ", "WRITE", "DELETE"],  # 如果用不到rabc精细化权限可以不返回，建议返回
                "username": username,  # 用户名，必须返回
                "avatar": userIconUrl,  # 头像，必须返回
                "perms": perms
            }
        }
        return response.json(0, res)


# 获取菜单
class GetList(TemplateView):
    @method_decorator(csrf_exempt)  # @csrf_exempt
    def dispatch(self, *args, **kwargs):
        return super(GetList, self).dispatch(*args, **kwargs)

    def get(self, request, *args, **kwargs):
        token = request.META.get('HTTP_AUTHORIZATION')
        request.encoding = 'utf-8'
        request_dict = request.GET
        language = request_dict.get('language', 'en')
        response = ResponseObject(language, 'pc')
        return self.validates(request_dict, token, response)

    def validates(self, request_dict, token, response):
        tko = TokenObject(token, returntpye='pc')
        response.lang = tko.lang
        if tko.code != 0:
            return response.json(tko.code)
        userID = tko.userID

        role_qs = Role.objects.filter(device_user=userID)
        menu_qs = MenuModel.objects.filter(parentId=0, role__in=role_qs, menutype=1);
        list = []

        for menu in menu_qs:
            list.append(
                {
                    'id': menu.id,
                    'parentId': menu.parentId,
                    'path': menu.path,
                    'name': menu.name,
                    'component': menu.component,
                    'meta': {
                        'hidden': menu.hidden,
                        'levelHidden': menu.levelHidden,
                        'title': menu.title,
                        'icon': menu.icon,
                        'isCustomSvg': menu.isCustomSvg,
                        'noKeepAlive': menu.noKeepAlive,
                        'noClosable': menu.noClosable,
                        'badge': menu.badge,
                        'tabHidden': menu.tabHidden,
                        'activeMenu': menu.activeMenu,
                        'dot': menu.dot,
                        'dynamicNewTab': menu.dynamicNewTab,
                        'sort': menu.sort
                    }
                }
            )
        menu_qs = MenuModel.objects.filter(role__in=role_qs, menutype=1)
        menulist = []
        for objlist in list:
            menulist.append(self.menulist(menu_qs, objlist))
        return response.json(0, {'list': menulist})

    def menulist(self, menu_qs, objlist):
        if objlist is None:
            return
        for menu in menu_qs:
            if objlist['id'] == menu.parentId:
                if 'children' not in objlist:
                    objlist['children'] = []

                obj = {
                    'id': menu.id,
                    'parentId': menu.parentId,
                    'path': menu.path,
                    'name': menu.name,
                    'component': menu.component,
                    'menutype': menu.menutype,
                    'menu_code': menu.menu_code,
                    'meta': {
                        'hidden': menu.hidden,
                        'levelHidden': menu.levelHidden,
                        'title': menu.title,
                        'icon': menu.icon,
                        'isCustomSvg': menu.isCustomSvg,
                        'noKeepAlive': menu.noKeepAlive,
                        'noClosable': menu.noClosable,
                        'badge': menu.badge,
                        'tabHidden': menu.tabHidden,
                        'activeMenu': menu.activeMenu,
                        'dot': menu.dot,
                        'dynamicNewTab': menu.dynamicNewTab,
                        'sort': menu.sort
                    }
                }
                objlist['children'].append(
                    obj
                )
                self.menulist(menu_qs, obj)

        return objlist


class UserManagement(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):
        language = request_dict.get('language', 'en')
        response = ResponseObject(language, 'pc')
        if operation == 'sendSysMessage':
            return self.sendSysMessage(request_dict, response)
        elif operation == 'getAppDataList':
            return self.getAppDataList(request_dict, response)
        elif operation == 'replyFeedBack':
            return self.replyFeedBack(request_dict, response)
        elif operation == 'sendSysMsgToUser':
            return self.sendSysMsgToUser(request_dict, response)
        elif operation == 'getCountryList':  # 查询国家列表
            return self.getCountryList(response)
        elif operation == 'getDeviceTypeList':  # 查询设备型号列表
            return self.getDeviceTypeList(response)
        else:
            tko = TokenObject(request.META.get('HTTP_AUTHORIZATION'), returntpye='pc')
            if tko.code != 0:
                return response.json(tko.code)
            response.lang = tko.lang
            userID = tko.userID
            if operation == 'getUserInfo':
                return self.getUserInfo(userID, request_dict, response)
            elif operation == 'AddOrEditAccount':
                return self.AddOrEditAccount(userID, request_dict, response)
            elif operation == 'doDelete':
                return self.doDelete(request_dict, response)
            elif operation == 'resetPassword':
                return self.resetPassword(request_dict, response)
            elif operation == 'getFeedbackList':
                return self.getFeedbackList(request_dict, response)
            elif operation == 'deleteFeedBack':
                return self.deleteFeedBack(request_dict, response)
            elif operation == 'getSysMessageList':
                return self.getSysMessageList(request_dict, response)
            elif operation == 'collectFeedBack':
                return self.collectFeedBack(request_dict, response)
            elif operation == 'exportFeedBack':
                return self.exportFeedBack(request_dict, response)
            elif operation == 'customerServiceManagement':  # 审核用户请求/生成超级密码
                return self.customerServiceManagement(request_dict, response)
            elif operation == 'getDeviceSuperPassword':  # 查询超级密码请求表
                return self.getDeviceSuperPassword(request_dict, response)
            elif operation == 'deleteInformation':  # 删除超级密码请求表
                return self.deleteInformation(request_dict, response)
            # 定制推送
            elif operation == 'getCustomizedPushList':  # 查询定制推送列表
                return self.getCustomizedPushList(request_dict, response)
            elif operation == 'addOrEditCustomizedPush':  # 新增/编辑推送内容
                return self.addOrEditCustomizedPush(request, request_dict, response)
            else:
                return response.json(414)

    def getUserInfo(self, userID, request_dict, response):
        """
        @param userID:用户ID
        @param request_dict:请求参数
        @param response:响应对象
        @param username:用户名
        @param NickName:用户昵称
        @param phone:电话号
        @param userEmail:用户邮箱
        @return:
        """
        print('request_dict: ', request_dict)
        username = request_dict.get('username', '').strip()  # 移除字符串头尾的空格
        NickName = request_dict.get('NickName', '').strip()
        phone = request_dict.get('phone', '').strip()
        userEmail = request_dict.get('userEmail', '').strip()
        countryName = request_dict.get('countryName', '').strip()
        pageNo = request_dict.get('pageNo', None)
        pageSize = request_dict.get('pageSize', None)

        if not all([pageNo, pageSize]):
            return response.json(444)

        page = int(pageNo)
        line = int(pageSize)

        try:
            device_user_qs = Device_User.objects.all()
            # 条件查询
            if username:
                device_user_qs = device_user_qs.filter(username__icontains=username)
            if NickName:
                device_user_qs = device_user_qs.filter(NickName__icontains=NickName)
            if phone:
                device_user_qs = device_user_qs.filter(phone__icontains=phone)
            if userEmail:
                device_user_qs = device_user_qs.filter(userEmail__icontains=userEmail)
            if countryName:
                country_qs = CountryModel.objects.filter(country_name=countryName).values('id')
                if not country_qs:
                    return response.json(10, '国家不存在')
                device_user_qs = device_user_qs.filter(region_country=country_qs[0]['id'])
            if not device_user_qs.exists():
                return response.json(0)
            total = device_user_qs.count()
            device_users = device_user_qs[(page - 1) * line:page * line]

            user_list = []
            for device_user in device_users:
                role = device_user.role.first()
                rid = role.rid if role else 1  # 不存在角色默认分配为'Users'
                user_ex_qs = UserExModel.objects.filter(userID_id=device_user.userID).values('appBundleId')
                app_bundle_id = user_ex_qs[0]['appBundleId'] if user_ex_qs.exists() else ''
                country_qs = CountryModel.objects.filter(id=device_user.region_country).values('country_name')
                countryName = country_qs[0]['country_name'] if country_qs.exists() else '未知国家'
                user_list.append({
                    'userID': device_user.userID,
                    'username': device_user.username,
                    'NickName': device_user.NickName,
                    'role': Role.objects.get(rid=rid).roleName,
                    'phone': device_user.phone,
                    'userEmail': device_user.userEmail,
                    'data_joined': device_user.data_joined.strftime("%Y-%m-%d %H:%M:%S"),
                    'last_login': device_user.last_login.strftime("%Y-%m-%d %H:%M:%S"),
                    'appBundleId': app_bundle_id,
                    'countryName': countryName
                })
            print('user_list: ', user_list)
            return response.json(0, {'list': user_list, 'total': total})
        except Exception as e:
            print(e)
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def AddOrEditAccount(self, userID, request_dict, response):
        """
        添加/编辑用户
        @param userID:用户ID
        @param request_dict:请求参数
        @param response:响应对象
        @param roleName:用户角色
        @param isEdit:添加用户需要输入密码
        @return:
        """
        print('request_dict: ', request_dict)
        username = request_dict.get('username', '').strip()  # 移除字符串头尾的空格
        userEmail = request_dict.get('userEmail', '').strip()
        roleName = request_dict.get('role', None)
        password = request_dict.get('password', None)
        isEdit = request_dict.get('isEdit', None)
        password_version = request_dict.get('pwdVersion', 'V1')

        # 校验用户名,邮箱,密码是否符合规则
        dataValid = DataValid()
        if not username or not dataValid.name_validate(username):
            return response.json(444, {'Parameter error': 'username'})
        if userEmail and not dataValid.email_validate(userEmail):
            return response.json(444, {'Parameter error': 'userEmail'})
        if not isEdit:  # 添加用户需要输入密码
            if not password or not dataValid.password_validate(password):
                return response.json(444, {'Parameter error': 'password'})
        if password_version == 'V1':
            password = make_password(password)
        try:
            if isEdit:  # 编辑用户信息
                userID = request_dict.get('userID')
                user_data = {
                    "username": username,
                    "NickName": username,
                    "userEmail": userEmail,
                    "password": password,
                }
                device_user_qs = Device_User.objects.filter(userID=userID)
                device_user_qs.update(**user_data)

                # 如果角色改变,修改用户角色
                device_user_role = device_user_qs[0].role
                user_role = device_user_role.first()
                if not user_role or roleName != user_role.roleName:
                    device_user_role.clear()
                    role_qs = Role.objects.filter(roleName=roleName)  # 账号角色
                    device_user_qs[0].role.set(role_qs)
            else:  # 添加用户
                # 查询邮箱是否已注册
                if Device_User.objects.filter(userEmail=userEmail).exists():
                    return response.json(103)
                role_qs = Role.objects.filter(roleName=roleName)  # 账号角色
                # 创建用户
                user_data = {
                    "username": username,
                    "NickName": username,
                    "userEmail": userEmail,
                    "password": password,
                    "userID": CommonService.getUserID(μs=False, setOTAID=True),
                    "is_active": True,
                    "user_isValid": True,
                }
                Device_User.objects.create(**user_data).role.set(role_qs)
            return response.json(0)
        except Exception as e:
            print(e)
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def doDelete(self, request_dict, response):
        userID = request_dict.get('userID', '')
        if not userID:
            return response.json(444)
        try:
            Device_User.objects.filter(userID=userID).delete()
            return response.json(0)
        except Exception as e:
            print(e)
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def resetPassword(self, request_dict, response):
        userID = request_dict.get('userID', None)
        if not userID:
            return response.json(444)
        try:
            password = '123456'
            is_update = Device_User.objects.filter(userID=userID).update(password=make_password(password))
            if is_update:
                return response.json(0)
            else:
                return response.json(177)
        except Exception as e:
            print(e)
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def getFeedbackList(self, request_dict, response):
        """
        用户反馈查询
        @param request_dict:请求参数
        @param response:响应对象
        @param status:回复状态
        @param collectStatus:收藏状态1
        @return:
        """
        status = request_dict.get('status', 0)
        username = request_dict.get('username', None)
        collectStatus = request_dict.get('collectStatus', None)
        pageNo = request_dict.get('pageNo', None)
        pageSize = request_dict.get('pageSize', None)
        if not all([pageNo, pageSize]):
            return response.json(444)
        page = int(pageNo)
        line = int(pageSize)
        try:
            filter_data = {}
            if status or username or collectStatus:
                if status:
                    filter_data['status'] = int(status)
                if username:
                    filter_data['userID_id'] = ModelService.get_userID_byname(username)
                if collectStatus:
                    filter_data['collect_status'] = int(collectStatus)
            feed_back_qs = FeedBackModel.objects.filter()
            if filter_data:
                feed_back_qs = feed_back_qs.filter(**filter_data).values()
            total = feed_back_qs.count()
            feed_backs = feed_back_qs.values(
                'id',
                'userID__username',
                'userID__phone',
                'userID__userEmail',
                'content',
                'addTime',
                'status',
                'type',
                'app',
                'app_version',
                'phone_model',
                'os_version',
                'uid',
                'appBundleId',
                'score',
                'collect_status'
            )
            feed_backs = feed_backs[(page - 1) * line: page * line]
            feed_back_id_list = [feed_back['id'] for feed_back in feed_backs]
            stat_res_qs = StatResModel.objects.filter(
                feedbackmodel__id__in=feed_back_id_list).values(
                'name', 'feedbackmodel__id')
            auth = oss2.Auth(OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET)
            bucket = oss2.Bucket(
                auth, 'oss-cn-hongkong.aliyuncs.com', 'statres')
            feed_back_list = []
            for feed_back in feed_backs:
                feed_back['img_url'] = []
                for stat_res in stat_res_qs:
                    if stat_res['feedbackmodel__id'] == feed_back['id']:
                        obj = 'feedback/' + stat_res['name']
                        img_url = bucket.sign_url('GET', obj, 3600)
                        feed_back['img_url'].append(img_url)
                        if not feed_back['userID__username']:
                            feed_back['userID__username'] = feed_back['userID__userEmail'] if feed_back[
                                'userID__userEmail'] else feed_back['userID__phone']
                feed_back_list.append(feed_back)
            return response.json(0, {'list': feed_back_list, 'total': total})
        except Exception as e:
            print(e)
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def replyFeedBack(self, request_dict, response):
        feedBackID = request_dict.get('feedBackID', None)
        msg = request_dict.get('msg', None)
        uid = request_dict.get('uid', None)

        if not all([feedBackID, msg]):
            return response.json(444)

        try:
            nowTime = int(time.time())
            feed_back_qs = FeedBackModel.objects.filter(id=feedBackID)
            if not feed_back_qs.exists():
                return response.json(173)
            with transaction.atomic():
                SysMsgModel.objects.create(userID_id=feed_back_qs.first().userID_id, msg=msg, uid=uid,
                                           addTime=nowTime, updTime=nowTime)  # 创建系统消息
                feed_back_qs.update(status=1)  # 更新状态为已回复
            return response.json(0)
        except Exception as e:
            print(e)
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def sendSysMsgToUser(self, request_dict, response):
        """
        发送系统消息至用户
        @param request_dict:请求参数
        @param response:响应对象
        @param userID:用户ID
        @param msg:发送内容
        @return:
        """
        userID = request_dict.get('userID', None)
        msg = request_dict.get('msg', None)

        if not all([userID, msg]):
            return response.json(444)

        try:
            nowTime = int(time.time())
            SysMsgModel.objects.create(userID_id=userID, msg=msg, addTime=nowTime, updTime=nowTime)
            return response.json(0)
        except Exception as e:
            print(e)
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def deleteFeedBack(self, request_dict, response):
        feedBackID = request_dict.get('feedBackID', None)
        if not feedBackID:
            return response.json(444)
        try:
            feed_back = FeedBackModel.objects.get(id=feedBackID)
            sr_id_list = feed_back.FS.values_list('id', flat=True)
            StatResModel.objects.filter(id__in=sr_id_list).delete()
            feed_back.delete()
            return response.json(0)
        except Exception as e:
            print(e)
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def getSysMessageList(self, request_dict, response):
        # 功能群发查询
        print('request_dict: ', request_dict)
        pageNo = request_dict.get('pageNo', None)
        pageSize = request_dict.get('pageSize', None)

        if not all([pageNo, pageSize]):
            return response.json(444)

        page = int(pageNo)
        line = int(pageSize)

        try:
            sys_mass_qs = SysMassModel.objects.filter()
            total = sys_mass_qs.count()
            sys_mass_qs = sys_mass_qs.values('id', 'sender__username', 'addTime', 'updTime', 'lang', 'recever', 'msg',
                                             'platform')
            sys_mass_qs = sys_mass_qs[(page - 1) * line:page * line]
            return response.json(0, {'list': list(sys_mass_qs), 'total': total})
        except Exception as e:
            print(e)
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def getAppDataList(self, request_dict, response):
        print('request_dict: ', request_dict)
        platform = request_dict.get('platform', None)

        if platform == 'ios':
            app_type = [1]
        elif platform == 'android':
            app_type = [2]
        else:
            app_type = [1, 2]

        try:
            app_info_qs = App_Info.objects.filter(app_type__in=app_type).values('appBundleId', 'appName').distinct()
            appBundleId_list = []
            for app_info in app_info_qs:
                appBundleId_list.append(app_info['appBundleId'])
            return response.json(0, {'appBundleId_list': appBundleId_list})
        except Exception as e:
            print(e)
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def sendSysMessage(self, request_dict, response):
        print('request_dict: ', request_dict)
        lang = request_dict.get('lang', None)
        platform = request_dict.get('platform', None)
        recever = request_dict.get('app_list', None)
        msg = request_dict.get('msg', None)

        if not all([lang, platform, recever, msg]):
            return response.json(444)

        try:
            with transaction.atomic():
                # SysMassModel表创建群发消息记录数据
                nowTime = int(time.time())
                sender_id = Device_User.objects.filter(username='13800138001').values('userID').first()['userID']
                SysMassModel.objects.create(
                    sender_id=sender_id,
                    lang=lang,
                    platform=platform,
                    recever=recever,
                    msg=msg,
                    addTime=nowTime,
                    updTime=nowTime,
                )
                # 根据UserExModel表的userID群发消息给用户
                region_list = lang.split(',')
                appBundleId_list = recever.split(',')
                userID_list = UserExModel.objects.filter(appBundleId__in=appBundleId_list, region__in=region_list) \
                    .values_list('userID_id', flat=True)
                sys_msg_list = []
                for userID in userID_list:
                    sys_msg_list.append(SysMsgModel(userID_id=userID, msg=msg, addTime=nowTime, updTime=nowTime))
                    if len(sys_msg_list) > 5000:
                        SysMsgModel.objects.bulk_create(sys_msg_list)
                        sys_msg_list = []
                SysMsgModel.objects.bulk_create(sys_msg_list)
            return response.json(0)
        except Exception as e:
            print(e)
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def collectFeedBack(self, request_dict, response):
        """收藏或取消收藏用户反馈信息"""
        feedBackID = request_dict.get('feedBackID', None)
        collect_status = request_dict.get('collectStatus', None)
        if not all([feedBackID, collect_status]):
            return response.json(444)
        feedBackID = int(feedBackID)
        collect_status = int(collect_status)
        feed_back_qs = FeedBackModel.objects.filter(id=feedBackID, collect_status=collect_status)
        if feed_back_qs.exists():  # 判断是否已收藏
            feed_qs = feed_back_qs.first()
            feed_qs.collect_status = 0
            feed_qs.save()
        else:
            FeedBackModel.objects.filter(id=feedBackID).update(collect_status=collect_status)
        return response.json(0)

    def exportFeedBack(self, request_dict, response):
        status = request_dict.get('status', None)
        collectStatus = request_dict.get('collectStatus', None)
        try:
            with transaction.atomic():
                filter_data = {}
                if status or collectStatus:
                    if status:
                        filter_data['status'] = int(status)
                    if collectStatus:
                        filter_data['collect_status'] = int(collectStatus)
                feed_back_qs = FeedBackModel.objects.filter()
                if filter_data:
                    feed_back_qs = feed_back_qs.filter(**filter_data)
                feed_backs = feed_back_qs.values(
                    'id',
                    'userID__username',
                    'userID__phone',
                    'userID__userEmail',
                    'content',
                    'addTime',
                    'status',
                    'type',
                    'app',
                    'app_version',
                    'phone_model',
                    'os_version',
                    'uid',
                    'appBundleId',
                    'score',
                    'collect_status'
                )
                feed_back_id_list = [feed_back['id'] for feed_back in feed_backs]
                stat_res_qs = StatResModel.objects.filter(
                    feedbackmodel__id__in=feed_back_id_list).values(
                    'name', 'feedbackmodel__id')
                auth = oss2.Auth(OSS_STS_ACCESS_KEY, OSS_STS_ACCESS_SECRET)
                bucket = oss2.Bucket(
                    auth, 'oss-cn-hongkong.aliyuncs.com', 'statres')
                feed_back_list = []
                for feed_back in feed_backs:
                    feed_back['img_url'] = []
                    for stat_res in stat_res_qs:
                        if stat_res['feedbackmodel__id'] == feed_back['id']:
                            obj = 'feedback/' + stat_res['name']
                            img_url = bucket.sign_url('GET', obj, 3600)
                            feed_back['img_url'].append(img_url)
                            if not feed_back['userID__username']:
                                feed_back['userID__username'] = feed_back['userID__userEmail'] if feed_back[
                                    'userID__userEmail'] else feed_back['userID__phone']
                    feed_back_list.append(feed_back)
            return response.json(0, {'list': feed_back_list})
        except Exception as e:
            print(e)

    def customerServiceManagement(self, request_dict, response):
        """
        审核用户请求/生成超级密码
        @param request_dict:请求参数
        @param response:响应对象
        @request_dict status: 0:未通过,1:通过
        @request_dict hint: 温馨提示
        @return:
        """
        ID = request_dict.get('ID', None)
        userID = request_dict.get('userID', None)
        uid = request_dict.get('uid', None)
        status = request_dict.get('status', None)
        hint = request_dict.get('hint', None)
        lang = request_dict.get('lang', 'en')
        if not all({ID, uid, userID}):
            return response.json(444, 'ID, uid, userID')
        now = int(time.time())
        try:
            with transaction.atomic():
                device_super_password_qs = DeviceSuperPassword.objects.filter(id=ID, uid=uid, userID=userID)
                if not device_super_password_qs.exists():
                    return response.json(173)
                status = int(status)
                if status == 1:
                    # 验证码生成
                    super_code = RandomStr(6, True)
                    super_password_id = "super_password_%s" % userID
                    redisObj = RedisObject()
                    redis = redisObj.set_data(key=super_password_id, val=super_code, expire=86400)
                    if redis is False:
                        return response.json(121)
                    device_super_password_qs.update(status=status)
                    if lang == 'en':
                        msg = "Your authorization code is " + super_code + ",valid within 24 hours"
                    else:
                        msg = "您的授权代码：" + super_code + "，24小时内有效"
                    # eventType: 0系统消息，1 ipcamera消息，2 超级密码
                    SysMsgModel.objects.create(userID_id=userID, msg=msg, addTime=now, updTime=now, uid=uid,
                                               eventType=2)
                    return response.json(0)
                if status == 0 and len(hint) > 1:
                    device_super_password_qs.update(status=status, hint=hint)
                    SysMsgModel.objects.create(userID_id=userID, msg=hint, addTime=now, updTime=now, uid=uid,
                                               eventType=2)
                    return response.json(0)
                return response.json(177)
        except Exception as e:
            print('修改状态异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def getDeviceSuperPassword(self, request_dict, response):
        """
        查询用户请求表
        @param request_dict:请求参数
        @param response:响应对象
        @return:
        """
        pageNo = request_dict.get('pageNo', None)
        pageSize = request_dict.get('pageSize', None)
        status = request_dict.get('status', None)
        userID = request_dict.get('userID', None)
        uid = request_dict.get('uid', None)
        if not all([pageNo, pageSize]):
            return response.json(444)
        page = int(pageNo)
        line = int(pageSize)
        try:
            device_super_password_qs = DeviceSuperPassword.objects.all()
            if status:
                device_super_password_qs = device_super_password_qs.filter(status=status)
            if userID:
                device_super_password_qs = device_super_password_qs.filter(userID=userID)
            if uid:
                device_super_password_qs = device_super_password_qs.filter(uid=uid)
            if not device_super_password_qs.exists():
                return response.json(0, [])
            count = device_super_password_qs.count()
            device_super_password_qs = device_super_password_qs.values('id',
                                                                       'uid',
                                                                       'userID',
                                                                       'orderID',
                                                                       'describe',
                                                                       'purchase_channel',
                                                                       'addTime',
                                                                       'status',
                                                                       'buyTime',
                                                                       'hint',
                                                                       'lang',
                                                                       'userID__username')
            device_super_password_qs = device_super_password_qs.order_by('-addTime')[
                                       (page - 1) * line:page * line]
            return response.json(0, {'list': list(device_super_password_qs), 'count': count})
        except Exception as e:
            print('查询异常,errLine:{}, errMsg:{}'.format(e.__traceback__.tb_lineno, repr(e)))
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    def deleteInformation(self, request_dict, response):
        """
        删除信息
        @param request_dict:请求参数
        @param response:响应对象
        """
        ID = request_dict.get('id', None)
        if not ID:
            return response.json(444)
        device_super_password_qs = DeviceSuperPassword.objects.filter(id=ID)
        if not device_super_password_qs.exists():
            return response.json(173)
        device_super_password_qs.delete()
        return response.json(0)

    @staticmethod
    def getCustomizedPushList(request_dict, response):
        page = request_dict.get('pageNo', None)
        line = request_dict.get('pageSize', None)

        if not all([page, line]):
            return response.json(444)

        page = int(page)
        line = int(line)

        try:
            customized_push_qs = CustomizedPush.objects.filter()
            total = customized_push_qs.count()
            customized_push_qs = customized_push_qs.\
                values('id', 'title', 'msg', 'link', 'icon_link', 'country', 'device_type', 'register_period',
                       'time_zone', 'push_time', 'push_app', 'push_satus')
            customized_push_qs = customized_push_qs[(page - 1) * line:page * line]
            customized_push_list = []
            for customized_push in customized_push_qs:
                # 格式化数据
                device_type_list = customized_push['device_type'].split(',')
                register_period = customized_push['register_period'] + '年'
                time_zone = 'UTC ' + customized_push['time_zone']

                customized_push_list.append({
                    'customized_push_id': customized_push['id'],
                    'title': customized_push['title'],
                    'msg': customized_push['msg'],
                    'link': customized_push['link'],
                    'icon_link': customized_push['icon_link'],
                    'country': customized_push['country'],
                    'device_type_list': device_type_list,
                    'register_period': register_period,
                    'time_zone': time_zone,
                    'push_time': customized_push['push_time'],
                    'push_app': customized_push['push_app'],
                    'push_satus': customized_push['push_satus']
                })
            return response.json(0, {'list': customized_push_list, 'total': total})
        except Exception as e:
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    @staticmethod
    def addOrEditCustomizedPush(request, request_dict, response):
        title = request_dict.get('title', None)
        msg = request_dict.get('msg', None)
        link = request_dict.get('link', None)
        icon = request.FILES.get('icon', None)
        country = request_dict.get('country', None)
        device_type = request_dict.get('deviceType', None)
        register_period = request_dict.get('registerPeriod', None)
        time_zone = request_dict.get('timeZone', None)
        push_time = request_dict.get('pushTime', None)
        push_app = request_dict.get('pushApp', None)
        is_edit = request_dict.get('isEdit', None)

        if not all([title, msg, link, country, device_type, register_period, time_zone, push_time, push_app]):
            return response.json(444)

        # 截掉UTC和空格
        time_zone = time_zone[4:]
        try:
            push_timestamp = CommonService.convert_to_timestamp(float(time_zone), push_time)
            customized_push_data = {
                'title': title,
                'msg': msg,
                'link': link,
                'country': country,
                'device_type': device_type,
                'register_period': register_period,
                'time_zone': time_zone,
                'push_time': push_time,
                'push_timestamp': push_timestamp,
                'push_app': push_app
            }
            icon_link = ''
            if icon is not None:
                icon_name = icon.name
                icon_link = 'https://ansjerfilemanager.s3.amazonaws.com/customized-push/' + icon_name
                customized_push_data['icon_link'] = icon_link

                if icon_link:
                    # 上传没有上传过的图片到S3
                    customized_push_qs = CustomizedPush.objects.filter(icon_link=icon_link)
                    if not customized_push_qs.exists():
                        bucket = 'ansjerfilemanager'
                        file_key = 'customized-push/' + icon_name
                        s3 = AmazonS3Util(AWS_ACCESS_KEY_ID[1], AWS_SECRET_ACCESS_KEY[1], AWS_SES_ACCESS_REGION)
                        s3.upload_file_obj(
                            bucket,
                            file_key,
                            icon,
                            {'ContentType': icon.content_type, 'ACL': 'public-read'})

            if is_edit:     # 编辑
                customized_push_id = request_dict.get('customizedPushId', None)
                if not customized_push_id:
                    return response.json(444)
                CustomizedPush.objects.filter(id=customized_push_id).update(**customized_push_data)
            else:           # 新增
                CustomizedPush.objects.create(**customized_push_data)
            return response.json(0)
        except Exception as e:
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    @staticmethod
    def getCountryList(response):
        try:
            country_qs = CountryModel.objects.filter().values('country_name')
            if not country_qs.exists():
                return response.json(173)

            country_list = []
            for country in country_qs:
                country_list.append(country['country_name'])
            return response.json(0, {'list': country_list})
        except Exception as e:
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))

    @staticmethod
    def getDeviceTypeList(response):
        try:
            device_type_qs = DeviceTypeModel.objects.filter().values('name')
            if not device_type_qs.exists():
                return response.json(173)

            device_type_list = []
            for device_type in device_type_qs:
                device_type_list.append(device_type['name'])
            return response.json(0, {'list': device_type_list})
        except Exception as e:
            return response.json(500, 'error_line:{}, error_msg:{}'.format(e.__traceback__.tb_lineno, repr(e)))