From 8bb9fe3e7f6dda7720784a049177d606e66fbc2b Mon Sep 17 00:00:00 2001
From: zhangxiao <898441624@qq.com>
Date: 星期五, 16 八月 2024 18:02:55 +0800
Subject: [PATCH] Merge branch 'master' of http://192.168.5.5:10010/r/web/flow_web
---
src/views/sessionManager/components/agentSession.vue | 60 +++++++++++++++++++++++++++++++-----------------------------
1 files changed, 31 insertions(+), 29 deletions(-)
diff --git a/src/views/sessionManager/components/agentSession.vue b/src/views/sessionManager/components/agentSession.vue
index 342d9a3..b408c10 100644
--- a/src/views/sessionManager/components/agentSession.vue
+++ b/src/views/sessionManager/components/agentSession.vue
@@ -106,7 +106,7 @@
</template>
<script setup lang="ts">
-import { defineProps, ref, watch, defineEmits, onMounted, reactive, computed, nextTick } from "vue";
+import { defineProps, ref, watch, defineEmits, onMounted, reactive, computed, nextTick, onBeforeUnmount } from "vue";
import { Message } from '@arco-design/web-vue';
import { useAppStore } from "@/store";
import { getAuthorization } from "@/utils/auth";
@@ -150,9 +150,6 @@
// 鍒濆鍖栭〉闈�
const initPage = async () => {
agentSet();
- agentReset();
- agentCompletion();
- queryAgentSessionDetail(agentObj.id);
};
const createNewAgent = async (session) => {
@@ -175,6 +172,7 @@
if (res.code == 0) {
// sessionDetailList.value = res.data.dsl.messages;
// Message.success('淇敼鎴愬姛');
+ agentReset();
}
}
// 璋冪敤reset鏂规硶
@@ -182,8 +180,9 @@
const res = await agentResetApi({
id: agentObj.id,
});
- if (res.code === 200) {
+ if (res.code == 0) {
// Message.success('淇敼鎴愬姛');
+ agentCompletion();
}
}
// 璋冪敤completion鏂规硶
@@ -207,30 +206,30 @@
.pipeThrough(new EventSourceParserStream())
.getReader();
currIndex.value = 0;
- // while (true) {
- // const x = await reader?.read();
- // if (x) {
- // const { done, value } = x;
- // console.log(x, 999);
- // try {
- // const val = JSON.parse(value?.data || '');
- // const d = val?.data;
- // if (typeof d !== 'boolean') {
- // console.info('data:', d);
- // streamStr.value = d.content;
- // startDisplayStr();
- // }
- // } catch (e) {
- // console.warn(e);
- // }
- // if (done) {
- // console.info('done');
- // displayedText.value = '';
- // queryAgentSessionDetail(agentObj.id);
- // break;
- // }
- // }
- // }
+ while (true) {
+ const x = await reader?.read();
+ if (x) {
+ const { done, value } = x;
+ console.log(x, 999);
+ try {
+ const val = JSON.parse(value?.data || '');
+ const d = val?.data;
+ if (typeof d !== 'boolean') {
+ console.info('data:', d);
+ streamStr.value = d.content;
+ startDisplayStr();
+ }
+ } catch (e) {
+ console.warn(e);
+ }
+ if (done) {
+ console.info('done');
+ displayedText.value = '';
+ queryAgentSessionDetail(agentObj.id);
+ break;
+ }
+ }
+ }
chatDis.value = false;
loading.value = false;
inputMsg.value = '';
@@ -377,6 +376,9 @@
createNewAgent(data);
});
});
+onBeforeUnmount(() => {
+ EventBus.off('createAgent');
+});
watch(
() => props.modalObj,
--
Gitblit v1.8.0