From a9cc2343ceaad3e99dc25eb036dc99aeded279a6 Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Fri, 20 Oct 2023 09:26:36 +0800 Subject: [PATCH] Merge branch 'dev' of http://blit.7drlb.com:8888/r/moral into wb --- screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java | 66 ++++++++++++++++++++++++++++++++- 1 files changed, 64 insertions(+), 2 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 cdca09d..627b26a 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,6 +1,7 @@ package com.moral.api.service.impl; import com.alibaba.fastjson.JSON; +import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.moral.api.entity.*; import com.moral.api.mapper.HistorySecondUavMapper; @@ -10,18 +11,17 @@ import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.moral.api.service.OrganizationService; import com.moral.api.service.SpecialDeviceService; +import com.moral.api.utils.UnitConvertUtils; 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; @@ -162,6 +162,7 @@ dateMap.put("startTime", slotStartDate); dateMap.put("endTime", slotEndDate); dateMap.put("batch", mKey); + dateMap.put("total",mValue.size()); timeSlots.add(dateMap); }); }); @@ -185,6 +186,10 @@ for (HistorySecondUav data : datas) { String value = data.getValue(); Map<String, Object> valueMap = JSON.parseObject(value, Map.class); + //������value��������������������� + if (!valueMap.containsKey("flyhig")|| !valueMap.containsKey("flylat")|| !valueMap.containsKey("flylon")){ + continue; + } //������������ Double height = Double.valueOf((String) valueMap.get("flyhig")); if (height < lowestHeight) @@ -195,6 +200,10 @@ for (HistorySecondUav data : datas) { String value = data.getValue(); Map<String, Object> valueMap = JSON.parseObject(value, Map.class); + //������value��������������������� + if (!valueMap.containsKey("flyhig")|| !valueMap.containsKey("flylat")|| !valueMap.containsKey("flylon")){ + continue; + } //������������ Double height = Double.valueOf((String) valueMap.get("flyhig")); //������������������������ @@ -206,6 +215,9 @@ } //���������������������,���������������������������������2��������� datas = filterDatas(datas); + if (datas.size()<2){ + return null; + } //������������ unitConvert(datas); return datas; @@ -227,6 +239,9 @@ datas.remove(0); for (HistorySecondUav data : datas) { Double distance = getDistance(tempData, data); + if (distance==null){ + continue; + } if (distance > filterDistance) { result.add(data); tempData = data; @@ -247,6 +262,11 @@ String value2 = uav2.getValue(); Map<String, Object> value1Map = JSON.parseObject(value1, Map.class); Map<String, Object> value2Map = JSON.parseObject(value2, Map.class); + //��������������������������������������������� + if (!value1Map.containsKey("flylon")||!value1Map.containsKey("flylat")||!value1Map.containsKey("flyhig")|| + !value2Map.containsKey("flylon")||!value2Map.containsKey("flylat")||!value2Map.containsKey("flyhig")){ + return null; + } //������������1��������������������� Double longtitude1 = Double.valueOf((String) value1Map.get("flylon")); Double latitude1 = Double.valueOf((String) value1Map.get("flylat")); @@ -330,4 +350,46 @@ } } + @Override + public boolean UAVTest(BigDecimal lat, BigDecimal lon, String batch) { + List<HistorySecondUav> list = new ArrayList<>(); + + QueryWrapper<HistorySecondUav> wrapper = new QueryWrapper<>(); + wrapper.eq("batch", batch); + wrapper.select("value,mac,time,organization_id"); + wrapper.orderByAsc("time"); + List<HistorySecondUav> datas = historySecondUavMapper.selectList(wrapper); + Date time =DateUtils.addDays(datas.get(2).getTime(),0); + //String bat = "2023-08-08 14:42:20"; + for(HistorySecondUav g : datas){ + HistorySecondUav historySecondUav = new HistorySecondUav(); + historySecondUav.setTime(DateUtils.addDays(g.getTime(),0)); + historySecondUav.setMac(g.getMac()); + historySecondUav.setBatch(time); + historySecondUav.setOrganizationId(g.getOrganizationId()); + Map<String, Object> data = JSON.parseObject(g.getValue(), Map.class); + Map<String, Object> dataResult = new HashMap<>(); + dataResult = data; + dataResult.put("flylat",Objects.isNull(data.get("flylat"))||data.get("flylat").toString().equals("0")?0d:Double.parseDouble(String.format("%.10f",Double.parseDouble(data.get("flylat").toString())+lat.doubleValue()))); + dataResult.put("flylon",Objects.isNull(data.get("flylon"))||data.get("flylon").toString().equals("0")?0d:Double.parseDouble(String.format("%.10f",Double.parseDouble(data.get("flylon").toString())+lon.doubleValue()))); + /*if(Objects.nonNull(data.get("a21026"))&& !data.get("a21026").toString().equals("0")){ + Double a21026D = Double.parseDouble(data.get("a21026").toString()); + if( a21026D>15){ + a21026D = a21026D -10; + } + dataResult.put("a21026",Double.parseDouble(String.format("%.4f",a21026D))); + } + if(Objects.nonNull(data.get("a21004"))&& !data.get("a21004").toString().equals("0")){ + Double a21024D = Double.parseDouble(data.get("a21004").toString()); + if( a21024D>100){ + a21024D = a21024D -100; + } + dataResult.put("a21004",Double.parseDouble(String.format("%.4f",a21024D))); + }*/ + historySecondUav.setValue(JSONObject.toJSONString(dataResult)); + list.add(historySecondUav); + } + this.saveBatch(list); + return true; + } } -- Gitblit v1.8.0