1
0

user.go 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  1. package service
  2. import (
  3. "errors"
  4. "x-ui/database"
  5. "x-ui/database/model"
  6. "x-ui/logger"
  7. "x-ui/util/crypto"
  8. "gorm.io/gorm"
  9. )
  10. type UserService struct{}
  11. func (s *UserService) GetFirstUser() (*model.User, error) {
  12. db := database.GetDB()
  13. user := &model.User{}
  14. err := db.Model(model.User{}).
  15. First(user).
  16. Error
  17. if err != nil {
  18. return nil, err
  19. }
  20. return user, nil
  21. }
  22. func (s *UserService) CheckUser(username string, password string, secret string) *model.User {
  23. db := database.GetDB()
  24. user := &model.User{}
  25. err := db.Model(model.User{}).
  26. Where("username = ? and login_secret = ?", username, secret).
  27. First(user).
  28. Error
  29. if err == gorm.ErrRecordNotFound {
  30. return nil
  31. } else if err != nil {
  32. logger.Warning("check user err:", err)
  33. return nil
  34. }
  35. if crypto.CheckPasswordHash(user.Password, password) {
  36. return user
  37. }
  38. return nil
  39. }
  40. func (s *UserService) UpdateUser(id int, username string, password string) error {
  41. db := database.GetDB()
  42. hashedPassword, err := crypto.HashPasswordAsBcrypt(password)
  43. if err != nil {
  44. return err
  45. }
  46. return db.Model(model.User{}).
  47. Where("id = ?", id).
  48. Updates(map[string]any{"username": username, "password": hashedPassword}).
  49. Error
  50. }
  51. func (s *UserService) UpdateUserSecret(id int, secret string) error {
  52. db := database.GetDB()
  53. return db.Model(model.User{}).
  54. Where("id = ?", id).
  55. Update("login_secret", secret).
  56. Error
  57. }
  58. func (s *UserService) RemoveUserSecret() error {
  59. db := database.GetDB()
  60. return db.Model(model.User{}).
  61. Where("1 = 1").
  62. Update("login_secret", "").
  63. Error
  64. }
  65. func (s *UserService) GetUserSecret(id int) *model.User {
  66. db := database.GetDB()
  67. user := &model.User{}
  68. err := db.Model(model.User{}).
  69. Where("id = ?", id).
  70. First(user).
  71. Error
  72. if err == gorm.ErrRecordNotFound {
  73. return nil
  74. }
  75. return user
  76. }
  77. func (s *UserService) CheckSecretExistence() (bool, error) {
  78. db := database.GetDB()
  79. var count int64
  80. err := db.Model(model.User{}).
  81. Where("login_secret IS NOT NULL").
  82. Count(&count).
  83. Error
  84. if err != nil {
  85. return false, err
  86. }
  87. return count > 0, nil
  88. }
  89. func (s *UserService) UpdateFirstUser(username string, password string) error {
  90. if username == "" {
  91. return errors.New("username can not be empty")
  92. } else if password == "" {
  93. return errors.New("password can not be empty")
  94. }
  95. hashedPassword, er := crypto.HashPasswordAsBcrypt(password)
  96. if er != nil {
  97. return er
  98. }
  99. db := database.GetDB()
  100. user := &model.User{}
  101. err := db.Model(model.User{}).First(user).Error
  102. if database.IsNotFound(err) {
  103. user.Username = username
  104. user.Password = hashedPassword
  105. return db.Model(model.User{}).Create(user).Error
  106. } else if err != nil {
  107. return err
  108. }
  109. user.Username = username
  110. user.Password = hashedPassword
  111. return db.Save(user).Error
  112. }