diff --git a/.idea/inspectionProfiles/Project_Default.xml b/.idea/inspectionProfiles/Project_Default.xml index 8d66637..187f5ad 100644 --- a/.idea/inspectionProfiles/Project_Default.xml +++ b/.idea/inspectionProfiles/Project_Default.xml @@ -1,5 +1,65 @@ \ No newline at end of file diff --git a/cloud-etl-client/pom.xml b/cloud-etl-client/pom.xml index b9ef6a2..6ff9395 100644 --- a/cloud-etl-client/pom.xml +++ b/cloud-etl-client/pom.xml @@ -22,7 +22,6 @@ com.muyu cloud-etl-common - 1.0.0 diff --git a/cloud-etl-client/src/main/java/com/muyu/Main.java b/cloud-etl-client/src/main/java/com/muyu/Main.java deleted file mode 100644 index 95690d4..0000000 --- a/cloud-etl-client/src/main/java/com/muyu/Main.java +++ /dev/null @@ -1,7 +0,0 @@ -package com.muyu; - -public class Main { - public static void main(String[] args) { - System.out.println("Hello world!"); - } -} \ No newline at end of file diff --git a/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/AssetAccredit.java b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/AssetAccredit.java new file mode 100644 index 0000000..f91654a --- /dev/null +++ b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/AssetAccredit.java @@ -0,0 +1,33 @@ +package com.muyu.cloud.etl.domain.source; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.muyu.common.core.annotation.Excel; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; + +/** + * @author Lenovo + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-20:34 + * @ Version：1.0 + * @ Description：资产授权 + */ +@Data +@SuperBuilder +@AllArgsConstructor +@NoArgsConstructor +@TableName("asset_accredit") +public class AssetAccredit { + /** + * 主键 + */ + @TableId(value = "id", type = IdType.AUTO) + @Excel(name = "主键") + private Long id; + +} diff --git a/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/AssetDataSource.java b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/AssetDataSource.java new file mode 100644 index 0000000..1276811 --- /dev/null +++ b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/AssetDataSource.java @@ -0,0 +1,49 @@ +package com.muyu.cloud.etl.domain.source; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.muyu.common.core.annotation.Excel; +import com.muyu.common.core.web.domain.BaseEntity; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-20-14:58 + * @ Version：1.0 + * @ Description：资产数据源 + * @author Lenovo + */ + +@Data +@AllArgsConstructor +@NoArgsConstructor +@EqualsAndHashCode(callSuper = true) +@TableName(value = "asset_data_source",autoResultMap = true) +public class AssetDataSource extends BaseEntity { + /** + * 主键 + */ + @Excel(name = "主键") + @TableId(value = "id", type = IdType.AUTO) + private Long id; + /** + * 接入源名称 + */ + @Excel(name = "接入源名称") + private String name; + /** + * 数据来源系统名称 + */ + @Excel(name = "数据来源系统名称") + private String systemName; + /** + * 数据库名称 + */ + @Excel(name = "数据库名称") + private String databaseName; +} diff --git a/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/Children.java b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/Children.java new file mode 100644 index 0000000..157dc24 --- /dev/null +++ b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/Children.java @@ -0,0 +1,55 @@ +package com.muyu.cloud.etl.domain.source; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.muyu.common.core.annotation.Excel; +import com.muyu.common.core.web.domain.BaseEntity; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-20-14:18 + * @ Version：1.0 + * @ Description：数据库结构 + * @author Lenovo + */ + +@Data +@AllArgsConstructor +@NoArgsConstructor +@EqualsAndHashCode(callSuper = true) +@TableName(value = "children",autoResultMap = true) +public class Children extends BaseEntity { + /** + * 主键 + */ + @Excel(name = "主键") + @TableId(value = "id", type = IdType.AUTO) + private Long id; + /** + * 表名 + */ + @Excel(name = "表名") + private String name; + /** + * 表注释 + */ + @Excel(name = "表注释") + private String annotation; + /** + * 数据条数 + */ + @Excel(name = "数据条数") + private Integer dataTotal; + /** + * 数据源 + */ + @Excel(name = "数据源id") + private Integer assetId; + +} diff --git a/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/DataSource.java b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/DataSource.java new file mode 100644 index 0000000..ef7e283 --- /dev/null +++ b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/DataSource.java @@ -0,0 +1,130 @@ +package com.muyu.cloud.etl.domain.source; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.muyu.common.core.annotation.Excel; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/**u + * @author Lenovo + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-20-10:59 + * @ Version：1.0 + * @ Description：数据源 + */ + +@Data +@NoArgsConstructor +@AllArgsConstructor +@TableName(value = "data_source",autoResultMap = true) +public class DataSource { + /** + * 主键 + */ + @Excel(name = "主键") + @TableId(value = "id", type = IdType.AUTO) + private Long id; + /** + * 接入源名称 + */ + @Excel(name = "接入源名称") + @TableField ("name") + private String name; + /** + * 数据来源系统名称 + */ + @Excel(name = "数据来源系统名称") + @TableField ("system_name") + private String systemName; + + /** + * 数据库类型 + */ + @Excel(name = "数据库类型") + @TableField("data_type") + private String dataType; + + /** + * ip地址 + */ + @Excel(name = "ip地址") + @TableField("ip") + private String ip; + + /** + * 端口号 + */ + @Excel(name = "端口号") + @TableField("port") + private String port; + + /** + * 数据库名称 + */ + @Excel(name = "数据库名称") + @TableField("database_name") + private String databaseName; + + /** + * 用户名 + */ + @Excel(name = "用户名") + @TableField("user_name") + private String userName; + + /** + * 密码 + */ + @Excel(name = "密码") + @TableField("password") + private String password; + + /** + * 数据连接参数 + */ + @Excel(name = "数据连接参数") + @TableField("connection_param") + private String connectionParam; + + /** + * 是否初始化 状态 'Y'/'N' + */ + @Excel(name = "是否初始化") + @TableField("is_init") + private String isInit; + + /** + * 初始化连接数量 + */ + @Excel(name = "初始连接数量") + @TableField("init_total") + private Long initNum; + + /** + * 最大连接数量 + */ + @Excel(name = "最大连接数量") + @TableField("max_num") + private Long maxNum; + + /** + * 最大等待时间 + */ + @Excel(name = "最大等待时间") + @TableField("max_wait_time") + private Long maxWaitTime; + + /** + * 最大等待次数 + */ + @Excel(name = "最大等待次数") + @TableField("max_wait_size") + private Long maxWaitSize; + + +} diff --git a/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/TableData.java b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/TableData.java new file mode 100644 index 0000000..fbe81b5 --- /dev/null +++ b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/TableData.java @@ -0,0 +1,94 @@ +package com.muyu.cloud.etl.domain.source; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.muyu.common.core.annotation.Excel; +import com.muyu.common.core.web.domain.BaseEntity; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-20-15:02 + * @ Version：1.0 + * @ Description：表结构 + * @author Lenovo + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +@EqualsAndHashCode(callSuper = true) +@TableName(value = "table_data",autoResultMap = true) +public class TableData extends BaseEntity { + /** + * 主键 + */ + @TableId(value = "id", type = IdType.AUTO) + @Excel(name = "主键") + private Long id; + /** + * 字段名称 + */ + @Excel(name = "字段名称") + private String name; + /** + * 字段注释 + */ + @Excel(name = "字段注释") + private String comment; + /** + * 是否主键 + */ + @Excel(name = "是否主键") + private String isPrimaryKey; + /** + * 字段类型 + */ + @Excel(name = "字段类型") + private String type; + /** + * 映射类型 + */ + @Excel(name = "映射类型") + private String mappingType; + /** + * 长度 + */ + @Excel(name = "长度") + private Integer length; + /** + * 小数位 + */ + @Excel(name = "小数位") + private Integer decimalPlaces; + /** + * 是否为空 + */ + @Excel(name = "是否为空") + private String isNull; + /** + * 默认值 + */ + @Excel(name = "默认值") + private String defaultValue; + /** + * 是否字典 + */ + @Excel(name = "是否字典") + private String isDict; + /** + * 映射字典 + */ + @Excel(name = "映射字典") + private String dictKey; + /** + * 数据库结构ID + */ + @Excel(name = "数据库结构ID") + private Integer childrenId; + +} diff --git a/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/req/DataSourceEditReq.java b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/req/DataSourceEditReq.java new file mode 100644 index 0000000..7af1b96 --- /dev/null +++ b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/req/DataSourceEditReq.java @@ -0,0 +1,110 @@ +package com.muyu.cloud.etl.domain.source.req; + +import com.muyu.common.core.web.domain.BaseEntity; +import io.swagger.v3.oas.annotations.tags.Tag; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; + +/** + * @author Lenovo + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-14:14 + * @ Version：1.0 + * @ Description：数据源对象 + */ + +@Data +@AllArgsConstructor +@NoArgsConstructor +@Tag(name = "数据源列表") +@EqualsAndHashCode(callSuper = true) +public class DataSourceEditReq extends BaseEntity { + private static final long serialVersionUID = 1L; + + /** + * 接入源名称 + */ + + private String name; + + /** + * 数据来源系统名称 + */ + + private String systemName; + + /** + * 数据库类型 + */ + + private String dataType; + + /** + * ip地址 + */ + + private String ip; + + /** + * 端口号 + */ + + private String port; + + /** + * 数据库名称 + */ + + private String databaseName; + + /** + * 用户名 + */ + + private String userName; + + /** + * 密码 + */ + + private String password; + + /** + * 数据连接参数 + */ + + private String connectionParam; + + /** + * 是否初始化 + */ + + private String isInit; + + /** + * 初始连接数量 + */ + + private Long initTotal; + + /** + * 最大连接数量 + */ + + private Long maxNum; + + /** + * 最大等待时间 + */ + + private Long maxWaitTime; + + /** + * 最大等待次数 + */ + + private Long maxWaitSize; +} diff --git a/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/req/DataSourceQueryReq.java b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/req/DataSourceQueryReq.java new file mode 100644 index 0000000..b2f365a --- /dev/null +++ b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/req/DataSourceQueryReq.java @@ -0,0 +1,37 @@ +package com.muyu.cloud.etl.domain.source.req; + +import com.muyu.common.core.web.domain.BaseEntity; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; + +/** + * @author Lenovo + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-14:17 + * @ Version：1.0 + * @ Description：数据源 + */ +@Data +@SuperBuilder +@NoArgsConstructor +@AllArgsConstructor +@EqualsAndHashCode(callSuper = true) +public class DataSourceQueryReq extends BaseEntity { + + private static final long serialVersionUID = 1L; + + /** + * 接入源名称 + */ + private String name; + + /** + * 数据来源系统名称 + */ + private String systemName; + +} diff --git a/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/resp/StatisticsResp.java b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/resp/StatisticsResp.java new file mode 100644 index 0000000..1122ca6 --- /dev/null +++ b/cloud-etl-common/src/main/java/com/muyu/cloud/etl/domain/source/resp/StatisticsResp.java @@ -0,0 +1,32 @@ +package com.muyu.cloud.etl.domain.source.resp; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-21:50 + * @ Version：1.0 + * @ Description：统计 + * @author Lenovo + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +public class StatisticsResp { + + /** + * 数据接入统计数量 + */ + private Long dataAccessQuantity; + /** + * 资产模型统计数量 + */ + private Long assetModelQuantity; + /** + * 数据源统计数量 + */ + private Long numberOfDataModels; +} diff --git a/cloud-etl-remote/src/main/java/com/muyu/Main.java b/cloud-etl-remote/src/main/java/com/muyu/Main.java deleted file mode 100644 index 95690d4..0000000 --- a/cloud-etl-remote/src/main/java/com/muyu/Main.java +++ /dev/null @@ -1,7 +0,0 @@ -package com.muyu; - -public class Main { - public static void main(String[] args) { - System.out.println("Hello world!"); - } -} \ No newline at end of file diff --git a/cloud-etl-remote/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports b/cloud-etl-remote/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports new file mode 100644 index 0000000..8b13789 --- /dev/null +++ b/cloud-etl-remote/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports @@ -0,0 +1 @@ + diff --git a/cloud-etl-server/src/main/java/com/muyu/Main.java b/cloud-etl-server/src/main/java/com/muyu/Main.java deleted file mode 100644 index 95690d4..0000000 --- a/cloud-etl-server/src/main/java/com/muyu/Main.java +++ /dev/null @@ -1,7 +0,0 @@ -package com.muyu; - -public class Main { - public static void main(String[] args) { - System.out.println("Hello world!"); - } -} \ No newline at end of file diff --git a/cloud-etl-server/src/main/java/com/muyu/source/MuYuSourceApplication.java b/cloud-etl-server/src/main/java/com/muyu/source/MuYuSourceApplication.java new file mode 100644 index 0000000..10931b1 --- /dev/null +++ b/cloud-etl-server/src/main/java/com/muyu/source/MuYuSourceApplication.java @@ -0,0 +1,23 @@ +package com.muyu.source; + +import com.muyu.common.security.annotation.EnableCustomConfig; +import com.muyu.common.security.annotation.EnableMyFeignClients; +import groovy.util.logging.Log4j2; +import org.springframework.boot.SpringApplication; +import org.springframework.boot.autoconfigure.SpringBootApplication; + +/** + * @author Lenovo + * 支付启动类 + */ + +@Log4j2 +@EnableCustomConfig +@EnableMyFeignClients +@SpringBootApplication +public class MuYuSourceApplication { + public static void main (String[] args) { + SpringApplication.run(MuYuSourceApplication.class, args); + } + +} diff --git a/cloud-etl-server/src/main/java/com/muyu/source/config/MybatisPlusConfig.java b/cloud-etl-server/src/main/java/com/muyu/source/config/MybatisPlusConfig.java new file mode 100644 index 0000000..2d701ac --- /dev/null +++ b/cloud-etl-server/src/main/java/com/muyu/source/config/MybatisPlusConfig.java @@ -0,0 +1,45 @@ +package com.muyu.source.config; + +import com.baomidou.mybatisplus.annotation.DbType; +import com.baomidou.mybatisplus.extension.plugins.inner.BlockAttackInnerInterceptor; +import com.baomidou.mybatisplus.extension.plugins.inner.OptimisticLockerInnerInterceptor; +import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor; +import org.springframework.context.annotation.Bean; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-20-22:36 + * @ Version：1.0 + * @ Description：Mybatis Plus 配置 + * @author Lenovo + */ +public class MybatisPlusConfig { + // 配置分页插件 + @Bean + public PaginationInnerInterceptor paginationInnerInterceptor() { + PaginationInnerInterceptor paginationInnerInterceptor = new PaginationInnerInterceptor(); + // 设置数据库类型为mysql + paginationInnerInterceptor.setDbType(DbType.MYSQL); + // 设置最大单页限制数量，默认 500 条，-1 不受限制 + paginationInnerInterceptor.setMaxLimit(-1L); + return paginationInnerInterceptor; + } + @Bean + /** + * 乐观锁插件 https://baomidou.com/guide/interceptor-optimistic-locker.html + */ + public OptimisticLockerInnerInterceptor optimisticLockerInnerInterceptor() + { + return new OptimisticLockerInnerInterceptor(); + } + @Bean + /** + * 如果是对全表的删除或更新操作，就会终止该操作 https://baomidou.com/guide/interceptor-block-attack.html + */ + public BlockAttackInnerInterceptor blockAttackInnerInterceptor() + { + return new BlockAttackInnerInterceptor(); + } + +} diff --git a/cloud-etl-server/src/main/java/com/muyu/source/controller/DataSourceController.java b/cloud-etl-server/src/main/java/com/muyu/source/controller/DataSourceController.java new file mode 100644 index 0000000..3073272 --- /dev/null +++ b/cloud-etl-server/src/main/java/com/muyu/source/controller/DataSourceController.java @@ -0,0 +1,78 @@ +package com.muyu.source.controller; + +import com.muyu.cloud.etl.domain.source.DataSource; +import com.muyu.common.core.domain.Result; +import com.muyu.common.core.web.controller.BaseController; +import com.muyu.source.service.DataSourceService; +import io.swagger.v3.oas.annotations.tags.Tag; +import lombok.extern.log4j.Log4j2; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import java.util.List; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-20-18:34 + * @ Version：1.0 + * @ Description：数据源控制层 + * @author Lenovo + */ +@Log4j2 +@RestController +@RequestMapping("/dataSource") +@Tag(name = "数据源控制层",description = "进行数据源管理，查看等相关操作") +public class DataSourceController extends BaseController { + + /** + * 数据源业务层 + */ + @Autowired + private DataSourceService dataSourceService; + + /** + * 查询数据源的全部数据 + * @return + */ + @GetMapping("/list") + public Result> list(){ + List list =dataSourceService.list(); + return Result.success(list); + } + + /** + * 添加数据源 + * @param dataSource + * @return + */ + @PostMapping("/insert") + public Result insert(@RequestBody DataSource dataSource){ + dataSourceService.save(dataSource); + return Result.success(); + } + + /** + * 修改数据源 + * @param dataSource + * @return + */ + @PutMapping("/update") + public Result update(@RequestBody DataSource dataSource){ + dataSourceService.updateById(dataSource); + return Result.success(); + } + + /** + * 删除数据源 + * @param dataSource + * @return + */ + @DeleteMapping("/delete") + public Result delete(@RequestBody DataSource dataSource){ + dataSourceService.removeById(dataSource); + return Result.success(); + } + + +} diff --git a/cloud-etl-server/src/main/java/com/muyu/source/mapper/DataSourceMapper.java b/cloud-etl-server/src/main/java/com/muyu/source/mapper/DataSourceMapper.java new file mode 100644 index 0000000..6140f92 --- /dev/null +++ b/cloud-etl-server/src/main/java/com/muyu/source/mapper/DataSourceMapper.java @@ -0,0 +1,17 @@ +package com.muyu.source.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.muyu.cloud.etl.domain.source.DataSource; +import org.apache.ibatis.annotations.Mapper; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-20-20:03 + * @ Version：1.0 + * @ Description：数据源持久层 + * @author Lenovo + */ +@Mapper +public interface DataSourceMapper extends BaseMapper { +} diff --git a/cloud-etl-server/src/main/java/com/muyu/source/service/DataSourceService.java b/cloud-etl-server/src/main/java/com/muyu/source/service/DataSourceService.java new file mode 100644 index 0000000..4ebaaf9 --- /dev/null +++ b/cloud-etl-server/src/main/java/com/muyu/source/service/DataSourceService.java @@ -0,0 +1,18 @@ +package com.muyu.source.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.muyu.cloud.etl.domain.source.DataSource; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-20-20:06 + * @ Version：1.0 + * @ Description：数据源业务层 + * @author Lenovo + */ +public interface DataSourceService extends IService { + + + +} diff --git a/cloud-etl-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java b/cloud-etl-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java new file mode 100644 index 0000000..5ac5903 --- /dev/null +++ b/cloud-etl-server/src/main/java/com/muyu/source/service/Impl/DataSourceServiceImpl.java @@ -0,0 +1,22 @@ +package com.muyu.source.service.Impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.muyu.cloud.etl.domain.source.DataSource; +import com.muyu.source.mapper.DataSourceMapper; +import com.muyu.source.service.DataSourceService; +import org.springframework.stereotype.Service; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-20-20:06 + * @ Version：1.0 + * @ Description：数据源业务层 + * @author Lenovo + */ +@Service +public class DataSourceServiceImpl extends ServiceImpl implements DataSourceService { + + +} + diff --git a/cloud-etl-server/src/main/resources/banner.txt b/cloud-etl-server/src/main/resources/banner.txt new file mode 100644 index 0000000..0dd5eee --- /dev/null +++ b/cloud-etl-server/src/main/resources/banner.txt @@ -0,0 +1,2 @@ +Spring Boot Version: ${spring-boot.version} +Spring Application Name: ${spring.application.name} diff --git a/cloud-etl-server/src/main/resources/bootstrap.yml b/cloud-etl-server/src/main/resources/bootstrap.yml new file mode 100644 index 0000000..fb36461 --- /dev/null +++ b/cloud-etl-server/src/main/resources/bootstrap.yml @@ -0,0 +1,63 @@ +# Tomcat +server: + port: 19652 + +# nacos线上地址 +nacos: + addr: 10.0.1.97:8848 + user-name: nacos + password: nacos + namespace: cloud-2112 + + +# Spring +spring: + main: + allow-bean-definition-overriding: true + application: + # 应用名称 + name: muyu-source + profiles: + # 环境配置 + active: dev + cloud: + nacos: + discovery: + # 服务注册地址 + server-addr: ${nacos.addr} + # nacos用户名 + username: ${nacos.user-name} + # nacos密码 + password: ${nacos.password} + + namespace: ${nacos.namespace} + config: + # 服务注册地址 + server-addr: ${nacos.addr} + # nacos用户名 + username: ${nacos.user-name} + # nacos密码 + password: ${nacos.password} + + namespace: ${nacos.namespace} + # 配置文件格式 + file-extension: yml + # 共享配置 + shared-configs: + # 系统共享配置 + - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} + # 系统环境Config共享配置 + - application-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} + # xxl-job 配置文件 + - application-xxl-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} + # rabbit 配置文件 + - application-rabbit-config-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} +#mybatis-plus 配置 +mybatis-plus: + #xml文件位置 + mapper-locations: classpath:mapper/*.xml + configuration: + #控制台打印信息 + log-impl: org.apache.ibatis.logging.stdout.StdOutImpl + #驼峰配置 + map-underscore-to-camel-case: true diff --git a/cloud-etl-server/src/main/resources/logback/dev.xml b/cloud-etl-server/src/main/resources/logback/dev.xml new file mode 100644 index 0000000..f025146 --- /dev/null +++ b/cloud-etl-server/src/main/resources/logback/dev.xml @@ -0,0 +1,74 @@ + + + + + + + + + + + ${log.pattern} + + + + + + ${log.path}/info.log + + + + ${log.path}/info.%d{yyyy-MM-dd}.log + + 60 + + + ${log.pattern} + + + + INFO + + ACCEPT + + DENY + + + + + ${log.path}/error.log + + + + ${log.path}/error.%d{yyyy-MM-dd}.log + + 60 + + + ${log.pattern} + + + + ERROR + + ACCEPT + + DENY + + + + + + + + + + + + + + + + + + diff --git a/cloud-etl-server/src/main/resources/logback/prod.xml b/cloud-etl-server/src/main/resources/logback/prod.xml new file mode 100644 index 0000000..08fb191 --- /dev/null +++ b/cloud-etl-server/src/main/resources/logback/prod.xml @@ -0,0 +1,81 @@ + + + + + + + + + + + + ${log.sky.pattern} + + + + + + ${log.path}/info.log + + + + ${log.path}/info.%d{yyyy-MM-dd}.log + + 60 + + + + + INFO + + ACCEPT + + DENY + + + + + ${log.path}/error.log + + + + ${log.path}/error.%d{yyyy-MM-dd}.log + + 60 + + + + + ERROR + + ACCEPT + + DENY + + + + + + + + ${log.sky.pattern} + + + + + + + + + + + + + + + + + + + + diff --git a/cloud-etl-server/src/main/resources/logback/test.xml b/cloud-etl-server/src/main/resources/logback/test.xml new file mode 100644 index 0000000..08fb191 --- /dev/null +++ b/cloud-etl-server/src/main/resources/logback/test.xml @@ -0,0 +1,81 @@ + + + + + + + + + + + + ${log.sky.pattern} + + + + + + ${log.path}/info.log + + + + ${log.path}/info.%d{yyyy-MM-dd}.log + + 60 + + + + + INFO + + ACCEPT + + DENY + + + + + ${log.path}/error.log + + + + ${log.path}/error.%d{yyyy-MM-dd}.log + + 60 + + + + + ERROR + + ACCEPT + + DENY + + + + + + + + ${log.sky.pattern} + + + + + + + + + + + + + + + + + + + +