From 2cf0253cf25e8e74958075eb3d1a1b8eac70356d Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Mon, 09 Aug 2021 08:50:19 +0800 Subject: [PATCH] 去除员工管理菜单。角色分配唯一 --- screen-manage/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java | 6 +++--- 1 files changed, 3 insertions(+), 3 deletions(-) diff --git a/screen-manage/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java b/screen-manage/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java index adc3c81..55f3f67 100644 --- a/screen-manage/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java +++ b/screen-manage/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java @@ -62,7 +62,7 @@ String key = next.getKey(); Object value = next.getValue(); if (key.contains("-Avg")) { - newMap.put(key.replaceAll("-Avg", ""), value); + newMap.put(key.replaceAll("-Avg", ""), Double.parseDouble(value.toString())); } else { newMap.put(key, value); } @@ -102,7 +102,7 @@ String key = next.getKey(); Object value = next.getValue(); if (key.contains("-Avg")) { - newMap.put(key.replaceAll("-Avg", ""), value); + newMap.put(key.replaceAll("-Avg", ""), Double.parseDouble(value.toString())); } else { newMap.put(key, value); } @@ -133,7 +133,7 @@ //������������ data = deviceService.adjustDeviceData(data); //������redis - redisTemplate.opsForValue().set(RedisConstants.DEVICE_DATA + mac, data); + redisTemplate.opsForHash().put(RedisConstants.DATA_SECOND, mac, data); //��������������������������� deviceService.judgeDeviceState(data); ack.acknowledge(); -- Gitblit v1.8.0