| | |
|---|
| | | 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.DateUtil;
|
|---|
| | | import com.genersoft.iot.vmp.utils.DateUtil;
|
|---|
| | | import com.genersoft.iot.vmp.gb28181.utils.NumericUtil;
|
|---|
| | | import com.genersoft.iot.vmp.media.zlm.ZLMHttpHookSubscribe;
|
|---|
| | | import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
|
|---|
| | |
|---|
| | | import javax.sip.message.Request;
|
|---|
| | | import java.lang.reflect.Field;
|
|---|
| | | import java.text.ParseException;
|
|---|
| | | import java.util.ArrayList;
|
|---|
| | | import java.util.HashSet;
|
|---|
| | | import java.util.List;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * @description:设备能力接口，用于定义设备的控制、查询能力
|
|---|
| | |
|---|
| | | public class SIPCommander implements ISIPCommander {
|
|---|
| | |
|
|---|
| | | private final Logger logger = LoggerFactory.getLogger(SIPCommander.class);
|
|---|
| | | |
|---|
| | |
|
|---|
| | | @Autowired
|
|---|
| | | private SipConfig sipConfig;
|
|---|
| | |
|
|---|
| | |
|---|
| | | } else if("UDP".equals(device.getTransport())) {
|
|---|
| | | 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);
|
|---|
| | | } catch (ParseException e) {
|
|---|
| | | throw new RuntimeException(e);
|
|---|
| | | }
|
|---|
| | | request.addHeader(userAgentHeader);
|
|---|
| | | }
|
|---|
| | | CallIdHeader callIdHeader = (CallIdHeader)request.getHeader(CallIdHeader.NAME);
|
|---|
| | | // 添加错误订阅
|
|---|
| | | if (errorEvent != null) {
|
|---|
