dbloggingprovider.cs

SharpNuke源代码

using System;
using System.Data;
using System.Collections;
using System.IO;
using System.Reflection;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading;
using System.Web;
using System.Xml;
using System.Xml.Serialization;

using DotNetNuke.Common;
using DotNetNuke.Framework.Providers;
using DotNetNuke.Common.Utilities;
using DotNetNuke.Services.Exceptions;
using DotNetNuke.Services.Log.EventLog;
using DotNetNuke.Services.Log.EventLog.DBLoggingProvider.Data;
//
// DotNetNuke -  http://www.dotnetnuke.com
// Copyright (c) 2002-2005
// by Shaun Walker ( [e-mail] ) of Perpetual Motion Interactive Systems Inc. ( http://www.perpetualmotion.ca )
//
// Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated
// documentation files (the "Software"), to deal in the Software without restriction, including without limitation
// the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and
// to permit persons to whom the Software is furnished to do so, subject to the following conditions:
//
// The above copyright notice and this permission notice shall be included in all copies or substantial portions
// of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED
// TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
// THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
// CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
// DEALINGS IN THE SOFTWARE.
//

namespace DotNetNuke.Services.Log.EventLog.DBLoggingProvider
{
	
	public class DBLoggingProvider : LoggingProvider
	{
		
		private static ArrayList logQueue = new ArrayList();
		
		private static ReaderWriterLock lockNotif = new ReaderWriterLock();
		private static ReaderWriterLock lockPurgeLog = new ReaderWriterLock();
		private const int readerLockTimeout = 10000; //milliseconds
		private const int writerLockTimeout = 10000; //milliseconds
		
		#region public static properties
		public static ArrayList LogQueue
		{
			get { return logQueue; }
		}
		#endregion

		#region "Public Methods"
		
		public override void AddLog (LogInfo logInfo)
		{
			
			string configPortalID;
			if (logInfo.LogPortalID != Null.NullInteger)
			{
				configPortalID = logInfo.LogPortalID.ToString();
			}
			else
			{
				configPortalID = "*";
			}
			
			LogTypeConfigInfo logTypeConfigInfo;
			logTypeConfigInfo = GetLogTypeConfigInfoByKey(logInfo.LogTypeKey, configPortalID);
			
			if (!logTypeConfigInfo.LoggingIsActive)
			{
				return;
			}
			
			bool useEventLogBuffer = true;
			if (Globals.HostSettings.ContainsKey("EventLogBuffer"))
			{
				if (Convert.ToString(Globals.HostSettings["EventLogBuffer"]) != "Y")
				{
					useEventLogBuffer = false;
				}
			}
			else
			{
				useEventLogBuffer = false;
			}
			
			logInfo.LogConfigID = logTypeConfigInfo.ID;
			
			LogQueueItem logQueueItem = new LogQueueItem();
			logQueueItem.LogInfo = logInfo;
			logQueueItem.LogTypeConfigInfo = logTypeConfigInfo;
			
			Scheduling.SchedulingProvider scheduler = Scheduling.SchedulingProvider.Instance();
			if (logInfo.BypassBuffering || !Scheduling.SchedulingProvider.Enabled || scheduler.GetScheduleStatus() == Scheduling.ScheduleStatus.STOPPED || !useEventLogBuffer)
			{
				WriteLog(logQueueItem);
			}
			else
			{
				LogQueue.Add(logQueueItem);
			}
			
		}
		
		public override void AddLogTypeConfigInfo (string id, bool loggingIsActive, string logTypeKey, string logTypePortalID, 
			string keepMostRecent, string logFileName, bool emailNotificationIsActive, string threshold, string thresholdTime, 
			string thresholdTimeType, string mailFromAddress, string mailToAddress)
		{
			int intThreshold = - 1;
			int intThresholdTime = - 1;
			int intThresholdTimeType = - 1;
			int intKeepMostRecent = - 1;
			
			if (Regex.IsMatch(threshold, "\\d*", RegexOptions.Compiled))
			{
				intThreshold = Convert.ToInt32(threshold);
			}
			if (Regex.IsMatch(thresholdTime, "\\d*", RegexOptions.Compiled))
			{
				intThresholdTime = Convert.ToInt32(thresholdTime);
			}
			if (Regex.IsMatch(thresholdTimeType, "\\d*", RegexOptions.Compiled))
			{
				intThresholdTimeType = Convert.ToInt32(thresholdTimeType);
			}
			if (Regex.IsMatch(keepMostRecent, "\\d*", RegexOptions.Compiled))
			{
				intKeepMostRecent = Convert.ToInt32(keepMostRecent);
			}
			
			DataProvider.Instance().AddLogTypeConfigInfo(loggingIsActive, logTypeKey, logTypePortalID, intKeepMostRecent, 
				emailNotificationIsActive, intThreshold, intThresholdTime, intThresholdTimeType, mailFromAddress, mailToAddress);
			DataCache.RemoveCache("GetLogTypeConfigInfo");
			DataCache.RemoveCache("GetLogTypeConfigInfoByKey");
		}
		
		public override void UpdateLogTypeConfigInfo (string id, bool loggingIsActive, string logTypeKey, string logTypePortalID, 
			string keepMostRecent, string logFileName, bool emailNotificationIsActive, string threshold, string thresholdTime, 
			string thresholdTimeType, string mailFromAddress, string mailToAddress)
		{
			int intThreshold = - 1;
			int intThresholdTime = - 1;
			int intThresholdTimeType = - 1;
			int intKeepMostRecent = - 1;
			
			if (Regex.IsMatch(threshold, "\\d*", RegexOptions.Compiled))
			{
				intThreshold = Convert.ToInt32(threshold);
			}
			if (Regex.IsMatch(thresholdTime, "\\d*", RegexOptions.Compiled))
			{
				intThresholdTime = Convert.ToInt32(thresholdTime);
			}
			if (Regex.IsMatch(thresholdTimeType, "\\d*", RegexOptions.Compiled))
			{
				intThresholdTimeType = Convert.ToInt32(thresholdTimeType);
			}
			if (Regex.IsMatch(keepMostRecent, "\\d*", RegexOptions.Compiled))
			{
				intKeepMostRecent = Convert.ToInt32(keepMostRecent);
			}
			
			DataProvider.Instance().UpdateLogTypeConfigInfo(id, loggingIsActive, logTypeKey, logTypePortalID, intKeepMostRecent, 
				logFileName, emailNotificationIsActive, intThreshold, intThresholdTime, intThresholdTimeType, mailFromAddress, mailToAddress);
			DataCache.RemoveCache("GetLogTypeConfigInfo");
			DataCache.RemoveCache("GetLogTypeConfigInfoByKey");
		}
		
		public override void ClearLog ()
		{
			DataProvider.Instance().ClearLog();
		}
		
		public override void DeleteLog (LogInfo logInfo)
		{
			DataProvider.Instance().DeleteLog(logInfo.LogGUID);
		}
		
		public override void DeleteLogTypeConfigInfo (string id)
		{
			DataProvider.Instance().DeleteLogTypeConfigInfo(id);
			DataCache.RemoveCache("GetLogTypeConfigInfo");
			DataCache.RemoveCache("GetLogTypeConfigInfoByKey");
		}
		
		public override LogInfoArray GetLog(int pageSize, int pageIndex, ref int totalRecords)
		{
			LogInfoArray array = new LogInfoArray();
			IDataReader dr = null; 
			try
			{
				dr = DataProvider.Instance().GetLog(pageSize, pageIndex);
				LogInfo logInfo;

				while (dr.Read())
				{
					logInfo = FillLogInfo(dr);
					array.Add(logInfo);
				}
				dr.NextResult();
				while (dr.Read())
				{
					totalRecords = Convert.ToInt32(dr["TotalRecords"]);
				}
			}
			finally
			{
				if (dr != null)
				{
					dr.Close();
				}
			}
			return array;
		}
		
		public override LogInfoArray GetLog(string logType, int pageSize, int pageIndex, ref int totalRecords)
		{
			LogInfoArray array = new LogInfoArray();
			IDataReader dr = null; 
			try
			{
				dr = DataProvider.Instance().GetLog(logType, pageSize, pageIndex);
				LogInfo logInfo;
				while (dr.Read())
				{
					logInfo = FillLogInfo(dr);
					array.Add(logInfo);
				}
				dr.NextResult();
				while (dr.Read())
				{
					totalRecords = Convert.ToInt32(dr["TotalRecords"]);
				}
			}
			finally
			{
				if (dr != null)
				{
					dr.Close();
				}
			}
			return array;
		}
																	  
		public override LogInfoArray GetLog(int portalID, int pageSize, int pageIndex, ref int totalRecords)
		{
			if (portalID == -1)
			{
				return GetLog();
			}

			LogInfoArray array = new LogInfoArray();
			IDataReader dr = null; 
			try
			{
				dr = DataProvider.Instance().GetLog(portalID, pageSize, pageIndex);
				LogInfo logInfo;
				while (dr.Read())
				{
					logInfo = FillLogInfo(dr);
					array.Add(logInfo);
				}
				dr.NextResult();
				while (dr.Read())
				{
					totalRecords = Convert.ToInt32(dr["TotalRecords"]);
				}
			}
			finally
			{
				if (dr != null)
				{
					dr.Close();
				}
			}
			return array;
		}

		public override LogInfoArray GetLog(int portalID, string logType, int pageSize, int pageIndex, ref int totalRecords)
		{
			if (portalID == -1)
			{
				return GetLog(logType);
			}
			
			LogInfoArray array = new LogInfoArray();
			IDataReader dr = null; 
			try
			{
				dr = DataProvider.Instance().GetLog(portalID, logType, pageSize, pageIndex);
				LogInfo logInfo;
				while (dr.Read())
				{
					logInfo = FillLogInfo(dr);
					array.Add(logInfo);
				}
				dr.NextResult();
				while (dr.Read())
				{
					totalRecords = Convert.ToInt32(dr["TotalRecords"]);
				}
			}
			finally
			{
				if (dr != null)
				{
					dr.Close();
				}
			}
			return array;
		}

		public override LogInfoArray GetLog()
		{
			
			LogInfoArray objArr = new LogInfoArray();
			IDataReader dr = null;
			try
			{
				dr = DataProvider.Instance().GetLog();
				LogInfo logInfo;
				while (dr.Read())
				{
					logInfo = FillLogInfo(dr);
					objArr.Add(logInfo);
				}
			}
			finally
			{
				if (dr != null)
				{
					dr.Close();
				}
			}
			return objArr;
		}
		
		public override LogInfoArray GetLog(int portalID)
		{
			if (portalID == - 1)
			{
				return GetLog();
			}
			LogInfoArray objArr = new LogInfoArray();
			IDataReader dr =  null;
			try
			{
				dr = DataProvider.Instance().GetLog(portalID);
				LogInfo logInfo;
				while (dr.Read())
				{
					logInfo = FillLogInfo(dr);
					objArr.Add(logInfo);
				}
			}
			finally
			{
				if (dr != null)
				{
					dr.Close();
				}
			}
			return objArr;
		}
		
		public override LogInfoArray GetLog(int portalID, string logType)
		{
			if (portalID == - 1)
			{
				return GetLog(logType);
			}
			LogInfoArray objArr = new LogInfoArray();
			IDataReader dr = null;
			try
			{
				dr = DataProvider.Instance().GetLog(portalID, logType);
				LogInfo logInfo;
				while (dr.Read())
				{
					logInfo = FillLogInfo(dr);
					objArr.Add(logInfo);
				}
			}
			finally
			{
				if (dr != null)
				{
					dr.Close();
				}
			}
			return objArr;
		}
		
		public override LogInfoArray GetLog(string logType)
		{
			LogInfoArray objArr = new LogInfoArray();
			IDataReader dr = null;
			try
			{