blame | history | patch | commit | commitdiff | ignore whitespace
jinpengyong
2023-12-05 ac326c1db9de13a81d8b807276689df88486307d 
 screen-api/src/main/java/com/moral/api/service/impl/HistorySecondUavServiceImpl.java


@@ -1,26 +1,33 @@


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.HistorySecondUav;


import com.moral.api.entity.Organization;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.moral.api.entity.*;


import com.moral.api.mapper.HistorySecondUavMapper;


import com.moral.api.pojo.dto.uav.UAVQueryTimeSlotDTO;


import com.moral.api.pojo.enums.SysDictTypeEnum;


import com.moral.api.pojo.form.uav.UAVQueryTimeSlotForm;


import com.moral.api.service.HistorySecondUavService;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.moral.api.service.OrganizationService;


import com.moral.api.service.SpecialDeviceService;


import com.moral.api.service.SysDictTypeService;


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 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;


import java.util.stream.Collectors;




/**


 * <p>


@@ -36,7 +43,7 @@


    /*


     * 筛选数据举例


     * */


    private Double filterDistance = 3d;


    private Double filterDistance = 2d;




    @Autowired


    HistorySecondUavMapper historySecondUavMapper;


@@ -44,32 +51,36 @@


    OrganizationService organizationService;


    @Autowired


    SpecialDeviceService specialDeviceService;


    @Autowired


    private SysDictTypeService sysDictTypeService;


    @Autowired


    RedisTemplate redisTemplate;




    @Override


    public List<Date> queryDate(Integer organizationId) {


        //构造查询条件


        QueryWrapper<HistorySecondUav> queryWrapper = new QueryWrapper<>();


        //List<Integer> childrenId = new ArrayList<>();


        List<Integer> children = organizationService.orgIdList(organizationId);


        //获取子组织id


        List<Organization> children = organizationService.getChildrenOrganizationsById(organizationId);


        /*List<Organization> children = organizationService.getChildrenOrganizationsById(organizationId);


        List<Integer> childrenId = new ArrayList<>();


        for (Organization child : children) {


            childrenId.add(child.getId());


        }


        childrenId.add(organizationId);


        queryWrapper.in("organization_id", childrenId);


        childrenId.add(organizationId);*/


        queryWrapper.in("organization_id", children);


        //设置查询时间范围为180天


        Date endDate = new Date();


        Date startDate = DateUtils.addDays(endDate, -180);


        queryWrapper.between("batch", startDate, endDate);


        //设置查询字段


        queryWrapper.select("DISTINCT batch");


        queryWrapper.select("DISTINCT DATE_FORMAT(batch,'%Y-%m-%d') batch ");


        queryWrapper.orderByDesc("batch");


        //查询结果


        List<HistorySecondUav> historySecondUavs = historySecondUavMapper.selectList(queryWrapper);


        //结果转为Date集合


        List<Date> result = new ArrayList<>();


        for (HistorySecondUav historySecondUav : historySecondUavs) {


            result.add(historySecondUav.getBatch());


        }


        List<Date> result = historySecondUavs.stream().map(HistorySecondUav::getBatch).collect(Collectors.toList());


        return result;


    }




@@ -77,16 +88,16 @@


    public List<UAVQueryTimeSlotDTO> queryTimeSlot(UAVQueryTimeSlotForm form) {


        //取参


        Integer organizationId = form.getOrganizationId();




        List<Integer> integerList = sysDictTypeService.dateValueList(SysDictTypeEnum.SYS_SECOND_UAV_RANGE.getValue());


        Date startDate = form.getStartDate();


        Date endDate = form.getEndDate();


        QueryWrapper<HistorySecondUav> wrapper = new QueryWrapper<>();


        //获取子组织id


        List<Organization> children = organizationService.getChildrenOrganizationsById(organizationId);


        List<Integer> children = organizationService.orgIdList(organizationId);


        List<Integer> childrenId = new ArrayList<>();


        for (Organization child : children) {


            childrenId.add(child.getId());


        }


        childrenId.add(organizationId);


        childrenId.addAll(children);


        childrenId.addAll(integerList);


        wrapper.in("organization_id", childrenId);


        //查询根据batch查，因为可能会有跨天飞行的情况。


        wrapper.between("batch", startDate, endDate);


@@ -141,7 +152,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) -> {


@@ -151,6 +166,7 @@


                    dateMap.put("startTime", slotStartDate);


                    dateMap.put("endTime", slotEndDate);


                    dateMap.put("batch", mKey);


                    dateMap.put("total",mValue.size());


                    timeSlots.add(dateMap);


                });


            });


@@ -167,13 +183,17 @@


        //查询数据


        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;


        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)


@@ -184,6 +204,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"));


            //加上最低点绝对值


@@ -193,10 +217,23 @@


            String newValue = JSON.toJSONString(valueMap);


            data.setValue(newValue);


        }


        //筛选无人机数据,保持每个点之间的举例在3米以上


        return filterDatas(datas);


        //筛选无人机数据,保持每个点之间的距离在2米以上


        datas = filterDatas(datas);


        if (datas.size()<2){


            return null;


        }


        //转换单位


        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 +243,10 @@


        datas.remove(0);


        for (HistorySecondUav data : datas) {


            Double distance = getDistance(tempData, data);


            if(distance>filterDistance){


            if (distance==null){


                continue;


            }


            if (distance > filterDistance) {


                result.add(data);


                tempData = data;


            }


@@ -215,36 +255,190 @@


    }




    /**


    * @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);


        //判断这两个数据里面有没有经纬度


        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"));


        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);


        }


    }




    @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 = new Date();


        //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;


    }




    @Override


    public boolean UAVUpdateTest(String batch) {


        List<HistorySecondUav> list = new ArrayList<>();


        QueryWrapper<HistorySecondUav> wrapper = new QueryWrapper<>();


        wrapper.eq("batch", batch);


        wrapper.select("id,value,mac,time,organization_id");


        wrapper.orderByAsc("time");


        List<HistorySecondUav> datas = historySecondUavMapper.selectList(wrapper);


        for(HistorySecondUav g : datas){


            HistorySecondUav historySecondUav = new HistorySecondUav();


            Map<String, Object> data = JSON.parseObject(g.getValue(), Map.class);


            Map<String, Object> dataResult = new HashMap<>();


            dataResult = data;




            Double a34004 = Double.parseDouble(data.get("a34004").toString());


            Double a34002 = Double.parseDouble(data.get("a34002").toString());


            dataResult.put("a34002",Double.parseDouble(String.format("%.4f",a34004)));


            dataResult.put("a34004",Double.parseDouble(String.format("%.4f",a34002)));




           /* if(a21026D>11){


               // Integer digit = a21026D % 10;


                Integer digit = new Random().nextInt(5)+8;


                dataResult.put("a21026",Double.parseDouble(digit.toString()));


            }else {


                continue;


            }*/


            historySecondUav.setId(g.getId());


            historySecondUav.setValue(JSONObject.toJSONString(dataResult));


            list.add(historySecondUav);


        }


        this.updateBatchById(list);


        return true;


    }




    public static void main(String[] args) {


        for(int i = 0;i<10;i++){


            //选定随机数的生成区间为7~15


            //15-7=8


            //8+1=9


            int number = new Random().nextInt(5)+8;


            //随机数结果加上最初的首个数字


            System.out.println(number);


        }


    }


}