Merge remote-tracking branch 'gitlab/dev-v1' into dev-init

# Conflicts:
#	pom.xml
#	src/main/java/com/ediagnosis/cdr/dataService/DwsRepository.java

.gitignore

@@ -4,6 +4,7 @@ target/
 !**/src/test/**/target/
 
 ### IntelliJ IDEA ###
+.idea
 .idea/modules.xml
 .idea/jarRepositories.xml
 .idea/compiler.xml

pom.xml

@@ -39,6 +39,89 @@
             <scope>runtime</scope>
         </dependency>
 
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+
+
+        <!-- Hive JDBC 驱动 -->
+        <dependency>
+            <groupId>org.apache.hive</groupId>
+            <artifactId>hive-jdbc</artifactId>
+            <version>3.1.2</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.slf4j</groupId>
+                    <artifactId>slf4j-log4j12</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>log4j</groupId>
+                    <artifactId>log4j</artifactId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>log4j-1.2-api</artifactId>
+                    <groupId>org.apache.logging.log4j</groupId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>log4j-slf4j-impl</artifactId>
+                    <groupId>org.apache.logging.log4j</groupId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>log4j-web</artifactId>
+                    <groupId>org.apache.logging.log4j</groupId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>commons-logging</artifactId>
+                    <groupId>commons-logging</groupId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>jdk.tools</artifactId>
+                    <groupId>jdk.tools</groupId>
+                </exclusion>
+                <exclusion>
+                    <groupId>org.eclipse.jetty.aggregate</groupId>
+                    <artifactId>*</artifactId>
+                </exclusion>
+
+                <exclusion>
+                    <groupId>org.eclipse.jetty</groupId>
+                    <artifactId>jetty-runner</artifactId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>servlet-api</artifactId>
+                    <groupId>javax.servlet</groupId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>javax.servlet.jsp-api</artifactId>
+                    <groupId>javax.servlet.jsp</groupId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>javax.servlet.jsp</artifactId>
+                    <groupId>org.glassfish.web</groupId>
+                </exclusion>
+                <exclusion>
+                    <artifactId>junit</artifactId>
+                    <groupId>junit</groupId>
+                </exclusion>
+            </exclusions>
+
+
+
+        </dependency>
+
+        <dependency>
+
+            <groupId>org.apache.hadoop</groupId>
+            <artifactId>hadoop-common</artifactId>
+            <version>3.3.4</version>
+            <exclusions>
+                <exclusion>
+                    <artifactId>commons-logging</artifactId>
+                    <groupId>commons-logging</groupId>
+                </exclusion>
+            </exclusions>
+        </dependency>
         <dependency>
             <groupId>com.facebook.presto</groupId>
             <artifactId>presto-jdbc</artifactId>

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/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/dataCollect/BusinessDataController.java

+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<PageVo<BusinessDataSourceVo>> page(@RequestBody DataSourceQueryParam queryParam) {
+        BusinessDataSourceQueryDTO queryDTO = new BusinessDataSourceQueryDTO();
+        BeanUtils.copyProperties(queryParam, queryDTO);
+        Page<BusinessDataSourceDTO> dataSourcePage = dataRepository.querySourcePage(queryDTO);
+        PageVo<BusinessDataSourceVo> 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<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/dataCollect/BusinessSourceController.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 TODO
+ * @createTime 2025年08月05日
+ */
+@RestController
+@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);
+    }
+
+
+    @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/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/dataCollect/dao/dto/BusinessDataSourceDTO.java

+package com.ediagnosis.cdr.dataCollect.dao.dto;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author monojun
+ * @description 数据源dto
+ * @createTime 2025年07月31日
+ */
+@Data
+public class BusinessDataSourceDTO implements Serializable {
+    @Serial
+    private static final long serialVersionUID = -447329639545048136L;
+
+    /**
+     * 主键id
+     */
+    private Long id;
+
+    /**
+     * 数据源名称
+     */
+    private String name;
+
+    /**
+     * 数据源类型
+     */
+    private String type;
+
+    /**
+     * IP地址
+     */
+    private String ipAddress;
+
+    /**
+     * 属性信息
+     */
+    private String properties;
+
+    /**
+     * 业务系统id
+     */
+    private Long businessId;
+
+    /**
+     * 业务系统名称
+     */
+    private String businessName;
+
+    /**
+     * 描述
+     */
+    private String description;
+
+    /**
+     * 连接状态: 0-未知 1-已连接 2-未连接
+     */
+    private Integer status;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建人
+     */
+    private Long createUserId;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 更新人
+     */
+    private Long updateUserId;
+
+
+}

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

+package com.ediagnosis.cdr.dataCollect.dao.dto;
+
+import com.ediagnosis.cdr.dataCollect.endpoint.param.PageQuery;
+import lombok.Data;
+
+import java.io.Serial;
+import java.util.List;
+
+/**
+ * @author monojun
+ * @description 业务数据源查询dto
+ * @createTime 2025年07月31日
+ */
+@Data
+public class BusinessDataSourceQueryDTO extends PageQuery {
+    @Serial
+    private static final long serialVersionUID = 4373837873599613512L;
+
+    /**
+     * 业务系统id列表
+     */
+    private List<Long> businessIds;
+
+    /**
+     * 数据源名称
+     */
+    private String name;
+
+    /**
+     * ip地址
+     */
+    private String ipAddress;
+
+    /**
+     * 数据源类型
+     */
+    private String type;
+
+    /**
+     * 连接状态: 0-未知 1-已连接 2-未连接
+     */
+    private Integer status;
+}

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

+package com.ediagnosis.cdr.dataCollect.dao.dto;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author monojun
+ * @description 业务系统dto
+ * @createTime 2025年07月31日
+ */
+@Data
+public class BusinessDataSystemDTO implements Serializable {
+    @Serial
+    private static final long serialVersionUID = 8024021126762424795L;
+
+    /**
+     * 主键id
+     */
+    private Long id;
+
+    /**
+     * 业务系统名称
+     */
+    private String name;
+
+    /**
+     * 描述
+     */
+    private String description;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建人
+     */
+    private Long createUserId;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 更新人
+     */
+    private Long updateUserId;
+}

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

+package com.ediagnosis.cdr.dataCollect.dao.dto;
+
+import com.ediagnosis.cdr.dataCollect.endpoint.param.PageQuery;
+import lombok.Data;
+
+/**
+ * @author monojun
+ * @description 业务系统查询参数
+ * @createTime 2025年07月31日
+ */
+@Data
+public class BusinessDataSystemQueryDTO extends PageQuery {
+    private static final long serialVersionUID = -725393158125223566L;
+
+    /**
+     * 业务系统名称
+     */
+    private String name;
+
+
+}

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

+package com.ediagnosis.cdr.dataCollect.dao.dto;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author monojun
+ * @description 业务数据源名称
+ * @createTime 2025年07月31日
+ */
+@Data
+public class BusinessDataTableDTO implements Serializable {
+    @Serial
+    private static final long serialVersionUID = -1723613352839697417L;
+
+    /**
+     * 主键id
+     */
+    private Long id;
+
+    /**
+     * 业务表名称
+     */
+    private String name;
+
+    /**
+     * 业务表编号
+     */
+    private String tableNo;
+
+    /**
+     * 业务系统id
+     */
+    private Long businessId;
+
+    /**
+     * 业务系统名称
+     */
+    private String businessName;
+
+    /**
+     * 业务数据源id
+     */
+    private Long sourceId;
+
+    /**
+     * 业务数据源名称
+     */
+    private String sourceName;
+
+    /**
+     * 描述
+     */
+    private String description;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建人
+     */
+    private Long createUserId;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 更新人
+     */
+    private Long updateUserId;
+
+}

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

+package com.ediagnosis.cdr.dataCollect.dao.dto;
+
+import com.ediagnosis.cdr.dataCollect.endpoint.param.PageQuery;
+import lombok.Data;
+
+import java.io.Serial;
+
+/**
+ * @author monojun
+ * @description 业务数据表dto
+ * @createTime 2025年07月31日
+ */
+@Data
+public class BusinessDataTableFieldQueryDTO extends PageQuery {
+    @Serial
+    private static final long serialVersionUID = -7409716170936124466L;
+
+    /**
+     * 字段名称
+     */
+    private String fieldName;
+
+    /**
+     * 字段类型
+     */
+    private String fieldType;
+
+    /**
+     * 业务表id
+     */
+    private Long tableId;
+}

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

+package com.ediagnosis.cdr.dataCollect.dao.dto;
+
+import com.ediagnosis.cdr.dataCollect.endpoint.param.PageQuery;
+import lombok.Data;
+
+import java.io.Serial;
+import java.util.List;
+
+/**
+ * @author monojun
+ * @description 业务数据表dto
+ * @createTime 2025年07月31日
+ */
+@Data
+public class BusinessDataTableQueryDTO extends PageQuery {
+    @Serial
+    private static final long serialVersionUID = 2568845339056229745L;
+
+    /**
+     * 业务系统id
+     */
+    private List<Long> businessIds;
+
+    /**
+     * 业务数据源id列表
+     */
+    private List<Long> sourceIds;
+
+    /**
+     * 业务表名称
+     */
+    private String name;
+
+    /**
+     * 业务表编号
+     */
+    private String tableNo;
+}

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

+package com.ediagnosis.cdr.dataCollect.dao.entity;
+
+import com.mybatisflex.annotation.Column;
+import com.mybatisflex.annotation.Id;
+import com.mybatisflex.annotation.KeyType;
+import com.mybatisflex.annotation.Table;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author monojun
+ * @description 业务系统数据源表
+ * @createTime 2025年08月01日
+ */
+@Data
+@Table(value = "business_data_source")
+public class BusinessDataSource implements Serializable {
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键id
+     */
+    @Id(value = "id", keyType = KeyType.Auto)
+    private Long id;
+
+    /**
+     * 数据源名称
+     */
+    @Column(value = "name")
+    private String name;
+
+    /**
+     * 数据源类型
+     */
+    @Column(value = "type")
+    private String type;
+
+    /**
+     * IP地址
+     */
+    @Column(value = "ip_address")
+    private String ipAddress;
+
+    /**
+     * 属性信息
+     */
+    @Column(value = "properties")
+    private String properties;
+
+    /**
+     * 业务系统id
+     */
+    @Column(value = "business_id")
+    private Long businessId;
+
+    /**
+     * 描述
+     */
+    @Column(value = "description")
+    private String description;
+
+    /**
+     * 连接状态: 0-未知 1-已连接 2-未连接
+     */
+    @Column(value = "status")
+    private Integer status;
+
+    /**
+     * 创建时间
+     */
+    @Column(value = "create_time")
+    private Date createTime;
+
+    /**
+     * 创建人
+     */
+    @Column(value = "create_user_id")
+    private Long createUserId;
+
+    /**
+     * 更新时间
+     */
+    @Column(value = "update_time")
+    private Date updateTime;
+
+    /**
+     * 更新人
+     */
+    @Column(value = "update_user_id")
+    private Long updateUserId;
+
+    /**
+     * 是否删除: 0-未删除 1-已删除
+     */
+    @Column(value = "is_deleted", isLogicDelete = true)
+    private Integer isDeleted;
+}
\ No newline at end of file

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

+package com.ediagnosis.cdr.dataCollect.dao.entity;
+
+import com.mybatisflex.annotation.Column;
+import com.mybatisflex.annotation.Id;
+import com.mybatisflex.annotation.KeyType;
+import com.mybatisflex.annotation.Table;
+import lombok.Data;
+
+import java.util.Date;
+
+/**
+ * @author monojun
+ * @description 业务系统表
+ * @createTime 2025年08月01日
+ */
+@Data
+@Table("business_data_system")
+public class BusinessDataSystem {
+    /**
+     * 主键id
+     */
+    @Id(value = "id", keyType = KeyType.Auto)
+    private Long id;
+
+    /**
+     * 业务系统名称
+     */
+    @Column(value = "name")
+    private String name;
+
+    /**
+     * 描述
+     */
+    @Column(value = "description")
+    private String description;
+
+    /**
+     * 创建时间
+     */
+    @Column(value = "create_time")
+    private Date createTime;
+
+    /**
+     * 创建人
+     */
+    @Column(value = "create_user_id")
+    private Long createUserId;
+
+    /**
+     * 更新时间
+     */
+    @Column(value = "update_time")
+    private Date updateTime;
+
+    /**
+     * 更新人
+     */
+    @Column(value = "update_user_id")
+    private Long updateUserId;
+
+    /**
+     * 是否删除 0-未删除  1-已删除
+     */
+    @Column(value = "is_deleted", isLogicDelete = true)
+    private Integer isDeleted;
+}
\ No newline at end of file

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

+package com.ediagnosis.cdr.dataCollect.dao.entity;
+
+import com.mybatisflex.annotation.Column;
+import com.mybatisflex.annotation.Id;
+import com.mybatisflex.annotation.KeyType;
+import com.mybatisflex.annotation.Table;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author monojun
+ * @description 业务表信息表
+ * @createTime 2025年08月01日
+ */
+@Data
+@Table(value = "business_data_table")
+public class BusinessDataTable implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键id
+     */
+    @Id(value = "id", keyType = KeyType.Auto)
+    private Long id;
+
+    /**
+     * 业务表名称
+     */
+    @Column(value = "name")
+    private String name;
+
+    /**
+     * 业务表编号
+     */
+    @Column(value = "table_no")
+    private String tableNo;
+
+    /**
+     * 业务系统id
+     */
+    @Column(value = "business_id")
+    private Long businessId;
+
+    /**
+     * 业务数据源id
+     */
+    @Column(value = "source_id")
+    private Long sourceId;
+
+    /**
+     * 描述
+     */
+    @Column(value = "description")
+    private String description;
+
+    /**
+     * 创建时间
+     */
+    @Column(value = "create_time")
+    private Date createTime;
+
+    /**
+     * 创建人
+     */
+    @Column(value = "create_user_id")
+    private Long createUserId;
+
+    /**
+     * 更新时间
+     */
+    @Column(value = "update_time")
+    private Date updateTime;
+
+    /**
+     * 更新人
+     */
+    @Column(value = "update_user_id")
+    private Long updateUserId;
+
+    /**
+     * 是否删除: 0-未删除 1-已删除
+     */
+    @Column(value = "is_deleted", isLogicDelete = true)
+    private Byte isDeleted;
+}
\ No newline at end of file

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

+package com.ediagnosis.cdr.dataCollect.dao.entity;
+
+import com.mybatisflex.annotation.Column;
+import com.mybatisflex.annotation.Id;
+import com.mybatisflex.annotation.KeyType;
+import com.mybatisflex.annotation.Table;
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author monojun
+ * @description 业务字段信息表
+ * @createTime 2025年08月01日
+ */
+@Data
+@Table(value = "business_data_table_field")
+public class BusinessDataTableField implements Serializable {
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 主键id
+     */
+    @Id(value = "id", keyType = KeyType.Auto)
+    private Long id;
+
+    /**
+     * 字段名称
+     */
+    @Column(value = "field_name")
+    private String fieldName;
+
+    /**
+     * 字段类型
+     */
+    @Column(value = "field_type")
+    private String fieldType;
+
+    /**
+     * 业务表id
+     */
+    @Column(value = "table_id")
+    private Long tableId;
+
+    /**
+     * 描述
+     */
+    @Column(value = "description")
+    private String description;
+
+    /**
+     * 创建时间
+     */
+    @Column(value = "create_time")
+    private Date createTime;
+
+    /**
+     * 创建人
+     */
+    @Column(value = "create_user_id")
+    private Long createUserId;
+
+    /**
+     * 更新时间
+     */
+    @Column(value = "update_time")
+    private Date updateTime;
+
+    /**
+     * 更新人
+     */
+    @Column(value = "update_user_id")
+    private Long updateUserId;
+
+    /**
+     * 是否删除: 0-未删除 1-已删除
+     */
+    @Column(value = "is_deleted", isLogicDelete = true)
+    private Byte isDeleted;
+}
\ No newline at end of file

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

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

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

+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年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/dataCollect/dao/mapper/BusinessDataTableFieldMapper.java

+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年08月01日
+ */
+@Mapper
+public interface BusinessDataTableFieldMapper extends BaseMapper<BusinessDataTableField> {
+
+    int batchInsert(@Param("list") List<BusinessDataTableField> list);
+}
\ No newline at end of file

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

+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年08月01日
+ */
+@Mapper
+public interface BusinessDataTableMapper extends BaseMapper<BusinessDataTable> {
+    int batchInsert(@Param("list") List<BusinessDataTable> list);
+}
\ No newline at end of file

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

+package com.ediagnosis.cdr.dataCollect.endpoint.param;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.util.List;
+
+/**
+ * @author monojun
+ * @description 数据源查询参数
+ * @createTime 2025年08月01日
+ */
+@Data
+public class DataSourceQueryParam extends PageQuery {
+    @Serial
+    private static final long serialVersionUID = 4384878864788101913L;
+
+    /**
+     * 业务系统id列表
+     */
+    private List<Long> businessIds;
+
+    /**
+     * 数据源名称
+     */
+    private String name;
+
+    /**
+     * ip地址
+     */
+    private String ipAddress;
+
+    /**
+     * 数据源类型
+     */
+    private String type;
+}

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/dataCollect/endpoint/param/DataSystemQueryParam.java

+package com.ediagnosis.cdr.dataCollect.endpoint.param;
+
+import lombok.Data;
+
+import java.io.Serial;
+
+/**
+ * @author monojun
+ * @description 业务系统分页查询参数
+ * @createTime 2025年08月01日
+ */
+@Data
+public class DataSystemQueryParam extends PageQuery {
+    @Serial
+    private static final long serialVersionUID = 5408831076545737168L;
+
+    /**
+     * 业务系统名称
+     */
+    private String name;
+}

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/dataCollect/endpoint/param/DataTableFieldQueryParam.java

+package com.ediagnosis.cdr.dataCollect.endpoint.param;
+
+import lombok.Data;
+
+import java.io.Serial;
+
+/**
+ * @author monojun
+ * @description 表字段查询参数
+ * @createTime 2025年08月01日
+ */
+@Data
+public class DataTableFieldQueryParam extends PageQuery {
+
+    @Serial
+    private static final long serialVersionUID = 5419533067070233483L;
+    /**
+     * 字段名称
+     */
+    private String fieldName;
+
+    /**
+     * 字段类型
+     */
+    private String fieldType;
+
+    /**
+     * 业务表id
+     */
+    private Long tableId;
+}

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

+package com.ediagnosis.cdr.dataCollect.endpoint.param;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.util.List;
+
+/**
+ * @author monojun
+ * @description 表信息查询参数
+ * @createTime 2025年08月01日
+ */
+@Data
+public class DataTableQueryParam extends PageQuery {
+
+    @Serial
+    private static final long serialVersionUID = -6012405803243067316L;
+    /**
+     * 业务系统id列表
+     */
+    private List<Long> businessIds;
+
+    /**
+     * 业务数据源id列表
+     */
+    private List<Long> sourceIds;
+
+    /**
+     * 业务表名称
+     */
+    private String name;
+
+    /**
+     * 业务表编号
+     */
+    private String tableNo;
+}

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

+package com.ediagnosis.cdr.dataCollect.endpoint.param;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+
+/**
+ * 可以传入一个实体T类型来接收该类型属性值。
+ *
+ * @author wangziqiao
+ */
+@Data
+public class PageQuery implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = -1808475912533720127L;
+
+    private int pageNo = 1;
+
+    private int pageSize = 10;
+
+    public int getOffset() {
+        return (pageNo - 1) * pageSize;
+    }
+}

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

+package com.ediagnosis.cdr.dataCollect.endpoint.vo;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author monojun
+ * @description 数据源信息
+ * @createTime 2025年07月31日
+ */
+@Data
+public class BusinessDataSourceVo implements Serializable {
+    @Serial
+    private static final long serialVersionUID = -4205114103165887164L;
+
+    /**
+     * 主键id
+     */
+    private Long id;
+
+    /**
+     * 数据源名称
+     */
+    private String name;
+
+    /**
+     * 数据源类型（mysql、oracle、postgreSQL、sqlserver、h2、sqlite）
+     */
+    private String type;
+
+    /**
+     * IP地址
+     */
+    private String ipAddress;
+
+    /**
+     * 业务系统id
+     */
+    private Long bizSystemId;
+
+    /**
+     * 业务系统名称
+     */
+    private String bizSystemName;
+
+    /**
+     * 描述
+     */
+    private String description;
+
+    /**
+     * 属性
+     */
+    private String properties;
+
+    /**
+     * 连接状态
+     */
+    private Integer status;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建人
+     */
+    private Long createUserId;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 更新人
+     */
+    private Long updateUserId;
+}

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

+package com.ediagnosis.cdr.dataCollect.endpoint.vo;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author monojun
+ * @description 业务系统信息
+ * @createTime 2025年07月31日
+ */
+@Data
+public class BusinessDataSystemVo implements Serializable {
+    @Serial
+    private static final long serialVersionUID = 1995094555769215993L;
+    /**
+     * 主键id
+     */
+    private Long id;
+
+    /**
+     * 业务系统名称
+     */
+    private String name;
+
+    /**
+     * 描述
+     */
+    private String description;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建人
+     */
+    private Long createUserId;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 更新人
+     */
+    private Long updateUserId;
+
+}

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

+package com.ediagnosis.cdr.dataCollect.endpoint.vo;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author monojun
+ * @description 表字段信息
+ * @createTime 2025年07月31日
+ */
+@Data
+public class BusinessDataTableFieldVo implements Serializable {
+    @Serial
+    private static final long serialVersionUID = 3062177923173755855L;
+
+    /**
+     * 主键id
+     */
+    private Long id;
+
+    /**
+     * 字段名称
+     */
+    private String fieldName;
+
+    /**
+     * 字段类型
+     */
+    private String fieldType;
+
+    /**
+     * 业务表id
+     */
+    private Long tableId;
+
+    /**
+     * 描述
+     */
+    private String description;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建人
+     */
+    private Long createUserId;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 更新人
+     */
+    private Long updateUserId;
+}

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

+package com.ediagnosis.cdr.dataCollect.endpoint.vo;
+
+import lombok.Data;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @author monojun
+ * @description 表信息
+ * @createTime 2025年07月31日
+ */
+@Data
+public class BusinessDataTableVo implements Serializable {
+    @Serial
+    private static final long serialVersionUID = 8791629491093128048L;
+
+    /**
+     * 主键id
+     */
+    private Long id;
+
+    /**
+     * 业务表名称
+     */
+    private String name;
+
+    /**
+     * 业务表编号
+     */
+    private String tableNo;
+
+    /**
+     * 业务系统id
+     */
+    private Long businessId;
+
+    /**
+     * 业务系统名称
+     */
+    private String businessName;
+
+    /**
+     * 业务数据源id
+     */
+    private Long sourceId;
+
+    /**
+     * 业务数据源名称
+     */
+    private String sourceName;
+
+    /**
+     * 描述
+     */
+    private String description;
+
+    /**
+     * 创建时间
+     */
+    private Date createTime;
+
+    /**
+     * 创建人
+     */
+    private Long createUserId;
+
+    /**
+     * 更新时间
+     */
+    private Date updateTime;
+
+    /**
+     * 更新人
+     */
+    private Long updateUserId;
+}

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/dataService/DwsRepository.java

@@ -19,7 +19,7 @@ public class DwsRepository {
         this.hiveQueryExecutor = hiveQueryExecutor;
     }
 
-    public Page<Map<String, String>> queryPage(String sql, int pageNo,int pageSize) {
+    public PageVo<Map<String, String>> queryPage(String sql, int pageNo, int pageSize) {
         com.mybatisflex.core.paginate.Page<Row> rowPage = hiveQueryExecutor.selectByFullSql(sql, pageNo, pageSize);
         List<Map<String, String>> result = rowPage.getRecords().stream()
                 .map(row -> {
@@ -41,7 +41,7 @@ public class DwsRepository {
                 .filter(map -> !map.isEmpty()) // 可选：过滤掉空 map
                 .toList();
 
-        return new Page<>(pageNo, pageSize, rowPage.getTotalRow(), result);
+        return new PageVo<>(pageNo, pageSize, rowPage.getTotalRow(), result);
     }
 
 

src/main/java/com/ediagnosis/cdr/enums/DataSourceTypeEnum.java

+package com.ediagnosis.cdr.enums;
+
+import lombok.Getter;
+
+/**
+ * @author monojun
+ * @description 数据源类型枚举
+ * @createTime 2025年07月31日
+ */
+@Getter
+public enum DataSourceTypeEnum {
+
+    Mysql("Mysql", "mysql"),
+
+    Oracle("Oracle", "oracle"),
+
+    PostgreSQL("PostgreSQL", "postgreSQL"),
+
+    SQLServer("SQLServer", "sqlserver"),
+
+    H2("H2", "h2"),
+
+    SQLite("SQLite", "sqlite");
+
+
+    private final String key;
+
+    private final String value;
+
+
+    DataSourceTypeEnum(String key, String value) {
+        this.key = key;
+        this.value = value;
+    }
+
+}

src/main/java/com/ediagnosis/cdr/enums/FieldTypeEnum.java

+package com.ediagnosis.cdr.enums;
+
+import lombok.Getter;
+
+/**
+ * @author monojun
+ * @description 字段类型枚举
+ * @createTime 2025年08月01日
+ */
+@Getter
+public enum FieldTypeEnum {
+
+    varchar("varchar", "String"),
+
+    text("text", "String"),
+
+    decimal("decimal", "BigDecimal"),
+
+    integer("integer", "Integer"),
+
+    int4("int4", "Integer"),
+
+    int8("int8", "Integer"),
+
+    number("number", "Long"),
+
+    datetime("datetime", "Date"),
+
+    timestamp("timestamp", "Date"),
+
+    bool("boolean", "Boolean");
+
+
+    private final String key;
+
+    private final String value;
+
+
+    FieldTypeEnum(String key, String value) {
+        this.key = key;
+        this.value = value;
+    }
+}

src/main/java/com/ediagnosis/cdr/util/PageConvertUtils.java

+package com.ediagnosis.cdr.util;
+
+import com.ediagnosis.cdr.value.PageVo;
+import com.mybatisflex.core.paginate.Page;
+import org.springframework.beans.BeanUtils;
+
+import java.util.List;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+/**
+ * @author monojun
+ * @description 拷贝工具
+ * @createTime 2025年07月03日
+ */
+public class PageConvertUtils {
+    /**
+     * 拷贝 Page<T> 到 PageVo<R>
+     *
+     * @param source   原始分页数据
+     * @param function 转换函数 T -> R
+     * @param <T>      源类型
+     * @param <R>      目标类型
+     * @return PageInfo<R>
+     */
+    public static <T, R> PageVo<R> copyPageInfo(Page<T> source, Function<T, R> function) {
+        PageVo<R> result = new PageVo<>();
+        // 拷贝分页信息（排除list）
+        BeanUtils.copyProperties(source, result, "list");
+        result.setPageNo(source.getPageNumber());
+        result.setPageSize(source.getPageSize());
+        result.setTotalCount(source.getTotalRow());
+        result.setTotalPage(source.getTotalPage());
+        List<R> collect = source.getRecords().stream()
+                .map(function)
+                .collect(Collectors.toList());
+        result.setContent(collect);
+        return result;
+    }
+
+
+}

src/main/java/com/ediagnosis/cdr/value/Page.java → src/main/java/com/ediagnosis/cdr/value/PageVo.java

@@ -2,18 +2,18 @@ package com.ediagnosis.cdr.value;
 
 import java.util.List;
 
-public class Page<T> {
+public class PageVo<T> {
     private long pageNo;
     private long pageSize;
     private long totalCount;
     private List<T> content;
     private long totalPage;
 
-    public Page() {
+    public PageVo() {
     }
 
-    public Page(long pageNo, long pageSize,
-                long totalCount, List<T> content) {
+    public PageVo(long pageNo, long pageSize,
+                  long totalCount, List<T> content) {
         this.pageNo = pageNo;
         this.pageSize = pageSize;
         this.totalCount = totalCount;

src/main/resources/application.yml

@@ -2,7 +2,7 @@
 mybatis-flex:
   datasource:
     ds-mysql:
-      url: jdbc:mysql://10.11.4.21:33063/cdr
+      url: jdbc:mysql://10.11.4.21:33063/cdr_v1
       username: root
       password: Admin123456#
     ds-hive:

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.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" />
+    <result column="name" jdbcType="VARCHAR" property="name" />
+    <result column="type" jdbcType="VARCHAR" property="type" />
+    <result column="ip_address" jdbcType="VARCHAR" property="ipAddress" />
+    <result column="properties" jdbcType="LONGVARCHAR" property="properties" />
+    <result column="business_id" jdbcType="BIGINT" property="businessId" />
+    <result column="description" jdbcType="LONGVARCHAR" property="description" />
+    <result column="status" jdbcType="INTEGER" property="status" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="create_user_id" jdbcType="BIGINT" property="createUserId" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+    <result column="update_user_id" jdbcType="BIGINT" property="updateUserId" />
+    <result column="is_deleted" jdbcType="INTEGER" property="isDeleted" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, `name`, `type`, ip_address, properties, business_id, description, `status`, create_time, 
+    create_user_id, update_time, update_user_id, is_deleted
+  </sql>
+  <sql id="Column_List_DTO">
+    d.id, d.`name`, d.`type`, d.ip_address, d.properties, d.business_id, ds.name as businessName, d.description, d.`status`, d.create_time,
+    d.create_user_id, d.update_time, d.update_user_id
+  </sql>
+  <insert id="batchInsert" parameterType="map">
+    <!--@mbg.generated-->
+    insert into business_data_source
+    (id, `name`, `type`, ip_address, properties, business_id, description, `status`, 
+      create_time, create_user_id, update_time, update_user_id, is_deleted)
+    values
+    <foreach collection="list" item="item" separator=",">
+      (#{item.id,jdbcType=BIGINT}, #{item.name,jdbcType=VARCHAR}, #{item.type,jdbcType=VARCHAR}, 
+        #{item.ipAddress,jdbcType=VARCHAR}, #{item.properties,jdbcType=LONGVARCHAR}, #{item.businessId,jdbcType=BIGINT}, 
+        #{item.description,jdbcType=LONGVARCHAR}, #{item.status,jdbcType=INTEGER}, #{item.createTime,jdbcType=TIMESTAMP}, 
+        #{item.createUserId,jdbcType=BIGINT}, #{item.updateTime,jdbcType=TIMESTAMP}, #{item.updateUserId,jdbcType=BIGINT}, 
+        #{item.isDeleted,jdbcType=INTEGER})
+    </foreach>
+  </insert>
+
+</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.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" />
+    <result column="name" jdbcType="VARCHAR" property="name" />
+    <result column="description" jdbcType="LONGVARCHAR" property="description" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="create_user_id" jdbcType="BIGINT" property="createUserId" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+    <result column="update_user_id" jdbcType="BIGINT" property="updateUserId" />
+    <result column="is_deleted" jdbcType="INTEGER" property="isDeleted" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, name, description, create_time, create_user_id, update_time, update_user_id,
+    is_deleted
+  </sql>
+  <insert id="batchInsert" keyColumn="id" keyProperty="id" parameterType="map" useGeneratedKeys="true">
+    <!--@mbg.generated-->
+    insert into business_data_system
+    (name, description, create_time, create_user_id, update_time, update_user_id, is_deleted
+      )
+    values
+    <foreach collection="list" item="item" separator=",">
+      (#{item.name,jdbcType=VARCHAR}, #{item.description,jdbcType=LONGVARCHAR}, #{item.createTime,jdbcType=TIMESTAMP}, 
+        #{item.createUserId,jdbcType=BIGINT}, #{item.updateTime,jdbcType=TIMESTAMP}, #{item.updateUserId,jdbcType=BIGINT}, 
+        #{item.isDeleted,jdbcType=INTEGER})
+    </foreach>
+  </insert>
+</mapper>
\ No newline at end of file

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.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" />
+    <result column="field_name" jdbcType="VARCHAR" property="fieldName" />
+    <result column="field_type" jdbcType="VARCHAR" property="fieldType" />
+    <result column="table_id" jdbcType="BIGINT" property="tableId" />
+    <result column="description" jdbcType="LONGVARCHAR" property="description" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="create_user_id" jdbcType="BIGINT" property="createUserId" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+    <result column="update_user_id" jdbcType="BIGINT" property="updateUserId" />
+    <result column="is_deleted" jdbcType="INTEGER" property="isDeleted" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, field_name, field_type, table_id, description, create_time, create_user_id, update_time, 
+    update_user_id, is_deleted
+  </sql>
+  <insert id="batchInsert" parameterType="map">
+    <!--@mbg.generated-->
+    insert into business_data_table_field
+    (id, field_name, field_type, table_id, description, create_time, create_user_id, 
+      update_time, update_user_id, is_deleted)
+    values
+    <foreach collection="list" item="item" separator=",">
+      (#{item.id,jdbcType=BIGINT}, #{item.fieldName,jdbcType=VARCHAR}, #{item.fieldType,jdbcType=VARCHAR}, 
+        #{item.tableId,jdbcType=BIGINT}, #{item.description,jdbcType=LONGVARCHAR}, #{item.createTime,jdbcType=TIMESTAMP}, 
+        #{item.createUserId,jdbcType=BIGINT}, #{item.updateTime,jdbcType=TIMESTAMP}, #{item.updateUserId,jdbcType=BIGINT}, 
+        #{item.isDeleted,jdbcType=INTEGER})
+    </foreach>
+  </insert>
+</mapper>
\ No newline at end of file

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.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" />
+    <result column="name" jdbcType="VARCHAR" property="name" />
+    <result column="table_no" jdbcType="VARCHAR" property="tableNo" />
+    <result column="business_id" jdbcType="BIGINT" property="businessId" />
+    <result column="source_id" jdbcType="BIGINT" property="sourceId" />
+    <result column="description" jdbcType="LONGVARCHAR" property="description" />
+    <result column="create_time" jdbcType="TIMESTAMP" property="createTime" />
+    <result column="create_user_id" jdbcType="BIGINT" property="createUserId" />
+    <result column="update_time" jdbcType="TIMESTAMP" property="updateTime" />
+    <result column="update_user_id" jdbcType="BIGINT" property="updateUserId" />
+    <result column="is_deleted" jdbcType="INTEGER" property="isDeleted" />
+  </resultMap>
+  <sql id="Base_Column_List">
+    <!--@mbg.generated-->
+    id, `name`, table_no, business_id, source_id, description, create_time, create_user_id, 
+    update_time, update_user_id, is_deleted
+  </sql>
+  <insert id="batchInsert" parameterType="map">
+    <!--@mbg.generated-->
+    insert into business_data_table
+    (id, `name`, table_no, business_id, source_id, description, create_time, create_user_id, 
+      update_time, update_user_id, is_deleted)
+    values
+    <foreach collection="list" item="item" separator=",">
+      (#{item.id,jdbcType=BIGINT}, #{item.name,jdbcType=VARCHAR}, #{item.tableNo,jdbcType=VARCHAR}, 
+        #{item.businessId,jdbcType=BIGINT}, #{item.sourceId,jdbcType=BIGINT}, #{item.description,jdbcType=LONGVARCHAR}, 
+        #{item.createTime,jdbcType=TIMESTAMP}, #{item.createUserId,jdbcType=BIGINT}, #{item.updateTime,jdbcType=TIMESTAMP}, 
+        #{item.updateUserId,jdbcType=BIGINT}, #{item.isDeleted,jdbcType=INTEGER})
+    </foreach>
+  </insert>
+</mapper>
\ No newline at end of file

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

+package com.ediagnosis.cdr.dao;
+
+import com.ediagnosis.cdr.CdrApplication;
+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;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+
+/**
+ * @author monojun
+ * @description MapperTest
+ * @createTime 2025年07月31日
+ */
+@SpringBootTest(classes = CdrApplication.class)
+public class MapperTest {
+
+    @Autowired
+    private BusinessDataSourceMapper dataSourceMapper;
+
+    @Test
+    public void test1() {
+        BusinessDataSourceQueryDTO queryDTO = new BusinessDataSourceQueryDTO();
+        QueryWrapper queryWrapper = QueryWrapper.create()
+                .select("d.*, ds.name as businessName")
+                .from("business_data_source").as("d")
+                .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(dataSourceDTOPage);
+    }
+
+    @Test
+    public void test2() {
+        QueryWrapper queryWrapper = QueryWrapper.create()
+                .select("d.*", "ds.id as businessId, ds.name as businessName")
+                .from(BusinessDataSource.class).as("d")
+                .leftJoin(BusinessDataSystem.class).as("ds")
+                .on(BusinessDataSource::getBusinessId, BusinessDataSystem::getId);
+        queryWrapper.in(BusinessDataSource::getBusinessId, 1);
+
+        Page<BusinessDataSourceDTO> dataSourceDTOPage = dataSourceMapper.paginateAs(1, 10, queryWrapper, BusinessDataSourceDTO.class);
+        System.out.println(dataSourceDTOPage);
+    }
+}

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

+package com.ediagnosis.cdr.demo;
+
+import com.ediagnosis.cdr.CdrApplication;
+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;
+import org.springframework.boot.test.context.SpringBootTest;
+
+/**
+ * @author monojun
+ * @description ServiceTest
+ * @createTime 2025年07月31日
+ */
+@SpringBootTest(classes = CdrApplication.class)
+public class DemoTest {
+
+    @Autowired
+    private BusinessDataDao businessDataDao;
+
+    @Test
+    public void test1() {
+        BusinessDataTableQueryDTO queryDTO = new BusinessDataTableQueryDTO();
+        Page<BusinessDataTableDTO> businessDataTableDTOPage = businessDataDao.queryTablePage(queryDTO);
+        System.out.println(businessDataTableDTOPage);
+    }
+
+    @Test
+    public void test2() {
+        BusinessDataSystemQueryDTO queryDTO = new BusinessDataSystemQueryDTO();
+        Page<BusinessDataSystem> dataSystemPage = businessDataDao.querySystemPage(queryDTO);
+        System.out.println(dataSystemPage);
+    }
+
+    @Test
+    public void test3() {
+        Page<BusinessDataSourceDTO> dataSourceDTOPage = businessDataDao.querySourcePage(new BusinessDataSourceQueryDTO());
+        System.out.println(dataSourceDTOPage);
+    }
+
+
+}