from django.views.generic.base import View from django.utils.decorators import method_decorator from django.views.decorators.csrf import csrf_exempt from Service.TokenManager import JSONTokenManager from Service.ModelService import ModelService from Model.models import Feedback_Info from django.utils import timezone import traceback from Service.ResponseService import * ''' http://192.168.136.45:8077/feedbackInfo?operation=add&token=test&content=12341234 http://192.168.136.45:8077/feedbackInfo?operation=query&token=test&page=1&line=10 http://192.168.136.45:8077/feedbackInfo?operation=update&token=test&id=1&content=gggggggggggggggg http://192.168.136.45:8077/feedbackInfo?operation=delete&token=test&id=11&id=13&id=14 http://192.168.136.40:8077/feedbackInfo?operation=queryAll&token=test&page=1&line=5 http://192.168.136.45:8077/feedbackInfo?operation=deleteByAdmin&token=test&id=11&id=13&id=14 http://192.168.136.45:8077/feedbackInfo?operation=deleteByAdmin&token=test&id=11&id=13&id=14 http://192.168.136.45:8077/feedbackInfo?operation=updateByAdmin&token=test&id=1&status=1 ''' class FeedBackInfo(View): @method_decorator(csrf_exempt) def dispatch(self, *args, **kwargs): return super(FeedBackInfo, self).dispatch(*args, **kwargs) def get(self, request, *args, **kwargs): request.encoding = 'utf-8' return self.validation(request_dict=request.GET) def post(self, request, *args, **kwargs): request.encoding = 'utf-8' return self.validation(request_dict=request.POST) def validation(self, request_dict, *args, **kwargs): token = request_dict.get('token', None) if token is not None: tokenManager = JSONTokenManager() error_code = tokenManager.verify_AToken(token) if error_code == 0: userID = tokenManager.accessDict.get('userID', None) operation = request_dict.get('operation', None) param_flag = CommonService.get_param_flag(data=[userID, operation]) if param_flag is True: if operation == 'query': return self.query_info(request_dict=request_dict, userID=userID) elif operation == 'add': return self.add_info(request_dict=request_dict, userID=userID) elif operation == 'update': return self.update_info(request_dict=request_dict,userID=userID) elif operation == 'delete': return self.delete_info(request_dict=request_dict, userID=userID) elif operation == 'queryAll': return self.query_all_info(request_dict=request_dict,userID=userID) elif operation == 'deleteByAdmin': return self.delete_by_admin(request_dict=request_dict,userID=userID) elif operation == 'updateByAdmin': return self.update_by_admin(request_dict=request_dict,userID=userID) return ResponseJSON(444) else: return HttpResponse(tokenManager.errorCodeInfo(error_code)) else: return ResponseJSON(311) def add_info(self, request_dict, userID): content = request_dict.get('content', None) param_flag = CommonService.get_param_flag(data=[content]) if param_flag is True: try: feedback_info = Feedback_Info( userID=userID, content=content, ) feedback_info.save() except Exception: errorInfo = traceback.format_exc() print(errorInfo) return ResponseJSON(424, {'details': errorInfo}) else: print(type(feedback_info.add_time)) return ResponseJSON(0,{'id':feedback_info.id}) return ResponseJSON(444) def query_info(self, request_dict, userID): page = int(request_dict.get('page', None)) line = int(request_dict.get('line', None)) param_flag = CommonService.get_param_flag(data=[page, line]) if param_flag is True: feedback_info_queryset = Feedback_Info.objects.filter(userID=userID).order_by('-id') if feedback_info_queryset.exists(): count = feedback_info_queryset.count() res = feedback_info_queryset[(page - 1) * line:page * line] send_json = CommonService.query_set_to_dict(res) send_json['count'] = count return ResponseJSON(0, send_json) return ResponseJSON(0, {'datas': [], 'count': 0}) else: return ResponseJSON(444) def update_info(self, request_dict, userID): content = request_dict.get('content', None) id = request_dict.get('id',None) param_flag = CommonService.get_param_flag(data=[id, content]) if param_flag is True: try: feedback_info = Feedback_Info.objects.get(userID=userID, id=id) feedback_info.content = content feedback_info.save() except Exception as e: return ResponseJSON(302, {'details': repr(e)}) else: now_time = timezone.localtime(timezone.now()) return ResponseJSON(0, {'update_success': 1, 'update_time': str(now_time)}) else: return ResponseJSON(444) def delete_info(self, request_dict, userID): id_list = request_dict.getlist('id',None) param_flag = CommonService.get_param_flag(data=[id_list]) if param_flag is True: is_delete = Feedback_Info.objects.filter(id__in=id_list, userID=userID).delete() return ResponseJSON(0,{'delete_count':is_delete[0]}) else: return ResponseJSON(444) def query_all_info(self, request_dict, userID): page = int(request_dict.get('page', None)) line = int(request_dict.get('line', None)) order = request_dict.get('order','-id') status = request_dict.get('status',None) if order == '': order ='-id' param_flag = CommonService.get_param_flag(data=[page, line]) if param_flag is True: check_perm = ModelService.check_permission(userID=userID,permID=30) if check_perm is True: if status is not None: feedback_info_queryset = Feedback_Info.objects.filter(status=status).order_by(order) else: feedback_info_queryset = Feedback_Info.objects.all().order_by(order) if feedback_info_queryset.exists(): count = feedback_info_queryset.count() res = feedback_info_queryset[(page - 1) * line:page * line] send_json = CommonService.query_set_to_dict(res) for k, v in enumerate(send_json["datas"]): username = ModelService.get_user_name(userID=send_json["datas"][k]['fields']['userID']) send_json["datas"][k]['fields']['username']=username send_json['count'] = count return ResponseJSON(0, send_json) return ResponseJSON(0, {'datas': [], 'count': 0}) else: return ResponseJSON(404) else: return ResponseJSON(444) def delete_by_admin(self, request_dict, userID): id_list = request_dict.getlist('id', None) param_flag = CommonService.get_param_flag(data=[id_list]) if param_flag is True: check_perm = ModelService.check_permission(userID=userID, permID=10) if check_perm is True: is_delete = Feedback_Info.objects.filter(id__in=id_list).delete() return ResponseJSON(0, {'delete_count': is_delete[0]}) else: return ResponseJSON(404) else: return ResponseJSON(444) def update_by_admin(self, request_dict, userID): id = request_dict.get('id',None) status = request_dict.get('status',None) param_flag = CommonService.get_param_flag(data=[id, status]) if param_flag is True: check_perm = ModelService.check_permission(userID=userID, permID=50) if check_perm is True: try: feedback_info = Feedback_Info.objects.get(id=id) feedback_info.status = status feedback_info.save() except Exception as e: return ResponseJSON(302, {'details': repr(e)}) else: now_time = timezone.localtime(timezone.now()) return ResponseJSON(0, {'update_id': feedback_info.id,'update_time':str(now_time)}) else: return ResponseJSON(404) else: return ResponseJSON(444)