添加utf-8解析设备信息

648540858

2021-09-13 5e8a7ce21e35b2c4d7faeede04e60b3537db2f3c

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/request/impl/MessageRequestProcessor.java

@@ -4,17 +4,12 @@
import java.text.ParseException;

import java.util.*;



import javax.sip.*;

import javax.sip.address.SipURI;



import javax.sip.header.FromHeader;

import javax.sip.header.HeaderAddress;

import javax.sip.header.ToHeader;

import javax.sip.InvalidArgumentException;

import javax.sip.ListeningPoint;

import javax.sip.ObjectInUseException;

import javax.sip.RequestEvent;

import javax.sip.SipException;

import javax.sip.SipProvider;

import javax.sip.message.Request;

import javax.sip.message.Response;



@@ -35,6 +30,7 @@
import com.genersoft.iot.vmp.gb28181.utils.DateUtil;

import com.genersoft.iot.vmp.gb28181.utils.NumericUtil;

import com.genersoft.iot.vmp.gb28181.utils.XmlUtil;

import com.genersoft.iot.vmp.service.IDeviceAlarmService;

import com.genersoft.iot.vmp.storager.IRedisCatchStorage;

import com.genersoft.iot.vmp.storager.IVideoManagerStorager;

import com.genersoft.iot.vmp.utils.GpsUtil;

@@ -83,6 +79,8 @@
   private DeferredResultHolder deferredResultHolder;



   private DeviceOffLineDetector offLineDetector;



   private IDeviceAlarmService deviceAlarmService;



   private final static String CACHE_RECORDINFO_KEY = "CACHE_RECORDINFO_";



@@ -174,6 +172,7 @@
         String deviceId = deviceIdElement.getTextTrim().toString();

         Device device = storager.queryVideoDevice(deviceId);

         if (device != null) {

            rootElement = getRootElement(evt, device.getCharset());

            if (!StringUtils.isEmpty(device.getName())) {

               mobilePosition.setDeviceName(device.getName());

            }

@@ -226,7 +225,7 @@
         String name = rootElement.getName();

         Element deviceIdElement = rootElement.element("DeviceID");

         String deviceId = deviceIdElement.getText();



         Device device = storager.queryVideoDevice(deviceId);

         if (name.equalsIgnoreCase("Query")) { // 区分是Response——查询响应，还是Query——查询请求

            logger.info("接收到DeviceStatus查询消息");

            FromHeader fromHeader = (FromHeader) evt.getRequest().getHeader(FromHeader.NAME);

@@ -259,7 +258,7 @@
               deferredResultHolder.invokeResult(msg);



               if (offLineDetector.isOnline(deviceId)) {

                  publisher.onlineEventPublish(deviceId, VideoManagerConstants.EVENT_ONLINE_KEEPLIVE);

                  publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_MESSAGE);

               } else {

               }

            }

@@ -282,7 +281,7 @@
         //String result = XmlUtil.getText(rootElement, "Result");

         // 回复200 OK

         responseAck(evt);

         if (rootElement.getName().equals("Response")) {//} !XmlUtil.isEmpty(result)) {

         if (rootElement.getName().equals("Response")) {//} !StringUtils.isEmpty(result)) {

            // 此处是对本平台发出DeviceControl指令的应答

            JSONObject json = new JSONObject();

            XmlUtil.node2Json(rootElement, json);

@@ -299,7 +298,7 @@
            String platformId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(FromHeader.NAME)).getAddress().getURI()).getUser();

            String targetGBId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(ToHeader.NAME)).getAddress().getURI()).getUser();

            // 远程启动功能

            if (!XmlUtil.isEmpty(XmlUtil.getText(rootElement, "TeleBoot"))) {

            if (!StringUtils.isEmpty(XmlUtil.getText(rootElement, "TeleBoot"))) {

               if (deviceId.equals(targetGBId)) {

                  // 远程启动本平台：需要在重新启动程序后先对SipStack解绑

                  logger.info("执行远程启动本平台命令");

@@ -337,7 +336,7 @@
               }

            }

            // 云台/前端控制命令

            if (!XmlUtil.isEmpty(XmlUtil.getText(rootElement,"PTZCmd")) && !deviceId.equals(targetGBId)) {

            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);

@@ -421,7 +420,7 @@
         String deviceId = XmlUtil.getText(rootElement, "DeviceID");

         // 回复200 OK

         responseAck(evt);

         if (rootElement.getName().equals("Response")) {//   !XmlUtil.isEmpty(result)) {

         if (rootElement.getName().equals("Response")) {//   !StringUtils.isEmpty(result)) {

            // 此处是对本平台发出DeviceControl指令的应答

            JSONObject json = new JSONObject();

            XmlUtil.node2Json(rootElement, json);

@@ -451,7 +450,11 @@
         Element rootElement = getRootElement(evt);

         String requestName = rootElement.getName();

         Element deviceIdElement = rootElement.element("DeviceID");

         String deviceId = deviceIdElement.getTextTrim().toString();

         String deviceId = deviceIdElement.getTextTrim();

         Device device = storager.queryVideoDevice(deviceId);

         if (device != null ) {

            rootElement = getRootElement(evt, device.getCharset());

         }

         if (requestName.equals("Query")) {

            logger.info("接收到DeviceInfo查询消息");

            FromHeader fromHeader = (FromHeader) evt.getRequest().getHeader(FromHeader.NAME);

@@ -468,11 +471,12 @@
            }

         } else {

            logger.debug("接收到DeviceInfo应答消息");

            Device device = storager.queryVideoDevice(deviceId);

            if (device == null) {

               return;

            }



            device.setName(XmlUtil.getText(rootElement, "DeviceName"));



            device.setManufacturer(XmlUtil.getText(rootElement, "Manufacturer"));

            device.setModel(XmlUtil.getText(rootElement, "Model"));

            device.setFirmware(XmlUtil.getText(rootElement, "Firmware"));

@@ -489,7 +493,7 @@
            // 回复200 OK

            responseAck(evt);

            if (offLineDetector.isOnline(deviceId)) {

               publisher.onlineEventPublish(deviceId, VideoManagerConstants.EVENT_ONLINE_KEEPLIVE);

               publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_MESSAGE);

            }

         }

      } catch (DocumentException | SipException | InvalidArgumentException | ParseException e) {

@@ -552,7 +556,7 @@
                     deviceChannel.setStatus(gbStream.isStatus()?1:0);

//                     deviceChannel.setParentId(parentPlatform.getDeviceGBId());

                     deviceChannel.setRegisterWay(1);

                     deviceChannel.setCivilCode(cmder.getSipConfig().getSipDomain());

                     deviceChannel.setCivilCode(cmder.getSipConfig().getDomain());

                     deviceChannel.setModel("live");

                     deviceChannel.setOwner("wvp-pro");

//                     deviceChannel.setAddress("test");

@@ -571,12 +575,14 @@




         } 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) {

               Device device = storager.queryVideoDevice(deviceId);

               if (device == null) {

                  return;

               }



               // 遍历DeviceList

               while (deviceListIterator.hasNext()) {

                  Element itemDevice = deviceListIterator.next();

@@ -669,7 +675,7 @@
               // 回复200 OK

               responseAck(evt);

               if (offLineDetector.isOnline(deviceId)) {

                  publisher.onlineEventPublish(deviceId, VideoManagerConstants.EVENT_ONLINE_KEEPLIVE);

                  publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_MESSAGE);

               }

            }

         }

@@ -695,6 +701,9 @@
         if (device == null) {

            return;

         }

         if (device.getCharset() != null) {

            rootElement = getRootElement(evt, device.getCharset());

         }



         if (rootElement.getName().equals("Notify")) {   // 处理报警通知

            DeviceAlarm deviceAlarm = new DeviceAlarm();

@@ -718,7 +727,7 @@
               deviceAlarm.setLatitude(0.00);

            }

   

            if (!XmlUtil.isEmpty(deviceAlarm.getAlarmMethod())) {

            if (!StringUtils.isEmpty(deviceAlarm.getAlarmMethod())) {

               if ( deviceAlarm.getAlarmMethod().equals("4")) {

                  MobilePosition mobilePosition = new MobilePosition();

                  mobilePosition.setDeviceId(deviceAlarm.getDeviceId());

@@ -738,7 +747,9 @@
                  storager.insertMobilePosition(mobilePosition);

               }

            }

            // TODO: 需要实现存储报警信息、报警分类

            System.out.println("存储报警信息、报警分类");

            // 存储报警信息、报警分类

            deviceAlarmService.add(deviceAlarm);

   

            if (offLineDetector.isOnline(deviceId)) {

               publisher.deviceAlarmEventPublish(deviceAlarm);

@@ -756,7 +767,6 @@
            deferredResultHolder.invokeResult(msg);

         }

      } catch (DocumentException | SipException | InvalidArgumentException | ParseException e) {

         // } catch (DocumentException e) {

         e.printStackTrace();

      }

   }

@@ -771,17 +781,33 @@
         Element rootElement = getRootElement(evt);

         String deviceId = XmlUtil.getText(rootElement, "DeviceID");

         Device device = storager.queryVideoDevice(deviceId);

         // 检查设备是否存在并在线， 不存在则不回复

         if (device != null && device.getOnline() == 1) {



         // 检查设备是否存在并在线， 不在线则设置为在线

         if (device != null ) {

            // 回复200 OK

            responseAck(evt);

            if (offLineDetector.isOnline(deviceId)) {

               publisher.onlineEventPublish(deviceId, VideoManagerConstants.EVENT_ONLINE_KEEPLIVE);

            } else {

            }

         }else {

            logger.warn("收到[ "+deviceId+" ]心跳信息, 但是设备" + (device == null? "不存在":"离线") + ", 心跳信息不予以回复");

            publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_KEEPLIVE);

         }else{

            logger.warn("收到[ "+deviceId+" ]心跳信息, 但是设备不存在, 回复404");

            Response response = getMessageFactory().createResponse(Response.NOT_FOUND, evt.getRequest());

            ServerTransaction serverTransaction = getServerTransaction(evt);

            serverTransaction.sendResponse(response);

            if (serverTransaction.getDialog() != null) serverTransaction.getDialog().delete();

         }



//         if (device != null && device.getOnline() == 1) {

//

//            if (offLineDetector.isOnline(deviceId)) {

//               publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_KEEPLIVE);

//            } else {

//            }

//         }else {

////            logger.warn("收到[ "+deviceId+" ]心跳信息, 但是设备" + (device == null? "不存在":"离线") + ", 回复401");

////            Response response = getMessageFactory().createResponse(Response.UNAUTHORIZED, evt.getRequest());

////            getServerTransaction(evt).sendResponse(response);

//            publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_KEEPLIVE);

//

//         }

      } catch (ParseException | SipException | InvalidArgumentException | DocumentException e) {

         e.printStackTrace();

      }

@@ -801,6 +827,10 @@
         Element rootElement = getRootElement(evt);

         Element deviceIdElement = rootElement.element("DeviceID");

         String deviceId = deviceIdElement.getText().toString();

         Device device = storager.queryVideoDevice(deviceId);

         if (device != null ) {

            rootElement = getRootElement(evt, device.getCharset());

         }

         recordInfo.setDeviceId(deviceId);

         recordInfo.setName(XmlUtil.getText(rootElement, "Name"));

         if (XmlUtil.getText(rootElement, "SumNum")== null || XmlUtil.getText(rootElement, "SumNum") =="") {

@@ -974,7 +1004,9 @@
    */

   private void responseAck(RequestEvent evt) throws SipException, InvalidArgumentException, ParseException {

      Response response = getMessageFactory().createResponse(Response.OK, evt.getRequest());

      getServerTransaction(evt).sendResponse(response);

      ServerTransaction serverTransaction = getServerTransaction(evt);

      serverTransaction.sendResponse(response);

      if (serverTransaction.getDialog() != null) serverTransaction.getDialog().delete();

   }



   /***

@@ -986,13 +1018,21 @@
    */

   private void response404Ack(RequestEvent evt) throws SipException, InvalidArgumentException, ParseException {

      Response response = getMessageFactory().createResponse(Response.NOT_FOUND, evt.getRequest());

      getServerTransaction(evt).sendResponse(response);

      ServerTransaction serverTransaction = getServerTransaction(evt);

      serverTransaction.sendResponse(response);

      if (serverTransaction.getDialog() != null) serverTransaction.getDialog().delete();

   }



   private Element getRootElement(RequestEvent evt) throws DocumentException {



      return getRootElement(evt, "gb2312");

   }



   private Element getRootElement(RequestEvent evt, String charset) throws DocumentException {

      if (charset == null) charset = "gb2312";

      Request request = evt.getRequest();

      SAXReader reader = new SAXReader();

      reader.setEncoding("gbk");

      reader.setEncoding(charset);

      Document xml = reader.read(new ByteArrayInputStream(request.getRawContent()));

      return xml.getRootElement();

   }

@@ -1036,4 +1076,8 @@
   public void setCmderFroPlatform(SIPCommanderFroPlatform cmderFroPlatform) {

      this.cmderFroPlatform = cmderFroPlatform;

   }



   public void setDeviceAlarmService(IDeviceAlarmService deviceAlarmService) {

      this.deviceAlarmService = deviceAlarmService;

   }

}