~chenjialiang/moral.git

			@@ -1,17 +1,27 @@
			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.entity.SpecialDevice;
			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 +34,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 +74,179 @@
			}
			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查询设备名称
			SpecialDevice specialDevice = specialDeviceService.getSpecialDeviceMapByMac(key);
			if(specialDevice==null)
			return;
			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;
			}

			}