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