修复回放失败出现脏数据的问题以及添加拉流代理判断错误的问题

648540858 · guzijian
1 parent 1f39c6c6
Showing 2 changed files with 2 additions and 1 deletions
src/main/java/com/genersoft/iot/vmp/service/impl/PlayServiceImpl.java
src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java
@@ -314,6 +314,7 @@ public class PlayServiceImpl implements IPlayService {
         }, event -> {
             msg.setData(String.format("回放失败， 错误码： %s, %s", event.statusCode, event.msg));
             callback.call(msg);
+            streamSession.remove(device.getDeviceId(), channelId, ssrcInfo.getStream());
         });
         return result;
     }
@@ -716,7 +716,7 @@ public class VideoManagerStoragerImpl implements IVideoManagerStorager {
 		try {
 			if (streamProxyMapper.add(streamProxyItem) > 0) {
 				if (!StringUtils.isEmpty(streamProxyItem.getGbId())) {
-					if (gbStreamMapper.add(streamProxyItem) > 0) {
+					if (gbStreamMapper.add(streamProxyItem) <= 0) {
 						//事务回滚
 						dataSourceTransactionManager.rollback(transactionStatus);
 						return false;