| | |
|---|
| | | package com.genersoft.iot.vmp.gb28181.transmit.cmd.impl; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.alibaba.fastjson2.JSON; |
|---|
| | | import com.alibaba.fastjson2.JSONObject; |
|---|
| | | import com.genersoft.iot.vmp.gb28181.SipLayer; |
|---|
| | | import com.genersoft.iot.vmp.gb28181.bean.*; |
|---|
| | | import com.genersoft.iot.vmp.gb28181.event.SipSubscribe; |
|---|
| | |
|---|
| | | import com.genersoft.iot.vmp.service.IMediaServerService; |
|---|
| | | import com.genersoft.iot.vmp.service.bean.GPSMsgInfo; |
|---|
| | | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; |
|---|
| | | import gov.nist.javax.sip.SipProviderImpl; |
|---|
| | | import gov.nist.javax.sip.message.MessageFactoryImpl; |
|---|
| | | import gov.nist.javax.sip.message.SIPRequest; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.beans.factory.annotation.Qualifier; |
|---|
| | | import org.springframework.context.annotation.DependsOn; |
|---|
| | | import org.springframework.context.annotation.Lazy; |
|---|
| | | import org.springframework.lang.Nullable; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | import org.springframework.util.ObjectUtils; |
|---|
| | |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | logger.info("[发送报警通知] {}/{}->{},{}: {}", parentPlatform.getServerGBId(), deviceAlarm.getChannelId(), |
|---|
| | | deviceAlarm.getLongitude(), deviceAlarm.getLatitude(), JSONObject.toJSON(deviceAlarm)); |
|---|
| | | deviceAlarm.getLongitude(), deviceAlarm.getLatitude(), JSON.toJSONString(deviceAlarm)); |
|---|
| | | String characterSet = parentPlatform.getCharacterSet(); |
|---|
| | | StringBuffer deviceStatusXml = new StringBuffer(600); |
|---|
| | | deviceStatusXml.append("<?xml version=\"1.0\" encoding=\"" + characterSet + "\"?>\r\n"); |
|---|
| | |
|---|
| | | MediaServerItem mediaServerItem = mediaServerService.getOne(mediaServerId); |
|---|
| | | if (mediaServerItem != null) { |
|---|
| | | mediaServerService.releaseSsrc(mediaServerItem.getId(), sendRtpItem.getSsrc()); |
|---|
| | | zlmrtpServerFactory.closeRTPServer(mediaServerItem, sendRtpItem.getStreamId()); |
|---|
| | | zlmrtpServerFactory.closeRtpServer(mediaServerItem, sendRtpItem.getStreamId()); |
|---|
| | | } |
|---|
| | | SIPRequest byeRequest = headerProviderPlatformProvider.createByeRequest(parentPlatform, sendRtpItem); |
|---|
| | | if (byeRequest == null) { |
|---|
