#!/usr/bin/env python3 # -*- coding: utf-8 -*- """ @Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved. @AUTHOR: ASJRD018 @NAME: AnsjerFormal @software: PyCharm @DATE: 2018/9/11 15:08 @Version: python3.6 @MODIFY DECORD:ansjer dev @file: UserController.py @Contact: chanjunkai@163.com """ 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 from Controller.CheckUserData import DataValid, RandomStr from Model.models import Device_User, Role, UserExModel, CountryModel, MenuModel, FeedBackModel, StatResModel, \ SysMassModel, App_Info, SysMsgModel, DeviceSuperPassword 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) 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) if operation == 'customerServiceManagement': # 审核用户请求/生成超级密码 return self.customerServiceManagement(request_dict, response) if operation == 'getDeviceSuperPassword': # 查询超级密码请求表 return self.getDeviceSuperPassword(request_dict, response) if operation == 'deleteInformation': # 删除超级密码请求表 return self.deleteInformation(request_dict, response) else: return response.json(404) 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: if username or NickName or phone or userEmail or countryName: # 条件查询 if username: device_user_qs = Device_User.objects.filter(username__icontains=username) if NickName: device_user_qs = Device_User.objects.filter(NickName__icontains=NickName) if phone: device_user_qs = Device_User.objects.filter(phone__icontains=phone) if userEmail: device_user_qs = Device_User.objects.filter(userEmail__icontains=userEmail) if countryName: id_list = CountryModel.objects.filter(country_name=countryName).values_list('id', flat=True) device_user_qs = Device_User.objects.filter(region_country__in=id_list) if not device_user_qs.exists(): return response.json(0) total = len(device_user_qs) device_users = device_user_qs[(page - 1) * line:page * line] else: total = Device_User.objects.filter().count() device_users = Device_User.objects.filter()[(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)