package logic import ( "context" "time" "fusenapi/model" "fusenapi/server/home-user-auth/internal/svc" "fusenapi/server/home-user-auth/internal/types" "fusenapi/utils/auth" "fusenapi/utils/basic" "github.com/zeromicro/go-zero/core/logx" ) type UserLoginLogic struct { logx.Logger ctx context.Context svcCtx *svc.ServiceContext } func NewUserLoginLogic(ctx context.Context, svcCtx *svc.ServiceContext) *UserLoginLogic { return &UserLoginLogic{ Logger: logx.WithContext(ctx), ctx: ctx, svcCtx: svcCtx, } } func (l *UserLoginLogic) UserLogin(req *types.RequestUserLogin) (resp *basic.Response, jwtToken string) { // 创建一个 FsUserModel 对象 m 并实例化之,该对象用于操作 MySQL 数据库中的用户数据表。 m := model.NewFsUserModel(l.svcCtx.MysqlConn) // 在用户数据表中根据登录名查找用户记录,并返回 UserModel 类型的结构体对象 userModel。 userModel, err := m.FindOneByEmail(l.ctx, req.Name) // 如果在用户数据表中没有找到登录名匹配的用户记录,则抛出 ErrNotFound 错误并返回未认证的状态码以及错误信息。 if err == model.ErrNotFound { logx.Error(err) return resp.SetStatusWithMessage(basic.CodeServiceErr, err.Error()), jwtToken } // 如果在用户数据表中找到了登录名匹配的用户记录,则判断密码是否匹配。 if userModel.PasswordHash != req.Password { logx.Info("密码错误") return resp.SetStatusWithMessage(basic.CodeUnAuth, "密码错误"), jwtToken } // 如果密码匹配,则生成 JWT Token。 nowSec := time.Now().Unix() jwtToken, err = auth.GenerateJwtToken(&l.svcCtx.Config.Auth.AccessSecret, l.svcCtx.Config.Auth.AccessExpire, nowSec, int64(userModel.Id), 0) // 如果生成 JWT Token 失败,则抛出错误并返回未认证的状态码。 if err != nil { logx.Error(err) return resp.SetStatus(basic.CodeUnAuth), jwtToken } // 更新 MySQL 数据库中用户记录对应的 VerificationToken 字段值为生成的 JWT Token。 err = m.UpdateVerificationToken(l.ctx, userModel.Id, jwtToken) // 如果更新 VerificationToken 字段失败,则返回未认证的状态码。 if err != nil { return resp.SetStatus(basic.CodeUnAuth), jwtToken } // 构造 DataUserLogin 类型的数据对象 data 并设置其属性值为生成的 JWT Token。 data := &types.DataUserLogin{ Token: jwtToken, } // 返回认证成功的状态码以及数据对象 data 和 JWT Token。 return resp.SetStatus(basic.CodeOK, data), jwtToken }