fix

virgo.api/src/main/java/com/bosshand/virgo/api/workark/service/DifyService.java

@@ -674,7 +674,7 @@ public class DifyService {
                 @Override
                 public void onNodeFinished(NodeFinishedEvent event) {
                     System.out.println("节点完成: " + event.getData());
-                    SseEmitterUtil.sendMessage(simpleUUID, toJson(event.getData()));
+                    //SseEmitterUtil.sendMessage(simpleUUID, toJson(event.getData()));
                 }
 
                 @Override
@@ -685,7 +685,7 @@ public class DifyService {
                 @Override
                 public void onPing(PingEvent event) {
                     System.out.println("心跳: " + event);
-                    SseEmitterUtil.sendMessage(simpleUUID, event.toString());
+                    //SseEmitterUtil.sendMessage(simpleUUID, event.toString());
                 }
 
             });

virgo.api/src/main/java/com/bosshand/virgo/api/workark/util/SseEmitterUtil.java

@@ -43,9 +43,11 @@ public class SseEmitterUtil {
      * @param sseMessage 消息体
      */
     public static void sendMessage(String simpleUUID, String sseMessage) {
+        String escapedContent = sseMessage.replace("\n", "\\n").replace("#", "\\#");
+
         if (sseEmitterMap.containsKey(simpleUUID)) {
             try {
-                sseEmitterMap.get(simpleUUID).send(sseMessage);
+                sseEmitterMap.get(simpleUUID).send(escapedContent);
                 log.info("用户 {} 推送消息 {}", simpleUUID, sseMessage);
             } catch (IOException e) {
                 log.error("用户 {} 推送消息异常", simpleUUID, e);