| | |
|---|
| | | @Override |
|---|
| | | public boolean update(ParentPlatform parentPlatform) { |
|---|
| | | logger.info("[国标级联]更新平台 {}", parentPlatform.getDeviceGBId()); |
|---|
| | | // TODO 后续版本去除 |
|---|
| | | parentPlatform.setTreeType(""); |
|---|
| | | parentPlatform.setCharacterSet(parentPlatform.getCharacterSet().toUpperCase()); |
|---|
| | | ParentPlatform parentPlatformOld = platformMapper.getParentPlatById(parentPlatform.getId()); |
|---|
| | | ParentPlatformCatch parentPlatformCatchOld = redisCatchStorage.queryPlatformCatchInfo(parentPlatformOld.getServerGBId()); |
|---|
| | | parentPlatform.setUpdateTime(DateUtil.getNow()); |
|---|
| | | if (!parentPlatformOld.getTreeType().equals(parentPlatform.getTreeType())) { |
|---|
| | | // 目录结构发生变化，清空之前的关联关系 |
|---|
| | | logger.info("保存平台{}时发现目录结构变化，清空关联关系", parentPlatform.getDeviceGBId()); |
|---|
| | | catalogMapper.delByPlatformId(parentPlatformOld.getServerGBId()); |
|---|
| | | platformChannelMapper.delByPlatformId(parentPlatformOld.getServerGBId()); |
|---|
| | | platformGbStreamMapper.delByPlatformId(parentPlatformOld.getServerGBId()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | // 停止心跳定时 |
|---|
| | | final String keepaliveTaskKey = KEEPALIVE_KEY_PREFIX + parentPlatformOld.getServerGBId(); |
|---|
| | |
|---|
| | | // 注销旧的 |
|---|
| | | try { |
|---|
| | | if (parentPlatformOld.isStatus()) { |
|---|
| | | logger.info("保存平台{}时发现救平台在线，发送注销命令", parentPlatform.getDeviceGBId()); |
|---|
| | | logger.info("保存平台{}时发现救平台在线，发送注销命令", parentPlatformOld.getServerGBId()); |
|---|
| | | commanderForPlatform.unregister(parentPlatformOld, parentPlatformCatchOld.getSipTransactionInfo(), null, eventResult -> { |
|---|
| | | logger.info("[国标级联] 注销成功， 平台：{}", parentPlatformOld.getServerGBId()); |
|---|
| | | }); |
|---|
| | |
|---|
| | | // 保存时启用就发送注册 |
|---|
| | | // 注册成功时由程序直接调用了online方法 |
|---|
| | | try { |
|---|
| | | logger.info("[国标级联] 平台注册 {}", parentPlatform.getDeviceGBId()); |
|---|
| | | commanderForPlatform.register(parentPlatform, eventResult -> { |
|---|
| | | logger.info("[国标级联] {},添加向上级注册失败，请确定上级平台可用时重新保存", parentPlatform.getServerGBId()); |
|---|
| | | }, null); |
|---|
| | |
|---|
| | | // 心跳成功 |
|---|
| | | // 清空之前的心跳超时计数 |
|---|
| | | ParentPlatformCatch platformCatch = redisCatchStorage.queryPlatformCatchInfo(parentPlatform.getServerGBId()); |
|---|
| | | if (platformCatch.getKeepAliveReply() > 0) { |
|---|
| | | if (platformCatch != null && platformCatch.getKeepAliveReply() > 0) { |
|---|
| | | platformCatch.setKeepAliveReply(0); |
|---|
| | | redisCatchStorage.updatePlatformCatchInfo(platformCatch); |
|---|
| | | } |
|---|
