ASJServer/Controller/FeedBackInfo.py

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)