完善日志信息

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

@@ -105,13 +105,17 @@ public class ApiNodeServiceImpl implements ApiNodeService {
         Integer logId= jobTaskRunLog.getLogId();
         //设置日志id
         schedule.setLogId(logId);
-        TimerTask timerTask = new ScriptExecutorJobTask(schedule);
-        WorkRoulette.addJob(timerTask, triggerTime);
+
         RunLog runLog = RunLog.builder().isEnd(false).runLog("等待服务器分配资源").build();
         String runKey = "REAL:EXEC:" + logId;
-
         stringRedisTemplate.opsForList().rightPush(runKey, JSON.toJSONString(runLog, WriteClassName));
 
+        TimerTask timerTask = new ScriptExecutorJobTask(schedule);
+        WorkRoulette.addJob(timerTask, triggerTime);
+
+        RunLog runLogEnd = RunLog.builder().isEnd(false).runLog("服务器分配资源成功").build();
+        stringRedisTemplate.opsForList().rightPush(runKey, JSON.toJSONString(runLogEnd, WriteClassName));
+
         return runKey;
     }
 

byit-myth-executor/myth-executor-server/src/main/java/com/byit/process/MythJobProcess.java

@@ -120,6 +120,13 @@ public class MythJobProcess implements Callable<String>{
                 log.info("进程的id " + this.processId);
             }
 
+            if (stringRedisTemplate != null) {
+                RunLog runLog = RunLog.builder().isEnd(false).runLog("开始执行").build();
+                //TODO 向队列队尾插入一个值
+                Long aLong = stringRedisTemplate.opsForList().rightPush(runKey, JSON.toJSONString(runLog, WriteClassName));
+                log.info("-------{}-------",aLong);
+            }
+
             outputGobbler = new LogGobbler(new InputStreamReader(this.process.getInputStream(), "utf-8"), Boolean.FALSE, 30, runKey, stringRedisTemplate);
             errorGobbler = new LogGobbler(new InputStreamReader(this.process.getErrorStream(), "utf-8"), Boolean.TRUE, 30, runKey, stringRedisTemplate);
             //开始获取进程的运行日志