feat(login): 优化登录服务错误处理和用户状态验证

- 修改GetUserInfo错误处理,将致命错误改为业务错误返回
- 移除登录查询中的status条件限制
- 添加账户封禁状态检查功能
- 修复缓存设置中的passwordVersion参数传递问题

refactor(task): 调整任务配置表结构和字段定义

- 将表名从task_config改为config_task
- 移除TaskName字段
- 将ElfRewardIds从数组
This commit is contained in:
2025-12-31 18:58:44 +08:00
parent 027214ef85
commit c082eb3e91
5 changed files with 62 additions and 16 deletions

View File

@@ -52,7 +52,8 @@ func (s *BaseSysLoginService) Login(ctx context.Context, req *v1.BaseOpenLoginRe
// 调用方法
userInfo, err := GetUserInfo(username, password)
if err != nil {
log.Fatal(err)
err = gerror.New("用户系统错误")
return
}
// // 输出结果
@@ -75,7 +76,7 @@ func (s *BaseSysLoginService) Login(ctx context.Context, req *v1.BaseOpenLoginRe
}
} else {
m := cool.DBM(baseSysUser).Where("username=?", username).Where("status=?", 1)
m := cool.DBM(baseSysUser).Where("username=?", username)
m.Scan(&user)
if user == nil {
//这里实现注册用户
@@ -83,9 +84,14 @@ func (s *BaseSysLoginService) Login(ctx context.Context, req *v1.BaseOpenLoginRe
// return
NewBaseSysUserService().Gen(userInfo.Data.Attributes)
m := cool.DBM(baseSysUser).Where("username=?", username).Where("status=?", 1)
m := cool.DBM(baseSysUser).Where("username=?", username)
m.Scan(&user)
} else {
if *user.Status == 0 {
err = gerror.New("账户被封禁~")
return
}
user.HeadImg = &userInfo.Data.Attributes.AvatarUrl
var ttt = *user.PasswordV + 1
user.PasswordV = &ttt
@@ -94,7 +100,7 @@ func (s *BaseSysLoginService) Login(ctx context.Context, req *v1.BaseOpenLoginRe
log.Fatal(err)
}
cool.CacheManager.Set(ctx, fmt.Sprintf("admin:passwordVersion:%d", user.ID), user.PasswordV, 0)
cool.CacheManager.Set(ctx, fmt.Sprintf("admin:passwordVersion:%d", user.ID), ttt, 0)
}
}