增加redis通道

648540858

2023-06-27 c7d15150237c946fbb4f5547dab0018a5f573d88

 src/main/java/com/genersoft/iot/vmp/gb28181/utils/XmlUtil.java

@@ -1,9 +1,13 @@
package com.genersoft.iot.vmp.gb28181.utils;



import com.alibaba.fastjson.JSONArray;

import com.alibaba.fastjson.JSONObject;

import com.alibaba.fastjson2.JSONArray;

import com.alibaba.fastjson2.JSONObject;

import com.genersoft.iot.vmp.common.CivilCodePo;

import com.genersoft.iot.vmp.conf.CivilCodeFileConf;

import com.genersoft.iot.vmp.gb28181.bean.Device;

import com.genersoft.iot.vmp.gb28181.bean.DeviceChannel;

import com.genersoft.iot.vmp.gb28181.event.subscribe.catalog.CatalogEvent;

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

import org.dom4j.Attribute;

import org.dom4j.Document;

import org.dom4j.DocumentException;

@@ -11,12 +15,17 @@
import org.dom4j.io.SAXReader;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.util.StringUtils;

import org.springframework.util.ObjectUtils;

import org.springframework.util.ReflectionUtils;



import javax.sip.RequestEvent;

import javax.sip.message.Request;

import java.io.ByteArrayInputStream;

import java.io.StringReader;

import java.lang.reflect.Field;

import java.lang.reflect.InvocationTargetException;

import java.lang.reflect.ParameterizedType;

import java.lang.reflect.Type;

import java.util.*;



/**

@@ -28,7 +37,7 @@
    /**

     * 日志服务

     */

    private static Logger LOG = LoggerFactory.getLogger(XmlUtil.class);

    private static Logger logger = LoggerFactory.getLogger(XmlUtil.class);



    /**

     * 解析XML为Document对象

@@ -45,7 +54,7 @@
        try {

            document = saxReader.read(sr);

        } catch (DocumentException e) {

            LOG.error("解析失败", e);

            logger.error("解析失败", e);

        }

        return null == document ? null : document.getRootElement();

    }

@@ -115,12 +124,12 @@
        // 如果是属性

        for (Object o : element.attributes()) {

            Attribute attr = (Attribute) o;

            if (!StringUtils.isEmpty(attr.getValue())) {

            if (!ObjectUtils.isEmpty(attr.getValue())) {

                json.put("@" + attr.getName(), attr.getValue());

            }

        }

        List<Element> chdEl = element.elements();

        if (chdEl.isEmpty() && !StringUtils.isEmpty(element.getText())) {// 如果没有子元素,只有一个值

        if (chdEl.isEmpty() && !ObjectUtils.isEmpty(element.getText())) {// 如果没有子元素,只有一个值

            json.put(element.getName(), element.getText());

        }



@@ -151,7 +160,7 @@
            } else { // 子元素没有子元素

                for (Object o : element.attributes()) {

                    Attribute attr = (Attribute) o;

                    if (!StringUtils.isEmpty(attr.getValue())) {

                    if (!ObjectUtils.isEmpty(attr.getValue())) {

                        json.put("@" + attr.getName(), attr.getValue());

                    }

                }

@@ -181,176 +190,449 @@
        return xml.getRootElement();

    }



    public static DeviceChannel channelContentHander(Element itemDevice, Device device){

        Element channdelNameElement = itemDevice.element("Name");

        String channelName = channdelNameElement != null ? channdelNameElement.getTextTrim().toString() : "";

        Element statusElement = itemDevice.element("Status");

        String status = statusElement != null ? statusElement.getTextTrim().toString() : "ON";

    private enum ChannelType{

        CivilCode, BusinessGroup,VirtualOrganization,Other

    }



    public static DeviceChannel channelContentHandler(Element itemDevice, Device device, String event, CivilCodeFileConf civilCodeFileConf){

        DeviceChannel deviceChannel = new DeviceChannel();

        deviceChannel.setName(channelName);

        deviceChannel.setDeviceId(device.getDeviceId());

        Element channdelIdElement = itemDevice.element("DeviceID");

        String channelId = channdelIdElement != null ? channdelIdElement.getTextTrim().toString() : "";

        if (channdelIdElement == null) {

            logger.warn("解析Catalog消息时发现缺少 DeviceID");

            return null;

        }

        String channelId = channdelIdElement.getTextTrim();

        if (ObjectUtils.isEmpty(channelId)) {

            logger.warn("解析Catalog消息时发现缺少 DeviceID");

            return null;

        }

        deviceChannel.setChannelId(channelId);

        // ONLINE OFFLINE HIKVISION DS-7716N-E4 NVR的兼容性处理

        if (status.equals("ON") || status.equals("On") || status.equals("ONLINE") || status.equals("OK")) {

        if (event != null && !event.equals(CatalogEvent.ADD) && !event.equals(CatalogEvent.UPDATE)) {

            // 除了ADD和update情况下需要识别全部内容，

            return deviceChannel;

        }

        Element nameElement = itemDevice.element("Name");

        if (nameElement != null) {

            deviceChannel.setName(nameElement.getText());

        }

        if(channelId.length() <= 8) {

            deviceChannel.setHasAudio(false);

            CivilCodePo parentCode = civilCodeFileConf.getParentCode(channelId);

            if (parentCode != null) {

                deviceChannel.setParentId(parentCode.getCode());

                deviceChannel.setCivilCode(parentCode.getCode());

            }else {

                logger.warn("[xml解析] 无法确定行政区划{}的上级行政区划", channelId);

            }

            deviceChannel.setStatus(1);

        }

        if (status.equals("OFF") || status.equals("Off") || status.equals("OFFLINE")) {

            deviceChannel.setStatus(0);

        }



        deviceChannel.setManufacture(XmlUtil.getText(itemDevice, "Manufacturer"));

        deviceChannel.setModel(XmlUtil.getText(itemDevice, "Model"));

        deviceChannel.setOwner(XmlUtil.getText(itemDevice, "Owner"));

        deviceChannel.setCivilCode(XmlUtil.getText(itemDevice, "CivilCode"));

        deviceChannel.setBlock(XmlUtil.getText(itemDevice, "Block"));

        deviceChannel.setAddress(XmlUtil.getText(itemDevice, "Address"));

        String businessGroupID = XmlUtil.getText(itemDevice, "BusinessGroupID");

        if (XmlUtil.getText(itemDevice, "Parental") == null

                || XmlUtil.getText(itemDevice, "Parental").equals("")) {

            if (deviceChannel.getChannelId().length() <= 10

                    || (deviceChannel.getChannelId().length() == 20 && (

                            Integer.parseInt(deviceChannel.getChannelId().substring(10, 13)) == 215

                                    || Integer.parseInt(deviceChannel.getChannelId().substring(10, 13)) == 216

                            )

                        )

            ) {

                deviceChannel.setParental(1);

            }else {

                deviceChannel.setParental(0);

            }

        } else {

            // 由于海康会错误的发送65535作为这里的取值,所以这里除非是0否则认为是1

            deviceChannel.setParental(Integer.parseInt(XmlUtil.getText(itemDevice, "Parental")) == 1?1:0);

        }

        /**

         * 行政区划展示设备树与业务分组展示设备树是两种不同的模式

         * 行政区划展示设备树 各个目录之间主要靠deviceId做关联,摄像头通过CivilCode指定其属于那个行政区划;都是不超过十位的编号; 结构如下:

         * 河北省

         *    --> 石家庄市

         *          --> 摄像头

         *          --> 正定县

         *                  --> 摄像头

         *                  --> 摄像头

         *

         * 业务分组展示设备树是顶级是业务分组,其下的虚拟组织靠BusinessGroupID指定其所属的业务分组;摄像头通过ParentId来指定其所属于的虚拟组织:

         * 业务分组

         *    --> 虚拟组织

         *         --> 摄像头

         *         --> 虚拟组织

         *             --> 摄像头

         *             --> 摄像头

         */

        String parentId = XmlUtil.getText(itemDevice, "ParentID");

        if (parentId != null) {

            if (parentId.contains("/")) {

                String lastParentId = parentId.substring(parentId.lastIndexOf("/") + 1);

                deviceChannel.setParentId(lastParentId);

            }else {

                deviceChannel.setParentId(parentId);

            }

        }

        deviceChannel.setBusinessGroupId(businessGroupID);



//        else {

//            if (deviceChannel.getChannelId().length() <= 10) { // 此时为行政区划, 上下级行政区划使用DeviceId关联

//                deviceChannel.setParentId(deviceChannel.getChannelId().substring(0, deviceChannel.getChannelId().length() - 2));

//            }else if (deviceChannel.getChannelId().length() == 20) {

//                if (Integer.parseInt(deviceChannel.getChannelId().substring(10, 13)) == 216) { // 虚拟组织

//                    deviceChannel.setBusinessGroupId(businessGroupID);

//                }else if (Integer.parseInt(device.getDeviceId().substring(10, 13) )== 118) {//NVR 如果上级设备编号是NVR则直接将NVR的编号设置给通道的上级编号

//                    deviceChannel.setParentId(device.getDeviceId());

//                }else if (deviceChannel.getCivilCode() != null) {

//                    // 设备， 无parentId的20位是使用CivilCode表示上级的设备，

//                    // 注：215 业务分组是需要有parentId的

//                    deviceChannel.setParentId(deviceChannel.getCivilCode());

//                }

//            }else {

//                deviceChannel.setParentId(deviceChannel.getDeviceId());

//            }

//        }



        if (XmlUtil.getText(itemDevice, "SafetyWay") == null

                || XmlUtil.getText(itemDevice, "SafetyWay") == "") {

            deviceChannel.setSafetyWay(0);

        } else {

            deviceChannel.setSafetyWay(Integer.parseInt(XmlUtil.getText(itemDevice, "SafetyWay")));

        }

        if (XmlUtil.getText(itemDevice, "RegisterWay") == null

                || XmlUtil.getText(itemDevice, "RegisterWay") == "") {

            deviceChannel.setRegisterWay(1);

        } else {

            deviceChannel.setRegisterWay(Integer.parseInt(XmlUtil.getText(itemDevice, "RegisterWay")));

        }

        deviceChannel.setCertNum(XmlUtil.getText(itemDevice, "CertNum"));

        if (XmlUtil.getText(itemDevice, "Certifiable") == null

                || XmlUtil.getText(itemDevice, "Certifiable") == "") {

            deviceChannel.setCertifiable(0);

        } else {

            deviceChannel.setCertifiable(Integer.parseInt(XmlUtil.getText(itemDevice, "Certifiable")));

        }

        if (XmlUtil.getText(itemDevice, "ErrCode") == null

                || XmlUtil.getText(itemDevice, "ErrCode") == "") {

            deviceChannel.setErrCode(0);

        } else {

            deviceChannel.setErrCode(Integer.parseInt(XmlUtil.getText(itemDevice, "ErrCode")));

        }

        deviceChannel.setEndTime(XmlUtil.getText(itemDevice, "EndTime"));

        deviceChannel.setSecrecy(XmlUtil.getText(itemDevice, "Secrecy"));

        deviceChannel.setIpAddress(XmlUtil.getText(itemDevice, "IPAddress"));

        if (XmlUtil.getText(itemDevice, "Port") == null || XmlUtil.getText(itemDevice, "Port") == "") {

            deviceChannel.setPort(0);

        } else {

            deviceChannel.setPort(Integer.parseInt(XmlUtil.getText(itemDevice, "Port")));

        }

        deviceChannel.setPassword(XmlUtil.getText(itemDevice, "Password"));

        if (NumericUtil.isDouble(XmlUtil.getText(itemDevice, "Longitude"))) {

            deviceChannel.setLongitude(Double.parseDouble(XmlUtil.getText(itemDevice, "Longitude")));

        } else {

            deviceChannel.setLongitude(0.00);

        }

        if (NumericUtil.isDouble(XmlUtil.getText(itemDevice, "Latitude"))) {

            deviceChannel.setLatitude(Double.parseDouble(XmlUtil.getText(itemDevice, "Latitude")));

        } else {

            deviceChannel.setLatitude(0.00);

        }

        if (deviceChannel.getLongitude()*deviceChannel.getLatitude() > 0) {

            if ("WGS84".equals(device.getGeoCoordSys())) {

                deviceChannel.setLongitudeWgs84(deviceChannel.getLongitude());

                deviceChannel.setLatitudeWgs84(deviceChannel.getLatitude());

                Double[] position = Coordtransform.WGS84ToGCJ02(deviceChannel.getLongitude(), deviceChannel.getLatitude());

                deviceChannel.setLongitudeGcj02(position[0]);

                deviceChannel.setLatitudeGcj02(position[1]);

            }else if ("GCJ02".equals(device.getGeoCoordSys())) {

                deviceChannel.setLongitudeGcj02(deviceChannel.getLongitude());

                deviceChannel.setLatitudeGcj02(deviceChannel.getLatitude());

                Double[] position = Coordtransform.GCJ02ToWGS84(deviceChannel.getLongitude(), deviceChannel.getLatitude());

                deviceChannel.setLongitudeWgs84(position[0]);

                deviceChannel.setLatitudeWgs84(position[1]);

            }else {

                deviceChannel.setLongitudeGcj02(0.00);

                deviceChannel.setLatitudeGcj02(0.00);

                deviceChannel.setLongitudeWgs84(0.00);

                deviceChannel.setLatitudeWgs84(0.00);

            }

            return deviceChannel;

        }else {

            deviceChannel.setLongitudeGcj02(deviceChannel.getLongitude());

            deviceChannel.setLatitudeGcj02(deviceChannel.getLatitude());

            deviceChannel.setLongitudeWgs84(deviceChannel.getLongitude());

            deviceChannel.setLatitudeWgs84(deviceChannel.getLatitude());

        }

        if (XmlUtil.getText(itemDevice, "PTZType") == null || "".equals(XmlUtil.getText(itemDevice, "PTZType"))) {

            //兼容INFO中的信息

            Element info = itemDevice.element("Info");

            if(XmlUtil.getText(info, "PTZType") == null || "".equals(XmlUtil.getText(info, "PTZType"))){

                deviceChannel.setPTZType(0);

            }else{

                deviceChannel.setPTZType(Integer.parseInt(XmlUtil.getText(info, "PTZType")));

            if(channelId.length() != 20) {

                logger.warn("[xml解析] 失败，编号不符合国标28181定义： {}", channelId);

                return null;

            }

        } else {

            deviceChannel.setPTZType(Integer.parseInt(XmlUtil.getText(itemDevice, "PTZType")));



            int code = Integer.parseInt(channelId.substring(10, 13));

            if (code == 136 || code == 137 || code == 138) {

                deviceChannel.setHasAudio(true);

            }else {

                deviceChannel.setHasAudio(false);

            }

            // 设备厂商

            String manufacturer = getText(itemDevice, "Manufacturer");

            // 设备型号

            String model = getText(itemDevice, "Model");

            // 设备归属

            String owner = getText(itemDevice, "Owner");

            // 行政区域

            String civilCode = getText(itemDevice, "CivilCode");

            // 虚拟组织所属的业务分组ID,业务分组根据特定的业务需求制定,一个业务分组包含一组特定的虚拟组织

            String businessGroupID = getText(itemDevice, "BusinessGroupID");

            // 父设备/区域/系统ID

            String parentID = getText(itemDevice, "ParentID");

            if (parentID != null && parentID.equalsIgnoreCase("null")) {

                parentID = null;

            }

            // 注册方式(必选)缺省为1;1:符合IETFRFC3261标准的认证注册模式;2:基于口令的双向认证注册模式;3:基于数字证书的双向认证注册模式

            String registerWay = getText(itemDevice, "RegisterWay");

            // 保密属性(必选)缺省为0;0:不涉密,1:涉密

            String secrecy = getText(itemDevice, "Secrecy");

            // 安装地址

            String address = getText(itemDevice, "Address");



            switch (code){

                case 200:

                    // 系统目录

                    if (!ObjectUtils.isEmpty(manufacturer)) {

                        deviceChannel.setManufacture(manufacturer);

                    }

                    if (!ObjectUtils.isEmpty(model)) {

                        deviceChannel.setModel(model);

                    }

                    if (!ObjectUtils.isEmpty(owner)) {

                        deviceChannel.setOwner(owner);

                    }

                    if (!ObjectUtils.isEmpty(civilCode)) {

                        deviceChannel.setCivilCode(civilCode);

                        deviceChannel.setParentId(civilCode);

                    }else {

                        if (!ObjectUtils.isEmpty(parentID)) {

                            deviceChannel.setParentId(parentID);

                        }

                    }

                    if (!ObjectUtils.isEmpty(address)) {

                        deviceChannel.setAddress(address);

                    }

                    deviceChannel.setStatus(1);

                    if (!ObjectUtils.isEmpty(registerWay)) {

                        try {

                            deviceChannel.setRegisterWay(Integer.parseInt(registerWay));

                        }catch (NumberFormatException exception) {

                            logger.warn("[xml解析] 从通道数据获取registerWay失败： {}", registerWay);

                        }

                    }

                    if (!ObjectUtils.isEmpty(secrecy)) {

                        deviceChannel.setSecrecy(secrecy);

                    }

                    return deviceChannel;

                case 215:

                    // 业务分组

                    deviceChannel.setStatus(1);

                    if (!ObjectUtils.isEmpty(parentID)) {

                        if (!parentID.trim().equalsIgnoreCase(device.getDeviceId())) {

                            deviceChannel.setParentId(parentID);

                        }

                    }else {

                        logger.warn("[xml解析] 业务分组数据中缺少关键信息->ParentId");

                        if (!ObjectUtils.isEmpty(civilCode)) {

                            deviceChannel.setCivilCode(civilCode);

                        }

                    }

                    break;

                case 216:

                    // 虚拟组织

                    deviceChannel.setStatus(1);

                    if (!ObjectUtils.isEmpty(businessGroupID)) {

                        deviceChannel.setBusinessGroupId(businessGroupID);

                    }





                    if (!ObjectUtils.isEmpty(parentID)) {

                        if (parentID.contains("/")) {

                            String[] parentIdArray = parentID.split("/");

                            parentID = parentIdArray[parentIdArray.length - 1];

                        }

                        deviceChannel.setParentId(parentID);

                    }else {

                        if (!ObjectUtils.isEmpty(businessGroupID)) {

                            deviceChannel.setParentId(businessGroupID);

                        }

                    }

                    break;

                default:

                    // 设备目录

                    if (!ObjectUtils.isEmpty(manufacturer)) {

                        deviceChannel.setManufacture(manufacturer);

                    }

                    if (!ObjectUtils.isEmpty(model)) {

                        deviceChannel.setModel(model);

                    }

                    if (!ObjectUtils.isEmpty(owner)) {

                        deviceChannel.setOwner(owner);

                    }

                    if (!ObjectUtils.isEmpty(civilCode)) {

                        deviceChannel.setCivilCode(civilCode);

                    }

                    if (!ObjectUtils.isEmpty(businessGroupID)) {

                        deviceChannel.setBusinessGroupId(businessGroupID);

                    }



                    // 警区

                    String block = getText(itemDevice, "Block");

                    if (!ObjectUtils.isEmpty(block)) {

                        deviceChannel.setBlock(block);

                    }

                    if (!ObjectUtils.isEmpty(address)) {

                        deviceChannel.setAddress(address);

                    }



                    if (!ObjectUtils.isEmpty(secrecy)) {

                        deviceChannel.setSecrecy(secrecy);

                    }



                    // 当为设备时,是否有子设备(必选)1有,0没有

                    String parental = getText(itemDevice, "Parental");

                    if (!ObjectUtils.isEmpty(parental)) {

                        try {

                            // 由于海康会错误的发送65535作为这里的取值,所以这里除非是0否则认为是1

                            if (!ObjectUtils.isEmpty(parental) && parental.length() == 1 && Integer.parseInt(parental) == 0) {

                                deviceChannel.setParental(0);

                            }else {

                                deviceChannel.setParental(1);

                            }

                        }catch (NumberFormatException e) {

                            logger.warn("[xml解析] 从通道数据获取 parental失败： {}", parental);

                        }

                    }

                    // 父设备/区域/系统ID

                    String realParentId = parentID;

                    if (!ObjectUtils.isEmpty(parentID)) {

                        if (parentID.contains("/")) {

                            String[] parentIdArray = parentID.split("/");

                            realParentId = parentIdArray[parentIdArray.length - 1];

                        }

                        deviceChannel.setParentId(realParentId);

                    }else {

                        if (!ObjectUtils.isEmpty(businessGroupID)) {

                            deviceChannel.setParentId(businessGroupID);

                        }else {

                            if (!ObjectUtils.isEmpty(civilCode)) {

                                deviceChannel.setParentId(civilCode);

                            }

                        }

                    }

                    // 注册方式

                    if (!ObjectUtils.isEmpty(registerWay)) {

                        try {

                            int registerWayInt = Integer.parseInt(registerWay);

                            deviceChannel.setRegisterWay(registerWayInt);

                        }catch (NumberFormatException exception) {

                            logger.warn("[xml解析] 从通道数据获取registerWay失败： {}", registerWay);

                            deviceChannel.setRegisterWay(1);

                        }

                    }else {

                        deviceChannel.setRegisterWay(1);

                    }



                    // 信令安全模式(可选)缺省为0; 0:不采用;2:S/MIME 签名方式;3:S/MIME加密签名同时采用方式;4:数字摘要方式

                    String safetyWay = getText(itemDevice, "SafetyWay");

                    if (!ObjectUtils.isEmpty(safetyWay)) {

                        try {

                            deviceChannel.setSafetyWay(Integer.parseInt(safetyWay));

                        }catch (NumberFormatException e) {

                            logger.warn("[xml解析] 从通道数据获取 safetyWay失败： {}", safetyWay);

                        }

                    }



                    // 证书序列号(有证书的设备必选)

                    String certNum = getText(itemDevice, "CertNum");

                    if (!ObjectUtils.isEmpty(certNum)) {

                        deviceChannel.setCertNum(certNum);

                    }



                    // 证书有效标识(有证书的设备必选)缺省为0;证书有效标识:0:无效 1:有效

                    String certifiable = getText(itemDevice, "Certifiable");

                    if (!ObjectUtils.isEmpty(certifiable)) {

                        try {

                            deviceChannel.setCertifiable(Integer.parseInt(certifiable));

                        }catch (NumberFormatException e) {

                            logger.warn("[xml解析] 从通道数据获取 Certifiable失败： {}", certifiable);

                        }

                    }



                    // 无效原因码(有证书且证书无效的设备必选)

                    String errCode = getText(itemDevice, "ErrCode");

                    if (!ObjectUtils.isEmpty(errCode)) {

                        try {

                            deviceChannel.setErrCode(Integer.parseInt(errCode));

                        }catch (NumberFormatException e) {

                            logger.warn("[xml解析] 从通道数据获取 ErrCode失败： {}", errCode);

                        }

                    }



                    // 证书终止有效期(有证书的设备必选)

                    String endTime = getText(itemDevice, "EndTime");

                    if (!ObjectUtils.isEmpty(endTime)) {

                        deviceChannel.setEndTime(endTime);

                    }





                    // 设备/区域/系统IP地址

                    String ipAddress = getText(itemDevice, "IPAddress");

                    if (!ObjectUtils.isEmpty(ipAddress)) {

                        deviceChannel.setIpAddress(ipAddress);

                    }



                    // 设备/区域/系统端口

                    String port = getText(itemDevice, "Port");

                    if (!ObjectUtils.isEmpty(port)) {

                        try {

                            deviceChannel.setPort(Integer.parseInt(port));

                        }catch (NumberFormatException e) {

                            logger.warn("[xml解析] 从通道数据获取 Port失败： {}", port);

                        }

                    }



                    // 设备口令

                    String password = getText(itemDevice, "Password");

                    if (!ObjectUtils.isEmpty(password)) {

                        deviceChannel.setPassword(password);

                    }





                    // 设备状态

                    String status = getText(itemDevice, "Status");

                    if (status != null) {

                        // ONLINE OFFLINE HIKVISION DS-7716N-E4 NVR的兼容性处理

                        if (status.equals("ON") || status.equals("On") || status.equals("ONLINE") || status.equals("OK")) {

                            deviceChannel.setStatus(1);

                        }

                        if (status.equals("OFF") || status.equals("Off") || status.equals("OFFLINE")) {

                            deviceChannel.setStatus(0);

                        }

                    }else {

                        deviceChannel.setStatus(1);

                    }



                    // 经度

                    String longitude = getText(itemDevice, "Longitude");

                    if (NumericUtil.isDouble(longitude)) {

                        deviceChannel.setLongitude(Double.parseDouble(longitude));

                    } else {

                        deviceChannel.setLongitude(0.00);

                    }



                    // 纬度

                    String latitude = getText(itemDevice, "Latitude");

                    if (NumericUtil.isDouble(latitude)) {

                        deviceChannel.setLatitude(Double.parseDouble(latitude));

                    } else {

                        deviceChannel.setLatitude(0.00);

                    }



                    deviceChannel.setGpsTime(DateUtil.getNow());



                    // -摄像机类型扩展,标识摄像机类型:1-球机;2-半球;3-固定枪机;4-遥控枪机。当目录项为摄像机时可选

                    String ptzType = getText(itemDevice, "PTZType");

                    if (ObjectUtils.isEmpty(ptzType)) {

                        //兼容INFO中的信息

                        Element info = itemDevice.element("Info");

                        String ptzTypeFromInfo = XmlUtil.getText(info, "PTZType");

                        if(!ObjectUtils.isEmpty(ptzTypeFromInfo)){

                            try {

                                deviceChannel.setPTZType(Integer.parseInt(ptzTypeFromInfo));

                            }catch (NumberFormatException e){

                                logger.warn("[xml解析] 从通道数据info中获取PTZType失败： {}", ptzTypeFromInfo);

                            }

                        }

                    } else {

                        try {

                            deviceChannel.setPTZType(Integer.parseInt(ptzType));

                        }catch (NumberFormatException e){

                            logger.warn("[xml解析] 从通道数据中获取PTZType失败： {}", ptzType);

                        }

                    }



                    // TODO 摄像机位置类型扩展。

                    // 1-省际检查站、

                    // 2-党政机关、

                    // 3-车站码头、

                    // 4-中心广场、

                    // 5-体育场馆、

                    // 6-商业中心、

                    // 7-宗教场所、

                    // 8-校园周边、

                    // 9-治安复杂区域、

                    // 10-交通干线。

                    // String positionType = getText(itemDevice, "PositionType");



                    // TODO 摄像机安装位置室外、室内属性。1-室外、2-室内。

                    // String roomType = getText(itemDevice, "RoomType");

                    // TODO 摄像机用途属性

                    // String useType = getText(itemDevice, "UseType");

                    // TODO 摄像机补光属性。1-无补光、2-红外补光、3-白光补光

                    // String supplyLightType = getText(itemDevice, "SupplyLightType");

                    // TODO 摄像机监视方位属性。1-东、2-西、3-南、4-北、5-东南、6-东北、7-西南、8-西北。

                    // String directionType = getText(itemDevice, "DirectionType");

                    // TODO 摄像机支持的分辨率,可有多个分辨率值,各个取值间以“/”分隔。分辨率取值参见附录 F中SDPf字段规定

                    // String resolution = getText(itemDevice, "Resolution");



                    // TODO 下载倍速范围(可选),各可选参数以“/”分隔,如设备支持1,2,4倍速下载则应写为“1/2/4

                    // String downloadSpeed = getText(itemDevice, "DownloadSpeed");

                    // TODO 空域编码能力,取值0:不支持;1:1级增强(1个增强层);2:2级增强(2个增强层);3:3级增强(3个增强层)

                    // String svcSpaceSupportMode = getText(itemDevice, "SVCSpaceSupportMode");

                    // TODO 时域编码能力,取值0:不支持;1:1级增强;2:2级增强;3:3级增强

                    // String svcTimeSupportMode = getText(itemDevice, "SVCTimeSupportMode");





                    deviceChannel.setSecrecy(secrecy);

                    break;

            }

        }

        deviceChannel.setHasAudio(true); // 默认含有音频，播放时再检查是否有音频及是否AAC



        return deviceChannel;

    }



    /**

     * 新增方法支持内部嵌套

     *

     * @param element xmlElement

     * @param clazz 结果类

     * @param <T> 泛型

     * @return 结果对象

     * @throws NoSuchMethodException

     * @throws InvocationTargetException

     * @throws InstantiationException

     * @throws IllegalAccessException

     */

    public static <T> T loadElement(Element element, Class<T> clazz) throws NoSuchMethodException, InvocationTargetException, InstantiationException, IllegalAccessException {

        Field[] fields = clazz.getDeclaredFields();

        T t = clazz.getDeclaredConstructor().newInstance();

        for (Field field : fields) {

            ReflectionUtils.makeAccessible(field);

            MessageElement annotation = field.getAnnotation(MessageElement.class);

            if (annotation == null) {

                continue;

            }

            String value = annotation.value();

            String subVal = annotation.subVal();

            Element element1 = element.element(value);

            if (element1 == null) {

                continue;

            }

            if ("".equals(subVal)) {

                // 无下级数据

                Object fieldVal = element1.isTextOnly() ? element1.getText() : loadElement(element1, field.getType());

                Object o = simpleTypeDeal(field.getType(), fieldVal);

                ReflectionUtils.setField(field, t,  o);

            } else {

                // 存在下级数据

                ArrayList<Object> list = new ArrayList<>();

                Type genericType = field.getGenericType();

                if (!(genericType instanceof ParameterizedType)) {

                    continue;

                }

                Class<?> aClass = (Class<?>) ((ParameterizedType) genericType).getActualTypeArguments()[0];

                for (Element element2 : element1.elements(subVal)) {

                    list.add(loadElement(element2, aClass));

                }

                ReflectionUtils.setField(field, t, list);

            }

        }

        return t;

    }



    /**

     * 简单类型处理

     *

     * @param tClass

     * @param val

     * @return

     */

    private static Object simpleTypeDeal(Class<?> tClass, Object val) {

        if (tClass.equals(String.class)) {

            return val.toString();

        }

        if (tClass.equals(Integer.class)) {

            return Integer.valueOf(val.toString());

        }

        if (tClass.equals(Double.class)) {

            return Double.valueOf(val.toString());

        }

        if (tClass.equals(Long.class)) {

            return Long.valueOf(val.toString());

        }

        return val;

    }

}