From a3d67cd77e3f3d06000e032374329c870b2997a4 Mon Sep 17 00:00:00 2001 From: xufenglei <xufenglei> Date: Mon, 24 Jun 2019 09:12:41 +0800 Subject: [PATCH] update --- src/main/java/com/moral/controller/ScreenController.java | 134 ++++++++++++++++++++------------------------ 1 files changed, 62 insertions(+), 72 deletions(-) diff --git a/src/main/java/com/moral/controller/ScreenController.java b/src/main/java/com/moral/controller/ScreenController.java index d192bf3..3e19794 100644 --- a/src/main/java/com/moral/controller/ScreenController.java +++ b/src/main/java/com/moral/controller/ScreenController.java @@ -1,5 +1,48 @@ 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.util.ArrayList; +import java.util.Arrays; +import java.util.Collection; +import java.util.HashMap; +import java.util.LinkedHashMap; +import java.util.List; +import java.util.Map; +import java.util.Optional; +import java.util.stream.Collectors; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletRequest; + +import org.apache.commons.collections.CollectionUtils; +import org.apache.commons.net.ftp.FTPClient; +import org.apache.log4j.Logger; +import org.dom4j.Document; +import org.dom4j.Element; +import org.dom4j.io.SAXReader; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.cglib.beans.BeanMap; +import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.security.access.prepost.PreAuthorize; +import org.springframework.util.ObjectUtils; +import org.springframework.web.bind.annotation.CrossOrigin; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestMethod; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.ResponseBody; +import org.springframework.web.bind.annotation.RestController; +import org.springframework.web.servlet.ModelAndView; +import org.xml.sax.InputSource; + import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; @@ -44,51 +87,11 @@ import com.moral.service.SensorService; import com.moral.service.SensorUnitService; import com.moral.service.WeatherService; + import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; import io.swagger.annotations.ApiImplicitParams; import io.swagger.annotations.ApiOperation; -import org.apache.commons.collections.CollectionUtils; -import org.apache.commons.net.ftp.FTPClient; -import org.apache.log4j.Logger; -import org.dom4j.Document; -import org.dom4j.Element; -import org.dom4j.io.SAXReader; -import org.springframework.beans.factory.annotation.Value; -import org.springframework.cglib.beans.BeanMap; -import org.springframework.data.redis.core.RedisTemplate; -import org.springframework.security.access.prepost.PreAuthorize; -import org.springframework.util.ObjectUtils; -import org.springframework.web.bind.annotation.CrossOrigin; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.PostMapping; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestMethod; -import org.springframework.web.bind.annotation.RequestParam; -import org.springframework.web.bind.annotation.ResponseBody; -import org.springframework.web.bind.annotation.RestController; -import org.springframework.web.servlet.ModelAndView; -import org.xml.sax.InputSource; - -import javax.annotation.Resource; -import javax.servlet.http.HttpServletRequest; -import java.io.BufferedReader; -import java.io.ByteArrayInputStream; -import java.io.InputStream; -import java.io.InputStreamReader; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.Collection; -import java.util.HashMap; -import java.util.LinkedHashMap; -import java.util.List; -import java.util.Map; -import java.util.Optional; -import java.util.stream.Collectors; - -import static com.moral.common.util.ResourceUtil.getValue; -import static com.moral.common.util.WebUtils.getParametersStartingWith; /** * The Class ScreenController.������������ @@ -951,13 +954,11 @@ @ApiImplicitParams(value = { @ApiImplicitParam(name = "monitor_point_id", value = "������������id", required = true, paramType = "query", dataType = "String") }) - public ResultBean<Map<String, Map<String, Object>>> getSensorByMonitorPointId(HttpServletRequest request) throws Exception { + 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"); - System.out.println("ScreenController-----getSensorByMonitorPointId-----monitor_point_id:"+monitor_point_id); - Map<String, Map<String, Object>> map = sensorUnitService.getSensorsByMonitPointId(monitor_point_id); - System.out.println("ScreenController-----getSensorByMonitorPointId-----map:"+map); - return new ResultBean<Map<String, Map<String, Object>>>(map); + List<Map<String, Object>> map = sensorUnitService.getSensorsByMonitPointId2(monitor_point_id); + return new ResultBean<List<Map<String, Object>>>(map); } @GetMapping("AIForecast") @@ -970,15 +971,28 @@ }) public ResultBean<List<Map<String, Object>>> AIForecast (HttpServletRequest request) throws Exception { Map<String, Object> parameters = getParametersStartingWith(request, null); + //System.out.println(parameters); + 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); ParameterUtils.getTimeType4Time(parameters); String monitor_point_id = (String) parameters.get("monitorPoint"); parameters.put("monitorPointId", parameters.remove("monitorPoint")); String[] sensorKeys = parameters.remove("sensorKey").toString().split(","); - System.out.println("ScreenController-----AIForecast-----sensorKeys:"+sensorKeys.toString()); parameters.put("sensors", Arrays.asList(sensorKeys)); // monitorPointService.isCompensateCalculation(parameters); List<Map<String, Object>> list = historyMinutelyService.getMonitorPointOrDeviceAvgData(parameters); - System.out.println("ScreenController-----AIForecast-----list:"+list); //������������������ Map<String, Map<String, Object>> sensorUnitMap = sensorUnitService.getSensorsByMonitPointId(monitor_point_id); @@ -995,12 +1009,10 @@ units.add(sensorUnitMap.get(string).get("name").toString()); }else { Map<String, Object> sensorMap = sensorService.getSensorBySensorKey(string); - System.out.println("ScreenController-----AIForecast-----sensorMap:"+sensorMap); units.add(sensorMap.get("unit").toString()); } }else { Map<String, Object> sensorMap = sensorService.getSensorBySensorKey(string); - System.out.println("ScreenController-----AIForecast-----sensorMap:"+sensorMap); units.add(sensorMap.get("unit").toString()); } values.add((Number) map.remove(string)); @@ -1008,28 +1020,6 @@ map.put("values", values); map.put("units", units); } - - - /* - if(sensorMap!=null && !sensorMap.isEmpty()) { - for (Map<String, Object> map : list) { - System.out.println("ScreenController-----AIForecast-----map:"+map); - String time = map.get("time").toString(); - time = time.substring(time.length() - 2); - map.put("time", Integer.valueOf(time)); - map.put("value", map.remove(sensorKey)); - System.out.println("ScreenController-----AIForecast-----map:"+map); - System.out.println(sensorMap.get("unit")); - //String sensor = map.get("sensorKey").toString(); - if(sensorMap.get(sensorKey)!=null) { - map.put("unit", sensorMap.get(sensorKey).get("name")); - }else { - map.put("unit", "mg/m��"); - } - } - }*/ - //return null; - System.out.println("ScreenController-----AIForecast-----list:"+list); return new ResultBean<List<Map<String, Object>>>(list); } -- Gitblit v1.8.0