添加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());

            }

@@ -451,8 +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);

@@ -472,7 +474,9 @@
            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"));

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

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

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

      }

   }

@@ -780,7 +790,9 @@
         }else{

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

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

         }



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

@@ -815,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") =="") {

@@ -988,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();

   }



   /***

@@ -1000,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();

   }

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

      this.cmderFroPlatform = cmderFroPlatform;

   }



   public void setDeviceAlarmService(IDeviceAlarmService deviceAlarmService) {

      this.deviceAlarmService = deviceAlarmService;

   }

}