""" 项目管理API路由 """ from fastapi import APIRouter, Depends, HTTPException, status from sqlalchemy.orm import Session from typing import List from app.database import get_db from app.models.project import Project from app.schemas.project import ProjectCreate, ProjectUpdate, ProjectResponse router = APIRouter() @router.get("/", response_model=List[ProjectResponse]) async def get_projects( skip: int = 0, limit: int = 100, db: Session = Depends(get_db) ): """获取项目列表""" projects = db.query(Project).filter(Project.is_active == True).offset(skip).limit(limit).all() return projects @router.post("/", response_model=ProjectResponse, status_code=status.HTTP_201_CREATED) async def create_project( project: ProjectCreate, db: Session = Depends(get_db) ): """创建新项目""" db_project = Project(**project.dict()) db.add(db_project) db.commit() db.refresh(db_project) return db_project @router.get("/{project_id}", response_model=ProjectResponse) async def get_project( project_id: int, db: Session = Depends(get_db) ): """获取项目详情""" project = db.query(Project).filter(Project.id == project_id).first() if not project: raise HTTPException(status_code=404, detail="项目不存在") return project @router.put("/{project_id}", response_model=ProjectResponse) async def update_project( project_id: int, project_update: ProjectUpdate, db: Session = Depends(get_db) ): """更新项目信息""" project = db.query(Project).filter(Project.id == project_id).first() if not project: raise HTTPException(status_code=404, detail="项目不存在") update_data = project_update.dict(exclude_unset=True) for field, value in update_data.items(): setattr(project, field, value) db.commit() db.refresh(project) return project @router.delete("/{project_id}") async def delete_project( project_id: int, db: Session = Depends(get_db) ): """删除项目(软删除)""" project = db.query(Project).filter(Project.id == project_id).first() if not project: raise HTTPException(status_code=404, detail="项目不存在") project.is_active = False db.commit() return {"message": "项目已删除"}