user.go 2.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113
  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. return db.Model(model.User{}).
  65. Where("id = ?", id).
  66. Updates(map[string]any{"username": username, "password": hashedPassword}).
  67. Error
  68. }
  69. func (s *UserService) UpdateFirstUser(username string, password string) error {
  70. if username == "" {
  71. return errors.New("username can not be empty")
  72. } else if password == "" {
  73. return errors.New("password can not be empty")
  74. }
  75. hashedPassword, er := crypto.HashPasswordAsBcrypt(password)
  76. if er != nil {
  77. return er
  78. }
  79. db := database.GetDB()
  80. user := &model.User{}
  81. err := db.Model(model.User{}).First(user).Error
  82. if database.IsNotFound(err) {
  83. user.Username = username
  84. user.Password = hashedPassword
  85. return db.Model(model.User{}).Create(user).Error
  86. } else if err != nil {
  87. return err
  88. }
  89. user.Username = username
  90. user.Password = hashedPassword
  91. return db.Save(user).Error
  92. }