| | |
| | | <template> |
| | | <div class="flex flex-col h-full"> |
| | | <div class="h-full flex flex-col items-center overflow-y-auto"> |
| | | <div ref="chatListDom" class="h-full" :style="{ width: chatWidth }"> |
| | | <div |
| | | class="group flex px-4 py-6 hover:bg-slate-100 rounded-lg" |
| | | :class="{ 'flex-row-reverse': item.role === RoleEnum.user }" |
| | | v-for="(item, index) of computedMessageList" |
| | | :key="index" |
| | | > |
| | | <img |
| | | class="rounded-full size-12 mr-4" |
| | | :class="{ 'mr-4': item.role === RoleEnum.assistant, 'ml-4': item.role === RoleEnum.user }" |
| | | :src="roleImageMap[item.role]" |
| | | alt="" |
| | | srcset="" |
| | | /> |
| | | |
| | | <div class="inline-flex flex-col" :class="{ 'w-full': item.role === RoleEnum.assistant }"> |
| | | <div class="relative w-full" v-if="item.content?.values"> |
| | | <div |
| | | class="text-sm rounded-[6px] p-4 leading-relaxed" |
| | | :style="{ backgroundColor: item.role === RoleEnum.user ? 'rgb(197 224 255)' : 'white' }" |
| | | > |
| | | <div v-if="item.content.errCode === ErrorCode.Message" class="text-red-500 w-full">{{ item.content.msg }}</div> |
| | | <component v-else :is="answerTypeMapCom[item.content.type]" :data="item.content.values" /> |
| | | </div> |
| | | |
| | | <div v-if="item.role === RoleEnum.assistant" class="absolute flex items-center right-0 mr-2 mt-2 space-x-2"> |
| | | <div |
| | | class="flex items-center justify-center size-[15px]" |
| | | v-if="item.content?.type === AnswerType.Text || item.content?.type === AnswerType.Knowledge" |
| | | > |
| | | <i class="p-2 ywicon icon-copy cursor-pointer hover:text-[#0284ff] hover:!text-[18px]" @click="copyClick(item)" /> |
| | | </div> |
| | | <div class="flex items-center justify-center size-[15px]"> |
| | | <i |
| | | :class="{ 'text-[#0284ff]': item.state === AnswerState.Like }" |
| | | class="p-2 ywicon icon-dianzan cursor-pointer hover:text-[#0284ff] font-medium hover:!text-[18px]" |
| | | @click="likeClick(item)" |
| | | /> |
| | | </div> |
| | | <div class="flex items-center justify-center size-[15px]"> |
| | | <i |
| | | :class="{ 'text-[#0284ff]': item.state === AnswerState.Unlike }" |
| | | class="p-2 ywicon icon-buzan cursor-pointer hover:text-[#0284ff] !text-[13px] hover:!text-[15px]" |
| | | @click="unLikeClick(item)" |
| | | /> |
| | | </div> |
| | | </div> |
| | | </div> |
| | | |
| | | <Loding v-else class="w-12" :process="process" /> |
| | | </div> |
| | | </div> |
| | | <div v-if="showAskMore" class="ml-4 mt-5 text-sm"> |
| | | <div class="text-gray-600 mb-5">你可以继续问我:</div> |
| | | <div class="space-y-2 inline-flex flex-col"> |
| | | <div |
| | | v-for="item in computedMessageList.at(-1).content.askMoreList" |
| | | :key="item.history_id" |
| | | class="bg-white p-3 hover:bg-[#c5e0ff] hover:text-[#1c86ff] cursor-pointer rounded-lg" |
| | | @click="askMoreClick(item)" |
| | | > |
| | | {{ item.question }} |
| | | </div> |
| | | </div> |
| | | </div> |
| | | </div> |
| | | </div> |
| | | |
| | | <div class="sticky bottom-0 w-full p-6 pb-8 bg-[rgb(247,248,250)] flex justify-center"> |
| | | <PlayBar |
| | | <ChatContainer :loading="chatListLoading" :more-is-loading="moreIsLoading" :is-share-page="isSharePage" ref="containerRef"> |
| | | <!-- 消息列表 --> |
| | | <template #message-list> |
| | | <MessageList |
| | | v-if="computedMessageList?.length > 0" |
| | | :msgList="computedMessageList" |
| | | :isTalking="isTalking" |
| | | v-model="messageContent.values" |
| | | @sendClick="sendChatMessage" |
| | | :style="{ width: chatWidth }" |
| | | ></PlayBar> |
| | | </div> |
| | | </div> |
| | | @shareClick="shareClick" |
| | | @setCommonQuestionClick="setCommonPhraseClick" |
| | | @sendChatMessage="sendChatMessage" |
| | | @stopGenClick="stopGenClick" |
| | | @askMoreClick="askMoreClick" |
| | | /> |
| | | <el-empty v-else-if="isSharePage && !chatListLoading" :image-size="200"> |
| | | <template #description> |
| | | <span class="text-[15px]">分享的对话不存在或已失效</span> |
| | | </template> |
| | | </el-empty> |
| | | </template> |
| | | |
| | | <!-- 输入区域 --> |
| | | <template #input-area> |
| | | <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> |
| | | |
| | | <!-- 抽屉 --> |
| | | <template #drawer> |
| | | <CustomDrawer v-model:isShow="drawerIsShow" @updateChatInput="updateChatInput" /> |
| | | <ShareLinkDlg ref="shareLinkDlgRef" /> |
| | | </template> |
| | | </ChatContainer> |
| | | </template> |
| | | |
| | | <script setup lang="ts"> |
| | | import { ElMessage } from 'element-plus'; |
| | | import { computed, nextTick, onActivated, onMounted, ref, watch } from 'vue'; |
| | | import useClipboard from 'vue-clipboard3'; |
| | | import Loding from './components/Loding.vue'; |
| | | import type { CancelTokenSource } from 'axios'; |
| | | import axios from 'axios'; |
| | | import { orderBy } from 'lodash-es'; |
| | | import moment from 'moment'; |
| | | import { computed, nextTick, onActivated, onMounted, ref } from 'vue'; |
| | | import { loadAmisSource } from '../amis/load'; |
| | | import { useScrollLoad } from './hooks/useScrollLoad'; |
| | | import type { ChatContent } from './model/types'; |
| | | import { AnswerType, RoleEnum, answerTypeMapCom, roleImageMap, type ChatMessage, AnswerState } from './model/types'; |
| | | import { GetHistoryAnswer, QueryHistoryDetail, QuestionAi, SetHistoryAnswerState, getQuestionProcess } from '/@/api/ai/chat'; |
| | | import { AnswerState, AnswerType, RoleEnum, type ChatMessage } from './model/types'; |
| | | import { getShareChatJsonByPost, questionStreamByPost } from '/@/api/ai/chat'; |
| | | import PlayBar from '/@/components/chat/components/playBar/PlayBar.vue'; |
| | | import CustomDrawer from '/@/components/drawer/CustomDrawer.vue'; |
| | | import { Logger } from '/@/model/logger/Logger'; |
| | | import { triggerRef } from 'vue'; |
| | | import { ElLoadingService, ElMessage } from 'element-plus'; |
| | | import ChatContainer from './components/ChatContainer.vue'; |
| | | import ShareLinkDlg from './components/shareLink/index.vue'; |
| | | import router from '/@/router'; |
| | | import { activeChatRoom, activeLLMId, activeRoomId, activeSampleId, activeSectionAId, roomConfig } from '/@/stores/chatRoom'; |
| | | import { v4 as uuidv4 } from 'uuid'; |
| | | import _ from 'lodash'; |
| | | import { ErrorCode } from '/@/utils/request'; |
| | | |
| | | const chatWidth = '75%'; |
| | | |
| | | import MessageList from './messageList/index.vue'; |
| | | import { |
| | | activeChatRoom, |
| | | activeGroupType, |
| | | activeLLMId, |
| | | activeRoomId, |
| | | activeSampleId, |
| | | isSharePage, |
| | | roomConfig, |
| | | } from '/@/stores/chatRoom'; |
| | | 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'; |
| | | import { getCurrentPosition } from '/@/utils/brower'; |
| | | const containerRef = useCompRef(ChatContainer); |
| | | const chatListDom = computed(() => containerRef.value?.chatListDom); |
| | | 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: '', |
| | | }); |
| | | const currentRoute = router.currentRoute; |
| | | const currentRouteId = currentRoute.value.query.id as string; |
| | | const chatListDom = ref<HTMLDivElement>(); |
| | | activeRoomId.value = currentRouteId; |
| | | const messageList = ref<ChatMessage[]>([]); |
| | | const computedMessageList = computed(() => { |
| | | return messageList.value.filter((v) => v.role !== RoleEnum.system); |
| | | return messageList.value.filter((v) => !!v); |
| | | }); |
| | | |
| | | const showAskMore = computed(() => { |
| | | if (!computedMessageList.value || computedMessageList.value.length === 0) return false; |
| | | const last = computedMessageList.value.at(-1); |
| | | const isShow = last?.role === RoleEnum.assistant && last?.content?.values && last.content?.askMoreList?.length > 0; |
| | | return isShow; |
| | | }); |
| | | |
| | | const parseContent = (res) => { |
| | | let content: ChatContent = { |
| | | type: AnswerType.Text, |
| | | values: '解析失败!', |
| | | }; |
| | | |
| | | 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.Knowledge: |
| | | content = { |
| | | type: AnswerType.Knowledge, |
| | | values: res.knowledge, |
| | | }; |
| | | |
| | | break; |
| | | case AnswerType.Summary: |
| | | content = { |
| | | type: AnswerType.Summary, |
| | | values: res.summary, |
| | | }; |
| | | break; |
| | | case AnswerType.Url: |
| | | content = { |
| | | type: AnswerType.Url, |
| | | values: res.url, |
| | | }; |
| | | break; |
| | | default: |
| | | content = { |
| | | type: AnswerType.Text, |
| | | values: '解析失败!', |
| | | }; |
| | | break; |
| | | } |
| | | content.askMoreList = _.orderBy(res.context_history, [(item) => Number(item.radio)], ['desc']); |
| | | content.errCode = res?.err_code; |
| | | content.msg = res?.json_msg; |
| | | return content; |
| | | }; |
| | | //#region ====================== 查询进度 ====================== |
| | | let processId = ''; |
| | | const QUERY_PROCESS_INTERVAL = 1000; |
| | | const process = ref(''); |
| | | let processTimer = null; |
| | | let finishProcess = true; |
| | | |
| | | const queryProcessApi = async () => { |
| | | const res = await getQuestionProcess({ |
| | | process_id: processId, |
| | | }).catch((err) => { |
| | | process.value = err; |
| | | }); |
| | | |
| | | process.value = res.process; |
| | | finishProcess = true; |
| | | }; |
| | | |
| | | const queryProcess = () => { |
| | | processTimer = setInterval(() => { |
| | | if (!finishProcess) return; |
| | | finishProcess = false; |
| | | queryProcessApi(); |
| | | }, QUERY_PROCESS_INTERVAL); |
| | | }; |
| | | |
| | | const clearQueryProcess = () => { |
| | | process.value = ''; |
| | | clearInterval(processTimer); |
| | | }; |
| | | |
| | | //#endregion |
| | | |
| | | let questionRes = null; |
| | | const preQuestion = ref(null); |
| | | |
| | | let lastAxiosSource: CancelTokenSource = null; |
| | | |
| | | // 通过修改 isTalking 来触发更新 |
| | | const triggerRefresh = () => { |
| | | isTalking.value = !isTalking.value; |
| | | |
| | | nextTick(() => { |
| | | isTalking.value = !isTalking.value; |
| | | }); |
| | | }; |
| | | let position: Position = null; |
| | | const questionAi = async (text) => { |
| | | if (!currentSectionId) { |
| | | ElMessage.warning('发送失败,未确定应用场景!'); |
| | | let judgeParams = null; |
| | | if (!preQuestion.value) { |
| | | judgeParams = {}; |
| | | } else { |
| | | judgeParams = { |
| | | prev_question: preQuestion.value, |
| | | }; |
| | | } |
| | | processId = uuidv4(); |
| | | |
| | | const params = { |
| | | process_id: processId, |
| | | question: text, |
| | | // FIXME: 暂时这样 |
| | | section_a_id: currentSectionId, |
| | | history_group_id: currentRouteId, |
| | | raw_mode: roomConfig.value?.[currentRouteId]?.isAnswerByLLM ?? false, |
| | | ...judgeParams, |
| | | } as any; |
| | | |
| | | // if (!position) { |
| | | // const loadingInstance = ElLoadingService({ |
| | | // text: '获取位置中...', |
| | | // target: '.layout-parent', |
| | | // fullscreen:false, |
| | | // }); |
| | | // position = await getCurrentPosition().finally(() => { |
| | | // loadingInstance.close(); |
| | | // }); |
| | | // } |
| | | |
| | | // if (position) { |
| | | // const { latitude, longitude } = position; |
| | | // params.cur_pos = [longitude, latitude].join(','); |
| | | // } |
| | | |
| | | if (activeGroupType.value) { |
| | | params.group_type = activeGroupType.value; |
| | | } |
| | | |
| | | if (currentSampleId) { |
| | | params.sample_id = currentSampleId; |
| | | currentSampleId = ''; |
| | | } |
| | | |
| | | if (currentLLMId) { |
| | | params.llm_id = currentLLMId; |
| | | } |
| | | clearQueryProcess(); |
| | | queryProcess(); |
| | | const res = await QuestionAi(params).finally(() => { |
| | | clearQueryProcess(); |
| | | let lastTimestamp = new Date().getTime(); |
| | | questionRes = {}; |
| | | let lastIsResult = false; |
| | | const resultP = new Promise((resolve, reject) => { |
| | | const currentSource = axios.CancelToken.source(); |
| | | lastAxiosSource = currentSource; |
| | | |
| | | const getResReport = () => { |
| | | const resReport = { |
| | | answer_type: AnswerType.Report, |
| | | reports: [], |
| | | }; |
| | | return resReport; |
| | | }; |
| | | const checkReportEmpty = () => { |
| | | const isEmpty = !questionRes?.reports || questionRes?.reports?.length === 0; |
| | | return isEmpty; |
| | | }; |
| | | questionStreamByPost( |
| | | params, |
| | | (chunkRes) => { |
| | | Logger.info('chunk response:\n\n' + JSON.stringify(chunkRes)); |
| | | |
| | | if (chunkRes.mode === 'result') { |
| | | lastIsResult = true; |
| | | const res = chunkRes.value; |
| | | if (checkReportEmpty()) { |
| | | const resReport = getResReport(); |
| | | resReport.reports.push(res); |
| | | questionRes = resReport; |
| | | // resReport.reports = resReport.reports.concat([]); |
| | | resolve(resReport); |
| | | } else { |
| | | const lastMsg = computedMessageList.value.at(-1); |
| | | // lastMsg.content.values = lastMsg.content.values.concat([]); |
| | | // 已经解析过一次 reports |
| | | if (!lastMsg.content.values) { |
| | | lastMsg.content.values = []; |
| | | } |
| | | |
| | | lastMsg.content.values.push({ |
| | | content: parseContent(res, true, { |
| | | origin: res, |
| | | }), |
| | | }); |
| | | } |
| | | triggerRefresh(); |
| | | return; |
| | | // chunkRes.value = '准备数据分析'; |
| | | } |
| | | |
| | | if (chunkRes.mode === 'summary') { |
| | | const lastMsg = computedMessageList.value.at(-1); |
| | | const extraContent = parseExtraContent(chunkRes.value); |
| | | const isReportEmpty = checkReportEmpty(); |
| | | // 没有经过 result 报告还没初始化 |
| | | if (isReportEmpty) { |
| | | const resReport = getResReport(); |
| | | questionRes = resReport; |
| | | } |
| | | // 此对话已经加入到对话列表 |
| | | if (lastMsg.content?.values && extraContent) { |
| | | for (const key in extraContent) { |
| | | if (Object.prototype.hasOwnProperty.call(extraContent, key)) { |
| | | const value = extraContent[key]; |
| | | if (!lastMsg.content[key] || (Array.isArray(lastMsg.content[key]) && lastMsg.content[key].length === 0)) { |
| | | lastMsg.content[key] = value; |
| | | } |
| | | } |
| | | } |
| | | |
| | | lastMsg.historyId = chunkRes.value.history_id; |
| | | const userMsg = computedMessageList.value.at(-2); |
| | | userMsg.historyId = chunkRes.value.history_id; |
| | | userMsg.content.values = chunkRes.value.question; |
| | | } |
| | | |
| | | if (Object.keys(questionRes).length === 0) { |
| | | questionRes = chunkRes.value; |
| | | } |
| | | |
| | | // 此对话还未加入到对话列表 |
| | | if (!lastMsg.content?.values && questionRes) { |
| | | questionRes = { |
| | | ...questionRes, |
| | | ...chunkRes.value, |
| | | }; |
| | | } |
| | | |
| | | if (isReportEmpty) { |
| | | resolve(questionRes); |
| | | } |
| | | // computedMessageList.value[computedMessageList.value.length - 1] = finalMsg; |
| | | scrollToBottom(); |
| | | // chunkRes.value = '你可以继续问我'; |
| | | return; |
| | | } |
| | | |
| | | if (chunkRes.mode === 'conclusion') { |
| | | const lastReport = computedMessageList.value.at(-1)?.content?.values?.at(-1); |
| | | if (lastReport) { |
| | | lastReport.conclusion = chunkRes.value; |
| | | chunkRes.value = '分析结束'; |
| | | } |
| | | } |
| | | const getLastGroup = () => { |
| | | const lastGroup = computedMessageList.value.at(-1).stepGroup[0]; |
| | | 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 lastStepItem = getLastStepItem(); |
| | | checkStepItem(lastStepItem); |
| | | lastStepItem.subStep.push({ |
| | | type: chunkRes.value.type, |
| | | data: chunkRes.value, |
| | | }); |
| | | scrollToBottom(); |
| | | return; |
| | | } |
| | | |
| | | // 暂时不考虑多个 report 情况 |
| | | |
| | | if (lastIsResult && chunkRes.mode !== 'finish') { |
| | | // const lastTow = computedMessageList.value.at(-1); |
| | | // lastTow.stepGroup.at(-1).value.at(-1).finishLoading = true; |
| | | // lastTow.content.values = lastTow.content.values.concat([]); |
| | | |
| | | // 开始增加新的 stepGroup,后续的 stepGroup 并没有实际作用,只是为了做迭代用,迭代出组件,屎山代码实在太难改了!!! |
| | | computedMessageList.value.at(-1).stepGroup.push({ |
| | | value: [], |
| | | isShow: true, |
| | | }); |
| | | lastIsResult = false; |
| | | } |
| | | const lastGroup = computedMessageList.value.at(-1).stepGroup[0]; |
| | | const stepList = lastGroup?.value ?? []; |
| | | const currentTimeStamp = new Date().getTime(); |
| | | const ms = toMyFixed(currentTimeStamp - lastTimestamp, 2) + ' ms'; |
| | | if (chunkRes.mode === 'finish') { |
| | | stepList.at(-1).ms = ms; |
| | | isTalking.value = false; |
| | | return; |
| | | } |
| | | |
| | | if (stepList?.length >= 1) { |
| | | stepList.at(-1).ms = ms; |
| | | } else { |
| | | const stepGroup = computedMessageList.value.at(-1).stepGroup; |
| | | if (stepGroup.length > 1) { |
| | | const lastStepList = stepGroup.at(-2).value; |
| | | lastStepList.at(-1).ms = ms; |
| | | } |
| | | } |
| | | lastTimestamp = currentTimeStamp; |
| | | const stepItem = convertProcessItem(chunkRes); |
| | | |
| | | stepList.push(stepItem); |
| | | // 强制触发更新 |
| | | |
| | | scrollToBottom(); |
| | | }, |
| | | { |
| | | cancelToken: currentSource.token, |
| | | } |
| | | ) |
| | | .catch((err) => { |
| | | throw err; |
| | | }) |
| | | .finally(() => { |
| | | isTalking.value = false; |
| | | // 收起所有 stepGroup |
| | | computedMessageList.value.at(-1).stepGroup.forEach((item) => { |
| | | item.isShow = false; |
| | | }); |
| | | }); |
| | | }); |
| | | questionRes = res; |
| | | const content = parseContent(res); |
| | | |
| | | await resultP; |
| | | const content = parseContent(questionRes, true); |
| | | return content; |
| | | }; |
| | | |
| | |
| | | values: '', |
| | | }); |
| | | |
| | | const scrollToBottom = () => { |
| | | if (!chatListDom.value) return; |
| | | chatListDom.value.lastElementChild?.scrollIntoView(); |
| | | }; |
| | | let currentSectionId = null; |
| | | let currentSampleId = null; |
| | | let currentSampleId = ''; |
| | | |
| | | let currentLLMId = null; |
| | | |
| | | const getAnswerById = async (historyId: string) => { |
| | | return await GetHistoryAnswer({ |
| | | history_id: historyId, |
| | | }); |
| | | const stopGenClick = () => { |
| | | lastAxiosSource?.cancel(); |
| | | isTalking.value = false; |
| | | chatListLoading.value = false; |
| | | |
| | | computedMessageList.value.at(-1).isStopMsg = true; |
| | | }; |
| | | |
| | | const checkCanSend = (content: ChatContent = messageContent.value) => { |
| | | if (!content?.values) { |
| | | return false; |
| | | } |
| | | if (isTalking.value || chatListLoading.value) { |
| | | ElMessage.warning('ai 正在回复中,请稍后尝试提问'); |
| | | return false; |
| | | } |
| | | return true; |
| | | }; |
| | | |
| | | const addChatItem = (content: ChatContent) => { |
| | | isTalking.value = true; |
| | | const userItem: ChatMessage = { role: RoleEnum.user, content, isChecked: false } as any; |
| | | const assistantItem: ChatMessage = { |
| | | role: RoleEnum.assistant, |
| | | content: { |
| | | type: AnswerType.Report, |
| | | }, |
| | | state: AnswerState.Null, |
| | | stepGroup: [ |
| | | { |
| | | value: [], |
| | | isShow: true, |
| | | }, |
| | | ], |
| | | isStopMsg: false, |
| | | isChecked: false, |
| | | } as any; |
| | | messageList.value.push(userItem); |
| | | clearMessageContent(); |
| | | |
| | | messageList.value.push(assistantItem); |
| | | scrollToBottom(); |
| | | return [userItem, assistantItem]; |
| | | }; |
| | | |
| | | const sendChatMessage = async (content: ChatContent = messageContent.value) => { |
| | | if (!content?.values) return; |
| | | if (messageList.value.length === 0) { |
| | | if (!checkCanSend(content)) { |
| | | return; |
| | | } |
| | | const isNewChat = messageList.value.length === 0; |
| | | if (isNewChat) { |
| | | if (activeSampleId.value) { |
| | | currentSampleId = activeSampleId.value; |
| | | } |
| | |
| | | if (activeLLMId.value) { |
| | | currentLLMId = activeLLMId.value; |
| | | } |
| | | |
| | | if (activeSectionAId.value) { |
| | | currentSectionId = activeSectionAId.value; |
| | | } |
| | | } |
| | | let resMsgContent: ChatContent = null; |
| | | |
| | | try { |
| | | isTalking.value = true; |
| | | const userItem: ChatMessage = { role: RoleEnum.user, content } as any; |
| | | const assistantItem: ChatMessage = { role: RoleEnum.assistant, content: null, state: AnswerState.Null } as any; |
| | | // 发送当前 |
| | | messageList.value.push(userItem); |
| | | // 清空输入框 |
| | | clearMessageContent(); |
| | | |
| | | // 出现回复,置空出现等待动画 |
| | | messageList.value.push(assistantItem); |
| | | |
| | | let resMsgContent: ChatContent = null; |
| | | const [userItem, assistantItem] = addChatItem(content); |
| | | resMsgContent = await questionAi(content.values); |
| | | userItem.historyId = questionRes.history_id; |
| | | assistantItem.historyId = questionRes.history_id; |
| | | appendLastMessageContent(resMsgContent); |
| | | } catch (error: any) { |
| | | appendLastMessageContent({ |
| | | 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(current); |
| | | assistantItem.createTime = currentTime; |
| | | assistantItem.content = resMsgContent; |
| | | setTimeout(() => { |
| | | // 收到回复,继续滚 |
| | | scrollToBottom(); |
| | | }, 300); |
| | | } catch (error: any) {} |
| | | }; |
| | | |
| | | const sendClick = () => { |
| | | sendChatMessage(messageContent.value); |
| | | }; |
| | | |
| | | const { loadRangeData, onChatListScroll, moreIsLoading, updateLoadIndex } = useScrollLoad({ |
| | | container: chatListDom, |
| | | historyGroupId: currentRouteId, |
| | | messageList, |
| | | 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(() => { |
| | | emitter.emit('updateHeaderTitle', activeChatRoom.value?.title ?? ''); |
| | | }); |
| | | |
| | | const initNewChat = () => { |
| | | messageContent.value = { |
| | | type: AnswerType.Text, |
| | | values: activeChatRoom.value?.title, |
| | | }; |
| | | sendChatMessage(); |
| | | }; |
| | | |
| | | const initHistoryChat = () => { |
| | | // 初始状态滚一下 |
| | | scrollToBottom(); |
| | | |
| | | setTimeout(() => { |
| | | chatListDom.value.addEventListener('scroll', onChatListScroll); |
| | | }, 300); |
| | | }; |
| | | |
| | | /** |
| | | * 加载分享数据 |
| | | */ |
| | | 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: '发生错误!', |
| | | values: msgValue.question, |
| | | }, |
| | | isChecked: false, |
| | | }; |
| | | |
| | | const assistantMsg: ChatMessage = { |
| | | historyId: msgValue.history_id, |
| | | role: RoleEnum.assistant, |
| | | content: parseContent(msgValue), |
| | | stepGroup: (msgValue?.reports ?? []).map((item) => ({ |
| | | value: convertProcessToStep(item?.exec_process), |
| | | isShow: false, |
| | | })), |
| | | isStopMsg: false, |
| | | |
| | | conclusion: msgValue.conclusion ?? [], |
| | | isChecked: false, |
| | | }; |
| | | messageList.value = [userMsg, assistantMsg]; |
| | | }; |
| | | |
| | | onMounted(async () => { |
| | | messageList.value = []; |
| | | chatListLoading.value = true; |
| | | if (isSharePage.value) { |
| | | await loadShareData().finally(() => { |
| | | chatListLoading.value = false; |
| | | }); |
| | | } finally { |
| | | isTalking.value = false; |
| | | } else { |
| | | await loadRangeData().finally(() => { |
| | | chatListLoading.value = false; |
| | | }); |
| | | } |
| | | }; |
| | | const appendLastMessageContent = (content: ChatContent) => { |
| | | if (messageList.value.at(-1)) { |
| | | messageList.value.at(-1).content = content; |
| | | setTimeout(() => { |
| | | emitter.emit('updateHeaderTitle', activeChatRoom.value?.title ?? ''); |
| | | }, 300); |
| | | |
| | | if (messageList.value.length === 0) { |
| | | initNewChat(); |
| | | } else { |
| | | if (!isSharePage.value) { |
| | | setTimeout(() => { |
| | | initHistoryChat(); |
| | | }, 300); |
| | | } |
| | | } |
| | | }; |
| | | loadAmisSource(); |
| | | }); |
| | | |
| | | const askMoreClick = (item) => { |
| | | if (!item.question) return; |
| | | sendChatMessage({ type: AnswerType.Text, values: item.question }); |
| | | }; |
| | | |
| | | onMounted(async () => { |
| | | const res = await QueryHistoryDetail({ |
| | | history_group_id: currentRouteId, |
| | | }); |
| | | //#region ====================== 侧边栏drawer ====================== |
| | | const drawerIsShow = ref(false); |
| | | |
| | | messageList.value = (res.details ?? []).map((item) => { |
| | | return { |
| | | historyId: item.history_id, |
| | | role: RoleEnum.user, |
| | | content: { |
| | | type: AnswerType.Text, |
| | | values: item.question, |
| | | }, |
| | | } as ChatMessage; |
| | | }); |
| | | currentSectionId = res?.details?.[0]?.section_a_id; |
| | | currentSampleId = res?.details?.[0]?.sample_id; |
| | | const resList = await Promise.all((res.details ?? []).map((item) => getAnswerById(item.history_id))); |
| | | let i = 0; |
| | | |
| | | resList.map((item, index) => { |
| | | const insertIndex = index + 1 + i; |
| | | messageList.value.splice(insertIndex, 0, { |
| | | historyId: item.answer.history_id, |
| | | role: RoleEnum.assistant, |
| | | content: parseContent(item.answer), |
| | | state: item.answer_state, |
| | | }); |
| | | i++; |
| | | }); |
| | | |
| | | if (messageList.value.length === 0) { |
| | | messageContent.value = { |
| | | type: AnswerType.Text, |
| | | values: activeChatRoom.value.title, |
| | | }; |
| | | |
| | | sendChatMessage(); |
| | | } |
| | | }); |
| | | let forbidScroll = false; |
| | | watch( |
| | | messageList, |
| | | () => { |
| | | if (forbidScroll) return; |
| | | nextTick(() => scrollToBottom()); |
| | | }, |
| | | { |
| | | deep: true, |
| | | } |
| | | ); |
| | | |
| | | onActivated(() => { |
| | | if (forbidScroll) return; |
| | | nextTick(() => scrollToBottom()); |
| | | }); |
| | | |
| | | //#region ====================== 聊天内容操作 ====================== |
| | | |
| | | const { toClipboard } = useClipboard(); |
| | | |
| | | const copyClick = (item) => { |
| | | const type = item.content.type; |
| | | let text = ''; |
| | | if (type === AnswerType.Knowledge) { |
| | | text = item.content.values?.map((item) => item.answer).join('\n\n') ?? ''; |
| | | } else { |
| | | text = item.content.values; |
| | | } |
| | | ElMessage.success('复制成功'); |
| | | toClipboard(text); |
| | | const updateChatInput = (content) => { |
| | | messageContent.value.values = content; |
| | | }; |
| | | //#endregion |
| | | const playBarRef = useCompRef(PlayBar); |
| | | //用户问题设置为常用语 |
| | | const setCommonPhraseClick = (item) => { |
| | | playBarRef.value.addPhrase(item); |
| | | }; |
| | | |
| | | const likeClick = async (item) => { |
| | | const toSetState = item.state === AnswerState.Like ? AnswerState.Null : AnswerState.Like; |
| | | const res = await SetHistoryAnswerState({ |
| | | history_id: item.historyId, |
| | | answer_state: toSetState, |
| | | }); |
| | | item.state = toSetState; |
| | | forbidScroll = true; |
| | | nextTick(() => { |
| | | forbidScroll = false; |
| | | }); |
| | | }; |
| | | //#region ====================== 分享 ====================== |
| | | |
| | | const unLikeClick = async (item) => { |
| | | const toSetState = item.state === AnswerState.Unlike ? AnswerState.Null : AnswerState.Unlike; |
| | | const res = await SetHistoryAnswerState({ |
| | | history_id: item.historyId, |
| | | answer_state: toSetState, |
| | | }); |
| | | item.state = toSetState; |
| | | const shareLinkDlgRef = useCompRef(ShareLinkDlg); |
| | | |
| | | forbidScroll = true; |
| | | nextTick(() => { |
| | | forbidScroll = false; |
| | | }); |
| | | const shareClick = async (item: ChatMessage) => { |
| | | shareLinkDlgRef.value.openShare(item); |
| | | }; |
| | | //#endregion |
| | | </script> |
| | | |
| | | <style scoped> |
| | | 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; |
| | | } |
| | | <style scoped lang="scss"> |
| | | @import './index.scss'; |
| | | </style> |