chat

src/main/java/com/sxtvs/open/api/chat/service/impl/KimiChatServiceImpl.java

@@ -89,9 +89,10 @@ public class KimiChatServiceImpl extends ServiceImpl<KimiChatMapper, KimiChat> i
                         while ((line = reader.readLine()) != null) {
                             log.info("流数据 -- {} ", line);
                             if (!TextUtils.isEmpty(line)) {
+                                line = line.substring(6);
                                 sseService.sendData( groupId, line );
-                                if (!"data: [DONE]".equals(line) && !line.isEmpty()) {
-                                    stream2db(line.substring(6), groupId);
+                                if (!"[DONE]".equals(line) && !line.isEmpty()) {
+                                    stream2db(line, groupId);
                                 }
                             }
                         }

src/main/java/com/sxtvs/open/api/review/service/impl/SSEService.java

@@ -45,6 +45,7 @@ public class SSEService {
     }
 
     public void monitor(Long groupId, SseEmitter sseEmitter) {
+
         sseDataMap.put(groupId, sseEmitter);
     }