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

manscdp 添加 MessageDTO 用于基础信息解析

Browse Source
This commit is contained in:
shikong 2023-09-25 01:45:42 +08:00
parent b072ef7c58
commit d7848cf694
2 changed files with 36 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
gb28181-sip/src/main/java/cn/skcks/docking/gb28181/sip/manscdp/MessageDTO.java Normal file
View File

@ -0,0 +1,21 @@
package cn.skcks.docking.gb28181.sip.manscdp;
import com.fasterxml.jackson.dataformat.xml.annotation.JacksonXmlProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
@Builder
@NoArgsConstructor
@AllArgsConstructor
@Data
public class MessageDTO {
private String cmdType;
@JacksonXmlProperty(localName = "SN")
private String sn;
@JacksonXmlProperty(localName = "DeviceID")
private String deviceId;
}

26
gb28181-sip/src/test/java/cn/skcks/docking/gb28181/sip/manscdp/MANSCDPTest.java
View File

@ -31,7 +31,7 @@ public class MANSCDPTest {
public static String sn = String.valueOf(1); public static String sn = String.valueOf(1);
@Test @Test
public void keepalive(){ public void keepalive() {
KeepaliveNotifyDTO keepaliveNotifyDTO = KeepaliveNotifyDTO.builder() KeepaliveNotifyDTO keepaliveNotifyDTO = KeepaliveNotifyDTO.builder()
.deviceId(deviceId) .deviceId(deviceId)
.sn(sn) .sn(sn)
@ -41,11 +41,11 @@ public class MANSCDPTest {
.data(keepaliveNotifyDTO) .data(keepaliveNotifyDTO)
.build(); .build();
log.info("\n{}",MANSCDPUtils.toXml(xmlBuilder)); log.info("\n{}", MANSCDPUtils.toXml(xmlBuilder));
} }
@Test @Test
public void catalog(){ public void catalog() {
// 创建 目录查询 请求 // 创建 目录查询 请求
CatalogQueryDTO catalogQueryDTO = CatalogQueryDTO.builder() CatalogQueryDTO catalogQueryDTO = CatalogQueryDTO.builder()
@ -59,7 +59,7 @@ public class MANSCDPTest {
log.info("\n{}", serialize); log.info("\n{}", serialize);
CatalogQueryDTO queryDTO = MANSCDPUtils.parse(serialize, CatalogQueryDTO.class); CatalogQueryDTO queryDTO = MANSCDPUtils.parse(serialize, CatalogQueryDTO.class);
log.info("\n{}",queryDTO); log.info("\n{}", queryDTO);
// 创建 目录 查询响应 // 创建 目录 查询响应
CatalogItemDTO catalogItemDTO = CatalogItemDTO.builder() CatalogItemDTO catalogItemDTO = CatalogItemDTO.builder()
@ -84,7 +84,7 @@ public class MANSCDPTest {
serialize = MANSCDPUtils.toXml(response); serialize = MANSCDPUtils.toXml(response);
log.info("\n{}", serialize); log.info("\n{}", serialize);
CatalogResponseDTO responseDTO = MANSCDPUtils.parse(serialize, CatalogResponseDTO.class); CatalogResponseDTO responseDTO = MANSCDPUtils.parse(serialize, CatalogResponseDTO.class);
log.info("{}",responseDTO); log.info("{}", responseDTO);
// UTF8 编码 // UTF8 编码
response = MANSCDPUtils.XMLBuilder.<CatalogResponseDTO>builder() response = MANSCDPUtils.XMLBuilder.<CatalogResponseDTO>builder()
.encoding(StandardCharsets.UTF_8.name()) .encoding(StandardCharsets.UTF_8.name())
@ -93,11 +93,11 @@ public class MANSCDPTest {
serialize = MANSCDPUtils.toXml(response); serialize = MANSCDPUtils.toXml(response);
log.info("\n{}", serialize); log.info("\n{}", serialize);
responseDTO = MANSCDPUtils.parse(serialize, CatalogResponseDTO.class); responseDTO = MANSCDPUtils.parse(serialize, CatalogResponseDTO.class);
log.info("{}",responseDTO); log.info("{}", responseDTO);
} }
@Test @Test
public void deviceInfo(){ public void deviceInfo() {
DeviceInfoRequestDTO deviceInfoRequestDTO = DeviceInfoRequestDTO.builder() DeviceInfoRequestDTO deviceInfoRequestDTO = DeviceInfoRequestDTO.builder()
.deviceId(deviceId) .deviceId(deviceId)
.sn(sn) .sn(sn)
@ -123,7 +123,7 @@ public class MANSCDPTest {
} }
@Test @Test
public void recordInfo(){ public void recordInfo() {
RecordInfoRequestDTO recordInfoRequestDTO = RecordInfoRequestDTO.builder() RecordInfoRequestDTO recordInfoRequestDTO = RecordInfoRequestDTO.builder()
.type("all") .type("all")
.startTime(new Date()) .startTime(new Date())
@ -132,7 +132,7 @@ public class MANSCDPTest {
.sn(sn) .sn(sn)
.build(); .build();
MANSCDPUtils.XMLBuilder<RecordInfoRequestDTO> recordInfoRequestDTOXMLBuilder = MANSCDPUtils.build(recordInfoRequestDTO); MANSCDPUtils.XMLBuilder<RecordInfoRequestDTO> recordInfoRequestDTOXMLBuilder = MANSCDPUtils.build(recordInfoRequestDTO);
log.info("\n{}",MANSCDPUtils.toXml(recordInfoRequestDTOXMLBuilder)); log.info("\n{}", MANSCDPUtils.toXml(recordInfoRequestDTOXMLBuilder));
RecordInfoItemDTO recordInfoItemDTO = RecordInfoItemDTO.builder() RecordInfoItemDTO recordInfoItemDTO = RecordInfoItemDTO.builder()
@ -155,7 +155,11 @@ public class MANSCDPTest {
.recordList(recordInfoItemDTOList) .recordList(recordInfoItemDTOList)
.build()) .build())
.build(); .build();
MANSCDPUtils.XMLBuilder<RecordInfoResponseDTO> recordInfoResponseDTOXMLBuilder = MANSCDPUtils.build(recordInfoResponseDTO,"UTF8"); MANSCDPUtils.XMLBuilder<RecordInfoResponseDTO> recordInfoResponseDTOXMLBuilder = MANSCDPUtils.build(recordInfoResponseDTO, "UTF8");
log.info("\n{}", MANSCDPUtils.toXml(recordInfoResponseDTOXMLBuilder)); String xml = MANSCDPUtils.toXml(recordInfoResponseDTOXMLBuilder);
log.info("\n{}", xml);
MessageDTO messageDTO = MANSCDPUtils.parse(xml.getBytes(), MessageDTO.class);
log.info("{}", messageDTO);
} }
} }