blame | history | patch | commit | commitdiff | ignore whitespace
cjl
2024-08-09 a022ae9804d0c2f402711b6b5202319d853919cf 
 screen-api/src/main/java/com/moral/api/service/impl/DustldServiceImpl.java


@@ -1,7 +1,17 @@


package com.moral.api.service.impl;






import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


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


import com.moral.api.entity.SecondCruiserSort;


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;


import org.springframework.boot.system.ApplicationHome;


import org.springframework.stereotype.Service;


@@ -14,18 +24,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;


@@ -36,10 +35,6 @@


import com.moral.api.entity.Dustld;


import com.moral.api.entity.ManageCoordinate;


import com.moral.api.entity.MaxRoad;


import com.moral.api.mapper.DustldMapper;


import com.moral.api.mapper.HistorySecondCruiserMapper;


import com.moral.api.mapper.ManageCoordinateMapper;


import com.moral.api.mapper.MaxRoadMapper;


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


import com.moral.api.pojo.dust.DustForm;


import com.moral.api.pojo.dust.TimeForm;


@@ -59,6 +54,9 @@


    @Autowired


    private DustldMapper dustldMapper;




    @Autowired


    private SecondCruiserSortMapper secondCruiserSortMapper;




    /**


     * 保存日报信息


     * @param params


@@ -68,7 +66,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文件夹用来存储上传的图片


@@ -90,29 +88,33 @@


            for (TimeForm timeForm : tables) {


                String start = timeForm.getStart();


                String end = timeForm.getEnd();


                List<Double> dust = historySecondCruiserMapper.getDust(start, end, mac);


                List<String> dust = historySecondCruiserMapper.getDust(start, end, mac);


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


                for (Double aDouble : dust) {


                    double v =0.0;


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


                        v = aDouble + 170;


                for (String s : dust) {


                    double aDouble = Double.parseDouble(s);


                    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>=40 && aDouble<60 ){


                        v = aDouble + 130;


                    }


                    if (aDouble>=60 && aDouble<100 ){


                        v = aDouble + 110;


                    }


                    if (aDouble>=100 && aDouble<150 ){


                        v = aDouble + 70;


                    }


                    if (aDouble>=150 && aDouble<180 ){


                        v = aDouble + 30;


                    }


                    if (aDouble>=180){


                        v= aDouble;


                    }


                    rsDouble.add(v);


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


                        aDouble = aDouble + 170;


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


                        aDouble = aDouble + 130;


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


                        aDouble = aDouble + 110;


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


                        aDouble = aDouble + 70;


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


                        aDouble = aDouble + 30;


                    }else {


                        aDouble= aDouble+0;


                    }*/


                    rsDouble.add(aDouble);


                }


                list.addAll(rsDouble);


            }


@@ -274,14 +276,23 @@


    private ManageCoordinateMapper manageCoordinateMapper;


    @Autowired


    private MaxRoadMapper maxRoadMapper;


    @Autowired


    private OrganizationMapper organizationMapper;


    @Autowired


    private SysDictTypeService sysDictTypeService;




    @Override


    @Transactional


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




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


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


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


        if(CollectionUtils.isEmpty(orgList)){


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


        }


        String time1 = params.get("startTime").toString();


        String dateString1 = DateUtils.stringToDateString(time1, DateUtils.yyyy_MM_dd_HH_mm_ss_EN, DateUtils.yyyy_MM_dd_HH_mm_CN);


        String rsTime1 = dateString1.substring(5, 14);


@@ -290,14 +301,16 @@


        String rsTime2 = dateString2.substring(5, 14);


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


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


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


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


        //所有的高值路段


        StringBuilder builder = new StringBuilder();




        int i = 1;


        long timestamp = System.currentTimeMillis();


        for (String string : strings) {


            DustForm dustForm = new DustForm();


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


@@ -318,17 +331,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;


@@ -360,8 +370,6 @@


                }


            }


        }


        long timestamp2 = System.currentTimeMillis();


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


        //排序


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


        rsMap.put("list1",list1);


@@ -385,14 +393,14 @@


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


                }


            }


        }


        rsMap.put("data",builder);


        rsMap.put("data",ObjectUtils.isEmpty(builder)?"暂无高值路段":builder);


        rsMap.put("list3",list3);


        rsMap.put("time",rsTime1+"-"+rsTime2);


        rsMap.put("date1",dateString3.substring(5,10));


@@ -456,6 +464,37 @@


        return dustlds;


    }




    /**


     * 路段排序


     * @param mac


     * @param startTime


     * @param endTime


     * @return


     */


    @Override


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


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


        List<SecondCruiserSort> secondCruiserSorts = secondCruiserSortMapper.getSort(mac, startTime, endTime);




        //校准尘负荷


        if (!ObjectUtils.isEmpty(secondCruiserSorts)){


            for (SecondCruiserSort secondCruiserSort : secondCruiserSorts) {


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


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


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


//                        secondCruiserSort.setAvg(numAvg(resultStr,BigDecimal.valueOf(secondCruiserSort.getAvg())).doubleValue());


                        secondCruiserSort.setAvg((double) Math.round(numAvg(resultStr, BigDecimal.valueOf(secondCruiserSort.getAvg())).doubleValue()));


                    }


                }else {


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


//                    secondCruiserSort.setAvg(BigDecimal.valueOf(secondCruiserSort.getAvg()).add(dataValue).doubleValue());


                    secondCruiserSort.setAvg((double) Math.round(BigDecimal.valueOf(secondCruiserSort.getAvg()).add(dataValue).doubleValue()));


                }


            }


        }


        return secondCruiserSorts;


    }






    //获取图片地址


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


@@ -489,5 +528,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;


    }


}