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