修改配置

src/main/java/com/infoepoch/pms/dispatchassistant/controller/langchain/LangChainController.java

@@ -360,7 +360,7 @@ public class LangChainController {
                                     emitter.send(SseEmitter.event().data("stop"),MediaType.parseMediaType("application/json; charset=UTF-8"));
                                 }else
                                 {
-                                    String sendData=data.replace("attachment#[]#attachmentsource#[]#source","").replace("<br />", "\n").replaceAll("###(?=\\S)", "### ").replaceAll("##(?=\\S)", "## ")
+                                    String sendData=data.replace("attachment# []# attachmentsource# []# source","").replace("<br />", "\n").replaceAll("###(?=\\S)", "### ").replaceAll("##(?=\\S)", "## ")
                                             .replaceAll("#(?=\\S)", "# ").replaceAll("####(?=\\S)", "#### ").
                                                     replaceAll("#####(?=\\S)", "##### ").replaceAll("######(?=\\S)", "###### ");
                                     emitter.send(SseEmitter.event().data(sendData), MediaType.parseMediaType("application/json; charset=UTF-8"));
@@ -370,16 +370,18 @@ public class LangChainController {
                         }
                     }
                 }
-                messagesContent.setContent(content.toString());
-                chatService.updateMessage(messagesContent);
                 emitter.complete(); // 流结束
             } catch (Exception e) {
                 emitter.completeWithError(e);
                 logger.info(e.getMessage());
             } finally {
+                messagesContent.setContent(content.toString());
+                chatService.updateMessage(messagesContent);
                 if (connection != null) {
                     connection.disconnect();
+                    logger.info("关闭成功1");
                 }
+                logger.info("关闭成功2");
             }
         }).start();