rene
dee8d10496
- Tierarzt-Adresse: strasse / plz / ort statt einzeiligem Freitext - Modal: Rand in Primärfarbe + kein versehentliches Schließen beim Klick auf Hintergrund - Nav/Sidebar-Icons: inaktiv gedämpft, aktiv amber-getönt (CSS filter) - Datums-Kalender-Icon: ebenfalls amber statt Schwarz - SW-Cache → by-v8
95 lines
3.5 KiB
Python
95 lines
3.5 KiB
Python
"""BAN YARO — Tierärzte Routes (user-level, nie löschen)"""
|
|
|
|
from fastapi import APIRouter, Depends, HTTPException
|
|
from pydantic import BaseModel
|
|
from typing import Optional
|
|
from database import db
|
|
from auth import get_current_user
|
|
|
|
router = APIRouter()
|
|
|
|
|
|
class TierarztCreate(BaseModel):
|
|
name: str
|
|
strasse: Optional[str] = None
|
|
plz: Optional[str] = None
|
|
ort: Optional[str] = None
|
|
telefon: Optional[str] = None
|
|
notfall_telefon: Optional[str] = None
|
|
email: Optional[str] = None
|
|
website: Optional[str] = None
|
|
notizen: Optional[str] = None
|
|
ist_notfallpraxis: bool = False
|
|
|
|
|
|
class TierarztUpdate(BaseModel):
|
|
name: Optional[str] = None
|
|
strasse: Optional[str] = None
|
|
plz: Optional[str] = None
|
|
ort: Optional[str] = None
|
|
telefon: Optional[str] = None
|
|
notfall_telefon: Optional[str] = None
|
|
email: Optional[str] = None
|
|
website: Optional[str] = None
|
|
notizen: Optional[str] = None
|
|
ist_notfallpraxis: Optional[bool] = None
|
|
aktiv: Optional[bool] = None # False = inaktiv (Umzug etc.)
|
|
|
|
|
|
@router.get("")
|
|
async def list_tieraerzte(user=Depends(get_current_user)):
|
|
"""Alle Tierärzte des Users — aktive zuerst, dann inaktive (für Historienansicht)."""
|
|
with db() as conn:
|
|
rows = conn.execute(
|
|
"SELECT * FROM tieraerzte WHERE user_id=? ORDER BY aktiv DESC, name",
|
|
(user["id"],)
|
|
).fetchall()
|
|
return [dict(r) for r in rows]
|
|
|
|
|
|
@router.post("", status_code=201)
|
|
async def create_tierarzt(data: TierarztCreate, user=Depends(get_current_user)):
|
|
with db() as conn:
|
|
conn.execute(
|
|
"""INSERT INTO tieraerzte
|
|
(user_id, name, strasse, plz, ort, telefon, notfall_telefon,
|
|
email, website, notizen, ist_notfallpraxis)
|
|
VALUES (?,?,?,?,?,?,?,?,?,?,?)""",
|
|
(user["id"], data.name, data.strasse, data.plz, data.ort,
|
|
data.telefon, data.notfall_telefon, data.email, data.website,
|
|
data.notizen, int(data.ist_notfallpraxis))
|
|
)
|
|
row = conn.execute(
|
|
"SELECT * FROM tieraerzte WHERE user_id=? ORDER BY id DESC LIMIT 1",
|
|
(user["id"],)
|
|
).fetchone()
|
|
return dict(row)
|
|
|
|
|
|
@router.patch("/{tierarzt_id}")
|
|
async def update_tierarzt(tierarzt_id: int, data: TierarztUpdate,
|
|
user=Depends(get_current_user)):
|
|
with db() as conn:
|
|
entry = conn.execute(
|
|
"SELECT id FROM tieraerzte WHERE id=? AND user_id=?",
|
|
(tierarzt_id, user["id"])
|
|
).fetchone()
|
|
if not entry:
|
|
raise HTTPException(404, "Tierarzt nicht gefunden.")
|
|
|
|
updates = {k: v for k, v in data.model_dump().items() if v is not None}
|
|
if "ist_notfallpraxis" in updates:
|
|
updates["ist_notfallpraxis"] = int(updates["ist_notfallpraxis"])
|
|
if "aktiv" in updates:
|
|
updates["aktiv"] = int(updates["aktiv"])
|
|
if not updates:
|
|
row = conn.execute("SELECT * FROM tieraerzte WHERE id=?", (tierarzt_id,)).fetchone()
|
|
return dict(row)
|
|
|
|
set_clause = ", ".join(f"{k}=?" for k in updates)
|
|
conn.execute(
|
|
f"UPDATE tieraerzte SET {set_clause} WHERE id=?",
|
|
list(updates.values()) + [tierarzt_id]
|
|
)
|
|
row = conn.execute("SELECT * FROM tieraerzte WHERE id=?", (tierarzt_id,)).fetchone()
|
|
return dict(row)
|