From c9b6d9a10160ca1d18237a0728bac87ec8ff16da Mon Sep 17 00:00:00 2001
From: gerson <1405270578@qq.com>
Date: 星期二, 21 一月 2025 16:16:43 +0800
Subject: [PATCH] 屏蔽非当前聊天室chat_start

---
 src/components/chat/Chat.vue |  237 ++++++++++++++++-------------------------------------------
 1 files changed, 64 insertions(+), 173 deletions(-)

diff --git a/src/components/chat/Chat.vue b/src/components/chat/Chat.vue
index 1f15143..edbcb0d 100644
--- a/src/components/chat/Chat.vue
+++ b/src/components/chat/Chat.vue
@@ -1,11 +1,5 @@
 <template>
-	<ChatContainer
-		:loading="chatListLoading"
-		:more-is-loading="moreIsLoading"
-		:is-share-page="isSharePage"
-		:chat-width="chatWidth"
-		ref="containerRef"
-	>
+	<ChatContainer :loading="chatListLoading" :more-is-loading="moreIsLoading" :is-share-page="isSharePage" ref="containerRef">
 		<!-- 娑堟伅鍒楄〃 -->
 		<template #message-list>
 			<MessageList
@@ -15,6 +9,7 @@
 				@shareClick="shareClick"
 				@setCommonQuestionClick="setCommonPhraseClick"
 				@sendChatMessage="sendChatMessage"
+				@stopGenClick="stopGenClick"
 				@askMoreClick="askMoreClick"
 			/>
 			<el-empty v-else-if="isSharePage && !chatListLoading" :image-size="200">
@@ -26,17 +21,20 @@
 
 		<!-- 杈撳叆鍖哄煙 -->
 		<template #input-area>
-			<PlayBar
-				ref="playBarRef"
-				v-model:voicePageIsShow="voicePageIsShow"
-				:isTalking="isTalking"
-				:isHome="false"
-				:msgList="computedMessageList"
-				v-model="messageContent.values"
-				@sendClick="sendClick"
-				@stopGenClick="stopGenClick"
-				:style="{ width: chatWidth }"
-			/>
+			<div class="w-full ">
+				<PlayBar
+					ref="playBarRef"
+					v-model:voicePageIsShow="voicePageIsShow"
+					:isTalking="isTalking"
+					:isHome="false"
+					:msgList="computedMessageList"
+					v-model="messageContent.values"
+					@sendClick="sendClick"
+					@stopGenClick="stopGenClick"
+					:style="{ width: chatWidth }"
+					class="mx-auto"
+				/>
+			</div>
 		</template>
 
 		<!-- 鎶藉眽 -->
@@ -54,7 +52,7 @@
 import moment from 'moment';
 import { computed, onActivated, onMounted, ref } from 'vue';
 import { loadAmisSource } from '../amis/load';
-import { convertProcessItem, convertProcessToStep, formatShowTimeYear, useScrollLoad } from './hooks/useScrollLoad';
+import { useScrollLoad } from './hooks/useScrollLoad';
 import type { ChatContent } from './model/types';
 import { AnswerState, AnswerType, RoleEnum, type ChatMessage } from './model/types';
 import { getShareChatJsonByPost, questionStreamByPost } from '/@/api/ai/chat';
@@ -79,12 +77,17 @@
 import emitter from '/@/utils/mitt';
 import { useCompRef } from '/@/utils/types';
 import { toMyFixed } from '/@/utils/util';
+import { useLoadData } from './hooks/useLoadData';
+import { useSyncMsg } from './hooks/useSyncMsg';
 const containerRef = useCompRef(ChatContainer);
 const chatListDom = computed(() => containerRef.value?.chatListDom);
-const chatWidth = '75%';
+const scrollToBottom = () => {
+	containerRef.value?.scrollToBottom();
+};
+const { loadReplyData, parseContent, parseExtraContent, convertProcessItem, convertProcessToStep, formatShowTimeYear } = useLoadData();
 const voicePageIsShow = ref(false);
 let isTalking = ref(false);
-
+const chatWidth = computed(() => containerRef.value?.chatWidth);
 let messageContent = ref<ChatContent>({
 	type: AnswerType.Text,
 	values: '',
@@ -96,111 +99,6 @@
 const computedMessageList = computed(() => {
 	return messageList.value.filter((v) => !!v);
 });
-
-const parseExtraContent = (res) => {
-	if (!res) return {};
-	const askMoreList = orderBy(res.context_history, [(item) => Number(item.radio)], ['desc']);
-	const errCode = res?.err_code;
-	const errMsg = res?.json_msg;
-	const origin = res;
-
-	return {
-		askMoreList,
-		errCode,
-		errMsg,
-		origin,
-	};
-};
-
-const parseContent = (res, reportIsShow = false, extraContent?) => {
-	if (!res) return null;
-	let content: ChatContent = {
-		type: AnswerType.Text,
-		values: '瑙f瀽澶辫触锛�',
-	};
-	if (res.type) {
-		res.answer_type = res.type;
-	}
-	const curExtraContent = parseExtraContent(res);
-
-	switch (res.answer_type) {
-		case AnswerType.RecordSet:
-			content = {
-				type: AnswerType.RecordSet,
-				values: res.values,
-			};
-			break;
-		case AnswerType.Text:
-			content = {
-				type: AnswerType.Text,
-				values: res.values ?? res.answer,
-			};
-			break;
-		case AnswerType.Script:
-			content = {
-				type: AnswerType.Script,
-				values: res,
-			};
-			break;
-
-		case AnswerType.Knowledge:
-			content = {
-				type: AnswerType.Knowledge,
-				values: res.knowledge,
-			};
-
-			break;
-		case AnswerType.Report:
-			content = {
-				type: AnswerType.Report,
-				values: (res?.reports ?? []).map((item) => ({
-					content: parseContent(item, reportIsShow, { origin: item, conclusion: item.conclusion ?? [] }),
-				})),
-			};
-			break;
-
-		case AnswerType.Summary:
-			content = {
-				type: AnswerType.Summary,
-				values: res.summary?.map((item) => {
-					item.reportIsShow = reportIsShow;
-					return item;
-				}),
-			};
-			break;
-		case AnswerType.Url:
-			content = {
-				type: AnswerType.Url,
-				values: res.url,
-			};
-			break;
-		case AnswerType.Map:
-			content = {
-				type: AnswerType.Map,
-				values: res.values,
-			};
-			break;
-		default:
-			content = {
-				type: AnswerType.Text,
-				values: '瑙f瀽澶辫触锛�',
-			};
-			break;
-	}
-	if (!extraContent) {
-		content = {
-			...content,
-			...curExtraContent,
-		};
-	} else {
-		content = {
-			...content,
-			...extraContent,
-		};
-	}
-
-	return content;
-};
 
 let questionRes = null;
 let position = null;
@@ -340,14 +238,29 @@
 						chunkRes.value = '鍒嗘瀽缁撴潫';
 					}
 				}
+				const getLastGroup = () => {
+					const lastGroup = computedMessageList.value.at(-1).stepGroup.at(-1);
+					return lastGroup;
+				};
+				const getLastStepList = () => {
+					const stepList = getLastGroup()?.value ?? [];
+					return stepList;
+				};
+				const getLastStepItem = () => {
+					const stepList = getLastStepList();
+					const lastStepItem = stepList.at(-1);
+					return lastStepItem;
+				};
+
+				const checkStepItem = (stepItem) => {
+					if (!stepItem.subStep) {
+						stepItem.subStep = [];
+					}
+				};
 
 				if (chunkRes.mode === 'question') {
-					const lastGroup = computedMessageList.value.at(-1).stepGroup.at(-1);
-					const stepList = lastGroup?.value ?? [];
-					const lastStepItem = stepList.at(-1);
-					if (!lastStepItem.subStep) {
-						lastStepItem.subStep = [];
-					}
+					const lastStepItem = getLastStepItem();
+					checkStepItem(lastStepItem);
 					lastStepItem.subStep.push({
 						type: chunkRes.value.type,
 						data: chunkRes.value,
@@ -355,6 +268,7 @@
 					scrollToBottom();
 					return;
 				}
+
 				// 鏆傛椂涓嶈�冭檻澶氫釜 report鎯呭喌
 
 				// if (lastIsResult && chunkRes.mode !== 'finish') {
@@ -493,9 +407,11 @@
 		updateLoadIndex();
 
 		userItem.historyId = questionRes?.history_id;
+		const current = moment().format('YYYY-MM-DD HH:mm:ss');
+		userItem.createTime = current;
 		userItem.content.values = questionRes?.question ?? userItem.content.values;
 		assistantItem.historyId = questionRes?.history_id;
-		const currentTime = formatShowTimeYear(moment().format('YYYY-MM-DD HH:mm:ss'));
+		const currentTime = formatShowTimeYear(current);
 		assistantItem.createTime = currentTime;
 		assistantItem.content = resMsgContent;
 		setTimeout(() => {
@@ -513,9 +429,21 @@
 	container: chatListDom,
 	historyGroupId: currentRouteId,
 	messageList,
-	parseAnswerContent: parseContent,
+	loadReplyData,
 });
-
+useSyncMsg({
+	msgList: messageList,
+	updateLoadIndex,
+	historyGroupId: currentRouteId,
+	checkCanSync: (data) => {
+		return !isTalking.value && !moreIsLoading.value;
+	},
+	showTip: (data) => {
+		playBarRef.value.showSyncTip(data);
+	},
+	loadReplyData,
+	scrollToBottom,
+});
 const chatListLoading = ref(true);
 
 onActivated(() => {
@@ -528,9 +456,6 @@
 		values: activeChatRoom.value?.title,
 	};
 	sendChatMessage();
-};
-const scrollToBottom = () => {
-	containerRef.value?.scrollToBottom();
 };
 
 const initHistoryChat = () => {
@@ -609,8 +534,6 @@
 	loadAmisSource();
 });
 
-
-
 const askMoreClick = (item) => {
 	if (!item.question) return;
 	sendChatMessage({ type: AnswerType.Text, values: item.question });
@@ -640,37 +563,5 @@
 </script>
 
 <style scoped lang="scss">
-pre {
-	font-family: -apple-system, 'Noto Sans', 'Helvetica Neue', Helvetica, 'Nimbus Sans L', Arial, 'Liberation Sans', 'PingFang SC',
-		'Hiragino Sans GB', 'Noto Sans CJK SC', 'Source Han Sans SC', 'Source Han Sans CN', 'Microsoft YaHei', 'Wenquanyi Micro Hei',
-		'WenQuanYi Zen Hei', 'ST Heiti', SimHei, 'WenQuanYi Zen Hei Sharp', sans-serif;
-}
-
-.more-loading {
-	:deep(.el-loading-spinner) {
-		--loading-size: 35px;
-		margin-top: 0;
-		.circular {
-			width: var(--loading-size);
-			height: var(--loading-size);
-		}
-	}
-}
-
-:deep(.el-step__icon.is-text) {
-	--radius-size: 24px;
-	width: var(--radius-size);
-	height: var((--radius-size));
-}
-
-:deep(.el-step__icon-inner) {
-	font-size: 16px !important;
-}
-:deep(.el-step__description) {
-	min-height: 20px;
-}
-
-:deep(.el-step:last-of-type .el-step__description) {
-	// display: none;
-}
+@import './index.scss';
 </style>

--
Gitblit v1.9.3