chat

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

@@ -74,9 +74,9 @@ public class KimiChatServiceImpl extends ServiceImpl<KimiChatMapper, KimiChat> i
         client.sendAsync(request, HttpResponse.BodyHandlers.ofString())
                 .thenApply(HttpResponse::body)
                 .thenAccept(x -> {
+                    log.info("流数据 -- ",x);
                     sseService.sendData( dataId, x );
                     stream2db(x.substring(6), dataId);
-                    log.info("流数据 -- ",x);
                 })
                 .join();