From 3604b90f27205b63b559502fb181ce150c2d9a5d Mon Sep 17 00:00:00 2001 From: kaiyu <404897439@qq.com> Date: Tue, 14 Sep 2021 09:57:12 +0800 Subject: [PATCH] screen-api 修改获取特殊设备逻辑 --- screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java | 208 ++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 203 insertions(+), 5 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 81620b9..7b85f26 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,17 +1,26 @@ 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; import com.moral.api.mapper.HistorySecondUavMapper; +import com.moral.api.pojo.dto.uav.UAVQueryTimeSlotDTO; +import com.moral.api.pojo.form.uav.UAVQueryTimeSlotForm; import com.moral.api.service.HistorySecondUavService; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +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.util.ArrayList; -import java.util.Date; -import java.util.List; +import java.math.BigDecimal; +import java.text.SimpleDateFormat; +import java.util.*; +import java.util.function.Predicate; /** * <p> @@ -24,20 +33,37 @@ @Service public class HistorySecondUavServiceImpl extends ServiceImpl<HistorySecondUavMapper, HistorySecondUav> implements HistorySecondUavService { + /* + * ������������������ + * */ + private Double filterDistance = 2d; + @Autowired HistorySecondUavMapper historySecondUavMapper; + @Autowired + OrganizationService organizationService; + @Autowired + SpecialDeviceService specialDeviceService; @Override public List<Date> queryDate(Integer organizationId) { //������������������ QueryWrapper<HistorySecondUav> queryWrapper = new QueryWrapper<>(); - queryWrapper.eq("organization_id",organizationId); + //���������������id + List<Organization> children = organizationService.getChildrenOrganizationsById(organizationId); + List<Integer> childrenId = new ArrayList<>(); + for (Organization child : children) { + childrenId.add(child.getId()); + } + childrenId.add(organizationId); + 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"); + queryWrapper.orderByDesc("batch"); //������������ List<HistorySecondUav> historySecondUavs = historySecondUavMapper.selectList(queryWrapper); //������������Date������ @@ -47,4 +73,176 @@ } return result; } + + @Override + public List<UAVQueryTimeSlotDTO> queryTimeSlot(UAVQueryTimeSlotForm form) { + //������ + Integer organizationId = form.getOrganizationId(); + Date startDate = form.getStartDate(); + Date endDate = form.getEndDate(); + QueryWrapper<HistorySecondUav> wrapper = new QueryWrapper<>(); + //���������������id + List<Organization> children = organizationService.getChildrenOrganizationsById(organizationId); + List<Integer> childrenId = new ArrayList<>(); + for (Organization child : children) { + childrenId.add(child.getId()); + } + childrenId.add(organizationId); + wrapper.in("organization_id", childrenId); + //������������batch������������������������������������������������ + 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 + for (HistorySecondUav historySecondUav : historySecondUavs) { + //������batch��������������������� + List<HistorySecondUav> list = batchMap.get(DateUtils.dateToDateString(historySecondUav.getBatch(), "yyyy-MM-dd HH:mm:ss")); + if (list != null) { + list.add(historySecondUav); + } else { + ArrayList<HistorySecondUav> newList = new ArrayList<>(); + newList.add(historySecondUav); + 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) + return true; + return false; + } + }); + //������mac������������ + Map<String, List<Map<String, List<HistorySecondUav>>>> macBatchMap = new LinkedHashMap<>();//key���mac + //������batchMap���mac���������������������macBatchMap���key���batch���������map���������������������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); + maps.add(map); + } 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); + } + }); + //������������������ + List<UAVQueryTimeSlotDTO> dtos = new ArrayList<>(); + macBatchMap.forEach((key, value) -> { + UAVQueryTimeSlotDTO dto = new UAVQueryTimeSlotDTO(); + List<Map<String, Object>> timeSlots = new ArrayList<>(); + dto.setMac(key); + //������mac������������������ + dto.setName((String) specialDeviceService.getSpecialDeviceMapByMac(key).getName()); + //������������������batch + value.forEach(listValue -> { + listValue.forEach((mKey, mValue) -> { + Date slotStartDate = mValue.get(0).getTime(); + 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; + } + + @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