✨ 提交代码

pom.xml

@@ -45,13 +45,6 @@
         </dependency>
 
 
-        <dependency>
-            <groupId>com.alibaba</groupId>
-            <artifactId>fastjson</artifactId>
-            <version>1.2.60</version>
-        </dependency>
-
-
         <!-- Hive JDBC 驱动 -->
         <dependency>
             <groupId>org.apache.hive</groupId>

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) {

src/main/java/com/ediagnosis/cdr/controller/BusinessDataTableController.java

-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<PageVo<BusinessDataTableVo>> page(@RequestBody BusinessDataTableQueryParam queryParam) {
-        BusinessDataTableQueryDTO queryDTO = new BusinessDataTableQueryDTO();
-        BeanUtils.copyProperties(queryParam, queryDTO);
-        Page<BusinessDataTableDTO> dataTablePage = dataTableService.queryPage(queryDTO);
-        PageVo<BusinessDataTableVo> dataTableVoPageInfo = PageConvertUtils.copyPageInfo(dataTablePage, dataTable -> {
-            BusinessDataTableVo vo = new BusinessDataTableVo();
-            BeanUtils.copyProperties(dataTable, vo);
-            return vo;
-        });
-        return Response.success(dataTableVoPageInfo);
-    }
-}

src/main/java/com/ediagnosis/cdr/controller/BusinessDataTableFieldController.java

-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<PageVo<BusinessDataTableFieldVo>> page(@RequestBody BusinessDataTableFieldQueryParam queryParam) {
-        BusinessDataTableFieldQueryDTO queryDTO = new BusinessDataTableFieldQueryDTO();
-        BeanUtils.copyProperties(queryParam, queryDTO);
-        Page<BusinessDataTableField> dataTableFieldPage = dataTableFieldService.queryPage(queryDTO);
-        PageVo<BusinessDataTableFieldVo> tableFieldVoPageInfo = PageConvertUtils.copyPageInfo(dataTableFieldPage, dataTableField -> {
-            BusinessDataTableFieldVo vo = new BusinessDataTableFieldVo();
-            BeanUtils.copyProperties(dataTableField, vo);
-            return vo;
-        });
-        return Response.success(tableFieldVoPageInfo);
-    }
-}

src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataApi.java

+package com.ediagnosis.cdr.dataCollect;
+
+import org.springframework.stereotype.Component;
+
+/**
+ * @author monojun
+ * @description BusinessDataApi
+ * @createTime 2025年08月04日
+ */
+@Component
+public class BusinessDataApi {
+
+
+}

src/main/java/com/ediagnosis/cdr/controller/BusinessDataSourceController.java → src/main/java/com/ediagnosis/cdr/dataCollect/BusinessDataController.java

-package com.ediagnosis.cdr.controller;
+package com.ediagnosis.cdr.dataCollect;
 
-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.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.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日
+ * @description 业务系统controller
+ * @createTime 2025年08月04日
  */
 @RestController
-@RequestMapping("/dataSource")
-public class BusinessDataSourceController {
+@RequiredArgsConstructor
+public class BusinessDataController {
+
+    private final BusinessDataRepository dataRepository;
 
-    @Autowired
-    private BusinessDataSourceService dataSourceService;
 
-    @PostMapping("/page")
-    public Response<PageVo<BusinessDataSourceVo>> page(@RequestBody BusinessDataSourceQueryParam queryParam) {
+    @PostMapping("/dataSource/page")
+    public Response<PageVo<BusinessDataSourceVo>> page(@RequestBody DataSourceQueryParam queryParam) {
         BusinessDataSourceQueryDTO queryDTO = new BusinessDataSourceQueryDTO();
         BeanUtils.copyProperties(queryParam, queryDTO);
-        Page<BusinessDataSourceDTO> dataSourcePage = dataSourceService.queryPage(queryDTO);
+        Page<BusinessDataSourceDTO> dataSourcePage = dataRepository.querySourcePage(queryDTO);
         PageVo<BusinessDataSourceVo> systemVoPageInfo = PageConvertUtils.copyPageInfo(dataSourcePage, dataSourceDTO -> {
             BusinessDataSourceVo vo = new BusinessDataSourceVo();
             BeanUtils.copyProperties(dataSourceDTO, vo);
@@ -42,4 +46,32 @@ public class BusinessDataSourceController {
         });
         return Response.success(systemVoPageInfo);
     }
+
+    @PostMapping("/dataTable/page")
+    public Response<PageVo<BusinessDataTableVo>> page(@RequestBody DataTableQueryParam queryParam) {
+        BusinessDataTableQueryDTO queryDTO = new BusinessDataTableQueryDTO();
+        BeanUtils.copyProperties(queryParam, queryDTO);
+        Page<BusinessDataTableDTO> dataTablePage = dataRepository.queryTablePage(queryDTO);
+        PageVo<BusinessDataTableVo> dataTableVoPageInfo = PageConvertUtils.copyPageInfo(dataTablePage, dataTable -> {
+            BusinessDataTableVo vo = new BusinessDataTableVo();
+            BeanUtils.copyProperties(dataTable, vo);
+            return vo;
+        });
+        return Response.success(dataTableVoPageInfo);
+    }
+
+    @PostMapping("/dataTableField/page")
+    public Response<PageVo<BusinessDataTableFieldVo>> page(@RequestBody DataTableFieldQueryParam queryParam) {
+        BusinessDataTableFieldQueryDTO queryDTO = new BusinessDataTableFieldQueryDTO();
+        BeanUtils.copyProperties(queryParam, queryDTO);
+        Page<BusinessDataTableField> dataTableFieldPage = dataRepository.queryFieldPage(queryDTO);
+        PageVo<BusinessDataTableFieldVo> tableFieldVoPageInfo = PageConvertUtils.copyPageInfo(dataTableFieldPage, dataTableField -> {
+            BusinessDataTableFieldVo vo = new BusinessDataTableFieldVo();
+            BeanUtils.copyProperties(dataTableField, vo);
+            return vo;
+        });
+        return Response.success(tableFieldVoPageInfo);
+    }
+
+
 }

src/main/java/com/ediagnosis/cdr/controller/BusinessDataSystemController.java → src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSourceController.java

-package com.ediagnosis.cdr.controller;
+package com.ediagnosis.cdr.dataCollect;
 
-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.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.Response;
 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.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;
@@ -18,21 +22,39 @@ import org.springframework.web.bind.annotation.RestController;
 
 /**
  * @author monojun
- * @description 业务系统接口
- * @createTime 2025年07月31日
+ * @description TODO
+ * @createTime 2025年08月05日
  */
 @RestController
-@RequestMapping("/dataSystem")
-public class BusinessDataSystemController {
+@RequestMapping("/dataSource")
+@RequiredArgsConstructor
+public class BusinessSourceController {
+
+    private final BusinessSystemRepository systemRepository;
+
+
+    @PostMapping("/add")
+    public Response<Long> 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<Long> update(@RequestBody DataSystemUpdateParam updateParam) {
+        BusinessDataSystemDTO addDTO = new BusinessDataSystemDTO();
+        BeanUtils.copyProperties(updateParam, addDTO);
+        Long id = systemRepository.updateDataSystem(addDTO);
+        return Response.success(id);
+    }
 
-    @Autowired
-    private BusinessDataSystemService dataSystemService;
 
     @PostMapping("/page")
-    public Response<PageVo<BusinessDataSystemVo>> page(@RequestBody BusinessDataSystemQueryParam queryParam) {
+    public Response<PageVo<BusinessDataSystemVo>> page(@RequestBody DataSystemQueryParam queryParam) {
         BusinessDataSystemQueryDTO queryDTO = new BusinessDataSystemQueryDTO();
         BeanUtils.copyProperties(queryParam, queryDTO);
-        Page<BusinessDataSystem> dataSystemPage = dataSystemService.queryPage(queryDTO);
+        Page<BusinessDataSystem> dataSystemPage = systemRepository.queryPage(queryDTO);
         PageVo<BusinessDataSystemVo> systemVoPageInfo = PageConvertUtils.copyPageInfo(dataSystemPage, dataSystem -> {
             BusinessDataSystemVo vo = new BusinessDataSystemVo();
             BeanUtils.copyProperties(dataSystem, vo);
@@ -40,4 +62,12 @@ public class BusinessDataSystemController {
         });
         return Response.success(systemVoPageInfo);
     }
+
+
+    @PostMapping("/delete")
+    public Response<Long> delete(@RequestBody DataSystemDeleteParam deleteParam) {
+        systemRepository.deleteDataSystem(deleteParam.getId());
+        return Response.success(deleteParam.getId());
+    }
+
 }

src/main/java/com/ediagnosis/cdr/dataCollect/BusinessSystemController.java

+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<Long> 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<Long> 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<PageVo<BusinessDataSystemVo>> page(@RequestBody DataSystemQueryParam queryParam) {
+        BusinessDataSystemQueryDTO queryDTO = new BusinessDataSystemQueryDTO();
+        BeanUtils.copyProperties(queryParam, queryDTO);
+        Page<BusinessDataSystem> dataSystemPage = systemRepository.queryPage(queryDTO);
+        PageVo<BusinessDataSystemVo> systemVoPageInfo = PageConvertUtils.copyPageInfo(dataSystemPage, dataSystem -> {
+            BusinessDataSystemVo vo = new BusinessDataSystemVo();
+            BeanUtils.copyProperties(dataSystem, vo);
+            return vo;
+        });
+        return Response.success(systemVoPageInfo);
+    }
+
+
+    @PostMapping("/delete")
+    public Response<Long> delete(@RequestBody DataSystemDeleteParam deleteParam) {
+        systemRepository.deleteDataSystem(deleteParam.getId());
+        return Response.success(deleteParam.getId());
+    }
+
+
+}

src/main/java/com/ediagnosis/cdr/dataCollect/BusinessTableController.java

+package com.ediagnosis.cdr.dataCollect;
+
+/**
+ * @author monojun
+ * @description TODO
+ * @createTime 2025年08月05日
+ */
+public class BusinessTableController {
+}

src/main/java/com/ediagnosis/cdr/dataCollect/dao/BusinessDataDao.java

+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<BusinessDataSystem>
+     */
+    public Page<BusinessDataSystem> 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<BusinessDataSource>
+     */
+    public Page<BusinessDataSourceDTO> 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<BusinessDataTable>
+     */
+    public Page<BusinessDataTableDTO> 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<BusinessDataTableField>
+     */
+    public Page<BusinessDataTableField> 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);
+    }
+
+}

src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSourceDTO.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSourceDTO.java

-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;

src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSourceQueryDTO.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSourceQueryDTO.java

-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;

src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSystemDTO.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSystemDTO.java

-package com.ediagnosis.cdr.model.dto;
+package com.ediagnosis.cdr.dataCollect.dao.dto;
 
 import lombok.Data;
 

src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataSystemQueryDTO.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataSystemQueryDTO.java

-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;
 
 /**

src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataTableDTO.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataTableDTO.java

-package com.ediagnosis.cdr.model.dto;
+package com.ediagnosis.cdr.dataCollect.dao.dto;
 
 import lombok.Data;
 

src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataTableFieldQueryDTO.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataTableFieldQueryDTO.java

-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;

src/main/java/com/ediagnosis/cdr/model/dto/BusinessDataTableQueryDTO.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/dto/BusinessDataTableQueryDTO.java

-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;

src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataSource.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSource.java

-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")

src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataSystem.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataSystem.java

-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")

src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataTable.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTable.java

-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")

src/main/java/com/ediagnosis/cdr/dao/entity/BusinessDataTableField.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/entity/BusinessDataTableField.java

-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")

src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataSourceMapper.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataSourceMapper.java

-package com.ediagnosis.cdr.dao.mapper;
+package com.ediagnosis.cdr.dataCollect.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.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSource;
 import com.mybatisflex.core.BaseMapper;
-import com.mybatisflex.core.paginate.Page;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
@@ -13,14 +10,11 @@ import java.util.List;
 /**
  * @author monojun
  * @description 数据源mapper
- * @createTime 2025年07月31日
+ * @createTime 2025年08月01日
  */
 @Mapper
 public interface BusinessDataSourceMapper extends BaseMapper<BusinessDataSource> {
 
     int batchInsert(@Param("list") List<BusinessDataSource> list);
 
-    Page<BusinessDataSourceDTO> queryAll(Page<?> page, @Param("queryDTO")BusinessDataSourceQueryDTO queryDTO);
-
-
 }
\ No newline at end of file

src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataSystemMapper.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataSystemMapper.java

-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<BusinessDataSystem> {
 
     int batchInsert(@Param("list") List<BusinessDataSystem> list);
-
 }
\ No newline at end of file

src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataTableFieldMapper.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataTableFieldMapper.java

-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<BusinessDataTableField> {

src/main/java/com/ediagnosis/cdr/dao/mapper/BusinessDataTableMapper.java → src/main/java/com/ediagnosis/cdr/dataCollect/dao/mapper/BusinessDataTableMapper.java

-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<BusinessDataTable> {

src/main/java/com/ediagnosis/cdr/model/param/BusinessDataSourceQueryParam.java → src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSourceQueryParam.java

-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;
 

src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemAddParam.java

+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;
+
+
+}

src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemDeleteParam.java

+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;
+}

src/main/java/com/ediagnosis/cdr/model/param/BusinessDataSystemQueryParam.java → src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemQueryParam.java

-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;
 

src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataSystemUpdateParam.java

+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;
+
+}

src/main/java/com/ediagnosis/cdr/model/param/BusinessDataTableFieldQueryParam.java → src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableFieldQueryParam.java

-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;

src/main/java/com/ediagnosis/cdr/model/param/BusinessDataTableQueryParam.java → src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/DataTableQueryParam.java

-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;

src/main/java/com/ediagnosis/cdr/model/param/PageQuery.java → src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/param/PageQuery.java

-package com.ediagnosis.cdr.model.param;
+package com.ediagnosis.cdr.dataCollect.endpoint.param;
 
 import lombok.Data;
 

src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataSourceVo.java → src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataSourceVo.java

-package com.ediagnosis.cdr.model.vo;
+package com.ediagnosis.cdr.dataCollect.endpoint.vo;
 
 import lombok.Data;
 

src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataSystemVo.java → src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataSystemVo.java

-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;

src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataTableFieldVo.java → src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataTableFieldVo.java

-package com.ediagnosis.cdr.model.vo;
+package com.ediagnosis.cdr.dataCollect.endpoint.vo;
 
 import lombok.Data;
 

src/main/java/com/ediagnosis/cdr/model/vo/BusinessDataTableVo.java → src/main/java/com/ediagnosis/cdr/dataCollect/endpoint/vo/BusinessDataTableVo.java

-package com.ediagnosis.cdr.model.vo;
+package com.ediagnosis.cdr.dataCollect.endpoint.vo;
 
 import lombok.Data;
 

src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessDataRepository.java

+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<BusinessDataSystem>
+     */
+    public Page<BusinessDataSystem> queryPage(BusinessDataSystemQueryDTO queryDTO) {
+        return businessDataDao.querySystemPage(queryDTO);
+    }
+
+    /**
+     * 分页查询业务数据源信息
+     *
+     * @param queryDTO 查询dto
+     * @return PageInfo<BusinessDataSource>
+     */
+    public Page<BusinessDataSourceDTO> querySourcePage(BusinessDataSourceQueryDTO queryDTO) {
+        return businessDataDao.querySourcePage(queryDTO);
+    }
+
+    /**
+     * 分页查询业务表信息
+     *
+     * @param queryDTO 查询dto
+     * @return PageInfo<BusinessDataTable>
+     */
+    public Page<BusinessDataTableDTO> queryTablePage(BusinessDataTableQueryDTO queryDTO) {
+        return businessDataDao.queryTablePage(queryDTO);
+    }
+
+    /**
+     * 分页查询业务表字段信息
+     *
+     * @param queryDTO 查询dto
+     * @return PageInfo<BusinessDataTableField>
+     */
+    public Page<BusinessDataTableField> queryFieldPage(BusinessDataTableFieldQueryDTO queryDTO) {
+        return businessDataDao.queryFieldPage(queryDTO);
+    }
+}

src/main/java/com/ediagnosis/cdr/dataCollect/inner/BusinessSystemRepository.java

+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<BusinessDataSystem>
+     */
+    public Page<BusinessDataSystem> queryPage(BusinessDataSystemQueryDTO queryDTO) {
+        return businessDataDao.querySystemPage(queryDTO);
+    }
+
+    /**
+     * 删除业务系统
+     *
+     * @param dataSystemId 业务系统id
+     */
+    public void deleteDataSystem(Long dataSystemId) {
+        businessDataDao.deleteDataSystem(dataSystemId);
+    }
+
+}

src/main/java/com/ediagnosis/cdr/service/BusinessDataSourceService.java

-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<BusinessDataSource>
-     */
-    Page<BusinessDataSourceDTO> queryPage(BusinessDataSourceQueryDTO queryDTO);
-}

src/main/java/com/ediagnosis/cdr/service/BusinessDataSystemService.java

-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<BusinessDataSystem>
-     */
-    Page<BusinessDataSystem> queryPage(BusinessDataSystemQueryDTO queryDTO);
-}

src/main/java/com/ediagnosis/cdr/service/BusinessDataTableFieldService.java

-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<BusinessDataTableField>
-     */
-    Page<BusinessDataTableField> queryPage(BusinessDataTableFieldQueryDTO queryDTO);
-}

src/main/java/com/ediagnosis/cdr/service/BusinessDataTableService.java

-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<BusinessDataTable>
-     */
-    Page<BusinessDataTableDTO> queryPage(BusinessDataTableQueryDTO queryDTO);
-}

src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataSourceServiceImpl.java

-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<BusinessDataSourceDTO> 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);
-    }
-}

src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataSystemServiceImpl.java

-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<BusinessDataSystem> 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);
-    }
-}

src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataTableFieldServiceImpl.java

-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<BusinessDataTableField> 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);
-    }
-}

src/main/java/com/ediagnosis/cdr/service/impl/BusinessDataTableServiceImpl.java

-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<BusinessDataTableDTO> 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);
-    }
-}

src/main/resources/generator/mapper/BusinessDataSourceMapper.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.ediagnosis.cdr.dao.mapper.BusinessDataSourceMapper">
-  <resultMap id="BaseResultMap" type="com.ediagnosis.cdr.dao.entity.BusinessDataSource">
+<mapper namespace="com.ediagnosis.cdr.dataCollect.dao.mapper.BusinessDataSourceMapper">
+  <resultMap id="BaseResultMap" type="com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSource">
     <!--@mbg.generated-->
     <!--@Table business_data_source-->
     <id column="id" jdbcType="BIGINT" property="id" />
@@ -42,31 +42,4 @@
     </foreach>
   </insert>
 
-
-  <select id="queryAll" resultType="com.ediagnosis.cdr.model.dto.BusinessDataSourceDTO">
-    select
-    <include refid="Column_List_DTO"/>
-    from business_data_source d left join business_data_system ds on d.business_id = ds.id
-    <where>
-      <if test="queryDTO.businessIds != null and queryDTO.businessIds.size() != 0">
-        and d.business_id in
-        <foreach collection="queryDTO.businessIds" item="item" open="(" separator="," close=")">
-          #{item}
-        </foreach>
-      </if>
-      <if test="queryDTO.name != null and queryDTO.name != ''">
-        and d.name like concat('%', #{queryDTO.name,jdbcType=VARCHAR}, '%')
-      </if>
-      <if test="queryDTO.ipAddress != null and queryDTO.ipAddress != ''">
-        and d.ip_address like concat('%', #{queryDTO.ipAddress,jdbcType=VARCHAR}, '%')
-      </if>
-      <if test="queryDTO.type != null and queryDTO.type != ''">
-        and d.type = #{queryDTO.type,jdbcType=VARCHAR}
-      </if>
-      <if test="queryDTO.status != null">
-        and d.status = #{queryDTO.status,jdbcType=INTEGER}
-      </if>
-    </where>
-    order by d.update_time desc, id desc
-  </select>
 </mapper>
\ No newline at end of file

src/main/resources/generator/mapper/BusinessDataSystemMapper.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.ediagnosis.cdr.dao.mapper.BusinessDataSystemMapper">
-  <resultMap id="BaseResultMap" type="com.ediagnosis.cdr.dao.entity.BusinessDataSystem">
+<mapper namespace="com.ediagnosis.cdr.dataCollect.dao.mapper.BusinessDataSystemMapper">
+  <resultMap id="BaseResultMap" type="com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataSystem">
     <!--@mbg.generated-->
     <!--@Table business_data_system-->
     <id column="id" jdbcType="BIGINT" property="id" />

src/main/resources/generator/mapper/BusinessDataTableFieldMapper.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.ediagnosis.cdr.dao.mapper.BusinessDataTableFieldMapper">
-  <resultMap id="BaseResultMap" type="com.ediagnosis.cdr.dao.entity.BusinessDataTableField">
+<mapper namespace="com.ediagnosis.cdr.dataCollect.dao.mapper.BusinessDataTableFieldMapper">
+  <resultMap id="BaseResultMap" type="com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataTableField">
     <!--@mbg.generated-->
     <!--@Table business_data_table_field-->
     <id column="id" jdbcType="BIGINT" property="id" />

src/main/resources/generator/mapper/BusinessDataTableMapper.xml

 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.ediagnosis.cdr.dao.mapper.BusinessDataTableMapper">
-  <resultMap id="BaseResultMap" type="com.ediagnosis.cdr.dao.entity.BusinessDataTable">
+<mapper namespace="com.ediagnosis.cdr.dataCollect.dao.mapper.BusinessDataTableMapper">
+  <resultMap id="BaseResultMap" type="com.ediagnosis.cdr.dataCollect.dao.entity.BusinessDataTable">
     <!--@mbg.generated-->
     <!--@Table business_data_table-->
     <id column="id" jdbcType="BIGINT" property="id" />

src/test/java/com/ediagnosis/cdr/dao/MapperTest.java

 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<BusinessDataSourceDTO> 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<BusinessDataSourceDTO> dataSourceDTOPage = dataSourceMapper.paginateAs(1, 10, queryWrapper, BusinessDataSourceDTO.class);
-        System.out.println(JSON.toJSON(dataSourceDTOPage));
+        System.out.println(dataSourceDTOPage);
     }
 }

src/test/java/com/ediagnosis/cdr/demo/DemoTest.java

 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<BusinessDataTableDTO> businessDataTableDTOPage = tableService.queryPage(queryDTO);
-        System.out.println(JSON.toJSONString(businessDataTableDTOPage));
+        Page<BusinessDataTableDTO> businessDataTableDTOPage = businessDataDao.queryTablePage(queryDTO);
+        System.out.println(businessDataTableDTOPage);
     }
 
     @Test
     public void test2() {
         BusinessDataSystemQueryDTO queryDTO = new BusinessDataSystemQueryDTO();
-        Page<BusinessDataSystem> dataSystemPage = dataSystemService.queryPage(queryDTO);
-        System.out.println(JSON.toJSONString(dataSystemPage));
+        Page<BusinessDataSystem> 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<BusinessDataSourceDTO> dataSourceDTOPage = businessDataDao.querySourcePage(new BusinessDataSourceQueryDTO());
+        System.out.println(dataSourceDTOPage);
     }