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