From 081a109d369966182e5d6e4ff3ab38bb8512b498 Mon Sep 17 00:00:00 2001
From: zhaoqingang <zhaoqg0118@163.com>
Date: 星期三, 20 十一月 2024 15:59:01 +0800
Subject: [PATCH] 优化

---
 app/api/files.py |   21 ++++++++++++++-------
 1 files changed, 14 insertions(+), 7 deletions(-)

diff --git a/app/api/files.py b/app/api/files.py
index 12c55b0..fe80f4a 100644
--- a/app/api/files.py
+++ b/app/api/files.py
@@ -1,7 +1,7 @@
 from typing import Optional
 
 import requests
-from fastapi import Depends, APIRouter, HTTPException, UploadFile, File, Query
+from fastapi import Depends, APIRouter, HTTPException, UploadFile, File, Query, Form
 from pydantic import BaseModel
 from sqlalchemy.orm import Session
 from starlette.responses import StreamingResponse
@@ -11,9 +11,10 @@
 from app.models.agent_model import AgentType, AgentModel
 from app.models.base_model import get_db
 from app.models.user_model import UserModel
+from app.service.basic import BasicService
 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 +38,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)
@@ -58,6 +59,12 @@
             raise HTTPException(status_code=500, detail=str(e))
         result["file_name"] = file.filename
         return Response(code=200, msg="", data=result)
+    elif agent.agent_type == AgentType.BASIC:
+        if agent_id == "basic_excel_talk":
+            service = BasicService(base_url=settings.basic_base_url)
+            result = await service.excel_talk_upload(chat_id, file.filename, file_content)
+
+            return Response(code=200, msg="", data=result)
 
     else:
         return Response(code=200, msg="Unsupported agent type")
@@ -80,11 +87,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