From ea66c01f85340a5ed65d5dd74607e5cfcdbec03d Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Wed, 14 Dec 2022 10:01:33 +0800 Subject: [PATCH] 修改sql语句问题3 --- screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java | 4 ++-- 1 files changed, 2 insertions(+), 2 deletions(-) diff --git a/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java b/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java index e4ecbac..a00b64c 100644 --- a/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java +++ b/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java @@ -138,7 +138,7 @@ data.remove("entryTime"); //������������ - data = deviceService.adjustDeviceData(data); + data = deviceService.adjustDeviceData(data,"0"); //������redis data.put("DataTime", time); redisTemplate.opsForHash().put(RedisConstants.DATA_SECOND, mac, data); @@ -196,7 +196,7 @@ historySecondCruiserService.insertHistorySecond(data); ack.acknowledge(); } catch (Exception e) { - log.error("param{}" + msg); + log.error("param{}" + e); } } } -- Gitblit v1.8.0