| | |
|---|
| | | package com.genersoft.iot.vmp.gb28181.utils;
|
|---|
| | |
|
|---|
| | | import java.io.StringReader;
|
|---|
| | | import java.util.ArrayList;
|
|---|
| | | import java.util.HashMap;
|
|---|
| | | import java.util.Iterator;
|
|---|
| | | import java.util.List;
|
|---|
| | | import java.util.Map;
|
|---|
| | |
|
|---|
| | | import com.alibaba.fastjson.JSONArray;
|
|---|
| | | import com.alibaba.fastjson.JSONObject;
|
|---|
| | | import com.genersoft.iot.vmp.gb28181.bean.DeviceChannel;
|
|---|
| | | import org.dom4j.Attribute;
|
|---|
| | | import org.dom4j.Document;
|
|---|
| | | import org.dom4j.DocumentException;
|
|---|
| | |
|---|
| | | import org.dom4j.io.SAXReader;
|
|---|
| | | import org.slf4j.Logger;
|
|---|
| | | import org.slf4j.LoggerFactory;
|
|---|
| | | import org.springframework.util.StringUtils;
|
|---|
| | |
|
|---|
| | | import javax.sip.RequestEvent;
|
|---|
| | | import javax.sip.message.Request;
|
|---|
| | | import java.io.ByteArrayInputStream;
|
|---|
| | | import java.io.StringReader;
|
|---|
| | | import java.util.*;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 基于dom4j的工具包
|
|---|
| | | *
|
|---|
| | | *
|
|---|
| | | */
|
|---|
| | | public class XmlUtil
|
|---|
| | | {
|
|---|
| | | public class XmlUtil {
|
|---|
| | | /**
|
|---|
| | | * 日志服务
|
|---|
| | | */
|
|---|
| | |
|---|
| | | /**
|
|---|
| | | * 解析XML为Document对象
|
|---|
| | | *
|
|---|
| | | * @param xml
|
|---|
| | | * 被解析的XMl
|
|---|
| | | * @param xml 被解析的XMl
|
|---|
| | | * |
|---|
| | | * @return Document
|
|---|
| | | */
|
|---|
| | | public static Element parseXml(String xml)
|
|---|
| | | {
|
|---|
| | | public static Element parseXml(String xml) {
|
|---|
| | | Document document = null;
|
|---|
| | | //
|
|---|
| | | StringReader sr = new StringReader(xml);
|
|---|
| | | SAXReader saxReader = new SAXReader();
|
|---|
| | | try
|
|---|
| | | {
|
|---|
| | | try {
|
|---|
| | | document = saxReader.read(sr);
|
|---|
| | | }
|
|---|
| | | catch (DocumentException e)
|
|---|
| | | {
|
|---|
| | | } catch (DocumentException e) {
|
|---|
| | | LOG.error("解析失败", e);
|
|---|
| | | }
|
|---|
| | | return null == document ? null : document.getRootElement();
|
|---|
| | |
|---|
| | | /**
|
|---|
| | | * 获取element对象的text的值
|
|---|
| | | *
|
|---|
| | | * @param em
|
|---|
| | | * 节点的对象
|
|---|
| | | * @param tag
|
|---|
| | | * 节点的tag
|
|---|
| | | * @param em 节点的对象
|
|---|
| | | * @param tag 节点的tag
|
|---|
| | | * @return 节点
|
|---|
| | | */
|
|---|
| | | public static String getText(Element em, String tag)
|
|---|
| | | {
|
|---|
| | | if (null == em)
|
|---|
| | | {
|
|---|
| | | public static String getText(Element em, String tag) {
|
|---|
| | | if (null == em) {
|
|---|
| | | return null;
|
|---|
| | | }
|
|---|
| | | Element e = em.element(tag);
|
|---|
| | |
|---|
| | | /**
|
|---|
| | | * 递归解析xml节点，适用于 多节点数据
|
|---|
| | | *
|
|---|
| | | * @param node
|
|---|
| | | * node
|
|---|
| | | * @param nodeName
|
|---|
| | | * nodeName
|
|---|
| | | * @param node node
|
|---|
| | | * @param nodeName nodeName
|
|---|
| | | * @return List<Map<String, Object>>
|
|---|
| | | */
|
|---|
| | | public static List<Map<String, Object>> listNodes(Element node, String nodeName)
|
|---|
| | | {
|
|---|
| | | if (null == node)
|
|---|
| | | {
|
|---|
| | | public static List<Map<String, Object>> listNodes(Element node, String nodeName) {
|
|---|
| | | if (null == node) {
|
|---|
| | | return null;
|
|---|
| | | }
|
|---|
| | | // 初始化返回
|
|---|
| | |
|---|
| | |
|
|---|
| | | Map<String, Object> map = null;
|
|---|
| | | // 遍历属性节点
|
|---|
| | | for (Attribute attribute : list)
|
|---|
| | | {
|
|---|
| | | if (nodeName.equals(node.getName()))
|
|---|
| | | {
|
|---|
| | | if (null == map)
|
|---|
| | | {
|
|---|
| | | for (Attribute attribute : list) {
|
|---|
| | | if (nodeName.equals(node.getName())) {
|
|---|
| | | if (null == map) {
|
|---|
| | | map = new HashMap<String, Object>();
|
|---|
| | | listMap.add(map);
|
|---|
| | | }
|
|---|
| | |
|---|
| | | // 遍历当前节点下的所有节点 ，nodeName 要解析的节点名称
|
|---|
| | | // 使用递归
|
|---|
| | | Iterator<Element> iterator = node.elementIterator();
|
|---|
| | | while (iterator.hasNext())
|
|---|
| | | {
|
|---|
| | | while (iterator.hasNext()) {
|
|---|
| | | Element e = iterator.next();
|
|---|
| | | listMap.addAll(listNodes(e, nodeName));
|
|---|
| | | }
|
|---|
| | | return listMap;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * xml转json
|
|---|
| | | * |
|---|
| | | * @param element
|
|---|
| | | * @param json
|
|---|
| | | */
|
|---|
| | | public static void node2Json(Element element, JSONObject json) {
|
|---|
| | | // 如果是属性
|
|---|
| | | for (Object o : element.attributes()) {
|
|---|
| | | Attribute attr = (Attribute) o;
|
|---|
| | | if (!StringUtils.isEmpty(attr.getValue())) {
|
|---|
| | | json.put("@" + attr.getName(), attr.getValue());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | List<Element> chdEl = element.elements();
|
|---|
| | | if (chdEl.isEmpty() && !StringUtils.isEmpty(element.getText())) {// 如果没有子元素,只有一个值
|
|---|
| | | json.put(element.getName(), element.getText());
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | for (Element e : chdEl) { // 有子元素
|
|---|
| | | if (!e.elements().isEmpty()) { // 子元素也有子元素
|
|---|
| | | JSONObject chdjson = new JSONObject();
|
|---|
| | | node2Json(e, chdjson);
|
|---|
| | | Object o = json.get(e.getName());
|
|---|
| | | if (o != null) {
|
|---|
| | | JSONArray jsona = null;
|
|---|
| | | if (o instanceof JSONObject) { // 如果此元素已存在,则转为jsonArray
|
|---|
| | | JSONObject jsono = (JSONObject) o;
|
|---|
| | | json.remove(e.getName());
|
|---|
| | | jsona = new JSONArray();
|
|---|
| | | jsona.add(jsono);
|
|---|
| | | jsona.add(chdjson);
|
|---|
| | | }
|
|---|
| | | if (o instanceof JSONArray) {
|
|---|
| | | jsona = (JSONArray) o;
|
|---|
| | | jsona.add(chdjson);
|
|---|
| | | }
|
|---|
| | | json.put(e.getName(), jsona);
|
|---|
| | | } else {
|
|---|
| | | if (!chdjson.isEmpty()) {
|
|---|
| | | json.put(e.getName(), chdjson);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | } else { // 子元素没有子元素
|
|---|
| | | for (Object o : element.attributes()) {
|
|---|
| | | Attribute attr = (Attribute) o;
|
|---|
| | | if (!StringUtils.isEmpty(attr.getValue())) {
|
|---|
| | | json.put("@" + attr.getName(), attr.getValue());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | if (!e.getText().isEmpty()) {
|
|---|
| | | json.put(e.getName(), e.getText());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | public static Element getRootElement(RequestEvent evt) throws DocumentException {
|
|---|
| | |
|
|---|
| | | return getRootElement(evt, "gb2312");
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public static Element getRootElement(RequestEvent evt, String charset) throws DocumentException {
|
|---|
| | | Request request = evt.getRequest();
|
|---|
| | | return getRootElement(request.getRawContent(), charset);
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public static Element getRootElement(byte[] content, String charset) throws DocumentException {
|
|---|
| | | if (charset == null) {
|
|---|
| | | charset = "gb2312";
|
|---|
| | | }
|
|---|
| | | SAXReader reader = new SAXReader();
|
|---|
| | | reader.setEncoding(charset);
|
|---|
| | | Document xml = reader.read(new ByteArrayInputStream(content));
|
|---|
| | | return xml.getRootElement();
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | public static DeviceChannel channelContentHander(Element itemDevice){
|
|---|
| | | 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";
|
|---|
| | | DeviceChannel deviceChannel = new DeviceChannel();
|
|---|
| | | deviceChannel.setName(channelName);
|
|---|
| | | Element channdelIdElement = itemDevice.element("DeviceID");
|
|---|
| | | String channelId = channdelIdElement != null ? channdelIdElement.getTextTrim().toString() : "";
|
|---|
| | | deviceChannel.setChannelId(channelId);
|
|---|
| | | // ONLINE OFFLINE HIKVISION DS-7716N-E4 NVR的兼容性处理
|
|---|
| | | if (status.equals("ON") || status.equals("On") || status.equals("ONLINE")) {
|
|---|
| | | 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"));
|
|---|
| | | if (XmlUtil.getText(itemDevice, "Parental") == null
|
|---|
| | | || XmlUtil.getText(itemDevice, "Parental") == "") {
|
|---|
| | | deviceChannel.setParental(0);
|
|---|
| | | } else {
|
|---|
| | | deviceChannel.setParental(Integer.parseInt(XmlUtil.getText(itemDevice, "Parental")));
|
|---|
| | | }
|
|---|
| | | deviceChannel.setParentId(XmlUtil.getText(itemDevice, "ParentID"));
|
|---|
| | | 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 (XmlUtil.getText(itemDevice, "PTZType") == null
|
|---|
| | | || XmlUtil.getText(itemDevice, "PTZType") == "") {
|
|---|
| | | deviceChannel.setPTZType(0);
|
|---|
| | | } else {
|
|---|
| | | deviceChannel.setPTZType(Integer.parseInt(XmlUtil.getText(itemDevice, "PTZType")));
|
|---|
| | | }
|
|---|
| | | deviceChannel.setHasAudio(true); // 默认含有音频，播放时再检查是否有音频及是否AAC
|
|---|
| | | return deviceChannel;
|
|---|
| | | }
|
|---|
| | | }
|
|---|
