wvp-pro.git - Gitblit

			@@ -1,15 +1,12 @@
			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.Device;
			import com.genersoft.iot.vmp.gb28181.bean.DeviceChannel;
			import com.genersoft.iot.vmp.gb28181.bean.TreeType;
			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;
			@@ -17,23 +14,31 @@
			import org.dom4j.io.SAXReader;
			import org.slf4j.Logger;
			import org.slf4j.LoggerFactory;
			import org.springframework.util.ObjectUtils;
			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 {
			/**
			* 日志服务
			*/
			private static Logger LOG = LoggerFactory.getLogger(XmlUtil.class);
			private static Logger logger = LoggerFactory.getLogger(XmlUtil.class);

			/**
			* 解析XML为Document对象
			*
			*
			* @param xml 被解析的XMl
			*
			*
			* @return Document
			*/
			public static Element parseXml(String xml) {
			@@ -44,14 +49,14 @@
			try {
			document = saxReader.read(sr);
			} catch (DocumentException e) {
			LOG.error("解析失败", e);
			logger.error("解析失败", e);
			}
			return null == document ? null : document.getRootElement();
			}

			/**
			* 获取element对象的text的值
			*
			*
			* @param em 节点的对象
			* @param tag 节点的tag
			* @return 节点
			@@ -62,12 +67,12 @@
			}
			Element e = em.element(tag);
			//
			return null == e ? null : e.getText();
			return null == e ? null : e.getText().trim();
			}

			/**
			* 递归解析xml节点，适用于多节点数据
			*
			*
			* @param node node
			* @param nodeName nodeName
			* @return List<Map<String, Object>>
			@@ -106,7 +111,7 @@

			/**
			* xml转json
			*
			*
			* @param element
			* @param json
			*/
			@@ -114,12 +119,12 @@
			// 如果是属性
			for (Object o : element.attributes()) {
			Attribute attr = (Attribute) o;
			if (!isEmpty(attr.getValue())) {
			if (!ObjectUtils.isEmpty(attr.getValue())) {
			json.put("@" + attr.getName(), attr.getValue());
			}
			}
			List<Element> chdEl = element.elements();
			if (chdEl.isEmpty() && !isEmpty(element.getText())) {// 如果没有子元素,只有一个值
			if (chdEl.isEmpty() && !ObjectUtils.isEmpty(element.getText())) {// 如果没有子元素,只有一个值
			json.put(element.getName(), element.getText());
			}

			@@ -150,7 +155,7 @@
			} else { // 子元素没有子元素
			for (Object o : element.attributes()) {
			Attribute attr = (Attribute) o;
			if (!isEmpty(attr.getValue())) {
			if (!ObjectUtils.isEmpty(attr.getValue())) {
			json.put("@" + attr.getName(), attr.getValue());
			}
			}
			@@ -160,11 +165,246 @@
			}
			}
			}
			public static Element getRootElement(RequestEvent evt) throws DocumentException {

			public static boolean isEmpty(String str) {
			if (str == null \|\| str.trim().isEmpty() \|\| "null".equals(str)) {
			return true;
			}
			return false;
			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();
			}

			private enum ChannelType{
			CivilCode, BusinessGroup,VirtualOrganization,Other
			}

			public static DeviceChannel channelContentHander(Element itemDevice, Device device, String event){
			DeviceChannel deviceChannel = new DeviceChannel();
			deviceChannel.setDeviceId(device.getDeviceId());
			Element channdelIdElement = itemDevice.element("DeviceID");
			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);
			if (event != null && !event.equals(CatalogEvent.ADD) && !event.equals(CatalogEvent.UPDATE)) {
			// 除了ADD和update情况下需要识别全部内容，
			return deviceChannel;
			}

			ChannelType channelType = ChannelType.Other;
			if (channelId.length() <= 8) {
			channelType = ChannelType.CivilCode;
			deviceChannel.setHasAudio(false);
			}else {
			if (channelId.length() == 20) {
			int code = Integer.parseInt(channelId.substring(10, 13));
			switch (code){
			case 215:
			channelType = ChannelType.BusinessGroup;
			deviceChannel.setHasAudio(false);
			break;
			case 216:
			channelType = ChannelType.VirtualOrganization;
			deviceChannel.setHasAudio(false);
			break;
			case 136:
			case 137:
			case 138:
			deviceChannel.setHasAudio(true);
			break;
			default:
			deviceChannel.setHasAudio(false);
			break;

			}
			}
			}

			Element channdelNameElement = itemDevice.element("Name");
			String channelName = channdelNameElement != null ? channdelNameElement.getTextTrim() : "";
			deviceChannel.setName(channelName);

			String civilCode = XmlUtil.getText(itemDevice, "CivilCode");
			deviceChannel.setCivilCode(civilCode);
			if (channelType == ChannelType.CivilCode && civilCode == null) {
			deviceChannel.setParental(1);
			// 行政区划如果没有传递具体值，则推测一个
			if (channelId.length() > 2) {
			deviceChannel.setCivilCode(channelId.substring(0, channelId.length() - 2));
			}
			}
			if (channelType.equals(ChannelType.CivilCode)) {
			// 行政区划其他字段没必要识别了，默认在线即可
			deviceChannel.setStatus(1);
			deviceChannel.setParental(1);
			deviceChannel.setCreateTime(DateUtil.getNow());
			deviceChannel.setUpdateTime(DateUtil.getNow());
			return deviceChannel;
			}
			/**
			* 行政区划展示设备树与业务分组展示设备树是两种不同的模式
			* 行政区划展示设备树各个目录之间主要靠deviceId做关联,摄像头通过CivilCode指定其属于那个行政区划;都是不超过十位的编号; 结构如下:
			* 河北省
			* --> 石家庄市
			* --> 摄像头
			*String parentId = XmlUtil.getText(itemDevice, "ParentID");
			if (parentId != null) {
			if (parentId.contains("/")) {
			String lastParentId = parentId.substring(parentId.lastIndexOf("/") + 1);
			String businessGroup = parentId.substring(0, parentId.indexOf("/"));
			deviceChannel.setParentId(lastParentId);
			}else {
			deviceChannel.setParentId(parentId);
			}
			}
			deviceCh --> 正定县
			* --> 摄像头
			* --> 摄像头
			*
			* 业务分组展示设备树是顶级是业务分组,其下的虚拟组织靠BusinessGroupID指定其所属的业务分组;摄像头通过ParentId来指定其所属于的虚拟组织:
			* 业务分组
			* --> 虚拟组织
			* --> 摄像头
			* --> 虚拟组织
			* --> 摄像头
			* --> 摄像头
			*/
			String parentId = XmlUtil.getText(itemDevice, "ParentID");
			String businessGroupID = XmlUtil.getText(itemDevice, "BusinessGroupID");
			if (parentId != null) {
			if (parentId.contains("/")) {
			String lastParentId = parentId.substring(parentId.lastIndexOf("/") + 1);
			if (businessGroupID == null) {
			businessGroupID = parentId.substring(0, parentId.indexOf("/"));
			}
			deviceChannel.setParentId(lastParentId);
			}else {
			deviceChannel.setParentId(parentId);
			}
			}
			deviceChannel.setBusinessGroupId(businessGroupID);
			if (channelType.equals(ChannelType.BusinessGroup) \|\| channelType.equals(ChannelType.VirtualOrganization)) {
			// 业务分组和虚拟组织其他字段没必要识别了，默认在线即可
			deviceChannel.setStatus(1);
			deviceChannel.setParental(1);
			deviceChannel.setCreateTime(DateUtil.getNow());
			deviceChannel.setUpdateTime(DateUtil.getNow());
			return deviceChannel;
			}

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

			if (statusElement != null) {
			String status = statusElement.getTextTrim().trim();
			// 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 parental = XmlUtil.getText(itemDevice, "Parental");
			// 由于海康会错误的发送65535作为这里的取值,所以这里除非是0否则认为是1
			if (!ObjectUtils.isEmpty(parental) && parental.length() == 1 && Integer.parseInt(parental) == 0) {
			deviceChannel.setParental(0);
			}else {
			deviceChannel.setParental(1);
			}


			deviceChannel.setManufacture(XmlUtil.getText(itemDevice, "Manufacturer"));
			deviceChannel.setModel(XmlUtil.getText(itemDevice, "Model"));
			deviceChannel.setOwner(XmlUtil.getText(itemDevice, "Owner"));
			deviceChannel.setCertNum(XmlUtil.getText(itemDevice, "CertNum"));
			deviceChannel.setBlock(XmlUtil.getText(itemDevice, "Block"));
			deviceChannel.setAddress(XmlUtil.getText(itemDevice, "Address"));
			deviceChannel.setPassword(XmlUtil.getText(itemDevice, "Password"));

			String safetyWay = XmlUtil.getText(itemDevice, "SafetyWay");
			if (ObjectUtils.isEmpty(safetyWay)) {
			deviceChannel.setSafetyWay(0);
			} else {
			deviceChannel.setSafetyWay(Integer.parseInt(safetyWay));
			}

			String registerWay = XmlUtil.getText(itemDevice, "RegisterWay");
			if (ObjectUtils.isEmpty(registerWay)) {
			deviceChannel.setRegisterWay(1);
			} else {
			deviceChannel.setRegisterWay(Integer.parseInt(registerWay));
			}

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


			String longitude = XmlUtil.getText(itemDevice, "Longitude");
			if (NumericUtil.isDouble(longitude)) {
			deviceChannel.setLongitude(Double.parseDouble(longitude));
			} else {
			deviceChannel.setLongitude(0.00);
			}
			String latitude = XmlUtil.getText(itemDevice, "Latitude");
			if (NumericUtil.isDouble(latitude)) {
			deviceChannel.setLatitude(Double.parseDouble(latitude));
			} else {
			deviceChannel.setLatitude(0.00);
			}
			deviceChannel.setGpsTime(DateUtil.getNow());


			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")));
			}
			} else {
			deviceChannel.setPTZType(Integer.parseInt(XmlUtil.getText(itemDevice, "PTZType")));
			}
			return deviceChannel;
			}
			}