From 5ef590b70cc8e2de16083af2ee2d977daae5587c Mon Sep 17 00:00:00 2001
From: zhaoqingang <zhaoqg0118@163.com>
Date: 星期二, 19 十一月 2024 16:34:29 +0800
Subject: [PATCH] 会话缓存本地数据库
---
app/api/files.py | 12 ++++++------
1 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/app/api/files.py b/app/api/files.py
index 12c55b0..eed49d8 100644
--- a/app/api/files.py
+++ b/app/api/files.py
@@ -13,7 +13,7 @@
from app.models.user_model import UserModel
from app.service.bisheng import BishengService
from app.service.ragflow import RagflowService
-from app.service.token import get_ragflow_token, get_bisheng_token
+from app.service.service_token import get_ragflow_token, get_bisheng_token
import urllib.parse
router = APIRouter()
@@ -37,20 +37,20 @@
if agent.agent_type == AgentType.RAGFLOW:
token = get_ragflow_token(db, current_user.id)
- ragflow_service = RagflowService(base_url=settings.ragflow_base_url)
+ ragflow_service = RagflowService(base_url=settings.fwr_base_url)
# 鏌ヨ浼氳瘽鏄惁瀛樺湪锛屼笉瀛樺湪鍏堝垱寤轰細璇�
history = await ragflow_service.get_session_history(token, chat_id)
if len(history) == 0:
message = {"role": "user", "message": file.filename}
await ragflow_service.set_session(token, agent_id, message, chat_id, True)
- ragflow_service = RagflowService(base_url=settings.ragflow_base_url)
+ ragflow_service = RagflowService(base_url=settings.fwr_base_url)
token = get_ragflow_token(db, current_user.id)
doc_ids = await ragflow_service.upload_and_parse(token, chat_id, file.filename, file_content)
return Response(code=200, msg="", data={"doc_ids": doc_ids, "file_name": file.filename})
elif agent.agent_type == AgentType.BISHENG:
- bisheng_service = BishengService(base_url=settings.bisheng_base_url)
+ bisheng_service = BishengService(base_url=settings.sgb_base_url)
try:
token = get_bisheng_token(db, current_user.id)
result = await bisheng_service.upload(token, file.filename, file_content)
@@ -80,11 +80,11 @@
# 浠� URL 涓彁鍙栨枃浠跺悕
parsed_url = urllib.parse.urlparse(url)
filename = urllib.parse.unquote(parsed_url.path.split('/')[-1])
- url = url.replace("http://minio:9000", settings.bisheng_base_url)
+ url = url.replace("http://minio:9000", settings.sgb_base_url)
elif agent.agent_type == AgentType.RAGFLOW:
if not doc_id:
return Response(code=400, msg="doc_id is required")
- url = f"{settings.ragflow_base_url}/v1/document/get/{doc_id}"
+ url = f"{settings.fwr_base_url}/v1/document/get/{doc_id}"
filename = doc_name
else:
return Response(code=400, msg="Unsupported agent type")
--
Gitblit v1.8.0