From 8e41bd549e3bf0dab2f713ad1c967c4e673c0e5a Mon Sep 17 00:00:00 2001
From: chen_xi <276999030@qq.com>
Date: Thu, 17 Nov 2022 09:27:15 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev
---
screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java | 9 +--------
1 files changed, 1 insertions(+), 8 deletions(-)
diff --git a/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java b/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
index 2544cad..0ae5b3f 100644
--- a/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
+++ b/screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java
@@ -37,7 +37,6 @@
public void listen(ConsumerRecord<String, String> record, Consumer consumer) throws Exception {
String messageStr = record.value();
Map<String, Object> message = (Map<String, Object>) JSON.parse(messageStr);
- //long serverStartTime = System.currentTimeMillis();
CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets;
for (SingleDeviceServer socket : sockets) {
//���������������������������socket
@@ -50,7 +49,7 @@
Map<String, Object> adjustFormula = socket.getAdjustFormula();
Map<String, Object> regionAqi = socket.getRegionAqi();
//������������
- if(adjustFormula!=null&®ionAqi!=null)
+ if(adjustFormula!=null)
message = AdjustDataUtils.adjust(message,adjustFormula,regionAqi);
//������������������������
Map<String, Object> resultMessgae = new HashMap<>();
@@ -95,12 +94,6 @@
resultMessgae.put(sensor.getCode(), sourceData);
}
}
- //���������������������������������
- //resultMessgae.put("DataTime", message.get("DataTime"));
- //resultMessgae.put("time", message.get("time"));
- //resultMessgae.put("time1", message.get("time1"));
- //resultMessgae.put("serverTime", System.currentTimeMillis());
- //resultMessgae.put("serverStartTime", serverStartTime);
socket.sendMessage(JSON.toJSONString(resultMessgae));
}
}
--
Gitblit v1.8.0