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