Blame view

src/actions/StoreAction.lua 11 KB
cccc9c70   zhouhaihai   商城
1
2
  local _M = {}
  
192b96d3   zhouhaihai   重置
3
  local serverId = tonumber(skynet.getenv("servId"))
b6ed652b   zhouhaihai   充值
4
  local md5 = require "md5"
192b96d3   zhouhaihai   重置
5
  
b6ed652b   zhouhaihai   充值
6
7
  -- 入口在正式服关闭  -- mock 充值
  function _M.rechargeRpc(agent , data)
1ecdc048   zhouhaihai   屏蔽充值接口
8
  	if true then return end
cccc9c70   zhouhaihai   商城
9
10
11
12
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local dataSet = csvdb["shop_rechargeCsv"][id]
cccc9c70   zhouhaihai   商城
13
  	if not dataSet then return end
b6ed652b   zhouhaihai   充值
14
15
  	local roleId = role:getProperty("id")
  	
192b96d3   zhouhaihai   重置
16
  	--创建订单号
d705a315   zhouhaihai   充值 整理
17
  	local partnerOrderId = role:getPurchaseOrder(id)
b6ed652b   zhouhaihai   充值
18
  	SendPacket(actionCodes.Store_rechargeRpc, MsgPack.pack({ order = partnerOrderId }))
192b96d3   zhouhaihai   重置
19
  
39bcd7ca   zhouhaihai   LOG
20
  
b6ed652b   zhouhaihai   充值
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
  	-- 测试的 直接发奖励了
  	skynet.timeout(10, function ()
  		role:handlePurchase({
  			order = partnerOrderId,
  			amount = dataSet.rmb,
  			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
  
  
  -- google 充值 入口
  function _M.googleRechargeRpc(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")
192b96d3   zhouhaihai   重置
63
  
192b96d3   zhouhaihai   重置
64
  	role.ignoreHeartbeat = true
b6ed652b   zhouhaihai   充值
65
  	--创建订单号
d705a315   zhouhaihai   充值 整理
66
  	local partnerOrderId = role:getPurchaseOrder(id)
b6ed652b   zhouhaihai   充值
67
68
69
70
  	-- 签名
  	local secret_key = "b7657fa7ccd44c16a35e3f454ac7a075"
  	local need = {
  		out_trade_no = partnerOrderId,
f9f877b1   zhouhaihai   商店
71
  		money = dataSet.rmb * 100,
b6ed652b   zhouhaihai   充值
72
73
  		game_money = dataSet.diamond,
  		product_id = dataSet.productId,
ba84f3c7   zhouhaihai   签名回调地址由客户端上传
74
  		notify_url = msg.notifyUrl
b6ed652b   zhouhaihai   充值
75
76
77
78
  	}
  	local sign = signPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_googleRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
192b96d3   zhouhaihai   重置
79
80
81
  	return true
  end
  
8ae04b5a   zhouhaihai   mycard
82
83
84
85
86
87
88
89
90
91
92
  -- mycard 充值 入口
  function _M.myCardRechargeRpc(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
  	--创建订单号
d705a315   zhouhaihai   充值 整理
93
  	local partnerOrderId = role:getPurchaseOrder(id)
8ae04b5a   zhouhaihai   mycard
94
95
96
97
  	-- 签名
  	local secret_key = "48759e07540f46d9af17ec82669b4272"
  	local need = {
  		out_trade_no = partnerOrderId,
f9f877b1   zhouhaihai   商店
98
  		money = dataSet.rmb * 100,
8ae04b5a   zhouhaihai   mycard
99
  		game_money = dataSet.diamond,
ba84f3c7   zhouhaihai   签名回调地址由客户端上传
100
  		notify_url = msg.notifyUrl
8ae04b5a   zhouhaihai   mycard
101
102
103
  	}
  	local sign = signPms(need, secret_key)
  
e629295d   zhouhaihai   协议
104
  	SendPacket(actionCodes.Store_myCardRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
8ae04b5a   zhouhaihai   mycard
105
106
  	return true
  end
b6ed652b   zhouhaihai   充值
107
  
9e25c63d   zhouhaihai   iospay
108
109
110
111
112
113
114
115
116
117
118
  -- mycard 充值 入口
  function _M.iosRechargeRpc(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
  	--创建订单号
d705a315   zhouhaihai   充值 整理
119
  	local partnerOrderId = role:getPurchaseOrder(id)
9e25c63d   zhouhaihai   iospay
120
121
122
123
  	-- 签名
  	local secret_key = "9647d2efe1074c73b9ac19af4337a70e"
  	local need = {
  		out_trade_no = partnerOrderId,
f9f877b1   zhouhaihai   商店
124
  		money = dataSet.rmb * 100,
9e25c63d   zhouhaihai   iospay
125
  		game_money = dataSet.diamond,
3ab906d5   zhouhaihai   重置项目
126
  		product_id = dataSet.iap_product_id,
ba84f3c7   zhouhaihai   签名回调地址由客户端上传
127
  		notify_url = msg.notifyUrl
9e25c63d   zhouhaihai   iospay
128
129
130
131
132
133
134
  	}
  	local sign = signPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_iosRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
  	return true
  end
  
192b96d3   zhouhaihai   重置
135
136
137
138
139
140
141
142
  function _M.purchaseOrderResult(agent, data)
  	local role = agent.role
  
  	local roleId = role:getProperty("id")
  	local msg = MsgPack.unpack(data)
  
  	role.ignoreHeartbeat = false
  
d705a315   zhouhaihai   充值 整理
143
144
145
146
  	local status = {
  		fail = true,
  		success = true
  	}
192b96d3   zhouhaihai   重置
147
  
d705a315   zhouhaihai   充值 整理
148
149
150
  	local partnerOrderStr = msg.order
  	if partnerOrderStr then
  		role:updatePurchaseOrder(partnerOrderStr, msg.platformOrder, status[msg.status] and msg.status or "unknown")
cccc9c70   zhouhaihai   商城
151
  	end
cccc9c70   zhouhaihai   商城
152
153
154
155
  	return true
  end
  
  
c5825110   saicom   新增用户商城相关数据
156
157
158
159
160
161
162
163
164
  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   限时礼包
165
  	if dataSet.unlock ~= "" then
c72853af   liuzujun   修改每日礼包检测开启bug
166
  		if not role:checkHangPass(tonumber(dataSet.unlock)) then
9ea0c502   liuzujun   限时礼包
167
168
169
170
171
  			skynet.error(string.format("shopBuyRpc,user do not finish hang pass, user_id:%d", role:getProperty("id")))
  			return 1
  		end
  	end
  
3e20f499   saicom   完善商城相关协议
172
173
174
175
176
  	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   新增用户商城相关数据
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
  
  	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   完善商城相关协议
197
  		role.storeData:updateProperty({field = "buyR", value = buyRecord})
c5825110   saicom   新增用户商城相关数据
198
  	end
c5825110   saicom   新增用户商城相关数据
199
200
201
202
203
204
205
206
  	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   循环周活动
207
208
209
  	if dataSet.shop == 1 then
  		role:checkTaskEnter("ShopAll", {count = count})
  	end
c59e058b   zhouhaihai   新一批日志记录
210
211
212
213
214
215
216
217
218
219
220
  	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   自己的日志
221
  	role:mylog("role_action", {desc = desc, int1 = id, int2 = count})
c5825110   saicom   新增用户商城相关数据
222
223
224
225
  	SendPacket(actionCodes.Store_shopBuyRpc, MsgPack.pack({reward = reward}))
  	return true
  end
  
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
226
  function _M.getFreeChestRpc(agent, data)
3e20f499   saicom   完善商城相关协议
227
228
229
230
231
232
233
234
235
236
237
238
  	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
  
      local rechargeRecord = role.storeData:getProperty("payR")
  	local getCount = (rechargeRecord[id] or 0)
  	if getCount >= config.limit then
  		return 1
  	end
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
239
  	local reward, _ = role:award(config.itemFirst, {log = {desc = "freeGift", int1 = id}})
3e20f499   saicom   完善商城相关协议
240
241
242
243
  
  	rechargeRecord[id] = getCount + 1
  	role.storeData:updateProperty({field = "payR", value = rechargeRecord})
  
706b517e   liuzujun   翻倍掉落活动,商城免费宝箱
244
  	SendPacket(actionCodes.Store_getFreeChestRpc, MsgPack.pack({reward = reward}))
317a46a9   liuzujun   添加特权卡
245
  	return true
3e20f499   saicom   完善商城相关协议
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
  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   添加特权卡
281
  	return true
3e20f499   saicom   完善商城相关协议
282
283
  end
  
51d9d20b   liuzujun   付费签到,应用市场反馈
284
  -- 赛季卡
3e20f499   saicom   完善商城相关协议
285
286
287
288
289
290
291
292
293
  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   月卡赛季卡发送邮件奖励
294
      local battleCardFlag = role.storeData:getProperty("battleCard")
3e20f499   saicom   完善商城相关协议
295
296
297
298
299
300
301
302
303
304
305
  	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   月卡赛季卡发送邮件奖励
306
  	if battleCardFlag == 1 and limitFlag == "1" then
3e20f499   saicom   完善商城相关协议
307
308
309
  		return 1
  	end
  
fb3d084d   liuzujun   月卡赛季卡发送邮件奖励
310
  	if role:getProperty("battlePoint") < config.point then
1a0b3c56   liuzujun   抽卡保底,切换定向卡池
311
312
313
314
  		skynet.error(string.format("user do not have enough battle point, user_id:%d", role:getProperty("id")))
  		return 1
  	end
  
3e20f499   saicom   完善商城相关协议
315
316
317
318
319
320
321
322
  	local gift = ""
  	if  freeFlag == "0" then
  		gift = config.giftFree
  
  		battleCardFreeRecord = string.setbit(battleCardFreeRecord, id)
  		role.storeData:updateProperty({field = "battleFR", value = battleCardFreeRecord})
  	end
  
fb3d084d   liuzujun   月卡赛季卡发送邮件奖励
323
  	if battleCardFlag == 1 and limitFlag == "0" then
3e20f499   saicom   完善商城相关协议
324
325
326
327
328
329
  		if gift ~= "" then
  			gift = gift .. " "
  		end
  		gift = gift .. config.giftLimit
  
  		battleCardLimitRecord = string.setbit(battleCardLimitRecord, id)
fb3d084d   liuzujun   月卡赛季卡发送邮件奖励
330
  		role.storeData:updateProperty({field = "battleLR", value = battleCardLimitRecord})
3e20f499   saicom   完善商城相关协议
331
332
333
334
335
  	end
  	
  	local reward, _ = role:award(gift, {log = {desc = "battleCard", int1 = id}})
  
  	SendPacket(actionCodes.Store_getBattlePassRewardRpc, MsgPack.pack({reward = reward}))
317a46a9   liuzujun   添加特权卡
336
  	return true
3e20f499   saicom   完善商城相关协议
337
338
  end
  
51d9d20b   liuzujun   付费签到,应用市场反馈
339
340
341
342
343
344
345
  -- 探索指令奖励
  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   付费签到,抽卡阶段奖励,探索指令
346
  	local tab_name = "reward_levelpass" .. id .. "Csv"
e52c384f   liuzujun   探索指令bug, 充值返利活动
347
  	local config = csvdb[tab_name][subId]
51d9d20b   liuzujun   付费签到,应用市场反馈
348
349
  	if not config then return end
  
c99f08df   liuzujun   探索指令调试完成
350
  	local bpInfo = role.storeData:getProperty("bpInfo") or {}
51d9d20b   liuzujun   付费签到,应用市场反馈
351
352
  	local info = bpInfo[id] or {}
  	local flag = info["flag"] or 0
c99f08df   liuzujun   探索指令调试完成
353
  	--if flag == 0 then return 1 end
51d9d20b   liuzujun   付费签到,应用市场反馈
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
  
  	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   付费签到,抽卡阶段奖励,探索指令
370
  	if not role:checkHangPass(config.level) then
51d9d20b   liuzujun   付费签到,应用市场反馈
371
372
373
374
375
376
377
  		return 4
  	end
  
  	local gift = ""
  	if  freeFlag == "0" then
  		gift = config.giftFree
  
c99f08df   liuzujun   探索指令调试完成
378
  		freeRecord = string.setbit(freeRecord, subId)
51d9d20b   liuzujun   付费签到,应用市场反馈
379
380
381
382
383
384
385
386
387
  		info["fr"] = freeRecord
  	end
  
  	if flag == 1 and limitFlag == "0" then
  		if gift ~= "" then
  			gift = gift .. " "
  		end
  		gift = gift .. config.giftLimit
  
c99f08df   liuzujun   探索指令调试完成
388
  		buyRecord = string.setbit(buyRecord, subId)
51d9d20b   liuzujun   付费签到,应用市场反馈
389
390
391
  		info["br"] = buyRecord
  	end
  
c99f08df   liuzujun   探索指令调试完成
392
393
  	bpInfo[id] = info
  	role.storeData:updateProperty({field = "bpInfo", value = bpInfo})
51d9d20b   liuzujun   付费签到,应用市场反馈
394
395
396
397
398
399
400
  	
  	local reward, _ = role:award(gift, {log = {desc = "exploreCommand", int1 = id, int2 = subId}})
  
  	SendPacket(actionCodes.Store_getExploreCommandRewardRpc, MsgPack.pack({reward = reward}))
  	return true
  end
  
cccc9c70   zhouhaihai   商城
401
  return _M