From bf0a4c2abffd83305714402b911292aab86e6c6d Mon Sep 17 00:00:00 2001 From: zxb <919411476@qq.com> Date: Tue, 6 Feb 2024 15:14:39 +0800 Subject: [PATCH] =?UTF-8?q?recordList=20=E5=88=A4=E7=A9=BA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../message/query/cmd/RecordInfoQueryMessageHandler.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/query/cmd/RecordInfoQueryMessageHandler.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/query/cmd/RecordInfoQueryMessageHandler.java index 6488e04f..b71d3b66 100755 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/query/cmd/RecordInfoQueryMessageHandler.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/query/cmd/RecordInfoQueryMessageHandler.java @@ -108,8 +108,16 @@ public class RecordInfoQueryMessageHandler extends SIPRequestProcessorParent imp // 接收录像数据 recordEndEventListener.addEndEventHandler(deviceChannel.getDeviceId(), channelId, String.valueOf(sn),(recordInfo)->{ 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); if(item == null) { + logger.info("[国标级联] 录像查询收到数据, 通道: {}, {}, 准备转发", channelId, sn); + cmderFroPlatform.recordInfo(deviceChannel, parentPlatform, request.getFromTag(), recordInfo); return; } @@ -118,7 +126,6 @@ public class RecordInfoQueryMessageHandler extends SIPRequestProcessorParent imp return; } set.add(key); - logger.info("[国标级联] 录像查询收到数据, 通道: {}, {}, 准备转发", channelId, sn); cmderFroPlatform.recordInfo(deviceChannel, parentPlatform, request.getFromTag(), recordInfo); } catch (SipException | InvalidArgumentException | ParseException e) {