mirror of
https://github.com/complexcaresolutions/dak.c2s.git
synced 2026-03-17 21:53:41 +00:00
CCS Admin
d6fb04d5a7
- Add coding_service.py with queue retrieval, single + batch coding updates
- Add report schemas (DashboardKPIs, WeeklyDataPoint, ReportMeta)
- Add coding API router with /queue, PUT /{case_id}, POST /batch endpoints
- Add reports API router with /dashboard, /weekly, /generate, /download, /list
- Add excel_sync.py for bidirectional Abrechnung DB<->XLSX sync
- Register coding and reports routers in main.py
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
78 lines
2.2 KiB
Python
78 lines
2.2 KiB
Python
"""Coding queue API — dedicated endpoints for Gutachten classification workflow."""
|
|
|
|
from fastapi import APIRouter, Depends, Query
|
|
from sqlalchemy.orm import Session
|
|
|
|
from app.core.dependencies import require_admin
|
|
from app.database import get_db
|
|
from app.models.user import User
|
|
from app.schemas.case import CaseListResponse, CaseResponse, CodingUpdate
|
|
from app.services.coding_service import (
|
|
batch_update_coding,
|
|
get_coding_queue,
|
|
update_coding,
|
|
)
|
|
|
|
router = APIRouter()
|
|
|
|
|
|
@router.get("/queue", response_model=CaseListResponse)
|
|
def coding_queue(
|
|
fallgruppe: str | None = Query(None),
|
|
page: int = Query(1, ge=1),
|
|
per_page: int = Query(50, ge=1, le=200),
|
|
db: Session = Depends(get_db),
|
|
user: User = Depends(require_admin),
|
|
):
|
|
"""Return cases that need coding (gutachten=True, gutachten_typ=NULL).
|
|
|
|
Admin only. Supports optional fallgruppe filter and pagination.
|
|
"""
|
|
cases, total = get_coding_queue(db, fallgruppe, page, per_page)
|
|
return CaseListResponse(
|
|
items=[CaseResponse.model_validate(c) for c in cases],
|
|
total=total,
|
|
page=page,
|
|
per_page=per_page,
|
|
)
|
|
|
|
|
|
@router.put("/{case_id}", response_model=CaseResponse)
|
|
def update_case_coding(
|
|
case_id: int,
|
|
data: CodingUpdate,
|
|
db: Session = Depends(get_db),
|
|
user: User = Depends(require_admin),
|
|
):
|
|
"""Set Gutachten classification and therapy-change coding for a single case.
|
|
|
|
Admin only. Validates gutachten_typ and therapieaenderung values.
|
|
"""
|
|
case = update_coding(
|
|
db,
|
|
case_id,
|
|
data.gutachten_typ,
|
|
data.therapieaenderung,
|
|
data.ta_diagnosekorrektur,
|
|
data.ta_unterversorgung,
|
|
data.ta_uebertherapie,
|
|
user_id=user.id,
|
|
)
|
|
return CaseResponse.model_validate(case)
|
|
|
|
|
|
@router.post("/batch")
|
|
def batch_coding(
|
|
updates: list[dict],
|
|
db: Session = Depends(get_db),
|
|
user: User = Depends(require_admin),
|
|
):
|
|
"""Batch update coding for multiple cases at once.
|
|
|
|
Admin only. Accepts a list of dicts, each containing at minimum:
|
|
``case_id``, ``gutachten_typ``, ``therapieaenderung``.
|
|
|
|
Returns a summary with ``updated`` count and ``errors`` list.
|
|
"""
|
|
result = batch_update_coding(db, updates, user_id=user.id)
|
|
return result
|