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.ModelService import ModelService
from Model.models import Feedback_Info
from django.utils import timezone
import traceback
from Object.ResponseObject import ResponseObject
from Object.TokenObject import TokenObject
from Service.CommonService import CommonService


class FeedBackInfoView(View):
    def get(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        operation = kwargs.get('operation', None)
        return self.validation(request.GET, operation)

    def post(self, request, *args, **kwargs):
        request.encoding = 'utf-8'
        operation = kwargs.get('operation', None)
        return self.validation(request.POST, operation)

    def validation(self, request_dict, operation):
        response = ResponseObject()
        token = request_dict.get('token', None)
        tko = TokenObject(token)
        if operation == 'add':
            if tko.code == 0:
                return self.do_add(request_dict, response)
            else:
                return response.json(tko.code)
        else:
            return response.json(0, 414)

    def do_add(self, request_dict, response):

        return

    def add_info(self, request_dict, userID, response):
        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 response.json(424, {'details': errorInfo})
            else:
                print(type(feedback_info.add_time))
                return response.json(0, {'id': feedback_info.id})
        return response.json(444)

    def query_info(self, request_dict, userID, response):
        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.qs_to_dict(res)
                send_json['count'] = count
                return response.json(0, send_json)
            return response.json(0, {'datas': [], 'count': 0})
        else:
            return response.json(444)

    def update_info(self, request_dict, userID, response):
        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 response.json(10, {'details': repr(e)})
            else:
                now_time = timezone.localtime(timezone.now())
                return response.json(0, {'update_success': 1,
                                         'update_time': str(now_time)})
        else:
            return response.json(444)

    def delete_info(self, request_dict, userID, response):
        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 response.json(0, {'delete_count': is_delete[0]})
        else:
            return response.json(444)

    def query_all_info(self, request_dict, userID, response):
        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_perm(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.qs_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 response.json(0, send_json)
                return response.json(0, {'datas': [], 'count': 0})
            else:
                return response.json(404)
        else:
            return response.json(444)

    def delete_by_admin(self, request_dict, userID, response):
        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_perm(userID=userID, permID=10)
            if check_perm is True:
                is_delete = Feedback_Info.objects.filter(id__in=id_list).delete()
                return response.json(0, {'delete_count': is_delete[0]})
            else:
                return response.json(404)
        else:
            return response.json(444)

    def update_by_admin(self, request_dict, userID, response):
        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_perm(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 response.json(302, {'details': repr(e)})
                else:
                    now_time = timezone.localtime(timezone.now())
                    return response.json(0, {'update_id': feedback_info.id, 'update_time': str(now_time)})
            else:
                return response.json(404)
        else:
            return response.json(444)