userinfoservice.cs

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

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

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 UserInfoService
	{
        /// <summary>
        /// 添加用户方法
        /// </summary>
        /// <param name="userInfo">UserInfo</param>
        /// <returns>UserInfo Object</returns>
        public static UserInfo AddUserInfo(UserInfo userInfo)
		{
            string sql =
				"INSERT UserInfo (UserId,UserName, Password, DepartId, Gender, RoleId, UserStateId)" +
				"VALUES (@UserId,@UserName, @Password, @DepartId, @Gender, @RoleId, @UserStateId)";
				
			sql += " ; SELECT @@IDENTITY";

            try
            {
				SqlParameter[] para = new SqlParameter[]
				{
                    new SqlParameter("@UserId",userInfo.UserId),
					new SqlParameter("@UserStateId", userInfo.UserState.UserStateId), //FK
					new SqlParameter("@RoleId", userInfo.Role.RoleId), //FK
					new SqlParameter("@UserName", userInfo.UserName),
					new SqlParameter("@Password", userInfo.Password),
					new SqlParameter("@DepartId", userInfo.DepartId),
					new SqlParameter("@Gender", userInfo.Gender)
				};
				
                String newId = DBHelper.GetScalarString(sql, para);
				return GetUserInfoByUserId(newId);
            }
            catch (Exception e)
            {
				Console.WriteLine(e.Message);
                throw e;
            }
		}
		/// <summary>
		/// 删除用户方法
		/// </summary>
		/// <param name="userInfo"></param>
        public static void DeleteUserInfo(UserInfo userInfo)
		{
			DeleteUserInfoByUserId( userInfo.UserId );
		}
        /// <summary>
        /// 删除用户方法：根据用户ID
        /// </summary>
        /// <param name="userId"></param>
        public static void DeleteUserInfoByUserId(string userId)
		{
            string sql = "DELETE UserInfo WHERE UserId = @UserId";

            try
            {
				SqlParameter[] para = new SqlParameter[]
				{
					new SqlParameter("@UserId", userId)
				};
			
                DBHelper.ExecuteCommand(sql, para);
            }
            catch (Exception e)
            {
				Console.WriteLine(e.Message);
				throw e;
            }
		}
		/// <summary>
		/// 修改用户方法
		/// </summary>
		/// <param name="userInfo"></param>
        public static void ModifyUserInfo(UserInfo userInfo)
        {
            string sql =
                "UPDATE UserInfo " +
                "SET " +
	                "UserStateId = @UserStateId, " + //FK
	                "RoleId = @RoleId, " + //FK
	                "UserName = @UserName, " +
	                "Password = @Password, " +
	                "DepartId = @DepartId, " +
	                "Gender = @Gender " +
                "WHERE UserId = @UserId";


            try
            {
				SqlParameter[] para = new SqlParameter[]
				{
					new SqlParameter("@UserId", userInfo.UserId),
					new SqlParameter("@UserStateId", userInfo.UserState.UserStateId), //FK
					new SqlParameter("@RoleId", userInfo.Role.RoleId), //FK
					new SqlParameter("@UserName", userInfo.UserName),
					new SqlParameter("@Password", userInfo.Password),
					new SqlParameter("@DepartId", userInfo.DepartId),
					new SqlParameter("@Gender", userInfo.Gender)
				};

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

        }		
        /// <summary>
        /// 获取所有用户信息方法
        /// </summary>
        /// <returns></returns>
        public static IList<UserInfo> GetAllUserInfos()
        {
            string sqlAll = "SELECT * FROM UserInfo where UserStateId=1";
			return GetUserInfosBySql( sqlAll );
        }
        public static IList<UserInfo> GetUserInfosByDepartId(int departId)
        {
            string sqlAll = "SELECT * FROM UserInfo WHERE UserStateId = 1 and DepartId="+departId;
            return GetUserInfosBySql(sqlAll);
        }
        /// <summary>
        /// 检查用户
        /// </summary>
        /// <returns></returns>
        public static Boolean CheckUser(String userName)
        {
            string sql = "select * from UserInfo where UserId = @UserId";
            DataTable table = DBHelper.GetDataSet(sql, new SqlParameter("@UserId", userName));
            if (table.Rows.Count > 0)
                return true;
            else
                return false;
        }
		/// <summary>
		/// 获取用户信息方法
		/// </summary>
		/// <param name="userId"></param>
        /// <returns>UserInfo Object</returns>
        public static UserInfo GetUserInfoByUserId(String userId)
        {
            string sql = "SELECT * FROM UserInfo WHERE UserId = @UserId";

			int userStateId;
			int roleId;

            try
            {
                SqlDataReader reader = DBHelper.GetReader(sql, new SqlParameter("@UserId", userId));
                if (reader.Read())
                {
                    UserInfo userInfo = new UserInfo();

					userInfo.UserId = (string)reader["UserId"];
					userInfo.UserName = (string)reader["UserName"];
					userInfo.Password = (string)reader["Password"];
					userInfo.DepartId = (int)reader["DepartId"];
					userInfo.Gender = (int)reader["Gender"];
					userStateId = (int)reader["UserStateId"]; //FK
					roleId = (int)reader["RoleId"]; //FK

                    reader.Close();

					userInfo.UserState = UserStateService.GetUserStateByUserStateId(userStateId);
					userInfo.Role = RoleInfoService.GetRoleInfoByRoleId(roleId);
					
                    return userInfo;
                }
                else
                {
                    reader.Close();
                    return null;
                }
            }
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
        }
		
		
		
		/// <summary>
		/// 获取所有用户
		/// </summary>
		/// <param name="safeSql"></param>
		/// <returns></returns>
        private static IList<UserInfo> GetUserInfosBySql( string safeSql )
        {
            List<UserInfo> list = new List<UserInfo>();

			try
			{
				DataTable table = DBHelper.GetDataSet( safeSql );
				
				foreach (DataRow row in table.Rows)
				{
					UserInfo userInfo = new UserInfo();
					
					userInfo.UserId = (string)row["UserId"];
					userInfo.UserName = (string)row["UserName"];
					userInfo.Password = (string)row["Password"];
					userInfo.DepartId = (int)row["DepartId"];
					userInfo.Gender = (int)row["Gender"];
					userInfo.UserState = UserStateService.GetUserStateByUserStateId((int)row["UserStateId"]); //FK
					userInfo.Role = RoleInfoService.GetRoleInfoByRoleId((int)row["RoleId"]); //FK
	
					list.Add(userInfo);
				}
	
				return list;
			}
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
        }
		/// <summary>
		/// 获取用户信息方法
		/// </summary>
		/// <param name="sql"></param>
		/// <param name="values"></param>
		/// <returns></returns>
        private static IList<UserInfo> GetUserInfosBySql( string sql, params SqlParameter[] values )
        {
            List<UserInfo> list = new List<UserInfo>();

			try
			{
				DataTable table = DBHelper.GetDataSet( sql, values );
				
				foreach (DataRow row in table.Rows)
				{
					UserInfo userInfo = new UserInfo();
					
					userInfo.UserId = (string)row["UserId"];
					userInfo.UserName = (string)row["UserName"];
					userInfo.Password = (string)row["Password"];
					userInfo.DepartId = (int)row["DepartId"];
					userInfo.Gender = (int)row["Gender"];
					userInfo.UserState = UserStateService.GetUserStateByUserStateId((int)row["UserStateId"]); //FK
					userInfo.Role = RoleInfoService.GetRoleInfoByRoleId((int)row["RoleId"]); //FK
	
					list.Add(userInfo);
				}
	
				return list;
			}
            catch (Exception e)
            {
                Console.WriteLine(e.Message);
                throw e;
            }
			
        }
		
	}
}