114 lines
3.3 KiB
Python
114 lines
3.3 KiB
Python
from __future__ import annotations
|
|
|
|
import json
|
|
|
|
from fastapi import APIRouter, Depends, Query
|
|
from sqlalchemy.ext.asyncio import AsyncSession
|
|
|
|
from app.dependencies import get_admin_user, get_db
|
|
from app.models.user import User
|
|
from app.schemas.team import TeamCreate, TeamListOut, TeamOptionOut, TeamOut, TeamUpdate
|
|
from app.services.operation_log import log_operation
|
|
from app.services.team_service import create_team, list_team_options, list_teams, soft_delete_team, update_team
|
|
|
|
router = APIRouter(prefix="/admin/teams", tags=["admin-teams"])
|
|
|
|
|
|
@router.get("", response_model=TeamListOut)
|
|
async def list_admin_teams(
|
|
page: int = Query(1, ge=1),
|
|
page_size: int = Query(20, ge=1, le=500),
|
|
keyword: str | None = Query(None),
|
|
status: str | None = Query(None, pattern="^(active|disabled)$"),
|
|
admin: User = Depends(get_admin_user),
|
|
db: AsyncSession = Depends(get_db),
|
|
):
|
|
return await list_teams(db, page=page, page_size=page_size, keyword=keyword, status=status)
|
|
|
|
|
|
@router.get("/options", response_model=list[TeamOptionOut])
|
|
async def list_admin_team_options(
|
|
include_disabled: bool = Query(True),
|
|
admin: User = Depends(get_admin_user),
|
|
db: AsyncSession = Depends(get_db),
|
|
):
|
|
return await list_team_options(db, include_disabled=include_disabled)
|
|
|
|
|
|
@router.post("", response_model=TeamOut)
|
|
async def create_admin_team(
|
|
req: TeamCreate,
|
|
admin: User = Depends(get_admin_user),
|
|
db: AsyncSession = Depends(get_db),
|
|
):
|
|
team = await create_team(db, req)
|
|
await log_operation(
|
|
db,
|
|
admin.id,
|
|
admin.username,
|
|
f"创建团队 {team.name}",
|
|
"POST",
|
|
"/admin/teams",
|
|
detail=json.dumps({"after": req.model_dump()}, ensure_ascii=False),
|
|
)
|
|
return {
|
|
"id": team.id,
|
|
"name": team.name,
|
|
"code": team.code,
|
|
"description": team.description,
|
|
"status": team.status,
|
|
"sort_order": team.sort_order,
|
|
"member_count": 0,
|
|
"created_at": team.created_at,
|
|
"updated_at": team.updated_at,
|
|
}
|
|
|
|
|
|
@router.put("/{team_id}", response_model=TeamOut)
|
|
async def update_admin_team(
|
|
team_id: str,
|
|
req: TeamUpdate,
|
|
admin: User = Depends(get_admin_user),
|
|
db: AsyncSession = Depends(get_db),
|
|
):
|
|
team, before, after = await update_team(db, team_id, req)
|
|
await log_operation(
|
|
db,
|
|
admin.id,
|
|
admin.username,
|
|
f"修改团队 {team.name}",
|
|
"PUT",
|
|
f"/admin/teams/{team_id}",
|
|
detail=json.dumps({"before": before, "after": after}, ensure_ascii=False),
|
|
)
|
|
return {
|
|
"id": team.id,
|
|
"name": team.name,
|
|
"code": team.code,
|
|
"description": team.description,
|
|
"status": team.status,
|
|
"sort_order": team.sort_order,
|
|
"member_count": 0,
|
|
"created_at": team.created_at,
|
|
"updated_at": team.updated_at,
|
|
}
|
|
|
|
|
|
@router.delete("/{team_id}")
|
|
async def delete_admin_team(
|
|
team_id: str,
|
|
admin: User = Depends(get_admin_user),
|
|
db: AsyncSession = Depends(get_db),
|
|
):
|
|
team, before = await soft_delete_team(db, team_id)
|
|
await log_operation(
|
|
db,
|
|
admin.id,
|
|
admin.username,
|
|
f"删除团队 {team.name}",
|
|
"DELETE",
|
|
f"/admin/teams/{team_id}",
|
|
detail=json.dumps({"before": before, "after": {"deleted_at": str(team.deleted_at)}}, ensure_ascii=False),
|
|
)
|
|
return {"message": "ok"}
|