From 11bb93e34b91a8ba4c5588dbe907988a1f279859 Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Tue, 15 Dec 2020 14:06:00 +0800
Subject: [PATCH] 增加新的websocket版本
---
src/main/java/com/moral/service/impl/HistoryServiceImpl.java | 23 +++++++++++------------
1 files changed, 11 insertions(+), 12 deletions(-)
diff --git a/src/main/java/com/moral/service/impl/HistoryServiceImpl.java b/src/main/java/com/moral/service/impl/HistoryServiceImpl.java
index 3f5d6d6..08137c7 100644
--- a/src/main/java/com/moral/service/impl/HistoryServiceImpl.java
+++ b/src/main/java/com/moral/service/impl/HistoryServiceImpl.java
@@ -74,12 +74,10 @@
Map<String, Object> resultMap = new LinkedHashMap<String, Object>();
accountService.setOrgIdsByAccount(parameters);
LocalDateTime time = LocalDateTime.now();
- // ������������ -10������
- LocalDateTime start = time.minusMinutes(10);
- parameters.put("start", start);
+ parameters.put("end", time);
// ������������ -5������
- LocalDateTime end = time.minusMinutes(5);
- parameters.put("end", end);
+ LocalDateTime start = time.minusMinutes(5);
+ parameters.put("start", start);
List<Sensor> Sensors = sensorMapper.getSensorsByCriteria(parameters);
List<String> sensorKeys = new ArrayList<String>();
for (Sensor sensor : Sensors) {
@@ -87,7 +85,7 @@
}
parameters.put("sensorKeys", sensorKeys);
DateTimeFormatter df = DateTimeFormatter.ofPattern("yyyyMM");
- parameters.put("timeUnits", "minutely_" + df.format(start));
+ parameters.put("timeUnits", "five_minutely_" + df.format(time));
List<Map<String, Object>> list = historyMapper.getAreaAllDataByAccount(parameters);
resultMap.putAll(list.get(0));
return resultMap;
@@ -111,7 +109,6 @@
parameters.put("sensorKeys", sensorKeys);
parameters.put("timeUnits", "hourly");
List<Map<String, Object>> list = historyMapper.getAreaAllDataByAccount(parameters);
-
for (Map<String, Object> map : list) {
result.put((String) map.get("name"), map.get(macKey.toString()));
}
@@ -386,7 +383,6 @@
resultMap.put(map.remove("sensor_key").toString(), map);
}
return resultMap;
-
}
@Override
@@ -410,14 +406,17 @@
String timeUnits = startTime.substring(0, 10).replace("-", "");
Map<String, Object> map = historyMapper.getAVGValueByMacAndTimeslot(mac, startTime, endTime, timeUnits);
Map<String, Object> returnMap = new HashMap<>();
- if (map.isEmpty()) {
- returnMap.put("AQI", "N/V");
+ if (ObjectUtils.isEmpty(map) || map.isEmpty()) {
+ returnMap.put("AQI", "N/V");
+ return returnMap;
} else {
Map<String, Double> AQIMap = new HashMap<>();
for (Map.Entry<String, Object> entry : map.entrySet()) {
String key = entry.getKey();
- Double value = Double.parseDouble(entry.getValue().toString());
- AQIMap.put(key, value);
+ if (entry.getValue() != null) {
+ Double value = Double.parseDouble(entry.getValue().toString());
+ AQIMap.put(key, value);
+ }
}
returnMap = AQICalculation.hourlyAQI(AQIMap);
}
--
Gitblit v1.8.0