From 3884e9a56aeab7ac2ad7c9483059adc0df6683d9 Mon Sep 17 00:00:00 2001 From: jiang <893224616@qq.com> Date: 星期三, 07 九月 2022 15:56:48 +0800 Subject: [PATCH] 1.根据redis消息更新推流列表时同时更新在线状态 2.推流列表的模板增加在线状态 --- src/main/java/com/genersoft/iot/vmp/gb28181/session/RecordDataCatch.java | 6 +----- 1 files changed, 1 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/session/RecordDataCatch.java b/src/main/java/com/genersoft/iot/vmp/gb28181/session/RecordDataCatch.java index dd5b8df..1d2b34b 100644 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/session/RecordDataCatch.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/session/RecordDataCatch.java @@ -60,16 +60,12 @@ // 澶勭悊褰曞儚鏁版嵁锛� 杩斿洖缁欏墠绔� String msgKey = DeferredResultHolder.CALLBACK_CMD_RECORDINFO + recordInfo.getDeviceId() + recordInfo.getSn(); - WVPResult<RecordInfo> wvpResult = new WVPResult<>(); - wvpResult.setCode(0); - wvpResult.setMsg("success"); // 瀵规暟鎹繘琛屾帓搴� Collections.sort(recordInfo.getRecordList()); - wvpResult.setData(recordInfo); RequestMessage msg = new RequestMessage(); msg.setKey(msgKey); - msg.setData(wvpResult); + msg.setData(recordInfo); deferredResultHolder.invokeAllResult(msg); data.remove(key); } -- Gitblit v1.8.0