panlinlin
2021-04-11 a4ab9a0a6cd22b11b52200b66c0417d9379e3960
src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java
@@ -4,6 +4,7 @@
import java.util.UUID;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.genersoft.iot.vmp.common.StreamInfo;
import com.genersoft.iot.vmp.conf.MediaServerConfig;
import com.genersoft.iot.vmp.gb28181.bean.Device;
@@ -239,9 +240,14 @@
      String app = json.getString("app");
      String streamId = json.getString("stream");
      String schema = json.getString("schema");
      boolean regist = json.getBoolean("regist");
      JSONArray tracks = json.getJSONArray("tracks");
      String regist = json.getString("regist");
      if (tracks != null) {
         System.out.println("222222" + schema);
      }
      if ("rtmp".equals(schema)){
      if ("rtp".equals(app) && !regist ) {
         if ("rtp".equals(app) && regist != null ) {
         StreamInfo streamInfo = redisCatchStorage.queryPlayByStreamId(streamId);
         if (streamInfo!=null){
            redisCatchStorage.stopPlay(streamInfo);
@@ -251,14 +257,16 @@
            redisCatchStorage.stopPlayback(streamInfo);
         }
      }else {
         if (!"rtp".equals(app) && "rtmp".equals(schema)){
            if (regist) {
            if (!"rtp".equals(app) ){
               if (regist == null) {
               zlmMediaListManager.addMedia(app, streamId);
            }else {
               zlmMediaListManager.removeMedia(app, streamId);
            }
         }
      }
      }
      JSONObject ret = new JSONObject();
      ret.put("code", 0);
      ret.put("msg", "success");