From a574ff094428decbdc35332d184cd0d210716a44 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期四, 22 九月 2022 16:56:20 +0800
Subject: [PATCH] 修复使用队列导致的问题
---
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/query/cmd/CatalogQueryMessageHandler.java | 22 +++++++++++++++++++++-
1 files changed, 21 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/query/cmd/CatalogQueryMessageHandler.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/query/cmd/CatalogQueryMessageHandler.java
index 7f6f817..cd98094 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/query/cmd/CatalogQueryMessageHandler.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/query/cmd/CatalogQueryMessageHandler.java
@@ -66,7 +66,7 @@
FromHeader fromHeader = (FromHeader) evt.getRequest().getHeader(FromHeader.NAME);
try {
// 鍥炲200 OK
- responseAck(evt, Response.OK);
+ responseAck(getServerTransaction(evt), Response.OK);
Element snElement = rootElement.element("SN");
String sn = snElement.getText();
// 鍑嗗鍥炲閫氶亾淇℃伅
@@ -78,6 +78,11 @@
List<DeviceChannel> allChannels = new ArrayList<>();
+ // 鍥炲骞冲彴
+// DeviceChannel deviceChannel = getChannelForPlatform(parentPlatform);
+// allChannels.add(deviceChannel);
+
+ // 鍥炲鐩綍
if (catalogs.size() > 0) {
allChannels.addAll(catalogs);
}
@@ -104,4 +109,19 @@
}
}
+
+ private DeviceChannel getChannelForPlatform(ParentPlatform platform) {
+ DeviceChannel deviceChannel = new DeviceChannel();
+
+ deviceChannel.setChannelId(platform.getDeviceGBId());
+ deviceChannel.setName(platform.getName());
+ deviceChannel.setManufacture("wvp-pro");
+ deviceChannel.setOwner("wvp-pro");
+ deviceChannel.setCivilCode(platform.getAdministrativeDivision());
+ deviceChannel.setAddress("wvp-pro");
+ deviceChannel.setRegisterWay(0);
+ deviceChannel.setSecrecy("0");
+
+ return deviceChannel;
+ }
}
--
Gitblit v1.8.0