Commit 6a36d97b by huangfusuper

解决立即运行报错BUG

parent 5f50cb3d
...@@ -122,7 +122,17 @@ public class ApiNodeServiceImpl implements ApiNodeService { ...@@ -122,7 +122,17 @@ public class ApiNodeServiceImpl implements ApiNodeService {
//推送日志 //推送日志
stringRedisTemplate.opsForList().rightPush(runKey, JSON.toJSONString(runLog, WriteClassName)); stringRedisTemplate.opsForList().rightPush(runKey, JSON.toJSONString(runLog, WriteClassName));
TimerTask timerTask = new ScriptExecutorJobTask(schedule); TimerTask timerTask;
if (NodeTypeEnum.JAVA.getCode().equals(runNode.getJobType())) {
timerTask = new JavaNodeExecutorTask(schedule);
}else{
String privateParam = runParamWrapped.getPrivateParam();
privateParam = PlaceholderUtils.formatBizDateParam(privateParam, PlaceholderEnum.DATE_PLACEHOLDER.getName(), 1);
privateParam = PlaceholderUtils.formatBizDateParam(privateParam, PlaceholderEnum.NOW_DATE_PLACEHOLDER.getName(), 0);
runParamWrapped.setPrivateParam(privateParam);
schedule.setRunParam(JSON.toJSONString(runParamWrapped));
timerTask = new ScriptExecutorJobTask(schedule);
}
//添加到调度轮 //添加到调度轮
WorkRoulette.addJob(timerTask, triggerTime); WorkRoulette.addJob(timerTask, triggerTime);
......
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