package com.gkhy.fourierSpecialGasMonitor.service.impl;
|
|
import com.gkhy.fourierSpecialGasMonitor.commons.domain.Result;
|
import com.gkhy.fourierSpecialGasMonitor.commons.domain.SearchResult;
|
import com.gkhy.fourierSpecialGasMonitor.commons.enums.ResultCode;
|
import com.gkhy.fourierSpecialGasMonitor.commons.exception.BusinessException;
|
import com.gkhy.fourierSpecialGasMonitor.commons.model.PageQuery;
|
import com.gkhy.fourierSpecialGasMonitor.entity.SummaryStats;
|
import com.gkhy.fourierSpecialGasMonitor.entity.req.SummaryStatsReqDTO;
|
import com.gkhy.fourierSpecialGasMonitor.entity.resp.GasAtmospherePageRespDTO;
|
import com.gkhy.fourierSpecialGasMonitor.entity.resp.SummaryStatsPageRespDTO;
|
import com.gkhy.fourierSpecialGasMonitor.repository.SummaryStatsRepository;
|
import com.gkhy.fourierSpecialGasMonitor.service.SummaryStatsService;
|
import com.gkhy.fourierSpecialGasMonitor.utils.SummaryUtils;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.domain.Page;
|
import org.springframework.data.domain.PageRequest;
|
import org.springframework.data.domain.Pageable;
|
import org.springframework.data.domain.Sort;
|
import org.springframework.data.jpa.domain.Specification;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.CollectionUtils;
|
|
import javax.persistence.criteria.CriteriaBuilder;
|
import javax.persistence.criteria.CriteriaQuery;
|
import javax.persistence.criteria.Predicate;
|
import javax.persistence.criteria.Root;
|
import java.time.LocalDateTime;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
|
|
@Service
|
public class SummaryStatsServiceImpl implements SummaryStatsService {
|
|
@Autowired
|
private SummaryStatsRepository summaryStatsRepository;
|
|
@Override
|
public void save(SummaryStats stats) {
|
summaryStatsRepository.save(stats);
|
}
|
|
@Override
|
public Result listSummaryStats(PageQuery<SummaryStatsReqDTO> pageQuery) {
|
// 分页参数校验（复用已有逻辑，补充非空判断）
|
if (pageQuery == null || pageQuery.getPageIndex() == null || pageQuery.getPageSize() == null) {
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL, "分页参数不能为空");
|
}
|
// 校验分页索引和大小合法性（避免负数或过大值）
|
if (pageQuery.getPageIndex() < 1 || pageQuery.getPageSize() < 1 || pageQuery.getPageSize() > 1000) {
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR, "分页索引必须≥1，分页大小必须在1-1000之间");
|
}
|
|
//查询参数校验（处理 searchParams 为 null 的情况）
|
SummaryStatsReqDTO searchParams = pageQuery.getSearchParams();
|
if (searchParams == null) {
|
searchParams = new SummaryStatsReqDTO(); // 避免后续调用 NPE
|
}
|
LocalDateTime startTime = searchParams.getStartTime();
|
LocalDateTime endTime = searchParams.getEndTime();
|
String type = searchParams.getType(); // type 改为 String 类型
|
|
// 校验 type 合法性（允许为 null，若不为 null 则必须是指定值）
|
List<String> validTypes = Arrays.asList("temp", "humidity", "windSpeed", "windDirection", "pressure");
|
if (type != null && !validTypes.contains(type)) {
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR,
|
"type 必须为 temp、humidity、windSpeed、windDirection、pressure 中的一种");
|
}
|
|
// 初始化返回结果
|
SearchResult<List<SummaryStatsPageRespDTO>> searchResult = new SearchResult<>();
|
searchResult.setPageIndex(pageQuery.getPageIndex());
|
searchResult.setPageSize(pageQuery.getPageSize());
|
searchResult.setSuccess();
|
// 构建查询条件（使用 List 而非 Set，逻辑更清晰；补充时间范围非空判断）
|
Specification<SummaryStats> specification = (root, query, criteriaBuilder) -> {
|
List<Predicate> predicates = new ArrayList<>();
|
// 时间范围条件：仅当 start/endTime 非空时添加（避免 null 导致的查询异常）
|
if (startTime != null && endTime != null) {
|
predicates.add(criteriaBuilder.between(root.get("time"), startTime, endTime));
|
} else if (startTime != null) {
|
predicates.add(criteriaBuilder.greaterThanOrEqualTo(root.get("time"), startTime));
|
} else if (endTime != null) {
|
predicates.add(criteriaBuilder.lessThanOrEqualTo(root.get("time"), endTime));
|
}
|
// 可扩展其他条件（如按位置、设备筛选）
|
return criteriaBuilder.and(predicates.toArray(new Predicate[0]));
|
};
|
// 构建分页参数（封装分页索引转换逻辑，避免硬编码）
|
Pageable pageable = PageRequest.of(pageQuery.getPageIndex()-1, pageQuery.getPageSize(), Sort.Direction.DESC, "time");
|
// 执行查询
|
Page<SummaryStats> statsPage = summaryStatsRepository.findAll(specification, pageable);
|
if (statsPage.isEmpty()) {
|
return searchResult; // 空结果直接返回
|
}
|
|
SummaryUtils summaryUtils = new SummaryUtils();
|
// 转换结果（使用枚举映射处理 type 逻辑）
|
List<SummaryStatsPageRespDTO> respDTOS = statsPage.getContent().stream()
|
.map(stats -> summaryUtils.convertToResp(stats, type))
|
.collect(Collectors.toList());
|
|
// 填充返回结果
|
searchResult.setTotal(statsPage.getTotalElements());
|
searchResult.setPages(statsPage.getTotalPages());
|
searchResult.setData(respDTOS);
|
return searchResult;
|
}
|
}
|
