push

yd-ai-api/src/main/java/com/yd/ai/api/service/impl/ApiAiStreamServiceImpl.java

@@ -40,7 +40,7 @@ public class ApiAiStreamServiceImpl implements ApiAiStreamService {
      */
      */
     @Override
     @Override
     public Flux<ServerSentEvent<String>> streamChat(String question) {
     public Flux<ServerSentEvent<String>> streamChat(String question) {
-        // 敏感词校验
+        // 敏感词校验（此部分代码保持不变）
         try {
         try {
             apiSensitiveWordDetailService.checkWord(question);
             apiSensitiveWordDetailService.checkWord(question);
         } catch (BusinessException e) {
         } catch (BusinessException e) {
@@ -111,8 +111,10 @@ public class ApiAiStreamServiceImpl implements ApiAiStreamService {
                 })
                 })
                 .map(result -> {
                 .map(result -> {
                     String delta = result.getOutput().getChoices().get(0).getMessage().getContent();
                     String delta = result.getOutput().getChoices().get(0).getMessage().getContent();
-                    // 注意：不要对 delta 做额外处理，保持原样以保留 Markdown 格式
-                    return ServerSentEvent.builder(delta).build();
+                    // ===== 核心修复：在 delta 后追加换行符 =====
+                    // 为了确保 Markdown 格式（特别是表格）不被破坏，我们强制在 delta 后追加一个换行符。
+                    // 这确保了流式片段在拼接后，能够保留正确的换行结构。
+                    return ServerSentEvent.builder(delta + "\n").build();
                 })
                 })
                 .onErrorResume(e -> {
                 .onErrorResume(e -> {
                     log.error("流式响应处理出错: {}", e.getMessage());
                     log.error("流式响应处理出错: {}", e.getMessage());