648540858
2024-01-22 5a3b1c04d6990879531f360423003a59e76a6f89
补充日志
1个文件已修改
7 ■■■■ 已修改文件
src/main/java/com/genersoft/iot/vmp/gb28181/event/record/RecordEndEventListener.java 7 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/genersoft/iot/vmp/gb28181/event/record/RecordEndEventListener.java
@@ -35,7 +35,7 @@
        int sumNum = event.getRecordInfo().getSumNum();
        logger.info("录像查询完成事件触发,deviceId:{}, channelId: {}, 录像数量{}/{}条", event.getRecordInfo().getDeviceId(),
                event.getRecordInfo().getChannelId(), count,sumNum);
        if (handlerMap.size() > 0) {
        if (!handlerMap.isEmpty()) {
            RecordEndEventHandler handler = handlerMap.get(deviceId + channelId);
            if (handler !=null){
                handler.handler(event.getRecordInfo());
@@ -43,6 +43,9 @@
                    handlerMap.remove(deviceId + channelId);
                }
            }
        }else {
            logger.info("录像查询完成事件触发, 但是订阅为空,取消发送,deviceId:{}, channelId: {}",
                    event.getRecordInfo().getDeviceId(), event.getRecordInfo().getChannelId());
        }
    }
@@ -53,6 +56,7 @@
     * @param recordEndEventHandler
     */
    public void addEndEventHandler(String device, String channelId, RecordEndEventHandler recordEndEventHandler) {
        logger.info("录像查询事件添加监听,deviceId:{}, channelId: {}", device, channelId);
        handlerMap.put(device + channelId, recordEndEventHandler);
    }
    /**
@@ -61,6 +65,7 @@
     * @param channelId
     */
    public void delEndEventHandler(String device, String channelId) {
        logger.info("录像查询事件移除监听,deviceId:{}, channelId: {}", device, channelId);
        handlerMap.remove(device + channelId);
    }