package com.genersoft.iot.vmp.gb28181.event.record;
|
|
import com.genersoft.iot.vmp.gb28181.bean.RecordInfo;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.context.ApplicationListener;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Map;
|
import java.util.concurrent.ConcurrentHashMap;
|
|
/**
|
* @description: 录像查询结束事件
|
* @author: pan
|
* @data: 2022-02-23
|
*/
|
|
@Component
|
public class RecordEndEventListener implements ApplicationListener<RecordEndEvent> {
|
|
private final static Logger logger = LoggerFactory.getLogger(RecordEndEventListener.class);
|
|
public interface RecordEndEventHandler{
|
void handler(RecordInfo recordInfo);
|
}
|
|
private Map<String, RecordEndEventHandler> handlerMap = new ConcurrentHashMap<>();
|
|
@Override
|
public void onApplicationEvent(RecordEndEvent event) {
|
logger.info("录像查询完成事件触发，deviceId：{}, channelId: {}, 录像数量{}条", event.getRecordInfo().getDeviceId(),
|
event.getRecordInfo().getChannelId(), event.getRecordInfo().getSumNum() );
|
if (handlerMap.size() > 0) {
|
for (RecordEndEventHandler recordEndEventHandler : handlerMap.values()) {
|
recordEndEventHandler.handler(event.getRecordInfo());
|
}
|
}
|
}
|
|
public void addEndEventHandler(String device, String channelId, RecordEndEventHandler recordEndEventHandler) {
|
handlerMap.put(device + channelId, recordEndEventHandler);
|
}
|
}
|
