aunix/wvp-GB28181-pro
1
0
Fork 0
mirror of https://gitee.com/pan648540858/wvp-GB28181-pro.git synced 2026-05-24 14:07:50 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/master'

Browse Source
This commit is contained in:
lin 2025-06-05 09:41:17 +08:00
commit 6a6071973c
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/SubscribeRequestProcessor.java
View File

@ -69,6 +69,12 @@ public class SubscribeRequestProcessor extends SIPRequestProcessorParent impleme
responseAck(request, Response.BAD_REQUEST); responseAck(request, Response.BAD_REQUEST);
return; return;
} }
ExpiresHeader expires = request.getExpires();
if (expires == null) {
log.error("处理SUBSCRIBE请求 未获取到ExpiresHeader{}", evt.getRequest());
responseAck(request, Response.BAD_REQUEST, "missing expires");
return;
}
String platformId = SipUtils.getUserIdFromFromHeader(request); String platformId = SipUtils.getUserIdFromFromHeader(request);
String cmd = XmlUtil.getText(rootElement, "CmdType"); String cmd = XmlUtil.getText(rootElement, "CmdType");
log.info("[收到订阅请求] 类型： {}, 来自： {}", cmd, platformId); log.info("[收到订阅请求] 类型： {}, 来自： {}", cmd, platformId);
@ -181,7 +187,6 @@ public class SubscribeRequestProcessor extends SIPRequestProcessorParent impleme
.append("<Result>OK</Result>\r\n") .append("<Result>OK</Result>\r\n")
.append("</Response>\r\n"); .append("</Response>\r\n");
try { try {
int expires = request.getExpires().getExpires(); int expires = request.getExpires().getExpires();
Platform parentPlatform = platformService.queryPlatformByServerGBId(platformId); Platform parentPlatform = platformService.queryPlatformByServerGBId(platformId);