diff --git a/public/images/case-logo.png b/public/images/case-logo.png new file mode 100644 index 00000000..00c7cf41 Binary files /dev/null and b/public/images/case-logo.png differ diff --git a/src/api/boe/aiChat.js b/src/api/boe/aiChat.js new file mode 100644 index 00000000..fc2282ca --- /dev/null +++ b/src/api/boe/aiChat.js @@ -0,0 +1,30 @@ +import ajax from '@/utils/xajax.js' + +/** + * AI聊天对话接口 + * @param {Object} data - 请求参数 + * @param {string} data.conversationId - 会话ID，如果为空则创建新会话 + * @param {string} data.query - 用户提问内容 + * @returns {Promise} - 返回SSE流 + */ +export function aiChat(data) { + return ajax.postJson('http://192.168.3.178/xboe/m/boe/case/ai/chat', data) +} + +/** + * 查询会话消息记录接口 + * @param {string} conversationId - 会话ID + * @returns {Promise} - 返回会话历史记录 + */ +export function getChatMessages(conversationId) { + return ajax.get('/xboe/m/boe/case/ai/messages?conversationId=' + conversationId) +} + +/** + * 案例专家功能入口显示权限判断接口 + * 判断当前登录用户是否显示"案例专家"功能入口 + * @returns {Promise} - 返回是否显示功能入口的布尔值 + */ +export function showCaseAiEntrance() { + return ajax.get('/xboe/m/boe/case/ai/show-entrance') +} diff --git a/src/utils/sseHelper.js b/src/utils/sseHelper.js new file mode 100644 index 00000000..d85bb77d --- /dev/null +++ b/src/utils/sseHelper.js @@ -0,0 +1,83 @@ +/** + * SSE流式数据处理工具 + */ + +/** + * 处理SSE响应数据 + * @param {String} data - SSE响应数据 + * @param {Function} onMessage - 处理消息的回调函数 + * @param {Function} onComplete - 完成时的回调函数 + * @param {Function} onError - 错误处理回调函数 + */ +export function processSSEData(data, onMessage, onComplete, onError) { + try { + const lines = data.split('\n') + for (const line of lines) { + if (line.startsWith('data: ')) { + const jsonData = JSON.parse(line.substring(6)) + onMessage(jsonData) + + // 如果状态为4，表示对话结束 + if (jsonData.data && jsonData.data.status === 4) { + onComplete() + } + } + } + } catch (error) { + console.error('处理SSE数据时出错:', error) + if (onError) { + onError(error) + } + } +} + +/** + * 创建SSE连接 + * @param {String} url - 请求地址 + * @param {Object} data - 请求数据 + * @param {Function} onMessage - 消息处理回调 + * @param {Function} onComplete - 完成回调 + * @param {Function} onError - 错误回调 + * @returns {Promise} - 返回fetch Promise + */ +export function createSSEConnection(url, data, onMessage, onComplete, onError) { + return fetch(url, { + method: 'POST', + headers: { + 'Content-Type': 'application/json' + }, + body: JSON.stringify(data) + }).then(response => { + if (!response.ok) { + throw new Error(`HTTP error! status: ${response.status}`) + } + + const reader = response.body.getReader() + const decoder = new TextDecoder('utf-8') + let buffer = '' + + function read() { + reader.read().then(({ done, value }) => { + if (done) { + if (onComplete) onComplete() + return + } + + buffer += decoder.decode(value, { stream: true }) + processSSEData(buffer, onMessage, onComplete, onError) + + // 继续读取 + read() + }).catch(error => { + console.error('SSE读取错误:', error) + if (onError) onError(error) + }) + } + + // 开始读取数据 + read() + }).catch(error => { + console.error('SSE连接错误:', error) + if (onError) onError(error) + }) +} \ No newline at end of file diff --git a/src/views/portal/case/AICall.vue b/src/views/portal/case/AICall.vue new file mode 100644 index 00000000..b67a92b7 --- /dev/null +++ b/src/views/portal/case/AICall.vue @@ -0,0 +1,313 @@ + + + + + diff --git a/src/views/portal/case/Index.vue b/src/views/portal/case/Index.vue index 14767417..b31e930e 100644 --- a/src/views/portal/case/Index.vue +++ b/src/views/portal/case/Index.vue @@ -1,11 +1,12 @@