feature:增加查询数据集统计信息的接口

Author: hefanli

backend/services/data-management-service/src/main/java/com/dataengine/datamanagement/application/service/DatasetApplicationService.java

@@ -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;
@@ -240,4 +241,11 @@ public Map<String, Object> getDatasetStatistics(String datasetId) {
 
         return statistics;
     }
+
+    /**
+     * 获取所有数据集的汇总统计信息
+     */
+    public AllDatasetStatisticsResponse getAllDatasetStatistics() {
+        return datasetMapper.getAllDatasetStatistics();
+    }
 }

backend/services/data-management-service/src/main/java/com/dataengine/datamanagement/infrastructure/persistence/mapper/DatasetMapper.java

@@ -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;
@@ -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();
 }

backend/services/data-management-service/src/main/java/com/dataengine/datamanagement/interfaces/dto/AllDatasetStatisticsResponse.java

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

backend/services/data-management-service/src/main/java/com/dataengine/datamanagement/interfaces/rest/DatasetController.java

@@ -146,6 +146,11 @@ public ResponseEntity<Response<DatasetStatisticsResponse>> getDatasetStatistics(
         }
     }
 
+    @GetMapping("/statistics")
+    public ResponseEntity<Response<AllDatasetStatisticsResponse>> getAllStatistics() {
+        return ResponseEntity.ok(Response.ok(datasetApplicationService.getAllDatasetStatistics()));
+    }
+
     private DatasetResponse convertToResponse(Dataset dataset) {
         DatasetResponse response = new DatasetResponse();
         response.setId(dataset.getId());

backend/services/data-management-service/src/main/resources/mappers/DatasetMapper.xml

@@ -203,4 +203,11 @@
         DELETE FROM t_dm_datasets WHERE id = #{id}
     </delete>
 
+    <select id="getAllDatasetStatistics" resultType="com.dataengine.datamanagement.interfaces.dto.AllDatasetStatisticsResponse">
+      SELECT
+        COUNT(*) AS total_datasets,
+        SUM(size_bytes) AS total_size_bytes,
+        SUM(file_count) AS total_files
+      FROM t_dm_datasets;
+    </select>
 </mapper>