From ed28f15efe490b59126545de188a325ddb06af39 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Fri, 06 Nov 2020 13:39:25 +0800
Subject: [PATCH] 大屏设备数据导出excel接口更新

---
 src/main/java/com/moral/controller/ScreenController.java |   65 +++++++++++++++++++++++++++++---
 1 files changed, 58 insertions(+), 7 deletions(-)

diff --git a/src/main/java/com/moral/controller/ScreenController.java b/src/main/java/com/moral/controller/ScreenController.java
index 1b6ff2b..60502d8 100644
--- a/src/main/java/com/moral/controller/ScreenController.java
+++ b/src/main/java/com/moral/controller/ScreenController.java
@@ -2,6 +2,7 @@
 
 import java.io.*;
 import java.lang.reflect.Array;
+import java.net.URLEncoder;
 import java.text.DateFormat;
 import java.text.DecimalFormat;
 import java.text.ParseException;
@@ -40,6 +41,7 @@
 
 import com.rabbitmq.client.*;
 import com.rabbitmq.client.Channel;
+
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
@@ -47,6 +49,7 @@
 import io.swagger.models.auth.In;
 import jdk.nashorn.internal.runtime.regexp.joni.Regex;
 import net.sf.json.JSONString;
+
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.collections.MapUtils;
 import org.apache.commons.net.ftp.FTPClient;
@@ -71,6 +74,7 @@
 import org.springframework.web.bind.annotation.RestController;
 import org.springframework.web.servlet.ModelAndView;
 import org.xml.sax.InputSource;
+
 import static com.moral.common.util.ResourceUtil.getValue;
 import static com.moral.common.util.WebUtils.getParametersStartingWith;
 import static java.util.Calendar.*;
@@ -166,6 +170,9 @@
 
     @Resource
     private ScreenVersionService screenVersionService;
+
+    @Resource
+    private DeviceAdjustValueTimingService deviceAdjustValueTimingService;
 
     /**
      * Screen login. ������������
@@ -2023,7 +2030,7 @@
         Calendar calendar = Calendar.getInstance();
         calendar.set(Calendar.MINUTE, (calendar.get(Calendar.MINUTE) - 2));
         SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm");
-        String time = df.format(calendar.getTime()) + ":00";
+        //String time = df.format(calendar.getTime()) + ":00";
         int year = calendar.get(Calendar.YEAR);
         int month = calendar.get(Calendar.MONTH) + 1;
         String mon;
@@ -2033,7 +2040,7 @@
             mon = "" + month;
         }
         String table = "history_minutely_" + year + mon;
-        List list = deviceService.byMonitorIdGetDeviceAndWind(monitorPointId, time, table);
+        List list = deviceService.byMonitorIdGetDeviceAndWind(monitorPointId, table);
         return list;
     }
 
@@ -2054,7 +2061,7 @@
             mon = "" + month;
         }
         String table = "history_minutely_" + year + mon;
-        List list = deviceService.byMonitorIdGetDeviceAndWindSpecial(monitorPointId, time, table);
+        List list = deviceService.byMonitorIdGetDeviceAndWindSpecial(monitorPointId, table);
         return list;
     }
 
@@ -2178,7 +2185,7 @@
                     for (Map<String, Object> dataMap : dataList) {
                         JSONObject dataJson = JSONObject.parseObject(dataMap.get("json").toString());
                         if (dataMap.get("time").toString().equals(day + " 00:00:00.0")) {
-                            oneSensorMap.put(dataMap.get("time").toString().substring(0, 10), dataJson.getJSONArray(key).get(2));
+                            oneSensorMap.put(dataMap.get("time").toString().substring(0, 10), dataJson.getJSONArray(key).get(0));
                             break;
                         } else {
                             continue;
@@ -2194,7 +2201,7 @@
                     for (Map sameDayHourlyMap : sameDayHourlyList) {
                         List<Double> arr = new ArrayList<>();
                         JSONObject hourlyJson = JSONObject.parseObject(sameDayHourlyMap.get("json").toString());
-                        arr.add(Double.parseDouble(hourlyJson.getJSONArray(key).get(2).toString()));
+                        arr.add(Double.parseDouble(hourlyJson.getJSONArray(key).get(0).toString()));
                         Double sum = 0.0;
                         for (int i = 0; i < arr.size(); i++) {
                             sum += arr.get(i);
@@ -2230,8 +2237,10 @@
                     for (Map<String, Object> hourlyMap : hourlyList) {
                         JSONObject dataJson = JSONObject.parseObject(hourlyMap.get("json").toString());
                         if (hourlyMap.get("time").toString().equals(hour + ".0")) {
-                            oneSensorMap.put(hourlyMap.get("time").toString().substring(0, 19), dataJson.getJSONArray(key).get(2));
-                            break;
+                            if (dataJson.getJSONArray(key) != null) {
+                                oneSensorMap.put(hourlyMap.get("time").toString().substring(0, 19), dataJson.getJSONArray(key).get(0));
+                                break;
+                            }
                         } else {
                             continue;
                         }
@@ -2550,4 +2559,46 @@
         List<Map<String, Object>> list = historyMinutelyService.getAllDeviceDataToExcel(parameters);
         return new ResultBean<List<Map<String, Object>>>(list);
     }
+
+    /*@PostMapping("insertAdjustValue")
+    @ApiOperation(value = "���������������������������������", notes = "���������������������������������")
+    @ApiImplicitParams(value = {
+            @ApiImplicitParam(name = "id", value = "������id", required = true, paramType = "query", dataType = "String"),
+            @ApiImplicitParam(name = "time", value = "���������������08:30:00���", required = true, paramType = "query", dataType = "String"),
+            @ApiImplicitParam(name = "dataArray", value = "������", required = false, paramType = "query", dataType = "String")})
+    public void insertAdjustValue(HttpServletRequest request) throws Exception {
+        Map<String, Object> parameters = WebUtils.getParametersStartingWith(request, null);
+        int device_id = Integer.parseInt(parameters.get("id").toString());
+        String hour_minute_second = parameters.get("time").toString();
+        String[] arr = hour_minute_second.split(":");
+        int seconds = Integer.parseInt(arr[0])*3600+Integer.parseInt(arr[1])*60+Integer.parseInt(arr[2]);
+        String value = parameters.get("dataArray").toString();
+        deviceAdjustValueTimingService.insertData(device_id,seconds,value);;
+    }*/
+
+    @PostMapping("insertAdjustValue")
+    public  int insertAdjustValue(@RequestBody HashMap map){
+        try{
+            int device_id = Integer.parseInt(map.get("id").toString());
+            String time = map.get("time").toString();
+            String[] arr = time.split(":");
+            int seconds = Integer.parseInt(arr[0])*3600+Integer.parseInt(arr[1])*60+Integer.parseInt(arr[2]);
+            //String t = URLEncoder.encode(������,"UTF-8")
+            List list = (List) map.get("dataArray");
+            String val="";
+            for (int i = 0; i <list.size() ; i++) {
+                if (i==0){
+                    val=val+list.get(i);
+                }else {
+                    val=val+","+list.get(i);
+                }
+            }
+            String value = "{"+val+"}";
+            deviceAdjustValueTimingService.insertData(device_id,seconds,value);
+            return 1;
+        }catch (Exception e){
+            log.warn(e);
+        }
+        return 0;
+    }
 }
\ No newline at end of file

--
Gitblit v1.8.0