From 514778f64e7708db4443a1c93c902e8294939f50 Mon Sep 17 00:00:00 2001
From: zhangxiao <898441624@qq.com>
Date: 星期六, 17 八月 2024 11:10:03 +0800
Subject: [PATCH] Merge branch 'master' of http://192.168.5.5:10010/r/web/flow_web
---
src/views/sessionManager/components/agentSession.vue | 66 ++++++++++++++++++--------------
1 files changed, 37 insertions(+), 29 deletions(-)
diff --git a/src/views/sessionManager/components/agentSession.vue b/src/views/sessionManager/components/agentSession.vue
index 342d9a3..5092bff 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 = '';
@@ -322,6 +321,7 @@
console.info('done');
displayedText.value = '';
queryAgentSessionDetail(agentObj.id);
+ EventBus.emit('queryAppUsageList');
break;
}
}
@@ -376,6 +376,14 @@
EventBus.on('createAgent', (data) => {
createNewAgent(data);
});
+ EventBus.on('queryAgentSessionDetail', (data) => {
+ Object.assign(agentObj, data);
+ queryAgentSessionDetail(data.id);
+ });
+});
+onBeforeUnmount(() => {
+ EventBus.off('createAgent');
+ EventBus.off('queryAgentSessionDetail');
});
watch(
--
Gitblit v1.8.0