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/hooks/useScrollLoad.ts | 167 +++++--------------------------------------------------
1 files changed, 16 insertions(+), 151 deletions(-)
diff --git a/src/components/chat/hooks/useScrollLoad.ts b/src/components/chat/hooks/useScrollLoad.ts
index de7cc1b..656f211 100644
--- a/src/components/chat/hooks/useScrollLoad.ts
+++ b/src/components/chat/hooks/useScrollLoad.ts
@@ -1,50 +1,15 @@
import moment from 'moment';
import type { Ref, ShallowRef } from 'vue';
-import { computed, nextTick, onBeforeUnmount, ref, unref } from 'vue';
+import { nextTick, onBeforeUnmount, ref, unref } from 'vue';
import { LOAD_CHAT_LIMIT } from '../constants';
-import type { ChatContent, ChatMessage, StepItem } from '../model/types';
-import { AnswerType, MultiChatType, RoleEnum, StepEnum } from '../model/types';
-import { GetHistoryAnswer, QueryHistoryDetail, getShareChatJsonByPost } from '/@/api/ai/chat';
-import router from '/@/router';
-import { isSharePage } from '/@/stores/chatRoom';
+import type { ChatMessage } from '../model/types';
+import { useLoadData } from './useLoadData';
+import { QueryHistoryDetail } from '/@/api/ai/chat';
type UseScrollLoadOption = {
container: ShallowRef<HTMLDivElement>;
historyGroupId: string | Ref<string>;
messageList: Ref<ChatMessage[]>;
- parseAnswerContent: (res: any) => ChatContent;
-};
-
-export const convertProcessItem = (processItem: any) => {
- switch (processItem.mode) {
- case 'begin':
- break;
- case 'end':
- break;
- }
- return {
- status: StepEnum.Success,
- title: processItem.value,
- } as StepItem;
-};
-export const convertProcessToStep = (process: any[]) => {
- const stepList = (process ?? []).reduce((preVal, curVal) => {
- if (curVal.mode === 'question') {
- const last = preVal.at(-1);
- if (!last.subStep) {
- last.subStep = [];
- }
- const sub = {
- data: curVal.value,
- type: MultiChatType.Select,
- };
- last.subStep.push(sub);
- } else {
- const cur = convertProcessItem(curVal);
- preVal.push(cur);
- }
- return preVal;
- }, []);
- return stepList;
+ loadReplyData: (res: any) => Promise<ChatMessage[]>;
};
/**
@@ -52,127 +17,26 @@
* @returns
*/
export const useScrollLoad = (option: UseScrollLoadOption) => {
- const { container, historyGroupId, messageList, parseAnswerContent } = option;
+ const { container, historyGroupId, messageList, loadReplyData } = option;
const moreIsLoading = ref(false);
/** @description 涓嬫闇�瑕佸姞杞界殑鐢ㄦ埛缁撴潫绱㈠紩锛堝�掔潃鏁帮級 */
- const nextUserMsgEndIndex = ref(0);
+ let nextUserMsgEndIndex = 0;
// 鏄惁娌℃湁鏇村鏁版嵁浜�
let isNoMore = false;
- const getAnswerById = async (historyId: string) => {
- return await GetHistoryAnswer({
- history_id: historyId,
- });
- };
- const formatShowTimeYear = computed(() => {
- return (str) => {
- return moment(str).format('MM鏈圖D鏃� HH:mm:ss');
- };
- });
- /**
- * 鑾峰彇鐢ㄦ埛鍥炲鏁版嵁锛屽苟鎻掑叆鍒板璇濆綋涓幓
- */
- const loadReplyData = async (userMsg: any[]) => {
- const userItemIdMap = new Map();
- // 鐢ㄦ埛娑堟伅
- const tmpMessageList: ChatMessage[] = userMsg.map((item) => {
- return {
- historyId: item.history_id,
- role: RoleEnum.user,
- content: {
- type: AnswerType.Text,
- values: item.question,
- },
- isChecked: false,
- } as ChatMessage;
- });
- const resList = await Promise.all(
- (userMsg ?? []).map((item) => {
- userItemIdMap.set(item.history_id, item);
- return getAnswerById(item.history_id);
- })
- );
- let i = 0;
- resList.map((item, index) => {
- const insertIndex = index + 1 + i;
- const currentUserMsg = tmpMessageList[insertIndex - 1];
- currentUserMsg.content.values = item?.answer?.question ?? currentUserMsg.content.values;
-
- const mapUser = userItemIdMap.get(item.answer?.history_id);
-
- const answerTime = formatShowTimeYear.value(mapUser?.create_time);
- tmpMessageList.splice(
- insertIndex,
- 0,
- item.answer === null
- ? null
- : {
- historyId: item.answer?.history_id,
- role: RoleEnum.assistant,
- content: parseAnswerContent(item?.answer),
- state: item.answer_state,
- sectionAId: mapUser?.section_a_id,
- createTime: answerTime,
- stepList: convertProcessToStep(item?.answer?.reports?.[0]?.exec_process),
- stepIsShow: false,
- isStopMsg: false,
-
- conclusion: item?.answer?.conclusion ?? [],
- isChecked: false,
- }
- );
- i++;
- });
-
- messageList.value.unshift(...tmpMessageList);
- };
/**
- * 鍔犺浇鍒嗕韩鏁版嵁
+ * 鏇存柊鍔犺浇绱㈠紩
*/
- const loadShareData = async () => {
- const res = await getShareChatJsonByPost({
- share_id: router.currentRoute.value.query.id as string,
- });
-
- const msgValue = res?.values;
- if (!msgValue) {
- messageList.value = [];
- return;
- }
- const userMsg: ChatMessage = {
- historyId: msgValue.history_id,
- role: RoleEnum.user,
- content: {
- type: AnswerType.Text,
- values: msgValue.question,
- },
- isChecked: false,
- };
-
- const assistantMsg: ChatMessage = {
- historyId: msgValue.history_id,
- role: RoleEnum.assistant,
- content: parseAnswerContent(msgValue),
- stepList: convertProcessToStep(msgValue?.reports?.[0]?.exec_process),
- stepIsShow: false,
- isStopMsg: false,
-
- conclusion: msgValue.conclusion ?? [],
- isChecked: false,
- };
- messageList.value = [userMsg, assistantMsg];
+ const updateLoadIndex = (addCount = 1) => {
+ nextUserMsgEndIndex += addCount;
};
/**
* 鍔犺浇婊氬姩鑼冨洿鏁版嵁
*/
- const loadRangeData = async (lastEnd = nextUserMsgEndIndex.value) => {
- if (isSharePage.value) {
- await loadShareData();
- return;
- }
+ const loadRangeData = async (lastEnd = nextUserMsgEndIndex) => {
const res = await QueryHistoryDetail({
history_group_id: unref(historyGroupId),
last_end: lastEnd,
@@ -180,8 +44,9 @@
});
const result: ChatMessage[] = res.details ?? [];
if (result.length) {
- nextUserMsgEndIndex.value += result.length;
- await loadReplyData(res.details);
+ nextUserMsgEndIndex += result.length;
+ const rangeMsgList = await loadReplyData(res.details);
+ messageList.value.unshift(...rangeMsgList);
} else {
isNoMore = true;
}
@@ -203,7 +68,7 @@
const h1 = container.value.scrollHeight;
moreIsLoading.value = true;
- await loadRangeData(nextUserMsgEndIndex.value).finally(() => {
+ await loadRangeData(nextUserMsgEndIndex).finally(() => {
moreIsLoading.value = false;
});
//鏇存柊鍚庯紝绛夊緟椤甸潰娓叉煋瀹屾瘯鍐嶅幓鎷縮crollHeight,鍚﹀垯鎷垮埌鐨勬槸涔嬪墠鐨�
@@ -228,9 +93,9 @@
});
return {
- nextUserMsgEndIndex,
loadRangeData,
onChatListScroll,
moreIsLoading,
+ updateLoadIndex,
};
};
--
Gitblit v1.9.3