From a7b1117ea24c4ffd783c52a0685961eff95f049f Mon Sep 17 00:00:00 2001
From: lizijie <lzjiiie@163.com>
Date: Thu, 17 Dec 2020 15:49:48 +0800
Subject: [PATCH] UV风向工具类修改，根据时间段获取五分钟数据
---
src/main/java/com/moral/webSocketServer/BSAQIWebSocketServerTest.java | 11 +++++++++--
1 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/moral/webSocketServer/BSAQIWebSocketServerTest.java b/src/main/java/com/moral/webSocketServer/BSAQIWebSocketServerTest.java
index ac6ada1..2341912 100644
--- a/src/main/java/com/moral/webSocketServer/BSAQIWebSocketServerTest.java
+++ b/src/main/java/com/moral/webSocketServer/BSAQIWebSocketServerTest.java
@@ -9,6 +9,7 @@
import com.rabbitmq.client.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
+import org.springframework.util.ObjectUtils;
import javax.annotation.PostConstruct;
import javax.websocket.*;
@@ -155,8 +156,14 @@
//���������������������������������
sortMap.put("name", device.getName());
sortMap.put("address", device.getAddress());
- //���������������������������������
- sortMap.putAll(param);
+ //������������
+ param.forEach((key, value) -> {
+ Sensor sensor = sensors.get(key);
+ if (!ObjectUtils.isEmpty(sensor)) {
+ String unit = ObjectUtils.isEmpty(sensor.getUnit()) ? "" : (String) sensor.getUnit();
+ sortMap.put(sensor.getSensorKey(), value + unit);
+ }
+ });
sendMessage(JSON.toJSONString(sortMap));
} catch (IOException e) {
log.error("������mac������������������������");
--
Gitblit v1.8.0