工业级后台API v2
blame | history | patch | commit | commitdiff | ignore whitespace
lizijie
2019-09-11 9b2bea0002ad5f7293fc00b70778511bf1e636c6 
 src/main/java/com/moral/controller/ScreenController.java


@@ -1,29 +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.time.LocalDate;



import java.text.SimpleDateFormat;



import java.time.LocalDateTime;



import java.time.Month;



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;



@@ -103,6 +98,12 @@


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.大屏接口



@@ -372,15 +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 historyService.gitHourlyAQIByMacAndTimeslot(parameters);



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



        return historyService.gitHourlyAQIByMacAndTimeslot(parameters);



    }







    /**



@@ -872,8 +873,8 @@


            @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 = "monitorPointId", value = "监测点id", required = false, paramType = "query", dataType = "int"),



            @ApiImplicitParam(name = "mac", value = "设备mac", required = false, 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);



@@ -926,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());



@@ -995,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预测")



@@ -1053,18 +1054,10 @@


        //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);



        System.out.println("startTime:"+alterTime);



        parameters.put("time", alterTime);



        ParameterUtils.getTimeType4Time(parameters);



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



@@ -1136,38 +1129,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);



    }



@@ -1207,7 +1168,7 @@


            params.put("sensorInfo", sensorList);



            params.put("sensorInfoMin", sensorListMin);



            params.put("sensorInfoMax", sensorListMax);



            params.put("sensorsMap",sensorsMap);



            params.put("sensorsMap", sensorsMap);



            String paramsJson = params.toJSONString();



            model.addObject("uavTrajectoryParams", paramsJson);



            model.setViewName("uavtrajectory");



@@ -1225,7 +1186,7 @@


    @GetMapping("/pollutionSource")



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



    @ApiImplicitParams(value = {



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



            @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 {



@@ -1236,30 +1197,27 @@


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



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



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



        System.out.println(timeLocalDateTime);



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



        Point dirPoint= historyHourlyService.getDirPoint(parameters);



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



        System.out.println(dirPoint.toString());



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



        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);



        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")})



            @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);



@@ -1271,31 +1229,38 @@


        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);



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



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



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



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



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



        returnMap.put("站点AQI", hourAqi.get("AQI"));



        returnMap.put("国控AQI", StateControl.get("AQI"));



        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>> returnList = historyService.getMointorPointRankByOrganizationId(account);



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



   }



    






    @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);



    }







}