forked from moral

blame | history | patch | commit | commitdiff | ignore whitespace
cjl
2023-09-12 ea1373d4e1511b620bb87872e692643e2edb81f8 
 screen-api/src/main/java/com/moral/api/service/impl/SpecialDeviceServiceImpl.java


@@ -13,6 +13,9 @@


import com.moral.api.mapper.HistorySecondCruiserMapper;


import com.moral.api.mapper.SpecialDeviceMapper;


import com.moral.api.pojo.bo.ExcelBO;


import com.moral.api.pojo.dto.historySecondCruiser.HistorySecondCruiserListDTO;


import com.moral.api.pojo.dto.historySecondCruiser.HistorySecondCruiserResultCountDTO;


import com.moral.api.pojo.dto.historySecondCruiser.HistorySecondCruiserResultDTO;


import com.moral.api.pojo.vo.excel.DailyVo;


import com.moral.api.service.OrganizationService;


import com.moral.api.service.SpecialDeviceHistoryService;


@@ -26,25 +29,21 @@


import com.moral.util.GeodesyUtils;


import com.moral.util.TokenUtils;




import org.apache.commons.collections4.CollectionUtils;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.boot.system.ApplicationHome;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Service;


import org.springframework.util.ObjectUtils;


import org.springframework.util.StringUtils;


import org.springframework.web.multipart.MultipartFile;




import java.io.File;


import java.math.BigDecimal;


import java.text.ParseException;


import java.text.SimpleDateFormat;


import java.util.ArrayList;


import java.util.Arrays;


import java.util.Collections;


import java.util.Date;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.UUID;


import java.util.*;


import java.util.stream.Collectors;




/**


@@ -84,6 +83,9 @@




    private final static Double dis = 50d;






    private final static Double DIS_NEW = 100d;




    @Override


    public List<Map<String, Object>> selectCruisers() {


        //获取当前用户信息


@@ -103,7 +105,7 @@


    }




    @Override


    public List<Map<String, Object>> carTrajectory(Map<String, Object> params) {


    public List<Map<String, Object>> carTrajectory(Map<String, Object> params,boolean type) {


        params.put("dateFormat", "%Y-%m-%d %H:%i:%s");


        Map<String, Object> userInfo = (Map<String, Object>) TokenUtils.getUserInfo();


        Map<String, Object> orgInfo = (Map<String, Object>) userInfo.get("organization");


@@ -144,6 +146,33 @@


    }




    @Override


    public List<HistorySecondCruiserResultDTO> carTrajectoryNewAvg(Map<String, Object> params) {


        double range = Double.valueOf(params.get("range").toString());


        params.put("dateFormat", "%Y-%m-%d %H:%i:%s");


        Map<String, Object> userInfo = (Map<String, Object>) TokenUtils.getUserInfo();


        Map<String, Object> orgInfo = (Map<String, Object>) userInfo.get("organization");


        Integer orgId = (Integer) orgInfo.get("id");


        params.put("orgId", orgId);


        params.put("type","$."+params.get("type"));


        //从秒数据表获取走航车数据


        List<HistorySecondCruiserListDTO> data = HistorySecondCruiserMapper.getCruiserDataNewAvg(params);


        data.removeIf(o->{


            if (ObjectUtils.isEmpty(o.getFlyLon()) || ObjectUtils.isEmpty(o.getFlyLat())) {


                return true;


            }


            double lon = o.getFlyLon();


            double lat = o.getFlyLat();


            if (lon < 70 || lon > 150 || lat < 20 || lat > 60) {


                return true;


            }


            return false;


        });


        if(CollectionUtils.isEmpty(data)){


            return null;


        }


        return filterDataNew(data,range);


    }


    @Override


    public SpecialDevice getSpecialDeviceMapByMac(String mac) {


        QueryWrapper<SpecialDevice> queryWrapper = new QueryWrapper();


        queryWrapper.eq("mac", mac);


@@ -182,7 +211,10 @@


        String time2 = params.get("time2").toString();


        String rsTime = getTime(time1, time2);


        list.add(rsTime);


        List<Map<String, Object>> maps = specialDeviceService.carTrajectory(params);


//        List<Map<String, Object>> maps = specialDeviceService.carTrajectory(params,false);


//        List<Map<String, Object>> maps = HistorySecondCruiserMapper.getCruiserData(params);


        List<Map<String, Object>> maps = HistorySecondCruiserMapper.getAllCruiserData(params);




        if (ObjectUtils.isEmpty(maps)){


            return null;


        }


@@ -194,7 +226,8 @@


            map.put("time1",time3);


            map.put("time2",time4);


            map.put("mac",mac);


            List<Map<String, Object>> maps1 = specialDeviceService.carTrajectory(map);


//            List<Map<String, Object>> maps1 = specialDeviceService.carTrajectory(map,false);


            List<Map<String, Object>> maps1 = HistorySecondCruiserMapper.getAllCruiserData(params);


            if (ObjectUtils.isEmpty(maps1)){


                return null;


            }


@@ -210,7 +243,8 @@


            map.put("time1",time5);


            map.put("time2",time6);


            map.put("mac",mac);


            List<Map<String, Object>> maps1 = specialDeviceService.carTrajectory(map);


//            List<Map<String, Object>> maps1 = specialDeviceService.carTrajectory(map,false);


            List<Map<String, Object>> maps1 = HistorySecondCruiserMapper.getAllCruiserData(params);


            if (ObjectUtils.isEmpty(maps1)){


                return null;


            }


@@ -430,20 +464,28 @@






        for (Map<String, Object> map : maps) {


//            String flylon = map.get("flylon").toString();


//            String flylat = map.get("flylat").toString();


//            String s = flylon + "-" + flylat;


//            if (Double.parseDouble(map.get("a34004").toString())>200){


//


//            }


            pm25List.add(Double.parseDouble(map.get("a34004").toString()));


            pm10List.add(Double.parseDouble(map.get("a34002").toString()));


            COList.add(Double.parseDouble(map.get("a21005").toString()));


            SO2List.add(Double.parseDouble(map.get("a21026").toString()));


            NO2List.add(Double.parseDouble(map.get("a21004").toString()));


            O3List.add(Double.parseDouble(map.get("a05024").toString()));


            VOCList.add(Double.parseDouble(map.get("a99054").toString()));




            Map value = JSON.parseObject(map.get("value").toString(), Map.class);


            if (!ObjectUtils.isEmpty(value.get("a34004"))){


                pm25List.add(Double.parseDouble(value.get("a34004").toString()));


            }


            if (!ObjectUtils.isEmpty(value.get("a34002"))){


                pm10List.add(Double.parseDouble(value.get("a34002").toString()));


            }


            if (!ObjectUtils.isEmpty(value.get("a21005"))){


                COList.add(Double.parseDouble(value.get("a21005").toString()));


            }


            if (!ObjectUtils.isEmpty(value.get("a21026"))){


                SO2List.add(Double.parseDouble(value.get("a21026").toString()));


            }


            if (!ObjectUtils.isEmpty(value.get("a21004"))){


                NO2List.add(Double.parseDouble(value.get("a21004").toString()));


            }


            if (!ObjectUtils.isEmpty(value.get("a05024"))){


                O3List.add(Double.parseDouble(value.get("a05024").toString()));


            }


            if (!ObjectUtils.isEmpty(value.get("a99054"))){


                VOCList.add(Double.parseDouble(value.get("a99054").toString()));


            }


        }




        //获取平均值


@@ -495,6 +537,143 @@


                result.add(map);


            }


        }






        return result;


    }


    //范围取均值


    private List<Map<String, Object>> filterData(List<Map<String, Object>> data, List<Map<String, Object>> result) {


        List<Map<String, Object>> list = new ArrayList<>();




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


        result.forEach(it->map.put(it.get(Constants.SENSOR_CODE_LON).toString()+ "_"+Constants.SENSOR_CODE_LAT.toString(),Arrays.asList(it)));


        // 坐标在50 以内分组


        for (Map<String, Object> mapData : data) {


            for (Map.Entry<String, List<Object>> entry : map.entrySet()) {


                double lng1 = Double.parseDouble(mapData.get(Constants.SENSOR_CODE_LON).toString());


                double lat1 = Double.parseDouble(mapData.get(Constants.SENSOR_CODE_LAT).toString());


                String[] mapKey = entry.getKey().split("_");


                List<Object> mapValue = entry.getValue();


                double lng2 = Double.parseDouble(mapKey[0]);


                double lat2 = Double.parseDouble(mapKey[1]);


                double distance = GeodesyUtils.getDistance(lat1, lng1, lat2, lng2);


                if (distance < dis) {


                    mapValue.add(mapData);


                }


            }


        }




        return list;


    }


    //根据距离筛选数据


    private List<HistorySecondCruiserResultDTO> filterDataNew(List<HistorySecondCruiserListDTO> data,double range) {


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


        Map<Integer, HistorySecondCruiserResultCountDTO> map = new HashMap<>();


        Map<String, BigDecimal> mapTest = new HashMap<>();


        Integer integer = 1;


        HistorySecondCruiserResultCountDTO countDTO  = new HistorySecondCruiserResultCountDTO();


        countDTO.setSumNum(data.get(0).getNum());


        countDTO.setContNum(1);


        map.put(integer,countDTO);


        list.add(0,data.remove(0));


        mapTest.put(data.get(0).getFlyLon()+"_"+data.get(0).getFlyLat(),data.get(0).getNum());


        int k =1;


        for (HistorySecondCruiserListDTO d : data) {


            boolean flag = true;


            for (HistorySecondCruiserListDTO l : list) {


                double distance = GeodesyUtils.getDistance(d.getFlyLat(), d.getFlyLon(), l.getFlyLat(), l.getFlyLon());


                if (distance < range) {


                    flag = false;


                    if(integer.equals(list.size())&& !mapTest.containsKey(d.getFlyLon()+"_"+d.getFlyLat())){


                        HistorySecondCruiserResultCountDTO countResultDTO = Objects.isNull(map.get(integer))?new HistorySecondCruiserResultCountDTO():map.get(integer);


                        countResultDTO.setContNum(countResultDTO.getContNum()+1);


                        countResultDTO.setSumNum(countResultDTO.getSumNum().add(d.getNum()));


                        map.put(integer,countResultDTO);


                        mapTest.put(d.getFlyLon()+"_"+d.getFlyLat(),d.getNum());


                        k++;


                    }


                }


            }


            if (flag) {


                if(!list.contains(d)){


                    list.add(d);


                    integer++;


                    HistorySecondCruiserResultCountDTO countResultDTO = Objects.isNull(map.get(integer))?new HistorySecondCruiserResultCountDTO():map.get(integer);


                    countResultDTO.setSumNum(d.getNum());


                    countResultDTO.setContNum(1);


                    map.put(integer,countResultDTO);


                    mapTest.put(d.getFlyLon()+"_"+d.getFlyLat(),d.getNum());


                }


            }


        }


        if(!list.contains(data.get(data.size()-1))){


            HistorySecondCruiserListDTO result = data.get(data.size()-1);


            list.add(result);


            integer++;


            HistorySecondCruiserResultCountDTO countResultDTO = new HistorySecondCruiserResultCountDTO();


            countResultDTO.setContNum(1);


            countResultDTO.setSumNum(result.getNum());


            map.put(integer,countResultDTO);


        }


        return filterDataNe(list,map);


    }


    private List<HistorySecondCruiserResultDTO> filterDataNe(List<HistorySecondCruiserListDTO> list,Map<Integer, HistorySecondCruiserResultCountDTO> map){


        List<HistorySecondCruiserResultDTO> listResult = new ArrayList<>();


        for(Map.Entry<Integer, HistorySecondCruiserResultCountDTO> entry : map.entrySet()){


            Integer mapKey = entry.getKey();


            HistorySecondCruiserResultCountDTO mapValue = entry.getValue();


            BigDecimal avgNum = mapValue.getSumNum().divide(BigDecimal.valueOf(mapValue.getContNum()),2,BigDecimal.ROUND_HALF_UP);


            HistorySecondCruiserResultDTO resultDTO = new HistorySecondCruiserResultDTO();


            resultDTO.setTime(list.get(mapKey-1).getTime());


            resultDTO.setAvgNum(avgNum);


            resultDTO.setFlyLon(list.get(mapKey-1).getFlyLon());


            resultDTO.setFlyLat(list.get(mapKey-1).getFlyLat());


            listResult.add(resultDTO);


        }


    return listResult;






    }




    private List<HistorySecondCruiserResultDTO> filterDataNew(List<HistorySecondCruiserListDTO> data, List<HistorySecondCruiserListDTO> list,double range) {


        List<HistorySecondCruiserResultDTO> listResult = new ArrayList<>();


        List<HistorySecondCruiserListDTO> filter = new ArrayList<>();


        for (HistorySecondCruiserListDTO d : data) {


            for (HistorySecondCruiserListDTO l : list) {


                double distance = GeodesyUtils.getDistance(d.getFlyLat(), d.getFlyLon(), l.getFlyLat(), l.getFlyLon());


                if (filter.contains(d)) {


                    break;


                }


                if (distance < range ) {


                    List<BigDecimal> numList = new ArrayList<>(CollectionUtils.isEmpty(l.getNumList()) ? Arrays.asList(l.getNum()) : l.getNumList());


                    numList.add(d.getNum());


                    l.setNumList(numList);


                    filter.add(d);


                    break;


                }


            }


        }


        int k = 0;


        for(int j =0;j<list.size(); j++){


            HistorySecondCruiserListDTO l = list.get(j);


            HistorySecondCruiserResultDTO resultDTO = new HistorySecondCruiserResultDTO();


            resultDTO.setFlyLat(l.getFlyLat());


            resultDTO.setTime(l.getTime());


            resultDTO.setFlyLon(l.getFlyLon());


            BigDecimal num = BigDecimal.ZERO;


            int count = l.getNumList().size();


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


                num = num.add(l.getNumList().get(i));


            }


            k = k+count;


            resultDTO.setAvgNum(num.divide(BigDecimal.valueOf(count),2,BigDecimal.ROUND_HALF_UP));


            listResult.add(resultDTO);


        }


        System.out.println("sss>>>>:"+ (k++));


        System.out.println("sss>>>>:"+ (filter.size())+">>>>:"+data.size());


        int z = 0 ;


        return listResult;






    }


}