Blame view

src/actions/StoreAction.lua 6.93 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
8
9
10
11
12
13
14
15
16
17
18
19
  local function makeOrder(roleId, rechargeId)
  	local orderId = redisproxy:hincrby("autoincrement_set", "order", 1)
  	local partnerOrderId = string.format("%d_%d_%d", serverId, roleId, orderId)
  	local orderKey = string.format("order:%d:%d", roleId, orderId)
  	redisproxy:del(orderKey)
  	local order = require("models.Order").new({ 
  		key = orderKey, 
  		order = partnerOrderId, 
  		rechargeId = rechargeId, 
  	})
  	order:create()
  	redisproxy:sadd(string.format("role:%d:orders", roleId), partnerOrderId)
  	return partnerOrderId
  end
192b96d3   zhouhaihai   重置
20
  
b6ed652b   zhouhaihai   充值
21
  -- 入口在正式服关闭  -- mock 充值
cccc9c70   zhouhaihai   商城
22
23
24
  function _M.rechargeRpc(agent , data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
3e513948   zhouhaihai   不能充值
25
  	if true then return end
cccc9c70   zhouhaihai   商城
26
27
28
  	local id = msg.id
  	local dataSet = csvdb["shop_rechargeCsv"][id]
  	if not dataSet then return end
b6ed652b   zhouhaihai   充值
29
30
  	local roleId = role:getProperty("id")
  	
192b96d3   zhouhaihai   重置
31
  	--创建订单号
b6ed652b   zhouhaihai   充值
32
33
  	local partnerOrderId = makeOrder(roleId, id)
  	SendPacket(actionCodes.Store_rechargeRpc, MsgPack.pack({ order = partnerOrderId }))
cccc9c70   zhouhaihai   商城
34
  
b6ed652b   zhouhaihai   充值
35
36
37
38
39
40
41
42
43
44
45
  	-- 测试的 直接发奖励了
  	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)
cccc9c70   zhouhaihai   商城
46
  	
b6ed652b   zhouhaihai   充值
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
  	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   重置
77
  
192b96d3   zhouhaihai   重置
78
  	role.ignoreHeartbeat = true
b6ed652b   zhouhaihai   充值
79
80
81
82
83
84
85
86
87
88
89
90
91
  	--创建订单号
  	local partnerOrderId = makeOrder(roleId, id)
  	-- 签名
  	local secret_key = "b7657fa7ccd44c16a35e3f454ac7a075"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb,
  		game_money = dataSet.diamond,
  		product_id = dataSet.productId,
  	}
  	local sign = signPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_googleRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
192b96d3   zhouhaihai   重置
92
93
94
  	return true
  end
  
8ae04b5a   zhouhaihai   mycard
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
  -- 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
  	--创建订单号
  	local partnerOrderId = makeOrder(roleId, id)
  	-- 签名
  	local secret_key = "48759e07540f46d9af17ec82669b4272"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb,
  		game_money = dataSet.diamond,
  	}
  	local sign = signPms(need, secret_key)
  
e629295d   zhouhaihai   协议
116
  	SendPacket(actionCodes.Store_myCardRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
8ae04b5a   zhouhaihai   mycard
117
118
  	return true
  end
b6ed652b   zhouhaihai   充值
119
  
9e25c63d   zhouhaihai   iospay
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
  -- 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
  	--创建订单号
  	local partnerOrderId = makeOrder(roleId, id)
  	-- 签名
  	local secret_key = "9647d2efe1074c73b9ac19af4337a70e"
  	local need = {
  		out_trade_no = partnerOrderId,
  		money = dataSet.rmb,
  		game_money = dataSet.diamond,
  		product_id = dataSet.productId,
  	}
  	local sign = signPms(need, secret_key)
  
  	SendPacket(actionCodes.Store_iosRechargeRpc, MsgPack.pack({ order = partnerOrderId, sign = sign}))
  	return true
  end
  
192b96d3   zhouhaihai   重置
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
  function _M.purchaseOrderResult(agent, data)
  	local role = agent.role
  
  	local roleId = role:getProperty("id")
  	local msg = MsgPack.unpack(data)
  
  	role.ignoreHeartbeat = false
  
  	local partnerOrderStr = msg.order
  	local _, _, orderId = string.match(partnerOrderStr, "(.+)_(.+)_(.+)")
  	local orderObject = require("models.Order").new({ key = string.format("order:%d:%d", roleId, orderId) })
  	if not orderObject:load() then
  		-- 订单不存在
  		skynet.error("cancelPurchaseRpc", string.format("order %s not exist", partnerOrderStr))
  		return true
  	end
  
  	if msg.status == "success" then
  		orderObject:setProperty("transactionId", msg.platformOrder or "")
  		return true
  	end
  
  	if orderObject:getProperty("finishTime") > 0 then
  		return true
cccc9c70   zhouhaihai   商城
170
171
  	end
  
192b96d3   zhouhaihai   重置
172
  	orderObject:setProperty("status", msg.status)
3133cb76   zhouhaihai   日志
173
  
192b96d3   zhouhaihai   重置
174
  	redisproxy:srem(string.format("role:%d:orders", roleId), partnerOrderStr)
cccc9c70   zhouhaihai   商城
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
  	return true
  end
  
  
  function _M.dailyBuyRpc(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_diamondCsv"][id]
  	if not dataSet then return 1 end
  
  	local dailySDC = role.dailyData:getProperty("dailySDC")
  
  	if math.illegalNum(count, 1, (dataSet.limit == 0 and math.huge or dataSet.limit - (dailySDC[id] or 0))) then return 1 end
  
  	local cost = dataSet.cost
2ab0d91b   zhouhaihai   每日商店删掉 type [王宇杰]
193
194
195
196
  
  	local dailySDD = role.dailyData:getProperty("dailySDD")
  	if dailySDD[id] then -- 折扣
  		cost = math.ceil(cost * (1 - dataSet.disount / 100))
cccc9c70   zhouhaihai   商城
197
198
  	end
  
b216676d   zhouhaihai   log
199
  	if not role:costDiamond({count = cost * count, log = {desc = "dailyShop", int1 = id, int2 = count}}) then
cccc9c70   zhouhaihai   商城
200
201
202
203
204
205
206
  		return 4 
  	end
  
  	if dataSet.limit ~= 0 then
  		dailySDC[id] = (dailySDC[id] or 0) + count
  		role.dailyData:updateProperty({field = "dailySDC", value = dailySDC})
  	end
aa5cbb54   zhouhaihai   商店bug
207
208
209
210
211
  	local gift = {}
  	for itemId, count_ in pairs(dataSet.gift:toNumMap()) do
  		gift[itemId] = count_ * count
  	end
  	local reward = role:award(gift, {log = {desc = "dailyShop", int1 = id, int2 = count}})
3133cb76   zhouhaihai   日志
212
213
  
  	role:log("role_action", {desc = "dailyShop", int1 = id, int2 = count})
cccc9c70   zhouhaihai   商城
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
  
  	SendPacket(actionCodes.Store_dailyBuyRpc, MsgPack.pack({reward = reward}))
  	return true
  end
  
  
  function _M.dinerBuyRpc(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_dinerCsv"][id]
  	if not dataSet then return end
  
  	local dinerS = role:getProperty("dinerS")
  	if math.illegalNum(count, 1, (dataSet.limit == 0 and math.huge or dataSet.limit - (dinerS[id] or 0))) then return 1 end
  
  	local cost = {[ItemId.DinerCoin] = dataSet.cost}
  	if not role:checkItemEnough(cost) then return end
  
  	if dataSet.limit ~= 0 then
  		dinerS[id] = (dinerS[id] or 0) + count
  		role:updateProperty({field = "dinerS", value = dinerS})
  	end
  
3133cb76   zhouhaihai   日志
240
  	role:costItems(cost, {log = {desc = "dinerShop", int1 = id, int2 = count}})
cccc9c70   zhouhaihai   商城
241
242
243
244
245
  
  	local gift = {}
  	for _id, _count in pairs(dataSet.gift:toNumMap()) do
  		gift[_id] = _count * count
  	end
3133cb76   zhouhaihai   日志
246
247
248
  	local reward = role:award(gift, {log = {desc = "dinerShop", int1 = id, int2 = count}})
  	
  	role:log("role_action", {desc = "dinerShop", int1 = id, int2 = count})
cccc9c70   zhouhaihai   商城
249
250
251
252
253
254
  
  	SendPacket(actionCodes.Store_dinerBuyRpc, MsgPack.pack({reward = reward}))
  	return true
  end
  
  return _M