Commit 1b99bf63 by huangfusuper

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

parent ab224cfe
......@@ -99,7 +99,7 @@ public class JavaFlowFreeTaskCallbackThread implements Runnable {
if(jobTaskRunLogWithBLOBs != null) {
mythJobTaskRunLogService.saveJobTaskRunLog(jobTaskRunLogWithBLOBs);
}else {
logTemple = "%s\n\n 日志追加失败,失败原因是没有找到正确的节点!";
logTemple = "%s\n\n 日志追加失败,失败原因是没有找到正确的节点或者没有正在运行中的实例!";
jobTaskRunLog.setRunMsg(String.format(logTemple,jobTaskRunLog.getRunMsg()));
}
......@@ -121,6 +121,9 @@ public class JavaFlowFreeTaskCallbackThread implements Runnable {
}
RunRecording runRecording = bean.runIngRunRecording(flowName,byName.getWorkspaceId());
if(runRecording == null) {
return null;
}
List<JobTaskRunLogWithBLOBs> jobTaskRunLogWithBLOBsByFlowIdAndRunId = mythJobTaskRunLogService.findJobTaskRunLogWithBLOBsByFlowIdAndRunId(runRecording.getFlowId(), runRecording.getRunId());
JobTaskRunLogWithBLOBs jobTaskRunLogWithBLOBs = jobTaskRunLogWithBLOBsByFlowIdAndRunId.stream().filter(log -> log.getNodeName().equals(specialJavaNode.getNodeName())).findFirst().orElse(null);
if(jobTaskRunLogWithBLOBs != null) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment