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 +++++++++++++++++++++++++------
screen-api/src/main/java/com/moral/api/service/HistorySecondUavService.java | 9 +
screen-common/src/main/java/com/moral/util/MathUtils.java | 53 ++++++++++
screen-api/src/main/java/com/moral/api/controller/MonitorPointController.java | 7 +
screen-api/src/main/java/com/moral/api/pojo/dto/uav/UAVQueryTimeSlotDTO.java | 3
screen-api/src/main/java/com/moral/api/pojo/vo/uav/UAVQueryTimeSlotVOs.java | 16 ++-
screen-api/src/main/java/com/moral/api/controller/UAVController.java | 33 +++++-
7 files changed, 234 insertions(+), 45 deletions(-)
diff --git a/screen-api/src/main/java/com/moral/api/controller/MonitorPointController.java b/screen-api/src/main/java/com/moral/api/controller/MonitorPointController.java
index 7b5ae9c..2540199 100644
--- a/screen-api/src/main/java/com/moral/api/controller/MonitorPointController.java
+++ b/screen-api/src/main/java/com/moral/api/controller/MonitorPointController.java
@@ -62,6 +62,13 @@
return new ResultMessage(ResponseCodeEnum.SUCCESS.getCode(), ResponseCodeEnum.SUCCESS.getMsg(), vo);
}
+ /**
+ * @Description: ���������������������
+ * @Param: [regionCode]
+ * @return: com.moral.constant.ResultMessage
+ * @Author: ���������
+ * @Date: 2021/9/9
+ */
@GetMapping("queryStateControlStation")
public ResultMessage queryStateControlStation(Integer regionCode) {
diff --git a/screen-api/src/main/java/com/moral/api/controller/UAVController.java b/screen-api/src/main/java/com/moral/api/controller/UAVController.java
index 0342ed5..787b4f6 100644
--- a/screen-api/src/main/java/com/moral/api/controller/UAVController.java
+++ b/screen-api/src/main/java/com/moral/api/controller/UAVController.java
@@ -36,20 +36,30 @@
public class UAVController {
@Autowired
- HistorySecondUavMapper historySecondUavMapper;
- @Autowired
HistorySecondUavService historySecondUavService;
+ @Autowired
+ HistorySecondUavMapper historySecondUavMapper;
+
/**
- * @Description: ������������id���mac���������������������������������
- * @Param: []
+ * @Description: ������������������������������������������
+ * @Param: [batch]
* @return: com.moral.constant.ResultMessage
* @Author: ���������
- * @Date: 2021/8/31
+ * @Date: 2021/9/13
*/
- @RequestMapping("query")
- public ResultMessage query(){
- List<HistorySecondUav> historySecondUavs = historySecondUavMapper.selectList(new QueryWrapper<>());
+ @RequestMapping("queryDataByBatch")
+ public ResultMessage queryDataByBatch(String batch){
+ List<HistorySecondUav> historySecondUavs = historySecondUavService.queryDataByBatch(batch);
return new ResultMessage(ResponseCodeEnum.SUCCESS.getCode(), ResponseCodeEnum.SUCCESS.getMsg(),historySecondUavs);
+ }
+
+ @RequestMapping("test")
+ public ResultMessage test(String batch){
+ QueryWrapper<HistorySecondUav> wrapper = new QueryWrapper();
+ wrapper.select("value");
+ wrapper.eq("batch", "2021-07-08 01:00:00");
+ List<HistorySecondUav> datas = historySecondUavMapper.selectList(wrapper);
+ return new ResultMessage(ResponseCodeEnum.SUCCESS.getCode(), ResponseCodeEnum.SUCCESS.getMsg(),datas);
}
@@ -71,6 +81,13 @@
}
+ /**
+ * @Description: ���������������������������������������������
+ * @Param: [form]
+ * @return: com.moral.constant.ResultMessage
+ * @Author: ���������
+ * @Date: 2021/9/13
+ */
@RequestMapping("queryTimeSlot")
public ResultMessage queryTimeSlot(UAVQueryTimeSlotForm form){
//������������������������
diff --git a/screen-api/src/main/java/com/moral/api/pojo/dto/uav/UAVQueryTimeSlotDTO.java b/screen-api/src/main/java/com/moral/api/pojo/dto/uav/UAVQueryTimeSlotDTO.java
index 80c0087..c4dc110 100644
--- a/screen-api/src/main/java/com/moral/api/pojo/dto/uav/UAVQueryTimeSlotDTO.java
+++ b/screen-api/src/main/java/com/moral/api/pojo/dto/uav/UAVQueryTimeSlotDTO.java
@@ -30,6 +30,7 @@
* ������������������������
* map������������������key���startTime
* ���������������key���endTime
+ * ������������batch
* */
- private List<Map<String,Date>> timeSlot;
+ private List<Map<String,Object>> timeSlot;
}
diff --git a/screen-api/src/main/java/com/moral/api/pojo/vo/uav/UAVQueryTimeSlotVOs.java b/screen-api/src/main/java/com/moral/api/pojo/vo/uav/UAVQueryTimeSlotVOs.java
index a713d11..4ff8a79 100644
--- a/screen-api/src/main/java/com/moral/api/pojo/vo/uav/UAVQueryTimeSlotVOs.java
+++ b/screen-api/src/main/java/com/moral/api/pojo/vo/uav/UAVQueryTimeSlotVOs.java
@@ -26,13 +26,17 @@
vo.setMac(dto.getMac());
vo.setName(dto.getName());
List<Map<String,String>> timeSlotVo = new ArrayList<>();
- List<Map<String, Date>> timeSlot = dto.getTimeSlot();
- for (Map<String, Date> map : timeSlot) {
+ List<Map<String, Object>> timeSlot = dto.getTimeSlot();
+ for (Map<String, Object> map : timeSlot) {
Map<String,String> newMap = new LinkedHashMap<>();
- map.forEach((key,value)->{
- String dateStr = DateUtils.dateToDateString(value, "yyyy-MM-dd HH:mm:ss");
- newMap.put(key,dateStr);
- });
+ //������������������
+ Date startDate = (Date) map.get("startTime");
+ newMap.put("startTime",DateUtils.dateToDateString(startDate, "yyyy-MM-dd HH:mm:ss"));
+ //������������������
+ Date endDate = (Date) map.get("endTime");
+ newMap.put("endTime",DateUtils.dateToDateString(endDate, "yyyy-MM-dd HH:mm:ss"));
+ //������batch������
+ newMap.put("batch", (String) map.get("batch"));
timeSlotVo.add(newMap);
}
vo.setTimeSlot(timeSlotVo);
diff --git a/screen-api/src/main/java/com/moral/api/service/HistorySecondUavService.java b/screen-api/src/main/java/com/moral/api/service/HistorySecondUavService.java
index 4b663ca..9c5a01c 100644
--- a/screen-api/src/main/java/com/moral/api/service/HistorySecondUavService.java
+++ b/screen-api/src/main/java/com/moral/api/service/HistorySecondUavService.java
@@ -36,5 +36,14 @@
*/
List<UAVQueryTimeSlotDTO> queryTimeSlot(UAVQueryTimeSlotForm form);
+ /**
+ * @Description: ������������������������������������
+ * @Param: [batch]
+ * @return: java.util.List<com.moral.api.entity.HistorySecondUav>
+ * @Author: ���������
+ * @Date: 2021/9/13
+ */
+ List<HistorySecondUav> queryDataByBatch(String batch);
+
}
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;
+ }
+
+
+
+
}
diff --git a/screen-common/src/main/java/com/moral/util/MathUtils.java b/screen-common/src/main/java/com/moral/util/MathUtils.java
new file mode 100644
index 0000000..f067ff7
--- /dev/null
+++ b/screen-common/src/main/java/com/moral/util/MathUtils.java
@@ -0,0 +1,53 @@
+package com.moral.util;
+
+import java.math.BigDecimal;
+
+/**
+ * @ClassName MathUtils
+ * @Description ���������������
+ * @Author ���������
+ * @Date 2021/9/13 9:54
+ * @Version TODO
+ **/
+public class MathUtils {
+
+ /**
+ * @Description: ������double������������
+ * @Param: [v1, v2]
+ * @return: double
+ * @Author: ���������
+ * @Date: 2021/9/13
+ */
+ public static double add(double v1, double v2) {
+ BigDecimal b1 = new BigDecimal(Double.toString(v1));
+ BigDecimal b2 = new BigDecimal(Double.toString(v2));
+ return b1.add(b2).doubleValue();
+ }
+
+
+ /**
+ * @Description: ������double������������
+ * @Param: [v1, v2]
+ * @return: double
+ * @Author: ���������
+ * @Date: 2021/9/13
+ */
+ public static double sub(double v1, double v2) {
+ BigDecimal b1 = new BigDecimal(Double.toString(v1));
+ BigDecimal b2 = new BigDecimal(Double.toString(v2));
+ return b1.subtract(b2).doubleValue();
+ }
+
+ /**
+ * @Description: ������double������������
+ * @Param: [v1, v2]
+ * @return: double
+ * @Author: ���������
+ * @Date: 2021/9/13
+ */
+ public static double mul(double v1, double v2) {
+ BigDecimal b1 = new BigDecimal(Double.toString(v1));
+ BigDecimal b2 = new BigDecimal(Double.toString(v2));
+ return b1.multiply(b2).doubleValue();
+ }
+}
--
Gitblit v1.8.0