|
@@ -0,0 +1,157 @@
|
|
|
+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)
|
|
|
+ page = int(page)
|
|
|
+ line = int(line)
|
|
|
+ omqs = App_Colophon.objects.filter()
|
|
|
+ if not omqs.exists():
|
|
|
+ return response.json(0, [])
|
|
|
+ count = omqs.count()
|
|
|
+ order_ql = omqs[(page - 1) * line:page * line]. \
|
|
|
+ values("id", "lang", "newApp_version", "content", "app_id__appBundleId")
|
|
|
+ order_list = list(order_ql)
|
|
|
+ return response.json(0, {'data': order_list, 'count': count})
|
|
|
+
|
|
|
+ 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)
|
|
|
+ lang = request_dict.get('lang', None)
|
|
|
+ newApp_version = request_dict.get('newApp_version', None)
|
|
|
+ content = request_dict.get('content', None)
|
|
|
+ param_flag = CommonService.get_param_flag(
|
|
|
+ data=[lang, newApp_version, content])
|
|
|
+ if param_flag is not True:
|
|
|
+ return response.json(444)
|
|
|
+ try:
|
|
|
+ AppColophon = App_Colophon(
|
|
|
+ app_id=App_Info.objects.get(appBundleId=app_id),
|
|
|
+ lang=lang,
|
|
|
+ newApp_version=newApp_version,
|
|
|
+ content=content)
|
|
|
+ AppColophon.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)
|
|
|
+ id = request_dict.get('id', None)
|
|
|
+ if not id:
|
|
|
+ return response.json(444, 'content,id')
|
|
|
+ try:
|
|
|
+ print (id)
|
|
|
+ AppColophon = App_Colophon.objects.filter(id=id)
|
|
|
+
|
|
|
+ if AppColophon.exists():
|
|
|
+ AppColophon.update( lang=lang,
|
|
|
+ newApp_version=newApp_version,
|
|
|
+ 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})
|
|
|
+
|
|
|
+
|
|
|
+
|