diff --git a/muyu-source-common/src/main/java/com/muyu/source/domain/AssetAccredit.java b/muyu-source-common/src/main/java/com/muyu/source/domain/AssetAccredit.java new file mode 100644 index 0000000..66ed569 --- /dev/null +++ b/muyu-source-common/src/main/java/com/muyu/source/domain/AssetAccredit.java @@ -0,0 +1,33 @@ +package com.muyu.source.domain; + +import com.baomidou.mybatisplus.annotation.IdType; +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import com.muyu.common.core.annotation.Excel; +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; +import lombok.experimental.SuperBuilder; + +/** + * @author Lenovo + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-20:34 + * @ Version：1.0 + * @ Description：资产授权 + */ +@Data +@SuperBuilder +@AllArgsConstructor +@NoArgsConstructor +@TableName("asset_accredit") +public class AssetAccredit { + /** + * 主键 + */ + @TableId(value = "id", type = IdType.AUTO) + @Excel(name = "主键") + private Long id; + +} diff --git a/muyu-source-common/src/main/java/com/muyu/source/domain/Children.java b/muyu-source-common/src/main/java/com/muyu/source/domain/Children.java index 181d7bc..b4cb53c 100644 --- a/muyu-source-common/src/main/java/com/muyu/source/domain/Children.java +++ b/muyu-source-common/src/main/java/com/muyu/source/domain/Children.java @@ -45,11 +45,11 @@ public class Children extends BaseEntity { * 数据条数 */ @Excel(name = "数据条数") - private Integer dataTotal; + private Long dataTotal; /** * 数据源 */ @Excel(name = "数据源id") - private Integer assetId; + private Long assetId; } diff --git a/muyu-source-common/src/main/java/com/muyu/source/domain/TableData.java b/muyu-source-common/src/main/java/com/muyu/source/domain/TableData.java index 95795ee..b02b245 100644 --- a/muyu-source-common/src/main/java/com/muyu/source/domain/TableData.java +++ b/muyu-source-common/src/main/java/com/muyu/source/domain/TableData.java @@ -89,6 +89,6 @@ public class TableData extends BaseEntity { * 数据库结构ID */ @Excel(name = "数据库结构ID") - private Integer childrenId; + private Long childrenId; } diff --git a/muyu-source-common/src/main/java/com/muyu/source/domain/resp/StatisticsResp.java b/muyu-source-common/src/main/java/com/muyu/source/domain/resp/StatisticsResp.java new file mode 100644 index 0000000..346152a --- /dev/null +++ b/muyu-source-common/src/main/java/com/muyu/source/domain/resp/StatisticsResp.java @@ -0,0 +1,32 @@ +package com.muyu.source.domain.resp; + +import lombok.AllArgsConstructor; +import lombok.Data; +import lombok.NoArgsConstructor; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-21:50 + * @ Version：1.0 + * @ Description：统计 + * @author Lenovo + */ +@Data +@AllArgsConstructor +@NoArgsConstructor +public class StatisticsResp { + + /** + * 数据接入统计数量 + */ + private Long dataAccessQuantity; + /** + * 资产模型统计数量 + */ + private Long assetModelQuantity; + /** + * 数据源统计数量 + */ + private Long numberOfDataModels; +} diff --git a/muyu-source-server/src/main/java/com/muyu/source/controller/ChildrenController.java b/muyu-source-server/src/main/java/com/muyu/source/controller/ChildrenController.java new file mode 100644 index 0000000..f55a6b3 --- /dev/null +++ b/muyu-source-server/src/main/java/com/muyu/source/controller/ChildrenController.java @@ -0,0 +1,49 @@ +package com.muyu.source.controller; + +import com.muyu.common.core.domain.Result; +import com.muyu.source.domain.Children; +import com.muyu.source.service.ChildrenService; +import io.swagger.v3.oas.annotations.tags.Tag; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-19:05 + * @ Version：1.0 + * @ Description：数据库结构控制层 + * @author Lenovo + */ +@RestController +@RequestMapping("/children") +@Tag(name = "数据库结构控制层",description = "进行数据库结构管理，查看等相关操作") +public class ChildrenController { + + @Autowired + private ChildrenService childrenService; + /** + * 查询数据库结构 + * @param id 数据库id + * @return 数据库结构 + */ + @GetMapping("/selectChildren/{id}") + public Result selectChildren(@PathVariable("id") Integer id){ + Children children = childrenService.getById(id); + return Result.success(children); + } + + /** + * 查询单个数据库中表的数量 + * @param id 数据库结构ID + * @return 资产数据模型数量 + */ + @GetMapping("/getTableDataCount/{id}") + public Result getTableDataCount(@PathVariable("id") Integer id){ + //TODO 统计资产模型的总数量 + return null; + } +} diff --git a/muyu-source-server/src/main/java/com/muyu/source/controller/DataSourceController.java b/muyu-source-server/src/main/java/com/muyu/source/controller/DataSourceController.java index 9740483..ad56eac 100644 --- a/muyu-source-server/src/main/java/com/muyu/source/controller/DataSourceController.java +++ b/muyu-source-server/src/main/java/com/muyu/source/controller/DataSourceController.java @@ -1,13 +1,16 @@ package com.muyu.source.controller; import com.muyu.common.core.domain.Result; +import com.muyu.common.core.utils.poi.ExcelUtil; import com.muyu.common.core.web.controller.BaseController; import com.muyu.source.domain.DataSource; import com.muyu.source.domain.req.DataSourceQueryReq; import com.muyu.source.service.DataSourceService; import io.swagger.v3.oas.annotations.tags.Tag; +import jakarta.servlet.http.HttpServletResponse; import lombok.extern.log4j.Log4j2; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.HttpRequestHandler; import org.springframework.web.bind.annotation.*; import java.util.List; @@ -64,6 +67,39 @@ public class DataSourceController extends BaseController { return Result.success(list); } + /** + * 导出数据源 + * @param dataSource 数据源 + * @param response response + */ + @PostMapping("/export") + public void derive(DataSource dataSource,HttpServletResponse response){ + List list = dataSourceService.list(dataSource); + ExcelUtil excelUtil = new ExcelUtil<>(DataSource.class); + excelUtil.exportExcel(response, list, "数据源数据"); + } + + /** + * 获取数据源详细信息 + * @param id 数据源ID + * @return 数据源详细信息 + */ + @GetMapping("/{id}") + public Result getById(@PathVariable("id") Long id){ + return Result.success(dataSourceService.getById(id)); + } + /** + * 查询表数据总数 + * + * @return + */ + @GetMapping("/selectTableDataCount") + public Result selectTableDataCount() { + //TODO 统计出数据接入的数量 + return null; + } + + /** * 添加数据源 * @param dataSource 数据源 @@ -88,12 +124,12 @@ public class DataSourceController extends BaseController { /** * 删除数据源 - * @param dataSource 数据源 + * @param id 数据源 * @return 数据源 */ - @DeleteMapping("/delete") - public Result delete(@RequestBody DataSource dataSource){ - dataSourceService.removeById(dataSource); + @DeleteMapping("/delete/{id}") + public Result delete(@PathVariable("id") List id){ + dataSourceService.removeBatchByIds(id); return Result.success(); } diff --git a/muyu-source-server/src/main/java/com/muyu/source/controller/TableDataController.java b/muyu-source-server/src/main/java/com/muyu/source/controller/TableDataController.java new file mode 100644 index 0000000..2724d35 --- /dev/null +++ b/muyu-source-server/src/main/java/com/muyu/source/controller/TableDataController.java @@ -0,0 +1,51 @@ +package com.muyu.source.controller; + +import com.muyu.common.core.domain.Result; +import com.muyu.source.domain.TableData; +import com.muyu.source.service.TableDataService; +import io.swagger.v3.oas.annotations.tags.Tag; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PathVariable; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-19:51 + * @ Version：1.0 + * @ Description：表结构控制层 + * @author Lenovo + */ +@RestController +@RequestMapping("/tableData") +@Tag(name = "表结构控制层",description = "进行表结构管理，查看等相关操作") +public class TableDataController { + @Autowired + private TableDataService tableDataService; + + /** + * 根据id查询表结构 + * @param id id + * @return 表结构 + */ + @GetMapping("/selectTableData/{id}") + public Result selectTableData(@PathVariable("id") Integer id){ + return Result.success(tableDataService.getById(id)); + } + + /** + * 统计出一个表中字段的数量 + * @param id 表ID + * @return 数量 + */ + @GetMapping("/selectTableDataCount/{id}") + public Result selectTableDataCount(@PathVariable("id") Integer id){ + //TODO 统计出数据模型的数量 + return null; + } + + + +} diff --git a/muyu-source-server/src/main/java/com/muyu/source/mapper/ChildrenMapper.java b/muyu-source-server/src/main/java/com/muyu/source/mapper/ChildrenMapper.java new file mode 100644 index 0000000..5dbf26e --- /dev/null +++ b/muyu-source-server/src/main/java/com/muyu/source/mapper/ChildrenMapper.java @@ -0,0 +1,17 @@ +package com.muyu.source.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.muyu.source.domain.Children; +import org.apache.ibatis.annotations.Mapper; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-19:06 + * @ Version：1.0 + * @ Description：数据库结构持久层 + * @author Lenovo + */ +@Mapper +public interface ChildrenMapper extends BaseMapper { +} diff --git a/muyu-source-server/src/main/java/com/muyu/source/mapper/TableDataMapper.java b/muyu-source-server/src/main/java/com/muyu/source/mapper/TableDataMapper.java new file mode 100644 index 0000000..f70ab44 --- /dev/null +++ b/muyu-source-server/src/main/java/com/muyu/source/mapper/TableDataMapper.java @@ -0,0 +1,17 @@ +package com.muyu.source.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.muyu.source.domain.TableData; +import org.apache.ibatis.annotations.Mapper; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-19:52 + * @ Version：1.0 + * @ Description：表结构持久层 + * @author Lenovo + */ +@Mapper +public interface TableDataMapper extends BaseMapper { +} diff --git a/muyu-source-server/src/main/java/com/muyu/source/service/ChildrenService.java b/muyu-source-server/src/main/java/com/muyu/source/service/ChildrenService.java new file mode 100644 index 0000000..1ffc97e --- /dev/null +++ b/muyu-source-server/src/main/java/com/muyu/source/service/ChildrenService.java @@ -0,0 +1,19 @@ +package com.muyu.source.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.muyu.source.domain.Children; + +import java.util.List; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-19:07 + * @ Version：1.0 + * @ Description：数据库结构业务层 + * @author Lenovo + */ +public interface ChildrenService extends IService { + + +} diff --git a/muyu-source-server/src/main/java/com/muyu/source/service/Impl/ChildrenServiceImpl.java b/muyu-source-server/src/main/java/com/muyu/source/service/Impl/ChildrenServiceImpl.java new file mode 100644 index 0000000..45b5ff7 --- /dev/null +++ b/muyu-source-server/src/main/java/com/muyu/source/service/Impl/ChildrenServiceImpl.java @@ -0,0 +1,26 @@ +package com.muyu.source.service.Impl; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.muyu.source.domain.Children; +import com.muyu.source.mapper.ChildrenMapper; +import com.muyu.source.service.ChildrenService; +import org.springframework.stereotype.Service; + +import java.util.List; +import java.util.stream.IntStream; +import java.util.stream.LongStream; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-19:08 + * @ Version：1.0 + * @ Description：数据库结构业务实现层 + * @author Lenovo + */ +@Service +public class ChildrenServiceImpl extends ServiceImpl implements ChildrenService { + + +} diff --git a/muyu-source-server/src/main/java/com/muyu/source/service/Impl/TableDataServiceImpl.java b/muyu-source-server/src/main/java/com/muyu/source/service/Impl/TableDataServiceImpl.java new file mode 100644 index 0000000..f8dd5c0 --- /dev/null +++ b/muyu-source-server/src/main/java/com/muyu/source/service/Impl/TableDataServiceImpl.java @@ -0,0 +1,20 @@ +package com.muyu.source.service.Impl; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.muyu.source.domain.TableData; +import com.muyu.source.mapper.TableDataMapper; +import com.muyu.source.service.TableDataService; +import org.springframework.stereotype.Service; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-19:53 + * @ Version：1.0 + * @ Description：表结构业务实现层 + * @author Lenovo + */ +@Service +public class TableDataServiceImpl extends ServiceImpl implements TableDataService { + +} diff --git a/muyu-source-server/src/main/java/com/muyu/source/service/TableDataService.java b/muyu-source-server/src/main/java/com/muyu/source/service/TableDataService.java new file mode 100644 index 0000000..033c505 --- /dev/null +++ b/muyu-source-server/src/main/java/com/muyu/source/service/TableDataService.java @@ -0,0 +1,15 @@ +package com.muyu.source.service; + +import com.baomidou.mybatisplus.extension.service.IService; +import com.muyu.source.domain.TableData; + +/** + * @ Tool：IntelliJ IDEA + * @ Author：CHX + * @ Date：2024-08-21-19:53 + * @ Version：1.0 + * @ Description：表结构业务层 + * @author Lenovo + */ +public interface TableDataService extends IService { +}