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 |   94 ++++++++++++++++++++++++++++++++++++----------
 1 files changed, 73 insertions(+), 21 deletions(-)

diff --git a/src/views/sessionManager/components/agentSession.vue b/src/views/sessionManager/components/agentSession.vue
index 53aaf45..5092bff 100644
--- a/src/views/sessionManager/components/agentSession.vue
+++ b/src/views/sessionManager/components/agentSession.vue
@@ -1,8 +1,15 @@
 <template>
   <!--      鍐呭-->
+  <div class="header___lEPyH">
+    <div class="chatHeader">
+      <div class="chatHeaderBox">
+        <span class="title">{{agentTitle}}</span>
+      </div>
+    </div>
+  </div>
   <a-scrollbar
     ref="scrollbar"
-    id="home"
+    id="agentHome"
     class="chat-list"
     style="
               width: 90%;
@@ -99,12 +106,13 @@
 </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";
 import { EventSourceParserStream } from 'eventsource-parser/stream';
 import { agentResetApi, agentSetApi, getAgentSessionDetailsApi } from "@/api/agentSession";
+import EventBus from '@/utils/EventBus';
 const props = defineProps({
   modalObj: Object,
 });
@@ -117,6 +125,7 @@
 const dialogId = ref('');
 const chatDis = ref(false);
 const loading = ref(false);
+const agentTitle = ref("鏈懡鍚嶄細璇�");
 
 
 const currIndex = ref(0);
@@ -141,10 +150,16 @@
 // 鍒濆鍖栭〉闈�
 const initPage = async () => {
   agentSet();
-  agentReset();
-  agentCompletion();
-  queryAgentSessionDetail(agentObj.id);
 };
+
+const createNewAgent = async (session) => {
+  Object.assign(agentObj, session);
+  initPage();
+
+
+}
+
+
 
 // 璋冪敤set鏂规硶
 const agentSet = async () => {
@@ -153,8 +168,11 @@
     title: agentObj.title,
     dsl: agentObj.dsl,
   });
-  if (res.code === 200) {
+  console.log(res,'agentSet');
+  if (res.code == 0) {
+    // sessionDetailList.value = res.data.dsl.messages;
     // Message.success('淇敼鎴愬姛');
+    agentReset();
   }
 }
 // 璋冪敤reset鏂规硶
@@ -162,8 +180,9 @@
   const res = await agentResetApi({
     id: agentObj.id,
   });
-  if (res.code === 200) {
+  if (res.code == 0) {
     // Message.success('淇敼鎴愬姛');
+    agentCompletion();
   }
 }
 // 璋冪敤completion鏂规硶
@@ -222,7 +241,8 @@
   if (code == 0) {
     console.log(data,'浼氳瘽璇︽儏');
     sessionDetailList.value = data.dsl.messages;
-    // refreshScroll(); //鍒锋柊婊氬姩鏉′綅缃�
+    agentTitle.value = data.name || '鏈懡鍚嶄細璇�';
+    refreshScroll(); //鍒锋柊婊氬姩鏉′綅缃�
   }
 };
 
@@ -243,12 +263,12 @@
 
       chatDis.value = true;
       loading.value = true;
-      if (!activeSessionId.value) {
-        Message.warning('璇烽�夋嫨浼氳瘽');
-        chatDis.value = false;
-        loading.value = false;
-        return;
-      }
+      // if (!agentObj.id) {
+      //   Message.warning('璇烽�夋嫨浼氳瘽');
+      //   chatDis.value = false;
+      //   loading.value = false;
+      //   return;
+      // }
 
       // if (displayedText.value) {
       //   querySessionList();
@@ -270,8 +290,8 @@
               'Content-Type': 'application/json',
             },
             body: JSON.stringify({
-              conversation_id: activeSessionId.value,
-              messages: inputMsg.value,
+              id: agentObj.id,
+              message: inputMsg.value,
             }),
           }
         );
@@ -301,6 +321,7 @@
               console.info('done');
               displayedText.value = '';
               queryAgentSessionDetail(agentObj.id);
+              EventBus.emit('queryAppUsageList');
               break;
             }
           }
@@ -345,24 +366,33 @@
 const scrollbar = ref(null);
 const refreshScroll = () => {
   nextTick(() => {
-    const container = document.getElementById('home');
+    const container = document.getElementById('agentHome');
     scrollbar.value.scrollTop(container.scrollHeight);
   });
 };
 
 
 onMounted(() => {
-
+  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(
   () => props.modalObj,
   (newVal, oldVal) => {
-    console.log(newVal,'鐩戝惉鍙樺寲');
-    Object.assign(agentObj, newVal);
+    // Object.assign(agentObj, newVal);
     //璋冪敤agent鍒濆鍖栨柟娉�
     if(JSON.stringify(newVal) != '{}'){
-      initPage();
+      // initPage();
     }
   },{
     immediate: true,
@@ -501,4 +531,26 @@
     }
   }
 }
+.header___lEPyH {
+  width: 100%;
+  height: 46px;
+  position: relative;
+  backdrop-filter: blur(15px);
+  display: flex;
+  align-items: center;
+  justify-content: center;
+  -webkit-backdrop-filter: blur(15px);
+  .chatHeaderBox {
+    width: auto;
+    border-radius: 8px;
+    padding: 4px 20px;
+    transition: all var(--animation-duration) var(--animation-transition);
+    display: flex;
+    align-items: flex-end;
+    overflow: hidden;        /* 闅愯棌瓒呭嚭鐨勫唴瀹� */
+    text-overflow: ellipsis; /* 浣跨敤鐪佺暐鍙锋潵浠ｆ浛琚殣钘忕殑鏂囧瓧 */
+    white-space: nowrap;     /* 涓嶆崲琛岋紝浣垮唴瀹瑰湪涓�琛屽唴鏄剧ず */
+    max-width: 200px;
+  }
+}
 </style>

--
Gitblit v1.8.0