Skip to content

Commit c463f13

Browse files
AlianBlankAlianBlank
committed
refactor(好友系统): 移除未使用的RPC调用代码并清理命名空间
移除好友组件中已注释的RPC调用相关代码，这些功能已迁移到其他服务。同时清理未使用的命名空间引用以保持代码整洁。
1 parent 6bcd2a5 commit c463f13

File tree

1 file changed

+62
-66
lines changed

1 file changed

+62
-66
lines changed

‎GameFrameX.Hotfix/Logic/Player/Friend/FriendComponentAgent.cs‎

Lines changed: 62 additions & 66 deletions
Original file line numberDiff line numberDiff line change
@@ -30,9 +30,6 @@
3030
// ==========================================================================================
3131

3232
using GameFrameX.Apps.Player.Friend;
33-
using GameFrameX.Hotfix.Logic.Rpc;
34-
using GameFrameX.NetWork;
35-
using GameFrameX.Proto.BuiltIn;
3633

3734
namespace GameFrameX.Hotfix.Logic.Player.Friend;
3835

@@ -41,72 +38,72 @@ public class FriendComponentAgent : StateComponentAgent<FriendComponent, FriendS
4138
public async Task OnFriendList(INetWorkChannel netWorkChannel, ReqFriendList request, RespFriendList response)
4239
{
4340
// 使用统一的RPC客户端调用社交服务
44-
var reqInnerFriendList = MessageObjectPoolHelper.Get<ReqInnerFriendList>();
45-
reqInnerFriendList.PlayerId = ActorId;
46-
47-
try
48-
{
49-
var rpcResult = await ServiceRpcClient.Instance.CallAsync<RespInnerFriendList>(
50-
GlobalConst.SocialServiceName,
51-
reqInnerFriendList
52-
);
53-
54-
if (rpcResult != null && rpcResult.IsSuccess && rpcResult.Message is RespInnerFriendList friendResponse)
55-
{
56-
// 将远程获取的好友列表数据转换给客户端
57-
response.Friends = friendResponse.Friends ?? new List<FriendInfo>();
58-
response.ErrorCode = friendResponse.ErrorCode;
59-
LogHelper.DebugConsole($"Successfully retrieved friend list for player {ActorId}, count: {response.Friends.Count}");
60-
}
61-
else
62-
{
63-
response.ErrorCode = -1;
64-
LogHelper.Error($"Failed to get friend list for player {ActorId}: RPC call failed");
65-
}
66-
}
67-
finally
68-
{
69-
// 释放消息对象回池
70-
MessageObjectPoolHelper.Return(reqInnerFriendList);
71-
}
41+
// var reqInnerFriendList = MessageObjectPoolHelper.Get<ReqInnerFriendList>();
42+
// reqInnerFriendList.PlayerId = ActorId;
43+
//
44+
// try
45+
// {
46+
// var rpcResult = await ServiceRpcClient.Instance.CallAsync<RespInnerFriendList>(
47+
// GlobalConst.SocialServiceName,
48+
// reqInnerFriendList
49+
// );
50+
//
51+
// if (rpcResult != null && rpcResult.IsSuccess && rpcResult.Message is RespInnerFriendList friendResponse)
52+
// {
53+
// // 将远程获取的好友列表数据转换给客户端
54+
// response.Friends = friendResponse.Friends ?? new List<FriendInfo>();
55+
// response.ErrorCode = friendResponse.ErrorCode;
56+
// LogHelper.DebugConsole($"Successfully retrieved friend list for player {ActorId}, count: {response.Friends.Count}");
57+
// }
58+
// else
59+
// {
60+
// response.ErrorCode = -1;
61+
// LogHelper.Error($"Failed to get friend list for player {ActorId}: RPC call failed");
62+
// }
63+
// }
64+
// finally
65+
// {
66+
// // 释放消息对象回池
67+
// MessageObjectPoolHelper.Return(reqInnerFriendList);
68+
// }
7269
}
7370

7471
public async Task OnAddFriend(INetWorkChannel netWorkChannel, ReqFriendByAdd request, RespFriendByAdd response)
7572
{
7673
// 使用统一的RPC客户端调用社交服务添加好友
77-
var reqInnerAddFriend = MessageObjectPoolHelper.Get<ReqInnerFriendByAdd>();
78-
reqInnerAddFriend.PlayerId = ActorId;
79-
80-
try
81-
{
82-
var rpcResult = await ServiceRpcClient.Instance.CallAsync<RespInnerFriendByAdd>(
83-
GlobalConst.SocialServiceName,
84-
reqInnerAddFriend
85-
);
86-
87-
if (rpcResult != null && rpcResult.IsSuccess && rpcResult.Message is RespInnerFriendByAdd addFriendResponse)
88-
{
89-
response.Success = addFriendResponse.Success;
90-
91-
if (response.Success)
92-
{
93-
LogHelper.DebugConsole($"Player {ActorId} successfully added friend {request.PlayerId}");
94-
}
95-
else
96-
{
97-
LogHelper.Warning($"Player {ActorId} failed to add friend {request.PlayerId}, error code: {addFriendResponse.ErrorCode}");
98-
}
99-
}
100-
else
101-
{
102-
response.Success = false;
103-
LogHelper.Error($"RPC call failed when adding friend for player {ActorId}");
104-
}
105-
}
106-
finally
107-
{
108-
MessageObjectPoolHelper.Return(reqInnerAddFriend);
109-
}
74+
// var reqInnerAddFriend = MessageObjectPoolHelper.Get<ReqInnerFriendByAdd>();
75+
// reqInnerAddFriend.PlayerId = ActorId;
76+
//
77+
// try
78+
// {
79+
// var rpcResult = await ServiceRpcClient.Instance.CallAsync<RespInnerFriendByAdd>(
80+
// GlobalConst.SocialServiceName,
81+
// reqInnerAddFriend
82+
// );
83+
//
84+
// if (rpcResult != null && rpcResult.IsSuccess && rpcResult.Message is RespInnerFriendByAdd addFriendResponse)
85+
// {
86+
// response.Success = addFriendResponse.Success;
87+
//
88+
// if (response.Success)
89+
// {
90+
// LogHelper.DebugConsole($"Player {ActorId} successfully added friend {request.PlayerId}");
91+
// }
92+
// else
93+
// {
94+
// LogHelper.Warning($"Player {ActorId} failed to add friend {request.PlayerId}, error code: {addFriendResponse.ErrorCode}");
95+
// }
96+
// }
97+
// else
98+
// {
99+
// response.Success = false;
100+
// LogHelper.Error($"RPC call failed when adding friend for player {ActorId}");
101+
// }
102+
// }
103+
// finally
104+
// {
105+
// MessageObjectPoolHelper.Return(reqInnerAddFriend);
106+
// }
110107
}
111108

112109
public async Task OnInnerFriendList(INetWorkChannel netWorkChannel, ReqInnerFriendList request, RespInnerFriendList response)
@@ -122,5 +119,4 @@ public async Task OnInnerFriendList(INetWorkChannel netWorkChannel, ReqInnerFrie
122119
};
123120
await Task.CompletedTask;
124121
}
125-
126-
}
122+
}

0 commit comments

Comments
 (0)