From a9cc2343ceaad3e99dc25eb036dc99aeded279a6 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Fri, 20 Oct 2023 09:26:36 +0800
Subject: [PATCH] Merge branch 'dev' of http://blit.7drlb.com:8888/r/moral into wb

---
 screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java |   66 ++++++++++++++++++++++++++++++++-
 1 files changed, 64 insertions(+), 2 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 cdca09d..627b26a 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
@@ -1,6 +1,7 @@
 package com.moral.api.service.impl;
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.moral.api.entity.*;
 import com.moral.api.mapper.HistorySecondUavMapper;
@@ -10,18 +11,17 @@
 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 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;
@@ -162,6 +162,7 @@
                     dateMap.put("startTime", slotStartDate);
                     dateMap.put("endTime", slotEndDate);
                     dateMap.put("batch", mKey);
+                    dateMap.put("total",mValue.size());
                     timeSlots.add(dateMap);
                 });
             });
@@ -185,6 +186,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"));
             if (height < lowestHeight)
@@ -195,6 +200,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"));
             //������������������������
@@ -206,6 +215,9 @@
         }
         //���������������������,���������������������������������2���������
         datas = filterDatas(datas);
+        if (datas.size()<2){
+            return null;
+        }
         //������������
         unitConvert(datas);
         return datas;
@@ -227,6 +239,9 @@
         datas.remove(0);
         for (HistorySecondUav data : datas) {
             Double distance = getDistance(tempData, data);
+            if (distance==null){
+                continue;
+            }
             if (distance > filterDistance) {
                 result.add(data);
                 tempData = data;
@@ -247,6 +262,11 @@
         String value2 = uav2.getValue();
         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"));
@@ -330,4 +350,46 @@
         }
     }
 
+    @Override
+    public boolean UAVTest(BigDecimal lat, BigDecimal lon, String batch) {
+        List<HistorySecondUav> list = new ArrayList<>();
+
+        QueryWrapper<HistorySecondUav> wrapper = new QueryWrapper<>();
+        wrapper.eq("batch", batch);
+        wrapper.select("value,mac,time,organization_id");
+        wrapper.orderByAsc("time");
+        List<HistorySecondUav> datas = historySecondUavMapper.selectList(wrapper);
+        Date time =DateUtils.addDays(datas.get(2).getTime(),0);
+        //String bat = "2023-08-08 14:42:20";
+        for(HistorySecondUav g : datas){
+            HistorySecondUav historySecondUav = new HistorySecondUav();
+            historySecondUav.setTime(DateUtils.addDays(g.getTime(),0));
+            historySecondUav.setMac(g.getMac());
+            historySecondUav.setBatch(time);
+            historySecondUav.setOrganizationId(g.getOrganizationId());
+            Map<String, Object> data = JSON.parseObject(g.getValue(), Map.class);
+            Map<String, Object> dataResult = new HashMap<>();
+            dataResult = data;
+            dataResult.put("flylat",Objects.isNull(data.get("flylat"))||data.get("flylat").toString().equals("0")?0d:Double.parseDouble(String.format("%.10f",Double.parseDouble(data.get("flylat").toString())+lat.doubleValue())));
+            dataResult.put("flylon",Objects.isNull(data.get("flylon"))||data.get("flylon").toString().equals("0")?0d:Double.parseDouble(String.format("%.10f",Double.parseDouble(data.get("flylon").toString())+lon.doubleValue())));
+            /*if(Objects.nonNull(data.get("a21026"))&& !data.get("a21026").toString().equals("0")){
+                Double a21026D = Double.parseDouble(data.get("a21026").toString());
+                if( a21026D>15){
+                    a21026D = a21026D -10;
+                }
+                dataResult.put("a21026",Double.parseDouble(String.format("%.4f",a21026D)));
+            }
+            if(Objects.nonNull(data.get("a21004"))&& !data.get("a21004").toString().equals("0")){
+                Double a21024D = Double.parseDouble(data.get("a21004").toString());
+                if( a21024D>100){
+                    a21024D = a21024D -100;
+                }
+                dataResult.put("a21004",Double.parseDouble(String.format("%.4f",a21024D)));
+            }*/
+            historySecondUav.setValue(JSONObject.toJSONString(dataResult));
+            list.add(historySecondUav);
+        }
+        this.saveBatch(list);
+        return true;
+    }
 }

--
Gitblit v1.8.0