工业级后台API v2
blame | history | patch | commit | commitdiff | ignore whitespace
kaiyu
2020-09-17 613dd76a3aded439f1002d904d85d8332ddb03d1 
 src/main/java/com/moral/controller/ScreenController.java


@@ -1,9 +1,7 @@


package com.moral.controller;




import java.io.BufferedReader;


import java.io.ByteArrayInputStream;


import java.io.InputStream;


import java.io.InputStreamReader;


import java.io.*;


import java.lang.reflect.Array;


import java.text.DateFormat;


import java.text.DecimalFormat;


import java.text.SimpleDateFormat;


@@ -17,6 +15,7 @@




import com.alibaba.fastjson.JSON;


import com.alibaba.fastjson.JSONArray;




import com.alibaba.fastjson.JSONObject;


import com.googlecode.aviator.AviatorEvaluator;


import com.googlecode.aviator.Expression;


@@ -29,15 +28,7 @@


import com.moral.common.util.ValidateUtil;


import com.moral.common.util.WebUtils;


import com.moral.common.xml.Version;


import com.moral.entity.Account;


import com.moral.entity.AreaNames;


import com.moral.entity.Device;


import com.moral.entity.DeviceVersion;


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.*;


import com.moral.entity.alarm.AlarmConfig;


import com.moral.entity.alarm.AlarmConfigValue;


import com.moral.entity.alarm.AlarmSensorLevel;


@@ -65,12 +56,14 @@


import com.moral.service.WeatherService;


import com.moral.util.*;




import com.rabbitmq.client.*;


import com.rabbitmq.client.Channel;


import io.swagger.annotations.Api;


import io.swagger.annotations.ApiImplicitParam;


import io.swagger.annotations.ApiImplicitParams;


import io.swagger.annotations.ApiOperation;


import jdk.nashorn.internal.runtime.regexp.joni.Regex;


import net.sf.json.JSONString;




import org.apache.commons.collections.CollectionUtils;


import org.apache.commons.collections.MapUtils;


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


@@ -95,9 +88,9 @@


import org.springframework.web.bind.annotation.RestController;


import org.springframework.web.servlet.ModelAndView;


import org.xml.sax.InputSource;




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


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


import static java.util.Calendar.*;




/**


 * The Class ScreenController.大屏接口


@@ -181,6 +174,7 @@




    @Resource


    private QualityDailyService qualityDailyService;






    /**


     * Screen login. 大屏登录


@@ -712,8 +706,8 @@


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


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


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


            if (parameters.get("type").equals("day")) {


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


            if(parameters.get("type").equals("day")){


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


            }


            map.put("value", map.remove(sensorKey));


        }


@@ -1916,8 +1910,8 @@


            if (minAngle > (Double) longAndLatiList.get(j).get("angle")) {


                minAngle = (Double) longAndLatiList.get(j).get("angle");


                indexAngle = j;


            } else {


                indexAngle = indexAngle;


            }else {


                indexAngle=indexAngle;


            }


        }


        preAngleDeviceList.add(deviceList.get((Integer) longAndLatiList.get(indexAngle).get("h")));


@@ -1953,11 +1947,82 @@


        return params;


    }




    @GetMapping("/allDevice")


    @ResponseBody


    public Map<String,List> getAllDevice() {


        List<String> macList=deviceService.getAllMac();


        Map<String,List> latlngMap=new HashMap<String,List>();


        Map devMap=null;


        List list=new ArrayList();


        for (String mac : macList) {


            devMap=new HashMap();


            if (mac!=null){


                Device device=deviceService.byMacGetDevice(mac);


                List list1= LatLngTransformation.Convert_BD09_To_GCJ02(device.getLatitude(),device.getLongitude());


                if (device.getState()!=4+""){


                    devMap.put("state",device.getState());


                }


                devMap.put("lat",list1.get(1));


                devMap.put("lng",list1.get(0));


                devMap.put("monitorPointId",device.getMonitorPointId());


                //System.out.println(device);


                list.add(devMap);


            }else {


                continue;


            }


        }


        latlngMap.put("latlng",list);


        return latlngMap;


    }








    @GetMapping("/windAndDeviceData")


    @ResponseBody


    public List windAndDeviceData(String monitorPointId) {


        Calendar calendar = Calendar.getInstance();


        calendar.set(Calendar.MINUTE, (calendar.get(Calendar.MINUTE) - 2));


        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm");


        String time = df.format(calendar.getTime())+":00";


        int year = calendar.get(Calendar.YEAR);


        int month = calendar.get(Calendar.MONTH) + 1;


        String mon;


        if (month<10){


            mon="0"+month;


        }else {


            mon=""+month;


        }


        String table="history_minutely_"+year+mon;


        List list=deviceService.byMonitorIdGetDeviceAndWind(monitorPointId,time,table);


        return list;


    }




    //局部风场


    @GetMapping("/windAndDeviceDataByArea")


    @ResponseBody


    public List windAndDeviceDataByArea(String monitorPointId) {


        Calendar calendar = Calendar.getInstance();


        calendar.set(Calendar.MINUTE, (calendar.get(Calendar.MINUTE) - 2));


        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm");


        String time = df.format(calendar.getTime())+":00";


        int year = calendar.get(Calendar.YEAR);


        int month = calendar.get(Calendar.MONTH) + 1;


        String mon;


        if (month<10){


            mon="0"+month;


        }else {


            mon=""+month;


        }


        String table="history_minutely_"+year+mon;


        List list=deviceService.byMonitorIdGetDeviceAndWindSpecial(monitorPointId,time,table);


        return list;


    }




    @GetMapping("forecastO3")


    @ApiOperation(value = "预测和实际臭氧对比", notes = "预测和实际臭氧对比")


    @ApiImplicitParams(value = {


            @ApiImplicitParam(name = "monitorPointId", defaultValue = "1", value = "监控站id", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "time", value = "时间(格式：2020-03-19)", required = true, paramType = "query", dataType = "String")})


            @ApiImplicitParam(name = "time", value = "时6间(格式：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);


        List<Map<String, Object>> resultList = weatherService.getForecastAndReal(parameters);


@@ -1965,7 +2030,7 @@


    }




    @GetMapping("weatherData")


    @ApiOperation(value = "根据city查询预测和实际数据", notes = "根据city查询预测和实际数据")


    @ApiOperation(value = "根据city查询小时预测和实测数据", notes = "根据city查询小时预测和实测数据")


    @ApiImplicitParams(value = {


            @ApiImplicitParam(name = "city", value = "城市名", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "time", value = "时间(格式：2020-03-19)", required = true, paramType = "query", dataType = "String")})


@@ -1973,6 +2038,30 @@


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


        List<Map<String, Object>> weatherList = weatherService.getWeatherData(parameters);


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


    }




    @GetMapping("weatherDataDay")


    @ApiOperation(value = "根据city查询日实测数据", notes = "根据city查询日实测数据")


    @ApiImplicitParams(value = {


            @ApiImplicitParam(name = "city", value = "城市名", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "time", value = "时间(格式：2020-03-19)", required = true, paramType = "query", dataType = "String")})


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


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


        List<Map<String, Object>> weatherList = weatherService.getWeatherDataByDay(parameters);


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


    }




    @GetMapping("monitorDeviceData")


    @ApiOperation(value = "获取微型站5分钟和半小时数据", notes = "获取微型站5分钟和半小时数据")


    @ApiImplicitParams(value = {


            @ApiImplicitParam(name = "city", value = "城市名", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "time", value = "时间(格式：2020-03-15)", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "type", value = "类型(5分钟：m,半小时：h)", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "range", value = "要查看的设备范围(国控站周边：m,全城：a)", required = true, paramType = "query", dataType = "String")})


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


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


        List<Map<String, Object>> deviceData = historyMinutelyService.get5MinutesOrHalfHour(parameters);


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


    }




    @PostMapping("updateForecastWeather")


@@ -1993,7 +2082,7 @@


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


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


        //对时间进行操作的接口


        Calendar calendar = Calendar.getInstance();


        Calendar calendar = getInstance();


        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");


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


        Map device = deviceService.getAllFieldByMac(parameters);


@@ -2124,4 +2213,18 @@


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


    }








    @GetMapping("/contrastFactor")


    @ApiOperation(value = "因子对比", notes = "因子对比")


    @ApiImplicitParams(value = {


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


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


            @ApiImplicitParam(name = "time", value = "时间(格式：2020-03-19、20、21)", required = true, paramType = "query", dataType = "String")})


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


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


        List list=historyHourlyService.getDataByMacAndTime(parameters);


        //System.out.println(list);


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


    }


}