diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/RecordInfoResponseMessageHandler.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/RecordInfoResponseMessageHandler.java index c0a277e7..edf392e2 100755 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/RecordInfoResponseMessageHandler.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/RecordInfoResponseMessageHandler.java @@ -159,9 +159,10 @@ public class RecordInfoResponseMessageHandler extends SIPRequestProcessorParent recordItems.addAll(recordList); recordListMap.put(resKey, recordItems); logger.info("{}/{}", count.get(), sumNum); - if (count.get() < sumNum) { - return; - } else { +// if (count.get() < sumNum) { +// return; +// } else { + // 不管有没有拿全 超过 时间间隔就直接返回 Optional.ofNullable(scheduleMap.get(resKey)).ifPresent(scheduledFuture -> { scheduleMap.remove(resKey); scheduledFuture.cancel(true); @@ -176,7 +177,7 @@ public class RecordInfoResponseMessageHandler extends SIPRequestProcessorParent releaseRequest(device.getDeviceId(), sn,recordInfo); }, 500, TimeUnit.MILLISECONDS); scheduleMap.put(resKey,schedule); - } +// } } } } catch (Exception e) {