| """ |
| 合同收款 API 层 |
| 符合三层架构规范：只做请求/响应处理，业务逻辑在 Service 层 |
| """ |
|
|
| from __future__ import annotations |
|
|
| from decimal import Decimal |
| from typing import Any |
|
|
| from django.http import HttpRequest |
| from django.utils.dateparse import parse_date |
| from ninja import Router |
|
|
| from apps.contracts.schemas import ContractPaymentIn, ContractPaymentOut, ContractPaymentUpdate |
| from apps.core.dto.request_context import extract_request_context |
|
|
| router = Router() |
|
|
|
|
| def _get_payment_service() -> Any: |
| """工厂函数：创建 ContractPaymentService 实例""" |
| from apps.contracts.services.payment.contract_payment_service import ContractPaymentService |
|
|
| return ContractPaymentService() |
|
|
|
|
| @router.get("/finance/payments", response=list[ContractPaymentOut]) |
| def list_payments( |
| request: HttpRequest, |
| contract_id: int | None = None, |
| invoice_status: str | None = None, |
| start_date: str | None = None, |
| end_date: str | None = None, |
| ) -> list[Any]: |
| """获取收款列表""" |
| service = _get_payment_service() |
| ctx = extract_request_context(request) |
|
|
| d1 = parse_date(start_date) if start_date else None |
| d2 = parse_date(end_date) if end_date else None |
|
|
| return list( |
| service.list_payments( |
| contract_id=contract_id, |
| invoice_status=invoice_status, |
| start_date=d1, |
| end_date=d2, |
| user=ctx.user, |
| perm_open_access=ctx.perm_open_access, |
| ) |
| ) |
|
|
|
|
| @router.post("/finance/payments", response=ContractPaymentOut) |
| def create_payment(request: HttpRequest, payload: ContractPaymentIn) -> Any: |
| """创建收款记录""" |
| service = _get_payment_service() |
| ctx = extract_request_context(request) |
|
|
| received_at = parse_date(payload.received_at) if payload.received_at else None |
|
|
| return service.create_payment( |
| contract_id=payload.contract_id, |
| amount=Decimal(str(payload.amount)), |
| received_at=received_at, |
| invoice_status=payload.invoice_status, |
| invoiced_amount=Decimal(str(payload.invoiced_amount)) if payload.invoiced_amount else None, |
| note=payload.note, |
| user=ctx.user, |
| confirm=payload.confirm, |
| ) |
|
|
|
|
| @router.put("/finance/payments/{payment_id}", response=ContractPaymentOut) |
| def update_payment(request: HttpRequest, payment_id: int, payload: ContractPaymentUpdate) -> Any: |
| """更新收款记录""" |
| service = _get_payment_service() |
| ctx = extract_request_context(request) |
|
|
| data = payload.model_dump(exclude_unset=True) |
|
|
| if data.get("received_at"): |
| data["received_at"] = parse_date(data["received_at"]) |
|
|
| confirm = data.pop("confirm", False) |
|
|
| return service.update_payment( |
| payment_id=payment_id, |
| data=data, |
| user=ctx.user, |
| confirm=confirm, |
| ) |
|
|
|
|
| @router.delete("/finance/payments/{payment_id}") |
| def delete_payment(request: HttpRequest, payment_id: int) -> Any: |
| """删除收款记录""" |
| service = _get_payment_service() |
| ctx = extract_request_context(request) |
| confirm = request.GET.get("confirm") == "true" |
|
|
| return service.delete_payment( |
| payment_id=payment_id, |
| user=ctx.user, |
| confirm=confirm, |
| ) |
|
|
