From 10d4b885a9b2af2a38bb03249d7547283f948197 Mon Sep 17 00:00:00 2001 From: kaiyu <404897439@qq.com> Date: Mon, 13 Sep 2021 13:15:18 +0800 Subject: [PATCH] screen-api 增加获取无人机数据接口 --- screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java | 158 ++++++++++++++++++++++++++++++++++++++++++---------- 1 files changed, 128 insertions(+), 30 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 1565dc3..ed2433a 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,5 +1,6 @@ package com.moral.api.service.impl; +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; @@ -11,9 +12,13 @@ import com.moral.api.service.OrganizationService; import com.moral.api.service.SpecialDeviceService; 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.stereotype.Service; +import java.math.BigDecimal; +import java.text.SimpleDateFormat; import java.util.*; import java.util.function.Predicate; @@ -27,6 +32,11 @@ */ @Service public class HistorySecondUavServiceImpl extends ServiceImpl<HistorySecondUavMapper, HistorySecondUav> implements HistorySecondUavService { + + /* + * ������������������ + * */ + private Double filterDistance = 3d; @Autowired HistorySecondUavMapper historySecondUavMapper; @@ -46,11 +56,11 @@ childrenId.add(child.getId()); } childrenId.add(organizationId); - queryWrapper.in("organization_id",childrenId); + queryWrapper.in("organization_id", childrenId); //���������������������������180��� Date endDate = new Date(); Date startDate = DateUtils.addDays(endDate, -180); - queryWrapper.between("batch",startDate,endDate); + queryWrapper.between("batch", startDate, endDate); //������������������ queryWrapper.select("DISTINCT batch"); //������������ @@ -77,76 +87,164 @@ childrenId.add(child.getId()); } childrenId.add(organizationId); - wrapper.in("organization_id",childrenId); + wrapper.in("organization_id", childrenId); //������������batch������������������������������������������������ - wrapper.between("batch",startDate,endDate); + wrapper.between("batch", startDate, endDate); //������������������ wrapper.select("mac,time,batch"); //������������ List<HistorySecondUav> historySecondUavs = historySecondUavMapper.selectList(wrapper); //������batch������������ - Map<String,List<HistorySecondUav>> batchMap = new LinkedHashMap<>();//key���batch���string + Map<String, List<HistorySecondUav>> batchMap = new LinkedHashMap<>();//key���batch���string for (HistorySecondUav historySecondUav : historySecondUavs) { //������batch��������������������� - List<HistorySecondUav> list = batchMap.get(historySecondUav.getBatch().toString()); - if(list!=null){ + List<HistorySecondUav> list = batchMap.get(DateUtils.dateToDateString(historySecondUav.getBatch(), "yyyy-MM-dd HH:mm:ss")); + if (list != null) { list.add(historySecondUav); - }else{ + } else { ArrayList<HistorySecondUav> newList = new ArrayList<>(); newList.add(historySecondUav); - batchMap.put(historySecondUav.getBatch().toString(),newList); + batchMap.put(DateUtils.dateToDateString(historySecondUav.getBatch(), "yyyy-MM-dd HH:mm:ss"), newList); } } //������������30������������������ batchMap.values().removeIf(new Predicate<List<HistorySecondUav>>() { @Override public boolean test(List<HistorySecondUav> historySecondUavs) { - if(historySecondUavs.size()<=30) + if (historySecondUavs.size() <= 30) return true; return false; } }); //������mac������������ - Map<String,List<Map<String,List<HistorySecondUav>>>> macBatchMap = new LinkedHashMap<>();//key���mac + Map<String, List<Map<String, List<HistorySecondUav>>>> macBatchMap = new LinkedHashMap<>();//key���mac //������batchMap���mac���������������������macBatchMap���key���batch���������map���������������������value - batchMap.forEach((key,value)->{ + batchMap.forEach((key, value) -> { String mac = value.get(0).getMac(); List<Map<String, List<HistorySecondUav>>> maps = macBatchMap.get(mac); - if(maps!=null){ - Map<String,List<HistorySecondUav>> map = new LinkedHashMap<>(); - map.put(key,value); + if (maps != null) { + Map<String, List<HistorySecondUav>> map = new LinkedHashMap<>(); + map.put(key, value); maps.add(map); - }else{ - List<Map<String,List<HistorySecondUav>>> list = new ArrayList<>(); - Map<String,List<HistorySecondUav>> map = new LinkedHashMap<>(); - map.put(key,value); + } else { + List<Map<String, List<HistorySecondUav>>> list = new ArrayList<>(); + Map<String, List<HistorySecondUav>> map = new LinkedHashMap<>(); + map.put(key, value); list.add(map); - macBatchMap.put(value.get(0).getMac(),list); + macBatchMap.put(value.get(0).getMac(), list); } }); //������������������ List<UAVQueryTimeSlotDTO> dtos = new ArrayList<>(); - macBatchMap.forEach((key,value)->{ + macBatchMap.forEach((key, value) -> { UAVQueryTimeSlotDTO dto = new UAVQueryTimeSlotDTO(); - List<Map<String,Date>> timeSlots = new ArrayList<>(); + List<Map<String, Object>> timeSlots = new ArrayList<>(); dto.setMac(key); //������mac������������������ dto.setName((String) specialDeviceService.getSpecialDeviceMapByMac(key).get("name")); - //��������������� - value.forEach(listValue->{ - listValue.forEach((mKey,mValue)->{ + //������������������batch + value.forEach(listValue -> { + listValue.forEach((mKey, mValue) -> { Date slotStartDate = mValue.get(0).getTime(); - Date slotEndDate = mValue.get(mValue.size()-1).getTime(); - Map<String,Date> dateMap = new HashMap<>(); - dateMap.put("startTime",slotStartDate); - dateMap.put("endTime",slotEndDate); + Date slotEndDate = mValue.get(mValue.size() - 1).getTime(); + Map<String, Object> dateMap = new HashMap<>(); + dateMap.put("startTime", slotStartDate); + dateMap.put("endTime", slotEndDate); + dateMap.put("batch", mKey); timeSlots.add(dateMap); }); }); dto.setTimeSlot(timeSlots); dtos.add(dto); }); - return dtos; + return dtos; } + @Override + public List<HistorySecondUav> queryDataByBatch(String batch) { + //batch������������ + Date batchDate = DateUtils.getDate(batch, "yyyy-MM-dd HH:mm:ss"); + //������������ + QueryWrapper<HistorySecondUav> wrapper = new QueryWrapper<>(); + wrapper.eq("batch", batchDate); + wrapper.select("value"); + 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); + //������������ + Double height = Double.valueOf((String) valueMap.get("flyhig")); + if (height < lowestHeight) + lowestHeight = height; + } + //������������������������������������������������������������������0������������������������������������������������������������������������ + lowestHeight = Math.abs(lowestHeight); + for (HistorySecondUav data : datas) { + String value = data.getValue(); + Map<String, Object> valueMap = JSON.parseObject(value, Map.class); + //������������ + Double height = Double.valueOf((String) valueMap.get("flyhig")); + //������������������������ + height = MathUtils.add(height, lowestHeight); + //������������������ + valueMap.put("flyhig", height); + String newValue = JSON.toJSONString(valueMap); + data.setValue(newValue); + } + //���������������������,���������������������������������3��������� + return filterDatas(datas); + } + + private List<HistorySecondUav> filterDatas(List<HistorySecondUav> datas) { + //������������������ + List<HistorySecondUav> result = new ArrayList<>(); + //������������������������������������������ + HistorySecondUav tempData = datas.get(0); + result.add(tempData); + datas.remove(0); + for (HistorySecondUav data : datas) { + Double distance = getDistance(tempData, data); + if(distance>filterDistance){ + result.add(data); + tempData = data; + } + } + return result; + } + + /** + * @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); + //������������1��������������������� + 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 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)); + return Distance; + } + + + + } -- Gitblit v1.8.0