Shikong/gb28181-docking-platform-mocking
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

目录推送

Browse Source
This commit is contained in:
shikong 2023-09-13 14:08:46 +08:00
parent 2fa97835fe
commit 90b716e404
2 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/core/sip/message/processor/message/request/MessageRequestProcessor.java
View File

@ -57,13 +57,11 @@ public class MessageRequestProcessor implements MessageProcessor {
MessageDTO messageDto = XmlUtils.parse(content, MessageDTO.class, GB28181Constant.CHARSET); MessageDTO messageDto = XmlUtils.parse(content, MessageDTO.class, GB28181Constant.CHARSET);
log.debug("deviceId:{}, 接收到的消息 => {}", deviceId, messageDto); log.debug("deviceId:{}, 接收到的消息 => {}", deviceId, messageDto);
Response response = null;
if(messageDto.getCmdType().equalsIgnoreCase(CmdType.CATALOG)) { if(messageDto.getCmdType().equalsIgnoreCase(CmdType.CATALOG)) {
sender.send(senderIp, okResponse(request));
catalogCmdProcessor.process(request, content); catalogCmdProcessor.process(request, content);
} else { } else {
response = SipResponseBuilder.response(request, Response.NOT_IMPLEMENTED, ResponseStatus.NOT_IMPLEMENTED.getMessage()); Response response = SipResponseBuilder.response(request, Response.NOT_IMPLEMENTED, ResponseStatus.NOT_IMPLEMENTED.getMessage());
}
if(response != null){
sender.send(senderIp, response); sender.send(senderIp, response);
} }
} }

4
gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/core/sip/message/processor/message/request/catalog/CatalogCmdProcessor.java
View File

@ -50,13 +50,11 @@ public class CatalogCmdProcessor {
.sumNum(Long.valueOf(catalogDeviceListDTO.getNum())) .sumNum(Long.valueOf(catalogDeviceListDTO.getNum()))
.build(); .build();
long cSeq = request.getCSeq().getSeqNumber() + 1;
FromHeader fromHeader = request.getFromHeader(); FromHeader fromHeader = request.getFromHeader();
sender.sendRequest((provider, ip, port)->{ sender.sendRequest((provider, ip, port)->{
CallIdHeader callIdHeader = provider.getNewCallId(); CallIdHeader callIdHeader = provider.getNewCallId();
return SipRequestBuilder.createMessageRequest(mockingDevice, return SipRequestBuilder.createMessageRequest(mockingDevice,
ip, port, cSeq, XmlUtils.toXml(catalogResponseDTO), fromHeader.getTag(), callIdHeader); ip, port, 1, XmlUtils.toXml(catalogResponseDTO), fromHeader.getTag(), callIdHeader);
}); });
} }
} }