Shikong/wvp-gb28181-project
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

recordList 判空

Browse Source
This commit is contained in:
zxb 2024-02-06 15:14:39 +08:00
parent d39b68b071
commit bf0a4c2abf
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/query/cmd/RecordInfoQueryMessageHandler.java
View File

@ -108,8 +108,16 @@ public class RecordInfoQueryMessageHandler extends SIPRequestProcessorParent imp
// 接收录像数据 // 接收录像数据
recordEndEventListener.addEndEventHandler(deviceChannel.getDeviceId(), channelId, String.valueOf(sn),(recordInfo)->{ recordEndEventListener.addEndEventHandler(deviceChannel.getDeviceId(), channelId, String.valueOf(sn),(recordInfo)->{
try { try {
if(recordInfo.getRecordList() == null){
logger.info("[国标级联] 录像查询收到数据， 通道： {}, {}, 准备转发", channelId, sn);
cmderFroPlatform.recordInfo(deviceChannel, parentPlatform, request.getFromTag(), recordInfo);
return;
}
RecordItem item = recordInfo.getRecordList().stream().findFirst().orElse(null); RecordItem item = recordInfo.getRecordList().stream().findFirst().orElse(null);
if(item == null) { if(item == null) {
logger.info("[国标级联] 录像查询收到数据， 通道： {}, {}, 准备转发", channelId, sn);
cmderFroPlatform.recordInfo(deviceChannel, parentPlatform, request.getFromTag(), recordInfo);
return; return;
} }
@ -118,7 +126,6 @@ public class RecordInfoQueryMessageHandler extends SIPRequestProcessorParent imp
return; return;
} }
set.add(key); set.add(key);
logger.info("[国标级联] 录像查询收到数据， 通道： {}, {}, 准备转发", channelId, sn); logger.info("[国标级联] 录像查询收到数据， 通道： {}, {}, 准备转发", channelId, sn);
cmderFroPlatform.recordInfo(deviceChannel, parentPlatform, request.getFromTag(), recordInfo); cmderFroPlatform.recordInfo(deviceChannel, parentPlatform, request.getFromTag(), recordInfo);
} catch (SipException | InvalidArgumentException | ParseException e) { } catch (SipException | InvalidArgumentException | ParseException e) {