From db0d184aa3c1b738ee6b0d06d4c5a90db439cbd1 Mon Sep 17 00:00:00 2001
From: "simon.song" <CSw12X45>
Date: Mon, 1 Feb 2021 13:58:21 +0800
Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E8=BF=81=E7=A7=BB=E5=8A=9F?=
 =?UTF-8?q?=E8=83=BD=E5=AE=8C=E6=88=90=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../i3plus/pojo/mes/bean/MesDataMigrationCfg.java  | 99 ++++++++++++++++++++++
 .../repository/MesDataMigrationCfgRepository.java  |  9 ++
 2 files changed, 108 insertions(+)
 create mode 100644 modules/i3plus-pojo-mes/src/main/java/cn/estsh/i3plus/pojo/mes/bean/MesDataMigrationCfg.java
 create mode 100644 modules/i3plus-pojo-mes/src/main/java/cn/estsh/i3plus/pojo/mes/repository/MesDataMigrationCfgRepository.java

diff --git a/modules/i3plus-pojo-mes/src/main/java/cn/estsh/i3plus/pojo/mes/bean/MesDataMigrationCfg.java b/modules/i3plus-pojo-mes/src/main/java/cn/estsh/i3plus/pojo/mes/bean/MesDataMigrationCfg.java
new file mode 100644
index 0000000..f640f59
--- /dev/null
+++ b/modules/i3plus-pojo-mes/src/main/java/cn/estsh/i3plus/pojo/mes/bean/MesDataMigrationCfg.java
@@ -0,0 +1,99 @@
+package cn.estsh.i3plus.pojo.mes.bean;
+
+import cn.estsh.i3plus.pojo.base.bean.BaseBean;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiParam;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.hibernate.annotations.DynamicInsert;
+import org.hibernate.annotations.DynamicUpdate;
+
+import javax.persistence.*;
+import java.io.Serializable;
+
+@Data
+@Entity
+@DynamicInsert
+@DynamicUpdate
+@EqualsAndHashCode(callSuper = true)
+@Inheritance(strategy = InheritanceType.JOINED)
+@Table(name = "MES_DATA_MIGRATION_CFG")
+@Api("MES数据迁移配置表")
+public class MesDataMigrationCfg extends BaseBean implements Serializable {
+
+    private static final long serialVersionUID = -6445732389643648643L;
+
+    @Column(name = "MIG_NAME")
+    @ApiParam("名称")
+    private String migName;
+
+    @Column(name = "REMARK")
+    @ApiParam("描述")
+    private String remark;
+
+    @Column(name = "MIGRATION_CYCLE")
+    @ApiParam("迁移周期")
+    private String migrationCycle;
+
+    @Column(name = "NEXT_EXECUTION_TIME")
+    @ApiParam("下次执行时间")
+    private String nextExecutionTime;
+
+    @Column(name = "SRC_TABLE_NAME")
+    @ApiParam("来源表名")
+    private String srcTableName;
+
+    @Column(name = "SRC_QUERY_CONDITIONS")
+    @ApiParam("来源表查询条件")
+    private String srcQueryConditions;
+
+    @Column(name = "PROCESS_QTY")
+    @ApiParam(value = "每次处理行数", example = "0")
+    private Integer processQty;
+
+    @Column(name = "DEST_TABLE_NAME")
+    @ApiParam("目标表名")
+    private String destTableName;
+
+    @Column(name = "IS_PHYSICAL_DELETE")
+    @ApiParam(value = "是否物理删除", example = "0")
+    private Integer isPhysicalDelete;
+
+    @Column(name = "LAST_EXECUTION_TIME")
+    @ApiParam("末次迁移时间")
+    private String lastExecutionTime;
+
+    @Column(name = "LAST_MIGRATION_QTY")
+    @ApiParam(value = "末次迁移记录数", example = "0")
+    private Integer lastMigrationQty;
+
+    @Column(name = "ERROR_MESSAGE")
+    @ApiParam("执行错误日志")
+    private String errorMessage;
+
+
+    @Transient
+    @ApiParam(value = "开始时间")
+    private String mcStartTime;
+
+    @Transient
+    @ApiParam(value = "结束时间")
+    private String mcEndTime;
+
+    /*public MesDataMigrationCfg(String migName, String remark, String migrationCycle, String nextExecutionTime, String srcTableName, String srcQueryConditions, Integer processQty, String destTableName, Integer isPhysicalDelete, String lastExecutionTime, Integer lastMigrationQty, String errorMessage, String mcStartTime, String mcEndTime) {
+        this.migName = migName;
+        this.remark = remark;
+        this.migrationCycle = migrationCycle;
+        this.nextExecutionTime = nextExecutionTime;
+        this.srcTableName = srcTableName;
+        this.srcQueryConditions = srcQueryConditions;
+        this.processQty = processQty;
+        this.destTableName = destTableName;
+        this.isPhysicalDelete = isPhysicalDelete;
+        this.lastExecutionTime = lastExecutionTime;
+        this.lastMigrationQty = lastMigrationQty;
+        this.errorMessage = errorMessage;
+        this.mcStartTime = mcStartTime;
+        this.mcEndTime = mcEndTime;
+    }*/
+}
diff --git a/modules/i3plus-pojo-mes/src/main/java/cn/estsh/i3plus/pojo/mes/repository/MesDataMigrationCfgRepository.java b/modules/i3plus-pojo-mes/src/main/java/cn/estsh/i3plus/pojo/mes/repository/MesDataMigrationCfgRepository.java
new file mode 100644
index 0000000..caa29bb
--- /dev/null
+++ b/modules/i3plus-pojo-mes/src/main/java/cn/estsh/i3plus/pojo/mes/repository/MesDataMigrationCfgRepository.java
@@ -0,0 +1,9 @@
+package cn.estsh.i3plus.pojo.mes.repository;
+
+import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository;
+import cn.estsh.i3plus.pojo.mes.bean.MesDataMigrationCfg;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface MesDataMigrationCfgRepository extends BaseRepository<MesDataMigrationCfg, Long> {
+}