import time import traceback import simplejson as json from django.utils.decorators import method_decorator from django.views.decorators.csrf import csrf_exempt from django.views.generic.base import View from Model.models import App_Colophon,App_Info from Object.ResponseObject import ResponseObject from Object.TokenObject import TokenObject from Service.CommonService import CommonService from Service.ModelService import ModelService ''' # 管理员获取信息 http://192.168.136.39:8000/appCol/adminQuery?token=local&page=1&line=10 管理员删除信息 http://192.168.136.39:8000/appCol/adminDelete?token=local&id=2 管理员添加信息 http://192.168.136.39:8000/appCol/adminAdd?token=local&id=321&app_id=2&lang=cn&newApp_version=1.1.1&content=我马上升级 管理员编辑信息 http://192.168.136.39:8000/appCol/adminEdit?token=local&id=6&content={"token_val":"9999"} ''' # 设备信息添加 class AppColView(View): @method_decorator(csrf_exempt) def dispatch(self, *args, **kwargs): return super(AppColView, self).dispatch(*args, **kwargs) 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): response = ResponseObject() if operation is None: return response.json(444, 'error path') token = request_dict.get('token', None) # 设备主键uid tko = TokenObject(token) response.lang = tko.lang if tko.code != 0: return response.json(tko.code) userID = tko.userID if operation == 'adminDelete': return self.do_admin_delete(request_dict, userID, response) elif operation == 'adminQuery': return self.do_admin_query(request_dict, userID, response) elif operation == 'adminAdd': return self.do_admin_add(request_dict, userID, response) elif operation == 'adminEdit': return self.do_admin_edit(request_dict, userID, response) else: return response.json(444, 'error path') # 管理员删除 def do_admin_delete(self, request_dict, userID, response): own_perm = ModelService.check_perm(userID, 20) if own_perm is True: id = request_dict.get('id') try: list = App_Colophon.objects.filter(id=id) if list.exists(): list.delete() return response.json(0) else: return response.json(173) except Exception as e: print(repr(e)) return response.json(424, repr(e)) else: return response.json(404) # 管理员查询接口 def do_admin_query(self, request_dict, userID, response): own_perm = ModelService.check_perm(userID, 30) if own_perm is True: page = request_dict.get('page', None) line = request_dict.get('line', None) app_type = request_dict.get('app_type', None) if not app_type: omqs = App_Colophon.objects.all().order_by('app_id').values_list( 'app_id__appBundleId', flat=True).distinct() else : omqs = App_Colophon.objects.filter(app_id__app_type=app_type).order_by('app_id').values_list('app_id__appBundleId', flat=True).distinct() page = int(page) line = int(line) if not omqs.exists(): return response.json(0, []) count = omqs.count() omqs = list(omqs[(page - 1) * line:page * line]) # 查询时候用记得用in，查询是多个 ev_qs = App_Colophon.objects.filter(app_id__appBundleId__in=list(omqs)).values("id", "lang", "newApp_version", "content","version_time", "app_id__appBundleId", "app_id__appName", "app_id__app_type") order_list = list(ev_qs) datas = {} # 组装数据 for ev in order_list: for id in omqs: if id not in datas.keys(): datas[id] = [] if id == ev['app_id__appBundleId']: datas[id].append(ev) for k, v in enumerate(datas): new = sorted(datas[v], key=lambda x: x['id'],reverse=True) datas[v]=new res = { 'datas': datas, 'count': count } return response.json(0, res) else: return response.json(404) # 管理员的添加 def do_admin_add(self, request_dict, userID, response): own_perm = ModelService.check_perm(userID=userID, permID=40) if own_perm is not True: return response.json(404) app_id = request_dict.get('app_id', None) newApp_version = request_dict.get('newApp_version', None) en_content = request_dict.get('en_content', None) content = request_dict.get('content', None) version_time = request_dict.get('version_time', None) param_flag = CommonService.get_param_flag( data=[app_id,en_content,version_time, newApp_version, content]) if param_flag is not True: return response.json(444) app_info = App_Info.objects.filter(appBundleId=app_id) if app_info.exists(): print ("ok") else : return response.json(701) try: AppColophon = App_Colophon( app_id=App_Info.objects.get(appBundleId=app_id), lang='cn', newApp_version=newApp_version, version_time=version_time, content=content) AppColophon.save() AppColophon2 = App_Colophon( app_id=App_Info.objects.get(appBundleId=app_id), lang='en', newApp_version=newApp_version, version_time=version_time, content=en_content) AppColophon2.save() return response.json(0) except Exception: errorInfo = traceback.format_exc() print(errorInfo) return response.json(500, {'details': errorInfo}) # 管理员的编辑 def do_admin_edit(self, request_dict, userID, response): own_perm = ModelService.check_perm(userID=userID, permID=50) if own_perm is not True: return response.json(404) lang = request_dict.get('lang', None) newApp_version = request_dict.get('newApp_version', None) content = request_dict.get('content', None) version_time = request_dict.get('version_time', None) id = request_dict.get('id', None) if not id: return response.json(444, 'id') try: print (id) AppColophon = App_Colophon.objects.filter(id=id) if AppColophon.exists(): AppColophon.update(lang=lang, newApp_version=newApp_version, version_time=version_time, content=content) return response.json(0) else: return response.json(173) except Exception: errorInfo = traceback.format_exc() print(errorInfo) return response.json(500, {'details': errorInfo})