From 93fe0b66e85e95e3a7e77a28504d6d289b6906b9 Mon Sep 17 00:00:00 2001 From: kaiyu <404897439@qq.com> Date: Fri, 08 Oct 2021 13:11:22 +0800 Subject: [PATCH] screen-manage screen-api 更改拦截器逻辑,记录token无效的请求IP以及URL。 manage记录到数据库日志中 api记录在日志文件中 --- screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java | 135 ++++++++++++++++++++++++++++++++++++-------- 1 files changed, 109 insertions(+), 26 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 8ec181a..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) { @@ -63,6 +69,7 @@ queryWrapper.between("batch", startDate, endDate); //������������������ queryWrapper.select("DISTINCT batch"); + queryWrapper.orderByDesc("batch"); //������������ List<HistorySecondUav> historySecondUavs = historySecondUavMapper.selectList(queryWrapper); //������������Date������ @@ -141,7 +148,11 @@ List<Map<String, Object>> timeSlots = new ArrayList<>(); dto.setMac(key); //������mac������������������ - dto.setName((String) specialDeviceService.getSpecialDeviceMapByMac(key).get("name")); + SpecialDevice specialDevice = specialDeviceService.getSpecialDeviceMapByMac(key); + //������������������������������������ + if (specialDevice == null) + return; + dto.setName(specialDevice.getName()); //������������������batch value.forEach(listValue -> { listValue.forEach((mKey, mValue) -> { @@ -167,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; @@ -193,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<>(); @@ -206,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; } @@ -215,36 +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