From aa55464a176eb339f135b0c7cc7461d83b4ed1fb Mon Sep 17 00:00:00 2001
From: zxb <919411476@qq.com>
Date: Tue, 29 Aug 2023 17:25:56 +0800
Subject: [PATCH] =?UTF-8?q?=E5=85=BC=E5=AE=B9=20=E4=B8=8D=E6=A0=87?=
 =?UTF-8?q?=E5=87=86=E7=9A=84=20recordInfo=20=E5=8D=8F=E8=AE=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../response/cmd/RecordInfoResponseMessageHandler.java   | 9 +++++----
 1 file changed, 5 insertions(+), 4 deletions(-)

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) {