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

兼容 不标准的 recordInfo 协议

Browse Source
This commit is contained in:
zxb 2023-08-29 17:25:56 +08:00
parent 8c559a8de1
commit 1f07304e80
1 changed files with 5 additions and 4 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/response/cmd/RecordInfoResponseMessageHandler.java
View File

@ -163,9 +163,10 @@ public class RecordInfoResponseMessageHandler extends SIPRequestProcessorParent
recordItems.addAll(recordList); recordItems.addAll(recordList);
recordListMap.put(resKey, recordItems); recordListMap.put(resKey, recordItems);
logger.info("{}/{}", count.get(), sumNum); logger.info("{}/{}", count.get(), sumNum);
if (count.get() < sumNum) { // if (count.get() < sumNum) {
return; // return;
} else { // } else {
// 不管有没有拿全 超过 时间间隔就直接返回
Optional.ofNullable(scheduleMap.get(resKey)).ifPresent(scheduledFuture -> { Optional.ofNullable(scheduleMap.get(resKey)).ifPresent(scheduledFuture -> {
scheduleMap.remove(resKey); scheduleMap.remove(resKey);
scheduledFuture.cancel(true); scheduledFuture.cancel(true);
@ -180,7 +181,7 @@ public class RecordInfoResponseMessageHandler extends SIPRequestProcessorParent
releaseRequest(device.getDeviceId(), sn,recordInfo); releaseRequest(device.getDeviceId(), sn,recordInfo);
}, 500, TimeUnit.MILLISECONDS); }, 500, TimeUnit.MILLISECONDS);
scheduleMap.put(resKey,schedule); scheduleMap.put(resKey,schedule);
} // }
} }
} }
} catch (Exception e) { } catch (Exception e) {