From 35bedb798dc6a84d1dd316ebd882ef1edb9f87f3 Mon Sep 17 00:00:00 2001
From: lizijie <lzjiiie@163.com>
Date: Mon, 13 Sep 2021 16:24:30 +0800
Subject: [PATCH] 特殊设备添加guid字段,修改相关接口
---
screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java | 231 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 231 insertions(+), 0 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 c0da684..5cbea96 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,10 +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.math.BigDecimal;
+import java.text.SimpleDateFormat;
+import java.util.*;
+import java.util.function.Predicate;
/**
* <p>
@@ -17,4 +33,219 @@
@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<>();
+ //���������������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.select("DISTINCT batch");
+ queryWrapper.orderByDesc("batch");
+ //������������
+ List<HistorySecondUav> historySecondUavs = historySecondUavMapper.selectList(queryWrapper);
+ //������������Date������
+ List<Date> result = new ArrayList<>();
+ for (HistorySecondUav historySecondUav : historySecondUavs) {
+ result.add(historySecondUav.getBatch());
+ }
+ 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).get("name"));
+ //������������������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