refactor: change all user to account

This commit is contained in:
Leon
2025-12-05 14:25:39 +08:00
parent 311a27523f
commit c5331a459f
8 changed files with 95 additions and 95 deletions

View File

@@ -1,6 +1,6 @@
package account package account
type User struct { type Account struct {
ID uint `gorm:"primaryKey" json:"id"` ID uint `gorm:"primaryKey" json:"id"`
Username string `gorm:"unique" json:"username"` Username string `gorm:"unique" json:"username"`
Password string `json:"-"` Password string `json:"-"`

View File

@@ -4,60 +4,60 @@ import (
"gorm.io/gorm" "gorm.io/gorm"
) )
type UserRepository struct { type AccountRepository struct {
db *gorm.DB db *gorm.DB
} }
func NewUserRepository(db *gorm.DB) *UserRepository { func NewAccountRepository(db *gorm.DB) *AccountRepository {
return &UserRepository{db: db} return &AccountRepository{db: db}
} }
func (ur *UserRepository) CreateUser(user *User) error { func (ar *AccountRepository) CreateAccount(account *Account) error {
if err := ur.db.Create(user).Error; err != nil { if err := ar.db.Create(account).Error; err != nil {
return err return err
} }
return nil return nil
} }
func (ur *UserRepository) RenameByID(id uint, newUsername string) error { func (ar *AccountRepository) RenameByID(id uint, newUsername string) error {
if err := ur.db.Model(&User{}).Where("id = ?", id).Update("username", newUsername).Error; err != nil { if err := ar.db.Model(&Account{}).Where("id = ?", id).Update("username", newUsername).Error; err != nil {
return err return err
} }
return nil return nil
} }
func (ur *UserRepository) ChangePassword(id uint, newPassword string) error { func (ar *AccountRepository) ChangePassword(id uint, newPassword string) error {
if err := ur.db.Model(&User{}).Where("id = ?", id).Update("password", newPassword).Error; err != nil { if err := ar.db.Model(&Account{}).Where("id = ?", id).Update("password", newPassword).Error; err != nil {
return err return err
} }
return nil return nil
} }
func (ur *UserRepository) FindByID(id uint) (*User, error) { func (ar *AccountRepository) FindByID(id uint) (*Account, error) {
var user User var account Account
if err := ur.db.First(&user, id).Error; err != nil { if err := ar.db.First(&account, id).Error; err != nil {
return nil, err return nil, err
} }
return &user, nil return &account, nil
} }
func (ur *UserRepository) FindByUsername(username string) (*User, error) { func (ar *AccountRepository) FindByUsername(username string) (*Account, error) {
var user User var account Account
if err := ur.db.Where("username = ?", username).First(&user).Error; err != nil { if err := ar.db.Where("username = ?", username).First(&account).Error; err != nil {
return nil, err return nil, err
} }
return &user, nil return &account, nil
} }
func (ur *UserRepository) Login(id uint, token string) error { func (ar *AccountRepository) Login(id uint, token string) error {
if err := ur.db.Model(&User{}).Where("id = ?", id).Update("token", token).Error; err != nil { if err := ar.db.Model(&Account{}).Where("id = ?", id).Update("token", token).Error; err != nil {
return err return err
} }
return nil return nil
} }
func (ur *UserRepository) Logout(id uint, token string) error { func (ar *AccountRepository) Logout(id uint, token string) error {
if err := ur.db.Model(&User{}).Where("id = ?", id).Update("token", "").Error; err != nil { if err := ar.db.Model(&Account{}).Where("id = ?", id).Update("token", "").Error; err != nil {
return err return err
} }
return nil return nil

View File

@@ -7,94 +7,94 @@ import (
"golang.org/x/crypto/bcrypt" "golang.org/x/crypto/bcrypt"
) )
type UserService struct { type AccountService struct {
userRepository *UserRepository accountRepository *AccountRepository
} }
func NewUserService(userRepository *UserRepository) *UserService { func NewAccountService(accountRepository *AccountRepository) *AccountService {
return &UserService{userRepository: userRepository} return &AccountService{accountRepository: accountRepository}
} }
func (us *UserService) CreateUser(user *User) error { func (as *AccountService) CreateAccount(account *Account) error {
passwordHash, err := bcrypt.GenerateFromPassword([]byte(user.Password), bcrypt.DefaultCost) passwordHash, err := bcrypt.GenerateFromPassword([]byte(account.Password), bcrypt.DefaultCost)
if err != nil { if err != nil {
return err return err
} }
user.Password = string(passwordHash) account.Password = string(passwordHash)
if err := us.userRepository.CreateUser(user); err != nil { if err := as.accountRepository.CreateAccount(account); err != nil {
return err return err
} }
return nil return nil
} }
func (us *UserService) RenameByID(id uint, newUsername string) error { func (as *AccountService) RenameByID(id uint, newUsername string) error {
if err := us.userRepository.RenameByID(id, newUsername); err != nil { if err := as.accountRepository.RenameByID(id, newUsername); err != nil {
return err return err
} }
return nil return nil
} }
func (us *UserService) ChangePassword(username, oldPassword, newPassword string) error { func (as *AccountService) ChangePassword(username, oldPassword, newPassword string) error {
user, err := us.FindByUsername(username) account, err := as.FindByUsername(username)
if err != nil { if err != nil {
return err return err
} }
if err := bcrypt.CompareHashAndPassword([]byte(user.Password), []byte(oldPassword)); err != nil { if err := bcrypt.CompareHashAndPassword([]byte(account.Password), []byte(oldPassword)); err != nil {
return err return err
} }
passwordHash, err := bcrypt.GenerateFromPassword([]byte(newPassword), bcrypt.DefaultCost) passwordHash, err := bcrypt.GenerateFromPassword([]byte(newPassword), bcrypt.DefaultCost)
if err != nil { if err != nil {
return err return err
} }
if err := us.userRepository.ChangePassword(user.ID, string(passwordHash)); err != nil { if err := as.accountRepository.ChangePassword(account.ID, string(passwordHash)); err != nil {
return err return err
} }
return nil return nil
} }
func (us *UserService) FindByID(id uint) (*User, error) { func (as *AccountService) FindByID(id uint) (*Account, error) {
if user, err := us.userRepository.FindByID(id); err != nil { if account, err := as.accountRepository.FindByID(id); err != nil {
return nil, err return nil, err
} else { } else {
return user, nil return account, nil
} }
} }
func (us *UserService) FindByUsername(username string) (*User, error) { func (as *AccountService) FindByUsername(username string) (*Account, error) {
if user, err := us.userRepository.FindByUsername(username); err != nil { if account, err := as.accountRepository.FindByUsername(username); err != nil {
return nil, err return nil, err
} else { } else {
return user, nil return account, nil
} }
} }
func (us *UserService) Login(username, password string) (string, error) { func (as *AccountService) Login(username, password string) (string, error) {
user, err := us.FindByUsername(username) account, err := as.FindByUsername(username)
if err != nil { if err != nil {
return "", err return "", err
} }
if err := bcrypt.CompareHashAndPassword([]byte(user.Password), []byte(password)); err != nil { if err := bcrypt.CompareHashAndPassword([]byte(account.Password), []byte(password)); err != nil {
return "", err return "", err
} }
// generate token // generate token
token, err := auth.GenerateToken(user.ID, user.Username) token, err := auth.GenerateToken(account.ID, account.Username)
if err != nil { if err != nil {
return "", err return "", err
} }
if err := us.userRepository.Login(user.ID, token); err != nil { if err := as.accountRepository.Login(account.ID, token); err != nil {
return "", err return "", err
} }
return token, nil return token, nil
} }
func (us *UserService) Logout(userID uint) error { func (as *AccountService) Logout(accountID uint) error {
user, err := us.FindByID(userID) account, err := as.FindByID(accountID)
if err != nil { if err != nil {
return err return err
} }
if user.Token == "" { if account.Token == "" {
return errors.New("user already logged out") return errors.New("account already logged out")
} }
return us.userRepository.Logout(user.ID, user.Token) return as.accountRepository.Logout(account.ID, account.Token)
} }

View File

@@ -10,17 +10,17 @@ import (
var secret = []byte("change-me-in-env") var secret = []byte("change-me-in-env")
type Claims struct { type Claims struct {
UserID uint `json:"user_id"` AccountID uint `json:"account_id"`
Username string `json:"username"` Username string `json:"username"`
jwt.RegisteredClaims jwt.RegisteredClaims
} }
func GenerateToken(userID uint, username string) (string, error) { func GenerateToken(accountID uint, username string) (string, error) {
now := time.Now() now := time.Now()
claims := Claims{ claims := Claims{
UserID: userID, AccountID: accountID,
Username: username, Username: username,
RegisteredClaims: jwt.RegisteredClaims{ RegisteredClaims: jwt.RegisteredClaims{
ExpiresAt: jwt.NewNumericDate(now.Add(24 * time.Hour)), ExpiresAt: jwt.NewNumericDate(now.Add(24 * time.Hour)),
IssuedAt: jwt.NewNumericDate(now), IssuedAt: jwt.NewNumericDate(now),

View File

@@ -22,7 +22,7 @@ func NewDB(dbcfg config.DatabaseConfig) (*gorm.DB, error) {
} }
func AutoMigrate(db *gorm.DB) error { func AutoMigrate(db *gorm.DB) error {
return db.AutoMigrate(&account.User{}) return db.AutoMigrate(&account.Account{})
} }
func CloseDB(db *gorm.DB) error { func CloseDB(db *gorm.DB) error {

View File

@@ -6,16 +6,16 @@ import (
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
) )
type UserHandler struct { type AccountHandler struct {
userService *account.UserService accountService *account.AccountService
} }
type CreateUserRequest struct { type CreateAccountRequest struct {
Username string `json:"username"` Username string `json:"username"`
Password string `json:"password"` Password string `json:"password"`
} }
type CreateUserResponse struct { type CreateAccountResponse struct {
} }
type RenameByIDRequest struct { type RenameByIDRequest struct {
@@ -66,86 +66,86 @@ type LogoutRequest struct {
type LogoutResponse struct { type LogoutResponse struct {
} }
func NewUserHandler(userService *account.UserService) *UserHandler { func NewAccountHandler(accountService *account.AccountService) *AccountHandler {
return &UserHandler{userService: userService} return &AccountHandler{accountService: accountService}
} }
func (h *UserHandler) CreateUser(c *gin.Context) { func (h *AccountHandler) CreateAccount(c *gin.Context) {
var req CreateUserRequest var req CreateAccountRequest
if err := c.ShouldBindJSON(&req); err != nil { if err := c.ShouldBindJSON(&req); err != nil {
c.JSON(400, gin.H{"error": err.Error()}) c.JSON(400, gin.H{"error": err.Error()})
return return
} }
if err := h.userService.CreateUser(&account.User{ if err := h.accountService.CreateAccount(&account.Account{
Username: req.Username, Username: req.Username,
Password: req.Password, Password: req.Password,
}); err != nil { }); err != nil {
c.JSON(500, gin.H{"error": err.Error()}) c.JSON(500, gin.H{"error": err.Error()})
return return
} }
c.JSON(200, gin.H{"message": "user created"}) c.JSON(200, gin.H{"message": "account created"})
} }
func (h *UserHandler) RenameByID(c *gin.Context) { func (h *AccountHandler) RenameByID(c *gin.Context) {
var req RenameByIDRequest var req RenameByIDRequest
if err := c.ShouldBindJSON(&req); err != nil { if err := c.ShouldBindJSON(&req); err != nil {
c.JSON(400, gin.H{"error": err.Error()}) c.JSON(400, gin.H{"error": err.Error()})
return return
} }
if err := h.userService.RenameByID(req.ID, req.NewUsername); err != nil { if err := h.accountService.RenameByID(req.ID, req.NewUsername); err != nil {
c.JSON(500, gin.H{"error": err.Error()}) c.JSON(500, gin.H{"error": err.Error()})
return return
} }
c.JSON(200, gin.H{"message": "user renamed"}) c.JSON(200, gin.H{"message": "account renamed"})
} }
func (h *UserHandler) ChangePassword(c *gin.Context) { func (h *AccountHandler) ChangePassword(c *gin.Context) {
var req ChangePasswordRequest var req ChangePasswordRequest
if err := c.ShouldBindJSON(&req); err != nil { if err := c.ShouldBindJSON(&req); err != nil {
c.JSON(400, gin.H{"error": err.Error()}) c.JSON(400, gin.H{"error": err.Error()})
return return
} }
if err := h.userService.ChangePassword(req.Username, req.OldPassword, req.NewPassword); err != nil { if err := h.accountService.ChangePassword(req.Username, req.OldPassword, req.NewPassword); err != nil {
c.JSON(500, gin.H{"error": err.Error()}) c.JSON(500, gin.H{"error": err.Error()})
return return
} }
c.JSON(200, gin.H{"message": "password changed"}) c.JSON(200, gin.H{"message": "password changed"})
} }
func (h *UserHandler) FindByID(c *gin.Context) { func (h *AccountHandler) FindByID(c *gin.Context) {
var req FindByIDRequest var req FindByIDRequest
if err := c.ShouldBindJSON(&req); err != nil { if err := c.ShouldBindJSON(&req); err != nil {
c.JSON(400, gin.H{"error": err.Error()}) c.JSON(400, gin.H{"error": err.Error()})
return return
} }
if user, err := h.userService.FindByID(req.ID); err != nil { if account, err := h.accountService.FindByID(req.ID); err != nil {
c.JSON(500, gin.H{"error": err.Error()}) c.JSON(500, gin.H{"error": err.Error()})
return return
} else { } else {
c.JSON(200, user) c.JSON(200, account)
} }
} }
func (h *UserHandler) FindByUsername(c *gin.Context) { func (h *AccountHandler) FindByUsername(c *gin.Context) {
var req FindByUsernameRequest var req FindByUsernameRequest
if err := c.ShouldBindJSON(&req); err != nil { if err := c.ShouldBindJSON(&req); err != nil {
c.JSON(400, gin.H{"error": err.Error()}) c.JSON(400, gin.H{"error": err.Error()})
return return
} }
if user, err := h.userService.FindByUsername(req.Username); err != nil { if account, err := h.accountService.FindByUsername(req.Username); err != nil {
c.JSON(500, gin.H{"error": err.Error()}) c.JSON(500, gin.H{"error": err.Error()})
return return
} else { } else {
c.JSON(200, user) c.JSON(200, account)
} }
} }
func (h *UserHandler) Login(c *gin.Context) { func (h *AccountHandler) Login(c *gin.Context) {
var req LoginRequest var req LoginRequest
if err := c.ShouldBindJSON(&req); err != nil { if err := c.ShouldBindJSON(&req); err != nil {
c.JSON(400, gin.H{"error": err.Error()}) c.JSON(400, gin.H{"error": err.Error()})
return return
} }
if token, err := h.userService.Login(req.Username, req.Password); err != nil { if token, err := h.accountService.Login(req.Username, req.Password); err != nil {
c.JSON(500, gin.H{"error": err.Error()}) c.JSON(500, gin.H{"error": err.Error()})
return return
} else { } else {
@@ -153,13 +153,13 @@ func (h *UserHandler) Login(c *gin.Context) {
} }
} }
func (h *UserHandler) Logout(c *gin.Context) { func (h *AccountHandler) Logout(c *gin.Context) {
var req LogoutRequest var req LogoutRequest
if err := c.ShouldBindJSON(&req); err != nil { if err := c.ShouldBindJSON(&req); err != nil {
c.JSON(400, gin.H{"error": err.Error()}) c.JSON(400, gin.H{"error": err.Error()})
return return
} }
if err := h.userService.Logout(req.ID); err != nil { if err := h.accountService.Logout(req.ID); err != nil {
c.JSON(500, gin.H{"error": err.Error()}) c.JSON(500, gin.H{"error": err.Error()})
return return
} }

View File

@@ -11,26 +11,26 @@ import (
func SetRouter(db *gorm.DB) *gin.Engine { func SetRouter(db *gorm.DB) *gin.Engine {
r := gin.Default() r := gin.Default()
userRepository := account.NewUserRepository(db) accountRepository := account.NewAccountRepository(db)
userService := account.NewUserService(userRepository) accountService := account.NewAccountService(accountRepository)
userHandler := NewUserHandler(userService) accountHandler := NewAccountHandler(accountService)
userGroup := r.Group("/user") accountGroup := r.Group("/account")
{ {
userGroup.POST("/register", userHandler.CreateUser) accountGroup.POST("/register", accountHandler.CreateAccount)
userGroup.POST("/rename", userHandler.RenameByID) accountGroup.POST("/rename", accountHandler.RenameByID)
userGroup.POST("/changePassword", userHandler.ChangePassword) accountGroup.POST("/changePassword", accountHandler.ChangePassword)
userGroup.POST("/findByID", userHandler.FindByID) accountGroup.POST("/findByID", accountHandler.FindByID)
userGroup.POST("/findByUsername", userHandler.FindByUsername) accountGroup.POST("/findByUsername", accountHandler.FindByUsername)
} }
authGroup := r.Group("/auth") authGroup := r.Group("/auth")
{ {
authGroup.POST("/login", userHandler.Login) authGroup.POST("/login", accountHandler.Login)
} }
protectedAuthGroup := authGroup.Group("") protectedAuthGroup := authGroup.Group("")
protectedAuthGroup.Use(middleware.JWTAuth()) protectedAuthGroup.Use(middleware.JWTAuth())
{ {
protectedAuthGroup.POST("/logout", userHandler.Logout) protectedAuthGroup.POST("/logout", accountHandler.Logout)
} }
return r return r

View File

@@ -33,7 +33,7 @@ func JWTAuth() gin.HandlerFunc {
return return
} }
c.Set("userID", claims.UserID) c.Set("accountID", claims.AccountID)
c.Set("username", claims.Username) c.Set("username", claims.Username)
c.Next() c.Next()