From c941b948f1fa8eff615985a83110a401ae426ab3 Mon Sep 17 00:00:00 2001 From: zhaoqingang <zhaoqg0118@163.com> Date: 星期三, 18 十二月 2024 11:03:49 +0800 Subject: [PATCH] 知识库和智能体同步 --- app/api/knowledge.py | 25 +++++++++++++++++++++---- 1 files changed, 21 insertions(+), 4 deletions(-) diff --git a/app/api/knowledge.py b/app/api/knowledge.py index c50464f..5b0a4f4 100644 --- a/app/api/knowledge.py +++ b/app/api/knowledge.py @@ -5,7 +5,8 @@ from app.models import klgParameter from app.models.base_model import get_db from app.models.user_model import UserModel -from app.service.knowledge import get_knowledge_list, create_knowledge_service +from app.service.knowledge import get_knowledge_list, create_knowledge_service, sync_knowledge_service, \ + delete_knowledge_service from typing import Optional knowledge_router = APIRouter() @@ -30,8 +31,8 @@ async def create_knowledge_api(klg: klgParameter, current_user: UserModel = Depends(get_current_user), db=Depends(get_db)): is_create = await create_knowledge_service(db, klg.id, klg.name, klg.description, klg.icon, klg.klgType, current_user.id) if not is_create: - return Response(code=500, msg="role create failure", data={}) - return Response(code=200, msg="role create success", data={}) + return Response(code=500, msg="role knowledge failure", data={}) + return Response(code=200, msg="role knowledge success", data={}) @knowledge_router.get("/update", response_model=Response) @@ -39,4 +40,20 @@ # is_create = await update_dialog_status_service(db, dialog.id, dialog.status) # if not is_create: # return Response(code=500, msg="dialog update failure", data={}) - return Response(code=200, msg="dialog update success", data={}) \ No newline at end of file + return Response(code=200, msg="knowledge update success", data={}) + + +@knowledge_router.get("/sync", response_model=Response) +async def sync_knowledge_api(knowledgeId: str, current_user: UserModel = Depends(get_current_user), db=Depends(get_db)): + is_create = await sync_knowledge_service(db, knowledgeId) + if not is_create: + return Response(code=500, msg="knowledge update failure", data={}) + return Response(code=200, msg="knowledge update success", data={}) + + +@knowledge_router.get("/delete", response_model=Response) +async def sync_knowledge_api(knowledgeId: str, current_user: UserModel = Depends(get_current_user), db=Depends(get_db)): + is_delete = await delete_knowledge_service(db, knowledgeId) + if not is_delete: + return Response(code=500, msg="knowledge delete failure", data={}) + return Response(code=200, msg="knowledge delete success", data={}) \ No newline at end of file -- Gitblit v1.8.0