first commit
This commit is contained in:
commit
f51a0657f1
12 files changed
+327
No files matched your search
@@ -0,0 +1 @@
|
||||
# Package init for routers
|
||||
@@ -0,0 +1,35 @@
|
||||
from fastapi import APIRouter, Depends, HTTPException, status
|
||||
from sqlalchemy.orm import Session
|
||||
from ..database import get_db
|
||||
from .. import models
|
||||
from typing import List
|
||||
from pydantic import BaseModel
|
||||
router = APIRouter()
|
||||
class ClientCreate(BaseModel):
|
||||
name: str
|
||||
class ClientOut(ClientCreate):
|
||||
id: int
|
||||
class Config:
|
||||
orm_mode = True
|
||||
@router.post("/", response_model=ClientOut, status_code=status.HTTP_201_CREATED)
|
||||
def create_client(client: ClientCreate, db: Session = Depends(get_db)):
|
||||
db_client = models.Client(name=client.name)
|
||||
db.add(db_client)
|
||||
try:
|
||||
db.commit()
|
||||
db.refresh(db_client)
|
||||
except Exception as e:
|
||||
db.rollback()
|
||||
raise HTTPException(status_code=400, detail=str(e))
|
||||
return db_client
|
||||
@router.get("/", response_model=List[ClientOut])
|
||||
def list_clients(skip: int = 0, limit: int = 100, db: Session = Depends(get_db)):
|
||||
clients = db.query(models.Client).offset(skip).limit(limit).all()
|
||||
return clients
|
||||
@router.get("/{client_id}", response_model=ClientOut)
|
||||
def get_client(client_id: int, db: Session = Depends(get_db)):
|
||||
client = db.query(models.Client).filter(models.Client.id == client_id).first()
|
||||
if not client:
|
||||
raise HTTPException(status_code=404, detail="Client not found")
|
||||
return client
|
||||
|
||||
@@ -0,0 +1,46 @@
|
||||
from fastapi import APIRouter, Depends, HTTPException, status
|
||||
from sqlalchemy.orm import Session
|
||||
from ..database import get_db
|
||||
from .. import models
|
||||
from typing import List
|
||||
from pydantic import BaseModel
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
class ProviderCreate(BaseModel):
|
||||
name: str
|
||||
photo_url: str | None = None
|
||||
# No hourly_rate; services will be added separately
|
||||
class ProviderOut(ProviderCreate):
|
||||
id: int
|
||||
class Config:
|
||||
orm_mode = True
|
||||
|
||||
@router.post("/", response_model=ProviderOut, status_code=status.HTTP_201_CREATED)
|
||||
def create_provider(provider: ProviderCreate, db: Session = Depends(get_db)):
|
||||
db_provider = models.Provider(
|
||||
name=provider.name,
|
||||
photo_url=provider.photo_url,
|
||||
)
|
||||
db.add(db_provider)
|
||||
try:
|
||||
db.commit()
|
||||
db.refresh(db_provider)
|
||||
except Exception as e:
|
||||
db.rollback()
|
||||
raise HTTPException(status_code=400, detail=str(e))
|
||||
return db_provider
|
||||
|
||||
@router.get("/", response_model=List[ProviderOut])
|
||||
def list_providers(skip: int = 0, limit: int = 100, db: Session = Depends(get_db)):
|
||||
providers = db.query(models.Provider).offset(skip).limit(limit).all()
|
||||
return providers
|
||||
|
||||
@router.get("/{provider_id}", response_model=ProviderOut)
|
||||
def get_provider(provider_id: int, db: Session = Depends(get_db)):
|
||||
provider = db.query(models.Provider).filter(models.Provider.id == provider_id).first()
|
||||
if not provider:
|
||||
raise HTTPException(status_code=404, detail="Provider not found")
|
||||
return provider
|
||||
|
||||
|
||||
@@ -0,0 +1,52 @@
|
||||
from fastapi import APIRouter, Depends, HTTPException, status
|
||||
from sqlalchemy.orm import Session
|
||||
from ..database import get_db
|
||||
from .. import models
|
||||
from typing import List
|
||||
from pydantic import BaseModel
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
class ServiceCreate(BaseModel):
|
||||
provider_id: int
|
||||
name: str
|
||||
price: float
|
||||
duration_minutes: int | None = None
|
||||
|
||||
class ServiceOut(ServiceCreate):
|
||||
id: int
|
||||
class Config:
|
||||
orm_mode = True
|
||||
|
||||
@router.post("/", response_model=ServiceOut, status_code=status.HTTP_201_CREATED)
|
||||
def create_service(service: ServiceCreate, db: Session = Depends(get_db)):
|
||||
# Verify provider exists
|
||||
provider = db.query(models.Provider).filter(models.Provider.id == service.provider_id).first()
|
||||
if not provider:
|
||||
raise HTTPException(status_code=404, detail="Provider not found")
|
||||
db_service = models.Service(
|
||||
provider_id=service.provider_id,
|
||||
name=service.name,
|
||||
price=service.price,
|
||||
duration_minutes=service.duration_minutes,
|
||||
)
|
||||
db.add(db_service)
|
||||
try:
|
||||
db.commit()
|
||||
db.refresh(db_service)
|
||||
except Exception as e:
|
||||
db.rollback()
|
||||
raise HTTPException(status_code=400, detail=str(e))
|
||||
return db_service
|
||||
|
||||
@router.get("/", response_model=List[ServiceOut])
|
||||
def list_services(skip: int = 0, limit: int = 100, db: Session = Depends(get_db)):
|
||||
services = db.query(models.Service).offset(skip).limit(limit).all()
|
||||
return services
|
||||
|
||||
@router.get("/{service_id}", response_model=ServiceOut)
|
||||
def get_service(service_id: int, db: Session = Depends(get_db)):
|
||||
service = db.query(models.Service).filter(models.Service.id == service_id).first()
|
||||
if not service:
|
||||
raise HTTPException(status_code=404, detail="Service not found")
|
||||
return service
|
||||
@@ -0,0 +1,53 @@
|
||||
from fastapi import APIRouter, Depends, HTTPException, status
|
||||
from sqlalchemy.orm import Session
|
||||
from ..database import get_db
|
||||
from .. import models
|
||||
from typing import List
|
||||
from pydantic import BaseModel
|
||||
from datetime import datetime
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
class VisitCreate(BaseModel):
|
||||
provider_id: int
|
||||
client_id: int
|
||||
start_time: str | None = None
|
||||
duration_minutes: int
|
||||
|
||||
class VisitOut(VisitCreate):
|
||||
id: int
|
||||
|
||||
class Config:
|
||||
orm_mode = True
|
||||
|
||||
@router.post("/", response_model=VisitOut, status_code=status.HTTP_201_CREATED)
|
||||
def create_visit(visit: VisitCreate, db: Session = Depends(get_db)):
|
||||
# Convert ISO string to datetime
|
||||
start_dt = datetime.fromisoformat(visit.start_time) if visit.start_time else None
|
||||
db_visit = models.Visit(
|
||||
provider_id=visit.provider_id,
|
||||
client_id=visit.client_id,
|
||||
start_time=start_dt,
|
||||
duration_minutes=visit.duration_minutes,
|
||||
)
|
||||
db.add(db_visit)
|
||||
try:
|
||||
db.commit()
|
||||
db.refresh(db_visit)
|
||||
except Exception as e:
|
||||
db.rollback()
|
||||
raise HTTPException(status_code=400, detail=str(e))
|
||||
return db_visit
|
||||
|
||||
@router.get("/", response_model=List[VisitOut])
|
||||
def list_visits(skip: int = 0, limit: int = 100, db: Session = Depends(get_db)):
|
||||
visits = db.query(models.Visit).offset(skip).limit(limit).all()
|
||||
return visits
|
||||
|
||||
@router.get("/{visit_id}", response_model=VisitOut)
|
||||
def get_visit(visit_id: int, db: Session = Depends(get_db)):
|
||||
visit = db.query(models.Visit).filter(models.Visit.id == visit_id).first()
|
||||
if not visit:
|
||||
raise HTTPException(status_code=404, detail="Visit not found")
|
||||
return visit
|
||||
|
||||
Reference in new issue
Block a user