scj/apps/finance/views.py

# coding=utf-8

import traceback
import json

from django.db.models import Q, Sum
from django.db.models import ProtectedError
from django.views.decorators.csrf import csrf_exempt
from django.db import transaction, IntegrityError
from django.conf import settings
from apps.base import Formater
from apps.finance.filters import FinanceCategoryFilter, FinancePurposeFilter, FinanceIncomeFilter
from apps.finance.models import FinanceCategory, FinancePurpose, dbFinanceIncome
from apps.finance.serializers import FinanceCategorySerializer, FinancePurposeSerializer, FinanceIncomeSerializer
from apps.account.decorators import token_required, permission_required
from apps.foundation.models import BizLog, Option

from libs.http import JSONResponse, JSONError, DataGridJSONResponse
from libs import utils
from apps.exceptions import CustomError


@csrf_exempt
@permission_required('finance.view_finance_category')
def finance_category_list(request):
    f = FinanceCategoryFilter(request.GET, queryset=FinanceCategory.objects.filter())
    rows, total = utils.get_page_data(request, f.qs)
    serializer = FinanceCategorySerializer(rows, many=True)
    return DataGridJSONResponse(serializer.data, total)\


@csrf_exempt
@token_required
def finance_category_dict(request):
    result = {
        'category': FinanceCategorySerializer(FinanceCategory.objects.filter(enabled=True), many=True).data,
        'purpose': FinancePurposeSerializer(FinancePurpose.objects.filter(enabled=True), many=True).data,
    }
    return JSONResponse(result)


@csrf_exempt
@permission_required('finance.add_finance_category')
def finance_category_save(request):
    id = request.GET.get('id')
    data = json.loads(request.body)

    try:
        with transaction.atomic():
            serializer = FinanceCategorySerializer.factory(request.user, data, id)
            serializer.validSave()
    except CustomError, e:
        return JSONError(e.get_error_msg())
    except Exception, e:
        traceback.print_exc()
        return JSONError(u'保存失败！')
    return JSONResponse({})


@csrf_exempt
@permission_required('finance.delete_finance_category')
def finance_category_delete(request):
    id = request.GET.get('id')

    try:
        with transaction.atomic():
            instance = FinanceCategory.getById(id)
            BizLog.objects.addnew(request.user, BizLog.DELETE, u"删除财务收支类别[%s]，id=%d" % (instance.name, instance.id))
            instance.delete()
    except CustomError, e:
        return JSONError(e.get_error_msg())
    except ProtectedError:
        return JSONError(u'该财务收支类别已被使用，禁止删除！')
    except IntegrityError:
        return JSONError(u'该财务收支类别已被使用，禁止删除！')
    except Exception, e:
        traceback.print_exc()
        return JSONError(u'删除失败！')

    return JSONResponse({})


@csrf_exempt
@permission_required('finance.view_finance_category')
def finance_purpose_list(request):
    f = FinancePurposeFilter(request.GET, queryset=FinancePurpose.objects.filter())
    rows, total = utils.get_page_data(request, f.qs)
    serializer = FinancePurposeSerializer(rows, many=True)
    return DataGridJSONResponse(serializer.data, total)


@csrf_exempt
@permission_required('finance.add_finance_category')
def finance_purpose_save(request):
    id = request.GET.get('id')
    data = json.loads(request.body)
    try:
        with transaction.atomic():
            serializer = FinancePurposeSerializer.factory(request.user, data, id)
            serializer.validSave()
    except CustomError, e:
        return JSONError(e.get_error_msg())
    except Exception, e:
        traceback.print_exc()
        return JSONError(u'保存失败！')
    return JSONResponse({})


@csrf_exempt
@permission_required('finance.delete_finance_category')
def finance_purpose_delete(request):
    id = request.GET.get('id')

    try:
        with transaction.atomic():
            instance = FinancePurpose.getById(id)
            BizLog.objects.addnew(request.user, BizLog.DELETE, u"删除财务收支用途[%s]，id=%d" % (instance.name, instance.id))
            instance.delete()
    except CustomError, e:
        return JSONError(e.get_error_msg())
    except ProtectedError:
        return JSONError(u'该财务收支用途已被使用，禁止删除！')
    except IntegrityError:
        return JSONError(u'该财务收支用途已被使用，禁止删除！')
    except Exception, e:
        traceback.print_exc()
        return JSONError(u'删除失败！')

    return JSONResponse({})

@csrf_exempt
@permission_required('finance.view_finance_income')
def finance_income_list(request):
    department_ids = request.user.getSubDepartmentIds()
    user_ids = request.user.getSubEmployeeIds()
    # f = FinanceIncomeFilter(request.GET, queryset=dbFinanceIncome.objects.filter())
    rows = dbFinanceIncome.objects.filter(Q(create_user_id__in=user_ids) | Q(department_id__in=department_ids) | Q(create_user=request.user))
    f = FinanceIncomeFilter(request.GET, queryset=rows)
    total_row = f.qs.aggregate(sum_amount=Sum('amount'))
    more = {
        'sum_amount': Formater.formatAmountShow(total_row['sum_amount']),
    }

    rows, total = utils.get_page_data(request, f.qs)
    serializer = FinanceIncomeSerializer(rows, many=True)
    return DataGridJSONResponse(serializer.data, total, more)


@csrf_exempt
@permission_required('finance.add_finance_income')
def finance_income_save(request):
    id = request.GET.get('id')
    data = json.loads(request.body)

    try:
        with transaction.atomic():

            serializer = FinanceIncomeSerializer.factory(request.user, data, id)
            if serializer.instance and serializer.instance.check_status == settings.PASS:
                raise CustomError(u'该收支单已审核，禁止修改！')
            serializer.validSave()
            BizLog.objects.addnew(request.user, BizLog.DELETE, u"编辑收支单[%s]，id=%d" % (serializer.instance.no, serializer.instance.id), data)
    except CustomError, e:
        return JSONError(e.get_error_msg())
    except Exception, e:
        traceback.print_exc()
        return JSONError(u'保存失败！')
    return JSONResponse({})

@csrf_exempt
@permission_required('finance.check_finance_income')
def finance_income_check(request):
    id = request.GET.get('id')
    check_status = request.GET.get('check_status')
    try:
        with transaction.atomic():
            instance = dbFinanceIncome.getById(id)
            instance.check_status = check_status
            instance.save()
            BizLog.objects.addnew(request.user, BizLog.DELETE, u"审核收支单[%s]，id=%d" % (instance.no, instance.id), check_status)
    except CustomError, e:
        return JSONError(e.get_error_msg())
    except Exception, e:
        traceback.print_exc()
        return JSONError(u'保存失败！')
    return JSONResponse({})

@csrf_exempt
@permission_required('finance.view_finance_income')
def finance_bank_data(request):
    create_time = request.GET.get('create_time')
    end_time = request.GET.get('end_time')
    data = []
    more = {
        'qichu_yue': 0,
        'benqi_shouru': 0,
        'benqi_fachu': 0,
        'qimo_yue': 0,
    }
    rows = dbFinanceIncome.objects.filter(check_status=settings.PASS)
    accounts = Option.objects.filter(type=Option.PAYMENT_ACCOUNT, enabled=True)
    for account in accounts:
        qichu_yue = rows.filter(create_time__lt=create_time, account=account).aggregate(amount=Sum('amount'))['amount']
        benqi_shouru = rows.filter(Q(create_time__gte=create_time,create_time__lte=end_time,account=account,),
                                   Q(type=dbFinanceIncome.SALE_ENTRY_PAY,) | Q(purpose__type=FinancePurpose.PAY,)
                                   ).aggregate(amount=Sum('amount'))['amount']

        benqi_fachu = rows.filter(create_time__gte=create_time,create_time__lte=end_time,account=account,
                                   ).exclude(Q(type=dbFinanceIncome.SALE_ENTRY_PAY) | Q( purpose__type=FinancePurpose.PAY,)).aggregate(amount=Sum('amount'))['amount']
        qimo_yue = rows.filter(create_time__lte=end_time, account=account).aggregate(amount=Sum('amount'))['amount']

        more['qichu_yue'] += qichu_yue or 0
        more['benqi_shouru'] += benqi_shouru or 0
        more['benqi_fachu'] += benqi_fachu or 0
        more['qimo_yue'] += qimo_yue or 0
        item = {
            'name':account.name,
            'qichu_yue':Formater.formatAmountShow(qichu_yue),
            'benqi_shouru':Formater.formatAmountShow(benqi_shouru),
            'benqi_fachu':Formater.formatAmountShow(benqi_fachu),
            'qimo_yue':Formater.formatAmountShow(qimo_yue),
        }
        data.append(item)
    more = {
        'qichu_yue': Formater.formatAmountShow(more['qichu_yue']),
        'benqi_shouru': Formater.formatAmountShow(more['benqi_shouru']),
        'benqi_fachu': Formater.formatAmountShow(more['benqi_fachu']),
        'qimo_yue': Formater.formatAmountShow(more['qimo_yue']),
    }
    return DataGridJSONResponse(data, len(data), more)