| | |
| | | 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 time1 = params.get("time1").toString(); |
| | | 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); |
| | | String time2 = params.get("time2").toString(); |
| | | String time2 = params.get("endTime").toString(); |
| | | String dateString2 = DateUtils.stringToDateString(time2, DateUtils.yyyy_MM_dd_HH_mm_ss_EN, DateUtils.yyyy_MM_dd_HH_mm_CN); |
| | | String rsTime2 = dateString2.substring(5, 14); |
| | | HashMap<String, Object> rsMap = new HashMap<>(); |
| | |
| | | Map<String, List<DustldDTO>> collect = manageCoordinateMapper.CompareTo(orgId).stream().collect(Collectors.groupingBy(o -> o.getName())); |
| | | Set<String> strings = collect.keySet(); |
| | | ArrayList<DustForm> list1 = new ArrayList<>(); |
| | | ArrayList<DustForm> list2 = new ArrayList<>(); |
| | | //所有的高值路段 |
| | | StringBuilder builder = new StringBuilder(); |
| | | |
| | | int i = 1; |
| | |
| | | for (DustldDTO dustldDTO : dustldDTOS) { |
| | | String flyLat = dustldDTO.getFlyLat(); |
| | | String flyLon = dustldDTO.getFlyLon(); |
| | | // if (flyLon==null && flyLat==null){ |
| | | // continue; |
| | | // } |
| | | 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 (flyLat1.equals(flyLat) && flyLon1.equals(flyLon)){ |
| | | 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; |
| | | } |
| | | if (dustld>=40 && dustld<60 ){ |
| | | }else if (dustld>=40 && dustld<60){ |
| | | dustld = dustld + 130; |
| | | } |
| | | if (dustld>=60 && dustld<100 ){ |
| | | }else if (dustld>=60 && dustld<100 ){ |
| | | dustld = dustld + 110; |
| | | } |
| | | if (dustld>=100 && dustld<150 ){ |
| | | }else if (dustld>=100 && dustld<150){ |
| | | dustld = dustld + 70; |
| | | } |
| | | if (dustld>=150 && dustld<180 ){ |
| | | }else if (dustld>=150 && dustld<180){ |
| | | dustld = dustld + 30; |
| | | } |
| | | doubleArrayList.add(dustld); |
| | |
| | | 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); |
| | | if (rsAvg>=0.3){ |
| | | builder.append("("+i+")"+string); |
| | | i++; |
| | | list1.add(dustForm); |
| | | //添加高值路段 |
| | | QueryWrapper<MaxRoad> wrapper = new QueryWrapper<>(); |
| | | wrapper.eq("name",string); |
| | |
| | | maxRoad.setTime(DateUtils.getDate(time1,DateUtils.yyyy_MM_dd_EN)); |
| | | maxRoadMapper.insert(maxRoad); |
| | | } |
| | | |
| | | }else { |
| | | list2.add(dustForm); |
| | | } |
| | | } |
| | | long timestamp2 = System.currentTimeMillis(); |
| | | log.info(timestamp2-timestamp+""); |
| | | //排序 |
| | | list1.sort(Comparator.comparing(DustForm::getValue).reversed()); |
| | | list2.sort(Comparator.comparing(DustForm::getValue).reversed()); |
| | | rsMap.put("list1",list1); |
| | | rsMap.put("list2",list2); |
| | | |
| | | |
| | | //获取上一次的高值路段 |
| | | ArrayList<Map<String, Object>> list3 = new ArrayList<>(); |
| | |
| | | wrapper2.eq("time",maxRoads.get(0).getTime()); |
| | | List<MaxRoad> maxRoads1 = maxRoadMapper.selectList(wrapper2); |
| | | |
| | | //合并数据 |
| | | ArrayList<DustForm> dustForms = new ArrayList<>(); |
| | | dustForms.addAll(list1); |
| | | dustForms.addAll(list2); |
| | | //获取两次路段相同的值 |
| | | for (MaxRoad road : maxRoads1) { |
| | | for (DustForm dustForm : dustForms) { |
| | | for (DustForm dustForm : list1) { |
| | | if (road.getName().equals(dustForm.getRoad())){ |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("road",road.getName()); |