| | |
|---|
| | | @Override |
|---|
| | | public void judgeOffLineDevice() { |
|---|
| | | QueryWrapper<Device> queryWrapper = new QueryWrapper<>(); |
|---|
| | | queryWrapper.ne("state", Constants.DEVICE_STATE_OFFLINE); |
|---|
| | | queryWrapper.eq("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.DATA_SECOND, device.getMac()); |
|---|
| | | Map<String, Object> data = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.DATA_FIVE_MINUTES, 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); |
|---|
| | | if (data != null && data.containsKey("dataTime")) { |
|---|
| | | Date time = DateUtils.getDate((String) data.get("dataTime"), DateUtils.yyyyMMddHHmmss_EN); |
|---|
| | | //超过两分钟无数据就离线 |
|---|
| | | if (DateUtils.getDateOfMin(time, 2).getTime() < new Date().getTime()) { |
|---|
| | | if (DateUtils.getDateOfMin(time, 12).getTime() > new Date().getTime()) { |
|---|
| | | device.setState("1"); |
|---|
| | | updateDeviceState(device); |
|---|
| | | } |
|---|
| | | } else { |
|---|
| | | updateDeviceState(device); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
