| | |
|---|
| | | package com.genersoft.iot.vmp.gb28181.event.record; |
|---|
| | | |
|---|
| | | import com.genersoft.iot.vmp.gb28181.bean.RecordInfo; |
|---|
| | | import com.genersoft.iot.vmp.gb28181.bean.RecordItem; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | | import org.springframework.context.ApplicationListener; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | import org.springframework.web.servlet.mvc.method.annotation.SseEmitter; |
|---|
| | | |
|---|
| | | import java.io.IOException; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.concurrent.ConcurrentHashMap; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @description: 录像查询结束时间 |
|---|
| | | * @description: 录像查询结束事件 |
|---|
| | | * @author: pan |
|---|
| | | * @data: 2022-02-23 |
|---|
| | | */ |
|---|
| | |
|---|
| | | |
|---|
| | | private final static Logger logger = LoggerFactory.getLogger(RecordEndEventListener.class); |
|---|
| | | |
|---|
| | | private static Map<String, SseEmitter> sseEmitters = new Hashtable<>(); |
|---|
| | | |
|---|
| | | public interface RecordEndEventHandler{ |
|---|
| | | void handler(RecordInfo recordInfo); |
|---|
| | | } |
|---|
| | | |
|---|
| | | private Map<String, RecordEndEventHandler> handlerMap = new HashMap<>(); |
|---|
| | | private Map<String, RecordEndEventHandler> handlerMap = new ConcurrentHashMap<>(); |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void onApplicationEvent(RecordEndEvent event) { |
|---|
| | | logger.info("录像查询完成事件触发，deviceId：{}, channelId: {}, 录像数量{}条", event.getRecordInfo().getDeviceId(), |
|---|
| | |
|---|
| | | recordEndEventHandler.handler(event.getRecordInfo()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | public void addEndEventHandler(String device, String channelId, RecordEndEventHandler recordEndEventHandler) { |
|---|
