增加上级远程启动TeleBoot功能的支持

lawrencehj

2021-03-14 712b25fb6eea8e85fd2c43d2956529312afdd3dc

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

@@ -133,8 +133,6 @@
      if (logger.isDebugEnabled()) {

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

      }

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

      // String streamId = json.getString("id");



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

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

@@ -212,6 +210,13 @@
      if (logger.isDebugEnabled()) {

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

      }

      // 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");

@@ -262,20 +267,25 @@
      }

      

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



      cmder.streamByeCmd(streamId);

      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);

      }

		


      JSONObject ret = new JSONObject();

      ret.put("code", 0);

      ret.put("close", true);



      if (streamInfo != null) {

         if (redisCatchStorage.isChannelSendingRTP(streamInfo.getChannelId())) {

            ret.put("close", false);

         } else {

            cmder.streamByeCmd(streamId);

            redisCatchStorage.stopPlay(streamInfo);

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

         }

      }else{

         cmder.streamByeCmd(streamId);

         streamInfo = redisCatchStorage.queryPlaybackByStreamId(streamId);

         redisCatchStorage.stopPlayback(streamInfo);

      }

      return new ResponseEntity<String>(ret.toString(),HttpStatus.OK);

   }