Karte 10: Geräte-Code für Objektpositionen (Code128-Vorbereitung) + Code-Vorschlag
objektposition.code (nullable, unique) für Geräte-Etiketten, separat von
seriennummer. Lookup-Endpunkt für Geräte-Scan (GET /objektpositionen/code/{code})
sowie Auto-Vorschlag PRAEFIX-NNN für Objekt- und Objektposition-Codes
(GET /objekte/naechster-code, GET /objektpositionen/naechster-code).
Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01CVgbozhYmuEhiEJHffRXCV
This commit is contained in:
@@ -19,7 +19,13 @@ from app.schemas.objekt import (
|
||||
ObjektpositionUpdate,
|
||||
ObjektRead,
|
||||
)
|
||||
from app.services.objekte import dupliziere_objekt, objekt_aus_vorlage, sollmenge_effektiv, sollmenge_map
|
||||
from app.services.objekte import (
|
||||
dupliziere_objekt,
|
||||
naechster_freier_code,
|
||||
objekt_aus_vorlage,
|
||||
sollmenge_effektiv,
|
||||
sollmenge_map,
|
||||
)
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
@@ -53,6 +59,53 @@ async def hole_objekt_per_code(
|
||||
return objekt
|
||||
|
||||
|
||||
@router.get("/objekte/naechster-code")
|
||||
async def naechster_objekt_code(
|
||||
praefix: str, db: AsyncSession = Depends(get_db), _=Depends(get_current_user)
|
||||
) -> dict[str, str]:
|
||||
"""Code-Vorschlag beim Anlegen/Duplizieren (Konzept-Ergänzung Karte 10/Prompt 09).
|
||||
Vorschlag ist überschreibbar, Eindeutigkeit erzwingt weiterhin objekt.code UNIQUE."""
|
||||
return {"code": await naechster_freier_code(db, Objekt.code, praefix)}
|
||||
|
||||
|
||||
@router.get("/objektpositionen/naechster-code")
|
||||
async def naechster_objektposition_code(
|
||||
praefix: str, db: AsyncSession = Depends(get_db), _=Depends(get_current_user)
|
||||
) -> dict[str, str]:
|
||||
"""Code-Vorschlag für Geräte-Exemplare (objektposition.code, eigener
|
||||
Nummernkreis je Präfix, unabhängig von objekt.code)."""
|
||||
return {"code": await naechster_freier_code(db, Objektposition.code, praefix)}
|
||||
|
||||
|
||||
@router.get("/objektpositionen/code/{code}", response_model=ObjektpositionRead)
|
||||
async def hole_objektposition_per_code(
|
||||
code: str, db: AsyncSession = Depends(get_db), _=Depends(get_current_user)
|
||||
) -> ObjektpositionRead:
|
||||
"""Geräte-Scan (Konzept-Ergänzung Karte 10/Prompt 09): Code128-Etikett am
|
||||
Exemplar identifiziert die Objektposition direkt, unabhängig vom Objekt-Code -
|
||||
löst SN-vorbelegte Kontroll-Erfassung ohne Umweg über Objekt-Scan aus."""
|
||||
result = await db.execute(select(Objektposition).where(Objektposition.code == code))
|
||||
position = result.scalar_one_or_none()
|
||||
if position is None:
|
||||
raise HTTPException(status_code=status.HTTP_404_NOT_FOUND, detail="Objektposition nicht gefunden")
|
||||
|
||||
objekt = await db.get(Objekt, position.objekt_id)
|
||||
vorlagen_sollmengen = await sollmenge_map(db, objekt.vorlage_id if objekt else None)
|
||||
return ObjektpositionRead(
|
||||
id=position.id,
|
||||
objekt_id=position.objekt_id,
|
||||
material_id=position.material_id,
|
||||
sollmenge_override=position.sollmenge_override,
|
||||
sollmenge_effektiv=sollmenge_effektiv(position, vorlagen_sollmengen),
|
||||
ist_status=position.ist_status,
|
||||
istmenge=position.istmenge,
|
||||
seriennummer=position.seriennummer,
|
||||
ablaufdatum=position.ablaufdatum,
|
||||
chargennummer=position.chargennummer,
|
||||
code=position.code,
|
||||
)
|
||||
|
||||
|
||||
@router.get("/objekte/{objekt_id}", response_model=ObjektRead)
|
||||
async def hole_objekt(
|
||||
objekt_id: int, db: AsyncSession = Depends(get_db), _=Depends(get_current_user)
|
||||
@@ -86,6 +139,7 @@ async def liste_objektpositionen(
|
||||
seriennummer=p.seriennummer,
|
||||
ablaufdatum=p.ablaufdatum,
|
||||
chargennummer=p.chargennummer,
|
||||
code=p.code,
|
||||
)
|
||||
for p in positionen
|
||||
]
|
||||
@@ -176,6 +230,7 @@ async def aendere_objektposition(
|
||||
seriennummer=position.seriennummer,
|
||||
ablaufdatum=position.ablaufdatum,
|
||||
chargennummer=position.chargennummer,
|
||||
code=position.code,
|
||||
)
|
||||
|
||||
|
||||
@@ -219,4 +274,5 @@ async def fuege_zusatzposition_hinzu(
|
||||
seriennummer=position.seriennummer,
|
||||
ablaufdatum=position.ablaufdatum,
|
||||
chargennummer=position.chargennummer,
|
||||
code=position.code,
|
||||
)
|
||||
|
||||
@@ -39,3 +39,7 @@ class Objektposition(Base):
|
||||
seriennummer: Mapped[str | None] = mapped_column(String)
|
||||
ablaufdatum: Mapped[date | None] = mapped_column(Date)
|
||||
chargennummer: Mapped[str | None] = mapped_column(String)
|
||||
# Code128-Etikett für Geräte-Exemplare (Konzept-Ergänzung Karte 10/Prompt 09),
|
||||
# separat von seriennummer: Code identifiziert das gedruckte Label, SN das
|
||||
# Herstellerattribut - beide können divergieren (Etikett verloren/neu vergeben).
|
||||
code: Mapped[str | None] = mapped_column(String, unique=True)
|
||||
|
||||
@@ -45,6 +45,7 @@ class ObjektpositionRead(BaseModel):
|
||||
seriennummer: str | None
|
||||
ablaufdatum: date | None
|
||||
chargennummer: str | None
|
||||
code: str | None
|
||||
|
||||
|
||||
class ObjektpositionUpdate(BaseModel):
|
||||
@@ -54,6 +55,7 @@ class ObjektpositionUpdate(BaseModel):
|
||||
seriennummer: str | None = None
|
||||
ablaufdatum: date | None = None
|
||||
chargennummer: str | None = None
|
||||
code: str | None = None
|
||||
|
||||
|
||||
class ObjektpositionCreate(BaseModel):
|
||||
|
||||
@@ -1,3 +1,4 @@
|
||||
import re
|
||||
from decimal import Decimal
|
||||
|
||||
from sqlalchemy import select
|
||||
@@ -7,6 +8,26 @@ from app.models.objekt import Objekt
|
||||
from app.models.objektposition import Objektposition, ObjektpositionStatus
|
||||
from app.models.vorlage import Beladungsvorlage, Vorlagenposition
|
||||
|
||||
_CODE_MUSTER = re.compile(r"^-(\d+)$")
|
||||
|
||||
|
||||
async def naechster_freier_code(db: AsyncSession, spalte, praefix: str) -> str:
|
||||
"""Konzept-Ergänzung Karte 10/Prompt 09: Code-Vorschlag PRAEFIX-NNN mit
|
||||
fortlaufender Nummer je Präfix. Zahlenbreite folgt der bisher größten
|
||||
vergebenen Nummer (mind. 5 Stellen bei Erstvergabe), damit die Sortierung im
|
||||
Regal stabil bleibt, solange nicht mehr als 10^Breite Objekte existieren."""
|
||||
result = await db.execute(select(spalte).where(spalte.like(f"{praefix}-%")))
|
||||
hoechste = 0
|
||||
breite = 5
|
||||
for (code,) in result.all():
|
||||
treffer = _CODE_MUSTER.match(code[len(praefix) :])
|
||||
if treffer is None:
|
||||
continue
|
||||
zahl = treffer.group(1)
|
||||
breite = max(breite, len(zahl))
|
||||
hoechste = max(hoechste, int(zahl))
|
||||
return f"{praefix}-{hoechste + 1:0{breite}d}"
|
||||
|
||||
|
||||
async def sollmenge_map(db: AsyncSession, vorlage_id: int | None) -> dict[int, Decimal]:
|
||||
"""material_id -> Sollmenge laut Vorlage (Prompt 10: Basis für die dynamische
|
||||
|
||||
Reference in New Issue
Block a user