package com.gkhy.fourierSpecialGasMonitor.utils;
|
|
import com.alibaba.druid.util.StringUtils;
|
import com.gkhy.fourierSpecialGasMonitor.commons.enums.ResultCode;
|
import com.gkhy.fourierSpecialGasMonitor.commons.exception.BusinessException;
|
import com.gkhy.fourierSpecialGasMonitor.entity.GasConcentration;
|
import com.gkhy.fourierSpecialGasMonitor.entity.SummaryStats;
|
import com.gkhy.fourierSpecialGasMonitor.entity.req.SummaryStatsReqDTO;
|
import com.gkhy.fourierSpecialGasMonitor.entity.resp.SummaryStatsPageRespDTO;
|
import com.gkhy.fourierSpecialGasMonitor.enums.StatsTypeEnum;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.BeanUtils;
|
|
import java.lang.reflect.Field;
|
import java.time.LocalDate;
|
import java.time.Year;
|
import java.time.YearMonth;
|
import java.time.format.DateTimeParseException;
|
import java.util.Arrays;
|
|
public class SummaryUtils {
|
|
private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
|
|
|
/**
|
* 初始化统计数据（当当天无数据时，用新数据作为初始值）
|
*/
|
public static void initSummaryStats(SummaryStats stats, GasConcentration data) {
|
// 初始化 temp 相关统计（min/max/avg 均为当前数据值）
|
stats.setTempMin(data.getTemp());
|
stats.setTempMax(data.getTemp());
|
stats.setTempAvg(data.getTemp());
|
|
// 初始化 humidity 相关统计
|
stats.setHumidityMin(data.getHumidity());
|
stats.setHumidityMax(data.getHumidity());
|
stats.setHumidityAvg(data.getHumidity());
|
|
// 初始化 windSpeed 相关统计
|
Double windSpeed = data.getWindSpeed();
|
stats.setWindSpeedMin(windSpeed);
|
stats.setWindSpeedMax(windSpeed);
|
stats.setWindSpeedAvg(windSpeed);
|
|
// 初始化 windDirection 相关统计（处理可能的 null）
|
Integer windDirection = data.getWindDirection();
|
stats.setWindDirectionMin(windDirection);
|
stats.setWindDirectionMax(windDirection);
|
stats.setWindDirectionAvg(windDirection != null ? windDirection.doubleValue() : null);
|
|
// 初始化 pressure 相关统计
|
Double pressure = data.getPressure();
|
stats.setPressureMin(pressure);
|
stats.setPressureMax(pressure);
|
stats.setPressureAvg(pressure);
|
}
|
|
/**
|
* 更新统计数据（根据新数据重新计算 min/max/avg）
|
*/
|
public static void updateSummaryStats(SummaryStats stats, GasConcentration newData) {
|
// 更新 temp：min 取更小值，max 取更大值，avg 重新计算（需注意：avg 不能直接用当前 avg 计算，需累计总和/数量）
|
// 注意：此处简化处理，实际 avg 需基于总样本数计算（建议在数据库查询时直接聚合，而非内存中更新）
|
Double newTemp = newData.getTemp();
|
stats.setTempMin(min(stats.getTempMin(), newTemp));
|
stats.setTempMax(max(stats.getTempMax(), newTemp));
|
|
// 更新 humidity
|
Double newHumidity = newData.getHumidity();
|
stats.setHumidityMin(min(stats.getHumidityMin(), newHumidity));
|
stats.setHumidityMax(max(stats.getHumidityMax(), newHumidity));
|
|
// 更新 windSpeed
|
Double newWindSpeed = newData.getWindSpeed();
|
stats.setWindSpeedMin(min(stats.getWindSpeedMin(), newWindSpeed));
|
stats.setWindSpeedMax(max(stats.getWindSpeedMax(), newWindSpeed));
|
|
// 更新 windDirection
|
Integer newWindDir = newData.getWindDirection();
|
stats.setWindDirectionMin(min(stats.getWindDirectionMin(), newWindDir));
|
stats.setWindDirectionMax(max(stats.getWindDirectionMax(), newWindDir));
|
|
// 更新 pressure
|
Double newPressure = newData.getPressure();
|
stats.setPressureMin(min(stats.getPressureMin(), newPressure));
|
stats.setPressureMax(max(stats.getPressureMax(), newPressure));
|
}
|
|
/**
|
* 安全计算两个 Double 的最小值（处理 null）
|
*/
|
private static Double min(Double a, Double b) {
|
if (a == null) return b;
|
if (b == null) return a;
|
return Math.min(a, b);
|
}
|
|
/**
|
* 安全计算两个 Integer 的最小值（处理 null）
|
*/
|
private static Integer min(Integer a, Integer b) {
|
if (a == null) return b;
|
if (b == null) return a;
|
return Math.min(a, b);
|
}
|
|
// 同理实现 max 方法（Double 和 Integer 版本）
|
private static Double max(Double a, Double b) {
|
if (a == null) return b;
|
if (b == null) return a;
|
return Math.max(a, b);
|
}
|
|
private static Integer max(Integer a, Integer b) {
|
if (a == null) return b;
|
if (b == null) return a;
|
return Math.max(a, b);
|
}
|
|
public void validateParams(SummaryStatsReqDTO reqDTO) {
|
if (reqDTO == null) {
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(),"请求参数不能为空");
|
}
|
if (StringUtils.isEmpty(reqDTO.getType())) {
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(),"气体类型（type）不能为空");
|
}
|
if (reqDTO.getDateType() == null || !Arrays.asList(1, 2, 3).contains(reqDTO.getDateType())) {
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_ILLEGAL.getCode(),"dateType必须为1（日）、2（月）、3（年）");
|
}
|
if (StringUtils.isEmpty(reqDTO.getDate())) {
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(),"日期（date）不能为空");
|
}
|
// 校验date格式（根据dateType）
|
try {
|
switch (reqDTO.getDateType()) {
|
case 1:
|
LocalDate.parse(reqDTO.getDate()); // 校验 yyyy-MM-dd
|
break;
|
case 2:
|
YearMonth.parse(reqDTO.getDate()); // 校验 yyyy-MM
|
break;
|
case 3:
|
Year.parse(reqDTO.getDate()); // 校验 yyyy
|
break;
|
}
|
} catch (DateTimeParseException e) {
|
throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_ILLEGAL.getCode(),"日期格式错误，dateType=" + reqDTO.getDateType() + "时，date应为" +
|
(reqDTO.getDateType() == 1 ? "yyyy-MM-dd" : reqDTO.getDateType() == 2 ? "yyyy-MM" : "yyyy"));
|
}
|
}
|
|
|
public SummaryStatsPageRespDTO convertToResp(SummaryStats stats, String type) {
|
SummaryStatsPageRespDTO respDTO = new SummaryStatsPageRespDTO();
|
BeanUtils.copyProperties(stats, respDTO); // 复制公共字段（如 time）
|
|
if (type == null) {
|
return respDTO; // 若 type 为 null，不设置指标相关字段
|
}
|
|
StatsTypeEnum mapper = StatsTypeEnum.getByType(type);
|
if (mapper == null) {
|
return respDTO; // 无效 type（理论上已在参数校验时拦截）
|
}
|
|
try {
|
// 反射获取字段值（通过枚举映射的字段名）
|
Field valueField = SummaryStats.class.getDeclaredField(mapper.getValueField());
|
Field minField = SummaryStats.class.getDeclaredField(mapper.getMinField());
|
Field maxField = SummaryStats.class.getDeclaredField(mapper.getMaxField());
|
Field avgField = SummaryStats.class.getDeclaredField(mapper.getAvgField());
|
|
valueField.setAccessible(true);
|
minField.setAccessible(true);
|
maxField.setAccessible(true);
|
avgField.setAccessible(true);
|
|
// 设置到响应 DTO
|
respDTO.setValue(valueField.get(stats));
|
respDTO.setMin(minField.get(stats));
|
respDTO.setMax(maxField.get(stats));
|
respDTO.setAvg(avgField.get(stats));
|
} catch (NoSuchFieldException | IllegalAccessException e) {
|
logger.error("转换 SummaryStats 到 DTO 失败，type={}, stats={}", type, stats, e);
|
}
|
return respDTO;
|
}
|
}
|
