user.go 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123
  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. "github.com/xlzd/gotp"
  9. "gorm.io/gorm"
  10. )
  11. type UserService struct {
  12. settingService SettingService
  13. }
  14. func (s *UserService) GetFirstUser() (*model.User, error) {
  15. db := database.GetDB()
  16. user := &model.User{}
  17. err := db.Model(model.User{}).
  18. First(user).
  19. Error
  20. if err != nil {
  21. return nil, err
  22. }
  23. return user, nil
  24. }
  25. func (s *UserService) CheckUser(username string, password string, twoFactorCode string) *model.User {
  26. db := database.GetDB()
  27. user := &model.User{}
  28. err := db.Model(model.User{}).
  29. Where("username = ?", username).
  30. First(user).
  31. Error
  32. if err == gorm.ErrRecordNotFound {
  33. return nil
  34. } else if err != nil {
  35. logger.Warning("check user err:", err)
  36. return nil
  37. }
  38. if !crypto.CheckPasswordHash(user.Password, password) {
  39. return nil
  40. }
  41. twoFactorEnable, err := s.settingService.GetTwoFactorEnable()
  42. if err != nil {
  43. logger.Warning("check two factor err:", err)
  44. return nil
  45. }
  46. if twoFactorEnable {
  47. twoFactorToken, err := s.settingService.GetTwoFactorToken()
  48. if err != nil {
  49. logger.Warning("check two factor token err:", err)
  50. return nil
  51. }
  52. if gotp.NewDefaultTOTP(twoFactorToken).Now() != twoFactorCode {
  53. return nil
  54. }
  55. }
  56. return user
  57. }
  58. func (s *UserService) UpdateUser(id int, username string, password string) error {
  59. db := database.GetDB()
  60. hashedPassword, err := crypto.HashPasswordAsBcrypt(password)
  61. if err != nil {
  62. return err
  63. }
  64. twoFactorEnable, err := s.settingService.GetTwoFactorEnable()
  65. if err != nil {
  66. return err
  67. }
  68. if twoFactorEnable {
  69. s.settingService.SetTwoFactorEnable(false)
  70. s.settingService.SetTwoFactorToken("")
  71. }
  72. return db.Model(model.User{}).
  73. Where("id = ?", id).
  74. Updates(map[string]any{"username": username, "password": hashedPassword}).
  75. Error
  76. }
  77. func (s *UserService) UpdateFirstUser(username string, password string) error {
  78. if username == "" {
  79. return errors.New("username can not be empty")
  80. } else if password == "" {
  81. return errors.New("password can not be empty")
  82. }
  83. hashedPassword, er := crypto.HashPasswordAsBcrypt(password)
  84. if er != nil {
  85. return er
  86. }
  87. db := database.GetDB()
  88. user := &model.User{}
  89. err := db.Model(model.User{}).First(user).Error
  90. if database.IsNotFound(err) {
  91. user.Username = username
  92. user.Password = hashedPassword
  93. return db.Model(model.User{}).Create(user).Error
  94. } else if err != nil {
  95. return err
  96. }
  97. user.Username = username
  98. user.Password = hashedPassword
  99. return db.Save(user).Error
  100. }