From f832f967fb899a2fb25c5036834431a076d0beaa Mon Sep 17 00:00:00 2001 From: 于紫祥_1901 <email@yuzixiang_1910> Date: Wed, 18 Nov 2020 10:19:49 +0800 Subject: [PATCH] 风场更新 --- src/main/java/com/moral/controller/ScreenController.java | 8 ++++---- src/main/java/com/moral/service/impl/HistoryHourlyServiceImpl.java | 27 +++++++++++++-------------- 2 files changed, 17 insertions(+), 18 deletions(-) diff --git a/src/main/java/com/moral/controller/ScreenController.java b/src/main/java/com/moral/controller/ScreenController.java index 416054a..cd20e80 100644 --- a/src/main/java/com/moral/controller/ScreenController.java +++ b/src/main/java/com/moral/controller/ScreenController.java @@ -2071,7 +2071,7 @@ } else { mon = "" + month; } - String table = "history_minutely_" + year + mon; + String table = "history_five_minutely_" + year + mon; List list = deviceService.byMonitorIdGetDeviceAndWind(monitorPointId, table); return list; } @@ -2092,7 +2092,7 @@ } else { mon = "" + month; } - String table = "history_minutely_" + year + mon; + String table = "history_five_minutely_" + year + mon; List list = deviceService.byMonitorIdGetDeviceAndWindSpecial(monitorPointId, table); return list; } @@ -2692,7 +2692,7 @@ @ApiImplicitParams(value = { @ApiImplicitParam(name = "monitorPointIds", value = "������monitorid", required = true, paramType = "query", dataType = "String"), @ApiImplicitParam(name = "time", value = "������(���������2020-03-19)", required = true, paramType = "query", dataType = "String")}) - public List<List<Map>> monitorAVGData(HttpServletRequest request) throws Exception { + public ResultBean<List<List<Map>>> monitorAVGData(HttpServletRequest request) throws Exception { Map<String, Object> parameters = getParametersStartingWith(request, null); String monitorPointIds = (String) parameters.get("monitorPointIds"); String time = (String) parameters.get("time"); @@ -2717,6 +2717,6 @@ lists.add(dataAvbByMIdAndTime); } } - return lists; + return new ResultBean<List<List<Map>>>(lists); } } diff --git a/src/main/java/com/moral/service/impl/HistoryHourlyServiceImpl.java b/src/main/java/com/moral/service/impl/HistoryHourlyServiceImpl.java index ffaffab..4beb266 100644 --- a/src/main/java/com/moral/service/impl/HistoryHourlyServiceImpl.java +++ b/src/main/java/com/moral/service/impl/HistoryHourlyServiceImpl.java @@ -295,7 +295,7 @@ timeOfHour=timeOfHour+1; } O3_8.put("time", String.valueOf(timeOfHour)); - O3_8.put("O3-8h", String.valueOf(avg1)); + O3_8.put("O3_8h", String.valueOf(avg1)); mapList1.add(O3_8); }else { continue; @@ -310,25 +310,24 @@ List<Map<String, String>> mapList1 = listArrayList.get(0); List<Double> O3List = new ArrayList(); for (Map<String, String> stringStringMap : mapList1) { - O3List.add(Double.parseDouble(stringStringMap.get("O3-8h"))); + O3List.add(Double.parseDouble(stringStringMap.get("O3_8h"))); } - maxO3 = Collections.max(O3List); for (int i = 0; i <dataAvbByMIdAndTime.size() ; i++) { - dataAvbByMIdAndTime.get(i).put("O3-8h",null); + dataAvbByMIdAndTime.get(i).put("O3_8h",null); int time = Integer.parseInt(((Object)dataAvbByMIdAndTime.get(i).get("time")).toString().substring(11,13)) ; for (int j = 0; j <mapList1.size() ; j++) { int time1 = Integer.parseInt(mapList1.get(j).get("time").toString()) ; if (time==time1){ - Double O3_8h = Double.parseDouble(mapList1.get(j).get("O3-8h").toString()); - dataAvbByMIdAndTime.get(i).put("O3-8h",new BigDecimal(O3_8h).setScale(4,BigDecimal.ROUND_HALF_UP).doubleValue()); + Double O3_8h = Double.parseDouble(mapList1.get(j).get("O3_8h").toString()); + dataAvbByMIdAndTime.get(i).put("O3_8h",new BigDecimal(O3_8h).setScale(4,BigDecimal.ROUND_HALF_UP).doubleValue()); } } } } Map<String, Object> dailyAvgData = historyMapper.getDailyAvgData(mId, startTime); if (dailyAvgData!=null){ - dailyAvgData.put("maxO3-8h",new BigDecimal(maxO3).setScale(4,BigDecimal.ROUND_HALF_UP).doubleValue()); + dailyAvgData.put("maxO3_8h",new BigDecimal(maxO3).setScale(4,BigDecimal.ROUND_HALF_UP).doubleValue()); dailyAvgData.put("time",startTime); } if (dataAvbByMIdAndTime.size()>24){ @@ -338,9 +337,9 @@ dataAvbByMIdAndTime.get(i).put("AQI",Double.parseDouble(map1.get("AQI").toString())); if (Double.parseDouble(map1.get("AQI").toString())>=50){ String name = map1.get("maxSensor").toString(); - dataAvbByMIdAndTime.get(i).put("���������������",name); + dataAvbByMIdAndTime.get(i).put("primary_pollutants",name); }else { - dataAvbByMIdAndTime.get(i).put("���������������","-"); + dataAvbByMIdAndTime.get(i).put("primary_pollutants","-"); } } }else { @@ -350,14 +349,14 @@ dataAvbByMIdAndTime.get(i).put("AQI",Double.parseDouble(map1.get("AQI").toString())); if (Double.parseDouble(map1.get("AQI").toString())>=50){ String name = map1.get("maxSensor").toString(); - dataAvbByMIdAndTime.get(i).put("���������������",name); + dataAvbByMIdAndTime.get(i).put("primary_pollutants",name); }else { - dataAvbByMIdAndTime.get(i).put("���������������","-"); + dataAvbByMIdAndTime.get(i).put("primary_pollutants","-"); } } } Map<String, Object> dayAQI = AQICalculation2.dayAQI(dailyAvgData); - dailyAvgData.put("���������������",dayAQI.get("maxSensor")); + dailyAvgData.put("primary_pollutants",dayAQI.get("maxSensor")); dailyAvgData.put("AQI",dayAQI.get("AQI")); dataAvbByMIdAndTime.add(dataAvbByMIdAndTime.size(),dailyAvgData); @@ -367,13 +366,13 @@ if (i!=dataAvbByMIdAndTime.size()-1){ String time = dataAvbByMIdAndTime.get(i).get("time").toString().substring(11,13); dataAvbByMIdAndTime.get(i).remove("time"); - timeAndDate.put("time",time); + timeAndDate.put("time",time+"H"); timeAndDate.put("data",dataAvbByMIdAndTime.get(i)); finalList.add(timeAndDate); }else { String time = dataAvbByMIdAndTime.get(i).get("time").toString().substring(0,11); dataAvbByMIdAndTime.get(i).remove("time"); - timeAndDate.put("time",time); + timeAndDate.put("time",time+"H"); timeAndDate.put("data",dataAvbByMIdAndTime.get(i)); finalList.add(timeAndDate); } -- Gitblit v1.8.0