From 6919ec8dbbbc9338cbc6b5bc1c43ba0d14d5634b Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Fri, 07 Aug 2020 17:57:06 +0800
Subject: [PATCH] update,大屏O3预测

---
 src/main/resources/mapper/ForecastWeatherMapper.xml          |   12 +-
 src/main/java/com/moral/entity/ForecastWeather.java          |    2 
 src/main/resources/mapper/RealWeatherMapper.xml              |    6 
 src/main/resources/mapper/HangzhouAqiMapper.xml              |    4 
 src/main/java/com/moral/mapper/AreaMapper.java               |    3 
 src/main/resources/mapper/AreaMapper.xml                     |    5 +
 src/main/java/com/moral/entity/RealWeather.java              |    2 
 src/main/java/com/moral/controller/ScreenController.java     |    3 
 src/main/java/com/moral/service/impl/WeatherServiceImpl.java |  214 +++++++++++++++++++++++-------------------
 9 files changed, 137 insertions(+), 114 deletions(-)

diff --git a/src/main/java/com/moral/controller/ScreenController.java b/src/main/java/com/moral/controller/ScreenController.java
index 97d4bcd..6f3b199 100644
--- a/src/main/java/com/moral/controller/ScreenController.java
+++ b/src/main/java/com/moral/controller/ScreenController.java
@@ -1964,7 +1964,6 @@
             @ApiImplicitParam(name = "time", value = "������(���������2020-03-19)", required = true, paramType = "query", dataType = "String")})
     public ResultBean<List<Map<String, Object>>> getWeatherNextDayDataByRegion(HttpServletRequest request) throws Exception {
         Map<String, Object> parameters = getParametersStartingWith(request, null);
-        parameters.put("typeFormat", "%Y-%m-%d %H:%i:%s");
         List<Map<String, Object>> resultList = weatherService.getForecastAndReal(parameters);
         return new ResultBean<List<Map<String, Object>>>(resultList);
     }
@@ -1976,7 +1975,6 @@
             @ApiImplicitParam(name = "time", value = "������(���������2020-03-19)", required = true, paramType = "query", dataType = "String")})
     public ResultBean<List<Map<String, Object>>> getWeatherData(HttpServletRequest request) throws Exception {
         Map<String, Object> parameters = getParametersStartingWith(request, null);
-        parameters.put("typeFormat", "%Y-%m-%d %H:%i:%s");
         List<Map<String, Object>> weatherList = weatherService.getWeatherData(parameters);
         return new ResultBean<List<Map<String, Object>>>(weatherList);
     }
@@ -2088,4 +2086,5 @@
         }
         return new ResultBean<List<Map<String, Object>>>(list);
     }
+
 }
diff --git a/src/main/java/com/moral/entity/ForecastWeather.java b/src/main/java/com/moral/entity/ForecastWeather.java
index d61c829..3111e6e 100644
--- a/src/main/java/com/moral/entity/ForecastWeather.java
+++ b/src/main/java/com/moral/entity/ForecastWeather.java
@@ -9,7 +9,7 @@
 @Data
 public class ForecastWeather {
     @Id
-    private Integer monitorPointId;
+    private String cityCode;
 
     private Date time;
 
diff --git a/src/main/java/com/moral/entity/RealWeather.java b/src/main/java/com/moral/entity/RealWeather.java
index cb099ea..3907f99 100644
--- a/src/main/java/com/moral/entity/RealWeather.java
+++ b/src/main/java/com/moral/entity/RealWeather.java
@@ -9,7 +9,7 @@
 @Data
 public class RealWeather {
     @Id
-    private Integer monitorPointId;
+    private String cityCode;
 
     private Date time;
 
diff --git a/src/main/java/com/moral/mapper/AreaMapper.java b/src/main/java/com/moral/mapper/AreaMapper.java
index c381477..bdb8064 100644
--- a/src/main/java/com/moral/mapper/AreaMapper.java
+++ b/src/main/java/com/moral/mapper/AreaMapper.java
@@ -1,5 +1,7 @@
 package com.moral.mapper;
 
+import java.util.List;
+
 import org.apache.ibatis.annotations.Param;
 
 import com.moral.common.mapper.BaseMapper;
@@ -9,4 +11,5 @@
 
     Area getAreaByName(@Param(value="name") String name);
 
+    List<Area> getAreaByCityCode(@Param(value="cityCode") Integer cityCode);
 }
\ No newline at end of file
diff --git a/src/main/java/com/moral/service/impl/WeatherServiceImpl.java b/src/main/java/com/moral/service/impl/WeatherServiceImpl.java
index 3eae89e..2114c71 100644
--- a/src/main/java/com/moral/service/impl/WeatherServiceImpl.java
+++ b/src/main/java/com/moral/service/impl/WeatherServiceImpl.java
@@ -176,6 +176,7 @@
 
     @Override
     public List<Map<String, Object>> getForecastAndReal(Map<String, Object> parameters) throws ParseException {
+        parameters.put("typeFormat", "%Y-%m-%d %H:%i:%s");
         String monitorPointId = parameters.get("monitorPointId").toString();
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
         String time = parameters.get("time").toString() + " 00:00:00";
@@ -187,17 +188,20 @@
         String nextDay = sdf.format(c.getTime());
         parameters.put("start", sdf.parse(time));
         parameters.put("end", sdf.parse(nextDay));
-        List<Map<String, Object>> forecastList = forecastWeatherMapper.getForecastHour(parameters);
         MonitorPoint monitorPoint = monitorPointMapper.selectByPrimaryKey(Integer.valueOf(monitorPointId));
-        parameters.put("areaCode", monitorPoint.getAreaCode());
-        String sensors = "O3C";
-        String sensor1 = "O3";
-        parameters.put("sensors", sensors);
-        parameters.put("sensors1", sensor1);
-        parameters.put("sensors2", sensor1);
+
+        //List<Map<String, Object>> forecastList = forecastWeatherMapper.getForecastHour(parameters);
+
+        if (monitorPoint.getAreaCode() == null) {
+            parameters.put("cityCode", monitorPoint.getCityCode());
+        } else {
+            parameters.put("cityCode", monitorPoint.getAreaCode());
+        }
         List<Map<String, Object>> aqiList = hangzhouAqiMapper.getAqiDataByAreaCode(parameters);
+        List<Map<String, Object>> forecastList = forecastWeatherMapper.getForecastHour(parameters);
+
         if (aqiList.size() == 0) {
-            parameters.put("areaCode", monitorPoint.getCityCode());
+            parameters.put("cityCode", monitorPoint.getCityCode());
             aqiList = hangzhouAqiMapper.getAqiDataByAreaCode(parameters);
         }
         for (Map<String, Object> map : aqiList) {
@@ -218,7 +222,7 @@
                 }
                 map.put("time", Integer.valueOf(hour));
                 values.add("");
-                values.add(aqiMap.get(sensor1).toString());
+                values.add(aqiMap.get("O3").toString());
                 map.put("values", values);
                 resultList.add(map);
             }
@@ -257,7 +261,7 @@
                 }
                 for (Map<String, Object> aqiMap : aqiList) {
                     if (forecastMap.get("time").equals(aqiMap.get("time"))) {
-                        values.add(aqiMap.get(sensor1).toString());
+                        values.add(aqiMap.get("O3").toString());
                     }
                 }
                 map.put("values", values);
@@ -275,59 +279,69 @@
 
     @Override
     public List<Map<String, Object>> getWeatherData(Map<String, Object> parameters) throws ParseException {
+        parameters.put("typeFormat", "%Y-%m-%d %H:%i:%s");
         String cityName = parameters.get("city").toString();
         Area area = areaMapper.getAreaByName(cityName);
         MonitorPoint monitorPoint;
-        Integer areaCode = 0;
-        Integer cityCode = 0;
+        Integer parentCode = 0;
+        Integer code = 0;
+        String name = "";
         if (area == null) {
             City city = cityMapper.getCityByName(cityName);
             if (city == null) {
                 Province province = provinceMapper.getProvinceByName(cityName);
-                Integer provinceCode = province.getProvinceCode();
-                monitorPoint = monitorPointMapper.getFirstMonitorPointByProvinceCode(provinceCode);
-                parameters.put("areaCode", provinceCode);
-                parameters.put("city", province.getProvinceName());
+                code = province.getProvinceCode();
+                name = province.getProvinceName();
             } else {
-                cityCode = city.getCityCode();
-                monitorPoint = monitorPointMapper.getFirstMonitorPointByCityCode(cityCode);
-                parameters.put("areaCode", cityCode);
-                parameters.put("city", city.getCityName());
+                code = city.getCityCode();
+                parentCode = city.getProvinceCode();
+                name = city.getCityName();
             }
         } else {
-            areaCode = area.getAreaCode();
-            monitorPoint = monitorPointMapper.getFirstMonitorPointByAreaCode(areaCode);
-            cityCode = area.getCityCode();
-            parameters.put("areaCode", areaCode);
-            parameters.put("city", area.getAreaName());
+            code = area.getAreaCode();
+            parentCode = area.getCityCode();
+            name = area.getAreaName();
         }
-        if (monitorPoint == null) {
-            return new ArrayList<>();
-        }
-        parameters.put("monitorPointId", monitorPoint.getId());
+
+        parameters.put("cityCode", code);
+        parameters.put("name", name);
+        parameters.put("areaCode", code);
+
+
         String time = parameters.get("time").toString();
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
         SimpleDateFormat sdf1 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
         Date now = new Date();
-        Date selectTime = sdf1.parse(time + " 00:00:00");
-        Calendar c1 = Calendar.getInstance();
-        c1.setTime(selectTime);
-        c1.add(Calendar.DAY_OF_MONTH, -1);
-        Date beforeDay = c1.getTime();
-        String format = sdf.format(beforeDay);
-        Calendar c = Calendar.getInstance();
-        c.setTime(sdf.parse(time));
-        c.add(Calendar.HOUR_OF_DAY, 1);
-        Date start = c.getTime();
-        c.add(Calendar.DAY_OF_MONTH, 1);
-        Date end = c.getTime();
-        parameters.put("start", start);
+        Date selectTime = sdf1.parse(time + " 01:00:00");
+        Calendar cal = Calendar.getInstance();
+        cal.setTime(selectTime);
+        cal.add(Calendar.DAY_OF_MONTH, 1);
+        Date end = cal.getTime();
+        cal.setTime(sdf.parse(time));
+        cal.add(Calendar.DAY_OF_MONTH, -1);
+        String beforeDay = sdf.format(cal.getTime());
+        parameters.put("start", selectTime);
         parameters.put("end", end);
         List<Map<String, Object>> forecastList = forecastWeatherMapper.getForecast(parameters);
+        if (forecastList.size() == 0) {
+            parameters.put("cityCode", parentCode);
+            forecastList = forecastWeatherMapper.getForecast(parameters);
+            if (forecastList.size() == 0) {
+                List<Area> areaList = areaMapper.getAreaByCityCode(code);
+                for (Area area1 : areaList) {
+                    parameters.put("cityCode", area1.getAreaCode());
+                    forecastList = forecastWeatherMapper.getForecast(parameters);
+                    if (forecastList.size() != 0) {
+                        break;
+                    }
+                }
+            }
+        }
+
         List<Map<String, Object>> foreList = new ArrayList<>();
-        for (Map<String, Object> map : forecastList) {
+        for (Map<String, Object> forecastMap : forecastList) {
             Map<String, Object> hashMap = new HashMap<>();
-            hashMap.put("time", map.get("time").toString());
+            hashMap.put("time", forecastMap.get("time").toString());
             hashMap.put("type", "������");
             hashMap.put("TVOC", "");
             hashMap.put("altitude", "");
@@ -339,37 +353,36 @@
             hashMap.put("O3C", "");
             hashMap.put("PM25C", "");
             hashMap.put("PM10C", "");
-            hashMap.put("city", parameters.get("city").toString());
-
-            if (selectTime.getTime() <= now.getTime()) {
-                hashMap.put("fxTime", (format + " 15:00").substring(5, 16));
+            hashMap.put("city", parameters.get("name").toString());
+            if (sdf.parse(time).getTime() <= now.getTime()) {
+                hashMap.put("fxTime", (beforeDay + " 15:00").substring(5, 16));
             } else {
-                String s = sdf1.format(now).split(" ")[1].split(":")[0];
-                Integer hour = Integer.valueOf(s);
-                if (hour > 15) {
-                    hashMap.put("fxTime", (format + " 15:00").substring(5, 16));
-                } else if (hour > 7 && hour < 15) {
-                    hashMap.put("fxTime", (format + " 07:00").substring(5, 16));
+                String format = sdf1.format(now).split(" ")[0];
+                Date date1 = sdf1.parse(format + " 07:00:00");
+                Date date2 = sdf1.parse(format + " 15:00:00");
+                if (now.getTime() > date2.getTime()) {
+                    hashMap.put("fxTime", (beforeDay + " 15:00").substring(5, 16));
+                } else if (now.getTime() > date1.getTime() && (now.getTime() < date2.getTime() || now.getTime() == date2.getTime())) {
+                    hashMap.put("fxTime", (beforeDay + " 07:00").substring(5, 16));
                 }
             }
-            Map<String, Object> jsonMap = (Map<String, Object>) JSONObject.parse(map.get("json").toString());
+            Map<String, Object> jsonMap = (Map<String, Object>) JSONObject.parse(forecastMap.get("json").toString());
             hashMap.putAll(jsonMap);
             foreList.add(hashMap);
         }
 
         for (Map<String, Object> foreMap : foreList) {
             String ftime = foreMap.get("time").toString();
-            Calendar calendar = Calendar.getInstance();
             Date endTime = sdf1.parse(ftime);
-            calendar.setTime(endTime);
-            calendar.add(Calendar.HOUR, -6);
-            Date startTime = calendar.getTime();
+            cal.setTime(endTime);
+            cal.add(Calendar.HOUR, -6);
+            Date startTime = cal.getTime();
             Map<String, Object> hashMap = new HashMap<>();
-            hashMap.put("areaCode", Integer.valueOf(parameters.get("areaCode").toString()));
             hashMap.put("start", startTime);
             hashMap.put("end", endTime);
-            hashMap.put("monitorPointId", Integer.valueOf(parameters.get("monitorPointId").toString()));
+            hashMap.put("cityCode", Integer.valueOf(parameters.get("cityCode").toString()));
             Map<String, Object> precip6HourMap = forecastWeatherMapper.getPrecip6Hour(hashMap);
+            foreMap.put("precip6", "");
             if (precip6HourMap != null) {
                 foreMap.put("precip6", precip6HourMap.get("precip6").toString());
             }
@@ -377,7 +390,7 @@
 
         List<Map<String, Object>> aqiList = hangzhouAqiMapper.getAqi(parameters);
         if (aqiList.size() == 0) {
-            parameters.put("areaCode", cityCode);
+            parameters.put("areaCode", parentCode);
             aqiList = hangzhouAqiMapper.getAqi(parameters);
         }
 
@@ -387,15 +400,15 @@
             hashMap.put("time", aqiMap.get("time"));
             Map<String, Object> jsonMap = (Map<String, Object>) JSONObject.parse(aqiMap.get("json").toString());
             hashMap.putAll(jsonMap);
-            hashMap.put("city", parameters.get("city").toString());
+            hashMap.put("city", parameters.get("name").toString());
             realAqilist.add(hashMap);
         }
 
         for (Map<String, Object> map : realAqilist) {
             Date endTime = sdf1.parse(map.get("time").toString());
-            c.setTime(endTime);
-            c.add(Calendar.HOUR, -8);
-            Date startTime = c.getTime();
+            cal.setTime(endTime);
+            cal.add(Calendar.HOUR, -8);
+            Date startTime = cal.getTime();
             Map<String, Object> hashMap = new HashMap<>();
             hashMap.put("areaCode", Integer.valueOf(parameters.get("areaCode").toString()));
             hashMap.put("start", startTime);
@@ -408,14 +421,13 @@
         }
 
         //������
-        String code = parameters.get("areaCode").toString();
+        String ac = parameters.get("areaCode").toString();
         Map<String, Object> params = new HashMap<>();
-        if (code.endsWith("00")) {
-            params.put("cityCode", Integer.valueOf(code));
+        if (ac.endsWith("00")) {
+            params.put("cityCode", Integer.valueOf(ac));
         } else {
-            params.put("areaCode", Integer.valueOf(code));
+            params.put("areaCode", Integer.valueOf(ac));
         }
-
         List<MonitorPoint> monitorList = monitorPointMapper.getMonitorList(params);
 
         List<Integer> pointList = new ArrayList<>();
@@ -437,7 +449,6 @@
             beamList = historyHourlyMapper.getBeamByMacs(parameters);
         }
 
-
         List<Map<String, Object>> realList = realWeatherMapper.getRealWeather(parameters);
         List<Map<String, Object>> realWeatherList = new ArrayList<>();
         for (Map<String, Object> realMap : realList) {
@@ -445,7 +456,7 @@
             hashMap.put("time", realMap.get("time"));
             Map<String, Object> jsonMap = (Map<String, Object>) JSONObject.parse(realMap.get("json").toString());
             hashMap.putAll(jsonMap);
-            hashMap.put("city", parameters.get("city").toString());
+            hashMap.put("city", parameters.get("name").toString());
             realWeatherList.add(hashMap);
         }
 
@@ -454,21 +465,24 @@
             for (Map<String, Object> beamMap : beamList) {
                 String btime = beamMap.get("time").toString();
                 if (btime.equals(rtime)) {
-                    realMap.put("beam", beamMap.get("beam").toString().split("\\.")[0]);
+                    realMap.put("beam", Math.floor((Double) beamMap.get("beam")));
                 }
             }
-            Calendar calendar = Calendar.getInstance();
+
             Date endTime = sdf1.parse(rtime);
-            calendar.setTime(endTime);
-            calendar.add(Calendar.HOUR, -6);
-            Date startTime = calendar.getTime();
+            cal.setTime(endTime);
+            cal.add(Calendar.HOUR, -6);
+            Date startTime = cal.getTime();
             Map<String, Object> hashMap = new HashMap<>();
-            hashMap.put("areaCode", Integer.valueOf(parameters.get("areaCode").toString()));
+            hashMap.put("cityCode", Integer.valueOf(parameters.get("areaCode").toString()));
             hashMap.put("start", startTime);
             hashMap.put("end", endTime);
-            hashMap.put("monitorPointId", Integer.valueOf(parameters.get("monitorPointId").toString()));
+
             Map<String, Object> precip6HourMap = realWeatherMapper.getPrecip6Hour(hashMap);
-            realMap.put("precip6", precip6HourMap.get("precip6").toString());
+
+            if (precip6HourMap != null) {
+                realMap.put("precip6", precip6HourMap.get("precip6").toString());
+            }
         }
 
         List<Map<String, Object>> list = new ArrayList<>();
@@ -506,13 +520,10 @@
             }
         }
 
-
         list.removeAll(Collections.singleton(null));
-
-
         for (Map<String, Object> map : list) {
             map.put("type", "������");
-            map.put("city", parameters.get("city").toString());
+            map.put("city", parameters.get("name").toString());
         }
 
         List<Map<String, Object>> resultList = new ArrayList<>();
@@ -559,6 +570,7 @@
         return resultList;
     }
 
+
     @Override
     public void updateForecastWeather(Map<String, Object> parameters) {
         List<Integer> list = new ArrayList<>();
@@ -583,18 +595,27 @@
                 String time = map.get("time").toString() + ":00";
                 Map<String, Object> hashMap = new HashMap<>();
                 hashMap.put("time", time);
-                String city = map.get("city").toString();
-                Area area = areaMapper.getAreaByName(city);
-                Map<String, Object> idMap = new HashMap<>();
+                String cityName = map.get("city").toString();
+                Area area = areaMapper.getAreaByName(cityName);
+                //Map<String, Object> idMap = new HashMap<>();
                 if (area == null) {
-                    Integer cityCode = cityMapper.getCityByName(city).getCityCode();
-                    idMap.put("cityCode", cityCode);
+                    City city = cityMapper.getCityByName(cityName);
+                    if (city == null) {
+                        Province province = provinceMapper.getProvinceByName(cityName);
+                        if (province == null) {
+                            return;
+                        } else {
+                            hashMap.put("cityCode", province.getProvinceCode());
+                        }
+                    } else {
+                        Integer cityCode = city.getCityCode();
+                        hashMap.put("cityCode", cityCode);
+                    }
                 } else {
                     Integer areaCode = area.getAreaCode();
-                    idMap.put("areaCode", areaCode);
+                    hashMap.put("cityCode", areaCode);
                 }
 
-                List<MonitorPoint> monitorList = monitorPointMapper.getMonitorList(idMap);
                 Map<String, Object> jsonMap = new HashMap<>();
                 for (String key : map.keySet()) {
                     if (!key.equals("city") && !key.equals("time") && !key.equals("type") && !key.equals("fxTime")) {
@@ -602,13 +623,8 @@
                         jsonMap.put(key, value);
                     }
                 }
-
-                String json = JSONObject.toJSONString(jsonMap);
-                hashMap.put("json", json);
-                for (MonitorPoint monitorPoint : monitorList) {
-                    hashMap.put("monitorPointId", monitorPoint.getId());
-                    forecastWeatherMapper.updateForecastWeather(hashMap);
-                }
+                hashMap.put("json", JSONObject.toJSONString(jsonMap));
+                forecastWeatherMapper.updateForecastWeather(hashMap);
             }
         }
     }
diff --git a/src/main/resources/mapper/AreaMapper.xml b/src/main/resources/mapper/AreaMapper.xml
index 2343107..455b56d 100644
--- a/src/main/resources/mapper/AreaMapper.xml
+++ b/src/main/resources/mapper/AreaMapper.xml
@@ -11,4 +11,9 @@
     select * from area
     where area_name like '%${name}%' limit 0,1
   </select>
+
+  <select id="getAreaByCityCode" resultType="com.moral.entity.Area" resultMap="BaseResultMap">
+    select * from area
+    where city_code=#{cityCode}
+  </select>
 </mapper>
\ No newline at end of file
diff --git a/src/main/resources/mapper/ForecastWeatherMapper.xml b/src/main/resources/mapper/ForecastWeatherMapper.xml
index 2e04576..16fffbb 100644
--- a/src/main/resources/mapper/ForecastWeatherMapper.xml
+++ b/src/main/resources/mapper/ForecastWeatherMapper.xml
@@ -2,7 +2,7 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.moral.mapper.ForecastWeatherMapper">
     <resultMap id="BaseResultMap" type="com.moral.entity.ForecastWeather">
-        <id column="monitor_point_id" property="monitorPointId" jdbcType="INTEGER"/>
+        <id column="city_code" property="cityCode" jdbcType="INTEGER"/>
     </resultMap>
     <select id="getForecastHour" resultType="java.util.Map">
         SELECT
@@ -11,7 +11,7 @@
         from forecast_weather
         where time >= #{start}
         AND time <![CDATA[<]]> #{end}
-        AND monitor_point_id=#{monitorPointId}
+        AND city_code=#{cityCode}
     </select>
 
     <select id="getForecast" resultType="java.util.Map">
@@ -20,14 +20,14 @@
         from forecast_weather
         where time >= #{start}
         AND time <![CDATA[<]]> #{end}
-        AND monitor_point_id=#{monitorPointId}
+        AND city_code=#{cityCode}
         ORDER BY
         time
     </select>
 
     <update id="updateForecastWeather">
-        update forecast_weather set json=#{json}
-        where monitor_point_id=#{monitorPointId}
+        update forecast_weather1 set json=#{json}
+        where city_code=#{cityCode}
         and time=#{time}
     </update>
 
@@ -40,6 +40,6 @@
     WHERE
     time >= #{start}
     AND time <![CDATA[<]]> #{end}
-    AND monitor_point_id = #{monitorPointId}
+    AND city_code = #{cityCode}
     </select>
 </mapper>
\ No newline at end of file
diff --git a/src/main/resources/mapper/HangzhouAqiMapper.xml b/src/main/resources/mapper/HangzhouAqiMapper.xml
index 3b0bbb0..dff422f 100644
--- a/src/main/resources/mapper/HangzhouAqiMapper.xml
+++ b/src/main/resources/mapper/HangzhouAqiMapper.xml
@@ -71,13 +71,13 @@
     <select id="getAqiDataByAreaCode" resultType="java.util.Map">
     SELECT
     DATE_FORMAT(time, #{typeFormat}) time,
-    ifnull(aqi_json->'$.${sensors}',"") as '${sensors2}'
+    ifnull(aqi_json->'$.O3C',"") as 'O3'
     FROM
     hangzhou_aqi ha
     WHERE
     ha.time >= #{start}
     AND ha.time <![CDATA[<]]> #{end}
-    AND ha.city_code = #{areaCode}
+    AND ha.city_code = #{cityCode}
     ORDER BY
     time
   </select>
diff --git a/src/main/resources/mapper/RealWeatherMapper.xml b/src/main/resources/mapper/RealWeatherMapper.xml
index 80934c3..f1eec74 100644
--- a/src/main/resources/mapper/RealWeatherMapper.xml
+++ b/src/main/resources/mapper/RealWeatherMapper.xml
@@ -2,7 +2,7 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.moral.mapper.RealWeatherMapper">
     <resultMap id="BaseResultMap" type="com.moral.entity.RealWeather">
-        <id column="monitor_point_id" property="monitorPointId" jdbcType="INTEGER"/>
+        <id column="city_code" property="cityCode" jdbcType="INTEGER"/>
     </resultMap>
     <select id="getRealWeather" resultType="java.util.Map">
     select
@@ -13,7 +13,7 @@
     WHERE
     time >= #{start}
     AND time <![CDATA[<]]> #{end}
-    AND monitor_point_id = #{monitorPointId}
+    AND city_code = #{areaCode}
     ORDER BY
     time
    </select>
@@ -26,6 +26,6 @@
     WHERE
     time >= #{start}
     AND time <![CDATA[<]]> #{end}
-    AND monitor_point_id = #{monitorPointId}
+    AND city_code = #{cityCode}
     </select>
 </mapper>
\ No newline at end of file

--
Gitblit v1.8.0