| | |
|---|
| | | if (parentPlatformCatch == null) { // serverGBId 已变化 |
|---|
| | | ParentPlatform parentPlatById = platformMapper.getParentPlatById(parentPlatform.getId()); |
|---|
| | | // 使用旧的查出缓存ID |
|---|
| | | parentPlatformCatch = redisCatchStorage.queryPlatformCatchInfo(parentPlatById.getServerGBId()); |
|---|
| | | parentPlatformCatch = new ParentPlatformCatch(); |
|---|
| | | parentPlatformCatch.setId(parentPlatform.getServerGBId()); |
|---|
| | | redisCatchStorage.delPlatformCatchInfo(parentPlatById.getServerGBId()); |
|---|
| | | } |
|---|
| | |
|---|
| | | try { |
|---|
| | | if (streamProxyMapper.update(streamProxyItem) > 0) { |
|---|
| | | if (!StringUtils.isEmpty(streamProxyItem.getGbId())) { |
|---|
| | | if (gbStreamMapper.update(streamProxyItem) > 0) { |
|---|
| | | if (gbStreamMapper.update(streamProxyItem) < 0) { |
|---|
| | | //事务回滚 |
|---|
| | | dataSourceTransactionManager.rollback(transactionStatus); |
|---|
| | | return false; |
|---|
