kafka 修改

jinpengyong

2021-09-01 9188066e4c0ffe7002dfad598910f6567b575b48

 screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java

@@ -142,6 +142,7 @@
            //存入redis
            redisTemplate.opsForHash().put(RedisConstants.DATA_SECOND, mac, data);
            //判断并修改设备状态
            data.put("mac", mac);
            deviceService.judgeDeviceState(data);
        } catch (Exception e) {
            log.error("param{}" + msg);