去除对redis key过期事件的使用；重构国标级联的注册保活

648540858

2022-08-31 2de4c322f6dc79ecfb120106af07e3335994657a

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommander.java

@@ -10,6 +10,7 @@
import com.genersoft.iot.vmp.gb28181.session.VideoStreamSessionManager;

import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommander;

import com.genersoft.iot.vmp.gb28181.transmit.cmd.SIPRequestHeaderProvider;

import com.genersoft.iot.vmp.gb28181.utils.HeaderUtils;

import com.genersoft.iot.vmp.media.zlm.dto.HookSubscribeFactory;

import com.genersoft.iot.vmp.media.zlm.dto.HookSubscribeForStreamChange;

import com.genersoft.iot.vmp.media.zlm.dto.HookType;

@@ -32,6 +33,7 @@
import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.context.annotation.DependsOn;

import org.springframework.stereotype.Component;

import org.springframework.util.ObjectUtils;

import org.springframework.util.StringUtils;



import javax.sip.*;

@@ -639,7 +641,7 @@
                  hookEvent.call(new InviteStreamInfo(mediaServerItem, json, callIdHeader.getCallId(), "rtp", ssrcInfo.getStream()));

                  subscribe.removeSubscribe(hookSubscribe);

                  hookSubscribe.getContent().put("regist", false);

                  hookSubscribe.getContent().put("schema", "rtmp");

                  hookSubscribe.getContent().put("schema", "rtsp");

                  // 添加流注销的订阅，注销了后向设备发送bye

                  subscribe.addSubscribe(hookSubscribe,

                        (MediaServerItem mediaServerItemForEnd, JSONObject jsonForEnd)->{

@@ -739,15 +741,7 @@
         // 增加Contact header

         Address concatAddress = sipFactory.createAddressFactory().createAddress(sipFactory.createAddressFactory().createSipURI(sipConfig.getId(), sipConfig.getIp()+":"+sipConfig.getPort()));

         byeRequest.addHeader(sipFactory.createHeaderFactory().createContactHeader(concatAddress));

         List<String> agentParam = new ArrayList<>();

         agentParam.add("wvp-pro");

         // TODO 添加版本信息以及日期

         UserAgentHeader userAgentHeader = null;

         try {

            userAgentHeader = sipFactory.createHeaderFactory().createUserAgentHeader(agentParam);

         } catch (ParseException e) {

            throw new RuntimeException(e);

         }

         UserAgentHeader userAgentHeader = HeaderUtils.createUserAgentHeader(sipFactory);

         byeRequest.addHeader(userAgentHeader);

         ClientTransaction clientTransaction = null;

         if("TCP".equals(protocol)) {

@@ -856,7 +850,7 @@
         cmdXml.append("<Control>\r\n");

         cmdXml.append("<CmdType>DeviceControl</CmdType>\r\n");

         cmdXml.append("<SN>" + (int)((Math.random()*9+1)*100000) + "</SN>\r\n");

         if (StringUtils.isEmpty(channelId)) {

         if (ObjectUtils.isEmpty(channelId)) {

            cmdXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

         } else {

            cmdXml.append("<DeviceID>" + channelId + "</DeviceID>\r\n");

@@ -959,16 +953,16 @@
         cmdXml.append("<SN>" + (int)((Math.random()*9+1)*100000) + "</SN>\r\n");

         cmdXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

         cmdXml.append("<AlarmCmd>ResetAlarm</AlarmCmd>\r\n");

         if (!StringUtils.isEmpty(alarmMethod) || !StringUtils.isEmpty(alarmType)) {

         if (!ObjectUtils.isEmpty(alarmMethod) || !ObjectUtils.isEmpty(alarmType)) {

            cmdXml.append("<Info>\r\n");

         }

         if (!StringUtils.isEmpty(alarmMethod)) {

         if (!ObjectUtils.isEmpty(alarmMethod)) {

            cmdXml.append("<AlarmMethod>" + alarmMethod + "</AlarmMethod>\r\n");

         }

         if (!StringUtils.isEmpty(alarmType)) {

         if (!ObjectUtils.isEmpty(alarmType)) {

            cmdXml.append("<AlarmType>" + alarmType + "</AlarmType>\r\n");

         }

         if (!StringUtils.isEmpty(alarmMethod) || !StringUtils.isEmpty(alarmType)) {

         if (!ObjectUtils.isEmpty(alarmMethod) || !ObjectUtils.isEmpty(alarmType)) {

            cmdXml.append("</Info>\r\n");

         }

         cmdXml.append("</Control>\r\n");

@@ -1002,7 +996,7 @@
         cmdXml.append("<Control>\r\n");

         cmdXml.append("<CmdType>DeviceControl</CmdType>\r\n");

         cmdXml.append("<SN>" + (int)((Math.random()*9+1)*100000) + "</SN>\r\n");

         if (StringUtils.isEmpty(channelId)) {

         if (ObjectUtils.isEmpty(channelId)) {

            cmdXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

         } else {

            cmdXml.append("<DeviceID>" + channelId + "</DeviceID>\r\n");

@@ -1041,7 +1035,7 @@
         cmdXml.append("<Control>\r\n");

         cmdXml.append("<CmdType>DeviceControl</CmdType>\r\n");

         cmdXml.append("<SN>" + (int)((Math.random()*9+1)*100000) + "</SN>\r\n");

         if (StringUtils.isEmpty(channelId)) {

         if (ObjectUtils.isEmpty(channelId)) {

            cmdXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

         } else {

            cmdXml.append("<DeviceID>" + channelId + "</DeviceID>\r\n");

@@ -1110,13 +1104,13 @@
         cmdXml.append("<Control>\r\n");

         cmdXml.append("<CmdType>DeviceConfig</CmdType>\r\n");

         cmdXml.append("<SN>" + (int)((Math.random()*9+1)*100000) + "</SN>\r\n");

         if (StringUtils.isEmpty(channelId)) {

         if (ObjectUtils.isEmpty(channelId)) {

            cmdXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

         } else {

            cmdXml.append("<DeviceID>" + channelId + "</DeviceID>\r\n");

         }

         cmdXml.append("<BasicParam>\r\n");

         if (!StringUtils.isEmpty(name)) {

         if (!ObjectUtils.isEmpty(name)) {

            cmdXml.append("<Name>" + name + "</Name>\r\n");

         }

         if (NumericUtil.isInteger(expiration)) {

@@ -1326,22 +1320,22 @@
         cmdXml.append("<CmdType>Alarm</CmdType>\r\n");

         cmdXml.append("<SN>" + (int)((Math.random()*9+1)*100000) + "</SN>\r\n");

         cmdXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

         if (!StringUtils.isEmpty(startPriority)) {

         if (!ObjectUtils.isEmpty(startPriority)) {

            cmdXml.append("<StartAlarmPriority>" + startPriority + "</StartAlarmPriority>\r\n");

         }

         if (!StringUtils.isEmpty(endPriority)) {

         if (!ObjectUtils.isEmpty(endPriority)) {

            cmdXml.append("<EndAlarmPriority>" + endPriority + "</EndAlarmPriority>\r\n");

         }

         if (!StringUtils.isEmpty(alarmMethod)) {

         if (!ObjectUtils.isEmpty(alarmMethod)) {

            cmdXml.append("<AlarmMethod>" + alarmMethod + "</AlarmMethod>\r\n");

         }

         if (!StringUtils.isEmpty(alarmType)) {

         if (!ObjectUtils.isEmpty(alarmType)) {

            cmdXml.append("<AlarmType>" + alarmType + "</AlarmType>\r\n");

         }

         if (!StringUtils.isEmpty(startTime)) {

         if (!ObjectUtils.isEmpty(startTime)) {

            cmdXml.append("<StartAlarmTime>" + startTime + "</StartAlarmTime>\r\n");

         }

         if (!StringUtils.isEmpty(endTime)) {

         if (!ObjectUtils.isEmpty(endTime)) {

            cmdXml.append("<EndAlarmTime>" + endTime + "</EndAlarmTime>\r\n");

         }

         cmdXml.append("</Query>\r\n");

@@ -1376,7 +1370,7 @@
         cmdXml.append("<Query>\r\n");

         cmdXml.append("<CmdType>ConfigDownload</CmdType>\r\n");

         cmdXml.append("<SN>" + (int)((Math.random()*9+1)*100000) + "</SN>\r\n");

         if (StringUtils.isEmpty(channelId)) {

         if (ObjectUtils.isEmpty(channelId)) {

            cmdXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

         } else {

            cmdXml.append("<DeviceID>" + channelId + "</DeviceID>\r\n");

@@ -1412,7 +1406,7 @@
         cmdXml.append("<Query>\r\n");

         cmdXml.append("<CmdType>PresetQuery</CmdType>\r\n");

         cmdXml.append("<SN>" + (int)((Math.random()*9+1)*100000) + "</SN>\r\n");

         if (StringUtils.isEmpty(channelId)) {

         if (ObjectUtils.isEmpty(channelId)) {

            cmdXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

         } else {

            cmdXml.append("<DeviceID>" + channelId + "</DeviceID>\r\n");

@@ -1543,22 +1537,22 @@
         cmdXml.append("<CmdType>Alarm</CmdType>\r\n");

         cmdXml.append("<SN>" + (int)((Math.random()*9+1)*100000) + "</SN>\r\n");

         cmdXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

         if (!StringUtils.isEmpty(startPriority)) {

         if (!ObjectUtils.isEmpty(startPriority)) {

            cmdXml.append("<StartAlarmPriority>" + startPriority + "</StartAlarmPriority>\r\n");

         }

         if (!StringUtils.isEmpty(endPriority)) {

         if (!ObjectUtils.isEmpty(endPriority)) {

            cmdXml.append("<EndAlarmPriority>" + endPriority + "</EndAlarmPriority>\r\n");

         }

         if (!StringUtils.isEmpty(alarmMethod)) {

         if (!ObjectUtils.isEmpty(alarmMethod)) {

            cmdXml.append("<AlarmMethod>" + alarmMethod + "</AlarmMethod>\r\n");

         }

         if (!StringUtils.isEmpty(alarmType)) {

         if (!ObjectUtils.isEmpty(alarmType)) {

            cmdXml.append("<AlarmType>" + alarmType + "</AlarmType>\r\n");

         }

         if (!StringUtils.isEmpty(startTime)) {

         if (!ObjectUtils.isEmpty(startTime)) {

            cmdXml.append("<StartAlarmTime>" + startTime + "</StartAlarmTime>\r\n");

         }

         if (!StringUtils.isEmpty(endTime)) {

         if (!ObjectUtils.isEmpty(endTime)) {

            cmdXml.append("<EndAlarmTime>" + endTime + "</EndAlarmTime>\r\n");

         }

         cmdXml.append("</Query>\r\n");

@@ -1639,7 +1633,7 @@
         dragXml.append("<Control>\r\n");

         dragXml.append("<CmdType>DeviceControl</CmdType>\r\n");

         dragXml.append("<SN>" + (int) ((Math.random() * 9 + 1) * 100000) + "</SN>\r\n");

         if (StringUtils.isEmpty(channelId)) {

         if (ObjectUtils.isEmpty(channelId)) {

            dragXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

         } else {

            dragXml.append("<DeviceID>" + channelId + "</DeviceID>\r\n");

@@ -1676,14 +1670,11 @@
         clientTransaction = udpSipProvider.getNewClientTransaction(request);

      }

      if (request.getHeader(UserAgentHeader.NAME) == null) {

         List<String> agentParam = new ArrayList<>();

         agentParam.add("wvp-pro");

         // TODO 添加版本信息以及日期

         UserAgentHeader userAgentHeader = null;

         try {

            userAgentHeader = sipFactory.createHeaderFactory().createUserAgentHeader(agentParam);

            userAgentHeader = HeaderUtils.createUserAgentHeader(sipFactory);

         } catch (ParseException e) {

            throw new RuntimeException(e);

            logger.error("添加UserAgentHeader失败", e);

         }

         request.addHeader(userAgentHeader);

      }