工业级后台API v2
blame | history | patch | commit | commitdiff | ignore whitespace
于紫祥_1901
2020-10-22 3a4442da13b6f1300956bd63a5d106c5b2fc7184 
 src/main/java/com/moral/controller/ScreenController.java


@@ -1,24 +1,14 @@


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


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


import java.util.LinkedHashMap;


import java.util.List;


import java.util.Map;


import java.util.Optional;


import java.util.*;


import java.util.stream.Collectors;




import javax.annotation.Resource;


@@ -26,6 +16,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;


@@ -38,50 +29,28 @@


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;


import com.moral.entity.charts.DataSortCondition;


import com.moral.entity.layout.RealTimeDeviceLayout;


import com.moral.service.AccountService;


import com.moral.service.AlarmConfigService;


import com.moral.service.AlarmDailyService;


import com.moral.service.AreaService;


import com.moral.service.DeviceService;


import com.moral.service.DeviceVersionService;


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;


import com.moral.service.MonitorPointService;


import com.moral.service.OrganizationLayoutService;


import com.moral.service.OrganizationService;


import com.moral.service.QualityDailyService;


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 com.moral.service.*;


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 io.swagger.models.auth.In;


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;


import org.apache.ibatis.annotations.Param;


import org.apache.log4j.Logger;


import org.dom4j.Document;


import org.dom4j.Element;


@@ -102,9 +71,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.大屏接口


@@ -129,6 +98,9 @@


    MonitorPointService monitorPointService;


    @Resource


    DeviceVersionService deviceVersionService;




  /*  @Resource


    HistorySpecialService historySpecialService;*/




    /**


     * The screen service.


@@ -188,6 +160,12 @@




    @Resource


    private QualityDailyService qualityDailyService;




    @Resource


    private DeviceRoadService deviceRoadService;




    @Resource


    private ScreenVersionService screenVersionService;




    /**


     * Screen login. 大屏登录


@@ -628,12 +606,12 @@


    @ResponseBody


    @ApiOperation(value = "设备信息", notes = "设备信息")


    @ApiImplicitParams(value = {


            @ApiImplicitParam(name = "orgId",defaultValue = "5", value = "组织Id", required = true, paramType = "query", dataType = "Integer"),


            @ApiImplicitParam(name = "regionCode",defaultValue = "320583", value = "地区编码", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "Fe", defaultValue = "31.485018",value = "东北角纬度", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "Ge", defaultValue = "121.378395",value = "东北角经度", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "Ke", defaultValue = "31.296614",value = "西南角纬度", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "Le", defaultValue = "120.59651",value = "西南角经度", required = true, paramType = "query", dataType = "String")


            @ApiImplicitParam(name = "orgId", defaultValue = "5", value = "组织Id", required = true, paramType = "query", dataType = "Integer"),


            @ApiImplicitParam(name = "regionCode", defaultValue = "320583", value = "地区编码", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "Fe", defaultValue = "31.485018", value = "东北角纬度", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "Ge", defaultValue = "121.378395", value = "东北角经度", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "Ke", defaultValue = "31.296614", value = "西南角纬度", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "Le", defaultValue = "120.59651", value = "西南角经度", required = true, paramType = "query", dataType = "String")


    })


    public ResultBean getDevices(@RequestParam("orgId") Integer orgId, MapBounds mapBounds,


                                 @RequestParam("regionCode") String regionCode) {


@@ -704,25 +682,41 @@


        return new ResultBean<List<MonitorPoint>>(monitorPoints);


    }






    /*


     * 参数：monitorPoint=368&mac=p5dnd7a0392018&sensorKey=e92&time=2020-08-11


     * 获取传感器均值接口


     * */


    @GetMapping("report_avg_datas")


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


            throws Exception {


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


        //该方法用于判断时间是具体到年月日


        ParameterUtils.getTimeType4Time(parameters);


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


        Object sensorKey = parameters.remove("sensorKey");


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


        // monitorPointService.isCompensateCalculation(parameters);


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




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


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


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


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


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


        String time1 = (String) parameters.get("time");


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


        List<Map<String, Object>> list = null;


        if (mac1 != null && mac1.equals("p5dnd7a0392018") && time1.substring(0, 4).equals("2019")) {


            list = null;


        } else {


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


            Object sensorKey = parameters.remove("sensorKey");


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


            // monitorPointService.isCompensateCalculation(parameters);


            list = historyMinutelyService.getMonitorPointOrDeviceAvgData(parameters);


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


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


                }


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


            }


        }


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


    }






    @GetMapping("report_alarm_datas")


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


@@ -870,7 +864,6 @@




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


        List<Map<String, Object>> areaList = hangzhouAqiService.getAreaAvgDataByAreaCode(parameters);




        if (areaList.isEmpty() && monitorList.isEmpty()) {


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


        } else if (areaList.isEmpty()) {


@@ -1068,6 +1061,13 @@


            throws Exception {


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


        List<MonitorPoint> monitorPoints = monitorPointService.getMonitorPointsAndDevicesByRegion(parameters);


        //给每一个monitorPoint下的设备通过device.getName()进行排序


        for (MonitorPoint monitorPoint : monitorPoints) {


            List<Device> deviceList = monitorPoint.getDevices();


            deviceList.sort((Device o1, Device o2) -> {


                return o1.getName().compareTo(o2.getName());


            });


        }


        return new ResultBean<List<MonitorPoint>>(monitorPoints);


    }




@@ -1198,9 +1198,7 @@


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


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


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


      //System.out.println("ScreenController-----getSensor-----mac:"+mac);


      Map<String, Object> map = sensorUnitService.getSensorByMac(mac);


      System.out.println("ScreenController-----getSensor-----map:"+map);


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


   }*/




@@ -1268,7 +1266,6 @@


    })


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


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


        //System.out.println(parameters);


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


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


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


@@ -1513,13 +1510,15 @@


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


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


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


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


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


        int endHourValue = Integer.valueOf(endHour);


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


       /* int endHourValue = Integer.valueOf(endHour);


        int startHourValue = Integer.valueOf(startHour);


        if (endHourValue <= startHourValue) {


            endHourValue = startHourValue + 1;


        }


        String endTime = startYearAndDay + " " + endHourValue + ":00:00";


        String endTime = startYearAndDay + " " + endHourValue + ":00:00";*/


        parameters.put("startTime", startTime);


        parameters.put("endTime", endTime);


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


@@ -1534,6 +1533,7 @@


            params.put("sensorInfo", sensorList);


            params.put("sensorsMap", sensorsMap);


            String paramsJson = params.toJSONString();


            //System.out.println(paramsJson);


            model.addObject("carTrajectoryParams", paramsJson);


            model.setViewName("cartrajectory");


            return model;


@@ -1624,9 +1624,12 @@




    @RequestMapping(value = "/newMap-page", method = RequestMethod.GET)


    public ModelAndView newMap(ModelAndView model, @RequestParam("areaCode") long code,


                            @RequestParam("accountId") int accountId) {


                               @RequestParam("accountId") int accountId) {




        Account account = accountService.getAccountById(accountId);


        List<MonitorPoint> monitorPointList = monitorPointService.getMonitorPointListByAccountId(accountId);


        String regionName = areaService.queryFullNameByCode(code);




        if (account != null && regionName != null) {


            Object sensors = sensorService.queryAll();


            JSONObject params = new JSONObject();


@@ -1682,12 +1685,12 @@


            JSONObject params = new JSONObject();


            params.put("sensorInfo", sensorData);


            params.put("sensorsMap", sensorsMap);


            params.put("sensorKey",parameters.get("sensorKey"));


            params.put("unit",parameters.get("unit"));


            params.put("description",parameters.get("description"));


            params.put("sensorKey", parameters.get("sensorKey"));


            params.put("unit", parameters.get("unit"));


            params.put("description", parameters.get("description"));


            String paramsJson = params.toJSONString();


            model.addObject("uavDroppointParams", paramsJson);


            model.setViewName("uavdroppointnew");


            model.setViewName("uavdroppoint");


            return model;


        } else {


            StringBuilder msg = new StringBuilder();


@@ -1730,9 +1733,9 @@


            JSONObject params = new JSONObject();


            params.put("sensorInfo", sensorData);


            params.put("sensorsMap", sensorsMap);


            params.put("sensorKey",parameters.get("sensorKey"));


            params.put("unit",parameters.get("unit"));


            params.put("description",parameters.get("description"));


            params.put("sensorKey", parameters.get("sensorKey"));


            params.put("unit", parameters.get("unit"));


            params.put("description", parameters.get("description"));


            String paramsJson = params.toJSONString();


            model.addObject("uavChannelParams", paramsJson);


            model.setViewName("uavchannelnew");


@@ -1778,9 +1781,9 @@


            JSONObject params = new JSONObject();


            params.put("sensorInfo", sensorData);


            params.put("sensorsMap", sensorsMap);


            params.put("sensorKey",parameters.get("sensorKey"));


            params.put("unit",parameters.get("unit"));


            params.put("description",parameters.get("description"));


            params.put("sensorKey", parameters.get("sensorKey"));


            params.put("unit", parameters.get("unit"));


            params.put("description", parameters.get("description"));


            String paramsJson = params.toJSONString();


            model.addObject("uavTracingParams", paramsJson);


            model.setViewName("uavtracing");


@@ -1801,16 +1804,16 @@


            @ApiImplicitParam(name = "monitorPointId", value = "公司Id", required = true, paramType = "query", dataType = "String"),


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


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


    public ModelAndView PurificationRate(HttpServletRequest request,ModelAndView model){


    public ModelAndView PurificationRate(HttpServletRequest request, ModelAndView model) {


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


        String monitPointIdS= (String) parameters.get("monitorPointId");


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


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


        String monitPointIdS = (String) parameters.get("monitorPointId");


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


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


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


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


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


        int monitPointId=Integer.parseInt(monitPointIdS);


        JSONObject params=monitorPointService.getMonitorPointById(monitPointId,Time,1,sensor);


        int monitPointId = Integer.parseInt(monitPointIdS);


        JSONObject params = monitorPointService.getMonitorPointById(monitPointId, Time, 1, sensor);


        String paramsJson = params.toJSONString();


        model.addObject("mapParams", paramsJson);


        model.setViewName("purityMap");


@@ -1823,22 +1826,21 @@


    @ApiImplicitParams(value = {


            @ApiImplicitParam(name = "monitorPointId", value = "公司Id", required = true, paramType = "query", dataType = "String"),


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


    public ModelAndView collectionRate(HttpServletRequest request,ModelAndView model){


    public ModelAndView collectionRate(HttpServletRequest request, ModelAndView model) {


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


        String monitPointIdS= (String) parameters.get("monitorPointId");


        String sensor= "";


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


        String monitPointIdS = (String) parameters.get("monitorPointId");


        String sensor = "";


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


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


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


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


        int monitPointId=Integer.parseInt(monitPointIdS);


        int monitPointId = Integer.parseInt(monitPointIdS);


        //获取公司信息


        JSONObject params=monitorPointService.getMonitorPointById(monitPointId,Time,2,sensor);


        model.addObject("params",params);


        JSONObject params = monitorPointService.getMonitorPointById(monitPointId, Time, 2, sensor);


        model.addObject("params", params);


        model.setViewName("pressureMap");


        return model;


    }








    @GetMapping("/unorganizedEmissions")


@@ -1848,20 +1850,678 @@


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


            // @ApiImplicitParam(name = "sensorKey", value = "传感器key,如有多个用逗号分隔", required = true, paramType = "query", dataType = "String"),


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


    public ModelAndView unorganizedEmissions(HttpServletRequest request,ModelAndView model){


    public ModelAndView unorganizedEmissions(HttpServletRequest request, ModelAndView model) {


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


        String monitPointIdS= (String) parameters.get("monitorPointId");


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


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


        String monitPointIdS = (String) parameters.get("monitorPointId");


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


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


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


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


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


        int monitPointId=Integer.parseInt(monitPointIdS);


        int monitPointId = Integer.parseInt(monitPointIdS);


        //获取公司信息


        JSONObject params=monitorPointService.getMonitorPointById(monitPointId,Time,3,sensor);


        model.addObject("params",params);


        JSONObject params = monitorPointService.getMonitorPointById(monitPointId, Time, 3, sensor);


        model.addObject("params", params);


        model.setViewName("unorganizedMap");


        return model;


    }




}




    @GetMapping("/unorganizedEmissionsRealTime")


    @ApiOperation(value = "无组织排放实时", notes = "无组织排放实时")


    @ApiImplicitParams(value = {


            @ApiImplicitParam(name = "monitorPointId", value = "公司Id", required = true, paramType = "query", dataType = "String"),


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


            @ApiImplicitParam(name = "accountId", value = "用户id", required = false, paramType = "query", dataType = "String")})


    public ModelAndView unorganizedEmissionsBackups(HttpServletRequest request, ModelAndView model) {


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


        String monitPointIdS = (String) parameters.get("monitorPointId");


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


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


        Account account = accountService.getAccountById(Integer.parseInt(accountId));


        int monitPointId = Integer.parseInt(monitPointIdS);


        JSONObject params = monitorPointService.getMacList(monitPointId);


        params.put("accountId", accountId);


        params.put("orgId", account.getOrganizationId());


        params.put("sensor", sensor);


        //获取公司信息


        //JSONObject params=monitorPointService.getMonitorPointById(monitPointId,Time,3,sensor);


        // model.addObject("params",params);


        model.addObject("params", params);


        model.setViewName("newUnorganizedMap");


        return model;


    }




    @GetMapping("/chooseDevice")


    @ResponseBody


    public Object unorganizedEmissionsBackups(String wind, String monitPointId) {


        JSONObject params = new JSONObject();


        Double windDir = Double.parseDouble(wind);


        List<Device> deviceList = deviceService.getDeviceById2(Integer.parseInt(monitPointId));


        Map<String, Object> longAndLatiMap;


        List<Map> longAndLatiList = new ArrayList<>();//经纬度夹角集合，存放的是windList中两台设备的下标和两台设备夹角与风向角的差值


        List<Device> preAngleDeviceList = new ArrayList<Device>(); //角度减去风向最小的两台设备


        for (int f = 0; f < deviceList.size(); f++) {


            for (int h = 0; h < deviceList.size(); h++) {


                if (f != h) {


                    longAndLatiMap = new HashMap<String, Object>();


                    longAndLatiMap.put("h", h);


                    longAndLatiMap.put("f", f);


                    Double angle = mapUtils.getAngle(


                            new MyLatLng((Double) deviceList.get(h).getLongitude(),


                                    (Double) deviceList.get(h).getLatitude()),


                            new MyLatLng((Double) deviceList.get(f).getLongitude(),


                                    (Double) deviceList.get(f).getLatitude()));


                    Double angleDiff = Math.abs(angle - windDir);


                    longAndLatiMap.put("angle", angleDiff);


                    longAndLatiList.add(longAndLatiMap);


                }


            }


        }


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


        int indexAngle = 0;


        for (int j = 1; j < longAndLatiList.size(); j++) {


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


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


                indexAngle = j;


            } else {


                indexAngle = indexAngle;


            }


        }


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


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


        Double length = mapUtils.getDistance((Double) preAngleDeviceList.get(0).getLongitude(), (Double) preAngleDeviceList.get(0).getLatitude(),


                (Double) preAngleDeviceList.get(1).getLongitude(), (Double) preAngleDeviceList.get(1).getLatitude());


        Double subLength = length / 5;


        Double subLength1 = length / 6.1;


        Double angle = mapUtils.getAngle(


                new MyLatLng((Double) preAngleDeviceList.get(0).getLongitude(),


                        (Double) preAngleDeviceList.get(0).getLatitude()),


                new MyLatLng((Double) preAngleDeviceList.get(1).getLongitude(),


                        (Double) preAngleDeviceList.get(1).getLatitude()));


        List locationList = new ArrayList();


        String[] firstLocation = mapUtils.calLocationByDistanceAndLocationAndDirection(angle, (Double) preAngleDeviceList.get(0).getLongitude(),


                (Double) preAngleDeviceList.get(0).getLatitude(), subLength);


        String[] secondLoction = mapUtils.calLocationByDistanceAndLocationAndDirection(angle, Double.parseDouble(firstLocation[0]),


                Double.parseDouble(firstLocation[1]), subLength);


        String[] thirdLocation = mapUtils.calLocationByDistanceAndLocationAndDirection(angle, Double.parseDouble(secondLoction[0]),


                Double.parseDouble(secondLoction[1]), subLength);


        String[] fourthLoction = mapUtils.calLocationByDistanceAndLocationAndDirection(angle, Double.parseDouble(thirdLocation[0]),


                Double.parseDouble(thirdLocation[1]), subLength);


        String[] fivethLoction = mapUtils.calLocationByDistanceAndLocationAndDirection(angle, Double.parseDouble(fourthLoction[0]),


                Double.parseDouble(fourthLoction[1]), subLength1);


        locationList.add(firstLocation);


        locationList.add(secondLoction);


        locationList.add(thirdLocation);


        locationList.add(fourthLoction);


        locationList.add(fivethLoction);


        String preAngleDeviceString = JSON.toJSON(preAngleDeviceList).toString();


        params.put("preAngleDeviceString", preAngleDeviceString);//两台添加箭头的设备


        params.put("locationList", locationList);


        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 = "时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);


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


    }




    @GetMapping("weatherData")


    @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>>> getWeatherData(HttpServletRequest request) throws Exception {


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


    public void updateForecastWeather(HttpServletRequest request) {


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


        weatherService.updateForecastWeather(parameters);


    }




    @GetMapping("dataByTimeSlot")


    @ApiOperation(value = "根据时间类型获取因子的值", notes = "根据时间类型获取因子的值")


    @ApiImplicitParams(value = {


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


            @ApiImplicitParam(name = "startTime", value = "起始时间(格式：2020-08-03/2020-08-03-13)", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "endTime", value = "结束时间(格式：2020-08-04/2020-08-04-14)", required = true, paramType = "query", dataType = "String")})


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


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


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


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


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


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


        Calendar calendar = getInstance();


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


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


        Map device = deviceService.getAllFieldByMac(parameters);


        Map monitorPointMap = monitorPointService.selectAllById(device.get("monitor_point_id").toString());


        List<Map<String, Object>> device_sensorList = sensorService.getSensorByDeviceId(device.get("id").toString());


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


        for (Map<String, Object> device_sensorMap : device_sensorList) {


            device_sensorUnit_map.put(device_sensorMap.get("sensor_key").toString(), device_sensorMap.get("unit"));


        }


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


        if (startTime.length() == 10 && endTime.length() == 10) {


            //获取当日时间


            Date dd = new Date();


            //格式化


            SimpleDateFormat sim = new SimpleDateFormat("yyyy-MM-dd");


            //获取系统当前时间


            String nowTime = sim.format(dd);


            int days = endTime.compareTo(nowTime);


            //System.out.println(days);


            List<String> dayList = DatesUtil.findDaysStr(startTime, endTime);


            //System.out.println("dayList:"+dayList);


            /*if (days<0){


                Date date=null;


                try {


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


                } catch (ParseException e) {


                    e.printStackTrace();


                }


                calendar.setTime(date);


                int day=calendar.get(Calendar.DATE);


                calendar.set(Calendar.DATE,day+1);




                endTime=new SimpleDateFormat("yyyy-MM-dd").format(calendar.getTime());


            }*/


            List<Map<String, Object>> sameDayHourlyList = null;


            if (days >= 0) {


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


                //获取系统当前时间


                String currentTime = df.format(dd);


                sameDayHourlyList = historyHourlyService.getDataByTimeSlot(mac, nowTime, currentTime);


            }


            List<Map<String, Object>> dataList = historyDailyService.getDataByTimeSlot(mac, startTime, endTime);


            if (dataList.isEmpty()) {


                return null;


            }


            Set<String> keys = sensorMap.keySet();


            for (String key : keys) {


                Map<String, Object> oneSensorMap = new LinkedHashMap<>();


                oneSensorMap.put("monitorPointName", monitorPointMap.get("name"));


                oneSensorMap.put("deviceName", device.get("name"));


                oneSensorMap.put("sersorKey", sensorMap.get(key) + "（" + device_sensorUnit_map.get(key) + "）");


                for (String day : dayList) {


                    for (Map<String, Object> dataMap : dataList) {


                        JSONObject dataJson = JSONObject.parseObject(dataMap.get("json").toString());


                        if (dataMap.get("time").toString().equals(day + " 00:00:00.0")) {


                            oneSensorMap.put(dataMap.get("time").toString().substring(0, 10), dataJson.getJSONArray(key).get(2));


                            break;


                        } else {


                            continue;


                        }


                    }


                    if (!oneSensorMap.containsKey(day)) {


                        oneSensorMap.put(day, "");


                    }


                }




                Double avg = 0.0;


                if (sameDayHourlyList != null) {


                    for (Map sameDayHourlyMap : sameDayHourlyList) {


                        List<Double> arr = new ArrayList<>();


                        JSONObject hourlyJson = JSONObject.parseObject(sameDayHourlyMap.get("json").toString());


                        arr.add(Double.parseDouble(hourlyJson.getJSONArray(key).get(2).toString()));


                        Double sum = 0.0;


                        for (int i = 0; i < arr.size(); i++) {


                            sum += arr.get(i);


                        }


                        avg = sum / arr.size();


                    }


                    oneSensorMap.put(nowTime, avg);


                }


                list.add(oneSensorMap);


            }


        } else if (startTime.length() == 13 && endTime.length() == 13) {


            StringBuilder startTime_sb = new StringBuilder(startTime);


            startTime_sb.replace(10, 11, " ");


            startTime = startTime_sb.toString() + ":00:00";


            StringBuilder endTime_sb = new StringBuilder(endTime);


            endTime_sb.replace(10, 11, " ");


            endTime = endTime_sb.toString() + ":00:00";




            List<String> hoursList = DatesUtil.findHoursStr(startTime, endTime);


            //System.out.println("hoursList:"+hoursList);




            List<Map<String, Object>> hourlyList = historyHourlyService.getDataByTimeSlot(mac, startTime, endTime);


            if (hourlyList.isEmpty()) {


                return null;


            }


            Set<String> keys = sensorMap.keySet();


            for (String key : keys) {


                Map<String, Object> oneSensorMap = new LinkedHashMap<>();


                oneSensorMap.put("monitorPointName", monitorPointMap.get("name"));


                oneSensorMap.put("deviceName", device.get("name"));


                oneSensorMap.put("sersorKey", sensorMap.get(key) + "（" + device_sensorUnit_map.get(key) + "）");


                for (String hour : hoursList) {


                    for (Map<String, Object> hourlyMap : hourlyList) {


                        JSONObject dataJson = JSONObject.parseObject(hourlyMap.get("json").toString());


                        if (hourlyMap.get("time").toString().equals(hour + ".0")) {


                            oneSensorMap.put(hourlyMap.get("time").toString().substring(0, 19), dataJson.getJSONArray(key).get(2));


                            break;


                        } else {


                            continue;


                        }


                    }


                    if (!oneSensorMap.containsKey(hour)) {


                        oneSensorMap.put(hour, "");


                    }


                }


                /*for (Map<String, Object> hourlyMap: hourlyList) {


                    JSONObject hourlyJson = JSONObject.parseObject(hourlyMap.get("json").toString());


                    oneSensorMap.put(hourlyMap.get("time").toString().substring(0,19),hourlyJson.getJSONArray(key).get(2));




                }*/


                list.add(oneSensorMap);


            }


        } else {


            return null;


        }


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


    }




    @GetMapping("/getAlarm")


    @ResponseBody


    public List<DeviceRoad> getAlarm(@Param("windData") String windData, @Param("code") String code, @Param("mac") String mac, @Param("speedLevel") String speedLevel) {


        List<DeviceRoad> alarmData = deviceRoadService.getAlarmData(windData, code, mac, speedLevel);


        return alarmData;


    }




    @GetMapping("multiDeviceContrast")


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


    @ApiImplicitParams(value = {


            @ApiImplicitParam(name = "macs", value = "设备mac,如有多个用逗号分隔", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "sensorKey", value = "传感器key", required = true, paramType = "query", dataType = "String"),


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


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


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


        ParameterUtils.getTimeType4Time(parameters);


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


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


    }






    @PostMapping("/tellAlarm")


    @ResponseBody


    public List<List> tellAlarm(String states, String orgId, String accountId, String states1, String regionCode) {


        JSONArray stateList = JSONArray.parseArray(states);//最新的设备数据


        JSONArray stateList1 = JSONArray.parseArray(states1);//前10秒的设备数据


        List<List> lookList = new ArrayList<>();


        Map params = new HashMap();


        String lookString = "";


        //判断前十秒数据和现在数据是否相等，如果不相等进入方法


        //第一次进入接口前十秒数据为null


        if (stateList1 != null && !states.equals(states1)) {


            List<Map> listDevice = JSONObject.parseArray(stateList.toJSONString(), Map.class);


            List<Map> listDevice1 = JSONObject.parseArray(stateList1.toJSONString(), Map.class);


            //将所有设备放到同一个集合下


            List<Map> deviceList = new ArrayList<Map>();


            List<Map> deviceList1 = new ArrayList<Map>();


            //存放所有组织的id


            List orgList = new ArrayList();


            for (Map devices : listDevice) {


                int monitorId = Integer.parseInt((String) devices.get("id"));


                MonitorPoint monitorPoint = monitorPointService.byIdGetMonitorPoint(monitorId);


                int org_id = monitorPoint.getOrganizationId();


                orgList.add(org_id);


                List<Map> devicesList = (List<Map>) devices.get("devices");


                if (!devicesList.isEmpty()) {


                    if (devicesList.size() > 1) {


                        for (Map map : devicesList) {


                            deviceList.add(map);


                        }


                    } else {


                        deviceList.add((Map) ((List) devices.get("devices")).get(0));


                    }


                }


            }


            for (Map devices1 : listDevice1) {


                int monitorId = Integer.parseInt((String) devices1.get("id"));


                MonitorPoint monitorPoint = monitorPointService.byIdGetMonitorPoint(monitorId);


                int org_id = monitorPoint.getOrganizationId();


                List<Map> devicesList = (List<Map>) devices1.get("devices");


                if (!devicesList.isEmpty()) {


                    if (devicesList.size() > 1) {


                        for (Map map : devicesList) {


                            deviceList1.add(map);


                        }


                    } else {


                        deviceList1.add((Map) ((List) devices1.get("devices")).get(0));


                    }


                }


            }


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


            //获得两个时间的设备状态改变的mac号


            for (Map map : deviceList) {


                String state = (String) map.get("state");


                String mac = (String) map.get("mac");


                for (Map map1 : deviceList1) {


                    String state1 = (String) map1.get("state");


                    String mac1 = (String) map1.get("mac");


                    if (mac.equals(mac1)) {


                        if (Integer.parseInt(state) > Integer.parseInt(state1) && Integer.parseInt(state) != 4 /*&& Integer.parseInt(state1) == 0*/) {


                            macList.add(mac + "-" + state + "-" + state1);


                        }


                    }


                }


            }


            //存放不重合的数组


            LinkedHashSet<Integer> orgS = new LinkedHashSet<Integer>(orgList);


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


            Date date = new Date(System.currentTimeMillis());


            Date date1 = new Date(System.currentTimeMillis() - 1000);


            //系统当前时间


            String time = formatter.format(date);


            //系统当前时间的前一秒


            String time1 = formatter.format(date1);


            List<Map> alarmList = new ArrayList<Map>();


            for (Integer org : orgS) {


                int orgNum = alarmConfigService.containOrgId(org);


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


                if (orgNum == 1) {


                    String alarmConfig = alarmConfigService.getValueByOrganizationId(Integer.parseInt(String.valueOf(org)));


                    Map hashMap = JSON.parseObject(alarmConfig, HashMap.class);


                    Map alarmLevels = (Map) hashMap.get("alarmLevels");


                    //数据库因子表只有106个因子


                    for (int i = 1; i < 106; i++) {


                        if (alarmLevels.containsKey("e" + i)) {


                            Map map = (Map) alarmLevels.get("e" + i);


                            if (!map.isEmpty()) {


                                Integer enable = (Integer) map.get("enable");


                                List increment = (List) map.get("increment");


                                if (enable == 1) {


                                    if (!(increment.get(0).toString().equals("0") && increment.get(1).toString().equals("0"))) {


                                        eMap.put("e" + i, increment);


                                    } else {


                                        continue;


                                    }


                                } else {


                                    continue;


                                }


                            }


                        }


                    }


                } else {


                    String defultAlarm = dictionaryDataService.getDefultAlarm();


                    Map hashMap = JSON.parseObject(defultAlarm, HashMap.class);


                    Map alarmLevels = (Map) hashMap.get("alarmLevels");


                    //数据库因子表只有106个因子


                    for (int i = 1; i < 106; i++) {


                        if (alarmLevels.containsKey("e" + i)) {


                            Map map = (Map) alarmLevels.get("e" + i);


                            if (!map.isEmpty()) {


                                Integer enable = (Integer) map.get("enable");


                                List increment = (List) map.get("increment");


                                if (enable == 1) {


                                    if (!(increment.get(0).toString().equals("0") && increment.get(1).toString().equals("0"))) {


                                        eMap.put("e" + i, increment);


                                    } else {


                                        continue;


                                    }


                                } else {


                                    continue;


                                }


                            }


                        }


                    }


                }


                Map map = new HashMap();


                map.put("eMap", eMap);


                map.put("org", org);


                alarmList.add(map);


            }


            for (Map aEMap : alarmList) {


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


                if (macList.size() > 0) {


                    for (String sMac : macList) {


                        String[] aMac = sMac.split("-");


                        String mac = aMac[0];


                        //因为数据库数据是两秒钟插入一条，所以通过两个时间区间获取一条数据，防止一个时间获取数据为空的情况


                        String value = historyService.getValueByMacAndTime(mac, time, time1);


                        Map<String, String> map = new HashMap<String, String>();


                        if (value == null) {


                            Date date2 = new Date(System.currentTimeMillis() - 2000);


                            //系统当前时间的前两秒


                            String time2 = formatter.format(date1);


                            value = historyService.getValueByMacAndTime(mac, time, time2);


                            if (value == null) {


                                Date date3 = new Date(System.currentTimeMillis() - 3000);


                                //系统当前时间的前三秒


                                String time3 = formatter.format(date1);


                                value = historyService.getValueByMacAndTime(mac, time, time3);


                            }


                        }


                        if (value != null) {


                            map.put("mac", mac);


                            map.put("value", value);


                            map.put("state", aMac[1]);


                            map.put("state1", aMac[2]);


                            values.add(map);


                        } else {


                            continue;


                        }


                    }


                }




                if (values.size() > 0 && values.size() == macList.size()) {


                    for (Map dataMap : values) {


                        String oId = deviceService.byMacGetOrgId((String) dataMap.get("mac"));


                        if (!(aEMap.get("org").toString()).equals(oId)) {


                            continue;


                        }


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


                        Map sensorMap = JSONObject.parseObject((String) dataMap.get("value"));


                        Iterator<String> iter = sensorMap.keySet().iterator();


                        while (iter.hasNext()) {


                            String key = iter.next();


                            list.add(key);


                        }


                        String state = (String) dataMap.get("state");


                        String state1 = (String) dataMap.get("state1");


                        List<Map> mapList = new ArrayList();


                        for (String key : list) {


                            if (((Map) aEMap.get("eMap")).containsKey(key)) {


                                Double val = Double.valueOf(sensorMap.get(key).toString());


                                List valueList = (List) ((Map) aEMap.get("eMap")).get(key);


                                Device device = deviceService.byMacGetDevice((String) dataMap.get("mac"));


                                Map<String, Object> sensors = sensorService.getSensorBySensorKey(key);


                                if (key.equals("e1") || key.equals("e2") || key.equals("e10") || key.equals("e11") || key.equals("e15") || key.equals("e16")) {


                                    //判断六参因子超标


                                    if ((state1.equals("0") || state1.equals("1")) && Integer.parseInt(state) > 1) {


                                        if (val > Double.valueOf(String.valueOf(valueList.get(1)))) {


                                            Map lookMap = new HashMap();


                                            lookMap.put("time", time);


                                            lookMap.put("name", device.getName());


                                            lookMap.put("sensor", sensors.get("description"));


                                            lookMap.put("value", val + "" + sensors.get("unit"));


                                            mapList.add(lookMap);


                                            //lookString = time+" "+device.getName()+sensors.get("description")+"="+val + sensors.get("unit")+"超标";


                                            //System.out.println(time + "====" + device.getName() + "=====" + sensors.get("description") + "======" + val + sensors.get("unit"));


                                        }


                                    }


                                } else {//判断非六参因子超标


                                    if (state1.equals("0")) {


                                        if (val > Double.valueOf(String.valueOf(valueList.get(0)))) {


                                            Map lookMap = new HashMap();


                                            lookMap.put("time", time);


                                            lookMap.put("name", device.getName());


                                            lookMap.put("sensor", sensors.get("description"));


                                            lookMap.put("value", val + "" + sensors.get("unit"));


                                            mapList.add(lookMap);


                                        }


                                    }


                                }




                            }


                        }


                        if (mapList.size() > 0) {


                            lookList.add(mapList);


                        } else {


                            continue;


                        }


                    }


                }


            }


        }


        return lookList;


    }




    /*  @GetMapping("/lianxian")


      @ApiOperation(value = "连线", notes = "连线" )


      @GetMapping("multiDeviceContrast")


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


      @ApiImplicitParams(value = {


              @ApiImplicitParam(name = "macs", value = "设备mac,如有多个用逗号分隔", required = true, paramType = "query", dataType = "String"),


              @ApiImplicitParam(name = "sensorKey", value = "传感器key", required = true, paramType = "query", dataType = "String"),


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


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


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


          ParameterUtils.getTimeType4Time(parameters);


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


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


      }




      /*


      * 根据大屏版本号获取版本更新信息


      */


    @GetMapping("screenVersion")


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


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


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


        return screenVersionService.getScreenVersion(version);


    }




    @GetMapping("allDeviceExcel")


    @ApiOperation(value = "所有设备多因子数据报表", notes = "所有设备多因子数据报表")


    @ApiImplicitParams(value = {


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


            @ApiImplicitParam(name = "sensorKey", value = "传感器key,多个逗号隔开", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "startTime", value = "起始时间(格式：2020-08-03)", required = true, paramType = "query", dataType = "String"),


            @ApiImplicitParam(name = "endTime", value = "结束时间(格式：2020-08-04)", required = false, paramType = "query", dataType = "String")})


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


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


        ParameterUtils.getTimeType4Time(parameters);


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


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


    }


}