From ee24b431edb7c9856a8c8365a6661fb3905f9db2 Mon Sep 17 00:00:00 2001 From: MD04192 Date: Tue, 5 Aug 2025 10:05:50 +0800 Subject: [PATCH] =?UTF-8?q?:sparkles:=20=E6=8F=90=E4=BA=A4=E4=BB=A3?= =?UTF-8?q?=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 7 - .../com/ediagnosis/cdr/CdrApplication.java | 5 +- .../BusinessDataSourceController.java | 45 ----- .../BusinessDataSystemController.java | 43 ----- .../BusinessDataTableController.java | 43 ----- .../BusinessDataTableFieldController.java | 43 ----- .../dao/mapper/BusinessDataSourceMapper.java | 26 --- .../cdr/dataCollect/BusinessDataApi.java | 14 ++ .../dataCollect/BusinessDataController.java | 77 ++++++++ .../dataCollect/BusinessSourceController.java | 73 +++++++ .../dataCollect/BusinessSystemController.java | 74 ++++++++ .../dataCollect/BusinessTableController.java | 9 + .../cdr/dataCollect/dao/BusinessDataDao.java | 179 ++++++++++++++++++ .../dao}/dto/BusinessDataSourceDTO.java | 5 +- .../dao}/dto/BusinessDataSourceQueryDTO.java | 5 +- .../dao}/dto/BusinessDataSystemDTO.java | 2 +- .../dao}/dto/BusinessDataSystemQueryDTO.java | 4 +- .../dao}/dto/BusinessDataTableDTO.java | 2 +- .../dto/BusinessDataTableFieldQueryDTO.java | 4 +- .../dao}/dto/BusinessDataTableQueryDTO.java | 4 +- .../dao/entity/BusinessDataSource.java | 4 +- .../dao/entity/BusinessDataSystem.java | 4 +- .../dao/entity/BusinessDataTable.java | 4 +- .../dao/entity/BusinessDataTableField.java | 4 +- .../dao/mapper/BusinessDataSourceMapper.java | 20 ++ .../dao/mapper/BusinessDataSystemMapper.java | 12 +- .../mapper/BusinessDataTableFieldMapper.java | 11 +- .../dao/mapper/BusinessDataTableMapper.java | 10 +- .../endpoint/param/DataSourceQueryParam.java} | 6 +- .../endpoint/param/DataSystemAddParam.java | 29 +++ .../endpoint/param/DataSystemDeleteParam.java | 19 ++ .../endpoint/param/DataSystemQueryParam.java} | 6 +- .../endpoint/param/DataSystemUpdateParam.java | 29 +++ .../param/DataTableFieldQueryParam.java} | 6 +- .../endpoint/param/DataTableQueryParam.java} | 6 +- .../endpoint}/param/PageQuery.java | 2 +- .../endpoint}/vo/BusinessDataSourceVo.java | 2 +- .../endpoint}/vo/BusinessDataSystemVo.java | 5 +- .../vo/BusinessDataTableFieldVo.java | 2 +- .../endpoint}/vo/BusinessDataTableVo.java | 2 +- .../inner/BusinessDataRepository.java | 62 ++++++ .../inner/BusinessSystemRepository.java | 63 ++++++ .../service/BusinessDataSourceService.java | 21 -- .../service/BusinessDataSystemService.java | 44 ----- .../BusinessDataTableFieldService.java | 21 -- .../cdr/service/BusinessDataTableService.java | 21 -- .../impl/BusinessDataSourceServiceImpl.java | 52 ----- .../impl/BusinessDataSystemServiceImpl.java | 61 ------ .../BusinessDataTableFieldServiceImpl.java | 39 ---- .../impl/BusinessDataTableServiceImpl.java | 52 ----- .../mapper/BusinessDataSourceMapper.xml | 31 +-- .../mapper/BusinessDataSystemMapper.xml | 4 +- .../mapper/BusinessDataTableFieldMapper.xml | 4 +- .../mapper/BusinessDataTableMapper.xml | 4 +- .../com/ediagnosis/cdr/dao/MapperTest.java | 15 +- .../com/ediagnosis/cdr/demo/DemoTest.java | 35 +--- 56 files changed, 728 insertions(+), 648 deletions(-) delete mode 100644 src/main/java/com/ediagnosis/cdr/controller/BusinessDataSourceController.java delete mode 100644 src/main/java/com/ediagnosis/cdr/controller/BusinessDataSystemController.java delete mode 100644 src/main/java/com/ediagnosis/cdr/controller/BusinessDataTableController.java delete mode 100644 src/main/java/com/ediagnosis/cdr/controller/BusinessDataTableFieldController.java delete mode 100644 src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataSourceMapper.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataApi.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataController.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSourceController.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSystemController.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/BusinessTableController.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/dao/BusinessDataDao.java rename src/main/java/com/ediagnosis/cdr/{model => dataCollect/dao}/dto/BusinessDataSourceDTO.java (88%) rename src/main/java/com/ediagnosis/cdr/{model => dataCollect/dao}/dto/BusinessDataSourceQueryDTO.java (84%) rename src/main/java/com/ediagnosis/cdr/{model => dataCollect/dao}/dto/BusinessDataSystemDTO.java (94%) rename src/main/java/com/ediagnosis/cdr/{model => dataCollect/dao}/dto/BusinessDataSystemQueryDTO.java (74%) rename src/main/java/com/ediagnosis/cdr/{model => dataCollect/dao}/dto/BusinessDataTableDTO.java (95%) rename src/main/java/com/ediagnosis/cdr/{model => dataCollect/dao}/dto/BusinessDataTableFieldQueryDTO.java (81%) rename src/main/java/com/ediagnosis/cdr/{model => dataCollect/dao}/dto/BusinessDataTableQueryDTO.java (84%) rename src/main/java/com/ediagnosis/cdr/{ => dataCollect}/dao/entity/BusinessDataSource.java (95%) rename src/main/java/com/ediagnosis/cdr/{ => dataCollect}/dao/entity/BusinessDataSystem.java (93%) rename src/main/java/com/ediagnosis/cdr/{ => dataCollect}/dao/entity/BusinessDataTable.java (95%) rename src/main/java/com/ediagnosis/cdr/{ => dataCollect}/dao/entity/BusinessDataTableField.java (94%) create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataSourceMapper.java rename src/main/java/com/ediagnosis/cdr/{ => dataCollect}/dao/mapper/BusinessDataSystemMapper.java (70%) rename src/main/java/com/ediagnosis/cdr/{ => dataCollect}/dao/mapper/BusinessDataTableFieldMapper.java (71%) rename src/main/java/com/ediagnosis/cdr/{ => dataCollect}/dao/mapper/BusinessDataTableMapper.java (70%) rename src/main/java/com/ediagnosis/cdr/{model/param/BusinessDataSourceQueryParam.java => dataCollect/endpoint/param/DataSourceQueryParam.java} (77%) create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemAddParam.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemDeleteParam.java rename src/main/java/com/ediagnosis/cdr/{model/param/BusinessDataSystemQueryParam.java => dataCollect/endpoint/param/DataSystemQueryParam.java} (66%) create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemUpdateParam.java rename src/main/java/com/ediagnosis/cdr/{model/param/BusinessDataTableFieldQueryParam.java => dataCollect/endpoint/param/DataTableFieldQueryParam.java} (73%) rename src/main/java/com/ediagnosis/cdr/{model/param/BusinessDataTableQueryParam.java => dataCollect/endpoint/param/DataTableQueryParam.java} (78%) rename src/main/java/com/ediagnosis/cdr/{model => dataCollect/endpoint}/param/PageQuery.java (89%) rename src/main/java/com/ediagnosis/cdr/{model => dataCollect/endpoint}/vo/BusinessDataSourceVo.java (95%) rename src/main/java/com/ediagnosis/cdr/{model => dataCollect/endpoint}/vo/BusinessDataSystemVo.java (83%) rename src/main/java/com/ediagnosis/cdr/{model => dataCollect/endpoint}/vo/BusinessDataTableFieldVo.java (94%) rename src/main/java/com/ediagnosis/cdr/{model => dataCollect/endpoint}/vo/BusinessDataTableVo.java (95%) create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessDataRepository.java create mode 100644 src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSystemRepository.java delete mode 100644 src/main/java/com/ediagnosis/cdr/service/BusinessDataSourceService.java delete mode 100644 src/main/java/com/ediagnosis/cdr/service/BusinessDataSystemService.java delete mode 100644 src/main/java/com/ediagnosis/cdr/service/BusinessDataTableFieldService.java delete mode 100644 src/main/java/com/ediagnosis/cdr/service/BusinessDataTableService.java delete mode 100644 src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataSourceServiceImpl.java delete mode 100644 src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataSystemServiceImpl.java delete mode 100644 src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataTableFieldServiceImpl.java delete mode 100644 src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataTableServiceImpl.java diff --git a/pom.xml b/pom.xml index aa92f6c..0e2cb03 100644 --- a/pom.xml +++ b/pom.xml @@ -45,13 +45,6 @@ - - com.alibaba - fastjson - 1.2.60 - - - org.apache.hive diff --git a/src/main/java/com/ediagnosis/cdr/CdrApplication.java b/src/main/java/com/ediagnosis/cdr/CdrApplication.java index 4ed68fa..d4f33ae 100644 --- a/src/main/java/com/ediagnosis/cdr/CdrApplication.java +++ b/src/main/java/com/ediagnosis/cdr/CdrApplication.java @@ -5,7 +5,10 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication -@MapperScan("com.ediagnosis.cdr.dao.mapper") +@MapperScan(basePackages = { + "com.ediagnosis.cdr.*.dao.mapper", + "com.ediagnosis.cdr.dao.mapper" +}) public class CdrApplication { public static void main(String[] args) { diff --git a/src/main/java/com/ediagnosis/cdr/controller/BusinessDataSourceController.java b/src/main/java/com/ediagnosis/cdr/controller/BusinessDataSourceController.java deleted file mode 100644 index 852f7b9..0000000 --- a/src/main/java/com/ediagnosis/cdr/controller/BusinessDataSourceController.java +++ /dev/null @@ -1,45 +0,0 @@ -package com.ediagnosis.cdr.controller; - -import com.ediagnosis.cdr.model.dto.BusinessDataSourceDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataSourceQueryDTO; -import com.ediagnosis.cdr.model.param.BusinessDataSourceQueryParam; -import com.ediagnosis.cdr.model.vo.BusinessDataSourceVo; -import com.ediagnosis.cdr.service.BusinessDataSourceService; -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 org.springframework.beans.BeanUtils; -import org.springframework.beans.factory.annotation.Autowired; -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 数据源接口 - * @createTime 2025年07月31日 - */ -@RestController -@RequestMapping("/dataSource") -public class BusinessDataSourceController { - - @Autowired - private BusinessDataSourceService dataSourceService; - - @PostMapping("/page") - public Response> page(@RequestBody BusinessDataSourceQueryParam queryParam) { - BusinessDataSourceQueryDTO queryDTO = new BusinessDataSourceQueryDTO(); - BeanUtils.copyProperties(queryParam, queryDTO); - Page dataSourcePage = dataSourceService.queryPage(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); - } -} diff --git a/src/main/java/com/ediagnosis/cdr/controller/BusinessDataSystemController.java b/src/main/java/com/ediagnosis/cdr/controller/BusinessDataSystemController.java deleted file mode 100644 index 7783d83..0000000 --- a/src/main/java/com/ediagnosis/cdr/controller/BusinessDataSystemController.java +++ /dev/null @@ -1,43 +0,0 @@ -package com.ediagnosis.cdr.controller; - -import com.ediagnosis.cdr.dao.entity.BusinessDataSystem; -import com.ediagnosis.cdr.model.dto.BusinessDataSystemQueryDTO; -import com.ediagnosis.cdr.model.param.BusinessDataSystemQueryParam; -import com.ediagnosis.cdr.model.vo.BusinessDataSystemVo; -import com.ediagnosis.cdr.service.BusinessDataSystemService; -import com.ediagnosis.cdr.util.PageConvertUtils; -import com.ediagnosis.cdr.value.Response; -import com.ediagnosis.cdr.value.PageVo; -import com.mybatisflex.core.paginate.Page; -import org.springframework.beans.BeanUtils; -import org.springframework.beans.factory.annotation.Autowired; -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 业务系统接口 - * @createTime 2025年07月31日 - */ -@RestController -@RequestMapping("/dataSystem") -public class BusinessDataSystemController { - - @Autowired - private BusinessDataSystemService dataSystemService; - - @PostMapping("/page") - public Response> page(@RequestBody BusinessDataSystemQueryParam queryParam) { - BusinessDataSystemQueryDTO queryDTO = new BusinessDataSystemQueryDTO(); - BeanUtils.copyProperties(queryParam, queryDTO); - Page dataSystemPage = dataSystemService.queryPage(queryDTO); - PageVo systemVoPageInfo = PageConvertUtils.copyPageInfo(dataSystemPage, dataSystem -> { - BusinessDataSystemVo vo = new BusinessDataSystemVo(); - BeanUtils.copyProperties(dataSystem, vo); - return vo; - }); - return Response.success(systemVoPageInfo); - } -} diff --git a/src/main/java/com/ediagnosis/cdr/controller/BusinessDataTableController.java b/src/main/java/com/ediagnosis/cdr/controller/BusinessDataTableController.java deleted file mode 100644 index 9ba4a97..0000000 --- a/src/main/java/com/ediagnosis/cdr/controller/BusinessDataTableController.java +++ /dev/null @@ -1,43 +0,0 @@ -package com.ediagnosis.cdr.controller; - -import com.ediagnosis.cdr.model.dto.BusinessDataTableDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataTableQueryDTO; -import com.ediagnosis.cdr.model.param.BusinessDataTableQueryParam; -import com.ediagnosis.cdr.model.vo.BusinessDataTableVo; -import com.ediagnosis.cdr.service.BusinessDataTableService; -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 org.springframework.beans.BeanUtils; -import org.springframework.beans.factory.annotation.Autowired; -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 数据表接口 - * @createTime 2025年07月31日 - */ -@RestController -@RequestMapping("/dataTable") -public class BusinessDataTableController { - - @Autowired - private BusinessDataTableService dataTableService; - - @PostMapping("/page") - public Response> page(@RequestBody BusinessDataTableQueryParam queryParam) { - BusinessDataTableQueryDTO queryDTO = new BusinessDataTableQueryDTO(); - BeanUtils.copyProperties(queryParam, queryDTO); - Page dataTablePage = dataTableService.queryPage(queryDTO); - PageVo dataTableVoPageInfo = PageConvertUtils.copyPageInfo(dataTablePage, dataTable -> { - BusinessDataTableVo vo = new BusinessDataTableVo(); - BeanUtils.copyProperties(dataTable, vo); - return vo; - }); - return Response.success(dataTableVoPageInfo); - } -} diff --git a/src/main/java/com/ediagnosis/cdr/controller/BusinessDataTableFieldController.java b/src/main/java/com/ediagnosis/cdr/controller/BusinessDataTableFieldController.java deleted file mode 100644 index 56a6f8b..0000000 --- a/src/main/java/com/ediagnosis/cdr/controller/BusinessDataTableFieldController.java +++ /dev/null @@ -1,43 +0,0 @@ -package com.ediagnosis.cdr.controller; - -import com.ediagnosis.cdr.dao.entity.BusinessDataTableField; -import com.ediagnosis.cdr.model.dto.BusinessDataTableFieldQueryDTO; -import com.ediagnosis.cdr.model.param.BusinessDataTableFieldQueryParam; -import com.ediagnosis.cdr.model.vo.BusinessDataTableFieldVo; -import com.ediagnosis.cdr.service.BusinessDataTableFieldService; -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 org.springframework.beans.BeanUtils; -import org.springframework.beans.factory.annotation.Autowired; -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 数据表字段接口 - * @createTime 2025年07月31日 - */ -@RestController -@RequestMapping("/dataTableField") -public class BusinessDataTableFieldController { - - @Autowired - private BusinessDataTableFieldService dataTableFieldService; - - @PostMapping("/page") - public Response> page(@RequestBody BusinessDataTableFieldQueryParam queryParam) { - BusinessDataTableFieldQueryDTO queryDTO = new BusinessDataTableFieldQueryDTO(); - BeanUtils.copyProperties(queryParam, queryDTO); - Page dataTableFieldPage = dataTableFieldService.queryPage(queryDTO); - PageVo tableFieldVoPageInfo = PageConvertUtils.copyPageInfo(dataTableFieldPage, dataTableField -> { - BusinessDataTableFieldVo vo = new BusinessDataTableFieldVo(); - BeanUtils.copyProperties(dataTableField, vo); - return vo; - }); - return Response.success(tableFieldVoPageInfo); - } -} diff --git a/src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataSourceMapper.java b/src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataSourceMapper.java deleted file mode 100644 index 34ecda8..0000000 --- a/src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataSourceMapper.java +++ /dev/null @@ -1,26 +0,0 @@ -package com.ediagnosis.cdr.dao.mapper; - -import com.ediagnosis.cdr.dao.entity.BusinessDataSource; -import com.ediagnosis.cdr.model.dto.BusinessDataSourceDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataSourceQueryDTO; -import com.mybatisflex.core.BaseMapper; -import com.mybatisflex.core.paginate.Page; -import org.apache.ibatis.annotations.Mapper; -import org.apache.ibatis.annotations.Param; - -import java.util.List; - -/** - * @author monojun - * @description 数据源mapper - * @createTime 2025年07月31日 - */ -@Mapper -public interface BusinessDataSourceMapper extends BaseMapper { - - int batchInsert(@Param("list") List list); - - Page queryAll(Page page, @Param("queryDTO")BusinessDataSourceQueryDTO queryDTO); - - -} \ No newline at end of file diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataApi.java b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataApi.java new file mode 100644 index 0000000..b9947dc --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataApi.java @@ -0,0 +1,14 @@ +package com.ediagnosis.cdr.dataCollect; + +import org.springframework.stereotype.Component; + +/** + * @author monojun + * @description BusinessDataApi + * @createTime 2025年08月04日 + */ +@Component +public class BusinessDataApi { + + +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataController.java b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataController.java new file mode 100644 index 0000000..c156264 --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataController.java @@ -0,0 +1,77 @@ +package com.ediagnosis.cdr.dataCollect; + + +import com.ediagnosis.cdr.dataCollect.dao.dto.*; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataTableField; +import com.ediagnosis.cdr.dataCollect.endpoint.param.DataSourceQueryParam; +import com.ediagnosis.cdr.dataCollect.endpoint.param.DataTableFieldQueryParam; +import com.ediagnosis.cdr.dataCollect.endpoint.param.DataTableQueryParam; +import com.ediagnosis.cdr.dataCollect.endpoint.vo.BusinessDataSourceVo; +import com.ediagnosis.cdr.dataCollect.endpoint.vo.BusinessDataTableFieldVo; +import com.ediagnosis.cdr.dataCollect.endpoint.vo.BusinessDataTableVo; +import com.ediagnosis.cdr.dataCollect.inner.BusinessDataRepository; +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.RestController; + +/** + * @author monojun + * @description 业务系统controller + * @createTime 2025年08月04日 + */ +@RestController +@RequiredArgsConstructor +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(); + BeanUtils.copyProperties(queryParam, queryDTO); + Page dataTableFieldPage = dataRepository.queryFieldPage(queryDTO); + PageVo tableFieldVoPageInfo = PageConvertUtils.copyPageInfo(dataTableFieldPage, dataTableField -> { + BusinessDataTableFieldVo vo = new BusinessDataTableFieldVo(); + BeanUtils.copyProperties(dataTableField, vo); + return vo; + }); + return Response.success(tableFieldVoPageInfo); + } + + +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSourceController.java b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSourceController.java new file mode 100644 index 0000000..488ccbb --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSourceController.java @@ -0,0 +1,73 @@ +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.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 + * @createTime 2025年08月05日 + */ +@RestController +@RequestMapping("/dataSource") +@RequiredArgsConstructor +public class BusinessSourceController { + + private final BusinessSystemRepository systemRepository; + + + @PostMapping("/add") + public Response page(@RequestBody DataSystemAddParam addParam) { + BusinessDataSystemDTO addDTO = new BusinessDataSystemDTO(); + BeanUtils.copyProperties(addParam, addDTO); + Long id = systemRepository.addDataSystem(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); + return Response.success(id); + } + + + @PostMapping("/page") + public Response> page(@RequestBody DataSystemQueryParam queryParam) { + BusinessDataSystemQueryDTO queryDTO = new BusinessDataSystemQueryDTO(); + BeanUtils.copyProperties(queryParam, queryDTO); + Page dataSystemPage = systemRepository.queryPage(queryDTO); + PageVo systemVoPageInfo = PageConvertUtils.copyPageInfo(dataSystemPage, dataSystem -> { + BusinessDataSystemVo vo = new BusinessDataSystemVo(); + BeanUtils.copyProperties(dataSystem, vo); + return vo; + }); + return Response.success(systemVoPageInfo); + } + + + @PostMapping("/delete") + public Response delete(@RequestBody DataSystemDeleteParam deleteParam) { + systemRepository.deleteDataSystem(deleteParam.getId()); + return Response.success(deleteParam.getId()); + } + +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSystemController.java b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSystemController.java new file mode 100644 index 0000000..631e867 --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSystemController.java @@ -0,0 +1,74 @@ +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.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 业务系统controller + * @createTime 2025年08月04日 + */ +@RestController +@RequestMapping("/bizSystem") +@RequiredArgsConstructor +public class BusinessSystemController { + + private final BusinessSystemRepository systemRepository; + + + @PostMapping("/add") + public Response page(@RequestBody DataSystemAddParam addParam) { + BusinessDataSystemDTO addDTO = new BusinessDataSystemDTO(); + BeanUtils.copyProperties(addParam, addDTO); + Long id = systemRepository.addDataSystem(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); + return Response.success(id); + } + + + @PostMapping("/page") + public Response> page(@RequestBody DataSystemQueryParam queryParam) { + BusinessDataSystemQueryDTO queryDTO = new BusinessDataSystemQueryDTO(); + BeanUtils.copyProperties(queryParam, queryDTO); + Page dataSystemPage = systemRepository.queryPage(queryDTO); + PageVo systemVoPageInfo = PageConvertUtils.copyPageInfo(dataSystemPage, dataSystem -> { + BusinessDataSystemVo vo = new BusinessDataSystemVo(); + BeanUtils.copyProperties(dataSystem, vo); + return vo; + }); + return Response.success(systemVoPageInfo); + } + + + @PostMapping("/delete") + public Response delete(@RequestBody DataSystemDeleteParam deleteParam) { + systemRepository.deleteDataSystem(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 new file mode 100644 index 0000000..4c0529c --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/BusinessTableController.java @@ -0,0 +1,9 @@ +package com.ediagnosis.cdr.dataCollect; + +/** + * @author monojun + * @description TODO + * @createTime 2025年08月05日 + */ +public class BusinessTableController { +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/dao/BusinessDataDao.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/BusinessDataDao.java new file mode 100644 index 0000000..0e4e2b0 --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/BusinessDataDao.java @@ -0,0 +1,179 @@ +package com.ediagnosis.cdr.dataCollect.dao; + + +import com.ediagnosis.cdr.dataCollect.dao.dto.*; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSource; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSystem; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataTable; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataTableField; +import com.ediagnosis.cdr.dataCollect.dao.mapper.BusinessDataSourceMapper; +import com.ediagnosis.cdr.dataCollect.dao.mapper.BusinessDataSystemMapper; +import com.ediagnosis.cdr.dataCollect.dao.mapper.BusinessDataTableFieldMapper; +import com.ediagnosis.cdr.dataCollect.dao.mapper.BusinessDataTableMapper; +import com.mybatisflex.core.paginate.Page; +import com.mybatisflex.core.query.QueryWrapper; +import lombok.RequiredArgsConstructor; +import org.apache.commons.collections4.CollectionUtils; +import org.springframework.beans.BeanUtils; +import org.springframework.stereotype.Component; +import org.springframework.util.StringUtils; + +import java.util.Date; + +/** + * @author monojun + * @description 业务dao + * @createTime 2025年08月04日 + */ +@Component +@RequiredArgsConstructor +public class BusinessDataDao { + + private final BusinessDataSystemMapper dataSystemMapper; + + private final BusinessDataSourceMapper dataSourceMapper; + + private final BusinessDataTableMapper dataTableMapper; + + private final BusinessDataTableFieldMapper dataTableFieldMapper; + + /** + * 新增业务系统 + * + * @param dataSystemDTO dataSystemDTO + * @return 业务系统主键id + */ + public Long addDataSystem(BusinessDataSystemDTO dataSystemDTO) { + BusinessDataSystem dataSystem = new BusinessDataSystem(); + BeanUtils.copyProperties(dataSystemDTO, dataSystem); + dataSystem.setCreateTime(new Date()); + dataSystem.setUpdateTime(new Date()); + dataSystemMapper.insert(dataSystem); + return dataSystem.getId(); + } + + /** + * 更新业务系统 + * + * @param dataSystemDTO dataSystemDTO + * @return 业务系统主键id + */ + public Long updateDataSystem(BusinessDataSystemDTO dataSystemDTO) { + BusinessDataSystem dataSystem = new BusinessDataSystem(); + BeanUtils.copyProperties(dataSystemDTO, dataSystem); + dataSystem.setUpdateTime(new Date()); + dataSystemMapper.update(dataSystem); + return dataSystem.getId(); + } + + /** + * 删除业务系统 + * + * @param dataSystemId 业务系统id + */ + public void deleteDataSystem(Long dataSystemId) { + dataSystemMapper.deleteById(dataSystemId); + } + + /** + * 分页查询业务系统信息 + * + * @param queryDTO 查询dto + * @return PageInfo + */ + public Page querySystemPage(BusinessDataSystemQueryDTO queryDTO) { + QueryWrapper queryWrapper = QueryWrapper.create(); + if (StringUtils.hasText(queryDTO.getName())) { + queryWrapper.like(BusinessDataSystem::getName, queryDTO.getName()); + } + queryWrapper.orderBy(BusinessDataSystem::getUpdateTime, false); + queryWrapper.orderBy(BusinessDataSystem::getId, false); + return dataSystemMapper.paginate(queryDTO.getPageNo(), queryDTO.getPageSize(), queryWrapper); + } + + /** + * 分页查询业务数据源信息 + * + * @param queryDTO 查询dto + * @return PageInfo + */ + public Page querySourcePage(BusinessDataSourceQueryDTO queryDTO) { + QueryWrapper queryWrapper = QueryWrapper.create() + .select("d.*", "ds.name as businessName") + .from(BusinessDataSource.class).as("d") + .leftJoin(BusinessDataSystem.class).as("ds") + .on(BusinessDataSource::getBusinessId, BusinessDataSystem::getId) + .orderBy(BusinessDataSource::getUpdateTime, false) + .orderBy(BusinessDataSource::getId, false); + if (!CollectionUtils.isEmpty(queryDTO.getBusinessIds())) { + queryWrapper.in(BusinessDataSource::getBusinessId, queryDTO.getBusinessIds()); + } + if (StringUtils.hasText(queryDTO.getName())) { + queryWrapper.like(BusinessDataSource::getName, queryDTO.getName()); + } + if (StringUtils.hasText(queryDTO.getIpAddress())) { + queryWrapper.like(BusinessDataSource::getIpAddress, queryDTO.getIpAddress()); + } + if (StringUtils.hasText(queryDTO.getType())) { + queryWrapper.eq(BusinessDataSource::getType, queryDTO.getType()); + } + if (queryDTO.getStatus() != null) { + queryWrapper.eq(BusinessDataSource::getStatus, queryDTO.getStatus()); + } + return dataSourceMapper.paginateAs(queryDTO.getPageNo(), queryDTO.getPageSize(), queryWrapper, BusinessDataSourceDTO.class); + } + + /** + * 分页查询业务表信息 + * + * @param queryDTO 查询dto + * @return PageInfo + */ + public Page queryTablePage(BusinessDataTableQueryDTO queryDTO) { + QueryWrapper queryWrapper = QueryWrapper.create() + .select("t.*, d.id as sourceId, d.name as sourceName, ds.id as businessId, ds.name as businessName") + .from(BusinessDataTable.class).as("t") + .leftJoin(BusinessDataSource.class).as("d") + .on(BusinessDataTable::getSourceId, BusinessDataSource::getId) + .leftJoin(BusinessDataSystem.class).as("ds") + .on(BusinessDataSource::getBusinessId, BusinessDataSystem::getId) + .orderBy(BusinessDataTable::getUpdateTime, false) + .orderBy(BusinessDataTable::getId, false); + 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()); + } + if (StringUtils.hasText(queryDTO.getTableNo())) { + queryWrapper.like(BusinessDataTable::getTableNo, queryDTO.getTableNo()); + } + return dataTableMapper.paginateAs(queryDTO.getPageNo(), queryDTO.getPageSize(), queryWrapper, BusinessDataTableDTO.class); + } + + /** + * 分页查询业务表字段信息 + * + * @param queryDTO 查询dto + * @return PageInfo + */ + public Page queryFieldPage(BusinessDataTableFieldQueryDTO queryDTO) { + QueryWrapper queryWrapper = QueryWrapper.create(); + if (StringUtils.hasText(queryDTO.getFieldName())) { + queryWrapper.like(BusinessDataTableField::getFieldName, queryDTO.getFieldName()); + } + if (StringUtils.hasText(queryDTO.getFieldType())) { + queryWrapper.like(BusinessDataTableField::getFieldType, queryDTO.getFieldType()); + } + if (queryDTO.getTableId() != null) { + queryWrapper.eq(BusinessDataTableField::getTableId, queryDTO.getTableId()); + } + queryWrapper.orderBy(BusinessDataTableField::getUpdateTime, false); + queryWrapper.orderBy(BusinessDataTableField::getId, false); + return dataTableFieldMapper.paginate(queryDTO.getPageNo(), queryDTO.getPageSize(), queryWrapper); + } + +} diff --git a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSourceDTO.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSourceDTO.java similarity index 88% rename from src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSourceDTO.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSourceDTO.java index 011d23d..00b9dc0 100644 --- a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSourceDTO.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSourceDTO.java @@ -1,8 +1,5 @@ -package com.ediagnosis.cdr.model.dto; +package com.ediagnosis.cdr.dataCollect.dao.dto; -import com.mybatisflex.annotation.Column; -import com.mybatisflex.annotation.Id; -import com.mybatisflex.annotation.KeyType; import lombok.Data; import java.io.Serial; diff --git a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSourceQueryDTO.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSourceQueryDTO.java similarity index 84% rename from src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSourceQueryDTO.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSourceQueryDTO.java index c1de65d..e298941 100644 --- a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSourceQueryDTO.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSourceQueryDTO.java @@ -1,7 +1,6 @@ -package com.ediagnosis.cdr.model.dto; +package com.ediagnosis.cdr.dataCollect.dao.dto; -import com.ediagnosis.cdr.model.param.PageQuery; -import com.mybatisflex.annotation.Column; +import com.ediagnosis.cdr.dataCollect.endpoint.param.PageQuery; import lombok.Data; import java.io.Serial; diff --git a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSystemDTO.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSystemDTO.java similarity index 94% rename from src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSystemDTO.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSystemDTO.java index 89b383c..5e2bc3d 100644 --- a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSystemDTO.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSystemDTO.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.model.dto; +package com.ediagnosis.cdr.dataCollect.dao.dto; import lombok.Data; diff --git a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSystemQueryDTO.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSystemQueryDTO.java similarity index 74% rename from src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSystemQueryDTO.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSystemQueryDTO.java index ef32dcb..9832247 100644 --- a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSystemQueryDTO.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSystemQueryDTO.java @@ -1,6 +1,6 @@ -package com.ediagnosis.cdr.model.dto; +package com.ediagnosis.cdr.dataCollect.dao.dto; -import com.ediagnosis.cdr.model.param.PageQuery; +import com.ediagnosis.cdr.dataCollect.endpoint.param.PageQuery; import lombok.Data; /** diff --git a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataTableDTO.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataTableDTO.java similarity index 95% rename from src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataTableDTO.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataTableDTO.java index bfd28f3..935ff83 100644 --- a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataTableDTO.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataTableDTO.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.model.dto; +package com.ediagnosis.cdr.dataCollect.dao.dto; import lombok.Data; diff --git a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataTableFieldQueryDTO.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataTableFieldQueryDTO.java similarity index 81% rename from src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataTableFieldQueryDTO.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataTableFieldQueryDTO.java index 2856ccc..56f5211 100644 --- a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataTableFieldQueryDTO.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataTableFieldQueryDTO.java @@ -1,6 +1,6 @@ -package com.ediagnosis.cdr.model.dto; +package com.ediagnosis.cdr.dataCollect.dao.dto; -import com.ediagnosis.cdr.model.param.PageQuery; +import com.ediagnosis.cdr.dataCollect.endpoint.param.PageQuery; import lombok.Data; import java.io.Serial; diff --git a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataTableQueryDTO.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataTableQueryDTO.java similarity index 84% rename from src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataTableQueryDTO.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataTableQueryDTO.java index 0be5861..f0a49f4 100644 --- a/src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataTableQueryDTO.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataTableQueryDTO.java @@ -1,6 +1,6 @@ -package com.ediagnosis.cdr.model.dto; +package com.ediagnosis.cdr.dataCollect.dao.dto; -import com.ediagnosis.cdr.model.param.PageQuery; +import com.ediagnosis.cdr.dataCollect.endpoint.param.PageQuery; import lombok.Data; import java.io.Serial; diff --git a/src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataSource.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSource.java similarity index 95% rename from src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataSource.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSource.java index 2c3ed86..79ac5ac 100644 --- a/src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataSource.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSource.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.dao.entity; +package com.ediagnosis.cdr.dataCollect.dao.entity; import com.mybatisflex.annotation.Column; import com.mybatisflex.annotation.Id; @@ -13,7 +13,7 @@ import java.util.Date; /** * @author monojun * @description 业务系统数据源表 - * @createTime 2025年07月31日 + * @createTime 2025年08月01日 */ @Data @Table(value = "business_data_source") diff --git a/src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataSystem.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSystem.java similarity index 93% rename from src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataSystem.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSystem.java index a4bfd46..168199c 100644 --- a/src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataSystem.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSystem.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.dao.entity; +package com.ediagnosis.cdr.dataCollect.dao.entity; import com.mybatisflex.annotation.Column; import com.mybatisflex.annotation.Id; @@ -11,7 +11,7 @@ import java.util.Date; /** * @author monojun * @description 业务系统表 - * @createTime 2025年07月31日 + * @createTime 2025年08月01日 */ @Data @Table("business_data_system") diff --git a/src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataTable.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTable.java similarity index 95% rename from src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataTable.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTable.java index e328d36..597d10d 100644 --- a/src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataTable.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTable.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.dao.entity; +package com.ediagnosis.cdr.dataCollect.dao.entity; import com.mybatisflex.annotation.Column; import com.mybatisflex.annotation.Id; @@ -13,7 +13,7 @@ import java.util.Date; /** * @author monojun * @description 业务表信息表 - * @createTime 2025年07月31日 + * @createTime 2025年08月01日 */ @Data @Table(value = "business_data_table") diff --git a/src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataTableField.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTableField.java similarity index 94% rename from src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataTableField.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTableField.java index 8481f4d..a2509c0 100644 --- a/src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataTableField.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTableField.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.dao.entity; +package com.ediagnosis.cdr.dataCollect.dao.entity; import com.mybatisflex.annotation.Column; import com.mybatisflex.annotation.Id; @@ -13,7 +13,7 @@ import java.util.Date; /** * @author monojun * @description 业务字段信息表 - * @createTime 2025年07月31日 + * @createTime 2025年08月01日 */ @Data @Table(value = "business_data_table_field") diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataSourceMapper.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataSourceMapper.java new file mode 100644 index 0000000..97994e3 --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataSourceMapper.java @@ -0,0 +1,20 @@ +package com.ediagnosis.cdr.dataCollect.dao.mapper; + +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSource; +import com.mybatisflex.core.BaseMapper; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +/** + * @author monojun + * @description 数据源mapper + * @createTime 2025年08月01日 + */ +@Mapper +public interface BusinessDataSourceMapper extends BaseMapper { + + int batchInsert(@Param("list") List list); + +} \ No newline at end of file diff --git a/src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataSystemMapper.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataSystemMapper.java similarity index 70% rename from src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataSystemMapper.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataSystemMapper.java index f655526..4e56b42 100644 --- a/src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataSystemMapper.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataSystemMapper.java @@ -1,21 +1,19 @@ -package com.ediagnosis.cdr.dao.mapper; - -import com.ediagnosis.cdr.dao.entity.BusinessDataSystem; - -import java.util.List; +package com.ediagnosis.cdr.dataCollect.dao.mapper; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSystem; import com.mybatisflex.core.BaseMapper; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; +import java.util.List; + /** * @author monojun * @description 业务系统mapper - * @createTime 2025年07月31日 + * @createTime 2025年08月01日 */ @Mapper public interface BusinessDataSystemMapper extends BaseMapper { int batchInsert(@Param("list") List list); - } \ No newline at end of file diff --git a/src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataTableFieldMapper.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataTableFieldMapper.java similarity index 71% rename from src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataTableFieldMapper.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataTableFieldMapper.java index 5c7ed18..e886a84 100644 --- a/src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataTableFieldMapper.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataTableFieldMapper.java @@ -1,17 +1,16 @@ -package com.ediagnosis.cdr.dao.mapper; - -import com.ediagnosis.cdr.dao.entity.BusinessDataTableField; - -import java.util.List; +package com.ediagnosis.cdr.dataCollect.dao.mapper; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataTableField; import com.mybatisflex.core.BaseMapper; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; +import java.util.List; + /** * @author monojun * @description 业务表字段mapper - * @createTime 2025年07月31日 + * @createTime 2025年08月01日 */ @Mapper public interface BusinessDataTableFieldMapper extends BaseMapper { diff --git a/src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataTableMapper.java b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataTableMapper.java similarity index 70% rename from src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataTableMapper.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataTableMapper.java index b54c1ca..4320472 100644 --- a/src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataTableMapper.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataTableMapper.java @@ -1,16 +1,16 @@ -package com.ediagnosis.cdr.dao.mapper; - -import com.ediagnosis.cdr.dao.entity.BusinessDataTable; -import java.util.List; +package com.ediagnosis.cdr.dataCollect.dao.mapper; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataTable; import com.mybatisflex.core.BaseMapper; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Param; +import java.util.List; + /** * @author monojun * @description 业务表mapper - * @createTime 2025年07月31日 + * @createTime 2025年08月01日 */ @Mapper public interface BusinessDataTableMapper extends BaseMapper { diff --git a/src/main/java/com/ediagnosis/cdr/model/param/BusinessDataSourceQueryParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceQueryParam.java similarity index 77% rename from src/main/java/com/ediagnosis/cdr/model/param/BusinessDataSourceQueryParam.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceQueryParam.java index 302fbd0..b21d4c3 100644 --- a/src/main/java/com/ediagnosis/cdr/model/param/BusinessDataSourceQueryParam.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceQueryParam.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.model.param; +package com.ediagnosis.cdr.dataCollect.endpoint.param; import lombok.Data; @@ -8,10 +8,10 @@ import java.util.List; /** * @author monojun * @description 数据源查询参数 - * @createTime 2025年07月31日 + * @createTime 2025年08月01日 */ @Data -public class BusinessDataSourceQueryParam extends PageQuery { +public class DataSourceQueryParam extends PageQuery { @Serial private static final long serialVersionUID = 4384878864788101913L; 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 new file mode 100644 index 0000000..f7ab46d --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemAddParam.java @@ -0,0 +1,29 @@ +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 DataSystemAddParam implements Serializable { + @Serial + private static final long serialVersionUID = 8362821373667292598L; + + /** + * 业务系统名称 + */ + private String name; + + /** + * 描述 + */ + private String description; + + +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemDeleteParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemDeleteParam.java new file mode 100644 index 0000000..3ed8e7e --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemDeleteParam.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 DataSystemDeleteParam implements Serializable { + @Serial + private static final long serialVersionUID = -5941215912179720671L; + + private Long id; +} diff --git a/src/main/java/com/ediagnosis/cdr/model/param/BusinessDataSystemQueryParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemQueryParam.java similarity index 66% rename from src/main/java/com/ediagnosis/cdr/model/param/BusinessDataSystemQueryParam.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemQueryParam.java index d7079a9..2424007 100644 --- a/src/main/java/com/ediagnosis/cdr/model/param/BusinessDataSystemQueryParam.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemQueryParam.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.model.param; +package com.ediagnosis.cdr.dataCollect.endpoint.param; import lombok.Data; @@ -7,10 +7,10 @@ import java.io.Serial; /** * @author monojun * @description 业务系统分页查询参数 - * @createTime 2025年07月31日 + * @createTime 2025年08月01日 */ @Data -public class BusinessDataSystemQueryParam extends PageQuery { +public class DataSystemQueryParam extends PageQuery { @Serial private static final long serialVersionUID = 5408831076545737168L; diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemUpdateParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemUpdateParam.java new file mode 100644 index 0000000..bbd50b1 --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemUpdateParam.java @@ -0,0 +1,29 @@ +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 DataSystemUpdateParam implements Serializable { + @Serial + private static final long serialVersionUID = -7333708471431047394L; + + private Long id; + /** + * 业务系统名称 + */ + private String name; + + /** + * 描述 + */ + private String description; + +} diff --git a/src/main/java/com/ediagnosis/cdr/model/param/BusinessDataTableFieldQueryParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableFieldQueryParam.java similarity index 73% rename from src/main/java/com/ediagnosis/cdr/model/param/BusinessDataTableFieldQueryParam.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableFieldQueryParam.java index 37b691e..e3d0a2a 100644 --- a/src/main/java/com/ediagnosis/cdr/model/param/BusinessDataTableFieldQueryParam.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableFieldQueryParam.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.model.param; +package com.ediagnosis.cdr.dataCollect.endpoint.param; import lombok.Data; @@ -7,10 +7,10 @@ import java.io.Serial; /** * @author monojun * @description 表字段查询参数 - * @createTime 2025年07月31日 + * @createTime 2025年08月01日 */ @Data -public class BusinessDataTableFieldQueryParam extends PageQuery{ +public class DataTableFieldQueryParam extends PageQuery { @Serial private static final long serialVersionUID = 5419533067070233483L; diff --git a/src/main/java/com/ediagnosis/cdr/model/param/BusinessDataTableQueryParam.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableQueryParam.java similarity index 78% rename from src/main/java/com/ediagnosis/cdr/model/param/BusinessDataTableQueryParam.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableQueryParam.java index dfcb680..6da57c0 100644 --- a/src/main/java/com/ediagnosis/cdr/model/param/BusinessDataTableQueryParam.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableQueryParam.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.model.param; +package com.ediagnosis.cdr.dataCollect.endpoint.param; import lombok.Data; @@ -8,10 +8,10 @@ import java.util.List; /** * @author monojun * @description 表信息查询参数 - * @createTime 2025年07月31日 + * @createTime 2025年08月01日 */ @Data -public class BusinessDataTableQueryParam extends PageQuery { +public class DataTableQueryParam extends PageQuery { @Serial private static final long serialVersionUID = -6012405803243067316L; diff --git a/src/main/java/com/ediagnosis/cdr/model/param/PageQuery.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/PageQuery.java similarity index 89% rename from src/main/java/com/ediagnosis/cdr/model/param/PageQuery.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/PageQuery.java index d8eef68..739e0a2 100644 --- a/src/main/java/com/ediagnosis/cdr/model/param/PageQuery.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/PageQuery.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.model.param; +package com.ediagnosis.cdr.dataCollect.endpoint.param; import lombok.Data; diff --git a/src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataSourceVo.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataSourceVo.java similarity index 95% rename from src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataSourceVo.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataSourceVo.java index c9eada3..10d5bf3 100644 --- a/src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataSourceVo.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataSourceVo.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.model.vo; +package com.ediagnosis.cdr.dataCollect.endpoint.vo; import lombok.Data; diff --git a/src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataSystemVo.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataSystemVo.java similarity index 83% rename from src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataSystemVo.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataSystemVo.java index 3b54e29..a3cb847 100644 --- a/src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataSystemVo.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataSystemVo.java @@ -1,8 +1,5 @@ -package com.ediagnosis.cdr.model.vo; +package com.ediagnosis.cdr.dataCollect.endpoint.vo; -import com.mybatisflex.annotation.Column; -import com.mybatisflex.annotation.Id; -import com.mybatisflex.annotation.KeyType; import lombok.Data; import java.io.Serial; diff --git a/src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataTableFieldVo.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataTableFieldVo.java similarity index 94% rename from src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataTableFieldVo.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataTableFieldVo.java index 41af7bd..6a0d2f5 100644 --- a/src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataTableFieldVo.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataTableFieldVo.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.model.vo; +package com.ediagnosis.cdr.dataCollect.endpoint.vo; import lombok.Data; diff --git a/src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataTableVo.java b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataTableVo.java similarity index 95% rename from src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataTableVo.java rename to src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataTableVo.java index 720c46f..3f814a3 100644 --- a/src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataTableVo.java +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataTableVo.java @@ -1,4 +1,4 @@ -package com.ediagnosis.cdr.model.vo; +package com.ediagnosis.cdr.dataCollect.endpoint.vo; import lombok.Data; diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessDataRepository.java b/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessDataRepository.java new file mode 100644 index 0000000..b8dc93f --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessDataRepository.java @@ -0,0 +1,62 @@ +package com.ediagnosis.cdr.dataCollect.inner; + + +import com.ediagnosis.cdr.dataCollect.dao.BusinessDataDao; +import com.ediagnosis.cdr.dataCollect.dao.dto.*; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSystem; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataTableField; +import com.mybatisflex.core.paginate.Page; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Repository; + +/** + * @author monojun + * @description BusinessDataRepository + * @createTime 2025年08月04日 + */ +@Repository +@RequiredArgsConstructor +public class BusinessDataRepository { + + private final BusinessDataDao businessDataDao; + + /** + * 分页查询业务系统信息 + * + * @param queryDTO 查询dto + * @return PageInfo + */ + public Page queryPage(BusinessDataSystemQueryDTO queryDTO) { + return businessDataDao.querySystemPage(queryDTO); + } + + /** + * 分页查询业务数据源信息 + * + * @param queryDTO 查询dto + * @return PageInfo + */ + public Page querySourcePage(BusinessDataSourceQueryDTO queryDTO) { + return businessDataDao.querySourcePage(queryDTO); + } + + /** + * 分页查询业务表信息 + * + * @param queryDTO 查询dto + * @return PageInfo + */ + public Page queryTablePage(BusinessDataTableQueryDTO queryDTO) { + return businessDataDao.queryTablePage(queryDTO); + } + + /** + * 分页查询业务表字段信息 + * + * @param queryDTO 查询dto + * @return PageInfo + */ + public Page queryFieldPage(BusinessDataTableFieldQueryDTO queryDTO) { + return businessDataDao.queryFieldPage(queryDTO); + } +} diff --git a/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSystemRepository.java b/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSystemRepository.java new file mode 100644 index 0000000..83be93b --- /dev/null +++ b/src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSystemRepository.java @@ -0,0 +1,63 @@ +package com.ediagnosis.cdr.dataCollect.inner; + +import com.ediagnosis.cdr.dataCollect.dao.BusinessDataDao; +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.mybatisflex.core.paginate.Page; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Repository; + +/** + * @author monojun + * @description BusinessSystemRepository + * @createTime 2025年08月05日 + */ +@Repository +@RequiredArgsConstructor +public class BusinessSystemRepository { + + private final BusinessDataDao businessDataDao; + + /** + * 新增业务系统 + * + * @param dataSystemDTO 业务系统dto + * @return 业务系统主键id + */ + public Long addDataSystem(BusinessDataSystemDTO dataSystemDTO) { + businessDataDao.addDataSystem(dataSystemDTO); + return businessDataDao.addDataSystem(dataSystemDTO); + } + + + /** + * 更新业务系统 + * + * @param dataSystemDTO 业务系统dto + * @return 业务系统主键id + */ + public Long updateDataSystem(BusinessDataSystemDTO dataSystemDTO) { + return businessDataDao.updateDataSystem(dataSystemDTO); + } + + /** + * 分页查询业务系统信息 + * + * @param queryDTO 查询dto + * @return PageInfo + */ + public Page queryPage(BusinessDataSystemQueryDTO queryDTO) { + return businessDataDao.querySystemPage(queryDTO); + } + + /** + * 删除业务系统 + * + * @param dataSystemId 业务系统id + */ + public void deleteDataSystem(Long dataSystemId) { + businessDataDao.deleteDataSystem(dataSystemId); + } + +} diff --git a/src/main/java/com/ediagnosis/cdr/service/BusinessDataSourceService.java b/src/main/java/com/ediagnosis/cdr/service/BusinessDataSourceService.java deleted file mode 100644 index c1c99d7..0000000 --- a/src/main/java/com/ediagnosis/cdr/service/BusinessDataSourceService.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.ediagnosis.cdr.service; - -import com.ediagnosis.cdr.model.dto.BusinessDataSourceDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataSourceQueryDTO; -import com.mybatisflex.core.paginate.Page; - -/** - * @author monojun - * @description 业务数据源service - * @createTime 2025年07月31日 - */ -public interface BusinessDataSourceService { - - /** - * 分页查询业务数据源信息 - * - * @param queryDTO 查询dto - * @return PageInfo - */ - Page queryPage(BusinessDataSourceQueryDTO queryDTO); -} diff --git a/src/main/java/com/ediagnosis/cdr/service/BusinessDataSystemService.java b/src/main/java/com/ediagnosis/cdr/service/BusinessDataSystemService.java deleted file mode 100644 index a9c2b2c..0000000 --- a/src/main/java/com/ediagnosis/cdr/service/BusinessDataSystemService.java +++ /dev/null @@ -1,44 +0,0 @@ -package com.ediagnosis.cdr.service; - -import com.ediagnosis.cdr.dao.entity.BusinessDataSystem; -import com.ediagnosis.cdr.model.dto.BusinessDataSystemDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataSystemQueryDTO; -import com.mybatisflex.core.paginate.Page; - -/** - * @author monojun - * @description 业务系统service - * @createTime 2025年07月31日 - */ -public interface BusinessDataSystemService { - /** - * 新增业务系统 - * - * @param dataSystemDTO 业务系统dto - * @return 主键id - */ - Long addDataSystem(BusinessDataSystemDTO dataSystemDTO); - - /** - * 更新业务系统 - * - * @param dataSystemDTO 业务系统dto - * @return Long - */ - Long updateDataSystem(BusinessDataSystemDTO dataSystemDTO); - - /** - * 删除业务系统 - * - * @param dataSystemId 任务主键id - */ - void deleteDataSystem(Long dataSystemId); - - /** - * 分页查询业务系统信息 - * - * @param queryDTO 查询dto - * @return PageInfo - */ - Page queryPage(BusinessDataSystemQueryDTO queryDTO); -} diff --git a/src/main/java/com/ediagnosis/cdr/service/BusinessDataTableFieldService.java b/src/main/java/com/ediagnosis/cdr/service/BusinessDataTableFieldService.java deleted file mode 100644 index 2d6bc61..0000000 --- a/src/main/java/com/ediagnosis/cdr/service/BusinessDataTableFieldService.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.ediagnosis.cdr.service; - -import com.ediagnosis.cdr.dao.entity.BusinessDataTableField; -import com.ediagnosis.cdr.model.dto.BusinessDataTableFieldQueryDTO; -import com.mybatisflex.core.paginate.Page; - -/** - * @author monojun - * @description 业务表字段service - * @createTime 2025年07月31日 - */ -public interface BusinessDataTableFieldService { - - /** - * 分页查询业务表字段信息 - * - * @param queryDTO 查询dto - * @return PageInfo - */ - Page queryPage(BusinessDataTableFieldQueryDTO queryDTO); -} diff --git a/src/main/java/com/ediagnosis/cdr/service/BusinessDataTableService.java b/src/main/java/com/ediagnosis/cdr/service/BusinessDataTableService.java deleted file mode 100644 index 3e931b9..0000000 --- a/src/main/java/com/ediagnosis/cdr/service/BusinessDataTableService.java +++ /dev/null @@ -1,21 +0,0 @@ -package com.ediagnosis.cdr.service; - -import com.ediagnosis.cdr.model.dto.BusinessDataTableDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataTableQueryDTO; -import com.mybatisflex.core.paginate.Page; - -/** - * @author monojun - * @description 业务表service - * @createTime 2025年07月31日 - */ -public interface BusinessDataTableService { - - /** - * 分页查询业务表信息 - * - * @param queryDTO 查询dto - * @return PageInfo - */ - Page queryPage(BusinessDataTableQueryDTO queryDTO); -} diff --git a/src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataSourceServiceImpl.java b/src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataSourceServiceImpl.java deleted file mode 100644 index 8faefe6..0000000 --- a/src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataSourceServiceImpl.java +++ /dev/null @@ -1,52 +0,0 @@ -package com.ediagnosis.cdr.service.impl; - -import com.ediagnosis.cdr.dao.entity.BusinessDataSource; -import com.ediagnosis.cdr.dao.entity.BusinessDataSystem; -import com.ediagnosis.cdr.dao.mapper.BusinessDataSourceMapper; -import com.ediagnosis.cdr.model.dto.BusinessDataSourceDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataSourceQueryDTO; -import com.ediagnosis.cdr.service.BusinessDataSourceService; -import com.mybatisflex.core.paginate.Page; -import com.mybatisflex.core.query.QueryWrapper; -import org.apache.commons.collections4.CollectionUtils; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; -import org.springframework.util.StringUtils; - -/** - * @author monojun - * @description 业务数据源service - * @createTime 2025年07月31日 - */ -@Service -public class BusinessDataSourceServiceImpl implements BusinessDataSourceService { - - @Autowired - private BusinessDataSourceMapper dataSourceMapper; - - @Override - public Page queryPage(BusinessDataSourceQueryDTO queryDTO) { - QueryWrapper queryWrapper = QueryWrapper.create() - .select("d.*", "ds.name as businessName") - .from(BusinessDataSource.class).as("d") - .leftJoin(BusinessDataSystem.class).as("ds") - .on(BusinessDataSource::getBusinessId, BusinessDataSystem::getId) - .orderBy(BusinessDataSource::getId, false); - if (!CollectionUtils.isEmpty(queryDTO.getBusinessIds())) { - queryWrapper.in(BusinessDataSource::getBusinessId, queryDTO.getBusinessIds()); - } - if (StringUtils.hasText(queryDTO.getName())) { - queryWrapper.like(BusinessDataSource::getName, queryDTO.getName()); - } - if (StringUtils.hasText(queryDTO.getIpAddress())) { - queryWrapper.like(BusinessDataSource::getIpAddress, queryDTO.getIpAddress()); - } - if (StringUtils.hasText(queryDTO.getType())) { - queryWrapper.eq(BusinessDataSource::getType, queryDTO.getType()); - } - if (queryDTO.getStatus() != null) { - queryWrapper.eq(BusinessDataSource::getStatus, queryDTO.getStatus()); - } - return dataSourceMapper.paginateAs(queryDTO.getPageNo(), queryDTO.getPageSize(), queryWrapper, BusinessDataSourceDTO.class); - } -} diff --git a/src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataSystemServiceImpl.java b/src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataSystemServiceImpl.java deleted file mode 100644 index 67091b8..0000000 --- a/src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataSystemServiceImpl.java +++ /dev/null @@ -1,61 +0,0 @@ -package com.ediagnosis.cdr.service.impl; - -import com.ediagnosis.cdr.dao.entity.BusinessDataSystem; -import com.ediagnosis.cdr.dao.mapper.BusinessDataSystemMapper; -import com.ediagnosis.cdr.model.dto.BusinessDataSystemDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataSystemQueryDTO; -import com.ediagnosis.cdr.service.BusinessDataSystemService; -import com.mybatisflex.core.paginate.Page; -import com.mybatisflex.core.query.QueryWrapper; -import org.springframework.beans.BeanUtils; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; -import org.springframework.util.StringUtils; - -import java.util.Date; - -/** - * @author monojun - * @description 业务系统service - * @createTime 2025年07月31日 - */ -@Service -public class BusinessDataSystemServiceImpl implements BusinessDataSystemService { - - @Autowired - private BusinessDataSystemMapper dataSystemMapper; - - @Override - public Long addDataSystem(BusinessDataSystemDTO dataSystemDTO) { - BusinessDataSystem dataSystem = new BusinessDataSystem(); - BeanUtils.copyProperties(dataSystemDTO, dataSystem); - dataSystem.setCreateTime(new Date()); - dataSystem.setUpdateTime(new Date()); - dataSystemMapper.insert(dataSystem); - return dataSystem.getId(); - } - - @Override - public Long updateDataSystem(BusinessDataSystemDTO dataSystemDTO) { - BusinessDataSystem dataSystem = new BusinessDataSystem(); - BeanUtils.copyProperties(dataSystemDTO, dataSystem); - dataSystem.setUpdateTime(new Date()); - dataSystemMapper.update(dataSystem); - return dataSystem.getId(); - } - - @Override - public void deleteDataSystem(Long dataSystemId) { - dataSystemMapper.deleteById(dataSystemId); - } - - @Override - public Page queryPage(BusinessDataSystemQueryDTO queryDTO) { - QueryWrapper queryWrapper = QueryWrapper.create(); - if (StringUtils.hasText(queryDTO.getName())) { - queryWrapper.like(BusinessDataSystem::getName, queryDTO.getName()); - } - queryWrapper.orderBy(BusinessDataSystem::getId, false); - return dataSystemMapper.paginate(queryDTO.getPageNo(), queryDTO.getPageSize(), queryWrapper); - } -} diff --git a/src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataTableFieldServiceImpl.java b/src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataTableFieldServiceImpl.java deleted file mode 100644 index ab39865..0000000 --- a/src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataTableFieldServiceImpl.java +++ /dev/null @@ -1,39 +0,0 @@ -package com.ediagnosis.cdr.service.impl; - -import com.ediagnosis.cdr.dao.entity.BusinessDataTableField; -import com.ediagnosis.cdr.dao.mapper.BusinessDataTableFieldMapper; -import com.ediagnosis.cdr.model.dto.BusinessDataTableFieldQueryDTO; -import com.ediagnosis.cdr.service.BusinessDataTableFieldService; -import com.mybatisflex.core.paginate.Page; -import com.mybatisflex.core.query.QueryWrapper; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; -import org.springframework.util.StringUtils; - -/** - * @author monojun - * @description 业务表字段service - * @createTime 2025年07月31日 - */ -@Service -public class BusinessDataTableFieldServiceImpl implements BusinessDataTableFieldService { - - @Autowired - private BusinessDataTableFieldMapper dataTableFieldMapper; - - @Override - public Page queryPage(BusinessDataTableFieldQueryDTO queryDTO) { - QueryWrapper queryWrapper = QueryWrapper.create(); - if (StringUtils.hasText(queryDTO.getFieldName())) { - queryWrapper.like(BusinessDataTableField::getFieldName, queryDTO.getFieldName()); - } - if (StringUtils.hasText(queryDTO.getFieldType())) { - queryWrapper.like(BusinessDataTableField::getFieldType, queryDTO.getFieldType()); - } - if (queryDTO.getTableId() != null) { - queryWrapper.eq(BusinessDataTableField::getTableId, queryDTO.getTableId()); - } - queryWrapper.orderBy(BusinessDataTableField::getId, false); - return dataTableFieldMapper.paginate(queryDTO.getPageNo(), queryDTO.getPageSize(), queryWrapper); - } -} diff --git a/src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataTableServiceImpl.java b/src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataTableServiceImpl.java deleted file mode 100644 index b1a2265..0000000 --- a/src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataTableServiceImpl.java +++ /dev/null @@ -1,52 +0,0 @@ -package com.ediagnosis.cdr.service.impl; - -import com.ediagnosis.cdr.dao.entity.BusinessDataSource; -import com.ediagnosis.cdr.dao.entity.BusinessDataSystem; -import com.ediagnosis.cdr.dao.entity.BusinessDataTable; -import com.ediagnosis.cdr.dao.mapper.BusinessDataTableMapper; -import com.ediagnosis.cdr.model.dto.BusinessDataTableDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataTableQueryDTO; -import com.ediagnosis.cdr.service.BusinessDataTableService; -import com.mybatisflex.core.paginate.Page; -import com.mybatisflex.core.query.QueryWrapper; -import org.apache.commons.collections4.CollectionUtils; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.stereotype.Service; -import org.springframework.util.StringUtils; - -/** - * @author monojun - * @description 业务表service - * @createTime 2025年07月31日 - */ -@Service -public class BusinessDataTableServiceImpl implements BusinessDataTableService { - - @Autowired - private BusinessDataTableMapper dataTableMapper; - - @Override - public Page queryPage(BusinessDataTableQueryDTO queryDTO) { - QueryWrapper queryWrapper = QueryWrapper.create() - .select("t.*, d.id as sourceId, d.name as sourceName, ds.id as businessId, ds.name as businessName") - .from(BusinessDataTable.class).as("t") - .leftJoin(BusinessDataSource.class).as("d") - .on(BusinessDataTable::getSourceId, BusinessDataSource::getId) - .leftJoin(BusinessDataSystem.class).as("ds") - .on(BusinessDataSource::getBusinessId, BusinessDataSystem::getId) - .orderBy(BusinessDataTable::getId, false); - 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()); - } - if (StringUtils.hasText(queryDTO.getTableNo())) { - queryWrapper.like(BusinessDataTable::getTableNo, queryDTO.getTableNo()); - } - return dataTableMapper.paginateAs(queryDTO.getPageNo(), queryDTO.getPageSize(), queryWrapper, BusinessDataTableDTO.class); - } -} diff --git a/src/main/resources/generator/mapper/BusinessDataSourceMapper.xml b/src/main/resources/generator/mapper/BusinessDataSourceMapper.xml index c30bc88..8f93e8f 100644 --- a/src/main/resources/generator/mapper/BusinessDataSourceMapper.xml +++ b/src/main/resources/generator/mapper/BusinessDataSourceMapper.xml @@ -1,7 +1,7 @@ - - + + @@ -42,31 +42,4 @@ - - \ No newline at end of file diff --git a/src/main/resources/generator/mapper/BusinessDataSystemMapper.xml b/src/main/resources/generator/mapper/BusinessDataSystemMapper.xml index 2bed50f..a605d18 100644 --- a/src/main/resources/generator/mapper/BusinessDataSystemMapper.xml +++ b/src/main/resources/generator/mapper/BusinessDataSystemMapper.xml @@ -1,7 +1,7 @@ - - + + diff --git a/src/main/resources/generator/mapper/BusinessDataTableFieldMapper.xml b/src/main/resources/generator/mapper/BusinessDataTableFieldMapper.xml index 9951e2c..db6c4df 100644 --- a/src/main/resources/generator/mapper/BusinessDataTableFieldMapper.xml +++ b/src/main/resources/generator/mapper/BusinessDataTableFieldMapper.xml @@ -1,7 +1,7 @@ - - + + diff --git a/src/main/resources/generator/mapper/BusinessDataTableMapper.xml b/src/main/resources/generator/mapper/BusinessDataTableMapper.xml index df36447..7685dc7 100644 --- a/src/main/resources/generator/mapper/BusinessDataTableMapper.xml +++ b/src/main/resources/generator/mapper/BusinessDataTableMapper.xml @@ -1,7 +1,7 @@ - - + + diff --git a/src/test/java/com/ediagnosis/cdr/dao/MapperTest.java b/src/test/java/com/ediagnosis/cdr/dao/MapperTest.java index 6d75e21..3eb473d 100644 --- a/src/test/java/com/ediagnosis/cdr/dao/MapperTest.java +++ b/src/test/java/com/ediagnosis/cdr/dao/MapperTest.java @@ -1,12 +1,11 @@ package com.ediagnosis.cdr.dao; -import com.alibaba.fastjson.JSON; import com.ediagnosis.cdr.CdrApplication; -import com.ediagnosis.cdr.dao.entity.BusinessDataSource; -import com.ediagnosis.cdr.dao.entity.BusinessDataSystem; -import com.ediagnosis.cdr.dao.mapper.BusinessDataSourceMapper; -import com.ediagnosis.cdr.model.dto.BusinessDataSourceDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataSourceQueryDTO; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataSourceDTO; +import com.ediagnosis.cdr.dataCollect.dao.dto.BusinessDataSourceQueryDTO; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSource; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSystem; +import com.ediagnosis.cdr.dataCollect.dao.mapper.BusinessDataSourceMapper; import com.mybatisflex.core.paginate.Page; import com.mybatisflex.core.query.QueryWrapper; import org.junit.jupiter.api.Test; @@ -33,7 +32,7 @@ public class MapperTest { .leftJoin("business_data_system").as("ds") .on("d.business_id = ds.id"); Page dataSourceDTOPage = dataSourceMapper.paginateAs(1, 10, queryWrapper, BusinessDataSourceDTO.class); - System.out.println(JSON.toJSON(dataSourceDTOPage)); + System.out.println(dataSourceDTOPage); } @Test @@ -46,6 +45,6 @@ public class MapperTest { queryWrapper.in(BusinessDataSource::getBusinessId, 1); Page dataSourceDTOPage = dataSourceMapper.paginateAs(1, 10, queryWrapper, BusinessDataSourceDTO.class); - System.out.println(JSON.toJSON(dataSourceDTOPage)); + System.out.println(dataSourceDTOPage); } } diff --git a/src/test/java/com/ediagnosis/cdr/demo/DemoTest.java b/src/test/java/com/ediagnosis/cdr/demo/DemoTest.java index dc708ce..5ad7429 100644 --- a/src/test/java/com/ediagnosis/cdr/demo/DemoTest.java +++ b/src/test/java/com/ediagnosis/cdr/demo/DemoTest.java @@ -1,14 +1,9 @@ package com.ediagnosis.cdr.demo; -import com.alibaba.fastjson.JSON; import com.ediagnosis.cdr.CdrApplication; -import com.ediagnosis.cdr.dao.entity.BusinessDataSystem; -import com.ediagnosis.cdr.model.dto.BusinessDataSystemDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataSystemQueryDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataTableDTO; -import com.ediagnosis.cdr.model.dto.BusinessDataTableQueryDTO; -import com.ediagnosis.cdr.service.BusinessDataSystemService; -import com.ediagnosis.cdr.service.BusinessDataTableService; +import com.ediagnosis.cdr.dataCollect.dao.BusinessDataDao; +import com.ediagnosis.cdr.dataCollect.dao.dto.*; +import com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSystem; import com.mybatisflex.core.paginate.Page; import org.junit.jupiter.api.Test; import org.springframework.beans.factory.annotation.Autowired; @@ -23,36 +18,26 @@ import org.springframework.boot.test.context.SpringBootTest; public class DemoTest { @Autowired - private BusinessDataTableService tableService; - - @Autowired - private BusinessDataSystemService dataSystemService; + private BusinessDataDao businessDataDao; @Test public void test1() { BusinessDataTableQueryDTO queryDTO = new BusinessDataTableQueryDTO(); - Page businessDataTableDTOPage = tableService.queryPage(queryDTO); - System.out.println(JSON.toJSONString(businessDataTableDTOPage)); + Page businessDataTableDTOPage = businessDataDao.queryTablePage(queryDTO); + System.out.println(businessDataTableDTOPage); } @Test public void test2() { BusinessDataSystemQueryDTO queryDTO = new BusinessDataSystemQueryDTO(); - Page dataSystemPage = dataSystemService.queryPage(queryDTO); - System.out.println(JSON.toJSONString(dataSystemPage)); + Page dataSystemPage = businessDataDao.querySystemPage(queryDTO); + System.out.println(dataSystemPage); } @Test public void test3() { - BusinessDataSystemDTO dataSystemDTO = new BusinessDataSystemDTO(); - dataSystemDTO.setName("业务系统demo3"); - dataSystemDTO.setDescription("业务系统demo3描述"); - Long l = dataSystemService.addDataSystem(dataSystemDTO); - System.out.println(l); - BusinessDataSystemDTO updateDataSystemDTO = new BusinessDataSystemDTO(); - updateDataSystemDTO.setId(l); - updateDataSystemDTO.setDescription("业务系统demo3描述1"); - dataSystemService.updateDataSystem(updateDataSystemDTO); + Page dataSourceDTOPage = businessDataDao.querySourcePage(new BusinessDataSourceQueryDTO()); + System.out.println(dataSourceDTOPage); } -- 2.18.1