搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
64850858
2021-07-14 e48ef997c03b49c8090970f5fbb29ce80b0ac6df 
 src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/play/PlayController.java


@@ -1,12 +1,15 @@


package com.genersoft.iot.vmp.vmanager.gb28181.play;




import com.alibaba.fastjson.JSONArray;


import com.genersoft.iot.vmp.common.StreamInfo;


import com.genersoft.iot.vmp.gb28181.session.VideoStreamSessionManager;


import com.genersoft.iot.vmp.media.zlm.ZLMServerConfig;


import com.genersoft.iot.vmp.gb28181.bean.Device;


import com.genersoft.iot.vmp.gb28181.transmit.callback.DeferredResultHolder;


import com.genersoft.iot.vmp.gb28181.transmit.callback.RequestMessage;


import com.genersoft.iot.vmp.media.zlm.ZLMRESTfulUtils;


import com.genersoft.iot.vmp.storager.IRedisCatchStorage;


import com.genersoft.iot.vmp.vmanager.bean.WVPResult;


import com.genersoft.iot.vmp.vmanager.gb28181.play.bean.PlayResult;


import com.genersoft.iot.vmp.service.IMediaService;


import com.genersoft.iot.vmp.service.IPlayService;


@@ -19,7 +22,6 @@


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.http.HttpStatus;


import org.springframework.http.ResponseEntity;


import org.springframework.util.ResourceUtils;


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


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


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


@@ -32,7 +34,8 @@


import com.genersoft.iot.vmp.storager.IVideoManagerStorager;


import org.springframework.web.context.request.async.DeferredResult;




import java.io.FileNotFoundException;


import java.util.Enumeration;


import java.util.Map;


import java.util.UUID;




import javax.sip.message.Response;


@@ -47,6 +50,9 @@




   @Autowired


   private SIPCommander cmder;




   @Autowired


   private VideoStreamSessionManager streamSession;




   @Autowired


   private IVideoManagerStorager storager;


@@ -154,7 +160,7 @@


   })


   @PostMapping("/convert/{streamId}")


   public ResponseEntity<String> playConvert(@PathVariable String streamId) {


      StreamInfo streamInfo = redisCatchStorage.queryPlayByStreamId(streamId);


      StreamInfo streamInfo = streamId.startsWith("gb_play_") ? redisCatchStorage.queryPlayByStreamId(streamId) : redisCatchStorage.queryPlaybackByStreamId(streamId);


      if (streamInfo == null) {


         logger.warn("视频转码API调用失败！, 视频流已经停止!");


         return new ResponseEntity<String>("未找到视频流信息, 视频流可能已经停止", HttpStatus.OK);


@@ -168,7 +174,7 @@


         String dstUrl = String.format("rtmp://%s:%s/convert/%s", "127.0.0.1", mediaInfo.getRtmpPort(),


               streamId );


         String srcUrl = String.format("rtsp://%s:%s/rtp/%s", "127.0.0.1", mediaInfo.getRtspPort(), streamId);


         JSONObject jsonObject = zlmresTfulUtils.addFFmpegSource(srcUrl, dstUrl, "1000000");


         JSONObject jsonObject = zlmresTfulUtils.addFFmpegSource(srcUrl, dstUrl, "1000000", true, false, null);


         logger.info(jsonObject.toJSONString());


         JSONObject result = new JSONObject();


         if (jsonObject != null && jsonObject.getInteger("code") == 0) {


@@ -229,6 +235,20 @@


            logger.debug("语音广播API调用");


        }


        Device device = storager.queryVideoDevice(deviceId);


      DeferredResult<ResponseEntity<String>> result = new DeferredResult<ResponseEntity<String>>(3 * 1000L);


        if (device == null) {


         resultHolder.put(DeferredResultHolder.CALLBACK_CMD_BROADCAST + deviceId, result);


         RequestMessage msg = new RequestMessage();


         msg.setId(DeferredResultHolder.CALLBACK_CMD_BROADCAST + deviceId);


         JSONObject json = new JSONObject();


         json.put("DeviceID", deviceId);


         json.put("CmdType", "Broadcast");


         json.put("Result", "Failed");


         json.put("Description", "Device 不存在");


         msg.setData(json);


         resultHolder.invokeResult(msg);


         return result;


      }


      cmder.audioBroadcastCmd(device, event -> {


         Response response = event.getResponse();


         RequestMessage msg = new RequestMessage();


@@ -241,7 +261,7 @@


         msg.setData(json);


         resultHolder.invokeResult(msg);


      });


        DeferredResult<ResponseEntity<String>> result = new DeferredResult<ResponseEntity<String>>(3 * 1000L);




      result.onTimeout(() -> {


         logger.warn(String.format("语音广播操作超时, 设备未返回应答指令"));


         RequestMessage msg = new RequestMessage();


@@ -258,5 +278,32 @@


      return result;


   }




   @ApiOperation("获取所有的ssrc")


   @GetMapping("/ssrc")


   public WVPResult<JSONObject> getSSRC() {


      if (logger.isDebugEnabled()) {


         logger.debug("获取所有的ssrc");


      }


      JSONArray objects = new JSONArray();


      for(Map.Entry<String, String> entry: streamSession.getSsrcMap().entrySet()) {


         System.out.println("Key = " + entry.getKey() + ", Value = " + entry.getValue());


         JSONObject jsonObject = new JSONObject();


         String[] keyArray = entry.getKey().split("_");


         jsonObject.put("deviceId", keyArray[0]);


         jsonObject.put("channelId", keyArray[1]);


         jsonObject.put("ssrc", entry.getValue());


         jsonObject.put("streamId", streamSession.getStreamIdMap().get(entry.getKey()));


         objects.add(jsonObject);


      }


      WVPResult<JSONObject> result = new WVPResult<>();


      result.setCode(0);


      result.setMsg("success");


      JSONObject jsonObject = new JSONObject();


      jsonObject.put("data", objects);


      jsonObject.put("count", objects.size());


      result.setData(jsonObject);


      return result;


   }




}