【重构任务执行日志表】重构重构任务执行日志表

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

@@ -128,16 +128,16 @@ public class MythJobFlowNodeCurrent {
     @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 remainingCount;
+    /**
      * 当前节点的失败重试次数
      */
     @Column(columnDefinition = "int(12) COMMENT  '当前节点的失败重试次数'")
@@ -162,4 +162,19 @@ public class MythJobFlowNodeCurrent {
      */
     @Column(columnDefinition = "varchar(36) COMMENT '当前任务的类型 java python shell sql script'")
     private String jobType;
+    /**
+     * 设置任务的优先级 1最低  2最高
+     */
+    @Column(columnDefinition = "char(1) COMMENT '设置任务的优先级，1最低  2最高'")
+    private String priority;
+    /**
+     * 当前工作流版本的报警邮箱
+     */
+    @Column(columnDefinition = "varchar(256) COMMENT '当前工作流版本的报警邮箱'")
+    private String alarmEmail;
+    /**
+     * 当前工作流版本的告警的时机
+     */
+    @Column(columnDefinition = "char(1) COMMENT '当前工作流版本的告警的时机'")
+    private String mailAction;
 }

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

@@ -172,5 +172,19 @@ public class MythJobFlowNodeVersion {
      */
     @Column(columnDefinition = "varchar(36) COMMENT '当前任务的类型 java python shell sql script'")
     private String jobType;
-
+    /**
+     * 设置任务的优先级 1最低  2最高
+     */
+    @Column(columnDefinition = "char(1) COMMENT '设置任务的优先级，1最低  2最高'")
+    private String priority;
+    /**
+     * 当前工作流版本的报警邮箱
+     */
+    @Column(columnDefinition = "varchar(256) COMMENT '当前工作流版本的报警邮箱'")
+    private String alarmEmail;
+    /**
+     * 当前工作流版本的告警的时机
+     */
+    @Column(columnDefinition = "char(1) COMMENT '当前工作流版本的告警的时机'")
+    private String mailAction;
 }

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

@@ -76,5 +76,25 @@ public class MythJobFlowRunRecording {
      */
     @Column(columnDefinition = "varchar(36) COMMENT '运行标识'")
     private String RunId;
+    /**
+     * 设置任务的优先级 1最低  2最高
+     */
+    @Column(columnDefinition = "char(1) COMMENT '设置任务的优先级，1最低  2最高'")
+    private String priority;
+    /**
+     * 当前工作流版本的报警邮箱
+     */
+    @Column(columnDefinition = "varchar(256) COMMENT '当前工作流版本的报警邮箱'")
+    private String alarmEmail;
+    /**
+     * 当前工作流版本的告警的时机
+     */
+    @Column(columnDefinition = "char(1) COMMENT '当前工作流版本的告警的时机'")
+    private String mailAction;
+    /**
+     * 调度状态：0-暂停，1-运行
+     */
+    @Column(columnDefinition = "char(1) COMMENT '调度状态：0-暂停，1-运行'")
+    private String triggerStatus;
 
 }

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

@@ -172,4 +172,19 @@ public class MythJobTask {
      */
     @Column(columnDefinition = "varchar(36) COMMENT '当前任务的类型 java python shell sql script'")
     private String jobType;
+    /**
+     * 设置任务的优先级 1最低  2最高
+     */
+    @Column(columnDefinition = "char(1) COMMENT '设置任务的优先级，1最低  2最高'")
+    private String priority;
+    /**
+     * 当前工作流版本的报警邮箱
+     */
+    @Column(columnDefinition = "varchar(256) COMMENT '当前工作流版本的报警邮箱'")
+    private String alarmEmail;
+    /**
+     * 当前工作流版本的告警的时机
+     */
+    @Column(columnDefinition = "char(1) COMMENT '当前工作流版本的告警的时机'")
+    private String mailAction;
 }

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

+package com.byit.model;
+
+import lombok.*;
+
+import javax.persistence.*;
+import java.util.Date;
+
+/**
+ * @program: byit-myth-job->MythJobRunLog
+ * @description: 节点执行日志
+ * @author: huangfu
+ * @date: 2019/12/20 10:21
+ **/
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@EqualsAndHashCode
+@Builder
+@Entity
+@Table(name = "job_task_run_log")
+@org.hibernate.annotations.Table(appliesTo = "job_task_run_log",comment="节点执行日志")
+public class MythJobTaskRunLog {
+    /**
+     * 日志ID
+     */
+    @Id
+    @GeneratedValue(strategy= GenerationType.IDENTITY)
+    @Column(nullable = false,columnDefinition = "int(13) COMMENT '日志ID'")
+    private Integer logId;
+    /**
+     * 执行机主键
+     */
+    @Column(columnDefinition = "int(13) COMMENT '执行机主键'")
+    private Integer jobGroupId;
+    /**
+     * 任务流的主键
+     */
+    @Column(columnDefinition = "int(13) COMMENT '任务流主键'")
+    private Integer jobFlowId;
+    /**
+     * 任务流版本的主键
+     */
+    @Column(columnDefinition = "int(13) COMMENT '任务流版本的主键'")
+    private Integer flowVersionId;
+    /**
+     * 所属任务流的名称
+     */
+    @Column(columnDefinition = "varchar(13) COMMENT '所属任务流的名称'")
+    private String jobFlowName;
+    /**
+     * 节点名称
+     */
+    @Column(columnDefinition = "int(13) COMMENT '节点名称'")
+    private String nodeName;
+    /**
+     * 节点类型  node type
+     */
+    @Column(columnDefinition = "varchar(36) COMMENT '节点类型  node type'")
+    private String nodeType;
+    /**
+     * 运行方式 1执行机运行，2本地运行
+     */
+    @Column(columnDefinition = "char(1) COMMENT '运行方式 1执行机运行，2本地运行'")
+    private String runType;
+    /**
+     * 插件方节点key
+     */
+    @Column(columnDefinition = "varchar(36) COMMENT '插件方节点key'")
+    private String localNodeHandlerName;
+    /**
+     * 运行参数
+     */
+    @Column(columnDefinition = "varchar(36) COMMENT '运行参数'")
+    private String runParams;
+    /**
+     * 触发时间
+     */
+    @Column(columnDefinition = "DATE COMMENT '触发时间'")
+    private Date triggerTime;
+    /**
+     * 调度结果 1成功  2失败
+     */
+    @Column(columnDefinition = "char(1) COMMENT '调度结果 1成功  2失败'")
+    private String triggerCode;
+    /**
+     * 调度信息
+     */
+    @Column(columnDefinition = "text COMMENT '调度信息'")
+    private String triggerMsg;
+    /**
+     * 执行时间
+     */
+    @Column(columnDefinition = "DATE COMMENT '执行时间'")
+    private Date runTime;
+    /**
+     * 运行结果 0未执行完成  1成功 2失败
+     */
+    @Column(columnDefinition = "char(1) COMMENT '运行结果'")
+    private String runCode;
+    /**
+     * 运行结果信息
+     */
+    @Column(columnDefinition = "text COMMENT '运行结果信息'")
+    private String runMsg;
+    /**
+     * 当前节点的失败剩余重试次数  初始阶段为初始的重试次数
+     */
+    @Column(columnDefinition = "int(12) COMMENT  '当前节点的失败剩余重试次数  初始阶段为初始的重试次数'")
+    private Integer failedRemainingCount;
+    /**
+     * 当前工作流版本的报警邮箱
+     */
+    @Column(columnDefinition = "varchar(256) COMMENT '当前工作流版本的报警邮箱'")
+    private String alarmEmail;
+    /**
+     * 当前工作流版本的告警的时机
+     */
+    @Column(columnDefinition = "char(1) COMMENT '当前工作流版本的告警的时机'")
+    private String mailAction;
+
+    /**
+     * 告警结果 1-告警成功 2-告警失败
+     */
+    @Column(columnDefinition = "char(1) COMMENT '告警结果,1-告警成功 2-告警失败'")
+    private String alarmStatus;
+
+}

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

@@ -172,4 +172,19 @@ public class MythJobTaskSchedule {
      */
     @Column(columnDefinition = "varchar(36) COMMENT '当前任务的类型 java python shell sql script'")
     private String jobType;
+    /**
+     * 设置任务的优先级 1最低  2最高
+     */
+    @Column(columnDefinition = "char(1) COMMENT '设置任务的优先级，1最低  2最高'")
+    private String priority;
+    /**
+     * 当前工作流版本的报警邮箱
+     */
+    @Column(columnDefinition = "varchar(256) COMMENT '当前工作流版本的报警邮箱'")
+    private String alarmEmail;
+    /**
+     * 当前工作流版本的告警的时机
+     */
+    @Column(columnDefinition = "char(1) COMMENT '当前工作流版本的告警的时机'")
+    private String mailAction;
 }