| | |
|---|
| | | list().forEach( |
|---|
| | | device -> { |
|---|
| | | RedisDeviceStatus deviceStatus = new RedisDeviceStatus(); |
|---|
| | | deviceStatus.setDeviceId(device.getAirMac()); |
|---|
| | | deviceStatus.setDeviceId(device.getMac()); |
|---|
| | | |
|---|
| | | if (RedisUtils.getBean().get(AtmoFunctionCode.AIR_HEARTBEAT_STATE.getCode() + device.getAirMac()) != null) { |
|---|
| | | if (RedisUtils.getBean().get(AtmoFunctionCode.AIR_HEARTBEAT_STATE.getCode() + device.getMac()) != null) { |
|---|
| | | deviceStatus.setStatus(0); |
|---|
| | | } else { |
|---|
| | | deviceStatus.setStatus(1); |
|---|
| | | } |
|---|
| | | redisUtils.set(DeviceRedisKey.AIR + device.getAirMac(), JSON.toJSONString(deviceStatus)); |
|---|
| | | redisUtils.set(DeviceRedisKey.AIR + device.getMac(), JSON.toJSONString(deviceStatus)); |
|---|
| | | // redisUtils.delete(DeviceRedisKey.AIR + device.getAirMac()); |
|---|
| | | } |
|---|
| | | ); |
|---|
