File size: 2,520 Bytes
f8b03c1 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 | """
案件指派 API
符合四层架构规范：只做请求/响应处理，业务逻辑在 Service 层
"""
from __future__ import annotations
from typing import Any, cast
from django.http import HttpRequest
from ninja import Router
from apps.cases.schemas import CaseAssignmentIn, CaseAssignmentOut, CaseAssignmentUpdate
from apps.core.dto.request_context import extract_request_context
router = Router()
def _get_case_assignment_service() -> Any:
"""工厂函数：创建 CaseAssignmentService 实例"""
from apps.cases.services.party.case_assignment_service import CaseAssignmentService
return CaseAssignmentService()
@router.get("/assignments", response=list[CaseAssignmentOut])
def list_assignments(
request: HttpRequest, case_id: int | None = None, lawyer_id: int | None = None
) -> list[CaseAssignmentOut]:
service = _get_case_assignment_service()
ctx = extract_request_context(request)
return cast(list[CaseAssignmentOut], service.list_assignments(case_id=case_id, lawyer_id=lawyer_id, user=ctx.user))
@router.post("/assignments", response=CaseAssignmentOut)
def create_assignment(request: HttpRequest, payload: CaseAssignmentIn) -> CaseAssignmentOut:
service = _get_case_assignment_service()
ctx = extract_request_context(request)
return cast(
CaseAssignmentOut,
service.create_assignment(case_id=payload.case_id, lawyer_id=payload.lawyer_id, user=ctx.user),
)
@router.get("/assignments/{assignment_id}", response=CaseAssignmentOut)
def get_assignment(request: HttpRequest, assignment_id: int) -> CaseAssignmentOut:
service = _get_case_assignment_service()
ctx = extract_request_context(request)
return cast(CaseAssignmentOut, service.get_assignment(assignment_id=assignment_id, user=ctx.user))
@router.put("/assignments/{assignment_id}", response=CaseAssignmentOut)
def update_assignment(request: HttpRequest, assignment_id: int, payload: CaseAssignmentUpdate) -> CaseAssignmentOut:
service = _get_case_assignment_service()
ctx = extract_request_context(request)
data = payload.dict(exclude_unset=True)
return cast(CaseAssignmentOut, service.update_assignment(assignment_id=assignment_id, data=data, user=ctx.user))
@router.delete("/assignments/{assignment_id}")
def delete_assignment(request: HttpRequest, assignment_id: int) -> Any:
service = _get_case_assignment_service()
ctx = extract_request_context(request)
return service.delete_assignment(assignment_id=assignment_id, user=ctx.user)
|