From 93f9d6fc8738c579cb815084654f6663debd80ae Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期五, 15 十一月 2024 15:51:59 +0800
Subject: [PATCH] 对话列表过滤name空数据

---
 app/service/bisheng.py |   30 ++++++++++++++++++++++++++++--
 1 files changed, 28 insertions(+), 2 deletions(-)

diff --git a/app/service/bisheng.py b/app/service/bisheng.py
index ad5d084..863491e 100644
--- a/app/service/bisheng.py
+++ b/app/service/bisheng.py
@@ -56,8 +56,8 @@
             data = self._check_response(response)
             return data.get('public_key')
 
-    async def get_chat_sessions(self, token: str) -> list:
-        url = f"{self.base_url}/api/v1/chat/list?page=1&limit=40"
+    async def get_chat_sessions(self, token: str, page: int = 1, limit: int=100) -> list:
+        url = f"{self.base_url}/api/v1/chat/list?page={page}&limit={limit}"
         headers = {'cookie': f"access_token_cookie={token};"}
         async with httpx.AsyncClient() as client:
             response = await client.get(url, headers=headers)
@@ -70,9 +70,35 @@
                     "updated_time": int(datetime.strptime(item["update_time"], "%Y-%m-%dT%H:%M:%S").timestamp() * 1000)
                 }
                 for item in data
+                if
+                "latest_message" in item and "message" in item["latest_message"] and item["latest_message"]["message"]
             ]
             return result
 
+    async def get_session_log(self, token: str, agent_id: str, conversation_id: str):
+        url = (
+            f"{self.base_url}/api/v1/chat/history?"
+            f"flow_id={agent_id}&"
+            f"chat_id={conversation_id}&page_size=30&id="
+        )
+        headers = {'cookie': f"access_token_cookie={token};"}
+        async with httpx.AsyncClient() as client:
+            response = await client.get(url, headers=headers)
+            response.raise_for_status()
+            data = self._check_response(response)
+            session_log = [
+                {
+                    "message": message.get("message"),
+                    "role": message.get("category"),
+                    "ts": message.get("create_time")
+                }
+                for message in data
+            ]
+
+            # 鎶妔ession_log 鎸塼s 鍗囧簭鎺掑簭
+            session_log.sort(key=lambda x: x['ts'])
+            return session_log
+
     async def variable_list(self, token: str, agent_id: str) -> list:
         url = f"{self.base_url}/api/v1/variable/list?flow_id={agent_id}"
         headers = {'cookie': f"access_token_cookie={token};"}

--
Gitblit v1.8.0