删除登录、登出接口

pull/3727/head
hawklin2017 3 weeks ago
parent bd42186c1b
commit b34d7262e3

@ -179,10 +179,6 @@ func newGinRouter(ctx context.Context, client discovery.SvcDiscoveryRegistry, co
userRouterGroup.POST("/get_user_by_phone", u.GetUserByPhone)
// 根据昵称精确查询用户(可多结果,与 getPaginationUsers 模糊搜索不同)
userRouterGroup.POST("/get_users_by_nickname", u.GetUsersByNickname)
// 记录用户登录时间,返回登录时间戳及上次登录信息
userRouterGroup.POST("/login", u.UserLogin)
// 记录用户登出时间,返回登出时间戳(毫秒)
userRouterGroup.POST("/logout", u.UserLogout)
// 全局黑名单管理(仅管理员)
userRouterGroup.POST("/add_global_blacklist", bl.AddGlobalBlacklist)

@ -370,13 +370,3 @@ func (u *UserApi) GetUserByPhone(c *gin.Context) {
func (u *UserApi) GetUsersByNickname(c *gin.Context) {
a2r.Call(c, user.UserClient.GetUsersByNickname, u.Client)
}
// UserLogin 记录当前用户的登录时间。
func (u *UserApi) UserLogin(c *gin.Context) {
a2r.Call(c, user.UserClient.UserLogin, u.Client)
}
// UserLogout 记录当前用户的登出时间。
func (u *UserApi) UserLogout(c *gin.Context) {
a2r.Call(c, user.UserClient.UserLogout, u.Client)
}

@ -1064,45 +1064,3 @@ func (s *userServer) SortQuery(ctx context.Context, req *pbuser.SortQueryReq) (*
}
return &pbuser.SortQueryResp{Users: convert.UsersDB2Pb(users)}, nil
}
// UserLogin 记录当前用户的登录时间userID 取自上下文 opUserID
func (s *userServer) UserLogin(ctx context.Context, _ *pbuser.UserLoginReq) (*pbuser.UserLoginResp, error) {
userID := mcontext.GetOpUserID(ctx)
if userID == "" {
return nil, errs.ErrArgs.WrapMsg("opUserID is required")
}
if _, err := s.db.FindWithError(ctx, []string{userID}); err != nil {
log.ZError(ctx, "UserLogin: user not found", err, "userID", userID)
return nil, err
}
now := time.Now()
if err := s.db.UpdateByMap(ctx, userID, map[string]any{
"cur_login_time": now,
}); err != nil {
log.ZError(ctx, "UserLogin: UpdateByMap failed", err, "userID", userID)
return nil, err
}
log.ZDebug(ctx, "UserLogin: recorded login time", "userID", userID, "loginTime", now)
return &pbuser.UserLoginResp{}, nil
}
// UserLogout 记录当前登录用户的登出时间userID 取自上下文 opUserID
func (s *userServer) UserLogout(ctx context.Context, _ *pbuser.UserLogoutReq) (*pbuser.UserLogoutResp, error) {
userID := mcontext.GetOpUserID(ctx)
if userID == "" {
return nil, errs.ErrArgs.WrapMsg("opUserID is required")
}
if _, err := s.db.FindWithError(ctx, []string{userID}); err != nil {
log.ZError(ctx, "UserLogout: user not found", err, "userID", userID)
return nil, err
}
now := time.Now()
if err := s.db.UpdateByMap(ctx, userID, map[string]any{
"last_logout_time": now,
}); err != nil {
log.ZError(ctx, "UserLogout: UpdateByMap failed", err, "userID", userID)
return nil, err
}
log.ZDebug(ctx, "UserLogout: recorded logout time", "userID", userID, "logoutTime", now)
return &pbuser.UserLogoutResp{}, nil
}

@ -81,10 +81,6 @@ type User struct {
Status int32 `bson:"status"`
// MsgBurnDuration 用户全局消息阅后即焚时长0 表示关闭
MsgBurnDuration int32 `bson:"msg_burn_duration"`
// CurLoginTime 当前最近一次登录时间nil 表示从未登录
CurLoginTime *time.Time `bson:"cur_login_time"`
// LastLogoutTime 最近一次登出时间nil 表示从未登出
LastLogoutTime *time.Time `bson:"last_logout_time"`
}
func (u *User) GetNickname() string {

@ -1 +1 @@
Subproject commit 4741c40fbd3d369bdf0f9f34c00791ec6483425b
Subproject commit f7bfce630638a3dc3fd776842d1c3e8078559269
Loading…
Cancel
Save