增加事务

byit-myth-admin/src/main/java/com/byit/service/impl/ApiNodeServiceImpl.java

@@ -58,7 +58,7 @@ public class ApiNodeServiceImpl implements ApiNodeService {
 
 
     @Override
-    @Transactional(propagation = Propagation.NESTED )
+    @Transactional(rollbackFor = Exception.class)
     public String runNode(String param) {
         ValidationUtil.dataNotBank(param, "请求参数不允许为空！");
         RunNode runNode = JSON.parseObject(param, RunNode.class);
@@ -69,7 +69,7 @@ public class ApiNodeServiceImpl implements ApiNodeService {
         ValidationUtil.dataNotBank(runNode.getRunCmd(), "运行命令不允许为空！");
         ValidationUtil.dataNotBank(runNode.getJobType(), "节点类型不允许为空！");
 
-        Long triggerTime = System.currentTimeMillis();
+        Long triggerTime = System.currentTimeMillis()+2000;
 
 
         JobTaskSchedule schedule = new JobTaskSchedule();

byit-myth-core/myth-admin-core/src/main/java/com/byit/job/WorkRoulette.java

@@ -27,7 +27,7 @@ public class WorkRoulette {
 
 
     public static void addJob(TimerTask timerTask,long triggerNextTime) {
-        //log.info("-----添加任务{}-------",((JavaTaskJobTask)timerTask).getJavaTask().getTaskName());
+        log.info("-----任务{}毫秒后执行-------",triggerNextTime-System.currentTimeMillis());
         HASHED_WHEEL_TIMER.newTimeout(timerTask, TimeUnit.MILLISECONDS.toNanos(triggerNextTime-System.currentTimeMillis()), TimeUnit.NANOSECONDS);
     }