logprintthread.cs

监控系统

using System;
using System.IO;
using System.Threading;
using System.Collections;
using MonitorSystem.BasicClass;
using MonitorSystem.LogFileModule;
using MonitorSystem.RuleFileProcess;


namespace MonitorSystem.MonitorInterface
{
	public class LogRecord
	{
		/// <summary>
		/// 日志队列
		/// </summary>
		public static BasicQueue LogQueue = new BasicQueue();

		/// <summary>
		/// 平台ID
		/// </summary>
		public int iPlatformID;
		/// <summary>
		/// 节点ID
		/// </summary>
		public int iNodeID;
		/// <summary>
		/// 监控类型ID
		/// </summary>
		public int iTypeID;
		/// <summary>
		/// 监控规则ID
		/// </summary>
		public int iRuleID;
		/// <summary>
		/// 所监控对象的具体名称
		/// </summary>
		public string strRuleName;
		/// <summary>
		/// 监控数据
		/// </summary>
		public string strValue;
		/// <summary>
		/// 状态 0－正常 1－一般警告 2－严重警告 3－一般故障 4－严重故障 5－未知（等待分析）
		/// </summary>
		public int iStatus;
		/// <summary>
		/// 报警方式 0－无 1－鸣叫 2－短信 3－电子邮件通知 4-等待分析
		/// </summary>
		public int iAction;
		/// <summary>
		/// 报警方式参数
		/// </summary>
		public string strActionParam;
		/// <summary>
		/// 保留1
		/// </summary>
		public string strReserve1;
		/// <summary>
		/// 保留2
		/// </summary>
		public string strReserve2;
		/// <summary>
		/// 报警方式列表
		/// </summary>
		public int[] iInterfaceAction;
		/// <summary>
		/// 报警参数列表
		/// </summary>
		public string[] strInActionParam;
		/// <summary>
		/// 报警说明
		/// </summary>
		public string strAlertRemark;

		public string strDateTime;
		public string strLogName;				//文件路径名称

		public void SetLog(
			string strLogName,				//文件路径名称
			string strDateTime,
			int iPlatformID,				//平台ID
			int iNodeID,					//节点ID
			int iTypeID,					//监控类型ID
			int iRuleID,					//监控规则ID
			string strRuleName,				//所监控对象的具体名称
			string strValue,				//监控数据
			int iStatus,					//状态 0－正常 1－一般警告 2－严重警告 3－一般故障 4－严重故障 5－未知（等待分析）
			int iAction,					//报警方式 0－无 1－鸣叫 2－短信 3－电子邮件通知 4-等待分析
			string strActionParam,			//报警方式参数
			string strReserve1,				
			string strReserve2)
		{
			this.strLogName = strLogName;
			this.strDateTime = strDateTime;
			this.iPlatformID = iPlatformID;
			this.iNodeID = iNodeID;
			this.iTypeID = iTypeID;
			this.iRuleID = iRuleID;
			this.strRuleName = strRuleName;
			this.strValue = strValue;
			this.iStatus = iStatus;
			this.iAction = iAction;
			this.strActionParam = strActionParam;
			this.strReserve1 = strReserve1;
			this.strReserve2 = strReserve2;
			LogQueue.Enqueue(this);
			
		}


		public void SetLog(
			string strLogName,				//文件路径名称
			string strDateTime,
			int iPlatformID,				//平台ID
			int iNodeID,					//节点ID
			int iTypeID,					//监控类型ID
			int iRuleID,					//监控规则ID
			string strRuleName,				//所监控对象的具体名称
			string strValue,				//监控数据
			int iStatus,					//状态 0－正常 1－一般警告 2－严重警告 3－一般故障 4－严重故障 5－未知（等待分析）
			int[] iAction,					//报警方式 0－无 1－鸣叫 2－短信 3－电子邮件通知 4-等待分析
			string[] strActionParam,			//报警方式参数
			string strReserve1,				
			string strReserve2)
		{
			this.strLogName = strLogName;
			this.strDateTime = strDateTime;
			this.iPlatformID = iPlatformID;
			this.iNodeID = iNodeID;
			this.iTypeID = iTypeID;
			this.iRuleID = iRuleID;
			this.strRuleName = strRuleName;
			this.strValue = strValue;
			this.iStatus = iStatus;
			this.iInterfaceAction = iAction;
			this.strInActionParam = strActionParam;
			this.strReserve1 = strReserve1;
			this.strReserve2 = strReserve2;
			LogQueue.Enqueue(this);
		}


	}

	/// <summary>
	/// LogPrintThread 的摘要说明。
	/// </summary>
	public class LogPrintThread
	{
		private Thread m_Thread;
		private bool m_Pause;
		private bool m_Exit;
		public DateTime CreateTime;
		public static bool m_IsUpdate = false;
		public static string m_UploadFile;
		private StreamWriter out_fd=null;
		private SystemLog m_SysLog;

		private string m_FileName;

		public LogPrintThread()
		{
			m_Pause = false;
			m_Exit = false;
			CreateTime = System.DateTime.Now;
			m_SysLog=new SystemLog();
		}

		public void Run()
		{
			while(true)
			{
				while(m_Pause)
				{
					try
					{
						Thread.Sleep(1000);
					}
					catch(Exception)
					{
					}
					continue;
				}
				if(m_Exit)
				{
					break;
				}


				
				if (LogRecord.LogQueue.Count<=0)
				{
					try
					{
						Thread.Sleep(1000);
						continue;
					}
					catch(Exception)
					{
						continue;
					}
				}

				try
				{
					LogRecord log = new LogRecord();
					log = (LogRecord)LogRecord.LogQueue.Dequeue();
					InterfaceWriteToFile(log);
				}
				catch(Exception ex)
				{
					m_SysLog.WriteToSysLog(ex.Message + ex.StackTrace);
				}
			}
		}

		/// <summary>
		/// 用于中心接口生成日志文件，以字段间加TABLE符号的方式写入行，写入监控日志文件
		/// 每分钟生成一个日志文件，不用指定文件名，文件名由程序产生
		/// </summary>
		public void InterfaceWriteToFile(LogRecord log)
		{
			try
			{
				if(System.DateTime.Now.Minute != CreateTime.Minute)
				{
					if(out_fd!=null)
					{
						out_fd.Close();
						out_fd = null;
					}
				}
				if(out_fd == null)
				{
					if (m_FileName!=null)
					{
						m_IsUpdate = true;
						m_UploadFile = m_FileName;
					}

					m_FileName =  string.Format("{0}_{1,4:0000}_{2}{3,2:00}{4,2:00}{5,2:00}{6,2:00}.log",
						log.strLogName, log.iPlatformID,
						DateTime.Now.Year,DateTime.Now.Month,
						DateTime.Now.Day,DateTime.Now.Hour,DateTime.Now.Minute);

					//open a file for Detail Record
					FileStream fs = new FileStream(m_FileName,FileMode.Append, FileAccess.Write);         
					out_fd = new System.IO.StreamWriter(fs, System.Text.Encoding.GetEncoding(936));	
					CreateTime = System.DateTime.Now;
				}
				
				string strAction="";
				for(int i=0; i<log.iInterfaceAction.Length; i++)
				{
					if(i>=1)
						strAction+="&";
					
					strAction+=Convert.ToString(log.iInterfaceAction[i]);
				}

				log.strActionParam="";
				for(int i=0; i<log.strInActionParam.Length; i++)
				{
					if(i>=1)
						log.strActionParam+="&";
					
					log.strActionParam+=Convert.ToString(log.strInActionParam[i]);
				}
				
				string strDataLine=string.Format("{0}\t{1}\t{2}\t{3}\t{4}\t{5}\t{6}\t{7}\t{8}\t{9}\t{10}\t{11}",
					log.strDateTime,log.iPlatformID,log.iNodeID,log.iTypeID,log.iRuleID,log.strRuleName,log.strValue,
					log.iStatus,strAction,log.strActionParam,log.strReserve1,log.strReserve2);
				out_fd.WriteLine(strDataLine);
				out_fd.Flush();
			}
			catch(Exception e)
			{				
				throw new Exception(e.Message  + e.StackTrace);
			}
		}

		public void Startup()
		{ 				
			m_Thread = new Thread(new ThreadStart(this.Run));
			// Start the thread
			m_Pause = false;
			m_Exit = false;		
			m_Thread.Start();			
		}
		public void Join()
		{
			if(m_Thread != null)
			{
				m_Thread.Interrupt();
				m_Thread.Join();
			}
			else
			{
				return;
			}
		}
		public bool IsAlive()
		{
			if(m_Thread != null)
			{
				return m_Thread.IsAlive;
			}
			else
			{
				return false;
			}
		}
		public void Suspend()
		{
			if(m_Pause == false)
				m_Pause = true;
		}
		public void Resume()
		{
			if(m_Pause == true)
				m_Pause = false;		
		}
		public void SetExit()
		{
			if(m_Exit == false)
				m_Exit = true;		
		}

	}
}