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";
///
/// 检查XML流是不是个异常
///
///
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("登录过期!");
}
}
///
/// PDM XML格式返回值转化成String类型
///
/// xml流字符串
///
public static string PDMSimpleReturnXmlStreamToString(string xmlStream)
{
//
// simple
// 2009-07-08 10:40:00
// 2009-07-08 10:40:02
// 0/1
// login sucessfully!
//
// 5F2BB7B637654441BB3460C3A55386A7
//
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;
}
}
///
/// 获取由PDMRecordReturnXMLStreamToString解析后的某个字段的值
///
/// 传入要获取的字段名
/// 所要查找的所有字段类型
/// 所要查找的所有字段名称
/// 所要查找的所有字段值
/// 返回查找字段的类型
/// 返回查找字段的值
///
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 PDMRecordReturnXMLStreamRowToList(string xmlStream)
{
//
// record
// 2014-11-25 17:19:16
// 2014-11-25 17:19:16
// 0
//
// String
// filename <--字段名为FileName,其实传回的是文件的本地完整路径
//
// D:\\ws\\SolidWorks\\测试博众-图档管理性能\\BZPART01.SLDPRT|D:\\ws\\SolidWorks\\测试博众-图档管理性能\\BZPART23.SLDPRT
//
//
//
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(strs);
}
return null;
}
public static void PDMRecordReturnXMLStreamToString(string xmlStream,
out string fieldTypeString,
out string fieldNameString,
out List fieldValueStringList)
{
#region WebService XML流格式返回值格式
//
// record
// 2009-07-08 10:40:00
// 2009-07-08 10:40:02
// 0/1
// login sucessfully!
//
//
// string|string|string|boolean|byte|int|float|double|date|datetime
// guid|md$number|md$description|booleanValue|byteValue|intValue|floatValue|doubleValue|dateValue|datetimeValue
//
// doc$vf@8606abcd|doc-001|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:10:00
// doc$vf@8606abce|doc-002|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:20:00
// doc$vf@8606abd0|doc-003|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:30:00
// doc$vf@8606abd1|doc-004|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:40:00
//
//
//
#endregion
fieldTypeString = "";
fieldNameString = "";
fieldValueStringList = new List();
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);
}
}
}
}
///
/// Record类型字符串转化成PDM XML流类型参数
///
/// 参数的类型组合字符串
/// 参数名称组合字符串
/// 参数值组合字符串列表
/// XML流类型字符串
public static string RecordParameterToXmlStream(string typeString, string fieldString, List valueStringList)
{
//
//
// record
//
// string|string|string|boolean|byte|int|float|double|date|datetime
// guid|md$number|md$description|booleanValue|byteValue|intValue|floatValue|doubleValue|dateValue|datetimeValue
//
// doc$vf@8606abcd|doc-001|11|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:10:00
// doc$vf@8606abce|doc-002|22|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:20:00
// doc$vf@8606abd0|doc-003|33|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:30:00
// doc$vf@8606abd1|doc-004|44|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:40:00
//
//
//
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;
}
///
/// 从XML流中转换成对象
///
/// 要转换成的对象类型
/// XML字符串
/// 对象类型
/// 转换后的对象
public static List ConvertXMLToObjectList(string xml)
{
#region WebService XML流格式返回值格式
//
// record
// 2009-07-08 10:40:00
// 2009-07-08 10:40:02
// 0/1
// login sucessfully!
//
//
// string|string|string|boolean|byte|int|float|double|date|datetime
// guid|md$number|md$description|booleanValue|byteValue|intValue|floatValue|doubleValue|dateValue|datetimeValue
//
// doc$vf@8606abcd|doc-001|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:10:00
// doc$vf@8606abce|doc-002|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:20:00
// doc$vf@8606abd0|doc-003|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:30:00
// doc$vf@8606abd1|doc-004|文档|true|1|2|1.0|2.0|2009-07-08|2009-07-08 00:40:00
//
//
//
#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 resultList = new List();
// 处理每一行数据
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;
}
}
///
/// 根据字段类型将字符串值转换为对应的类型
///
/// 字符串值
/// 字段类型
/// 转换后的对象
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;
}
}
}
}