|  |  | 
 |  |  | package com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.response.cmd; | 
 |  |  |  | 
 |  |  | import com.alibaba.fastjson.JSONObject; | 
 |  |  | import com.alibaba.fastjson2.JSONObject; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.bean.Device; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.transmit.callback.DeferredResultHolder; | 
 |  |  | 
 |  |  | import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.IMessageHandler; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.response.ResponseMessageHandler; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.utils.XmlUtil; | 
 |  |  | import gov.nist.javax.sip.message.SIPRequest; | 
 |  |  | import org.dom4j.Element; | 
 |  |  | import org.slf4j.Logger; | 
 |  |  | import org.slf4j.LoggerFactory; | 
 |  |  | 
 |  |  |     public void handForDevice(RequestEvent evt, Device device, Element element) { | 
 |  |  |         // 此处是对本平台发出DeviceControl指令的应答 | 
 |  |  |         try { | 
 |  |  |             responseAck(evt, Response.OK); | 
 |  |  |             JSONObject json = new JSONObject(); | 
 |  |  |             String channelId = getText(element, "DeviceID"); | 
 |  |  |             XmlUtil.node2Json(element, json); | 
 |  |  |             if (logger.isDebugEnabled()) { | 
 |  |  |                 logger.debug(json.toJSONString()); | 
 |  |  |             } | 
 |  |  |             RequestMessage msg = new RequestMessage(); | 
 |  |  |             String key = DeferredResultHolder.CALLBACK_CMD_DEVICECONTROL +  device.getDeviceId() + channelId; | 
 |  |  |             msg.setKey(key); | 
 |  |  |             msg.setData(json); | 
 |  |  |             deferredResultHolder.invokeAllResult(msg); | 
 |  |  |         } catch (SipException e) { | 
 |  |  |             e.printStackTrace(); | 
 |  |  |         } catch (InvalidArgumentException e) { | 
 |  |  |             e.printStackTrace(); | 
 |  |  |         } catch (ParseException e) { | 
 |  |  |             e.printStackTrace(); | 
 |  |  |              responseAck((SIPRequest) evt.getRequest(), Response.OK); | 
 |  |  |         } catch (SipException | InvalidArgumentException | ParseException e) { | 
 |  |  |             logger.error("[命令发送失败] 国标级联 设备控制: {}", e.getMessage()); | 
 |  |  |         } | 
 |  |  |         JSONObject json = new JSONObject(); | 
 |  |  |         String channelId = getText(element, "DeviceID"); | 
 |  |  |         XmlUtil.node2Json(element, json); | 
 |  |  |         if (logger.isDebugEnabled()) { | 
 |  |  |             logger.debug(json.toJSONString()); | 
 |  |  |         } | 
 |  |  |         RequestMessage msg = new RequestMessage(); | 
 |  |  |         String key = DeferredResultHolder.CALLBACK_CMD_DEVICECONTROL +  device.getDeviceId() + channelId; | 
 |  |  |         msg.setKey(key); | 
 |  |  |         msg.setData(json); | 
 |  |  |         deferredResultHolder.invokeAllResult(msg); | 
 |  |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override |