| | |
| | | ArdDroneInfo local = localMap.get(boxSn); |
| | | boolean dbOnline = local != null && local.getOnLine() == 1; |
| | | boolean needUpdate = (dbOnline != currentOnline); |
| | | |
| | | // 只要远端设备在线,就刷新Redis缓存(无论状态是否变化),保证缓存一定存在 |
| | | if (currentOnline) { |
| | | redisCache.setCacheObject(redisKey, remote); |
| | | } else { |
| | | // 远端离线,删除Redis缓存 |
| | | redisCache.deleteObject(redisKey); |
| | | } |
| | | // 如果状态变化才更新 |
| | | if (needUpdate){ |
| | | // 更新 Redis |
| | | if (currentOnline) { |
| | | redisCache.setCacheObject(redisKey, remote); |
| | | } else { |
| | | redisCache.deleteObject(redisKey); |
| | | } |
| | | // 发布事件 |
| | | eventPublisher.publishEvent(new DeviceStatusEvent(boxSn, currentOnline)); |
| | | // 更新数据库 |
| | |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 更新 localBoxInfo 的字段,如果有变化返回 true,否则返回 false |
| | | */ |
| | | private boolean updateChangedAttributes(ArdDroneInfo localBoxInfo, BoxInfoReceiver remoteArdDrone) { |
| | | boolean changed = false; |
| | | |
| | | if (!Objects.equals(localBoxInfo.getBoxName(), remoteArdDrone.getBoxName())) { |
| | | localBoxInfo.setBoxName(remoteArdDrone.getBoxName()); |
| | | changed = true; |
| | | } |
| | | if (!Objects.equals(localBoxInfo.getBoxVersion(), remoteArdDrone.getBoxVersion())) { |
| | | localBoxInfo.setBoxVersion(remoteArdDrone.getBoxVersion()); |
| | | changed = true; |
| | | } |
| | | if (!Objects.equals(localBoxInfo.getLastTaskId(), remoteArdDrone.getLastTaskId())) { |
| | | localBoxInfo.setLastTaskId(remoteArdDrone.getLastTaskId()); |
| | | changed = true; |
| | | } |
| | | if (!Objects.equals(localBoxInfo.getOnLine(), remoteArdDrone.getOnLine())) { |
| | | localBoxInfo.setOnLine(remoteArdDrone.getOnLine()); |
| | | changed = true; |
| | | } |
| | | |
| | | // TODO: 更新其他属性时,如果变化也设置 changed = true |
| | | |
| | | return changed; |
| | | } |
| | | |
| | | } |