139 lines
3.7 KiB
Go
139 lines
3.7 KiB
Go
package internal
|
|
|
|
import (
|
|
"context"
|
|
"server/internal/consts"
|
|
"server/internal/dao"
|
|
"server/internal/model"
|
|
"server/internal/model/do"
|
|
"server/internal/model/entity"
|
|
"server/internal/service"
|
|
"server/utility/ecode"
|
|
"server/utility/jwt"
|
|
|
|
"github.com/gogf/gf/v2/os/gtime"
|
|
"github.com/gogf/gf/v2/util/grand"
|
|
)
|
|
|
|
type sUser struct{}
|
|
|
|
func init() {
|
|
service.RegisterUser(New())
|
|
go checkUserRole()
|
|
}
|
|
|
|
func checkUserRole() {
|
|
ctx := context.Background()
|
|
exist, err := dao.Roles.Ctx(ctx).Where(do.Roles{Code: consts.UserRoleCode}).Exist()
|
|
if err != nil {
|
|
return
|
|
}
|
|
if !exist {
|
|
_, err := dao.Roles.Ctx(ctx).Data(do.Roles{
|
|
Name: "用户",
|
|
Code: consts.UserRoleCode,
|
|
Description: "用户角色",
|
|
Status: consts.RoleEnable,
|
|
IsDeletable: false,
|
|
}).Insert()
|
|
if err != nil {
|
|
return
|
|
}
|
|
}
|
|
}
|
|
|
|
func New() service.IUser {
|
|
return &sUser{}
|
|
}
|
|
|
|
func (s *sUser) Login(ctx context.Context, in *model.UserLoginIn) (out *model.UserLoginOut, err error) {
|
|
value, err := dao.Roles.Ctx(ctx).Where(do.Roles{Code: consts.UserRoleCode}).Fields(dao.Roles.Columns().Code).Value()
|
|
if err != nil {
|
|
return nil, ecode.Fail.Sub("查找角色失败")
|
|
}
|
|
// 根据 OpenId 查找用户
|
|
exist, err := dao.Users.Ctx(ctx).Where(do.Users{WxOpenId: in.OpenId}).Exist()
|
|
if err != nil {
|
|
return nil, ecode.Fail.Sub("查找用户失败")
|
|
}
|
|
var userId int64
|
|
if !exist {
|
|
// 用户不存在，创建新用户
|
|
user := &entity.Users{
|
|
WxOpenId: in.OpenId,
|
|
Username: grand.Digits(10),
|
|
FirstVisitAt: gtime.Now(),
|
|
}
|
|
result, err := dao.Users.Ctx(ctx).Insert(user)
|
|
if err != nil {
|
|
return nil, ecode.Fail.Sub("创建用户失败")
|
|
}
|
|
userId, err = result.LastInsertId()
|
|
if err != nil {
|
|
return nil, ecode.Fail.Sub("获取用户ID失败")
|
|
}
|
|
} else {
|
|
// 用户存在，更新最后登录时间
|
|
var user entity.Users
|
|
if err := dao.Users.Ctx(ctx).Where(do.Users{WxOpenId: in.OpenId}).Scan(&user); err != nil {
|
|
return nil, ecode.Fail.Sub("查找用户失败")
|
|
}
|
|
userId = user.Id
|
|
if _, err := dao.Users.Ctx(ctx).Where(do.Users{Id: userId}).Update(do.Users{LastLoginAt: gtime.Now()}); err != nil {
|
|
return nil, ecode.Fail.Sub("更新登录时间失败")
|
|
}
|
|
}
|
|
|
|
// 生成 token
|
|
token, err := jwt.GenerateToken(&jwt.TokenIn{
|
|
UserId: userId,
|
|
Role: value.String(),
|
|
})
|
|
if err != nil {
|
|
return nil, ecode.Fail.Sub("生成token失败")
|
|
}
|
|
|
|
out = &model.UserLoginOut{
|
|
Token: token,
|
|
}
|
|
return
|
|
}
|
|
func (s *sUser) WeChatLogin(ctx context.Context, in *model.WeChatLogin) (out *model.WeChatLoginOut, err error) {
|
|
return
|
|
}
|
|
|
|
func (s *sUser) Info(ctx context.Context, in *model.UserInfoIn) (out *model.UserInfoOut, err error) {
|
|
exist, err := dao.Users.Ctx(ctx).Where(do.Users{WxOpenId: in.OpenId, Id: in.Id}).OmitEmptyWhere().Exist()
|
|
if err != nil {
|
|
return nil, ecode.Fail.Sub("查找用户失败")
|
|
}
|
|
if !exist {
|
|
return nil, ecode.Params.Sub("用户不存在")
|
|
}
|
|
var user entity.Users
|
|
if err := dao.Users.Ctx(ctx).Where(do.Users{WxOpenId: in.OpenId, Id: in.Id}).OmitEmptyWhere().Scan(&user); err != nil {
|
|
return nil, ecode.Fail.Sub("查找用户失败")
|
|
}
|
|
out = &model.UserInfoOut{
|
|
Id: user.Id,
|
|
}
|
|
return
|
|
}
|
|
|
|
func (s *sUser) Code(ctx context.Context, in *model.UserCodeIn) (out *model.UserCodeOut, err error) {
|
|
return
|
|
}
|
|
func (s *sUser) Update(ctx context.Context, in *model.UserUpdateIn) (out *model.UpdateOut, err error) {
|
|
return
|
|
}
|
|
|
|
func (s *sUser) BindPhone(ctx context.Context, in *model.UserBindPhoneIn) (out *model.UpdateOut, err error) {
|
|
// 绑定手机号，需要验证入参和缓存中的验证码时候相同
|
|
return
|
|
}
|
|
|
|
func (s *sUser) List(ctx context.Context, in *model.UserListIn) (out *model.UserListOut, err error) {
|
|
// 用于系统管理员、商户、门店查看用户列表， 展示用户最近的相关信息
|
|
return
|
|
}
|