From 79e01bba597d27d631ef4afaf9cb6d25c4d079ba Mon Sep 17 00:00:00 2001 From: MD04192 Date: Wed, 6 Aug 2025 08:28:45 +0800 Subject: [PATCH] =?UTF-8?q?:memo:=20=E4=BF=AE=E6=94=B9=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dataCollect/BusinessDataController.java | 29 ------ .../dataCollect/BusinessSourceController.java | 52 +++++----- .../dataCollect/BusinessTableController.java | 63 +++++++++++- .../cdr/dataCollect/dao/BusinessDataDao.java | 96 ++++++++++++++++++- .../dao/entity/BusinessDataSource.java | 2 +- .../dao/entity/BusinessDataSystem.java | 2 +- .../dao/entity/BusinessDataTable.java | 2 +- .../dao/entity/BusinessDataTableField.java | 2 +- .../endpoint/bo/BusinessTableBO.java | 19 ++++ .../endpoint/param/DataSourceAddParam.java | 54 +++++++++++ .../endpoint/param/DataSourceDeleteParam.java | 19 ++++ .../endpoint/param/DataSourceUpdateParam.java | 63 ++++++++++++ .../endpoint/param/DataSystemAddParam.java | 1 + .../endpoint/param/DataTableAddParam.java | 48 ++++++++++ .../endpoint/param/DataTableDeleteParam.java | 19 ++++ .../endpoint/param/DataTableUpdateParam.java | 56 +++++++++++ .../endpoint/vo/BusinessDataSourceVo.java | 4 +- .../inner/BusinessSourceRepository.java | 60 ++++++++++++ .../inner/BusinessSystemRepository.java | 1 - .../inner/BusinessTableRepository.java | 61 ++++++++++++ .../com/ediagnosis/cdr/dao/MapperTest.java | 28 ++++++ 21 files changed, 615 insertions(+), 66 deletions(-) create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/bo/BusinessTableBO.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceAddParam.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceDeleteParam.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceUpdateParam.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableAddParam.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableDeleteParam.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableUpdateParam.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSourceRepository.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessTableRepository.java diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataController.java b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataController.java index c156264..283dfc2 100644 --- a/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataController.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataController.java @@ -31,35 +31,6 @@ public class BusinessDataController { private final BusinessDataRepository dataRepository; - - @PostMapping("/dataSource/page") - public Response> page(@RequestBody DataSourceQueryParam queryParam) { - BusinessDataSourceQueryDTO queryDTO = new BusinessDataSourceQueryDTO(); - BeanUtils.copyProperties(queryParam, queryDTO); - Page dataSourcePage = dataRepository.querySourcePage(queryDTO); - PageVo systemVoPageInfo = PageConvertUtils.copyPageInfo(dataSourcePage, dataSourceDTO -> { - BusinessDataSourceVo vo = new BusinessDataSourceVo(); - BeanUtils.copyProperties(dataSourceDTO, vo); - vo.setBizSystemId(dataSourceDTO.getBusinessId()); - vo.setBizSystemName(dataSourceDTO.getBusinessName()); - return vo; - }); - return Response.success(systemVoPageInfo); - } - - @PostMapping("/dataTable/page") - public Response> page(@RequestBody DataTableQueryParam queryParam) { - BusinessDataTableQueryDTO queryDTO = new BusinessDataTableQueryDTO(); - BeanUtils.copyProperties(queryParam, queryDTO); - Page dataTablePage = dataRepository.queryTablePage(queryDTO); - PageVo dataTableVoPageInfo = PageConvertUtils.copyPageInfo(dataTablePage, dataTable -> { - BusinessDataTableVo vo = new BusinessDataTableVo(); - BeanUtils.copyProperties(dataTable, vo); - return vo; - }); - return Response.success(dataTableVoPageInfo); - } - @PostMapping("/dataTableField/page") public Response> page(@RequestBody DataTableFieldQueryParam queryParam) { BusinessDataTableFieldQueryDTO queryDTO = new BusinessDataTableFieldQueryDTO(); diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSourceController.java b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSourceController.java index 488ccbb..3b88b19 100644 --- a/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSourceController.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSourceController.java @@ -1,14 +1,13 @@ package com.ediagnosis.cdr.dataCollect; -import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataSystemDTO; -import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataSystemQueryDTO; -import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSystem; -import com.ediagnosis.cdr.dataCollect.endpoint.param.DataSystemAddParam; -import com.ediagnosis.cdr.dataCollect.endpoint.param.DataSystemDeleteParam; -import com.ediagnosis.cdr.dataCollect.endpoint.param.DataSystemQueryParam; -import com.ediagnosis.cdr.dataCollect.endpoint.param.DataSystemUpdateParam; -import com.ediagnosis.cdr.dataCollect.endpoint.vo.BusinessDataSystemVo; -import com.ediagnosis.cdr.dataCollect.inner.BusinessSystemRepository; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataSourceDTO; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataSourceQueryDTO; +import com.ediagnosis.cdr.dataCollect.endpoint.param.DataSourceAddParam; +import com.ediagnosis.cdr.dataCollect.endpoint.param.DataSourceDeleteParam; +import com.ediagnosis.cdr.dataCollect.endpoint.param.DataSourceQueryParam; +import com.ediagnosis.cdr.dataCollect.endpoint.param.DataSourceUpdateParam; +import com.ediagnosis.cdr.dataCollect.endpoint.vo.BusinessDataSourceVo; +import com.ediagnosis.cdr.dataCollect.inner.BusinessSourceRepository; import com.ediagnosis.cdr.util.PageConvertUtils; import com.ediagnosis.cdr.value.PageVo; import com.ediagnosis.cdr.value.Response; @@ -20,9 +19,10 @@ import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; + /** * @author monojun - * @description TODO + * @description 数据源controller * @createTime 2025年08月05日 */ @RestController @@ -30,34 +30,34 @@ import org.springframework.web.bind.annotation.RestController; @RequiredArgsConstructor public class BusinessSourceController { - private final BusinessSystemRepository systemRepository; + private final BusinessSourceRepository sourceRepository; @PostMapping("/add") - public Response page(@RequestBody DataSystemAddParam addParam) { - BusinessDataSystemDTO addDTO = new BusinessDataSystemDTO(); + public Response page(@RequestBody DataSourceAddParam addParam) { + BusinessDataSourceDTO addDTO = new BusinessDataSourceDTO(); BeanUtils.copyProperties(addParam, addDTO); - Long id = systemRepository.addDataSystem(addDTO); + Long id = sourceRepository.addDataSource(addDTO); return Response.success(id); } @PostMapping("/update") - public Response update(@RequestBody DataSystemUpdateParam updateParam) { - BusinessDataSystemDTO addDTO = new BusinessDataSystemDTO(); - BeanUtils.copyProperties(updateParam, addDTO); - Long id = systemRepository.updateDataSystem(addDTO); + public Response update(@RequestBody DataSourceUpdateParam updateParam) { + BusinessDataSourceDTO updateDTO = new BusinessDataSourceDTO(); + BeanUtils.copyProperties(updateParam, updateDTO); + Long id = sourceRepository.updateDataSource(updateDTO); return Response.success(id); } @PostMapping("/page") - public Response> page(@RequestBody DataSystemQueryParam queryParam) { - BusinessDataSystemQueryDTO queryDTO = new BusinessDataSystemQueryDTO(); + public Response> page(@RequestBody DataSourceQueryParam queryParam) { + BusinessDataSourceQueryDTO queryDTO = new BusinessDataSourceQueryDTO(); BeanUtils.copyProperties(queryParam, queryDTO); - Page dataSystemPage = systemRepository.queryPage(queryDTO); - PageVo systemVoPageInfo = PageConvertUtils.copyPageInfo(dataSystemPage, dataSystem -> { - BusinessDataSystemVo vo = new BusinessDataSystemVo(); - BeanUtils.copyProperties(dataSystem, vo); + Page dataSourcePage = sourceRepository.queryPage(queryDTO); + PageVo systemVoPageInfo = PageConvertUtils.copyPageInfo(dataSourcePage, dataSource -> { + BusinessDataSourceVo vo = new BusinessDataSourceVo(); + BeanUtils.copyProperties(dataSource, vo); return vo; }); return Response.success(systemVoPageInfo); @@ -65,8 +65,8 @@ public class BusinessSourceController { @PostMapping("/delete") - public Response delete(@RequestBody DataSystemDeleteParam deleteParam) { - systemRepository.deleteDataSystem(deleteParam.getId()); + public Response delete(@RequestBody DataSourceDeleteParam deleteParam) { + sourceRepository.deleteDataSource(deleteParam.getId()); return Response.success(deleteParam.getId()); } diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessTableController.java b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessTableController.java index 4c0529c..602af91 100644 --- a/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessTableController.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessTableController.java @@ -1,9 +1,70 @@ package com.ediagnosis.cdr.dataCollect; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataSystemQueryDTO; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataTableDTO; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataTableQueryDTO; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSystem; +import com.ediagnosis.cdr.dataCollect.endpoint.param.*; +import com.ediagnosis.cdr.dataCollect.endpoint.vo.BusinessDataSystemVo; +import com.ediagnosis.cdr.dataCollect.endpoint.vo.BusinessDataTableVo; +import com.ediagnosis.cdr.dataCollect.inner.BusinessTableRepository; +import com.ediagnosis.cdr.util.PageConvertUtils; +import com.ediagnosis.cdr.value.PageVo; +import com.ediagnosis.cdr.value.Response; +import com.mybatisflex.core.paginate.Page; +import lombok.RequiredArgsConstructor; +import org.springframework.beans.BeanUtils; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + /** * @author monojun - * @description TODO + * @description 源数据表controller * @createTime 2025年08月05日 */ +@RestController +@RequestMapping("/dataTable") +@RequiredArgsConstructor public class BusinessTableController { + + private final BusinessTableRepository tableRepository; + + @PostMapping("/add") + public Response page(@RequestBody DataTableAddParam addParam) { + BusinessDataTableDTO addDTO = new BusinessDataTableDTO(); + BeanUtils.copyProperties(addParam, addDTO); + Long id = tableRepository.addDataTable(addDTO); + return Response.success(id); + } + + @PostMapping("/update") + public Response update(@RequestBody DataTableUpdateParam updateParam) { + BusinessDataTableDTO updateDTO = new BusinessDataTableDTO(); + BeanUtils.copyProperties(updateParam, updateDTO); + Long id = tableRepository.updateDataTable(updateDTO); + return Response.success(id); + } + + + @PostMapping("/page") + public Response> page(@RequestBody DataTableQueryParam queryParam) { + BusinessDataTableQueryDTO queryDTO = new BusinessDataTableQueryDTO(); + BeanUtils.copyProperties(queryParam, queryDTO); + Page dataSystemPage = tableRepository.queryPage(queryDTO); + PageVo systemVoPageInfo = PageConvertUtils.copyPageInfo(dataSystemPage, dataTableDTO -> { + BusinessDataTableVo vo = new BusinessDataTableVo(); + BeanUtils.copyProperties(dataTableDTO, vo); + return vo; + }); + return Response.success(systemVoPageInfo); + } + + + @PostMapping("/delete") + public Response delete(@RequestBody DataTableDeleteParam deleteParam) { + tableRepository.deleteDataSystem(deleteParam.getId()); + return Response.success(deleteParam.getId()); + } } diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/dao/BusinessDataDao.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/BusinessDataDao.java index 0e4e2b0..24b5017 100644 --- a/src/main/java/com/ediagnosis/cdr/dataCollect/dao/BusinessDataDao.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/BusinessDataDao.java @@ -66,6 +66,20 @@ public class BusinessDataDao { return dataSystem.getId(); } + /** + * 新增or更新业务系统 + * + * @param dataSystemDTO dataSystemDTO + * @return 业务系统主键id + */ + public Long insertOrUpdateSystem(BusinessDataSystemDTO dataSystemDTO) { + BusinessDataSystem dataSystem = new BusinessDataSystem(); + BeanUtils.copyProperties(dataSystemDTO, dataSystem); + dataSystem.setUpdateTime(new Date()); + dataSystemMapper.insertOrUpdate(dataSystem); + return dataSystem.getId(); + } + /** * 删除业务系统 * @@ -91,6 +105,44 @@ public class BusinessDataDao { return dataSystemMapper.paginate(queryDTO.getPageNo(), queryDTO.getPageSize(), queryWrapper); } + /** + * 新增数据源 + * + * @param dataSourceDTO dataSourceDTO + * @return 数据源主键id + */ + public Long addDataSource(BusinessDataSourceDTO dataSourceDTO) { + BusinessDataSource dataSource = new BusinessDataSource(); + BeanUtils.copyProperties(dataSourceDTO, dataSource); + dataSource.setCreateTime(new Date()); + dataSource.setUpdateTime(new Date()); + dataSourceMapper.insert(dataSource); + return dataSource.getId(); + } + + /** + * 更新数据源 + * + * @param dataSourceDTO dataSourceDTO + * @return 数据源主键id + */ + public Long updateDataSource(BusinessDataSourceDTO dataSourceDTO) { + BusinessDataSource dataSource = new BusinessDataSource(); + BeanUtils.copyProperties(dataSourceDTO, dataSource); + dataSource.setUpdateTime(new Date()); + dataSourceMapper.update(dataSource); + return dataSource.getId(); + } + + /** + * 删除数据源 + * + * @param dataSourceId 数据源id + */ + public void deleteDataSource(Long dataSourceId) { + dataSourceMapper.deleteById(dataSourceId); + } + /** * 分页查询业务数据源信息 * @@ -123,6 +175,44 @@ public class BusinessDataDao { return dataSourceMapper.paginateAs(queryDTO.getPageNo(), queryDTO.getPageSize(), queryWrapper, BusinessDataSourceDTO.class); } + /** + * 新增数据表 + * + * @param dataTableDTO dataTableDTO + * @return 数据表主键id + */ + public Long addDataTable(BusinessDataTableDTO dataTableDTO) { + BusinessDataTable dataTable = new BusinessDataTable(); + BeanUtils.copyProperties(dataTableDTO, dataTable); + dataTable.setCreateTime(new Date()); + dataTable.setUpdateTime(new Date()); + dataTableMapper.insert(dataTable); + return dataTable.getId(); + } + + /** + * 更新业务系统 + * + * @param dataTableDTO dataTableDTO + * @return 数据表主键id + */ + public Long updateDataTable(BusinessDataTableDTO dataTableDTO) { + BusinessDataTable dataTable = new BusinessDataTable(); + BeanUtils.copyProperties(dataTableDTO, dataTable); + dataTable.setUpdateTime(new Date()); + dataTableMapper.update(dataTable); + return dataTable.getId(); + } + + /** + * 删除业务系统 + * + * @param dataTableId 业务系统id + */ + public void deleteDataTable(Long dataTableId) { + dataTableMapper.deleteById(dataTableId); + } + /** * 分页查询业务表信息 * @@ -139,12 +229,12 @@ public class BusinessDataDao { .on(BusinessDataSource::getBusinessId, BusinessDataSystem::getId) .orderBy(BusinessDataTable::getUpdateTime, false) .orderBy(BusinessDataTable::getId, false); + if (!CollectionUtils.isEmpty(queryDTO.getBusinessIds())) { + queryWrapper.in(BusinessDataSource::getBusinessId, queryDTO.getBusinessIds()); + } if (StringUtils.hasText(queryDTO.getName())) { queryWrapper.like(BusinessDataTable::getName, queryDTO.getName()); } - if (!CollectionUtils.isEmpty(queryDTO.getBusinessIds())) { - queryWrapper.in(BusinessDataTable::getBusinessId, queryDTO.getBusinessIds()); - } if (!CollectionUtils.isEmpty(queryDTO.getSourceIds())) { queryWrapper.in(BusinessDataTable::getSourceId, queryDTO.getSourceIds()); } diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSource.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSource.java index 79ac5ac..560750f 100644 --- a/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSource.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSource.java @@ -96,6 +96,6 @@ public class BusinessDataSource implements Serializable { /** * 是否删除: 0-未删除 1-已删除 */ - @Column(value = "is_deleted", isLogicDelete = true) + @Column(value = "is_deleted") private Integer isDeleted; } \ No newline at end of file diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSystem.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSystem.java index 168199c..e619432 100644 --- a/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSystem.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSystem.java @@ -61,6 +61,6 @@ public class BusinessDataSystem { /** * 是否删除 0-未删除 1-已删除 */ - @Column(value = "is_deleted", isLogicDelete = true) + @Column(value = "is_deleted") private Integer isDeleted; } \ No newline at end of file diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTable.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTable.java index 597d10d..a1b0d15 100644 --- a/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTable.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTable.java @@ -85,6 +85,6 @@ public class BusinessDataTable implements Serializable { /** * 是否删除: 0-未删除 1-已删除 */ - @Column(value = "is_deleted", isLogicDelete = true) + @Column(value = "is_deleted") private Byte isDeleted; } \ No newline at end of file diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTableField.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTableField.java index a2509c0..827b424 100644 --- a/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTableField.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTableField.java @@ -78,6 +78,6 @@ public class BusinessDataTableField implements Serializable { /** * 是否删除: 0-未删除 1-已删除 */ - @Column(value = "is_deleted", isLogicDelete = true) + @Column(value = "is_deleted") private Byte isDeleted; } \ No newline at end of file diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/bo/BusinessTableBO.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/bo/BusinessTableBO.java new file mode 100644 index 0000000..6d3f403 --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/bo/BusinessTableBO.java @@ -0,0 +1,19 @@ +package com.ediagnosis.cdr.dataCollect.endpoint.bo; + +import lombok.Data; + +import java.io.Serial; +import java.io.Serializable; + +/** + * @author monojun + * @description 业务表bo + * @createTime 2025年08月05日 + */ +@Data +public class BusinessTableBO implements Serializable { + @Serial + private static final long serialVersionUID = 3274296809089410424L; + + +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceAddParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceAddParam.java new file mode 100644 index 0000000..a850eaf --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceAddParam.java @@ -0,0 +1,54 @@ +package com.ediagnosis.cdr.dataCollect.endpoint.param; + +import com.mybatisflex.annotation.Column; +import lombok.Data; + +import java.io.Serial; +import java.io.Serializable; + +/** + * @author monojun + * @description 数据源新增参数 + * @createTime 2025年08月05日 + */ +@Data +public class DataSourceAddParam implements Serializable { + @Serial + private static final long serialVersionUID = 5282468723403441092L; + + /** + * 数据源名称 + */ + @Column(value = "name") + private String name; + + /** + * 数据源类型 + */ + @Column(value = "type") + private String type; + + /** + * IP地址 + */ + @Column(value = "ip_address") + private String ipAddress; + + /** + * 属性信息 + */ + @Column(value = "properties") + private String properties; + + /** + * 业务系统id + */ + @Column(value = "business_id") + private Long businessId; + + /** + * 描述 + */ + @Column(value = "description") + private String description; +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceDeleteParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceDeleteParam.java new file mode 100644 index 0000000..9dae256 --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceDeleteParam.java @@ -0,0 +1,19 @@ +package com.ediagnosis.cdr.dataCollect.endpoint.param; + +import lombok.Data; + +import java.io.Serial; +import java.io.Serializable; + +/** + * @author monojun + * @description 数据源删除参数 + * @createTime 2025年08月05日 + */ +@Data +public class DataSourceDeleteParam implements Serializable { + @Serial + private static final long serialVersionUID = -1494009606397055551L; + + private Long id; +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceUpdateParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceUpdateParam.java new file mode 100644 index 0000000..62eb196 --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceUpdateParam.java @@ -0,0 +1,63 @@ +package com.ediagnosis.cdr.dataCollect.endpoint.param; + +import com.mybatisflex.annotation.Column; +import com.mybatisflex.annotation.Id; +import com.mybatisflex.annotation.KeyType; +import lombok.Data; + +import java.io.Serial; +import java.io.Serializable; + +/** + * @author monojun + * @description 数据源更新参数 + * @createTime 2025年08月05日 + */ +@Data +public class DataSourceUpdateParam implements Serializable { + @Serial + private static final long serialVersionUID = -7780208261663923172L; + + /** + * 主键id + */ + @Id(value = "id", keyType = KeyType.Auto) + + private Long id; + + /** + * 数据源名称 + */ + @Column(value = "name") + private String name; + + /** + * 数据源类型 + */ + @Column(value = "type") + private String type; + + /** + * IP地址 + */ + @Column(value = "ip_address") + private String ipAddress; + + /** + * 属性信息 + */ + @Column(value = "properties") + private String properties; + + /** + * 业务系统id + */ + @Column(value = "business_id") + private Long businessId; + + /** + * 描述 + */ + @Column(value = "description") + private String description; +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemAddParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemAddParam.java index f7ab46d..92eb90b 100644 --- a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemAddParam.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemAddParam.java @@ -1,5 +1,6 @@ package com.ediagnosis.cdr.dataCollect.endpoint.param; +import jakarta.validation.constraints.NotBlank; import lombok.Data; import java.io.Serial; diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableAddParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableAddParam.java new file mode 100644 index 0000000..c9ef290 --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableAddParam.java @@ -0,0 +1,48 @@ +package com.ediagnosis.cdr.dataCollect.endpoint.param; + +import com.mybatisflex.annotation.Column; +import lombok.Data; + +import java.io.Serial; +import java.io.Serializable; + +/** + * @author monojun + * @description 数据表新增参数 + * @createTime 2025年08月05日 + */ +@Data +public class DataTableAddParam implements Serializable { + @Serial + private static final long serialVersionUID = 3378139727731995899L; + + /** + * 业务表名称 + */ + @Column(value = "name") + private String name; + + /** + * 业务表编号 + */ + @Column(value = "table_no") + private String tableNo; + + /** + * 业务系统id + */ + @Column(value = "business_id") + private Long businessId; + + /** + * 业务数据源id + */ + @Column(value = "source_id") + private Long sourceId; + + /** + * 描述 + */ + @Column(value = "description") + private String description; +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableDeleteParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableDeleteParam.java new file mode 100644 index 0000000..20f306f --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableDeleteParam.java @@ -0,0 +1,19 @@ +package com.ediagnosis.cdr.dataCollect.endpoint.param; + +import lombok.Data; + +import java.io.Serial; +import java.io.Serializable; + +/** + * @author monojun + * @description 数据表删除参数 + * @createTime 2025年08月05日 + */ +@Data +public class DataTableDeleteParam implements Serializable { + @Serial + private static final long serialVersionUID = 6212775010515528227L; + + private Long id; +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableUpdateParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableUpdateParam.java new file mode 100644 index 0000000..a7fa247 --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableUpdateParam.java @@ -0,0 +1,56 @@ +package com.ediagnosis.cdr.dataCollect.endpoint.param; + +import com.mybatisflex.annotation.Column; +import com.mybatisflex.annotation.Id; +import com.mybatisflex.annotation.KeyType; +import lombok.Data; + +import java.io.Serial; +import java.io.Serializable; + +/** + * @author monojun + * @description 数据表更新参数 + * @createTime 2025年08月05日 + */ +@Data +public class DataTableUpdateParam implements Serializable { + @Serial + private static final long serialVersionUID = 646168747509610187L; + + /** + * 主键id + */ + @Id(value = "id", keyType = KeyType.Auto) + private Long id; + + /** + * 业务表名称 + */ + @Column(value = "name") + private String name; + + /** + * 业务表编号 + */ + @Column(value = "table_no") + private String tableNo; + + /** + * 业务系统id + */ + @Column(value = "business_id") + private Long businessId; + + /** + * 业务数据源id + */ + @Column(value = "source_id") + private Long sourceId; + + /** + * 描述 + */ + @Column(value = "description") + private String description; +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataSourceVo.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataSourceVo.java index 10d5bf3..f8a1804 100644 --- a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataSourceVo.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataSourceVo.java @@ -39,12 +39,12 @@ public class BusinessDataSourceVo implements Serializable { /** * 业务系统id */ - private Long bizSystemId; + private Long businessId; /** * 业务系统名称 */ - private String bizSystemName; + private String businessName; /** * 描述 diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSourceRepository.java b/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSourceRepository.java new file mode 100644 index 0000000..8262bff --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSourceRepository.java @@ -0,0 +1,60 @@ +package com.ediagnosis.cdr.dataCollect.inner; + +import com.ediagnosis.cdr.dataCollect.dao.BusinessDataDao; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataSourceDTO; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataSourceQueryDTO; +import com.mybatisflex.core.paginate.Page; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Repository; + +/** + * @author monojun + * @description 数据源Repository + * @createTime 2025年08月05日 + */ +@Repository +@RequiredArgsConstructor +public class BusinessSourceRepository { + + private final BusinessDataDao businessDataDao; + + /** + * 新增数据源 + * + * @param dataSourceDTO 数据源dto + * @return 数据源主键id + */ + public Long addDataSource(BusinessDataSourceDTO dataSourceDTO) { + return businessDataDao.addDataSource(dataSourceDTO); + } + + + /** + * 更新数据源 + * + * @param dataSourceDTO 业务系统dto + * @return 数据源主键id + */ + public Long updateDataSource(BusinessDataSourceDTO dataSourceDTO) { + return businessDataDao.updateDataSource(dataSourceDTO); + } + + /** + * 分页查询数据源信息 + * + * @param queryDTO 查询dto + * @return PageInfo + */ + public Page queryPage(BusinessDataSourceQueryDTO queryDTO) { + return businessDataDao.querySourcePage(queryDTO); + } + + /** + * 删除业务系统 + * + * @param dataSourceId 数据源id + */ + public void deleteDataSource(Long dataSourceId) { + businessDataDao.deleteDataSource(dataSourceId); + } +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSystemRepository.java b/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSystemRepository.java index 83be93b..b099b63 100644 --- a/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSystemRepository.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSystemRepository.java @@ -26,7 +26,6 @@ public class BusinessSystemRepository { * @return 业务系统主键id */ public Long addDataSystem(BusinessDataSystemDTO dataSystemDTO) { - businessDataDao.addDataSystem(dataSystemDTO); return businessDataDao.addDataSystem(dataSystemDTO); } diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessTableRepository.java b/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessTableRepository.java new file mode 100644 index 0000000..9b0bc8c --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessTableRepository.java @@ -0,0 +1,61 @@ +package com.ediagnosis.cdr.dataCollect.inner; + +import com.ediagnosis.cdr.dataCollect.dao.BusinessDataDao; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataTableDTO; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataTableQueryDTO; +import com.mybatisflex.core.paginate.Page; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Repository; +import org.springframework.util.CollectionUtils; + +/** + * @author monojun + * @description 数据表Repository + * @createTime 2025年08月05日 + */ +@Repository +@RequiredArgsConstructor +public class BusinessTableRepository { + + private final BusinessDataDao businessDataDao; + + /** + * 新增源业务表 + * + * @param dataTableDTO 源业务表dto + * @return 源业务表主键id + */ + public Long addDataTable(BusinessDataTableDTO dataTableDTO) { + return businessDataDao.addDataTable(dataTableDTO); + } + + + /** + * 更新源业务表 + * + * @param dataTableDTO 业务表dto + * @return 源业务表主键id + */ + public Long updateDataTable(BusinessDataTableDTO dataTableDTO) { + return businessDataDao.updateDataTable(dataTableDTO); + } + + /** + * 分页查询源业务表信息 + * + * @param queryDTO 查询dto + * @return PageInfo + */ + public Page queryPage(BusinessDataTableQueryDTO queryDTO) { + return businessDataDao.queryTablePage(queryDTO); + } + + /** + * 删除源业务表 + * + * @param dataTableId 源数据表id + */ + public void deleteDataSystem(Long dataTableId) { + businessDataDao.deleteDataTable(dataTableId); + } +} diff --git a/src/test/java/com/ediagnosis/cdr/dao/MapperTest.java b/src/test/java/com/ediagnosis/cdr/dao/MapperTest.java index 3eb473d..4887e74 100644 --- a/src/test/java/com/ediagnosis/cdr/dao/MapperTest.java +++ b/src/test/java/com/ediagnosis/cdr/dao/MapperTest.java @@ -1,8 +1,11 @@ package com.ediagnosis.cdr.dao; import com.ediagnosis.cdr.CdrApplication; +import com.ediagnosis.cdr.dataCollect.dao.BusinessDataDao; import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataSourceDTO; import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataSourceQueryDTO; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataTableDTO; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataTableQueryDTO; import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSource; import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSystem; import com.ediagnosis.cdr.dataCollect.dao.mapper.BusinessDataSourceMapper; @@ -12,6 +15,11 @@ import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; +import java.util.Arrays; +import java.util.List; +import java.util.stream.Collectors; +import java.util.stream.Stream; + /** * @author monojun * @description MapperTest @@ -23,6 +31,9 @@ public class MapperTest { @Autowired private BusinessDataSourceMapper dataSourceMapper; + @Autowired + private BusinessDataDao businessDataDao; + @Test public void test1() { BusinessDataSourceQueryDTO queryDTO = new BusinessDataSourceQueryDTO(); @@ -47,4 +58,21 @@ public class MapperTest { Page dataSourceDTOPage = dataSourceMapper.paginateAs(1, 10, queryWrapper, BusinessDataSourceDTO.class); System.out.println(dataSourceDTOPage); } + + @Test + public void test3() { + BusinessDataTableQueryDTO queryDTO = new BusinessDataTableQueryDTO(); + List businessIds = Arrays.asList(1L, 2L, 3L); + queryDTO.setBusinessIds(businessIds); + Page businessDataTableDTOPage = businessDataDao.queryTablePage(queryDTO); + System.out.println(businessDataTableDTOPage); + + BusinessDataTableQueryDTO query1DTO = new BusinessDataTableQueryDTO(); + List list = Stream.of(1L, 2L, 3L).collect(Collectors.toList()); + query1DTO.setSourceIds(list); + Page businessDataTableDTOPage1 = businessDataDao.queryTablePage(query1DTO); + System.out.println(businessDataTableDTOPage1); + } + + } -- 2.18.1