| """API endpoints.""" |
|
|
| from __future__ import annotations |
|
|
| from typing import Any |
|
|
| from django.http import HttpRequest |
| from ninja import Router |
|
|
| from apps.cases.schemas import ( |
| CaseMaterialBindCandidateOut, |
| CaseMaterialBindIn, |
| CaseMaterialDeleteAllIn, |
| CaseMaterialDeleteAllOut, |
| CaseMaterialDeleteOut, |
| CaseMaterialGroupOrderIn, |
| CaseMaterialGroupRenameIn, |
| CaseMaterialGroupRenameOut, |
| CaseMaterialReplaceIn, |
| CaseMaterialReplaceOut, |
| CaseMaterialUploadOut, |
| ) |
| from apps.cases.services import CaseLogService |
| from apps.cases.services.material.wiring import build_case_material_service |
| from apps.core.infrastructure.throttling import rate_limit_from_settings |
| from apps.core.security import get_request_access_context |
|
|
| router = Router() |
|
|
|
|
| def _get_case_material_service() -> Any: |
| return build_case_material_service() |
|
|
|
|
| def _get_caselog_service() -> CaseLogService: |
| return CaseLogService() |
|
|
|
|
| @router.get("/{case_id}/materials/bind-candidates", response=list[CaseMaterialBindCandidateOut]) |
| def list_bind_candidates(request: HttpRequest, case_id: int) -> Any: |
| service = _get_case_material_service() |
| ctx = get_request_access_context(request) |
| return service.list_bind_candidates( |
| case_id=case_id, |
| user=ctx.user, |
| org_access=ctx.org_access, |
| perm_open_access=ctx.perm_open_access, |
| ) |
|
|
|
|
| @router.post("/{case_id}/materials/bind") |
| @rate_limit_from_settings("TASK", by_user=True) |
| def bind_materials(request: HttpRequest, case_id: int, payload: CaseMaterialBindIn) -> dict[str, int]: |
| service = _get_case_material_service() |
| ctx = get_request_access_context(request) |
| items: list[dict[str, Any]] = [x.model_dump() for x in payload.items] |
| saved = service.bind_materials( |
| case_id=case_id, |
| items=items, |
| user=ctx.user, |
| org_access=ctx.org_access, |
| perm_open_access=ctx.perm_open_access, |
| ) |
| return {"saved_count": len(saved)} |
|
|
|
|
| @router.post("/{case_id}/materials/group-order") |
| @rate_limit_from_settings("TASK", by_user=True) |
| def save_group_order(request: HttpRequest, case_id: int, payload: CaseMaterialGroupOrderIn) -> dict[str, bool]: |
| service = _get_case_material_service() |
| ctx = get_request_access_context(request) |
| service.save_group_order( |
| case_id=case_id, |
| category=payload.category, |
| ordered_type_ids=payload.ordered_type_ids, |
| side=payload.side, |
| supervising_authority_id=payload.supervising_authority_id, |
| user=ctx.user, |
| org_access=ctx.org_access, |
| perm_open_access=ctx.perm_open_access, |
| ) |
| return {"ok": True} |
|
|
|
|
| @router.post("/{case_id}/materials/upload", response=CaseMaterialUploadOut) |
| @rate_limit_from_settings("UPLOAD", by_user=True) |
| def upload_materials(request: HttpRequest, case_id: int) -> dict[str, Any]: |
| service = _get_caselog_service() |
| ctx = get_request_access_context(request) |
| files = request.FILES.getlist("files") if hasattr(request, "FILES") else [] |
| log = service.create_log( |
| case_id=case_id, |
| content="上传材料", |
| user=ctx.user, |
| org_access=ctx.org_access, |
| perm_open_access=ctx.perm_open_access, |
| ) |
| created = service.upload_attachments( |
| log_id=log.id, |
| files=files, |
| user=ctx.user, |
| org_access=ctx.org_access, |
| perm_open_access=ctx.perm_open_access, |
| ) |
| return {"log_id": log.id, "attachment_ids": [x.id for x in created]} |
|
|
|
|
| @router.post( |
| "/{case_id}/materials/{material_id}/replace", |
| response=CaseMaterialReplaceOut, |
| ) |
| @rate_limit_from_settings("TASK", by_user=True) |
| def replace_material_file( |
| request: HttpRequest, case_id: int, material_id: int, payload: CaseMaterialReplaceIn |
| ) -> dict[str, Any]: |
| """替换材料对应的附件文件。""" |
| service = _get_case_material_service() |
| ctx = get_request_access_context(request) |
| return service.replace_material_file( |
| case_id=case_id, |
| material_id=material_id, |
| new_attachment_id=payload.new_attachment_id, |
| user=ctx.user, |
| org_access=ctx.org_access, |
| perm_open_access=ctx.perm_open_access, |
| ) |
|
|
|
|
| @router.post( |
| "/{case_id}/materials/group-rename", |
| response=CaseMaterialGroupRenameOut, |
| ) |
| @rate_limit_from_settings("TASK", by_user=True) |
| def rename_group(request: HttpRequest, case_id: int, payload: CaseMaterialGroupRenameIn) -> dict[str, Any]: |
| """重命名材料分组。""" |
| service = _get_case_material_service() |
| ctx = get_request_access_context(request) |
| return service.rename_group( |
| case_id=case_id, |
| type_id=payload.type_id, |
| new_type_name=payload.new_type_name, |
| update_global=payload.update_global, |
| user=ctx.user, |
| org_access=ctx.org_access, |
| perm_open_access=ctx.perm_open_access, |
| ) |
|
|
|
|
| @router.delete( |
| "/{case_id}/materials/{material_id}", |
| response=CaseMaterialDeleteOut, |
| ) |
| @rate_limit_from_settings("TASK", by_user=True) |
| def delete_material(request: HttpRequest, case_id: int, material_id: int) -> dict[str, Any]: |
| """删除材料绑定（附件文件不受影响）。""" |
| service = _get_case_material_service() |
| ctx = get_request_access_context(request) |
| return service.delete_material( |
| case_id=case_id, |
| material_id=material_id, |
| user=ctx.user, |
| org_access=ctx.org_access, |
| perm_open_access=ctx.perm_open_access, |
| ) |
|
|
|
|
| @router.delete( |
| "/{case_id}/materials", |
| response=CaseMaterialDeleteAllOut, |
| ) |
| @rate_limit_from_settings("TASK", by_user=True) |
| def delete_all_materials(request: HttpRequest, case_id: int, payload: CaseMaterialDeleteAllIn) -> dict[str, Any]: |
| """按分类删除案件下的所有材料。""" |
| service = _get_case_material_service() |
| ctx = get_request_access_context(request) |
| return service.delete_all_materials( |
| case_id=case_id, |
| category=payload.category, |
| user=ctx.user, |
| org_access=ctx.org_access, |
| perm_open_access=ctx.perm_open_access, |
| ) |
|
|
