Blame view

src/actions/StoreAction.lua 15.3 KB
cccc9c70   zhouhaihai   商城
1
2
  local _M = {}
  
b6ed652b   zhouhaihai   充值
3
  local md5 = require "md5"
192b96d3   zhouhaihai   重置
4
  
b6ed652b   zhouhaihai   充值
5
6
  -- 入口在正式服关闭  -- mock 充值
  function _M.rechargeRpc(agent , data)
cccc9c70   zhouhaihai   商城
7
8
9
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
10
  	local choose = msg.choose or ""
cccc9c70   zhouhaihai   商城
11
  	local dataSet = csvdb["shop_rechargeCsv"][id]
cccc9c70   zhouhaihai   商城
12
  	if not dataSet then return end
b6ed652b   zhouhaihai   充值
13
14
  	local roleId = role:getProperty("id")
  	
192b96d3   zhouhaihai   重置
15
  	--创建订单号
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
16
  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
eb5ffd1c   liuzujun   世界boss翻牌奖励 活动卡池保底...
17
18
19
  	if partnerOrderId == "" then
  		return 1
  	end
b6ed652b   zhouhaihai   充值
20
  	SendPacket(actionCodes.Store_rechargeRpc, MsgPack.pack({ order = partnerOrderId }))
192b96d3   zhouhaihai   重置
21
  
39bcd7ca   zhouhaihai   LOG
22
  
b6ed652b   zhouhaihai   充值
23
24
25
26
  	-- 测试的 直接发奖励了
  	skynet.timeout(10, function ()
  		role:handlePurchase({
  			order = partnerOrderId,
668f23ea   zhouhaihai   单位分
27
  			amount = dataSet.rmb * 100,
b6ed652b   zhouhaihai   充值
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
  			game_money = dataSet.diamond,
  			product_id = dataSet.productId,
  			pay_time = skynet.timex(),
  			transactionId = "onlyTest",
  		})
  	end)
  	
  	return true
  end
  
  local function table_keys( t )
      local keys = {}
      for k, _ in pairs( t ) do
          keys[#keys + 1] = k
      end
      return keys
  end
  
  local function signPms(params, secret_key)
      local keys = table_keys(params)
      table.sort(keys)
      local urlCode = ""
      for index, key in ipairs(keys) do
  		urlCode = urlCode .. params[key]
  	end
  	return md5.sumhexa(urlCode .. secret_key):lower()
  end
  
19c418d9   chenyueqi   bili-android渠道的充值...
56
57
58
59
60
61
62
63
64
65
66
  -- bili android 充值 入口
  function _M.biliAndroidRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
7a3a7fff   chenyueqi   支付协议号
67
  	local partnerOrderId = role:getPurchaseOrder(id)
19c418d9   chenyueqi   bili-android渠道的充值...
68
69
70
71
72
73
74
75
76
77
78
79
80
  	-- 签名
  	local secret_key = "8920e9dcf0cb4ebca87393ce48021ead"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb * 100,
  		game_money = dataSet.diamond,
  		notify_url = msg.notifyUrl
  	}
  	local sign = signPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_biliAndroidRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
  	return true
  end
b6ed652b   zhouhaihai   充值
81
  
7a3a7fff   chenyueqi   支付协议号
82
  -- 享游sdk充值
f9b72d4f   chenyueqi   支付协议号
83
  function _M.biliCpsRechargeRpc(agent, data)
7a3a7fff   chenyueqi   支付协议号
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
  	local partnerOrderId = role:getPurchaseOrder(id)
  	-- 签名
  	local secret_key = "d69365fe15144af990065443749f0f1b"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb * 100,
  		game_money = dataSet.diamond,
  		notify_url = msg.notifyUrl
  	}
  	local sign = signPms(need, secret_key)
  
f9b72d4f   chenyueqi   支付协议号
104
  	SendPacket(actionCodes.Store_biliCpsRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
7a3a7fff   chenyueqi   支付协议号
105
106
107
108
  	return true
  end
  
  -- 享游sdk充值
f9b72d4f   chenyueqi   支付协议号
109
  function _M.biliUoRechargeRpc(agent, data)
7a3a7fff   chenyueqi   支付协议号
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
  	local partnerOrderId = role:getPurchaseOrder(id)
  	-- 签名
  	local secret_key = "4243b5fb44b64175a20a53dcfb1346eb"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb * 100,
  		game_money = dataSet.diamond,
  		notify_url = msg.notifyUrl
  	}
  	local sign = signPms(need, secret_key)
  
f9b72d4f   chenyueqi   支付协议号
130
  	SendPacket(actionCodes.Store_biliUoRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
7a3a7fff   chenyueqi   支付协议号
131
132
133
  	return true
  end
  
8ba57e2c   chenyueqi   云游戏的充值消息
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
  -- 云游戏sdk充值
  function _M.biliCloudRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
  	local partnerOrderId = role:getPurchaseOrder(id)
  	-- 签名
  	local secret_key = "c97a19c2c00143d6b0f0da2bc52208e7"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb * 100,
  		game_money = dataSet.diamond,
  		notify_url = msg.notifyUrl
  	}
  	local sign = signPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_biliCloudRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
  	return true
  end
  
b6ed652b   zhouhaihai   充值
160
161
162
163
164
  -- google 充值 入口
  function _M.googleRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
165
  	local choose = msg.choose or ""
b6ed652b   zhouhaihai   充值
166
167
168
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
192b96d3   zhouhaihai   重置
169
  
192b96d3   zhouhaihai   重置
170
  	role.ignoreHeartbeat = true
b6ed652b   zhouhaihai   充值
171
  	--创建订单号
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
172
  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
b6ed652b   zhouhaihai   充值
173
  	-- 签名
ebeefd34   chenyueqi   修改Google的充值参数
174
175
  	-- local secret_key = "b7657fa7ccd44c16a35e3f454ac7a075"
  	local secret_key = "8920e9dcf0cb4ebca87393ce48021ead"
b6ed652b   zhouhaihai   充值
176
177
  	local need = {
  		out_trade_no = partnerOrderId,
f9f877b1   zhouhaihai   商店
178
  		money = dataSet.rmb * 100,
b6ed652b   zhouhaihai   充值
179
  		game_money = dataSet.diamond,
ebeefd34   chenyueqi   修改Google的充值参数
180
  		-- product_id = dataSet.productId,
ba84f3c7   zhouhaihai   签名回调地址由客户端上传
181
  		notify_url = msg.notifyUrl
b6ed652b   zhouhaihai   充值
182
183
184
185
  	}
  	local sign = signPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_googleRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
192b96d3   zhouhaihai   重置
186
187
188
  	return true
  end
  
8ae04b5a   zhouhaihai   mycard
189
190
191
192
193
  -- mycard 充值 入口
  function _M.myCardRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
194
  	local choose = msg.choose or ""
8ae04b5a   zhouhaihai   mycard
195
196
197
198
199
200
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
201
  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
8ae04b5a   zhouhaihai   mycard
202
203
204
205
  	-- 签名
  	local secret_key = "48759e07540f46d9af17ec82669b4272"
  	local need = {
  		out_trade_no = partnerOrderId,
f9f877b1   zhouhaihai   商店
206
  		money = dataSet.rmb * 100,
8ae04b5a   zhouhaihai   mycard
207
  		game_money = dataSet.diamond,
ba84f3c7   zhouhaihai   签名回调地址由客户端上传
208
  		notify_url = msg.notifyUrl
8ae04b5a   zhouhaihai   mycard
209
210
211
  	}
  	local sign = signPms(need, secret_key)
  
e629295d   zhouhaihai   协议
212
  	SendPacket(actionCodes.Store_myCardRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
8ae04b5a   zhouhaihai   mycard
213
214
  	return true
  end
b6ed652b   zhouhaihai   充值
215
  
7a3a7fff   chenyueqi   支付协议号
216
  -- bili ios 充值 入口
9e25c63d   zhouhaihai   iospay
217
218
219
220
  function _M.iosRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
221
  	local choose = msg.choose or ""
9e25c63d   zhouhaihai   iospay
222
223
224
225
226
227
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
228
  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
9e25c63d   zhouhaihai   iospay
229
  	-- 签名
7a3a7fff   chenyueqi   支付协议号
230
  	local secret_key = "1916d62251dd4a8aa5e452121eefc9a1"
9e25c63d   zhouhaihai   iospay
231
232
  	local need = {
  		out_trade_no = partnerOrderId,
f9f877b1   zhouhaihai   商店
233
  		money = dataSet.rmb * 100,
9e25c63d   zhouhaihai   iospay
234
  		game_money = dataSet.diamond,
775d0388   chenyueqi   ios支付订单签名参数错误
235
  		product_id = dataSet.iap_product_id,
ba84f3c7   zhouhaihai   签名回调地址由客户端上传
236
  		notify_url = msg.notifyUrl
9e25c63d   zhouhaihai   iospay
237
238
239
240
241
242
243
  	}
  	local sign = signPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_iosRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
  	return true
  end
  
192b96d3   zhouhaihai   重置
244
245
246
247
248
249
250
251
  function _M.purchaseOrderResult(agent, data)
  	local role = agent.role
  
  	local roleId = role:getProperty("id")
  	local msg = MsgPack.unpack(data)
  
  	role.ignoreHeartbeat = false
  
d705a315   zhouhaihai   充值 整理
252
253
254
255
  	local status = {
  		fail = true,
  		success = true
  	}
192b96d3   zhouhaihai   重置
256
  
d705a315   zhouhaihai   充值 整理
257
258
259
  	local partnerOrderStr = msg.order
  	if partnerOrderStr then
  		role:updatePurchaseOrder(partnerOrderStr, msg.platformOrder, status[msg.status] and msg.status or "unknown")
cccc9c70   zhouhaihai   商城
260
  	end
cccc9c70   zhouhaihai   商城
261
262
263
264
  	return true
  end
  
  
c5825110   saicom   新增用户商城相关数据
265
266
267
268
269
270
271
272
273
  function _M.shopBuyRpc(agent , data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local count = msg.count or 1
  
  	local dataSet = csvdb["shop_normalCsv"][id]
  	if not dataSet then return end
  
9ea0c502   liuzujun   限时礼包
274
  	if dataSet.unlock ~= "" then
c72853af   liuzujun   修改每日礼包检测开启bug
275
  		if not role:checkHangPass(tonumber(dataSet.unlock)) then
9ea0c502   liuzujun   限时礼包
276
277
278
279
280
  			skynet.error(string.format("shopBuyRpc,user do not finish hang pass, user_id:%d", role:getProperty("id")))
  			return 1
  		end
  	end
  
3e20f499   saicom   完善商城相关协议
281
282
283
284
285
  	local buyRecord = role.storeData:getProperty("buyR")
  	if math.illegalNum(count, 1, (dataSet.limit == 0 and math.huge or dataSet.limit - (buyRecord[id] or 0))) then 
  		skynet.error(string.format("shop buy over limit, user_id:%d, goods_id:%d", role:getProperty("id"), id))
  		return 1 
  	end
c5825110   saicom   新增用户商城相关数据
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
  
  	local cost = {[dataSet.icon] = dataSet.cost * count}
  
  	local desc = "unknown"
  	if dataSet.shop == 1 then		-- 普通商店
  		desc = "dailyShop"
  		local dailySDD = role.dailyData:getProperty("dailySDD")
  		if dailySDD[id] then -- 折扣
  			cost = math.ceil(dataSet.cost * (1 - dataSet.disount / 100))
  		end
  	elseif dataSet.shop == 2 then		-- 美食商店
  		desc = "dinerShop"
  	elseif dataSet.shop == 3 then		-- 竞技场商店
  		desc = "pvpShop"
  	end
  
  	if not role:checkItemEnough(cost) then return end
  
  	if dataSet.limit ~= 0 then
  		buyRecord[id] = (buyRecord[id] or 0) + count
3e20f499   saicom   完善商城相关协议
306
  		role.storeData:updateProperty({field = "buyR", value = buyRecord})
c5825110   saicom   新增用户商城相关数据
307
  	end
c5825110   saicom   新增用户商城相关数据
308
309
310
311
312
313
314
315
  	role:costItems(cost, {log = {desc = desc, int1 = id, int2 = count}})
  
  	local gift = {}
  	for _id, _count in pairs(dataSet.gift:toNumMap()) do
  		gift[_id] = _count * count
  	end
  	local reward = role:award(gift, {log = {desc = desc, int1 = id, int2 = count}})
  	
7f9f002d   liuzujun   循环周活动
316
317
318
  	if dataSet.shop == 1 then
  		role:checkTaskEnter("ShopAll", {count = count})
  	end
c59e058b   zhouhaihai   新一批日志记录
319
320
321
322
323
324
325
326
327
328
329
  	local costId, costCount = next(cost)
  
  	role:log("shop_purchase", {
  		item_id = id, -- 道具id
  		item_type = 0, -- 道具类型,具体见枚举表中道具类型枚举表
  		item_level = 0, -- 道具等级
  		item_cnt = count, -- 购买数量技术
  		currency_type = costId or 0, -- 购买道具消耗的货币类型,记录货币ID
  		shop_purchase_current = costCount or 0, -- 购买道具消耗的货币数量
  		shop_id = dataSet.shop, -- 商店ID
  	})
f22a33af   zhouhaihai   自己的日志
330
  	role:mylog("role_action", {desc = desc, int1 = id, int2 = count})
c5825110   saicom   新增用户商城相关数据
331
332
333
334
  	SendPacket(actionCodes.Store_shopBuyRpc, MsgPack.pack({reward = reward}))
  	return true
  end
  
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
335
  function _M.getFreeChestRpc(agent, data)
3e20f499   saicom   完善商城相关协议
336
337
338
339
340
341
342
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  
  	local config = csvdb["shop_rechargeCsv"][id]
  	if not config then return end
  
d19b2af3   liuzujun   活动免费礼包判断活动是否开启
343
344
345
346
347
348
349
  	--判断是否是活动商品
  	if config.activity_id ~= 0 then
  		local actCfg = csvdb["activity_ctrlCsv"][config.activity_id]
  		if not actCfg then return 2 end
  		if not role.activity:isOpenById(config.activity_id, "ActShopGoods") then return 3 end
  	end
  
3e20f499   saicom   完善商城相关协议
350
351
352
353
354
      local rechargeRecord = role.storeData:getProperty("payR")
  	local getCount = (rechargeRecord[id] or 0)
  	if getCount >= config.limit then
  		return 1
  	end
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
355
  	local reward, _ = role:award(config.itemFirst, {log = {desc = "freeGift", int1 = id}})
3e20f499   saicom   完善商城相关协议
356
357
358
359
  
  	rechargeRecord[id] = getCount + 1
  	role.storeData:updateProperty({field = "payR", value = rechargeRecord})
  
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
360
  	SendPacket(actionCodes.Store_getFreeChestRpc, MsgPack.pack({reward = reward}))
317a46a9   liuzujun   添加特权卡
361
  	return true
3e20f499   saicom   完善商城相关协议
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
  end
  
  function _M.getGrowFundRewardRpc(agent, data)	
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  
  	local config = csvdb["reward_newbeeCsv"][id]
  	if not config then return end
  
      local growFundFlag = role.storeData:getProperty("growFund")
  	local growFundRecord = role.storeData:getProperty("growFundR")
  	
  	if growFundFlag == 0 then
  		skynet.error("user do not buy grow fund")
  		return 1
  	end
  
  	if not role:checkHangPass(config.condition) then
  		skynet.error(string.format("user do not finish hang pass, user_id:%d", role:getProperty("id")))
  		return 1
  	end
  
  	local b = string.getbit(growFundRecord, id)
  	if string.char(b) == "1" then
  		return 1
  	end
  
  	growFundRecord = string.setbit(growFundRecord, id)
  	role.storeData:updateProperty({field = "growFundR", value = growFundRecord})
  
  	local gift = config.giftFree .. " " .. config.giftLimit
  	local reward, _ = role:award(gift, {log = {desc = "grownFund", int1 = id}})
  
  	SendPacket(actionCodes.Store_getGrowFundRewardRpc, MsgPack.pack({reward = reward}))
317a46a9   liuzujun   添加特权卡
397
  	return true
3e20f499   saicom   完善商城相关协议
398
399
  end
  
51d9d20b   liuzujun   付费签到,应用市场反馈
400
  -- 赛季卡
3e20f499   saicom   完善商城相关协议
401
402
403
404
405
406
407
408
409
  function _M.getBattlePassRewardRpc(agent, data)	
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  
  	local config = csvdb["reward_battlepassCsv"][id]
  	if not config then return end
  
  	local timeNow = skynet.timex()
fb3d084d   liuzujun   月卡赛季卡发送邮件奖励
410
      local battleCardFlag = role.storeData:getProperty("battleCard")
3e20f499   saicom   完善商城相关协议
411
412
413
414
415
416
417
418
419
420
421
  	local battleCardFreeRecord = role.storeData:getProperty("battleFR")
  	local battleCardLimitRecord = role.storeData:getProperty("battleLR")
  
  	local freeFlag = string.char(string.getbit(battleCardFreeRecord, id))
  	local limitFlag = string.char(string.getbit(battleCardLimitRecord, id))
  
  	if freeFlag == "1" and limitFlag == "1" then
  		skynet.error("user already get battle pass reward")
  		return 1
  	end
  
fb3d084d   liuzujun   月卡赛季卡发送邮件奖励
422
  	if battleCardFlag == 1 and limitFlag == "1" then
3e20f499   saicom   完善商城相关协议
423
424
425
  		return 1
  	end
  
fb3d084d   liuzujun   月卡赛季卡发送邮件奖励
426
  	if role:getProperty("battlePoint") < config.point then
1a0b3c56   liuzujun   抽卡保底,切换定向卡池
427
428
429
430
  		skynet.error(string.format("user do not have enough battle point, user_id:%d", role:getProperty("id")))
  		return 1
  	end
  
3e20f499   saicom   完善商城相关协议
431
432
433
434
435
436
437
438
  	local gift = ""
  	if  freeFlag == "0" then
  		gift = config.giftFree
  
  		battleCardFreeRecord = string.setbit(battleCardFreeRecord, id)
  		role.storeData:updateProperty({field = "battleFR", value = battleCardFreeRecord})
  	end
  
fb3d084d   liuzujun   月卡赛季卡发送邮件奖励
439
  	if battleCardFlag == 1 and limitFlag == "0" then
3e20f499   saicom   完善商城相关协议
440
441
442
443
444
445
  		if gift ~= "" then
  			gift = gift .. " "
  		end
  		gift = gift .. config.giftLimit
  
  		battleCardLimitRecord = string.setbit(battleCardLimitRecord, id)
fb3d084d   liuzujun   月卡赛季卡发送邮件奖励
446
  		role.storeData:updateProperty({field = "battleLR", value = battleCardLimitRecord})
3e20f499   saicom   完善商城相关协议
447
448
449
450
451
  	end
  	
  	local reward, _ = role:award(gift, {log = {desc = "battleCard", int1 = id}})
  
  	SendPacket(actionCodes.Store_getBattlePassRewardRpc, MsgPack.pack({reward = reward}))
317a46a9   liuzujun   添加特权卡
452
  	return true
3e20f499   saicom   完善商城相关协议
453
454
  end
  
51d9d20b   liuzujun   付费签到,应用市场反馈
455
456
457
458
459
460
461
  -- 探索指令奖励
  function _M.getExploreCommandRewardRpc(agent, data)	
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id		-- 探索id
  	local subId = msg.subId		-- 领取的阶段id
  
37bb4611   liuzujun   付费签到,抽卡阶段奖励,探索指令
462
  	local tab_name = "reward_levelpass" .. id .. "Csv"
e52c384f   liuzujun   探索指令bug, 充值返利活动
463
  	local config = csvdb[tab_name][subId]
51d9d20b   liuzujun   付费签到,应用市场反馈
464
465
  	if not config then return end
  
c99f08df   liuzujun   探索指令调试完成
466
  	local bpInfo = role.storeData:getProperty("bpInfo") or {}
51d9d20b   liuzujun   付费签到,应用市场反馈
467
468
  	local info = bpInfo[id] or {}
  	local flag = info["flag"] or 0
c99f08df   liuzujun   探索指令调试完成
469
  	--if flag == 0 then return 1 end
51d9d20b   liuzujun   付费签到,应用市场反馈
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
  
  	local freeRecord = info["fr"] or ""
  	local buyRecord = info["br"] or ""
  
  	local freeFlag = string.char(string.getbit(freeRecord, subId))
  	local limitFlag = string.char(string.getbit(buyRecord, subId))
  
  	if freeFlag == "1" and limitFlag == "1" then
  		skynet.error("user already get explore command reward")
  		return 2
  	end
  
  	if flag == 1 and limitFlag == "1" then
  		return 3
  	end
  
37bb4611   liuzujun   付费签到,抽卡阶段奖励,探索指令
486
  	if not role:checkHangPass(config.level) then
51d9d20b   liuzujun   付费签到,应用市场反馈
487
488
489
490
491
492
493
  		return 4
  	end
  
  	local gift = ""
  	if  freeFlag == "0" then
  		gift = config.giftFree
  
c99f08df   liuzujun   探索指令调试完成
494
  		freeRecord = string.setbit(freeRecord, subId)
51d9d20b   liuzujun   付费签到,应用市场反馈
495
496
497
498
499
500
501
502
503
  		info["fr"] = freeRecord
  	end
  
  	if flag == 1 and limitFlag == "0" then
  		if gift ~= "" then
  			gift = gift .. " "
  		end
  		gift = gift .. config.giftLimit
  
c99f08df   liuzujun   探索指令调试完成
504
  		buyRecord = string.setbit(buyRecord, subId)
51d9d20b   liuzujun   付费签到,应用市场反馈
505
506
507
  		info["br"] = buyRecord
  	end
  
c99f08df   liuzujun   探索指令调试完成
508
509
  	bpInfo[id] = info
  	role.storeData:updateProperty({field = "bpInfo", value = bpInfo})
51d9d20b   liuzujun   付费签到,应用市场反馈
510
511
512
513
514
515
516
  	
  	local reward, _ = role:award(gift, {log = {desc = "exploreCommand", int1 = id, int2 = subId}})
  
  	SendPacket(actionCodes.Store_getExploreCommandRewardRpc, MsgPack.pack({reward = reward}))
  	return true
  end
  
4f7cffe5   liuzujun   多队挂机任务取消功能,累充奖励
517
518
519
520
521
  -- 累充奖励
  function _M.getTotalRechargeAwardRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local index = msg.index		-- 领取的索引id
b8b1c164   liuzujun   扭蛋活动,万能碎片bug
522
  	local totalTwd = role:getProperty("twdC")
4f7cffe5   liuzujun   多队挂机任务取消功能,累充奖励
523
524
  	local totalRechargeRecord = role.storeData:getProperty("totalRR")
  	local flag = string.char(string.getbit(totalRechargeRecord, index))
b8b1c164   liuzujun   扭蛋活动,万能碎片bug
525
  	if flag == "1" then return 1 end
2bc706ab   liuzujun   兑换活动重置,累充功能
526
  	local cfg = csvdb["activity_payRebateCsv"][index]
4f7cffe5   liuzujun   多队挂机任务取消功能,累充奖励
527
  	if not cfg then return 2 end
2bc706ab   liuzujun   兑换活动重置,累充功能
528
  	if cfg.twd > totalTwd then return 3 end
b8b1c164   liuzujun   扭蛋活动,万能碎片bug
529
530
531
  
  	totalRechargeRecord = string.setbit(totalRechargeRecord, index)
  	role.storeData:updateProperty({field = "totalRR", value = totalRechargeRecord})
2bc706ab   liuzujun   兑换活动重置,累充功能
532
533
534
535
536
  	local main = cfg.main_reward:toNumMap()
  	local sub = cfg.sub_reward:toNumMap()
  	for k, v in pairs(sub) do
  		main[k] = (main[k] or 0) + v
  	end
4f7cffe5   liuzujun   多队挂机任务取消功能,累充奖励
537
  
2bc706ab   liuzujun   兑换活动重置,累充功能
538
539
  	local reward, change = role:award(main, {log = {desc = "totalRecharge", int1 = index}})
  	SendPacket(actionCodes.Store_getTotalRechargeAwardRpc, MsgPack.pack(role:packReward(reward, change)))
4f7cffe5   liuzujun   多队挂机任务取消功能,累充奖励
540
541
542
  	return true
  end
  
cccc9c70   zhouhaihai   商城
543
  return _M