Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
25 changes: 0 additions & 25 deletions backend/services/data-management-service/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -75,31 +75,6 @@
<classifier>exec</classifier>
</configuration>
</plugin>
<plugin>
<groupId>org.openapitools</groupId>
<artifactId>openapi-generator-maven-plugin</artifactId>
<version>6.6.0</version>
<executions>
<execution>
<goals>
<goal>generate</goal>
</goals>
<configuration>
<inputSpec>${project.basedir}/../../openapi/specs/data-management.yaml</inputSpec>
<generatorName>spring</generatorName>
<output>${project.build.directory}/generated-sources/openapi</output>
<apiPackage>com.dataengine.datamanagement.interfaces.api</apiPackage>
<modelPackage>com.dataengine.datamanagement.interfaces.dto</modelPackage>
<configOptions>
<interfaceOnly>true</interfaceOnly>
<useTags>true</useTags>
<useSpringBoot3>true</useSpringBoot3>
<documentationProvider>springdoc</documentationProvider>
</configOptions>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
</project>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
import com.dataengine.datamanagement.infrastructure.persistence.mapper.DatasetFileMapper;
import com.dataengine.datamanagement.infrastructure.persistence.mapper.DatasetMapper;
import com.dataengine.datamanagement.infrastructure.persistence.mapper.TagMapper;
import com.dataengine.datamanagement.interfaces.dto.AllDatasetStatisticsResponse;
import org.apache.ibatis.session.RowBounds;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
Expand Down Expand Up @@ -240,4 +241,11 @@ public Map<String, Object> getDatasetStatistics(String datasetId) {

return statistics;
}

/**
* 获取所有数据集的汇总统计信息
*/
public AllDatasetStatisticsResponse getAllDatasetStatistics() {
return datasetMapper.getAllDatasetStatistics();
}
}
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package com.dataengine.datamanagement.infrastructure.persistence.mapper;

import com.dataengine.datamanagement.domain.model.dataset.Dataset;
import com.dataengine.datamanagement.interfaces.dto.AllDatasetStatisticsResponse;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.session.RowBounds;
Expand Down Expand Up @@ -29,4 +30,5 @@ long countByCriteria(@Param("typeCode") String typeCode,
int insert(Dataset dataset);
int update(Dataset dataset);
int deleteById(@Param("id") String id);
AllDatasetStatisticsResponse getAllDatasetStatistics();
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,20 @@
package com.dataengine.datamanagement.interfaces.dto;

import lombok.Getter;
import lombok.Setter;

/**
* 所有数据集统计信息响应DTO
*/
@Getter
@Setter
public class AllDatasetStatisticsResponse {
/** 总数据集数 */
private Integer totalDatasets;

/** 总文件数 */
private Long totalSize;

/** 总大小(字节) */
private Long totalFiles;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,26 @@
package com.dataengine.datamanagement.interfaces.dto;

import lombok.Getter;
import lombok.Setter;

import java.util.List;

/**
* 创建数据集请求DTO
*/
@Getter
@Setter
public class CreateDatasetRequest {
/** 数据集名称 */
private String name;
/** 数据集描述 */
private String description;
/** 数据集类型 */
private String type;
/** 标签列表 */
private List<String> tags;
/** 数据源 */
private String dataSource;
/** 目标位置 */
private String targetLocation;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
package com.dataengine.datamanagement.interfaces.dto;

import lombok.Getter;
import lombok.Setter;

/**
* 创建标签请求DTO
*/
@Getter
@Setter
public class CreateTagRequest {
/** 标签名称 */
private String name;
/** 标签颜色 */
private String color;
/** 标签描述 */
private String description;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,33 @@
package com.dataengine.datamanagement.interfaces.dto;

import lombok.Getter;
import lombok.Setter;
import java.time.LocalDateTime;

/**
* 数据集文件响应DTO
*/
@Getter
@Setter
public class DatasetFileResponse {
/** 文件ID */
private String id;
/** 文件名 */
private String fileName;
/** 原始文件名 */
private String originalName;
/** 文件类型 */
private String fileType;
/** 文件大小(字节) */
private Long size;
/** 文件状态 */
private String status;
/** 文件描述 */
private String description;
/** 文件路径 */
private String filePath;
/** 上传时间 */
private LocalDateTime uploadedAt;
/** 上传者 */
private String uploadedBy;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,43 @@
package com.dataengine.datamanagement.interfaces.dto;

import lombok.Getter;
import lombok.Setter;

import java.time.LocalDateTime;
import java.util.List;

/**
* 数据集响应DTO
*/
@Getter
@Setter
public class DatasetResponse {
/** 数据集ID */
private String id;
/** 数据集名称 */
private String name;
/** 数据集描述 */
private String description;
/** 数据集类型 */
private DatasetTypeResponse type;
/** 数据集状态 */
private String status;
/** 标签列表 */
private List<TagResponse> tags;
/** 数据源 */
private String dataSource;
/** 目标位置 */
private String targetLocation;
/** 文件数量 */
private Integer fileCount;
/** 总大小(字节) */
private Long totalSize;
/** 完成率(0-100) */
private Float completionRate;
/** 创建时间 */
private LocalDateTime createdAt;
/** 更新时间 */
private LocalDateTime updatedAt;
/** 创建者 */
private String createdBy;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
package com.dataengine.datamanagement.interfaces.dto;

import lombok.Getter;
import lombok.Setter;
import java.util.Map;

/**
* 数据集统计信息响应DTO
*/
@Getter
@Setter
public class DatasetStatisticsResponse {
/** 总文件数 */
private Integer totalFiles;
/** 已完成文件数 */
private Integer completedFiles;
/** 总大小(字节) */
private Long totalSize;
/** 完成率(0-100) */
private Float completionRate;
/** 文件类型分布 */
private Map<String, Integer> fileTypeDistribution;
/** 状态分布 */
private Map<String, Integer> statusDistribution;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,23 @@
package com.dataengine.datamanagement.interfaces.dto;

import lombok.Getter;
import lombok.Setter;
import java.util.List;

/**
* 数据集类型响应DTO
*/
@Getter
@Setter
public class DatasetTypeResponse {
/** 类型编码 */
private String code;
/** 类型名称 */
private String name;
/** 类型描述 */
private String description;
/** 支持的文件格式 */
private List<String> supportedFormats;
/** 图标 */
private String icon;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
package com.dataengine.datamanagement.interfaces.dto;

import lombok.Getter;
import lombok.Setter;
import java.util.List;

/**
* 数据集文件分页响应DTO
*/
@Getter
@Setter
public class PagedDatasetFileResponse {
/** 文件内容列表 */
private List<DatasetFileResponse> content;
/** 当前页码 */
private Integer page;
/** 每页大小 */
private Integer size;
/** 总元素数 */
private Integer totalElements;
/** 总页数 */
private Integer totalPages;
/** 是否为第一页 */
private Boolean first;
/** 是否为最后一页 */
private Boolean last;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,28 @@
package com.dataengine.datamanagement.interfaces.dto;

import lombok.Getter;
import lombok.Setter;

import java.util.List;

/**
* 数据集分页响应DTO
*/
@Getter
@Setter
public class PagedDatasetResponse {
/** 数据集内容列表 */
private List<DatasetResponse> content;
/** 当前页码 */
private Integer page;
/** 每页大小 */
private Integer size;
/** 总元素数 */
private Integer totalElements;
/** 总页数 */
private Integer totalPages;
/** 是否为第一页 */
private Boolean first;
/** 是否为最后一页 */
private Boolean last;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
package com.dataengine.datamanagement.interfaces.dto;

import lombok.Getter;
import lombok.Setter;

/**
* 标签响应DTO
*/
@Getter
@Setter
public class TagResponse {
/** 标签ID */
private String id;
/** 标签名称 */
private String name;
/** 标签颜色 */
private String color;
/** 标签描述 */
private String description;
/** 使用次数 */
private Integer usageCount;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
package com.dataengine.datamanagement.interfaces.dto;

import lombok.Getter;
import lombok.Setter;

import java.util.List;

/**
* 更新数据集请求DTO
*/
@Getter
@Setter
public class UpdateDatasetRequest {
/** 数据集名称 */
private String name;
/** 数据集描述 */
private String description;
/** 标签列表 */
private List<String> tags;
/** 数据集状态 */
private String status;
}
Loading