src/main/java/com/genersoft/iot/vmp/gb28181/transmit/request/impl/MessageRequestProcessor.java
@@ -5,9 +5,11 @@
import java.util.*;
import javax.sip.*;
import javax.sip.address.Address;
import javax.sip.address.SipURI;
import javax.sip.header.FromHeader;
import javax.sip.header.Header;
import javax.sip.header.HeaderAddress;
import javax.sip.header.ToHeader;
import javax.sip.message.Request;
@@ -34,6 +36,7 @@
import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
import com.genersoft.iot.vmp.storager.IVideoManagerStorager;
import com.genersoft.iot.vmp.utils.GpsUtil;
import com.genersoft.iot.vmp.utils.SipUtils;
import com.genersoft.iot.vmp.utils.SpringBeanFactory;
import com.genersoft.iot.vmp.utils.redis.RedisUtil;
import com.genersoft.iot.vmp.vmanager.gb28181.platform.bean.ChannelReduce;
@@ -166,18 +169,21 @@
    */
   private void processMessageMobilePosition(RequestEvent evt) {
      try {
         Element rootElement = getRootElement(evt);
         MobilePosition mobilePosition = new MobilePosition();
         Element deviceIdElement = rootElement.element("DeviceID");
         String deviceId = deviceIdElement.getTextTrim().toString();
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         Device device = storager.queryVideoDevice(deviceId);
         if (device != null) {
            rootElement = getRootElement(evt, device.getCharset());
            if (!StringUtils.isEmpty(device.getName())) {
               mobilePosition.setDeviceName(device.getName());
            }
         if (device == null) {
            logger.warn("处理MobilePosition移动位置消息时未找到设备信息");
            response404Ack(evt);
            return;
         }
         mobilePosition.setDeviceId(XmlUtil.getText(rootElement, "DeviceID"));
         Element rootElement = getRootElement(evt, device.getCharset());
         MobilePosition mobilePosition = new MobilePosition();
         if (!StringUtils.isEmpty(device.getName())) {
            mobilePosition.setDeviceName(device.getName());
         }
         mobilePosition.setDeviceId(deviceId);
         mobilePosition.setChannelId(XmlUtil.getText(rootElement, "DeviceID"));
         mobilePosition.setTime(XmlUtil.getText(rootElement, "Time"));
         mobilePosition.setLongitude(Double.parseDouble(XmlUtil.getText(rootElement, "Longitude")));
         mobilePosition.setLatitude(Double.parseDouble(XmlUtil.getText(rootElement, "Latitude")));
@@ -221,11 +227,17 @@
    */
   private void processMessageDeviceStatus(RequestEvent evt) {
      try {
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         Device device = storager.queryVideoDevice(deviceId);
         if (device == null) {
            logger.warn("处理DeviceStatus设备状态Message时未找到设备信息");
            response404Ack(evt);
            return;
         }
         Element rootElement = getRootElement(evt);
         String name = rootElement.getName();
         Element deviceIdElement = rootElement.element("DeviceID");
         String deviceId = deviceIdElement.getText();
         Device device = storager.queryVideoDevice(deviceId);
         String channelId = deviceIdElement.getText();
         if (name.equalsIgnoreCase("Query")) { // 区分是Response——查询响应,还是Query——查询请求
            logger.info("接收到DeviceStatus查询消息");
            FromHeader fromHeader = (FromHeader) evt.getRequest().getHeader(FromHeader.NAME);
@@ -252,10 +264,9 @@
                  logger.debug(json.toJSONString());
               }
               RequestMessage msg = new RequestMessage();
               msg.setDeviceId(deviceId);
               msg.setType(DeferredResultHolder.CALLBACK_CMD_DEVICESTATUS);
               msg.setKey(DeferredResultHolder.CALLBACK_CMD_DEVICESTATUS + deviceId + channelId);
               msg.setData(json);
               deferredResultHolder.invokeResult(msg);
               deferredResultHolder.invokeAllResult(msg);
               if (offLineDetector.isOnline(deviceId)) {
                  publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_MESSAGE);
@@ -276,8 +287,15 @@
    */
   private void processMessageDeviceControl(RequestEvent evt) {
      try {
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         Device device = storager.queryVideoDevice(deviceId);
         if (device == null) {
            logger.warn("处理DeviceControl设备状态Message未找到设备信息");
            response404Ack(evt);
            return;
         }
         Element rootElement = getRootElement(evt);
         String deviceId = XmlUtil.getText(rootElement, "DeviceID");
         String channelId = XmlUtil.getText(rootElement, "DeviceID");
         //String result = XmlUtil.getText(rootElement, "Result");
         // 回复200 OK
         responseAck(evt);
@@ -289,10 +307,10 @@
               logger.debug(json.toJSONString());
            }
            RequestMessage msg = new RequestMessage();
            msg.setDeviceId(deviceId);
            msg.setType(DeferredResultHolder.CALLBACK_CMD_DEVICECONTROL);
            String key = DeferredResultHolder.CALLBACK_CMD_DEVICECONTROL +  deviceId + channelId;
            msg.setKey(key);
            msg.setData(json);
            deferredResultHolder.invokeResult(msg);
            deferredResultHolder.invokeAllResult(msg);
         } else {
            // 此处是上级发出的DeviceControl指令
            String platformId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(FromHeader.NAME)).getAddress().getURI()).getUser();
@@ -338,8 +356,8 @@
            // 云台/前端控制命令
            if (!StringUtils.isEmpty(XmlUtil.getText(rootElement,"PTZCmd")) && !deviceId.equals(targetGBId)) {
               String cmdString = XmlUtil.getText(rootElement,"PTZCmd");
               Device device = storager.queryVideoDeviceByPlatformIdAndChannelId(platformId, deviceId);
               cmder.fronEndCmd(device, deviceId, cmdString);
               Device deviceForPlatform = storager.queryVideoDeviceByPlatformIdAndChannelId(platformId, deviceId);
               cmder.fronEndCmd(deviceForPlatform, deviceId, cmdString);
            }
         }
      } catch (ParseException | SipException | InvalidArgumentException | DocumentException e) {
@@ -354,8 +372,16 @@
    */
   private void processMessageDeviceConfig(RequestEvent evt) {
      try {
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         // 查询设备是否存在
         Device device = storager.queryVideoDevice(deviceId);
         if (device == null) {
            logger.warn("处理DeviceConfig设备状态Message消息时未找到设备信息");
            response404Ack(evt);
            return;
         }
         Element rootElement = getRootElement(evt);
         String deviceId = XmlUtil.getText(rootElement, "DeviceID");
         String channelId = XmlUtil.getText(rootElement, "DeviceID");
         // 回复200 OK
         responseAck(evt);
         if (rootElement.getName().equals("Response")) {
@@ -365,11 +391,11 @@
            if (logger.isDebugEnabled()) {
               logger.debug(json.toJSONString());
            }
            String key = DeferredResultHolder.CALLBACK_CMD_DEVICECONFIG + deviceId + channelId;
            RequestMessage msg = new RequestMessage();
            msg.setDeviceId(deviceId);
            msg.setType(DeferredResultHolder.CALLBACK_CMD_DEVICECONFIG);
            msg.setKey(key);
            msg.setData(json);
            deferredResultHolder.invokeResult(msg);
            deferredResultHolder.invokeAllResult(msg);
         } else {
            // 此处是上级发出的DeviceConfig指令
         }
@@ -385,8 +411,17 @@
    */
   private void processMessageConfigDownload(RequestEvent evt) {
      try {
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         // 查询设备是否存在
         Device device = storager.queryVideoDevice(deviceId);
         if (device == null) {
            logger.warn("处理ConfigDownload设备状态Message时未找到设备信息");
            response404Ack(evt);
            return;
         }
         Element rootElement = getRootElement(evt);
         String deviceId = XmlUtil.getText(rootElement, "DeviceID");
         String channelId = XmlUtil.getText(rootElement, "DeviceID");
         String key = DeferredResultHolder.CALLBACK_CMD_CONFIGDOWNLOAD + deviceId + channelId;
         // 回复200 OK
         responseAck(evt);
         if (rootElement.getName().equals("Response")) {
@@ -397,10 +432,9 @@
               logger.debug(json.toJSONString());
            }
            RequestMessage msg = new RequestMessage();
            msg.setDeviceId(deviceId);
            msg.setType(DeferredResultHolder.CALLBACK_CMD_CONFIGDOWNLOAD);
            msg.setKey(key);
            msg.setData(json);
            deferredResultHolder.invokeResult(msg);
            deferredResultHolder.invokeAllResult(msg);
         } else {
            // 此处是上级发出的DeviceConfig指令
         }
@@ -416,8 +450,17 @@
    */
   private void processMessagePresetQuery(RequestEvent evt) {
      try {
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         // 查询设备是否存在
         Device device = storager.queryVideoDevice(deviceId);
         if (device == null) {
            logger.warn("处理PresetQuery预置位列表Message时未找到设备信息");
            response404Ack(evt);
            return;
         }
         Element rootElement = getRootElement(evt);
         String deviceId = XmlUtil.getText(rootElement, "DeviceID");
         String channelId = XmlUtil.getText(rootElement, "DeviceID");
         String key = DeferredResultHolder.CALLBACK_CMD_PRESETQUERY + deviceId + channelId;
         // 回复200 OK
         responseAck(evt);
         if (rootElement.getName().equals("Response")) {//   !StringUtils.isEmpty(result)) {
@@ -428,10 +471,9 @@
               logger.debug(json.toJSONString());
            }
            RequestMessage msg = new RequestMessage();
            msg.setDeviceId(deviceId);
            msg.setType(DeferredResultHolder.CALLBACK_CMD_PRESETQUERY);
            msg.setKey(key);
            msg.setData(json);
            deferredResultHolder.invokeResult(msg);
            deferredResultHolder.invokeAllResult(msg);
         } else {
            // 此处是上级发出的DeviceControl指令
         }
@@ -447,11 +489,19 @@
    */
   private void processMessageDeviceInfo(RequestEvent evt) {
      try {
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         // 查询设备是否存在
         Device device = storager.queryVideoDevice(deviceId);
         if (device == null) {
            logger.warn("处理DeviceInfo设备信息Message时未找到设备信息");
            response404Ack(evt);
            return;
         }
         Element rootElement = getRootElement(evt);
         String requestName = rootElement.getName();
         Element deviceIdElement = rootElement.element("DeviceID");
         String deviceId = deviceIdElement.getTextTrim();
         Device device = storager.queryVideoDevice(deviceId);
         String channelId = deviceIdElement.getTextTrim();
         String key = DeferredResultHolder.CALLBACK_CMD_DEVICEINFO + deviceId + channelId;
         if (device != null ) {
            rootElement = getRootElement(evt, device.getCharset());
         }
@@ -486,10 +536,9 @@
            storager.updateDevice(device);
   
            RequestMessage msg = new RequestMessage();
            msg.setDeviceId(deviceId);
            msg.setType(DeferredResultHolder.CALLBACK_CMD_DEVICEINFO);
            msg.setKey(key);
            msg.setData(device);
            deferredResultHolder.invokeResult(msg);
            deferredResultHolder.invokeAllResult(msg);
            // 回复200 OK
            responseAck(evt);
            if (offLineDetector.isOnline(deviceId)) {
@@ -508,12 +557,22 @@
    */
   private void processMessageCatalogList(RequestEvent evt) {
      try {
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         // 查询设备是否存在
         Device device = storager.queryVideoDevice(deviceId);
         if (device == null) {
            logger.warn("处理DeviceInfo设备信息Message时未找到设备信息");
            response404Ack(evt);
            return;
         }
         Element rootElement = getRootElement(evt);
         String name = rootElement.getName();
         Element deviceIdElement = rootElement.element("DeviceID");
         String deviceId = deviceIdElement.getText();
         String channelId = deviceIdElement.getText();
         Element deviceListElement = rootElement.element("DeviceList");
         String key = DeferredResultHolder.CALLBACK_CMD_CATALOG + deviceId;
         FromHeader fromHeader = (FromHeader) evt.getRequest().getHeader(FromHeader.NAME);
         AddressImpl address = (AddressImpl) fromHeader.getAddress();
         SipUri uri = (SipUri) address.getURI();
@@ -575,10 +634,6 @@
         } else {
            Device device = storager.queryVideoDevice(deviceId);
            if (device == null) {
               return;
            }
            deviceListElement = getRootElement(evt, device.getCharset()).element("DeviceList");
            Iterator<Element> deviceListIterator = deviceListElement.elementIterator();
            if (deviceListIterator != null) {
@@ -668,10 +723,9 @@
               }
               RequestMessage msg = new RequestMessage();
               msg.setDeviceId(deviceId);
               msg.setType(DeferredResultHolder.CALLBACK_CMD_CATALOG);
               msg.setKey(key);
               msg.setData(device);
               deferredResultHolder.invokeResult(msg);
               deferredResultHolder.invokeAllResult(msg);
               // 回复200 OK
               responseAck(evt);
               if (offLineDetector.isOnline(deviceId)) {
@@ -691,16 +745,20 @@
    */
   private void processMessageAlarm(RequestEvent evt) {
      try {
         Element rootElement = getRootElement(evt);
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         Device device = storager.queryVideoDevice(deviceId);
         if (device == null) {
            logger.warn("处理alarm设备报警信息未找到设备信息");
            response404Ack(evt);
            return;
         }
         Element rootElement = getRootElement(evt, device.getCharset());
         Element deviceIdElement = rootElement.element("DeviceID");
         String deviceId = deviceIdElement.getText().toString();
         String channelId = deviceIdElement.getText().toString();
         String key = DeferredResultHolder.CALLBACK_CMD_ALARM + deviceId + channelId;
         // 回复200 OK
         responseAck(evt);
         Device device = storager.queryVideoDevice(deviceId);
         if (device == null) {
            return;
         }
         if (device.getCharset() != null) {
            rootElement = getRootElement(evt, device.getCharset());
         }
@@ -708,6 +766,7 @@
         if (rootElement.getName().equals("Notify")) {   // 处理报警通知
            DeviceAlarm deviceAlarm = new DeviceAlarm();
            deviceAlarm.setDeviceId(deviceId);
            deviceAlarm.setChannelId(channelId);
            deviceAlarm.setAlarmPriority(XmlUtil.getText(rootElement, "AlarmPriority"));
            deviceAlarm.setAlarmMethod(XmlUtil.getText(rootElement, "AlarmMethod"));
            deviceAlarm.setAlarmTime(XmlUtil.getText(rootElement, "AlarmTime"));
@@ -761,10 +820,9 @@
               logger.debug(json.toJSONString());
            }
            RequestMessage msg = new RequestMessage();
            msg.setDeviceId(deviceId);
            msg.setType(DeferredResultHolder.CALLBACK_CMD_ALARM);
            msg.setKey(key);
            msg.setData(json);
            deferredResultHolder.invokeResult(msg);
            deferredResultHolder.invokeAllResult(msg);
         }
      } catch (DocumentException | SipException | InvalidArgumentException | ParseException e) {
         e.printStackTrace();
@@ -778,9 +836,13 @@
    */
   private void processMessageKeepAlive(RequestEvent evt) {
      try {
         Element rootElement = getRootElement(evt);
         String deviceId = XmlUtil.getText(rootElement, "DeviceID");
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         // 查询设备是否存在
         Device device = storager.queryVideoDevice(deviceId);
         Element rootElement = getRootElement(evt);
         String channelId = XmlUtil.getText(rootElement, "DeviceID");
         // 检查设备是否存在并在线, 不在线则设置为在线
         if (device != null ) {
@@ -792,7 +854,9 @@
            Response response = getMessageFactory().createResponse(Response.NOT_FOUND, evt.getRequest());
            ServerTransaction serverTransaction = getServerTransaction(evt);
            serverTransaction.sendResponse(response);
            if (serverTransaction.getDialog() != null) serverTransaction.getDialog().delete();
            if (serverTransaction.getDialog() != null) {
               serverTransaction.getDialog().delete();
            }
         }
//         if (device != null && device.getOnline() == 1) {
@@ -820,18 +884,29 @@
    */
   private void processMessageRecordInfo(RequestEvent evt) {
      try {
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         // 查询设备是否存在
         Device device = storager.queryVideoDevice(deviceId);
         if (device == null) {
            logger.warn("处理DeviceInfo设备信息Message时未找到设备信息");
            response404Ack(evt);
            return;
         }
         // 回复200 OK
         responseAck(evt);
         String uuid = UUID.randomUUID().toString().replace("-", "");
         RecordInfo recordInfo = new RecordInfo();
         Element rootElement = getRootElement(evt);
         Element deviceIdElement = rootElement.element("DeviceID");
         String deviceId = deviceIdElement.getText().toString();
         Device device = storager.queryVideoDevice(deviceId);
         String channelId = deviceIdElement.getText().toString();
         String key = DeferredResultHolder.CALLBACK_CMD_RECORDINFO + deviceId + channelId;
         if (device != null ) {
            rootElement = getRootElement(evt, device.getCharset());
         }
         recordInfo.setDeviceId(deviceId);
         recordInfo.setChannelId(channelId);
         recordInfo.setName(XmlUtil.getText(rootElement, "Name"));
         if (XmlUtil.getText(rootElement, "SumNum")== null || XmlUtil.getText(rootElement, "SumNum") =="") {
            recordInfo.setSumNum(0);
@@ -843,10 +918,9 @@
         if (recordListElement == null || recordInfo.getSumNum() == 0) {
            logger.info("无录像数据");
            RequestMessage msg = new RequestMessage();
            msg.setDeviceId(deviceId);
            msg.setType(DeferredResultHolder.CALLBACK_CMD_RECORDINFO);
            msg.setKey(key);
            msg.setData(recordInfo);
            deferredResultHolder.invokeResult(msg);
            deferredResultHolder.invokeAllResult(msg);
         } else {
            Iterator<Element> recordListIterator = recordListElement.elementIterator();
            List<RecordItem> recordList = new ArrayList<RecordItem>();
@@ -945,10 +1019,20 @@
     */
   private void processMessageMediaStatus(RequestEvent evt){
      try {
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         // 查询设备是否存在
         Device device = storager.queryVideoDevice(deviceId);
         if (device == null) {
            logger.warn("处理DeviceInfo设备信息Message时未找到设备信息");
            response404Ack(evt);
            return;
         }
         // 回复200 OK
         responseAck(evt);
         Element rootElement = getRootElement(evt);
         String deviceId = XmlUtil.getText(rootElement, "DeviceID");
         String channelId = XmlUtil.getText(rootElement, "DeviceID");
         String NotifyType =XmlUtil.getText(rootElement, "NotifyType");
         if (NotifyType.equals("121")){
            logger.info("媒体播放完毕,通知关流");
@@ -970,8 +1054,19 @@
    */
   private void processMessageBroadcast(RequestEvent evt) {
      try {
         String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
         // 查询设备是否存在
         Device device = storager.queryVideoDevice(deviceId);
         if (device == null) {
            logger.warn("处理DeviceInfo设备信息Message时未找到设备信息");
            response404Ack(evt);
            return;
         }
         Element rootElement = getRootElement(evt);
         String deviceId = XmlUtil.getText(rootElement, "DeviceID");
         String channelId = XmlUtil.getText(rootElement, "DeviceID");
         String key = DeferredResultHolder.CALLBACK_CMD_BROADCAST + deviceId + channelId;
         // 回复200 OK
         responseAck(evt);
         if (rootElement.getName().equals("Response")) {
@@ -982,10 +1077,9 @@
               logger.debug(json.toJSONString());
            }
            RequestMessage msg = new RequestMessage();
            msg.setDeviceId(deviceId);
            msg.setType(DeferredResultHolder.CALLBACK_CMD_BROADCAST);
            msg.setKey(key);
            msg.setData(json);
            deferredResultHolder.invokeResult(msg);
            deferredResultHolder.invokeAllResult(msg);
         } else {
            // 此处是上级发出的Broadcast指令
         }
@@ -1006,7 +1100,9 @@
      Response response = getMessageFactory().createResponse(Response.OK, evt.getRequest());
      ServerTransaction serverTransaction = getServerTransaction(evt);
      serverTransaction.sendResponse(response);
      if (serverTransaction.getDialog() != null) serverTransaction.getDialog().delete();
      if (serverTransaction.getDialog() != null) {
         serverTransaction.getDialog().delete();
      }
   }
   /***
@@ -1020,7 +1116,9 @@
      Response response = getMessageFactory().createResponse(Response.NOT_FOUND, evt.getRequest());
      ServerTransaction serverTransaction = getServerTransaction(evt);
      serverTransaction.sendResponse(response);
      if (serverTransaction.getDialog() != null) serverTransaction.getDialog().delete();
      if (serverTransaction.getDialog() != null) {
         serverTransaction.getDialog().delete();
      }
   }
   private Element getRootElement(RequestEvent evt) throws DocumentException {
@@ -1029,7 +1127,9 @@
   }
   private Element getRootElement(RequestEvent evt, String charset) throws DocumentException {
      if (charset == null) charset = "gb2312";
      if (charset == null) {
         charset = "gb2312";
      }
      Request request = evt.getRequest();
      SAXReader reader = new SAXReader();
      reader.setEncoding(charset);