From d99988283de685d763df9460e180bdfcc686ac0b Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Thu, 16 Sep 2021 15:11:41 +0800
Subject: [PATCH] screen-api 获取无人机数据添加单位
---
screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java | 134 +++++++++++++++++++++++++++------
screen-api/src/main/java/com/moral/api/entity/SpecialDevice.java | 6 +
screen-api/src/main/java/com/moral/api/controller/UAVController.java | 5 +
screen-api/src/main/java/com/moral/api/pojo/vo/uav/HistorySecondUavVO.java | 30 +++++++
screen-api/src/main/java/com/moral/api/pojo/vo/uav/HistorySecondUavVOs.java | 35 ++++++++
5 files changed, 183 insertions(+), 27 deletions(-)
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 787b4f6..73c119e 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
@@ -5,6 +5,7 @@
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.pojo.vo.uav.HistorySecondUavVOs;
import com.moral.api.pojo.vo.uav.UAVQueryDateVO;
import com.moral.api.pojo.vo.uav.UAVQueryTimeSlotVO;
import com.moral.api.pojo.vo.uav.UAVQueryTimeSlotVOs;
@@ -50,7 +51,9 @@
@RequestMapping("queryDataByBatch")
public ResultMessage queryDataByBatch(String batch){
List<HistorySecondUav> historySecondUavs = historySecondUavService.queryDataByBatch(batch);
- return new ResultMessage(ResponseCodeEnum.SUCCESS.getCode(), ResponseCodeEnum.SUCCESS.getMsg(),historySecondUavs);
+ //������������������������
+ HistorySecondUavVOs vo = HistorySecondUavVOs.convert(historySecondUavs);
+ return new ResultMessage(ResponseCodeEnum.SUCCESS.getCode(), ResponseCodeEnum.SUCCESS.getMsg(),vo);
}
@RequestMapping("test")
diff --git a/screen-api/src/main/java/com/moral/api/entity/SpecialDevice.java b/screen-api/src/main/java/com/moral/api/entity/SpecialDevice.java
index 99df6fb..1e8fbde 100644
--- a/screen-api/src/main/java/com/moral/api/entity/SpecialDevice.java
+++ b/screen-api/src/main/java/com/moral/api/entity/SpecialDevice.java
@@ -24,6 +24,7 @@
private static final long serialVersionUID = 1L;
+
/**
* id
*/
@@ -41,6 +42,11 @@
private String mac;
/**
+ * ������������id
+ */
+ private String guid;
+
+ /**
* ���������id���������������������������������manage_account
*/
private String operateIds;
diff --git a/screen-api/src/main/java/com/moral/api/pojo/vo/uav/HistorySecondUavVO.java b/screen-api/src/main/java/com/moral/api/pojo/vo/uav/HistorySecondUavVO.java
new file mode 100644
index 0000000..cbfc7dd
--- /dev/null
+++ b/screen-api/src/main/java/com/moral/api/pojo/vo/uav/HistorySecondUavVO.java
@@ -0,0 +1,30 @@
+package com.moral.api.pojo.vo.uav;
+
+import lombok.Data;
+
+/**
+ * @ClassName HistorySecondUavVO
+ * @Description TODO
+ * @Author ���������
+ * @Date 2021/9/16 15:03
+ * @Version TODO
+ **/
+@Data
+public class HistorySecondUavVO {
+
+ /*
+ * ������������������������mac
+ * */
+ private String mac;
+
+ /*
+ * ���������������
+ * */
+ private String time;
+
+ /*
+ * ���������
+ * */
+ private String value;
+
+}
diff --git a/screen-api/src/main/java/com/moral/api/pojo/vo/uav/HistorySecondUavVOs.java b/screen-api/src/main/java/com/moral/api/pojo/vo/uav/HistorySecondUavVOs.java
new file mode 100644
index 0000000..3c52d12
--- /dev/null
+++ b/screen-api/src/main/java/com/moral/api/pojo/vo/uav/HistorySecondUavVOs.java
@@ -0,0 +1,35 @@
+package com.moral.api.pojo.vo.uav;
+
+import com.moral.api.entity.HistorySecondUav;
+import com.moral.util.DateUtils;
+import lombok.Data;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @ClassName HistorySecondUavVOs
+ * @Description TODO
+ * @Author ���������
+ * @Date 2021/9/16 15:05
+ * @Version TODO
+ **/
+@Data
+public class HistorySecondUavVOs {
+
+ List<HistorySecondUavVO> vos;
+
+ public static HistorySecondUavVOs convert(List<HistorySecondUav> datas){
+ HistorySecondUavVOs vos = new HistorySecondUavVOs();
+ List<HistorySecondUavVO> list = new ArrayList<>();
+ for (HistorySecondUav data : datas) {
+ HistorySecondUavVO vo = new HistorySecondUavVO();
+ vo.setMac(data.getMac());
+ vo.setTime(DateUtils.dateToDateString(data.getTime(),"yyyy-MM-dd HH:mm:ss"));
+ vo.setValue(data.getValue());
+ list.add(vo);
+ }
+ vos.setVos(list);
+ return vos;
+ }
+}
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 86c5e57..79340ac 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
@@ -2,9 +2,7 @@
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.entity.*;
import com.moral.api.mapper.HistorySecondUavMapper;
import com.moral.api.pojo.dto.uav.UAVQueryTimeSlotDTO;
import com.moral.api.pojo.form.uav.UAVQueryTimeSlotForm;
@@ -12,15 +10,20 @@
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.moral.api.service.OrganizationService;
import com.moral.api.service.SpecialDeviceService;
+import com.moral.constant.RedisConstants;
import com.moral.util.DateUtils;
import com.moral.util.GeodesyUtils;
import com.moral.util.MathUtils;
+import com.moral.util.UnitConvertUtils;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
+import org.springframework.util.ObjectUtils;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
import java.util.function.Predicate;
/**
@@ -45,6 +48,8 @@
OrganizationService organizationService;
@Autowired
SpecialDeviceService specialDeviceService;
+ @Autowired
+ RedisTemplate redisTemplate;
@Override
public List<Date> queryDate(Integer organizationId) {
@@ -144,13 +149,14 @@
dto.setMac(key);
//������mac������������������
SpecialDevice specialDevice = specialDeviceService.getSpecialDeviceMapByMac(key);
- if(specialDevice==null)
+ //������������������������������������
+ if (specialDevice == null)
return;
dto.setName(specialDevice.getName());
//������������������batch
value.forEach(listValue -> {
listValue.forEach((mKey, mValue) -> {
- Date slotStartDate = mValue. get(0).getTime();
+ Date slotStartDate = mValue.get(0).getTime();
Date slotEndDate = mValue.get(mValue.size() - 1).getTime();
Map<String, Object> dateMap = new HashMap<>();
dateMap.put("startTime", slotStartDate);
@@ -172,7 +178,7 @@
//������������
QueryWrapper<HistorySecondUav> wrapper = new QueryWrapper<>();
wrapper.eq("batch", batchDate);
- wrapper.select("value");
+ wrapper.select("value,mac,time");
List<HistorySecondUav> datas = historySecondUavMapper.selectList(wrapper);
//������������������������������������
Double lowestHeight = 0d;
@@ -198,10 +204,20 @@
String newValue = JSON.toJSONString(valueMap);
data.setValue(newValue);
}
- //���������������������,���������������������������������3���������
- return filterDatas(datas);
+ //���������������������,���������������������������������2���������
+ datas = filterDatas(datas);
+ //������������
+ unitConvert(datas);
+ return datas;
}
+ /**
+ * @Description: ������������
+ * @Param: [datas]
+ * @return: java.util.List<com.moral.api.entity.HistorySecondUav>
+ * @Author: ���������
+ * @Date: 2021/9/16
+ */
private List<HistorySecondUav> filterDatas(List<HistorySecondUav> datas) {
//������������������
List<HistorySecondUav> result = new ArrayList<>();
@@ -211,7 +227,7 @@
datas.remove(0);
for (HistorySecondUav data : datas) {
Double distance = getDistance(tempData, data);
- if(distance>filterDistance){
+ if (distance > filterDistance) {
result.add(data);
tempData = data;
}
@@ -220,33 +236,99 @@
}
/**
- * @Description: ���������������������������������
- * @Param: [uav1, uav2]
- * @return: java.lang.Double
- * @Author: ���������
- * @Date: 2021/9/13
- */
- private Double getDistance(HistorySecondUav uav1 , HistorySecondUav uav2){
+ * @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);
+ 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 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 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));
+ Double heightDsitance = Math.abs(MathUtils.sub(height2, height1));
+ Double Distance = Math.sqrt(MathUtils.mul(planDistance, planDistance) + MathUtils.mul(heightDsitance, heightDsitance));
return Distance;
}
+ /**
+ * @Description: ������������������������������
+ * @Param: [datas]
+ * @return: java.util.List<com.moral.api.entity.HistorySecondUav>
+ * @Author: ���������
+ * @Date: 2021/9/16
+ */
+ private void unitConvert(List<HistorySecondUav> datas) {
+ //������������������
+ List<UnitConversion> unitConversions = redisTemplate.opsForList().range(RedisConstants.UNIT_CONVERSION, 0, -1);
+ //���������������������������
+ SpecialDevice specialDevice = (SpecialDevice) redisTemplate.opsForHash().get(RedisConstants.SPECIAL_DEVICE_INFO, datas.get(0).getMac());
+ //������������������������������������������
+ List<Sensor> sensors = specialDevice.getVersion().getSensors();
+ Map<String, Sensor> sensorsMap = new HashMap<>();
+ sensors.forEach(value -> sensorsMap.put(value.getCode(), value));
+ //������������������������������
+ for (HistorySecondUav data : datas) {
+ String valueStr = data.getValue();
+ ConcurrentHashMap<String, Object> valueMap = JSON.parseObject(valueStr, ConcurrentHashMap.class);
+ Set<Map.Entry<String, Object>> entries = valueMap.entrySet();
+ Iterator<Map.Entry<String, Object>> iterator = entries.iterator();
+ //���������������������������������
+ while(iterator.hasNext()){
+ Map.Entry<String, Object> entry = iterator.next();
+ String code = entry.getKey();
+ String value = String.valueOf(entry.getValue());
+ Sensor sensor = sensorsMap.get(code);
+ if (sensor == null) {//���������������������������������������
+ valueMap.remove(code);
+ continue;
+ }
+ String unit = sensor.getUnit();
+ String unitKey = sensor.getUnitKey();
+ String showUnit = sensor.getShowUnit();
+ String showUnitKey = sensor.getShowUnitKey();
+ //���������������������������������������������������������
+ if (showUnitKey.equals(unitKey)) {
+ value += " " + unit;
+ } else {
+ String formula = sensor.getFormula();
+ //������sensor���������������������������������������������
+ if (ObjectUtils.isEmpty(formula)) {
+ for (UnitConversion unitConversion : unitConversions) {
+ if (unitConversion.getOriginalUnitKey().equals(unitKey) && unitConversion.getTargetUnitKey().equals(showUnitKey))
+ formula = unitConversion.getFormula();
+ }
+ }
+ //������������������������������
+ String resultValue = UnitConvertUtils.calculate((String) value, formula);
+ if (resultValue != null) {
+ resultValue += showUnit;
+ } else {//���������������������������null���������������������������������������������������������������
+ resultValue = value + unit;
+ }
+ value = resultValue;
+ }
+ //������������������������������
+ valueMap.put(code, value);
+ }
+ String value = JSON.toJSONString(valueMap);
+ data.setValue(value);
+ }
+ System.out.println(111);
+ }
+
}
--
Gitblit v1.8.0