Thirdparty
/
wvp-GB28181-pro
mirror of https://github.com/648540858/wvp-GB28181-pro
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

修复国标级联点播

pull/1642/head
648540858 2024-09-10 22:33:38 +08:00
parent 1b34787d3a
commit 09c668f017
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/PlayServiceImpl.java
View File

@ -669,11 +669,9 @@ public class PlayServiceImpl implements IPlayService {
if (streamInfo != null) { if (streamInfo != null) {
streamInfo.setStartTime(startTime); streamInfo.setStartTime(startTime);
streamInfo.setEndTime(endTime); streamInfo.setEndTime(endTime);
deviceChannelService.startPlay(channel.getId(), streamInfo.getStream());
InviteInfo inviteInfo = inviteStreamService.getInviteInfoByStream(InviteSessionType.PLAYBACK, mediaInfo.getStream()); InviteInfo inviteInfo = inviteStreamService.getInviteInfoByStream(InviteSessionType.PLAYBACK, mediaInfo.getStream());
if (inviteInfo != null) { if (inviteInfo != null) {
inviteInfo.setStatus(InviteSessionStatus.ok); inviteInfo.setStatus(InviteSessionStatus.ok);
inviteInfo.setStreamInfo(streamInfo); inviteInfo.setStreamInfo(streamInfo);
inviteStreamService.updateInviteInfo(inviteInfo); inviteStreamService.updateInviteInfo(inviteInfo);
} }

8
src/main/java/com/genersoft/iot/vmp/service/impl/SendRtpServerServiceImpl.java
View File

@ -52,8 +52,14 @@ public class SendRtpServerServiceImpl implements ISendRtpServerService {
if (localPort <= 0) { if (localPort <= 0) {
throw new PlayException(javax.sip.message.Response.SERVER_INTERNAL_ERROR, "server internal error"); throw new PlayException(javax.sip.message.Response.SERVER_INTERNAL_ERROR, "server internal error");
} }
return SendRtpInfo.getInstance(localPort, mediaServer, ip, port, ssrc, null, platformId, channelId, SendRtpInfo sendRtpInfo = SendRtpInfo.getInstance(localPort, mediaServer, ip, port, ssrc, null, platformId, channelId,
tcp, rtcp, userSetting.getServerId()); tcp, rtcp, userSetting.getServerId());
if (sendRtpInfo == null) {
return null;
}
sendRtpInfo.setApp(app);
sendRtpInfo.setStream(stream);
return sendRtpInfo;
} }
@Override @Override