From 2ea1bc8ae165d89fe5fb27bff776ed80798a861a Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期五, 23 九月 2022 23:15:57 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/wvp-dialog' into wvp-dialog
---
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/PresetQueryResponseMessageHandler.java | 51 ++++++++++++++++++++++++---------------------------
1 files changed, 24 insertions(+), 27 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/PresetQueryResponseMessageHandler.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/PresetQueryResponseMessageHandler.java
index 0ed119e..366c7ad 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/PresetQueryResponseMessageHandler.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/PresetQueryResponseMessageHandler.java
@@ -17,6 +17,7 @@
import javax.sip.InvalidArgumentException;
import javax.sip.RequestEvent;
+import javax.sip.ServerTransaction;
import javax.sip.SipException;
import javax.sip.message.Response;
import java.text.ParseException;
@@ -49,12 +50,15 @@
@Override
public void handForDevice(RequestEvent evt, Device device, Element element) {
- Element rootElement = null;
+
+ ServerTransaction serverTransaction = getServerTransaction(evt);
+
try {
- rootElement = getRootElement(evt, device.getCharset());
+ Element rootElement = getRootElement(evt, device.getCharset());
+
if (rootElement == null) {
logger.warn("[ 璁惧棰勭疆浣嶆煡璇㈠簲绛� ] content cannot be null, {}", evt.getRequest());
- responseAck(evt, Response.BAD_REQUEST);
+ responseAck(serverTransaction, Response.BAD_REQUEST);
return;
}
Element presetListNumElement = rootElement.element("PresetList");
@@ -62,46 +66,39 @@
//璇ュ瓧娈靛彲鑳戒负閫氶亾鎴栧垯璁惧鐨刬d
String deviceId = getText(rootElement, "DeviceID");
String key = DeferredResultHolder.CALLBACK_CMD_PRESETQUERY + deviceId;
- if (snElement == null || presetListNumElement == null) {
- responseAck(evt, Response.BAD_REQUEST, "xml error");
+ if (snElement == null || presetListNumElement == null) {
+ responseAck(serverTransaction, Response.BAD_REQUEST, "xml error");
return;
}
int sumNum = Integer.parseInt(presetListNumElement.attributeValue("Num"));
List<PresetQuerySipReq> presetQuerySipReqList = new ArrayList<>();
if (sumNum > 0) {
- for (Iterator<Element> presetIterator = presetListNumElement.elementIterator();presetIterator.hasNext();){
+ for (Iterator<Element> presetIterator = presetListNumElement.elementIterator(); presetIterator.hasNext(); ) {
Element itemListElement = presetIterator.next();
PresetQuerySipReq presetQuerySipReq = new PresetQuerySipReq();
- for (Iterator<Element> itemListIterator = itemListElement.elementIterator();itemListIterator.hasNext();){
- // 閬嶅巻item
- Element itemOne = itemListIterator.next();
- String name = itemOne.getName();
- String textTrim = itemOne.getTextTrim();
- if("PresetID".equals(name)){
- presetQuerySipReq.setPresetId(textTrim);
- }else {
- presetQuerySipReq.setPresetName(textTrim);
- }
+ for (Iterator<Element> itemListIterator = itemListElement.elementIterator(); itemListIterator.hasNext(); ) {
+ // 閬嶅巻item
+ Element itemOne = itemListIterator.next();
+ String name = itemOne.getName();
+ String textTrim = itemOne.getTextTrim();
+ if ("PresetID".equalsIgnoreCase(name)) {
+ presetQuerySipReq.setPresetId(textTrim);
+ } else {
+ presetQuerySipReq.setPresetName(textTrim);
+ }
}
presetQuerySipReqList.add(presetQuerySipReq);
-
-
}
-
}
RequestMessage requestMessage = new RequestMessage();
requestMessage.setKey(key);
requestMessage.setData(presetQuerySipReqList);
deferredResultHolder.invokeAllResult(requestMessage);
- responseAck(evt, Response.OK);
+ responseAck(serverTransaction, Response.OK);
} catch (DocumentException e) {
- e.printStackTrace();
- } catch (InvalidArgumentException e) {
- e.printStackTrace();
- } catch (ParseException e) {
- e.printStackTrace();
- } catch (SipException e) {
- e.printStackTrace();
+ logger.error("[瑙ｆ瀽xml]澶辫触: ", e);
+ } catch (InvalidArgumentException | ParseException | SipException e) {
+ logger.error("[鍛戒护鍙戦�佸け璐 璁惧棰勭疆浣嶆煡璇㈠簲绛斿鐞�: {}", e.getMessage());
}
}
--
Gitblit v1.8.0