Blame view

src/actions/FriendAction.lua 19.8 KB
c384626d   zhouhaihai   好友
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
  local ipairs = ipairs
  local table = table
  local math = math
  local string = string
  local redisproxy = redisproxy
  local MsgPack = MsgPack
  local string_format = string.format
  local tonumber = tonumber
  local table_insert = table.insert
  local table_unpack = table.unpack
  local table_find = table.find
  local table_nums = table.nums
  local math_random = math.randomInt
  
  local _M = {}
  
  local function formatArray(tb)
  	tb = tb or {}
  	local t = {}
  	for _, objectId in ipairs(tb) do
  		t[tonumber(objectId)] = 1
  	end
  	return t
  end
  
  local function checkFriendLimit(roleId)
  	roleId = tonumber(roleId)
  	local count = redisproxy:hlen(FRIEND_KEY:format(roleId))
  	return count < globalCsv.friendListLimit
  end
  
  
  local function addAndCheckApplyLimit(roleId, objId)
  	roleId = tonumber(roleId)
  	local dbKey = FRIEND_APPLY_KEY:format(roleId)
  	local redret = redisproxy:pipelining(function (red)
  		red:zadd(dbKey, skynet.timex(), objId)
  		red:zremrangebyrank(dbKey, 0, -(globalCsv.friendApplyLimit + 1))
  	end)
  end
  
  local function checkBlackLimit(roleId)
  	roleId = tonumber(roleId)
  	local count = redisproxy:scard(FRIEND_BLACK_KEY:format(roleId))
  	return count < globalCsv.friendListLimit
  end
  
  local function getRoleInfo(roleId)
  	local online, info = rpcRole(roleId, "friendSInfo")
  	return online, info
  end
  
  local function getRoleAllInfo(roleId)
  	local online, info = rpcRole(roleId, "friendInfo")
  	return online, info
  end
  
  local function table_merge(tab1, tab2, filter)
  	tab1 = tab1 or {}
  	tab2 = tab2 or {}
  	filter = filter or {}
  	for k_, v_ in pairs(tab2) do
  		if not filter[k_] then
  			tab1[k_] = v_
  		end
  	end
  	return tab1
  end
  
  function _M.searchRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  	local msg = MsgPack.unpack(data)
  	local key = msg.key
  
  	if not key then return end
  
  	local objIds = {}
  	local tempId = tonumber(key)
  	if tempId then
  		if redisproxy:exists(string_format("role:%d", tempId)) then
  			objIds[tempId] = 1
  		end
  	end
  	local tempId = redisproxy:get(string_format("user:%s", string.upper(key)))
  	if tempId then
  		objIds[tonumber(tempId)] = 1
  	end
  	objIds[roleId] = nil --不能有自己
  
  	local searchList = {}
  	for objId, _ in pairs(objIds) do
  		local online, info = getRoleInfo(objId)
  		local redret = redisproxy:pipelining(function (red)
  			red:hexists(FRIEND_KEY:format(roleId), objId)
  			red:zscore(FRIEND_APPLY_KEY:format(objId), roleId)
  			red:sismember(FRIEND_BLACK_KEY:format(roleId), objId)
  		end)
  		local isFriend = redret[1] == 1 and 1 or nil
  		local hadApply = redret[2] and 1 or nil
  		local inBlack = redret[3] == 1 and 1 or nil
  
  		table.insert(searchList, table_merge({
  			roleId = objId, 
  			online = online, 
  			isFriend = isFriend, 
  			hadApply = hadApply,
  			inBlack = inBlack,
  		}, info, {
  
  		}))
  	end
3133cb76   zhouhaihai   日志
113
  
f22a33af   zhouhaihai   自己的日志
114
  	role:mylog("role_action", {desc = "searchFriend"})
c384626d   zhouhaihai   好友
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
  	SendPacket(actionCodes.Friend_searchRpc, MsgPack.pack({searchList = searchList}))
  	return true
  end
  
  
  function _M.applyRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  
  	local msg = MsgPack.unpack(data)
  	local objectId = msg.roleId
  
  	if objectId == roleId then
  		return
  	end
  
  	local result = nil
  	local redret = redisproxy:pipelining(function (red)
  		red:exists(string_format("role:%d", objectId))
  		red:hexists(FRIEND_KEY:format(roleId), objectId)
  		red:zscore(FRIEND_APPLY_KEY:format(objectId), roleId)
  		red:sismember(FRIEND_BLACK_KEY:format(objectId), roleId)
  		red:sismember(FRIEND_BLACK_KEY:format(roleId), objectId)
  		red:hlen(FRIEND_KEY:format(roleId))
  		red:hlen(FRIEND_KEY:format(objectId))
  	end)
5dfc4978   zhouhaihai   好友完善
141
  
c384626d   zhouhaihai   好友
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
  	-- 玩家id不存在
  	if not result and redret[1] ~= 1 then
  		result = 1	
  	end
  
  	-- 已经有这个好友
  	if not result and redret[2] == 1 then
  		result = 2
  	end
  	-- 已经申请
  	if not result and redret[3] then
  		result = 3
  	end
  	-- 对方把你拉黑
  	if not result and redret[4] == 1 then
  		result = 4
  	end
  
  	-- 你把对方拉黑了
5dfc4978   zhouhaihai   好友完善
161
  	if not result and redret[5] == 1 then
c384626d   zhouhaihai   好友
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
  		result = 5
  	end
  
  	-- 自己好友已经满
  	if not result and redret[6] >= globalCsv.friendListLimit then
  		result = 6
  	end
  	-- 对方的好友已满
  	if not result and redret[7] >= globalCsv.friendListLimit then
  		result = 7
  	end
  
  	if not result then
  		addAndCheckApplyLimit(objectId, roleId)
  		local myInfo = role:friendSInfo()
  		myInfo.roleId = roleId
  		myInfo.online = true
  		myInfo.hadApply = true
3133cb76   zhouhaihai   日志
180
  
f22a33af   zhouhaihai   自己的日志
181
182
  		role:mylog("role_action", {desc = "addFriend", int1 = 1})
  
c384626d   zhouhaihai   好友
183
184
  		rpcRole(objectId, "SendPacket", actionCodes.Friend_updateProperty, MsgPack.pack({newApply = 1, info = {myInfo}})) 	-- 通知对方
  	end
3133cb76   zhouhaihai   日志
185
186
187
  
  	
  
c384626d   zhouhaihai   好友
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
  	SendPacket(actionCodes.Friend_applyRpc, MsgPack.pack({result = result}))
  	return true
  end
  
  function _M.applyListRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  
  	local applyList = {}
  
  	local friends = redisproxy:zrange(FRIEND_APPLY_KEY:format(roleId), 0, -1)
  	for _ , id in pairs(friends) do
  		id = tonumber(id)
  		local online, info = getRoleInfo(id)
  		table.insert(applyList, table_merge({
  			roleId = id, online = online
  		}, info, {
  
  		}))
  	end
  	SendPacket(actionCodes.Friend_applyListRpc, MsgPack.pack({list = applyList}))
  	return true
  end
  
763d6396   zhouhaihai   批量增加好友bug
212
213
  local function checkHandleApply(roleId, objectId, needAddNew) 
  	needAddNew = needAddNew or 0
c384626d   zhouhaihai   好友
214
215
216
217
218
219
  	local redret = redisproxy:pipelining(function (red)
  		red:hlen(FRIEND_KEY:format(roleId))
  		red:hlen(FRIEND_KEY:format(objectId))
  		red:sismember(FRIEND_BLACK_KEY:format(objectId), roleId)
  		red:sismember(FRIEND_BLACK_KEY:format(roleId), objectId)
  	end)
c59e058b   zhouhaihai   新一批日志记录
220
  
c384626d   zhouhaihai   好友
221
  	--自己好友满了
763d6396   zhouhaihai   批量增加好友bug
222
223
  	if (redret[1] + needAddNew) >= globalCsv.friendListLimit then
  		return 1
c384626d   zhouhaihai   好友
224
225
  	end
  	-- 对方好友满了
763d6396   zhouhaihai   批量增加好友bug
226
227
  	if redret[2] >= globalCsv.friendListLimit then
  		return 2
c384626d   zhouhaihai   好友
228
229
  	end
  	-- 对方把你拉黑
763d6396   zhouhaihai   批量增加好友bug
230
231
  	if redret[3] == 1 then
  		return 3
c384626d   zhouhaihai   好友
232
233
  	end
  	-- 你把对方拉黑了
763d6396   zhouhaihai   批量增加好友bug
234
235
  	if redret[4] == 1 then
  		return 4
c384626d   zhouhaihai   好友
236
  	end
c59e058b   zhouhaihai   新一批日志记录
237
238
  
  	return nil, redret[1]
c384626d   zhouhaihai   好友
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
  end
  
  function _M.handleApplyRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  
  	local msg = MsgPack.unpack(data)
  	local cmd = msg.cmd
  
  	local newTag = MsgPack.pack({ skynet.timex(), 1})
  	local result = nil
  	if cmd == 1 then	--同意
  
  		local objectId = msg.roleId
  
  		if not redisproxy:zscore(FRIEND_APPLY_KEY:format(roleId), objectId) then
  			return
  		end
c59e058b   zhouhaihai   新一批日志记录
257
258
  		local curCount
  		result, curCount = checkHandleApply(roleId, objectId)
c384626d   zhouhaihai   好友
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
  
  		if not result then
  			redisproxy:pipelining(function (red)
  				red:ZREM(FRIEND_APPLY_KEY:format(roleId), objectId)
  				red:ZREM(FRIEND_APPLY_KEY:format(objectId), roleId)
  				red:hsetnx(FRIEND_KEY:format(roleId), objectId, newTag)
  				red:hsetnx(FRIEND_KEY:format(objectId), roleId, newTag)--告知对放有新好友
  			end)
  			local myInfo = role:friendSInfo()
  			myInfo.online = true
  			myInfo.roleId = roleId
  			myInfo.isFriend = 1
  			local redret = redisproxy:pipelining(function (red)
  				red:sismember(FRIEND_POINT:format(objectId), roleId)
  				red:sismember(FRIEND_POINT:format(roleId), objectId)
  			end)
  			myInfo.pGet = redret[1] == 1 and 1 or nil
  			rpcRole(objectId, "SendPacket", actionCodes.Friend_updateProperty, MsgPack.pack({newFriend = 1, info = {myInfo}}))	-- 通知对方
  			local online , otherInfo = getRoleInfo(objectId)
  			otherInfo.roleId = objectId
  			otherInfo.online = online
  			otherInfo.isFriend = true
  			otherInfo.pGet = redret[2] == 1 and 1 or nil
  			SendPacket(actionCodes.Friend_updateProperty, MsgPack.pack({newFriend = 1, info = {otherInfo}}))
3133cb76   zhouhaihai   日志
283
  
c59e058b   zhouhaihai   新一批日志记录
284
285
286
287
288
  			role:log("friend_opt", {
  				friend_opt_type = 100, -- 好友操作类型,见枚举表中 好友操作类型枚举表
  				friend_roleid = objectId, -- 好友账户下的角色id
  				friend_cnt = curCount + 1, -- 操作后好友数量
  			})
f22a33af   zhouhaihai   自己的日志
289
290
  			role:mylog("role_action", {desc = "addFriend", int1 = 1})
  
c384626d   zhouhaihai   好友
291
292
293
294
295
296
297
298
299
300
301
302
  		end
  
  	elseif cmd == 0 then	-- 不同意
  		local objectId = msg.roleId
  		if not redisproxy:zscore(FRIEND_APPLY_KEY:format(roleId), objectId) then
  			return
  		end
  		redisproxy:ZREM(FRIEND_APPLY_KEY:format(roleId), objectId)
  	elseif cmd == 2 then    -- 一键拒绝
  		redisproxy:del(FRIEND_APPLY_KEY:format(roleId))
  	elseif cmd == 3 then    -- 一键同意
  		local redret = redisproxy:pipelining(function(red)
5dfc4978   zhouhaihai   好友完善
303
  			red:zrange(FRIEND_APPLY_KEY:format(roleId), 0, -1)
c384626d   zhouhaihai   好友
304
305
306
307
308
309
310
311
312
  			red:SMEMBERS(FRIEND_POINT:format(roleId))
  		end)
  		local allIds = redret[1]
  		local fpoint = formatArray(redret[2])
  		local needAdd = {}
  		local needAddMy = {}
  		local needAddInfo = {}
  		for _, objId in ipairs(allIds) do
  			objId = tonumber(objId)
c59e058b   zhouhaihai   新一批日志记录
313
  			local cr, curCount = checkHandleApply(roleId, objId, #needAdd)
c384626d   zhouhaihai   好友
314
315
316
317
318
319
320
321
322
323
  			if not cr then 
  				table.insert(needAdd, objId)
  				table.insert(needAddMy, objId)
  				table.insert(needAddMy, newTag)
  				local online, otherInfo = getRoleInfo(objId)
  				otherInfo.online = true
  				otherInfo.roleId = objId
  				otherInfo.isFriend = true
  				otherInfo.pGet = fpoint[objId] and 1 or nil
  				table.insert(needAddInfo, otherInfo)
c59e058b   zhouhaihai   新一批日志记录
324
325
326
327
328
329
  
  				role:log("friend_opt", {
  					friend_opt_type = 100, -- 好友操作类型,见枚举表中 好友操作类型枚举表
  					friend_roleid = objId, -- 好友账户下的角色id
  					friend_cnt = curCount + 1, -- 操作后好友数量
  				})
c384626d   zhouhaihai   好友
330
331
332
333
  			end
  		end
  
  		redisproxy:pipelining(function (red)
92d7d6ac   zhouhaihai   加一些数据保护
334
335
336
337
338
339
340
341
342
  			if next(needAdd) then
  				red:ZREM(FRIEND_APPLY_KEY:format(roleId), table_unpack(needAdd))
  				for _, objectId in pairs(needAdd) do
  					red:ZREM(FRIEND_APPLY_KEY:format(objectId), roleId)
  					red:hsetnx(FRIEND_KEY:format(objectId), roleId, newTag)--告知对放有新好友
  				end
  			end
  			if next(needAddMy) then
  				red:HMSET(FRIEND_KEY:format(roleId), table_unpack(needAddMy))
c384626d   zhouhaihai   好友
343
344
345
346
347
348
349
350
351
352
353
354
  			end
  		end)
  		local myInfo = role:friendSInfo()
  		myInfo.roleId = roleId
  		myInfo.online = true
  		myInfo.isFriend = 1
  		local giveFP = role.dailyData:getProperty("giveFP")
  		for _, objectId in pairs(needAdd) do
  			myInfo.pGet = giveFP[objectId]
  			rpcRole(objectId, "SendPacket", actionCodes.Friend_updateProperty, MsgPack.pack({newFriend = 1, info = {myInfo}}))	-- 通知对方
  		end
  		if next(needAdd) then
f22a33af   zhouhaihai   自己的日志
355
356
  			role:mylog("role_action", {desc = "addFriend", int1 = #needAdd})
  
c384626d   zhouhaihai   好友
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
  			SendPacket(actionCodes.Friend_updateProperty, MsgPack.pack({newFriend = 1, info = needAddInfo}))
  		else
  			result = 1
  		end
  		
  	else 	--不存在
  		return
  	end
  
  	SendPacket(actionCodes.Friend_handleApplyRpc, MsgPack.pack({result = result}))
  	return true
  end
  
  function _M.listRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  
  	local friendList = {}
  	local redret = redisproxy:pipelining(function (red)
  		red:hgetall(FRIEND_KEY:format(roleId))
  		red:SMEMBERS(FRIEND_POINT:format(roleId))
  	end)
  
  	local friends = redret[1]
  	local fpoint = formatArray(redret[2])
  	local hadGet = role.dailyData:getProperty("getFP")
  	local hadGive = role.dailyData:getProperty("giveFP")
  
  	local clearRed = {}
  	for i = 1, #friends, 2 do
  		local id = friends[i]
  		local data = friends[i + 1]
  		local friendInfo = MsgPack.unpack(data)
  		id = tonumber(id)
  		local online, info = getRoleInfo(id)
  		local roleInfo = {
  			roleId = id, 
  			online = online, 
  			addTime = friendInfo[1], 
  			isNew = friendInfo[2],
  			pGive = hadGive[id],
  			pGet = hadGet[id] and -1 or (fpoint[id] and 1 or nil)
  		}
  		roleInfo = table_merge(roleInfo, info, {})
  
  		friendList[#friendList + 1] = roleInfo
  
  		if friendInfo[2] then
  			friendInfo[2] = nil	--清除新好友标记
  			clearRed[#clearRed + 1] = id
  			clearRed[#clearRed + 1] = MsgPack.pack(friendInfo)
  		end
  	end
  	if next(clearRed) then
  		redisproxy:hmset(FRIEND_KEY:format(roleId), table_unpack(clearRed))	--清除新好友标记
3dbbc9f3   zhouhaihai   加上新的任务
412
  		role:checkTaskEnter("AddFriend", {count = #friendList})
c384626d   zhouhaihai   好友
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
  	end
  
  	SendPacket(actionCodes.Friend_listRpc, MsgPack.pack({list = friendList}))
  	return true
  end
  
  function _M.deleteRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  	local msg = MsgPack.unpack(data)
  	local objectId = msg.roleId
  	if not redisproxy:exists(string_format("role:%d", objectId)) then
  		return
  	end
  	-- 是否在好友列表中
  	if redisproxy:hexists(FRIEND_KEY:format(roleId), objectId) then
  		redisproxy:pipelining(function (red)
  			red:hdel(FRIEND_KEY:format(roleId), objectId)
  			red:hdel(FRIEND_KEY:format(objectId), roleId)
  			red:ZREM(FRIEND_APPLY_KEY:format(roleId), objectId)
  			red:ZREM(FRIEND_APPLY_KEY:format(objectId), roleId)
  		end)
  	end
  	rpcRole(objectId, "SendPacket", actionCodes.Friend_updateProperty, MsgPack.pack({deleteFriend = 1, roleId = roleId}))
  
c59e058b   zhouhaihai   新一批日志记录
438
439
440
441
442
  	role:log("friend_opt", {
  		friend_opt_type = 200, -- 好友操作类型,见枚举表中 好友操作类型枚举表
  		friend_roleid = objectId, -- 好友账户下的角色id
  		friend_cnt = 0, -- 操作后好友数量
  	})
c384626d   zhouhaihai   好友
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
  	SendPacket(actionCodes.Friend_deleteRpc, MsgPack.pack(""))
  	return true
  end
  
  function _M.blockRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  	local msg = MsgPack.unpack(data)
  	local cmd = msg.cmd
  	local objectId = msg.roleId
  	if not redisproxy:exists(string_format("role:%d", objectId)) then
  		return
  	end
  
  	local result = nil
  	if cmd == 1 then
  		-- 黑名单满了
  		if not result and not checkBlackLimit(roleId) then 
  			result = 1
  		end
  		-- 删除好友
  		if not result then
  			redisproxy:pipelining(function (red)
  				red:hdel(FRIEND_KEY:format(roleId), objectId)
  				red:hdel(FRIEND_KEY:format(objectId), roleId)
85083dba   zhouhaihai   拉黑从申请列表移除
468
469
  				red:ZREM(FRIEND_APPLY_KEY:format(roleId), objectId)
  				red:ZREM(FRIEND_APPLY_KEY:format(objectId), roleId)
c384626d   zhouhaihai   好友
470
471
  				red:sadd(FRIEND_BLACK_KEY:format(roleId), objectId)
  			end)
c59e058b   zhouhaihai   新一批日志记录
472
473
474
475
476
477
  			rpcRole(objectId, "SendPacket", actionCodes.Friend_updateProperty, MsgPack.pack({deleteFriend = 1, roleId = roleId}))
  			role:log("friend_opt", {
  				friend_opt_type = 300, -- 好友操作类型,见枚举表中 好友操作类型枚举表
  				friend_roleid = objectId, -- 好友账户下的角色id
  				friend_cnt = 0, -- 操作后好友数量
  			})
c384626d   zhouhaihai   好友
478
479
480
481
482
483
  		end
  	elseif cmd == 2 then
  		redisproxy:SREM(FRIEND_BLACK_KEY:format(roleId), objectId)
  	else
  		return
  	end
c384626d   zhouhaihai   好友
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
  	SendPacket(actionCodes.Friend_blockRpc, MsgPack.pack({result = result}))
  	return true
  end
  
  function _M.blockListRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  
  	local blockList = {}
  
  	local friends = redisproxy:SMEMBERS(FRIEND_BLACK_KEY:format(roleId))
  	for _ , id in pairs(friends) do
  		id = tonumber(id)
  		local online, info = getRoleInfo(id)
  		table.insert(blockList, table_merge({
  			roleId = id, online = online
  		}, info, {
  
  		}))
  	end
5dfc4978   zhouhaihai   好友完善
504
  
c384626d   zhouhaihai   好友
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
  	SendPacket(actionCodes.Friend_blockListRpc, MsgPack.pack({list = blockList}))
  	return true
  end
  
  function _M.infoRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  	local msg = MsgPack.unpack(data)
  	local objectId = msg.roleId
  	if not redisproxy:exists(string_format("role:%d", objectId)) then
  		return
  	end
  
  	local online, info = getRoleAllInfo(objectId)
  	local redret = redisproxy:pipelining(function (red)
  		red:hexists(FRIEND_KEY:format(roleId), objectId)
  		red:zscore(FRIEND_APPLY_KEY:format(objectId), roleId)
  		red:sismember(FRIEND_BLACK_KEY:format(roleId), objectId)
  	end)
  	local isFriend = redret[1] == 1 and 1 or nil
  	local hadApply = redret[2] == 1 and 1 or nil
  	local inBlack = redret[3] == 1 and 1 or nil
  
  	local objInfo = table_merge({
  		roleId = objectId, 
  		online = online, 
  		isFriend = isFriend, 
  		hadApply = hadApply,
  		inBlack = inBlack,
  	}, info, {
  
  	})
  	SendPacket(actionCodes.Friend_infoRpc, MsgPack.pack({info = objInfo}))
  	return true
  end
  
  function _M.pointRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  	local msg = MsgPack.unpack(data)
  	local cmd = msg.cmd
  	local result = nil
  	local reward = {}
  	if cmd == 1 then  -- 赠送
  		local objId = msg.roleId
  		local giveP = role.dailyData:getProperty("giveFP")
  		if not result and giveP[objId] then 
  			result = 1
  		end
  		if not result and not redisproxy:hexists(FRIEND_KEY:format(roleId), objId) then
  			result = 2
  		end
  		if not result then
  			redisproxy:sadd(FRIEND_POINT:format(objId), roleId)
  			giveP[objId] = 1
  			role.dailyData:updateProperty({field = "giveFP", value = giveP})
3dbbc9f3   zhouhaihai   加上新的任务
561
  			role:checkTaskEnter("GiveFriendP", {count = 1})
c384626d   zhouhaihai   好友
562
  			rpcRole(objId, "SendPacket", actionCodes.Friend_updateProperty, MsgPack.pack({newPoint = 1, roleId = roleId}))
f22a33af   zhouhaihai   自己的日志
563
564
  
  			role:mylog("role_action", {desc = "giveFPoint", int1 = 1})
c384626d   zhouhaihai   好友
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
  		end
  	elseif cmd == 2 then -- 领取
  		local objId = msg.roleId
  		local getP = role.dailyData:getProperty("getFP")
  		if not result and table.numbers(getP) >= globalCsv.friendPointLimit then
  			result = 1
  		end
  		if not result and getP[objId] then
  			result = 2
  		end
  		if not redisproxy:sismember(FRIEND_POINT:format(roleId), objId) then
  			result = 3
  		end
  		if not result then
  			getP[objId] = 1
3133cb76   zhouhaihai   日志
580
  			reward = role:award({[ItemId.FriendPoint] = 1}, {log = {desc = "friendPoint"}})
c384626d   zhouhaihai   好友
581
  			role.dailyData:updateProperty({field = "getFP", value = getP})
3dbbc9f3   zhouhaihai   加上新的任务
582
  			role:checkTaskEnter("GetFriendP", {count = 1})
3133cb76   zhouhaihai   日志
583
  
f22a33af   zhouhaihai   自己的日志
584
  			role:mylog("role_action", {desc = "getFPoint", int1 = 1})
c384626d   zhouhaihai   好友
585
586
587
588
589
  		end
  	elseif cmd == 3 then -- 一键赠送领取
  		-- 赠送
  		local giveP = role.dailyData:getProperty("giveFP")
  		local friends = redisproxy:hgetall(FRIEND_KEY:format(roleId))
3dbbc9f3   zhouhaihai   加上新的任务
590
  		local change = 0
c384626d   zhouhaihai   好友
591
592
593
594
595
  		redisproxy:pipelining(function(red)
  			for i = 1, #friends , 2 do
  				local objId = tonumber(friends[i])
  				if not giveP[objId] then
  					giveP[objId] = 1
3dbbc9f3   zhouhaihai   加上新的任务
596
  					change = change + 1
c384626d   zhouhaihai   好友
597
598
599
600
601
  					red:sadd(FRIEND_POINT:format(objId), roleId)
  					rpcRole(objId, "SendPacket", actionCodes.Friend_updateProperty, MsgPack.pack({newPoint = 1, roleId = roleId}))
  				end
  			end
  		end)
3dbbc9f3   zhouhaihai   加上新的任务
602
  		if change > 0 then
c384626d   zhouhaihai   好友
603
  			role.dailyData:updateProperty({field = "giveFP", value = giveP})
3dbbc9f3   zhouhaihai   加上新的任务
604
  			role:checkTaskEnter("GiveFriendP", {count = change})
3133cb76   zhouhaihai   日志
605
  
f22a33af   zhouhaihai   自己的日志
606
607
  			role:mylog("role_action", {desc = "giveFPoint", int1 = change})
  
c384626d   zhouhaihai   好友
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
  		else
  			result = 1
  		end
  		
  		--领取
  		local getP = role.dailyData:getProperty("getFP")
  		local curCount = table.numbers(getP)
  		local getCount = 0
  		if curCount < globalCsv.friendPointLimit then
  			for _, objId in pairs(redisproxy:SMEMBERS(FRIEND_POINT:format(roleId))) do
  				local objId = tonumber(objId)
  				if not getP[objId] then
  					getCount = getCount + 1
  					curCount = curCount + 1
  					getP[objId] = 1
  					if curCount >= globalCsv.friendPointLimit then
  						break
  					end
  				end
  			end
  			if getCount > 0 then
3133cb76   zhouhaihai   日志
629
  				reward = role:award({[ItemId.FriendPoint] = getCount}, {log = {desc = "friendPoint"}})
c384626d   zhouhaihai   好友
630
  				role.dailyData:updateProperty({field = "getFP", value = getP})
3dbbc9f3   zhouhaihai   加上新的任务
631
  				role:checkTaskEnter("GetFriendP", {count = getCount})
f22a33af   zhouhaihai   自己的日志
632
  				role:mylog("role_action", {desc = "getFPoint", int1 = getCount})
c384626d   zhouhaihai   好友
633
  			else
8474ca36   zhouhaihai   聊天
634
  				result = (result or 0) + 2
c384626d   zhouhaihai   好友
635
636
637
638
639
640
641
642
643
644
645
646
647
648
  			end
  		end
  	else
  		return
  	end
  	SendPacket(actionCodes.Friend_pointRpc, MsgPack.pack({result = result, reward = reward}))
  	return true
  end
  function _M.randomRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  
  	local redret = redisproxy:pipelining(function (red)
  		red:hgetall(FRIEND_KEY:format(roleId))
5dfc4978   zhouhaihai   好友完善
649
650
  		red:zrevrange(FRIEND_RECOMMEND, 0, globalCsv.friendRecommendLimit + globalCsv.friendListLimit + 10) --扩充10个
  		red:SMEMBERS(FRIEND_BLACK_KEY:format(roleId))
c384626d   zhouhaihai   好友
651
  	end)
5dfc4978   zhouhaihai   好友完善
652
653
654
655
656
  	local friends = {}
  	for i = 1, #redret[1], 2 do
  		friends[tonumber(redret[1][i])] = redret[1][i + 1]
  	end
  
c384626d   zhouhaihai   好友
657
  	local newList = redret[2]
5dfc4978   zhouhaihai   好友完善
658
659
  	local hadBlack = formatArray(redret[3])
  
c384626d   zhouhaihai   好友
660
661
662
  	local needRoleIds = {}
  	for _, newId in pairs(newList) do
  		local numNewId = tonumber(newId)
5dfc4978   zhouhaihai   好友完善
663
  		if numNewId ~= roleId and not friends[numNewId] and not hadBlack[numNewId] then
c384626d   zhouhaihai   好友
664
665
666
667
668
  			table.insert(needRoleIds, numNewId)
  		end
  	end
  
  	local randomRoles = {}
5dfc4978   zhouhaihai   好友完善
669
670
  	local redret = redisproxy:pipelining(function (red)
  		for _, objId in ipairs(needRoleIds) do
c384626d   zhouhaihai   好友
671
  			red:zscore(FRIEND_APPLY_KEY:format(objId), roleId)
5dfc4978   zhouhaihai   好友完善
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
  		end
  	end)
  	for idx, objId in ipairs(needRoleIds) do
  		if not redret[idx] then
  			local online, info = getRoleInfo(objId)
  			table.insert(randomRoles, table_merge({
  				roleId = objId, 
  				online = online,  
  				hadApply = hadApply,
  				inBlack = inBlack,
  			}, info, {
  
  			}))
  			if #randomRoles >= globalCsv.friendRecommendLimit then break end
  		end
c384626d   zhouhaihai   好友
687
688
689
690
691
692
  	end
  
  	SendPacket(actionCodes.Friend_randomRpc, MsgPack.pack({list = randomRoles}))
  	return true
  end
  
f603a60f   zhouhaihai   支援技实装
693
694
695
696
697
698
699
700
701
702
  function _M.battleInfoRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  	local msg = MsgPack.unpack(data)
  	local objId = msg.roleId
  	local online, matchInfo = rpcRole(objId, "friendBattleInfo")
  	SendPacket(actionCodes.Friend_battleInfoRpc, MsgPack.pack({matchInfo = matchInfo}))
  	return true
  end
  
c384626d   zhouhaihai   好友
703
704
  
  return _M