From 03791ab057f15d102bc20b83c687f8a8028a4b8f Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Tue, 28 Dec 2021 13:47:38 +0800 Subject: [PATCH] 行业贡献率update --- screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java | 135 ++++++++++++++++++++++++++++++++++++-------- 1 files changed, 110 insertions(+), 25 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 145895d..cdca09d 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,8 +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.*; import com.moral.api.mapper.HistorySecondUavMapper; import com.moral.api.pojo.dto.uav.UAVQueryTimeSlotDTO; import com.moral.api.pojo.form.uav.UAVQueryTimeSlotForm; @@ -11,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; /** @@ -44,6 +48,8 @@ OrganizationService organizationService; @Autowired SpecialDeviceService specialDeviceService; + @Autowired + RedisTemplate redisTemplate; @Override public List<Date> queryDate(Integer organizationId) { @@ -142,11 +148,15 @@ List<Map<String, Object>> timeSlots = new ArrayList<>(); dto.setMac(key); //������mac������������������ - dto.setName((String) specialDeviceService.getSpecialDeviceMapByMac(key).getName()); + SpecialDevice specialDevice = specialDeviceService.getSpecialDeviceMapByMac(key); + //������������������������������������ + 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); @@ -168,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; @@ -194,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<>(); @@ -207,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; } @@ -216,33 +236,98 @@ } /** - * @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); + } + } + } -- Gitblit v1.8.0