From 1830f5429730a40f7d2f17ca748a80a4b1046c21 Mon Sep 17 00:00:00 2001 From: xufenglei <xufenglei> Date: Mon, 25 Mar 2019 09:12:22 +0800 Subject: [PATCH] update --- src/main/java/com/moral/controller/ScreenController.java | 147 +++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 131 insertions(+), 16 deletions(-) diff --git a/src/main/java/com/moral/controller/ScreenController.java b/src/main/java/com/moral/controller/ScreenController.java index 4be11b4..32d638a 100644 --- a/src/main/java/com/moral/controller/ScreenController.java +++ b/src/main/java/com/moral/controller/ScreenController.java @@ -3,24 +3,24 @@ import static com.moral.common.util.ResourceUtil.getValue; import static com.moral.common.util.WebUtils.getParametersStartingWith; -import java.io.*; -import java.util.*; +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 com.alibaba.fastjson.*; -import com.moral.common.util.BeanUtils; -import com.moral.common.util.ParameterUtils; -import com.moral.common.util.StringUtils; -import com.moral.entity.*; -import com.moral.entity.alarm.AlarmConfig; -import com.moral.entity.alarm.AlarmConfigValue; -import com.moral.entity.charts.DataSortCondition; -import com.moral.entity.layout.RealTimeDeviceLayout; -import com.moral.service.*; import org.apache.commons.collections.CollectionUtils; -import org.apache.commons.lang.math.NumberUtils; import org.apache.commons.net.ftp.FTPClient; import org.apache.log4j.Logger; import org.dom4j.Document; @@ -31,17 +31,61 @@ 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.*; +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; import com.moral.common.bean.Constants; import com.moral.common.bean.JsonData; import com.moral.common.bean.PageResult; import com.moral.common.bean.ResultBean; +import com.moral.common.util.BeanUtils; +import com.moral.common.util.ParameterUtils; 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.Region; +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.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.WeatherService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiImplicitParam; @@ -468,11 +512,13 @@ } @RequestMapping(value="/get-monitorpoints",method = RequestMethod.GET) @ResponseBody - public ResultBean getMonitorpointList(@RequestParam("orgId")String orgId,MapBounds mapBounds){ + public ResultBean getMonitorpointList(@RequestParam("orgId")String orgId,MapBounds mapBounds,@RequestParam("regionCode")String regionCode){ ResultBean<List<MonitorPoint>> resultBean = new ResultBean(); Map<String,Object> paramMap = new HashMap<String, Object>(); paramMap.put("orgId", orgId); paramMap.put("mapBounds",mapBounds); + paramMap.put("regionCode",regionCode); + ParameterUtils.getRegionType4RegionCode(paramMap); List<MonitorPoint> list = monitorPointService.queryWithStateByMap(paramMap); resultBean.setData(list); resultBean.setCode(ResultBean.SUCCESS); @@ -480,11 +526,13 @@ } @RequestMapping(value="/get-devices",method = RequestMethod.GET) @ResponseBody - public ResultBean getDevices(@RequestParam("orgId")Integer orgId,MapBounds mapBounds){ + public ResultBean getDevices(@RequestParam("orgId")Integer orgId,MapBounds mapBounds,@RequestParam("regionCode")String regionCode){ ResultBean<List<Device>> resultBean = new ResultBean(); Map<String,Object> paramMap = new HashMap<String, Object>(); paramMap.put("orgId", orgId); paramMap.put("mapBounds",mapBounds); + paramMap.put("regionCode",regionCode); + ParameterUtils.getRegionType4RegionCode(paramMap); List<Device> list = deviceService.query(paramMap); resultBean.setData(list); resultBean.setCode(ResultBean.SUCCESS); @@ -773,4 +821,71 @@ return new ResultBean<List<MonitorPoint>>(monitorPoints); } + + @GetMapping("devices-state") + @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") + }) + public ResultBean<Collection<Object>> getDevicesStateByRegion(HttpServletRequest request) throws Exception { + Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); + Collection<Object> monitorPoints= monitorPointService.getDevicesStateByRegion(parameters); + return new ResultBean<Collection<Object>>(monitorPoints); + } + + @Resource + private HistoryDailyService historyDailyService; + + @GetMapping("emissions") + @ApiOperation(value = "���������", notes = "���������") + @ApiImplicitParams(value = { + @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") + }) + 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); + return new ResultBean<List<Map<String, Object>>>(result); + } + + + @GetMapping("overproof") + @ApiOperation(value = "������������", notes = "������������") + @ApiImplicitParams(value = { + @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 = "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") + }) + public ResultBean<Map> getOverproofData(HttpServletRequest request) throws Exception { + Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null); + Map result = historyDailyService.getOverproofData(parameters); + return new ResultBean<Map>(result); + } + + @GetMapping("limit-device") + @ApiOperation(value = "���������������������������", notes = "���������������������������") + @ApiImplicitParams(value = { + @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); + JSONObject parseObject = JSONObject.parseObject(density); + List<Map<String, Object>> resuList = new ArrayList<Map<String,Object>>(); + for (Map.Entry entry : parseObject.entrySet()) { + resuList.add(new HashMap<String, Object>() { + { + put("key",entry.getKey()); + put("limit", entry.getValue()); + } + }); + } + return new ResultBean<List<Map<String, Object>>>(resuList); + } + } -- Gitblit v1.8.0