interregpackage.cs

监控系统

using System;
using System.IO;
using System.Runtime.Serialization;
using System.Runtime.Serialization.Formatters.Binary;

namespace MonitorSystem.BasicClass
{
	/// <summary>
	/// InterfaceRegPackage 的摘要说明。
	/// </summary>
	public class InterRegPlatPackage:SocketPackageBase
	{
		#region 监控接口注册本平台请求包体信息
		private char[] m_MonitorPlatformID = new char[4];
		private char[] m_MonitorPlatformName = new char[64];
		private char[] m_MonitorRemark = new char[128];
		private int m_Length = 196;

		public char[] MonitorPlatformID
		{
			get{return m_MonitorPlatformID;}
			set{m_MonitorPlatformID = value;}
		}
		public char[] MonitorPlatformName
		{
			get{return m_MonitorPlatformName;}
			set{m_MonitorPlatformName = value;}
		}
		public char[] MonitorRemark
		{
			get{return m_MonitorRemark;}
			set{m_MonitorRemark = value;}
		}
		public int Length
		{
			get{return m_Length;}
		}
		#endregion

		/// <summary>
		/// 注册请求解包
		/// </summary>
		/// <param name="package"></param>
		/// <returns></returns>
		public override int DecodeSocketPackage(byte[] package)
		{
			IFormatter formatter = new BinaryFormatter();
			MemoryStream stream = new MemoryStream();
			InterRegPlatPackage interregplat = new InterRegPlatPackage();

			try
			{
				stream.Write(package,0,package.Length);
				stream.Seek(0,SeekOrigin.Begin);
				interregplat = (InterRegPlatPackage)formatter.Deserialize(stream);

				this.m_HeadFlag = interregplat.m_HeadFlag;
				this.m_ContentLength = interregplat.m_ContentLength;
				this.m_CommandID = interregplat.m_CommandID;
				this.m_PacketType = interregplat.m_PacketType;
				this.m_Version = interregplat.m_Version;
				this.m_Reserve = interregplat.m_Reserve;
				this.m_MonitorPlatformID  = interregplat.m_MonitorPlatformID;
				this.m_MonitorPlatformName = interregplat.m_MonitorPlatformName;
				this.m_MonitorRemark = interregplat.m_MonitorRemark;
				stream.Close();
			}
			catch(Exception ex)
			{
				string msg = ex.Message;
				return -1;
			}
			return 0;
		}

	}

	public class InterRegNodePackage:SocketPackageBase
	{
		#region 监控接口注册本平台节点请求包体信息
		private char[] m_MonitorPlatformID = new char[4];
		private char[] m_MonitorNodeID = new char[4];
		private char[] m_MonitorNodeName = new char[64];
		private char[] m_MonitorRemark = new char[128];
		private char[] m_interReserve = new char[8];
		private uint m_Length = 208;

		public char[] MonitorPlatformID
		{
			get{return m_MonitorPlatformID;}
			set{m_MonitorPlatformID = value;}
		}
		public char[] MonitorNodeID
		{
			get{return m_MonitorNodeID;}
			set{m_MonitorNodeID = value;}
		}
		public char[] MonitorNodeName
		{
			get{return m_MonitorNodeName;}
			set{m_MonitorNodeName = value;}
		}
		public char[] MonitorRemark
		{
			get{return m_MonitorRemark;}
			set{m_MonitorRemark = value;}
		}
			public char[] InterReserve
		{
			get{return m_interReserve;}
			set{m_interReserve = value;}
		}
		public uint Length
		{
			get{return m_Length;}
		}
		#endregion
		
		/// <summary>
		/// 注册请求解包
		/// </summary>
		/// <param name="package"></param>
		/// <returns></returns>
		public override int DecodeSocketPackage(byte[] package)
		{
			IFormatter formatter = new BinaryFormatter();
			MemoryStream stream = new MemoryStream();
			InterRegNodePackage interregnode = new InterRegNodePackage();

			try
			{
				stream.Write(package,0,package.Length);
				stream.Seek(0,SeekOrigin.Begin);
				interregnode = (InterRegNodePackage)formatter.Deserialize(stream);

				this.m_HeadFlag = interregnode.m_HeadFlag;
				this.m_ContentLength = interregnode.m_ContentLength;
				this.m_CommandID = interregnode.m_CommandID;
				this.m_PacketType = interregnode.m_PacketType;
				this.m_Version = interregnode.m_Version;
				this.m_Reserve = interregnode.m_Reserve;
				this.m_MonitorPlatformID  = interregnode.m_MonitorPlatformID;
				this.m_MonitorNodeID = interregnode.m_MonitorNodeID;
				this.m_MonitorNodeName = interregnode.m_MonitorNodeName;
				this.m_MonitorRemark = interregnode.m_MonitorRemark;
				this.m_interReserve = interregnode.m_interReserve;
				stream.Close();
			}
			catch(Exception ex)
			{
				string msg = ex.Message;
				return -1;
			}
			return 0;
		}


	}


	/// <summary>
	/// 监控接口注册应答包
	/// </summary>
	[Serializable]
	public class InterRegPlatRespPackage:SocketPackageBase
	{
		#region 监控接口注册平台应答包体信息
		private int m_iResult;
		private char[] m_CenLogFtpPath = new char[256];
		private char[] m_CenConfigFtpPath = new char[256];
		private char[] m_CenFtpLoginID = new char[64];
		private char[] m_CenFtpLoginPwd = new char[64];
		private char[] m_BodyReserve = new char[8];

		public int iResult
		{
			get{return m_iResult;}
			set{m_iResult = value;}
		}
		
		public char[] CenLogFtpPath
		{
			get{return m_CenLogFtpPath;}
			set{m_CenLogFtpPath = value;}
		}
		public char[] CenConfigFtpPath
		{
			get{return m_CenConfigFtpPath;}
			set{m_CenConfigFtpPath = value;}
		}
		public char[] CenFtpLoginID
		{
			get{return m_CenFtpLoginID;}
			set{m_CenFtpLoginID = value;}
		}
		public char[] CenFtpLoginPwd
		{
			get{return m_CenFtpLoginPwd;}
			set{m_CenFtpLoginPwd = value;}
		}
		public char[] BodyReserve
		{
			get{return m_BodyReserve;}
			set{m_BodyReserve = value;}
		}
		#endregion

		/// <summary>
		/// 注册平台应答解包
		/// </summary>
		/// <param name="package"></param>
		/// <returns></returns>
		public override int DecodeSocketPackage(byte[] package)
		{
			IFormatter formatter = new BinaryFormatter();
			MemoryStream stream = new MemoryStream();
			InterRegPlatRespPackage interregplat_resp = new InterRegPlatRespPackage();

			try
			{
				stream.Write(package,0,package.Length);
				stream.Seek(0,SeekOrigin.Begin);
				interregplat_resp = (InterRegPlatRespPackage)formatter.Deserialize(stream);

				this.m_HeadFlag = interregplat_resp.m_HeadFlag;
				this.m_ContentLength = interregplat_resp.m_ContentLength;
				this.m_CommandID = interregplat_resp.m_CommandID;
				this.m_PacketType = interregplat_resp.m_PacketType;
				this.m_Version = interregplat_resp.m_Version;
				this.m_Reserve = interregplat_resp.m_Reserve;
				this.m_iResult = interregplat_resp.m_iResult;
				this.m_CenLogFtpPath = interregplat_resp.m_CenLogFtpPath;
				this.m_CenConfigFtpPath = interregplat_resp.m_CenConfigFtpPath;
				this.m_CenFtpLoginID = interregplat_resp.m_CenFtpLoginID;
				this.m_CenFtpLoginPwd = interregplat_resp.m_CenFtpLoginPwd;
				this.m_BodyReserve = interregplat_resp.m_BodyReserve;
				stream.Close();
			}
			catch(Exception ex)
			{
				string msg = ex.Message;
				return -1;
			}
			return 0;
		}
	}

	/// <summary>
	/// 监控接口注册本平台节点应答包
	/// </summary>
	[Serializable]
	public class InterRegNodeRespPackage:SocketPackageBase
	{
		#region 监控接口注册本平台节点应答包体信息
		private int m_iResult;
		private char[] m_BodyReserve = new char[8];

		public int iResult
		{
			get{return m_iResult;}
			set{m_iResult = value;}
		}
		public char[] BodyReserve
		{
			get{return m_BodyReserve;}
			set{m_BodyReserve = value;}
		}
			#endregion

		/// <summary>
		/// 注册本平台节点应答解包
		/// </summary>
		/// <param name="package"></param>
		/// <returns></returns>
		public override int DecodeSocketPackage(byte[] package)
		{
			IFormatter formatter = new BinaryFormatter();
			MemoryStream stream = new MemoryStream();
			InterRegNodeRespPackage interregnode_resp = new InterRegNodeRespPackage();

			try
			{
				stream.Write(package,0,package.Length);
				stream.Seek(0,SeekOrigin.Begin);
				interregnode_resp = (InterRegNodeRespPackage)formatter.Deserialize(stream);

				this.m_HeadFlag = interregnode_resp.m_HeadFlag;
				this.m_ContentLength = interregnode_resp.m_ContentLength;
				this.m_CommandID = interregnode_resp.m_CommandID;
				this.m_PacketType = interregnode_resp.m_PacketType;
				this.m_Version = interregnode_resp.m_Version;
				this.m_Reserve = interregnode_resp.m_Reserve;
				this.m_iResult = interregnode_resp.m_iResult;
				this.m_BodyReserve = interregnode_resp.m_BodyReserve;
				stream.Close();
			}
			catch(Exception ex)
			{
				string msg = ex.Message;
				return -1;
			}
			return 0;
		}
	}
}