From 03791ab057f15d102bc20b83c687f8a8028a4b8f Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Tue, 28 Dec 2021 13:47:38 +0800
Subject: [PATCH] 行业贡献率update

---
 screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java |  135 ++++++++++++++++++++++++++++++++++++--------
 1 files changed, 110 insertions(+), 25 deletions(-)

diff --git a/screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java
index 145895d..cdca09d 100644
--- a/screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java
+++ b/screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java
@@ -2,8 +2,7 @@
 
 import com.alibaba.fastjson.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.moral.api.entity.HistorySecondUav;
-import com.moral.api.entity.Organization;
+import com.moral.api.entity.*;
 import com.moral.api.mapper.HistorySecondUavMapper;
 import com.moral.api.pojo.dto.uav.UAVQueryTimeSlotDTO;
 import com.moral.api.pojo.form.uav.UAVQueryTimeSlotForm;
@@ -11,15 +10,20 @@
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.moral.api.service.OrganizationService;
 import com.moral.api.service.SpecialDeviceService;
+import com.moral.constant.RedisConstants;
 import com.moral.util.DateUtils;
 import com.moral.util.GeodesyUtils;
 import com.moral.util.MathUtils;
+import com.moral.util.UnitConvertUtils;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Service;
+import org.springframework.util.ObjectUtils;
 
 import java.math.BigDecimal;
 import java.text.SimpleDateFormat;
 import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.function.Predicate;
 
 /**
@@ -44,6 +48,8 @@
     OrganizationService organizationService;
     @Autowired
     SpecialDeviceService specialDeviceService;
+    @Autowired
+    RedisTemplate redisTemplate;
 
     @Override
     public List<Date> queryDate(Integer organizationId) {
@@ -142,11 +148,15 @@
             List<Map<String, Object>> timeSlots = new ArrayList<>();
             dto.setMac(key);
             //������mac������������������
-            dto.setName((String) specialDeviceService.getSpecialDeviceMapByMac(key).getName());
+            SpecialDevice specialDevice = specialDeviceService.getSpecialDeviceMapByMac(key);
+            //������������������������������������
+            if (specialDevice == null)
+                return;
+            dto.setName(specialDevice.getName());
             //������������������batch
             value.forEach(listValue -> {
                 listValue.forEach((mKey, mValue) -> {
-                    Date slotStartDate = mValue.    get(0).getTime();
+                    Date slotStartDate = mValue.get(0).getTime();
                     Date slotEndDate = mValue.get(mValue.size() - 1).getTime();
                     Map<String, Object> dateMap = new HashMap<>();
                     dateMap.put("startTime", slotStartDate);
@@ -168,7 +178,7 @@
         //������������
         QueryWrapper<HistorySecondUav> wrapper = new QueryWrapper<>();
         wrapper.eq("batch", batchDate);
-        wrapper.select("value");
+        wrapper.select("value,mac,time");
         List<HistorySecondUav> datas = historySecondUavMapper.selectList(wrapper);
         //������������������������������������
         Double lowestHeight = 0d;
@@ -194,10 +204,20 @@
             String newValue = JSON.toJSONString(valueMap);
             data.setValue(newValue);
         }
-        //���������������������,���������������������������������3���������
-        return filterDatas(datas);
+        //���������������������,���������������������������������2���������
+        datas = filterDatas(datas);
+        //������������
+        unitConvert(datas);
+        return datas;
     }
 
+    /**
+     * @Description: ������������
+     * @Param: [datas]
+     * @return: java.util.List<com.moral.api.entity.HistorySecondUav>
+     * @Author: ���������
+     * @Date: 2021/9/16
+     */
     private List<HistorySecondUav> filterDatas(List<HistorySecondUav> datas) {
         //������������������
         List<HistorySecondUav> result = new ArrayList<>();
@@ -207,7 +227,7 @@
         datas.remove(0);
         for (HistorySecondUav data : datas) {
             Double distance = getDistance(tempData, data);
-            if(distance>filterDistance){
+            if (distance > filterDistance) {
                 result.add(data);
                 tempData = data;
             }
@@ -216,33 +236,98 @@
     }
 
     /**
-    * @Description: ���������������������������������
-            * @Param: [uav1, uav2]
-            * @return: java.lang.Double
-            * @Author: ���������
-            * @Date: 2021/9/13
-            */
-    private Double getDistance(HistorySecondUav uav1 , HistorySecondUav uav2){
+     * @Description: ���������������������������������
+     * @Param: [uav1, uav2]
+     * @return: java.lang.Double
+     * @Author: ���������
+     * @Date: 2021/9/13
+     */
+    private Double getDistance(HistorySecondUav uav1, HistorySecondUav uav2) {
         String value1 = uav1.getValue();
         String value2 = uav2.getValue();
-        Map<String,Object> value1Map = JSON.parseObject(value1,Map.class);
-        Map<String,Object> value2Map = JSON.parseObject(value2,Map.class);
+        Map<String, Object> value1Map = JSON.parseObject(value1, Map.class);
+        Map<String, Object> value2Map = JSON.parseObject(value2, Map.class);
         //������������1���������������������
-        Double longtitude1 = Double.valueOf((String)value1Map.get("flylon"));
-        Double latitude1 = Double.valueOf((String)value1Map.get("flylat"));
-        BigDecimal c1 = (BigDecimal)value1Map.get("flyhig");
+        Double longtitude1 = Double.valueOf((String) value1Map.get("flylon"));
+        Double latitude1 = Double.valueOf((String) value1Map.get("flylat"));
+        BigDecimal c1 = (BigDecimal) value1Map.get("flyhig");
         double height1 = c1.doubleValue();
         //������������2���������������������
-        Double longtitude2 = Double.valueOf((String)value2Map.get("flylon"));
-        Double latitude2 = Double.valueOf((String)value2Map.get("flylat"));
-        BigDecimal c2 = (BigDecimal)value2Map.get("flyhig");
+        Double longtitude2 = Double.valueOf((String) value2Map.get("flylon"));
+        Double latitude2 = Double.valueOf((String) value2Map.get("flylat"));
+        BigDecimal c2 = (BigDecimal) value2Map.get("flyhig");
         double height2 = c2.doubleValue();
         //������������������������������������
         Double planDistance = GeodesyUtils.getDistance(latitude1, longtitude1, latitude2, longtitude2);
         //������������������������������������������������������������
-        Double heightDsitance = Math.abs(MathUtils.sub(height2,height1));
-        Double Distance = Math.sqrt(MathUtils.mul(planDistance,planDistance)+MathUtils.mul(heightDsitance,heightDsitance));
+        Double heightDsitance = Math.abs(MathUtils.sub(height2, height1));
+        Double Distance = Math.sqrt(MathUtils.mul(planDistance, planDistance) + MathUtils.mul(heightDsitance, heightDsitance));
         return Distance;
     }
 
+    /**
+     * @Description: ������������������������������
+     * @Param: [datas]
+     * @return: java.util.List<com.moral.api.entity.HistorySecondUav>
+     * @Author: ���������
+     * @Date: 2021/9/16
+     */
+    private void unitConvert(List<HistorySecondUav> datas) {
+        //������������������
+        List<UnitConversion> unitConversions = redisTemplate.opsForList().range(RedisConstants.UNIT_CONVERSION, 0, -1);
+        //���������������������������
+        SpecialDevice specialDevice = (SpecialDevice) redisTemplate.opsForHash().get(RedisConstants.SPECIAL_DEVICE_INFO, datas.get(0).getMac());
+        //������������������������������������������
+        List<Sensor> sensors = specialDevice.getVersion().getSensors();
+        Map<String, Sensor> sensorsMap = new HashMap<>();
+        sensors.forEach(value -> sensorsMap.put(value.getCode(), value));
+        //������������������������������
+        for (HistorySecondUav data : datas) {
+            String valueStr = data.getValue();
+            ConcurrentHashMap<String, Object> valueMap = JSON.parseObject(valueStr, ConcurrentHashMap.class);
+            Set<Map.Entry<String, Object>> entries = valueMap.entrySet();
+            Iterator<Map.Entry<String, Object>> iterator = entries.iterator();
+            //���������������������������������
+            while(iterator.hasNext()){
+                Map.Entry<String, Object> entry = iterator.next();
+                String code = entry.getKey();
+                String value = String.valueOf(entry.getValue());
+                Sensor sensor = sensorsMap.get(code);
+                if (sensor == null) {//���������������������������������������
+                    valueMap.remove(code);
+                    continue;
+                }
+                String unit = sensor.getUnit();
+                String unitKey = sensor.getUnitKey();
+                String showUnit = sensor.getShowUnit();
+                String showUnitKey = sensor.getShowUnitKey();
+                //���������������������������������������������������������
+                if (showUnitKey.equals(unitKey)) {
+                    value += " " + unit;
+                } else {
+                    String formula = sensor.getFormula();
+                    //������sensor���������������������������������������������
+                    if (ObjectUtils.isEmpty(formula)) {
+                        for (UnitConversion unitConversion : unitConversions) {
+                            if (unitConversion.getOriginalUnitKey().equals(unitKey) && unitConversion.getTargetUnitKey().equals(showUnitKey))
+                                formula = unitConversion.getFormula();
+                        }
+                    }
+                    //������������������������������
+                    String resultValue = UnitConvertUtils.calculate((String) value, formula);
+                    if (resultValue != null) {
+                        resultValue += showUnit;
+                    } else {//���������������������������null���������������������������������������������������������������
+                        resultValue = value + unit;
+                    }
+                    value = resultValue;
+                }
+                //������������������������������
+                valueMap.put(code, value);
+            }
+            String value = JSON.toJSONString(valueMap);
+            data.setValue(value);
+        }
+    }
+
 }

--
Gitblit v1.8.0