EPLAN_PROD_Plugin/Sinvo.EplanHpD.Plugin.DynaClient/XmlFormatStream.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Xml;

namespace Sinvo.EplanHpD.Plugin.DynaClient
{
    class XmlFormatStream
    {
        private const string XTN_PDMOUT_STATUS = "pdmOut/status";
        private const string XTN_PDMOUT_MESSAGE = "pdmOut/message";
        private const string XTN_PDMOUT_RESULT = "pdmOut/result";
        private const string XTN_PDMOUT_RESULT_FIELDTYPE = "pdmOut/result/fieldtype";
        private const string XTN_PDMOUT_RESULT_FIELDNAME = "pdmOut/result/fieldname";
        private const string XTN_PDMOUT_RESULT_VALUE_ROW = "pdmOut/result/value/row";
        private const string XTN_PDMIN = "pdmIn";
        private const string XTN_PDM_IN_SERIAL = "serial";
        private const string XTN_PDM_IN_PARAM = "param";
        private const string XTN_PDM_IN_FIELD_TYPE = "fieldtype";
        private const string XTN_PDM_IN_FIELD_NAME = "fieldname";
        private const string XTN_PDM_IN_FIELD_VALUE = "value";
        private const string XTN_PDM_IN_FIELD_VALUE_ROW = "row";
        private const string XAN_PDM_IN_PARAM_TYPE = "type";

        /// <summary>
        /// 检查XML流是不是个异常
        /// </summary>
        /// <param name="xmlStream"></param>
        public static void CheckXmlException(string xmlStream)
        {
            XmlDocument xmlDoc = new XmlDocument();
            xmlDoc.LoadXml(xmlStream);
            XmlNode statusNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_STATUS);
            if (statusNode == null)
            {
                return;
            }
            string strStatus = statusNode.InnerText;
            if (strStatus.CompareTo("1") == 0)
            {
                // 失败
                XmlNode msgNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_MESSAGE);
                if (msgNode == null)
                {
                    throw new Exception("无法解析XML，请检查");
                }
                string strFailedMsg = msgNode.InnerText;
                throw new Exception(strFailedMsg);
            }
            else if (strStatus.CompareTo("201") == 0)
            {
                throw new Exception("登录过期！");
            }
        }
        /// <summary>
        /// PDM XML格式返回值转化成String类型
        /// </summary>
        /// <param name="xmlStream">xml流字符串</param>
        /// <returns></returns>
        public static string PDMSimpleReturnXmlStreamToString(string xmlStream)
        {
            //<pdmOut>
            //  <serial>simple</serial> 
            //  <starttime>2009-07-08 10:40:00</starttime> 
            //  <endtime>2009-07-08 10:40:02</endtime> 
            //  <status>0/1</status> 
            //  <message>login sucessfully!</message> 
            //  <exception /> 
            //  <result type="string">5F2BB7B637654441BB3460C3A55386A7</result> 
            //</pdmOut>

            string strResult = "";

            XmlDocument xmlDoc = new XmlDocument();
            xmlDoc.LoadXml(xmlStream);

            XmlNode statusNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_STATUS);
            if (statusNode == null)
            {
                throw new Exception();
            }
            string strStatus = statusNode.InnerText;
            if (strStatus.CompareTo("1") == 0)
            {
                // 失败
                XmlNode msgNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_MESSAGE);
                if (msgNode == null)
                {
                    throw new Exception();
                }
                string strFailedMsg = msgNode.InnerText;
                throw new Exception(strFailedMsg);
            }
            else if (strStatus.CompareTo("201") == 0)
            {
                throw new Exception("登录过期！");
            }
            else
            {
                XmlNode resultNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_RESULT);
                if (resultNode == null)
                {
                    throw new Exception();
                }
                strResult = resultNode.InnerText;
                return strResult;
            }
        }

        /// <summary>
        /// 获取由PDMRecordReturnXMLStreamToString解析后的某个字段的值
        /// </summary>
        /// <param name="strFieldName">传入要获取的字段名</param>
        /// <param name="arrFieldTypeString">所要查找的所有字段类型</param>
        /// <param name="arrFieldNameString">所要查找的所有字段名称</param>
        /// <param name="arrFieldValueString">所要查找的所有字段值</param>
        /// <param name="strFieldType">返回查找字段的类型</param>
        /// <param name="strFieldValue">返回查找字段的值</param>
        /// <returns></returns>
        public static bool GetFieldValueByName(string strFieldName, string[] arrFieldTypeString,
                                                string[] arrFieldNameString, string[] arrFieldValueString,
                                                out string strFieldType, out string strFieldValue)
        {
            strFieldType = "";
            strFieldValue = "";
            if (string.IsNullOrEmpty(strFieldName))
            {
                return false;
            }
            if ((arrFieldTypeString == null) || (arrFieldNameString == null) || (arrFieldValueString == null))
            {
                return false;
            }
            if (arrFieldNameString.Length < 1)
            {
                return false;
            }
            if (arrFieldTypeString.Length != arrFieldNameString.Length)
            {
                return false;
            }
            if (arrFieldTypeString.Length != arrFieldValueString.Length)
            {
                return false;
            }

            for (int i = 0; i < arrFieldNameString.Length; i++)
            {
                if (string.Compare(arrFieldNameString[i], strFieldName) == 0)
                {
                    strFieldType = arrFieldTypeString[i];
                    strFieldValue = arrFieldValueString[i];
                    return true;
                }
            }

            return false;
        }

        public static List<string> PDMRecordReturnXMLStreamRowToList(string xmlStream)
        {
            //<pdmOut>
            //  <serial>record</serial>
            //  <starttime>2014-11-25 17:19:16</starttime>
            //  <endtime>2014-11-25 17:19:16</endtime>
            //  <status>0</status>
            //  <result type="record">
            //    <fieldtype>String</fieldtype>
            //    <fieldname>filename</fieldname>   <--字段名为FileName，其实传回的是文件的本地完整路径
            //    <value>
            //      <row>D:\\ws\\SolidWorks\\测试博众-图档管理性能\\BZPART01.SLDPRT|D:\\ws\\SolidWorks\\测试博众-图档管理性能\\BZPART23.SLDPRT</row>
            //    </value>
            //  </result>
            //</pdmOut>
            XmlDocument doc = new XmlDocument();
            doc.LoadXml(xmlStream);
            XmlNode pdmOut = doc.SelectSingleNode("pdmOut");
            if (pdmOut == null)
                return null;
            XmlNode rt = pdmOut.SelectSingleNode("result");
            if (rt == null)
                return null;
            XmlNode val = rt.SelectSingleNode("value");
            if (val == null)
                return null;
            XmlNode row = val.SelectSingleNode("row");
            if (row == null)
                return null;
            string[] strs = row.InnerText.Trim().Split('|');
            if (strs.Length > 0)
            {
                return new List<string>(strs);
            }

            return null;
        }


        public static void PDMRecordReturnXMLStreamToString(string xmlStream,
                                                      out string fieldTypeString,
                                                      out string fieldNameString,
                                                      out List<string> fieldValueStringList)

        {
            #region WebService XML流格式返回值格式
            //<pdmOut>
            //  <serial>record</serial> 
            //  <starttime>2009-07-08 10:40:00</starttime> 
            //  <endtime>2009-07-08 10:40:02</endtime> 
            //  <status>0/1</status> 
            //  <message>login sucessfully!</message> 
            //  <exception /> 
            //  <result type="record">
            //    <type>string|string|string|boolean|byte|int|float|double|date|datetime</type> 
            //    <field>guid|md$number|md$description|booleanValue|byteValue|intValue|floatValue|doubleValue|dateValue|datetimeValue</field> 
            //    <value>
            //       <row>doc$vf@8606abcd|doc-001|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:10:00</row> 
            //       <row>doc$vf@8606abce|doc-002|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:20:00</row> 
            //       <row>doc$vf@8606abd0|doc-003|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:30:00</row> 
            //       <row>doc$vf@8606abd1|doc-004|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:40:00</row> 
            //    </value>
            //  </result>
            //</pdmOut>
            #endregion

            fieldTypeString = "";
            fieldNameString = "";
            fieldValueStringList = new List<string>();

            XmlDocument xmlDoc = new XmlDocument();
            xmlDoc.LoadXml(xmlStream);

            XmlNode statusNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_STATUS);
            if (statusNode == null)
            {
                throw new Exception();
            }
            string strStatus = statusNode.InnerText;
            if (strStatus.CompareTo("1") == 0)
            {
                // 失败
                XmlNode messageNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_MESSAGE);
                if (messageNode == null)
                {
                    throw new Exception();
                }

                string strFailedMsg = messageNode.InnerText;
                throw new Exception(strFailedMsg);
            }
            else if (strStatus.CompareTo("201") == 0)
            {
                throw new Exception("登录过期！");
            }
            else
            {
                XmlNode fieldTypeNode = null;
                XmlNode fieldNameNode = null;
                fieldTypeNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_RESULT_FIELDTYPE);
                fieldNameNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_RESULT_FIELDNAME);
                if (fieldTypeNode == null || fieldNameNode == null)
                {
                    throw new Exception();
                }
                fieldTypeString = fieldTypeNode.InnerText;
                fieldNameString = fieldNameNode.InnerText;
                XmlNodeList valueNodeList = xmlDoc.SelectNodes(XTN_PDMOUT_RESULT_VALUE_ROW);
                if (valueNodeList != null)
                {
                    foreach (XmlNode tmpNode in valueNodeList)
                    {
                        fieldValueStringList.Add(tmpNode.InnerText);
                    }
                }
            }

        }


        /// <summary>
        /// Record类型字符串转化成PDM　XML流类型参数
        /// </summary>
        /// <param name="typeString">参数的类型组合字符串</param>
        /// <param name="fieldString">参数名称组合字符串</param>
        /// <param name="valueStringList">参数值组合字符串列表</param>
        /// <returns>XML流类型字符串</returns>
        public static string RecordParameterToXmlStream(string typeString, string fieldString, List<string> valueStringList)
        {
            //<!--record 数据类型-->
            // <pdmIn>
            //  <serial>record</serial> 
            //  <param type="record/bom">
            //      <fieldtype>string|string|string|boolean|byte|int|float|double|date|datetime</fieldtype> 
            //      <fieldname>guid|md$number|md$description|booleanValue|byteValue|intValue|floatValue|doubleValue|dateValue|datetimeValue</fieldname> 
            //      <value>
            //          <row>doc$vf@8606abcd|doc-001|11|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:10:00</row> 
            //          <row>doc$vf@8606abce|doc-002|22|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:20:00</row> 
            //          <row>doc$vf@8606abd0|doc-003|33|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:30:00</row> 
            //          <row>doc$vf@8606abd1|doc-004|44|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:40:00</row>
            //      </value>
            //  </param>
            // </pdmIn>

            XmlDocument xmlDoc = new XmlDocument();
            XmlElement rootElement = xmlDoc.CreateElement(XTN_PDMIN);
            xmlDoc.AppendChild(rootElement);

            XmlElement serialElement = xmlDoc.CreateElement(XTN_PDM_IN_SERIAL);
            serialElement.InnerText = "record";
            rootElement.AppendChild(serialElement);

            XmlElement paramElement = xmlDoc.CreateElement(XTN_PDM_IN_PARAM);
            paramElement.SetAttribute(XAN_PDM_IN_PARAM_TYPE, "record");
            rootElement.AppendChild(paramElement);

            XmlElement typeElement = xmlDoc.CreateElement(XTN_PDM_IN_FIELD_TYPE);
            typeElement.InnerText = typeString;
            paramElement.AppendChild(typeElement);

            XmlElement fieldElement = xmlDoc.CreateElement(XTN_PDM_IN_FIELD_NAME);
            fieldElement.InnerText = fieldString;
            paramElement.AppendChild(fieldElement);

            XmlElement valueElement = xmlDoc.CreateElement(XTN_PDM_IN_FIELD_VALUE);
            paramElement.AppendChild(valueElement);

            foreach (string tmpValueString in valueStringList)
            {
                XmlElement tmpRowElement = xmlDoc.CreateElement(XTN_PDM_IN_FIELD_VALUE_ROW);
                tmpRowElement.InnerText = tmpValueString;
                valueElement.AppendChild(tmpRowElement);
            }
            //LogFile.WriteMessageToLog($"RecordParameterToXmlStream->\r\n{xmlDoc.InnerXml}");
            return xmlDoc.InnerXml;
        }

        /// <summary>
        /// 从XML流中转换成对象
        /// </summary>
        /// <typeparam name="T">要转换成的对象类型</typeparam>
        /// <param name="xml">XML字符串</param>
        /// <param name="clazz">对象类型</param>
        /// <returns>转换后的对象</returns>
        public static List<T> ConvertXMLToObjectList<T>(string xml)
        {
            #region WebService XML流格式返回值格式
            //<pdmOut>
            //  <serial>record</serial> 
            //  <starttime>2009-07-08 10:40:00</starttime> 
            //  <endtime>2009-07-08 10:40:02</endtime> 
            //  <status>0/1</status> 
            //  <message>login sucessfully!</message> 
            //  <exception /> 
            //  <result type="record">
            //    <type>string|string|string|boolean|byte|int|float|double|date|datetime</type> 
            //    <field>guid|md$number|md$description|booleanValue|byteValue|intValue|floatValue|doubleValue|dateValue|datetimeValue</field> 
            //    <value>
            //       <row>doc$vf@8606abcd|doc-001|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:10:00</row> 
            //       <row>doc$vf@8606abce|doc-002|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:20:00</row> 
            //       <row>doc$vf@8606abd0|doc-003|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:30:00</row> 
            //       <row>doc$vf@8606abd1|doc-004|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:40:00</row> 
            //    </value>
            //  </result>
            //</pdmOut>
            #endregion
            XmlDocument xmlDoc = new XmlDocument();
            xmlDoc.LoadXml(xml);
            XmlNode statusNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_STATUS);
            if (statusNode == null)
            {
                throw new Exception("XML流中未找到状态节点");
            }

            string strStatus = statusNode.InnerText;
            if (strStatus.CompareTo("1") == 0)
            {
                // 失败
                XmlNode msgNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_MESSAGE);
                if (msgNode == null)
                {
                    throw new Exception("XML流中未找到消息节点");
                }
                string strFailedMsg = msgNode.InnerText;
                throw new Exception(strFailedMsg);
            }
            else if (strStatus.CompareTo("201") == 0)
            {
                throw new Exception("登录过期！");
            }
            else
            {
                XmlNode resultNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_RESULT);
                if (resultNode == null)
                {
                    throw new Exception("XML流中未找到结果节点");
                }

                XmlNode fieldTypeNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_RESULT_FIELDTYPE);
                XmlNode fieldNameNode = XMLMethod.GetXmlNode(xmlDoc, XTN_PDMOUT_RESULT_FIELDNAME);
                XmlNodeList valueNodeList = xmlDoc.SelectNodes(XTN_PDMOUT_RESULT_VALUE_ROW);

                if (fieldTypeNode == null || fieldNameNode == null || valueNodeList == null)
                {
                    throw new Exception("XML流中数据格式不正确");
                }

                // 解析字段类型和字段名称
                string[] fieldTypes = fieldTypeNode.InnerText.Split('|');
                string[] fieldNames = fieldNameNode.InnerText.Split('|');

                // 验证字段类型与字段名称数量是否匹配
                if (fieldTypes.Length != fieldNames.Length)
                {
                    throw new Exception("字段类型和字段名称数量不匹配");
                }

                // 创建结果列表
                List<T> resultList = new List<T>();

                // 处理每一行数据
                foreach (XmlNode rowNode in valueNodeList)
                {
                    string[] values = rowNode.InnerText.Split('|');

                    // 验证值的数量是否匹配字段数量
                    if (values.Length != fieldNames.Length)
                    {
                        throw new Exception($"字段值数量({values.Length})与字段名称数量({fieldNames.Length})不匹配");
                    }
                    var clazz = typeof(T);
                    // 创建对象实例
                    T obj = (T)Activator.CreateInstance(clazz);

                    // 设置对象属性
                    for (int i = 0; i < fieldNames.Length; i++)
                    {
                        try
                        {
                            // 获取属性信息
                            var property = clazz.GetProperty(fieldNames[i],
                                System.Reflection.BindingFlags.Public |
                                System.Reflection.BindingFlags.Instance |
                                System.Reflection.BindingFlags.IgnoreCase);

                            if (property != null && property.CanWrite)
                            {
                                // 根据字段类型转换值
                                object convertedValue = ConvertValueByType(values[i], fieldTypes[i]);
                                property.SetValue(obj, convertedValue);
                            }
                        }
                        catch (Exception ex)
                        {
                            throw new Exception($"设置属性 {fieldNames[i]} 值失败: {ex.Message}");
                        }
                    }

                    resultList.Add(obj);
                }

                return resultList;
            }
        }

        /// <summary>
        /// 根据字段类型将字符串值转换为对应的类型
        /// </summary>
        /// <param name="value">字符串值</param>
        /// <param name="type">字段类型</param>
        /// <returns>转换后的对象</returns>
        private static object ConvertValueByType(string value, string type)
        {
            switch (type.ToLower())
            {
                case "string":
                    return value;
                case "boolean":
                    return Convert.ToBoolean(value);
                case "byte":
                    return Convert.ToByte(value);
                case "int":
                    return Convert.ToInt32(value);
                case "float":
                    return Convert.ToSingle(value);
                case "double":
                    return Convert.ToDouble(value);
                case "date":
                    return DateTime.Parse(value).Date;
                case "datetime":
                    return DateTime.Parse(value);
                default:
                    return value;
            }
        }

    }
}