From f32e22e52376cabe49e8c7d1f52adb4b1aebffd3 Mon Sep 17 00:00:00 2001 From: ZhuDongming <773644075@qq.com> Date: Wed, 20 Nov 2019 17:15:08 +0800 Subject: [PATCH] update:移动到设备marker上实时显示因子数据 --- src/main/java/com/moral/controller/ScreenController.java | 322 ++++++++++++++++++++++++++++++++++------------------- 1 files changed, 204 insertions(+), 118 deletions(-) diff --git a/src/main/java/com/moral/controller/ScreenController.java b/src/main/java/com/moral/controller/ScreenController.java index 429fd24..042724a 100644 --- a/src/main/java/com/moral/controller/ScreenController.java +++ b/src/main/java/com/moral/controller/ScreenController.java @@ -1,16 +1,18 @@ package com.moral.controller; -import static com.moral.common.util.ResourceUtil.getValue; -import static com.moral.common.util.WebUtils.getParametersStartingWith; - import java.io.BufferedReader; import java.io.ByteArrayInputStream; import java.io.InputStream; import java.io.InputStreamReader; +import java.text.DateFormat; import java.text.DecimalFormat; +import java.text.SimpleDateFormat; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.Arrays; import java.util.Collection; +import java.util.Date; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.List; @@ -18,10 +20,8 @@ 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.collections.MapUtils; import org.apache.commons.net.ftp.FTPClient; import org.apache.log4j.Logger; import org.dom4j.Document; @@ -65,6 +65,7 @@ import com.moral.entity.MapBounds; import com.moral.entity.MonitorPoint; import com.moral.entity.Organization; +import com.moral.entity.Point; import com.moral.entity.Region; import com.moral.entity.alarm.AlarmConfig; import com.moral.entity.alarm.AlarmConfigValue; @@ -80,6 +81,7 @@ import com.moral.service.DictionaryDataService; import com.moral.service.HangzhouAqiService; import com.moral.service.HistoryDailyService; +import com.moral.service.HistoryHourlyService; import com.moral.service.HistoryMinutelyService; import com.moral.service.HistoryService; import com.moral.service.MachineActivateService; @@ -90,12 +92,19 @@ import com.moral.service.SensorService; import com.moral.service.SensorUnitService; import com.moral.service.WeatherService; +import com.moral.util.AQICalculation; import com.moral.util.TempAllocationUtils; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; + +import static com.moral.common.util.ResourceUtil.getValue; +import static com.moral.common.util.WebUtils.getParametersStartingWith; /** * The Class ScreenController.������������ @@ -138,6 +147,9 @@ */ @Resource private DeviceService deviceService; + + @Resource + private HistoryHourlyService historyHourlyService; @Resource private HistoryMinutelyService historyMinutelyService; @@ -362,15 +374,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); } /** @@ -530,6 +542,24 @@ model.setViewName("403"); return model; } + } + + @GetMapping("/getSensorsMap") + public ResultBean getSensorsMapOnly(String mac){ + Map<String, String> paramMap = sensorService.getSensorsMapOnly(mac); + ResultBean<Map<String, String>> resultBean = new ResultBean(); + resultBean.setData(paramMap); + resultBean.setCode(ResultBean.SUCCESS); + return resultBean; + } + + @GetMapping("/getSensorsUnitMap") + public ResultBean getSensorsUnitMap(String mac){ + Map<String, String> paramMap = sensorService.getSensorsUnitMap(mac); + ResultBean<Map<String, String>> resultBean = new ResultBean(); + resultBean.setData(paramMap); + resultBean.setCode(ResultBean.SUCCESS); + return resultBean; } @RequestMapping(value = "/get-monitorpoints", method = RequestMethod.GET) @@ -862,8 +892,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); @@ -916,10 +946,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()); @@ -985,50 +1015,51 @@ 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("list:"+list); + System.out.println("sensorUnitList:"+sensorUnitList); + for (Map<String, Object> sensorMap : list) { + for (Map<String, Object> sensorUnitMap : sensorUnitList) { + if (sensorUnitMap.get("sensor_key").equals(sensorMap.get("sensorKey"))) { + sensorMap.put("unit", sensorUnitMap.get("name")); + } + } + } + return new ResultBean<List<Map<String, Object>>>(list); + } @GetMapping("AIForecast") @ApiOperation(value = "AI������", notes = "AI������") @@ -1043,25 +1074,15 @@ //System.out.println(parameters); String monitorPoint = (String) parameters.get("monitorPoint"); String intoTime = parameters.get("time").toString(); - String[] timeArray = intoTime.split("-"); - //System.out.println(timeArray); - Integer year = Integer.parseInt(timeArray[0]); - Integer mon = Integer.parseInt(timeArray[1]); - if (mon > 1) { - mon = mon - 1; - } else { - mon = 12; - year = year - 1; - } - String alterTime = year.toString() + "-" + mon.toString() + "-" + timeArray[2]; - //System.out.println(alterTime); + Date date = new SimpleDateFormat("yy-MM-dd").parse(intoTime); + DateFormat df1 = new SimpleDateFormat("yyyy-MM-dd"); + String alterTime = df1.format(date.getTime()-15*24*60*60*1000); parameters.put("time", alterTime); ParameterUtils.getTimeType4Time(parameters); String monitor_point_id = (String) parameters.get("monitorPoint"); parameters.put("monitorPointId", parameters.remove("monitorPoint")); String[] sensorKeys = parameters.remove("sensorKey").toString().split(","); parameters.put("sensors", Arrays.asList(sensorKeys)); - // monitorPointService.isCompensateCalculation(parameters); List<Map<String, Object>> list = historyMinutelyService.getMonitorPointOrDeviceAvgData(parameters); Map<String, Object> mpMap = new HashMap<>(); @@ -1071,8 +1092,18 @@ weatherParameters.put("organizationId", mpMap.get("organization_id")); weatherParameters.put("time", intoTime); //������������������ - Map<String, Object> weatherMap = weatherService.get15DayWeatherDataByRegion(weatherParameters); - Map<String, Object> tempMap = TempAllocationUtils.tempAllocation(weatherMap); + Map<String, Object> weatherMap = new HashMap<>(); + Map<String, Object> tempMap = new HashMap<>(); + Boolean tf = false; + for(int i=0;i<sensorKeys.length;i++) { + if(sensorKeys[i].equals("e7")) { + tf = true; + } + } + if (tf) { + weatherMap = weatherService.get15DayWeatherDataByRegion(weatherParameters); + tempMap = TempAllocationUtils.tempAllocation(weatherMap); + } //������������������ Map<String, Map<String, Object>> sensorUnitMap = sensorUnitService.getSensorsByMonitPointId(monitor_point_id); @@ -1080,7 +1111,9 @@ String time = map.get("time").toString(); time = time.substring(time.length() - 2); map.put("time", Integer.valueOf(time)); - map.put("temp", tempMap.get(map.get("time").toString())); + if (tempMap!=null) { + map.put("temp", tempMap.get(map.get("time").toString())); + } List<Number> values = new ArrayList<Number>(); List<String> units = new ArrayList<String>(); for (String string : sensorKeys) { @@ -1126,38 +1159,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); } @@ -1182,26 +1183,25 @@ parameters.put("startTime", startTime); parameters.put("endTime", endTime); String mac = parameters.get("mac").toString(); - List<Map<String, Object>> sensorList=null; - List<Map<String, Object>> sensorListMin=null; - List<Map<String, Object>> sensorListMax=null; if (mac != null && mac.length() != 0) { - if(historyMinutelyService.getSensorData(parameters).size()==3){ - sensorList = historyMinutelyService.getSensorData(parameters).get(0); - sensorListMin = historyMinutelyService.getSensorData(parameters).get(1); - sensorListMax = historyMinutelyService.getSensorData(parameters).get(2); - }else{ - sensorList = new ArrayList<>(); - sensorListMin = new ArrayList<>(); - sensorListMax = new ArrayList<>(); + List<List<Map<String, Object>>> sensorData = historyMinutelyService.getSensorData(parameters); + Map<String, String> sensorsMap = sensorService.getSensorsMap(parameters); + List<Map<String, Object>> sensorList = new ArrayList<>(); + List<Map<String, Object>> sensorListMin = new ArrayList<>(); + List<Map<String, Object>> sensorListMax = new ArrayList<>(); + if (sensorData.size() == 3) { + sensorList = sensorData.get(0); + sensorListMin = sensorData.get(1); + sensorListMax = sensorData.get(2); } JSONObject params = new JSONObject(); params.put("sensorInfo", sensorList); params.put("sensorInfoMin", sensorListMin); params.put("sensorInfoMax", sensorListMax); + params.put("sensorsMap", sensorsMap); String paramsJson = params.toJSONString(); model.addObject("uavTrajectoryParams", paramsJson); - model.setViewName("uavTrajectory"); + model.setViewName("uavtrajectory"); return model; } else { StringBuilder msg = new StringBuilder(); @@ -1213,4 +1213,90 @@ } } + @GetMapping("/pollutionSource") + @ApiOperation(value = "������������������", notes = "������������������") + @ApiImplicitParams(value = { + @ApiImplicitParam(name = "mac", value = "������mac������(������898607b0101730392251)", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "sensorKey", value = "������������������������key(���������e1)", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "time", value = "������������(���������2019-09-01-10)", required = true, paramType = "query", dataType = "String")}) + public ModelAndView pollutionSource(ModelAndView model, HttpServletRequest request) throws Exception { + Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); + String timeStr = parameters.get("time").toString(); + String YearAndDay = timeStr.substring(0, timeStr.lastIndexOf("-")); + String Hour = timeStr.substring(timeStr.lastIndexOf("-") + 1); + String time = YearAndDay + " " + Hour + ":00:00"; + DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + LocalDateTime timeLocalDateTime = LocalDateTime.parse(time, dateTimeFormatter); + int month = timeLocalDateTime.getMonth().getValue(); + Point dirPoint = historyHourlyService.getDirPoint(parameters); + Map<String, Object> getPollutionSourceData = historyHourlyService.getPollutionSourceDataByHour(parameters); + if (MapUtils.isEmpty(getPollutionSourceData)) { + getPollutionSourceData = historyHourlyService.getPollutionSourceDataAll(parameters); + } + if (MapUtils.isEmpty(getPollutionSourceData)) { + getPollutionSourceData = new HashMap<>(); + } + String mac = parameters.get("mac").toString(); + Device device = deviceService.getDeviceByMac(mac, false); + JSONObject params = new JSONObject(); + params.put("device", device); + params.put("month", month); + params.put("dirPoint", dirPoint); + params.put("getPollutionSourceData", getPollutionSourceData); + String paramsJson = params.toJSONString(); + model.addObject("pollutionSourceParams", paramsJson); + model.setViewName("pollutionsource"); + return model; + } + + @GetMapping("getAirQualityComparison") + @ApiOperation(value = "������������������", notes = "������������������") + @ApiImplicitParams(value = { + @ApiImplicitParam(name = "organizationId", defaultValue = "5", value = "���������������������id", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "monitor_point_id", defaultValue = "5", value = "������������id", required = true, paramType = "query", dataType = "String")}) + public ResultBean<Map<String, Object>> getAirQualityComparison(HttpServletRequest request) throws Exception { + Map<String, Object> parameters = getParametersStartingWith(request, null); + Map<String, Object> map = weatherService.getWeatherDataByRegion(parameters); + Map<String, Double> sensorMap = new HashMap<>(); + sensorMap.put("e1", Double.parseDouble(map.get("pm25").toString())); + sensorMap.put("e2", Double.parseDouble(map.get("pm10").toString())); + sensorMap.put("e11", Double.parseDouble(map.get("so2").toString())); + sensorMap.put("e16", Double.parseDouble(map.get("no2").toString())); + sensorMap.put("e10", Double.parseDouble(map.get("co").toString())); + sensorMap.put("e15", Double.parseDouble(map.get("o3").toString())); + Map<String, Object> StateControl = AQICalculation.hourlyAQI(sensorMap); + System.out.println("StateControl:" + StateControl); + Map<String, Object> hourAqi = historyService.gitHourlyAQIByMonitorPointIdAndTimeslot(parameters); + System.out.println("hourAqi:" + hourAqi); + Map<String, Object> returnMap = new HashMap<>(); + returnMap.put("MonitorPointAQI", hourAqi.get("AQI")); + returnMap.put("StateControlAQI", StateControl.get("AQI")); + return new ResultBean<Map<String, Object>>(returnMap); + } + + + @GetMapping("mointorPointRank") + @ApiOperation(value = "������������������", notes = "������������������") + @ApiImplicitParams(value = { + @ApiImplicitParam(name = "accountId", value = "������id", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "sensor", value = "������", required = true, paramType = "query", dataType = "String") + }) + public ResultBean<List<Map<String, Object>>> getMointorPointRank(HttpServletRequest request) { + Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); + String id = parameters.get("accountId").toString(); + String sensor = parameters.get("sensor").toString(); + Map<String, Object> account = accountService.getOrganizationIdByAccountId(id); + //������������id������������������������������ + account.put("sensor", sensor); + List<Map<String, Object>> rankList = historyService.getMointorPointRankByOrganizationId(account); + List<Map<String, Object>> returnList = new ArrayList<>(); + for (Map<String, Object> map : rankList) { + boolean contains = map.containsKey("sensor"); + if (contains) { + returnList.add(map); + } + } + return new ResultBean<List<Map<String, Object>>>(returnList); + } + } -- Gitblit v1.8.0