From 8228b06f808840d95d58e4ad457e072800af33e6 Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Wed, 09 Mar 2022 11:35:00 +0800 Subject: [PATCH] 校准公式工具类修改 --- screen-manage/src/main/java/com/moral/api/util/AdjustDataUtils.java | 107 +++++++++++++++++++++++++++++++++++++++++++++++------ 1 files changed, 94 insertions(+), 13 deletions(-) diff --git a/screen-manage/src/main/java/com/moral/api/util/AdjustDataUtils.java b/screen-manage/src/main/java/com/moral/api/util/AdjustDataUtils.java index 1f1deba..0064a49 100644 --- a/screen-manage/src/main/java/com/moral/api/util/AdjustDataUtils.java +++ b/screen-manage/src/main/java/com/moral/api/util/AdjustDataUtils.java @@ -9,25 +9,45 @@ import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.Optional; +import java.util.Set; import com.alibaba.fastjson.JSON; import com.googlecode.aviator.AviatorEvaluator; import com.googlecode.aviator.Expression; import com.moral.api.entity.DeviceAdjustValue; +import com.moral.constant.Constants; import com.moral.util.DateUtils; @Slf4j @Component public class AdjustDataUtils { - //��������������� + /** + * @param deviceData ������������ + * @param adjustFormula ������������������������������������������������key���������code,value������������������������������������������List��� + * @param aqiMap ������������������������������aqi������ + * @return Map<String, Object> ��������������� + */ public Map<String, Object> adjust(Map<String, Object> deviceData, Map<String, Object> adjustFormula, Map<String, Object> aqiMap) { try { - Object dataTime = deviceData.get("DataTime"); - //��������������������������� - long time = Math.round(new Double((String) dataTime) / 1000) * 1000L; - long finalTime = DateUtils.dataToTimeStampTime(new Date(time), DateUtils.HH_mm_ss_EN).getTime(); + Date time = DateUtils.getDate((String) deviceData.remove("DataTime"), DateUtils.yyyyMMddHHmmss_EN); + long finalTime = DateUtils.dataToTimeStampTime(time, DateUtils.HH_mm_ss_EN).getTime(); + + //������������������������������������������������������ + if (deviceData.get(Constants.SENSOR_CODE_CURRENT_SPEED) != null) { + deviceData = adjustFlueSpeedAndFlow(deviceData, adjustFormula); + } + + //������������������������������������������������ + Set<String> dateKey = deviceData.keySet(); + for (String adjustKey : adjustFormula.keySet()) { + if (!dateKey.contains(adjustKey)) { + deviceData.put(adjustKey, "0"); + } + } + for (String key : deviceData.keySet()) { - if (!key.equals("mac") && !key.equals("time") && !key.equals("DataTime") && !key.equals("ver") && !key.contains("Flag")) { + if (!key.contains("Flag")) { //��������� Object measuredValue = deviceData.get(key); //������������������������ @@ -36,11 +56,14 @@ deviceData.put(key, measuredValue); continue; } - //��������������������������������� - DeviceAdjustValue deviceAdjustValue = sensorFormulas.stream() + DeviceAdjustValue deviceAdjustValue = new DeviceAdjustValue(); + Optional<DeviceAdjustValue> optional = sensorFormulas.stream() .filter(o -> o.getStartTime().getTime() <= finalTime && o.getEndTime().getTime() > finalTime) - .findFirst().get(); + .findFirst(); + if (optional.isPresent()) { + deviceAdjustValue = optional.get(); + } String formula = deviceAdjustValue.getValue(); if (StringUtils.isEmpty(formula)) { deviceData.put(key, measuredValue); @@ -57,7 +80,7 @@ env.put("aqi", ObjectUtils.isEmpty(aqiValue) ? 0F : Float.parseFloat((String) aqiValue)); } if (formula.contains("vocs")) { - Object vocsValue = ObjectUtils.isEmpty(deviceData.get("a99054")) ? 0F : deviceData.get("a99054"); + Object vocsValue = ObjectUtils.isEmpty(deviceData.get(Constants.SENSOR_CODE_VOCS)) ? 0F : deviceData.get(Constants.SENSOR_CODE_VOCS); env.put("vocs", vocsValue); } if (formula.contains("cel")) { @@ -66,15 +89,73 @@ //������ measuredValue = expression.execute(env); //������������ - if (Float.parseFloat(measuredValue.toString()) < 0 && !"a01001".equals(measuredValue)) { + if (!Constants.SENSOR_CODE_TEMP.equals(measuredValue) && Float.parseFloat(measuredValue.toString()) < 0) { measuredValue = 0F; } - deviceData.put(key, Double.parseDouble(String.format("%.3f", measuredValue))); + deviceData.put(key, Double.parseDouble(String.format("%.4f", measuredValue))); } } } catch (Exception e) { log.error("param[0] deviceData:" + JSON.toJSONString(deviceData)); - log.error(e.getMessage()); + } + return deviceData; + } + + /** + * ��������������������������������� + * + * @param deviceData ��������������������������������������������������������������������������������������������������������� + * @param adjustFormula ���������������������������������������������������key���������code + */ + public Map<String, Object> adjustFlueSpeedAndFlow(Map<String, Object> deviceData, Map<String, Object> adjustFormula) { + Date time = DateUtils.getDate((String) deviceData.remove("DataTime"), DateUtils.yyyyMMddHHmmss_EN); + long finalTime = DateUtils.dataToTimeStampTime(time, DateUtils.HH_mm_ss_EN).getTime(); + //��������������� + Object measuredValue = deviceData.get(Constants.SENSOR_CODE_CURRENT_SPEED); + + + //������������ + List<DeviceAdjustValue> speedFormulas = (List<DeviceAdjustValue>) adjustFormula.get(Constants.SENSOR_CODE_CURRENT_SPEED); + if (!ObjectUtils.isEmpty(speedFormulas)) { + //��������������������������������� + DeviceAdjustValue deviceAdjustValue = new DeviceAdjustValue(); + Optional<DeviceAdjustValue> optional = speedFormulas.stream() + .filter(o -> o.getStartTime().getTime() <= finalTime && o.getEndTime().getTime() > finalTime) + .findFirst(); + if (optional.isPresent()) { + deviceAdjustValue = optional.get(); + } + + String formula = deviceAdjustValue.getValue(); + if (!StringUtils.isEmpty(formula)) { + + Expression expression = AviatorEvaluator.compile(formula); + Map<String, Object> env = new HashMap<>(); + env.put("cel", Float.parseFloat((String) measuredValue)); + //������ + measuredValue = expression.execute(env); + deviceData.put(Constants.SENSOR_CODE_CURRENT_SPEED, Double.parseDouble(String.format("%.4f", measuredValue))); + } + + + //������������ + List<DeviceAdjustValue> flowFormulas = (List<DeviceAdjustValue>) adjustFormula.get(Constants.SENSOR_CODE_CURRENT_FLOW); + //��������������������������������� + optional = flowFormulas.stream() + .filter(o -> o.getStartTime().getTime() <= finalTime && o.getEndTime().getTime() > finalTime) + .findFirst(); + if (optional.isPresent()) { + deviceAdjustValue = optional.get(); + } + + formula = deviceAdjustValue.getValue(); + if (!StringUtils.isEmpty(formula)) { + Expression expression = AviatorEvaluator.compile(formula); + Map<String, Object> env = new HashMap<>(); + String currentSpeed = deviceData.get(Constants.SENSOR_CODE_CURRENT_SPEED).toString(); + env.put("currentSpeed", Float.parseFloat(currentSpeed)); + deviceData.put(Constants.SENSOR_CODE_CURRENT_FLOW, Double.parseDouble(String.format("%.4f", expression.execute(env)))); + } } return deviceData; } -- Gitblit v1.8.0