【重构任务排期表】重构任务排期表，七秒内将要执行的任务全在这个表里面

byit-myth-core/myth-admin-core/src/main/java/com/byit/model/MythJobTaskSchedule.java

+package com.byit.model;
+
+import lombok.*;
+
+import javax.persistence.*;
+import java.util.Date;
+
+/**
+ * @program: byit-myth-job->MythJobTaskSchedule
+ * @description: 工作任务排期表，存储七秒内即将执行的任务节点,这个表也是对接工作流的
+ * @author: huangfu
+ * @date: 2019/12/20 10:16
+ **/
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@EqualsAndHashCode
+@Builder
+@Entity
+@Table(name = "job_task_schedule")
+@org.hibernate.annotations.Table(appliesTo = "job_task_schedule",comment="工作任务排期表，存储七秒内即将执行的任务节点，这个表也是对接工作流的")
+public class MythJobTaskSchedule {
+    /**
+     * 当前版本节点主键
+     */
+    @Id
+    @GeneratedValue(strategy= GenerationType.IDENTITY)
+    @Column(nullable = false,columnDefinition = "INT(13) COMMENT '当前版本节点主键'")
+    private Integer nodeId;
+    /**
+     * 当前节点的名称
+     */
+    @Column(nullable = false,columnDefinition = "VARCHAR(255) COMMENT '当前节点的名称'")
+    private String nodeName;
+    /**
+     * 本地节点（插件方） 的节点的名字
+     */
+    @Column(columnDefinition = "VARCHAR(255) COMMENT '本地节点（插件方） 的节点的名字'")
+    private String localNodeHandlerName;
+    /**
+     * 这个在设置节点执行时间跟随任务流的时候，他是没用的，但是设置不跟随的时候，节点的执行按照他自己的时间执行
+     */
+    @Column(columnDefinition = "VARCHAR(255) COMMENT '这个在设置节点执行时间跟随任务流的时候，他是没用的，但是设置不跟随的时候，节点的执行按照他自己的时间执行'")
+    private String nodeCron;
+    /**
+     * 节点的说明
+     */
+    @Column(columnDefinition = "VARCHAR(255) COMMENT '节点的说明'")
+    private String nodeDesc;
+    /**
+     * 插件端的url集合
+     */
+    @Column(columnDefinition = "VARCHAR(255) COMMENT '插件端的url集合'")
+    private String pluginUrls;
+    /**
+     * 路由策略
+     */
+    @Column(columnDefinition = "VARCHAR(32) COMMENT '路由策略'")
+    private String routingStrategy;
+    /**
+     * 阻塞策略
+     */
+    @Column(columnDefinition = "VARCHAR(32) COMMENT '阻塞策略'")
+    private String blockStrategy;
+    /**
+     * 调度中心端请求插件时的令牌
+     */
+    @Column(columnDefinition = "VARCHAR(32) COMMENT '调度中心端请求插件时的令牌'")
+    private String callbackToken;
+    /**
+     * 插件端请求调度中心的令牌
+     */
+    @Column(columnDefinition = "VARCHAR(32) COMMENT '插件端请求调度中心的令牌'")
+    private String gatewayToken;
+    /**
+     * 节点的参数
+     */
+    @Column(columnDefinition = "VARCHAR(256) COMMENT '节点的参数'")
+    private String runParam;
+    /**
+     * 节点的类型 node flow
+     */
+    @Column(columnDefinition = "VARCHAR(32) COMMENT '节点的类型 node flow' ")
+    private String nodeType;
+    /**
+     * 工作流ID
+     */
+    @Column(columnDefinition = "INT(13) COMMENT '工作流ID' ")
+    private Integer flowId;
+    /**
+     * 该节点的依赖节点
+     */
+    @Column(columnDefinition = "VARCHAR(256) COMMENT '该节点的依赖节点' ")
+    private String dependencyNodes;
+    /**
+     * 节点的超时时间 -1不超时
+     */
+    @Column(columnDefinition = "BIGINT COMMENT '节点的超时时间 -1不超时' ")
+    private Long nodeTimeout;
+    /**
+     * 脚本的文件服务器路径集
+     */
+    @Column(columnDefinition = "VARCHAR(512) COMMENT '脚本的文件服务器路径集' ")
+    private String scriptUrls;
+    /**
+     * 源码
+     */
+    @Column(columnDefinition = "LONGTEXT COMMENT '源码' ")
+    private String runSource;
+    /**
+     * 源码备注
+     */
+    @Column(columnDefinition = "VARCHAR(255) COMMENT '源码备注' " )
+    private String runSourceDesc;
+    /**
+     * 源码的修改时间
+     */
+    @Column(columnDefinition = "DATE COMMENT '源码的修改时间' " )
+    private Date sourceUpdateTime;
+    /**
+     * 源码负责人
+     */
+    @Column(columnDefinition = "varchar(32) COMMENT '源码负责人'")
+    private String sourcePrincipal;
+    /**
+     * 节点的任务流id
+     */
+    @Column(columnDefinition = "int(13) COMMENT 'nodeOfFlowId'")
+    private Integer nodeOfFlowId;
+    /**
+     * 节点的剩余次数
+     */
+    @Column(columnDefinition = "int(12) COMMENT '节点的剩余次数'")
+    private Integer remainingCount;
+    /**
+     * 当前节点总共重复次数
+     */
+    @Column(columnDefinition = "int(12) COMMENT  '当前节点总共重复次数'")
+    private Integer repeatCount ;
+    /**
+     * 当前节点的失败重试次数
+     */
+    @Column(columnDefinition = "int(12) COMMENT  '当前节点的失败重试次数'")
+    private Integer failedRetryCount;
+    /**
+     * 重试的间隔
+     */
+    @Column(columnDefinition = "bigint(12) COMMENT  '重试的间隔'")
+    private Long retryInterval;
+    /**
+     * 是否跟随任务流
+     */
+    @Column(columnDefinition = "char(1) COMMENT  '是否跟随任务流 1跟随 2不跟随'")
+    private String followTaskFlow;
+    /**
+     * 当前版本的节点的下次执行时间
+     */
+    @Column(columnDefinition = "bigint(20) COMMENT '当前版本的节点的下次执行时间'")
+    private Long triggerNextTime;
+    /**
+     * 节点的运行标识
+     */
+    @Column(columnDefinition = "varchar(36) COMMENT '运行标识'")
+    private String runId;
+    /**
+     * 调度状态：0-暂停，1-运行
+     */
+    @Column(columnDefinition = "char(1) COMMENT '调度状态：0-暂停，1-运行'")
+    private String triggerStatus;
+    /**
+     * 当前任务的类型 java python shell sql script
+     */
+    @Column(columnDefinition = "varchar(36) COMMENT '当前任务的类型 java python shell sql script'")
+    private String jobType;
+}