From 768a63bdae68f9440d4b7f5768c3ea7f9308f2ab Mon Sep 17 00:00:00 2001
From: wujingjing <gersonwu@qq.com>
Date: 星期三, 06 十一月 2024 14:08:58 +0800
Subject: [PATCH] 流更改

---
 src/components/chat/Chat.vue |   51 ++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 38 insertions(+), 13 deletions(-)

diff --git a/src/components/chat/Chat.vue b/src/components/chat/Chat.vue
index 8d4f7fd..05b6846 100644
--- a/src/components/chat/Chat.vue
+++ b/src/components/chat/Chat.vue
@@ -84,7 +84,12 @@
 												</div>
 											</div>
 											<template v-else>
-												<component :is="answerTypeMapCom[item.content.type]" :data="item.content.values" :originData="item" />
+												<component
+													:conclusion="item.conclusion"
+													:is="answerTypeMapCom[item.content.type]"
+													:data="item.content.values"
+													:originData="item"
+												/>
 												<div
 													v-if="item.role === RoleEnum.assistant && item.content.origin?.ext_call_list"
 													class="flex font-bold items-center mt-6"
@@ -412,20 +417,42 @@
 	// queryProcess();
 	resetStep();
 	let res = null;
-	await questionStreamByPost(params, (chunkRes) => {
-		Logger.info('chunk response锛歕n\n' + JSON.stringify(chunkRes));
-		if (chunkRes.mode === 'result') {
-			res = chunkRes.value;
-		} else {
+	
+	const resultP = new Promise(async (resolve, reject) => {
+		await questionStreamByPost(params, (chunkRes) => {
+			Logger.info('chunk response锛歕n\n' + JSON.stringify(chunkRes));
+			if (chunkRes.mode === 'result') {
+				res = chunkRes.value;
+				resolve(res);
+				chunkRes.value = '鍑嗗鏁版嵁鍒嗘瀽';
+			}
+
+			if (chunkRes.mode === 'conclusion') {
+				computedMessageList.value.at(-1).conclusion = chunkRes.value;
+				chunkRes.value = '鍒嗘瀽缁撴潫';
+			}
+
+			if (chunkRes.mode === 'finish') {
+				isTalking.value = false;
+				return;
+			}
+
 			const stepItem = convertProcessItem(chunkRes);
 			computedMessageList.value.at(-1).stepList.push(stepItem);
 			scrollToBottom();
-		}
-	}).finally(() => {
-		computedMessageList.value.at(-1).stepIsShow = false;
-		resetStep();
+		})
+			.catch((err) => {
+				throw err;
+			})
+			.finally(() => {
+				isTalking.value = false;
+
+				computedMessageList.value.at(-1).stepIsShow = false;
+				resetStep();
+			});
 	});
-	questionRes = res;
+
+	questionRes = await resultP;
 	const content = parseContent(res);
 	return content;
 };
@@ -502,8 +529,6 @@
 		// 	type: AnswerType.Text,
 		// 	values: '鍙戠敓閿欒锛�',
 		// });
-	} finally {
-		isTalking.value = false;
 	}
 };
 

--
Gitblit v1.9.3