From 8ad3579408a912d00996ffba55dc0a931b7a36af Mon Sep 17 00:00:00 2001 From: huangzhuang_3rd Date: Wed, 12 Aug 2026 13:30:34 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20AI=20Worker=20=E5=B9=B3=E5=8F=B0=20MVP?= =?UTF-8?q?=20v1.0.0=20-=20=E5=A4=9A=E7=A7=9F=E6=88=B7/=E9=A1=B9=E7=9B=AE?= =?UTF-8?q?=E7=AE=A1=E7=90=86/AI=20Worker/=E4=BB=BB=E5=8A=A1=E7=BC=96?= =?UTF-8?q?=E6=8E=92/HITL=E5=AE=A1=E6=A0=B8/=E6=88=90=E6=9C=AC=E6=B2=BB?= =?UTF-8?q?=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- backend/app/api/v1/tenants.py | 60 +++++++++++++++++++++++++++++++++++ 1 file changed, 60 insertions(+) create mode 100644 backend/app/api/v1/tenants.py diff --git a/backend/app/api/v1/tenants.py b/backend/app/api/v1/tenants.py new file mode 100644 index 0000000..c0f5f6b --- /dev/null +++ b/backend/app/api/v1/tenants.py @@ -0,0 +1,60 @@ +"""Tenant management endpoints.""" +from fastapi import APIRouter, Depends, HTTPException +from sqlalchemy.orm import Session +from typing import List +from app.database import get_db +from app.schemas.tenant import TenantCreate, TenantUpdate, TenantResponse +from app.services.tenant_service import TenantService +from app.api.deps import get_current_user, require_roles +from app.core.permissions import Role +from app.models.user import User + +router = APIRouter(prefix="/tenants") + + +@router.get("", response_model=List[TenantResponse]) +def list_tenants( + skip: int = 0, limit: int = 100, + user: User = Depends(require_roles(Role.SUPER_ADMIN)), + db: Session = Depends(get_db), +): + return TenantService.list_tenants(db, skip, limit) + + +@router.post("", response_model=TenantResponse) +def create_tenant( + req: TenantCreate, + user: User = Depends(require_roles(Role.SUPER_ADMIN)), + db: Session = Depends(get_db), +): + try: + return TenantService.create_tenant(db, req) + except ValueError as e: + raise HTTPException(status_code=409, detail=str(e)) + + +@router.get("/{tenant_id}", response_model=TenantResponse) +def get_tenant( + tenant_id: int, + user: User = Depends(get_current_user), + db: Session = Depends(get_db), +): + if user.role != Role.SUPER_ADMIN.value and user.tenant_id != tenant_id: + raise HTTPException(status_code=403, detail="Cannot access other tenants") + t = TenantService.get_tenant(db, tenant_id) + if not t: + raise HTTPException(status_code=404, detail="Tenant not found") + return t + + +@router.put("/{tenant_id}", response_model=TenantResponse) +def update_tenant( + tenant_id: int, + req: TenantUpdate, + user: User = Depends(require_roles(Role.SUPER_ADMIN, Role.TENANT_ADMIN)), + db: Session = Depends(get_db), +): + try: + return TenantService.update_tenant(db, tenant_id, req) + except ValueError as e: + raise HTTPException(status_code=404, detail=str(e))