|
|
@@ -230,7 +230,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
int zoomSpeed) {
|
|
|
try {
|
|
|
String cmdStr= cmdString(leftRight, upDown, inOut, moveSpeed, zoomSpeed);
|
|
|
- StringBuffer ptzXml = new StringBuffer(200);
|
|
|
+ StringBuilder ptzXml = new StringBuilder(200);
|
|
|
ptzXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
ptzXml.append("<Control>\r\n");
|
|
|
ptzXml.append("<CmdType>DeviceControl</CmdType>\r\n");
|
|
|
@@ -271,7 +271,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
try {
|
|
|
String cmdStr= frontEndCmdString(cmdCode, parameter1, parameter2, combineCode2);
|
|
|
logger.info("控制字符串:" + cmdStr);
|
|
|
- StringBuffer ptzXml = new StringBuffer(200);
|
|
|
+ StringBuilder ptzXml = new StringBuilder(200);
|
|
|
ptzXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
ptzXml.append("<Control>\r\n");
|
|
|
ptzXml.append("<CmdType>DeviceControl</CmdType>\r\n");
|
|
|
@@ -305,7 +305,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean fronEndCmd(Device device, String channelId, String cmdString) {
|
|
|
try {
|
|
|
- StringBuffer ptzXml = new StringBuffer(200);
|
|
|
+ StringBuilder ptzXml = new StringBuilder(200);
|
|
|
ptzXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
ptzXml.append("<Control>\r\n");
|
|
|
ptzXml.append("<CmdType>DeviceControl</CmdType>\r\n");
|
|
|
@@ -356,7 +356,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
subscribe.removeSubscribe(ZLMHttpHookSubscribe.HookType.on_stream_changed, subscribeKey);
|
|
|
});
|
|
|
//
|
|
|
- StringBuffer content = new StringBuffer(200);
|
|
|
+ StringBuilder content = new StringBuilder(200);
|
|
|
content.append("v=0\r\n");
|
|
|
content.append("o="+"00000"+" 0 0 IN IP4 "+ mediaServerItem.getSdpIp() +"\r\n");
|
|
|
content.append("s=Play\r\n");
|
|
|
@@ -409,7 +409,6 @@ public class SIPCommander implements ISIPCommander {
|
|
|
}
|
|
|
}
|
|
|
//验证1:获取码流
|
|
|
- //content.append("a="+MediaStream.getMe diaStreamA(dpi)+"\r\n");
|
|
|
content.append("y="+ssrcInfo.getSsrc()+"\r\n");//ssrc
|
|
|
//验证2:设置编码格式、分辨率、帧数、码率类型、码率大小、编码格式、码率大小
|
|
|
content.append("f="+MediaStream.getMediaStreamF(dpi)+"\r\n");
|
|
|
@@ -461,7 +460,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
subscribe.removeSubscribe(ZLMHttpHookSubscribe.HookType.on_stream_changed, subscribeKey);
|
|
|
});
|
|
|
|
|
|
- StringBuffer content = new StringBuffer(200);
|
|
|
+ StringBuilder content = new StringBuilder(200);
|
|
|
content.append("v=0\r\n");
|
|
|
content.append("o="+sipConfig.getId()+" 0 0 IN IP4 "+sipConfig.getIp()+"\r\n");
|
|
|
content.append("s=Playback\r\n");
|
|
|
@@ -563,7 +562,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
subscribe.removeSubscribe(ZLMHttpHookSubscribe.HookType.on_stream_changed, subscribeKey);
|
|
|
});
|
|
|
|
|
|
- StringBuffer content = new StringBuffer(200);
|
|
|
+ StringBuilder content = new StringBuilder(200);
|
|
|
content.append("v=0\r\n");
|
|
|
content.append("o="+sipConfig.getId()+" 0 0 IN IP4 "+sipConfig.getIp()+"\r\n");
|
|
|
content.append("s=Download\r\n");
|
|
|
@@ -673,7 +672,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
eventListenersField.setAccessible(true);
|
|
|
eventListenersField.set(dialog, new HashSet<>());
|
|
|
} catch (NoSuchFieldException | IllegalAccessException e) {
|
|
|
- e.printStackTrace();
|
|
|
+ logger.error("streamByeCmd异常:"+e);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -706,6 +705,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
}
|
|
|
} catch (SipException | ParseException e) {
|
|
|
e.printStackTrace();
|
|
|
+ logger.error("streamByeCmd异常:"+e);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@@ -729,7 +729,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean audioBroadcastCmd(Device device) {
|
|
|
try {
|
|
|
- StringBuffer broadcastXml = new StringBuffer(200);
|
|
|
+ StringBuilder broadcastXml = new StringBuilder(200);
|
|
|
broadcastXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
broadcastXml.append("<Notify>\r\n");
|
|
|
broadcastXml.append("<CmdType>Broadcast</CmdType>\r\n");
|
|
|
@@ -754,7 +754,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public void audioBroadcastCmd(Device device, SipSubscribe.Event errorEvent) {
|
|
|
try {
|
|
|
- StringBuffer broadcastXml = new StringBuffer(200);
|
|
|
+ StringBuilder broadcastXml = new StringBuilder(200);
|
|
|
broadcastXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
broadcastXml.append("<Notify>\r\n");
|
|
|
broadcastXml.append("<CmdType>Broadcast</CmdType>\r\n");
|
|
|
@@ -783,7 +783,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean recordCmd(Device device, String channelId, String recordCmdStr, SipSubscribe.Event errorEvent) {
|
|
|
try {
|
|
|
- StringBuffer cmdXml = new StringBuffer(200);
|
|
|
+ StringBuilder cmdXml = new StringBuilder(200);
|
|
|
cmdXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
cmdXml.append("<Control>\r\n");
|
|
|
cmdXml.append("<CmdType>DeviceControl</CmdType>\r\n");
|
|
|
@@ -815,7 +815,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean teleBootCmd(Device device) {
|
|
|
try {
|
|
|
- StringBuffer cmdXml = new StringBuffer(200);
|
|
|
+ StringBuilder cmdXml = new StringBuilder(200);
|
|
|
cmdXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
cmdXml.append("<Control>\r\n");
|
|
|
cmdXml.append("<CmdType>DeviceControl</CmdType>\r\n");
|
|
|
@@ -844,7 +844,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean guardCmd(Device device, String guardCmdStr, SipSubscribe.Event errorEvent) {
|
|
|
try {
|
|
|
- StringBuffer cmdXml = new StringBuffer(200);
|
|
|
+ StringBuilder cmdXml = new StringBuilder(200);
|
|
|
cmdXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
cmdXml.append("<Control>\r\n");
|
|
|
cmdXml.append("<CmdType>DeviceControl</CmdType>\r\n");
|
|
|
@@ -872,7 +872,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean alarmCmd(Device device, String alarmMethod, String alarmType, SipSubscribe.Event errorEvent) {
|
|
|
try {
|
|
|
- StringBuffer cmdXml = new StringBuffer(200);
|
|
|
+ StringBuilder cmdXml = new StringBuilder(200);
|
|
|
cmdXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
cmdXml.append("<Control>\r\n");
|
|
|
cmdXml.append("<CmdType>DeviceControl</CmdType>\r\n");
|
|
|
@@ -916,7 +916,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean iFrameCmd(Device device, String channelId) {
|
|
|
try {
|
|
|
- StringBuffer cmdXml = new StringBuffer(200);
|
|
|
+ StringBuilder cmdXml = new StringBuilder(200);
|
|
|
cmdXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
cmdXml.append("<Control>\r\n");
|
|
|
cmdXml.append("<CmdType>DeviceControl</CmdType>\r\n");
|
|
|
@@ -954,7 +954,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean homePositionCmd(Device device, String channelId, String enabled, String resetTime, String presetIndex, SipSubscribe.Event errorEvent) {
|
|
|
try {
|
|
|
- StringBuffer cmdXml = new StringBuffer(200);
|
|
|
+ StringBuilder cmdXml = new StringBuilder(200);
|
|
|
cmdXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
cmdXml.append("<Control>\r\n");
|
|
|
cmdXml.append("<CmdType>DeviceControl</CmdType>\r\n");
|
|
|
@@ -1004,7 +1004,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
*/
|
|
|
@Override
|
|
|
public boolean deviceConfigCmd(Device device) {
|
|
|
- // TODO Auto-generated method stub
|
|
|
+ // Auto-generated method stub
|
|
|
return false;
|
|
|
}
|
|
|
|
|
|
@@ -1022,7 +1022,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
public boolean deviceBasicConfigCmd(Device device, String channelId, String name, String expiration,
|
|
|
String heartBeatInterval, String heartBeatCount, SipSubscribe.Event errorEvent) {
|
|
|
try {
|
|
|
- StringBuffer cmdXml = new StringBuffer(200);
|
|
|
+ StringBuilder cmdXml = new StringBuilder(200);
|
|
|
cmdXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
cmdXml.append("<Control>\r\n");
|
|
|
cmdXml.append("<CmdType>DeviceConfig</CmdType>\r\n");
|
|
|
@@ -1076,7 +1076,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean deviceStatusQuery(Device device, SipSubscribe.Event errorEvent) {
|
|
|
try {
|
|
|
- StringBuffer catalogXml = new StringBuffer(200);
|
|
|
+ StringBuilder catalogXml = new StringBuilder(200);
|
|
|
catalogXml.append("<?xml version=\"1.0\" encoding=\"GB2312\"?>\r\n");
|
|
|
catalogXml.append("<Query>\r\n");
|
|
|
catalogXml.append("<CmdType>DeviceStatus</CmdType>\r\n");
|
|
|
@@ -1108,7 +1108,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean deviceInfoQuery(Device device) {
|
|
|
try {
|
|
|
- StringBuffer catalogXml = new StringBuffer(200);
|
|
|
+ StringBuilder catalogXml = new StringBuilder(200);
|
|
|
catalogXml.append("<?xml version=\"1.0\" encoding=\"GB2312\"?>\r\n");
|
|
|
catalogXml.append("<Query>\r\n");
|
|
|
catalogXml.append("<CmdType>DeviceInfo</CmdType>\r\n");
|
|
|
@@ -1142,7 +1142,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
// 清空通道
|
|
|
storager.cleanChannelsForDevice(device.getDeviceId());
|
|
|
try {
|
|
|
- StringBuffer catalogXml = new StringBuffer(200);
|
|
|
+ StringBuilder catalogXml = new StringBuilder(200);
|
|
|
catalogXml.append("<?xml version=\"1.0\" encoding=\"GB2312\"?>\r\n");
|
|
|
catalogXml.append("<Query>\r\n");
|
|
|
catalogXml.append("<CmdType>Catalog</CmdType>\r\n");
|
|
|
@@ -1176,7 +1176,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
public boolean recordInfoQuery(Device device, String channelId, String startTime, String endTime) {
|
|
|
|
|
|
try {
|
|
|
- StringBuffer recordInfoXml = new StringBuffer(200);
|
|
|
+ StringBuilder recordInfoXml = new StringBuilder(200);
|
|
|
recordInfoXml.append("<?xml version=\"1.0\" encoding=\"GB2312\"?>\r\n");
|
|
|
recordInfoXml.append("<Query>\r\n");
|
|
|
recordInfoXml.append("<CmdType>RecordInfo</CmdType>\r\n");
|
|
|
@@ -1221,7 +1221,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
public boolean alarmInfoQuery(Device device, String startPriority, String endPriority, String alarmMethod, String alarmType,
|
|
|
String startTime, String endTime, SipSubscribe.Event errorEvent) {
|
|
|
try {
|
|
|
- StringBuffer cmdXml = new StringBuffer(200);
|
|
|
+ StringBuilder cmdXml = new StringBuilder(200);
|
|
|
cmdXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
cmdXml.append("<Query>\r\n");
|
|
|
cmdXml.append("<CmdType>Alarm</CmdType>\r\n");
|
|
|
@@ -1271,7 +1271,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean deviceConfigQuery(Device device, String channelId, String configType, SipSubscribe.Event errorEvent) {
|
|
|
try {
|
|
|
- StringBuffer cmdXml = new StringBuffer(200);
|
|
|
+ StringBuilder cmdXml = new StringBuilder(200);
|
|
|
cmdXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
cmdXml.append("<Query>\r\n");
|
|
|
cmdXml.append("<CmdType>ConfigDownload</CmdType>\r\n");
|
|
|
@@ -1306,7 +1306,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean presetQuery(Device device, String channelId, SipSubscribe.Event errorEvent) {
|
|
|
try {
|
|
|
- StringBuffer cmdXml = new StringBuffer(200);
|
|
|
+ StringBuilder cmdXml = new StringBuilder(200);
|
|
|
cmdXml.append("<?xml version=\"1.0\" ?>\r\n");
|
|
|
cmdXml.append("<Query>\r\n");
|
|
|
cmdXml.append("<CmdType>PresetQuery</CmdType>\r\n");
|
|
|
@@ -1340,7 +1340,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
@Override
|
|
|
public boolean mobilePostitionQuery(Device device, SipSubscribe.Event errorEvent) {
|
|
|
try {
|
|
|
- StringBuffer mobilePostitionXml = new StringBuffer(200);
|
|
|
+ StringBuilder mobilePostitionXml = new StringBuilder(200);
|
|
|
mobilePostitionXml.append("<?xml version=\"1.0\" encoding=\"GB2312\"?>\r\n");
|
|
|
mobilePostitionXml.append("<Query>\r\n");
|
|
|
mobilePostitionXml.append("<CmdType>MobilePosition</CmdType>\r\n");
|
|
|
@@ -1375,7 +1375,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
*/
|
|
|
public boolean mobilePositionSubscribe(Device device, int expires, int interval) {
|
|
|
try {
|
|
|
- StringBuffer subscribePostitionXml = new StringBuffer(200);
|
|
|
+ StringBuilder subscribePostitionXml = new StringBuilder(200);
|
|
|
subscribePostitionXml.append("<?xml version=\"1.0\" encoding=\"GB2312\"?>\r\n");
|
|
|
subscribePostitionXml.append("<Query>\r\n");
|
|
|
subscribePostitionXml.append("<CmdType>MobilePosition</CmdType>\r\n");
|
|
|
@@ -1391,7 +1391,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
CallIdHeader callIdHeader = device.getTransport().equals("TCP") ? tcpSipProvider.getNewCallId()
|
|
|
: udpSipProvider.getNewCallId();
|
|
|
|
|
|
- Request request = headerProvider.createSubscribeRequest(device, subscribePostitionXml.toString(), "z9hG4bK-viaPos-" + tm, "fromTagPos" + tm, null, expires, "presence" ,callIdHeader); //Position;id=" + tm.substring(tm.length() - 4));
|
|
|
+ Request request = headerProvider.createSubscribeRequest(device, subscribePostitionXml.toString(), "z9hG4bK-viaPos-" + tm, "fromTagPos" + tm, null, expires, "presence" ,callIdHeader);
|
|
|
transmitRequest(device, request);
|
|
|
|
|
|
return true;
|
|
|
@@ -1417,7 +1417,7 @@ public class SIPCommander implements ISIPCommander {
|
|
|
*/
|
|
|
public boolean alarmSubscribe(Device device, int expires, String startPriority, String endPriority, String alarmMethod, String alarmType, String startTime, String endTime) {
|
|
|
try {
|
|
|
- StringBuffer cmdXml = new StringBuffer(200);
|
|
|
+ StringBuilder cmdXml = new StringBuilder(200);
|
|
|
cmdXml.append("<?xml version=\"1.0\" encoding=\"GB2312\"?>\r\n");
|
|
|
cmdXml.append("<Query>\r\n");
|
|
|
cmdXml.append("<CmdType>Alarm</CmdType>\r\n");
|
|
|
@@ -1486,7 +1486,9 @@ public class SIPCommander implements ISIPCommander {
|
|
|
sipSubscribe.addOkSubscribe(callIdHeader.getCallId(), okEvent);
|
|
|
}
|
|
|
|
|
|
- clientTransaction.sendRequest();
|
|
|
+ if(clientTransaction!=null){
|
|
|
+ clientTransaction.sendRequest();
|
|
|
+ }
|
|
|
return clientTransaction;
|
|
|
}
|
|
|
}
|