Commit 356cd45f by huangfusuper

修改提示记录

parent 55f0650f
...@@ -1589,7 +1589,8 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -1589,7 +1589,8 @@ public class ApiFlowServiceImpl implements ApiFlowService {
List<String> runIdList = Arrays.asList(runIds.split(",")); List<String> runIdList = Arrays.asList(runIds.split(","));
runIdList.forEach(runId -> { runIdList.forEach(runId -> {
List<RunRecording> runRecordList = runRecordingMapper.findStopRunCordByRunId(runId); List<RunRecording> runRecordList = runRecordingMapper.findStopRunCordByRunId(runId);
ValidationUtil.isTrueValidation(null == runRecordList || runRecordList.size() == 0, "运行记录" + runId + "不存在暂停中运行记录!"); log.warn("---------运行记录{},不存在暂停记录中!---",runId);
ValidationUtil.isTrueValidation(null == runRecordList || runRecordList.size() == 0, "该工作流不是暂停状态!");
runRecordingMapper.startByRunId(runId); runRecordingMapper.startByRunId(runId);
jobTaskMapper.startByRunId(runId); jobTaskMapper.startByRunId(runId);
}); });
......
...@@ -91,6 +91,7 @@ public class RunRecordingAndJobTaskServiceImpl implements RunRecordingAndJobTask ...@@ -91,6 +91,7 @@ public class RunRecordingAndJobTaskServiceImpl implements RunRecordingAndJobTask
jobTaskRunLog.setIsVirtual(jobTask.getIsVirtual()); jobTaskRunLog.setIsVirtual(jobTask.getIsVirtual());
jobTaskRunLog.setMapFlowId(jobTask.getMapFlowId()); jobTaskRunLog.setMapFlowId(jobTask.getMapFlowId());
jobTaskRunLog.setRunCode(NodeRunStatusPropertyEnum.RUN_ING.getCode()); jobTaskRunLog.setRunCode(NodeRunStatusPropertyEnum.RUN_ING.getCode());
jobTaskRunLog.setNodeDepend(jobTask.getNodeDepend());
//目前都设置为执行机运行 //目前都设置为执行机运行
jobTaskRunLog.setRunType("1"); jobTaskRunLog.setRunType("1");
Date thisDate = new Date(); Date thisDate = new Date();
......
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