CapsuleAction.lua
3.54 KB
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
113
114
115
116
117
118
119
120
121
122
123
local ipairs = ipairs
local table = table
local math = math
local next = next
local string = string
local redisproxy = redisproxy
local MsgPack = MsgPack
local getRandomName = getRandomName
local mcast_util = mcast_util
local string_format = string.format
local tonumber = tonumber
local require = require
local _M = {}
function _M.listRpc(agent, data)
local role = agent.role
local msg = MsgPack.unpack(data)
local typ = msg.typ
local coin = msg.coin
local capsules = {}
if typ == 1 then
local ret = skynet.call(agent.capsule_serv, "lua", "list", coin)
if next(ret) then
for k, v in pairs(ret) do
capsules[k] = v
end
end
elseif typ == 0 then
local ret = role:getCapsuleList(coin)
if next(ret) then
for k, v in pairs(ret) do
capsules[k] = v
end
end
end
SendPacket(actionCodes.Capsule_listRpc, MsgPack.pack(capsules))
return true
end
function _M.joinRpc(agent, data)
local role = agent.role
local msg = MsgPack.unpack(data)
local roleId = role:getProperty("id")
local capsuleId = msg.capsule_id --如果刷新则需要传递当前扭蛋机id
local typ = msg.typ or 1
local ret = {}
if typ == 1 then
ret = skynet.call(agent.capsule_serv, "lua", "join", roleId, capsuleId)
elseif typ == 0 then
ret = role:joinCapsule()
end
SendPacket(actionCodes.Capsule_joinRpc, MsgPack.pack(ret))
return true
end
function _M.exitRpc(agent, data)
local role = agent.role
local msg = MsgPack.unpack(data)
local roleId = role:getProperty("id")
local capsuleId = msg.capsule_id --如果刷新则需要传递当前扭蛋机id
local typ = msg.typ or 1
local ret = {}
if typ == 1 then
ret = skynet.call(agent.capsule_serv, "lua", "exit", roleId, capsuleId)
elseif typ == 0 then
ret = role:exitCapsule()
end
SendPacket(actionCodes.Capsule_exitRpc, MsgPack.pack(ret))
return true
end
function _M.registerRpc(agent, data)
local role = agent.role
local msg = MsgPack.unpack(data)
local roleId = role:getProperty("id")
local capsuleId = msg.capsule_id
local ret = skynet.call(agent.capsule_serv, "lua", "register", roleId, capsuleId)
SendPacket(actionCodes.Capsule_registerRpc, MsgPack.pack(ret))
return true
end
function _M.drawRpc(agent, data)
local role = agent.role
local msg = MsgPack.unpack(data)
local roleId = role:getProperty("id")
local capsuleId = msg.capsule_id
local typ = msg.typ --0=独享，1= 公开
local full = msg.full -- 0=单次，1=十连抽 2=全收
local continue = msg.continue--确认次数。
local cares = msg.cares
local ret, reward, change
if typ == 1 then
ret, reward = skynet.call(agent.capsule_serv, "lua", "draw_capsule", roleId, capsuleId, full, continue, cares)
else
ret, reward = role:drawCapsule(capsuleId, full, cares)
end
if ret <= 4 then return ret end
reward, change = role:award(reward, {log = {desc = "CapsuleReward", int1 = capsuleId, int2 = roleId}})
dump(reward)
SendPacket(actionCodes.Capsule_drawRpc, MsgPack.pack(role:packReward(reward, change)))
return true
end
function _M.switchRoomRpc(agent, data)
local role = agent.role
local msg = MsgPack.unpack(data)
local roleId = role:getProperty("id")
local ret = skynet.call(agent.capsule_serv, "lua", "switch_room", roleId)
SendPacket(actionCodes.Capsule_switchRoomRpc, MsgPack.pack(ret))
return true
end
return _M