预测接口温度判断

lizijie

2019-09-12 032c41299701ee41f1093267225cf0992227e99a

 src/main/java/com/moral/controller/ScreenController.java

@@ -1,25 +1,24 @@
package com.moral.controller;



import static com.moral.common.util.ResourceUtil.getValue;

import static com.moral.common.util.WebUtils.getParametersStartingWith;



import java.io.BufferedReader;

import java.io.ByteArrayInputStream;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.text.DateFormat;

import java.text.DecimalFormat;

import java.text.SimpleDateFormat;

import java.time.LocalDateTime;

import java.time.format.DateTimeFormatter;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.Collection;

import java.util.Date;

import java.util.HashMap;

import java.util.LinkedHashMap;

import java.util.List;

import java.util.Map;

import java.util.Optional;

import java.util.stream.Collectors;



import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;



import org.apache.commons.collections.CollectionUtils;

import org.apache.commons.net.ftp.FTPClient;

@@ -65,6 +64,7 @@
import com.moral.entity.MapBounds;

import com.moral.entity.MonitorPoint;

import com.moral.entity.Organization;

import com.moral.entity.Point;

import com.moral.entity.Region;

import com.moral.entity.alarm.AlarmConfig;

import com.moral.entity.alarm.AlarmConfigValue;

@@ -80,6 +80,7 @@
import com.moral.service.DictionaryDataService;

import com.moral.service.HangzhouAqiService;

import com.moral.service.HistoryDailyService;

import com.moral.service.HistoryHourlyService;

import com.moral.service.HistoryMinutelyService;

import com.moral.service.HistoryService;

import com.moral.service.MachineActivateService;

@@ -90,12 +91,19 @@
import com.moral.service.SensorService;

import com.moral.service.SensorUnitService;

import com.moral.service.WeatherService;

import com.moral.util.AQICalculation;

import com.moral.util.TempAllocationUtils;



import io.swagger.annotations.Api;

import io.swagger.annotations.ApiImplicitParam;

import io.swagger.annotations.ApiImplicitParams;

import io.swagger.annotations.ApiOperation;



import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;



import static com.moral.common.util.ResourceUtil.getValue;

import static com.moral.common.util.WebUtils.getParametersStartingWith;



/**

 * The Class ScreenController.大屏接口

@@ -138,6 +146,9 @@
     */

    @Resource

    private DeviceService deviceService;



    @Resource

    private HistoryHourlyService historyHourlyService;



    @Resource

    private HistoryMinutelyService historyMinutelyService;

@@ -362,12 +373,15 @@
        Map<String, Object> parameters = getParametersStartingWith(request, null);

        return historyMinutelyService.getDayAQIByDevice(parameters);

    }

    


    @GetMapping("hour-aqi")

    @ApiOperation(value = "获取一小时AQI", notes = "获取一小时AQI")

    @ApiImplicitParams(value = {

            @ApiImplicitParam(name = "mac", value = "设备mac地址", required = true, paramType = "query", dataType = "String")

    })

    public Map<String, Object> getHourAQIByDevice(HttpServletRequest request) {

       Map<String, Object> parameters = getParametersStartingWith(request, null);

       return historyMinutelyService.getHourAQIByDevice(parameters);

        Map<String, Object> parameters = getParametersStartingWith(request, null);

        return historyService.gitHourlyAQIByMacAndTimeslot(parameters);

    }



    /**

@@ -858,7 +872,9 @@
            @ApiImplicitParam(name = "organizationId", defaultValue = "5", value = "登录账号的组织id", required = true, paramType = "query", dataType = "Integer"),

            @ApiImplicitParam(name = "time", defaultValue = "2019", value = "查询的时间", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "sensorKey", defaultValue = "e27", value = "查询的监测因子的key", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "regionCode", defaultValue = "130000", value = "区域码", required = true, paramType = "query", dataType = "String")})

            @ApiImplicitParam(name = "regionCode", defaultValue = "130000", value = "区域码", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "monitorPointId", value = "监测点id(格式：376)", required = false, paramType = "query", dataType = "int"),

            @ApiImplicitParam(name = "mac", value = "设备mac(格式：vocscxwnm00001)", required = false, paramType = "query", dataType = "String")})

    public ResultBean<List<Map<String, Object>>> getemissionsData(HttpServletRequest request) throws Exception {

        Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);

        List<Map<String, Object>> result = historyDailyService.getEmissionsData(parameters);

@@ -911,10 +927,10 @@
    @GetMapping("/map-traceability")

    @ApiOperation(value = "获取污染溯源", notes = "获取污染溯源")

    @ApiImplicitParams(value = {

            @ApiImplicitParam(name = "monitorPointId", value = "监测点id", required = true, paramType = "query", dataType = "int"),

            @ApiImplicitParam(name = "mac", value = "设备mac地址", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "sensorKey", value = "查询的监测因子的key", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "time", value = "查询时间", required = true, paramType = "query", dataType = "String")})

            @ApiImplicitParam(name = "monitorPointId", value = "监测点id(格式：319)", required = true, paramType = "query", dataType = "int"),

            @ApiImplicitParam(name = "mac", value = "设备mac地址(格式：p5dnd7a0391993)", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "sensorKey", value = "查询的监测因子的key(格式：e1)", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "time", value = "查询时间(格式：2019-09-08)", required = true, paramType = "query", dataType = "String")})

    public ModelAndView traceability(ModelAndView model, HttpServletRequest request) throws Exception {

        Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);

        Integer monitorPointId = Integer.parseInt(parameters.get("monitorPointId").toString());

@@ -980,50 +996,50 @@
        List<Map<String, Object>> map = sensorUnitService.getSensorsByMonitPointId2(monitor_point_id);

        return new ResultBean<List<Map<String, Object>>>(map);

    }

    


    @GetMapping("getSensorByDeviceId")

   @ApiOperation(value = "通过设备获取因子", notes = "通过设备获取因子")

   @ApiImplicitParams(value = {

         @ApiImplicitParam(name = "id", value = "设备id", required = true, paramType = "query", dataType = "String")

   })

   public ResultBean<List<Map<String, Object>>> getSensorByDeviceId(HttpServletRequest request) throws Exception {

      Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);

      String id = (String) parameters.get("id");

      List<Map<String, Object>> list = sensorService.getSensorByDeviceId(id);

      Map<String,Object> map = list.get(0);

      String monitor_point_id = map.get("monitor_point_id").toString();

      List<Map<String, Object>> sensorUnitList = sensorUnitService.getSensorsByMonitPointId2(monitor_point_id);

      System.out.println(sensorUnitList);

      for (Map<String, Object> sensorMap : list) {

         for (Map<String, Object> sensorUnitMap : sensorUnitList) {

            if (sensorUnitMap.get("sensor_key").equals(sensorMap.get("sensor_key"))) {

               sensorMap.put("unit", sensorUnitMap.get("name"));

            }

         }

      }

      return new ResultBean<List<Map<String, Object>>>(list);

   }

	
   @GetMapping("getSensorWithUnitByMonitorPointId")

   @ApiOperation(value = "通过站点获取因子", notes = "通过站点获取因子")

   @ApiImplicitParams(value = {

         @ApiImplicitParam(name = "monitor_point_id", value = "站点id", required = true, paramType = "query", dataType = "String")

   })

   public ResultBean<List<Map<String, Object>>> getSensorWithUnitByMonitorPointId(HttpServletRequest request) throws Exception {

      Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);

      String monitor_point_id = (String) parameters.get("monitor_point_id");

      List<Map<String, Object>> list = sensorService.getSensorByMonitorPointId(monitor_point_id);

      List<Map<String, Object>> sensorUnitList = sensorUnitService.getSensorsByMonitPointId2(monitor_point_id);

      System.out.println(sensorUnitList);

      for (Map<String, Object> sensorMap : list) {

         for (Map<String, Object> sensorUnitMap : sensorUnitList) {

            if (sensorUnitMap.get("sensor_key").equals(sensorMap.get("sensor_key"))) {

               sensorMap.put("unit", sensorUnitMap.get("name"));

            }

         }

      }

      return new ResultBean<List<Map<String, Object>>>(list);

   }

    @ApiOperation(value = "通过设备获取因子", notes = "通过设备获取因子")

    @ApiImplicitParams(value = {

            @ApiImplicitParam(name = "id", value = "设备id", required = true, paramType = "query", dataType = "String")

    })

    public ResultBean<List<Map<String, Object>>> getSensorByDeviceId(HttpServletRequest request) throws Exception {

        Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);

        String id = (String) parameters.get("id");

        List<Map<String, Object>> list = sensorService.getSensorByDeviceId(id);

        Map<String, Object> map = list.get(0);

        String monitor_point_id = map.get("monitor_point_id").toString();

        List<Map<String, Object>> sensorUnitList = sensorUnitService.getSensorsByMonitPointId2(monitor_point_id);

        System.out.println(sensorUnitList);

        for (Map<String, Object> sensorMap : list) {

            for (Map<String, Object> sensorUnitMap : sensorUnitList) {

                if (sensorUnitMap.get("sensor_key").equals(sensorMap.get("sensor_key"))) {

                    sensorMap.put("unit", sensorUnitMap.get("name"));

                }

            }

        }

        return new ResultBean<List<Map<String, Object>>>(list);

    }



    @GetMapping("getSensorWithUnitByMonitorPointId")

    @ApiOperation(value = "通过站点获取因子", notes = "通过站点获取因子")

    @ApiImplicitParams(value = {

            @ApiImplicitParam(name = "monitor_point_id", value = "站点id", required = true, paramType = "query", dataType = "String")

    })

    public ResultBean<List<Map<String, Object>>> getSensorWithUnitByMonitorPointId(HttpServletRequest request) throws Exception {

        Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);

        String monitor_point_id = (String) parameters.get("monitor_point_id");

        List<Map<String, Object>> list = sensorService.getSensorByMonitorPointId(monitor_point_id);

        List<Map<String, Object>> sensorUnitList = sensorUnitService.getSensorsByMonitPointId2(monitor_point_id);

        System.out.println(sensorUnitList);

        for (Map<String, Object> sensorMap : list) {

            for (Map<String, Object> sensorUnitMap : sensorUnitList) {

                if (sensorUnitMap.get("sensor_key").equals(sensorMap.get("sensor_key"))) {

                    sensorMap.put("unit", sensorUnitMap.get("name"));

                }

            }

        }

        return new ResultBean<List<Map<String, Object>>>(list);

    }



    @GetMapping("AIForecast")

    @ApiOperation(value = "AI预测", notes = "AI预测")

@@ -1038,25 +1054,15 @@
        //System.out.println(parameters);

        String monitorPoint = (String) parameters.get("monitorPoint");

        String intoTime = parameters.get("time").toString();

        String[] timeArray = intoTime.split("-");

        //System.out.println(timeArray);

        Integer year = Integer.parseInt(timeArray[0]);

        Integer mon = Integer.parseInt(timeArray[1]);

        if (mon > 1) {

            mon = mon - 1;

        } else {

            mon = 12;

            year = year - 1;

        }

        String alterTime = year.toString() + "-" + mon.toString() + "-" + timeArray[2];

        //System.out.println(alterTime);

        Date date = new SimpleDateFormat("yy-MM-dd").parse(intoTime);

        DateFormat df1 = new SimpleDateFormat("yyyy-MM-dd");

        String alterTime = df1.format(date.getTime()-15*24*60*60*1000);

        parameters.put("time", alterTime);

        ParameterUtils.getTimeType4Time(parameters);

        String monitor_point_id = (String) parameters.get("monitorPoint");

        parameters.put("monitorPointId", parameters.remove("monitorPoint"));

        String[] sensorKeys = parameters.remove("sensorKey").toString().split(",");

        parameters.put("sensors", Arrays.asList(sensorKeys));

        // monitorPointService.isCompensateCalculation(parameters);

        List<Map<String, Object>> list = historyMinutelyService.getMonitorPointOrDeviceAvgData(parameters);



        Map<String, Object> mpMap = new HashMap<>();

@@ -1066,8 +1072,18 @@
        weatherParameters.put("organizationId", mpMap.get("organization_id"));

        weatherParameters.put("time", intoTime);

        //获取天气信息

        Map<String, Object> weatherMap = weatherService.get15DayWeatherDataByRegion(weatherParameters);

        Map<String, Object> tempMap = TempAllocationUtils.tempAllocation(weatherMap);

        Map<String, Object> weatherMap = new HashMap<>();

        Map<String, Object> tempMap = new HashMap<>();

        Boolean tf = false;

        for(int i=0;i<sensorKeys.length;i++) {

           if(sensorKeys[i].equals("e7")) {

              tf = true;

           }

        }

        if (tf) {

            weatherMap = weatherService.get15DayWeatherDataByRegion(weatherParameters);

            tempMap = TempAllocationUtils.tempAllocation(weatherMap);

      }

        //获取单位信息

        Map<String, Map<String, Object>> sensorUnitMap = sensorUnitService.getSensorsByMonitPointId(monitor_point_id);



@@ -1075,7 +1091,9 @@
            String time = map.get("time").toString();

            time = time.substring(time.length() - 2);

            map.put("time", Integer.valueOf(time));

            map.put("temp", tempMap.get(map.get("time").toString()));

            if (tempMap!=null) {

               map.put("temp", tempMap.get(map.get("time").toString()));

         }

            List<Number> values = new ArrayList<Number>();

            List<String> units = new ArrayList<String>();

            for (String string : sensorKeys) {

@@ -1121,38 +1139,6 @@
    public ResultBean<Map<String, Object>> getWeather(HttpServletRequest request) throws Exception {

        Map<String, Object> parameters = getParametersStartingWith(request, null);

        Map<String, Object> map = weatherService.get15DayWeatherDataByRegion(parameters);

        /*Map<String, Object> tempMap = new HashMap<>();

        Double tempDay = Double.parseDouble(map.get("tempDay").toString());

        Double tempNight = Double.parseDouble(map.get("tempNight").toString());

        Double time5 = tempNight;

        Double time13 = tempDay;

        Double difference = tempDay-tempNight;

        Double dif_8 = difference/8;

        Double dif_16 = difference/16;

        tempMap.put("5", time5);

        tempMap.put("13", time13);

        String time = null;

        Double t = time5;

        for(int i=4;i>=0;i--) {

           time = ""+i;

           t = t+dif_16;

           String tempLast = ""+Math.round(t);

           tempMap.put(time, tempLast);

        }

        Double y = time5;

        for(int i=6;i<13;i++) {

           time = ""+i;

           y = y+dif_8;

           String tempLast = ""+Math.round(y);

           tempMap.put(time, tempLast);

        }

        Double z = time13;

        for(int i=14;i<=23;i++) {

           time = ""+i;

           z = z-dif_16;

           String tempLast = ""+Math.round(z);

           tempMap.put(time, tempLast);

        }*/

        Map<String, Object> tempMap = TempAllocationUtils.tempAllocation(map);

        return new ResultBean<Map<String, Object>>(tempMap);

    }

@@ -1161,21 +1147,43 @@
    @ApiOperation(value = "显示无人机飞行轨迹", notes = "显示无人机飞行轨迹")

    @ApiImplicitParams(value = {

            @ApiImplicitParam(name = "mac", value = "设备mac（格式：p5dnd7a0392068）", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "startTime", value = "开始时间(格式：2019-07-17 17:07:00)", required = false, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "endTime", value = "结束时间(格式：2019-07-17 17:07:00)", required = false, paramType = "query", dataType = "String")

            @ApiImplicitParam(name = "startTime", value = "开始时间(格式：2019-07-17-17)", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "endTime", value = "结束时间(格式：2019-07-17-18)", required = true, paramType = "query", dataType = "String")

    })

    public ModelAndView uavTrajectory(ModelAndView model, HttpServletRequest request) throws Exception {

        Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);

        String st = parameters.get("startTime").toString();

        String startYearAndDay = st.substring(0, st.lastIndexOf("-"));

        String startHour = st.substring(st.lastIndexOf("-") + 1);

        String startTime = startYearAndDay + " " + startHour + ":00:00";

        String et = parameters.get("endTime").toString();

        String endYearAndDay = et.substring(0, et.lastIndexOf("-"));

        String endHour = et.substring(et.lastIndexOf("-") + 1);

        String endTime = endYearAndDay + " " + endHour + ":00:00";

        parameters.put("startTime", startTime);

        parameters.put("endTime", endTime);

        String mac = parameters.get("mac").toString();

        if (mac != null && mac.length() != 0) {

            List<Map<String, Object>> sensorList = historyMinutelyService.getSensorData(parameters);

            List<List<Map<String, Object>>> sensorData = historyMinutelyService.getSensorData(parameters);

            Map<String, String> sensorsMap = sensorService.getSensorsMap(parameters);

            List<Map<String, Object>> sensorList = new ArrayList<>();

            List<Map<String, Object>> sensorListMin = new ArrayList<>();

            List<Map<String, Object>> sensorListMax = new ArrayList<>();

            if (sensorData.size() == 3) {

                sensorList = sensorData.get(0);

                sensorListMin = sensorData.get(1);

                sensorListMax = sensorData.get(2);

            }

            JSONObject params = new JSONObject();

            params.put("sensorInfo", sensorList);

            params.put("sensorInfoMin", sensorListMin);

            params.put("sensorInfoMax", sensorListMax);

            params.put("sensorsMap", sensorsMap);

            String paramsJson = params.toJSONString();

            model.addObject("uavTrajectoryParams", paramsJson);

            model.setViewName("uavTrajectory");

            model.setViewName("uavtrajectory");

            return model;

        }else {

        } else {

            StringBuilder msg = new StringBuilder();

            msg.append(" param[0] mac:");

            msg.append(mac);

@@ -1185,4 +1193,84 @@
        }

    }



    @GetMapping("/pollutionSource")

    @ApiOperation(value = "污染传播来源", notes = "污染传播来源")

    @ApiImplicitParams(value = {

            @ApiImplicitParam(name = "mac", value = "设备mac地址(如：898607b0101730392251)", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "sensorKey", value = "查询的监测因子的key(格式：e1)", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "time", value = "查询时间(格式：2019-09-01-10)", required = true, paramType = "query", dataType = "String")})

    public ModelAndView pollutionSource(ModelAndView model, HttpServletRequest request) throws Exception {

        Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);

        String timeStr = parameters.get("time").toString();

        String YearAndDay = timeStr.substring(0, timeStr.lastIndexOf("-"));

        String Hour = timeStr.substring(timeStr.lastIndexOf("-") + 1);

        String time = YearAndDay + " " + Hour + ":00:00";

        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");

        LocalDateTime timeLocalDateTime = LocalDateTime.parse(time, dateTimeFormatter);

        int month = timeLocalDateTime.getMonth().getValue();

        Point dirPoint = historyHourlyService.getDirPoint(parameters);

        Map<String, Object> getPollutionSourceData = historyHourlyService.getPollutionSourceData(parameters);

        String mac = parameters.get("mac").toString();

        Device device = deviceService.getDeviceByMac(mac, false);

        JSONObject params = new JSONObject();

        params.put("device", device);

        params.put("month", month);

        params.put("dirPoint", dirPoint);

        params.put("getPollutionSourceData", getPollutionSourceData);

        String paramsJson = params.toJSONString();

        model.addObject("pollutionSourceParams", paramsJson);

        model.setViewName("pollutionsource");

        return model;

    }



    @GetMapping("getAirQualityComparison")

    @ApiOperation(value = "空气质量对比", notes = "空气质量对比")

    @ApiImplicitParams(value = {

            @ApiImplicitParam(name = "organizationId", defaultValue = "5", value = "登录账号的组织id", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "monitor_point_id", defaultValue = "5", value = "监控站点id", required = true, paramType = "query", dataType = "String")})

    public ResultBean<Map<String, Object>> getAirQualityComparison(HttpServletRequest request) throws Exception {

        Map<String, Object> parameters = getParametersStartingWith(request, null);

        Map<String, Object> map = weatherService.getWeatherDataByRegion(parameters);

        Map<String, Double> sensorMap = new HashMap<>();

        sensorMap.put("e1", Double.parseDouble(map.get("pm25").toString()));

        sensorMap.put("e2", Double.parseDouble(map.get("pm10").toString()));

        sensorMap.put("e11", Double.parseDouble(map.get("so2").toString()));

        sensorMap.put("e16", Double.parseDouble(map.get("no2").toString()));

        sensorMap.put("e10", Double.parseDouble(map.get("co").toString()));

        sensorMap.put("e15", Double.parseDouble(map.get("o3").toString()));

        Map<String, Object> StateControl = AQICalculation.hourlyAQI(sensorMap);

        System.out.println("StateControl:" + StateControl);

        Map<String, Object> hourAqi = historyService.gitHourlyAQIByMonitorPointIdAndTimeslot(parameters);

        System.out.println("hourAqi:" + hourAqi);

        Map<String, Object> returnMap = new HashMap<>();

        returnMap.put("MonitorPointAQI", hourAqi.get("AQI"));

        returnMap.put("StateControlAQI", StateControl.get("AQI"));

        return new ResultBean<Map<String, Object>>(returnMap);

    }





    @GetMapping("mointorPointRank")

    @ApiOperation(value = "获取站点排名", notes = "获取站点排名")

    @ApiImplicitParams(value = {

            @ApiImplicitParam(name = "accountId", value = "账号id", required = true, paramType = "query", dataType = "String"),

            @ApiImplicitParam(name = "sensor", value = "因子", required = true, paramType = "query", dataType = "String")

    })

    public ResultBean<List<Map<String, Object>>> getMointorPointRank(HttpServletRequest request) {

        Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);

        String id = parameters.get("accountId").toString();

        String sensor = parameters.get("sensor").toString();

        Map<String, Object> account = accountService.getOrganizationIdByAccountId(id);

        //通过组织id来获取站点和设备信息

        account.put("sensor", sensor);

        List<Map<String, Object>> rankList = historyService.getMointorPointRankByOrganizationId(account);

        List<Map<String, Object>> returnList = new ArrayList<>();

        for (Map<String, Object> map : rankList) {

            boolean contains = map.containsKey("sensor");

            if (contains) {

                returnList.add(map);

            }

        }

        return new ResultBean<List<Map<String, Object>>>(returnList);

    }



}