From f848280fe3ed8841147fcc8f26a788580b82ae0c Mon Sep 17 00:00:00 2001
From: liudong <liudong>
Date: 星期六, 17 八月 2024 10:37:46 +0800
Subject: [PATCH] 首页页面bug修改

---
 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