package system import ( "errors" "github.com/flipped-aurora/gin-vue-admin/server/global" "github.com/flipped-aurora/gin-vue-admin/server/model/common/request" "github.com/flipped-aurora/gin-vue-admin/server/model/system" systemReq "github.com/flipped-aurora/gin-vue-admin/server/model/system/request" "github.com/flipped-aurora/gin-vue-admin/server/utils" uuid "github.com/satori/go.uuid" "gorm.io/gorm" ) //@author: [piexlmax](https://github.com/piexlmax) //@function: Register //@description: 用户注册 //@param: u model.SysUser //@return: err error, userInter model.SysUser type UserService struct { } func (userService *UserService) Register(u system.SysUser) (err error, userInter system.SysUser) { var user system.SysUser if !errors.Is(global.GVA_DB.Where("username = ?", u.Username).First(&user).Error, gorm.ErrRecordNotFound) { // 判断用户名是否注册 return errors.New("用户名已注册"), userInter } // 否则 附加uuid 密码md5简单加密 注册 u.Password = utils.MD5V([]byte(u.Password)) u.UUID = uuid.NewV4() err = global.GVA_DB.Create(&u).Error return err, u } //@author: [piexlmax](https://github.com/piexlmax) //@function: Login //@description: 用户登录 //@param: u *model.SysUser //@return: err error, userInter *model.SysUser func (userService *UserService) Login(u *system.SysUser) (err error, userInter *system.SysUser) { var user system.SysUser u.Password = utils.MD5V([]byte(u.Password)) err = global.GVA_DB.Where("username = ? AND password = ?", u.Username, u.Password).Preload("Authorities").Preload("Authority").First(&user).Error return err, &user } //@author: [piexlmax](https://github.com/piexlmax) //@function: ChangePassword //@description: 修改用户密码 //@param: u *model.SysUser, newPassword string //@return: err error, userInter *model.SysUser func (userService *UserService) ChangePassword(u *system.SysUser, newPassword string) (err error, userInter *system.SysUser) { var user system.SysUser u.Password = utils.MD5V([]byte(u.Password)) err = global.GVA_DB.Where("username = ? AND password = ?", u.Username, u.Password).First(&user).Update("password", utils.MD5V([]byte(newPassword))).Error return err, u } //@author: [piexlmax](https://github.com/piexlmax) //@function: GetUserInfoList //@description: 分页获取数据 //@param: info request.PageInfo //@return: err error, list interface{}, total int64 func (userService *UserService) GetUserInfoList(info request.PageInfo) (err error, list interface{}, total int64) { limit := info.PageSize offset := info.PageSize * (info.Page - 1) db := global.GVA_DB.Model(&system.SysUser{}) var userList []system.SysUser err = db.Count(&total).Error err = db.Limit(limit).Offset(offset).Preload("Authorities").Preload("Authority").Find(&userList).Error return err, userList, total } func (userService *UserService) GetUserPInfoList(info systemReq.UserSearch) (err error, list interface{}, total int64) { limit := info.PageSize offset := info.PageSize * (info.Page - 1) db := global.GVA_DB.Model(&system.SysUser{}) db.Where("id != 1") if info.AuthorityId != "" { db.Where("authority_id=?", info.AuthorityId) } var userList []system.SysUser err = db.Count(&total).Error err = db.Limit(limit).Offset(offset).Preload("Authorities").Preload("Authority").Order("created_at desc").Find(&userList).Error return err, userList, total } //@author: [piexlmax](https://github.com/piexlmax) //@function: SetUserAuthority //@description: 设置一个用户的权限 //@param: uuid uuid.UUID, authorityId string //@return: err error func (userService *UserService) SetUserAuthority(id uint, uuid uuid.UUID, authorityId string) (err error) { assignErr := global.GVA_DB.Where("sys_user_id = ? AND sys_authority_authority_id = ?", id, authorityId).First(&system.SysUseAuthority{}).Error if errors.Is(assignErr, gorm.ErrRecordNotFound) { return errors.New("该用户无此角色") } err = global.GVA_DB.Where("uuid = ?", uuid).First(&system.SysUser{}).Update("authority_id", authorityId).Error return err } //@author: [piexlmax](https://github.com/piexlmax) //@function: SetUserAuthorities //@description: 设置一个用户的权限 //@param: id uint, authorityIds []string //@return: err error func (userService *UserService) SetUserAuthorities(id uint, authorityIds []string) (err error) { return global.GVA_DB.Transaction(func(tx *gorm.DB) error { TxErr := tx.Delete(&[]system.SysUseAuthority{}, "sys_user_id = ?", id).Error if TxErr != nil { return TxErr } useAuthority := []system.SysUseAuthority{} for _, v := range authorityIds { useAuthority = append(useAuthority, system.SysUseAuthority{ id, v, }) } TxErr = tx.Create(&useAuthority).Error if TxErr != nil { return TxErr } // 返回 nil 提交事务 return nil }) } //@author: [piexlmax](https://github.com/piexlmax) //@function: DeleteUser //@description: 删除用户 //@param: id float64 //@return: err error func (userService *UserService) DeleteUser(id float64) (err error) { var user system.SysUser err = global.GVA_DB.Where("id = ?", id).Delete(&user).Error err = global.GVA_DB.Delete(&[]system.SysUseAuthority{}, "sys_user_id = ?", id).Error return err } //@author: [piexlmax](https://github.com/piexlmax) //@function: SetUserInfo //@description: 设置用户信息 //@param: reqUser model.SysUser //@return: err error, user model.SysUser func (userService *UserService) SetUserInfo(reqUser system.SysUser) (err error, user system.SysUser) { err = global.GVA_DB.Updates(&reqUser).Error return err, reqUser } func (userService *UserService) SetUserName(reqUser system.SysUser) (err error, user system.SysUser) { err = global.GVA_DB.Where("id=?", reqUser.ID).Save(reqUser).Error return err, reqUser } //@author: [piexlmax](https://github.com/piexlmax) //@function: GetUserInfo //@description: 获取用户信息 //@param: uuid uuid.UUID //@return: err error, user system.SysUser func (userService *UserService) GetUserInfo(uuid uuid.UUID) (err error, user system.SysUser) { var reqUser system.SysUser err = global.GVA_DB.Preload("Authorities").Preload("Authority").First(&reqUser, "uuid = ?", uuid).Error return err, reqUser } func (userService *UserService) GetUserInfoByWechatId(wechatId string) (err error, user system.SysUser) { var reqUser system.SysUser err = global.GVA_DB.First(&reqUser, "wechat_id = ?", wechatId).Error return err, reqUser } func (userService *UserService) GetUserInfoByUnionId(unionId string) (err error, user system.SysUser) { var reqUser system.SysUser err = global.GVA_DB.First(&reqUser, "union_id = ?", unionId).Error return err, reqUser } //@author: [SliverHorn](https://github.com/SliverHorn) //@function: FindUserById //@description: 通过id获取用户信息 //@param: id int //@return: err error, user *model.SysUser func (userService *UserService) FindUserById(id int) (err error, user system.SysUser) { var u system.SysUser err = global.GVA_DB.Where("`id` = ?", id).First(&u).Error return err, u } //@author: [SliverHorn](https://github.com/SliverHorn) //@function: FindUserByUuid //@description: 通过uuid获取用户信息 //@param: uuid string //@return: err error, user *model.SysUser func (userService *UserService) FindUserByUuid(uuid string) (err error, user *system.SysUser) { var u system.SysUser if err = global.GVA_DB.Where("`uuid` = ?", uuid).First(&u).Error; err != nil { return errors.New("用户不存在"), &u } return nil, &u } func (userService *UserService) FindUserByOpenId(openid string) (err error, user *system.SysUser) { var u system.SysUser if err = global.GVA_DB.Where("`open_id` = ?", openid).First(&u).Error; err != nil { return errors.New("用户不存在"), &u } return nil, &u }