From 1a406e3e206af1ab7e38042548a085b078b6ca09 Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Tue, 15 Dec 2020 14:34:26 +0800
Subject: [PATCH] 增加websocket单位
---
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