fix: 修复文件上传显示重复问题

- 使用 lastSentMessageWithFiles 判断避免重复显示
- 图片在前端直接显示预览（base64）
- 文本文件显示名称和内容摘要
- extra_data 保存图片/文件信息用于历史记录

main_v2.py

@@ -648,6 +648,7 @@ async def get_messages(conversation_id: str, db: Session = Depends(get_db)):
                 "role": m.role,
                 "content": m.content,
                 "thinking_content": m.thinking_content,  # v2新增
+                "extra_data": m.extra_data,  # 包含搜索结果等
                 "source": m.source,
                 "agent_id": m.agent_id,  # v2新增
                 "model_used": m.model_used,  # v2新增
@@ -742,6 +743,7 @@ async def websocket_endpoint(websocket: WebSocket, user_id: str):
                                     "role": m.role,
                                     "content": m.content,
                                     "thinking_content": m.thinking_content,
+                                    "extra_data": m.extra_data,  # 包含搜索结果等
                                     "agent_id": m.agent_id,  # 每条消息的Agent ID
                                     "source": m.source,
                                     "created_at": m.created_at.isoformat()
@@ -764,6 +766,7 @@ async def websocket_endpoint(websocket: WebSocket, user_id: str):
                 
                 elif action == "chat":
                     message = data.get("message", "")
+                    files = data.get("files", [])  # 上传的文件
                     conversation_id = data.get("conversation_id")
                     enable_thinking = data.get("enable_thinking", True)
                     agent_id_override = data.get("agent_id")
@@ -774,106 +777,45 @@ async def websocket_endpoint(websocket: WebSocket, user_id: str):
                         if agent and agent.is_active:
                             current_agent_id = agent_id_override
                     
-                    if not message.strip():
+                    # 如果没有消息但有文件，构造消息
+                    if not message.strip() and files:
+                        message = "[上传文件]"
+                    
+                    if not message.strip() and not files:
                         continue
                     
-                    # 获取Agent配置
+                    # 处理文件内容，添加到消息
+                    image_contents = []  # 图片内容（用于视觉模型）
+                    if files:
+                        for f in files:
+                            if f.get('type') and f['type'].startswith('image/'):
+                                # 图片：记录 base64 数据，后续可能用于视觉模型
+                                image_contents.append({
+                                    'name': f['name'],
+                                    'type': f['type'],
+                                    'data': f.get('content', '')  # base64 数据
+                                })
+                                message += f"\n[图片: {f['name']}]"
+                            elif f.get('content'):
+                                # 文本文件：直接添加内容
+                                message += f"\n\n文件 {f['name']} 内容:\n{f['content'][:3000]}"
+                                if len(f['content']) > 3000:
+                                    message += "...(内容过长已截断)"
+                    
+                    # 保存图片信息到 extra_data（用于历史记录）
+                    extra_data_for_msg = None
+                    if image_contents:
+                        # 只保存图片 URL（不保存完整 base64）
+                        extra_data_for_msg = {
+                            'images': [{'name': i['name'], 'type': i['type']} for i in image_contents],
+                            'files': [{'name': f['name'], 'type': f['type']} for f in files if not f['type'].startswith('image/')]
+                        }
+                    
+                    # 1. 获取Agent配置
                     agent_config = agent_service.get_agent_config(current_agent_id)
                     agent_tools = agent_config.get('agent', {}).get('tools', [])
                     
-                    # 检查是否需要执行搜索
-                    search_context = None
-                    search_results_for_client = None  # 用于发送给前端
-                    logger.info(f"检查搜索条件: agent_tools={agent_tools}, disabled_tools={disabled_tools}")
-                    
-                    if 'search' in agent_tools and 'search' not in disabled_tools:
-                        # 只要启用了搜索工具且未禁用，就执行搜索
-                        logger.info("搜索条件满足，开始执行搜索")
-                        
-                        # 执行搜索
-                        tool_service = ToolService(db)
-                        search_tool = tool_service.get_default_tool('search')
-                        logger.info(f"获取到搜索工具: {search_tool.name if search_tool else 'None'}")
-                        
-                        if search_tool and search_tool.config.get('api_key'):
-                            # 执行搜索
-                            tool_service = ToolService(db)
-                            search_tool = tool_service.get_default_tool('search')
-                            
-                            if search_tool and search_tool.config.get('api_key'):
-                                import httpx
-                                import time
-                                start_time = time.time()
-                                try:
-                                    logger.info(f"执行搜索: query={message}")
-                                    tavily_url = "https://api.tavily.com/search"
-                                    config = search_tool.config
-                                    payload = {
-                                        "api_key": config.get('api_key'),
-                                        "query": message,
-                                        "max_results": config.get('max_results', 5),
-                                        "search_depth": config.get('search_depth', 'basic')
-                                    }
-                                    
-                                    # 同步调用
-                                    with httpx.Client(timeout=30) as client:
-                                        resp = client.post(tavily_url, json=payload)
-                                        search_result = resp.json()
-                                    
-                                    duration_ms = int((time.time() - start_time) * 1000)
-                                    
-                                    if search_result.get("results"):
-                                        # 构建搜索上下文（给LLM）
-                                        search_context = "\n\n【搜索结果】\n"
-                                        for i, r in enumerate(search_result["results"][:5], 1):
-                                            search_context += f"{i}. {r.get('title', 'N/A')}\n   {r.get('content', r.get('snippet', 'N/A'))[:200]}\n   来源: {r.get('url', 'N/A')}\n"
-                                        logger.info(f"搜索完成: {len(search_result['results'])} 条结果")
-                                        
-                                        # 构建搜索结果给前端展示
-                                        search_results_for_client = [
-                                            {
-                                                "title": r.get('title', 'N/A'),
-                                                "snippet": r.get('content', r.get('snippet', ''))[:150],
-                                                "url": r.get('url', 'N/A')
-                                            }
-                                            for r in search_result["results"][:5]
-                                        ]
-                                        
-                                        # 发送搜索结果给前端
-                                        await websocket.send_json({
-                                            "type": "search_results",
-                                            "conversation_id": conversation_id,
-                                            "results": search_results_for_client,
-                                            "query": message
-                                        })
-                                        
-                                        # 更新统计和日志
-                                        tool_service.increment_stats(search_tool.id, True)
-                                        tool_service.log_usage({
-                                            'tool_id': search_tool.id,
-                                            'tool_type': 'search',
-                                            'query': message,
-                                            'success': True,
-                                            'result_summary': f'{len(search_result["results"])} results',
-                                            'conversation_id': conversation_id,
-                                            'agent_id': current_agent_id,
-                                            'duration_ms': duration_ms
-                                        })
-                                except Exception as e:
-                                    duration_ms = int((time.time() - start_time) * 1000)
-                                    logger.error(f"搜索失败: {e}")
-                                    tool_service.increment_stats(search_tool.id, False)
-                                    tool_service.log_usage({
-                                        'tool_id': search_tool.id,
-                                        'tool_type': 'search',
-                                        'query': message,
-                                        'success': False,
-                                        'error_message': str(e),
-                                        'conversation_id': conversation_id,
-                                        'duration_ms': duration_ms
-                                    })
-                    
-                    # 获取或创建会话
+                    # 2. 获取或创建会话（先有 conversation_id）
                     if conversation_id:
                         conversation = conv_service.get_conversation(conversation_id)
                     else:
@@ -884,30 +826,131 @@ async def websocket_endpoint(websocket: WebSocket, user_id: str):
                             "conversation_id": conversation_id
                         })
                     
-                    # 保存用户消息
-                    user_msg = conv_service.add_message(
-                        conversation_id=conversation.id,
-                        role='user',
-                        content=message,
-                        source='web'
-                    )
-                    
-                    # 广播用户消息
+                    # 3. 广播用户消息（前端立即看到）
                     await manager.send_to_user(MAIN_USER_ID, {
                         "type": "user_message",
                         "conversation_id": conversation_id,
                         "message": {
-                            "id": user_msg.id,
+                            "id": None,  # 临时，后面会保存
                             "role": "user",
                             "content": message,
                             "source": "web",
-                            "created_at": user_msg.created_at.isoformat()
+                            "created_at": datetime.utcnow().isoformat()
                         }
                     })
                     
-                    # 获取Agent配置
-                    agent_config = agent_service.get_agent_config(current_agent_id)
+                    # 4. 执行搜索并发送搜索结果
+                    search_context = None
+                    search_results_for_client = None  # 用于发送给前端和保存
+                    logger.info(f"检查搜索条件: agent_tools={agent_tools}, disabled_tools={disabled_tools}")
                     
+                    if 'search' in agent_tools and 'search' not in disabled_tools:
+                        logger.info("搜索条件满足，开始执行搜索")
+                        
+                        tool_service = ToolService(db)
+                        search_tool = tool_service.get_default_tool('search')
+                        logger.info(f"获取到搜索工具: {search_tool.name if search_tool else 'None'}")
+                        
+                        if search_tool and search_tool.config.get('api_key'):
+                            import httpx
+                            import time
+                            start_time = time.time()
+                            try:
+                                logger.info(f"执行搜索: query={message}")
+                                tavily_url = "https://api.tavily.com/search"
+                                config = search_tool.config
+                                payload = {
+                                    "api_key": config.get('api_key'),
+                                    "query": message,
+                                    "max_results": config.get('max_results', 5),
+                                    "search_depth": config.get('search_depth', 'basic')
+                                }
+                                
+                                with httpx.Client(timeout=30) as client:
+                                    resp = client.post(tavily_url, json=payload)
+                                    search_result = resp.json()
+                                
+                                duration_ms = int((time.time() - start_time) * 1000)
+                                
+                                if search_result.get("results"):
+                                    # 构建搜索上下文（给LLM）
+                                    max_for_llm = config.get('max_results', 5)
+                                    search_context = "\n\n【搜索结果】\n"
+                                    for i, r in enumerate(search_result["results"][:max_for_llm], 1):
+                                        search_context += f"{i}. {r.get('title', 'N/A')}\n   {r.get('content', r.get('snippet', 'N/A'))[:200]}\n   来源: {r.get('url', 'N/A')}\n"
+                                    logger.info(f"搜索完成: {len(search_result['results'])} 条结果，使用 {min(len(search_result['results']), max_for_llm)} 条")
+                                    
+                                    # 发送搜索结果给前端（按配置的数量）
+                                    max_display = config.get('max_results', 5)
+                                    search_results_for_client = [
+                                        {
+                                            "title": r.get('title', 'N/A'),
+                                            "snippet": r.get('content', r.get('snippet', ''))[:150],
+                                            "url": r.get('url', 'N/A')
+                                        }
+                                        for r in search_result["results"][:max_display]
+                                    ]
+                                    await websocket.send_json({
+                                        "type": "search_results",
+                                        "conversation_id": conversation_id,
+                                        "results": search_results_for_client,
+                                        "query": message
+                                    })
+                                    
+                                    # 更新统计和日志
+                                    tool_service.increment_stats(search_tool.id, True)
+                                    tool_service.log_usage({
+                                        'tool_id': search_tool.id,
+                                        'tool_type': 'search',
+                                        'query': message,
+                                        'success': True,
+                                        'result_summary': f'{len(search_result["results"])} results',
+                                        'conversation_id': conversation_id,
+                                        'agent_id': current_agent_id,
+                                        'duration_ms': duration_ms
+                                    })
+                            except Exception as e:
+                                duration_ms = int((time.time() - start_time) * 1000)
+                                logger.error(f"搜索失败: {e}")
+                                tool_service.increment_stats(search_tool.id, False)
+                                tool_service.log_usage({
+                                    'tool_id': search_tool.id,
+                                    'tool_type': 'search',
+                                    'query': message,
+                                    'success': False,
+                                    'error_message': str(e),
+                                    'conversation_id': conversation_id,
+                                    'duration_ms': duration_ms
+                                })
+                    
+                    # 5. 保存用户消息到数据库
+                    extra_data_to_save = None
+                    if search_results_for_client:
+                        extra_data_to_save = {'search_results': search_results_for_client, 'search_query': message}
+                    if extra_data_for_msg:
+                        if extra_data_to_save:
+                            extra_data_to_save.update(extra_data_for_msg)
+                        else:
+                            extra_data_to_save = extra_data_for_msg
+                    
+                    user_msg = conv_service.add_message(
+                        conversation_id=conversation.id,
+                        role='user',
+                        content=message,
+                        source='web',
+                        extra_data=extra_data_to_save
+                    )
+                    
+                    # 6. 获取对话历史（包含刚保存的用户消息）
+                    history = conv_service.get_conversation_history(conversation_id, limit=agent_config['agent'].get('max_history', 20))
+                    
+                    # 7. 如果有搜索结果，添加到消息中
+                    if search_context:
+                        modified_system_prompt = agent_config['agent'].get('system_prompt', '') + "\n\n如果提供了搜索结果，请基于搜索结果回答用户问题，并注明信息来源。"
+                        agent_config['agent']['system_prompt'] = modified_system_prompt
+                        history.append({"role": "system", "content": f"以下是搜索到的相关信息，请参考这些内容回答用户问题：{search_context}"})
+                    
+                    # 8. 调用LLM返回回复
                     if not agent_config or not agent_config.get('provider'):
                         await websocket.send_json({
                             "type": "error",
@@ -915,20 +958,7 @@ async def websocket_endpoint(websocket: WebSocket, user_id: str):
                         })
                         continue
                     
-                    # 获取对话历史
-                    history = conv_service.get_conversation_history(conversation_id, limit=agent_config['agent'].get('max_history', 20))
-                    
-                    # 如果有搜索结果，添加到消息中
-                    if search_context:
-                        # 在系统提示中添加搜索结果说明
-                        modified_system_prompt = agent_config['agent'].get('system_prompt', '') + "\n\n如果提供了搜索结果，请基于搜索结果回答用户问题，并注明信息来源。"
-                        agent_config['agent']['system_prompt'] = modified_system_prompt
-                        # 将搜索结果作为系统消息添加到历史
-                        history.append({"role": "system", "content": f"以下是搜索到的相关信息，请参考这些内容回答用户问题：{search_context}"})
-                    
-                    # 使用非流式调用LLM（简化版本，确保稳定）
                     try:
-                        # 调用LLM（非流式）
                         response, thinking_content = await llm_service.chat(
                             messages=history,
                             provider_config=agent_config['provider'],
@@ -949,7 +979,7 @@ async def websocket_endpoint(websocket: WebSocket, user_id: str):
                             model_used=agent_config['provider'].get('default_model')
                         )
                         
-                        # 发送完整回复（包含思考内容）
+                        # 发送AI回复
                         await websocket.send_json({
                             "type": "assistant_message",
                             "conversation_id": conversation_id,
@@ -967,7 +997,6 @@ async def websocket_endpoint(websocket: WebSocket, user_id: str):
                         
                         logger.info(f"AI回复已发送: conversation_id={conversation_id}")
                         
-                        # 启用发送按钮
                         await websocket.send_json({
                             "type": "stream_end",
                             "conversation_id": conversation_id

templates/index.html

@@ -86,13 +86,17 @@
         .thinking-toggle { font-size: 12px; color: #667eea; }
         .thinking-content { margin-top: 12px; display: none; }
         .thinking-content.expanded { display: block; }
-        .search-results-box { margin: 8px 0; padding: 12px; background: #f8f9fa; border-radius: 8px; border: 1px solid #e9ecef; }
-        .search-results-box h5 { margin: 0 0 8px; font-size: 14px; color: #495057; }
-        .search-result-item { margin-bottom: 8px; padding: 8px; background: white; border-radius: 6px; }
+        .search-results-box { margin: 12px 0; padding: 10px 12px; background: linear-gradient(135deg, #f0f7ff 0%, #e8f4f8 100%); border-radius: 8px; border: 1px solid #d0e8f0; }
+        .search-results-header { display: flex; align-items: center; justify-content: space-between; cursor: pointer; }
+        .search-results-header h5 { margin: 0; font-size: 13px; color: #10a37f; display: flex; align-items: center; gap: 6px; }
+        .search-results-toggle { font-size: 12px; color: #666; }
+        .search-results-content { margin-top: 10px; display: none; }
+        .search-results-content.expanded { display: block; }
+        .search-result-item { margin-bottom: 8px; padding: 8px 10px; background: white; border-radius: 6px; border: 1px solid #eee; }
         .search-result-item:last-child { margin-bottom: 0; }
         .search-result-title { font-size: 13px; color: #10a37f; font-weight: 500; margin-bottom: 4px; }
         .search-result-snippet { font-size: 12px; color: #666; line-height: 1.4; }
-        .search-result-url { font-size: 11px; color: #999; margin-top: 4px; }
+        .search-result-url { font-size: 11px; color: #999; margin-top: 4px; overflow: hidden; text-overflow: ellipsis; }
         
         /* Agent信息 */
         .agent-info { font-size: 12px; color: #999; margin-top: 8px; }
@@ -103,10 +107,23 @@
         .input-row { display: flex; gap: 12px; align-items: center; }
         .input-row textarea { flex: 1; padding: 12px 16px; border: 1px solid #ddd; border-radius: 12px; font-size: 16px; resize: none; outline: none; max-height: 200px; min-height: 48px; line-height: 1.5; }
         .input-row textarea:focus { border-color: #10a37f; }
+        .upload-btn { width: 48px; height: 48px; border-radius: 12px; background: #f5f5f5; border: 1px solid #ddd; cursor: pointer; font-size: 20px; display: flex; align-items: center; justify-content: center; transition: all 0.2s; color: #666; }
+        .upload-btn:hover { background: #e8e8e8; border-color: #10a37f; color: #10a37f; }
         .send-btn { width: 48px; height: 48px; border-radius: 12px; background: #10a37f; border: none; color: #fff; cursor: pointer; font-size: 20px; display: flex; align-items: center; justify-content: center; transition: background 0.2s; }
         .send-btn:hover { background: #0d8c6d; }
         .send-btn:disabled { background: #ccc; cursor: not-allowed; }
         
+        /* 文件预览 */
+        .file-preview-area { margin-top: 12px; display: flex; gap: 8px; flex-wrap: wrap; }
+        .file-preview-item { position: relative; border: 1px solid #e0e0e0; border-radius: 8px; padding: 8px; background: #f8f9fa; max-width: 200px; }
+        .file-preview-item.image-preview { padding: 4px; }
+        .file-preview-item img { max-width: 180px; max-height: 120px; border-radius: 6px; }
+        .file-preview-item .file-icon { display: flex; align-items: center; gap: 8px; }
+        .file-preview-item .file-icon i { font-size: 24px; color: #10a37f; }
+        .file-preview-item .file-name { font-size: 12px; color: #666; max-width: 150px; overflow: hidden; text-overflow: ellipsis; white-space: nowrap; }
+        .file-preview-item .file-remove { position: absolute; top: 4px; right: 4px; width: 20px; height: 20px; border-radius: 50%; background: #ff4757; color: white; border: none; cursor: pointer; font-size: 12px; display: flex; align-items: center; justify-content: center; }
+        .file-preview-item .file-remove:hover { background: #ff6b7a; }
+        
         /* 快捷语句 - 横向扁平 */
         .quick-phrases-bar { display: flex; align-items: center; gap: 8px; margin-top: 12px; position: relative; }
         .add-phrase-btn { padding: 6px 10px; background: #f0f0f0; border: 1px solid #ddd; border-radius: 6px; cursor: pointer; font-size: 12px; color: #666; white-space: nowrap; flex-shrink: 0; }
@@ -162,9 +179,12 @@
         <div class="input-container">
             <div class="input-area">
                 <div class="input-row">
+                    <input type="file" id="fileInput" multiple accept="image/*,.pdf,.txt,.md,.json,.csv,.doc,.docx" style="display:none" onchange="handleFileUpload(event)">
+                    <button class="upload-btn" onclick="document.getElementById('fileInput').click()" title="上传文件"><i class="ri-attachment-2"></i></button>
                     <textarea id="messageInput" placeholder="输入消息..." rows="1"></textarea>
                     <button class="send-btn" id="sendBtn" onclick="sendMessage()"><i class="ri-send-plane-fill"></i></button>
                 </div>
+                <div class="file-preview-area" id="filePreviewArea"></div>
                 <div class="quick-phrases-bar">
                     <div class="tool-toggle">
                         <input type="checkbox" id="enableSearch" checked>
@@ -276,9 +296,12 @@
                 case 'stream_end': document.getElementById('sendBtn').disabled = false; break;
                 case 'user_message': 
                     lastUserMessage = data.message.content; // 存储最后一条用户消息
-                    if (!isRegenerating) {
+                    // 如果是刚发送的消息（包含文件），已经显示了，不再重复显示
+                    if (!isRegenerating && data.message.content !== lastSentMessage && data.message.content !== lastSentMessageWithFiles) {
                         appendMessage('user', data.message.content); 
                     }
+                    lastSentMessage = null;
+                    lastSentMessageWithFiles = null;  // 清除标记
                     // 注意：不要在这里重置 isRegenerating，要等 assistant_message 处理后再重置
                     break;
                 case 'assistant_message': 
@@ -298,7 +321,7 @@
         }
         
         // 消息渲染
-        function appendMessage(role, content, thinking = null, agentName = null) {
+        function appendMessage(role, content, thinking = null, agentName = null, extraData = null) {
             const container = document.getElementById('messagesContainer');
             container.querySelector('.welcome')?.remove();
             
@@ -365,6 +388,23 @@
             
             html += '</div>';
             div.innerHTML = html;
+            
+            // 如果是用户消息且有搜索结果，在设置innerHTML后追加
+            if (role === 'user' && extraData) {
+                console.log('Processing extraData for user message:', extraData);
+                console.log('search_results exists:', extraData.search_results);
+                if (extraData.search_results && extraData.search_results.length > 0) {
+                    console.log('Building search results HTML for', extraData.search_results.length, 'results');
+                    const searchHtml = buildSearchResultsHtml(extraData.search_results, extraData.search_query || content);
+                    const bodyDiv = div.querySelector('.message-body');
+                    console.log('bodyDiv found:', bodyDiv != null);
+                    if (bodyDiv) {
+                        bodyDiv.insertAdjacentHTML('beforeend', searchHtml);
+                        console.log('Search results HTML inserted');
+                    }
+                }
+            }
+            
             container.appendChild(div);
             container.scrollTop = container.scrollHeight;
         }
@@ -616,7 +656,10 @@
         function displayHistory(messages) {
             const container = document.getElementById('messagesContainer');
             container.innerHTML = '';
-            messages.forEach(m => appendMessage(m.role, m.content, m.thinking_content));
+            messages.forEach(m => {
+                console.log('displayHistory message:', m.role, 'extra_data:', m.extra_data);
+                appendMessage(m.role, m.content, m.thinking_content, null, m.extra_data);
+            });
         }
         
         function clearMessages() {
@@ -635,12 +678,37 @@
             if (!results || results.length === 0) return;
             
             const container = document.getElementById('messagesContainer');
-            const div = document.createElement('div');
-            div.className = 'message assistant';
             
-            let html = `<div class="message-avatar">🔍</div><div class="message-body">
-                <div class="search-results-box">
-                    <h5>搜索: ${escapeHtml(query.substring(0, 50))}${query.length > 50 ? '...' : ''}</h5>`;
+            // 找到最后一条用户消息
+            const userMessages = container.querySelectorAll('.message.user');
+            const lastUserMsg = userMessages[userMessages.length - 1];
+            
+            if (!lastUserMsg) {
+                // 没有用户消息，作为独立消息显示
+                const div = document.createElement('div');
+                div.className = 'message assistant';
+                div.innerHTML = `<div class="message-avatar">🔍</div><div class="message-body">${buildSearchResultsHtml(results, query)}</div>`;
+                container.appendChild(div);
+            } else {
+                // 在用户消息的 message-body 中追加搜索结果
+                const msgBody = lastUserMsg.querySelector('.message-body');
+                if (msgBody) {
+                    msgBody.innerHTML += buildSearchResultsHtml(results, query);
+                }
+            }
+            
+            // 滚动到底部
+            container.scrollTop = container.scrollHeight;
+        }
+        
+        function buildSearchResultsHtml(results, query) {
+            const resultId = 'sr-' + Date.now();
+            let html = `<div class="search-results-box">
+                <div class="search-results-header" onclick="toggleSearchResults('${resultId}')">
+                    <h5><i class="ri-search-line"></i> 搜索: ${escapeHtml(query.substring(0, 30))}${query.length > 30 ? '...' : ''} (${results.length}条结果)</h5>
+                    <span class="search-results-toggle" id="${resultId}-toggle">展开 <i class="ri-arrow-down-s-line"></i></span>
+                </div>
+                <div class="search-results-content" id="${resultId}">`;
             
             for (const r of results) {
                 html += `<div class="search-result-item">
@@ -651,11 +719,19 @@
             }
             
             html += '</div></div>';
-            div.innerHTML = html;
-            container.appendChild(div);
-            
-            // 滚动到底部
-            container.scrollTop = container.scrollHeight;
+            return html;
+        }
+        
+        function toggleSearchResults(id) {
+            const content = document.getElementById(id);
+            const toggle = document.getElementById(id + '-toggle');
+            if (content.classList.contains('expanded')) {
+                content.classList.remove('expanded');
+                toggle.innerHTML = '展开 <i class="ri-arrow-down-s-line"></i>';
+            } else {
+                content.classList.add('expanded');
+                toggle.innerHTML = '收起 <i class="ri-arrow-up-s-line"></i>';
+            }
         }
         
         // 会话管理
@@ -714,27 +790,179 @@
         function sendMessage() {
             const input = document.getElementById('messageInput');
             const msg = input.value.trim();
-            if (!msg) return;
+            
+            // 如果没有消息且没有文件，不发送
+            if (!msg && pendingFiles.length === 0) return;
+            
             document.getElementById('sendBtn').disabled = true;
             input.value = '';
             input.style.height = 'auto';
             
+            // 立即显示用户消息（包含文件）
+            lastSentMessage = msg;
+            appendMessageWithFiles('user', msg, pendingFiles);
+            
+            // 清空文件预览
+            pendingFiles = [];
+            document.getElementById('filePreviewArea').innerHTML = '';
+            
             // 获取工具禁用状态
             const enableSearch = document.getElementById('enableSearch').checked;
             const disabledTools = [];
             if (!enableSearch) disabledTools.push('search');
             
+            // 发送消息（包含文件）
             if (ws?.readyState === WebSocket.OPEN) {
                 ws.send(JSON.stringify({ 
                     action: 'chat', 
                     message: msg, 
                     conversation_id: currentConversationId, 
                     agent_id: currentAgentId,
-                    disabled_tools: disabledTools  // 禁用的工具列表
+                    disabled_tools: disabledTools,
+                    files: lastSentFiles || []  // 发送的文件列表
                 }));
             }
+            
+            lastSentFiles = null;  // 清空
         }
         
+        let lastSentFiles = null;  // 记录发送的文件
+        let lastSentMessageWithFiles = null;  // 记录包含文件信息的完整消息
+        
+        // 显示带文件的用户消息
+        function appendMessageWithFiles(role, content, files) {
+            const container = document.getElementById('messagesContainer');
+            container.querySelector('.welcome')?.remove();
+            
+            const div = document.createElement('div');
+            div.className = `message ${role}`;
+            
+            const avatar = role === 'user' ? '👤' : '🤖';
+            let html = `<div class="message-avatar">${avatar}</div><div class="message-body">`;
+            
+            // 显示文本内容
+            if (content) {
+                html += `<div class="message-content"><div class="user-message-text">${escapeHtml(content)}</div></div>`;
+            }
+            
+            // 显示文件（图片直接显示，文本文件显示名称）
+            if (files && files.length > 0) {
+                html += '<div class="uploaded-files" style="margin-top:8px">';
+                lastSentFiles = files.map(f => ({
+                    name: f.name,
+                    type: f.type,
+                    content: f.content
+                }));
+                
+                for (const f of files) {
+                    if (f.type.startsWith('image/')) {
+                        // 图片直接显示
+                        html += `<div class="uploaded-image" style="margin-bottom:8px"><img src="${f.content}" style="max-width:300px;border-radius:8px"></div>`;
+                    } else {
+                        // 文本文件显示名称和内容摘要
+                        html += `<div class="uploaded-file" style="padding:8px;background:#f5f5f5;border-radius:6px;margin-bottom:8px">`;
+                        html += `<div style="font-size:13px;color:#10a37f"><i class="ri-file-text-line"></i> ${f.name}</div>`;
+                        if (f.content && f.content.length < 2000) {
+                            html += `<div style="font-size:12px;color:#666;margin-top:4px">${escapeHtml(f.content.substring(0, 300))}${f.content.length > 300 ? '...' : ''}</div>`;
+                        }
+                        html += '</div>';
+                    }
+                }
+                html += '</div>';
+                
+                // 记录完整消息（用于判断是否重复显示）
+                lastSentMessageWithFiles = content + '\n[文件:' + files.map(f => f.name).join(',') + ']';
+            }
+            
+            html += '</div>';
+            div.innerHTML = html;
+            container.appendChild(div);
+            
+            container.scrollTop = container.scrollHeight;
+        }
+            html += `<div class="message-actions"><button class="action-btn" onclick="copyMessage(this)"><i class="ri-file-copy-line"></i> 复制</button></div>`;
+            html += '</div>';
+            div.innerHTML = html;
+            container.appendChild(div);
+            
+            container.scrollTop = container.scrollHeight;
+        }
+        let pendingFiles = [];  // 待发送的文件
+        
+        // 文件上传处理
+        function handleFileUpload(event) {
+            const files = event.target.files;
+            const previewArea = document.getElementById('filePreviewArea');
+            
+            for (const file of files) {
+                const fileId = 'file-' + Date.now() + '-' + Math.random().toString(36).substr(2, 9);
+                
+                // 读取文件内容
+                const reader = new FileReader();
+                reader.onload = (e) => {
+                    const fileData = {
+                        id: fileId,
+                        name: file.name,
+                        type: file.type,
+                        size: file.size,
+                        content: e.target.result
+                    };
+                    pendingFiles.push(fileData);
+                    
+                    // 显示预览
+                    const previewItem = document.createElement('div');
+                    previewItem.className = 'file-preview-item';
+                    previewItem.id = fileId + '-preview';
+                    
+                    if (file.type.startsWith('image/')) {
+                        previewItem.classList.add('image-preview');
+                        previewItem.innerHTML = `
+                            <img src="${e.target.result}" alt="${file.name}">
+                            <button class="file-remove" onclick="removeFile('${fileId}')"><i class="ri-close-line"></i></button>
+                        `;
+                    } else {
+                        // 文件图标
+                        let iconClass = 'ri-file-text-line';
+                        if (file.name.endsWith('.pdf')) iconClass = 'ri-file-pdf-line';
+                        else if (file.name.endsWith('.json')) iconClass = 'ri-code-line';
+                        else if (file.name.endsWith('.csv')) iconClass = 'ri-table-line';
+                        else if (file.type.includes('word') || file.name.endsWith('.doc') || file.name.endsWith('.docx')) iconClass = 'ri-file-word-line';
+                        
+                        previewItem.innerHTML = `
+                            <div class="file-icon">
+                                <i class="${iconClass}"></i>
+                                <span class="file-name">${file.name}</span>
+                            </div>
+                            <button class="file-remove" onclick="removeFile('${fileId}')"><i class="ri-close-line"></i></button>
+                        `;
+                    }
+                    
+                    previewArea.appendChild(previewItem);
+                };
+                
+                // 根据文件类型选择读取方式
+                if (file.type.startsWith('image/')) {
+                    reader.readAsDataURL(file);
+                } else if (file.type === 'application/pdf') {
+                    reader.readAsDataURL(file);
+                } else {
+                    // 文本类文件直接读取内容
+                    reader.readAsText(file);
+                }
+            }
+            
+            // 清空 input 以便再次选择
+            event.target.value = '';
+        }
+        
+        function removeFile(fileId) {
+            pendingFiles = pendingFiles.filter(f => f.id !== fileId);
+            const preview = document.getElementById(fileId + '-preview');
+            if (preview) preview.remove();
+        }
+        
+        // 发送消息
+        
         function setupTextarea() {
             const textarea = document.getElementById('messageInput');
             textarea.addEventListener('keydown', e => { if (e.key === 'Enter' && !e.shiftKey) { e.preventDefault(); sendMessage(); } });