|
@@ -177,19 +177,19 @@ func (*friendService) AgreeAddFriend(ctx context.Context, userId, friendId int64 |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
resp, err := rpc.GetBusinessIntClient().GetUser(ctx, &pb.GetUserReq{UserId: friendId}) |
|
|
|
|
|
|
|
|
resp, err := rpc.GetBusinessIntClient().GetUser(ctx, &pb.GetUserReq{UserId: userId}) |
|
|
if err != nil { |
|
|
if err != nil { |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
err = proxy.MessageProxy.PushToUser(ctx, friendId, pb.PushCode_PC_AGREE_ADD_FRIEND, &pb.AgreeAddFriendPush{ |
|
|
err = proxy.MessageProxy.PushToUser(ctx, friendId, pb.PushCode_PC_AGREE_ADD_FRIEND, &pb.AgreeAddFriendPush{ |
|
|
FriendId: friendId, |
|
|
|
|
|
|
|
|
FriendId: userId, |
|
|
Nickname: resp.User.Nickname, |
|
|
Nickname: resp.User.Nickname, |
|
|
AvatarUrl: resp.User.AvatarUrl, |
|
|
AvatarUrl: resp.User.AvatarUrl, |
|
|
}, true) |
|
|
}, true) |
|
|
|
|
|
|
|
|
utils.FilePutContents("push_AgreeAddFriend", utils.SerializeStr(map[string]interface{}{ |
|
|
utils.FilePutContents("push_AgreeAddFriend", utils.SerializeStr(map[string]interface{}{ |
|
|
"friend_id": friendId, |
|
|
|
|
|
|
|
|
"friend_id": userId, |
|
|
"friend_nick_name": resp.User.Nickname, |
|
|
"friend_nick_name": resp.User.Nickname, |
|
|
"friend_avatar_url": resp.User.AvatarUrl, |
|
|
"friend_avatar_url": resp.User.AvatarUrl, |
|
|
"err": err, |
|
|
"err": err, |
|
|