From c2437fd00f22ef138716f43945c5b04c6d25a92c Mon Sep 17 00:00:00 2001 From: "castle.zang" Date: Fri, 7 Jan 2022 10:03:23 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8E=A5=E5=8F=A3=E6=98=A0=E5=B0=84bean?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../i3plus/pojo/base/enumutil/WmsEnumUtil.java | 79 +++++++++++++++++++ .../pojo/wms/bean/datasource/CusDatasource.java | 89 ++++++++++++++++++++++ .../wms/dbinterface/WmsInterfaceDataMapper.java | 10 +++ .../wms/repository/CusDatasourceRepository.java | 16 ++++ .../WmsInterfaceDataMapperRepository.java | 1 - 5 files changed, 194 insertions(+), 1 deletion(-) create mode 100644 modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/datasource/CusDatasource.java create mode 100644 modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/CusDatasourceRepository.java diff --git a/modules/i3plus-pojo-base/src/main/java/cn/estsh/i3plus/pojo/base/enumutil/WmsEnumUtil.java b/modules/i3plus-pojo-base/src/main/java/cn/estsh/i3plus/pojo/base/enumutil/WmsEnumUtil.java index 8ef2a14..d139dda 100644 --- a/modules/i3plus-pojo-base/src/main/java/cn/estsh/i3plus/pojo/base/enumutil/WmsEnumUtil.java +++ b/modules/i3plus-pojo-base/src/main/java/cn/estsh/i3plus/pojo/base/enumutil/WmsEnumUtil.java @@ -9747,6 +9747,85 @@ public class WmsEnumUtil { return valueOf(val); } } + + @JsonFormat(shape = JsonFormat.Shape.OBJECT) + public enum DATA_SOURCE_STATUS { + CONN_SUCCESS(10, "连接成功", "连接成功"), + CONN_FAILURE(20, "连接失败", "连接失败"); + + private int value; + private String code; + private String description; + + private DATA_SOURCE_STATUS(int value, String code, String description) { + this.value = value; + this.code = code; + this.description = description; + } + + public int getValue() { + return value; + } + + public String getCode() { + return code; + } + + public String getDescription() { + return description; + } + + + public static String valueOfCode(int val) { + String tmp = null; + for (int i = 0; i < values().length; i++) { + if (values()[i].value == val) { + tmp = values()[i].code; + } + } + return tmp; + } + + public static int codeOfValue(String code) { + int tmp = 1; + for (int i = 0; i < values().length; i++) { + if (values()[i].code.equals(code)) { + tmp = values()[i].value; + } + } + return tmp; + } + + public static String valueOfDescription(int val) { + String tmp = null; + for (int i = 0; i < values().length; i++) { + if (values()[i].value == val) { + tmp = values()[i].description; + } + } + return tmp; + } + + public static WmsEnumUtil.DATA_SOURCE_STATUS valueOf(int val) { + String tmp = null; + for (int i = 0; i < values().length; i++) { + if (values()[i].value == val) { + return values()[i]; + } + } + return null; + } + + public static String codeOfDescription(String code) { + String tmp = null; + for (int i = 0; i < values().length; i++) { + if (values()[i].code.equals(code)) { + tmp = values()[i].description; + } + } + return tmp; + } + } } diff --git a/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/datasource/CusDatasource.java b/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/datasource/CusDatasource.java new file mode 100644 index 0000000..c15859c --- /dev/null +++ b/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/bean/datasource/CusDatasource.java @@ -0,0 +1,89 @@ +package cn.estsh.i3plus.pojo.wms.bean.datasource; + +import cn.estsh.i3plus.pojo.base.bean.BaseBean; +import io.swagger.annotations.ApiParam; +import lombok.Data; +import lombok.NoArgsConstructor; +import org.hibernate.annotations.DynamicInsert; +import org.hibernate.annotations.DynamicUpdate; + +import javax.persistence.Column; +import javax.persistence.Entity; +import javax.persistence.Table; + +/** + * @Description : + * @Reference : + * @Author : Castle + * @CreateDate : 2021/12/17 10:26 + * @Modify: + **/ +@Data +@NoArgsConstructor +@DynamicInsert +@DynamicUpdate +@Entity +@Table(name = "wms_cus_datasource") +public class CusDatasource extends BaseBean { + @Column( + name = "SOURCE_NAME" + ) + @ApiParam("数据源名称") + private String sourceName; + @Column( + name = "SOURCE_CODE" + ) + @ApiParam("数据源编码") + private String sourceCode; + @Column( + name = "SOURCE_STATUS" + ) + @ApiParam( + value = "数据源状态", + name = "状态：可用，不可用 看枚举当中是否存在" + ) + private Integer sourceStatus; + @Column( + name = "SOURCE_TYPE" + ) + @ApiParam( + value = "数据源类型", + name = "BlockFormEnumUtil.DATA_SOURCE_TYPE" + ) + private Integer sourceType; + @Column( + name = "SOURCE_HOST" + ) + @ApiParam("数据源连接地址") + private String sourceHost; + @Column( + name = "SOURCE_PORT" + ) + @ApiParam("数据源端口") + private Integer sourcePort; + @Column( + name = "SOURCE_DATA_BASE_NAME" + ) + @ApiParam("数据库名称") + private String sourceDataBaseName; + @Column( + name = "SOURCE_USER_NAME" + ) + @ApiParam("数据库用户名称") + private String sourceUserName; + @Column( + name = "SOURCE_PASSWORD" + ) + @ApiParam("数据库用户密码") + private String sourcePassword; + @Column( + name = "SOURCE_DESCRIPTION" + ) + @ApiParam("数据源描述") + private String sourceDescription; + + public CusDatasource(Long id, String sourceCode) { + this.id = id; + this.sourceCode = sourceCode; + } +} diff --git a/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/dbinterface/WmsInterfaceDataMapper.java b/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/dbinterface/WmsInterfaceDataMapper.java index bb92ad8..bc98a06 100644 --- a/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/dbinterface/WmsInterfaceDataMapper.java +++ b/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/dbinterface/WmsInterfaceDataMapper.java @@ -50,6 +50,16 @@ public class WmsInterfaceDataMapper extends BaseBean { @Column(name = "SRC_DATA_SOURCE", length = 50) public String dataSource; /** + * 目标数据源id + */ + @Column(name = "DEST_DATA_SOURCE_ID)") + public Long destDatasourceId; + /** + * 来源数据源id + */ + @Column(name = "SRC_DATA_SOURCE_ID)") + public Long srcDatasourceId; + /** * 来源表名 */ @Column(name = "SRC_TABLE_NAME", length = 50) diff --git a/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/CusDatasourceRepository.java b/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/CusDatasourceRepository.java new file mode 100644 index 0000000..aaf5cd3 --- /dev/null +++ b/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/CusDatasourceRepository.java @@ -0,0 +1,16 @@ +package cn.estsh.i3plus.pojo.wms.repository; + +import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository; +import cn.estsh.i3plus.pojo.wms.bean.datasource.CusDatasource; +import org.springframework.stereotype.Repository; + +/** + * @Description : + * @Reference : + * @Author : Castle + * @CreateDate : 2021/12/21 13:33 + * @Modify: + **/ +@Repository +public interface CusDatasourceRepository extends BaseRepository { +} diff --git a/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/WmsInterfaceDataMapperRepository.java b/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/WmsInterfaceDataMapperRepository.java index 4b3a5a8..2b75b20 100644 --- a/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/WmsInterfaceDataMapperRepository.java +++ b/modules/i3plus-pojo-wms/src/main/java/cn/estsh/i3plus/pojo/wms/repository/WmsInterfaceDataMapperRepository.java @@ -1,7 +1,6 @@ package cn.estsh.i3plus.pojo.wms.repository; import cn.estsh.i3plus.pojo.base.jpa.dao.BaseRepository; -import cn.estsh.i3plus.pojo.wms.bean.AmpJisRec; import cn.estsh.i3plus.pojo.wms.dbinterface.WmsInterfaceDataMapper; import org.springframework.stereotype.Repository;