Blame view

src/actions/CapsuleAction.lua 5.82 KB
555f745e   zhangqijia   feat: 一番赏
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
  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)
f382b4f2   zhangqijia   fix: 一番赏的抽奖bug
85
      if not ret then return 1 end
555f745e   zhangqijia   feat: 一番赏
86
87
88
89
90
91
92
93
94
95
      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= 公开
0eb317fb   zhangqijia   fix: 一番赏奖励抽奖的bug与...
96
      local full = msg.full or 0-- 0=单次,1=十连抽 2=全收
555f745e   zhangqijia   feat: 一番赏
97
98
      local cares = msg.cares
  
0eb317fb   zhangqijia   fix: 一番赏奖励抽奖的bug与...
99
100
101
102
103
104
105
106
      local ret, token, reward, change, rewardByGoods, capsule
  
      --检查库存
      if typ == 1 then
          ret, token = skynet.call(agent.capsule_serv, "lua", "goods_stock", capsuleId)
      else
          ret, token = role:goodStock(capsuleId)
      end
096de6f7   zhangqijia   fix: 一番赏 抽扭蛋机通知 特...
107
      if ret == 0 then skynet.error("零库存 " .. capsuleId) return 0 end
0eb317fb   zhangqijia   fix: 一番赏奖励抽奖的bug与...
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
  
      --检查余额
      if not next(token) then skynet.error("代币未配置 " .. capsuleId) return 1 end
      local cost, drawsNum = {}, 0
      if full == 0 then
          drawsNum = 1
      elseif full == 1 then
          if ret < 10 then
              drawsNum = ret
          else
              drawsNum = 10
          end
      elseif full == 2 then
          drawsNum = ret
      end
      cost[token[1]] = drawsNum * token[2]
  
a997a3b0   zhangqijia   fix: 一番赏 打开消耗票的功能
125
126
      if not role:checkItemEnough(cost) then return 2 end
      role:costItems(cost, {log = {desc = "CapsuleCoinCost", int1 = token[1], int2 = cost[token[1]]}})
0eb317fb   zhangqijia   fix: 一番赏奖励抽奖的bug与...
127
128
  
      --开始抽奖
555f745e   zhangqijia   feat: 一番赏
129
      if typ == 1 then
cd2a7a67   zhangqijia   fix: 一番赏奖励中加入得奖者的...
130
          ret, reward, rewardByGoods, capsule = skynet.call(agent.capsule_serv, "lua", "draw_capsule", roleId, capsuleId, full, cares)
555f745e   zhangqijia   feat: 一番赏
131
      else
cd2a7a67   zhangqijia   fix: 一番赏奖励中加入得奖者的...
132
          ret, reward, rewardByGoods, capsule= role:drawCapsule(capsuleId, full, cares)
555f745e   zhangqijia   feat: 一番赏
133
      end
0eb317fb   zhangqijia   fix: 一番赏奖励抽奖的bug与...
134
      if ret < 5 then
f382b4f2   zhangqijia   fix: 一番赏的抽奖bug
135
136
137
          return ret
      end
  
0a421d34   zhangqijia   fix: 一番赏奖励 刷新协议缺少...
138
139
      --dump(rewardByGoods)
      --dump(capsule)
0eb317fb   zhangqijia   fix: 一番赏奖励抽奖的bug与...
140
141
142
143
  
      if ret == 5 then
          SendPacket(actionCodes.Capsule_drawRpc, MsgPack.pack({change = reward, capsule = capsule}))
          return true
f382b4f2   zhangqijia   fix: 一番赏的抽奖bug
144
      end
555f745e   zhangqijia   feat: 一番赏
145
  
0eb317fb   zhangqijia   fix: 一番赏奖励抽奖的bug与...
146
      -- rewardByGoods是抽到的扭蛋信息,reward是抽扭蛋后获得的所有奖励信息。
cd2a7a67   zhangqijia   fix: 一番赏奖励中加入得奖者的...
147
148
149
150
      if rewardByGoods and next(rewardByGoods) then
          reward, change = role:award(reward, {log = {desc = "CapsuleReward", int1 = tonumber(capsuleId), int2 = roleId}})
          SendPacket(actionCodes.Capsule_drawRpc, MsgPack.pack({reward = rewardByGoods, capsule = capsule}))
      else
0eb317fb   zhangqijia   fix: 一番赏奖励抽奖的bug与...
151
          return ret
cd2a7a67   zhangqijia   fix: 一番赏奖励中加入得奖者的...
152
      end
555f745e   zhangqijia   feat: 一番赏
153
154
155
      return true
  end
  
0a421d34   zhangqijia   fix: 一番赏奖励 刷新协议缺少...
156
  function _M.getDataRpc(agent, data)
555f745e   zhangqijia   feat: 一番赏
157
158
      local role = agent.role
      local msg = MsgPack.unpack(data)
0eb317fb   zhangqijia   fix: 一番赏奖励抽奖的bug与...
159
160
      local capsuleId = msg.capsule_id
      local typ = msg.typ --0=独享,1= 公开
0a421d34   zhangqijia   fix: 一番赏奖励 刷新协议缺少...
161
      local roleId = role:getProperty("id")
555f745e   zhangqijia   feat: 一番赏
162
  
0eb317fb   zhangqijia   fix: 一番赏奖励抽奖的bug与...
163
164
      local capsule
      if typ == 1 then
0a421d34   zhangqijia   fix: 一番赏奖励 刷新协议缺少...
165
          capsule = skynet.call(agent.capsule_serv, "lua", "capsule_data", roleId,  capsuleId)
0eb317fb   zhangqijia   fix: 一番赏奖励抽奖的bug与...
166
167
168
169
170
171
      else
          capsule = role:getCapsuleData(capsuleId)
      end
      if not capsule then return 1 end
  
      SendPacket(actionCodes.Capsule_getDataRpc, MsgPack.pack({capsule = capsule}))
555f745e   zhangqijia   feat: 一番赏
172
      return true
0eb317fb   zhangqijia   fix: 一番赏奖励抽奖的bug与...
173
  
555f745e   zhangqijia   feat: 一番赏
174
175
  end
  
d4f83f16   zhangqijia   feat: 一番赏 增加抽扭蛋机消...
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
  function _M.convertCapsuleRpc(agent, data)
      local role = agent.role
      local msg = MsgPack.unpack(data)
      local coin = msg.coin
      local count = msg.count or 1
  
      local cost, convert = {}
      for k, v in pairs(globalCsv.ichibankuji_buy_cost)do
          if k == coin then
              convert = v:toArray(true, "=")
              break
          end
      end
      cost[convert[1]] = convert[2] * count
      if not role:checkItemEnough(cost) then return 1 end
      role:costItems(cost, {log = {desc = "CapsuleConvert", int1 = convert[1], int2 = cost[convert[1]]}})
  
      local reward, change = role:award({coin = count}, {log = {desc = "CapsuleConvert"}})
      SendPacket(actionCodes.Capsule_convertCapsuleRpc, MsgPack.pack(role:packReward(reward, change)))
      return true
  end
  
555f745e   zhangqijia   feat: 一番赏
198
  return _M