From dba54bf8c8f9299d61c05bf3a941708ea399c998 Mon Sep 17 00:00:00 2001 From: ZhuDongming <773644075@qq.com> Date: Sun, 26 Apr 2020 15:20:22 +0800 Subject: [PATCH] update excel多个工作表导出 --- src/main/java/com/moral/controller/ScreenController.java | 626 ++++++++++++++++++++++++++++++++++++++++++-------------- 1 files changed, 467 insertions(+), 159 deletions(-) diff --git a/src/main/java/com/moral/controller/ScreenController.java b/src/main/java/com/moral/controller/ScreenController.java index a8375f6..e4bb92c 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; @@ -22,6 +24,7 @@ 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 +68,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 +84,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,6 +95,7 @@ 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; @@ -97,13 +103,16 @@ import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; +import static com.moral.common.util.ResourceUtil.getValue; +import static com.moral.common.util.WebUtils.getParametersStartingWith; + /** * The Class ScreenController.������������ */ @RestController @RequestMapping("/screen") @CrossOrigin(origins = "*", maxAge = 3600) -@SuppressWarnings({ "rawtypes", "unchecked", "unused" }) +@SuppressWarnings({"rawtypes", "unchecked", "unused"}) @Api(tags = "Screen", description = "������������") public class ScreenController { public static Logger log = Logger.getLogger(ScreenController.class); @@ -121,17 +130,26 @@ @Resource DeviceVersionService deviceVersionService; - /** The screen service. */ + /** + * The screen service. + */ @Resource private HistoryService historyService; - /** The account service. */ + /** + * The account service. + */ @Resource private AccountService accountService; - /** The device service. */ + /** + * The device service. + */ @Resource private DeviceService deviceService; + + @Resource + private HistoryHourlyService historyHourlyService; @Resource private HistoryMinutelyService historyMinutelyService; @@ -143,11 +161,15 @@ // @Value(value = "classpath:system/alarmLevels.json") // private org.springframework.core.io.Resource resource; - /** The redis template. */ + /** + * The redis template. + */ @Resource private RedisTemplate<String, String> redisTemplate; - /** The level key. */ + /** + * The level key. + */ private String levelKey = "alarm_"; @Resource @@ -169,7 +191,7 @@ /** * Screen login. ������������ - * + * * @param request the request * @return the map */ @@ -225,9 +247,61 @@ return resultMap; } + @GetMapping("loginNew") + public Map<String, Object> screenLoginNew(HttpServletRequest request) { + Map<String, Object> resultMap = new HashMap<String, Object>(); + Map<String, Object> parameters = getParametersStartingWith(request, null); + if (!(parameters.containsKey("account") && parameters.containsKey("password"))) { + resultMap.put("msg", "������������������������������������"); + resultMap.put("accountId", -1); + } else { + resultMap = accountService.screenLoginNew(parameters); + // ������������������������������������������ + Object orgId = resultMap.get("orgId"); + if (resultMap.get("orgId") != null && resultMap.get("orgId") instanceof Integer) { + StringBuilder areaNamesBuilder = new StringBuilder("������"); + if (!((Integer) orgId).equals(dictionaryDataService.querySupperOrgId())) { + Organization organization = organizationService.getOrganizationById((Integer) orgId); + if (organization.getAreaNames() != null) { + Map<String, String> areaNameMap = BeanUtils.beanToMap(organization.getAreaNames()); + List<String> names = areaNameMap.entrySet().stream().filter(item -> { + return item.getValue() != null; + }).map(item -> { + return item.getValue(); + }).collect(Collectors.toList()); + AreaNames areaNames = organization.getAreaNames(); + areaNamesBuilder.append("/"); + areaNamesBuilder.append(String.join("/", names)); + } + // ������������ + if (organization.getRank() != null && organization.getRank() == 0) { + resultMap.put("type", "enterprise"); + } else { + resultMap.put("type", "government"); + } + Number mapAreaCode = null; + if (organization.getVillageCode() != null) { + mapAreaCode = organization.getVillageCode(); + } else if (organization.getTownCode() != null) { + mapAreaCode = organization.getTownCode(); + } else if (organization.getAreaCode() != null) { + mapAreaCode = organization.getAreaCode(); + } else if (organization.getCityCode() != null) { + mapAreaCode = organization.getCityCode(); + } else if (organization.getProvinceCode() != null) { + mapAreaCode = organization.getProvinceCode(); + } + resultMap.put("mapAreaCode", mapAreaCode.toString()); + } + resultMap.put("mapPath", areaNamesBuilder.toString()); + } + } + return resultMap; + } + /** * Gets the equipment states. ��������������������������������������� - * + * * @param request the request * @return the equipment states */ @@ -240,13 +314,13 @@ /** * Gets the alarm levels. ������������������ - * + * * @param request the request * @return the alarm levels */ @GetMapping("alarm-levels") public Object getAlarmLevels(HttpServletRequest request, Optional<Integer> orgId, Optional<Integer> mpId, - Optional<String> mac) { + Optional<String> mac) { List<Map<String, Object>> sensorAlarmList = null; try { AlarmConfig alarmConfig = null; @@ -319,7 +393,6 @@ } /** - * * @param dataSortCondition ������������������������ * @return */ @@ -354,9 +427,19 @@ 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); + } + /** * Gets the average by all. ������������������������10������������5������������������������������������������ - * + * * @param request the request * @return the average by all * @throws Exception @@ -478,7 +561,7 @@ */ /** * ������������ - * + * * @param model * @param code * @param accountId @@ -486,7 +569,7 @@ */ @RequestMapping(value = "/map-page", method = RequestMethod.GET) public ModelAndView map(ModelAndView model, @RequestParam("areaCode") long code, - @RequestParam("accountId") int accountId) { + @RequestParam("accountId") int accountId) { Account account = accountService.getAccountById(accountId); String regionName = areaService.queryFullNameByCode(code); if (account != null && regionName != null) { @@ -513,10 +596,16 @@ } } + @GetMapping("/getSensorsMap") + public List<Map<String, String>> getSensorsMapOnly(String mac) { + List<Map<String, String>> sensorsMapList = sensorService.getSensorsMaps(mac); + return sensorsMapList; + } + @RequestMapping(value = "/get-monitorpoints", method = RequestMethod.GET) @ResponseBody public ResultBean getMonitorpointList(@RequestParam("orgId") String orgId, MapBounds mapBounds, - @RequestParam("regionCode") String regionCode) { + @RequestParam("regionCode") String regionCode) { ResultBean<List<MonitorPoint>> resultBean = new ResultBean(); Map<String, Object> paramMap = new HashMap<String, Object>(); paramMap.put("orgId", orgId); @@ -532,7 +621,7 @@ @RequestMapping(value = "/get-devices", method = RequestMethod.GET) @ResponseBody public ResultBean getDevices(@RequestParam("orgId") Integer orgId, MapBounds mapBounds, - @RequestParam("regionCode") String regionCode) { + @RequestParam("regionCode") String regionCode) { ResultBean<List<Device>> resultBean = new ResultBean(); Map<String, Object> paramMap = new HashMap<String, Object>(); paramMap.put("orgId", orgId); @@ -548,14 +637,14 @@ @RequestMapping(value = "get-devices-for-popup", method = RequestMethod.GET) @ResponseBody public PageResult getDevicesForPopup(@RequestParam("orgId") Integer orgId, String name, Integer pageSize, - Integer pageNo) { + Integer pageNo) { return deviceService.query(orgId, name, pageSize, pageNo); } @RequestMapping(value = "get-devices-by-mid-oid", method = RequestMethod.GET) @ResponseBody public PageResult getDevicesByMidOid(@RequestParam("orgId") Integer orgId, @RequestParam("mpId") Integer mpId, - Integer pageSize, Integer pageNo) { + Integer pageSize, Integer pageNo) { return deviceService.query(orgId, mpId, pageSize, pageNo); } @@ -646,7 +735,7 @@ /** * ���������������id������������������version��������� - * + * * @param mptid * @return */ @@ -662,7 +751,7 @@ @ApiImplicitParam(name = "dimension", value = "������(profession���region���monitorPoint������)", required = true, paramType = "query", dataType = "String"), @ApiImplicitParam(name = "sensorKey", value = "���������key", required = true, paramType = "query", dataType = "String"), @ApiImplicitParam(name = "accountId", value = "������id", required = true, paramType = "query", dataType = "int"), - @ApiImplicitParam(name = "timeType", value = "������������(month���day���hour������)", required = true, paramType = "query", dataType = "int"), }) + @ApiImplicitParam(name = "timeType", value = "������������(month���day���hour������)", required = true, paramType = "query", dataType = "int"),}) public ResultBean<List<Map<String, Object>>> getRegionRankingData(HttpServletRequest request) { Map<String, Object> parameters = getParametersStartingWith(request, null); List<Map<String, Object>> list = historyService.getRegionRankingData(parameters); @@ -676,7 +765,7 @@ @ApiOperation(value = "������������������������������", notes = "") @ApiImplicitParams(value = { @ApiImplicitParam(name = "primaryKey", defaultValue = "898607b0101730391967", value = "���������������mac������������id", required = true, paramType = "query", dataType = "String"), - @ApiImplicitParam(name = "type", defaultValue = "device", value = "���������'monitorPoint'���'device'", required = true, paramType = "query", dataType = "String"), }) + @ApiImplicitParam(name = "type", defaultValue = "device", value = "���������'monitorPoint'���'device'", required = true, paramType = "query", dataType = "String"),}) @GetMapping("rtm-layout") public ResultBean realTimeMonitorLayout(String primaryKey, String type) { RealTimeDeviceLayout rtdLayout = null; @@ -718,7 +807,7 @@ @ApiImplicitParam(name = "monitorPoint", value = "���������id", required = true, paramType = "query", dataType = "String"), @ApiImplicitParam(name = "mac", value = "������mac", required = false, paramType = "query", dataType = "String"), @ApiImplicitParam(name = "sensorKey", value = "���������key,���������������������������", required = true, paramType = "query", dataType = "String"), - @ApiImplicitParam(name = "time", value = "������,������(���������2018-03)", required = true, paramType = "query", dataType = "String"), }) + @ApiImplicitParam(name = "time", value = "������,������(���������2018-03)", required = true, paramType = "query", dataType = "String"),}) public ResultBean<List<Map<String, Object>>> getMonitorPointOrDeviceAvgDataBySensorKey(HttpServletRequest request) throws Exception { Map<String, Object> parameters = getParametersStartingWith(request, null); @@ -745,7 +834,7 @@ @GetMapping("getmpoint-byid") @ApiOperation(value = "���������������������", notes = "���������������������,���������������������������������������������") @ApiImplicitParams(value = { - @ApiImplicitParam(name = "monitorPointId", defaultValue = "1", value = "���������id", required = true, paramType = "query", dataType = "Integer"), }) + @ApiImplicitParam(name = "monitorPointId", defaultValue = "1", value = "���������id", required = true, paramType = "query", dataType = "Integer"),}) public ResultBean<MonitorPoint> getMonitorPointById(Integer monitorPointId) { MonitorPoint monitorPoint = monitorPointService.queryMonitorPointById(monitorPointId); return new ResultBean<>(monitorPoint); @@ -757,7 +846,7 @@ @GetMapping("aqi24hours") @ApiOperation(value = "������24������aqi������", notes = "������24������������aqi������") @ApiImplicitParams(value = { - @ApiImplicitParam(name = "orgid", defaultValue = "5", value = "������id", required = true, paramType = "query", dataType = "Integer"), }) + @ApiImplicitParam(name = "orgid", defaultValue = "5", value = "������id", required = true, paramType = "query", dataType = "Integer"),}) public ResultBean<List<Map<String, Object>>> getAqi24HoursNC(@RequestParam("orgid") Integer organizationId) { return new ResultBean<>(hangzhouAqiService.queryAqi24Hours(organizationId)); } @@ -765,7 +854,7 @@ @GetMapping("mpt-dev-summary") @ApiOperation(value = "���������������������������������", notes = "���������������������������������") @ApiImplicitParams(value = { - @ApiImplicitParam(name = "orgid", defaultValue = "5", value = "������id", required = true, paramType = "query", dataType = "Integer"), }) + @ApiImplicitParam(name = "orgid", defaultValue = "5", value = "������id", required = true, paramType = "query", dataType = "Integer"),}) public ResultBean<Map> getMptAndDevSummary(@RequestParam("orgid") Integer organizationId) { Map<String, Map> result = new HashMap<>(2); Integer mptCount = monitorPointService.countOfSubOrgs(organizationId); @@ -780,7 +869,7 @@ @GetMapping("weather") @ApiOperation(value = "������������������������", notes = "������������������������") @ApiImplicitParams(value = { - @ApiImplicitParam(name = "organizationId", defaultValue = "5", value = "���������������������id", required = true, paramType = "query", dataType = "String") }) + @ApiImplicitParam(name = "organizationId", defaultValue = "5", value = "���������������������id", required = true, paramType = "query", dataType = "String")}) public ResultBean<Map<String, Object>> getWeatherDataByRegion(HttpServletRequest request) throws Exception { Map<String, Object> parameters = getParametersStartingWith(request, null); Map<String, Object> map = weatherService.getWeatherDataByRegion(parameters); @@ -793,7 +882,7 @@ @ApiImplicitParam(name = "accountId", defaultValue = "1", value = "���������������id", required = true, paramType = "query", dataType = "String"), @ApiImplicitParam(name = "sensorKey", defaultValue = "e1,e2,e3", value = "���������key,���������������������������", required = true, paramType = "query", dataType = "String"), @ApiImplicitParam(name = "time", defaultValue = "", value = "������(long������������)", required = false, paramType = "query", dataType = "String"), - @ApiImplicitParam(name = "interval", defaultValue = "30", value = "���������������������", required = true, paramType = "query", dataType = "Integer"), }) + @ApiImplicitParam(name = "interval", defaultValue = "30", value = "���������������������", required = true, paramType = "query", dataType = "Integer"),}) public ResultBean<Map<String, Object>> getActualDataByRegion(HttpServletRequest request) throws Exception { Map<String, Object> parameters = getParametersStartingWith(request, null); Map<String, Object> map = historyService.getActualDataByRegion(parameters); @@ -803,7 +892,7 @@ @GetMapping("quality") @ApiOperation(value = "������������������", notes = "������������������") @ApiImplicitParams(value = { - @ApiImplicitParam(name = "organizationId", defaultValue = "5", value = "���������������������id", required = true, paramType = "query", dataType = "String") }) + @ApiImplicitParam(name = "organizationId", defaultValue = "5", value = "���������������������id", required = true, paramType = "query", dataType = "String")}) public ResultBean<Map<String, Object>> getQualityCountDayByRegion(HttpServletRequest request) throws Exception { Map<String, Object> parameters = getParametersStartingWith(request, null); Map<String, Object> map = qualityDailyService.getQualityCountDayByRegion(parameters); @@ -814,7 +903,7 @@ @ApiOperation(value = "���������������������������", notes = "���������������������������") @ApiImplicitParams(value = { @ApiImplicitParam(name = "organizationId", defaultValue = "8", value = "���������������������id", required = true, paramType = "query", dataType = "Integer"), - @ApiImplicitParam(name = "regionCode", defaultValue = "320583", value = "���������", required = true, paramType = "query", dataType = "String") }) + @ApiImplicitParam(name = "regionCode", defaultValue = "320583", value = "���������", required = true, paramType = "query", dataType = "String")}) public ResultBean<List<MonitorPoint>> getMonitorPointsAndDevicesByRegion(HttpServletRequest request) throws Exception { Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); @@ -826,7 +915,7 @@ @ApiOperation(value = "������������������", notes = "������������������") @ApiImplicitParams(value = { @ApiImplicitParam(name = "organizationId", defaultValue = "8", value = "���������������������id", required = true, paramType = "query", dataType = "Integer"), - @ApiImplicitParam(name = "regionCode", defaultValue = "320583", value = "���������", required = true, paramType = "query", dataType = "String") }) + @ApiImplicitParam(name = "regionCode", defaultValue = "320583", value = "���������", required = true, paramType = "query", dataType = "String")}) public ResultBean<Collection<Object>> getDevicesStateByRegion(HttpServletRequest request) throws Exception { Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); Collection<Object> monitorPoints = monitorPointService.getDevicesStateByRegion(parameters); @@ -842,7 +931,9 @@ @ApiImplicitParam(name = "organizationId", defaultValue = "5", value = "���������������������id", required = true, paramType = "query", dataType = "Integer"), @ApiImplicitParam(name = "time", defaultValue = "2019", value = "���������������", required = true, paramType = "query", dataType = "String"), @ApiImplicitParam(name = "sensorKey", defaultValue = "e27", value = "������������������������key", required = true, paramType = "query", dataType = "String"), - @ApiImplicitParam(name = "regionCode", defaultValue = "130000", value = "���������", required = true, paramType = "query", dataType = "String") }) + @ApiImplicitParam(name = "regionCode", defaultValue = "130000", value = "���������", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "monitorPointId", value = "���������id(���������376)", required = false, paramType = "query", dataType = "int"), + @ApiImplicitParam(name = "mac", value = "������mac(���������vocscxwnm00001)", required = false, paramType = "query", dataType = "String")}) public ResultBean<List<Map<String, Object>>> getemissionsData(HttpServletRequest request) throws Exception { Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); List<Map<String, Object>> result = historyDailyService.getEmissionsData(parameters); @@ -856,7 +947,7 @@ @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 = "overproofRatio", defaultValue = "0", value = "������������(0,1,2,3)(������,������100%,������200%,������300%)", required = true, paramType = "query", dataType = "String"), - @ApiImplicitParam(name = "regionCode", defaultValue = "130000", value = "���������", required = true, paramType = "query", dataType = "String") }) + @ApiImplicitParam(name = "regionCode", defaultValue = "130000", value = "���������", required = true, paramType = "query", dataType = "String")}) public ResultBean<Map> getOverproofData(HttpServletRequest request) throws Exception { Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); Map result = historyDailyService.getOverproofData(parameters); @@ -866,7 +957,7 @@ @GetMapping("limit-device") @ApiOperation(value = "���������������������������", notes = "���������������������������") @ApiImplicitParams(value = { - @ApiImplicitParam(name = "mac", defaultValue = "p5dnd7a0391956", value = "������mac���", required = true, paramType = "query", dataType = "String") }) + @ApiImplicitParam(name = "mac", defaultValue = "p5dnd7a0391956", value = "������mac���", required = true, paramType = "query", dataType = "String")}) public ResultBean<List<Map<String, Object>>> getLimitDataByDevice(HttpServletRequest request) throws Exception { Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); String density = deviceService.getLimitDataByDevice(parameters); @@ -884,21 +975,21 @@ } /** - * @description ������������mac������������������������������������������ - * @author ZhuDongming - * @date 2019-06-05 10:02:10 * @param model * @param request * @return * @throws Exception + * @description ������������mac������������������������������������������ + * @author ZhuDongming + * @date 2019-06-05 10:02: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()); @@ -918,7 +1009,7 @@ params.put("regionName", regionName); params.put("monitorPoint", monitorPoint); params.put("device", device); - params.put("deviceSecond",deviceSecond); + params.put("deviceSecond", deviceSecond); String paramsJson = params.toJSONString(); model.addObject("traceabilityParams", paramsJson); model.setViewName("traceability"); @@ -952,53 +1043,85 @@ System.out.println("ScreenController-----getSensor-----map:"+map); return new ResultBean<Map<String, Object>>(map); }*/ - - @GetMapping("getSensorByMonitorPointId") - @ApiOperation(value = "������������", notes = "������������") - @ApiImplicitParams(value = { - @ApiImplicitParam(name = "monitor_point_id", value = "������������id", required = true, paramType = "query", dataType = "String") - }) - public ResultBean<List<Map<String, Object>>> getSensorByMonitorPointId(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>> map = sensorUnitService.getSensorsByMonitPointId2(monitor_point_id); - return new ResultBean<List<Map<String, Object>>>(map); - } - - @GetMapping("AIForecast") - @ApiOperation(value = "AI������", notes = "AI������") - @ApiImplicitParams(value = { - @ApiImplicitParam(name = "monitorPoint", value = "���������id", required = true, paramType = "query", dataType = "String"), - @ApiImplicitParam(name = "mac", value = "������mac", required = false, paramType = "query", dataType = "String"), - @ApiImplicitParam(name = "sensorKey", value = "���������key,���������������������������", required = true, paramType = "query", dataType = "String"), - @ApiImplicitParam(name = "time", value = "������,���(���������2018-03-06)", required = true, paramType = "query", dataType = "String"), - }) - 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(); - 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); - parameters.put("time", alterTime); + + @GetMapping("getSensorByMonitorPointId") + @ApiOperation(value = "������������", notes = "������������") + @ApiImplicitParams(value = { + @ApiImplicitParam(name = "monitor_point_id", value = "������������id", required = true, paramType = "query", dataType = "String") + }) + public ResultBean<List<Map<String, Object>>> getSensorByMonitorPointId(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>> 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); + 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); + 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������") + @ApiImplicitParams(value = { + @ApiImplicitParam(name = "monitorPoint", value = "���������id", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "mac", value = "������mac", required = false, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "sensorKey", value = "���������key,���������������������������", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "time", value = "������,���(���������2018-03-06)", required = true, paramType = "query", dataType = "String"), + }) + 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); + 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"); + 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<>(); mpMap = monitorPointService.selectAllById(monitorPoint); //������������map��������������������������������������������������� @@ -1006,95 +1129,280 @@ 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); + Map<String, Map<String, Object>> sensorUnitMap = sensorUnitService.getSensorsByMonitPointId(monitor_point_id); 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("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) { - if(sensorUnitMap!=null && !sensorUnitMap.isEmpty()) { - if(sensorUnitMap.get(string)!=null) { - units.add(sensorUnitMap.get(string).get("name").toString()); - String rules = sensorUnitMap.get(string).get("rules").toString(); - rules = rules.replace("{0}", "a"); - rules = rules.replace("d", ""); - Expression expression = AviatorEvaluator.compile(rules); - Double value; - Map<String, Object> ev = new HashMap<>(); - ev.put("a", map.get(string)); - value = (Double) expression.execute(ev); - //������������������ - DecimalFormat df = new DecimalFormat("#.00"); - value = Double.parseDouble(df.format(value)); - values.add(value); - }else { - Map<String, Object> sensorMap = sensorService.getSensorBySensorKey(string); - units.add(sensorMap.get("unit").toString()); - values.add((Number) map.remove(string)); - } - }else { - Map<String, Object> sensorMap = sensorService.getSensorBySensorKey(string); - units.add(sensorMap.get("unit").toString()); - values.add((Number) map.remove(string)); - } + if (sensorUnitMap != null && !sensorUnitMap.isEmpty()) { + if (sensorUnitMap.get(string) != null) { + units.add(sensorUnitMap.get(string).get("name").toString()); + String rules = sensorUnitMap.get(string).get("rules").toString(); + rules = rules.replace("{0}", "a"); + rules = rules.replace("d", ""); + Expression expression = AviatorEvaluator.compile(rules); + Double value; + Map<String, Object> ev = new HashMap<>(); + ev.put("a", map.get(string)); + value = (Double) expression.execute(ev); + //������������������ + DecimalFormat df = new DecimalFormat("#.00"); + value = Double.parseDouble(df.format(value)); + values.add(value); + } else { + Map<String, Object> sensorMap = sensorService.getSensorBySensorKey(string); + units.add(sensorMap.get("unit").toString()); + values.add((Number) map.remove(string)); + } + } else { + Map<String, Object> sensorMap = sensorService.getSensorBySensorKey(string); + units.add(sensorMap.get("unit").toString()); + values.add((Number) map.remove(string)); + } //values.add((Number) map.remove(string)); } map.put("values", values); map.put("units", units); } - return new ResultBean<List<Map<String, Object>>>(list); - } - - @GetMapping("getWeather") - @ApiOperation(value = "������������������", notes = "������������������") - @ApiImplicitParams(value = { - @ApiImplicitParam(name = "organizationId", defaultValue = "5", value = "���������������������id", required = true, paramType = "query", dataType = "String"), - @ApiImplicitParam(name = "time", value = "������,���(���������2018-03-06)", required = true, paramType = "query", dataType = "String"), - }) - public ResultBean<Map<String, Object>> getWeather(HttpServletRequest request) throws Exception { - Map<String, Object> parameters = getParametersStartingWith(request, null); + return new ResultBean<List<Map<String, Object>>>(list); + } + + @GetMapping("getWeather") + @ApiOperation(value = "������������������", notes = "������������������") + @ApiImplicitParams(value = { + @ApiImplicitParam(name = "organizationId", defaultValue = "5", value = "���������������������id", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "time", value = "������,���(���������2018-03-06)", required = true, paramType = "query", dataType = "String"), + }) + 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); - } + } + + @GetMapping("/uavTrajectory") + @ApiOperation(value = "���������������������������", notes = "���������������������������") + @ApiImplicitParams(value = { + @ApiImplicitParam(name = "mac", value = "������mac������������p5dnd7a0392068���", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "startTime", value = "������������(���������2019-07-17-17)", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "endTime", value = "������������(���������2019-07-17-18)", required = true, paramType = "query", dataType = "String") + }) + public ModelAndView uavTrajectory(ModelAndView model, HttpServletRequest request) throws Exception { + Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); + String st = parameters.get("startTime").toString(); + String startYearAndDay = st.substring(0, st.lastIndexOf("-")); + String startHour = st.substring(st.lastIndexOf("-") + 1); + String startTime = startYearAndDay + " " + startHour + ":00:00"; + String et = parameters.get("endTime").toString(); + String endYearAndDay = et.substring(0, et.lastIndexOf("-")); + String endHour = et.substring(et.lastIndexOf("-") + 1); + String endTime = endYearAndDay + " " + endHour + ":00:00"; + parameters.put("startTime", startTime); + parameters.put("endTime", endTime); + String mac = parameters.get("mac").toString(); + if (mac != null && mac.length() != 0) { + List<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"); + return model; + } else { + StringBuilder msg = new StringBuilder(); + msg.append(" param[0] mac:"); + msg.append(mac); + log.warn(msg); + model.setViewName("403"); + return model; + } + } + + @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); + Map<String, Object> hourAqi = historyService.gitHourlyAQIByMonitorPointIdAndTimeslot(parameters); + 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); + } + + @GetMapping("/carTrajectory") + @ApiOperation(value = "���������������������", notes = "���������������������") + @ApiImplicitParams(value = { + @ApiImplicitParam(name = "mac", value = "������mac������������p5dnd7a0392082���", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "startTime", value = "������������(���������2020-03-19-14)", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "endTime", value = "������������(���������2020-03-19-17)", required = true, paramType = "query", dataType = "String") + }) + public ModelAndView carTrajectory(ModelAndView model, HttpServletRequest request) throws Exception { + Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); + String st = parameters.get("startTime").toString(); + String startYearAndDay = st.substring(0, st.lastIndexOf("-")); + String startHour = st.substring(st.lastIndexOf("-") + 1); + String startTime = startYearAndDay + " " + startHour + ":00:00"; + String et = parameters.get("endTime").toString(); + String endYearAndDay = et.substring(0, et.lastIndexOf("-")); + String endHour = et.substring(et.lastIndexOf("-") + 1); + String endTime = endYearAndDay + " " + endHour + ":00:00"; + parameters.put("startTime", startTime); + parameters.put("endTime", endTime); + String mac = parameters.get("mac").toString(); + if (mac != null && mac.length() != 0) { + List<List<Map<String, Object>>> sensorData = historyService.getCarSensorData(parameters); + Map<String, String> sensorsMap = sensorService.getSensorsMap(parameters); + List<Map<String, Object>> sensorList = new ArrayList<>(); + if (sensorData.size() == 3) { + sensorList = sensorData.get(0); + } + JSONObject params = new JSONObject(); + params.put("sensorInfo", sensorList); + params.put("sensorsMap", sensorsMap); + String paramsJson = params.toJSONString(); + model.addObject("carTrajectoryParams", paramsJson); + model.setViewName("cartrajectory"); + return model; + } else { + StringBuilder msg = new StringBuilder(); + msg.append(" param[0] mac:"); + msg.append(mac); + log.warn(msg); + model.setViewName("403"); + return model; + } + } + + @GetMapping("device-excel") + @ApiOperation(value = "������������������������", notes = "������������������������") + @ApiImplicitParams(value = { + @ApiImplicitParam(name = "sensorKey", value = "���������key", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "organizationId", defaultValue = "8", value = "���������������������id", required = true, paramType = "query", dataType = "Integer"), + @ApiImplicitParam(name = "regionCode", defaultValue = "320583", value = "���������", required = true, paramType = "query", dataType = "String"), + @ApiImplicitParam(name = "time", value = "������(���������2020-04-09���2019-04)", required = true, paramType = "query", dataType = "String")}) + public ResultBean<List<Map<String, Object>>> getDevicesDataToExcel(HttpServletRequest request) throws Exception { + Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); + ParameterUtils.getTimeType4Time(parameters); + Object sensorKey = parameters.get("sensorKey"); + parameters.put("sensorKeys", Arrays.asList(sensorKey)); + List<String> macList = new ArrayList<>(); + List<MonitorPoint> monitorPoints = monitorPointService.getMonitorPointsAndDevicesByRegion(parameters); + for (MonitorPoint m : monitorPoints) { + for (Device d : m.getDevices()) { + macList.add(d.getMac()); + } + } + parameters.put("macs", macList); + List<Map<String, Object>> list = new ArrayList<>(); + if (!CollectionUtils.isEmpty(macList)) { + list = historyMinutelyService.getDevicesAvgDataToExcel(parameters); + } + return new ResultBean<List<Map<String, Object>>>(list); + } } -- Gitblit v1.8.0