From 94171b34a3f10caca03968a436567e0424fa54b5 Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Mon, 19 Oct 2020 14:59:29 +0800
Subject: [PATCH] 获取六参平均值接口返回数据添加经纬度和state

---
 src/main/java/com/moral/controller/WebController.java |  152 +++++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 147 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/moral/controller/WebController.java b/src/main/java/com/moral/controller/WebController.java
index 0f63f51..60faef1 100644
--- a/src/main/java/com/moral/controller/WebController.java
+++ b/src/main/java/com/moral/controller/WebController.java
@@ -10,20 +10,20 @@
 import com.moral.entity.MonitorPoint;
 import com.moral.entity.Organization;
 import com.moral.service.*;
+import com.moral.util.DateUtil;
 import com.moral.util.LatLngTransformation;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
 import jdk.nashorn.internal.runtime.logging.Logger;
+import org.springframework.util.ObjectUtils;
 import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
-import java.util.Arrays;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.text.SimpleDateFormat;
+import java.util.*;
 import java.util.stream.Collectors;
 
 import static com.moral.common.util.WebUtils.getParametersStartingWith;
@@ -49,12 +49,20 @@
     @Resource
     DeviceService deviceService;
 
+
     @UserLoginToken
     @GetMapping("test")
     public String add() {
         return "test success!";
     }
 
+    /** 
+    * @Description: ������������
+            * @Param: [parameters]
+            * @return: java.util.Map<java.lang.String,java.lang.Object>
+            * @Author: ������������
+            * @Date: 2020/10/19
+            */ 
     @PostMapping("login")
     public Map<String, Object> login(@RequestBody Map<String, Object> parameters) {
         Map<String, Object> resultMap = new HashMap<String, Object>();
@@ -72,6 +80,13 @@
         return resultMap;
     }
 
+    /** 
+    * @Description: ������������
+            * @Param: [request]
+            * @return: java.util.Map<java.lang.String,java.lang.Object>
+            * @Author: ������������
+            * @Date: 2020/10/19
+            */ 
     @UserLoginToken
     @PostMapping("logout")
     public Map<String, Object> logout(HttpServletRequest request) {
@@ -83,6 +98,13 @@
         return resultMap;
     }
 
+    /** 
+    * @Description: 
+            * @Param: [request]
+            * @return: java.util.Map<java.lang.String,java.lang.Object>
+            * @Author: ������������
+            * @Date: 2020/10/19
+            */ 
     @UserLoginToken
     @GetMapping("getAccountInfo")
     public Map<String, Object> getAccountInfo(HttpServletRequest request) {
@@ -140,6 +162,13 @@
     }
 
 
+    /** 
+    * @Description: ������������������������
+            * @Param: [request]
+            * @return: com.moral.common.bean.ResultBean<java.util.List<java.util.Map<java.lang.String,java.lang.Object>>>
+            * @Author: ������������
+            * @Date: 2020/10/19
+            */ 
     @UserLoginToken
     @GetMapping("report_avg_datas")
     public ResultBean<List<Map<String, Object>>> getMonitorPointOrDeviceAvgData(HttpServletRequest request)
@@ -162,6 +191,13 @@
         return new ResultBean<List<Map<String, Object>>>(list);
     }
 
+    /**
+    * @Description: ������������������������������
+            * @Param: [request]
+            * @return: com.moral.common.bean.ResultBean<java.util.List<com.moral.entity.MonitorPoint>>
+            * @Author: ������������
+            * @Date: 2020/10/19
+            */
     @UserLoginToken
     @GetMapping("monitorpoints-devices")
     public ResultBean<List<MonitorPoint>> getMonitorPointsAndDevicesByRegion(HttpServletRequest request)
@@ -171,11 +207,117 @@
         return new ResultBean<List<MonitorPoint>>(monitorPoints);
     }
 
-    @UserLoginToken
+    /**
+    * @Description: ���������������������������������������
+            * @Param: [request]
+            * @return: com.moral.common.bean.ResultBean<java.util.List<com.moral.entity.Device>>
+            * @Author: ������������
+            * @Date: 2020/10/19
+            */
+   /* @UserLoginToken*/
     @GetMapping("coordinates")
     public ResultBean<List<Device>> getDeviceCoordinatesAndState(HttpServletRequest request){
         Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);
         ParameterUtils.getRegionType4RegionCode(parameters);
         return new ResultBean<List<Device>>(deviceService.queryDevice(parameters));
     }
+
+    /**
+    * @Description: ������monitorId���������������������������������������������������������������������
+            * @Param: []
+            * @return: com.moral.common.bean.ResultBean<java.util.Map<java.lang.String,java.lang.Object>>
+            * @Author: ������������
+            * @Date: 2020/10/19
+            */
+
+    @GetMapping("fiveMinuteAvgData")
+    public ResultBean<List<Map<String, Object>>> getSensorFiveMinuteAvgData(HttpServletRequest request){
+        //���������������������������monitorpointId
+        Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);
+        if((!parameters.containsKey("sensorKey"))||(!parameters.containsKey("monitorPointId")))
+            return  ResultBean.fail("���������null");
+        String sensorKey = (String) parameters.get("sensorKey");
+        Integer monitorPointId = Integer.parseInt((String) parameters.get("monitorPointId"));
+
+        //������monitorpointId������������������������������mac������
+        List<Device> devices = deviceService.getDevicesByMonitorPointId(monitorPointId);
+        if(ObjectUtils.isEmpty(devices))
+            return ResultBean.fail("���������������������monitorPointId������");
+        List<String> macs = new ArrayList<>();
+        devices.forEach(p->{
+            macs.add(p.getMac());
+        });
+
+        //���������������mac���������������������������������������������������������
+        Map<String, Object> timeAndYearMonth = getTimeAndYearMonthForFiveMinuteData();
+        String time= (String) timeAndYearMonth.get("time");
+        String yearAndMonth = (String) timeAndYearMonth.get("yearAndMonth");
+        parameters.put("time",time);
+        parameters.put("yearAndMonth",yearAndMonth);
+        parameters.put("macs",macs);
+        List<Map<String, Object>> datas = historyMinutelyService.getFiveMinutesDataByMacsAndTime(parameters);
+        datas = insertDeviceInfo(datas,devices);
+        return new ResultBean<List<Map<String, Object>>>(datas);
+
+    }
+
+    /**
+    * @Description: ���������������������������������������state
+            * @Param: [datas, devices]
+            * @return: java.util.List<java.util.Map<java.lang.String,java.lang.Object>>
+            * @Author: ������������
+            * @Date: 2020/10/19
+            */
+    public List<Map<String, Object>> insertDeviceInfo(List<Map<String, Object>> datas,List<Device> devices ){
+        Map<String,Device> map = new HashMap<>();
+        devices.forEach(p->{
+            map.put(p.getMac(),p);
+        });
+
+        datas.forEach(p->{
+            String mac = (String) p.get("mac");
+            Device device = map.get(mac);
+            p.put("longitude",device.getLongitude());
+            p.put("latitude",device.getLatitude());
+            p.put("state",device.getState());
+        });
+        return datas;
+    }
+
+    /**
+    * @Description: ������������������������������������������������������������������������������
+            * @Param: []
+            * @return: java.lang.String
+            * @Author: ������������
+            * @Date: 2020/10/19
+            */
+    private Map<String, Object> getTimeAndYearMonthForFiveMinuteData() {
+        Map<String, Object> map = new HashMap<>();
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        Date date = new Date();
+        String minute = DateUtil.getMinute(date);
+        String year = "";
+        String month = "";
+        String yearAndMonth = "";
+        String startTime = "";
+        Integer endMinute = Integer.parseInt(String.valueOf(minute.charAt(minute.length() - 1)));
+        if (endMinute >= 5) {
+            StringBuilder time = new StringBuilder(sdf.format(date));
+            startTime = time.replace(15, 19, "0:00").toString();
+        } else {
+            date = DateUtil.rollMinute(date, -5);
+            StringBuilder time = new StringBuilder(sdf.format(date));
+            startTime = time.replace(15, 19, "5:00").toString();
+        }
+
+        year = DateUtil.getYear(date);
+        month = DateUtil.getMonth(date);
+        yearAndMonth = year + month;
+        map.put("time", startTime);
+        map.put("yearAndMonth", yearAndMonth);
+        return map;
+    }
+
+
+
 }

--
Gitblit v1.8.0