From 57b29a43e4d1505d44e1ac82ed61ef640ba49e8c Mon Sep 17 00:00:00 2001 From: cjl <276999030@qq.com> Date: Wed, 27 Sep 2023 19:16:33 +0800 Subject: [PATCH] ci:持续修改 --- screen-api/src/main/java/com/moral/api/service/impl/RegionServiceImpl.java | 318 ++++++++++++++++++++++++++++++++-------------------- 1 files changed, 193 insertions(+), 125 deletions(-) diff --git a/screen-api/src/main/java/com/moral/api/service/impl/RegionServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/RegionServiceImpl.java index 834b1d3..b8d65b6 100644 --- a/screen-api/src/main/java/com/moral/api/service/impl/RegionServiceImpl.java +++ b/screen-api/src/main/java/com/moral/api/service/impl/RegionServiceImpl.java @@ -79,7 +79,7 @@ @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"); @@ -139,13 +139,13 @@ } @Override - public List<Map<String, Object>> regionContribution(Map<String, Object> params) { + public Map<String, Object> regionContribution(Map<String, Object> params) { int orgId = Integer.parseInt(params.get("organizationId").toString()); List<String> regionCodes = Arrays.asList(params.get("regionCodes").toString().split(",")); String type = params.get("type").toString(); String time = params.get("time").toString(); String sensorCode = params.get("sensorCode").toString(); - List<Map<String, Object>> result = new ArrayList<>(); + Map<String, Object> result = new HashMap<>(); switch (type) { case "year": result = regionContributionOfYear(orgId, regionCodes, time, sensorCode); @@ -163,8 +163,13 @@ } //��������������� - private List<Map<String, Object>> regionContributionOfYear(Integer orgId, List<String> regionCodes, String time, String sensorCode) { - List<Map<String, Object>> result = new ArrayList<>(); + private Map<String, Object> regionContributionOfYear(Integer orgId, List<String> regionCodes, String time, String sensorCode) { + Map<String, Object> result = new HashMap<>(); + + //1.������������������ + List<String> timeLag = DateUtils.getTimeLag(time); + result.put("time", timeLag); + //������������������������������ QueryWrapper<Organization> organizationQueryWrapper = new QueryWrapper<>(); @@ -172,10 +177,6 @@ .eq("id", orgId); Integer locationLevelCode = organizationService.getOne(organizationQueryWrapper).getLocationLevelCode(); - //��������������������������� - List<String> allMacs = deviceService.getMacsByOrganizationId(orgId); - - List<String> timeLag = DateUtils.getTimeLag(time); //��������������������������� QueryWrapper<CityAqiMonthly> cityAqiMonthlyQueryWrapper = new QueryWrapper<>(); @@ -191,25 +192,26 @@ } - //��������������������������������� + //��������������������������������������������������� + List<String> allMacs = deviceService.getMacsByOrganizationId(orgId); List<HistoryMonthly> allDeviceData = historyMonthlyService.getValueByMacs(allMacs, time); - //���time������ Map<String, List<HistoryMonthly>> allDeviceDataMap = allDeviceData.stream() .collect(Collectors.groupingBy(o -> DateUtils.dateToDateString(o.getTime()).substring(0, 7))); + //��������������������� + Map<String, Object> resultCityDataMap = new HashMap<>(); + List<Map<String, Object>> cityDataList = new ArrayList<>(); + //������������������������������������ + Map<String, Object> allDeviceSumMap = new HashMap<>(); for (String yearMonth : timeLag) { - Map<String, Object> resultMap = new HashMap<>(); - resultMap.put("time", yearMonth); - - //������������������������������ Double allDeviceSum = null; List<HistoryMonthly> historyMonthlyList = allDeviceDataMap.get(yearMonth); if (!ObjectUtils.isEmpty(historyMonthlyList)) { allDeviceSum = historyMonthlyService.calculatedValue(historyMonthlyList, sensorCode, "sum"); } - resultMap.put("allDeviceSum", allDeviceSum); + allDeviceSumMap.put(yearMonth, allDeviceSum); //��������� @@ -219,71 +221,92 @@ //������������aqi������������������������ String sensorName = senorMap.get(sensorCode); if (sensorName != null) { - cityValue = (Double) dataValue.get(sensorName); + cityValue = Double.parseDouble(dataValue.get(sensorName).toString()); } } - resultMap.put("cityValue", cityValue); - result.add(resultMap); + Map<String, Object> cityDataMap = new HashMap<>(); + //������������ + cityDataMap.put("value", cityValue); + cityDataList.add(cityDataMap); } + //2.������������������ + resultCityDataMap.put("data", cityDataList); + result.put("������", resultCityDataMap); + + for (String regionCode : regionCodes) { + //��������������������������������� + HashMap<String, Object> regionMap = new HashMap<>(); + List<Map<String, Object>> dataList = new ArrayList<>(); + + + //������������������ QueryWrapper<SysArea> queryWrapper = new QueryWrapper<>(); queryWrapper.select("area_name").eq("area_code", Integer.parseInt(regionCode)); String regionName = sysAreaService.getOne(queryWrapper).getAreaName(); - //��������������������������������� - List<String> regionMacs = deviceService.getMacsByOrgIdAndRegionCode(orgId, Integer.parseInt(regionCode)); - //������������������������������������������ + //���������������������������������,��������������������� + List<String> regionMacs = deviceService.getMacsByOrgIdAndRegionCode(orgId, Integer.parseInt(regionCode)); List<HistoryMonthly> regionDeviceData = historyMonthlyService.getValueByMacs(regionMacs, time); //���time������ Map<String, List<HistoryMonthly>> regionDataMap = regionDeviceData.stream() .collect(Collectors.groupingBy(o -> DateUtils.dateToDateString(o.getTime()).substring(0, 7))); - for (Map<String, Object> map : result) { - Object allDeviceSum = map.get("allDeviceSum"); - String resultTime = map.get("time").toString(); - List<HistoryMonthly> historyMonthlyList = regionDataMap.get(resultTime); + for (String resultTime : timeLag) { + //��������������������� + Map<String, Object> timeDataMap = new HashMap<>(); + Object o = allDeviceSumMap.get(resultTime); + Double allDeviceSum = null; + if (o != null) { + allDeviceSum = Double.parseDouble(o.toString()); + } + + List<HistoryMonthly> regionDeviceHistoryMonthlyList = regionDataMap.get(resultTime); //��������� String contributionRate = null; Double regionAvg = null; - if (!ObjectUtils.isEmpty(historyMonthlyList)) { - regionAvg = historyMonthlyService.calculatedValue(historyMonthlyList, sensorCode, "avg"); - Double regionSum = historyMonthlyService.calculatedValue(historyMonthlyList, sensorCode, "sum"); - //��������������������� + if (!ObjectUtils.isEmpty(regionDeviceHistoryMonthlyList)) { + //��������������������������� + regionAvg = historyMonthlyService.calculatedValue(regionDeviceHistoryMonthlyList, sensorCode, "avg"); + //��������������������������� + Double regionSum = historyMonthlyService.calculatedValue(regionDeviceHistoryMonthlyList, sensorCode, "sum"); + //��������������������������� NumberFormat numberFormat = NumberFormat.getInstance(); numberFormat.setMaximumFractionDigits(2); - if (allDeviceSum != null) { - contributionRate = numberFormat.format(regionSum / ((Double) allDeviceSum) * 100) + "%"; - System.out.println(regionSum + "===" + allDeviceSum); + if (allDeviceSum != null && allDeviceSum != 0d) { + contributionRate = numberFormat.format(regionSum / (allDeviceSum) * 100) + "%"; } } - Map<String, Object> professionMap = new HashMap<>(); - professionMap.put("contributionRate", contributionRate); - professionMap.put("value", regionAvg == null ? null : AmendUtils.sciCal(regionAvg, 0)); - map.put(regionName, professionMap); + + //������������������ + timeDataMap.put("value", regionAvg == null ? null : AmendUtils.sciCal(regionAvg, 0)); + //��������������������� + timeDataMap.put("name", contributionRate); + dataList.add(timeDataMap); } + regionMap.put("data", dataList); + result.put(regionName, regionMap); } - result.forEach(map -> map.remove("allDeviceSum")); return result; } //��������������� - private List<Map<String, Object>> regionContributionOfMonth(Integer orgId, List<String> regionCodes, String time, String sensorCode) { - List<Map<String, Object>> result = new ArrayList<>(); + private Map<String, Object> regionContributionOfMonth(Integer orgId, List<String> regionCodes, String time, String sensorCode) { + Map<String, Object> result = new HashMap<>(); + + //1.������������������ + List<String> timeLag = DateUtils.getTimeLag(time); + result.put("time", timeLag); + //������������������������������ QueryWrapper<Organization> organizationQueryWrapper = new QueryWrapper<>(); organizationQueryWrapper.select("location_level_code") .eq("id", orgId); Integer locationLevelCode = organizationService.getOne(organizationQueryWrapper).getLocationLevelCode(); - - //��������������������������� - List<String> allMacs = deviceService.getMacsByOrganizationId(orgId); - - //������������ - List<String> timeLag = DateUtils.getTimeLag(time); //��������������������������� @@ -300,24 +323,26 @@ } - //��������������������������������� + //��������������������������������������������������� + List<String> allMacs = deviceService.getMacsByOrganizationId(orgId); List<HistoryDaily> allDeviceData = historyDailyService.getValueByMacs(allMacs, time); - //���time������ Map<String, List<HistoryDaily>> allDeviceDataMap = allDeviceData.stream() .collect(Collectors.groupingBy(o -> DateUtils.dateToDateString(o.getTime()).substring(0, 10))); + //��������������������� + Map<String, Object> resultCityDataMap = new HashMap<>(); + List<Map<String, Object>> cityDataList = new ArrayList<>(); + //������������������������������������ + Map<String, Object> allDeviceSumMap = new HashMap<>(); for (String yearMonthDay : timeLag) { - Map<String, Object> resultMap = new HashMap<>(); - resultMap.put("time", yearMonthDay); - //������������������������������ Double allDeviceSum = null; List<HistoryDaily> historyDailyList = allDeviceDataMap.get(yearMonthDay); if (!ObjectUtils.isEmpty(historyDailyList)) { allDeviceSum = historyDailyService.calculatedValue(historyDailyList, sensorCode, "sum"); } - resultMap.put("allDeviceSum", allDeviceSum); + allDeviceSumMap.put(yearMonthDay, allDeviceSum); //��������� @@ -327,60 +352,85 @@ //������������aqi������������������������ String sensorName = senorMap.get(sensorCode); if (sensorName != null) { - cityValue = (Double) dataValue.get(sensorName); + cityValue = Double.parseDouble(dataValue.get(sensorName).toString()); } } - resultMap.put("cityValue", cityValue); - result.add(resultMap); + Map<String, Object> cityDataMap = new HashMap<>(); + //������������ + cityDataMap.put("value", cityValue); + cityDataList.add(cityDataMap); } + //2.������������������ + resultCityDataMap.put("data", cityDataList); + result.put("������", resultCityDataMap); + + for (String regionCode : regionCodes) { + //��������������������������������� + HashMap<String, Object> regionMap = new HashMap<>(); + List<Map<String, Object>> dataList = new ArrayList<>(); + + + //������������������ QueryWrapper<SysArea> queryWrapper = new QueryWrapper<>(); queryWrapper.select("area_name").eq("area_code", Integer.parseInt(regionCode)); String regionName = sysAreaService.getOne(queryWrapper).getAreaName(); - //��������������������������������� + + //���������������������������������,��������������������� List<String> regionMacs = deviceService.getMacsByOrgIdAndRegionCode(orgId, Integer.parseInt(regionCode)); - - - //������������������������������������ - List<HistoryDaily> professionDeviceData = historyDailyService.getValueByMacs(regionMacs, time); + List<HistoryDaily> regionDeviceData = historyDailyService.getValueByMacs(regionMacs, time); //���time������ - Map<String, List<HistoryDaily>> professionDataMap = professionDeviceData.stream() + Map<String, List<HistoryDaily>> regionDataMap = regionDeviceData.stream() .collect(Collectors.groupingBy(o -> DateUtils.dateToDateString(o.getTime()).substring(0, 10))); - for (Map<String, Object> map : result) { - Object allDeviceSum = map.get("allDeviceSum"); - String resultTime = map.get("time").toString(); - List<HistoryDaily> historyDailyList = professionDataMap.get(resultTime); + for (String resultTime : timeLag) { + //��������������������� + Map<String, Object> timeDataMap = new HashMap<>(); + Object o = allDeviceSumMap.get(resultTime); + Double allDeviceSum = null; + if (o != null) { + allDeviceSum = Double.parseDouble(o.toString()); + } + + List<HistoryDaily> regionDeviceHistoryDailyList = regionDataMap.get(resultTime); //��������� String contributionRate = null; Double regionAvg = null; - if (!ObjectUtils.isEmpty(historyDailyList)) { - //��������������������� - regionAvg = historyDailyService.calculatedValue(historyDailyList, sensorCode, "avg"); - //������������������������ - Double regionSum = historyDailyService.calculatedValue(historyDailyList, sensorCode, "sum"); - //��������������������� + if (!ObjectUtils.isEmpty(regionDeviceHistoryDailyList)) { + //��������������������������� + regionAvg = historyDailyService.calculatedValue(regionDeviceHistoryDailyList, sensorCode, "avg"); + //��������������������������� + Double regionSum = historyDailyService.calculatedValue(regionDeviceHistoryDailyList, sensorCode, "sum"); + //��������������������������� NumberFormat numberFormat = NumberFormat.getInstance(); numberFormat.setMaximumFractionDigits(2); - if (allDeviceSum != null) { - contributionRate = numberFormat.format(regionSum / ((Double) allDeviceSum) * 100) + "%"; + if (allDeviceSum != null && allDeviceSum != 0d) { + contributionRate = numberFormat.format(regionSum / (allDeviceSum) * 100) + "%"; } } - Map<String, Object> professionMap = new HashMap<>(); - professionMap.put("contributionRate", contributionRate); - professionMap.put("value", regionAvg == null ? null : AmendUtils.sciCal(regionAvg, 0)); - map.put(regionName, professionMap); + + //������������������ + timeDataMap.put("value", regionAvg == null ? null : AmendUtils.sciCal(regionAvg, 0)); + //��������������������� + timeDataMap.put("name", contributionRate); + dataList.add(timeDataMap); } + regionMap.put("data", dataList); + result.put(regionName, regionMap); } - result.forEach(map -> map.remove("allDeviceSum")); return result; } - private List<Map<String, Object>> regionContributionOfDay(Integer orgId, List<String> regionCodes, String time, String sensorCode) { - List<Map<String, Object>> result = new ArrayList<>(); + private Map<String, Object> regionContributionOfDay(Integer orgId, List<String> regionCodes, String time, String sensorCode) { + Map<String, Object> result = new HashMap<>(); + + //1.������������������ + List<String> timeLag = DateUtils.getTimeLag(time); + result.put("time", timeLag); + //������������������������������ QueryWrapper<Organization> organizationQueryWrapper = new QueryWrapper<>(); @@ -392,15 +442,12 @@ QueryWrapper<Sensor> sensorQueryWrapper = new QueryWrapper<>(); sensorQueryWrapper.select("lower", "upper").eq("code", sensorCode); Sensor sensor = sensorService.getOne(sensorQueryWrapper); - Double sensorLower = sensor.getLower(); - Double sensorUpper = sensor.getUpper(); - - //��������������������������� - List<String> allMacs = deviceService.getMacsByOrganizationId(orgId); - - //��������������� - List<String> timeLag = DateUtils.getTimeLag(time); - + Double sensorLower = null; + Double sensorUpper = null; + if (sensor != null) { + sensorLower = sensor.getLower(); + sensorUpper = sensor.getUpper(); + } //������������������������������ QueryWrapper<CityAqi> cityAqiQueryWrapper = new QueryWrapper<>(); @@ -416,83 +463,104 @@ } - //������������������������������������ + //������������������������������������������������������ + List<String> allMacs = deviceService.getMacsByOrganizationId(orgId); List<HistoryHourly> allDeviceData = historyHourlyService.getValueByMacs(allMacs, time); - //���time������ Map<String, List<HistoryHourly>> allDeviceDataMap = allDeviceData.stream() .collect(Collectors.groupingBy(o -> DateUtils.dateToDateString(o.getTime()).substring(0, 13))); - for (String yearMonthDayHour : timeLag) { - Map<String, Object> resultMap = new HashMap<>(); - resultMap.put("time", yearMonthDayHour); - - + //��������������������� + Map<String, Object> resultCityDataMap = new HashMap<>(); + List<Map<String, Object>> cityDataList = new ArrayList<>(); + //������������������������������������ + Map<String, Object> allDeviceSumMap = new HashMap<>(); + for (String yearMonthDay : timeLag) { //������������������������������ Double allDeviceSum = null; - List<HistoryHourly> historyHourlyList = allDeviceDataMap.get(yearMonthDayHour); + List<HistoryHourly> historyHourlyList = allDeviceDataMap.get(yearMonthDay); if (!ObjectUtils.isEmpty(historyHourlyList)) { allDeviceSum = historyHourlyService.calculatedValue(historyHourlyList, sensorCode, "sum", sensorLower, sensorUpper); } - resultMap.put("allDeviceSum", allDeviceSum); + allDeviceSumMap.put(yearMonthDay, allDeviceSum); //��������� Double cityValue = null; - if (cityAqiMap.get(yearMonthDayHour) != null) { - Map<String, Object> dataValue = JSONObject.parseObject(cityAqiMap.get(yearMonthDayHour).toString(), Map.class); + if (cityAqiMap.get(yearMonthDay) != null) { + Map<String, Object> dataValue = JSONObject.parseObject(cityAqiMap.get(yearMonthDay).toString(), Map.class); //������������aqi������������������������ String sensorName = senorMap.get(sensorCode); if (sensorName != null) { cityValue = Double.parseDouble(dataValue.get(sensorName).toString()); } } - resultMap.put("cityValue", cityValue); - result.add(resultMap); + Map<String, Object> cityDataMap = new HashMap<>(); + //������������ + cityDataMap.put("value", cityValue); + cityDataList.add(cityDataMap); } + //2.������������������ + resultCityDataMap.put("data", cityDataList); + result.put("������", resultCityDataMap); + + for (String regionCode : regionCodes) { + //��������������������������������� + HashMap<String, Object> regionMap = new HashMap<>(); + List<Map<String, Object>> dataList = new ArrayList<>(); + + + //������������������ QueryWrapper<SysArea> queryWrapper = new QueryWrapper<>(); queryWrapper.select("area_name").eq("area_code", Integer.parseInt(regionCode)); String regionName = sysAreaService.getOne(queryWrapper).getAreaName(); - //��������������������������������� + + //���������������������������������,������������������������ List<String> regionMacs = deviceService.getMacsByOrgIdAndRegionCode(orgId, Integer.parseInt(regionCode)); - - - //��������������������������������������� - List<HistoryHourly> professionDeviceData = historyHourlyService.getValueByMacs(regionMacs, time); + List<HistoryHourly> regionDeviceData = historyHourlyService.getValueByMacs(regionMacs, time); //���time������ - Map<String, List<HistoryHourly>> professionDataMap = professionDeviceData.stream() + Map<String, List<HistoryHourly>> regionDataMap = regionDeviceData.stream() .collect(Collectors.groupingBy(o -> DateUtils.dateToDateString(o.getTime()).substring(0, 13))); - for (Map<String, Object> map : result) { - Object allDeviceSum = map.get("allDeviceSum"); - String resultTime = map.get("time").toString(); - List<HistoryHourly> historyHourlyList = professionDataMap.get(resultTime); + for (String resultTime : timeLag) { + //��������������������� + Map<String, Object> timeDataMap = new HashMap<>(); + Object o = allDeviceSumMap.get(resultTime); + Double allDeviceSum = null; + if (o != null) { + allDeviceSum = Double.parseDouble(o.toString()); + } + + List<HistoryHourly> regionDeviceHistoryHourlyList = regionDataMap.get(resultTime); //��������� String contributionRate = null; Double regionAvg = null; - if (!ObjectUtils.isEmpty(historyHourlyList)) { - //��������������������� - regionAvg = historyHourlyService.calculatedValue(historyHourlyList, sensorCode, "avg", sensorLower, sensorUpper); - //������������������������ - Double regionSum = historyHourlyService.calculatedValue(historyHourlyList, sensorCode, "sum", sensorLower, sensorUpper); - //��������������������� + if (!ObjectUtils.isEmpty(regionDeviceHistoryHourlyList)) { + //��������������������������� + regionAvg = historyHourlyService.calculatedValue(regionDeviceHistoryHourlyList, sensorCode, "avg", sensorLower, sensorUpper); + //��������������������������� + Double regionSum = historyHourlyService.calculatedValue(regionDeviceHistoryHourlyList, sensorCode, "sum", sensorLower, sensorUpper); + //��������������������������� NumberFormat numberFormat = NumberFormat.getInstance(); numberFormat.setMaximumFractionDigits(2); - if (allDeviceSum != null) { - contributionRate = numberFormat.format(regionSum / ((Double) allDeviceSum) * 100) + "%"; + if (allDeviceSum != null && allDeviceSum != 0d) { + contributionRate = numberFormat.format(regionSum / (allDeviceSum) * 100) + "%"; } } - Map<String, Object> professionMap = new HashMap<>(); - professionMap.put("contributionRate", contributionRate); - professionMap.put("value", regionAvg == null ? null : AmendUtils.sciCal(regionAvg, 0)); - map.put(regionName, professionMap); + + //������������������ + timeDataMap.put("value", regionAvg == null ? null : AmendUtils.sciCal(regionAvg, 0)); + //��������������������� + timeDataMap.put("name", contributionRate); + dataList.add(timeDataMap); } + regionMap.put("data", dataList); + result.put(regionName, regionMap); } - result.forEach(map -> map.remove("allDeviceSum")); return result; } } -- Gitblit v1.8.0