push

src/views/ai/index.vue

@@ -323,26 +323,40 @@ export default {
           const lines = buffer.split('\n')
           buffer = lines.pop() || ''
 
+          // 在 sendMessage 中，解析 SSE 时增加对 event 的处理
+          let currentEvent = null;
           for (let line of lines) {
-            line = line.trim()
-            if (line === '') continue
+            line = line.trim();
+            if (line === '') continue;
 
-            let content = ''
+            if (line.startsWith('event:')) {
+              currentEvent = line.slice(6).trim();
+              continue;
+            }
+
+            let content = '';
             if (line.startsWith('data:')) {
-              content = line.slice(5).trim()
-              if (content === '[DONE]') continue
+              content = line.slice(5).trim();
+              if (content === '[DONE]') continue;
             } else if (line.startsWith('message:')) {
-              content = line.slice(8).trim()
-            } else if (line.startsWith('event:')) {
-              continue
+              content = line.slice(8).trim();
             } else {
-              content = line
+              content = line;
             }
 
             if (content) {
-              accumulatedContent += content
-              this.messages[assistantMessageIndex].content = accumulatedContent
-              this.scrollToBottom()
+              if (currentEvent === 'sensitive_notification') {
+                // 收到通知敏感词事件，移除刚添加的空消息，展示产品列表
+                this.messages.pop();
+                await this.fetchAndShowProducts(userQuestion);
+                currentEvent = null;
+                // 结束流式处理，不再继续
+                return;
+              } else {
+                accumulatedContent += content;
+                this.messages[assistantMessageIndex].content = accumulatedContent;
+                this.scrollToBottom();
+              }
             }
           }
         }