From 80978b3aec0e7f7a89d3ad671a9c0869c187be7c Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期四, 17 十月 2024 14:19:18 +0800
Subject: [PATCH] 解决知识问题不响应问题,解决解析错误问题

---
 app/service/bisheng.py |   13 +++++++++----
 1 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/app/service/bisheng.py b/app/service/bisheng.py
index e263c65..e7c92fa 100644
--- a/app/service/bisheng.py
+++ b/app/service/bisheng.py
@@ -16,7 +16,13 @@
         status_code = response_data.get("status_code", 0)
         if status_code != 200:
             raise Exception(f"Failed to fetch data from Bisheng API: {response.text}")
-        return response_data.get("data", {})
+        # 妫�鏌ヨ繑鍥炵殑鏁版嵁绫诲瀷
+        if isinstance(response_data.get("data"), dict):
+            return response_data.get("data", {})
+        elif isinstance(response_data.get("data"), list):
+            return response_data.get("data", [])
+        else:
+            return {}
 
     async def register(self, username: str, password: str):
         public_key = await self.get_public_key_api()
@@ -75,13 +81,12 @@
             data = self._check_response(response)
             return data
 
-    async def upload(self, token: str, file: bytes) -> dict:
+    async def upload(self, token: str, filename: str, file: bytes) -> dict:
         url = f"{self.base_url}/api/v1/knowledge/upload"
         headers = {'cookie': f"access_token_cookie={token};"}
 
         # 鍒涘缓琛ㄥ崟鏁版嵁锛屽寘鍚枃浠�
-        files = {"file": ("file", file)}  # 浣跨敤榛樿鏂囦欢鍚� "file"
-
+        files = {"file": (filename, file)}
         async with httpx.AsyncClient() as client:
             response = await client.post(url, headers=headers, files=files)
             data = self._check_response(response)

--
Gitblit v1.8.0