From 42f9c8cf31cc8a694c6478b12c832c1991bf35b7 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Mon, 21 Aug 2023 15:58:10 +0800
Subject: [PATCH] chore:测试提交
---
screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java | 10 ++++-
screen-manage/src/main/java/com/moral/api/util/AdjustDataUtils.java | 68 +++++++++++++++++++--------------
screen-manage/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java | 13 +++---
screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java | 16 +++++++
4 files changed, 68 insertions(+), 39 deletions(-)
diff --git a/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java
index d77376b..0a1b3c9 100644
--- a/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java
+++ b/screen-api/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java
@@ -349,8 +349,14 @@
Map<String,Object> historyHourlyMap = new HashMap<>();
historyHourlyMap.put("mac",mac);
JSONObject value = JSONObject.parseObject(historyFiveMinutely.getValue());
- Double sensorValue = Double.parseDouble(value.get(sensorCode).toString());
- historyHourlyMap.put(sensorCode,sensorValue);
+ if (value.get(sensorCode)==null){
+ historyHourlyMap.put(sensorCode,0.0);
+ }else {
+ Double sensorValue = Double.parseDouble(value.get(sensorCode).toString());
+ historyHourlyMap.put(sensorCode,sensorValue);
+ }
+// Double sensorValue = Double.parseDouble(value.get(sensorCode).toString());
+// historyHourlyMap.put(sensorCode,sensorValue);
Date time = historyFiveMinutely.getTime();
String timeStr = DateUtils.dateToDateString(time, DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
historyHourlyMap.put("time",timeStr);
diff --git a/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java b/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java
index c21f1fb..30041ec 100644
--- a/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java
+++ b/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java
@@ -10,6 +10,9 @@
import org.springframework.stereotype.Component;
import org.springframework.util.ObjectUtils;
+import java.text.DecimalFormat;
+import java.text.SimpleDateFormat;
+import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
@@ -96,8 +99,19 @@
}
//������������
-// data.remove("time");
+ data.remove("time");
data.remove("entryTime");
+ SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ String format = dateFormat.format(new Date().getTime());
+ //������������
+ String substring = format.substring(0, 4);
+
+ String substring1 = time.toString().substring(0, 4);
+
+ String replace = time.toString().replace(substring1, substring);
+
+ data.put("DataTime",replace);
+
Iterator<Map.Entry<String, Object>> iterator = data.entrySet().iterator();
Map<String, Object> newMap = new HashMap<>();
Map.Entry<String, Object> next;
diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java
index 71646df..5bc892c 100644
--- a/screen-manage/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java
+++ b/screen-manage/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java
@@ -51,14 +51,13 @@
Map<String, Object> versionInfo = (Map<String, Object>) deviceInfo.get("version");
Integer version = (Integer) versionInfo.get("id");
//���������������
- String time1 = data.get("time").toString();
- long l = Long.parseLong(time1);
- SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:00:00");
- String format1 = dateFormat.format(l);
- Date time = DateUtils.getDate(format1, DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
+// String time1 = data.get("time").toString();
+// long l = Long.parseLong(time1);
+// SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:00:00");
+// String format1 = dateFormat.format(l);
+// Date time = DateUtils.getDate(format1, DateUtils.yyyy_MM_dd_HH_mm_ss_EN);
-
-// Date time = DateUtils.getDate((String) data.remove("DataTime"), DateUtils.yyyyMMddHHmmss_EN);
+ Date time = DateUtils.getDate((String) data.remove("DataTime"), DateUtils.yyyyMMddHHmmss_EN);
String yearAndMonth = DateUtils.dateToDateString(DateUtils.addHours(time, -1), DateUtils.yyyyMM_EN);
result.put("mac", mac);
diff --git a/screen-manage/src/main/java/com/moral/api/util/AdjustDataUtils.java b/screen-manage/src/main/java/com/moral/api/util/AdjustDataUtils.java
index eda029a..8d59d01 100644
--- a/screen-manage/src/main/java/com/moral/api/util/AdjustDataUtils.java
+++ b/screen-manage/src/main/java/com/moral/api/util/AdjustDataUtils.java
@@ -126,35 +126,45 @@
if (ObjectUtils.isEmpty(map)){
return deviceData;
}
- if (ObjectUtils.isEmpty(aqiMap.get("a21005"))){
- JSONObject jsonObject = JSONObject.parseObject(map.get("value").toString());
- String a21005 = jsonObject.get("a21005").toString();
- deviceData.put("a21005",Double.parseDouble(a21005));
- }
- if (ObjectUtils.isEmpty(aqiMap.get("a21026"))){
- JSONObject jsonObject = JSONObject.parseObject(map.get("value").toString());
- String a21026 = jsonObject.get("a21026").toString();
- deviceData.put("a21026",Double.parseDouble(a21026));
- }
- if (ObjectUtils.isEmpty(aqiMap.get("a21004"))){
- JSONObject jsonObject = JSONObject.parseObject(map.get("value").toString());
- String a21004 = jsonObject.get("a21004").toString();
- deviceData.put("a21004",Double.parseDouble(a21004));
- }
- if (ObjectUtils.isEmpty(aqiMap.get("a34002"))){
- JSONObject jsonObject = JSONObject.parseObject(map.get("value").toString());
- String a34002 = jsonObject.get("a34002").toString();
- deviceData.put("a34002",Double.parseDouble(a34002));
- }
- if (ObjectUtils.isEmpty(aqiMap.get("a34004"))){
- JSONObject jsonObject = JSONObject.parseObject(map.get("value").toString());
- String a34004 = jsonObject.get("a34004").toString();
- deviceData.put("a34004",Double.parseDouble(a34004));
- }
- if (ObjectUtils.isEmpty(aqiMap.get("a05024"))){
- JSONObject jsonObject = JSONObject.parseObject(map.get("value").toString());
- String a05024 = jsonObject.get("a05024").toString();
- deviceData.put("a05024",Double.parseDouble(a05024));
+ JSONObject jsonObject = JSONObject.parseObject(map.get("value").toString());
+ if (ObjectUtils.isEmpty(aqiMap)){
+ deviceData.put("a21005",Double.parseDouble(jsonObject.get("a21005").toString()));
+ deviceData.put("a21026",Double.parseDouble(jsonObject.get("a21026").toString()));
+ deviceData.put("a21004",Double.parseDouble(jsonObject.get("a21004").toString()));
+ deviceData.put("a34002",Double.parseDouble(jsonObject.get("a34002").toString()));
+ deviceData.put("a34004",Double.parseDouble(jsonObject.get("a34004").toString()));
+ deviceData.put("a05024",Double.parseDouble(jsonObject.get("a05024").toString()));
+ }else {
+ if (ObjectUtils.isEmpty(aqiMap.get("a21005"))){
+
+ String a21005 = jsonObject.get("a21005").toString();
+ deviceData.put("a21005",Double.parseDouble(a21005));
+ }
+ if (ObjectUtils.isEmpty(aqiMap.get("a21026"))){
+// JSONObject jsonObject = JSONObject.parseObject(map.get("value").toString());
+ String a21026 = jsonObject.get("a21026").toString();
+ deviceData.put("a21026",Double.parseDouble(a21026));
+ }
+ if (ObjectUtils.isEmpty(aqiMap.get("a21004"))){
+// JSONObject jsonObject = JSONObject.parseObject(map.get("value").toString());
+ String a21004 = jsonObject.get("a21004").toString();
+ deviceData.put("a21004",Double.parseDouble(a21004));
+ }
+ if (ObjectUtils.isEmpty(aqiMap.get("a34002"))){
+// JSONObject jsonObject = JSONObject.parseObject(map.get("value").toString());
+ String a34002 = jsonObject.get("a34002").toString();
+ deviceData.put("a34002",Double.parseDouble(a34002));
+ }
+ if (ObjectUtils.isEmpty(aqiMap.get("a34004"))){
+// JSONObject jsonObject = JSONObject.parseObject(map.get("value").toString());
+ String a34004 = jsonObject.get("a34004").toString();
+ deviceData.put("a34004",Double.parseDouble(a34004));
+ }
+ if (ObjectUtils.isEmpty(aqiMap.get("a05024"))){
+// JSONObject jsonObject = JSONObject.parseObject(map.get("value").toString());
+ String a05024 = jsonObject.get("a05024").toString();
+ deviceData.put("a05024",Double.parseDouble(a05024));
+ }
}
}
--
Gitblit v1.8.0