使用工作流名称开启工作流

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

@@ -88,12 +88,12 @@ public class JavaFlowFreeTaskCallbackThread implements Runnable {
 
                 String logTemple = "该节点为工作流 【%s】 下的游离节点【%s】，属于二次运行：\n 本次调度信息:%s;\n 上次运行信息日志存放路径为：【%s】";
                 if(StringUtils.isBlank(flowName) || StringUtils.isBlank(nodeName) || StringUtils.isBlank(thisLogUrlPath)){
-                    logTemple = "该节点为工作流 【%s】 下的游离节点【%s】，属于二次运行：\n 本次调度信息:%s;\n 上次运行信息日志存放路径为：【%s】 " +
+                    String errorLogTemple = "该节点为工作流 【%s】 下的游离节点【%s】，属于二次运行：\n 本次调度信息:%s;\n 上次运行信息日志存放路径为：【%s】 " +
                             "\n\n 但是日志回写过程中发现回写参数中未携带【工作流名称】或者【节点名称】或者【日志路径信息】，本次日志追加失败！";
-                    String logFormat = String.format(logTemple, flowName, nodeName, thisLogUrlPath);
+                    String logFormat = String.format(errorLogTemple, flowName, nodeName,jobTaskRunLog.getRunMsg(), thisLogUrlPath);
                     jobTaskRunLog.setRunMsg(logFormat);
                 }else{
-                    String logFormat = String.format(logTemple, flowName, nodeName, thisLogUrlPath);
+                    String logFormat = String.format(logTemple, flowName, nodeName, jobTaskRunLog.getRunMsg(),thisLogUrlPath);
                     jobTaskRunLog.setRunMsg(logFormat);
                     JobTaskRunLogWithBLOBs jobTaskRunLogWithBLOBs = buildJobTaskRunLogWithBLOBs(specialJavaNode);
                     if(jobTaskRunLogWithBLOBs != null) {
@@ -164,4 +164,10 @@ public class JavaFlowFreeTaskCallbackThread implements Runnable {
         System.arraycopy(targetByte,0,result,sourceByte.length,targetByte.length);
         return result;
     }
+
+    public static void main(String[] args) {
+        String s = "该节点为工作流 【%s】 下的游离节点【%s】，属于二次运行：\n 本次调度信息:%s;\n 上次运行信息日志存放路径为：【%s】";
+        String format = String.format(s, "1", "1", "1", "1");
+        System.out.println(format);
+    }
 }