From 92d2ea48d343fc00d81905167d033c40200ea716 Mon Sep 17 00:00:00 2001
From: wujingjing <gersonwu@qq.com>
Date: 星期二, 04 三月 2025 15:56:19 +0800
Subject: [PATCH] 快速引用;去重
---
src/components/chat/smallChat/index.vue | 52 +++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 41 insertions(+), 11 deletions(-)
diff --git a/src/components/chat/smallChat/index.vue b/src/components/chat/smallChat/index.vue
index 6cbaff9..d19dd9c 100644
--- a/src/components/chat/smallChat/index.vue
+++ b/src/components/chat/smallChat/index.vue
@@ -134,7 +134,14 @@
<!-- 搴曢儴杈撳叆妗� -->
<div class="p-2 border-t">
- <ChatInput v-model="inputText" @sendClick="sendClick" @toggleHistory="toggleHistory" :showHistory="showHistory" />
+ <ChatInput
+ :isTalking="lastIsLoading"
+ v-model="inputText"
+ @sendClick="sendClick"
+ @toggleHistory="toggleHistory"
+ @stopGenClick="stopGenClick"
+ :showHistory="showHistory"
+ />
</div>
</div>
<Teleport to="body">
@@ -144,21 +151,23 @@
</template>
<script setup lang="ts" name="smallChat">
+import type { CancelTokenSource } from 'axios';
+import axios from 'axios';
import { cloneDeep, defaults } from 'lodash-es';
+import { fromLonLat } from 'ol/proj';
import { computed, nextTick, onMounted, ref } from 'vue';
import ChatInput from './ChatInput.vue';
import type { ChatMessage } from './types';
import { AssistantContent } from './types';
import WorkOrderDlg from './WorkOrderDlg.vue';
import { agentStreamByPost } from '/@/api/ai/chat';
+import { getSearchMapElement } from '/@/api/map';
import { useDrag } from '/@/hooks/useDrag';
import { Logger } from '/@/model/logger/Logger';
import { GaoDeSourceType, gaoDeSourceTypeMap, type OLMap } from '/@/model/map/OLMap';
-import userPic from '/static/images/role/user-200x206.png';
-import { getSearchMapElement } from '/@/api/map';
-import { formatDate } from '/@/utils/formatTime';
import { systemGlobalConfig } from '/@/stores/global';
-import { fromLonLat } from 'ol/proj';
+import { formatDate } from '/@/utils/formatTime';
+import userPic from '/static/images/role/user-200x206.png';
const props = defineProps<{
olMap?: OLMap;
}>();
@@ -199,12 +208,17 @@
{ title: '鍒涘缓宸ュ崟', question: '鏉剧澶ч亾DN800鏉惧矖鑱旈�氱洃娴嬭澶囨病鏈夋暟鎹紝鍒涘缓涓�涓澶囩淮淇伐鍗曪紝璇峰強鏃舵淳浜虹淮淇��' },
]);
const chatContentRef = ref<HTMLDivElement>(null);
-
const getLastAssistantMessage = () => {
const last = historyMessages.value[historyMessages.value.length - 1];
- const result = last.role === 'assistant' ? last : null;
+ const result = last?.role === 'assistant' ? last : null;
return result as ChatMessage<AssistantContent>;
};
+
+const lastIsLoading = computed(() => {
+ const last = getLastAssistantMessage();
+ const loading = last?.content?.isLoading ?? false;
+ return loading;
+});
//#region ====================== 娣诲姞宸ュ崟 ======================
const optDlgIsShow = ref(false);
@@ -247,13 +261,11 @@
const handleSwitchLayer = (formData: { layerId: string; visible: boolean }) => {
props.olMap.setLayerVisible(formData.layerId, formData.visible);
refreshAssistantMessage({ value: `鎴愬姛`, isError: false });
-
};
const changeTheme = (formData: { themeId: string }) => {
props.olMap.setThemeById(formData.themeId);
refreshAssistantMessage({ value: `鎴愬姛`, isError: false });
-
};
const handleQueryObject = async (formData: { objectName: string }) => {
@@ -312,11 +324,15 @@
props.olMap.setSourceType(formData.LayerId as GaoDeSourceType);
refreshAssistantMessage({ value: `鎴愬姛`, isError: false });
};
+let lastAxiosSource: CancelTokenSource = null;
const startStream = (question: string) => {
if (lastIsInit) {
showHistory.value = false;
}
+
+ const currentSource = axios.CancelToken.source();
+ lastAxiosSource = currentSource;
// if (question === '鏉剧澶ч亾DN800鏉惧矖鑱旈�氱洃娴嬭澶囨病鏈夋暟鎹紝鍒涘缓涓�涓澶囩淮淇伐鍗曪紝璇峰強鏃舵淳浜虹淮淇��') {
// setTimeout(() => {
// openOptDlg();
@@ -337,7 +353,7 @@
if (
chunkRes.type === 'string' &&
- ['create_work_order', 'switch_layers', 'switch_topic', 'query_address', 'query_object','map'].includes(chunkRes.mode)
+ ['create_work_order', 'switch_layers', 'switch_topic', 'query_address', 'query_object', 'map'].includes(chunkRes.mode)
) {
const jsonData = JSON.parse(chunkRes.value);
@@ -371,7 +387,7 @@
haveMapOperate = true;
handleQueryObject(jsonData);
break;
- case 'map':
+ case 'map':
haveMapOperate = true;
handleMapCommand(jsonData);
break;
@@ -383,6 +399,9 @@
refreshAssistantMessage({ reason: `鏈瘑鍒埌鎿嶄綔锛�"${question}"` });
}
}
+ },
+ {
+ cancelToken: currentSource.token,
}
).catch((error) => {
Logger.error('agent stream error锛歕n\n' + error);
@@ -519,6 +538,17 @@
});
};
//#endregion
+
+//#region ====================== 娴佸仠姝� ======================
+const stopGenClick = () => {
+ lastAxiosSource?.cancel();
+ const last = getLastAssistantMessage();
+ if (!last) return;
+ last.content.isLoading = false;
+ last.content.isError = true;
+ last.content.reason = '鐢ㄦ埛鍋滄鎿嶄綔';
+};
+//#endregion
onMounted(() => {});
</script>
--
Gitblit v1.9.3