执行节点监控

byit-myth-core/myth-admin-core/src/main/java/com/byit/thread/helper/UnfinishedNodeMonitoringRunHelper.java

 package com.byit.thread.helper;
 
 import cn.hutool.core.collection.CollectionUtil;
+import com.alibaba.fastjson.JSON;
+import com.byit.dto.plugin.RunLog;
 import com.byit.model.JobTaskRunLog;
 import com.byit.service.JobTaskRunLogService;
 import com.byit.thread.BaseThreadRunHelper;
@@ -10,6 +12,8 @@ import org.springframework.stereotype.Component;
 
 import java.util.List;
 
+import static com.alibaba.fastjson.serializer.SerializerFeature.WriteClassName;
+
 /**
  * @author huangfu
  */
@@ -23,7 +27,6 @@ public class UnfinishedNodeMonitoringRunHelper extends BaseThreadRunHelper {
     /**
      * 心跳前缀
      */
-    private static final String HEARTBEAT = "HEARTBEAT_";
     private final StringRedisTemplate stringRedisTemplate;
     private final JobTaskRunLogService jobTaskRunLogService;
 
@@ -37,9 +40,10 @@ public class UnfinishedNodeMonitoringRunHelper extends BaseThreadRunHelper {
         List<JobTaskRunLog> tempRunNodeList = jobTaskRunLogService.findTempRunNodeList();
         if (CollectionUtil.isNotEmpty(tempRunNodeList)) {
             tempRunNodeList.forEach(nodeLog -> {
+                log.debug("-----节点{}未执行完毕-----",nodeLog);
                 String runId = nodeLog.getRunId();
-                String key = HEARTBEAT + runId;
-                stringRedisTemplate.opsForList().rightPush(key, PENG);
+                RunLog runLog = RunLog.builder().isEnd(false).runLog(PENG).build();
+                stringRedisTemplate.opsForList().rightPush(runId, JSON.toJSONString(runLog, WriteClassName));
             });
         }
         return 5000L;