|  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public boolean stop(String app, String streamId) { | 
|---|
|  |  |  | StreamPushItem streamPushItem = streamPushMapper.selectOne(app, streamId); | 
|---|
|  |  |  | gbStreamService.sendCatalogMsg(streamPushItem, CatalogEvent.DEL); | 
|---|
|  |  |  | if (streamPushItem != null) { | 
|---|
|  |  |  | gbStreamService.sendCatalogMsg(streamPushItem, CatalogEvent.DEL); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | platformGbStreamMapper.delByAppAndStream(app, streamId); | 
|---|
|  |  |  | gbStreamMapper.del(app, streamId); | 
|---|
|  |  |  | 
|---|
|  |  |  | // 存储数据到stream_push表 | 
|---|
|  |  |  | streamPushMapper.addAll(streamPushItems); | 
|---|
|  |  |  | List<StreamPushItem> streamPushItemForGbStream = streamPushItems.stream() | 
|---|
|  |  |  | .filter(streamPushItem-> streamPushItem.getId() != null) | 
|---|
|  |  |  | .filter(streamPushItem-> streamPushItem.getGbId() != null) | 
|---|
|  |  |  | .collect(Collectors.toList()); | 
|---|
|  |  |  | // 存储数据到gb_stream表, id会返回到streamPushItemForGbStream里 | 
|---|
|  |  |  | if (streamPushItemForGbStream.size() > 0) { | 
|---|