Compare commits

...

5 Commits

Author SHA1 Message Date
648540858
d02acda243
Merge pull request #1990 from kairlec/master
fix: remove conflicting files `AblUrls.java` on Windows
2025-10-15 21:27:19 +08:00
Kairlec
5bafc3e389
fix: AblUrls.java file removed 2025-10-10 10:57:20 +08:00
Kairlec
99fd07d58d
fix: remove conflicting files AblUrls.java on Windows 2025-10-10 10:42:59 +08:00
648540858
96cc9cc7b1
Merge pull request #1981 from guoshaoqiu/master
[后端] 修复目录设置/位置移动的订阅逻辑:订阅周期必须 ≥30 秒,取消订阅时允许周期设为 0
2025-09-24 10:29:00 +08:00
guoshq
e91e96077a [后端] 修复目录设置/位置移动的订阅逻辑:订阅周期必须 ≥30 秒,取消订阅时允许周期设为 0 2025-09-17 13:38:23 +08:00
4 changed files with 18 additions and 62 deletions

View File

@ -1203,7 +1203,13 @@ public class SIPCommander implements ISIPCommander {
} else {
callIdHeader = sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport());
}
SIPRequest request = (SIPRequest) headerProvider.createSubscribeRequest(device, subscribePostitionXml.toString(), sipTransactionInfo, device.getSubscribeCycleForMobilePosition(), "presence",callIdHeader); //Position;id=" + tm.substring(tm.length() - 4));
int subscribeCycleForMobilePosition = device.getSubscribeCycleForMobilePosition();
if (subscribeCycleForMobilePosition > 0) {
// 移动位置订阅有效期不小于 30
subscribeCycleForMobilePosition = Math.max(subscribeCycleForMobilePosition, 30);
}
SIPRequest request = (SIPRequest) headerProvider.createSubscribeRequest(device, subscribePostitionXml.toString(), sipTransactionInfo, subscribeCycleForMobilePosition, "presence",callIdHeader); //Position;id=" + tm.substring(tm.length() - 4));
sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request, errorEvent, okEvent);
return request;
@ -1275,8 +1281,13 @@ public class SIPCommander implements ISIPCommander {
callIdHeader = sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport());
}
int subscribeCycleForCatalog = device.getSubscribeCycleForCatalog();
if (subscribeCycleForCatalog > 0) {
// 目录订阅有效期不小于 30
subscribeCycleForCatalog = Math.max(subscribeCycleForCatalog, 30);
}
// 有效时间默认为60秒以上
SIPRequest request = (SIPRequest) headerProvider.createSubscribeRequest(device, cmdXml.toString(), sipTransactionInfo, device.getSubscribeCycleForCatalog(), "Catalog",
SIPRequest request = (SIPRequest) headerProvider.createSubscribeRequest(device, cmdXml.toString(), sipTransactionInfo, subscribeCycleForCatalog, "Catalog",
callIdHeader);
sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request, errorEvent, okEvent);
return request;

View File

@ -17,5 +17,8 @@ public class ABLUrls {
@JSONField(name = "http-mp4")
private String httpMp4;
@JSONField(name = "http-hls")
private String httpHls;
private String download;
}

View File

@ -1,58 +0,0 @@
package com.genersoft.iot.vmp.media.abl.bean;
public class AblUrls {
private String rtsp;
private String rtmp;
private String httpFlv;
private String wsFlv;
private String httpMp4;
private String httpHls;
public String getRtsp() {
return rtsp;
}
public void setRtsp(String rtsp) {
this.rtsp = rtsp;
}
public String getRtmp() {
return rtmp;
}
public void setRtmp(String rtmp) {
this.rtmp = rtmp;
}
public String getHttpFlv() {
return httpFlv;
}
public void setHttpFlv(String httpFlv) {
this.httpFlv = httpFlv;
}
public String getWsFlv() {
return wsFlv;
}
public void setWsFlv(String wsFlv) {
this.wsFlv = wsFlv;
}
public String getHttpMp4() {
return httpMp4;
}
public void setHttpMp4(String httpMp4) {
this.httpMp4 = httpMp4;
}
public String getHttpHls() {
return httpHls;
}
public void setHttpHls(String httpHls) {
this.httpHls = httpHls;
}
}

View File

@ -1,6 +1,6 @@
package com.genersoft.iot.vmp.media.abl.bean.hook;
import com.genersoft.iot.vmp.media.abl.bean.AblUrls;
import com.genersoft.iot.vmp.media.abl.bean.ABLUrls;
import lombok.Getter;
import lombok.Setter;
@ -108,5 +108,5 @@ public class OnStreamArriveABLHookParam extends ABLHookParam{
private Integer audioBitrate;
private AblUrls url;
private ABLUrls url;
}