支持多个runid

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/JavaFlowFreeTaskCallbackThread.java

@@ -19,6 +19,7 @@ import com.byit.util.SpringUtil;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.BeanUtils;
 
 import java.io.IOException;
 import java.nio.charset.StandardCharsets;
@@ -101,14 +102,20 @@ public class JavaFlowFreeTaskCallbackThread implements Runnable {
                 } else {
                     String logFormat = String.format(logTemple, flowName, nodeName, jobTaskRunLog.getRunMsg(), thisLogUrlPath);
                     jobTaskRunLog.setRunMsg(logFormat);
-                    JobTaskRunLogWithBLOBs jobTaskRunLogWithBLOBs = buildJobTaskRunLogWithBLOBs(specialJavaNode);
+                    String runId = specialJavaNode.getRunId();
+                    String[] split = runId.split(",");
+                    for (String childRunId : split) {
+                        SpecialJavaNode specialJavaNodeChild = new SpecialJavaNode();
+                        BeanUtils.copyProperties(specialJavaNode, specialJavaNodeChild);
+                        specialJavaNodeChild.setRunId(childRunId);
+                        JobTaskRunLogWithBLOBs jobTaskRunLogWithBLOBs = buildJobTaskRunLogWithBLOBs(specialJavaNodeChild);
                         if (jobTaskRunLogWithBLOBs != null) {
                             mythJobTaskRunLogService.updateJobTaskRunLogWithBLOBs(jobTaskRunLogWithBLOBs);
                         } else {
                             logTemple = "%s\n\n 日志追加失败，失败原因是没有找到正确的节点或者没有正在运行中的实例！";
-                        jobTaskRunLog.setRunMsg(String.format(logTemple, jobTaskRunLog.getRunMsg()));
+                            jobTaskRunLog.setRunMsg(jobTaskRunLog.getRunMsg() + "\n" +String.format(logTemple, jobTaskRunLog.getRunMsg()));
+                        }
                     }
-
                 }
             }
         }