From 9be4808a8d7038e9af6de826f573c66ca38194db Mon Sep 17 00:00:00 2001
From: xuyonghao <898441624@qq.com>
Date: 星期三, 22 一月 2025 11:31:16 +0800
Subject: [PATCH] 报表合并webSocket信息格式修改
---
app/api/chat.py | 12 +++++++++---
1 files changed, 9 insertions(+), 3 deletions(-)
diff --git a/app/api/chat.py b/app/api/chat.py
index 508f2f2..2241161 100644
--- a/app/api/chat.py
+++ b/app/api/chat.py
@@ -721,6 +721,9 @@
# 姝ｅ父杈撳嚭
answer = data.get("answer", "")
result = {"message": answer, "type": "stream"}
+ elif data.get("event") == "error":
+ answer = data.get("message", "")
+ result = {"message": answer, "type": "system"}
elif data.get("event") == "workflow_finished":
answer = data.get("data", "")
if isinstance(answer, str):
@@ -873,6 +876,9 @@
# 姝ｅ父杈撳嚭
answer = data.get("answer", "")
result = {"message": answer, "type": "stream"}
+ elif data.get("event") == "error":
+ answer = data.get("message", "")
+ result = {"message": answer, "type": "system"}
elif data.get("event") == "workflow_finished":
answer = data.get("data", "")
if isinstance(answer, str):
@@ -888,8 +894,8 @@
else:
message = answer.get("error", "")
- # result = {"message": message, "type": "message",
- # "download_url": download_url}
+ result = {"message": message, "type": "system",
+ "download_url": download_url}
try:
SessionService(db).update_session(chat_id,
message={"role": "assistant",
@@ -902,7 +908,7 @@
logger.error("淇濆瓨dify鐨勪細璇濆紓甯革紒")
logger.error(e)
# await websocket.send_json(result)
- continue
+ # continue
elif data.get("event") == "message_end":
result = {"message": "", "type": "close"}
--
Gitblit v1.8.0