| | |
| | | import org.springframework.util.ObjectUtils; |
| | | |
| | | import java.text.NumberFormat; |
| | | import java.util.ArrayList; |
| | | import java.util.Arrays; |
| | | import java.util.Collections; |
| | | import java.util.HashMap; |
| | | import java.util.HashSet; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.Set; |
| | | import java.util.*; |
| | | import java.util.stream.Collectors; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | |
| | | @Autowired |
| | | private SensorService sensorService; |
| | | |
| | | private static Map<String, String> senorMap = new HashMap<>(); |
| | | private static final Map<String, String> senorMap = new HashMap<>(); |
| | | |
| | | static { |
| | | senorMap.put(Constants.SENSOR_CODE_PM25, "PM2_5"); |
| | |
| | | List<Map<String, Object>> devices = deviceService.getDevicesByOrganizationId(organizationId); |
| | | Set<Map<String, Object>> result = new HashSet<>(); |
| | | for (Map<String, Object> device : devices) { |
| | | List<Map<String, Object>> professions = (List<Map<String, Object>>) device.get("professions"); |
| | | result.addAll(professions); |
| | | if(Objects.nonNull(device)&&Objects.nonNull(device.get("professions"))&&device.containsKey("professions")){ |
| | | List<Map<String, Object>> professions = (List<Map<String, Object>>) device.get("professions"); |
| | | result.addAll(professions); |
| | | } |
| | | } |
| | | return result; |
| | | } |
| | |
| | | } |
| | | Map<String, Object> cityDataMap = new HashMap<>(); |
| | | //本市数据 |
| | | cityDataMap.put("name", cityValue); |
| | | cityDataMap.put("value", cityValue); |
| | | cityDataList.add(cityDataMap); |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | //行业均值 |
| | | timeDataMap.put("name", professionAvg == null ? null : AmendUtils.sciCal(professionAvg, 0)); |
| | | timeDataMap.put("value", professionAvg == null ? null : AmendUtils.sciCal(professionAvg, 0)); |
| | | //贡献率 |
| | | timeDataMap.put("value", contributionRate); |
| | | timeDataMap.put("name", contributionRate); |
| | | dataList.add(timeDataMap); |
| | | } |
| | | professionMap.put("data", dataList); |
| | |
| | | } |
| | | Map<String, Object> cityDataMap = new HashMap<>(); |
| | | //本市数据 |
| | | cityDataMap.put("name", cityValue); |
| | | cityDataMap.put("value", cityValue); |
| | | cityDataList.add(cityDataMap); |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | //行业均值 |
| | | timeDataMap.put("name", professionAvg == null ? null : AmendUtils.sciCal(professionAvg, 0)); |
| | | timeDataMap.put("value", professionAvg == null ? null : AmendUtils.sciCal(professionAvg, 0)); |
| | | //贡献率 |
| | | timeDataMap.put("value", contributionRate); |
| | | timeDataMap.put("name", contributionRate); |
| | | dataList.add(timeDataMap); |
| | | } |
| | | professionMap.put("data", dataList); |
| | |
| | | } |
| | | Map<String, Object> cityDataMap = new HashMap<>(); |
| | | //本市数据 |
| | | cityDataMap.put("name", cityValue); |
| | | cityDataMap.put("value", cityValue); |
| | | cityDataList.add(cityDataMap); |
| | | } |
| | | |
| | |
| | | } |
| | | |
| | | //行业均值 |
| | | timeDataMap.put("name", professionAvg == null ? null : AmendUtils.sciCal(professionAvg, 0)); |
| | | timeDataMap.put("value", professionAvg == null ? null : AmendUtils.sciCal(professionAvg, 0)); |
| | | //贡献率 |
| | | timeDataMap.put("value", contributionRate); |
| | | timeDataMap.put("name", contributionRate); |
| | | dataList.add(timeDataMap); |
| | | } |
| | | professionMap.put("data", dataList); |