From 5236663d1e40ca9ed0cbc0885cbc67a67c47943f Mon Sep 17 00:00:00 2001 From: kaiyu <404897439@qq.com> Date: Mon, 14 Mar 2022 16:27:23 +0800 Subject: [PATCH] screen-api 增加获取简报接口 --- screen-api/src/main/java/com/moral/api/utils/AdjustDataUtils.java | 112 +++++++++++++++++++++++++++++++++++++++++++++++-------- 1 files changed, 95 insertions(+), 17 deletions(-) diff --git a/screen-api/src/main/java/com/moral/api/utils/AdjustDataUtils.java b/screen-api/src/main/java/com/moral/api/utils/AdjustDataUtils.java index 324795d..81faef4 100644 --- a/screen-api/src/main/java/com/moral/api/utils/AdjustDataUtils.java +++ b/screen-api/src/main/java/com/moral/api/utils/AdjustDataUtils.java @@ -1,11 +1,5 @@ package com.moral.api.utils; -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; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Component; import org.springframework.util.ObjectUtils; @@ -15,22 +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 ������������ - * @param aqiMap ���������������������������������aqi������ + * @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) { + */ + public static Map<String, Object> adjust(Map<String, Object> deviceData, Map<String, Object> adjustFormula, Map<String, Object> aqiMap) { try { - Date time = DateUtils.getDate((String) deviceData.get("DataTime"), DateUtils.yyyyMMddHHmmss_EN); + 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); //������������������������ @@ -39,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); @@ -77,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 static 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