using System;
using System.Data;
using System.Configuration;
using System.Web;

using System.Data.SqlClient;

namespace LZ2007.Function.Log
{
    /// <summary>
    /// 数据库日志类.
    /// </summary>
    public class DataBaseLog : ILog
    {
        私有变量申明

        public DataBaseLog(Type objType)
        {
            _isDebug = Convert.ToBoolean(ConfigurationManager.AppSettings["eLogDebug"]);
            _isInfo = Convert.ToBoolean(ConfigurationManager.AppSettings["eLogInfo"]);
            _isError = Convert.ToBoolean(ConfigurationManager.AppSettings["eLogError"]);
            _isWarn = Convert.ToBoolean(ConfigurationManager.AppSettings["eLogWarn"]);
            _LogObjectSource = objType.FullName;
            //_LogType = Convert.ToInt32(ConfigurationManager.AppSettings["eLogType"]);
            _LogConnStr = ConfigurationManager.AppSettings["eLogConnStr"];
            _sqlConn = new SqlConnection(_LogConnStr);
            Init();
        }

        private void Init()
        {
            //检查是否有该表
            string strTest = "select count(name)as a1 from sysobjects where id = object_id(N’[LOGSYSTEM]’) and OBJECTPROPERTY(id, N’IsUserTable’) = 1";

            //建立表
            string strSQL = "CREATE TABLE [dbo].[LOGSYSTEM] (" +
                                "[lId] [int] IDENTITY (1, 1) NOT NULL ," +
                                "[lMessage] [nvarchar] (1000) COLLATE Chinese_PRC_CI_AS NULL ," +
                                "[lLevel] [int] NULL ," +
                                "[lSource] [nvarchar] (100) COLLATE Chinese_PRC_CI_AS NULL ," +
                                "[lException] [nvarchar] (100) COLLATE Chinese_PRC_CI_AS NULL ," +
                                "[lType] [int] NULL ," +
                                "[lDate] [datetime] NULL ," +
                                "[lADDIT1] [nvarchar] (100) COLLATE Chinese_PRC_CI_AS NULL ," +
                                "[lADDIT2] [nvarchar] (100) COLLATE Chinese_PRC_CI_AS NULL ," +
                                "[lADDIT3] [nvarchar] (100) COLLATE Chinese_PRC_CI_AS NULL " +
                            ") ON [PRIMARY]";

            _sqlConn.Open();
            SqlCommand sqlcomm = new SqlCommand(strTest, _sqlConn);
            int i = (int)sqlcomm.ExecuteScalar(); ;
            if (i == 0)
            {
                sqlcomm = new SqlCommand(strSQL, _sqlConn);


                sqlcomm.ExecuteNonQuery();
            }
            sqlcomm.Dispose();
        }

        private int insertLog(string message, int level, string source, string exception, int type)
        {

            string strSQL = "INSERT INTO LOGSYSTEM(lMessage,lLevel,lSource,lException,lType,lDate) " +
                "VALUES (@lMessage,@lLevel,@lSource,@lException,@lType,@lDate)";
            SqlCommand sqlcomm = new SqlCommand(strSQL, _sqlConn);
            if (_sqlConn.State == ConnectionState.Closed)
            {
                _sqlConn.Open();
            }
            sqlcomm.Parameters.Add("@lMessage", SqlDbType.NVarChar, 1000);
            sqlcomm.Parameters["@lMessage"].Direction = ParameterDirection.Input;
            sqlcomm.Parameters["@lMessage"].Value = message;

            sqlcomm.Parameters.Add("@lLevel", SqlDbType.Int);
            sqlcomm.Parameters["@lLevel"].Direction = ParameterDirection.Input;
            sqlcomm.Parameters["@lLevel"].Value = level;

            sqlcomm.Parameters.Add("@lSource", SqlDbType.NVarChar, 100);
            sqlcomm.Parameters["@lSource"].Direction = ParameterDirection.Input;
            sqlcomm.Parameters["@lSource"].Value = source;

            sqlcomm.Parameters.Add("@lException", SqlDbType.NVarChar, 100);
            sqlcomm.Parameters["@lException"].Direction = ParameterDirection.Input;
            sqlcomm.Parameters["@lException"].Value = exception;

            sqlcomm.Parameters.Add("@lType", SqlDbType.Int);
            sqlcomm.Parameters["@lType"].Direction = ParameterDirection.Input;
            sqlcomm.Parameters["@lType"].Value = type;

            sqlcomm.Parameters.Add("@lDate", SqlDbType.DateTime);
            sqlcomm.Parameters["@lDate"].Direction = ParameterDirection.Input;
            sqlcomm.Parameters["@lDate"].Value = DateTime.Now;
            return sqlcomm.ExecuteNonQuery();
        }

        public void Close()
        {
            this.Info("Log End", 5);
            _sqlConn.Close();
        }

        信息[Info]

        警告[Warn]

        调试[Debug]

        错误[Error]

        致命错误[Fatal]

    }
}