| | |
|---|
| | | package com.genersoft.iot.vmp.media.zlm; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSON; |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.genersoft.iot.vmp.common.StreamInfo; |
|---|
| | | import com.genersoft.iot.vmp.conf.MediaServerConfig; |
|---|
| | | import com.genersoft.iot.vmp.gb28181.transmit.cmd.impl.SIPCommander; |
|---|
| | | import com.genersoft.iot.vmp.storager.IVideoManagerStorager; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.beans.factory.annotation.Value; |
|---|
| | | import org.springframework.http.HttpStatus; |
|---|
| | | import org.springframework.http.ResponseEntity; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | import org.springframework.web.bind.annotation.*; |
|---|
| | | |
|---|
| | | import javax.servlet.http.HttpServletRequest; |
|---|
| | | import java.math.BigInteger; |
|---|
| | | import java.text.DecimalFormat; |
|---|
| | | import java.util.HashMap; |
|---|
| | | import java.util.Map; |
|---|
| | | import java.util.concurrent.ConcurrentHashMap; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @Description:针对 ZLMediaServer的hook事件订阅 |
|---|
| | |
|---|
| | | */ |
|---|
| | | @Component |
|---|
| | | public class ZLMHttpHookSubscribe { |
|---|
| | | |
|---|
| | | private final static Logger logger = LoggerFactory.getLogger(ZLMHttpHookSubscribe.class); |
|---|
| | | |
|---|
| | | public enum HookType{ |
|---|
| | | on_flow_report, |
|---|
| | |
|---|
| | | void response(JSONObject response); |
|---|
| | | } |
|---|
| | | |
|---|
| | | private Map<HookType, Map<JSONObject, ZLMHttpHookSubscribe.Event>> allSubscribes = new HashMap<>(); |
|---|
| | | private Map<HookType, Map<JSONObject, ZLMHttpHookSubscribe.Event>> allSubscribes = new ConcurrentHashMap<>(); |
|---|
| | | |
|---|
| | | public void addSubscribe(HookType type, JSONObject hookResponse, ZLMHttpHookSubscribe.Event event) { |
|---|
| | | Map<JSONObject, Event> eventMap = allSubscribes.get(type); |
|---|
| | |
|---|
| | | for (JSONObject key : eventMap.keySet()) { |
|---|
| | | Boolean result = null; |
|---|
| | | for (String s : key.keySet()) { |
|---|
| | | String string = hookResponse.getString(s); |
|---|
| | | String string1 = key.getString(s); |
|---|
| | | if (result == null) { |
|---|
| | | result = key.getString(s).equals(hookResponse.getString(s)); |
|---|
| | | }else { |
|---|
