开源ERP管理系统，该系统前后端分离，包含PDA移动端扫码操作，api使用restful协议，方便二次开发

from extensions.common.schema import * from extensions.common.base import * from extensions.permissions import * from extensions.exceptions import * from extensions.viewsets import * from apps.finance.serializers import * from apps.finance.permissions import * from apps.finance.filters import * from apps.finance.schemas import * from apps.finance.models import * from apps.flow.models import * from apps.data.models import * class ClientArrearsViewSet(BaseViewSet, ListModelMixin, RetrieveModelMixin): """应收欠款""" serializer_class = ClientArrearsSerializer permission_classes = [IsAuthenticated, ClientArrearsPermission] filterset_fields = ['level', 'is_active', 'has_arrears'] search_fields = ['number', 'name', 'contact', 'remark'] ordering_fields = ['id', 'number', 'name', 'initial_arrears_amount', 'arrears_amount'] ordering = ['id'] queryset = Client.objects.all() class SupplierArrearsViewSet(BaseViewSet, ListModelMixin, RetrieveModelMixin): """应付欠款""" serializer_class = SupplierArrearsSerializer permission_classes = [IsAuthenticated, SupplierArrearsPermission] filterset_fields = ['is_active', 'has_arrears'] search_fields = ['number', 'name', 'contact', 'remark'] ordering_fields = ['id', 'number', 'name', 'initial_arrears_amount', 'arrears_amount'] ordering = ['id'] queryset = Supplier.objects.all() class PaymentOrderViewSet(BaseViewSet, ListModelMixin, RetrieveModelMixin, CreateModelMixin): """付款单据""" serializer_class = PaymentOrderSerializer permission_classes = [IsAuthenticated, PaymentOrderPermission] filterset_class = PaymentOrderFilter search_fields = ['number', 'supplier__number', 'supplier__name', 'remark'] ordering_fields = ['id', 'number', 'total_amount', 'create_time'] select_related_fields = ['supplier', 'handler', 'creator'] prefetch_related_fields = ['payment_accounts', 'payment_accounts__account'] queryset = PaymentOrder.objects.all() @transaction.atomic def perform_create(self, serializer): payment_order = serializer.save() # 同步欠款 supplier = payment_order.supplier supplier.arrears_amount = NP.minus(supplier.arrears_amount, payment_order.total_amount) supplier.has_arrears = supplier.arrears_amount > 0 supplier.save(update_fields=['arrears_amount', 'has_arrears']) # 同步余额, 流水 finance_flows = [] for payment_account in payment_order.payment_accounts.all(): account = payment_account.account amount_before = account.balance_amount amount_change = payment_account.payment_amount amount_after = NP.minus(amount_before, amount_change) finance_flows.append(FinanceFlow( account=account, type=FinanceFlow.Type.PAYMENT, amount_before=amount_before, amount_change=amount_change, amount_after=amount_after, payment_order=payment_order, creator=self.user, team=self.team )) account.balance_amount = amount_after if account.balance_amount < 0: raise ValidationError(f'结算账户[{account.name}]余额不足') account.has_balance = account.balance_amount > 0 account.save(update_fields=['balance_amount', 'has_balance']) else: FinanceFlow.objects.bulk_create(finance_flows) @extend_schema(responses={200: NumberResponse}) @action(detail=False, methods=['get']) def number(self, request, *args, **kwargs): """获取编号""" number = PaymentOrder.get_number(self.team) return Response(data={'number': number}, status=status.HTTP_200_OK) @transaction.atomic @extend_schema(request=None, responses={200: PaymentOrderSerializer}) @action(detail=True, methods=['post']) def void(self, request, *args, **kwargs): """作废""" payment_order = self.get_object() payment_order.is_void = True payment_order.save(update_fields=['is_void']) # 同步欠款 supplier = payment_order.supplier supplier.arrears_amount = NP.plus(supplier.arrears_amount, payment_order.total_amount) supplier.has_arrears = supplier.arrears_amount > 0 supplier.save(update_fields=['arrears_amount', 'has_arrears']) # 同步余额, 流水 finance_flows = [] for payment_account in payment_order.payment_accounts.all(): account = payment_account.account amount_before = account.balance_amount amount_change = payment_account.payment_amount amount_after = NP.plus(amount_before, amount_change) finance_flows.append(FinanceFlow( account=account, type=FinanceFlow.Type.VOID_PAYMENT, amount_before=amount_before, amount_change=amount_change, amount_after=amount_after, void_payment_order=payment_order, creator=self.user, team=self.team )) account.balance_amount = amount_after if account.balance_amount < 0: raise ValidationError(f'结算账户[{account.name}]余额不足') account.has_balance = account.balance_amount > 0 account.save(update_fields=['balance_amount', 'has_balance']) else: FinanceFlow.objects.bulk_create(finance_flows) serializer = PaymentOrderSerializer(instance=payment_order) return Response(data=serializer.data, status=status.HTTP_200_OK) class CollectionOrderViewSet(BaseViewSet, ListModelMixin, RetrieveModelMixin, CreateModelMixin): """付款单据""" serializer_class = CollectionOrderSerializer permission_classes = [IsAuthenticated, CollectionOrderPermission] filterset_class = CollectionOrderFilter search_fields = ['number', 'client__number', 'client__name', 'remark'] ordering_fields = ['id', 'number', 'total_amount', 'create_time'] select_related_fields = ['client', 'handler', 'creator'] prefetch_related_fields = ['collection_accounts', 'collection_accounts__account'] queryset = CollectionOrder.objects.all() @transaction.atomic def perform_create(self, serializer): collection_order = serializer.save() # 同步欠款 client = collection_order.client client.arrears_amount = NP.minus(client.arrears_amount, collection_order.total_amount) client.has_arrears = client.arrears_amount > 0 client.save(update_fields=['arrears_amount', 'has_arrears']) # 同步余额, 流水 finance_flows = [] for collection_account in collection_order.collection_accounts.all(): account = collection_account.account amount_before = account.balance_amount amount_change = collection_account.collection_amount amount_after = NP.plus(amount_before, amount_change) finance_flows.append(FinanceFlow( account=account, type=FinanceFlow.Type.COLLECTION, amount_before=amount_before, amount_change=amount_change, amount_after=amount_after, collection_order=collection_order, creator=self.user, team=self.team )) account.balance_amount = amount_after if account.balance_amount < 0: raise ValidationError(f'结算账户[{account.name}]余额不足') account.has_balance = account.balance_amount > 0 account.save(update_fields=['balance_amount', 'has_balance']) else: FinanceFlow.objects.bulk_create(finance_flows) @extend_schema(responses={200: NumberResponse}) @action(detail=False, methods=['get']) def number(self, request, *args, **kwargs): """获取编号""" number = PaymentOrder.get_number(self.team) return Response(data={'number': number}, status=status.HTTP_200_OK) @transaction.atomic @extend_