From 4b4c4114db773d2a5c3d2bcd9c15f43f7b4ff062 Mon Sep 17 00:00:00 2001 From: lizijie <lzjiiie@163.com> Date: Fri, 08 Oct 2021 16:13:53 +0800 Subject: [PATCH] 判断时间,修改臭氧8小时滑动平均值 --- screen-api/src/main/java/com/moral/api/kafka/consumer/SecondDataConsumer.java | 1 - 1 files changed, 0 insertions(+), 1 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 feee1cb..8a11984 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 @@ -39,7 +39,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); - log.info(message.toString()); //long serverStartTime = System.currentTimeMillis(); CopyOnWriteArraySet<SingleDeviceServer> sockets = SingleDeviceServer.sockets; for (SingleDeviceServer socket : sockets) { -- Gitblit v1.8.0