| """ |
| 案件指派 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) |
|
|
