|
|
|
@ -289,13 +289,11 @@ func (s *userServer) SetUserStatus(ctx context.Context, req *pbuser.SetUserStatu
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
log.ZDebug(ctx, "============SetUserStatus pre===========")
|
|
|
|
|
for _, value := range req.StatusList {
|
|
|
|
|
list, err := s.UserDatabase.GetSubscribedList(ctx, value.UserID)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return nil, err
|
|
|
|
|
}
|
|
|
|
|
log.ZDebug(ctx, "============UserStatusChangeNotification pre pre===========", "list", list)
|
|
|
|
|
for _, userID := range list {
|
|
|
|
|
tips := &sdkws.UserStatusChangeTips{
|
|
|
|
|
FromUserID: value.UserID,
|
|
|
|
@ -303,11 +301,9 @@ func (s *userServer) SetUserStatus(ctx context.Context, req *pbuser.SetUserStatu
|
|
|
|
|
Status: value.Status,
|
|
|
|
|
PlatformID: value.PlatformID,
|
|
|
|
|
}
|
|
|
|
|
log.ZDebug(ctx, "============UserStatusChangeNotification pre===========", "tips", tips)
|
|
|
|
|
s.userNotificationSender.UserStatusChangeNotification(ctx, tips)
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
log.ZDebug(ctx, "============UserStatusChangeNotification after===========")
|
|
|
|
|
return &pbuser.SetUserStatusResp{}, nil
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|