Merge remote-tracking branch 'origin/wvp-28181-2.0' into wvp-28181-2.0

panlinlin

2021-01-12 6e4a8cac04432f5a36d5c5e3c5eb3d28d2295a5c

 src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java

@@ -21,6 +21,7 @@
import org.springframework.beans.factory.annotation.Value;

import org.springframework.http.HttpStatus;

import org.springframework.http.ResponseEntity;

import org.springframework.util.StringUtils;

import org.springframework.web.bind.annotation.PostMapping;

import org.springframework.web.bind.annotation.RequestBody;

import org.springframework.web.bind.annotation.RequestMapping;

@@ -68,6 +69,9 @@
   @Value("${media.ip}")

   private String mediaIp;



   @Value("${media.wanIp}")

   private String mediaWanIp;



   @Value("${media.port}")

   private int mediaPort;



@@ -78,13 +82,10 @@
   @ResponseBody

   @PostMapping(value = "/on_flow_report", produces = "application/json;charset=UTF-8")

   public ResponseEntity<String> onFlowReport(@RequestBody JSONObject json){

		
      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_flow_report API调用，参数：" + json.toString());

      }



      logger.debug("ZLM HOOK on_flow_report API调用，参数：" + json.toString());

      // TODO Auto-generated method stub



		
      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("msg", "success");

@@ -230,8 +231,13 @@
      if (logger.isDebugEnabled()) {

         logger.debug("ZLM HOOK on_shell_login API调用，参数：" + json.toString());

      }

      // TODO Auto-generated method stub

		
      // TODO 如果是带有rtpstream则开启按需拉流

      String app = json.getString("app");

      String stream = json.getString("stream");



      ZLMHttpHookSubscribe.Event subscribe = this.subscribe.getSubscribe(ZLMHttpHookSubscribe.HookType.on_publish, json);

      if (subscribe != null) subscribe.response(json);



      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("msg", "success");

@@ -257,6 +263,7 @@
      if ("rtp".equals(app) && !regist ) {

         if (streamInfo!=null){

            redisCatchStorage.stopPlay(streamInfo);

            storager.stopPlay(streamInfo.getDeviceID(), streamInfo.getChannelId());

         }else{

            streamInfo = redisCatchStorage.queryPlaybackByStreamId(streamId);

            redisCatchStorage.stopPlayback(streamInfo);

@@ -288,6 +295,7 @@
      StreamInfo streamInfo = redisCatchStorage.queryPlayByStreamId(streamId);

      if (streamInfo!=null){

         redisCatchStorage.stopPlay(streamInfo);

         storager.stopPlay(streamInfo.getDeviceID(), streamInfo.getChannelId());

      }else{

         streamInfo = redisCatchStorage.queryPlaybackByStreamId(streamId);

         redisCatchStorage.stopPlayback(streamInfo);

@@ -358,6 +366,7 @@
//      List<MediaServerConfig> mediaServerConfigs = JSON.parseArray(JSON.toJSONString(json), MediaServerConfig.class);

//      MediaServerConfig mediaServerConfig = mediaServerConfigs.get(0);

      MediaServerConfig mediaServerConfig = JSON.toJavaObject(json, MediaServerConfig.class);

      mediaServerConfig.setWanIp(StringUtils.isEmpty(mediaWanIp)? mediaIp: mediaWanIp);

      mediaServerConfig.setLocalIP(mediaIp);

      redisCatchStorage.updateMediaInfo(mediaServerConfig);

      // TODO Auto-generated method stub