628b37c73c
1. 后端： - 添加图片上传接口 /api/chat/image/upload - 在消息处理中支持图片内容 - 更新数据库模型和迁移脚本 - 实现图片处理工具类 2. 前端： - 添加图片上传和预览组件 - 支持多模态消息发送 - 更新消息显示以支持图片 - 集成图片上传API 3. 文档： - 更新agents-config.md添加多模态图片支持说明 - 更新roadmap.md添加多模态支持计划 主要功能包括： - 支持JPEG、PNG、WebP、GIF、BMP等格式 - 图片大小限制为10MB - 自动处理图片格式转换和压缩 - 支持单图片上传 - 图片以base64编码存储在数据库
1781 lines
49 KiB
Vue
1781 lines
49 KiB
Vue
<template>
|
||
<div class="chat-container" ref="chatContainerRef">
|
||
<ChatSidebarComponent
|
||
:current-chat-id="currentChatId"
|
||
:chats-list="chatsList"
|
||
:is-sidebar-open="chatUIStore.isSidebarOpen"
|
||
:is-initial-render="localUIState.isInitialRender"
|
||
:single-mode="props.singleMode"
|
||
:agents="agents"
|
||
:selected-agent-id="currentAgentId"
|
||
:is-creating-new-chat="chatUIStore.creatingNewChat"
|
||
@create-chat="createNewChat"
|
||
@select-chat="selectChat"
|
||
@delete-chat="deleteChat"
|
||
@rename-chat="renameChat"
|
||
@toggle-sidebar="toggleSidebar"
|
||
@open-agent-modal="openAgentModal"
|
||
:class="{
|
||
'floating-sidebar': isSmallContainer,
|
||
'sidebar-open': chatUIStore.isSidebarOpen,
|
||
'no-transition': localUIState.isInitialRender,
|
||
'collapsed': isSmallContainer && !chatUIStore.isSidebarOpen
|
||
}"
|
||
/>
|
||
<div class="sidebar-backdrop" v-if="chatUIStore.isSidebarOpen && isSmallContainer" @click="toggleSidebar"></div>
|
||
<div class="chat">
|
||
<div class="chat-header">
|
||
<div class="header__left">
|
||
<slot name="header-left" class="nav-btn"></slot>
|
||
<div type="button" class="agent-nav-btn" v-if="!chatUIStore.isSidebarOpen" @click="toggleSidebar">
|
||
<PanelLeftOpen class="nav-btn-icon" size="18"/>
|
||
</div>
|
||
<div
|
||
type="button"
|
||
class="agent-nav-btn"
|
||
v-if="!chatUIStore.isSidebarOpen"
|
||
:class="{ 'is-disabled': chatUIStore.creatingNewChat }"
|
||
@click="createNewChat"
|
||
>
|
||
<LoaderCircle v-if="chatUIStore.creatingNewChat" class="nav-btn-icon loading-icon" size="18"/>
|
||
<MessageCirclePlus v-else class="nav-btn-icon" size="18"/>
|
||
<span class="text" :class="{'hide-text': isMediumContainer}">新对话</span>
|
||
</div>
|
||
</div>
|
||
<div class="header__right">
|
||
<!-- <div class="nav-btn" @click="shareChat" v-if="currentChatId && currentAgent">
|
||
<ShareAltOutlined style="font-size: 18px;"/>
|
||
</div> -->
|
||
<!-- <div class="nav-btn test-history" @click="getAgentHistory" v-if="currentChatId && currentAgent">
|
||
<ThunderboltOutlined />
|
||
</div> -->
|
||
<slot name="header-right"></slot>
|
||
</div>
|
||
</div>
|
||
|
||
<!-- 加载状态：加载消息 -->
|
||
<div v-if="isLoadingMessages" class="chat-loading">
|
||
<div class="loading-spinner"></div>
|
||
<span>正在加载消息...</span>
|
||
</div>
|
||
|
||
<div v-else-if="!conversations.length" class="chat-examples">
|
||
<div style="margin-bottom: 150px"></div>
|
||
<h1>您好，我是{{ currentAgentName }}！</h1>
|
||
<!-- <h1>{{ currentAgent ? currentAgent.name : '请选择一个智能体开始对话' }}</h1>
|
||
<p>{{ currentAgent ? currentAgent.description : '不同的智能体有不同的专长和能力' }}</p> -->
|
||
|
||
<div class="inputer-init">
|
||
<MessageInputComponent
|
||
ref="messageInputRef"
|
||
v-model="userInput"
|
||
:is-loading="isProcessing"
|
||
:disabled="!currentAgent"
|
||
:send-button-disabled="(!userInput || !currentAgent) && !isProcessing"
|
||
placeholder="输入问题..."
|
||
@send="handleSendOrStop"
|
||
@keydown="handleKeyDown"
|
||
>
|
||
<template #top>
|
||
<ImagePreviewComponent
|
||
v-if="currentImage"
|
||
:image-data="currentImage"
|
||
@remove="handleImageRemoved"
|
||
class="image-preview-wrapper"
|
||
/>
|
||
</template>
|
||
<template #options-left>
|
||
<AttachmentOptionsComponent
|
||
v-if="supportsFileUpload"
|
||
:disabled="!currentAgent"
|
||
@upload="handleAttachmentUpload"
|
||
@upload-image="handleImageUpload"
|
||
@upload-image-success="handleImageUploadSuccess"
|
||
/>
|
||
</template>
|
||
<template #actions-left>
|
||
<AttachmentStatusIndicator
|
||
:attachments="currentAttachments"
|
||
:disabled="!currentAgent"
|
||
@remove="handleAttachmentRemove"
|
||
/>
|
||
</template>
|
||
</MessageInputComponent>
|
||
|
||
<!-- 示例问题 -->
|
||
<div class="example-questions" v-if="exampleQuestions.length > 0">
|
||
<div class="example-title">或试试这些问题：</div>
|
||
<div class="example-chips">
|
||
<div
|
||
v-for="question in exampleQuestions"
|
||
:key="question.id"
|
||
class="example-chip"
|
||
@click="handleExampleClick(question.text)"
|
||
>
|
||
{{ question.text }}
|
||
</div>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
<div class="chat-box" ref="messagesContainer">
|
||
<div class="conv-box" v-for="(conv, index) in conversations" :key="index">
|
||
<AgentMessageComponent
|
||
v-for="(message, msgIndex) in conv.messages"
|
||
:message="message"
|
||
:key="msgIndex"
|
||
:is-processing="isProcessing && conv.status === 'streaming' && msgIndex === conv.messages.length - 1"
|
||
:show-refs="showMsgRefs(message)"
|
||
@retry="retryMessage(message)"
|
||
>
|
||
</AgentMessageComponent>
|
||
<!-- 显示对话最后一个消息使用的模型 -->
|
||
<RefsComponent
|
||
v-if="shouldShowRefs(conv)"
|
||
:message="getLastMessage(conv)"
|
||
:show-refs="['model', 'copy']"
|
||
:is-latest-message="false"
|
||
/>
|
||
</div>
|
||
|
||
<!-- 生成中的加载状态 - 增强条件支持主聊天和resume流程 -->
|
||
<div class="generating-status" v-if="isProcessing && conversations.length > 0">
|
||
<div class="generating-indicator">
|
||
<div class="loading-dots">
|
||
<div></div>
|
||
<div></div>
|
||
<div></div>
|
||
</div>
|
||
<span class="generating-text">正在生成回复...</span>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
<div class="bottom">
|
||
<!-- 人工审批弹窗 - 放在输入框上方 -->
|
||
<HumanApprovalModal
|
||
:visible="approvalState.showModal"
|
||
:question="approvalState.question"
|
||
:operation="approvalState.operation"
|
||
@approve="handleApprove"
|
||
@reject="handleReject"
|
||
/>
|
||
|
||
<div class="message-input-wrapper" v-if="conversations.length > 0">
|
||
<MessageInputComponent
|
||
ref="messageInputRef"
|
||
v-model="userInput"
|
||
:is-loading="isProcessing"
|
||
:disabled="!currentAgent"
|
||
:send-button-disabled="(!userInput || !currentAgent) && !isProcessing"
|
||
placeholder="输入问题..."
|
||
@send="handleSendOrStop"
|
||
@keydown="handleKeyDown"
|
||
>
|
||
<template #top>
|
||
<ImagePreviewComponent
|
||
v-if="currentImage"
|
||
:image-data="currentImage"
|
||
@remove="handleImageRemoved"
|
||
class="image-preview-wrapper"
|
||
/>
|
||
</template>
|
||
<template #options-left>
|
||
<AttachmentOptionsComponent
|
||
v-if="supportsFileUpload"
|
||
:disabled="!currentAgent"
|
||
@upload="handleAttachmentUpload"
|
||
@upload-image="handleImageUpload"
|
||
@upload-image-success="handleImageUploadSuccess"
|
||
/>
|
||
</template>
|
||
<template #actions-left>
|
||
<AttachmentStatusIndicator
|
||
:attachments="currentAttachments"
|
||
:disabled="!currentAgent"
|
||
@remove="handleAttachmentRemove"
|
||
/>
|
||
</template>
|
||
</MessageInputComponent>
|
||
<div class="bottom-actions">
|
||
<p class="note">请注意辨别内容的可靠性</p>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
</div>
|
||
</template>
|
||
|
||
<script setup>
|
||
import { ref, reactive, onMounted, watch, nextTick, computed, onUnmounted } from 'vue';
|
||
import { LoadingOutlined } from '@ant-design/icons-vue';
|
||
import { message } from 'ant-design-vue';
|
||
import MessageInputComponent from '@/components/MessageInputComponent.vue'
|
||
import AttachmentInputPanel from '@/components/AttachmentInputPanel.vue'
|
||
import AttachmentOptionsComponent from '@/components/AttachmentOptionsComponent.vue'
|
||
import AttachmentStatusIndicator from '@/components/AttachmentStatusIndicator.vue'
|
||
import AgentMessageComponent from '@/components/AgentMessageComponent.vue'
|
||
import ImagePreviewComponent from '@/components/ImagePreviewComponent.vue'
|
||
import ChatSidebarComponent from '@/components/ChatSidebarComponent.vue'
|
||
import RefsComponent from '@/components/RefsComponent.vue'
|
||
import { PanelLeftOpen, MessageCirclePlus, LoaderCircle } from 'lucide-vue-next';
|
||
import { handleChatError, handleValidationError } from '@/utils/errorHandler';
|
||
import { ScrollController } from '@/utils/scrollController';
|
||
import { AgentValidator } from '@/utils/agentValidator';
|
||
import { useAgentStore } from '@/stores/agent';
|
||
import { useChatUIStore } from '@/stores/chatUI';
|
||
import { storeToRefs } from 'pinia';
|
||
import { MessageProcessor } from '@/utils/messageProcessor';
|
||
import { agentApi, threadApi } from '@/apis';
|
||
import HumanApprovalModal from '@/components/HumanApprovalModal.vue';
|
||
import { useApproval } from '@/composables/useApproval';
|
||
|
||
// ==================== PROPS & EMITS ====================
|
||
const props = defineProps({
|
||
agentId: { type: String, default: '' },
|
||
singleMode: { type: Boolean, default: true }
|
||
});
|
||
const emit = defineEmits(['open-config', 'open-agent-modal']);
|
||
|
||
// ==================== STORE MANAGEMENT ====================
|
||
const agentStore = useAgentStore();
|
||
const chatUIStore = useChatUIStore();
|
||
const {
|
||
agents,
|
||
selectedAgentId,
|
||
defaultAgentId,
|
||
} = storeToRefs(agentStore);
|
||
|
||
// ==================== LOCAL CHAT & UI STATE ====================
|
||
const userInput = ref('');
|
||
|
||
// 从智能体元数据获取示例问题
|
||
const exampleQuestions = computed(() => {
|
||
const agentId = currentAgentId.value;
|
||
let examples = [];
|
||
if (agentId && agents.value && agents.value.length > 0) {
|
||
const agent = agents.value.find(a => a.id === agentId);
|
||
examples = agent ? (agent.examples || []) : [];
|
||
}
|
||
return examples.map((text, index) => ({
|
||
id: index + 1,
|
||
text: text
|
||
}));
|
||
});
|
||
|
||
// Keep per-thread streaming scratch data in a consistent shape.
|
||
const createOnGoingConvState = () => ({
|
||
msgChunks: {},
|
||
currentRequestKey: null,
|
||
currentAssistantKey: null,
|
||
toolCallBuffers: {}
|
||
});
|
||
|
||
// 业务状态（保留在组件本地）
|
||
const chatState = reactive({
|
||
currentThreadId: null,
|
||
// 以threadId为键的线程状态
|
||
threadStates: {}
|
||
});
|
||
|
||
// 组件级别的线程和消息状态
|
||
const threads = ref([]);
|
||
const threadMessages = ref({});
|
||
|
||
// 本地 UI 状态（仅在本组件使用）
|
||
const localUIState = reactive({
|
||
isInitialRender: true,
|
||
containerWidth: 0,
|
||
});
|
||
|
||
const attachmentState = reactive({
|
||
itemsByThread: {},
|
||
limits: null,
|
||
isUploading: false,
|
||
})
|
||
|
||
// ==================== COMPUTED PROPERTIES ====================
|
||
const currentAgentId = computed(() => {
|
||
if (props.singleMode) {
|
||
return props.agentId || defaultAgentId.value;
|
||
} else {
|
||
return selectedAgentId.value;
|
||
}
|
||
});
|
||
|
||
const currentAgentName = computed(() => {
|
||
const agentId = currentAgentId.value;
|
||
if (agentId && agents.value && agents.value.length > 0) {
|
||
const agent = agents.value.find(a => a.id === agentId);
|
||
return agent ? agent.name : '智能体';
|
||
}
|
||
return '智能体';
|
||
});
|
||
|
||
const currentAgent = computed(() => {
|
||
if (!currentAgentId.value || !agents.value || !agents.value.length) return null;
|
||
return agents.value.find(a => a.id === currentAgentId.value) || null;
|
||
});
|
||
const chatsList = computed(() => threads.value || []);
|
||
const currentChatId = computed(() => chatState.currentThreadId);
|
||
const currentThread = computed(() => {
|
||
if (!currentChatId.value) return null;
|
||
return threads.value.find(thread => thread.id === currentChatId.value) || null;
|
||
});
|
||
|
||
const currentAttachments = computed(() => {
|
||
if (!currentChatId.value) return [];
|
||
return attachmentState.itemsByThread[currentChatId.value] || [];
|
||
});
|
||
|
||
// 检查当前智能体是否支持文件上传
|
||
const supportsFileUpload = computed(() => {
|
||
if (!currentAgent.value) return false;
|
||
const capabilities = currentAgent.value.capabilities || [];
|
||
return capabilities.includes('file_upload');
|
||
});
|
||
|
||
const currentThreadMessages = computed(() => threadMessages.value[currentChatId.value] || []);
|
||
|
||
// 计算是否显示Refs组件的条件
|
||
const shouldShowRefs = computed(() => {
|
||
return (conv) => {
|
||
return getLastMessage(conv) &&
|
||
conv.status !== 'streaming' &&
|
||
!approvalState.showModal &&
|
||
!(approvalState.threadId &&
|
||
chatState.currentThreadId === approvalState.threadId &&
|
||
isProcessing.value);
|
||
};
|
||
});
|
||
|
||
// 当前线程状态的computed属性
|
||
const currentThreadState = computed(() => {
|
||
return getThreadState(currentChatId.value);
|
||
});
|
||
|
||
const onGoingConvMessages = computed(() => {
|
||
const threadState = currentThreadState.value;
|
||
if (!threadState || !threadState.onGoingConv) return [];
|
||
|
||
const msgs = Object.values(threadState.onGoingConv.msgChunks).map(MessageProcessor.mergeMessageChunk);
|
||
return msgs.length > 0
|
||
? MessageProcessor.convertToolResultToMessages(msgs).filter(msg => msg.type !== 'tool')
|
||
: [];
|
||
});
|
||
|
||
const conversations = computed(() => {
|
||
const historyConvs = MessageProcessor.convertServerHistoryToMessages(currentThreadMessages.value);
|
||
const threadState = currentThreadState.value;
|
||
|
||
// 如果有进行中的消息且线程状态显示正在流式处理，添加进行中的对话
|
||
if (onGoingConvMessages.value.length > 0 && threadState?.isStreaming) {
|
||
const onGoingConv = {
|
||
messages: onGoingConvMessages.value,
|
||
status: 'streaming'
|
||
};
|
||
return [...historyConvs, onGoingConv];
|
||
}
|
||
|
||
// 即使流式结束，如果历史记录为空但还有消息没有完全同步，也保持显示
|
||
if (historyConvs.length === 0 && onGoingConvMessages.value.length > 0 && !threadState?.isStreaming) {
|
||
const finalConv = {
|
||
messages: onGoingConvMessages.value,
|
||
status: 'finished'
|
||
};
|
||
return [finalConv];
|
||
}
|
||
|
||
return historyConvs;
|
||
});
|
||
|
||
const isLoadingThreads = computed(() => chatUIStore.isLoadingThreads);
|
||
const isLoadingMessages = computed(() => chatUIStore.isLoadingMessages);
|
||
const isStreaming = computed(() => {
|
||
const threadState = currentThreadState.value;
|
||
return threadState ? threadState.isStreaming : false;
|
||
});
|
||
const isProcessing = computed(() => isStreaming.value);
|
||
const isSmallContainer = computed(() => localUIState.containerWidth <= 520);
|
||
const isMediumContainer = computed(() => localUIState.containerWidth <= 768);
|
||
|
||
// ==================== SCROLL & RESIZE HANDLING ====================
|
||
const chatContainerRef = ref(null);
|
||
const messageInputRef = ref(null);
|
||
const currentImage = ref(null);
|
||
const scrollController = new ScrollController('.chat');
|
||
let resizeObserver = null;
|
||
|
||
onMounted(() => {
|
||
nextTick(() => {
|
||
if (chatContainerRef.value) {
|
||
localUIState.containerWidth = chatContainerRef.value.offsetWidth;
|
||
resizeObserver = new ResizeObserver(entries => {
|
||
for (let entry of entries) {
|
||
localUIState.containerWidth = entry.contentRect.width;
|
||
}
|
||
});
|
||
resizeObserver.observe(chatContainerRef.value);
|
||
}
|
||
const chatContainer = document.querySelector('.chat');
|
||
if (chatContainer) {
|
||
chatContainer.addEventListener('scroll', scrollController.handleScroll, { passive: true });
|
||
}
|
||
});
|
||
setTimeout(() => { localUIState.isInitialRender = false; }, 300);
|
||
});
|
||
|
||
onUnmounted(() => {
|
||
if (resizeObserver) resizeObserver.disconnect();
|
||
scrollController.cleanup();
|
||
// 清理所有线程状态
|
||
resetOnGoingConv();
|
||
});
|
||
|
||
// ==================== THREAD STATE MANAGEMENT ====================
|
||
// 获取指定线程的状态，如果不存在则创建
|
||
const getThreadState = (threadId) => {
|
||
if (!threadId) return null;
|
||
if (!chatState.threadStates[threadId]) {
|
||
chatState.threadStates[threadId] = {
|
||
isStreaming: false,
|
||
streamAbortController: null,
|
||
onGoingConv: createOnGoingConvState()
|
||
};
|
||
}
|
||
return chatState.threadStates[threadId];
|
||
};
|
||
|
||
// 清理指定线程的状态
|
||
const cleanupThreadState = (threadId) => {
|
||
if (!threadId) return;
|
||
const threadState = chatState.threadStates[threadId];
|
||
if (threadState) {
|
||
if (threadState.streamAbortController) {
|
||
threadState.streamAbortController.abort();
|
||
}
|
||
delete chatState.threadStates[threadId];
|
||
}
|
||
};
|
||
|
||
// ==================== STREAM HANDLING LOGIC ====================
|
||
const resetOnGoingConv = (threadId = null, preserveMessages = false) => {
|
||
console.log('🔄 [RESET] Resetting on going conversation:', threadId, preserveMessages);
|
||
if (threadId) {
|
||
// 清理指定线程的状态
|
||
const threadState = getThreadState(threadId);
|
||
if (threadState) {
|
||
if (threadState.streamAbortController) {
|
||
threadState.streamAbortController.abort();
|
||
threadState.streamAbortController = null;
|
||
}
|
||
// 如果指定要保留消息，则延迟清空
|
||
if (preserveMessages) {
|
||
// 延迟清空消息，给历史记录加载足够时间
|
||
setTimeout(() => {
|
||
if (threadState.onGoingConv) {
|
||
threadState.onGoingConv = createOnGoingConvState();
|
||
}
|
||
}, 100);
|
||
} else {
|
||
threadState.onGoingConv = createOnGoingConvState();
|
||
}
|
||
}
|
||
} else {
|
||
// 清理当前线程或所有线程的状态
|
||
const targetThreadId = currentChatId.value;
|
||
if (targetThreadId) {
|
||
const threadState = getThreadState(targetThreadId);
|
||
if (threadState) {
|
||
if (threadState.streamAbortController) {
|
||
threadState.streamAbortController.abort();
|
||
threadState.streamAbortController = null;
|
||
}
|
||
if (preserveMessages) {
|
||
setTimeout(() => {
|
||
if (threadState.onGoingConv) {
|
||
threadState.onGoingConv = createOnGoingConvState();
|
||
}
|
||
}, 100);
|
||
} else {
|
||
threadState.onGoingConv = createOnGoingConvState();
|
||
}
|
||
}
|
||
} else {
|
||
// 如果没有当前线程，清理所有线程状态
|
||
Object.keys(chatState.threadStates).forEach(tid => {
|
||
cleanupThreadState(tid);
|
||
});
|
||
}
|
||
}
|
||
};
|
||
|
||
const _processStreamChunk = (chunk, threadId) => {
|
||
const { status, msg, request_id, message: chunkMessage } = chunk;
|
||
const threadState = getThreadState(threadId);
|
||
// console.log('Processing stream chunk:', chunk, 'for thread:', threadId);
|
||
|
||
if (!threadState) return false;
|
||
|
||
switch (status) {
|
||
case 'init':
|
||
threadState.onGoingConv.msgChunks[request_id] = [msg];
|
||
return false;
|
||
case 'loading':
|
||
if (msg.id) {
|
||
if (!threadState.onGoingConv.msgChunks[msg.id]) {
|
||
threadState.onGoingConv.msgChunks[msg.id] = [];
|
||
}
|
||
threadState.onGoingConv.msgChunks[msg.id].push(msg);
|
||
}
|
||
return false;
|
||
case 'error':
|
||
handleChatError({ message: chunkMessage }, 'stream');
|
||
// Stop the loading indicator
|
||
if (threadState) {
|
||
threadState.isStreaming = false;
|
||
|
||
// Abort the stream controller to stop processing further events
|
||
if (threadState.streamAbortController) {
|
||
threadState.streamAbortController.abort();
|
||
threadState.streamAbortController = null;
|
||
}
|
||
}
|
||
|
||
// Reload messages to show any partial content saved by the backend
|
||
fetchThreadMessages({ agentId: currentAgentId.value, threadId: threadId });
|
||
resetOnGoingConv(threadId);
|
||
return true;
|
||
case 'human_approval_required':
|
||
// 使用审批 composable 处理审批请求
|
||
return processApprovalInStream(chunk, threadId, currentAgentId.value);
|
||
case 'finished':
|
||
// 先标记流式结束，但保持消息显示直到历史记录加载完成
|
||
if (threadState) {
|
||
threadState.isStreaming = false;
|
||
}
|
||
// 异步加载历史记录，保持当前消息显示直到历史记录加载完成
|
||
fetchThreadMessages({ agentId: currentAgentId.value, threadId: threadId })
|
||
.finally(() => {
|
||
// 历史记录加载完成后，安全地清空当前进行中的对话
|
||
resetOnGoingConv(threadId, true);
|
||
});
|
||
return true;
|
||
case 'interrupted':
|
||
// 中断状态，刷新消息历史
|
||
if (threadState) {
|
||
threadState.isStreaming = false;
|
||
}
|
||
// 如果有 message 字段，显示提示（例如：敏感内容检测）
|
||
if (chunkMessage) {
|
||
message.info(chunkMessage);
|
||
}
|
||
fetchThreadMessages({ agentId: currentAgentId.value, threadId: threadId })
|
||
.finally(() => {
|
||
resetOnGoingConv(threadId, true);
|
||
});
|
||
return true;
|
||
}
|
||
|
||
return false;
|
||
};
|
||
|
||
// ==================== 线程管理方法 ====================
|
||
// 获取当前智能体的线程列表
|
||
const fetchThreads = async (agentId = null) => {
|
||
const targetAgentId = agentId || currentAgentId.value;
|
||
if (!targetAgentId) return;
|
||
|
||
chatUIStore.isLoadingThreads = true;
|
||
try {
|
||
const fetchedThreads = await threadApi.getThreads(targetAgentId);
|
||
threads.value = fetchedThreads || [];
|
||
const validIds = new Set((threads.value || []).map(thread => thread.id));
|
||
Object.keys(attachmentState.itemsByThread).forEach((id) => {
|
||
if (!validIds.has(id)) {
|
||
delete attachmentState.itemsByThread[id];
|
||
}
|
||
});
|
||
} catch (error) {
|
||
console.error('Failed to fetch threads:', error);
|
||
handleChatError(error, 'fetch');
|
||
throw error;
|
||
} finally {
|
||
chatUIStore.isLoadingThreads = false;
|
||
}
|
||
};
|
||
|
||
// 创建新线程
|
||
const createThread = async (agentId, title = '新的对话') => {
|
||
if (!agentId) return null;
|
||
|
||
chatState.isCreatingThread = true;
|
||
try {
|
||
const thread = await threadApi.createThread(agentId, title);
|
||
if (thread) {
|
||
threads.value.unshift(thread);
|
||
threadMessages.value[thread.id] = [];
|
||
attachmentState.itemsByThread[thread.id] = [];
|
||
}
|
||
return thread;
|
||
} catch (error) {
|
||
console.error('Failed to create thread:', error);
|
||
handleChatError(error, 'create');
|
||
throw error;
|
||
} finally {
|
||
chatState.isCreatingThread = false;
|
||
}
|
||
};
|
||
|
||
// 删除线程
|
||
const deleteThread = async (threadId) => {
|
||
if (!threadId) return;
|
||
|
||
chatState.isDeletingThread = true;
|
||
try {
|
||
await threadApi.deleteThread(threadId);
|
||
threads.value = threads.value.filter(thread => thread.id !== threadId);
|
||
delete threadMessages.value[threadId];
|
||
delete attachmentState.itemsByThread[threadId];
|
||
|
||
if (chatState.currentThreadId === threadId) {
|
||
chatState.currentThreadId = null;
|
||
}
|
||
} catch (error) {
|
||
console.error('Failed to delete thread:', error);
|
||
handleChatError(error, 'delete');
|
||
throw error;
|
||
} finally {
|
||
chatState.isDeletingThread = false;
|
||
}
|
||
};
|
||
|
||
// 更新线程标题
|
||
const updateThread = async (threadId, title) => {
|
||
if (!threadId || !title) return;
|
||
|
||
chatState.isRenamingThread = true;
|
||
try {
|
||
await threadApi.updateThread(threadId, title);
|
||
const thread = threads.value.find(t => t.id === threadId);
|
||
if (thread) {
|
||
thread.title = title;
|
||
}
|
||
} catch (error) {
|
||
console.error('Failed to update thread:', error);
|
||
handleChatError(error, 'update');
|
||
throw error;
|
||
} finally {
|
||
chatState.isRenamingThread = false;
|
||
}
|
||
};
|
||
|
||
// 获取线程消息
|
||
const fetchThreadMessages = async ({ agentId, threadId, delay = 0 }) => {
|
||
if (!threadId || !agentId) return;
|
||
|
||
// 如果指定了延迟，等待指定时间（用于确保后端数据库事务提交）
|
||
if (delay > 0) {
|
||
await new Promise(resolve => setTimeout(resolve, delay));
|
||
}
|
||
|
||
try {
|
||
const response = await agentApi.getAgentHistory(agentId, threadId);
|
||
console.log('🔄 [FETCH] Thread messages:', response);
|
||
threadMessages.value[threadId] = response.history || [];
|
||
} catch (error) {
|
||
handleChatError(error, 'load');
|
||
throw error;
|
||
}
|
||
};
|
||
|
||
const loadThreadAttachments = async (threadId, { silent = false } = {}) => {
|
||
if (!threadId) return;
|
||
try {
|
||
const response = await threadApi.getThreadAttachments(threadId);
|
||
attachmentState.itemsByThread[threadId] = response.attachments || [];
|
||
if (response.limits) {
|
||
attachmentState.limits = response.limits;
|
||
}
|
||
} catch (error) {
|
||
if (silent) {
|
||
console.warn('Failed to load attachments:', error);
|
||
} else {
|
||
handleChatError(error, 'load');
|
||
}
|
||
}
|
||
};
|
||
|
||
const ensureActiveThread = async (title = '新的对话') => {
|
||
if (currentChatId.value) return currentChatId.value;
|
||
try {
|
||
const newThread = await createThread(currentAgentId.value, title || '新的对话');
|
||
if (newThread) {
|
||
chatState.currentThreadId = newThread.id;
|
||
return newThread.id;
|
||
}
|
||
} catch (error) {
|
||
// createThread 已处理错误提示
|
||
}
|
||
return null;
|
||
};
|
||
|
||
const handleAttachmentUpload = async (files) => {
|
||
if (!files?.length) return;
|
||
if (!AgentValidator.validateAgentIdWithError(currentAgentId.value, '上传附件', handleValidationError)) return;
|
||
|
||
const preferredTitle = files[0]?.name || '新的对话';
|
||
const threadId = await ensureActiveThread(preferredTitle);
|
||
if (!threadId) {
|
||
message.error('创建对话失败，无法上传附件');
|
||
return;
|
||
}
|
||
|
||
attachmentState.isUploading = true;
|
||
try {
|
||
for (const file of files) {
|
||
await threadApi.uploadThreadAttachment(threadId, file);
|
||
message.success(`${file.name} 上传成功`);
|
||
}
|
||
await loadThreadAttachments(threadId, { silent: true });
|
||
} catch (error) {
|
||
handleChatError(error, 'upload');
|
||
} finally {
|
||
attachmentState.isUploading = false;
|
||
}
|
||
};
|
||
|
||
const handleAttachmentRemove = async (fileId) => {
|
||
if (!fileId || !currentChatId.value) return;
|
||
try {
|
||
await threadApi.deleteThreadAttachment(currentChatId.value, fileId);
|
||
await loadThreadAttachments(currentChatId.value, { silent: true });
|
||
message.success('附件已删除');
|
||
} catch (error) {
|
||
handleChatError(error, 'delete');
|
||
}
|
||
};
|
||
|
||
// 处理图片上传
|
||
const handleImageUpload = (imageData) => {
|
||
if (imageData && imageData.success) {
|
||
currentImage.value = imageData;
|
||
}
|
||
};
|
||
|
||
// 处理图片移除
|
||
const handleImageRemoved = () => {
|
||
currentImage.value = null;
|
||
};
|
||
|
||
// 处理图片上传成功，关闭选项面板
|
||
const handleImageUploadSuccess = () => {
|
||
if (messageInputRef.value) {
|
||
messageInputRef.value.closeOptions();
|
||
}
|
||
};
|
||
|
||
// ==================== 审批功能管理 ====================
|
||
const { approvalState, handleApproval, processApprovalInStream } = useApproval({
|
||
getThreadState,
|
||
resetOnGoingConv,
|
||
fetchThreadMessages
|
||
});
|
||
|
||
// 发送消息并处理流式响应
|
||
const sendMessage = async ({ agentId, threadId, text, signal = undefined, imageData = undefined }) => {
|
||
if (!agentId || !threadId || !text) {
|
||
const error = new Error("Missing agent, thread, or message text");
|
||
handleChatError(error, 'send');
|
||
return Promise.reject(error);
|
||
}
|
||
|
||
// 如果是新对话，用消息内容作为标题
|
||
if ((threadMessages.value[threadId] || []).length === 0) {
|
||
updateThread(threadId, text);
|
||
}
|
||
|
||
const requestData = {
|
||
query: text,
|
||
config: {
|
||
thread_id: threadId,
|
||
},
|
||
};
|
||
|
||
// 如果有图片，添加到请求中
|
||
if (imageData && imageData.imageContent) {
|
||
requestData.image_content = imageData.imageContent;
|
||
}
|
||
|
||
try {
|
||
return await agentApi.sendAgentMessage(agentId, requestData, signal ? { signal } : undefined);
|
||
} catch (error) {
|
||
handleChatError(error, 'send');
|
||
throw error;
|
||
}
|
||
};
|
||
|
||
|
||
// ==================== CHAT ACTIONS ====================
|
||
// 检查第一个对话是否为空
|
||
const isFirstChatEmpty = () => {
|
||
if (threads.value.length === 0) return false;
|
||
const firstThread = threads.value[0];
|
||
const firstThreadMessages = threadMessages.value[firstThread.id] || [];
|
||
return firstThreadMessages.length === 0;
|
||
};
|
||
|
||
// 如果第一个对话为空，直接切换到第一个对话
|
||
const switchToFirstChatIfEmpty = async () => {
|
||
if (threads.value.length > 0 && isFirstChatEmpty()) {
|
||
await selectChat(threads.value[0].id);
|
||
return true;
|
||
}
|
||
return false;
|
||
};
|
||
|
||
const createNewChat = async () => {
|
||
if (!AgentValidator.validateAgentId(currentAgentId.value, '创建对话') || chatUIStore.creatingNewChat) return;
|
||
|
||
// 如果第一个对话为空，直接切换到第一个对话而不是创建新对话
|
||
if (await switchToFirstChatIfEmpty()) return;
|
||
|
||
// 只有当当前对话是第一个对话且为空时，才阻止创建新对话
|
||
const currentThreadIndex = threads.value.findIndex(thread => thread.id === currentChatId.value);
|
||
if (currentChatId.value && conversations.value.length === 0 && currentThreadIndex === 0) return;
|
||
|
||
chatUIStore.creatingNewChat = true;
|
||
try {
|
||
const newThread = await createThread(currentAgentId.value, '新的对话');
|
||
if (newThread) {
|
||
// 中断之前线程的流式输出（如果存在）
|
||
const previousThreadId = chatState.currentThreadId;
|
||
if (previousThreadId) {
|
||
const previousThreadState = getThreadState(previousThreadId);
|
||
if (previousThreadState?.isStreaming && previousThreadState.streamAbortController) {
|
||
previousThreadState.streamAbortController.abort();
|
||
previousThreadState.isStreaming = false;
|
||
previousThreadState.streamAbortController = null;
|
||
}
|
||
}
|
||
|
||
chatState.currentThreadId = newThread.id;
|
||
}
|
||
} catch (error) {
|
||
handleChatError(error, 'create');
|
||
} finally {
|
||
chatUIStore.creatingNewChat = false;
|
||
}
|
||
};
|
||
|
||
const selectChat = async (chatId) => {
|
||
if (!AgentValidator.validateAgentIdWithError(currentAgentId.value, '选择对话', handleValidationError)) return;
|
||
|
||
// 中断之前线程的流式输出（如果存在）
|
||
const previousThreadId = chatState.currentThreadId;
|
||
if (previousThreadId && previousThreadId !== chatId) {
|
||
const previousThreadState = getThreadState(previousThreadId);
|
||
if (previousThreadState?.isStreaming && previousThreadState.streamAbortController) {
|
||
previousThreadState.streamAbortController.abort();
|
||
previousThreadState.isStreaming = false;
|
||
previousThreadState.streamAbortController = null;
|
||
}
|
||
}
|
||
|
||
chatState.currentThreadId = chatId;
|
||
chatUIStore.isLoadingMessages = true;
|
||
try {
|
||
await fetchThreadMessages({ agentId: currentAgentId.value, threadId: chatId });
|
||
await loadThreadAttachments(chatId, { silent: true });
|
||
} catch (error) {
|
||
handleChatError(error, 'load');
|
||
} finally {
|
||
chatUIStore.isLoadingMessages = false;
|
||
}
|
||
|
||
await nextTick();
|
||
scrollController.scrollToBottomStaticForce();
|
||
};
|
||
|
||
const deleteChat = async (chatId) => {
|
||
if (!AgentValidator.validateAgentIdWithError(currentAgentId.value, '删除对话', handleValidationError)) return;
|
||
try {
|
||
await deleteThread(chatId);
|
||
if (chatState.currentThreadId === chatId) {
|
||
chatState.currentThreadId = null;
|
||
// 如果删除的是当前对话，自动创建新对话
|
||
await createNewChat();
|
||
} else if (chatsList.value.length > 0) {
|
||
// 如果删除的不是当前对话，选择第一个可用对话
|
||
await selectChat(chatsList.value[0].id);
|
||
}
|
||
} catch (error) {
|
||
handleChatError(error, 'delete');
|
||
}
|
||
};
|
||
|
||
const renameChat = async (data) => {
|
||
let { chatId, title } = data;
|
||
if (!AgentValidator.validateRenameOperation(chatId, title, currentAgentId.value, handleValidationError)) return;
|
||
if (title.length > 30) title = title.slice(0, 30);
|
||
try {
|
||
await updateThread(chatId, title);
|
||
} catch (error) {
|
||
handleChatError(error, 'rename');
|
||
}
|
||
};
|
||
|
||
const handleSendMessage = async () => {
|
||
const text = userInput.value.trim();
|
||
if (!text || !currentAgent.value || isProcessing.value) return;
|
||
|
||
let threadId = currentChatId.value;
|
||
if (!threadId) {
|
||
threadId = await ensureActiveThread(text);
|
||
if (!threadId) {
|
||
message.error('创建对话失败，请重试');
|
||
return;
|
||
}
|
||
}
|
||
|
||
userInput.value = '';
|
||
|
||
// 保存当前图片数据，在发送后再清除
|
||
const imageData = currentImage.value;
|
||
currentImage.value = null;
|
||
|
||
await nextTick();
|
||
scrollController.scrollToBottom(true);
|
||
|
||
const threadState = getThreadState(threadId);
|
||
if (!threadState) return;
|
||
|
||
threadState.isStreaming = true;
|
||
resetOnGoingConv(threadId);
|
||
threadState.streamAbortController = new AbortController();
|
||
|
||
try {
|
||
const response = await sendMessage({
|
||
agentId: currentAgentId.value,
|
||
threadId: currentChatId.value,
|
||
text: text,
|
||
signal: threadState.streamAbortController?.signal,
|
||
imageData: imageData
|
||
});
|
||
|
||
const reader = response.body.getReader();
|
||
const decoder = new TextDecoder();
|
||
let buffer = '';
|
||
let stopReading = false;
|
||
|
||
while (!stopReading) {
|
||
const { done, value } = await reader.read();
|
||
if (done) break;
|
||
|
||
buffer += decoder.decode(value, { stream: true });
|
||
const lines = buffer.split('\n');
|
||
buffer = lines.pop() || '';
|
||
|
||
for (const line of lines) {
|
||
const trimmedLine = line.trim();
|
||
if (trimmedLine) {
|
||
try {
|
||
const chunk = JSON.parse(trimmedLine);
|
||
if (_processStreamChunk(chunk, threadId)) {
|
||
stopReading = true;
|
||
break;
|
||
}
|
||
} catch (e) { console.warn('Failed to parse stream chunk JSON:', e); }
|
||
}
|
||
}
|
||
}
|
||
if (!stopReading && buffer.trim()) {
|
||
try {
|
||
const chunk = JSON.parse(buffer.trim());
|
||
if (_processStreamChunk(chunk, threadId)) {
|
||
stopReading = true;
|
||
}
|
||
} catch (e) { console.warn('Failed to parse final stream chunk JSON:', e); }
|
||
}
|
||
} catch (error) {
|
||
if (error.name !== 'AbortError') {
|
||
handleChatError(error, 'send');
|
||
}
|
||
} finally {
|
||
threadState.isStreaming = false;
|
||
threadState.streamAbortController = null;
|
||
resetOnGoingConv(threadId);
|
||
}
|
||
};
|
||
|
||
// 发送或中断
|
||
const handleSendOrStop = async () => {
|
||
const threadId = currentChatId.value;
|
||
const threadState = getThreadState(threadId);
|
||
if (isProcessing.value && threadState && threadState.streamAbortController) {
|
||
// 中断生成
|
||
threadState.streamAbortController.abort();
|
||
|
||
// 中断后刷新消息历史，确保显示最新的状态
|
||
try {
|
||
await fetchThreadMessages({ agentId: currentAgentId.value, threadId: threadId, delay: 100 });
|
||
message.info('已中断对话生成');
|
||
} catch (error) {
|
||
console.error('刷新消息历史失败:', error);
|
||
message.info('已中断对话生成');
|
||
}
|
||
return;
|
||
}
|
||
await handleSendMessage();
|
||
};
|
||
|
||
// ==================== 人工审批处理 ====================
|
||
const handleApprovalWithStream = async (approved) => {
|
||
console.log('🔄 [STREAM] Starting resume stream processing');
|
||
|
||
const threadId = approvalState.threadId;
|
||
if (!threadId) {
|
||
message.error('无效的审批请求');
|
||
approvalState.showModal = false;
|
||
return;
|
||
}
|
||
|
||
const threadState = getThreadState(threadId);
|
||
if (!threadState) {
|
||
message.error('无法找到对应的对话线程');
|
||
approvalState.showModal = false;
|
||
return;
|
||
}
|
||
|
||
try {
|
||
// 使用审批 composable 处理审批
|
||
const response = await handleApproval(approved, currentAgentId.value);
|
||
|
||
if (!response) return; // 如果 handleApproval 抛出错误，这里不会执行
|
||
|
||
console.log('🔄 [STREAM] Processing resume streaming response');
|
||
|
||
// 处理流式响应
|
||
const reader = response.body.getReader();
|
||
const decoder = new TextDecoder();
|
||
let buffer = '';
|
||
let stopReading = false;
|
||
|
||
while (!stopReading) {
|
||
const { done, value } = await reader.read();
|
||
if (done) break;
|
||
|
||
buffer += decoder.decode(value, { stream: true });
|
||
const lines = buffer.split('\n');
|
||
buffer = lines.pop() || '';
|
||
|
||
for (const line of lines) {
|
||
const trimmedLine = line.trim();
|
||
if (trimmedLine) {
|
||
try {
|
||
const chunk = JSON.parse(trimmedLine);
|
||
console.log('🔄 [STREAM] Processing chunk:', chunk);
|
||
|
||
// 处理chunk并更新对话 - _processStreamChunk 已经处理了所有必要的逻辑
|
||
if (_processStreamChunk(chunk, threadId)) {
|
||
stopReading = true;
|
||
break;
|
||
}
|
||
|
||
} catch (e) {
|
||
console.warn('Failed to parse stream chunk JSON:', e, 'Line:', trimmedLine);
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
if (!stopReading && buffer.trim()) {
|
||
try {
|
||
const chunk = JSON.parse(buffer.trim());
|
||
console.log('🔄 [STREAM] Processing final chunk:', chunk);
|
||
|
||
// 处理最终chunk - _processStreamChunk 已经处理了所有必要的逻辑
|
||
if (_processStreamChunk(chunk, threadId)) {
|
||
stopReading = true;
|
||
}
|
||
|
||
} catch (e) {
|
||
console.warn('Failed to parse final stream chunk JSON:', e);
|
||
}
|
||
}
|
||
|
||
console.log('🔄 [STREAM] Resume stream processing completed');
|
||
|
||
} catch (error) {
|
||
console.error('❌ [STREAM] Resume stream failed:', error);
|
||
if (error.name !== 'AbortError') {
|
||
console.error('Resume approval error:', error);
|
||
// handleChatError 已在 useApproval 中调用
|
||
}
|
||
} finally {
|
||
console.log('🔄 [STREAM] Cleaning up streaming state');
|
||
if (threadState) {
|
||
threadState.isStreaming = false;
|
||
threadState.streamAbortController = null;
|
||
}
|
||
}
|
||
};
|
||
|
||
const handleApprove = () => {
|
||
handleApprovalWithStream(true);
|
||
};
|
||
|
||
const handleReject = () => {
|
||
handleApprovalWithStream(false);
|
||
};
|
||
|
||
// ==================== UI HANDLERS ====================
|
||
const handleKeyDown = (e) => {
|
||
if (e.key === 'Enter' && !e.shiftKey) {
|
||
e.preventDefault();
|
||
handleSendMessage();
|
||
}
|
||
};
|
||
|
||
// 处理示例问题点击
|
||
const handleExampleClick = (questionText) => {
|
||
userInput.value = questionText;
|
||
nextTick(() => {
|
||
handleSendMessage();
|
||
});
|
||
};
|
||
|
||
const buildExportPayload = () => {
|
||
const agentId = currentAgentId.value;
|
||
let agentDescription = '';
|
||
if (agentId && agents.value && agents.value.length > 0) {
|
||
const agent = agents.value.find(a => a.id === agentId);
|
||
agentDescription = agent ? (agent.description || '') : '';
|
||
}
|
||
|
||
const payload = {
|
||
chatTitle: currentThread.value?.title || '新对话',
|
||
agentName: currentAgentName.value || currentAgent.value?.name || '智能助手',
|
||
agentDescription: agentDescription || currentAgent.value?.description || '',
|
||
messages: conversations.value ? JSON.parse(JSON.stringify(conversations.value)) : [],
|
||
onGoingMessages: onGoingConvMessages.value ? JSON.parse(JSON.stringify(onGoingConvMessages.value)) : []
|
||
};
|
||
|
||
return payload;
|
||
};
|
||
|
||
defineExpose({
|
||
getExportPayload: buildExportPayload
|
||
});
|
||
|
||
const toggleSidebar = () => {
|
||
chatUIStore.toggleSidebar();
|
||
};
|
||
const openAgentModal = () => emit('open-agent-modal');
|
||
|
||
// ==================== HELPER FUNCTIONS ====================
|
||
const getLastMessage = (conv) => {
|
||
if (!conv?.messages?.length) return null;
|
||
for (let i = conv.messages.length - 1; i >= 0; i--) {
|
||
if (conv.messages[i].type === 'ai') return conv.messages[i];
|
||
}
|
||
return null;
|
||
};
|
||
|
||
const showMsgRefs = (msg) => {
|
||
// 如果正在审批中，不显示 refs
|
||
if (approvalState.showModal) {
|
||
return false;
|
||
}
|
||
|
||
// 如果当前线程ID与审批线程ID匹配，但审批框已关闭（说明刚刚处理完审批）
|
||
// 且当前有新的流式处理正在进行，则不显示之前被中断的消息的 refs
|
||
if (approvalState.threadId &&
|
||
chatState.currentThreadId === approvalState.threadId &&
|
||
!approvalState.showModal &&
|
||
isProcessing) {
|
||
return false;
|
||
}
|
||
|
||
// 只有真正完成的消息才显示 refs
|
||
if (msg.isLast && msg.status === 'finished') {
|
||
return ['copy'];
|
||
}
|
||
return false;
|
||
};
|
||
|
||
// ==================== LIFECYCLE & WATCHERS ====================
|
||
const loadChatsList = async () => {
|
||
const agentId = currentAgentId.value;
|
||
if (!agentId) {
|
||
console.warn('No agent selected, cannot load chats list');
|
||
threads.value = [];
|
||
chatState.currentThreadId = null;
|
||
return;
|
||
}
|
||
|
||
try {
|
||
await fetchThreads(agentId);
|
||
if (currentAgentId.value !== agentId) return;
|
||
|
||
// 如果当前线程不在线程列表中，清空当前线程
|
||
if (chatState.currentThreadId && !threads.value.find(t => t.id === chatState.currentThreadId)) {
|
||
chatState.currentThreadId = null;
|
||
}
|
||
|
||
// 如果有线程但没有选中任何线程，自动选择第一个
|
||
if (threads.value.length > 0 && !chatState.currentThreadId) {
|
||
await selectChat(threads.value[0].id);
|
||
}
|
||
} catch (error) {
|
||
handleChatError(error, 'load');
|
||
}
|
||
};
|
||
|
||
const initAll = async () => {
|
||
try {
|
||
if (!agentStore.isInitialized) {
|
||
await agentStore.initialize();
|
||
}
|
||
} catch (error) {
|
||
handleChatError(error, 'load');
|
||
}
|
||
};
|
||
|
||
onMounted(async () => {
|
||
await initAll();
|
||
scrollController.enableAutoScroll();
|
||
});
|
||
|
||
watch(currentAgentId, async (newAgentId, oldAgentId) => {
|
||
if (newAgentId !== oldAgentId) {
|
||
// 清理当前线程状态
|
||
chatState.currentThreadId = null;
|
||
threadMessages.value = {};
|
||
// 清理所有线程状态
|
||
resetOnGoingConv();
|
||
|
||
if (newAgentId) {
|
||
await loadChatsList();
|
||
} else {
|
||
threads.value = [];
|
||
}
|
||
}
|
||
}, { immediate: true });
|
||
|
||
|
||
watch(conversations, () => {
|
||
if (isProcessing.value) {
|
||
scrollController.scrollToBottom();
|
||
}
|
||
}, { deep: true, flush: 'post' });
|
||
|
||
</script>
|
||
|
||
<style lang="less" scoped>
|
||
@import '@/assets/css/main.css';
|
||
|
||
.chat-container {
|
||
display: flex;
|
||
width: 100%;
|
||
height: 100%;
|
||
position: relative;
|
||
}
|
||
|
||
.sidebar-backdrop {
|
||
display: none; /* 默认隐藏，通过v-if控制显示 */
|
||
position: absolute;
|
||
top: 0;
|
||
left: 0;
|
||
right: 0;
|
||
bottom: 0;
|
||
background-color: rgba(0, 0, 0, 0.4);
|
||
z-index: 99;
|
||
animation: fadeIn 0.3s ease;
|
||
}
|
||
|
||
.floating-sidebar {
|
||
position: absolute !important;
|
||
z-index: 100;
|
||
height: 100%;
|
||
left: 0;
|
||
top: 0;
|
||
transform: translateX(0);
|
||
transition: transform 0.3s ease;
|
||
width: 80% !important;
|
||
max-width: 300px;
|
||
|
||
&.no-transition {
|
||
transition: none !important;
|
||
}
|
||
|
||
&.collapsed {
|
||
transform: translateX(-100%);
|
||
}
|
||
}
|
||
|
||
.chat {
|
||
position: relative;
|
||
flex: 1;
|
||
display: flex;
|
||
flex-direction: column;
|
||
overflow-x: hidden;
|
||
background: white;
|
||
position: relative;
|
||
box-sizing: border-box;
|
||
overflow-y: scroll;
|
||
transition: all 0.3s ease;
|
||
|
||
.chat-header {
|
||
user-select: none;
|
||
position: sticky;
|
||
top: 0;
|
||
z-index: 10;
|
||
height: var(--header-height);
|
||
display: flex;
|
||
justify-content: space-between;
|
||
align-items: center;
|
||
padding: 1rem 8px;
|
||
|
||
.header__left, .header__right, .header__center {
|
||
display: flex;
|
||
align-items: center;
|
||
}
|
||
}
|
||
}
|
||
|
||
.chat-examples {
|
||
padding: 0 50px;
|
||
text-align: center;
|
||
position: absolute;
|
||
top: 15%;
|
||
width: 100%;
|
||
z-index: 9;
|
||
animation: slideInUp 0.5s ease-out;
|
||
|
||
h1 {
|
||
margin-bottom: 20px;
|
||
font-size: 1.3rem;
|
||
color: var(--gray-1000);
|
||
}
|
||
|
||
p {
|
||
font-size: 1.1rem;
|
||
color: var(--gray-700);
|
||
}
|
||
|
||
.agent-icons {
|
||
height: 180px;
|
||
}
|
||
|
||
.example-questions {
|
||
margin-top: 16px;
|
||
text-align: center;
|
||
|
||
.example-title {
|
||
font-size: 0.85rem;
|
||
color: var(--gray-600);
|
||
margin-bottom: 12px;
|
||
}
|
||
|
||
.example-chips {
|
||
display: flex;
|
||
flex-wrap: wrap;
|
||
gap: 8px;
|
||
justify-content: center;
|
||
}
|
||
|
||
.example-chip {
|
||
padding: 6px 12px;
|
||
background: var(--gray-25);
|
||
// border: 1px solid var(--gray-100);
|
||
border-radius: 16px;
|
||
cursor: pointer;
|
||
font-size: 0.8rem;
|
||
color: var(--gray-700);
|
||
transition: all 0.15s ease;
|
||
white-space: nowrap;
|
||
max-width: 200px;
|
||
overflow: hidden;
|
||
text-overflow: ellipsis;
|
||
|
||
&:hover {
|
||
// background: var(--main-25);
|
||
border-color: var(--main-200);
|
||
color: var(--main-700);
|
||
box-shadow: 0 0px 4px rgba(0, 0, 0, 0.03);
|
||
}
|
||
|
||
&:active {
|
||
transform: translateY(0);
|
||
box-shadow: 0 1px 2px rgba(0, 0, 0, 0.1);
|
||
}
|
||
}
|
||
}
|
||
|
||
.inputer-init {
|
||
margin: 20px auto;
|
||
width: 90%;
|
||
max-width: 800px;
|
||
}
|
||
}
|
||
|
||
.chat-loading {
|
||
padding: 0 50px;
|
||
text-align: center;
|
||
position: absolute;
|
||
top: 20%;
|
||
width: 100%;
|
||
z-index: 9;
|
||
animation: slideInUp 0.5s ease-out;
|
||
display: flex;
|
||
align-items: center;
|
||
justify-content: center;
|
||
gap: 12px;
|
||
|
||
span {
|
||
color: var(--gray-700);
|
||
font-size: 14px;
|
||
}
|
||
|
||
.loading-spinner {
|
||
width: 20px;
|
||
height: 20px;
|
||
border: 2px solid var(--gray-200);
|
||
border-top-color: var(--main-color);
|
||
border-radius: 50%;
|
||
animation: spin 0.8s linear infinite;
|
||
}
|
||
}
|
||
|
||
.chat-box {
|
||
width: 100%;
|
||
max-width: 800px;
|
||
margin: 0 auto;
|
||
flex-grow: 1;
|
||
padding: 1rem 2rem;
|
||
display: flex;
|
||
flex-direction: column;
|
||
}
|
||
|
||
.conv-box {
|
||
display: flex;
|
||
flex-direction: column;
|
||
gap: 4px;
|
||
}
|
||
|
||
.bottom {
|
||
position: sticky;
|
||
bottom: 0;
|
||
width: 100%;
|
||
margin: 0 auto;
|
||
padding: 4px 2rem 0 2rem;
|
||
background: white;
|
||
z-index: 1000;
|
||
|
||
.message-input-wrapper {
|
||
width: 100%;
|
||
max-width: 800px;
|
||
margin: 0 auto;
|
||
|
||
.bottom-actions {
|
||
display: flex;
|
||
justify-content: center;
|
||
align-items: center;
|
||
}
|
||
|
||
.note {
|
||
font-size: small;
|
||
color: #ccc;
|
||
margin: 4px 0;
|
||
user-select: none;
|
||
}
|
||
}
|
||
}
|
||
|
||
.conversation-list::-webkit-scrollbar {
|
||
position: absolute;
|
||
width: 4px;
|
||
height: 4px;
|
||
}
|
||
|
||
.conversation-list::-webkit-scrollbar-track {
|
||
background: transparent;
|
||
border-radius: 4px;
|
||
}
|
||
|
||
.conversation-list::-webkit-scrollbar-thumb {
|
||
background: var(--gray-400);
|
||
border-radius: 4px;
|
||
}
|
||
|
||
.conversation-list::-webkit-scrollbar-thumb:hover {
|
||
background: rgb(100, 100, 100);
|
||
border-radius: 4px;
|
||
}
|
||
|
||
.chat::-webkit-scrollbar {
|
||
position: absolute;
|
||
width: 4px;
|
||
height: 4px;
|
||
}
|
||
|
||
.chat::-webkit-scrollbar-track {
|
||
background: transparent;
|
||
border-radius: 4px;
|
||
}
|
||
|
||
.chat::-webkit-scrollbar-thumb {
|
||
background: var(--gray-400);
|
||
border-radius: 4px;
|
||
}
|
||
|
||
.chat::-webkit-scrollbar-thumb:hover {
|
||
background: rgb(100, 100, 100);
|
||
border-radius: 4px;
|
||
}
|
||
|
||
.loading-dots {
|
||
display: inline-flex;
|
||
align-items: center;
|
||
justify-content: center;
|
||
gap: 3px;
|
||
}
|
||
|
||
.loading-dots div {
|
||
width: 6px;
|
||
height: 6px;
|
||
background: linear-gradient(135deg, var(--main-color), var(--main-700));
|
||
border-radius: 50%;
|
||
animation: dotPulse 1.4s infinite ease-in-out both;
|
||
box-shadow: 0 1px 3px rgba(59, 130, 246, 0.3);
|
||
}
|
||
|
||
.loading-dots div:nth-child(1) {
|
||
animation-delay: -0.32s;
|
||
}
|
||
|
||
.loading-dots div:nth-child(2) {
|
||
animation-delay: -0.16s;
|
||
}
|
||
|
||
.loading-dots div:nth-child(3) {
|
||
animation-delay: 0s;
|
||
}
|
||
|
||
.generating-status {
|
||
display: flex;
|
||
justify-content: flex-start;
|
||
padding: 1rem 0;
|
||
animation: fadeInUp 0.4s ease-out;
|
||
transition: all 0.2s;
|
||
}
|
||
|
||
.generating-indicator {
|
||
display: flex;
|
||
align-items: center;
|
||
padding: 0.75rem 0rem;
|
||
|
||
.generating-text {
|
||
margin-left: 12px;
|
||
color: var(--gray-700);
|
||
font-size: 14px;
|
||
font-weight: 500;
|
||
letter-spacing: 0.025em;
|
||
}
|
||
}
|
||
|
||
@keyframes dotPulse {
|
||
0%, 80%, 100% {
|
||
transform: scale(0.8);
|
||
opacity: 0.5;
|
||
}
|
||
40% {
|
||
transform: scale(1.1);
|
||
opacity: 1;
|
||
}
|
||
}
|
||
|
||
@keyframes shimmer {
|
||
0% {
|
||
left: -100%;
|
||
}
|
||
100% {
|
||
left: 100%;
|
||
}
|
||
}
|
||
|
||
@keyframes swing-in-top-fwd {
|
||
0% {
|
||
transform: rotateX(-100deg);
|
||
transform-origin: top;
|
||
opacity: 0;
|
||
}
|
||
100% {
|
||
transform: rotateX(0deg);
|
||
transform-origin: top;
|
||
opacity: 1;
|
||
}
|
||
}
|
||
|
||
@keyframes slideInUp {
|
||
from {
|
||
transform: translateY(20px);
|
||
opacity: 0;
|
||
}
|
||
to {
|
||
transform: translateY(0);
|
||
opacity: 1;
|
||
}
|
||
}
|
||
|
||
@keyframes fadeInUp {
|
||
from {
|
||
opacity: 0;
|
||
transform: translateY(10px);
|
||
}
|
||
to {
|
||
opacity: 1;
|
||
transform: translateY(0);
|
||
}
|
||
}
|
||
|
||
@keyframes fadeInDown {
|
||
from {
|
||
opacity: 0;
|
||
transform: translateY(-10px);
|
||
}
|
||
to {
|
||
opacity: 1;
|
||
transform: translateY(0);
|
||
}
|
||
}
|
||
|
||
@keyframes fadeIn {
|
||
from {
|
||
opacity: 0;
|
||
}
|
||
to {
|
||
opacity: 1;
|
||
}
|
||
}
|
||
|
||
@keyframes spin {
|
||
0% {
|
||
transform: rotate(0deg);
|
||
}
|
||
100% {
|
||
transform: rotate(360deg);
|
||
}
|
||
}
|
||
|
||
@media (max-width: 1800px) {
|
||
|
||
.chat-header {
|
||
background-color: white;
|
||
border-bottom: 1px solid var(--gray-100);
|
||
}
|
||
}
|
||
|
||
|
||
|
||
@media (max-width: 768px) {
|
||
.chat-sidebar.collapsed {
|
||
width: 0;
|
||
border: none;
|
||
}
|
||
|
||
.chat-header {
|
||
.header__left {
|
||
.text {
|
||
display: none;
|
||
}
|
||
}
|
||
}
|
||
}
|
||
|
||
@media (max-width: 520px) {
|
||
.sidebar-backdrop {
|
||
display: block;
|
||
}
|
||
|
||
.chat-box {
|
||
padding: 1rem 1rem;
|
||
}
|
||
|
||
.bottom {
|
||
padding: 0.5rem 0.5rem;
|
||
}
|
||
|
||
.chat-header {
|
||
padding: 0.5rem 0 !important;
|
||
|
||
}
|
||
|
||
.floating-sidebar {
|
||
position: fixed;
|
||
z-index: 100;
|
||
height: 100%;
|
||
left: 0;
|
||
top: 0;
|
||
box-shadow: 0 4px 12px rgba(0, 0, 0, 0.15);
|
||
transform: translateX(0);
|
||
transition: transform 0.3s ease;
|
||
width: 80% !important;
|
||
max-width: 300px;
|
||
|
||
&.collapsed {
|
||
transform: translateX(-100%);
|
||
}
|
||
}
|
||
}
|
||
|
||
.hide-text {
|
||
display: none;
|
||
}
|
||
</style>
|
||
|
||
<style lang="less">
|
||
.agent-nav-btn {
|
||
display: flex;
|
||
gap: 10px;
|
||
padding: 6px 14px;
|
||
justify-content: center;
|
||
align-items: center;
|
||
border-radius: 12px;
|
||
color: var(--gray-900);
|
||
cursor: pointer;
|
||
width: auto;
|
||
font-size: 15px;
|
||
transition: background-color 0.3s;
|
||
border: none;
|
||
background: transparent;
|
||
|
||
&:hover:not(.is-disabled) {
|
||
background-color: var(--gray-50);
|
||
}
|
||
|
||
&.is-disabled {
|
||
cursor: not-allowed;
|
||
opacity: 0.7;
|
||
pointer-events: none;
|
||
}
|
||
|
||
.nav-btn-icon {
|
||
height: 24px;
|
||
}
|
||
|
||
.loading-icon {
|
||
animation: spin 1s linear infinite;
|
||
}
|
||
}
|
||
|
||
@keyframes spin {
|
||
from {
|
||
transform: rotate(0deg);
|
||
}
|
||
to {
|
||
transform: rotate(360deg);
|
||
}
|
||
}
|
||
</style>
|