chat

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

@@ -54,8 +54,8 @@ public class KimiChatServiceImpl extends ServiceImpl<KimiChatMapper, KimiChat> i
 
     private final String token = "sk-eKQV5KAqkQHINWZV9IBbsuefO21A6oTToY9pv9nyDeXPH0zu";
 
-    @Resource
-    private SSEService sseService;
+/*    @Resource
+    private SSEService sseService;*/
 
     private HttpHeaders getHeader(){
         HttpHeaders headers = new HttpHeaders();
@@ -91,7 +91,7 @@ public class KimiChatServiceImpl extends ServiceImpl<KimiChatMapper, KimiChat> i
                         while ((line = reader.readLine()) != null) {
                             log.info("流数据 -- {} ", line);
                             if (!TextUtils.isEmpty(line)) {
-                                sseService.sendData( dataId, line );
+//                                sseService.sendData( dataId, line );
                                 if (!"data: [DONE]".equals(line) && !line.isEmpty()) {
                                     stream2db(line.substring(6), dataId);
                                 }