From 11d10fc9ca90ec29159738c1eac5e2d9203d8bb6 Mon Sep 17 00:00:00 2001 From: kaiyu <404897439@qq.com> Date: Wed, 28 Jul 2021 09:14:12 +0800 Subject: [PATCH] screen-api kafka消费者组id从配置文件获取 screen-manage 除admin角色外无法查看admin角色 --- screen-job/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java | 5 +++-- 1 files changed, 3 insertions(+), 2 deletions(-) diff --git a/screen-job/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java index b66f7b9..704348c 100644 --- a/screen-job/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java +++ b/screen-job/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java @@ -40,10 +40,11 @@ public void judgeOffLineDevice() { QueryWrapper<Device> queryWrapper = new QueryWrapper<>(); queryWrapper.ne("state", Constants.DEVICE_STATE_OFFLINE); + queryWrapper.eq("is_delete",Constants.NOT_DELETE); //������������������������ List<Device> devices = deviceMapper.selectList(queryWrapper); for (Device device : devices) { - Map<String, Object> data = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.DEVICE_DATA, device.getMac()); + Map<String, Object> data = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.DATA_SECOND, device.getMac()); device.setState(Constants.DEVICE_STATE_OFFLINE); if (data != null && data.containsKey("DataTime")) { Date time = DateUtils.getDate((String) data.get("DataTime"), DateUtils.yyyyMMddHHmmss_EN); @@ -64,4 +65,4 @@ updateWrapper.eq("id", device.getId()).set("state", device.getState()); deviceMapper.update(null, updateWrapper); } -} +} \ No newline at end of file -- Gitblit v1.8.0