| | |
| | | <template> |
| | | <div class="flex h-full"> |
| | | <div class="flex flex-col h-full flex-auto"> |
| | | <div class="h-full flex flex-col items-center overflow-y-auto"> |
| | | <div ref="chatListDom" class="h-full" :style="{ width: chatWidth }"> |
| | | <div ref="chatListDom" class="relative h-full flex flex-col items-center overflow-y-auto"> |
| | | <span |
| | | class="more-loading absolute text-blue-400 left-[50%] translate-x-[-50%] cursor-pointer w-10" |
| | | v-loading="moreIsLoading" |
| | | ></span> |
| | | <div class="h-full relative" v-loading="chatListLoading" :style="{ width: chatWidth }"> |
| | | <div |
| | | class="group flex px-4 py-6 hover:bg-slate-100 rounded-lg relative" |
| | | :class="{ 'flex-row-reverse': item.role === RoleEnum.user }" |
| | | v-for="(item, index) of computedMessageList" |
| | | :key="index" |
| | | :key="`${item.historyId}_${item.role}`" |
| | | > |
| | | <div class="absolute top-0 left-[72px] text-[#8d8e99]">{{ item?.createTime }}</div> |
| | | <img |
| | | class="rounded-full size-12 flex-0" |
| | | :class="{ 'mr-4': item.role === RoleEnum.assistant, 'ml-4': item.role === RoleEnum.user }" |
| | |
| | | </div> |
| | | </div> |
| | | </div> |
| | | <div v-if="showAskMore" class="ml-4 mt-5 text-sm"> |
| | | <div v-if="showAskMore" class="ml-4 mt-5 text-sm pb-10"> |
| | | <div class="text-gray-600 mb-5">你可以继续问我:</div> |
| | | <div class="space-y-2 inline-flex flex-col"> |
| | | <div |
| | |
| | | </div> |
| | | </div> |
| | | |
| | | <div class="sticky bottom-0 w-full p-6 pb-8 bg-[rgb(247,248,250)] flex justify-center"> |
| | | <div class="sticky bottom-0 w-full p-6 bg-[rgb(247,248,250)] flex justify-center"> |
| | | <PlayBar |
| | | v-model:voicePageIsShow="voicePageIsShow" |
| | | :isTalking="isTalking" |
| | |
| | | </template> |
| | | |
| | | <script setup lang="ts"> |
| | | import { ElMessage } from 'element-plus'; |
| | | import _ from 'lodash'; |
| | | import moment from 'moment'; |
| | | import { v4 as uuidv4 } from 'uuid'; |
| | | import { computed, onMounted, ref } from 'vue'; |
| | | import FeedbackPanel from './components/FeedbackPanel.vue'; |
| | | import Loding from './components/Loding.vue'; |
| | | import { useAssistantContentOpt } from './hooks/useAssistantContentOpt'; |
| | | import { useQueryProcess } from './hooks/useQueryProcess'; |
| | | import { useScrollLoad } from './hooks/useScrollLoad'; |
| | | import { useScrollToBottom } from './hooks/useScrollToBottom'; |
| | | import type { ChatContent } from './model/types'; |
| | | import { AnswerState, AnswerType, RoleEnum, answerTypeMapCom, roleImageMap, type ChatMessage } from './model/types'; |
| | | import { GetHistoryAnswer, QueryHistoryDetail, QuestionAi, extCallQuery } from '/@/api/ai/chat'; |
| | | import { QuestionAi, extCallQuery } from '/@/api/ai/chat'; |
| | | import PlayBar from '/@/components/chat/components/playBar/PlayBar.vue'; |
| | | import CustomDrawer from '/@/components/drawer/CustomDrawer.vue'; |
| | | import router from '/@/router'; |
| | | import { activeChatRoom, activeLLMId, activeSampleId, activeSectionAId, getRoomConfig, roomConfig } from '/@/stores/chatRoom'; |
| | | import { |
| | | activeChatRoom, |
| | | activeGroupType, |
| | | activeLLMId, |
| | | activeRoomId, |
| | | activeSampleId, |
| | | activeSectionAId, |
| | | getRoomConfig, |
| | | roomConfig, |
| | | } from '/@/stores/chatRoom'; |
| | | import { ErrorCode } from '/@/utils/request'; |
| | | |
| | | const chatWidth = '75%'; |
| | |
| | | }); |
| | | const currentRoute = router.currentRoute; |
| | | const currentRouteId = currentRoute.value.query.id as string; |
| | | activeRoomId.value = currentRouteId; |
| | | const chatListDom = ref<HTMLDivElement>(); |
| | | const messageList = ref<ChatMessage[]>([]); |
| | | const computedMessageList = computed(() => { |
| | | return messageList.value.filter((v) => !!v); |
| | | }); |
| | | |
| | | const parseContent = (res) => { |
| | | if (!res) return null; |
| | | let content: ChatContent = { |
| | |
| | | content.origin = res; |
| | | return content; |
| | | }; |
| | | |
| | | const { clearQueryProcess, process, processId, queryProcess } = useQueryProcess(); |
| | | const DEFAULT_SECTION_A_ID = 'knowledge_base'; |
| | | |
| | | let questionRes = null; |
| | | |
| | | let finalCalcSectionAId = null; |
| | |
| | | process_id: processId.value, |
| | | question: text, |
| | | // FIXME: 暂时这样 |
| | | section_a_id: currentSectionAId, |
| | | // section_a_id: currentSectionAId, |
| | | history_group_id: currentRouteId, |
| | | raw_mode: roomConfig.value?.[currentRouteId]?.isAnswerByLLM ?? false, |
| | | ...judgeParams, |
| | | } as any; |
| | | |
| | | if (activeGroupType.value) { |
| | | params.group_type = activeGroupType.value; |
| | | } |
| | | |
| | | if (currentSampleId) { |
| | | params.sample_id = currentSampleId; |
| | |
| | | |
| | | let currentLLMId = null; |
| | | |
| | | const getAnswerById = async (historyId: string) => { |
| | | return await GetHistoryAnswer({ |
| | | history_id: historyId, |
| | | }); |
| | | }; |
| | | |
| | | const sendChatMessage = async (content: ChatContent = messageContent.value, cb?: any, isCallExtParams?: any) => { |
| | | if (!content?.values || isTalking.value) return; |
| | | if (!content?.values || isTalking.value || chatListLoading.value) return; |
| | | const isNewChat = messageList.value.length === 0; |
| | | if (isNewChat) { |
| | | if (activeSampleId.value) { |
| | |
| | | |
| | | // 出现回复,置空出现等待动画 |
| | | messageList.value.push(assistantItem); |
| | | // 滚动至当前发送消息 |
| | | scrollToBottom(); |
| | | |
| | | if (isCallExtParams) { |
| | | const extRes = await extCallQuery(isCallExtParams); |
| | | questionRes = extRes; |
| | |
| | | } else { |
| | | resMsgContent = await questionAi(content.values); |
| | | } |
| | | |
| | | nextUserMsgEndIndex.value++; |
| | | if (isNewChat) { |
| | | const firstResCb = getRoomConfig(currentRouteId, 'firstResCb'); |
| | | firstResCb?.(resMsgContent); |
| | |
| | | assistantItem.historyId = questionRes.history_id; |
| | | assistantItem.sectionAId = finalCalcSectionAId; |
| | | appendLastMessageContent(resMsgContent); |
| | | setTimeout(() => { |
| | | // 收到回复,继续滚 |
| | | scrollToBottom(); |
| | | }, 300); |
| | | } catch (error: any) { |
| | | // appendLastMessageContent({ |
| | | // type: AnswerType.Text, |
| | |
| | | sendChatMessage(messageContent.value, cb); |
| | | }; |
| | | const appendLastMessageContent = (content: ChatContent) => { |
| | | const currentTime = moment().format('MM年DD日 HH:mm:ss'); |
| | | if (messageList.value.at(-1)) { |
| | | messageList.value.at(-1).content = content; |
| | | messageList.value.at(-1).createTime = currentTime; |
| | | } |
| | | }; |
| | | const { loadRangeData, onChatListScroll, moreIsLoading, nextUserMsgEndIndex } = useScrollLoad({ |
| | | container: chatListDom, |
| | | historyGroupId: currentRouteId, |
| | | messageList, |
| | | parseAnswerContent: parseContent, |
| | | }); |
| | | |
| | | // 一次性加载最近条数限制 |
| | | const LOAD_CHAT_LIMIT = 10; |
| | | const chatListLoading = ref(false); |
| | | |
| | | // 所有用户提问历史记录 |
| | | let userMsgHistory = []; |
| | | // 下次加载用户提问索引位置 |
| | | let nextUserMsgEndIndex = 0; |
| | | const { scrollToBottom } = useScrollToBottom({ |
| | | chatListDom: chatListDom, |
| | | }); |
| | | |
| | | onMounted(async () => { |
| | | const res = await QueryHistoryDetail({ |
| | | history_group_id: currentRouteId, |
| | | }); |
| | | userMsgHistory = res.details ?? []; |
| | | nextUserMsgEndIndex = userMsgHistory.length; |
| | | // 截取倒数 LOAD_CHAT_LIMIT 条用户消息 |
| | | const currentUserMsgList = userMsgHistory.slice(nextUserMsgEndIndex - LOAD_CHAT_LIMIT, nextUserMsgEndIndex); |
| | | messageList.value = currentUserMsgList.map((item) => { |
| | | return { |
| | | historyId: item.history_id, |
| | | role: RoleEnum.user, |
| | | content: { |
| | | type: AnswerType.Text, |
| | | values: item.question, |
| | | }, |
| | | } as ChatMessage; |
| | | }); |
| | | const sectionAIdMap = new Map(); |
| | | messageList.value = []; |
| | | // 加载初始数据 |
| | | chatListLoading.value = true; |
| | | |
| | | // 获取结果插入到用户提问之后 |
| | | currentUserMsgList.map((item) => { |
| | | sectionAIdMap.set(item.history_id, item.section_a_id); |
| | | getAnswerById(item.history_id).then((aiRobot) => { |
| | | // 用户提问索引 |
| | | const userMsgIndex = messageList.value.findIndex((subItem) => subItem?.historyId === item.history_id); |
| | | const userMsg = messageList.value[userMsgIndex]; |
| | | // values 取回答之后最终的 question |
| | | userMsg.content.values = aiRobot.answer?.question ?? userMsg.content.values; |
| | | messageList.value.splice( |
| | | userMsgIndex + 1, |
| | | 0, |
| | | aiRobot.answer === null |
| | | ? null |
| | | : { |
| | | historyId: aiRobot.answer?.history_id, |
| | | role: RoleEnum.assistant, |
| | | content: parseContent(aiRobot.answer), |
| | | state: aiRobot.answer_state, |
| | | sectionAId: sectionAIdMap.get(aiRobot.answer.history_id), |
| | | } |
| | | ); |
| | | }); |
| | | await loadRangeData().finally(() => { |
| | | chatListLoading.value = false; |
| | | }); |
| | | |
| | | if (messageList.value.length === 0) { |
| | | messageContent.value = { |
| | | type: AnswerType.Text, |
| | |
| | | }; |
| | | |
| | | sendChatMessage(); |
| | | } else { |
| | | setTimeout(() => { |
| | | // 初始状态滚一下 |
| | | scrollToBottom(); |
| | | |
| | | setTimeout(() => { |
| | | chatListDom.value.addEventListener('scroll', onChatListScroll); |
| | | }, 300); |
| | | }, 300); |
| | | } |
| | | }); |
| | | |
| | | const { forbidScroll } = useScrollToBottom({ |
| | | chatListDom: chatListDom, |
| | | displayMessageList: computedMessageList, |
| | | }); |
| | | |
| | | //#region ====================== 关联查询 ====================== |
| | | const relativeQueryClick = async (val) => { |
| | | sendChatMessage( |
| | |
| | | showFixQuestion, |
| | | showAskMore, |
| | | } = useAssistantContentOpt({ |
| | | forbidScroll, |
| | | sendChatMessage, |
| | | displayMessageList: computedMessageList, |
| | | }); |
| | |
| | | //#endregion |
| | | </script> |
| | | |
| | | <style scoped> |
| | | <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); |
| | | } |
| | | } |
| | | } |
| | | </style> |