|
|
@@ -0,0 +1,61 @@
|
|
|
+/*
|
|
|
+* @desc:用户处理
|
|
|
+* @company:云南奇讯科技有限公司
|
|
|
+* @Author: yixiaohu
|
|
|
+* @Date: 2022/3/7 9:50
|
|
|
+ */
|
|
|
+
|
|
|
+package service
|
|
|
+
|
|
|
+import (
|
|
|
+ "context"
|
|
|
+ "github.com/gogf/gf/v2/errors/gerror"
|
|
|
+ "github.com/gogf/gf/v2/frame/g"
|
|
|
+ "github.com/tiger1103/gfast/v3/apiv1/system"
|
|
|
+ "github.com/tiger1103/gfast/v3/internal/app/system/model"
|
|
|
+ "github.com/tiger1103/gfast/v3/internal/app/system/service/internal/dao"
|
|
|
+ "github.com/tiger1103/gfast/v3/library/libUtils"
|
|
|
+ "github.com/tiger1103/gfast/v3/library/liberr"
|
|
|
+)
|
|
|
+
|
|
|
+var (
|
|
|
+ user = userImpl{}
|
|
|
+)
|
|
|
+
|
|
|
+func User() IUser {
|
|
|
+ return IUser(&user)
|
|
|
+}
|
|
|
+
|
|
|
+type IUser interface {
|
|
|
+ GetAdminUserByUsernamePassword(ctx context.Context, req *system.UserLoginReq) (user *model.LoginUserRes, err error)
|
|
|
+}
|
|
|
+
|
|
|
+type userImpl struct {
|
|
|
+}
|
|
|
+
|
|
|
+func (s *userImpl) GetAdminUserByUsernamePassword(ctx context.Context, req *system.UserLoginReq) (user *model.LoginUserRes, err error) {
|
|
|
+ err = g.Try(func() {
|
|
|
+ user, err = s.GetUserByUsername(ctx, req.Username)
|
|
|
+ liberr.ErrIsNil(ctx, err)
|
|
|
+ liberr.ValueIsNil(user, "账号密码错误")
|
|
|
+ //验证密码
|
|
|
+ if libUtils.EncryptPassword(req.Password, user.UserSalt) != user.UserPassword {
|
|
|
+ liberr.ErrIsNil(ctx, gerror.New("账号密码错误"))
|
|
|
+ }
|
|
|
+ //账号状态
|
|
|
+ if user.UserStatus == 0 {
|
|
|
+ liberr.ErrIsNil(ctx, gerror.New("账号已被冻结"))
|
|
|
+ }
|
|
|
+ })
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
+// GetUserByUsername 通过用户名获取用户信息
|
|
|
+func (s *userImpl) GetUserByUsername(ctx context.Context, userName string) (user *model.LoginUserRes, err error) {
|
|
|
+ err = g.Try(func() {
|
|
|
+ user = &model.LoginUserRes{}
|
|
|
+ err = dao.SysUser.Ctx(ctx).Fields(user).Where(dao.SysUser.Columns().UserName, userName).Scan(user)
|
|
|
+ liberr.ErrIsNil(ctx, err, "获取用户信息失败")
|
|
|
+ })
|
|
|
+ return
|
|
|
+}
|