loginlogservice.cs

办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统办公系统

//============================================================
// Producnt name:		BoBoARTS.CodeMad
// Version: 			1.0
// Coded by:			Shen Bo ([e-mail])
// Auto generated at: 	2008-9-18 16:21:54
//============================================================

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using Office.Model;

namespace Office.DAL
{
	public static partial class LoginLogService
	{
        /// <summary>
        /// 添加登录日志
        /// </summary>
        /// <param name="loginLog"></param>
        /// <returns></returns>
        public static LoginLog AddLoginLog(LoginLog loginLog)
		{
            string sql =
				"INSERT LoginLog (UserId, LoginTime, IfSuccess, LoginUserIp, LoginDesc)" +
				"VALUES (@UserId, @LoginTime, @IfSuccess, @LoginUserIp, @LoginDesc)";
				
			sql += " ; SELECT @@IDENTITY";

            try
            {
				SqlParameter[] para = new SqlParameter[]
				{
					new SqlParameter("@UserId", loginLog.User.UserId), //FK
					new SqlParameter("@LoginTime", loginLog.LoginTime),
					new SqlParameter("@IfSuccess", loginLog.IfSuccess),
					new SqlParameter("@LoginUserIp", loginLog.LoginUserIp),
					new SqlParameter("@LoginDesc", loginLog.LoginDesc)
				};
				
                int newId = DBHelper.GetScalar(sql, para);
				return GetLoginLogByLoginId(newId);
            }
            catch (Exception e)
            {
				Console.WriteLine(e.Message);
                throw e;
            }
		}
		/// <summary>
		/// 删除登录日志
		/// </summary>
		/// <param name="loginLog"></param>
        public static void DeleteLoginLog(LoginLog loginLog)
		{
			DeleteLoginLogByLoginId( loginLog.LoginId );
		}
        /// <summary>
        /// 根据ID删除登录日志
        /// </summary>
        /// <param name="loginId"></param>
        public static void DeleteLoginLogByLoginId(int loginId)
		{
            string sql = "DELETE LoginLog WHERE LoginId = @LoginId";

            try
            {
				SqlParameter[] para = new SqlParameter[]
				{
					new SqlParameter("@LoginId", loginId)
				};
			
                DBHelper.ExecuteCommand(sql, para);
            }
            catch (Exception e)
            {
				Console.WriteLine(e.Message);
				throw e;
            }
		}
		/// <summary>
		/// 修改登录日志
		/// </summary>
		/// <param name="loginLog"></param>
        public static void ModifyLoginLog(LoginLog loginLog)
        {
            string sql =
                "UPDATE LoginLog " +
                "SET " +
	                "UserId = @UserId, " + //FK
	                "LoginTime = @LoginTime, " +
	                "IfSuccess = @IfSuccess, " +
	                "LoginUserIp = @LoginUserIp, " +
	                "LoginDesc = @LoginDesc " +
                "WHERE LoginId = @LoginId";


            try
            {
				SqlParameter[] para = new SqlParameter[]
				{
					new SqlParameter("@LoginId", loginLog.LoginId),
					new SqlParameter("@UserId", loginLog.User.UserId), //FK
					new SqlParameter("@LoginTime", loginLog.LoginTime),
					new SqlParameter("@IfSuccess", loginLog.IfSuccess),
					new SqlParameter("@LoginUserIp", loginLog.LoginUserIp),
					new SqlParameter("@LoginDesc", loginLog.LoginDesc)
				};

				DBHelper.ExecuteCommand(sql, para);
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
				throw e;
            }

        }		
        /// <summary>
        /// 得到所有登录日志
        /// </summary>
        /// <returns></returns>
        public static IList<LoginLog> GetAllLoginLogs()
        {
            string sqlAll = "SELECT * FROM LoginLog";
			return GetLoginLogsBySql( sqlAll );
        }
        /// <summary>
        /// 
        /// </summary>
        /// <returns></returns>
        public static Boolean DeleteLoginByLoginIds(String logindIds)
        {
            string sql = "DELETE LoginLog WHERE LoginId in ("+logindIds+")";
            try
            {
                DBHelper.ExecuteCommand(sql);
                return true;
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
            return false;
        }
        /// <summary>
        /// 
        /// </summary>
        /// <returns></returns>
        public static IList<LoginLog> GetAllLoginLogsByCondition(string StartTime,string EndTime)
        {
            String sql = "select * from LoginLog";
            if (StartTime != "" && EndTime != "")
                sql += " where LoginTime between '"+StartTime+"' and '"+EndTime+"'";
            return GetLoginLogsBySql(sql);
        }
		/// <summary>
		/// 根据ID得到登录日志
		/// </summary>
		/// <param name="loginId"></param>
		/// <returns></returns>
        public static LoginLog GetLoginLogByLoginId(int loginId)
        {
            string sql = "SELECT * FROM LoginLog WHERE LoginId = @LoginId";

			string userId;

            try
            {
                SqlDataReader reader = DBHelper.GetReader(sql, new SqlParameter("@LoginId", loginId));
                if (reader.Read())
                {
                    LoginLog loginLog = new LoginLog();

					loginLog.LoginId = (int)reader["LoginId"];
					loginLog.LoginTime = (DateTime)reader["LoginTime"];
					loginLog.IfSuccess = (int)reader["IfSuccess"];
					loginLog.LoginUserIp = (string)reader["LoginUserIp"];
					loginLog.LoginDesc = (string)reader["LoginDesc"];
                    userId = (string)reader["UserId"]; //FK

                    reader.Close();

					loginLog.User = UserInfoService.GetUserInfoByUserId(userId);
					
                    return loginLog;
                }
                else
                {
                    reader.Close();
                    return null;
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
        }
		
		
		
		/// <summary>
		/// 根据安全的T-SQL语句得到登录日志
		/// </summary>
		/// <param name="safeSql"></param>
		/// <returns></returns>
        private static IList<LoginLog> GetLoginLogsBySql( string safeSql )
        {
            List<LoginLog> list = new List<LoginLog>();

			try
			{
				DataTable table = DBHelper.GetDataSet( safeSql );
				
				foreach (DataRow row in table.Rows)
				{
					LoginLog loginLog = new LoginLog();
					
					loginLog.LoginId = (int)row["LoginId"];
					loginLog.LoginTime = (DateTime)row["LoginTime"];
					loginLog.IfSuccess = (int)row["IfSuccess"];
					loginLog.LoginUserIp = (string)row["LoginUserIp"];
					loginLog.LoginDesc = (string)row["LoginDesc"];
					loginLog.User = UserInfoService.GetUserInfoByUserId((string)row["UserId"]); //FK
	
					list.Add(loginLog);
				}
	
				return list;
			}
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }

        }
		/// <summary>
        /// 重载方法:根据安全的T-SQL语句和参数得到登录日志
		/// </summary>
		/// <param name="sql"></param>
		/// <param name="values"></param>
		/// <returns></returns>
        private static IList<LoginLog> GetLoginLogsBySql( string sql, params SqlParameter[] values )
        {
            List<LoginLog> list = new List<LoginLog>();

			try
			{
				DataTable table = DBHelper.GetDataSet( sql, values );
				
				foreach (DataRow row in table.Rows)
				{
					LoginLog loginLog = new LoginLog();
					
					loginLog.LoginId = (int)row["LoginId"];
					loginLog.LoginTime = (DateTime)row["LoginTime"];
					loginLog.IfSuccess = (int)row["IfSuccess"];
					loginLog.LoginUserIp = (string)row["LoginUserIp"];
					loginLog.LoginDesc = (string)row["LoginDesc"];
					loginLog.User = UserInfoService.GetUserInfoByUserId((string)row["UserId"]); //FK
	
					list.Add(loginLog);
				}
	
				return list;
			}
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
			
        }
		
	}
}