Blame view

src/actions/StoreAction.lua 19.4 KB
cccc9c70   zhouhaihai   商城
1
2
  local _M = {}
  
b6ed652b   zhouhaihai   充值
3
  local md5 = require "md5"
344d2df3   liuzujun   微信支付宝下单接口
4
  local httpc = require("http.httpc")
192b96d3   zhouhaihai   重置
5
  
b6ed652b   zhouhaihai   充值
6
7
  -- 入口在正式服关闭  -- mock 充值
  function _M.rechargeRpc(agent , data)
d2d7ea5c   liuzujun   取消gm指令和充值接口
8
  	if true then return end
cccc9c70   zhouhaihai   商城
9
10
11
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
12
  	local choose = msg.choose or ""
cccc9c70   zhouhaihai   商城
13
  	local dataSet = csvdb["shop_rechargeCsv"][id]
cccc9c70   zhouhaihai   商城
14
  	if not dataSet then return end
b6ed652b   zhouhaihai   充值
15
16
  	local roleId = role:getProperty("id")
  	
192b96d3   zhouhaihai   重置
17
  	--创建订单号
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
18
  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
eb5ffd1c   liuzujun   世界boss翻牌奖励 活动卡池保底...
19
20
21
  	if partnerOrderId == "" then
  		return 1
  	end
b6ed652b   zhouhaihai   充值
22
  	SendPacket(actionCodes.Store_rechargeRpc, MsgPack.pack({ order = partnerOrderId }))
192b96d3   zhouhaihai   重置
23
  
b6ed652b   zhouhaihai   充值
24
25
26
27
  	-- 测试的 直接发奖励了
  	skynet.timeout(10, function ()
  		role:handlePurchase({
  			order = partnerOrderId,
c9c0150d   zhangqijia   fix: 月卡 购买不成功的bug
28
  			amount = dataSet.rmb * 100 / globalCsv.QArecharge,
b6ed652b   zhouhaihai   充值
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
  			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
  
d742048c   saicom   ios充值前面改为东银河
57
58
59
60
61
62
63
64
65
66
67
68
69
  local function signDyhPms(params, secret_key)
      local keys = table_keys(params)
      table.sort(keys)
      local str2Sign = ""
      for index, key in ipairs(keys) do
          if str2Sign ~= "" then
              str2Sign = str2Sign .. '&'
          end
          str2Sign = str2Sign .. string.format("%s=%s", key, params[key])
      end
  	return md5.sumhexa(str2Sign .. secret_key):lower()
  end
  
19c418d9   chenyueqi   bili-android渠道的充值...
70
71
72
73
74
75
76
77
78
79
80
  -- 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   支付协议号
81
  	local partnerOrderId = role:getPurchaseOrder(id)
19c418d9   chenyueqi   bili-android渠道的充值...
82
83
84
85
86
87
88
89
90
91
92
93
94
  	-- 签名
  	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   充值
95
  
7a3a7fff   chenyueqi   支付协议号
96
  -- 享游sdk充值
f9b72d4f   chenyueqi   支付协议号
97
  function _M.biliCpsRechargeRpc(agent, data)
7a3a7fff   chenyueqi   支付协议号
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
  	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   支付协议号
118
  	SendPacket(actionCodes.Store_biliCpsRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
7a3a7fff   chenyueqi   支付协议号
119
120
121
122
  	return true
  end
  
  -- 享游sdk充值
f9b72d4f   chenyueqi   支付协议号
123
  function _M.biliUoRechargeRpc(agent, data)
7a3a7fff   chenyueqi   支付协议号
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
  	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   支付协议号
144
  	SendPacket(actionCodes.Store_biliUoRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
7a3a7fff   chenyueqi   支付协议号
145
146
147
  	return true
  end
  
8ba57e2c   chenyueqi   云游戏的充值消息
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
  -- 云游戏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   充值
174
175
176
177
178
  -- google 充值 入口
  function _M.googleRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
179
  	local choose = msg.choose or ""
b6ed652b   zhouhaihai   充值
180
181
182
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
192b96d3   zhouhaihai   重置
183
  
192b96d3   zhouhaihai   重置
184
  	role.ignoreHeartbeat = true
b6ed652b   zhouhaihai   充值
185
  	--创建订单号
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
186
  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
b6ed652b   zhouhaihai   充值
187
  	-- 签名
ebeefd34   chenyueqi   修改Google的充值参数
188
189
  	-- local secret_key = "b7657fa7ccd44c16a35e3f454ac7a075"
  	local secret_key = "8920e9dcf0cb4ebca87393ce48021ead"
b6ed652b   zhouhaihai   充值
190
191
  	local need = {
  		out_trade_no = partnerOrderId,
f9f877b1   zhouhaihai   商店
192
  		money = dataSet.rmb * 100,
b6ed652b   zhouhaihai   充值
193
  		game_money = dataSet.diamond,
ebeefd34   chenyueqi   修改Google的充值参数
194
  		-- product_id = dataSet.productId,
ba84f3c7   zhouhaihai   签名回调地址由客户端上传
195
  		notify_url = msg.notifyUrl
b6ed652b   zhouhaihai   充值
196
197
198
199
  	}
  	local sign = signPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_googleRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
192b96d3   zhouhaihai   重置
200
201
202
  	return true
  end
  
8ae04b5a   zhouhaihai   mycard
203
204
205
206
207
  -- mycard 充值 入口
  function _M.myCardRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
208
  	local choose = msg.choose or ""
8ae04b5a   zhouhaihai   mycard
209
210
211
212
213
214
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
215
  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
8ae04b5a   zhouhaihai   mycard
216
217
218
219
  	-- 签名
  	local secret_key = "48759e07540f46d9af17ec82669b4272"
  	local need = {
  		out_trade_no = partnerOrderId,
f9f877b1   zhouhaihai   商店
220
  		money = dataSet.rmb * 100,
8ae04b5a   zhouhaihai   mycard
221
  		game_money = dataSet.diamond,
ba84f3c7   zhouhaihai   签名回调地址由客户端上传
222
  		notify_url = msg.notifyUrl
8ae04b5a   zhouhaihai   mycard
223
224
225
  	}
  	local sign = signPms(need, secret_key)
  
e629295d   zhouhaihai   协议
226
  	SendPacket(actionCodes.Store_myCardRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
8ae04b5a   zhouhaihai   mycard
227
228
  	return true
  end
b6ed652b   zhouhaihai   充值
229
  
7a3a7fff   chenyueqi   支付协议号
230
  -- bili ios 充值 入口
9e25c63d   zhouhaihai   iospay
231
232
233
234
  function _M.iosRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
235
  	local choose = msg.choose or ""
9e25c63d   zhouhaihai   iospay
236
237
238
239
240
241
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
  	local roleId = role:getProperty("id")
  
  	role.ignoreHeartbeat = true
  	--创建订单号
2dbe4fb9   chenyueqi   充值礼包自选部分逻辑
242
  	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
9e25c63d   zhouhaihai   iospay
243
  	-- 签名
d742048c   saicom   ios充值前面改为东银河
244
  	local secret_key = "2b2036e1f44640a59168c92462714870"
9e25c63d   zhouhaihai   iospay
245
246
  	local need = {
  		out_trade_no = partnerOrderId,
f9f877b1   zhouhaihai   商店
247
  		money = dataSet.rmb * 100,
9e25c63d   zhouhaihai   iospay
248
  		game_money = dataSet.diamond,
775d0388   chenyueqi   ios支付订单签名参数错误
249
  		product_id = dataSet.iap_product_id,
ba84f3c7   zhouhaihai   签名回调地址由客户端上传
250
  		notify_url = msg.notifyUrl
9e25c63d   zhouhaihai   iospay
251
  	}
c0290d89   saicom   东银河订单加签
252
  	local sign = signDyhPms(need, secret_key)
9e25c63d   zhouhaihai   iospay
253
254
255
256
257
  
  	SendPacket(actionCodes.Store_iosRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
  	return true
  end
  
e0d725cc   saicom   东银河安卓sdk
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
  -- dyh android 充值 入口
  function _M.dyhxAndroidRechargeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local choose = msg.choose or ""
  	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,nil,choose)
  	-- 签名
  	local secret_key = "51ba4398c69d4d229d5402295dc38b50"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb * 100,
  		game_money = dataSet.diamond,
  		notify_url = msg.notifyUrl
  	}
  	local sign = signDyhPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_dyhxAndroidRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
  	return true
  end
  
7e61a962   liuzujun   新增通用生成订单协议,
285
  local rechargeHandler = {
344d2df3   liuzujun   微信支付宝下单接口
286
287
288
289
290
291
292
293
294
295
296
297
298
  	ali = function(cp_order_id, rechargeId, cfg, result)
  		local codeurl = skynet.getenv("codeurl")
  		local content = {
  			["paytype"] = "alipay",
  			["rechargeid"] = rechargeId,
  			["order"] = cp_order_id,
  			["title"] = cfg.title,
  			["rmb"] = cfg.rmb,
  		}
  		local status, body = httpc.get(codeurl, "/payorder?" .. httpGetFormatData(content), {})
  		if status == 200 then
  			result["orderInfo"] = body
  		end
7e61a962   liuzujun   新增通用生成订单协议,
299
  	end,
344d2df3   liuzujun   微信支付宝下单接口
300
301
302
303
304
305
306
307
308
309
310
311
312
  	wx = function(cp_order_id, rechargeId, cfg, result)
  		local codeurl = skynet.getenv("codeurl")
  		local content = {
  			["paytype"] = "wxpay",
  			["rechargeid"] = rechargeId,
  			["order"] = cp_order_id,
  			["title"] = cfg.title,
  			["rmb"] = cfg.rmb,
  		}
  		local status, body = httpc.get(codeurl, "/payorder?" .. httpGetFormatData(content), {})
  		if status == 200 then
  			result["orderInfo"] = body
  		end
7e61a962   liuzujun   新增通用生成订单协议,
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
  	end,
  }
  
  function _M.getCpOrderIdRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local type = msg.skd_type or ""
  	local choose = msg.choose or ""
  	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,nil,choose)
  
  	local result = {}
  	result["order"] = partnerOrderId
  	local handler = rechargeHandler[type]
  	if handler then
344d2df3   liuzujun   微信支付宝下单接口
334
  		handler(partnerOrderId, id, dataSet, result)
7e61a962   liuzujun   新增通用生成订单协议,
335
336
337
  	end
  
  	SendPacket(actionCodes.Store_getCpOrderIdRpc, MsgPack.pack(result))
d81f1a3d   liuzujun   ios支付修改
338
  	return true
7e61a962   liuzujun   新增通用生成订单协议,
339
340
  end
  
e0d725cc   saicom   东银河安卓sdk
341
  
192b96d3   zhouhaihai   重置
342
343
344
345
346
347
348
349
  function _M.purchaseOrderResult(agent, data)
  	local role = agent.role
  
  	local roleId = role:getProperty("id")
  	local msg = MsgPack.unpack(data)
  
  	role.ignoreHeartbeat = false
  
d705a315   zhouhaihai   充值 整理
350
351
352
353
  	local status = {
  		fail = true,
  		success = true
  	}
192b96d3   zhouhaihai   重置
354
  
d705a315   zhouhaihai   充值 整理
355
356
357
  	local partnerOrderStr = msg.order
  	if partnerOrderStr then
  		role:updatePurchaseOrder(partnerOrderStr, msg.platformOrder, status[msg.status] and msg.status or "unknown")
cccc9c70   zhouhaihai   商城
358
  	end
cccc9c70   zhouhaihai   商城
359
360
361
362
  	return true
  end
  
  
c5825110   saicom   新增用户商城相关数据
363
364
365
366
367
368
  function _M.shopBuyRpc(agent , data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local count = msg.count or 1
  
167d24dc   zhangqijia   fix: shopnormal 商...
369
  	local dataSet = csvdb["shop_normalCsv"][id]
c5825110   saicom   新增用户商城相关数据
370
371
  	if not dataSet then return end
  
9ea0c502   liuzujun   限时礼包
372
  	if dataSet.unlock ~= "" then
c72853af   liuzujun   修改每日礼包检测开启bug
373
  		if not role:checkHangPass(tonumber(dataSet.unlock)) then
9ea0c502   liuzujun   限时礼包
374
375
376
377
378
  			skynet.error(string.format("shopBuyRpc,user do not finish hang pass, user_id:%d", role:getProperty("id")))
  			return 1
  		end
  	end
  
a33ade6c   liuzujun   rmb礼包改钻石礼包
379
380
381
382
383
384
385
  	--判断是否是活动商品
  	if dataSet.activity_id and dataSet.activity_id ~= 0 then
  		local actCfg = csvdb["activity_ctrlCsv"][dataSet.activity_id]
  		if not actCfg then return 2 end
  		if not role.activity:isOpenById(dataSet.activity_id, "ActShopGoods") then return 3 end
  	end
  
167d24dc   zhangqijia   fix: shopnormal 商...
386
387
  	local cost
  	if dataSet.disount == 0 then
34c8cf27   zhangqijia   fix: 商店不打折商品,售价为0的bu
388
389
390
391
  		cost = {[dataSet.icon] = math.ceil(dataSet.cost * count)}
  	else
  		cost = {[dataSet.icon] = math.ceil(dataSet.cost * count * ((dataSet.disount or 10) / 10))}
  	end
ff72d1eb   zhangqijia   fix: 商店商品购买折扣bug
392
  
c6a4c456   liuzujun   boss挑战门票购买可以超出上限
393
  	local desc = "unknowShop"
c5825110   saicom   新增用户商城相关数据
394
395
  	if dataSet.shop == 1 then		-- 普通商店
  		desc = "dailyShop"
c5825110   saicom   新增用户商城相关数据
396
397
398
399
400
401
  	elseif dataSet.shop == 2 then		-- 美食商店
  		desc = "dinerShop"
  	elseif dataSet.shop == 3 then		-- 竞技场商店
  		desc = "pvpShop"
  	end
  
a33ade6c   liuzujun   rmb礼包改钻石礼包
402
  	if not role:checkItemEnough(cost) then return 4 end
c5825110   saicom   新增用户商城相关数据
403
  
167d24dc   zhangqijia   fix: shopnormal 商...
404
405
406
407
408
409
  	local buyRecord = role.storeData:getProperty("buyR")
  	if math.illegalNum(count, 1, (dataSet.limit == 0 and 10000 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 6
  	end
  
5cf05cda   zhangqijia   fix: 解决小概率事件,当购买数...
410
411
  	if not role:costItems(cost, {log = {desc = desc, int1 = id, int2 = count, long1= dataSet.shop}}) then return 5 end
  
167d24dc   zhangqijia   fix: shopnormal 商...
412
  	local limitStr = ""
c5825110   saicom   新增用户商城相关数据
413
414
  	if dataSet.limit ~= 0 then
  		buyRecord[id] = (buyRecord[id] or 0) + count
3e20f499   saicom   完善商城相关协议
415
  		role.storeData:updateProperty({field = "buyR", value = buyRecord})
167d24dc   zhangqijia   fix: shopnormal 商...
416
  		limitStr = string.format("%s/%s", buyRecord[id], dataSet.limit)
c5825110   saicom   新增用户商城相关数据
417
  	end
c5825110   saicom   新增用户商城相关数据
418
419
420
421
422
  
  	local gift = {}
  	for _id, _count in pairs(dataSet.gift:toNumMap()) do
  		gift[_id] = _count * count
  	end
a33ade6c   liuzujun   rmb礼包改钻石礼包
423
  	local reward = role:award(gift, {log = {desc = desc, int1 = id, int2 = count, short1=dataSet.shop}})
c5825110   saicom   新增用户商城相关数据
424
  	
7f9f002d   liuzujun   循环周活动
425
426
427
  	if dataSet.shop == 1 then
  		role:checkTaskEnter("ShopAll", {count = count})
  	end
c59e058b   zhouhaihai   新一批日志记录
428
429
430
431
432
433
434
435
436
437
438
  	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
  	})
e84a1beb   liuzujun   gm后台查询日志,公告相关协议
439
  	role:mylog("role_action", {desc = "shopBuy", int1 = id, int2 = count, short1=dataSet.shop, key1 = limitStr})
c5825110   saicom   新增用户商城相关数据
440
441
442
443
  	SendPacket(actionCodes.Store_shopBuyRpc, MsgPack.pack({reward = reward}))
  	return true
  end
  
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
444
  function _M.getFreeChestRpc(agent, data)
3e20f499   saicom   完善商城相关协议
445
446
447
448
449
450
451
  	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   活动免费礼包判断活动是否开启
452
453
454
455
456
457
458
  	--判断是否是活动商品
  	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   完善商城相关协议
459
460
461
462
463
      local rechargeRecord = role.storeData:getProperty("payR")
  	local getCount = (rechargeRecord[id] or 0)
  	if getCount >= config.limit then
  		return 1
  	end
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
464
  	local reward, _ = role:award(config.itemFirst, {log = {desc = "freeGift", int1 = id}})
3e20f499   saicom   完善商城相关协议
465
466
467
468
  
  	rechargeRecord[id] = getCount + 1
  	role.storeData:updateProperty({field = "payR", value = rechargeRecord})
  
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
469
  	SendPacket(actionCodes.Store_getFreeChestRpc, MsgPack.pack({reward = reward}))
317a46a9   liuzujun   添加特权卡
470
  	return true
3e20f499   saicom   完善商城相关协议
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
  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   添加特权卡
506
  	return true
3e20f499   saicom   完善商城相关协议
507
508
  end
  
51d9d20b   liuzujun   付费签到,应用市场反馈
509
  -- 赛季卡
3e20f499   saicom   完善商城相关协议
510
511
512
513
514
515
516
517
518
  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   月卡赛季卡发送邮件奖励
519
      local battleCardFlag = role.storeData:getProperty("battleCard")
3e20f499   saicom   完善商城相关协议
520
521
522
523
524
525
526
527
528
529
530
  	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   月卡赛季卡发送邮件奖励
531
  	if battleCardFlag == 1 and limitFlag == "1" then
3e20f499   saicom   完善商城相关协议
532
533
534
  		return 1
  	end
  
fb3d084d   liuzujun   月卡赛季卡发送邮件奖励
535
  	if role:getProperty("battlePoint") < config.point then
1a0b3c56   liuzujun   抽卡保底,切换定向卡池
536
537
538
539
  		skynet.error(string.format("user do not have enough battle point, user_id:%d", role:getProperty("id")))
  		return 1
  	end
  
3e20f499   saicom   完善商城相关协议
540
541
542
543
544
545
546
547
  	local gift = ""
  	if  freeFlag == "0" then
  		gift = config.giftFree
  
  		battleCardFreeRecord = string.setbit(battleCardFreeRecord, id)
  		role.storeData:updateProperty({field = "battleFR", value = battleCardFreeRecord})
  	end
  
fb3d084d   liuzujun   月卡赛季卡发送邮件奖励
548
  	if battleCardFlag == 1 and limitFlag == "0" then
3e20f499   saicom   完善商城相关协议
549
550
551
552
553
554
  		if gift ~= "" then
  			gift = gift .. " "
  		end
  		gift = gift .. config.giftLimit
  
  		battleCardLimitRecord = string.setbit(battleCardLimitRecord, id)
fb3d084d   liuzujun   月卡赛季卡发送邮件奖励
555
  		role.storeData:updateProperty({field = "battleLR", value = battleCardLimitRecord})
3e20f499   saicom   完善商城相关协议
556
557
558
559
560
  	end
  	
  	local reward, _ = role:award(gift, {log = {desc = "battleCard", int1 = id}})
  
  	SendPacket(actionCodes.Store_getBattlePassRewardRpc, MsgPack.pack({reward = reward}))
317a46a9   liuzujun   添加特权卡
561
  	return true
3e20f499   saicom   完善商城相关协议
562
563
  end
  
51d9d20b   liuzujun   付费签到,应用市场反馈
564
565
566
567
568
569
570
  -- 探索指令奖励
  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   付费签到,抽卡阶段奖励,探索指令
571
  	local tab_name = "reward_levelpass" .. id .. "Csv"
e52c384f   liuzujun   探索指令bug, 充值返利活动
572
  	local config = csvdb[tab_name][subId]
51d9d20b   liuzujun   付费签到,应用市场反馈
573
574
  	if not config then return end
  
c99f08df   liuzujun   探索指令调试完成
575
  	local bpInfo = role.storeData:getProperty("bpInfo") or {}
51d9d20b   liuzujun   付费签到,应用市场反馈
576
577
  	local info = bpInfo[id] or {}
  	local flag = info["flag"] or 0
c99f08df   liuzujun   探索指令调试完成
578
  	--if flag == 0 then return 1 end
51d9d20b   liuzujun   付费签到,应用市场反馈
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
  
  	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
  
84cbc53e   zhangqijia   fix: 探索指令,奖励领取解锁条...
595
596
597
598
599
600
601
602
603
  	for k, level in pairs(config.level:toNumMap()) do
  		if k == 1 then
  			if not role:checkHangPass(level) then
  				return 4
  			end
  		elseif k == 2 then
  			if not role:checkAdvChapterPass(level) then
  				return 4
  			end
eb1f9a32   zhangqijia   fix: 探索指令,最终章的5个章...
604
  		end
51d9d20b   liuzujun   付费签到,应用市场反馈
605
606
607
608
609
610
  	end
  
  	local gift = ""
  	if  freeFlag == "0" then
  		gift = config.giftFree
  
c99f08df   liuzujun   探索指令调试完成
611
  		freeRecord = string.setbit(freeRecord, subId)
51d9d20b   liuzujun   付费签到,应用市场反馈
612
613
614
615
616
617
618
619
620
  		info["fr"] = freeRecord
  	end
  
  	if flag == 1 and limitFlag == "0" then
  		if gift ~= "" then
  			gift = gift .. " "
  		end
  		gift = gift .. config.giftLimit
  
c99f08df   liuzujun   探索指令调试完成
621
  		buyRecord = string.setbit(buyRecord, subId)
51d9d20b   liuzujun   付费签到,应用市场反馈
622
623
624
  		info["br"] = buyRecord
  	end
  
c99f08df   liuzujun   探索指令调试完成
625
626
  	bpInfo[id] = info
  	role.storeData:updateProperty({field = "bpInfo", value = bpInfo})
51d9d20b   liuzujun   付费签到,应用市场反馈
627
628
629
630
631
632
633
  	
  	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   多队挂机任务取消功能,累充奖励
634
635
636
637
638
  -- 累充奖励
  function _M.getTotalRechargeAwardRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local index = msg.index		-- 领取的索引id
b8b1c164   liuzujun   扭蛋活动,万能碎片bug
639
  	local totalTwd = role:getProperty("twdC")
4f7cffe5   liuzujun   多队挂机任务取消功能,累充奖励
640
641
  	local totalRechargeRecord = role.storeData:getProperty("totalRR")
  	local flag = string.char(string.getbit(totalRechargeRecord, index))
b8b1c164   liuzujun   扭蛋活动,万能碎片bug
642
  	if flag == "1" then return 1 end
2bc706ab   liuzujun   兑换活动重置,累充功能
643
  	local cfg = csvdb["activity_payRebateCsv"][index]
4f7cffe5   liuzujun   多队挂机任务取消功能,累充奖励
644
  	if not cfg then return 2 end
2bc706ab   liuzujun   兑换活动重置,累充功能
645
  	if cfg.twd > totalTwd then return 3 end
b8b1c164   liuzujun   扭蛋活动,万能碎片bug
646
647
648
  
  	totalRechargeRecord = string.setbit(totalRechargeRecord, index)
  	role.storeData:updateProperty({field = "totalRR", value = totalRechargeRecord})
2bc706ab   liuzujun   兑换活动重置,累充功能
649
650
651
652
653
  	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   多队挂机任务取消功能,累充奖励
654
  
2bc706ab   liuzujun   兑换活动重置,累充功能
655
656
  	local reward, change = role:award(main, {log = {desc = "totalRecharge", int1 = index}})
  	SendPacket(actionCodes.Store_getTotalRechargeAwardRpc, MsgPack.pack(role:packReward(reward, change)))
4f7cffe5   liuzujun   多队挂机任务取消功能,累充奖励
657
658
659
  	return true
  end
  
c40a6460   zhangqijia   feat: 月卡+特刊
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
  function _M.monthCardRewardRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
      local mcid = msg.mcid
  	local smcid = msg.smcid
  
  	local reward,change = {}, {}
  	--月卡奖励
  	local tmpreward, tmpchange = role.storeData:getMonthCardDailyReward(mcid)
  	if tmpreward then
  		for k, v in pairs(tmpreward) do
  			reward[k] = (reward[k] or 0) + v
  		end
  		if tmpchange then table.insert(change, tmpchange) end
  	end
  
      --特刊奖励
  	tmpreward, tmpchange = role.storeData:getSMonthCardDailyReward(smcid)
  	if tmpreward then
  		for k, v in pairs(tmpreward) do
  			reward[k] = (reward[k] or 0) + v
  		end
  		if tmpchange then table.insert(change, tmpchange) end
  	end
  	SendPacket(actionCodes.Store_monthCardRewardRpc, MsgPack.pack(role:packReward(reward, change)))
  	return true
  end
  
cccc9c70   zhouhaihai   商城
688
  return _M