From 05f34e1af59e139e6e914e772ba7dcd5b4bf680d Mon Sep 17 00:00:00 2001 From: yangyin <1850366751@qq.com> Date: 星期四, 31 十月 2024 15:56:26 +0800 Subject: [PATCH] 修改当天询问的问题时间 --- src/components/chat/Chat.vue | 637 +++++++++++++++++++++++++++++++++++++++++++-------------- 1 files changed, 474 insertions(+), 163 deletions(-) diff --git a/src/components/chat/Chat.vue b/src/components/chat/Chat.vue index 626008f..3fb1699 100644 --- a/src/components/chat/Chat.vue +++ b/src/components/chat/Chat.vue @@ -1,207 +1,518 @@ <template> - <div class="flex flex-col h-screen"> - <div class="flex flex-nowrap fixed w-full items-baseline top-0 px-6 py-4 bg-gray-100"> - <div class="text-2xl font-bold">ChatGPT</div> - <div class="ml-4 text-sm text-gray-500">鍩轰簬 OpenAI 鐨� ChatGPT 鑷劧璇█妯″瀷浜哄伐鏅鸿兘瀵硅瘽</div> - <div class="ml-auto px-3 py-2 text-sm cursor-pointer hover:bg-white rounded-md" @click="clickConfig()">璁剧疆</div> - </div> + <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}`" + > + <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 }" + :src="roleImageMap[item.role]" + alt="" + srcset="" + /> + <div class="flex-auto flex" :class="{ 'justify-end': item.role === RoleEnum.user }"> + <div class="inline-flex flex-col" :class="{ 'w-full': item.role === RoleEnum.assistant }"> + <div class="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="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 + '锛�' }} + </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> + <component :is="answerTypeMapCom[item.content.type]" :data="item.content.values" :originData="item" /> - <div class="flex-1 mx-2 mt-20 mb-2" ref="chatListDom"> - <div - class="group flex flex-col px-4 py-3 hover:bg-slate-100 rounded-lg" - v-for="(item, index) of messageList.filter((v) => v.role !== 'system')" - :key="index" - > - <div class="flex justify-between items-center mb-2"> - <div class="font-bold">{{ roleAlias[item.role] }}锛�</div> - <Copy class="invisible group-hover:visible" :content="item.content" /> + <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> + </div> + + <!-- 鎿嶄綔 --> + <div v-if="item.role === RoleEnum.assistant" class="absolute flex items-center right-0 mr-4 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 ywifont ywicon-copy cursor-pointer hover:text-[#0284ff] hover:!text-[18px]" + @click="copyClick(item)" + /> + </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> + </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> + </div> + </div> + + <Loding v-if="isTalking && index === computedMessageList.length - 1" class="w-fit" :process="process" /> + </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> </div> - <div> - <div class="prose text-sm text-slate-600 leading-relaxed" v-if="item.content" v-html="md.render(item.content)"></div> - <Loding v-else /> - </div> + </div> + + <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" + :style="{ width: chatWidth }" + ></PlayBar> </div> </div> - <div class="sticky bottom-0 w-full p-6 pb-8 bg-gray-100"> - <div class="-mt-2 mb-2 text-sm text-gray-500" v-if="isConfig">璇疯緭鍏� API Key锛�</div> - <div class="flex"> - <input - class="input" - :type="isConfig ? 'password' : 'text'" - :placeholder="isConfig ? 'sk-xxxxxxxxxx' : '璇疯緭鍏�'" - v-model="messageContent" - @keydown.enter="isTalking || sendOrSave()" - /> - <button class="btn" :disabled="isTalking" @click="sendOrSave()"> - {{ isConfig ? '淇濆瓨' : '鍙戦��' }} - </button> - </div> - </div> + <CustomDrawer v-model:isShow="drawerIsShow" @updateChatInput="updateChatInput" /> </div> </template> <script setup lang="ts"> -import type { ChatMessage } from './types'; -import { ref, watch, nextTick, onMounted } from 'vue'; -import cryptoJS from 'crypto-js'; +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 Copy from './components/Copy.vue'; -import { md } from './libs/markdown'; -let apiKey = ''; -let isConfig = ref(false); +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 { 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, + activeGroupType, + activeLLMId, + activeRoomId, + activeSampleId, + activeSectionAId, + getRoomConfig, + roomConfig, +} from '/@/stores/chatRoom'; +import { ErrorCode } from '/@/utils/request'; + +const chatWidth = '75%'; +const voicePageIsShow = ref(false); let isTalking = ref(false); -let messageContent = ref(''); -const chatListDom = ref<HTMLDivElement>(); -const decoder = new TextDecoder('utf-8'); -const roleAlias = { user: 'ME', assistant: 'ChatGPT', system: 'System' }; -const messageList = ref<ChatMessage[]>([ - { - role: 'system', - content: '浣犳槸 ChatGPT锛孫penAI 璁粌鐨勫ぇ鍨嬭瑷�妯″瀷锛屽敖鍙兘绠�娲佸湴鍥炵瓟銆�', - }, - { - role: 'assistant', - content: `浣犲ソ锛屾垜鏄疉I璇█妯″瀷锛屾垜鍙互鎻愪緵涓�浜涘父鐢ㄦ湇鍔″拰淇℃伅锛屼緥濡傦細 - - 1. 缈昏瘧锛氭垜鍙互鎶婁腑鏂囩炕璇戞垚鑻辨枃锛岃嫳鏂囩炕璇戞垚涓枃锛岃繕鏈夊叾浠栦竴浜涜瑷�缈昏瘧锛屾瘮濡傛硶璇�佹棩璇�佽タ鐝墮璇瓑銆� - - 2. 鍜ㄨ鏈嶅姟锛氬鏋滀綘鏈変换浣曢棶棰橀渶瑕佸挩璇紝渚嬪鍋ュ悍銆佹硶寰嬨�佹姇璧勭瓑鏂归潰锛屾垜鍙互灏藉彲鑳戒负浣犳彁渚涘府鍔┿�� - - 3. 闂茶亰锛氬鏋滀綘鎰熷埌瀵傚癁鎴栨棤鑱婏紝鎴戜滑鍙互鑱婁竴浜涙湁瓒g殑璇濋锛屼互鍑忚交浣犵殑鍘嬪姏銆� - - 璇峰憡璇夋垜浣犻渶瑕佸摢鏂归潰鐨勫府鍔╋紝鎴戜細鏍规嵁浣犵殑闇�姹傜粰浣犳彁渚涚浉搴旂殑淇℃伅鍜屽缓璁�俙, - }, -]); - -onMounted(() => { - if (getAPIKey()) { - switchConfigStatus(); - } +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) => { + if (!res) return null; + let content: ChatContent = { + type: AnswerType.Text, + values: '瑙f瀽澶辫触锛�', + }; -const sendChatMessage = async (content: string = messageContent.value) => { + 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; + case AnswerType.Map: + content = { + type: AnswerType.Map, + values: res.values, + }; + break; + default: + content = { + type: AnswerType.Text, + values: '瑙f瀽澶辫触锛�', + }; + 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; + return content; +}; +const { clearQueryProcess, process, processId, queryProcess } = useQueryProcess(); +const DEFAULT_SECTION_A_ID = 'knowledge_base'; +let questionRes = null; + +let finalCalcSectionAId = null; +const questionAi = async (text) => { + processId.value = uuidv4(); + 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, + // } + // : {}; + // 姝e父鍥炵瓟鏆傛椂涓嶉噰鐢� + judgeParams = {}; + } else { + judgeParams = { + prev_question: preQuestion.value, + }; + } + let currentSectionAId = ''; + if (activeSectionAId.value) { + currentSectionAId = activeSectionAId.value; + activeSectionAId.value = ''; + } else { + const lastSectionAItem = _.findLast( + computedMessageList.value as any, + (item) => item.role === RoleEnum.assistant && !!item.sectionAId + ); + currentSectionAId = lastSectionAItem?.sectionAId ?? DEFAULT_SECTION_A_ID; + } + 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 (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(); + }); + questionRes = res; + const content = parseContent(res); + return content; +}; + +const clearMessageContent = () => + (messageContent.value = { + type: AnswerType.Text, + values: '', + }); + +let currentSampleId = ''; + +let currentLLMId = null; + +const sendChatMessage = async (content: ChatContent = messageContent.value, cb?: any, isCallExtParams?: any) => { + if (!content?.values || isTalking.value || chatListLoading.value) return; + const isNewChat = messageList.value.length === 0; + if (isNewChat) { + if (activeSampleId.value) { + currentSampleId = activeSampleId.value; + } + + if (activeLLMId.value) { + currentLLMId = activeLLMId.value; + } + } + let resMsgContent: ChatContent = null; + try { isTalking.value = true; - if (messageList.value.length === 2) { - messageList.value.pop(); - } - messageList.value.push({ role: 'user', content }); + 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({ role: 'assistant', content: '' }); - // const { body, status } = await chat(messageList.value, getAPIKey()); - // if (body) { - // const reader = body.getReader(); - // await readStream(reader, status); - // } - const a = new Promise<string>((resolve) => { - setTimeout(() => { - resolve('nihao '); - }, 500); - }); + // 鍑虹幇鍥炲锛岀疆绌哄嚭鐜扮瓑寰呭姩鐢� + messageList.value.push(assistantItem); + // 婊氬姩鑷冲綋鍓嶅彂閫佹秷鎭� + scrollToBottom(); - const msg = await a; - appendLastMessageContent(msg); + if (isCallExtParams) { + const extRes = await extCallQuery(isCallExtParams); + questionRes = extRes; + resMsgContent = parseContent(extRes); + } else { + resMsgContent = await questionAi(content.values); + } + nextUserMsgEndIndex.value++; + if (isNewChat) { + const firstResCb = getRoomConfig(currentRouteId, 'firstResCb'); + firstResCb?.(resMsgContent); + } else { + cb?.(resMsgContent); + } + userItem.historyId = questionRes.history_id; + userItem.content.values = questionRes?.question ?? userItem.content.values; + assistantItem.historyId = questionRes.history_id; + assistantItem.sectionAId = finalCalcSectionAId; + appendLastMessageContent(resMsgContent); + setTimeout(() => { + // 鏀跺埌鍥炲锛岀户缁粴 + scrollToBottom(); + }, 300); } catch (error: any) { - appendLastMessageContent(error); + // appendLastMessageContent({ + // type: AnswerType.Text, + // values: '鍙戠敓閿欒锛�', + // }); } finally { isTalking.value = false; } }; -const readStream = async (reader: ReadableStreamDefaultReader<Uint8Array>, status: number) => { - let partialLine = ''; - - while (true) { - // eslint-disable-next-line no-await-in-loop - const { value, done } = await reader.read(); - if (done) break; - - const decodedText = decoder.decode(value, { stream: true }); - - if (status !== 200) { - const json = JSON.parse(decodedText); // start with "data: " - const content = json.error.message ?? decodedText; - appendLastMessageContent(content); - return; - } - - const chunk = partialLine + decodedText; - const newLines = chunk.split(/\r?\n/); - - partialLine = newLines.pop() ?? ''; - - for (const line of newLines) { - if (line.length === 0) continue; // ignore empty message - if (line.startsWith(':')) continue; // ignore sse comment message - if (line === 'data: [DONE]') return; // - - const json = JSON.parse(line.substring(6)); // start with "data: " - const content = status === 200 ? json.choices[0].delta.content ?? '' : json.error.message; - appendLastMessageContent(content); - } +const sendClick = (cb) => { + sendChatMessage(messageContent.value, cb); +}; +const appendLastMessageContent = (content: ChatContent) => { + const currentTime = moment().format('MM骞碊D鏃� 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 appendLastMessageContent = (content: string) => (messageList.value[messageList.value.length - 1].content += content); +const chatListLoading = ref(false); -const sendOrSave = () => { - if (!messageContent.value.length) return; - if (isConfig.value) { - if (saveAPIKey(messageContent.value.trim())) { - switchConfigStatus(); - } - clearMessageContent(); - } else { +const { scrollToBottom } = useScrollToBottom({ + chatListDom: chatListDom, +}); + +onMounted(async () => { + messageList.value = []; + // 鍔犺浇鍒濆鏁版嵁 + chatListLoading.value = true; + + await loadRangeData().finally(() => { + chatListLoading.value = false; + }); + if (messageList.value.length === 0) { + messageContent.value = { + type: AnswerType.Text, + values: activeChatRoom.value.title, + }; + sendChatMessage(); - } -}; - -const clickConfig = () => { - if (!isConfig.value) { - messageContent.value = getAPIKey(); } else { - clearMessageContent(); + setTimeout(() => { + // 鍒濆鐘舵�佹粴涓�涓� + scrollToBottom(); + + setTimeout(() => { + chatListDom.value.addEventListener('scroll', onChatListScroll); + }, 300); + }, 300); } - switchConfigStatus(); +}); +//#region ====================== 鍏宠仈鏌ヨ ====================== +const relativeQueryClick = async (val) => { + sendChatMessage( + { + type: AnswerType.Text, + values: val.question, + }, + undefined, + { + history_group_id: currentRouteId, + question: val.question, + call_ext_id: val.call_ext_id, + call_ext_args: val.agrs ? JSON.stringify(val.agrs) : null, + } + ); }; +//#endregion -const getSecretKey = () => 'lianginx'; +const { + copyClick, + likeClick, + unLikeClick, + feedbackPosition, + feedbackIsShow, + feedbackContent, + feedbackPanelRef, + currentFeedbackMapItem, + feedbackClick, + askMoreClick, + fixQuestionClick, + preQuestion, + showFixQuestion, + showAskMore, +} = useAssistantContentOpt({ + sendChatMessage, + displayMessageList: computedMessageList, +}); -const saveAPIKey = (apiKey: string) => { - if (apiKey.slice(0, 3) !== 'sk-' || apiKey.length !== 51) { - alert('API Key 閿欒锛岃妫�鏌ュ悗閲嶆柊杈撳叆锛�'); - return false; - } - const aesAPIKey = cryptoJS.AES.encrypt(apiKey, getSecretKey()).toString(); - localStorage.setItem('apiKey', aesAPIKey); - return true; +//#region ====================== 渚ц竟鏍廳rawer ====================== +const drawerIsShow = ref(false); + +const updateChatInput = (content) => { + messageContent.value.values = content; }; - -const getAPIKey = () => { - if (apiKey) return apiKey; - const aesAPIKey = localStorage.getItem('apiKey') ?? ''; - apiKey = cryptoJS.AES.decrypt(aesAPIKey, getSecretKey()).toString(cryptoJS.enc.Utf8); - return apiKey; -}; - -const switchConfigStatus = () => (isConfig.value = !isConfig.value); - -const clearMessageContent = () => (messageContent.value = ''); - -const scrollToBottom = () => { - if (!chatListDom.value) return; - scrollTo(0, chatListDom.value.scrollHeight); -}; - -watch(messageList.value, () => nextTick(() => scrollToBottom())); +//#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> -- Gitblit v1.9.3