| | |
| | | </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"; |
| | |
| | | // 初始化页面 |
| | | const initPage = async () => { |
| | | agentSet(); |
| | | agentReset(); |
| | | agentCompletion(); |
| | | queryAgentSessionDetail(agentObj.id); |
| | | }; |
| | | |
| | | const createNewAgent = async (session) => { |
| | |
| | | if (res.code == 0) { |
| | | // sessionDetailList.value = res.data.dsl.messages; |
| | | // Message.success('修改成功'); |
| | | agentReset(); |
| | | } |
| | | } |
| | | // 调用reset方法 |
| | |
| | | const res = await agentResetApi({ |
| | | id: agentObj.id, |
| | | }); |
| | | if (res.code === 200) { |
| | | if (res.code == 0) { |
| | | // Message.success('修改成功'); |
| | | agentCompletion(); |
| | | } |
| | | } |
| | | // 调用completion方法 |
| | |
| | | .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 = ''; |
| | |
| | | console.info('done'); |
| | | displayedText.value = ''; |
| | | queryAgentSessionDetail(agentObj.id); |
| | | EventBus.emit('queryAppUsageList'); |
| | | break; |
| | | } |
| | | } |
| | |
| | | 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( |
| | |
| | | text-overflow: ellipsis; /* 使用省略号来代替被隐藏的文字 */ |
| | | white-space: nowrap; /* 不换行,使内容在一行内显示 */ |
| | | max-width: 200px; |
| | | .title{ |
| | | color: var(--color-text-1); |
| | | font-size: 12px; |
| | | } |
| | | } |
| | | } |
| | | </style> |