【智能协同云图库】基于统一接口架构构建多维度分析功能、结合 ECharts 可视化与权限校验实现用户 / 管理员图库统计、通过 SQL 优化与流式处理提升数据

摘要：本节围绕提升空间图库管理分析能力，先分用户与管理员两类梳理资源使用、分类、标签等 6 大分析需求，再设计统一实现流程与接口方案，最后通过分层开发完成各需求后端功能，覆盖权限校验、数据处理与接口编写。

本节重点

为进一步提؜升用户 / 管理员⁠在平台上对空间图库‏的管理与分析能力，‌我们本节将重点扩展‏空间图库分析功能，包括：

  • 用户空间图库分析
  • 管理员全空间分析

通过这些分؜析功能，用户和管理⁠员能够快速掌握空间‏的使用情况，提升管‌理效率。

一、需求分析

根据我们空؜间表和图片表的已有⁠字段，可以挖掘出很‏多分析需求，整体分‌为用户空间图库分析‏和管理员全空间分析两类。

用户空间图库分析

用户可以对自己的空间图库进行分析，包括以下几个重点功能：

1）空间资源使用分析：通过统计当前空间已使用大小与总配额的比例，以及图片数量与最大允许数量的占比，帮助用户直观了解空间使用状态，及时清理空间。图表形式推荐使用 仪表盘，类似进度条，可以更直观地了解比例。

2）空间图片分类分析：统计不同分类下图片的数量和总大小占比，帮助用户清晰了解各分类的资源分布，优化存储策略。由于同一个分类要展示多个信息，可以选择 分组条形图 来展示。

3）空间图片标签分析：解析用户图库中的标签，统计每个标签的关联图片数量。由于标签比较多，可以用 词云图 展示所有的标签，并突出常用标签，便于优化管理和图片搜索。

4）空间图片大小分析：按图片大小（如 <100 KB、100 KB-1 MB、>1 MB）分段统计图片数量，帮助用户识别大体积图片，合理分配存储资源。由于按图片大小分类的数量不多，可以使用 饼图 展示，能够体现每类大小图片的数量占比。

5）用户上传行为分析：统计用户每月、每周、每日上传图片的数量趋势，帮助用户识别上传高峰期并优化管理策略（虽然对目前这个阶段没有用，但之后我们要开发团队空间，可以给团队管理员使用）。推荐使用 折线图 呈现时间序列趋势。

管理员全空间分析

管理员全空؜间分析的核心是面向⁠公共图库、以及所有‏用户空间的统计和管‌理：

1）全空间资源使用؜分析：统计公共图库、以及系统内所有⁠空间的总存储量和总图片数，并且也支‏持任意空间的图片分类、图片标签、图‌片大小、用户上传行为的分析，便于管‏理员了解系统资源分配和利用情况。

其实跟用户分析自己空间的需求一致，只不过分析的范围更大罢了。

2）空间使用排行分析：按存储使用量排序，统计占用存储最多的前 N 个空间，帮助管理员快速定位高占用空间，并识别潜在的资源滥用或异常情况。可以选用 柱状图，直观地展示排名和存储使用量。

二、方案设计

1、分析类需求的实现流程

对于分析类需求，实现流程几乎都是一致的，包括：

1）数据采集؜：从数据源（比如 MyS⁠QL 数据库或者大数据仓‏库）获取原始数据。要提前‌明确涉及的表和字段，必要‏时采用分页查询处理大数据量。

2）数据预处理：؜对数据进行清洗、加工和格式化，包⁠括过滤无效数据（比如逻辑删除或审‏核未通过）、解析复杂字段（比如 ‌JSON 格式的 tags），以‏及通过字段关联补充上下文信息。

3）数据计算：根据需求进行分؜组、聚合、排序等，从而计算关键指标，比如计算空间各分类图⁠片的占用比例、用户上传图片的时间趋势。可以根据场景调整计‏算方案，比如对于大数据量的计算，可以采用 Spark 之‌类的大数据计算组件做离线计算；对于数据实时性要求较高的实‏时分析场景，可以用 Flink 做流式处理。

4）数据存؜储：针对频⁠繁查询的分析结果，‏可将结果数据存储为‌单独的表或缓存，减‏少重复计算，提高查询效率。

5）数据接口设؜计：为前端提供统一接口，从⁠而支持查询和展示。需要考虑‏到数据量较大导致前端渲染卡‌顿的情况，可以按需精简返回‏的字符串、分页查询等。

6）数据可视化：通过图表直观展示分析结果，前端可以使用 Apache ECharts 等可视化库渲染。当然也可以让后端生成图表图片并返回，但这种实现方法的灵活度有限。

后续还可以؜根据用户的反馈持续⁠优化分析逻辑、增加‏指标或改进性能。

2、本项目实现方案

通过需求分析，我们发现，管理员对公共图库及全空间的分析需求，与用户对自己空间的分析需求在本质上是相同的，唯一的区别在于图片范围的选择。

1）用户分析自己的空间，SQL 示例：

SELECT category, SUM(picSize) AS totalSize
FROM picture 
WHERE spaceId = xxx
GROUP BY category;

2）管理员分析公共图库，SQL 示例：

SELECT category, SUM(picSize) AS totalSize
FROM picture 
WHERE spaceId IS NULL
GROUP BY category;

3）管理员分析全部空间，SQL 示例：

SELECT category, SUM(picSize) AS totalSize
FROM picture 
GROUP BY category;

你会发现，؜除了 where ⁠查询条件不同 之外，‏其他的计算方式都是‌一致的。

所以我们可؜以设计统一的接口，通⁠过传递不同的请求参数‏，同时满足上述需求。‌参数含义和优先级如下‏（优先级从高到低）

  1. queryAll 字段：为 true 时表示查询全空间，仅管理员可使用。
  2. queryPublic 字段：为 true 时表示查询公共图库，仅管理员可使用。
  3. spaceId 字段：仅在 queryAll 和 queryPublic 均为 false 时生效，表示对特定空间进行分析，仅空间创建者和管理员可使用。

对应的后端伪代码如下，可以将这段逻辑封装为单独的方法：

// 先权限校验
// 封装查询条件
QueryWrapper<Picture> queryWrapper = new QueryWrapper<>();
if (queryAll) {// 管理员查询全空间，不添加过滤条件
} else if (queryPublic) {// 管理员查询公共图库queryWrapper.isNull("spaceId");
} else if (spaceId != null) {// 用户或管理员查询特定空间queryWrapper.eq("spaceId", spaceId);
} else {throw new BusinessException(ErrorCode.PARAMS_ERROR, "未指定查询范围");
}

通过这种方؜式，就不用多针对不⁠同的查询范围编写一‏套接口了，可以大幅‌减少重复代码。

三、后端开发

下面我们依次开发每个具体的分析需求，由于分析类需求较多，我们可以编写单独的空间分析服务类（Service）、单独的空间分析接口（Controller)，并且统一将分析需求相关的 DTO 和 VO 数据模型放到 analyze 包下。

通用分析请求

1）由于我؜们的很多分析需求都⁠需要传递空间查询范‏围，可先写一个公‌共的图片分析请求封‏装类：

@Data
public class SpaceAnalyzeRequest implements Serializable {/*** 空间 ID*/private Long spaceId;/*** 是否查询公共图库*/private boolean queryPublic;/*** 全空间分析*/private boolean queryAll;private static final long serialVersionUID = 1L;
}

然后各个具؜体的分析请求封装类⁠就能直接继承了，这‏样也便于后续编写通‌用的分析请求处理方‏法。

2）我们可以新؜建 SpaceAnalyze⁠Service 和对应实现类‏，开发校验空间分析权限、根据‌分析范围填充查询对象这两个方‏法，后续的需求也都会用到。

校验空间分析权限：

private void checkSpaceAnalyzeAuth(SpaceAnalyzeRequest spaceAnalyzeRequest, User loginUser) {// 检查权限if (spaceAnalyzeRequest.isQueryAll() || spaceAnalyzeRequest.isQueryPublic()) {// 全空间分析或者公共图库权限校验：仅管理员可访问ThrowUtils.throwIf(!userService.isAdmin(loginUser), ErrorCode.NO_AUTH_ERROR, "无权访问公共图库");} else {// 私有空间权限校验Long spaceId = spaceAnalyzeRequest.getSpaceId();ThrowUtils.throwIf(spaceId == null || spaceId <= 0, ErrorCode.PARAMS_ERROR);Space space = spaceService.getById(spaceId);ThrowUtils.throwIf(space == null, ErrorCode.NOT_FOUND_ERROR, "空间不存在");spaceService.checkSpaceAuth(loginUser, space);}
}

根据分析范围填充查询对象：

private static void fillAnalyzeQueryWrapper(SpaceAnalyzeRequest spaceAnalyzeRequest, QueryWrapper<Picture> queryWrapper) {if (spaceAnalyzeRequest.isQueryAll()) {return;}if (spaceAnalyzeRequest.isQueryPublic()) {queryWrapper.isNull("spaceId");return;}Long spaceId = spaceAnalyzeRequest.getSpaceId();if (spaceId != null) {queryWrapper.eq("spaceId", spaceId);return;}throw new BusinessException(ErrorCode.PARAMS_ERROR, "未指定查询范围");
}

需求开发

1、空间资源使用分析

1）开发请؜求封装类，用于接收⁠前端请求的数据。此‏处直接继承通用的图‌片分析请求封装类即‏可，不需要传递其他字段：

@EqualsAndHashCode(callSuper = true)
@Data
public class SpaceUsageAnalyzeRequest extends SpaceAnalyzeRequest {}

2）开发响应视图类，用于将分析结果返回给前端：

@Data
public class SpaceUsageAnalyzeResponse implements Serializable {/*** 已使用大小*/private Long usedSize;/*** 总大小*/private Long maxSize;/*** 空间使用比例*/private Double sizeUsageRatio;/*** 当前图片数量*/private Long usedCount;/*** 最大图片数量*/private Long maxCount;/*** 图片数量占比*/private Double countUsageRatio;private static final long serialVersionUID = 1L;
}

3）开发 ؜SpaceAnal⁠yzeServic‏e 业务逻辑层，编‌写分析业务的实现逻‏辑。

注意，如果是分析全؜空间或公共图库的使用情况，需要编写⁠ “仅管理员可访问” 的权限校验逻‏辑，并且更改查询图片表的范围；如果‌只是分析单个空间的使用情况，直接从‏空间表查询出单个空间的数据即可。

代码如下：

/*** 获取空间使用分析数据** @param spaceUsageAnalyzeRequest SpaceUsageAnalyzeRequest 请求参数* @param loginUser                当前登录用户* @return SpaceUsageAnalyzeResponse 分析结果*/
@Override
public SpaceUsageAnalyzeResponse getSpaceUsageAnalyze(SpaceUsageAnalyzeRequest spaceUsageAnalyzeRequest, User loginUser) {ThrowUtils.throwIf(spaceUsageAnalyzeRequest == null, ErrorCode.PARAMS_ERROR);if (spaceUsageAnalyzeRequest.isQueryAll() || spaceUsageAnalyzeRequest.isQueryPublic()) {// 查询全部或公共图库逻辑// 仅管理员可以访问boolean isAdmin = userService.isAdmin(loginUser);ThrowUtils.throwIf(!isAdmin, ErrorCode.NO_AUTH_ERROR, "无权访问空间");// 统计公共图库的资源使用QueryWrapper<Picture> queryWrapper = new QueryWrapper<>();queryWrapper.select("picSize");if (!spaceUsageAnalyzeRequest.isQueryAll()) {queryWrapper.isNull("spaceId");}List<Object> pictureObjList = pictureService.getBaseMapper().selectObjs(queryWrapper);long usedSize = pictureObjList.stream().mapToLong(result -> result instanceof Long ? (Long) result : 0).sum();long usedCount = pictureObjList.size();// 封装返回结果SpaceUsageAnalyzeResponse spaceUsageAnalyzeResponse = new SpaceUsageAnalyzeResponse();spaceUsageAnalyzeResponse.setUsedSize(usedSize);spaceUsageAnalyzeResponse.setUsedCount(usedCount);// 公共图库无上限、无比例spaceUsageAnalyzeResponse.setMaxSize(null);spaceUsageAnalyzeResponse.setSizeUsageRatio(null);spaceUsageAnalyzeResponse.setMaxCount(null);spaceUsageAnalyzeResponse.setCountUsageRatio(null);return spaceUsageAnalyzeResponse;} else {// 查询指定空间Long spaceId = spaceUsageAnalyzeRequest.getSpaceId();ThrowUtils.throwIf(spaceId == null || spaceId <= 0, ErrorCode.PARAMS_ERROR);// 获取空间信息Space space = spaceService.getById(spaceId);ThrowUtils.throwIf(space == null, ErrorCode.NOT_FOUND_ERROR, "空间不存在");// 权限校验：仅空间所有者或管理员可访问spaceService.checkSpaceAuth(loginUser, space);// 构造返回结果SpaceUsageAnalyzeResponse response = new SpaceUsageAnalyzeResponse();response.setUsedSize(space.getTotalSize());response.setMaxSize(space.getMaxSize());// 后端直接算好百分比，这样前端可以直接展示double sizeUsageRatio = NumberUtil.round(space.getTotalSize() * 100.0 / space.getMaxSize(), 2).doubleValue();response.setSizeUsageRatio(sizeUsageRatio);response.setUsedCount(space.getTotalCount());response.setMaxCount(space.getMaxCount());double countUsageRatio = NumberUtil.round(space.getTotalCount() * 100.0 / space.getMaxCount(), 2).doubleValue();response.setCountUsageRatio(countUsageRatio);return response;}
}

上述代码中，有一个很重要的优化细节，由于我们只需要获取图片存储大小，从数据库中查询时要指定 只查询需要的列，并且使用 mapper 的 selectObjs 方法直接返回 Object 对象，而不用封装为 Picture 对象，可以提高性能并节约存储空间。

QueryWrapper<Picture> queryWrapper = new QueryWrapper<>();
queryWrapper.select("picSize");
if (!spaceUsageAnalyzeRequest.isQueryAll()) {queryWrapper.isNull("spaceId");
}
List<Object> pictureObjList = pictureService.getBaseMapper().selectObjs(queryWrapper);
long usedSize = pictureObjList.stream().mapToLong(result -> result instanceof Long ? (Long) result : 0).sum();

可以在 S؜paceServi⁠ce 中封装空间权‏限校验方法，其他的‌分析需求也会用到：

/*** 空间权限校验** @param loginUser* @param space*/
@Override
public void checkSpaceAuth(User loginUser, Space space) {// 仅本人或管理员可访问if (!space.getUserId().equals(loginUser.getId()) && !userService.isAdmin(loginUser)) {throw new BusinessException(ErrorCode.NO_AUTH_ERROR);}
}

然后可以将 ؜SpaceControl⁠ler 中编辑和删除操作‏的权限校验代码替换为 c‌heckSpaceAut‏h 方法，统一空间校验逻辑。

4）开发 ؜SpaceAnal⁠yzeContro‏ller 接口：

@RestController
@RequestMapping("/space/analyze")
public class SpaceAnalyzeController {@Resourceprivate SpaceAnalyzeService spaceAnalyzeService;@Resourceprivate UserService userService;/*** 获取空间使用状态*/@PostMapping("/usage")public BaseResponse<SpaceUsageAnalyzeResponse> getSpaceUsageAnalyze(@RequestBody SpaceUsageAnalyzeRequest spaceUsageAnalyzeRequest,HttpServletRequest request) {ThrowUtils.throwIf(spaceUsageAnalyzeRequest == null, ErrorCode.PARAMS_ERROR);User loginUser = userService.getLoginUser(request);SpaceUsageAnalyzeResponse spaceUsageAnalyze = spaceAnalyzeService.getSpaceUsageAnalyze(spaceUsageAnalyzeRequest, loginUser);return ResultUtils.success(spaceUsageAnalyze);}
}

2、空间图片分类分析

1）开发请求封装类。分类分析只需要传递空间范围相关参数，因此可以直接继承公共的 SpaceAnalyzeRequest：

@EqualsAndHashCode(callSuper = true)
@Data
public class SpaceCategoryAnalyzeRequest extends SpaceAnalyzeRequest {
​
}

2）开发响؜应视图类。分类分析⁠的结果需要返回图片‏分类、分类图片数量‌和分类图片总大小：

@Data
@AllArgsConstructor
@NoArgsConstructor
public class SpaceCategoryAnalyzeResponse implements Serializable {
​/*** 图片分类*/private String category;
​/*** 图片数量*/private Long count;
​/*** 分类图片总大小*/private Long totalSize;
​private static final long serialVersionUID = 1L;
}

3）开发 ؜Service 服⁠务。按照分类分组查‏询图片表的数据：

@Override
public List<SpaceCategoryAnalyzeResponse> getSpaceCategoryAnalyze(SpaceCategoryAnalyzeRequest spaceCategoryAnalyzeRequest, User loginUser) {ThrowUtils.throwIf(spaceCategoryAnalyzeRequest == null, ErrorCode.PARAMS_ERROR);
​// 检查权限checkSpaceAnalyzeAuth(spaceCategoryAnalyzeRequest, loginUser);
​// 构造查询条件QueryWrapper<Picture> queryWrapper = new QueryWrapper<>();// 根据分析范围补充查询条件fillAnalyzeQueryWrapper(spaceCategoryAnalyzeRequest, queryWrapper);
​// 使用 MyBatis-Plus 分组查询queryWrapper.select("category AS category","COUNT(*) AS count","SUM(picSize) AS totalSize").groupBy("category");
​// 查询并转换结果return pictureService.getBaseMapper().selectMaps(queryWrapper).stream().map(result -> {String category = result.get("category") != null ? result.get("category").toString() : "未分类";Long count = ((Number) result.get("count")).longValue();Long totalSize = ((Number) result.get("totalSize")).longValue();return new SpaceCategoryAnalyzeResponse(category, count, totalSize);}).collect(Collectors.toList());
}

💡 建议؜在编写具体的代码前⁠，先编写示例 SQ‏L 语句，并通过数‌据库查询客户端来验‏证。

4）开发接口：

@PostMapping("/category")
public BaseResponse<List<SpaceCategoryAnalyzeResponse>> getSpaceCategoryAnalyze(@RequestBody SpaceCategoryAnalyzeRequest spaceCategoryAnalyzeRequest, HttpServletRequest request) {ThrowUtils.throwIf(spaceCategoryAnalyzeRequest == null, ErrorCode.PARAMS_ERROR);User loginUser = userService.getLoginUser(request);List<SpaceCategoryAnalyzeResponse> resultList = spaceAnalyzeService.getSpaceCategoryAnalyze(spaceCategoryAnalyzeRequest, loginUser);return ResultUtils.success(resultList);
}

3、空间图片标签分析

1）开发请求封装类。标签分析同样需要继承 SpaceAnalyzeRequest：

@EqualsAndHashCode(callSuper = true)
@Data
public class SpaceTagAnalyzeRequest extends SpaceAnalyzeRequest {
​
}

2）开发响؜应视图类。标签分析⁠的结果需要返回标签‏名称和关联的图片数‌量：

@Data
@AllArgsConstructor
@NoArgsConstructor
public class SpaceTagAnalyzeResponse implements Serializable {
​/*** 标签名称*/private String tag;
​/*** 使用次数*/private Long count;
​private static final long serialVersionUID = 1L;
}

3）开发 ؜Service 服⁠务。统计每个标‌签的图片数量，并按‏使用次数降序排序：

@Override
public List<SpaceTagAnalyzeResponse> getSpaceTagAnalyze(SpaceTagAnalyzeRequest spaceTagAnalyzeRequest, User loginUser) {ThrowUtils.throwIf(spaceTagAnalyzeRequest == null, ErrorCode.PARAMS_ERROR);
​// 检查权限checkSpaceAnalyzeAuth(spaceTagAnalyzeRequest, loginUser);
​// 构造查询条件QueryWrapper<Picture> queryWrapper = new QueryWrapper<>();fillAnalyzeQueryWrapper(spaceTagAnalyzeRequest, queryWrapper);
​// 查询所有符合条件的标签queryWrapper.select("tags");List<String> tagsJsonList = pictureService.getBaseMapper().selectObjs(queryWrapper).stream().filter(ObjUtil::isNotNull).map(Object::toString).collect(Collectors.toList());
​// 合并所有标签并统计使用次数Map<String, Long> tagCountMap = tagsJsonList.stream().flatMap(tagsJson -> JSONUtil.toList(tagsJson, String.class).stream()).collect(Collectors.groupingBy(tag -> tag, Collectors.counting()));
​// 转换为响应对象，按使用次数降序排序return tagCountMap.entrySet().stream().sorted((e1, e2) -> Long.compare(e2.getValue(), e1.getValue())) // 降序排列.map(entry -> new SpaceTagAnalyzeResponse(entry.getKey(), entry.getValue())).collect(Collectors.toList());
}

4）开发接口：

@PostMapping("/tag")
public BaseResponse<List<SpaceTagAnalyzeResponse>> getSpaceTagAnalyze(@RequestBody SpaceTagAnalyzeRequest spaceTagAnalyzeRequest, HttpServletRequest request) {ThrowUtils.throwIf(spaceTagAnalyzeRequest == null, ErrorCode.PARAMS_ERROR);User loginUser = userService.getLoginUser(request);List<SpaceTagAnalyzeResponse> resultList = spaceAnalyzeService.getSpaceTagAnalyze(spaceTagAnalyzeRequest, loginUser);return ResultUtils.success(resultList);
}
4、空间图片大小分析

1）开发请求封装类。图片大小分析也继承 SpaceAnalyzeRequest：

@EqualsAndHashCode(callSuper = true)
@Data
public class SpaceSizeAnalyzeRequest extends SpaceAnalyzeRequest {}

2）开发响؜应视图类。大小分析⁠结果需要返回图片大‏小范围和对应的图片‌数量：

@Data
@AllArgsConstructor
@NoArgsConstructor
public class SpaceSizeAnalyzeResponse implements Serializable {/*** 图片大小范围*/private String sizeRange;/*** 图片数量*/private Long count;private static final long serialVersionUID = 1L;
}

3）开发 ؜Service 服务⁠。分段统计图片大小：‏          ‌          ‏            

@Override
public List<SpaceSizeAnalyzeResponse> getSpaceSizeAnalyze(SpaceSizeAnalyzeRequest spaceSizeAnalyzeRequest, User loginUser) {ThrowUtils.throwIf(spaceSizeAnalyzeRequest == null, ErrorCode.PARAMS_ERROR);// 检查权限checkSpaceAnalyzeAuth(spaceSizeAnalyzeRequest, loginUser);// 构造查询条件QueryWrapper<Picture> queryWrapper = new QueryWrapper<>();fillAnalyzeQueryWrapper(spaceSizeAnalyzeRequest, queryWrapper);// 查询所有符合条件的图片大小queryWrapper.select("picSize");List<Long> picSizes = pictureService.getBaseMapper().selectObjs(queryWrapper).stream().map(size -> ((Number) size).longValue()).collect(Collectors.toList());// 定义分段范围，注意使用有序 MapMap<String, Long> sizeRanges = new LinkedHashMap<>();sizeRanges.put("<100KB", picSizes.stream().filter(size -> size < 100 * 1024).count());sizeRanges.put("100KB-500KB", picSizes.stream().filter(size -> size >= 100 * 1024 && size < 500 * 1024).count());sizeRanges.put("500KB-1MB", picSizes.stream().filter(size -> size >= 500 * 1024 && size < 1 * 1024 * 1024).count());sizeRanges.put(">1MB", picSizes.stream().filter(size -> size >= 1 * 1024 * 1024).count());// 转换为响应对象return sizeRanges.entrySet().stream().map(entry -> new SpaceSizeAnalyzeResponse(entry.getKey(), entry.getValue())).collect(Collectors.toList());
}

上述代码其؜实还可以进一步优化⁠，只需要遍历一次 ‏picSizes ‌列表就可以按大小分‏别统计了。

4）开发接口：

@PostMapping("/size")
public BaseResponse<List<SpaceSizeAnalyzeResponse>> getSpaceSizeAnalyze(@RequestBody SpaceSizeAnalyzeRequest spaceSizeAnalyzeRequest, HttpServletRequest request) {ThrowUtils.throwIf(spaceSizeAnalyzeRequest == null, ErrorCode.PARAMS_ERROR);User loginUser = userService.getLoginUser(request);List<SpaceSizeAnalyzeResponse> resultList = spaceAnalyzeService.getSpaceSizeAnalyze(spaceSizeAnalyzeRequest, loginUser);return ResultUtils.success(resultList);
}

5、用户上传行为分析

1）开发请求؜封装类。用户上传行为分⁠析需要增加时间维度（日‏、周、月）和用户 ID‌ 参数，支持只分析某个‏用户上传图片的情况。

@EqualsAndHashCode(callSuper = true)
@Data
public class SpaceUserAnalyzeRequest extends SpaceAnalyzeRequest {/*** 用户 ID*/private Long userId;/*** 时间维度：day / week / month*/private String timeDimension;
}

2）开发响؜应视图类。用户行为⁠分析结果需要返回时‏间区间和对应的图片‌数量：

@Data
@AllArgsConstructor
@NoArgsConstructor
public class SpaceUserAnalyzeResponse implements Serializable {/*** 时间区间*/private String period;/*** 上传数量*/private Long count;private static final long serialVersionUID = 1L;
}

3）开发 ؜Service 服⁠务。基于图片的创建‏时间维度统计用户的‌上传行为，并按照时‏间升序排序：

@Override
public List<SpaceUserAnalyzeResponse> getSpaceUserAnalyze(SpaceUserAnalyzeRequest spaceUserAnalyzeRequest, User loginUser) {ThrowUtils.throwIf(spaceUserAnalyzeRequest == null, ErrorCode.PARAMS_ERROR);// 检查权限checkSpaceAnalyzeAuth(spaceUserAnalyzeRequest, loginUser);// 构造查询条件QueryWrapper<Picture> queryWrapper = new QueryWrapper<>();Long userId = spaceUserAnalyzeRequest.getUserId();queryWrapper.eq(ObjUtil.isNotNull(userId), "userId", userId);fillAnalyzeQueryWrapper(spaceUserAnalyzeRequest, queryWrapper);// 分析维度：每日、每周、每月String timeDimension = spaceUserAnalyzeRequest.getTimeDimension();switch (timeDimension) {case "day":queryWrapper.select("DATE_FORMAT(createTime, '%Y-%m-%d') AS period", "COUNT(*) AS count");break;case "week":queryWrapper.select("YEARWEEK(createTime) AS period", "COUNT(*) AS count");break;case "month":queryWrapper.select("DATE_FORMAT(createTime, '%Y-%m') AS period", "COUNT(*) AS count");break;default:throw new BusinessException(ErrorCode.PARAMS_ERROR, "不支持的时间维度");}// 分组和排序queryWrapper.groupBy("period").orderByAsc("period");// 查询结果并转换List<Map<String, Object>> queryResult = pictureService.getBaseMapper().selectMaps(queryWrapper);return queryResult.stream().map(result -> {String period = result.get("period").toString();Long count = ((Number) result.get("count")).longValue();return new SpaceUserAnalyzeResponse(period, count);}).collect(Collectors.toList());
}

上述代码中，我们؜使用 MySQL 的日期时间函⁠数对图片的创建时间进行了格式化‏，使得同一天（周 / 月）的值‌相同，就能够统一按照一个字段（‏period）进行分组和排序了。

4）开发接口：

@PostMapping("/user")
public BaseResponse<List<SpaceUserAnalyzeResponse>> getSpaceUserAnalyze(@RequestBody SpaceUserAnalyzeRequest spaceUserAnalyzeRequest, HttpServletRequest request) {ThrowUtils.throwIf(spaceUserAnalyzeRequest == null, ErrorCode.PARAMS_ERROR);User loginUser = userService.getLoginUser(request);List<SpaceUserAnalyzeResponse> resultList = spaceAnalyzeService.getSpaceUserAnalyze(spaceUserAnalyzeRequest, loginUser);return ResultUtils.success(resultList);
}

上述的这些需求，可以同时给用户和管理员使用，已经满足了管理员 “全空间资源使用分析” 的需求。接下来我们只需要单独开发一个 仅管理员可使用的功能 —— 空间使用排行分析。

6、空间使用排行分析

该功能仅管؜理员可使用，返回值就⁠是前 N 个空间的‏信息。由于已经有现成的‌ Space 空间对‏象，就不用编写响应视图类了。

1）开发请求封装类。空间使用排行需要接收一个参数 topN，指定要返回的前 N 名空间信息，默认值为 10：

@Data
public class SpaceRankAnalyzeRequest implements Serializable {
​/*** 排名前 N 的空间*/private Integer topN = 10;
​private static final long serialVersionUID = 1L;
}

2）开发 ؜Service 服⁠务。按存储使用量排‏序查询前 N ‌个空间。注意，只有管理‏员可以查看空间排行：

@Override
public List<Space> getSpaceRankAnalyze(SpaceRankAnalyzeRequest spaceRankAnalyzeRequest, User loginUser) {
ThrowUtils.throwIf(spaceRankAnalyzeRequest == null, ErrorCode.PARAMS_ERROR);
​
// 仅管理员可查看空间排行
ThrowUtils.throwIf(!userService.isAdmin(loginUser), ErrorCode.NO_AUTH_ERROR, "无权查看空间排行");
​
// 构造查询条件
QueryWrapper<Space> queryWrapper = new QueryWrapper<>();
queryWrapper.select("id", "spaceName", "userId", "totalSize").orderByDesc("totalSize").last("LIMIT " + spaceRankAnalyzeRequest.getTopN()); // 取前 N 名
​
// 查询结果
return spaceService.list(queryWrapper);
}

3）开发接口：

@PostMapping("/rank")
public BaseResponse<List<Space>> getSpaceRankAnalyze(@RequestBody SpaceRankAnalyzeRequest spaceRankAnalyzeRequest, HttpServletRequest request) {ThrowUtils.throwIf(spaceRankAnalyzeRequest == null, ErrorCode.PARAMS_ERROR);User loginUser = userService.getLoginUser(request);List<Space> resultList = spaceAnalyzeService.getSpaceRankAnalyze(spaceRankAnalyzeRequest, loginUser);return ResultUtils.success(resultList);
}

至此，分析؜需求的后端接口全部开发⁠完成！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如若转载，请注明出处：http://www.pswp.cn/news/921755.shtml
繁体地址，请注明出处：http://hk.pswp.cn/news/921755.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

HTML第八课：HTML4和HTML5的区别

HTML第八课：HTML4和HTML5的区别

HTML第八课&#xff1a;HTML4和HTML5的区别html4 与 html 5的区别快速学习平台html4 与 html 5的区别 示例图 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><title>Title</title> </head> &…
阅读更多...
CS336——1. Overview

CS336——1. Overview

文章目录1. CS336介绍2. 概览2.1 为什么会有这门课程2.1.1 LLM的参数和训练成本2.2.2 小语言模型和LLM的区别2.2 你可以学到什么&#xff1f;2.2.1 Intuitions2.2.2 The bitter lesson3. 全景图(current landscape)/发展历史4. 可执行的课件说明5. 课程设计6. 课程内容6. 1 bas…
阅读更多...
ncnn-Android-mediapipe_hand 踩坑部署实录

ncnn-Android-mediapipe_hand 踩坑部署实录

目录 同时有 nanodet 和yolox，可以做到10fps 没测试：yolox hand ncnn-Android-mediapipe_hand hand 关键点21个模型： ncnn版本： 跑通后，手部关键点集中在图像左上角，经过排查，原因是ncnn版本不对。 CMakeLists.txt 同时有 nanodet 和yolox，可以做到10fps 无训练…
阅读更多...
OSPF实验：外部路由引入

OSPF实验：外部路由引入

OSPF外部路由引入实验目的&#xff1a;除了内部通信外&#xff0c;企业还需要与外部网络进行通信&#xff0c;不同企业网络之间存在互访需求。假设A公司网络部署OSPF协议实现内部通信&#xff0c;因业务发展&#xff0c;需要访问B公司的一台WEB服务器。网络拓扑图&#xff1a;公…
阅读更多...
网络上那些在线 PDF 转换工具安全吗？转换 PDF 需要注意什么

网络上那些在线 PDF 转换工具安全吗？转换 PDF 需要注意什么

PDF 格式凭借跨设备兼容、格式稳定的优势&#xff0c;早已成为个人办公、企业协作中不可或缺的文件格式。无论是压缩 PDF 以满足邮件附件大小限制&#xff0c;还是将 Word 文档转成 PDF 确保排版不变&#xff0c;我们总能遇到需要 PDF 工具的场景。也正因如此&#xff0c;网上涌…
阅读更多...
生成对抗网络（GAN）

生成对抗网络（GAN）

目录 1 引言 2 生成对抗网络的基本原理 2.1 生成器与判别器 2.2 对抗训练过程 2.3 与传统生成模型的比较 3 GAN的衍生模型 3.1 架构创新与深度卷积GAN 3.2 损失函数优化与Wasserstein GAN 3.3 条件生成与可控合成 3.4 跨域转换与CycleGAN 3.5 高分辨率生成与规模化演…
阅读更多...
Vue 3.6 Alien Signals：让响应式性能飞跃式提升

Vue 3.6 Alien Signals：让响应式性能飞跃式提升

概述 Vue 3.6 引入了革命性的 Alien Signals 技术&#xff0c;这是一种全新的响应式系统&#xff0c;基于细粒度响应式原理&#xff0c;为 Vue 应用带来了前所未有的性能提升和开发体验优化。 什么是 Alien Signals&#xff1f; Alien Signals 是 Vue 3.6 内置的轻量级响应式…
阅读更多...
IOS OC 模仿携程的日历控件

IOS OC 模仿携程的日历控件

地址&#xff1a;代码地址
阅读更多...
React Hooks 报错？一招解决useState问题

React Hooks 报错？一招解决useState问题

文章目录问题分析问题 在使用import { useState } from "react";时报错&#xff1a;Youre importing a component that needs useState. This React Hook only works in a Client Component. To fix, mark the file (or its parent) with the “use client” direct…
阅读更多...
数据集成平台怎么选？从ETL到CDC再到iPaaS的全景对比

数据集成平台怎么选？从ETL到CDC再到iPaaS的全景对比

前言&#xff1a;一个制造企业的真实困境 近期在为某家制造企业做系统改造时&#xff0c;我们遇到了一个典型的数据集成难题。这家企业运营着独立的ERP、CRM和MES等30业务系统&#xff0c;看似完备的信息化基础却存在严重的数据割裂问题。 销售团队在CRM中查看的库存数据总是滞…
阅读更多...
驱动开发系列72 - GLSL编译器实现 - 指令选择（二）

驱动开发系列72 - GLSL编译器实现 - 指令选择（二）

前面介绍过，在指令选择时会执行一系列优化过程，本节介绍下“比特级常量传播优化”的实现。 一：什么是比特级常量传播优化 举一个GLSL语言例子： #version 450layout(location = 0) in vec4 inColor; layout(location = 0) out vec4 outColor;void main() {vec4 tmp = inCo…
阅读更多...
Redis(缓存)

Redis(缓存)

一 什么是缓存1. 生活上的例子比如有一个行李箱和一个手机&#xff0c;每次把手机放到行李箱在拿出来肯定很麻烦&#xff0c;如果放到裤兜里就会方便很多&#xff0c;所以裤兜算作行李箱的一个缓存&#xff0c;不仅仅是裤兜&#xff0c;甚至可以一直拿在手上等其他有存储介质的…
阅读更多...
openssl简介

openssl简介

一、openssl是什么 OpenSSL是一个开源的、功能强大的软件库和工具包，它实现了传输层安全（TLS） 和安全套接层（SSL） 协议以及一个全面的密码学原语库。它是用 C 语言编写的，为其带来了高性能和跨平台的特性。 作为库（Library）：开发者可以将其代码集成到自己的应用程序（…
阅读更多...
左值引用与右值引用

左值引用与右值引用

左值和右值 左值&#xff08;lvalue&#xff09;&#xff1a;在表达式结束后仍然存在&#xff0c;可以取地址。简单理解&#xff1a;有名字、有存储位置。 比如变量、数组元素、对象等。 右值&#xff08;rvalue&#xff09;&#xff1a;临时值&#xff0c;表达式结束后就消失&…
阅读更多...
中小企业SAP B1 HANA部署全解析：成本与云端优势

中小企业SAP B1 HANA部署全解析：成本与云端优势

目录 云端部署成本构成与效益分析 软件许可费 硬件成本 服务费 培训费 技术优势 快速部署 弹性扩展 高可用性 云端部署适用场景 IT预算有限的中小企业 分布在不同地区的机构 需要快速上线的情况 本地部署适用场景 数据监管严格的行业 拥有完善IT基础设施企业 …
阅读更多...
Django Channels实战：WebSocket实时通信开发

Django Channels实战：WebSocket实时通信开发

在当今Web应用开发中&#xff0c;实时通信功能已成为提升用户体验的关键要素。传统的HTTP请求-响应模式难以满足即时聊天、实时通知、协同编辑等场景的需求。本文将深入探讨如何利用Django Channels框架实现WebSocket通信&#xff0c;为你的Django项目添加实时交互能力。为什么…
阅读更多...
大数据毕业设计选题推荐-基于大数据的懂车帝二手车数据分析系统-Spark-Hadoop-Bigdata

大数据毕业设计选题推荐-基于大数据的懂车帝二手车数据分析系统-Spark-Hadoop-Bigdata

✨作者主页&#xff1a;IT研究室✨ 个人简介&#xff1a;曾从事计算机专业培训教学&#xff0c;擅长Java、Python、微信小程序、Golang、安卓Android等项目实战。接项目定制开发、代码讲解、答辩教学、文档编写、降重等。 ☑文末获取源码☑ 精彩专栏推荐⬇⬇⬇ Java项目 Python…
阅读更多...
python 通过selenium调用chrome浏览器

python 通过selenium调用chrome浏览器

更新selenium pip install -U selenium 下载浏览器和对应的驱动 Chrome for Testing availability 一般选稳定版本的&#xff0c;我是windows的就下win64的&#xff0c; 下载两个zip包后&#xff0c;把chromedriver.zip中的exe解压缩放到chrome_win64文件夹中 from selen…
阅读更多...
Codeium：免费开源代码自动补全工具，高效管理代码片段告别开发卡壳

Codeium：免费开源代码自动补全工具，高效管理代码片段告别开发卡壳

你有没有过这种尴尬时刻&#xff1f;写代码时突然想不起来常用的函数写法&#xff0c;比如 Python 的字典推导式&#xff0c;或者 MySQL 的联表查询语句&#xff0c;翻之前的项目文件翻半天&#xff0c;好不容易找到又得复制粘贴 —— 要是遇到换电脑&#xff0c;之前存的代码片…
阅读更多...
嵌入式系统学习Day35(sqlite3数据库)

嵌入式系统学习Day35(sqlite3数据库)

一.数据库 1、分类&#xff1a;大型中型小型 ORACLEMYSQL/MSSQL : SQLITE DBll powdb 关系型数据库 2、名词&#xff1a; DB数据库 select update database DBMS数据库管理系统 MIS管理信息系统 OA办公自动化 3、嵌入式数据库&#xff1a; sqlite3www.sqlite.org www.kernal.…
阅读更多...
最新文章

Copyright @ 2022~2023