From 6cb9dd439a318ca16a16c172708dfe4f304d91a8 Mon Sep 17 00:00:00 2001 From: sunshine7058 <2564255161@qq.com> Date: Mon, 22 Apr 2024 14:27:21 +0800 Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E6=8E=A5=E5=85=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../muyu/data/source/domain/DataSource.java | 173 ++++++++++++++++++ .../source/domain/req/DataSourceEditReq.java | 86 +++++++++ .../source/domain/req/DataSourceQueryReq.java | 38 ++++ .../source/domain/req/DataSourceSaveReq.java | 106 +++++++++++ .../source/MuYuDataSourceApplication.java | 23 +++ .../src/main/resources/bootstrap.yml | 32 ++++ 6 files changed, 458 insertions(+) create mode 100644 muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/DataSource.java create mode 100644 muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/req/DataSourceEditReq.java create mode 100644 muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/req/DataSourceQueryReq.java create mode 100644 muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/req/DataSourceSaveReq.java create mode 100644 muyu-modules/muyu-data-source/muyu-data-source-server/src/main/java/com/muyu/data/source/MuYuDataSourceApplication.java create mode 100644 muyu-modules/muyu-data-source/muyu-data-source-server/src/main/resources/bootstrap.yml diff --git a/muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/DataSource.java b/muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/DataSource.java new file mode 100644 index 0000000..265a922 --- /dev/null +++ b/muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/DataSource.java @@ -0,0 +1,173 @@ +package com.muyu.data.source.domain; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; +import lombok.AllArgsConstructor; +import lombok.experimental.SuperBuilder; +import io.swagger.annotations.*; +import com.muyu.common.core.annotation.Excel; +import com.muyu.data.source.domain.req.DataSourceQueryReq; +import com.muyu.data.source.domain.req.DataSourceSaveReq; +import com.muyu.data.source.domain.req.DataSourceEditReq; +import com.muyu.common.core.web.domain.BaseEntity; + +/** + * 数据源对象 data_source + * + * @author hufangming + * @date 2024-04-21 + */ +@Data +@SuperBuilder +@NoArgsConstructor +@AllArgsConstructor +@TableName("data_source") +@EqualsAndHashCode(callSuper = true) +@ApiModel(value = "DataSource", description = "数据源") +public class DataSource extends BaseEntity { + + private static final long serialVersionUID = 1L; + + /** 编号 */ + @TableId(value = "id",type = IdType.AUTO) + @ApiModelProperty(name = "编号", value = "编号") + private Long id; + + /** 接入源名称 */ + @Excel(name = "接入源名称") + @ApiModelProperty(name = "接入源名称", value = "接入源名称") + private String name; + + /** 数据来源系统名称 */ + @Excel(name = "数据来源系统名称") + @ApiModelProperty(name = "数据来源系统名称", value = "数据来源系统名称") + private String systemName; + + /** 数据库名称 */ + @Excel(name = "数据库名称") + @ApiModelProperty(name = "数据库名称", value = "数据库名称") + private String databaseName; + + /** 数据库类型 */ + @Excel(name = "数据库类型") + @ApiModelProperty(name = "数据库类型", value = "数据库类型") + private Long databaseType; + + /** 主机地址 */ + @Excel(name = "主机地址") + @ApiModelProperty(name = "主机地址", value = "主机地址") + private String host; + + /** 端口号 */ + @Excel(name = "端口号") + @ApiModelProperty(name = "端口号", value = "端口号") + private String port; + + /** 用户名 */ + @Excel(name = "用户名") + @ApiModelProperty(name = "用户名", value = "用户名") + private String user; + + /** 密码 */ + @Excel(name = "密码") + @ApiModelProperty(name = "密码", value = "密码") + private String password; + + /** 类型 '查询'/'存储' */ + @Excel(name = "类型 '查询'/'存储'") + @ApiModelProperty(name = "类型 '查询'/'存储'", value = "类型 '查询'/'存储'") + private String type; + + /** 数据连接参数 */ + @Excel(name = "数据连接参数") + @ApiModelProperty(name = "数据连接参数", value = "数据连接参数") + private String connectionParam; + + /** 状态 'Y'/'N' */ + @Excel(name = "状态 'Y'/'N'") + @ApiModelProperty(name = "状态 'Y'/'N'", value = "状态 'Y'/'N'") + private String status; + + /** 初始连接数量 */ + @Excel(name = "初始连接数量") + @ApiModelProperty(name = "初始连接数量", value = "初始连接数量") + private Long initNum; + + /** 最大连接数量 */ + @Excel(name = "最大连接数量") + @ApiModelProperty(name = "最大连接数量", value = "最大连接数量") + private Long maxNum; + + /** 最大等待时间 */ + @Excel(name = "最大等待时间") + @ApiModelProperty(name = "最大等待时间", value = "最大等待时间") + private Long maxWaitTime; + + /** 最大等待次数 */ + @Excel(name = "最大等待次数") + @ApiModelProperty(name = "最大等待次数", value = "最大等待次数") + private Long maxWaitSize; + + /** + * 查询构造器 + */ + public static DataSource queryBuild( DataSourceQueryReq dataSourceQueryReq){ + return DataSource.builder() + .name(dataSourceQueryReq.getName()) + .systemName(dataSourceQueryReq.getSystemName()) + .databaseName(dataSourceQueryReq.getDatabaseName()) + .build(); + } + + /** + * 添加构造器 + */ + public static DataSource saveBuild(DataSourceSaveReq dataSourceSaveReq){ + return DataSource.builder() + .name(dataSourceSaveReq.getName()) + .systemName(dataSourceSaveReq.getSystemName()) + .databaseName(dataSourceSaveReq.getDatabaseName()) + .databaseType(dataSourceSaveReq.getDatabaseType()) + .host(dataSourceSaveReq.getHost()) + .port(dataSourceSaveReq.getPort()) + .user(dataSourceSaveReq.getUser()) + .password(dataSourceSaveReq.getPassword()) + .type(dataSourceSaveReq.getType()) + .connectionParam(dataSourceSaveReq.getConnectionParam()) + .status(dataSourceSaveReq.getStatus()) + .initNum(dataSourceSaveReq.getInitNum()) + .maxNum(dataSourceSaveReq.getMaxNum()) + .maxWaitTime(dataSourceSaveReq.getMaxWaitTime()) + .maxWaitSize(dataSourceSaveReq.getMaxWaitSize()) + .build(); + } + + /** + * 修改构造器 + */ + public static DataSource editBuild(Long id, DataSourceEditReq dataSourceEditReq){ + return DataSource.builder() + .id(id) + .name(dataSourceEditReq.getName()) + .systemName(dataSourceEditReq.getSystemName()) + .databaseName(dataSourceEditReq.getDatabaseName()) + .databaseType(dataSourceEditReq.getDatabaseType()) + .host(dataSourceEditReq.getHost()) + .port(dataSourceEditReq.getPort()) + .user(dataSourceEditReq.getUser()) + .password(dataSourceEditReq.getPassword()) + .type(dataSourceEditReq.getType()) + .connectionParam(dataSourceEditReq.getConnectionParam()) + .status(dataSourceEditReq.getStatus()) + .initNum(dataSourceEditReq.getInitNum()) + .maxNum(dataSourceEditReq.getMaxNum()) + .maxWaitTime(dataSourceEditReq.getMaxWaitTime()) + .maxWaitSize(dataSourceEditReq.getMaxWaitSize()) + .build(); + } + +} diff --git a/muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/req/DataSourceEditReq.java b/muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/req/DataSourceEditReq.java new file mode 100644 index 0000000..f99679e --- /dev/null +++ b/muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/req/DataSourceEditReq.java @@ -0,0 +1,86 @@ +package com.muyu.data.source.domain.req; + +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; +import lombok.AllArgsConstructor; +import lombok.experimental.SuperBuilder; +import io.swagger.annotations.*; +import com.muyu.common.core.web.domain.BaseEntity; + +/** + * 数据源对象 data_source + * + * @author hufangming + * @date 2024-04-21 + */ +@Data +@SuperBuilder +@NoArgsConstructor +@AllArgsConstructor +@ApiModel(value = "DataSourceEditReq", description = "数据源") +public class DataSourceEditReq extends BaseEntity { + + private static final long serialVersionUID = 1L; + + /** 接入源名称 */ + @ApiModelProperty(name = "接入源名称", value = "接入源名称") + private String name; + + /** 数据来源系统名称 */ + @ApiModelProperty(name = "数据来源系统名称", value = "数据来源系统名称") + private String systemName; + + /** 数据库名称 */ + @ApiModelProperty(name = "数据库名称", value = "数据库名称") + private String databaseName; + + /** 数据库类型 */ + @ApiModelProperty(name = "数据库类型", value = "数据库类型") + private Long databaseType; + + /** 主机地址 */ + @ApiModelProperty(name = "主机地址", value = "主机地址") + private String host; + + /** 端口号 */ + @ApiModelProperty(name = "端口号", value = "端口号") + private String port; + + /** 用户名 */ + @ApiModelProperty(name = "用户名", value = "用户名") + private String user; + + /** 密码 */ + @ApiModelProperty(name = "密码", value = "密码") + private String password; + + /** 类型 '查询'/'存储' */ + @ApiModelProperty(name = "类型 '查询'/'存储'", value = "类型 '查询'/'存储'") + private String type; + + /** 数据连接参数 */ + @ApiModelProperty(name = "数据连接参数", value = "数据连接参数") + private String connectionParam; + + /** 状态 'Y'/'N' */ + @ApiModelProperty(name = "状态 'Y'/'N'", value = "状态 'Y'/'N'") + private String status; + + /** 初始连接数量 */ + @ApiModelProperty(name = "初始连接数量", value = "初始连接数量") + private Long initNum; + + /** 最大连接数量 */ + @ApiModelProperty(name = "最大连接数量", value = "最大连接数量") + private Long maxNum; + + /** 最大等待时间 */ + @ApiModelProperty(name = "最大等待时间", value = "最大等待时间") + private Long maxWaitTime; + + /** 最大等待次数 */ + @ApiModelProperty(name = "最大等待次数", value = "最大等待次数") + private Long maxWaitSize; + +} diff --git a/muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/req/DataSourceQueryReq.java b/muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/req/DataSourceQueryReq.java new file mode 100644 index 0000000..bf0cabf --- /dev/null +++ b/muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/req/DataSourceQueryReq.java @@ -0,0 +1,38 @@ +package com.muyu.data.source.domain.req; + +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; +import lombok.AllArgsConstructor; +import lombok.experimental.SuperBuilder; +import io.swagger.annotations.*; +import com.muyu.common.core.web.domain.BaseEntity; + +/** + * 数据源对象 data_source + * + * @author hufangming + * @date 2024-04-21 + */ +@Data +@SuperBuilder +@NoArgsConstructor +@AllArgsConstructor +@ApiModel(value = "DataSourceQueryReq", description = "数据源") +public class DataSourceQueryReq extends BaseEntity { + + private static final long serialVersionUID = 1L; + + /** 接入源名称 */ + @ApiModelProperty(name = "接入源名称", value = "接入源名称") + private String name; + + /** 数据来源系统名称 */ + @ApiModelProperty(name = "数据来源系统名称", value = "数据来源系统名称") + private String systemName; + + /** 数据库名称 */ + @ApiModelProperty(name = "数据库名称", value = "数据库名称") + private String databaseName; + +} diff --git a/muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/req/DataSourceSaveReq.java b/muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/req/DataSourceSaveReq.java new file mode 100644 index 0000000..fab79a7 --- /dev/null +++ b/muyu-modules/muyu-data-source/muyu-data-source-common/src/main/java/com/muyu/data/source/domain/req/DataSourceSaveReq.java @@ -0,0 +1,106 @@ +package com.muyu.data.source.domain.req; + +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; +import lombok.AllArgsConstructor; +import lombok.experimental.SuperBuilder; +import io.swagger.annotations.*; +import com.muyu.common.core.web.domain.BaseEntity; + +/** + * 数据源对象 data_source + * + * @author hufangming + * @date 2024-04-21 + */ +@Data +@SuperBuilder +@NoArgsConstructor +@AllArgsConstructor +@ApiModel(value = "DataSourceSaveReq", description = "数据源") +public class DataSourceSaveReq extends BaseEntity { + + private static final long serialVersionUID = 1L; + + /** 编号 */ + + @ApiModelProperty(name = "编号", value = "编号") + private Long id; + + /** 接入源名称 */ + + @ApiModelProperty(name = "接入源名称", value = "接入源名称") + private String name; + + /** 数据来源系统名称 */ + + @ApiModelProperty(name = "数据来源系统名称", value = "数据来源系统名称") + private String systemName; + + /** 数据库名称 */ + + @ApiModelProperty(name = "数据库名称", value = "数据库名称") + private String databaseName; + + /** 数据库类型 */ + + @ApiModelProperty(name = "数据库类型", value = "数据库类型") + private Long databaseType; + + /** 主机地址 */ + + @ApiModelProperty(name = "主机地址", value = "主机地址") + private String host; + + /** 端口号 */ + + @ApiModelProperty(name = "端口号", value = "端口号") + private String port; + + /** 用户名 */ + + @ApiModelProperty(name = "用户名", value = "用户名") + private String user; + + /** 密码 */ + + @ApiModelProperty(name = "密码", value = "密码") + private String password; + + /** 类型 '查询'/'存储' */ + + @ApiModelProperty(name = "类型 '查询'/'存储'", value = "类型 '查询'/'存储'") + private String type; + + /** 数据连接参数 */ + + @ApiModelProperty(name = "数据连接参数", value = "数据连接参数") + private String connectionParam; + + /** 状态 'Y'/'N' */ + + @ApiModelProperty(name = "状态 'Y'/'N'", value = "状态 'Y'/'N'") + private String status; + + /** 初始连接数量 */ + + @ApiModelProperty(name = "初始连接数量", value = "初始连接数量") + private Long initNum; + + /** 最大连接数量 */ + + @ApiModelProperty(name = "最大连接数量", value = "最大连接数量") + private Long maxNum; + + /** 最大等待时间 */ + + @ApiModelProperty(name = "最大等待时间", value = "最大等待时间") + private Long maxWaitTime; + + /** 最大等待次数 */ + + @ApiModelProperty(name = "最大等待次数", value = "最大等待次数") + private Long maxWaitSize; + +} diff --git a/muyu-modules/muyu-data-source/muyu-data-source-server/src/main/java/com/muyu/data/source/MuYuDataSourceApplication.java b/muyu-modules/muyu-data-source/muyu-data-source-server/src/main/java/com/muyu/data/source/MuYuDataSourceApplication.java new file mode 100644 index 0000000..a14978d --- /dev/null +++ b/muyu-modules/muyu-data-source/muyu-data-source-server/src/main/java/com/muyu/data/source/MuYuDataSourceApplication.java @@ -0,0 +1,23 @@ +package com.muyu.data.source; + + +import com.muyu.common.security.annotation.EnableCustomConfig; +import com.muyu.common.security.annotation.EnableMyFeignClients; +import com.muyu.common.swagger.annotation.EnableCustomSwagger2; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * 系统模块 + * + * @author muyu + */ +@EnableCustomConfig +@EnableCustomSwagger2 +@EnableMyFeignClients +@SpringBootApplication +public class MuYuDataSourceApplication { + public static void main (String[] args) { + SpringApplication.run(MuYuDataSourceApplication.class, args); + } +} diff --git a/muyu-modules/muyu-data-source/muyu-data-source-server/src/main/resources/bootstrap.yml b/muyu-modules/muyu-data-source/muyu-data-source-server/src/main/resources/bootstrap.yml new file mode 100644 index 0000000..6066a85 --- /dev/null +++ b/muyu-modules/muyu-data-source/muyu-data-source-server/src/main/resources/bootstrap.yml @@ -0,0 +1,32 @@ +# Tomcat +server: + port: 9511 + +# Spring +spring: + main: + allow-circular-references: true + application: + # 应用名称 + name: muyu-data-source + profiles: + # 环境配置 + active: dev + cloud: + nacos: + discovery: + # 服务注册地址 + server-addr: 192.168.16.128 + namespace: ry + config: + # 配置中心地址 + server-addr: 192.168.16.128 + namespace: ry + # 配置文件格式 + file-extension: yml + # 共享配置 + shared-configs: + - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} +logging: + level: + com.muyu.shop.cart.mapper: DEBUG