| | |
|---|
| | | try { |
|---|
| | | if (streamProxyMapper.update(streamProxyItem) > 0) { |
|---|
| | | if (!StringUtils.isEmpty(streamProxyItem.getGbId())) { |
|---|
| | | if (gbStreamMapper.update(streamProxyItem) > 0) { |
|---|
| | | if (gbStreamMapper.updateByallAndStream(streamProxyItem) > 0) { |
|---|
| | | //事务回滚 |
|---|
| | | dataSourceTransactionManager.rollback(transactionStatus); |
|---|
| | | return false; |
|---|
| | |
|---|
| | | List<ParentPlatform> parentPlatforms = parentPlatformMapper.selectAllAhareAllLiveStream(); |
|---|
| | | if (parentPlatforms.size() > 0) { |
|---|
| | | for (ParentPlatform parentPlatform : parentPlatforms) { |
|---|
| | | StreamProxyItem streamProxyItems = platformGbStreamMapper.selectOne(streamPushItem.getApp(), streamPushItem.getStream(), |
|---|
| | | StreamProxyItem streamProxyItem = platformGbStreamMapper.selectOne(streamPushItem.getApp(), streamPushItem.getStream(), |
|---|
| | | parentPlatform.getServerGBId()); |
|---|
| | | if (streamProxyItems == null) { |
|---|
| | | if (streamProxyItem == null) { |
|---|
| | | streamPushItem.setCatalogId(parentPlatform.getCatalogId()); |
|---|
| | | streamPushItem.setPlatformId(parentPlatform.getServerGBId()); |
|---|
| | | platformGbStreamMapper.add(streamPushItem); |
|---|
