Skip to content

B
byit-myth-job
Commit 423633fa by huangfusuper
Options

修改立即运行的方式

parent 89a4b368
Showing with 2 additions and 1 deletion
byit-myth-admin/src/main/java/com/byit/service/impl/ApiNodeServiceImpl.java
...@@ -91,7 +91,7 @@ public class ApiNodeServiceImpl implements ApiNodeService { ...@@ -91,7 +91,7 @@ public class ApiNodeServiceImpl implements ApiNodeService {
schedule.setTriggerTime(triggerTime); schedule.setTriggerTime(triggerTime);
schedule.setScheduleType(ScheduleTypeEnum.REAL.getCode()); schedule.setScheduleType(ScheduleTypeEnum.REAL.getCode());
schedule.setRunParam(PlaceholderUtils.formatParam(schedule.getRunParam()));
String runCommand = schedule.getRunCommand(); String runCommand = schedule.getRunCommand();
if (StringUtils.isNotBlank(runCommand)) { if (StringUtils.isNotBlank(runCommand)) {
runCommand = runCommand.replace("${"+ PlaceholderEnum.DATE_PLACEHOLDER.getName() +"}", DateUtil.dateLessDayStr(new Date(),"yyyyMMdd",1)); runCommand = runCommand.replace("${"+ PlaceholderEnum.DATE_PLACEHOLDER.getName() +"}", DateUtil.dateLessDayStr(new Date(),"yyyyMMdd",1));
...@@ -115,6 +115,7 @@ public class ApiNodeServiceImpl implements ApiNodeService { ...@@ -115,6 +115,7 @@ public class ApiNodeServiceImpl implements ApiNodeService {
if (NodeTypeEnum.JAVA.getCode().equals(runNode.getJobType())) { if (NodeTypeEnum.JAVA.getCode().equals(runNode.getJobType())) {
timerTask = new JavaNodeExecutorTask(schedule); timerTask = new JavaNodeExecutorTask(schedule);
}else{ }else{
schedule.setRunParam(PlaceholderUtils.formatParam(schedule.getRunParam()));
timerTask = new ScriptExecutorJobTask(schedule); timerTask = new ScriptExecutorJobTask(schedule);
} }
......
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