goweb實現用戶管理系統
用戶后臺管理系統功能描述
登錄功能
- 支持用戶通過郵箱密碼和密碼進行登錄。
- 對輸入的郵箱和密碼進行驗證,確保用戶信息的正確性。
- 登錄成功后,更新用戶的今日登錄統計信息,并將用戶信息存入會話(cookie)中,便于后續操作。
- 提供友好的錯誤提示,如“用戶不存在”“密碼錯誤”“用戶已被禁用”等,幫助用戶了解登錄失敗的原因。
package serviceimport ("UserManager/src/mapper""UserManager/src/utils""fmt""golang.org/x/crypto/bcrypt"
)type LoginService struct {Mapper *mapper.LoginMapper
}func NewLoginService(lm *mapper.LoginMapper) *LoginService {return &LoginService{Mapper: lm,}
}// 用戶登錄
func (ls *LoginService) LoginUser(email string, password string) (string, error) {user, err := ls.Mapper.GetUserByEmail(email)if err != nil || user == nil {return "", fmt.Errorf("用戶不存在")}//驗證密碼if err := bcrypt.CompareHashAndPassword([]byte(user.PasswordHash), []byte(password)); err != nil {return "", fmt.Errorf("密碼錯誤")}fmt.Println("hhh", user)if user.Status == 0 {return "", fmt.Errorf("用戶已被禁用")}//生成JWTtoken, err := utils.GenerateToken(user)if err != nil {return "", fmt.Errorf("生成令牌失敗")}return token, nil
}
注冊功能
- 允許用戶輸入郵箱、驗證碼,密碼及確認密碼進行注冊。
- 對郵箱進行唯一性校驗,避免重復注冊,并發送驗證碼。
- 檢查兩次輸入的密碼是否一致,確保用戶密碼的準確性。
- 使用 bcrypt 算法對用戶密碼進行加密存儲,保障用戶密碼的安全性。
- 注冊成功后,自動增加今日新增人數統計。
package serviceimport ("UserManager/src/mapper""UserManager/src/models""UserManager/src/utils""fmt""github.com/google/uuid""golang.org/x/crypto/bcrypt""regexp"
)// VerificationInfo 保存驗證碼及其過期時間type RegisterService struct {Mapper *mapper.RegisterMapperEmailService *utils.EmailServiceVerificationService *utils.VerificationService
}func NewRegisterService(rm *mapper.RegisterMapper, emailService *utils.EmailService, vService *utils.VerificationService) *RegisterService {return &RegisterService{Mapper: rm,EmailService: emailService,VerificationService: vService,}
}// SendVerificationCode 生成驗證碼,并使用 Redis 存儲(有效期5分鐘)后發送郵件
func (rs *RegisterService) SendVerificationCode(email string) error {code, err := rs.VerificationService.GenerateAndStoreCode(email)if err != nil {return err}subject := "您的驗證碼"body := fmt.Sprintf("您的驗證碼為:%s,請勿泄露于他人!該驗證碼5分鐘內有效!如非本人操作,請忽略此郵件!。", code)return rs.EmailService.SendEmail(email, subject, body)
}// 用戶注冊
func (rs *RegisterService) RegisterUser(email, inputCode, password, passwordConfirm string) error {if !isValidPassword(password) {return fmt.Errorf("密碼必須是8-12位字母和數字組合")}if password != passwordConfirm {return fmt.Errorf("兩次密碼輸入不一致")}// 驗證驗證碼if err := rs.VerificationService.VerifyCode(email, inputCode); err != nil {return err}// 檢查郵箱是否已注冊if user, _ := rs.Mapper.GetUserByEmail(email); user != nil {return fmt.Errorf("郵箱已注冊")}// 加密密碼hashed, err := bcrypt.GenerateFromPassword([]byte(password), bcrypt.DefaultCost)if err != nil {return fmt.Errorf("密碼加密失敗:%v", err)}// 插入新用戶newUser := &models.User{Email: email,PasswordHash: string(hashed),Nickname: "user_" + uuid.New().String()[:8],}if err := rs.Mapper.InsertUser(newUser); err != nil {return fmt.Errorf("用戶注冊失敗:%v", err)}return nil
}// isValidPassword 校驗密碼是否滿足8-12位字母和數字組合
func isValidPassword(password string) bool {// 1. 檢查長度是否為8-12位if len(password) < 8 || len(password) > 12 {return false}// 2. 檢查是否只包含字母和數字validChars, err := regexp.MatchString(`^[0-9A-Za-z]+$`, password)if err != nil || !validChars {return false}// 3. 檢查是否至少包含一個字母hasLetter, err := regexp.MatchString(`[A-Za-z]`, password)if err != nil || !hasLetter {return false}// 4. 檢查是否至少包含一個數字hasDigit, err := regexp.MatchString(`\d`, password)if err != nil || !hasDigit {return false}return true
}
用戶管理
用戶列表展示
- 以分頁的形式展示系統中的用戶列表,每頁顯示固定數量的用戶記錄。
- 提供用戶的基本信息,包括用戶名、角色、狀態、郵箱、頭像、注冊時間等,方便管理員快速了解用戶情況。
- 根據當前頁碼和總記錄數,動態計算并顯示分頁導航欄,方便管理員切換頁面查看不同用戶數據。
用戶搜索
- 支持管理員通過用戶名關鍵字進行用戶搜索,快速定位目標用戶。
- 搜索結果同樣以分頁形式展示,方便查看大量用戶數據。
- 提供搜索結果的總記錄數、總頁數等信息,幫助管理員了解搜索結果的范圍。
用戶創建
**
- 管理員可以輸入用戶名、密碼、郵箱、角色、狀態等信息創建新用戶。
- 對輸入的用戶信息進行校驗,如用戶名是否已存在、必填項是否填寫等。
- 支持上傳用戶頭像,并對上傳的文件進行類型、大小校驗,確保頭像的合法性。 創建成功后,自動更新今日新增人數統計。
用戶更新
- 管理員可以對現有用戶的信息進行修改,包括用戶名、密碼、郵箱、角色、狀態、頭像等。
- 在修改密碼時,只有當用戶輸入了新密碼時才會進行密碼更新,并且會對新密碼進行加密處理。
- 對修改后的用戶信息進行校驗,如用戶名是否被其他用戶占用等。
- 更新成功后,返回更新后的用戶頭像路徑等信息。
用戶刪除
- 管理員可以刪除指定的用戶,但不允許刪除當前登錄用戶自己。
- 刪除用戶時,同時刪除該用戶的頭像文件(如果頭像不是默認頭像)。
- 刪除成功后,自動更新今日被刪除人數統計。
package serviceimport ("UserManager/src/mapper""UserManager/src/models""UserManager/src/utils""errors""fmt""golang.org/x/crypto/bcrypt""io"
)type UserService struct {Mapper *mapper.UserMapper
}func NewUserService(hm *mapper.UserMapper) *UserService {return &UserService{Mapper: hm,}
}// GetUsers 支持分頁 + 搜索 + 狀態篩選
func (us *UserService) GetUsers(keyword, statusStr string, page, pageSize int) ([]*models.User, int, error) {// 計算 offsetoffset := (page - 1) * pageSize// 委托 Mapper 執行查詢并返回總數return us.Mapper.QueryUsersWithPage(keyword, statusStr, offset, pageSize)
}// 新增用戶
func (us *UserService) CreateUser(email, passwordHash, nickname string, avatarFile io.Reader, avatarFileName string, role, status int) (*models.User, error) {// 上傳頭像到 OSSavatarURL, err := utils.UploadFileToOSS(avatarFile, avatarFileName)if err != nil {return nil, err}// 檢查郵箱是否已注冊if user, _ := us.Mapper.GetUserByEmail(email); user != nil {return nil, errors.New("郵箱已注冊,請使用其他郵箱")}// 加密密碼hashed, err := bcrypt.GenerateFromPassword([]byte(passwordHash), bcrypt.DefaultCost)if err != nil {return nil, errors.New("密碼加密失敗")}user := &models.User{Email: email,PasswordHash: string(hashed),Nickname: nickname,AvatarUrl: avatarURL,Role: role,Status: status,}if err := us.Mapper.CreateUser(user); err != nil {return nil, err}return user, nil
}func (us *UserService) UpdateUser(id int, email, passwordHash, nickname string, avatarFile io.Reader, avatarFileName string, role, status int) (*models.User, error) {// 1. 先取出數據庫中的原用戶user, err := us.Mapper.GetUserByID(id)if err != nil {return nil, err}// 2. 如果郵箱被修改,檢查是否重復if email != user.Email {if existing, _ := us.Mapper.GetUserByEmail(email); existing != nil {return nil, errors.New("郵箱已注冊,請使用其他郵箱")}}// 3. 更新基本字段user.Email = emailuser.Nickname = nicknameuser.Role = roleuser.Status = status// 4. 如果前端傳了非空密碼,才加密并更新if passwordHash != "" {if !isValidPassword(passwordHash) {return nil, fmt.Errorf("密碼必須是8-12位字母和數字組合")}hashed, err := bcrypt.GenerateFromPassword([]byte(passwordHash), bcrypt.DefaultCost)if err != nil {return nil, errors.New("密碼加密失敗")}user.PasswordHash = string(hashed)}// 5. 如果前端上傳了新頭像,才上傳并更新 URLif avatarFile != nil {url, err := utils.UploadFileToOSS(avatarFile, avatarFileName)if err != nil {return nil, err}user.AvatarUrl = url}// 6. 寫回數據庫if err := us.Mapper.UpdateUser(user); err != nil {return nil, err}return user, nil
}// 根據用戶 ID 獲取用戶信息
func (us *UserService) GetUserByID(id int) (*models.User, error) {return us.Mapper.GetUserByID(id)
}// 刪除用戶信息
func (us *UserService) DeleteUser(id int) error {return us.Mapper.DeleteUser(id)
}
用戶統計與數據展示
首頁統計信息展示
- 在系統首頁展示一些關鍵的用戶統計數據,如總用戶數、本月登錄人次、注銷用戶數量等。
提供登錄增長率、用戶增長率、注銷用戶增長率等指標,幫助管理員了解系統的整體發展趨勢 - 展示過去 30天的登錄趨勢圖表,以日期為維度展示每日的登錄次數,方便管理員觀察登錄量的變化趨勢。
- 相關的統計信息(如今日登錄人數、今日新增人數、今日被刪除人數)會隨著用戶的登錄、注冊、刪除等操作實時更新,確保數據的準確性和時效性。
package serviceimport ("UserManager/src/mapper""time"
)type HomeService struct {Mapper *mapper.HomeMapper
}// TrendData 用于返回給前端的訪問趨勢數據
type TrendData struct {Date string `json:"date"`Count int `json:"count"`
}// 儀表數據
type DashboardData struct {RegisteredUsers int `json:"registered_users"`Visits int `json:"visits"`DeactivatedUsers int `json:"deactivated_users"`RegisteredUsersGrowth float64 `json:"registered_users_growth"`VisitsGrowth float64 `json:"visits_growth"`DeactivatedUsersGrowth float64 `json:"deactivated_users_growth"`
}func NewHomeService(hm *mapper.HomeMapper) *HomeService {return &HomeService{Mapper: hm,}
}// 獲取儀表盤統計數據
func (hs *HomeService) GetDashboardStats() (DashboardData, error) {// 獲取當前時間now := time.Now()currentUsers, err := hs.Mapper.CountRegisteredUsers(now)if err != nil {return DashboardData{}, err}currentVisits, err := hs.Mapper.CountVisits(time.Now())if err != nil {return DashboardData{}, err}currentDeactivated, err := hs.Mapper.CountDeactivatedUsers(time.Now())if err != nil {return DashboardData{}, err}//獲取上個月的數據// 獲取當前年份和月份year, month, _ := now.Date()// 計算上個月的年份和月份if month == time.January {year--month = time.December} else {month--}// 獲取上個月的第一天firstOfMonth := time.Date(year, month, 1, 0, 0, 0, 0, now.Location())// 上個月的最后一天是本月第一天的前一天lastMonth := firstOfMonth.AddDate(0, 1, -1)previousUsers, err := hs.Mapper.CountRegisteredUsers(lastMonth)if err != nil {return DashboardData{}, err}previousVisits, err := hs.Mapper.CountVisits(lastMonth)if err != nil {return DashboardData{}, err}previousDeactivated, err := hs.Mapper.CountDeactivatedUsers(lastMonth)if err != nil {return DashboardData{}, err}// 計算增長率usersGrowth := calculateGrowth(previousUsers, currentUsers)visitsGrowth := calculateGrowth(previousVisits, currentVisits)deactivatedGrowth := calculateGrowth(previousDeactivated, currentDeactivated)return DashboardData{RegisteredUsers: currentUsers,Visits: currentVisits,DeactivatedUsers: currentDeactivated,RegisteredUsersGrowth: usersGrowth,VisitsGrowth: visitsGrowth,DeactivatedUsersGrowth: deactivatedGrowth,}, nil
}// calculateGrowth 計算增長率
func calculateGrowth(previous, current int) float64 {if previous == 0 {if current > 0 {return 100.0 // 從0增長到正數,視為100%增長}return 0.0 // 無變化}return (float64(current-previous) / float64(previous)) * 100
}
func (hs *HomeService) AddVisitCounts(userID int) error {err := hs.Mapper.AddVisitCounts(userID)if err != nil {return err}return nil
}// 根據傳入天數獲取訪問趨勢數據
func (hs *HomeService) GetAccessTrends(days int) ([]TrendData, error) {// 計算起始時間(包含當天)startTime := time.Now().AddDate(0, 0, -days+1)visits, err := hs.Mapper.GetVisitsFrom(startTime)if err != nil {return nil, err}// 初始化每天的訪問計數(key 為日期字符串)trendMap := make(map[string]int)for i := 0; i < days; i++ {dateStr := time.Now().AddDate(0, 0, -i).Format("2006-01-02")trendMap[dateStr] = 0}// 遍歷訪問記錄進行計數for _, visit := range visits {dateStr := visit.VisitTime.Format("2006-01-02")trendMap[dateStr]++}// 按時間順序組織返回數據(例如從最早到最新)var trends []TrendDatafor i := days - 1; i >= 0; i-- {date := time.Now().AddDate(0, 0, -i).Format("2006-01-02")trends = append(trends, TrendData{Date: date,Count: trendMap[date],})}return trends, nil
}
具體代碼看我github,https://github.com/cxzgit/UserManager
另外utils下的oss.go這里你配一下就好了
package utilsimport ("fmt""github.com/aliyun/aliyun-oss-go-sdk/oss""io""time"
)// UploadFileToOSS 上傳文件到 OSS,并返回公開訪問的 URL
func UploadFileToOSS(file io.Reader, fileName string) (string, error) {endpoint := ""accessKeyID := ""accessKeySecret := ""bucketName := ""client, err := oss.New(endpoint, accessKeyID, accessKeySecret)if err != nil {return "", fmt.Errorf("failed to create OSS client: %w", err)}bucket, err := client.Bucket(bucketName)if err != nil {return "", fmt.Errorf("failed to get OSS bucket: %w", err)}// 生成唯一的對象 key(例如:avatars/時間戳_原文件名)objectKey := fmt.Sprintf("avatars/%d_%s", time.Now().UnixNano(), fileName)if err := bucket.PutObject(objectKey, file); err != nil {return "", fmt.Errorf("failed to upload file: %w", err)}// 假設 bucket 為公共讀,構造公開訪問的 URLossURL := fmt.Sprintf("https://%s.%s/%s", bucketName, endpoint, objectKey)return ossURL, nil}