feat: V1 - DAG编排/告警系统/Agent循环/知识库RAG/Webhook + 审核管理富上下文修复

This commit is contained in:
2026-08-13 00:45:49 +08:00
parent fb3b688695
commit 015609dc7b
+14 -6
View File
@@ -3,7 +3,9 @@ from fastapi import APIRouter, Depends, HTTPException
from sqlalchemy.orm import Session from sqlalchemy.orm import Session
from typing import List, Optional from typing import List, Optional
from app.database import get_db from app.database import get_db
from app.schemas.review import ReviewResponse, ReviewDecision, ReviewCreate from app.schemas.review import (
ReviewResponse, ReviewDetailResponse, ReviewDecision, ReviewCreate,
)
from app.services.review_service import ReviewService from app.services.review_service import ReviewService
from app.api.deps import get_current_user, require_roles from app.api.deps import get_current_user, require_roles
from app.core.permissions import Role from app.core.permissions import Role
@@ -12,7 +14,7 @@ from app.models.user import User
router = APIRouter(prefix="/reviews") router = APIRouter(prefix="/reviews")
@router.get("", response_model=List[ReviewResponse]) @router.get("", response_model=List[ReviewDetailResponse])
def list_reviews( def list_reviews(
status: Optional[str] = None, status: Optional[str] = None,
project_id: Optional[int] = None, project_id: Optional[int] = None,
@@ -20,7 +22,10 @@ def list_reviews(
user: User = Depends(get_current_user), user: User = Depends(get_current_user),
db: Session = Depends(get_db), db: Session = Depends(get_db),
): ):
return ReviewService.list_reviews(db, user.tenant_id, status, project_id, skip, limit) """List reviews with full context (task/project/worker/cost)."""
return ReviewService.list_reviews_detail(
db, user.tenant_id, status, project_id, skip, limit
)
@router.post("", response_model=ReviewResponse, status_code=201) @router.post("", response_model=ReviewResponse, status_code=201)
@@ -32,13 +37,14 @@ def create_review(
return ReviewService.create_review(db, user.tenant_id, req) return ReviewService.create_review(db, user.tenant_id, req)
@router.get("/{review_id}", response_model=ReviewResponse) @router.get("/{review_id}", response_model=ReviewDetailResponse)
def get_review( def get_review(
review_id: int, review_id: int,
user: User = Depends(get_current_user), user: User = Depends(get_current_user),
db: Session = Depends(get_db), db: Session = Depends(get_db),
): ):
r = ReviewService.get_review(db, user.tenant_id, review_id) """Get a single review with full context."""
r = ReviewService.get_review_detail(db, user.tenant_id, review_id)
if not r: if not r:
raise HTTPException(status_code=404, detail="Review not found") raise HTTPException(status_code=404, detail="Review not found")
return r return r
@@ -48,7 +54,9 @@ def get_review(
def make_decision( def make_decision(
review_id: int, review_id: int,
req: ReviewDecision, req: ReviewDecision,
user: User = Depends(require_roles(Role.SUPER_ADMIN, Role.TENANT_ADMIN, Role.PROJECT_MANAGER, Role.REVIEWER)), user: User = Depends(require_roles(
Role.SUPER_ADMIN, Role.TENANT_ADMIN, Role.PROJECT_MANAGER, Role.REVIEWER
)),
db: Session = Depends(get_db), db: Session = Depends(get_db),
): ):
try: try: