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

设备历史录像查询(调整/部分重构) 订阅器修正

Browse Source
This commit is contained in:
shikong 2023-10-03 17:29:38 +08:00
parent 4a69cbd8ac
commit dc3cf8f5b5
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
gb28181-service/src/main/java/cn/skcks/docking/gb28181/service/record/RecordService.java
View File

@ -138,7 +138,7 @@ public class RecordService {
public void onComplete() { public void onComplete() {
result.setResult(JsonResponse.success(RecordConvertor.INSTANCE.dto2Vo(sortedRecordList(list)))); result.setResult(JsonResponse.success(RecordConvertor.INSTANCE.dto2Vo(sortedRecordList(list))));
log.debug("订阅结束 => {}", key); log.debug("订阅结束 => {}", key);
subscribe.getRecordInfoSubscribe().delPublisher(key); subscribe.getSipRequestSubscribe().delPublisher(key);
} }
}; };
subscribe.getSipRequestSubscribe().addSubscribe(key, subscriber); subscribe.getSipRequestSubscribe().addSubscribe(key, subscriber);
@ -146,7 +146,7 @@ public class RecordService {
result.setResult(JsonResponse.build(ResponseStatus.PARTIAL_CONTENT, result.setResult(JsonResponse.build(ResponseStatus.PARTIAL_CONTENT,
RecordConvertor.INSTANCE.dto2Vo(sortedRecordList(Collections.emptyList())), RecordConvertor.INSTANCE.dto2Vo(sortedRecordList(Collections.emptyList())),
"查询超时, 结果可能不完整")); "查询超时, 结果可能不完整"));
subscribe.getRecordInfoSubscribe().delPublisher(key); subscribe.getSipRequestSubscribe().delPublisher(key);
}); });
provider.sendRequest(request); provider.sendRequest(request);