blame | history | patch | commit | commitdiff | ignore whitespace
swb
2024-06-27 2a354294d885900b57bf8b05083f842878668a71 
 screen-api/src/main/java/com/moral/api/service/impl/DustldServiceImpl.java


@@ -1,8 +1,13 @@


package com.moral.api.service.impl;






import com.moral.api.config.Interceptor.UserHelper;


import com.moral.api.entity.SysDictData;


import com.moral.api.exception.BusinessException;


import com.moral.api.mapper.*;


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


import com.moral.api.pojo.vo.user.QxUser;


import com.moral.api.service.SysDictTypeService;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.collections4.CollectionUtils;


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


@@ -17,18 +22,7 @@


import java.text.DecimalFormat;


import java.text.ParseException;


import java.text.SimpleDateFormat;


import java.util.ArrayList;


import java.util.Collections;


import java.util.Comparator;


import java.util.Date;


import java.util.HashMap;


import java.util.Iterator;


import java.util.LinkedHashMap;


import java.util.List;


import java.util.Map;


import java.util.Objects;


import java.util.Set;


import java.util.UUID;


import java.util.*;


import java.util.stream.Collectors;




import com.alibaba.fastjson.JSON;


@@ -67,7 +61,7 @@


     */


    @Override


    public Integer getDailyDustld(Map<String, Object> params,MultipartFile file ) {




        SysDictData listDict = sysDictTypeService.listOne(SysDictTypeEnum.SYS_SECOND_CRUISER.getValue(),"dustld");


        //获取jar包所在目录


        ApplicationHome applicationHome = new ApplicationHome(getClass());


        //在jar包所在目录下生成一个upload文件夹用来存储上传的图片


@@ -93,8 +87,16 @@


                ArrayList<Double> rsDouble = new ArrayList<>();


                for (String s : dust) {


                    double aDouble = Double.parseDouble(s);




                    if (aDouble>=0 && aDouble<40 ){


                    if(listDict.getDataValue().contains(",")){


                        List<String> resultStr = Arrays.asList(listDict.getDataValue().split(","));


                        if(resultStr.size() % 2 ==0){


                            aDouble = numAvg(resultStr,BigDecimal.valueOf(aDouble)).doubleValue();


                        }


                    }else {


                        BigDecimal dataValue = Objects.nonNull(listDict.getDataValue())?BigDecimal.valueOf(Double.parseDouble(listDict.getDataValue())):BigDecimal.ZERO;


                        aDouble = BigDecimal.valueOf(aDouble).add(dataValue).doubleValue();


                    }


                    /*if (aDouble>=0 && aDouble<40 ){


                        aDouble = aDouble + 170;


                    }else if (aDouble>=40 && aDouble<60){


                        aDouble = aDouble + 130;


@@ -106,7 +108,7 @@


                        aDouble = aDouble + 30;


                    }else {


                        aDouble= aDouble+0;


                    }


                    }*/


                    rsDouble.add(aDouble);


                }


                list.addAll(rsDouble);


@@ -271,11 +273,13 @@


    private MaxRoadMapper maxRoadMapper;


    @Autowired


    private OrganizationMapper organizationMapper;


    @Autowired


    private SysDictTypeService sysDictTypeService;




    @Override


    @Transactional


    public Map<String, Object> dailyDustlds(Map<String, Object> params) {




        SysDictData list = sysDictTypeService.listOne(SysDictTypeEnum.SYS_SECOND_CRUISER.getValue(),"dustld");


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


@@ -302,7 +306,6 @@


        StringBuilder builder = new StringBuilder();




        int i = 1;


        long timestamp = System.currentTimeMillis();


        for (String string : strings) {


            DustForm dustForm = new DustForm();


            ArrayList<Double> doubleArrayList = new ArrayList<>();


@@ -323,17 +326,14 @@


//                    String flyLon1 = dust.get("flyLon").toString();


                    if (latDouble1==latDouble && lonDouble1==lonDouble){


                        Double dustld = Objects.nonNull(dust.get("dustld"))?Double.parseDouble(dust.get("dustld").toString()):0d;




                        if (dustld>=0 && dustld<40 ){


                            dustld = dustld + 170;


                        }else if (dustld>=40 && dustld<60){


                            dustld = dustld + 130;


                        }else if (dustld>=60 && dustld<100 ){


                            dustld = dustld + 110;


                        }else if (dustld>=100 && dustld<150){


                            dustld = dustld + 70;


                        }else if (dustld>=150 && dustld<180){


                            dustld = dustld + 30;


                        if(list.getDataValue().contains(",")){


                            List<String> resultStr = Arrays.asList(list.getDataValue().split(","));


                            if(resultStr.size() % 2 ==0){


                                dustld = numAvg(resultStr,BigDecimal.valueOf(dustld)).doubleValue();


                            }


                        }else {


                            BigDecimal dataValue = Objects.nonNull(list.getDataValue())?BigDecimal.valueOf(Double.parseDouble(list.getDataValue())):BigDecimal.ZERO;


                            dustld = BigDecimal.valueOf(dustld).add(dataValue).doubleValue();


                        }


                        doubleArrayList.add(dustld);


                        break;


@@ -365,8 +365,6 @@


                }


            }


        }


        long timestamp2 = System.currentTimeMillis();


        log.info(timestamp2-timestamp+"");


        //排序


        list1.sort(Comparator.comparing(DustForm::getValue).reversed());


        rsMap.put("list1",list1);


@@ -390,9 +388,9 @@


                if (road.getName().equals(dustForm.getRoad())){


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


                    map.put("road",road.getName());


                    map.put("value1",road.getData());


                    map.put("value2",dustForm.getValue());


                    map.put("value3",road.getData()-dustForm.getValue());


                    map.put("value1",String.format("%.2f",road.getData()));


                    map.put("value2",String.format("%.2f",dustForm.getValue()));


                    map.put("value3",String.format("%.2f",road.getData()-dustForm.getValue()));


                    list3.add(map);


                }


            }


@@ -461,6 +459,84 @@


        return dustlds;


    }




    /**


     * 路段排序


     * @param mac


     * @param startTime


     * @param endTime


     * @return


     */


    @Override


    public List<DustForm> sort(String mac, String startTime, String endTime) {


        SysDictData list = sysDictTypeService.listOne(SysDictTypeEnum.SYS_SECOND_CRUISER.getValue(),"dustld");


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




        List<Integer> orgList = organizationMapper.orgIdSpecialDevList(orgId,mac);


        if(CollectionUtils.isEmpty(orgList)){


            throw new BusinessException("该设备没有路段组织信息！");


        }




        HashMap<String, Object> params = new HashMap<>();


        params.put("mac",mac);


        params.put("startTime",startTime);


        params.put("endTime",endTime);


        List<Map<String, Object>> dusts = historySecondCruiserMapper.getDusts(params);


        Map<String, List<DustldDTO>> collect = manageCoordinateMapper.CompareTo(orgList.get(0)).stream().collect(Collectors.groupingBy(o -> o.getName()));


        if (ObjectUtils.isEmpty(dusts) || ObjectUtils.isEmpty(collect)){


            return null;


        }


        Set<String> strings = collect.keySet();


        ArrayList<DustForm> list1 = new ArrayList<>();


        for (String string : strings) {


            DustForm dustForm = new DustForm();


            ArrayList<Double> doubleArrayList = new ArrayList<>();


            List<DustldDTO> dustldDTOS = collect.get(string);


            for (DustldDTO dustldDTO : dustldDTOS) {


                String flyLat = dustldDTO.getFlyLat();


                String flyLon = dustldDTO.getFlyLon();


                if (flyLon==null && flyLat==null){


                    continue;


                }


                double latDouble1 = Double.parseDouble(flyLat);


                double lonDouble1 = Double.parseDouble(flyLon);


                for (Map<String, Object> dust : dusts) {


                    String flyLat1 = Objects.nonNull(dust.get("flyLat")) ? dust.get("flyLat").toString() :"0";


                    String flyLon1 = Objects.nonNull(dust.get("flyLon")) ? dust.get("flyLon").toString() :"0";


                    double latDouble = Double.parseDouble(flyLat1);


                    double lonDouble = Double.parseDouble(flyLon1);


//                    String flyLon1 = dust.get("flyLon").toString();


                    if (latDouble1==latDouble && lonDouble1==lonDouble){


                        Double dustld = Objects.nonNull(dust.get("dustld"))?Double.parseDouble(dust.get("dustld").toString()):0d;


                        if(list.getDataValue().contains(",")){


                            List<String> resultStr = Arrays.asList(list.getDataValue().split(","));


                            if(resultStr.size() % 2 ==0){


                                dustld = numAvg(resultStr,BigDecimal.valueOf(dustld)).doubleValue();


                            }


                        }else {


                            BigDecimal dataValue = Objects.nonNull(list.getDataValue())?BigDecimal.valueOf(Double.parseDouble(list.getDataValue())):BigDecimal.ZERO;


                            dustld = BigDecimal.valueOf(dustld).add(dataValue).doubleValue();


                        }


                        doubleArrayList.add(dustld);


                        break;


                    }


                }


            }


            if (ObjectUtils.isEmpty(doubleArrayList)){


                continue;


            }


            Double ListAva = doubleArrayList.stream() .collect(Collectors.averagingDouble(Double::doubleValue));


            double rsAvg = new BigDecimal(ListAva/1000).setScale(3, BigDecimal.ROUND_HALF_UP).doubleValue();


            dustForm.setRoad(string);


            dustForm.setValue(rsAvg);


            list1.add(dustForm);


        }


        //排序


        list1.sort(Comparator.comparing(DustForm::getValue).reversed());


        return list1;


    }






    //获取图片地址


    private String getList(String path, List<MultipartFile> files1) {


@@ -494,5 +570,14 @@


        }


        return null;


    }




    private BigDecimal numAvg(List<String> list , BigDecimal num){


        int nums = 1;


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


            if(num.compareTo(BigDecimal.valueOf(Double.parseDouble(list.get(i))))>= 0 ){


                return num.add(BigDecimal.valueOf(Double.parseDouble(list.get(i+1))));


            }


            nums+=2;


        }


        return num;


    }


}