old mode 100644
new mode 100755
| | |
| | | |
| | | @Override |
| | | public boolean stop(String app, String streamId) { |
| | | logger.info("[推流 ] 停止流: {}/{}", app, streamId); |
| | | StreamPushItem streamPushItem = streamPushMapper.selectOne(app, streamId); |
| | | if (streamPushItem != null) { |
| | | gbStreamService.sendCatalogMsg(streamPushItem, CatalogEvent.DEL); |
| | |
| | | |
| | | } |
| | | } |
| | | if (streamPushItemListFroPlatform.size() > 0) { |
| | | if (!streamPushItemListFroPlatform.isEmpty()) { |
| | | platformGbStreamMapper.batchAdd(streamPushItemListFroPlatform); |
| | | // 发送通知 |
| | | for (String platformId : platformForEvent.keySet()) { |
| | |
| | | stream.setUpdateTime(DateUtil.getNow()); |
| | | stream.setCreateTime(DateUtil.getNow()); |
| | | stream.setServerId(userSetting.getServerId()); |
| | | stream.setMediaServerId(mediaConfig.getId()); |
| | | stream.setSelf(true); |
| | | stream.setPushIng(true); |
| | | |
| | | // 放在事务内执行 |
| | | boolean result = false; |