From 48cde94624bec615f9df9a481339d5b71be311e5 Mon Sep 17 00:00:00 2001
From: jpy <812110275@qq.com>
Date: Sat, 27 May 2023 17:39:23 +0800
Subject: [PATCH] test

---
 screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java |  155 ++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 127 insertions(+), 28 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 df440a9..fd65fa6 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,9 +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.SpecialDevice;
+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;
@@ -12,15 +10,19 @@
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.moral.api.service.OrganizationService;
 import com.moral.api.service.SpecialDeviceService;
+import com.moral.api.utils.UnitConvertUtils;
+import com.moral.constant.RedisConstants;
 import com.moral.util.DateUtils;
 import com.moral.util.GeodesyUtils;
 import com.moral.util.MathUtils;
 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;
 
 /**
@@ -45,6 +47,8 @@
     OrganizationService organizationService;
     @Autowired
     SpecialDeviceService specialDeviceService;
+    @Autowired
+    RedisTemplate redisTemplate;
 
     @Override
     public List<Date> queryDate(Integer organizationId) {
@@ -144,13 +148,14 @@
             dto.setMac(key);
             //������mac������������������
             SpecialDevice specialDevice = specialDeviceService.getSpecialDeviceMapByMac(key);
-            if(specialDevice==null)
+            //������������������������������������
+            if (specialDevice == null)
                 return;
-            dto.setName((String) specialDeviceService.getSpecialDeviceMapByMac(key).getName());
+            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);
@@ -172,13 +177,17 @@
         //������������
         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;
         for (HistorySecondUav data : datas) {
             String value = data.getValue();
             Map<String, Object> valueMap = JSON.parseObject(value, Map.class);
+            //������value���������������������
+            if (!valueMap.containsKey("flyhig")|| !valueMap.containsKey("flylat")|| !valueMap.containsKey("flylon")){
+                continue;
+            }
             //������������
             Double height = Double.valueOf((String) valueMap.get("flyhig"));
             if (height < lowestHeight)
@@ -189,6 +198,10 @@
         for (HistorySecondUav data : datas) {
             String value = data.getValue();
             Map<String, Object> valueMap = JSON.parseObject(value, Map.class);
+            //������value���������������������
+            if (!valueMap.containsKey("flyhig")|| !valueMap.containsKey("flylat")|| !valueMap.containsKey("flylon")){
+                continue;
+            }
             //������������
             Double height = Double.valueOf((String) valueMap.get("flyhig"));
             //������������������������
@@ -198,10 +211,23 @@
             String newValue = JSON.toJSONString(valueMap);
             data.setValue(newValue);
         }
-        //���������������������,���������������������������������3���������
-        return filterDatas(datas);
+        //���������������������,���������������������������������2���������
+        datas = filterDatas(datas);
+        if (datas.size()<2){
+            return null;
+        }
+        //������������
+        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<>();
@@ -211,7 +237,10 @@
         datas.remove(0);
         for (HistorySecondUav data : datas) {
             Double distance = getDistance(tempData, data);
-            if(distance>filterDistance){
+            if (distance==null){
+                continue;
+            }
+            if (distance > filterDistance) {
                 result.add(data);
                 tempData = data;
             }
@@ -220,33 +249,103 @@
     }
 
     /**
-    * @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);
+        //���������������������������������������������
+        if (!value1Map.containsKey("flylon")||!value1Map.containsKey("flylat")||!value1Map.containsKey("flyhig")||
+                !value2Map.containsKey("flylon")||!value2Map.containsKey("flylat")||!value2Map.containsKey("flyhig")){
+            return null;
+        }
         //������������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