users.cs

动易SiteFactory&#8482 网上商店系统1.0源代码

            parameters.AddInParameter("@FirstFailedPasswordAnswerAttempTime", DbType.DateTime, usersInfo.FirstFailedPasswordAnswerAttempTime);
            parameters.AddInParameter("@Status", DbType.Int32, usersInfo.Status);
            parameters.AddInParameter("@CheckNum", DbType.AnsiStringFixedLength, usersInfo.CheckNum);
            parameters.AddInParameter("@EnableResetPassword", DbType.Boolean, usersInfo.EnableResetPassword);
            parameters.AddInParameter("@UserFace", DbType.String, usersInfo.UserFace);
            parameters.AddInParameter("@FaceWidth", DbType.Int32, usersInfo.FaceWidth);
            parameters.AddInParameter("@FaceHeight", DbType.Int32, usersInfo.FaceHeight);
            parameters.AddInParameter("@Sign", DbType.String, usersInfo.Sign);
            parameters.AddInParameter("@PrivacySetting", DbType.Int32, usersInfo.PrivacySetting);
            parameters.AddInParameter("@Balance", DbType.Currency, usersInfo.Balance);
            parameters.AddInParameter("@UserPoint", DbType.Int32, usersInfo.UserPoint);
            parameters.AddInParameter("@UserExp", DbType.Int32, usersInfo.UserExp);
            parameters.AddInParameter("@ConsumeMoney", DbType.Int32, usersInfo.ConsumeMoney);
            parameters.AddInParameter("@ConsumePoint", DbType.Int32, usersInfo.ConsumePoint);
            parameters.AddInParameter("@ConsumeExp", DbType.Int32, usersInfo.ConsumeExp);
            parameters.AddInParameter("@PostItems", DbType.Int32, usersInfo.PostItems);
            parameters.AddInParameter("@PassedItems", DbType.Int32, usersInfo.PassedItems);
            parameters.AddInParameter("@RejectItems", DbType.Int32, usersInfo.RejectItems);
            parameters.AddInParameter("@DelItems", DbType.Int32, usersInfo.DelItems);
            parameters.AddInParameter("@EndTime", DbType.DateTime, usersInfo.EndTime);
            parameters.AddInParameter("@IsInheritGroupRole", DbType.Boolean, usersInfo.IsInheritGroupRole);
            parameters.AddInParameter("@TrueName", DbType.String, usersInfo.UserTrueName);
            return parameters;
        }

        public UserInfo GetUsersByEmail(string email)
        {
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand sqlStringCommand = database.GetSqlStringCommand("SELECT * FROM [PE_Users] WHERE Email =@Email");
            database.AddInParameter(sqlStringCommand, "@Email", DbType.String, email);
            using (NullableDataReader reader = new NullableDataReader(database.ExecuteReader(sqlStringCommand)))
            {
                if (reader.Read())
                {
                    return UsersFromrdr(reader);
                }
                return new UserInfo(true);
            }
        }

        public IList<UserInfo> GetUsersByGroupId(string groupId)
        {
            IList<UserInfo> list = new List<UserInfo>();
            string query = "SELECT * FROM PE_Users WHERE GroupId IN (" + groupId + ")";
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand sqlStringCommand = database.GetSqlStringCommand(query);
            using (NullableDataReader reader = new NullableDataReader(database.ExecuteReader(sqlStringCommand)))
            {
                while (reader.Read())
                {
                    list.Add(UsersFromrdr(reader));
                }
            }
            return list;
        }

        public IList<UserInfo> GetUsersByUserId(string userId)
        {
            IList<UserInfo> list = new List<UserInfo>();
            string query = "SELECT * FROM PE_Users WHERE UserId IN (" + userId + ")";
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand sqlStringCommand = database.GetSqlStringCommand(query);
            using (NullableDataReader reader = new NullableDataReader(database.ExecuteReader(sqlStringCommand)))
            {
                while (reader.Read())
                {
                    list.Add(UsersFromrdr(reader));
                }
            }
            return list;
        }

        public UserInfo GetUsersByUserName(string userName)
        {
            Parameters cmdParams = new Parameters("@UserName", DbType.String, userName);
            using (NullableDataReader reader = DBHelper.ExecuteReaderSql("SELECT * FROM [PE_Users] WHERE UserName =@UserName", cmdParams))
            {
                if (reader.Read())
                {
                    return UsersFromrdr(reader);
                }
                return new UserInfo(true);
            }
        }

        public static bool LockUser(int userId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserID", DbType.Int32, userId);
            object obj2 = DBHelper.ExecuteScalarSql("SELECT Status FROM PE_Users WHERE UserID = @UserID", cmdParams);
            if (obj2 == null)
            {
                return false;
            }
            UserStatus userStatus = ((UserStatus) ((int) obj2)) | UserStatus.Locked;
            return UpdateUserStatus(userId, userStatus);
        }

        public bool MinusPoint(int infoPoint, string userName)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserPoint", DbType.Int32, infoPoint);
            cmdParams.AddInParameter("@UserName", DbType.String, userName);
            string strSql = "Update PE_Users set UserPoint=UserPoint-@UserPoint where UserName=@UserName";
            return DBHelper.ExecuteSql(strSql, cmdParams);
        }

        public bool MoveBetweenUserId(int startUserId, int endUserId, int groupId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserType", DbType.Int32, 3);
            cmdParams.AddInParameter("@StartUserId", DbType.Int32, startUserId);
            cmdParams.AddInParameter("@EndUserId", DbType.Int32, endUserId);
            cmdParams.AddInParameter("@GroupId", DbType.Int32, groupId);
            return DBHelper.ExecuteProc("PR_UserManage_Users_BatchMove", cmdParams);
        }

        public bool MoveByGroups(string groupId, int targetGroupId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserType", DbType.Int32, 4);
            cmdParams.AddInParameter("@BatchUserGroupId", DbType.String, groupId);
            cmdParams.AddInParameter("@GroupId", DbType.Int32, targetGroupId);
            return DBHelper.ExecuteProc("PR_UserManage_Users_BatchMove", cmdParams);
        }

        public bool MoveByUserName(string userName, int groupId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserType", DbType.Int32, 2);
            cmdParams.AddInParameter("@UserName", DbType.String, userName);
            cmdParams.AddInParameter("@GroupId", DbType.Int32, groupId);
            return DBHelper.ExecuteProc("PR_UserManage_Users_BatchMove", cmdParams);
        }

        public bool MoveByUsers(string userId, int groupId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserId", DbType.String, userId);
            cmdParams.AddInParameter("@GroupId", DbType.Int32, groupId);
            return DBHelper.ExecuteProc("PR_UserManage_Users_BatchMove", cmdParams);
        }

        public bool RemoveFromAdminCompany(string userName)
        {
            return DBHelper.ExecuteSql("update PE_Users set UserType=3 where UserType=2 and UserName=@UserName", new Parameters("@UserName", DbType.String, userName));
        }

        public bool RemoveFromCompany(string userName)
        {
            return DBHelper.ExecuteSql("update PE_Users set UserType=0,CompanyID=0,ClientID=0 where UserName=@UserName", new Parameters("@UserName", DbType.String, userName));
        }

        public bool SaveUserPurview(UserPurviewInfo userPurviewInfo, int userId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserId", DbType.Int32, userId);
            cmdParams.AddInParameter("@UserSetting", DbType.String, ser.SerializeField(userPurviewInfo));
            return DBHelper.ExecuteSql("UPDATE PE_Users SET UserSetting = @UserSetting WHERE UserId = @UserId", cmdParams);
        }

        public bool SaveUserPurview(bool inheritGroupRole, int userId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserId", DbType.Int32, userId);
            cmdParams.AddInParameter("@IsInheritGroupRole", DbType.Boolean, inheritGroupRole);
            return DBHelper.ExecuteSql("UPDATE PE_Users SET IsInheritGroupRole = @IsInheritGroupRole WHERE UserId = @UserId", cmdParams);
        }

        public static bool UnlockUser(int userId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserID", DbType.Int32, userId);
            object obj2 = DBHelper.ExecuteScalarSql("SELECT Status FROM PE_Users WHERE UserID = @UserID", cmdParams);
            if (obj2 == null)
            {
                return false;
            }
            UserStatus userStatus = (UserStatus) ((int) obj2);
            if ((userStatus & UserStatus.Locked) == UserStatus.Locked)
            {
                userStatus ^= UserStatus.Locked;
            }
            return UpdateUserStatus(userId, userStatus);
        }

        public bool Update(UserInfo usersInfo)
        {
            return DBHelper.ExecuteProc("PR_UserManage_Users_Update", GetUserParameters(usersInfo));
        }

        public bool Update(int userId, string fieldName, string fieldValue)
        {
            return DBHelper.ExecuteSql(string.Format("Update PE_Users SET {0}='{1}' where [UserID]={2}", fieldName, fieldValue, userId.ToString()));
        }

        public bool UpdateForCompany(int companyId, string userName, UserType userType, int companyClientId)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@CompanyID", DbType.Int32, companyId);
            cmdParams.AddInParameter("@UserName", DbType.String, userName);
            cmdParams.AddInParameter("@UserType", DbType.String, (int) userType);
            if (companyClientId > 0)
            {
                cmdParams.AddInParameter("@ClientID", DbType.Int32, companyClientId);
                return DBHelper.ExecuteSql("update PE_Users set UserType=@UserType,CompanyID= @CompanyID,ClientID=@ClientID where UserName=@UserName", cmdParams);
            }
            return DBHelper.ExecuteSql("update PE_Users set UserType=@UserType,CompanyID= @CompanyID where UserName=@UserName", cmdParams);
        }

        public bool UpdateUserFriendGroup(string userName, string userFriendGroup)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserName", DbType.String, userName);
            cmdParams.AddInParameter("@UserFriendGroup", DbType.String, userFriendGroup);
            return DBHelper.ExecuteSql("update PE_Users set UserFriendGroup= @UserFriendGroup where UserName=@UserName", cmdParams);
        }

        public static bool UpdateUserStatus(int userId, UserStatus userStatus)
        {
            Parameters cmdParams = new Parameters();
            cmdParams.AddInParameter("@UserID", DbType.Int32, userId);
            cmdParams.AddInParameter("@Status", DbType.Int32, userStatus);
            return DBHelper.ExecuteProc("PR_UserManage_Users_UpdateUserStatus", cmdParams);
        }

        private static UserInfo UsersFromrdr(NullableDataReader rdr)
        {
            UserInfo info = new UserInfo();
            info.UserId = rdr.GetInt32("UserID");
            info.GroupId = rdr.GetInt32("GroupID");
            info.CompanyId = rdr.GetInt32("CompanyID");
            info.ClientId = rdr.GetInt32("ClientID");
            info.UserType = (UserType) rdr.GetInt32("UserType");
            info.UserName = rdr.GetString("UserName");
            info.UserPassword = rdr.GetString("UserPassword");
            info.LastPassword = rdr.GetString("LastPassword");
            info.Question = rdr.GetString("Question");
            info.Answer = rdr.GetString("Answer");
            info.Email = rdr.GetString("Email");
            info.Sex = (UserSexType) rdr.GetInt32("Sex");
            info.RegTime = rdr.GetDateTime("RegTime");
            info.JoinTime = rdr.GetDateTime("JoinTime");
            info.LoginTimes = rdr.GetInt32("LoginTimes");
            info.LastLoginTime = rdr.GetNullableDateTime("LastLoginTime");
            info.LastPresentTime = rdr.GetNullableDateTime("LastPresentTime");
            info.LastLoginIP = rdr.GetString("LastLoginIP");
            info.LastPasswordChangedTime = rdr.GetNullableDateTime("LastPasswordChangedTime");
            info.LastLockoutTime = rdr.GetNullableDateTime("LastLockoutTime");
            info.FailedPasswordAttemptCount = rdr.GetInt32("FailedPasswordAttemptCount");
            info.FirstFailedPasswordAttempTime = rdr.GetNullableDateTime("FirstFailedPasswordAttempTime");
            info.FailedPasswordAnswerAttempCount = rdr.GetInt32("FailedPasswordAnswerAttempCount");
            info.FirstFailedPasswordAnswerAttempTime = rdr.GetNullableDateTime("FirstFailedPasswordAnswerAttempTime");
            info.Status = (UserStatus) rdr.GetInt32("Status");
            info.CheckNum = rdr.GetString("CheckNum");
            info.EnableResetPassword = rdr.GetBoolean("EnableResetPassword");
            info.UserFace = rdr.GetString("UserFace");
            info.FaceWidth = rdr.GetInt32("FaceWidth");
            info.FaceHeight = rdr.GetInt32("FaceHeight");
            info.Sign = rdr.GetString("Sign");
            info.PrivacySetting = rdr.GetInt32("PrivacySetting");
            info.Balance = rdr.GetDecimal("Balance");
            info.UserPoint = rdr.GetInt32("UserPoint");
            info.UserExp = rdr.GetInt32("UserExp");
            info.ConsumeMoney = rdr.GetInt32("ConsumeMoney");
            info.ConsumePoint = rdr.GetInt32("ConsumePoint");
            info.ConsumeExp = rdr.GetInt32("ConsumeExp");
            info.PostItems = rdr.GetInt32("PostItems");
            info.PassedItems = rdr.GetInt32("PassedItems");
            info.RejectItems = rdr.GetInt32("RejectItems");
            info.DelItems = rdr.GetInt32("DelItems");
            info.EndTime = rdr.GetNullableDateTime("EndTime");
            info.IsInheritGroupRole = rdr.GetBoolean("IsInheritGroupRole");
            info.UserSetting = rdr.GetString("UserSetting");
            info.UserFriendGroup = rdr.GetString("UserFriendGroup");
            info.UserTrueName = rdr.GetString("TrueName");
            return info;
        }

        public int ValidateUser(string username, string password)
        {
            Database database = DatabaseFactory.CreateDatabase();
            DbCommand sqlStringCommand = database.GetSqlStringCommand("SELECT UserId FROM [PE_Users] WHERE UserName =@UserName And UserPassword=@Password");
            database.AddInParameter(sqlStringCommand, "@UserName", DbType.String, username);
            database.AddInParameter(sqlStringCommand, "@Password", DbType.String, password);
            int num = -1;
            using (NullableDataReader reader = new NullableDataReader(database.ExecuteReader(sqlStringCommand)))
            {
                if (reader.Read())
                {
                    num = reader.GetInt32("UserId");
                }
            }
            return num;
        }
    }
}