feat 错误包装
This commit is contained in:
@@ -22,12 +22,12 @@ func (s *Server) PhoneLogin(ctx context.Context, req *grpc_pb.PhoneLoginReq) (*g
|
|||||||
if user, err = userDao.Create(&model.User{
|
if user, err = userDao.Create(&model.User{
|
||||||
Phone: req.Phone,
|
Phone: req.Phone,
|
||||||
}); err != nil {
|
}); err != nil {
|
||||||
return nil, err
|
return nil, utils.ErrorsWrap(err)
|
||||||
}
|
}
|
||||||
user.Name = fmt.Sprintf("user_%v", user.Sn)
|
user.Name = fmt.Sprintf("user_%v", user.Sn)
|
||||||
_ = userDao.Updates(user)
|
_ = userDao.Updates(user)
|
||||||
} else {
|
} else {
|
||||||
return nil, err
|
return nil, utils.ErrorsWrap(err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -40,7 +40,7 @@ func (s *Server) PhoneLogin(ctx context.Context, req *grpc_pb.PhoneLoginReq) (*g
|
|||||||
func (s *Server) WxMiniLogin(ctx context.Context, req *grpc_pb.WxMiniLoginReq) (*grpc_pb.WxMiniLoginResp, error) {
|
func (s *Server) WxMiniLogin(ctx context.Context, req *grpc_pb.WxMiniLoginReq) (*grpc_pb.WxMiniLoginResp, error) {
|
||||||
session, err := wechat.MiniCode2Session(req.Code)
|
session, err := wechat.MiniCode2Session(req.Code)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, utils.ErrorsWrap(err)
|
||||||
}
|
}
|
||||||
userDao := repository.NewUserDao(ctx, redis.GetCacheClient())
|
userDao := repository.NewUserDao(ctx, redis.GetCacheClient())
|
||||||
user, err := userDao.FindByWxUnionIDOrOpenID(session.UnionID, session.OpenID)
|
user, err := userDao.FindByWxUnionIDOrOpenID(session.UnionID, session.OpenID)
|
||||||
@@ -50,12 +50,12 @@ func (s *Server) WxMiniLogin(ctx context.Context, req *grpc_pb.WxMiniLoginReq) (
|
|||||||
WxUnionID: session.UnionID,
|
WxUnionID: session.UnionID,
|
||||||
WxMiniOpenID: session.OpenID,
|
WxMiniOpenID: session.OpenID,
|
||||||
}); err != nil {
|
}); err != nil {
|
||||||
return nil, err
|
return nil, utils.ErrorsWrap(err)
|
||||||
}
|
}
|
||||||
user.Name = fmt.Sprintf("user_%v", user.Sn)
|
user.Name = fmt.Sprintf("user_%v", user.Sn)
|
||||||
_ = userDao.Updates(user)
|
_ = userDao.Updates(user)
|
||||||
} else {
|
} else {
|
||||||
return nil, err
|
return nil, utils.ErrorsWrap(err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -67,12 +67,12 @@ func (s *Server) WxMiniLogin(ctx context.Context, req *grpc_pb.WxMiniLoginReq) (
|
|||||||
|
|
||||||
func (s *Server) GetUserInfo(ctx context.Context, req *grpc_pb.GetUserInfoReq) (*grpc_pb.GetUserInfoResp, error) {
|
func (s *Server) GetUserInfo(ctx context.Context, req *grpc_pb.GetUserInfoReq) (*grpc_pb.GetUserInfoResp, error) {
|
||||||
if !utils.ShouldBindUsn(ctx, &req.USN) {
|
if !utils.ShouldBindUsn(ctx, &req.USN) {
|
||||||
return nil, http_resp.ParamError
|
return nil, utils.ErrorsWrap(http_resp.ParamError)
|
||||||
}
|
}
|
||||||
userDao := repository.NewUserDao(ctx, redis.GetCacheClient())
|
userDao := repository.NewUserDao(ctx, redis.GetCacheClient())
|
||||||
user, err := userDao.FindBySn(req.USN)
|
user, err := userDao.FindBySn(req.USN)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, utils.ErrorsWrap(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
return &grpc_pb.GetUserInfoResp{
|
return &grpc_pb.GetUserInfoResp{
|
||||||
|
|||||||
@@ -16,6 +16,7 @@ func NewServer(ttl int64) *Server {
|
|||||||
s := &Server{
|
s := &Server{
|
||||||
Base: service.Base{
|
Base: service.Base{
|
||||||
Target: common.KeyDiscoverUser,
|
Target: common.KeyDiscoverUser,
|
||||||
|
ServiceName: common.KeyDiscoverServiceNameUser,
|
||||||
EtcdTTL: ttl,
|
EtcdTTL: ttl,
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user