chore：进入客服页面不乱跳了

common/js/ai-service.js

@@ -1,349 +1,489 @@
-import http from './http.js'
+import Config from './config.js'
-import store from '@/store/index.js'
+import http from './http.js'
-
+import store from '@/store/index.js'
-export default {
+let currentConversationId = null;
-  /**
+const CONVERSATION_KEY = 'ai_conversation_id';
-   * 发送消息到Dify API
+
-   * @param {string} message 用户消息内容
+// 初始化时从本地读取
-   * @param {Object} options 配置选项
+try {
-   * @returns {Promise} 
+  const saved = uni.getStorageSync(CONVERSATION_KEY);
-   */
+  if (saved) {
-  async sendMessage(message, options = {}) {
+    currentConversationId = saved;
-    try {
+  }
-      // 获取AI配置
+} catch (e) {
-      const aiConfig = store.getters.globalAIKefuConfig
+  console.warn('读取会话ID失败:', e);
-
+}
-      // const new_conversationId =  await this.generateConversationId()
+export default {
-      
+  /**
-      // 构建Dify API请求参数
+   * 发送消息到Dify API
-      const params = {
+   * @param {string} message 用户消息内容
-        url: '/api/kefu/chat', // 后端代理接口
+   * @param {Object} options 配置选项
-        data: {
+   * @returns {Promise} 
-          message: message,
+   */
-          // conversation_id: options.conversationId ?? new_conversationId,
+  async sendMessage(message, options = {}) {
-          user_id: store.state.memberInfo?.id || 'anonymous',
+    try {
-          stream: options.stream || false, // 是否流式响应
+      const aiConfig = store.getters.globalAIKefuConfig
-          // Dify API参数
+      const params = {
-          inputs: {},
+        url: '/api/kefu/chat',
-          query: message,
+        data: {
-          response_mode: options.stream ? 'streaming' : 'blocking',
+          user_id: store.state.memberInfo?.id || 'anonymous',
-          user: store.state.memberInfo?.id || 'anonymous'
+          stream: false,
-        },
+          inputs: {},
-        header: {
+          query: message,
-          'Content-Type': 'application/json'
+          response_mode: options.stream ? 'streaming' : 'blocking',
-        }
+          user: store.state.memberInfo?.id || 'anonymous',
-      }
+		  conversation_id: this.getConversationId() || '' 
-      
+        },
-      // 发送请求
+        header: {
-      const response = await http.sendRequest({
+          'Content-Type': 'application/json'
-        ...params,
+        }
-        async: false // 使用Promise方式
+      }
-      })
+      console.log('Sending request to:', params.url);
-      
+      console.log('Request data:', params.data);
-      return this.handleResponse(response, options)
+
-      
+      const response = await http.sendRequest({
-    } catch (error) {
+        ...params,
-      console.error('Dify API请求失败:', error)
+        async: false
-      throw new Error('AI服务暂时不可用，请稍后重试')
+      })
-    }
+	  
-  },
+      const result = this.handleResponse(response, options);
-  
+           if (result.conversationId) {
-  /**
+             this.setConversationId(result.conversationId);
-   * 流式消息处理
+           }
-   * @param {string} message 用户消息
+           return result;
-   * @param {Function} onChunk 流式数据回调
+         } catch (error) {
-   * @param {Function} onComplete 完成回调
+           console.error('Dify API请求失败:', error)
-   */
+           throw new Error('AI服务暂时不可用，请稍后重试')
-  async sendStreamMessage(message, onChunk, onComplete) {
+         }
-    try {
+       },
-        // 使用HTTP流式请求
+  
-        return this.sendHttpStream(message, onChunk, onComplete)
+  /**
-      
+   * 流式消息处理
-    } catch (error) {
+   */
-      console.error('流式消息发送失败:', error)
+  async sendStreamMessage(message, onChunk, onComplete) {
-      throw error
+    try {
-    }
+      return this.sendHttpStream(message, onChunk, onComplete)
-  },
+    } catch (error) {
-  
+      console.error('流式消息发送失败:', error)
-  /**
+      throw error
-   * WebSocket连接
+    }
-   */
+  },
-  connectWebSocket(message, onChunk, onComplete) {
+
-    return new Promise((resolve, reject) => {
+  /**
-      const aiConfig = store.getters.globalAIKefuConfig
+   * EventSource 流式聊天
-      const wsUrl = aiConfig.difyWsUrl
+   */
-      
+  chatWithEventSource(message, conversationId = '', onMessage, onComplete, onError) {
-      if (!wsUrl) {
+    if (window.currentEventSource) {
-        reject(new Error('未配置WebSocket地址'))
+      window.currentEventSource.close();
-        return
+    }
-      }
+    const params = new URLSearchParams({
-      
+      uniacid: store.state.uniacid || '1',
-      // #ifdef H5
+      user_id: store.state.memberInfo?.id || '123456',
-      const ws = new WebSocket(wsUrl)
+      query: message,
-      
+      conversation_id: conversationId || '',
-      ws.onopen = () => {
+      stream: 'true'
-        // 发送消息
+    });
-        ws.send(JSON.stringify({
+    const url = `/api/kefu/chat?${params.toString()}`;
-          message: message,
+    try {
-          user_id: store.state.memberInfo?.id || 'anonymous',
+      const eventSource = new EventSource(url);
-          conversation_id: this.generateConversationId()
+      window.currentEventSource = eventSource;
-        }))
+      let aiMessage = '';
-      }
+      eventSource.addEventListener('message', (event) => {
-      
+        try {
-      ws.onmessage = (event) => {
+          const data = JSON.parse(event.data);
-        try {
+          if (data.event === 'message') {
-          const data = JSON.parse(event.data)
+            aiMessage += data.answer || '';
-          if (data.type === 'chunk' && onChunk) {
+            if (onMessage) onMessage(data.answer || '');
-            onChunk(data.content)
+          }
-          } else if (data.type === 'complete' && onComplete) {
+          if (data.event === 'message_end') {
-            onComplete(data.content)
+            if (onComplete) onComplete({ 
-            ws.close()
+              conversation_id: data.conversation_id,
-            resolve(data.content)
+              message: aiMessage 
-          }
+            });
-        } catch (e) {
+          }
-          console.error('WebSocket消息解析失败:', e)
+          if (data.conversation_id) {
-        }
+            conversationId = data.conversation_id;
-      }
+          }
-      
+        } catch (error) {
-      ws.onerror = (error) => {
+          console.error('解析消息失败:', error);
-        console.error('WebSocket连接错误:', error)
+        }
-        reject(error)
+      });
-      }
+      eventSource.addEventListener('done', (event) => {
-      
+        try {
-      ws.onclose = () => {
+          const data = JSON.parse(event.data);
-        console.log('WebSocket连接关闭')
+          if (onComplete) onComplete(data);
-      }
+        } catch (error) {
-      // #endif
+          console.error('解析完成事件失败:', error);
-      
+        }
-      // #ifdef MP-WEIXIN || APP-PLUS
+      });
-      // 小程序和APP使用uni.connectSocket
+      eventSource.addEventListener('close', (event) => {
-      uni.connectSocket({
+        try {
-        url: wsUrl,
+          const data = JSON.parse(event.data);
-        success: () => {
+          console.log('连接正常结束:', data);
-          uni.onSocketOpen(() => {
+        } catch (error) {
-            uni.sendSocketMessage({
+          console.error('解析关闭事件失败:', error);
-              data: JSON.stringify({
+        }
-                message: message,
+        window.currentEventSource = null;
-                user_id: store.state.memberInfo?.id || 'anonymous',
+      });
-                conversation_id: this.generateConversationId()
+      eventSource.addEventListener('error', (error) => {
-              })
+        console.error('EventSource错误:', error);
-            })
+        if (onError) onError({ error: 'EventSource连接错误' });
-          })
+        window.currentEventSource = null;
-          
+      });
-          uni.onSocketMessage((res) => {
+      return eventSource;
-            try {
+    } catch (error) {
-              const data = JSON.parse(res.data)
+      console.error('创建EventSource失败:', error);
-              if (data.type === 'chunk' && onChunk) {
+      if (onError) onError({ error: error.message });
-                onChunk(data.content)
+      return null;
-              } else if (data.type === 'complete' && onComplete) {
+    }
-                onComplete(data.content)
+  },
-                uni.closeSocket()
+
-                resolve(data.content)
+  /**
-              }
+   * Fetch API 流式聊天
-            } catch (e) {
+   */
-              console.error('WebSocket消息解析失败:', e)
+  async chatWithFetchStream(message, conversationId = '', onMessage, onComplete, onError) {
-            }
+    try {
-          })
+      let requestData;
-          
+      let headers = {
-          uni.onSocketError((error) => {
+        'Accept': 'text/event-stream'
-            console.error('WebSocket连接错误:', error)
+      };
-            reject(error)
+      requestData = {
-          })
+        uniacid: store.state.uniacid || '1',
-        },
+        user_id: store.state.memberInfo?.id || '123456',
-        fail: (error) => {
+        query: message,
-          reject(error)
+        conversation_id: conversationId || '',
-        }
+        stream: true,
-      })
+        inputs: {},
-      // #endif
+        response_mode: 'streaming',
-    })
+        user: store.state.memberInfo?.id || '123456'
-  },
+      };
-  
+      headers['Content-Type'] = 'application/json';
-  /**
+      const response = await fetch('/api/kefu/chat', {
-   * HTTP流式请求
+        method: 'POST',
-   */
+        headers: headers,
-  async sendHttpStream(message, onChunk, onComplete) {
+        body: JSON.stringify(requestData)
-    const aiConfig = store.getters.globalAIKefuConfig
+      });
-    
+      if (!response.ok) {
-    const params = {
+        throw new Error(`HTTP error! status: ${response.status}`);
-      url: '/api/kefu/chat-stream',
+      }
-      data: {
+      if (!response.body) {
-        message: message,
+        throw new Error('响应体不可用');
-        conversation_id: this.generateConversationId(),
+      }
-        user_id: store.state.memberInfo?.id || 'anonymous',
+      const reader = response.body.getReader();
-        stream: true
+      const decoder = new TextDecoder('utf-8');
-      },
+      let buffer = '';
-      header: {
+      let aiMessage = '';
-        'Content-Type': 'application/json'
+      while (true) {
-      }
+        const { done, value } = await reader.read();
-    }
+        if (done) break;
-    
+        buffer += decoder.decode(value, { stream: true });
-    if (aiConfig?.difyApiKey) {
+        let lineEnd;
-      params.header['Authorization'] = `Bearer ${aiConfig.difyApiKey}`
+        while ((lineEnd = buffer.indexOf('\n')) !== -1) {
-    }
+          const line = buffer.substring(0, lineEnd);
-    
+          buffer = buffer.substring(lineEnd + 1);
-    // 使用fetch API进行流式请求（H5环境）
+          if (line.startsWith('data: ')) {
-    // #ifdef H5
+            try {
-    try {
+              const data = JSON.parse(line.substring(6));
-      const response = await fetch(`/api/kefu/chat-messages`, {
+              if (data.event === 'message' || data.event === 'text_message') {
-        method: 'POST',
+                const textContent = data.answer || data.text || '';
-        headers: {
+                aiMessage += textContent;
-          'Content-Type': 'application/json',
+                if (onMessage) onMessage(textContent);
-        },
+              } else if (data.event === 'message_end' || data.event === 'done') {
-        body: JSON.stringify({
+                if (onComplete) onComplete({
-          inputs: {},
+                  conversation_id: data.conversation_id,
-          query: message,
+                  message: aiMessage,
-          response_mode: 'streaming',
+                  ...data
-          user: store.state.memberInfo?.id || 'anonymous'
+                });
-        })
+              } else if (data.event === 'error' && onError) {
-      })
+                onError(data);
-      
+              }
-      const reader = response.body.getReader()
+              if (data.conversation_id) {
-      const decoder = new TextDecoder()
+                conversationId = data.conversation_id;
-      let content = ''
+              }
-      
+            } catch (e) {
-      while (true) {
+              console.warn('解析流式数据失败:', e);
-        const { done, value } = await reader.read()
+            }
-        if (done) break
+          }
-        
+        }
-        const chunk = decoder.decode(value)
+      }
-        const lines = chunk.split('\n')
+      if (buffer.startsWith('data: ')) {
-        
+        try {
-        for (const line of lines) {
+          const data = JSON.parse(buffer.substring(6));
-          if (line.startsWith('data: ')) {
+          if ((data.event === 'message' || data.event === 'text_message') && onMessage) {
-            try {
+            const textContent = data.answer || data.text || '';
-              const data = JSON.parse(line.slice(6))
+            onMessage(textContent);
-              if (data.event === 'text_message' && data.text) {
+          } else if ((data.event === 'message_end' || data.event === 'done') && onComplete) {
-                content += data.text
+            onComplete({
-                if (onChunk) onChunk(data.text)
+              conversation_id: data.conversation_id,
-              }
+              message: aiMessage,
-            } catch (e) {
+              ...data
-              // 忽略解析错误
+            });
-            }
+          }
-          }
+        } catch (e) {
-        }
+          console.warn('解析剩余数据失败:', e);
-      }
+        }
-      
+      }
-      if (onComplete) onComplete(content)
+    } catch (error) {
-      return content
+      console.error('Fetch流式聊天请求失败:', error);
-      
+      if (onError) onError({ error: error.message });
-    } catch (error) {
+    }
-      console.error('HTTP流式请求失败:', error)
+  },
-      throw error
+    
-    }
+  /**
-    // #endif
+   * HTTP流式请求（修复conversationId未定义）
-    
+   */
-    // 非H5环境使用普通请求模拟流式效果
+  async sendHttpStream(message, onChunk, onComplete) {    
-    // #ifndef H5
+    const params = {
-    const response = await http.sendRequest({
+      url: '/api/kefu/chat',
-      ...params,
+      data: {
-      async: false
+        query: message,
-    })
+        conversation_id: '',
-    
+        user_id: store.state.memberInfo?.id || 'anonymous',
-    // 模拟流式效果
+        stream: true,
-    if (response.success && response.data) {
+        uniacid: store.state.uniacid,
-      const content = response.data
+        inputs: {},
-      const chunkSize = 3
+        response_mode: 'streaming',
-      let index = 0
+        user: store.state.memberInfo?.id || 'anonymous'
-      
+      },
-      const streamInterval = setInterval(() => {
+      header: {
-        if (index < content.length) {
+        'Content-Type': 'application/json'
-          const chunk = content.substring(index, index + chunkSize)
+      }
-          index += chunkSize
+    }
-          if (onChunk) onChunk(chunk)
+    // #ifdef H5
-        } else {
+    try {
-          clearInterval(streamInterval)
+      const url = Config.baseUrl + `/api/kefu/chat`;
-          if (onComplete) onComplete(content)
+      const response = await fetch(url, {
-        }
+        method: 'POST',
-      }, 100)
+        headers: {
-    }
+          'Content-Type': 'application/json',
-    // #endif
+          'Accept': 'text/event-stream',
-  },
+        },
-  
+        body: JSON.stringify({
-  /**
+          uniacid: store.state.uniacid || '1',
-   * 处理API响应
+          inputs: {},
-   */
+          query: message,
-  handleResponse(response, options) {
+          response_mode: 'streaming',
-    if (response.code === 0 || response.success) {
+          user_id: store.state.memberInfo?.id || 'anonymous'
-      return {
+        })
-        success: true,
+      })
-        content: response.data?.answer || response.data?.content || response.data?.reply|| response.data,
+      const reader = response.body.getReader()
-        conversationId: response.data?.conversation_id,
+      const decoder = new TextDecoder()
-        messageId: response.data?.message_id
+      let content = ''
-      }
+      let buffer = ''
-    } else {
+      // 修复：声明conversationId变量
-      throw new Error(response.message || 'AI服务返回错误')
+      let conversationId = ''; 
-    }
+      
-  },
+      function processStreamData(buffer, callback) {
-  
+        const lines = buffer.split('\n');
-  /**
+        buffer = lines.pop() || '';
-   * 生成会话ID
+        lines.forEach(line => {
-   */
+          line = line.trim();
-  async generateConversationId() {
+          if (!line) return;
-          // 构建Dify API请求参数
+          if (line.startsWith('data:')) {
-      const params = {
+            const dataPart = line.slice(5).trim();
-        url: '/api/kefu/createConversation', // 后端代理接口
+            if (dataPart) {
-        data: {
+              try {
-          uniacid: store.state.uniacid,
+                const data = JSON.parse(dataPart);
-          user_id: store.state.memberInfo?.id || 'anonymous',
+                if (data.event === 'message') {
-          member_id: store.state.memberInfo?.id || '',
+                  callback(data.answer || '');
-        },
+                }
-        header: {
+                if (data.conversation_id) {
-          'Content-Type': 'application/json'
+                  conversationId = data.conversation_id;
-        }
+                }
-      }
+                if (data.event === 'message_end') {
-      
+                  console.log('对话完成');
-      // 发送请求
+                }
-      const response = await http.sendRequest({
+              } catch (error) {
-        ...params,
+                console.error('解析流式数据失败:', error);
-        async: false // 使用Promise方式
+              }
-      })
+            }
-      
+          }
-      return this.handleResponse(response, options)
+        });
-  },
+        return buffer;
-  
+      }
-  /**
+      
-   * 获取AI服务状态
+      while (true) {
-   */
+        const { done, value } = await reader.read()
-  async getServiceStatus() {
+        if (done) break
-    try {
+        buffer += decoder.decode(value, { stream: true });
-      // 简单的健康检查
+        buffer = processStreamData(buffer, (newData) => {
-      const response = await http.sendRequest({
+          if (newData) {
-        url: '/api/kefu/health',
+            content += newData;
-        async: false,
+            if (onChunk) onChunk(newData);
-        data: {}
+          }
-      })
+        });
-
+      }
-      const available = [response?.data?.status, response?.data?.components?.ai_service_config?.status].filter(item => item === 'healthy').length > 0;
+	  
-      
+       if (onComplete) onComplete({ content, conversation_id: conversationId });
-      return {
+        return { content, conversation_id: conversationId };
-        available,
+    } catch (error) {
-        reason: available ? '服务正常' : '服务异常'
+      console.error('HTTP流式请求失败:', error)
-      }
+      throw error
-      
+    }
-    } catch (error) {
+    // #endif
-      return {
+    // #ifndef H5
-        available: false,
+    const response = await http.sendRequest({
-        reason: '服务检查失败'
+      ...params,
-      }
+      async: false
-    }
+    })
-  },
+    if (response.success && response.data) {
-  
+      const content = response.data
-  /**
+      const chunkSize = 3
-   * 清除会话历史
+      let index = 0
-   */
+      const streamInterval = setInterval(() => {
-  async clearConversation(conversationId) {
+        if (index < content.length) {
-    try {
+          const chunk = content.substring(index, index + chunkSize)
-      const response = await http.sendRequest({
+          index += chunkSize
-        url: '/api/kefu/clear-conversation',
+          if (onChunk) onChunk(chunk)
-        data: { conversation_id: conversationId },
+        } else {
-        async: false
+          clearInterval(streamInterval)
-      })
+          if (onComplete) onComplete(content)
-      
+        }
-      return response.success
+      }, 100)
-      
+    }
-    } catch (error) {
+    // #endif
-      console.error('清除会话失败:', error)
+  },
-      return false
+  
-    }
+  /**
-  }
+   * 处理API响应
+   */
+  handleResponse(response, options) {
+    if (response.code === 0 || response.success) {
+      return {
+        success: true,
+        content: response.data?.answer || response.data?.content || response.data?.reply|| response.data,
+        conversationId: response.data?.conversation_id,
+        messageId: response.data?.message_id
+      }
+    } else {
+      throw new Error(response.message || 'AI服务返回错误')
+    }
+  },
+  
+  /**
+   * 生成会话ID
+   */
+  async generateConversationId() {
+    const params = {
+      url: '/api/kefu/createConversation',
+      data: {
+        uniacid: store.state.uniacid,
+        user_id: store.state.memberInfo?.id || 'anonymous',
+        member_id: store.state.memberInfo?.id || '',
+      },
+      header: {
+        'Content-Type': 'application/json'
+      }
+    }
+    const response = await http.sendRequest({
+      ...params,
+      async: false
+    })
+    return this.handleResponse(response)
+  },
+  
+  /**
+   * 获取AI服务状态
+   */
+  async getServiceStatus() {
+    try {
+      const response = await http.sendRequest({
+        url: '/api/kefu/health',
+        async: false,
+        data: {}
+      })
+      const available = [response?.data?.status, response?.data?.components?.ai_service_config?.status].filter(item => item === 'healthy').length > 0;
+      return {
+        available,
+        reason: available ? '服务正常' : '服务异常'
+      }
+    } catch (error) {
+      return {
+        available: false,
+        reason: '服务检查失败'
+      }
+    }
+  },
+  
+  /**
+   * 清除会话历史
+   */
+  async clearConversation(conversationId) {
+    try {
+      const response = await http.sendRequest({
+        url: '/api/kefu/clear-conversation',
+        data: { conversation_id: conversationId },
+        async: false
+      })
+      return response.success
+    } catch (error) {
+      console.error('清除会话失败:', error)
+      return false
+    }
+  },
+  getConversationId() {
+      return currentConversationId;
+    },
+  
+    setConversationId(id) {
+      if (id && id !== currentConversationId) {
+        currentConversationId = id;
+        try {
+          uni.setStorageSync(CONVERSATION_KEY, id);
+        } catch (e) {
+          console.error('保存会话ID失败:', e);
+        }
+      }
+    },
+  
+    clearConversationId() {
+      currentConversationId = null;
+      try {
+        uni.removeStorageSync(CONVERSATION_KEY);
+      } catch (e) {
+        console.error('清除会话ID失败:', e);
+      }
+    },
+
+  /**
+   * 获取会话历史
+   */
+  async getConversationHistory(params = {}) {
+    try {
+      if (!params.conversation_id) {
+        throw new Error('会话ID（conversation_id）是必填参数');
+      }
+      const requestData = {
+        uniacid: params.uniacid || store.state.uniacid || '1',
+        conversation_id: params.conversation_id,
+        user_id: params.user_id || store.state.memberInfo?.id || 'anonymous',
+        limit: params.limit || 20,
+        offset: params.offset || 0,
+        member_id: params.member_id || store.state.memberInfo?.id || '',
+        token: params.token || ''
+      };
+      const response = await http.sendRequest({
+        url: '/api/kefu/getHistory',
+        data: requestData,
+        header: {
+          'Content-Type': 'application/json'
+        },
+        async: false
+      });
+      if (response.code === 0 || response.success) {
+        return {
+          success: true,
+          data: response.data,
+          messages: response.data?.messages || [],
+          total: response.data?.total || 0,
+          page_info: response.data?.page_info || { limit: 20, offset: 0 }
+        };
+      } else {
+        throw new Error(response.message || '获取会话历史失败');
+      }
+    } catch (error) {
+      console.error('获取会话历史失败:', error);
+      throw new Error(error.message || '获取会话历史时发生错误，请稍后重试');
+    }
+  }
 }

components/ai-chat-message/ai-chat-message.vue

@@ -5,8 +5,8 @@
       class="chat-messages" 
       scroll-y 
       :scroll-top="scrollTop"
-      @scrolltoupper="loadMoreHistory"
+       @scroll="onScroll"
-      :scroll-with-animation="true">
+      :scroll-with-animation="false">
       
       <!-- 加载更多历史消息 -->
       <view class="load-more" v-if="hasMoreHistory">
@@ -16,7 +16,7 @@
       <!-- 消息列表 -->
       <view 
         v-for="(message, index) in messages" 
-        :key="message.id" 
+        :key="`msg-${message.id || message.timestamp}-${index}`"  
         class="message-item"
         :class="[message.role, { 'first-message': index === 0 }]">
         
@@ -32,8 +32,7 @@
             <view class="message-bubble">
               <text class="message-text">{{ message.content }}</text>
             </view>
-            <view class="message-time">{{ formatTime(message.timestamp) }}</view>
+                      </view>
-          </view>
         </view>
         
         <!-- AI消息 -->
@@ -174,7 +173,7 @@
                 </button>
               </view>
             </view>
-            <view class="message-time">{{ formatTime(message.timestamp) }}</view>
+            
           </view>
         </view>
       </view>
@@ -395,7 +394,7 @@ export default {
     // 是否启用流式响应
     enableStreaming: {
       type: Boolean,
-      default: false
+      default: true
     },
     // 流式响应速度（字符/秒）
     streamSpeed: {
@@ -403,7 +402,7 @@ export default {
       default: 20
     }
   },
-  data() {
+  data(){
     return {
       messages: [],
       inputText: '',
@@ -436,9 +435,35 @@ export default {
       // Dify API相关
       currentConversationId: null,
       isAIServiceAvailable: true,
-      aiServiceError: null
+      aiServiceError: null,
+	  isLoadingHistory: false, // 新增：标记历史加载状态
+      shouldScrollToBottom: false,
+	   scrollTimer: null,
+	  lastScrollTop: 0,
+	  historyOffset: 0,
+	   isFetchingHistory: false
     }
   },
+  onShow() {
+           // 优先读取本地缓存的会话 ID
+           const localConvId = this.getConversationIdFromLocal();
+           if (localConvId) {
+             this.currentConversationId = localConvId;
+             aiService.setConversationId(localConvId);
+           } else {
+             this.currentConversationId = aiService.getConversationId();
+           }
+           // 加载初始历史后，同步historyOffset
+               this.loadChatHistoryIfExist().then(() => {
+                 // 初始历史条数作为偏移量
+                 this.historyOffset = this.messages.length;
+               });
+               // 移除：this.historyOffset = 0;（避免覆盖初始历史的偏移量）
+             },
+             // 新增：组件销毁时清除防抖定时器
+             beforeDestroy() {
+               if (this.scrollTimer) clearTimeout(this.scrollTimer);
+             },
   created() {
     this.messages = [...this.initialMessages]
     this.messageId = this.messages.length
@@ -447,21 +472,42 @@ export default {
     this.initUserAvatarData()
     // 初始化用户昵称（缓存优先）
     this.initUserNicknameData()
+	this.currentConversationId = aiService.getConversationId();
   },
-  mounted() {
+   mounted() {
-    this.scrollToBottom()
+      // 初始加载时滚底（仅一次）
-  },
+      this.$nextTick(() => {
+        this.scrollToBottom()
+      })
+    },
   watch: {
-    messages: {
+      messages: {
-      handler() {
+        handler() {
-        this.$nextTick(() => {
+          this.$nextTick(() => {
-          this.scrollToBottom()
+            // 仅当不是加载历史、且需要滚底时，才执行滚底
-        })
+            if (!this.isLoadingHistory && this.shouldScrollToBottom) {
-      },
+              this.scrollToBottom()
+              // 滚底后重置状态，避免重复触发
+              this.shouldScrollToBottom = false
+            }
+          })
+        },
       deep: true
     }
   },
   methods: {
+	  // 【新增：会话 ID 本地缓存方法】
+	   saveConversationIdToLocal(convId) {
+	      if (convId) {
+	        uni.setStorageSync('dify_conversation_id', convId);
+	      }
+	    },
+	    getConversationIdFromLocal() {
+	      return uni.getStorageSync('dify_conversation_id') || null;
+	    },
+	    clearConversationIdFromLocal() {
+	      uni.removeStorageSync('dify_conversation_id');
+	    },
     // 初始化音频上下文
     initAudioContext() {
       // #ifdef H5
@@ -470,7 +516,18 @@ export default {
       }
       // #endif
     },
-    
+        onScroll(e) {
+          const currentScrollTop = e.detail.scrollTop;
+          this.lastScrollTop = currentScrollTop;
+          // 防抖处理：50ms内只执行一次，避免频繁触发
+          if (this.scrollTimer) clearTimeout(this.scrollTimer);
+          this.scrollTimer = setTimeout(() => {
+            // 滚动到顶部附近（<20px）、不在加载中、显示加载更多时，触发加载
+            if (currentScrollTop < 20 && !this.isLoadingHistory && this.showLoadMore) {
+              this.loadMoreHistory();
+            }
+          }, 50);
+        },
     // 初始化用户头像（支持缓存持久化）
     initUserAvatarData() {
       // 1. 优先读取本地缓存的头像
@@ -490,7 +547,43 @@ export default {
         this.localUserAvatar = this.defaultAvatar
       }
     },
-    
+    // 👇 新增：加载历史记录
+   async loadChatHistoryIfExist() {
+     const convId = aiService.getConversationId();
+     if (convId) {
+       try {
+         const history = await aiService.getChatHistory();
+         if (!history || !Array.isArray(history.messages)) {
+           console.warn('历史记录为空或格式无效');
+           return;
+         }
+   
+         this.messages = history.messages.map(msg => {
+           let content = '';
+           if (msg.role === 'user') {
+             content = msg.query || (typeof msg.inputs === 'string' ? msg.inputs : JSON.stringify(msg.inputs || '')) || '';
+           } else {
+             content = msg.answer || '';
+           }
+           return {
+             id: msg.message_id || (Date.now() + Math.random() * 10000),
+             role: msg.role === 'user' ? 'user' : 'assistant',
+             content: content,
+             timestamp: msg.created_at,
+             actions: msg.role !== 'user' ? [
+               { id: 1, text: '有帮助', type: 'like' },
+               { id: 2, text: '没帮助', type: 'dislike' }
+             ] : []
+           };
+         });
+       } catch (error) {
+         console.error('加载历史记录失败:', error);
+         aiService.clearConversationId();
+         this.clearConversationIdFromLocal();
+         this.currentConversationId = null;
+       }
+     }
+   },
     // 新增：初始化用户昵称（支持缓存持久化）
     initUserNicknameData() {
       // 1. 优先读取本地缓存的昵称
@@ -628,7 +721,7 @@ export default {
         content: this.inputText.trim(),
         timestamp: Date.now()
       }
-      
+       this.shouldScrollToBottom = true
       this.messages.push(userMessage)
       this.inputText = ''
       
@@ -640,7 +733,7 @@ export default {
         content: '',
         timestamp: Date.now()
       }
-      
+      this.shouldScrollToBottom = true
       this.messages.push(loadingMessage)
       
       try {
@@ -676,7 +769,7 @@ export default {
             { id: 1, text: '重试', type: 'retry' }
           ]
         }
-        
+        this.shouldScrollToBottom = true
         this.messages.push(errorMessage)
         this.$emit('ai-response', errorMessage)
       }
@@ -697,7 +790,9 @@ export default {
       
       // 更新会话ID
       if (response.conversationId) {
-        this.currentConversationId = response.conversationId
+        this.currentConversationId = response.conversationId;
+		aiService.setConversationId(response.conversationId);
+		  this.saveConversationIdToLocal(response.conversationId);
       }
       
       const aiMessage = {
@@ -713,7 +808,7 @@ export default {
           { id: 2, text: '没帮助', type: 'dislike' }
         ]
       }
-      
+      this.shouldScrollToBottom = true
       this.messages.push(aiMessage)
       this.$emit('ai-response', aiMessage)
     },
@@ -732,34 +827,52 @@ export default {
       
       // 移除加载状态，添加流式消息
       this.messages = this.messages.filter(msg => msg.type !== 'loading')
+	  this.shouldScrollToBottom = true
       this.messages.push(streamMessage)
       
-      // 开始流式响应
+     // 开始流式响应
-      await aiService.sendStreamMessage(
+     await aiService.sendStreamMessage(
-        userMessage,
+       userMessage,
-        // 流式数据回调
+       // 流式数据回调
-        (chunk) => {
+       (chunk) => {
-          streamMessage.content += chunk
+         streamMessage.content += chunk
-          // 触发内容更新
+         this.$forceUpdate() // 或 this.$nextTick()
-          this.$forceUpdate()
+       },
-        },
+       // 完成回调：处理对象或字符串
-        // 完成回调
+       (completeResult) => {
-        (completeContent) => {
+         let finalContent = '';
-          streamMessage.isStreaming = false
+         let convId = '';
-          streamMessage.content = completeContent
+     
-          
+         // 判断是对象还是字符串
-          // 添加操作按钮
+         if (typeof completeResult === 'string') {
-          streamMessage.actions = [
+           finalContent = completeResult;
-            { id: 1, text: '有帮助', type: 'like' },
+         } else {
-            { id: 2, text: '没帮助', type: 'dislike' }
+           finalContent = completeResult.content || '';
-          ]
+           convId = completeResult.conversation_id || ''; // 👈 关键：提取 conversation_id
-          
+         }
-          this.$emit('ai-response', streamMessage)
+     
-        }
+         // 更新消息状态
-      )
+         streamMessage.isStreaming = false;
-    },
+         streamMessage.content = finalContent;
-    
+     
-    // 生成AI回复（模拟）
+         // 添加操作按钮
+         streamMessage.actions = [
+           { id: 1, text: '有帮助', type: 'like' },
+           { id: 2, text: '没帮助', type: 'dislike' }
+         ];
+     
+         //  保存 conversation_id 到本地
+         if (convId) {
+           aiService.setConversationId(convId);
+         }
+     
+         // 触发事件
+         this.$emit('ai-response', streamMessage);
+		 this.saveConversationIdToLocal(convId);
+		 this.currentConversationId = convId;
+       }
+     );
+	 },
     generateAIResponse(userMessage) {
       const responses = {
         '你好': '您好！我是AI智能客服，很高兴为您服务！有什么可以帮助您的吗？',
@@ -767,16 +880,15 @@ export default {
         '发货': '一般情况下，订单会在24小时内发货，具体时效请查看物流信息。',
         '退货': '支持7天无理由退货，请确保商品完好无损。',
         '客服': '我们的客服工作时间是9:00-18:00，有问题可以随时联系我们。'
-      }
+      };
-      
       for (let key in responses) {
         if (userMessage.includes(key)) {
-          return responses[key]
+          return responses[key];
         }
       }
-      
+      return `感谢您的咨询！关于"${userMessage}"的问题，我们的专业客服会尽快为您解答。您也可以查看我们的帮助文档获取更多信息。`;
-      return `感谢您的咨询！关于"${userMessage}"的问题，我们的专业客服会尽快为您解答。您也可以查看我们的帮助文档获取更多信息。`
     },
+  
     
     // 解析Markdown
     parseMarkdown(content) {
@@ -837,37 +949,76 @@ export default {
     },
     
     // 加载更多历史消息
-    loadMoreHistory() {
+ async loadMoreHistory() {
-      if (!this.showLoadMore) return
+       if (!this.currentConversationId) {
-      
+         this.currentConversationId = this.getConversationIdFromLocal();
-      this.hasMoreHistory = true
+         aiService.setConversationId(this.currentConversationId);
-      this.loadingText = '加载历史消息中...'
+       }
-      
+       // 防止重复加载
-      // 模拟加载历史消息
+       if (!this.showLoadMore || !this.currentConversationId || this.isLoadingHistory) {
-      setTimeout(() => {
+         return;
-        const historyMessages = [
+       }
-          {
+       this.isFetchingHistory = true;
-            id: --this.messageId,
+       this.isLoadingHistory = true;
-            role: 'ai',
+       this.loadingText = '加载历史消息中...';
-            type: 'text',
+       this.hasMoreHistory = true;
-            content: '这是历史消息1',
+ 
-            timestamp: Date.now() - 86400000
+       try {
-          },
+         // 关键修改：用独立的historyOffset作为偏移量，不再依赖messages.length
-          {
+         const response = await aiService.getConversationHistory({
-            id: --this.messageId,
+           conversation_id: this.currentConversationId,
-            role: 'user',
+           limit: 20,
-            type: 'text',
+           offset: this.historyOffset // 改用独立偏移量
-            content: '这是历史消息2',
+         });
-            timestamp: Date.now() - 86400000
+ 
-          }
+         if (response.success && Array.isArray(response.messages) && response.messages.length > 0) {
-        ]
+           const historyMessages = response.messages.map(msg => ({
-        
+             id: msg.id || `history-${Date.now()}-${Math.random().toString(36).slice(2)}`,
-        this.messages = [...historyMessages, ...this.messages]
+             role: msg.role === 'user' ? 'user' : 'ai',
-        this.hasMoreHistory = false
+             type: 'text',
-        this.$emit('history-loaded', historyMessages)
+             content: msg.content,
-      }, 1000)
+             timestamp: msg.create_time * 1000
-    },
+           }));
-    
+ 
+           // 1. 记录新增消息数量
+           const newMsgCount = historyMessages.length;
+           // 2. 添加到消息列表开头
+           this.messages = [...historyMessages, ...this.messages];
+           // 3. 更新历史偏移量（累加，不是覆盖）
+           this.historyOffset += newMsgCount;
+ 
+           // 4. 等待DOM渲染后，精准计算滚动位置
+           await this.$nextTick();
+           // 获取新增消息的实际DOM高度
+           const query = uni.createSelectorQuery().in(this);
+           const heightPromises = [];
+           for (let i = 0; i < newMsgCount; i++) {
+             heightPromises.push(new Promise(resolve => {
+               query.select(`.message-item:nth-child(${i + 1})`).boundingClientRect(rect => {
+                 resolve(rect ? rect.height + 32 : 0); // 加上消息间距（32rpx）
+               }).exec();
+             }));
+           }
+           // 计算总高度
+           const heights = await Promise.all(heightPromises);
+           const totalNewHeight = heights.reduce((sum, h) => sum + h, 0);
+           // 5. 设置scrollTop，保持滚动条在顶部附近
+           this.scrollTop = totalNewHeight;
+         } else {
+           // 无更多历史
+           this.showLoadMore = false;
+         }
+       } catch (error) {
+         console.error('加载历史失败:', error);
+         uni.showToast({ title: '加载历史失败', icon: 'none' });
+         this.showLoadMore = false;
+       } finally {
+         this.isLoadingHistory = false;
+		  this.isFetchingHistory = false;
+         this.hasMoreHistory = false;
+         this.loadingText = '加载更多历史消息';
+       }
+     },
     // 显示更多工具
     showMoreTools() {
       this.showToolsPanel = true