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 | 77 +++++++++++++++++++++++++++++++++++++- 1 files changed, 75 insertions(+), 2 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 4406532..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 @@ -10,6 +10,7 @@ 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; @@ -23,7 +24,7 @@ public class AdjustDataUtils { /** * @param deviceData ������������ - * @param adjustFormula ������������ + * @param adjustFormula ������������������������������������������������key���������code,value������������������������������������������List��� * @param aqiMap ������������������������������aqi������ * @return Map<String, Object> ��������������� */ @@ -31,6 +32,20 @@ try { 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.contains("Flag")) { //��������� @@ -82,7 +97,65 @@ } } 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