【重构表格】

byit-myth-core/myth-admin-core/src/main/java/com/byit/mapper/WorkspaceMapper.java

+package com.byit.mapper;
+
+import com.byit.model.Workspace;
+
+public interface WorkspaceMapper {
+    int deleteById(Integer workspaceId);
+
+    int insert(Workspace record);
+
+    int insertSelective(Workspace record);
+
+    Workspace getById(Integer workspaceId);
+
+    int updateByIdSelective(Workspace record);
+
+    int updateById(Workspace record);
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+public class EmailAlarm implements Serializable {
+    /**
+     * 主键
+     */
+    @ApiModelProperty("主键")
+    private Integer id;
+
+    /**
+     * 工作流Id
+     */
+    @ApiModelProperty("工作流Id")
+    private Integer flowId;
+
+    /**
+     * 工作流名称
+     */
+    @ApiModelProperty("工作流名称")
+    private String flowName;
+
+    /**
+     * 运行标识
+     */
+    @ApiModelProperty("运行标识")
+    private String runId;
+
+    /**
+     * 版本名称
+     */
+    @ApiModelProperty("版本名称")
+    private String versionName;
+
+    /**
+     * 告警邮箱
+     */
+    @ApiModelProperty("告警邮箱")
+    private String alarmEmail;
+
+    /**
+     * 当前工作流版本的告警的时机(0 不告警， 1 完成时告警， 2 失败时告警， 3 成功时告警)
+     */
+    @ApiModelProperty("当前工作流版本的告警的时机(0 不告警， 1 完成时告警， 2 失败时告警， 3 成功时告警)")
+    private String alarmAction;
+
+    /**
+     * 告警结果(0, 未告警  1,告警成功  2,告警失败)
+     */
+    @ApiModelProperty("告警结果(0, 未告警  1,告警成功  2,告警失败)")
+    private String alarmResult;
+
+    /**
+     * 发送时间
+     */
+    @ApiModelProperty("发送时间")
+    private Date sendTime;
+
+    /**
+     * 告警内容
+     */
+    @ApiModelProperty("告警内容")
+    private String alarmContent;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+public class Flow implements Serializable {
+    /**
+     * 当前版本工作流主键
+     */
+    @ApiModelProperty("当前版本工作流主键")
+    private Integer flowId;
+
+    /**
+     * 当前工作流版本的报警邮箱
+     */
+    @ApiModelProperty("当前工作流版本的报警邮箱")
+    private String alarmEmail;
+
+    /**
+     * 执行类型  周期执行1  手动执行2
+     */
+    @ApiModelProperty("执行类型  周期执行1  手动执行2")
+    private String execType;
+
+    /**
+     * 任务流的cron表达式
+     */
+    @ApiModelProperty("任务流的cron表达式")
+    private String flowCron;
+
+    /**
+     * 当前工作流的介绍
+     */
+    @ApiModelProperty("当前工作流的介绍")
+    private String flowDesc;
+
+    /**
+     * 当前版本工作流名字
+     */
+    @ApiModelProperty("当前版本工作流名字")
+    private String flowName;
+
+    /**
+     * 工作流调度上的节点数目
+     */
+    @ApiModelProperty("工作流调度上的节点数目")
+    private Integer flowNodeCount;
+
+    /**
+     * 工作流的超时时间
+     */
+    @ApiModelProperty("工作流的超时时间")
+    private Long flowTimeout;
+
+    /**
+     * 是否是内嵌工作流 1 否， 0 是
+     */
+    @ApiModelProperty("是否是内嵌工作流 1 否， 0 是")
+    private String isInner;
+
+    /**
+     * 当前工作流版本的告警的时机(0 不告警， 1 完成时告警， 2 失败时告警， 3 成功时告警)
+     */
+    @ApiModelProperty("当前工作流版本的告警的时机(0 不告警， 1 完成时告警， 2 失败时告警， 3 成功时告警)")
+    private String alarmlAction;
+
+    /**
+     * 设置任务的优先级，1最低  2最高
+     */
+    @ApiModelProperty("设置任务的优先级，1最低  2最高")
+    private String priority;
+
+    /**
+     * 当前版本的工作流的下次执行时间
+     */
+    @ApiModelProperty("当前版本的工作流的下次执行时间")
+    private Long triggerNextTime;
+
+    /**
+     * 工作空间的id
+     */
+    @ApiModelProperty("工作空间的id")
+    private Integer workspaceId;
+
+    /**
+     * 创建人
+     */
+    @ApiModelProperty("创建人")
+    private String author;
+
+    /**
+     * 创建时间
+     */
+    @ApiModelProperty("创建时间")
+    private Date addTime;
+
+    /**
+     * 是否启动   1不启动  0启动
+     */
+    @ApiModelProperty("是否启动   1不启动  0启动")
+    private String startUp;
+
+    /**
+     * 责任人
+     */
+    @ApiModelProperty("责任人")
+    private String principal;
+
+    /**
+     * 版本名称
+     */
+    @ApiModelProperty("版本名称")
+    private String versionName;
+
+    /**
+     * 工作流版本额重复次数
+     */
+    @ApiModelProperty("工作流版本额重复次数")
+    private Integer repeatCount;
+
+    /**
+     * 剩余执行次数
+     */
+    @ApiModelProperty("剩余执行次数")
+    private Integer remainingCount;
+
+    /**
+     * 节点是否跟随任务流，1跟随  2不跟随
+     */
+    @ApiModelProperty("节点是否跟随任务流，1跟随  2不跟随")
+    private String scheduleFollow;
+
+    /**
+     * 是否修改过 0 是(默认)  1 否
+     */
+    @ApiModelProperty("是否修改过 0 是(默认)  1 否")
+    private String isUpdate;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+public class FlowVersion implements Serializable {
+    /**
+     * 版本工作流主键
+     */
+    @ApiModelProperty("版本工作流主键")
+    private Integer flowVersionId;
+
+    /**
+     * 添加时间
+     */
+    @ApiModelProperty("添加时间")
+    private Date addTime;
+
+    /**
+     * 工作流版本的报警邮箱
+     */
+    @ApiModelProperty("工作流版本的报警邮箱")
+    private String alarmEmail;
+
+    /**
+     * 执行类型  周期执行1  手动执行2
+     */
+    @ApiModelProperty("执行类型  周期执行1  手动执行2")
+    private String execType;
+
+    /**
+     * 任务流的cron表达式
+     */
+    @ApiModelProperty("任务流的cron表达式")
+    private String flowCron;
+
+    /**
+     * 工作流的介绍
+     */
+    @ApiModelProperty("工作流的介绍")
+    private String flowDesc;
+
+    /**
+     * 工作流主键
+     */
+    @ApiModelProperty("工作流主键")
+    private Integer flowId;
+
+    /**
+     * 版本工作流名字
+     */
+    @ApiModelProperty("版本工作流名字")
+    private String flowName;
+
+    /**
+     * 前版本工作流节点数目
+     */
+    @ApiModelProperty("前版本工作流节点数目")
+    private Integer flowNodeCount;
+
+    /**
+     * 当前工作流版本的告警的时机(0 不告警， 1 完成时告警， 2 失败时告警， 3 成功时告警)
+     */
+    @ApiModelProperty("当前工作流版本的告警的时机(0 不告警， 1 完成时告警， 2 失败时告警， 3 成功时告警)")
+    private String alarmlAction;
+
+    /**
+     * 节点是否跟随任务流，1跟随  2不跟随
+     */
+    @ApiModelProperty("节点是否跟随任务流，1跟随  2不跟随")
+    private String scheduleFollow;
+
+    /**
+     * 设置任务的优先级，1最低  2最高
+     */
+    @ApiModelProperty("设置任务的优先级，1最低  2最高")
+    private String priority;
+
+    /**
+     * 删除标志  1正常  2删除
+     */
+    @ApiModelProperty("删除标志  1正常  2删除")
+    private String removeMark;
+
+    /**
+     * 工作流版本额重复次数
+     */
+    @ApiModelProperty("工作流版本额重复次数")
+    private Integer repeatCount;
+
+    /**
+     * 当前版本的标志  this
+     */
+    @ApiModelProperty("当前版本的标志  this")
+    private String versionMark;
+
+    /**
+     * 工作空间的id
+     */
+    @ApiModelProperty("工作空间的id")
+    private Integer workspaceId;
+
+    /**
+     * 创建人
+     */
+    @ApiModelProperty("创建人")
+    private String author;
+
+    /**
+     * 责任人
+     */
+    @ApiModelProperty("责任人")
+    private String principal;
+
+    /**
+     * 版本名称
+     */
+    @ApiModelProperty("版本名称")
+    private String versionName;
+
+    /**
+     * 是否是内嵌工作流 1 否， 0 是
+     */
+    @ApiModelProperty("是否是内嵌工作流 1 否， 0 是")
+    private String isInner;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import lombok.Data;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+public class JobTask implements Serializable {
+    /**
+     */
+    @ApiModelProperty("")
+    private Integer id;
+
+    /**
+     * 当前版本节点主键
+     */
+    @ApiModelProperty("当前版本节点主键")
+    private Integer nodeId;
+
+    /**
+     * 阻塞策略
+     */
+    @ApiModelProperty("阻塞策略")
+    private String blockStrategy;
+
+    /**
+     * 插件的网络令牌
+     */
+    @ApiModelProperty("插件的网络令牌")
+    private String pluginToken;
+
+    /**
+     * 当前节点的失败重试次数
+     */
+    @ApiModelProperty("当前节点的失败重试次数")
+    private Integer failedRetryCount;
+
+    /**
+     * 工作流ID
+     */
+    @ApiModelProperty("工作流ID")
+    private Integer flowId;
+
+    /**
+     * 插件端请求调度中心的令牌
+     */
+    @ApiModelProperty("插件端请求调度中心的令牌")
+    private String gatewayToken;
+
+    /**
+     * 当前任务的类型 java python shell sql script
+     */
+    @ApiModelProperty("当前任务的类型 java python shell sql script")
+    private String jobType;
+
+    /**
+     * 本地节点（插件方） 的节点的名字
+     */
+    @ApiModelProperty("本地节点（插件方） 的节点的名字")
+    private String handlerName;
+
+    /**
+     * 节点的说明
+     */
+    @ApiModelProperty("节点的说明")
+    private String nodeDesc;
+
+    /**
+     * 当前节点的名称
+     */
+    @ApiModelProperty("当前节点的名称")
+    private String nodeName;
+
+    /**
+     * 映射的工作流id（当节点为虚节点，有意义）
+     */
+    @ApiModelProperty("映射的工作流id（当节点为虚节点，有意义）")
+    private Integer mapFlowId;
+
+    /**
+     * 节点的超时时间 -1不超时
+     */
+    @ApiModelProperty("节点的超时时间 -1不超时")
+    private Long nodeTimeout;
+
+    /**
+     * 是否是虚节点（0 是， 1 否），虚节点代表是内嵌工作流
+     */
+    @ApiModelProperty("是否是虚节点（0 是， 1 否），虚节点代表是内嵌工作流")
+    private String isVirtual;
+
+    /**
+     * 插件端的url集合
+     */
+    @ApiModelProperty("插件端的url集合")
+    private String pluginUrls;
+
+    /**
+     * 设置任务的优先级，1最低  2最高
+     */
+    @ApiModelProperty("设置任务的优先级，1最低  2最高")
+    private String priority;
+
+    /**
+     * 失败重试的间隔（单位毫秒）
+     */
+    @ApiModelProperty("失败重试的间隔（单位毫秒）")
+    private Long failedRetryInterval;
+
+    /**
+     * 路由策略
+     */
+    @ApiModelProperty("路由策略")
+    private String routingStrategy;
+
+    /**
+     * 运行标识
+     */
+    @ApiModelProperty("运行标识")
+    private String runId;
+
+    /**
+     * 节点的参数
+     */
+    @ApiModelProperty("节点的参数")
+    private String runParam;
+
+    /**
+     * 源码备注
+     */
+    @ApiModelProperty("源码备注")
+    private String runSourceDesc;
+
+    /**
+     * 脚本的文件服务器路径集
+     */
+    @ApiModelProperty("脚本的文件服务器路径集")
+    private String scriptUrls;
+
+    /**
+     * 源码负责人
+     */
+    @ApiModelProperty("源码负责人")
+    private String sourcePrincipal;
+
+    /**
+     * 节点的本次执行时间
+     */
+    @ApiModelProperty("节点的本次执行时间")
+    private Long triggerTime;
+
+    /**
+     * 调度状态：0-暂停，1-运行
+     */
+    @ApiModelProperty("调度状态：0-暂停，1-运行")
+    private String triggerStatus;
+
+    /**
+     * 工作流版本名称
+     */
+    @ApiModelProperty("工作流版本名称")
+    private String versionName;
+
+    /**
+     * 运行命令
+     */
+    @ApiModelProperty("运行命令")
+    private String runCommand;
+
+    /**
+     * 源码
+     */
+    @ApiModelProperty("源码")
+    private String runSource;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+public class JobTaskRunLog implements Serializable {
+    /**
+     * 日志ID
+     */
+    @ApiModelProperty("日志ID")
+    private Integer logId;
+
+    /**
+     * 当前节点的失败剩余重试次数  初始阶段为初始的重试次数
+     */
+    @ApiModelProperty("当前节点的失败剩余重试次数  初始阶段为初始的重试次数")
+    private Integer failedRemainingCount;
+
+    /**
+     * 版本名称
+     */
+    @ApiModelProperty("版本名称")
+    private String versionName;
+
+    /**
+     * 任务流主键
+     */
+    @ApiModelProperty("任务流主键")
+    private Integer flowId;
+
+    /**
+     * 所属任务流的名称
+     */
+    @ApiModelProperty("所属任务流的名称")
+    private String flowName;
+
+    /**
+     * 执行机主键
+     */
+    @ApiModelProperty("执行机主键")
+    private Integer jobGroupId;
+
+    /**
+     * 插件方节点key
+     */
+    @ApiModelProperty("插件方节点key")
+    private String handlerName;
+
+    /**
+     * 节点名称
+     */
+    @ApiModelProperty("节点名称")
+    private String nodeName;
+
+    /**
+     * 是否是虚节点（0 是， 1 否），虚节点代表是内嵌工作流
+     */
+    @ApiModelProperty("是否是虚节点（0 是， 1 否），虚节点代表是内嵌工作流")
+    private String isVirtual;
+
+    /**
+     * 运行结果 1 成功  2 失败  3 补批成功  4 补批失败 5.kill
+     */
+    @ApiModelProperty("运行结果 1 成功  2 失败  3 补批成功  4 补批失败 5.kill")
+    private String runCode;
+
+    /**
+     * 运行参数
+     */
+    @ApiModelProperty("运行参数")
+    private String runParams;
+
+    /**
+     * 开始时间
+     */
+    @ApiModelProperty("开始时间")
+    private Date startTime;
+
+    /**
+     * 运行方式 1执行机运行，2插件运行
+     */
+    @ApiModelProperty("运行方式 1执行机运行，2插件运行")
+    private String runType;
+
+    /**
+     * 调度结果 1成功  2失败
+     */
+    @ApiModelProperty("调度结果 1成功  2失败")
+    private String triggerCode;
+
+    /**
+     * 触发时间
+     */
+    @ApiModelProperty("触发时间")
+    private Date triggerTime;
+
+    /**
+     * 执行机的IP地址
+     */
+    @ApiModelProperty("执行机的IP地址")
+    private String jobGroupIp;
+
+    /**
+     * 映射的工作流id（当节点为虚节点，有意义）
+     */
+    @ApiModelProperty("映射的工作流id（当节点为虚节点，有意义）")
+    private Integer mapFlowId;
+
+    /**
+     * 运行命令
+     */
+    @ApiModelProperty("运行命令")
+    private String runCommand;
+
+    /**
+     * 结束时间
+     */
+    @ApiModelProperty("结束时间")
+    private Date endTime;
+
+    /**
+     * 节点id
+     */
+    @ApiModelProperty("节点id")
+    private Integer nodeId;
+
+    /**
+     * 节点任务类型
+     */
+    @ApiModelProperty("节点任务类型")
+    private String jobType;
+
+    /**
+     * 是否已完成告警(0未完成  1完成)
+     */
+    @ApiModelProperty("是否已完成告警(0未完成  1完成)")
+    private String alertEnd;
+
+    /**
+     * 运行标识
+     */
+    @ApiModelProperty("运行标识")
+    private String runId;
+
+    /**
+     * 重跑的运行标识
+     */
+    @ApiModelProperty("重跑的运行标识")
+    private String reRunId;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import lombok.Data;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+public class JobTaskRunLogWithBLOBs extends JobTaskRunLog implements Serializable {
+    /**
+     * 运行结果信息
+     */
+    @ApiModelProperty("运行结果信息")
+    private String runMsg;
+
+    /**
+     * 调度信息
+     */
+    @ApiModelProperty("调度信息")
+    private String triggerMsg;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import lombok.Data;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+public class JobTaskSchedule implements Serializable {
+    /**
+     */
+    @ApiModelProperty("")
+    private Integer id;
+
+    /**
+     * 当前版本节点主键
+     */
+    @ApiModelProperty("当前版本节点主键")
+    private Integer nodeId;
+
+    /**
+     * 阻塞策略
+     */
+    @ApiModelProperty("阻塞策略")
+    private String blockStrategy;
+
+    /**
+     * 插件的网络令牌
+     */
+    @ApiModelProperty("插件的网络令牌")
+    private String pluginToken;
+
+    /**
+     * 当前节点的失败重试次数
+     */
+    @ApiModelProperty("当前节点的失败重试次数")
+    private Integer failedRetryCount;
+
+    /**
+     * 工作流ID
+     */
+    @ApiModelProperty("工作流ID")
+    private Integer flowId;
+
+    /**
+     * 插件端请求调度中心的令牌
+     */
+    @ApiModelProperty("插件端请求调度中心的令牌")
+    private String gatewayToken;
+
+    /**
+     * 当前任务的类型 java python shell sql script
+     */
+    @ApiModelProperty("当前任务的类型 java python shell sql script")
+    private String jobType;
+
+    /**
+     * 本地节点（插件方） 的节点的名字
+     */
+    @ApiModelProperty("本地节点（插件方） 的节点的名字")
+    private String handlerName;
+
+    /**
+     * 节点的说明
+     */
+    @ApiModelProperty("节点的说明")
+    private String nodeDesc;
+
+    /**
+     * 当前节点的名称
+     */
+    @ApiModelProperty("当前节点的名称")
+    private String nodeName;
+
+    /**
+     * 映射的工作流id（当节点为虚节点，有意义）
+     */
+    @ApiModelProperty("映射的工作流id（当节点为虚节点，有意义）")
+    private Integer mapFlowId;
+
+    /**
+     * 节点的超时时间 -1不超时
+     */
+    @ApiModelProperty("节点的超时时间 -1不超时")
+    private Long nodeTimeout;
+
+    /**
+     * 是否是虚节点（0 是， 1 否），虚节点代表是内嵌工作流
+     */
+    @ApiModelProperty("是否是虚节点（0 是， 1 否），虚节点代表是内嵌工作流")
+    private String isVirtual;
+
+    /**
+     * 插件端的url集合
+     */
+    @ApiModelProperty("插件端的url集合")
+    private String pluginUrls;
+
+    /**
+     * 设置任务的优先级，1最低  2最高
+     */
+    @ApiModelProperty("设置任务的优先级，1最低  2最高")
+    private String priority;
+
+    /**
+     * 失败重试的间隔（单位毫秒）
+     */
+    @ApiModelProperty("失败重试的间隔（单位毫秒）")
+    private Long failedRetryInterval;
+
+    /**
+     * 路由策略
+     */
+    @ApiModelProperty("路由策略")
+    private String routingStrategy;
+
+    /**
+     * 运行标识
+     */
+    @ApiModelProperty("运行标识")
+    private String runId;
+
+    /**
+     * 节点的参数
+     */
+    @ApiModelProperty("节点的参数")
+    private String runParam;
+
+    /**
+     * 源码备注
+     */
+    @ApiModelProperty("源码备注")
+    private String runSourceDesc;
+
+    /**
+     * 脚本的文件服务器路径集
+     */
+    @ApiModelProperty("脚本的文件服务器路径集")
+    private String scriptUrls;
+
+    /**
+     * 源码负责人
+     */
+    @ApiModelProperty("源码负责人")
+    private String sourcePrincipal;
+
+    /**
+     * 节点的本次执行时间
+     */
+    @ApiModelProperty("节点的本次执行时间")
+    private Long triggerTime;
+
+    /**
+     * 调度状态：0-暂停，1-运行
+     */
+    @ApiModelProperty("调度状态：0-暂停，1-运行")
+    private String triggerStatus;
+
+    /**
+     * 工作流版本名称
+     */
+    @ApiModelProperty("工作流版本名称")
+    private String versionName;
+
+    /**
+     * 日志表id
+     */
+    @ApiModelProperty("日志表id")
+    private Integer logId;
+
+    /**
+     * 运行命令
+     */
+    @ApiModelProperty("运行命令")
+    private String runCommand;
+
+    /**
+     * 源码
+     */
+    @ApiModelProperty("源码")
+    private String runSource;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+public class Node implements Serializable {
+    /**
+     * 当前版本节点主键
+     */
+    @ApiModelProperty("当前版本节点主键")
+    private Integer nodeId;
+
+    /**
+     * 阻塞策略 （0，阻塞等待  1，丢弃）
+     */
+    @ApiModelProperty("阻塞策略 （0，阻塞等待  1，丢弃）")
+    private String blockStrategy;
+
+    /**
+     * 插件端网关令牌
+     */
+    @ApiModelProperty("插件端网关令牌")
+    private String pluginToken;
+
+    /**
+     * 当前节点的失败重试次数
+     */
+    @ApiModelProperty("当前节点的失败重试次数")
+    private Integer failedRetryCount;
+
+    /**
+     * 工作流ID
+     */
+    @ApiModelProperty("工作流ID")
+    private Integer flowId;
+
+    /**
+     * 插件端请求调度中心的令牌
+     */
+    @ApiModelProperty("插件端请求调度中心的令牌")
+    private String gatewayToken;
+
+    /**
+     * 当前任务的类型 java python shell sql script
+     */
+    @ApiModelProperty("当前任务的类型 java python shell sql script")
+    private String jobType;
+
+    /**
+     * 本地节点（插件方） 的节点的名字
+     */
+    @ApiModelProperty("本地节点（插件方） 的节点的名字")
+    private String handlerName;
+
+    /**
+     * 这个在设置节点执行时间跟随任务流的时候，他是没用的，但是设置不跟随的时候，节点的执行按照他自己的时间执行
+     */
+    @ApiModelProperty("这个在设置节点执行时间跟随任务流的时候，他是没用的，但是设置不跟随的时候，节点的执行按照他自己的时间执行")
+    private String nodeCron;
+
+    /**
+     * 节点的说明
+     */
+    @ApiModelProperty("节点的说明")
+    private String nodeDesc;
+
+    /**
+     * 当前节点的名称
+     */
+    @ApiModelProperty("当前节点的名称")
+    private String nodeName;
+
+    /**
+     * 映射的工作流id（当节点为虚节点，有意义）
+     */
+    @ApiModelProperty("映射的工作流id（当节点为虚节点，有意义）")
+    private Integer mapFlowId;
+
+    /**
+     * 节点的超时时间 -1不超时
+     */
+    @ApiModelProperty("节点的超时时间 -1不超时")
+    private Long nodeTimeout;
+
+    /**
+     * 是否是虚节点（0 是， 1 否），虚节点代表是内嵌工作流
+     */
+    @ApiModelProperty("是否是虚节点（0 是， 1 否），虚节点代表是内嵌工作流")
+    private String isVirtual;
+
+    /**
+     * 插件端的url集合
+     */
+    @ApiModelProperty("插件端的url集合")
+    private String pluginUrls;
+
+    /**
+     * 设置任务的优先级，1最低  2最高
+     */
+    @ApiModelProperty("设置任务的优先级，1最低  2最高")
+    private String priority;
+
+    /**
+     * 节点剩余执行次数
+     */
+    @ApiModelProperty("节点剩余执行次数")
+    private Integer remainingCount;
+
+    /**
+     * 节点可执行次数
+     */
+    @ApiModelProperty("节点可执行次数")
+    private Integer repeatCount;
+
+    /**
+     * 失败重试的间隔（毫秒）
+     */
+    @ApiModelProperty("失败重试的间隔（毫秒）")
+    private Long failedRetryInterval;
+
+    /**
+     * 路由策略
+     */
+    @ApiModelProperty("路由策略")
+    private String routingStrategy;
+
+    /**
+     * 节点的参数
+     */
+    @ApiModelProperty("节点的参数")
+    private String runParam;
+
+    /**
+     * 源码备注
+     */
+    @ApiModelProperty("源码备注")
+    private String runSourceDesc;
+
+    /**
+     * 脚本的文件服务器路径集
+     */
+    @ApiModelProperty("脚本的文件服务器路径集")
+    private String scriptUrls;
+
+    /**
+     * 源码负责人
+     */
+    @ApiModelProperty("源码负责人")
+    private String sourcePrincipal;
+
+    /**
+     * 源码的修改时间
+     */
+    @ApiModelProperty("源码的修改时间")
+    private Date sourceUpdateTime;
+
+    /**
+     * 当前版本的节点的下次执行时间
+     */
+    @ApiModelProperty("当前版本的节点的下次执行时间")
+    private Long triggerNextTime;
+
+    /**
+     * 创建人
+     */
+    @ApiModelProperty("创建人")
+    private String author;
+
+    /**
+     * 创建时间
+     */
+    @ApiModelProperty("创建时间")
+    private Date addTime;
+
+    /**
+     * 版本名称
+     */
+    @ApiModelProperty("版本名称")
+    private String versionName;
+
+    /**
+     * 在调度上（0，在 1, 不在）
+     */
+    @ApiModelProperty("在调度上（0，在 1, 不在）")
+    private String onFork;
+
+    /**
+     * 运行命令
+     */
+    @ApiModelProperty("运行命令")
+    private String runCommand;
+
+    /**
+     * 源码
+     */
+    @ApiModelProperty("源码")
+    private String runSource;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import lombok.Data;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+public class NodeDependencyKey implements Serializable {
+    /**
+     * 节点id
+     */
+    @ApiModelProperty("节点id")
+    private Integer nodeId;
+
+    /**
+     * 依赖的id
+     */
+    @ApiModelProperty("依赖的id")
+    private Integer dependencyId;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+public class NodeVersion implements Serializable {
+    /**
+     * 当前版本节点主键
+     */
+    @ApiModelProperty("当前版本节点主键")
+    private Integer nodeVersionId;
+
+    /**
+     * 节点的id
+     */
+    @ApiModelProperty("节点的id")
+    private Integer nodeId;
+
+    /**
+     * 阻塞策略
+     */
+    @ApiModelProperty("阻塞策略")
+    private String blockStrategy;
+
+    /**
+     * 插件端网关令牌
+     */
+    @ApiModelProperty("插件端网关令牌")
+    private String puginToken;
+
+    /**
+     * 当前节点的失败重试次数
+     */
+    @ApiModelProperty("当前节点的失败重试次数")
+    private Integer failedRetryCount;
+
+    /**
+     * 工作流ID
+     */
+    @ApiModelProperty("工作流ID")
+    private Integer flowId;
+
+    /**
+     * 所属工作流的id
+     */
+    @ApiModelProperty("所属工作流的id")
+    private Integer flowVersionId;
+
+    /**
+     * 插件端请求调度中心的令牌
+     */
+    @ApiModelProperty("插件端请求调度中心的令牌")
+    private String gatewayToken;
+
+    /**
+     * 当前任务的类型 java python shell sql script
+     */
+    @ApiModelProperty("当前任务的类型 java python shell sql script")
+    private String jobType;
+
+    /**
+     * 本地节点（插件方） 的节点的名字
+     */
+    @ApiModelProperty("本地节点（插件方） 的节点的名字")
+    private String handlerName;
+
+    /**
+     * 这个在设置节点执行时间跟随任务流的时候，他是没用的，但是设置不跟随的时候，节点的执行按照他自己的时间执行
+     */
+    @ApiModelProperty("这个在设置节点执行时间跟随任务流的时候，他是没用的，但是设置不跟随的时候，节点的执行按照他自己的时间执行")
+    private String nodeCron;
+
+    /**
+     * 节点的说明
+     */
+    @ApiModelProperty("节点的说明")
+    private String nodeDesc;
+
+    /**
+     * 当前节点的名称
+     */
+    @ApiModelProperty("当前节点的名称")
+    private String nodeName;
+
+    /**
+     * 映射的工作流id（当节点为虚节点，有意义）
+     */
+    @ApiModelProperty("映射的工作流id（当节点为虚节点，有意义）")
+    private Integer mapFlowId;
+
+    /**
+     * 节点的超时时间 -1不超时
+     */
+    @ApiModelProperty("节点的超时时间 -1不超时")
+    private Long nodeTimeout;
+
+    /**
+     * 是否是虚节点（0 是， 1 否），虚节点代表是内嵌工作流
+     */
+    @ApiModelProperty("是否是虚节点（0 是， 1 否），虚节点代表是内嵌工作流")
+    private String isVirtual;
+
+    /**
+     * 插件端的url集合
+     */
+    @ApiModelProperty("插件端的url集合")
+    private String pluginUrls;
+
+    /**
+     * 设置任务的优先级，1最低  2最高
+     */
+    @ApiModelProperty("设置任务的优先级，1最低  2最高")
+    private String priority;
+
+    /**
+     * 删除标识 1正常 2 删除
+     */
+    @ApiModelProperty("删除标识 1正常 2 删除")
+    private String removeMark;
+
+    /**
+     * 当前节点总共重复次数(默认为-1，不限制)
+     */
+    @ApiModelProperty("当前节点总共重复次数(默认为-1，不限制)")
+    private Integer repeatCount;
+
+    /**
+     * 失败重试的间隔（毫秒）
+     */
+    @ApiModelProperty("失败重试的间隔（毫秒）")
+    private Long failedRetryInterval;
+
+    /**
+     * 路由策略
+     */
+    @ApiModelProperty("路由策略")
+    private String routingStrategy;
+
+    /**
+     * 节点的参数
+     */
+    @ApiModelProperty("节点的参数")
+    private String runParam;
+
+    /**
+     * 源码备注
+     */
+    @ApiModelProperty("源码备注")
+    private String runSourceDesc;
+
+    /**
+     * 脚本的文件服务器路径集
+     */
+    @ApiModelProperty("脚本的文件服务器路径集")
+    private String scriptUrls;
+
+    /**
+     * 源码负责人
+     */
+    @ApiModelProperty("源码负责人")
+    private String sourcePrincipal;
+
+    /**
+     * 源码的修改时间
+     */
+    @ApiModelProperty("源码的修改时间")
+    private Date sourceUpdateTime;
+
+    /**
+     * 当前节点的版本标识 this
+     */
+    @ApiModelProperty("当前节点的版本标识 this")
+    private String versionMark;
+
+    /**
+     * 节点的作者
+     */
+    @ApiModelProperty("节点的作者")
+    private String author;
+
+    /**
+     * 创建时间
+     */
+    @ApiModelProperty("创建时间")
+    private Date addTime;
+
+    /**
+     * 版本名称
+     */
+    @ApiModelProperty("版本名称")
+    private String versionName;
+
+    /**
+     * 在调度上（0，在 1, 不在）
+     */
+    @ApiModelProperty("在调度上（0，在 1, 不在）")
+    private String onFork;
+
+    /**
+     * 运行命令
+     */
+    @ApiModelProperty("运行命令")
+    private String runCommand;
+
+    /**
+     * 源码
+     */
+    @ApiModelProperty("源码")
+    private String runSource;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import java.util.Date;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+public class RunRecording implements Serializable {
+    /**
+     * 记录主键
+     */
+    @ApiModelProperty("记录主键")
+    private Integer recordingId;
+
+    /**
+     * 运行标识
+     */
+    @ApiModelProperty("运行标识")
+    private String runId;
+
+    /**
+     * 当前工作流版本的报警邮箱
+     */
+    @ApiModelProperty("当前工作流版本的报警邮箱")
+    private String alarmEmail;
+
+    /**
+     * 被哪一个调度器加载的
+     */
+    @ApiModelProperty("被哪一个调度器加载的")
+    private String dispatchIp;
+
+    /**
+     * 工作流的名字
+     */
+    @ApiModelProperty("工作流的名字")
+    private String flowName;
+
+    /**
+     * 执行结果  1 成功  2 失败  3 补批成功  4 补批失败 5.kill
+     */
+    @ApiModelProperty("执行结果  1 成功  2 失败  3 补批成功  4 补批失败 5.kill")
+    private String flowRunResult;
+
+    /**
+     * 运行状态 1 未开始  2运行中  3暂停  4完成
+     */
+    @ApiModelProperty("运行状态 1 未开始  2运行中  3暂停  4完成")
+    private String flowStatus;
+
+    /**
+     * 工作流的超时时间
+     */
+    @ApiModelProperty("工作流的超时时间")
+    private Long flowTimeout;
+
+    /**
+     * 工作流的版本名称
+     */
+    @ApiModelProperty("工作流的版本名称")
+    private String flowVersionName;
+
+    /**
+     * 当前工作流版本的告警的时机(0 不告警， 1 完成时告警， 2 失败时告警， 3 成功时告警)
+     */
+    @ApiModelProperty("当前工作流版本的告警的时机(0 不告警， 1 完成时告警， 2 失败时告警， 3 成功时告警)")
+    private String alarmlAction;
+
+    /**
+     * 设置任务的优先级，1最低  2最高
+     */
+    @ApiModelProperty("设置任务的优先级，1最低  2最高")
+    private String priority;
+
+    /**
+     * 本次任务的执行时间
+     */
+    @ApiModelProperty("本次任务的执行时间")
+    private Long triggerTime;
+
+    /**
+     * 责任人
+     */
+    @ApiModelProperty("责任人")
+    private String principal;
+
+    /**
+     * 工作流Id
+     */
+    @ApiModelProperty("工作流Id")
+    private Integer flowId;
+
+    /**
+     * 开始时间
+     */
+    @ApiModelProperty("开始时间")
+    private Date startTime;
+
+    /**
+     * 结束时间
+     */
+    @ApiModelProperty("结束时间")
+    private Date endTime;
+
+    /**
+     * 是否已告警(0，是   1，否)
+     */
+    @ApiModelProperty("是否已告警(0，是   1，否)")
+    private String isAlarm;
+
+    /**
+     * 是否是内嵌工作流 0 否， 1 是
+     */
+    @ApiModelProperty("是否是内嵌工作流 0 否， 1 是")
+    private String isInner;
+
+    /**
+     * 快速失败标识  0 不快速失败   1 快速失败
+     */
+    @ApiModelProperty("快速失败标识  0 不快速失败   1 快速失败")
+    private String failFast;
+
+    /**
+     * 工作流版本名称
+     */
+    @ApiModelProperty("工作流版本名称")
+    private String versionName;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+public class SourceHistory implements Serializable {
+    /**
+     * 历史源码主键
+     */
+    @ApiModelProperty("历史源码主键")
+    private String id;
+
+    /**
+     * 节点主键
+     */
+    @ApiModelProperty("节点主键")
+    private String jobNodeId;
+
+    /**
+     * 备注
+     */
+    @ApiModelProperty("备注")
+    private String glueRemark;
+
+    /**
+     * 添加时间
+     */
+    @ApiModelProperty("添加时间")
+    private Date addTime;
+
+    /**
+     * 源代码
+     */
+    @ApiModelProperty("源代码")
+    private String glueSource;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

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

+package com.byit.model;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ *  
+ */
+@ApiModel
+@Data
+public class Workspace implements Serializable {
+    /**
+     * 主键
+     */
+    @ApiModelProperty("主键")
+    private Integer workspaceId;
+
+    /**
+     * 工作空间名称
+     */
+    @ApiModelProperty("工作空间名称")
+    private String workspaceName;
+
+    /**
+     * 创建人
+     */
+    @ApiModelProperty("创建人")
+    private String author;
+
+    /**
+     * 添加时间
+     */
+    @ApiModelProperty("添加时间")
+    private Date addTime;
+
+    /**
+     * 删除标志  1正常  2删除
+     */
+    @ApiModelProperty("删除标志  1正常  2删除")
+    private String removeMark;
+
+    /**
+     */
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

byit-myth-core/myth-admin-core/src/main/resources/mapper/FlowMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.byit.mapper.FlowMapper">
+  <resultMap id="BaseResultMap" type="com.byit.model.Flow">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    <id column="flow_id" jdbcType="INTEGER" property="flowId" />
+    <result column="alarm_email" jdbcType="VARCHAR" property="alarmEmail" />
+    <result column="exec_type" jdbcType="CHAR" property="execType" />
+    <result column="flow_cron" jdbcType="VARCHAR" property="flowCron" />
+    <result column="flow_desc" jdbcType="VARCHAR" property="flowDesc" />
+    <result column="flow_name" jdbcType="VARCHAR" property="flowName" />
+    <result column="flow_node_count" jdbcType="INTEGER" property="flowNodeCount" />
+    <result column="flow_timeout" jdbcType="BIGINT" property="flowTimeout" />
+    <result column="is_inner" jdbcType="CHAR" property="isInner" />
+    <result column="alarml_action" jdbcType="CHAR" property="alarmlAction" />
+    <result column="priority" jdbcType="CHAR" property="priority" />
+    <result column="trigger_next_time" jdbcType="BIGINT" property="triggerNextTime" />
+    <result column="workspace_id" jdbcType="INTEGER" property="workspaceId" />
+    <result column="author" jdbcType="VARCHAR" property="author" />
+    <result column="add_time" jdbcType="TIMESTAMP" property="addTime" />
+    <result column="start_up" jdbcType="CHAR" property="startUp" />
+    <result column="principal" jdbcType="VARCHAR" property="principal" />
+    <result column="version_name" jdbcType="VARCHAR" property="versionName" />
+    <result column="repeat_count" jdbcType="INTEGER" property="repeatCount" />
+    <result column="remaining_count" jdbcType="INTEGER" property="remainingCount" />
+    <result column="schedule_follow" jdbcType="CHAR" property="scheduleFollow" />
+    <result column="is_update" jdbcType="CHAR" property="isUpdate" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    flow_id, alarm_email, exec_type, flow_cron, flow_desc, flow_name, flow_node_count, 
+    flow_timeout, is_inner, alarml_action, priority, trigger_next_time, workspace_id, 
+    author, add_time, start_up, principal, version_name, repeat_count, remaining_count, 
+    schedule_follow, is_update
+  </sql>
+  <select id="getById" parameterType="java.lang.Integer" resultMap="BaseResultMap">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    select 
+    <include refid="Base_Column_List" />
+    from flow
+    where flow_id = #{flowId,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteById" parameterType="java.lang.Integer">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    delete from flow
+    where flow_id = #{flowId,jdbcType=INTEGER}
+  </delete>
+  <insert id="insert" parameterType="com.byit.model.Flow">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into flow (flow_id, alarm_email, exec_type, 
+      flow_cron, flow_desc, flow_name, 
+      flow_node_count, flow_timeout, is_inner, 
+      alarml_action, priority, trigger_next_time, 
+      workspace_id, author, add_time, 
+      start_up, principal, version_name, 
+      repeat_count, remaining_count, schedule_follow, 
+      is_update)
+    values (#{flowId,jdbcType=INTEGER}, #{alarmEmail,jdbcType=VARCHAR}, #{execType,jdbcType=CHAR}, 
+      #{flowCron,jdbcType=VARCHAR}, #{flowDesc,jdbcType=VARCHAR}, #{flowName,jdbcType=VARCHAR}, 
+      #{flowNodeCount,jdbcType=INTEGER}, #{flowTimeout,jdbcType=BIGINT}, #{isInner,jdbcType=CHAR}, 
+      #{alarmlAction,jdbcType=CHAR}, #{priority,jdbcType=CHAR}, #{triggerNextTime,jdbcType=BIGINT}, 
+      #{workspaceId,jdbcType=INTEGER}, #{author,jdbcType=VARCHAR}, #{addTime,jdbcType=TIMESTAMP}, 
+      #{startUp,jdbcType=CHAR}, #{principal,jdbcType=VARCHAR}, #{versionName,jdbcType=VARCHAR}, 
+      #{repeatCount,jdbcType=INTEGER}, #{remainingCount,jdbcType=INTEGER}, #{scheduleFollow,jdbcType=CHAR}, 
+      #{isUpdate,jdbcType=CHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.byit.model.Flow">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into flow
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="flowId != null">
+        flow_id,
+      </if>
+      <if test="alarmEmail != null">
+        alarm_email,
+      </if>
+      <if test="execType != null">
+        exec_type,
+      </if>
+      <if test="flowCron != null">
+        flow_cron,
+      </if>
+      <if test="flowDesc != null">
+        flow_desc,
+      </if>
+      <if test="flowName != null">
+        flow_name,
+      </if>
+      <if test="flowNodeCount != null">
+        flow_node_count,
+      </if>
+      <if test="flowTimeout != null">
+        flow_timeout,
+      </if>
+      <if test="isInner != null">
+        is_inner,
+      </if>
+      <if test="alarmlAction != null">
+        alarml_action,
+      </if>
+      <if test="priority != null">
+        priority,
+      </if>
+      <if test="triggerNextTime != null">
+        trigger_next_time,
+      </if>
+      <if test="workspaceId != null">
+        workspace_id,
+      </if>
+      <if test="author != null">
+        author,
+      </if>
+      <if test="addTime != null">
+        add_time,
+      </if>
+      <if test="startUp != null">
+        start_up,
+      </if>
+      <if test="principal != null">
+        principal,
+      </if>
+      <if test="versionName != null">
+        version_name,
+      </if>
+      <if test="repeatCount != null">
+        repeat_count,
+      </if>
+      <if test="remainingCount != null">
+        remaining_count,
+      </if>
+      <if test="scheduleFollow != null">
+        schedule_follow,
+      </if>
+      <if test="isUpdate != null">
+        is_update,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="flowId != null">
+        #{flowId,jdbcType=INTEGER},
+      </if>
+      <if test="alarmEmail != null">
+        #{alarmEmail,jdbcType=VARCHAR},
+      </if>
+      <if test="execType != null">
+        #{execType,jdbcType=CHAR},
+      </if>
+      <if test="flowCron != null">
+        #{flowCron,jdbcType=VARCHAR},
+      </if>
+      <if test="flowDesc != null">
+        #{flowDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="flowName != null">
+        #{flowName,jdbcType=VARCHAR},
+      </if>
+      <if test="flowNodeCount != null">
+        #{flowNodeCount,jdbcType=INTEGER},
+      </if>
+      <if test="flowTimeout != null">
+        #{flowTimeout,jdbcType=BIGINT},
+      </if>
+      <if test="isInner != null">
+        #{isInner,jdbcType=CHAR},
+      </if>
+      <if test="alarmlAction != null">
+        #{alarmlAction,jdbcType=CHAR},
+      </if>
+      <if test="priority != null">
+        #{priority,jdbcType=CHAR},
+      </if>
+      <if test="triggerNextTime != null">
+        #{triggerNextTime,jdbcType=BIGINT},
+      </if>
+      <if test="workspaceId != null">
+        #{workspaceId,jdbcType=INTEGER},
+      </if>
+      <if test="author != null">
+        #{author,jdbcType=VARCHAR},
+      </if>
+      <if test="addTime != null">
+        #{addTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="startUp != null">
+        #{startUp,jdbcType=CHAR},
+      </if>
+      <if test="principal != null">
+        #{principal,jdbcType=VARCHAR},
+      </if>
+      <if test="versionName != null">
+        #{versionName,jdbcType=VARCHAR},
+      </if>
+      <if test="repeatCount != null">
+        #{repeatCount,jdbcType=INTEGER},
+      </if>
+      <if test="remainingCount != null">
+        #{remainingCount,jdbcType=INTEGER},
+      </if>
+      <if test="scheduleFollow != null">
+        #{scheduleFollow,jdbcType=CHAR},
+      </if>
+      <if test="isUpdate != null">
+        #{isUpdate,jdbcType=CHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByIdSelective" parameterType="com.byit.model.Flow">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update flow
+    <set>
+      <if test="alarmEmail != null">
+        alarm_email = #{alarmEmail,jdbcType=VARCHAR},
+      </if>
+      <if test="execType != null">
+        exec_type = #{execType,jdbcType=CHAR},
+      </if>
+      <if test="flowCron != null">
+        flow_cron = #{flowCron,jdbcType=VARCHAR},
+      </if>
+      <if test="flowDesc != null">
+        flow_desc = #{flowDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="flowName != null">
+        flow_name = #{flowName,jdbcType=VARCHAR},
+      </if>
+      <if test="flowNodeCount != null">
+        flow_node_count = #{flowNodeCount,jdbcType=INTEGER},
+      </if>
+      <if test="flowTimeout != null">
+        flow_timeout = #{flowTimeout,jdbcType=BIGINT},
+      </if>
+      <if test="isInner != null">
+        is_inner = #{isInner,jdbcType=CHAR},
+      </if>
+      <if test="alarmlAction != null">
+        alarml_action = #{alarmlAction,jdbcType=CHAR},
+      </if>
+      <if test="priority != null">
+        priority = #{priority,jdbcType=CHAR},
+      </if>
+      <if test="triggerNextTime != null">
+        trigger_next_time = #{triggerNextTime,jdbcType=BIGINT},
+      </if>
+      <if test="workspaceId != null">
+        workspace_id = #{workspaceId,jdbcType=INTEGER},
+      </if>
+      <if test="author != null">
+        author = #{author,jdbcType=VARCHAR},
+      </if>
+      <if test="addTime != null">
+        add_time = #{addTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="startUp != null">
+        start_up = #{startUp,jdbcType=CHAR},
+      </if>
+      <if test="principal != null">
+        principal = #{principal,jdbcType=VARCHAR},
+      </if>
+      <if test="versionName != null">
+        version_name = #{versionName,jdbcType=VARCHAR},
+      </if>
+      <if test="repeatCount != null">
+        repeat_count = #{repeatCount,jdbcType=INTEGER},
+      </if>
+      <if test="remainingCount != null">
+        remaining_count = #{remainingCount,jdbcType=INTEGER},
+      </if>
+      <if test="scheduleFollow != null">
+        schedule_follow = #{scheduleFollow,jdbcType=CHAR},
+      </if>
+      <if test="isUpdate != null">
+        is_update = #{isUpdate,jdbcType=CHAR},
+      </if>
+    </set>
+    where flow_id = #{flowId,jdbcType=INTEGER}
+  </update>
+  <update id="updateById" parameterType="com.byit.model.Flow">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update flow
+    set alarm_email = #{alarmEmail,jdbcType=VARCHAR},
+      exec_type = #{execType,jdbcType=CHAR},
+      flow_cron = #{flowCron,jdbcType=VARCHAR},
+      flow_desc = #{flowDesc,jdbcType=VARCHAR},
+      flow_name = #{flowName,jdbcType=VARCHAR},
+      flow_node_count = #{flowNodeCount,jdbcType=INTEGER},
+      flow_timeout = #{flowTimeout,jdbcType=BIGINT},
+      is_inner = #{isInner,jdbcType=CHAR},
+      alarml_action = #{alarmlAction,jdbcType=CHAR},
+      priority = #{priority,jdbcType=CHAR},
+      trigger_next_time = #{triggerNextTime,jdbcType=BIGINT},
+      workspace_id = #{workspaceId,jdbcType=INTEGER},
+      author = #{author,jdbcType=VARCHAR},
+      add_time = #{addTime,jdbcType=TIMESTAMP},
+      start_up = #{startUp,jdbcType=CHAR},
+      principal = #{principal,jdbcType=VARCHAR},
+      version_name = #{versionName,jdbcType=VARCHAR},
+      repeat_count = #{repeatCount,jdbcType=INTEGER},
+      remaining_count = #{remainingCount,jdbcType=INTEGER},
+      schedule_follow = #{scheduleFollow,jdbcType=CHAR},
+      is_update = #{isUpdate,jdbcType=CHAR}
+    where flow_id = #{flowId,jdbcType=INTEGER}
+  </update>
+</mapper>
\ No newline at end of file

byit-myth-core/myth-admin-core/src/main/resources/mapper/FlowVersionMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.byit.mapper.FlowVersionMapper">
+  <resultMap id="BaseResultMap" type="com.byit.model.FlowVersion">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    <id column="flow_version_id" jdbcType="INTEGER" property="flowVersionId" />
+    <result column="add_time" jdbcType="TIMESTAMP" property="addTime" />
+    <result column="alarm_email" jdbcType="VARCHAR" property="alarmEmail" />
+    <result column="exec_type" jdbcType="CHAR" property="execType" />
+    <result column="flow_cron" jdbcType="VARCHAR" property="flowCron" />
+    <result column="flow_desc" jdbcType="VARCHAR" property="flowDesc" />
+    <result column="flow_id" jdbcType="INTEGER" property="flowId" />
+    <result column="flow_name" jdbcType="VARCHAR" property="flowName" />
+    <result column="flow_node_count" jdbcType="INTEGER" property="flowNodeCount" />
+    <result column="alarml_action" jdbcType="CHAR" property="alarmlAction" />
+    <result column="schedule_follow" jdbcType="CHAR" property="scheduleFollow" />
+    <result column="priority" jdbcType="CHAR" property="priority" />
+    <result column="remove_mark" jdbcType="CHAR" property="removeMark" />
+    <result column="repeat_count" jdbcType="INTEGER" property="repeatCount" />
+    <result column="version_mark" jdbcType="CHAR" property="versionMark" />
+    <result column="workspace_id" jdbcType="INTEGER" property="workspaceId" />
+    <result column="author" jdbcType="VARCHAR" property="author" />
+    <result column="principal" jdbcType="VARCHAR" property="principal" />
+    <result column="version_name" jdbcType="VARCHAR" property="versionName" />
+    <result column="is_inner" jdbcType="CHAR" property="isInner" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    flow_version_id, add_time, alarm_email, exec_type, flow_cron, flow_desc, flow_id, 
+    flow_name, flow_node_count, alarml_action, schedule_follow, priority, remove_mark, 
+    repeat_count, version_mark, workspace_id, author, principal, version_name, is_inner
+  </sql>
+  <select id="getById" parameterType="java.lang.Integer" resultMap="BaseResultMap">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    select 
+    <include refid="Base_Column_List" />
+    from flow_version
+    where flow_version_id = #{flowVersionId,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteById" parameterType="java.lang.Integer">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    delete from flow_version
+    where flow_version_id = #{flowVersionId,jdbcType=INTEGER}
+  </delete>
+  <insert id="insert" parameterType="com.byit.model.FlowVersion">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into flow_version (flow_version_id, add_time, alarm_email, 
+      exec_type, flow_cron, flow_desc, 
+      flow_id, flow_name, flow_node_count, 
+      alarml_action, schedule_follow, priority, 
+      remove_mark, repeat_count, version_mark, 
+      workspace_id, author, principal, 
+      version_name, is_inner)
+    values (#{flowVersionId,jdbcType=INTEGER}, #{addTime,jdbcType=TIMESTAMP}, #{alarmEmail,jdbcType=VARCHAR}, 
+      #{execType,jdbcType=CHAR}, #{flowCron,jdbcType=VARCHAR}, #{flowDesc,jdbcType=VARCHAR}, 
+      #{flowId,jdbcType=INTEGER}, #{flowName,jdbcType=VARCHAR}, #{flowNodeCount,jdbcType=INTEGER}, 
+      #{alarmlAction,jdbcType=CHAR}, #{scheduleFollow,jdbcType=CHAR}, #{priority,jdbcType=CHAR}, 
+      #{removeMark,jdbcType=CHAR}, #{repeatCount,jdbcType=INTEGER}, #{versionMark,jdbcType=CHAR}, 
+      #{workspaceId,jdbcType=INTEGER}, #{author,jdbcType=VARCHAR}, #{principal,jdbcType=VARCHAR}, 
+      #{versionName,jdbcType=VARCHAR}, #{isInner,jdbcType=CHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.byit.model.FlowVersion">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into flow_version
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="flowVersionId != null">
+        flow_version_id,
+      </if>
+      <if test="addTime != null">
+        add_time,
+      </if>
+      <if test="alarmEmail != null">
+        alarm_email,
+      </if>
+      <if test="execType != null">
+        exec_type,
+      </if>
+      <if test="flowCron != null">
+        flow_cron,
+      </if>
+      <if test="flowDesc != null">
+        flow_desc,
+      </if>
+      <if test="flowId != null">
+        flow_id,
+      </if>
+      <if test="flowName != null">
+        flow_name,
+      </if>
+      <if test="flowNodeCount != null">
+        flow_node_count,
+      </if>
+      <if test="alarmlAction != null">
+        alarml_action,
+      </if>
+      <if test="scheduleFollow != null">
+        schedule_follow,
+      </if>
+      <if test="priority != null">
+        priority,
+      </if>
+      <if test="removeMark != null">
+        remove_mark,
+      </if>
+      <if test="repeatCount != null">
+        repeat_count,
+      </if>
+      <if test="versionMark != null">
+        version_mark,
+      </if>
+      <if test="workspaceId != null">
+        workspace_id,
+      </if>
+      <if test="author != null">
+        author,
+      </if>
+      <if test="principal != null">
+        principal,
+      </if>
+      <if test="versionName != null">
+        version_name,
+      </if>
+      <if test="isInner != null">
+        is_inner,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="flowVersionId != null">
+        #{flowVersionId,jdbcType=INTEGER},
+      </if>
+      <if test="addTime != null">
+        #{addTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="alarmEmail != null">
+        #{alarmEmail,jdbcType=VARCHAR},
+      </if>
+      <if test="execType != null">
+        #{execType,jdbcType=CHAR},
+      </if>
+      <if test="flowCron != null">
+        #{flowCron,jdbcType=VARCHAR},
+      </if>
+      <if test="flowDesc != null">
+        #{flowDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="flowId != null">
+        #{flowId,jdbcType=INTEGER},
+      </if>
+      <if test="flowName != null">
+        #{flowName,jdbcType=VARCHAR},
+      </if>
+      <if test="flowNodeCount != null">
+        #{flowNodeCount,jdbcType=INTEGER},
+      </if>
+      <if test="alarmlAction != null">
+        #{alarmlAction,jdbcType=CHAR},
+      </if>
+      <if test="scheduleFollow != null">
+        #{scheduleFollow,jdbcType=CHAR},
+      </if>
+      <if test="priority != null">
+        #{priority,jdbcType=CHAR},
+      </if>
+      <if test="removeMark != null">
+        #{removeMark,jdbcType=CHAR},
+      </if>
+      <if test="repeatCount != null">
+        #{repeatCount,jdbcType=INTEGER},
+      </if>
+      <if test="versionMark != null">
+        #{versionMark,jdbcType=CHAR},
+      </if>
+      <if test="workspaceId != null">
+        #{workspaceId,jdbcType=INTEGER},
+      </if>
+      <if test="author != null">
+        #{author,jdbcType=VARCHAR},
+      </if>
+      <if test="principal != null">
+        #{principal,jdbcType=VARCHAR},
+      </if>
+      <if test="versionName != null">
+        #{versionName,jdbcType=VARCHAR},
+      </if>
+      <if test="isInner != null">
+        #{isInner,jdbcType=CHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByIdSelective" parameterType="com.byit.model.FlowVersion">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update flow_version
+    <set>
+      <if test="addTime != null">
+        add_time = #{addTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="alarmEmail != null">
+        alarm_email = #{alarmEmail,jdbcType=VARCHAR},
+      </if>
+      <if test="execType != null">
+        exec_type = #{execType,jdbcType=CHAR},
+      </if>
+      <if test="flowCron != null">
+        flow_cron = #{flowCron,jdbcType=VARCHAR},
+      </if>
+      <if test="flowDesc != null">
+        flow_desc = #{flowDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="flowId != null">
+        flow_id = #{flowId,jdbcType=INTEGER},
+      </if>
+      <if test="flowName != null">
+        flow_name = #{flowName,jdbcType=VARCHAR},
+      </if>
+      <if test="flowNodeCount != null">
+        flow_node_count = #{flowNodeCount,jdbcType=INTEGER},
+      </if>
+      <if test="alarmlAction != null">
+        alarml_action = #{alarmlAction,jdbcType=CHAR},
+      </if>
+      <if test="scheduleFollow != null">
+        schedule_follow = #{scheduleFollow,jdbcType=CHAR},
+      </if>
+      <if test="priority != null">
+        priority = #{priority,jdbcType=CHAR},
+      </if>
+      <if test="removeMark != null">
+        remove_mark = #{removeMark,jdbcType=CHAR},
+      </if>
+      <if test="repeatCount != null">
+        repeat_count = #{repeatCount,jdbcType=INTEGER},
+      </if>
+      <if test="versionMark != null">
+        version_mark = #{versionMark,jdbcType=CHAR},
+      </if>
+      <if test="workspaceId != null">
+        workspace_id = #{workspaceId,jdbcType=INTEGER},
+      </if>
+      <if test="author != null">
+        author = #{author,jdbcType=VARCHAR},
+      </if>
+      <if test="principal != null">
+        principal = #{principal,jdbcType=VARCHAR},
+      </if>
+      <if test="versionName != null">
+        version_name = #{versionName,jdbcType=VARCHAR},
+      </if>
+      <if test="isInner != null">
+        is_inner = #{isInner,jdbcType=CHAR},
+      </if>
+    </set>
+    where flow_version_id = #{flowVersionId,jdbcType=INTEGER}
+  </update>
+  <update id="updateById" parameterType="com.byit.model.FlowVersion">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update flow_version
+    set add_time = #{addTime,jdbcType=TIMESTAMP},
+      alarm_email = #{alarmEmail,jdbcType=VARCHAR},
+      exec_type = #{execType,jdbcType=CHAR},
+      flow_cron = #{flowCron,jdbcType=VARCHAR},
+      flow_desc = #{flowDesc,jdbcType=VARCHAR},
+      flow_id = #{flowId,jdbcType=INTEGER},
+      flow_name = #{flowName,jdbcType=VARCHAR},
+      flow_node_count = #{flowNodeCount,jdbcType=INTEGER},
+      alarml_action = #{alarmlAction,jdbcType=CHAR},
+      schedule_follow = #{scheduleFollow,jdbcType=CHAR},
+      priority = #{priority,jdbcType=CHAR},
+      remove_mark = #{removeMark,jdbcType=CHAR},
+      repeat_count = #{repeatCount,jdbcType=INTEGER},
+      version_mark = #{versionMark,jdbcType=CHAR},
+      workspace_id = #{workspaceId,jdbcType=INTEGER},
+      author = #{author,jdbcType=VARCHAR},
+      principal = #{principal,jdbcType=VARCHAR},
+      version_name = #{versionName,jdbcType=VARCHAR},
+      is_inner = #{isInner,jdbcType=CHAR}
+    where flow_version_id = #{flowVersionId,jdbcType=INTEGER}
+  </update>
+</mapper>
\ No newline at end of file

byit-myth-core/myth-admin-core/src/main/resources/mapper/NodeDependencyMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.byit.mapper.NodeDependencyMapper">
+  <resultMap id="BaseResultMap" type="com.byit.model.NodeDependencyKey">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    <id column="node_id" jdbcType="INTEGER" property="nodeId" />
+    <id column="dependency_id" jdbcType="INTEGER" property="dependencyId" />
+  </resultMap>
+  <delete id="deleteById" parameterType="com.byit.model.NodeDependencyKey">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    delete from node_dependency
+    where node_id = #{nodeId,jdbcType=INTEGER}
+      and dependency_id = #{dependencyId,jdbcType=INTEGER}
+  </delete>
+  <insert id="insert" parameterType="com.byit.model.NodeDependencyKey">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into node_dependency (node_id, dependency_id)
+    values (#{nodeId,jdbcType=INTEGER}, #{dependencyId,jdbcType=INTEGER})
+  </insert>
+  <insert id="insertSelective" parameterType="com.byit.model.NodeDependencyKey">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into node_dependency
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="nodeId != null">
+        node_id,
+      </if>
+      <if test="dependencyId != null">
+        dependency_id,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="nodeId != null">
+        #{nodeId,jdbcType=INTEGER},
+      </if>
+      <if test="dependencyId != null">
+        #{dependencyId,jdbcType=INTEGER},
+      </if>
+    </trim>
+  </insert>
+</mapper>
\ No newline at end of file

byit-myth-core/myth-admin-core/src/main/resources/mapper/NodeMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.byit.mapper.NodeMapper">
+  <resultMap id="BaseResultMap" type="com.byit.model.Node">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    <id column="node_id" jdbcType="INTEGER" property="nodeId" />
+    <result column="block_strategy" jdbcType="VARCHAR" property="blockStrategy" />
+    <result column="plugin_token" jdbcType="VARCHAR" property="pluginToken" />
+    <result column="failed_retry_count" jdbcType="INTEGER" property="failedRetryCount" />
+    <result column="flow_id" jdbcType="INTEGER" property="flowId" />
+    <result column="gateway_token" jdbcType="VARCHAR" property="gatewayToken" />
+    <result column="job_type" jdbcType="VARCHAR" property="jobType" />
+    <result column="handler_name" jdbcType="VARCHAR" property="handlerName" />
+    <result column="node_cron" jdbcType="VARCHAR" property="nodeCron" />
+    <result column="node_desc" jdbcType="VARCHAR" property="nodeDesc" />
+    <result column="node_name" jdbcType="VARCHAR" property="nodeName" />
+    <result column="map_flow_id" jdbcType="INTEGER" property="mapFlowId" />
+    <result column="node_timeout" jdbcType="BIGINT" property="nodeTimeout" />
+    <result column="is_virtual" jdbcType="CHAR" property="isVirtual" />
+    <result column="plugin_urls" jdbcType="VARCHAR" property="pluginUrls" />
+    <result column="priority" jdbcType="CHAR" property="priority" />
+    <result column="remaining_count" jdbcType="INTEGER" property="remainingCount" />
+    <result column="repeat_count" jdbcType="INTEGER" property="repeatCount" />
+    <result column="failed_retry_interval" jdbcType="BIGINT" property="failedRetryInterval" />
+    <result column="routing_strategy" jdbcType="VARCHAR" property="routingStrategy" />
+    <result column="run_param" jdbcType="VARCHAR" property="runParam" />
+    <result column="run_source_desc" jdbcType="VARCHAR" property="runSourceDesc" />
+    <result column="script_urls" jdbcType="VARCHAR" property="scriptUrls" />
+    <result column="source_principal" jdbcType="VARCHAR" property="sourcePrincipal" />
+    <result column="source_update_time" jdbcType="DATE" property="sourceUpdateTime" />
+    <result column="trigger_next_time" jdbcType="BIGINT" property="triggerNextTime" />
+    <result column="author" jdbcType="VARCHAR" property="author" />
+    <result column="add_time" jdbcType="TIMESTAMP" property="addTime" />
+    <result column="version_name" jdbcType="VARCHAR" property="versionName" />
+    <result column="on_fork" jdbcType="CHAR" property="onFork" />
+    <result column="run_command" jdbcType="VARCHAR" property="runCommand" />
+  </resultMap>
+  <resultMap extends="BaseResultMap" id="ResultMapWithBLOBs" type="com.byit.model.Node">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    <result column="run_source" jdbcType="LONGVARCHAR" property="runSource" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    node_id, block_strategy, plugin_token, failed_retry_count, flow_id, gateway_token, 
+    job_type, handler_name, node_cron, node_desc, node_name, map_flow_id, node_timeout, 
+    is_virtual, plugin_urls, priority, remaining_count, repeat_count, failed_retry_interval, 
+    routing_strategy, run_param, run_source_desc, script_urls, source_principal, source_update_time, 
+    trigger_next_time, author, add_time, version_name, on_fork, run_command
+  </sql>
+  <sql id="Blob_Column_List">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    run_source
+  </sql>
+  <select id="getById" parameterType="java.lang.Integer" resultMap="ResultMapWithBLOBs">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    select 
+    <include refid="Base_Column_List" />
+    ,
+    <include refid="Blob_Column_List" />
+    from node
+    where node_id = #{nodeId,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteById" parameterType="java.lang.Integer">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    delete from node
+    where node_id = #{nodeId,jdbcType=INTEGER}
+  </delete>
+  <insert id="insert" parameterType="com.byit.model.Node">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into node (node_id, block_strategy, plugin_token, 
+      failed_retry_count, flow_id, gateway_token, 
+      job_type, handler_name, node_cron, 
+      node_desc, node_name, map_flow_id, 
+      node_timeout, is_virtual, plugin_urls, 
+      priority, remaining_count, repeat_count, 
+      failed_retry_interval, routing_strategy, run_param, 
+      run_source_desc, script_urls, source_principal, 
+      source_update_time, trigger_next_time, author, 
+      add_time, version_name, on_fork, 
+      run_command, run_source)
+    values (#{nodeId,jdbcType=INTEGER}, #{blockStrategy,jdbcType=VARCHAR}, #{pluginToken,jdbcType=VARCHAR}, 
+      #{failedRetryCount,jdbcType=INTEGER}, #{flowId,jdbcType=INTEGER}, #{gatewayToken,jdbcType=VARCHAR}, 
+      #{jobType,jdbcType=VARCHAR}, #{handlerName,jdbcType=VARCHAR}, #{nodeCron,jdbcType=VARCHAR}, 
+      #{nodeDesc,jdbcType=VARCHAR}, #{nodeName,jdbcType=VARCHAR}, #{mapFlowId,jdbcType=INTEGER}, 
+      #{nodeTimeout,jdbcType=BIGINT}, #{isVirtual,jdbcType=CHAR}, #{pluginUrls,jdbcType=VARCHAR}, 
+      #{priority,jdbcType=CHAR}, #{remainingCount,jdbcType=INTEGER}, #{repeatCount,jdbcType=INTEGER}, 
+      #{failedRetryInterval,jdbcType=BIGINT}, #{routingStrategy,jdbcType=VARCHAR}, #{runParam,jdbcType=VARCHAR}, 
+      #{runSourceDesc,jdbcType=VARCHAR}, #{scriptUrls,jdbcType=VARCHAR}, #{sourcePrincipal,jdbcType=VARCHAR}, 
+      #{sourceUpdateTime,jdbcType=DATE}, #{triggerNextTime,jdbcType=BIGINT}, #{author,jdbcType=VARCHAR}, 
+      #{addTime,jdbcType=TIMESTAMP}, #{versionName,jdbcType=VARCHAR}, #{onFork,jdbcType=CHAR}, 
+      #{runCommand,jdbcType=VARCHAR}, #{runSource,jdbcType=LONGVARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.byit.model.Node">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into node
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="nodeId != null">
+        node_id,
+      </if>
+      <if test="blockStrategy != null">
+        block_strategy,
+      </if>
+      <if test="pluginToken != null">
+        plugin_token,
+      </if>
+      <if test="failedRetryCount != null">
+        failed_retry_count,
+      </if>
+      <if test="flowId != null">
+        flow_id,
+      </if>
+      <if test="gatewayToken != null">
+        gateway_token,
+      </if>
+      <if test="jobType != null">
+        job_type,
+      </if>
+      <if test="handlerName != null">
+        handler_name,
+      </if>
+      <if test="nodeCron != null">
+        node_cron,
+      </if>
+      <if test="nodeDesc != null">
+        node_desc,
+      </if>
+      <if test="nodeName != null">
+        node_name,
+      </if>
+      <if test="mapFlowId != null">
+        map_flow_id,
+      </if>
+      <if test="nodeTimeout != null">
+        node_timeout,
+      </if>
+      <if test="isVirtual != null">
+        is_virtual,
+      </if>
+      <if test="pluginUrls != null">
+        plugin_urls,
+      </if>
+      <if test="priority != null">
+        priority,
+      </if>
+      <if test="remainingCount != null">
+        remaining_count,
+      </if>
+      <if test="repeatCount != null">
+        repeat_count,
+      </if>
+      <if test="failedRetryInterval != null">
+        failed_retry_interval,
+      </if>
+      <if test="routingStrategy != null">
+        routing_strategy,
+      </if>
+      <if test="runParam != null">
+        run_param,
+      </if>
+      <if test="runSourceDesc != null">
+        run_source_desc,
+      </if>
+      <if test="scriptUrls != null">
+        script_urls,
+      </if>
+      <if test="sourcePrincipal != null">
+        source_principal,
+      </if>
+      <if test="sourceUpdateTime != null">
+        source_update_time,
+      </if>
+      <if test="triggerNextTime != null">
+        trigger_next_time,
+      </if>
+      <if test="author != null">
+        author,
+      </if>
+      <if test="addTime != null">
+        add_time,
+      </if>
+      <if test="versionName != null">
+        version_name,
+      </if>
+      <if test="onFork != null">
+        on_fork,
+      </if>
+      <if test="runCommand != null">
+        run_command,
+      </if>
+      <if test="runSource != null">
+        run_source,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="nodeId != null">
+        #{nodeId,jdbcType=INTEGER},
+      </if>
+      <if test="blockStrategy != null">
+        #{blockStrategy,jdbcType=VARCHAR},
+      </if>
+      <if test="pluginToken != null">
+        #{pluginToken,jdbcType=VARCHAR},
+      </if>
+      <if test="failedRetryCount != null">
+        #{failedRetryCount,jdbcType=INTEGER},
+      </if>
+      <if test="flowId != null">
+        #{flowId,jdbcType=INTEGER},
+      </if>
+      <if test="gatewayToken != null">
+        #{gatewayToken,jdbcType=VARCHAR},
+      </if>
+      <if test="jobType != null">
+        #{jobType,jdbcType=VARCHAR},
+      </if>
+      <if test="handlerName != null">
+        #{handlerName,jdbcType=VARCHAR},
+      </if>
+      <if test="nodeCron != null">
+        #{nodeCron,jdbcType=VARCHAR},
+      </if>
+      <if test="nodeDesc != null">
+        #{nodeDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="nodeName != null">
+        #{nodeName,jdbcType=VARCHAR},
+      </if>
+      <if test="mapFlowId != null">
+        #{mapFlowId,jdbcType=INTEGER},
+      </if>
+      <if test="nodeTimeout != null">
+        #{nodeTimeout,jdbcType=BIGINT},
+      </if>
+      <if test="isVirtual != null">
+        #{isVirtual,jdbcType=CHAR},
+      </if>
+      <if test="pluginUrls != null">
+        #{pluginUrls,jdbcType=VARCHAR},
+      </if>
+      <if test="priority != null">
+        #{priority,jdbcType=CHAR},
+      </if>
+      <if test="remainingCount != null">
+        #{remainingCount,jdbcType=INTEGER},
+      </if>
+      <if test="repeatCount != null">
+        #{repeatCount,jdbcType=INTEGER},
+      </if>
+      <if test="failedRetryInterval != null">
+        #{failedRetryInterval,jdbcType=BIGINT},
+      </if>
+      <if test="routingStrategy != null">
+        #{routingStrategy,jdbcType=VARCHAR},
+      </if>
+      <if test="runParam != null">
+        #{runParam,jdbcType=VARCHAR},
+      </if>
+      <if test="runSourceDesc != null">
+        #{runSourceDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="scriptUrls != null">
+        #{scriptUrls,jdbcType=VARCHAR},
+      </if>
+      <if test="sourcePrincipal != null">
+        #{sourcePrincipal,jdbcType=VARCHAR},
+      </if>
+      <if test="sourceUpdateTime != null">
+        #{sourceUpdateTime,jdbcType=DATE},
+      </if>
+      <if test="triggerNextTime != null">
+        #{triggerNextTime,jdbcType=BIGINT},
+      </if>
+      <if test="author != null">
+        #{author,jdbcType=VARCHAR},
+      </if>
+      <if test="addTime != null">
+        #{addTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="versionName != null">
+        #{versionName,jdbcType=VARCHAR},
+      </if>
+      <if test="onFork != null">
+        #{onFork,jdbcType=CHAR},
+      </if>
+      <if test="runCommand != null">
+        #{runCommand,jdbcType=VARCHAR},
+      </if>
+      <if test="runSource != null">
+        #{runSource,jdbcType=LONGVARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByIdSelective" parameterType="com.byit.model.Node">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update node
+    <set>
+      <if test="blockStrategy != null">
+        block_strategy = #{blockStrategy,jdbcType=VARCHAR},
+      </if>
+      <if test="pluginToken != null">
+        plugin_token = #{pluginToken,jdbcType=VARCHAR},
+      </if>
+      <if test="failedRetryCount != null">
+        failed_retry_count = #{failedRetryCount,jdbcType=INTEGER},
+      </if>
+      <if test="flowId != null">
+        flow_id = #{flowId,jdbcType=INTEGER},
+      </if>
+      <if test="gatewayToken != null">
+        gateway_token = #{gatewayToken,jdbcType=VARCHAR},
+      </if>
+      <if test="jobType != null">
+        job_type = #{jobType,jdbcType=VARCHAR},
+      </if>
+      <if test="handlerName != null">
+        handler_name = #{handlerName,jdbcType=VARCHAR},
+      </if>
+      <if test="nodeCron != null">
+        node_cron = #{nodeCron,jdbcType=VARCHAR},
+      </if>
+      <if test="nodeDesc != null">
+        node_desc = #{nodeDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="nodeName != null">
+        node_name = #{nodeName,jdbcType=VARCHAR},
+      </if>
+      <if test="mapFlowId != null">
+        map_flow_id = #{mapFlowId,jdbcType=INTEGER},
+      </if>
+      <if test="nodeTimeout != null">
+        node_timeout = #{nodeTimeout,jdbcType=BIGINT},
+      </if>
+      <if test="isVirtual != null">
+        is_virtual = #{isVirtual,jdbcType=CHAR},
+      </if>
+      <if test="pluginUrls != null">
+        plugin_urls = #{pluginUrls,jdbcType=VARCHAR},
+      </if>
+      <if test="priority != null">
+        priority = #{priority,jdbcType=CHAR},
+      </if>
+      <if test="remainingCount != null">
+        remaining_count = #{remainingCount,jdbcType=INTEGER},
+      </if>
+      <if test="repeatCount != null">
+        repeat_count = #{repeatCount,jdbcType=INTEGER},
+      </if>
+      <if test="failedRetryInterval != null">
+        failed_retry_interval = #{failedRetryInterval,jdbcType=BIGINT},
+      </if>
+      <if test="routingStrategy != null">
+        routing_strategy = #{routingStrategy,jdbcType=VARCHAR},
+      </if>
+      <if test="runParam != null">
+        run_param = #{runParam,jdbcType=VARCHAR},
+      </if>
+      <if test="runSourceDesc != null">
+        run_source_desc = #{runSourceDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="scriptUrls != null">
+        script_urls = #{scriptUrls,jdbcType=VARCHAR},
+      </if>
+      <if test="sourcePrincipal != null">
+        source_principal = #{sourcePrincipal,jdbcType=VARCHAR},
+      </if>
+      <if test="sourceUpdateTime != null">
+        source_update_time = #{sourceUpdateTime,jdbcType=DATE},
+      </if>
+      <if test="triggerNextTime != null">
+        trigger_next_time = #{triggerNextTime,jdbcType=BIGINT},
+      </if>
+      <if test="author != null">
+        author = #{author,jdbcType=VARCHAR},
+      </if>
+      <if test="addTime != null">
+        add_time = #{addTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="versionName != null">
+        version_name = #{versionName,jdbcType=VARCHAR},
+      </if>
+      <if test="onFork != null">
+        on_fork = #{onFork,jdbcType=CHAR},
+      </if>
+      <if test="runCommand != null">
+        run_command = #{runCommand,jdbcType=VARCHAR},
+      </if>
+      <if test="runSource != null">
+        run_source = #{runSource,jdbcType=LONGVARCHAR},
+      </if>
+    </set>
+    where node_id = #{nodeId,jdbcType=INTEGER}
+  </update>
+  <update id="updateByPrimaryKeyWithBLOBs" parameterType="com.byit.model.Node">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update node
+    set block_strategy = #{blockStrategy,jdbcType=VARCHAR},
+      plugin_token = #{pluginToken,jdbcType=VARCHAR},
+      failed_retry_count = #{failedRetryCount,jdbcType=INTEGER},
+      flow_id = #{flowId,jdbcType=INTEGER},
+      gateway_token = #{gatewayToken,jdbcType=VARCHAR},
+      job_type = #{jobType,jdbcType=VARCHAR},
+      handler_name = #{handlerName,jdbcType=VARCHAR},
+      node_cron = #{nodeCron,jdbcType=VARCHAR},
+      node_desc = #{nodeDesc,jdbcType=VARCHAR},
+      node_name = #{nodeName,jdbcType=VARCHAR},
+      map_flow_id = #{mapFlowId,jdbcType=INTEGER},
+      node_timeout = #{nodeTimeout,jdbcType=BIGINT},
+      is_virtual = #{isVirtual,jdbcType=CHAR},
+      plugin_urls = #{pluginUrls,jdbcType=VARCHAR},
+      priority = #{priority,jdbcType=CHAR},
+      remaining_count = #{remainingCount,jdbcType=INTEGER},
+      repeat_count = #{repeatCount,jdbcType=INTEGER},
+      failed_retry_interval = #{failedRetryInterval,jdbcType=BIGINT},
+      routing_strategy = #{routingStrategy,jdbcType=VARCHAR},
+      run_param = #{runParam,jdbcType=VARCHAR},
+      run_source_desc = #{runSourceDesc,jdbcType=VARCHAR},
+      script_urls = #{scriptUrls,jdbcType=VARCHAR},
+      source_principal = #{sourcePrincipal,jdbcType=VARCHAR},
+      source_update_time = #{sourceUpdateTime,jdbcType=DATE},
+      trigger_next_time = #{triggerNextTime,jdbcType=BIGINT},
+      author = #{author,jdbcType=VARCHAR},
+      add_time = #{addTime,jdbcType=TIMESTAMP},
+      version_name = #{versionName,jdbcType=VARCHAR},
+      on_fork = #{onFork,jdbcType=CHAR},
+      run_command = #{runCommand,jdbcType=VARCHAR},
+      run_source = #{runSource,jdbcType=LONGVARCHAR}
+    where node_id = #{nodeId,jdbcType=INTEGER}
+  </update>
+  <update id="updateById" parameterType="com.byit.model.Node">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update node
+    set block_strategy = #{blockStrategy,jdbcType=VARCHAR},
+      plugin_token = #{pluginToken,jdbcType=VARCHAR},
+      failed_retry_count = #{failedRetryCount,jdbcType=INTEGER},
+      flow_id = #{flowId,jdbcType=INTEGER},
+      gateway_token = #{gatewayToken,jdbcType=VARCHAR},
+      job_type = #{jobType,jdbcType=VARCHAR},
+      handler_name = #{handlerName,jdbcType=VARCHAR},
+      node_cron = #{nodeCron,jdbcType=VARCHAR},
+      node_desc = #{nodeDesc,jdbcType=VARCHAR},
+      node_name = #{nodeName,jdbcType=VARCHAR},
+      map_flow_id = #{mapFlowId,jdbcType=INTEGER},
+      node_timeout = #{nodeTimeout,jdbcType=BIGINT},
+      is_virtual = #{isVirtual,jdbcType=CHAR},
+      plugin_urls = #{pluginUrls,jdbcType=VARCHAR},
+      priority = #{priority,jdbcType=CHAR},
+      remaining_count = #{remainingCount,jdbcType=INTEGER},
+      repeat_count = #{repeatCount,jdbcType=INTEGER},
+      failed_retry_interval = #{failedRetryInterval,jdbcType=BIGINT},
+      routing_strategy = #{routingStrategy,jdbcType=VARCHAR},
+      run_param = #{runParam,jdbcType=VARCHAR},
+      run_source_desc = #{runSourceDesc,jdbcType=VARCHAR},
+      script_urls = #{scriptUrls,jdbcType=VARCHAR},
+      source_principal = #{sourcePrincipal,jdbcType=VARCHAR},
+      source_update_time = #{sourceUpdateTime,jdbcType=DATE},
+      trigger_next_time = #{triggerNextTime,jdbcType=BIGINT},
+      author = #{author,jdbcType=VARCHAR},
+      add_time = #{addTime,jdbcType=TIMESTAMP},
+      version_name = #{versionName,jdbcType=VARCHAR},
+      on_fork = #{onFork,jdbcType=CHAR},
+      run_command = #{runCommand,jdbcType=VARCHAR}
+    where node_id = #{nodeId,jdbcType=INTEGER}
+  </update>
+</mapper>
\ No newline at end of file

byit-myth-core/myth-admin-core/src/main/resources/mapper/NodeVersionMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.byit.mapper.NodeVersionMapper">
+  <resultMap id="BaseResultMap" type="com.byit.model.NodeVersion">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    <id column="node_version_id" jdbcType="INTEGER" property="nodeVersionId" />
+    <result column="node_id" jdbcType="INTEGER" property="nodeId" />
+    <result column="block_strategy" jdbcType="VARCHAR" property="blockStrategy" />
+    <result column="pugin_token" jdbcType="VARCHAR" property="puginToken" />
+    <result column="failed_retry_count" jdbcType="INTEGER" property="failedRetryCount" />
+    <result column="flow_id" jdbcType="INTEGER" property="flowId" />
+    <result column="flow_version_id" jdbcType="INTEGER" property="flowVersionId" />
+    <result column="gateway_token" jdbcType="VARCHAR" property="gatewayToken" />
+    <result column="job_type" jdbcType="VARCHAR" property="jobType" />
+    <result column="handler_name" jdbcType="VARCHAR" property="handlerName" />
+    <result column="node_cron" jdbcType="VARCHAR" property="nodeCron" />
+    <result column="node_desc" jdbcType="VARCHAR" property="nodeDesc" />
+    <result column="node_name" jdbcType="VARCHAR" property="nodeName" />
+    <result column="map_flow_id" jdbcType="INTEGER" property="mapFlowId" />
+    <result column="node_timeout" jdbcType="BIGINT" property="nodeTimeout" />
+    <result column="is_virtual" jdbcType="VARCHAR" property="isVirtual" />
+    <result column="plugin_urls" jdbcType="VARCHAR" property="pluginUrls" />
+    <result column="priority" jdbcType="CHAR" property="priority" />
+    <result column="remove_mark" jdbcType="CHAR" property="removeMark" />
+    <result column="repeat_count" jdbcType="INTEGER" property="repeatCount" />
+    <result column="failed_retry_interval" jdbcType="BIGINT" property="failedRetryInterval" />
+    <result column="routing_strategy" jdbcType="VARCHAR" property="routingStrategy" />
+    <result column="run_param" jdbcType="VARCHAR" property="runParam" />
+    <result column="run_source_desc" jdbcType="VARCHAR" property="runSourceDesc" />
+    <result column="script_urls" jdbcType="VARCHAR" property="scriptUrls" />
+    <result column="source_principal" jdbcType="VARCHAR" property="sourcePrincipal" />
+    <result column="source_update_time" jdbcType="TIMESTAMP" property="sourceUpdateTime" />
+    <result column="version_mark" jdbcType="VARCHAR" property="versionMark" />
+    <result column="author" jdbcType="VARCHAR" property="author" />
+    <result column="add_time" jdbcType="TIMESTAMP" property="addTime" />
+    <result column="version_name" jdbcType="VARCHAR" property="versionName" />
+    <result column="on_fork" jdbcType="CHAR" property="onFork" />
+    <result column="run_command" jdbcType="VARCHAR" property="runCommand" />
+  </resultMap>
+  <resultMap extends="BaseResultMap" id="ResultMapWithBLOBs" type="com.byit.model.NodeVersion">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    <result column="run_source" jdbcType="LONGVARCHAR" property="runSource" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    node_version_id, node_id, block_strategy, pugin_token, failed_retry_count, flow_id, 
+    flow_version_id, gateway_token, job_type, handler_name, node_cron, node_desc, node_name, 
+    map_flow_id, node_timeout, is_virtual, plugin_urls, priority, remove_mark, repeat_count, 
+    failed_retry_interval, routing_strategy, run_param, run_source_desc, script_urls, 
+    source_principal, source_update_time, version_mark, author, add_time, version_name, 
+    on_fork, run_command
+  </sql>
+  <sql id="Blob_Column_List">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    run_source
+  </sql>
+  <select id="getById" parameterType="java.lang.Integer" resultMap="ResultMapWithBLOBs">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    select 
+    <include refid="Base_Column_List" />
+    ,
+    <include refid="Blob_Column_List" />
+    from node_version
+    where node_version_id = #{nodeVersionId,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteById" parameterType="java.lang.Integer">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    delete from node_version
+    where node_version_id = #{nodeVersionId,jdbcType=INTEGER}
+  </delete>
+  <insert id="insert" parameterType="com.byit.model.NodeVersion">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into node_version (node_version_id, node_id, block_strategy, 
+      pugin_token, failed_retry_count, flow_id, 
+      flow_version_id, gateway_token, job_type, 
+      handler_name, node_cron, node_desc, 
+      node_name, map_flow_id, node_timeout, 
+      is_virtual, plugin_urls, priority, 
+      remove_mark, repeat_count, failed_retry_interval, 
+      routing_strategy, run_param, run_source_desc, 
+      script_urls, source_principal, source_update_time, 
+      version_mark, author, add_time, 
+      version_name, on_fork, run_command, 
+      run_source)
+    values (#{nodeVersionId,jdbcType=INTEGER}, #{nodeId,jdbcType=INTEGER}, #{blockStrategy,jdbcType=VARCHAR}, 
+      #{puginToken,jdbcType=VARCHAR}, #{failedRetryCount,jdbcType=INTEGER}, #{flowId,jdbcType=INTEGER}, 
+      #{flowVersionId,jdbcType=INTEGER}, #{gatewayToken,jdbcType=VARCHAR}, #{jobType,jdbcType=VARCHAR}, 
+      #{handlerName,jdbcType=VARCHAR}, #{nodeCron,jdbcType=VARCHAR}, #{nodeDesc,jdbcType=VARCHAR}, 
+      #{nodeName,jdbcType=VARCHAR}, #{mapFlowId,jdbcType=INTEGER}, #{nodeTimeout,jdbcType=BIGINT}, 
+      #{isVirtual,jdbcType=VARCHAR}, #{pluginUrls,jdbcType=VARCHAR}, #{priority,jdbcType=CHAR}, 
+      #{removeMark,jdbcType=CHAR}, #{repeatCount,jdbcType=INTEGER}, #{failedRetryInterval,jdbcType=BIGINT}, 
+      #{routingStrategy,jdbcType=VARCHAR}, #{runParam,jdbcType=VARCHAR}, #{runSourceDesc,jdbcType=VARCHAR}, 
+      #{scriptUrls,jdbcType=VARCHAR}, #{sourcePrincipal,jdbcType=VARCHAR}, #{sourceUpdateTime,jdbcType=TIMESTAMP}, 
+      #{versionMark,jdbcType=VARCHAR}, #{author,jdbcType=VARCHAR}, #{addTime,jdbcType=TIMESTAMP}, 
+      #{versionName,jdbcType=VARCHAR}, #{onFork,jdbcType=CHAR}, #{runCommand,jdbcType=VARCHAR}, 
+      #{runSource,jdbcType=LONGVARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.byit.model.NodeVersion">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into node_version
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="nodeVersionId != null">
+        node_version_id,
+      </if>
+      <if test="nodeId != null">
+        node_id,
+      </if>
+      <if test="blockStrategy != null">
+        block_strategy,
+      </if>
+      <if test="puginToken != null">
+        pugin_token,
+      </if>
+      <if test="failedRetryCount != null">
+        failed_retry_count,
+      </if>
+      <if test="flowId != null">
+        flow_id,
+      </if>
+      <if test="flowVersionId != null">
+        flow_version_id,
+      </if>
+      <if test="gatewayToken != null">
+        gateway_token,
+      </if>
+      <if test="jobType != null">
+        job_type,
+      </if>
+      <if test="handlerName != null">
+        handler_name,
+      </if>
+      <if test="nodeCron != null">
+        node_cron,
+      </if>
+      <if test="nodeDesc != null">
+        node_desc,
+      </if>
+      <if test="nodeName != null">
+        node_name,
+      </if>
+      <if test="mapFlowId != null">
+        map_flow_id,
+      </if>
+      <if test="nodeTimeout != null">
+        node_timeout,
+      </if>
+      <if test="isVirtual != null">
+        is_virtual,
+      </if>
+      <if test="pluginUrls != null">
+        plugin_urls,
+      </if>
+      <if test="priority != null">
+        priority,
+      </if>
+      <if test="removeMark != null">
+        remove_mark,
+      </if>
+      <if test="repeatCount != null">
+        repeat_count,
+      </if>
+      <if test="failedRetryInterval != null">
+        failed_retry_interval,
+      </if>
+      <if test="routingStrategy != null">
+        routing_strategy,
+      </if>
+      <if test="runParam != null">
+        run_param,
+      </if>
+      <if test="runSourceDesc != null">
+        run_source_desc,
+      </if>
+      <if test="scriptUrls != null">
+        script_urls,
+      </if>
+      <if test="sourcePrincipal != null">
+        source_principal,
+      </if>
+      <if test="sourceUpdateTime != null">
+        source_update_time,
+      </if>
+      <if test="versionMark != null">
+        version_mark,
+      </if>
+      <if test="author != null">
+        author,
+      </if>
+      <if test="addTime != null">
+        add_time,
+      </if>
+      <if test="versionName != null">
+        version_name,
+      </if>
+      <if test="onFork != null">
+        on_fork,
+      </if>
+      <if test="runCommand != null">
+        run_command,
+      </if>
+      <if test="runSource != null">
+        run_source,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="nodeVersionId != null">
+        #{nodeVersionId,jdbcType=INTEGER},
+      </if>
+      <if test="nodeId != null">
+        #{nodeId,jdbcType=INTEGER},
+      </if>
+      <if test="blockStrategy != null">
+        #{blockStrategy,jdbcType=VARCHAR},
+      </if>
+      <if test="puginToken != null">
+        #{puginToken,jdbcType=VARCHAR},
+      </if>
+      <if test="failedRetryCount != null">
+        #{failedRetryCount,jdbcType=INTEGER},
+      </if>
+      <if test="flowId != null">
+        #{flowId,jdbcType=INTEGER},
+      </if>
+      <if test="flowVersionId != null">
+        #{flowVersionId,jdbcType=INTEGER},
+      </if>
+      <if test="gatewayToken != null">
+        #{gatewayToken,jdbcType=VARCHAR},
+      </if>
+      <if test="jobType != null">
+        #{jobType,jdbcType=VARCHAR},
+      </if>
+      <if test="handlerName != null">
+        #{handlerName,jdbcType=VARCHAR},
+      </if>
+      <if test="nodeCron != null">
+        #{nodeCron,jdbcType=VARCHAR},
+      </if>
+      <if test="nodeDesc != null">
+        #{nodeDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="nodeName != null">
+        #{nodeName,jdbcType=VARCHAR},
+      </if>
+      <if test="mapFlowId != null">
+        #{mapFlowId,jdbcType=INTEGER},
+      </if>
+      <if test="nodeTimeout != null">
+        #{nodeTimeout,jdbcType=BIGINT},
+      </if>
+      <if test="isVirtual != null">
+        #{isVirtual,jdbcType=VARCHAR},
+      </if>
+      <if test="pluginUrls != null">
+        #{pluginUrls,jdbcType=VARCHAR},
+      </if>
+      <if test="priority != null">
+        #{priority,jdbcType=CHAR},
+      </if>
+      <if test="removeMark != null">
+        #{removeMark,jdbcType=CHAR},
+      </if>
+      <if test="repeatCount != null">
+        #{repeatCount,jdbcType=INTEGER},
+      </if>
+      <if test="failedRetryInterval != null">
+        #{failedRetryInterval,jdbcType=BIGINT},
+      </if>
+      <if test="routingStrategy != null">
+        #{routingStrategy,jdbcType=VARCHAR},
+      </if>
+      <if test="runParam != null">
+        #{runParam,jdbcType=VARCHAR},
+      </if>
+      <if test="runSourceDesc != null">
+        #{runSourceDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="scriptUrls != null">
+        #{scriptUrls,jdbcType=VARCHAR},
+      </if>
+      <if test="sourcePrincipal != null">
+        #{sourcePrincipal,jdbcType=VARCHAR},
+      </if>
+      <if test="sourceUpdateTime != null">
+        #{sourceUpdateTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="versionMark != null">
+        #{versionMark,jdbcType=VARCHAR},
+      </if>
+      <if test="author != null">
+        #{author,jdbcType=VARCHAR},
+      </if>
+      <if test="addTime != null">
+        #{addTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="versionName != null">
+        #{versionName,jdbcType=VARCHAR},
+      </if>
+      <if test="onFork != null">
+        #{onFork,jdbcType=CHAR},
+      </if>
+      <if test="runCommand != null">
+        #{runCommand,jdbcType=VARCHAR},
+      </if>
+      <if test="runSource != null">
+        #{runSource,jdbcType=LONGVARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByIdSelective" parameterType="com.byit.model.NodeVersion">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update node_version
+    <set>
+      <if test="nodeId != null">
+        node_id = #{nodeId,jdbcType=INTEGER},
+      </if>
+      <if test="blockStrategy != null">
+        block_strategy = #{blockStrategy,jdbcType=VARCHAR},
+      </if>
+      <if test="puginToken != null">
+        pugin_token = #{puginToken,jdbcType=VARCHAR},
+      </if>
+      <if test="failedRetryCount != null">
+        failed_retry_count = #{failedRetryCount,jdbcType=INTEGER},
+      </if>
+      <if test="flowId != null">
+        flow_id = #{flowId,jdbcType=INTEGER},
+      </if>
+      <if test="flowVersionId != null">
+        flow_version_id = #{flowVersionId,jdbcType=INTEGER},
+      </if>
+      <if test="gatewayToken != null">
+        gateway_token = #{gatewayToken,jdbcType=VARCHAR},
+      </if>
+      <if test="jobType != null">
+        job_type = #{jobType,jdbcType=VARCHAR},
+      </if>
+      <if test="handlerName != null">
+        handler_name = #{handlerName,jdbcType=VARCHAR},
+      </if>
+      <if test="nodeCron != null">
+        node_cron = #{nodeCron,jdbcType=VARCHAR},
+      </if>
+      <if test="nodeDesc != null">
+        node_desc = #{nodeDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="nodeName != null">
+        node_name = #{nodeName,jdbcType=VARCHAR},
+      </if>
+      <if test="mapFlowId != null">
+        map_flow_id = #{mapFlowId,jdbcType=INTEGER},
+      </if>
+      <if test="nodeTimeout != null">
+        node_timeout = #{nodeTimeout,jdbcType=BIGINT},
+      </if>
+      <if test="isVirtual != null">
+        is_virtual = #{isVirtual,jdbcType=VARCHAR},
+      </if>
+      <if test="pluginUrls != null">
+        plugin_urls = #{pluginUrls,jdbcType=VARCHAR},
+      </if>
+      <if test="priority != null">
+        priority = #{priority,jdbcType=CHAR},
+      </if>
+      <if test="removeMark != null">
+        remove_mark = #{removeMark,jdbcType=CHAR},
+      </if>
+      <if test="repeatCount != null">
+        repeat_count = #{repeatCount,jdbcType=INTEGER},
+      </if>
+      <if test="failedRetryInterval != null">
+        failed_retry_interval = #{failedRetryInterval,jdbcType=BIGINT},
+      </if>
+      <if test="routingStrategy != null">
+        routing_strategy = #{routingStrategy,jdbcType=VARCHAR},
+      </if>
+      <if test="runParam != null">
+        run_param = #{runParam,jdbcType=VARCHAR},
+      </if>
+      <if test="runSourceDesc != null">
+        run_source_desc = #{runSourceDesc,jdbcType=VARCHAR},
+      </if>
+      <if test="scriptUrls != null">
+        script_urls = #{scriptUrls,jdbcType=VARCHAR},
+      </if>
+      <if test="sourcePrincipal != null">
+        source_principal = #{sourcePrincipal,jdbcType=VARCHAR},
+      </if>
+      <if test="sourceUpdateTime != null">
+        source_update_time = #{sourceUpdateTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="versionMark != null">
+        version_mark = #{versionMark,jdbcType=VARCHAR},
+      </if>
+      <if test="author != null">
+        author = #{author,jdbcType=VARCHAR},
+      </if>
+      <if test="addTime != null">
+        add_time = #{addTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="versionName != null">
+        version_name = #{versionName,jdbcType=VARCHAR},
+      </if>
+      <if test="onFork != null">
+        on_fork = #{onFork,jdbcType=CHAR},
+      </if>
+      <if test="runCommand != null">
+        run_command = #{runCommand,jdbcType=VARCHAR},
+      </if>
+      <if test="runSource != null">
+        run_source = #{runSource,jdbcType=LONGVARCHAR},
+      </if>
+    </set>
+    where node_version_id = #{nodeVersionId,jdbcType=INTEGER}
+  </update>
+  <update id="updateByPrimaryKeyWithBLOBs" parameterType="com.byit.model.NodeVersion">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update node_version
+    set node_id = #{nodeId,jdbcType=INTEGER},
+      block_strategy = #{blockStrategy,jdbcType=VARCHAR},
+      pugin_token = #{puginToken,jdbcType=VARCHAR},
+      failed_retry_count = #{failedRetryCount,jdbcType=INTEGER},
+      flow_id = #{flowId,jdbcType=INTEGER},
+      flow_version_id = #{flowVersionId,jdbcType=INTEGER},
+      gateway_token = #{gatewayToken,jdbcType=VARCHAR},
+      job_type = #{jobType,jdbcType=VARCHAR},
+      handler_name = #{handlerName,jdbcType=VARCHAR},
+      node_cron = #{nodeCron,jdbcType=VARCHAR},
+      node_desc = #{nodeDesc,jdbcType=VARCHAR},
+      node_name = #{nodeName,jdbcType=VARCHAR},
+      map_flow_id = #{mapFlowId,jdbcType=INTEGER},
+      node_timeout = #{nodeTimeout,jdbcType=BIGINT},
+      is_virtual = #{isVirtual,jdbcType=VARCHAR},
+      plugin_urls = #{pluginUrls,jdbcType=VARCHAR},
+      priority = #{priority,jdbcType=CHAR},
+      remove_mark = #{removeMark,jdbcType=CHAR},
+      repeat_count = #{repeatCount,jdbcType=INTEGER},
+      failed_retry_interval = #{failedRetryInterval,jdbcType=BIGINT},
+      routing_strategy = #{routingStrategy,jdbcType=VARCHAR},
+      run_param = #{runParam,jdbcType=VARCHAR},
+      run_source_desc = #{runSourceDesc,jdbcType=VARCHAR},
+      script_urls = #{scriptUrls,jdbcType=VARCHAR},
+      source_principal = #{sourcePrincipal,jdbcType=VARCHAR},
+      source_update_time = #{sourceUpdateTime,jdbcType=TIMESTAMP},
+      version_mark = #{versionMark,jdbcType=VARCHAR},
+      author = #{author,jdbcType=VARCHAR},
+      add_time = #{addTime,jdbcType=TIMESTAMP},
+      version_name = #{versionName,jdbcType=VARCHAR},
+      on_fork = #{onFork,jdbcType=CHAR},
+      run_command = #{runCommand,jdbcType=VARCHAR},
+      run_source = #{runSource,jdbcType=LONGVARCHAR}
+    where node_version_id = #{nodeVersionId,jdbcType=INTEGER}
+  </update>
+  <update id="updateById" parameterType="com.byit.model.NodeVersion">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update node_version
+    set node_id = #{nodeId,jdbcType=INTEGER},
+      block_strategy = #{blockStrategy,jdbcType=VARCHAR},
+      pugin_token = #{puginToken,jdbcType=VARCHAR},
+      failed_retry_count = #{failedRetryCount,jdbcType=INTEGER},
+      flow_id = #{flowId,jdbcType=INTEGER},
+      flow_version_id = #{flowVersionId,jdbcType=INTEGER},
+      gateway_token = #{gatewayToken,jdbcType=VARCHAR},
+      job_type = #{jobType,jdbcType=VARCHAR},
+      handler_name = #{handlerName,jdbcType=VARCHAR},
+      node_cron = #{nodeCron,jdbcType=VARCHAR},
+      node_desc = #{nodeDesc,jdbcType=VARCHAR},
+      node_name = #{nodeName,jdbcType=VARCHAR},
+      map_flow_id = #{mapFlowId,jdbcType=INTEGER},
+      node_timeout = #{nodeTimeout,jdbcType=BIGINT},
+      is_virtual = #{isVirtual,jdbcType=VARCHAR},
+      plugin_urls = #{pluginUrls,jdbcType=VARCHAR},
+      priority = #{priority,jdbcType=CHAR},
+      remove_mark = #{removeMark,jdbcType=CHAR},
+      repeat_count = #{repeatCount,jdbcType=INTEGER},
+      failed_retry_interval = #{failedRetryInterval,jdbcType=BIGINT},
+      routing_strategy = #{routingStrategy,jdbcType=VARCHAR},
+      run_param = #{runParam,jdbcType=VARCHAR},
+      run_source_desc = #{runSourceDesc,jdbcType=VARCHAR},
+      script_urls = #{scriptUrls,jdbcType=VARCHAR},
+      source_principal = #{sourcePrincipal,jdbcType=VARCHAR},
+      source_update_time = #{sourceUpdateTime,jdbcType=TIMESTAMP},
+      version_mark = #{versionMark,jdbcType=VARCHAR},
+      author = #{author,jdbcType=VARCHAR},
+      add_time = #{addTime,jdbcType=TIMESTAMP},
+      version_name = #{versionName,jdbcType=VARCHAR},
+      on_fork = #{onFork,jdbcType=CHAR},
+      run_command = #{runCommand,jdbcType=VARCHAR}
+    where node_version_id = #{nodeVersionId,jdbcType=INTEGER}
+  </update>
+</mapper>
\ No newline at end of file

byit-myth-core/myth-admin-core/src/main/resources/mapper/SourceHistoryMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.byit.mapper.SourceHistoryMapper">
+  <resultMap id="BaseResultMap" type="com.byit.model.SourceHistory">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    <id column="id" jdbcType="VARCHAR" property="id" />
+    <result column="job_node_id" jdbcType="VARCHAR" property="jobNodeId" />
+    <result column="glue_remark" jdbcType="VARCHAR" property="glueRemark" />
+    <result column="add_time" jdbcType="TIMESTAMP" property="addTime" />
+  </resultMap>
+  <resultMap extends="BaseResultMap" id="ResultMapWithBLOBs" type="com.byit.model.SourceHistory">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    <result column="glue_source" jdbcType="LONGVARCHAR" property="glueSource" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    id, job_node_id, glue_remark, add_time
+  </sql>
+  <sql id="Blob_Column_List">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    glue_source
+  </sql>
+  <select id="getById" parameterType="java.lang.String" resultMap="ResultMapWithBLOBs">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    select 
+    <include refid="Base_Column_List" />
+    ,
+    <include refid="Blob_Column_List" />
+    from source_history
+    where id = #{id,jdbcType=VARCHAR}
+  </select>
+  <delete id="deleteById" parameterType="java.lang.String">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    delete from source_history
+    where id = #{id,jdbcType=VARCHAR}
+  </delete>
+  <insert id="insert" parameterType="com.byit.model.SourceHistory">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into source_history (id, job_node_id, glue_remark, 
+      add_time, glue_source)
+    values (#{id,jdbcType=VARCHAR}, #{jobNodeId,jdbcType=VARCHAR}, #{glueRemark,jdbcType=VARCHAR}, 
+      #{addTime,jdbcType=TIMESTAMP}, #{glueSource,jdbcType=LONGVARCHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.byit.model.SourceHistory">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into source_history
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="jobNodeId != null">
+        job_node_id,
+      </if>
+      <if test="glueRemark != null">
+        glue_remark,
+      </if>
+      <if test="addTime != null">
+        add_time,
+      </if>
+      <if test="glueSource != null">
+        glue_source,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=VARCHAR},
+      </if>
+      <if test="jobNodeId != null">
+        #{jobNodeId,jdbcType=VARCHAR},
+      </if>
+      <if test="glueRemark != null">
+        #{glueRemark,jdbcType=VARCHAR},
+      </if>
+      <if test="addTime != null">
+        #{addTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="glueSource != null">
+        #{glueSource,jdbcType=LONGVARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByIdSelective" parameterType="com.byit.model.SourceHistory">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update source_history
+    <set>
+      <if test="jobNodeId != null">
+        job_node_id = #{jobNodeId,jdbcType=VARCHAR},
+      </if>
+      <if test="glueRemark != null">
+        glue_remark = #{glueRemark,jdbcType=VARCHAR},
+      </if>
+      <if test="addTime != null">
+        add_time = #{addTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="glueSource != null">
+        glue_source = #{glueSource,jdbcType=LONGVARCHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+  <update id="updateByPrimaryKeyWithBLOBs" parameterType="com.byit.model.SourceHistory">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update source_history
+    set job_node_id = #{jobNodeId,jdbcType=VARCHAR},
+      glue_remark = #{glueRemark,jdbcType=VARCHAR},
+      add_time = #{addTime,jdbcType=TIMESTAMP},
+      glue_source = #{glueSource,jdbcType=LONGVARCHAR}
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+  <update id="updateById" parameterType="com.byit.model.SourceHistory">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update source_history
+    set job_node_id = #{jobNodeId,jdbcType=VARCHAR},
+      glue_remark = #{glueRemark,jdbcType=VARCHAR},
+      add_time = #{addTime,jdbcType=TIMESTAMP}
+    where id = #{id,jdbcType=VARCHAR}
+  </update>
+</mapper>
\ No newline at end of file

byit-myth-core/myth-admin-core/src/main/resources/mapper/WorkspaceMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.byit.mapper.WorkspaceMapper">
+  <resultMap id="BaseResultMap" type="com.byit.model.Workspace">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    <id column="workspace_id" jdbcType="INTEGER" property="workspaceId" />
+    <result column="workspace_name" jdbcType="VARCHAR" property="workspaceName" />
+    <result column="author" jdbcType="VARCHAR" property="author" />
+    <result column="add_time" jdbcType="TIMESTAMP" property="addTime" />
+    <result column="remove_mark" jdbcType="CHAR" property="removeMark" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    workspace_id, workspace_name, author, add_time, remove_mark
+  </sql>
+  <select id="getById" parameterType="java.lang.Integer" resultMap="BaseResultMap">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    select 
+    <include refid="Base_Column_List" />
+    from workspace
+    where workspace_id = #{workspaceId,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteById" parameterType="java.lang.Integer">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    delete from workspace
+    where workspace_id = #{workspaceId,jdbcType=INTEGER}
+  </delete>
+  <insert id="insert" parameterType="com.byit.model.Workspace">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into workspace (workspace_id, workspace_name, author, 
+      add_time, remove_mark)
+    values (#{workspaceId,jdbcType=INTEGER}, #{workspaceName,jdbcType=VARCHAR}, #{author,jdbcType=VARCHAR}, 
+      #{addTime,jdbcType=TIMESTAMP}, #{removeMark,jdbcType=CHAR})
+  </insert>
+  <insert id="insertSelective" parameterType="com.byit.model.Workspace">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    insert into workspace
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="workspaceId != null">
+        workspace_id,
+      </if>
+      <if test="workspaceName != null">
+        workspace_name,
+      </if>
+      <if test="author != null">
+        author,
+      </if>
+      <if test="addTime != null">
+        add_time,
+      </if>
+      <if test="removeMark != null">
+        remove_mark,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="workspaceId != null">
+        #{workspaceId,jdbcType=INTEGER},
+      </if>
+      <if test="workspaceName != null">
+        #{workspaceName,jdbcType=VARCHAR},
+      </if>
+      <if test="author != null">
+        #{author,jdbcType=VARCHAR},
+      </if>
+      <if test="addTime != null">
+        #{addTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="removeMark != null">
+        #{removeMark,jdbcType=CHAR},
+      </if>
+    </trim>
+  </insert>
+  <update id="updateByIdSelective" parameterType="com.byit.model.Workspace">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update workspace
+    <set>
+      <if test="workspaceName != null">
+        workspace_name = #{workspaceName,jdbcType=VARCHAR},
+      </if>
+      <if test="author != null">
+        author = #{author,jdbcType=VARCHAR},
+      </if>
+      <if test="addTime != null">
+        add_time = #{addTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="removeMark != null">
+        remove_mark = #{removeMark,jdbcType=CHAR},
+      </if>
+    </set>
+    where workspace_id = #{workspaceId,jdbcType=INTEGER}
+  </update>
+  <update id="updateById" parameterType="com.byit.model.Workspace">
+    <!-- generated @mbg.generated date: 2019-12-31 -->
+    update workspace
+    set workspace_name = #{workspaceName,jdbcType=VARCHAR},
+      author = #{author,jdbcType=VARCHAR},
+      add_time = #{addTime,jdbcType=TIMESTAMP},
+      remove_mark = #{removeMark,jdbcType=CHAR}
+    where workspace_id = #{workspaceId,jdbcType=INTEGER}
+  </update>
+</mapper>
\ No newline at end of file