LQAdminPlatform/src/views/snippet_view.py

"""
知识片段视图路由
"""
from fastapi import APIRouter, Depends, Query, Path, Body
from typing import Optional

from app.services.snippet_service import snippet_service
from app.schemas.base import ResponseSchema, PaginatedResponseSchema
from app.services.jwt_token import verify_token
from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials
from pydantic import BaseModel

router = APIRouter(prefix="/document/snippet", tags=["样本中心-知识片段"])
security = HTTPBearer()

# Schemas
class SnippetCreate(BaseModel):
    collection_name: str
    doc_name: str = "手动添加"
    content: str
    meta_info: Optional[str] = None

class SnippetUpdate(BaseModel):
    collection_name: str
    doc_name: Optional[str] = None
    content: str

@router.get("", response_model=PaginatedResponseSchema)
async def get_snippets(
    page: int = Query(1, ge=1),
    page_size: int = Query(10, ge=1),
    kb: Optional[str] = Query(None, description="知识库集合名称"),
    keyword: Optional[str] = Query(None),
    status: Optional[str] = Query(None),
    credentials: HTTPAuthorizationCredentials = Depends(security)
):
    """获取知识片段列表 (跨集合查询)"""
    items, meta = snippet_service.get_list(page, page_size, kb, keyword, status)
    
    return PaginatedResponseSchema(
        code=0, 
        message="获取成功", 
        data=items, 
        meta=meta
    )

@router.post("", response_model=ResponseSchema)
async def create_snippet(
    payload: SnippetCreate,
    credentials: HTTPAuthorizationCredentials = Depends(security)
):
    """创建知识片段"""
    payload_token = verify_token(credentials.credentials)
    if not payload_token:
        return ResponseSchema(code=401, message="无效的访问令牌")

    data = snippet_service.create(payload)
    return ResponseSchema(code=0, message="创建成功", data=data)

@router.post("/{id}", response_model=ResponseSchema)
async def update_snippet(
    id: str,
    payload: SnippetUpdate,
    credentials: HTTPAuthorizationCredentials = Depends(security)
):
    """更新知识片段"""
    payload_token = verify_token(credentials.credentials)
    if not payload_token:
        return ResponseSchema(code=401, message="无效的访问令牌")

    msg = snippet_service.update(id, payload)
    return ResponseSchema(code=0, message=msg)

@router.post("/{id}/delete", response_model=ResponseSchema)
async def delete_snippet(
    id: str, 
    kb: str = Query(..., description="知识库名称"), 
    credentials: HTTPAuthorizationCredentials = Depends(security)
):
    """删除知识片段"""
    payload_token = verify_token(credentials.credentials)
    if not payload_token:
        return ResponseSchema(code=401, message="无效的访问令牌")
        
    snippet_service.delete(id, kb)
    return ResponseSchema(code=0, message="删除成功")