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