搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
648540858
2022-05-16 39efda779fcd5d613870e9024cda69da28e571b2 
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/InviteRequestProcessor.java


@@ -29,6 +29,7 @@


import com.genersoft.iot.vmp.service.bean.SSRCInfo;


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


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


import com.genersoft.iot.vmp.utils.DateUtil;


import com.genersoft.iot.vmp.utils.SerializeUtils;


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


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


@@ -49,7 +50,7 @@


import javax.sip.message.Request;


import javax.sip.message.Response;


import java.text.ParseException;


import java.text.SimpleDateFormat;


import java.time.Instant;


import java.util.Date;


import java.util.List;


import java.util.Vector;


@@ -201,16 +202,16 @@




            Long startTime = null;


            Long stopTime = null;


            Date start = null;


            Date end = null;


            Instant start = null;


            Instant end = null;


            if (sdp.getTimeDescriptions(false) != null && sdp.getTimeDescriptions(false).size() > 0) {


               TimeDescriptionImpl timeDescription = (TimeDescriptionImpl)(sdp.getTimeDescriptions(false).get(0));


               TimeField startTimeFiled = (TimeField)timeDescription.getTime();


               startTime = startTimeFiled.getStartTime();


               stopTime = startTimeFiled.getStopTime();




               start = new Date(startTime*1000);


               end = new Date(stopTime*1000);


               start = Instant.ofEpochMilli(startTime*1000);


               end = Instant.ofEpochMilli(stopTime*1000);


            }


            //  获取支持的格式


            Vector mediaDescriptions = sdp.getMediaDescriptions(true);


@@ -352,13 +353,12 @@


               sendRtpItem.setApp("rtp");


               if ("Playback".equals(sessionName)) {


                  sendRtpItem.setPlayType(InviteStreamType.PLAYBACK);


                  SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServerItem, null, true);


                  SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServerItem, null, true, true);


                  sendRtpItem.setStreamId(ssrcInfo.getStream());


                  // 写入redis， 超时时回复


                  redisCatchStorage.updateSendRTPSever(sendRtpItem);


                  SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");


                  playService.playBack(mediaServerItem, ssrcInfo, device.getDeviceId(), channelId, format.format(start),


                        format.format(end), null, result -> {


                  playService.playBack(mediaServerItem, ssrcInfo, device.getDeviceId(), channelId, DateUtil.formatter.format(start),


                        DateUtil.formatter.format(end), null, result -> {


                        if (result.getCode() != 0){


                           logger.warn("录像回放失败");


                           if (result.getEvent() != null) {


@@ -394,7 +394,7 @@


                     if (mediaServerItem.isRtpEnable()) {


                        streamId = String.format("%s_%s", device.getDeviceId(), channelId);


                     }


                     SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServerItem, streamId, true);


                     SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServerItem, streamId, true, false);


                     sendRtpItem.setStreamId(ssrcInfo.getStream());


                     // 写入redis， 超时时回复


                     redisCatchStorage.updateSendRTPSever(sendRtpItem);


@@ -713,6 +713,7 @@


            String waiteStreamTimeoutTaskKey = "waite-stream-" + device.getDeviceId() + audioBroadcastCatch.getChannelId();


            dynamicTask.startDelay(waiteStreamTimeoutTaskKey, ()->{


               logger.info("等待推流超时: {}/{}", app, stream);


               subscribe.removeSubscribe(ZLMHttpHookSubscribe.HookType.on_stream_changed, subscribeKey);


               playService.stopAudioBroadcast(device.getDeviceId(), audioBroadcastCatch.getChannelId());


               // 发送bye


               try {


@@ -728,35 +729,42 @@




            subscribe.addSubscribe(ZLMHttpHookSubscribe.HookType.on_stream_changed, subscribeKey,


                  (MediaServerItem mediaServerItemInUse, JSONObject json)->{


                     sendRtpItem.setStatus(2);


                     dynamicTask.stop(waiteStreamTimeoutTaskKey);


                     redisCatchStorage.updateSendRTPSever(sendRtpItem);


                     StringBuffer content = new StringBuffer(200);


                     content.append("v=0\r\n");


                     content.append("o="+ audioBroadcastCatch.getChannelId() +" 0 0 IN IP4 "+mediaServerItem.getSdpIp()+"\r\n");


                     content.append("s=Play\r\n");


                     content.append("c=IN IP4 "+mediaServerItem.getSdpIp()+"\r\n");


                     content.append("t=0 0\r\n");


                     content.append("m=video "+ sendRtpItem.getLocalPort()+" RTP/AVP 8\r\n");


                     content.append("a=sendonly\r\n");


                     content.append("a=rtpmap:8 PCMA/8000\r\n");


                     content.append("y="+ finalSsrc + "\r\n");


                     content.append("f=v/////a/1/8/1\r\n");


               logger.info("收到语音对讲推流");


               try {


                  sendRtpItem.setStatus(2);


                  redisCatchStorage.updateSendRTPSever(sendRtpItem);


                  StringBuffer content = new StringBuffer(200);


                  content.append("v=0\r\n");


                  content.append("o="+ config.getId() +" "+ sdp.getOrigin().getSessionId() +" " + sdp.getOrigin().getSessionVersion()  + " IN IP4 "+mediaServerItem.getSdpIp()+"\r\n");


                  content.append("s=Play\r\n");


                  content.append("c=IN IP4 "+mediaServerItem.getSdpIp()+"\r\n");


                  content.append("t=0 0\r\n");


                  content.append("m=audio "+ sendRtpItem.getLocalPort()+" RTP/AVP 8\r\n");


                  content.append("a=sendonly\r\n");


                  content.append("a=rtpmap:8 PCMA/8000\r\n");


                  content.append("y="+ finalSsrc + "\r\n");


                  content.append("f=v/////a/1/8/1\r\n");




                     ParentPlatform parentPlatform = new ParentPlatform();


                     parentPlatform.setServerIP(device.getIp());


                     parentPlatform.setServerPort(device.getPort());


                     parentPlatform.setServerGBId(device.getDeviceId());


                     try {


                        responseSdpAck(evt, content.toString(), parentPlatform);


                     } catch (SipException e) {


                        throw new RuntimeException(e);


                     } catch (InvalidArgumentException e) {


                        throw new RuntimeException(e);


                     } catch (ParseException e) {


                        throw new RuntimeException(e);


                     }


                  });


                  ParentPlatform parentPlatform = new ParentPlatform();


                  parentPlatform.setServerIP(device.getIp());


                  parentPlatform.setServerPort(device.getPort());


                  parentPlatform.setServerGBId(device.getDeviceId());




                  responseSdpAck(evt, content.toString(), parentPlatform);


                  Dialog dialog = evt.getDialog();


                  audioBroadcastCatch.setDialog((SIPDialog) dialog);


                  audioBroadcastCatch.setRequest((SIPRequest) request);


                  audioBroadcastManager.update(audioBroadcastCatch);


               } catch (SipException e) {


                  throw new RuntimeException(e);


               } catch (InvalidArgumentException e) {


                  throw new RuntimeException(e);


               } catch (ParseException e) {


                  throw new RuntimeException(e);


               } catch (SdpParseException e) {


                  throw new RuntimeException(e);


               }


            });


         }


         String key = DeferredResultHolder.CALLBACK_CMD_BROADCAST + device.getDeviceId();


         WVPResult<AudioBroadcastResult> wvpResult = new WVPResult<>();