| | |
| | | <template> |
| | | <div class="flex h-full"> |
| | | <div class="flex flex-col h-full flex-auto"> |
| | | <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="`${item.historyId}_${item.role}`" |
| | | > |
| | | <ChatContainer |
| | | :loading="chatListLoading" |
| | | :more-is-loading="moreIsLoading" |
| | | :is-share-page="isSharePage" |
| | | :is-share-check="isShareCheck" |
| | | :chat-width="chatWidth" |
| | | ref="containerRef" |
| | | > |
| | | <!-- 消息列表 --> |
| | | <template #message-list> |
| | | <template v-if="computedMessageList?.length > 0"> |
| | | <div v-for="(item, msgIndex) of computedMessageList" :key="`${item.historyId}_${item.role}`"> |
| | | <UserMsg |
| | | :msg="item" |
| | | @copyMsg="copyClick" |
| | | @shareClick="shareClick" |
| | | @setCommonQuestion="setCommonQuestionClick" |
| | | v-if="item.role === RoleEnum.user" |
| | | ></UserMsg> |
| | | |
| | | <div v-else class="flex px-4 py-6 rounded-lg relative" :class="{ 'px-10': isShareCheck }"> |
| | | <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 }" |
| | | :class="{ 'mr-4': item.role === RoleEnum.assistant }" |
| | | :src="roleImageMap[item.role]" |
| | | alt="" |
| | | srcset="" |
| | | /> |
| | | <div class="flex-auto flex" :class="{ 'justify-end': item.role === RoleEnum.user }"> |
| | | <div class="flex-auto flex"> |
| | | <div class="inline-flex flex-col" :class="{ 'w-full': item.role === RoleEnum.assistant }"> |
| | | <div class="w-full"> |
| | | <div |
| | | class="text-sm rounded-[6px] p-4 leading-relaxed" |
| | | :style="{ backgroundColor: item.role === RoleEnum.user ? 'rgb(197 224 255)' : 'white' }" |
| | | > |
| | | <div class="flex flex-col" v-if="item?.stepList?.length > 0"> |
| | | <div class="flex items-center mb-3"> |
| | | <span class="mr-2">意图分析:</span> |
| | | <div |
| | | @click="toggleStepList(item)" |
| | | class="cursor-pointer border border-gray-300 border-solid w-fit px-2 flex items-center space-x-2 rounded-lg hover:bg-gray-100 active:bg-gray-200" |
| | | > |
| | | <span> |
| | | {{ toggleStepLabel(item) }} |
| | | </span> |
| | | <span class="ywifont" :class="{ 'ywicon-unfold': !item.stepIsShow, 'ywicon-fold': item.stepIsShow }"></span> |
| | | <div class="rounded-[6px] p-4 leading-relaxed bg-white"> |
| | | <!-- #region ====================== 消息内容 ======================--> |
| | | <!-- <template v-if="item.content?.values"> --> |
| | | <!-- #region ====================== 报错信息 ======================--> |
| | | <div v-if="item.content?.errCode === ErrorCode.Message" class="flex-column w-full"> |
| | | <p class="text-red-500"> |
| | | {{ item.content.errMsg }} |
| | | </p> |
| | | <div class="mt-3 flex" v-if="showFixQuestion(item)"> |
| | | <div class="text-gray-600 flex-0 mb-auto py-3"> |
| | | {{ '猜你想问:' }} |
| | | </div> |
| | | <div class="flex-auto space-x-2 space-y-1 inline-flex flex-wrap items-center"> |
| | | <div |
| | | v-for="fixItem in item.content.origin?.sample_question" |
| | | :key="fixItem" |
| | | class="bg-gray-200 p-3 hover:bg-[#c5e0ff] hover:text-[#1c86ff] cursor-pointer rounded-lg first-of-type:ml-2 first-of-type:mt-1" |
| | | @click="fixQuestionClick(fixItem, item.content.origin)" |
| | | > |
| | | {{ fixItem }} |
| | | </div> |
| | | </div> |
| | | </div> |
| | | |
| | | <!-- 过程输出 --> |
| | | <el-steps v-show="item.stepIsShow" direction="vertical" :active="activeStep"> |
| | | <el-step |
| | | v-for="(subItem, index) in item.stepList" |
| | | :title="subItem.title" |
| | | :status="stepEnumMap[subItem.status]" |
| | | > |
| | | <!-- <template #icon> |
| | | <span v-if="subItem.status === StepEnum.Loading" class="ywifont ywicon-loading animate-spin"></span> |
| | | <span v-else class="ywifont ywicon-loading1 animate-spin"></span> |
| | | </template> --> |
| | | <template #title> |
| | | <span class="text-sm">{{ subItem.title }}</span> |
| | | </template> |
| | | </el-step> |
| | | </el-steps> |
| | | </div> |
| | | <!-- #endregion --> |
| | | <!-- #region ====================== 回答组件 ======================--> |
| | | <template v-else> |
| | | <template v-if="item.content.type === AnswerType.Report"> |
| | | <div v-for="(num, index) in item?.stepGroup?.length" :key="index"> |
| | | <!-- #region ====================== 意图分析 ======================--> |
| | | <div class="flex flex-col" v-if="item?.stepGroup?.[index]?.value?.length > 0"> |
| | | <!-- #region ====================== 意图分析 ======================--> |
| | | <div class="flex items-center"> |
| | | <span class="mr-2">意图分析:</span> |
| | | <div |
| | | @click="toggleStepList(item?.stepGroup?.[index])" |
| | | class="cursor-pointer border border-gray-300 border-solid w-fit px-2 flex items-center space-x-2 rounded-lg hover:bg-gray-100 active:bg-gray-200" |
| | | > |
| | | <span> |
| | | {{ toggleStepLabel(item?.stepGroup?.[index]) }} |
| | | </span> |
| | | <span |
| | | class="ywifont" |
| | | :class="{ |
| | | 'ywicon-unfold': !item?.stepGroup?.[index].isShow, |
| | | 'ywicon-fold': item?.stepGroup?.[index].isShow, |
| | | }" |
| | | ></span> |
| | | </div> |
| | | </div> |
| | | <!-- #endregion --> |
| | | |
| | | <template v-if="item.content?.values"> |
| | | <div v-if="item.content.errCode === ErrorCode.Message" class="flex-column w-full"> |
| | | <p class="text-red-500"> |
| | | {{ item.content.errMsg }} |
| | | </p> |
| | | <div class="mt-5 flex items-center" v-if="showFixQuestion(item)"> |
| | | <div class="text-gray-600 flex-0"> |
| | | {{ item.content.origin.err_json.fix_question.title + ':' }} |
| | | <!-- #region ====================== 过程输出 ======================--> |
| | | <el-steps v-show="item?.stepGroup?.[index].isShow" class="mt-3" direction="vertical" :active="activeStep"> |
| | | <el-step |
| | | :key="`template-${stepIndex}`" |
| | | v-for="(subItem, stepIndex) in item?.stepGroup?.[index].value" |
| | | :title="subItem.title" |
| | | :status="stepEnumMap[subItem.status]" |
| | | > |
| | | <template |
| | | #icon |
| | | v-if=" |
| | | stepIndex + 1 === item?.stepGroup?.[index].value.length && |
| | | isTalking && |
| | | msgIndex === computedMessageList.length - 1 |
| | | " |
| | | > |
| | | <span class="ywifont ywicon-loading1 animate-spin !text-[24px]"></span> |
| | | </template> |
| | | <template #title> |
| | | <span class=""> |
| | | {{ subItem.title }} |
| | | |
| | | <span v-if="subItem.ms" class="text-green-600">{{ `(${subItem.ms})` }}</span></span |
| | | > |
| | | </template> |
| | | |
| | | <template #description v-if="subItem?.subStep?.length > 0"> |
| | | <div class="my-1 flex flex-col gap-1 text-[14px]"> |
| | | <div |
| | | :key="`${item.historyId}-${stepIndex + 1}-${multiChatIndex + 1}`" |
| | | v-for="(multiChatItem, multiChatIndex) in subItem.subStep" |
| | | > |
| | | <component |
| | | v-if="multiChatItem.type === MultiChatType.Select" |
| | | :order="`${stepIndex + 1}-${multiChatIndex + 1}`" |
| | | :item="multiChatItem" |
| | | :is="multiChatTypeMapCom[multiChatItem.type]" |
| | | :disabled=" |
| | | !( |
| | | stepIndex + 1 === item?.stepGroup?.[index].value.length && |
| | | isTalking && |
| | | msgIndex === computedMessageList.length - 1 |
| | | ) |
| | | " |
| | | /> |
| | | <component |
| | | v-else-if="multiChatItem.type === MultiChatType.Result" |
| | | :is="answerTypeMapCom['summary']" |
| | | :data="multiChatItem.data.content.values" |
| | | :originData="multiChatItem.data" |
| | | /> |
| | | <div v-else-if="multiChatItem.type === MultiChatType.Summary" class="ml-4 mt-5 pb-10"> |
| | | <div class="text-gray-600 mb-5">你可以继续问我:</div> |
| | | <div class="space-y-2 inline-flex flex-col"> |
| | | <div |
| | | v-for="item in multiChatItem.data.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> |
| | | </template> |
| | | </el-step> |
| | | </el-steps> |
| | | <!-- #endregion --> |
| | | </div> |
| | | <div class="ml-1 space-x-2 inline-flex flex-wrap"> |
| | | <div |
| | | v-for="fixItem in item.content.origin.err_json.fix_question?.values" |
| | | :key="fixItem" |
| | | class="bg-gray-200 p-3 hover:bg-[#c5e0ff] hover:text-[#1c86ff] cursor-pointer rounded-lg" |
| | | @click="fixQuestionClick(fixItem, item.content.origin)" |
| | | > |
| | | {{ fixItem.title }} |
| | | </div> |
| | | </div> |
| | | </div> |
| | | </div> |
| | | <template v-else> |
| | | <el-popover placement="bottom-start" trigger="hover" :popper-style="{ minWidth: '70px' }" :width="70"> |
| | | <template #default> |
| | | <div class="action" v-if="item.role === RoleEnum.user"> |
| | | <div class="flex items-center justify-center size-[20px]"> |
| | | <i |
| | | class="p-2 ywifont ywicon-copy cursor-pointer hover:text-[#0284ff] font-medium !text-[15px]" |
| | | @click="copyUserClick(item)" |
| | | /> |
| | | </div> |
| | | <div class="flex items-center justify-center size-[20px]"> |
| | | <i |
| | | class="p-2 ywifont ywicon-cubelifangti cursor-pointer hover:text-[#0284ff] text-[#000] font-[590] !text-[15px]" |
| | | @click="setCommonQuestionClick(item)" |
| | | /> |
| | | </div> |
| | | </div> |
| | | </template> |
| | | <template #reference> |
| | | <component |
| | | :is="answerTypeMapCom[item.content.type]" |
| | | v-if="item.role === RoleEnum.user" |
| | | :data="item.content.values" |
| | | :originData="item" |
| | | /> |
| | | </template> |
| | | </el-popover> |
| | | <component |
| | | :is="answerTypeMapCom[item.content.type]" |
| | | v-if="item.role !== RoleEnum.user" |
| | | :data="item.content.values" |
| | | :originData="item" |
| | | /> |
| | | <div |
| | | v-if="item.role === RoleEnum.assistant && item.content.origin?.ext_call_list" |
| | | class="flex font-bold items-center mt-6" |
| | | > |
| | | <div class="flex-0 mb-auto -mr-4">关联功能:</div> |
| | | <div class="space-x-5 flex flex-wrap"> |
| | | <div |
| | | v-for="callItem in item.content.origin?.ext_call_list" |
| | | :key="callItem.call_ext_id" |
| | | @click="relativeQueryClick(callItem)" |
| | | class="cursor-pointer hover:underline first-of-type:ml-5" |
| | | > |
| | | {{ callItem.question }} |
| | | </div> |
| | | </div> |
| | | <!-- #endregion --> |
| | | |
| | | <component |
| | | v-if="item.content?.values?.[index]" |
| | | :reportIndex="index" |
| | | :conclusion="item.content.values[index].conclusion" |
| | | :is="answerTypeMapCom[item.content.values[index].content.type]" |
| | | :data="item.content.values[index].content.values" |
| | | :originData="item.content.values[index]" |
| | | :historyId="item.historyId" |
| | | :isTalking="isTalking && msgIndex === computedMessageList.length - 1" |
| | | /> |
| | | </div> |
| | | </template> |
| | | <component |
| | | v-else |
| | | :historyId="item.historyId" |
| | | :conclusion="item.conclusion" |
| | | :is="answerTypeMapCom[item.content.type]" |
| | | :data="item.content.values" |
| | | :originData="item" |
| | | :isTalking="isTalking && msgIndex === computedMessageList.length - 1" |
| | | /> |
| | | <div |
| | | v-if="item.role === RoleEnum.assistant && item.content.origin?.ext_call_list" |
| | | class="flex font-bold items-center mt-6" |
| | | > |
| | | <div class="flex-0 mb-auto -mr-4">关联功能:</div> |
| | | <div class="space-x-5 flex flex-wrap"> |
| | | <div |
| | | v-for="callItem in item.content.origin?.ext_call_list" |
| | | :key="callItem.call_ext_id" |
| | | @click="relativeQueryClick(callItem)" |
| | | class="cursor-pointer hover:underline first-of-type:ml-5" |
| | | > |
| | | {{ callItem.question }} |
| | | </div> |
| | | </div> |
| | | </div> |
| | | </template> |
| | | <!-- #endregion --> |
| | | <!-- </template> --> |
| | | |
| | | <!-- #endregion --> |
| | | <!-- #region ====================== 附加内容 ======================--> |
| | | <!-- #region ====================== 停止 ======================--> |
| | | <span v-if="item.isStopMsg && item?.role === RoleEnum.assistant" class="text-gray-400 text-[12px]" |
| | | >(已停止)</span |
| | | > |
| | | <!-- parseContent 返回为 null --> |
| | | <p v-if="!item.content && !isTalking && !item.isStopMsg" class="text-red-500">暂无数据</p> |
| | | <!-- #endregion --> |
| | | <!-- #endregion --> |
| | | </div> |
| | | <!-- 操作 --> |
| | | <!-- #region ====================== ai 消息操作 ======================--> |
| | | <div |
| | | v-if="item.role === RoleEnum.assistant && item.content?.values" |
| | | v-if="item.role === RoleEnum.assistant && item.content?.values && !isSharePage && !isShareCheck" |
| | | class="absolute flex items-center right-0 mr-4 mt-2 space-x-2" |
| | | > |
| | | <div |
| | |
| | | /> |
| | | </div> |
| | | <template v-if="item.content.errCode !== ErrorCode.Message"> |
| | | <div class="flex items-center justify-center size-[15px]"> |
| | | <i |
| | | :class="{ 'text-[#0284ff]': item.state === AnswerState.Like }" |
| | | class="p-2 ywifont ywicon-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 ywifont ywicon-buzan cursor-pointer hover:text-[#0284ff] !text-[13px] hover:!text-[15px]" |
| | | @click="unLikeClick(item)" |
| | | /> |
| | | </div> |
| | | <el-tooltip effect="dark" content="点赞" placement="top"> |
| | | <div class="flex items-center justify-center size-[15px]"> |
| | | <i |
| | | :class="{ 'text-[#0284ff]': item.state === AnswerState.Like }" |
| | | class="p-2 ywifont ywicon-dianzan cursor-pointer hover:text-[#0284ff] font-medium hover:!text-[18px]" |
| | | @click="likeClick(item)" |
| | | /> |
| | | </div> |
| | | </el-tooltip> |
| | | <el-tooltip effect="dark" content="点踩" placement="top"> |
| | | <div class="flex items-center justify-center size-[15px]"> |
| | | <i |
| | | :class="{ 'text-[#0284ff]': item.state === AnswerState.Unlike }" |
| | | class="p-2 ywifont ywicon-buzan cursor-pointer hover:text-[#0284ff] !text-[13px] hover:!text-[15px]" |
| | | @click="unLikeClick(item)" |
| | | /> |
| | | </div> |
| | | </el-tooltip> |
| | | </template> |
| | | |
| | | <div class="flex items-center justify-center size-[15px] relative"> |
| | | <i |
| | | class="p-2 ywifont ywicon-wentifankui cursor-pointer hover:text-[#0284ff] !text-[13px] hover:!text-[15px]" |
| | | @click=" |
| | | ($event) => |
| | | feedbackClick( |
| | | $event, |
| | | item, |
| | | computedMessageList |
| | | .filter((v) => v.role === RoleEnum.assistant) |
| | | .findIndex((v) => v.historyId === item.historyId) |
| | | ) |
| | | " |
| | | /> |
| | | <FeedbackPanel |
| | | v-show="feedbackIsShow && currentFeedbackMapItem === item" |
| | | ref="feedbackPanelRef" |
| | | v-model:isShow="feedbackIsShow" |
| | | v-model:content="feedbackContent" |
| | | :chatItem="currentFeedbackMapItem" |
| | | :position="feedbackPosition" |
| | | /> |
| | | </div> |
| | | <el-tooltip effect="dark" content="分享" placement="top"> |
| | | <div class="flex items-center justify-center size-[15px]"> |
| | | <i |
| | | class="p-2 ywifont ywicon-fenxiang cursor-pointer hover:text-[#0284ff] !text-[15px] hover:!text-[18px]" |
| | | @click="shareClick(item)" |
| | | /> |
| | | </div> |
| | | </el-tooltip> |
| | | <el-tooltip effect="dark" content="反馈" placement="top"> |
| | | <div class="flex items-center justify-center size-[15px] relative"> |
| | | <i |
| | | class="p-2 ywifont ywicon-wentifankui cursor-pointer hover:text-[#0284ff] !text-[13px] hover:!text-[15px]" |
| | | @click=" |
| | | ($event) => |
| | | feedbackClick( |
| | | $event, |
| | | item, |
| | | computedMessageList |
| | | .filter((v) => v.role === RoleEnum.assistant) |
| | | .findIndex((v) => v.historyId === item.historyId) |
| | | ) |
| | | " |
| | | /> |
| | | <FeedbackPanel |
| | | v-show="feedbackIsShow && currentFeedbackMapItem === item" |
| | | ref="feedbackPanelRef" |
| | | v-model:isShow="feedbackIsShow" |
| | | v-model:content="feedbackContent" |
| | | :chatItem="currentFeedbackMapItem" |
| | | :position="feedbackPosition" |
| | | /> |
| | | </div> |
| | | </el-tooltip> |
| | | </div> |
| | | <!-- #endregion --> |
| | | </div> |
| | | </div> |
| | | </div> |
| | | </div> |
| | | <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 |
| | | 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 v-if="showAskMore" class="ml-4 mt-5 pb-10"> |
| | | <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> |
| | | </template> |
| | | <el-empty v-else-if="isSharePage && !chatListLoading" :image-size="200"> |
| | | <template #description> |
| | | <span class="text-[15px]">分享的对话不存在或已失效</span> |
| | | </template> |
| | | </el-empty> |
| | | </template> |
| | | |
| | | <div class="sticky bottom-0 w-full p-6 bg-[rgb(247,248,250)] flex justify-center"> |
| | | <PlayBar |
| | | v-model:voicePageIsShow="voicePageIsShow" |
| | | :isTalking="isTalking" |
| | | :isHome="false" |
| | | v-model="messageContent.values" |
| | | @sendClick="sendClick" |
| | | @showUpChatClick="showUpChatClick" |
| | | @showDownChatClick="showDownChatClick" |
| | | :style="{ width: chatWidth }" |
| | | ></PlayBar> |
| | | </div> |
| | | </div> |
| | | <CustomDrawer v-model:isShow="drawerIsShow" @updateChatInput="updateChatInput" /> |
| | | </div> |
| | | <!-- 输入区域 --> |
| | | <template #input-area> |
| | | <PlayBar |
| | | v-model:voicePageIsShow="voicePageIsShow" |
| | | :isTalking="isTalking" |
| | | :isHome="false" |
| | | v-model="messageContent.values" |
| | | @sendClick="sendClick" |
| | | @showUpChatClick="showUpChatClick" |
| | | @stopGenClick="stopGenClick" |
| | | @showDownChatClick="showDownChatClick" |
| | | :style="{ width: chatWidth }" |
| | | :setCommonQuestionInfo="setCommonQuestionInfo" |
| | | /> |
| | | </template> |
| | | |
| | | <!-- 抽屉 --> |
| | | <template #drawer> |
| | | <CustomDrawer v-model:isShow="drawerIsShow" @updateChatInput="updateChatInput" /> |
| | | <ShareLinkDlg ref="shareLinkDlgRef" /> |
| | | </template> |
| | | </ChatContainer> |
| | | </template> |
| | | |
| | | <script setup lang="ts"> |
| | | import _ from 'lodash'; |
| | | import type { CancelTokenSource } from 'axios'; |
| | | import axios from 'axios'; |
| | | import { findLast, orderBy } from 'lodash-es'; |
| | | import moment from 'moment'; |
| | | import { v4 as uuidv4 } from 'uuid'; |
| | | import { computed, onMounted, ref } from 'vue'; |
| | | import { computed, onActivated, onMounted, ref } from 'vue'; |
| | | import useClipboard from 'vue-clipboard3'; |
| | | import { loadAmisSource } from '../amis/load'; |
| | | import FeedbackPanel from './components/FeedbackPanel.vue'; |
| | | import Loding from './components/Loding.vue'; |
| | | import { useAssistantContentOpt } from './hooks/useAssistantContentOpt'; |
| | | import { useQueryProcess } from './hooks/useQueryProcess'; |
| | | import { convertProcessItem, useScrollLoad } from './hooks/useScrollLoad'; |
| | | import { useScrollToBottom } from './hooks/useScrollToBottom'; |
| | | import type { ChatContent, StepItem } from './model/types'; |
| | | import { AnswerState, AnswerType, RoleEnum, answerTypeMapCom, roleImageMap, type ChatMessage, stepEnumMap } from './model/types'; |
| | | import { QuestionAi, extCallQuery, questionStreamByPost } from '/@/api/ai/chat'; |
| | | import type { ChatContent } from './model/types'; |
| | | import { |
| | | AnswerState, |
| | | AnswerType, |
| | | MultiChatType, |
| | | RoleEnum, |
| | | answerTypeMapCom, |
| | | roleImageMap, |
| | | stepEnumMap, |
| | | type ChatMessage, |
| | | } from './model/types'; |
| | | import { extCallQuery, 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 { ElMessage } from 'element-plus'; |
| | | import ChatContainer from './components/ChatContainer.vue'; |
| | | import ShareLinkDlg from './components/shareLink/index.vue'; |
| | | import UserMsg from './user/index.vue'; |
| | | import { multiChatTypeMapCom } from '/@/components/chat/chatComponents/multiChat'; |
| | | import router from '/@/router'; |
| | | import { |
| | | activeChatRoom, |
| | |
| | | activeSampleId, |
| | | activeSectionAId, |
| | | getRoomConfig, |
| | | isSharePage, |
| | | roomConfig, |
| | | } from '/@/stores/chatRoom'; |
| | | import emitter from '/@/utils/mitt'; |
| | | import { ErrorCode } from '/@/utils/request'; |
| | | import { useCompRef } from '/@/utils/types'; |
| | | import { toMyFixed } from '/@/utils/util'; |
| | | const containerRef = ref(); |
| | | const chatListDom = computed(() => containerRef.value?.chatListDom); |
| | | const chatWidth = '75%'; |
| | | const voicePageIsShow = ref(false); |
| | | let isTalking = ref(false); |
| | | |
| | | let messageContent = ref<ChatContent>({ |
| | | type: AnswerType.Text, |
| | | values: '', |
| | |
| | | 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) => { |
| | | |
| | | 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: '解析失败!', |
| | | }; |
| | | |
| | | const curExtraContent = parseExtraContent(res); |
| | | |
| | | switch (res.answer_type) { |
| | | case AnswerType.RecordSet: |
| | |
| | | }; |
| | | |
| | | break; |
| | | case AnswerType.Report: |
| | | content = { |
| | | type: AnswerType.Report, |
| | | values: (res?.reports ?? []).map((item) => ({ |
| | | content: parseContent(item, reportIsShow, { origin: item }), |
| | | })), |
| | | }; |
| | | break; |
| | | |
| | | case AnswerType.Summary: |
| | | content = { |
| | | type: AnswerType.Summary, |
| | | values: res.summary, |
| | | values: res.summary?.map((item) => { |
| | | item.reportIsShow = reportIsShow; |
| | | return item; |
| | | }), |
| | | }; |
| | | break; |
| | | case AnswerType.Url: |
| | |
| | | }; |
| | | break; |
| | | } |
| | | content.askMoreList = _.orderBy(res.context_history, [(item) => Number(item.radio)], ['desc']); |
| | | content.errCode = res?.err_code; |
| | | content.errMsg = res?.json_msg; |
| | | content.origin = res; |
| | | if (!extraContent) { |
| | | content = { |
| | | ...content, |
| | | ...curExtraContent, |
| | | }; |
| | | } else { |
| | | content = { |
| | | ...content, |
| | | ...extraContent, |
| | | }; |
| | | } |
| | | |
| | | return content; |
| | | }; |
| | | const { clearQueryProcess, process, processId, queryProcess } = useQueryProcess(); |
| | | |
| | | //#region ====================== 步骤 step ====================== |
| | | const activeStep = ref(-1); |
| | | const stepList = ref<StepItem[]>([ |
| | | { |
| | | title: '意图分析中...', |
| | | status: 0, |
| | | }, |
| | | { |
| | | title: '意图分析完成', |
| | | status: 1, |
| | | }, |
| | | { |
| | | title: '思考如何执行:指标明细查询', |
| | | status: 1, |
| | | }, |
| | | { |
| | | title: '指标明细查询完成', |
| | | status: 1, |
| | | }, |
| | | ]); |
| | | |
| | | const resetStep = () => { |
| | | activeStep.value = -1; |
| | | stepList.value = []; |
| | | }; |
| | | |
| | | const toggleStepLabel = (item: ChatMessage) => (item.stepIsShow ? '收起' : '展开'); |
| | | const toggleStepList = (item: ChatMessage) => { |
| | | item.stepIsShow = !item.stepIsShow; |
| | | const toggleStepLabel = (item: any) => (item.isShow ? '收起' : '展开'); |
| | | const toggleStepList = (item: any) => { |
| | | item.isShow = !item.isShow; |
| | | }; |
| | | |
| | | //#endregion |
| | | |
| | | const DEFAULT_SECTION_A_ID = 'knowledge_base'; |
| | | let questionRes = null; |
| | | |
| | | let position = null; |
| | | let finalCalcSectionAId = null; |
| | | const questionAi = async (text, assistantMsg: ChatMessage) => { |
| | | // processId.value = uuidv4(); |
| | | |
| | | let lastAxiosSource: CancelTokenSource = null; |
| | | const questionAi = async (text) => { |
| | | let judgeParams = null; |
| | | if (!preQuestion.value) { |
| | | // const aiContent = computedMessageList.value.filter((item) => item.role === RoleEnum.assistant); |
| | | // const lastQuestion = aiContent[aiContent.length - 2]?.content?.origin?.question; |
| | | // judgeParams = lastQuestion |
| | | // ? { |
| | | // prev_question: lastQuestion, |
| | | // } |
| | | // : {}; |
| | | // 正常回答暂时不采用 |
| | | judgeParams = {}; |
| | | } else { |
| | | judgeParams = { |
| | |
| | | currentSectionAId = activeSectionAId.value; |
| | | activeSectionAId.value = ''; |
| | | } else { |
| | | const lastSectionAItem = _.findLast( |
| | | const lastSectionAItem = findLast( |
| | | computedMessageList.value as any, |
| | | (item) => item.role === RoleEnum.assistant && !!item.sectionAId |
| | | ); |
| | |
| | | finalCalcSectionAId = currentSectionAId; |
| | | |
| | | const params = { |
| | | // process_id: processId.value, |
| | | question: text, |
| | | // FIXME: 暂时这样 |
| | | // section_a_id: currentSectionAId, |
| | | history_group_id: currentRouteId, |
| | | raw_mode: roomConfig.value?.[currentRouteId]?.isAnswerByLLM ?? false, |
| | | ...judgeParams, |
| | | } as any; |
| | | |
| | | if (position) { |
| | | const longitude = position.coords.longitude; |
| | | const latitude = position.coords.latitude; |
| | | params.cur_pos = [longitude, latitude].join(','); |
| | | } |
| | | |
| | | if (activeGroupType.value) { |
| | | params.group_type = activeGroupType.value; |
| | |
| | | currentSampleId = ''; |
| | | } |
| | | |
| | | // if (currentLLMId) { |
| | | // params.llm_id = currentLLMId; |
| | | // } |
| | | // clearQueryProcess(); |
| | | // queryProcess(); |
| | | resetStep(); |
| | | let res = null; |
| | | await questionStreamByPost(params, (chunkRes) => { |
| | | if (chunkRes.mode === 'result') { |
| | | res = chunkRes.value; |
| | | } else { |
| | | const stepItem = convertProcessItem(chunkRes); |
| | | computedMessageList.value.at(-1).stepList.push(stepItem); |
| | | scrollToBottom(); |
| | | } |
| | | }).finally(() => { |
| | | computedMessageList.value.at(-1).stepIsShow = false; |
| | | resetStep(); |
| | | let lastTimestamp = new Date().getTime(); |
| | | questionRes = {}; |
| | | let lastIsResult = false; |
| | | const resultP = new Promise((resolve, reject) => { |
| | | const currentSource = axios.CancelToken.source(); |
| | | lastAxiosSource = currentSource; |
| | | questionStreamByPost( |
| | | params, |
| | | (chunkRes) => { |
| | | Logger.info('chunk response:\n\n' + JSON.stringify(chunkRes)); |
| | | |
| | | if (chunkRes.mode === 'result') { |
| | | lastIsResult = true; |
| | | const res = chunkRes.value; |
| | | |
| | | if (!questionRes?.reports || questionRes?.reports?.length === 0) { |
| | | const resReport = { |
| | | answer_type: AnswerType.Report, |
| | | reports: [res], |
| | | }; |
| | | questionRes = resReport; |
| | | resolve(resReport); |
| | | } else { |
| | | const lastMsg = computedMessageList.value.at(-1); |
| | | |
| | | // 已经解析过一次 reports |
| | | lastMsg.content.values.push({ |
| | | content: parseContent(res, true, { |
| | | origin: res, |
| | | }), |
| | | }); |
| | | } |
| | | return; |
| | | // chunkRes.value = '准备数据分析'; |
| | | } |
| | | |
| | | if (chunkRes.mode === 'summary') { |
| | | const lastMsg = computedMessageList.value.at(-1); |
| | | const extraContent = parseExtraContent(chunkRes.value); |
| | | // 此对话已经加入到对话列表 |
| | | 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, |
| | | }; |
| | | } |
| | | // computedMessageList.value[computedMessageList.value.length - 1] = finalMsg; |
| | | scrollToBottom(); |
| | | // chunkRes.value = '你可以继续问我'; |
| | | return; |
| | | } |
| | | |
| | | if (chunkRes.mode === 'conclusion') { |
| | | computedMessageList.value.at(-1).conclusion = chunkRes.value; |
| | | chunkRes.value = '分析结束'; |
| | | } |
| | | |
| | | 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 = []; |
| | | } |
| | | lastStepItem.subStep.push({ |
| | | type: chunkRes.value.type, |
| | | data: chunkRes.value, |
| | | }); |
| | | scrollToBottom(); |
| | | return; |
| | | } |
| | | |
| | | if (lastIsResult && chunkRes.mode !== 'finish') { |
| | | // 开始增加新的 stepGroup |
| | | computedMessageList.value.at(-1).stepGroup.push({ |
| | | value: [], |
| | | isShow: true, |
| | | }); |
| | | lastIsResult = false; |
| | | } |
| | | const lastGroup = computedMessageList.value.at(-1).stepGroup.at(-1); |
| | | 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; |
| | | }); |
| | | |
| | | resetStep(); |
| | | }); |
| | | }); |
| | | questionRes = res; |
| | | const content = parseContent(res); |
| | | |
| | | await resultP; |
| | | const content = parseContent(questionRes, true); |
| | | return content; |
| | | }; |
| | | |
| | |
| | | |
| | | let currentLLMId = null; |
| | | |
| | | const stopGenClick = () => { |
| | | lastAxiosSource?.cancel(); |
| | | isTalking.value = false; |
| | | chatListLoading.value = false; |
| | | resetStep(); |
| | | computedMessageList.value.at(-1).isStopMsg = true; |
| | | }; |
| | | |
| | | const sendChatMessage = async (content: ChatContent = messageContent.value, cb?: any, isCallExtParams?: any) => { |
| | | if (!content?.values || isTalking.value || chatListLoading.value) return; |
| | | if (!content?.values) { |
| | | return; |
| | | } |
| | | if (isTalking.value || chatListLoading.value) { |
| | | ElMessage.warning('ai 正在回复中,请稍后尝试提问'); |
| | | return; |
| | | } |
| | | |
| | | const isNewChat = messageList.value.length === 0; |
| | | if (isNewChat) { |
| | | if (activeSampleId.value) { |
| | |
| | | |
| | | try { |
| | | isTalking.value = true; |
| | | const userItem: ChatMessage = { role: RoleEnum.user, content } as any; |
| | | const userItem: ChatMessage = { role: RoleEnum.user, content, isChecked: false } as any; |
| | | const assistantItem: ChatMessage = { |
| | | role: RoleEnum.assistant, |
| | | content: null, |
| | | content: { |
| | | type: AnswerType.Report, |
| | | }, |
| | | state: AnswerState.Null, |
| | | stepList: [], |
| | | stepIsShow: true, |
| | | stepGroup: [ |
| | | { |
| | | value: [], |
| | | isShow: true, |
| | | }, |
| | | ], |
| | | isStopMsg: false, |
| | | isChecked: false, |
| | | } as any; |
| | | // 发送当前 |
| | | messageList.value.push(userItem); |
| | | // 清空输入框 |
| | | clearMessageContent(); |
| | | |
| | | // 出现回复,置空出现等待动画 |
| | | messageList.value.push(assistantItem); |
| | | // 滚动至当前发送消息 |
| | | scrollToBottom(); |
| | | |
| | | if (isCallExtParams) { |
| | | const extRes = await extCallQuery(isCallExtParams); |
| | | questionRes = extRes; |
| | | resMsgContent = parseContent(extRes); |
| | | resMsgContent = parseContent(extRes, true); |
| | | } else { |
| | | resMsgContent = await questionAi(content.values, assistantItem); |
| | | resMsgContent = await questionAi(content.values); |
| | | } |
| | | nextUserMsgEndIndex.value++; |
| | | if (isNewChat) { |
| | |
| | | } else { |
| | | cb?.(resMsgContent); |
| | | } |
| | | userItem.historyId = questionRes.history_id; |
| | | userItem.historyId = questionRes?.history_id; |
| | | userItem.content.values = questionRes?.question ?? userItem.content.values; |
| | | assistantItem.historyId = questionRes.history_id; |
| | | assistantItem.historyId = questionRes?.history_id; |
| | | assistantItem.sectionAId = finalCalcSectionAId; |
| | | appendLastMessageContent(resMsgContent); |
| | | setTimeout(() => { |
| | | // 收到回复,继续滚 |
| | | scrollToBottom(); |
| | | }, 300); |
| | | } catch (error: any) { |
| | | // appendLastMessageContent({ |
| | | // type: AnswerType.Text, |
| | | // values: '发生错误!', |
| | | // }); |
| | | } finally { |
| | | isTalking.value = false; |
| | | } |
| | | } catch (error: any) {} |
| | | }; |
| | | |
| | | const sendClick = (cb) => { |
| | |
| | | messageList.value.at(-1).createTime = currentTime; |
| | | } |
| | | }; |
| | | |
| | | const { loadRangeData, onChatListScroll, moreIsLoading, nextUserMsgEndIndex } = useScrollLoad({ |
| | | container: chatListDom, |
| | | historyGroupId: currentRouteId, |
| | |
| | | parseAnswerContent: parseContent, |
| | | }); |
| | | |
| | | const chatListLoading = ref(false); |
| | | const chatListLoading = ref(true); |
| | | |
| | | const { scrollToBottom } = useScrollToBottom({ |
| | | const { scrollToBottom, scrollToTop, isBottom } = useScrollToBottom({ |
| | | chatListDom: chatListDom, |
| | | }); |
| | | |
| | | onActivated(() => { |
| | | emitter.emit('updateHeaderTitle', activeChatRoom.value?.title ?? ''); |
| | | }); |
| | | |
| | | onMounted(async () => { |
| | | messageList.value = []; |
| | | // 加载初始数据 |
| | | chatListLoading.value = true; |
| | | |
| | | await loadRangeData().finally(() => { |
| | | chatListLoading.value = false; |
| | | }); |
| | | setTimeout(() => { |
| | | emitter.emit('updateHeaderTitle', activeChatRoom.value?.title ?? ''); |
| | | }, 300); |
| | | |
| | | if (messageList.value.length === 0) { |
| | | messageContent.value = { |
| | | type: AnswerType.Text, |
| | | values: activeChatRoom.value.title, |
| | | values: activeChatRoom.value?.title, |
| | | }; |
| | | |
| | | sendChatMessage(); |
| | | } else { |
| | | setTimeout(() => { |
| | | // 初始状态滚一下 |
| | | scrollToBottom(); |
| | | |
| | | if (isSharePage.value) { |
| | | // setTimeout(() => { |
| | | // // 滚动到顶部 |
| | | // scrollToTop(); |
| | | // }, 300); |
| | | } else { |
| | | setTimeout(() => { |
| | | chatListDom.value.addEventListener('scroll', onChatListScroll); |
| | | // 初始状态滚一下 |
| | | scrollToBottom(); |
| | | |
| | | setTimeout(() => { |
| | | chatListDom.value.addEventListener('scroll', onChatListScroll); |
| | | }, 300); |
| | | }, 300); |
| | | }, 300); |
| | | } |
| | | } |
| | | loadAmisSource(); |
| | | }); |
| | | //#region ====================== 关联查询 ====================== |
| | | const relativeQueryClick = async (val) => { |
| | |
| | | //显示上一条消息 |
| | | const showUpChatClick = () => { |
| | | if (computedMessageList.value.length === 0) return; |
| | | if (currentIndex.value === null) { |
| | | currentIndex.value = history_data.value.length - 1; |
| | | if (currentIndex.value == 0) { |
| | | messageContent.value.values = history_data.value[currentIndex.value].content.values; |
| | | return; |
| | | } else { |
| | | currentIndex.value = (currentIndex.value + history_data.value.length - 1) % history_data.value.length; |
| | | } |
| | |
| | | //显示下一条消息 |
| | | const showDownChatClick = () => { |
| | | if (computedMessageList.value.length === 0) return; |
| | | if (currentIndex.value == history_data.value.length - 1) { |
| | | messageContent.value.values = history_data.value[currentIndex.value].content.values; |
| | | return; |
| | | } |
| | | if (currentIndex.value === null) { |
| | | currentIndex.value = 0; |
| | | } else { |
| | |
| | | }; |
| | | //#endregion |
| | | //#region ====================== 用户询问的问题设置为常用语 ====================== |
| | | const setCommonQuestionInfo = ref({}); |
| | | const { toClipboard } = useClipboard(); |
| | | |
| | | //用户复制问题 |
| | | const copyUserClick = () => {}; |
| | | const copyUserClick = (item) => { |
| | | const text = item.content.values; |
| | | ElMessage.success('复制成功'); |
| | | toClipboard(text); |
| | | }; |
| | | //用户问题设置为常用语 |
| | | const setCommonQuestionClick = () => {}; |
| | | const setCommonQuestionClick = (item) => { |
| | | setCommonQuestionInfo.value = item; |
| | | }; |
| | | //#endregion |
| | | |
| | | //#region ====================== 分享 ====================== |
| | | |
| | | const shareLinkDlgRef = useCompRef(ShareLinkDlg); |
| | | const isShareCheck = ref(false); |
| | | |
| | | const shareClick = async (item: ChatMessage) => { |
| | | shareLinkDlgRef.value.openShare(item); |
| | | }; |
| | | //#endregion |
| | | </script> |
| | | |
| | |
| | | font-size: 16px !important; |
| | | } |
| | | :deep(.el-step__description) { |
| | | height: 20px; |
| | | min-height: 20px; |
| | | } |
| | | .action { |
| | | left: 0; |
| | | padding: 4px; |
| | | gap: 4px; |
| | | border-radius: 4px; |
| | | display: flex; |
| | | align-items: center; |
| | | flex-direction: row; |
| | | position: absolute; |
| | | top: 0; |
| | | } |
| | | .action { |
| | | left: 0; |
| | | padding: 4px; |
| | | gap: 4px; |
| | | border-radius: 4px; |
| | | display: flex; |
| | | align-items: center; |
| | | flex-direction: row; |
| | | position: absolute; |
| | | top: 0; |
| | | |
| | | :deep(.el-step:last-of-type .el-step__description) { |
| | | // display: none; |
| | | } |
| | | </style> |