Blame view

src/actions/StoreAction.lua 5.53 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
22
  -- 入口在正式服关闭  -- mock 充值
  function _M.rechargeRpc(agent , data)
cccc9c70   zhouhaihai   商城
23
24
25
26
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local dataSet = csvdb["shop_rechargeCsv"][id]
cccc9c70   zhouhaihai   商城
27
  	if not dataSet then return end
b6ed652b   zhouhaihai   充值
28
29
  	local roleId = role:getProperty("id")
  	
192b96d3   zhouhaihai   重置
30
  	--创建订单号
b6ed652b   zhouhaihai   充值
31
32
  	local partnerOrderId = makeOrder(roleId, id)
  	SendPacket(actionCodes.Store_rechargeRpc, MsgPack.pack({ order = partnerOrderId }))
192b96d3   zhouhaihai   重置
33
  
b6ed652b   zhouhaihai   充值
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
  	-- 测试的 直接发奖励了
  	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   重置
76
  
192b96d3   zhouhaihai   重置
77
  	role.ignoreHeartbeat = true
b6ed652b   zhouhaihai   充值
78
79
80
81
82
83
84
85
86
87
88
89
90
  	--创建订单号
  	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   重置
91
92
93
  	return true
  end
  
b6ed652b   zhouhaihai   充值
94
  
192b96d3   zhouhaihai   重置
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
  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   商城
119
120
  	end
  
192b96d3   zhouhaihai   重置
121
  	orderObject:setProperty("status", msg.status)
3133cb76   zhouhaihai   日志
122
  
192b96d3   zhouhaihai   重置
123
  	redisproxy:srem(string.format("role:%d:orders", roleId), partnerOrderStr)
cccc9c70   zhouhaihai   商城
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
  	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 [王宇杰]
142
143
144
145
  
  	local dailySDD = role.dailyData:getProperty("dailySDD")
  	if dailySDD[id] then -- 折扣
  		cost = math.ceil(cost * (1 - dataSet.disount / 100))
cccc9c70   zhouhaihai   商城
146
147
  	end
  
b216676d   zhouhaihai   log
148
  	if not role:costDiamond({count = cost * count, log = {desc = "dailyShop", int1 = id, int2 = count}}) then
cccc9c70   zhouhaihai   商城
149
150
151
152
153
154
155
  		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
156
157
158
159
160
  	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   日志
161
162
  
  	role:log("role_action", {desc = "dailyShop", int1 = id, int2 = count})
cccc9c70   zhouhaihai   商城
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
  
  	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   日志
189
  	role:costItems(cost, {log = {desc = "dinerShop", int1 = id, int2 = count}})
cccc9c70   zhouhaihai   商城
190
191
192
193
194
  
  	local gift = {}
  	for _id, _count in pairs(dataSet.gift:toNumMap()) do
  		gift[_id] = _count * count
  	end
3133cb76   zhouhaihai   日志
195
196
197
  	local reward = role:award(gift, {log = {desc = "dinerShop", int1 = id, int2 = count}})
  	
  	role:log("role_action", {desc = "dinerShop", int1 = id, int2 = count})
cccc9c70   zhouhaihai   商城
198
199
200
201
202
203
  
  	SendPacket(actionCodes.Store_dinerBuyRpc, MsgPack.pack({reward = reward}))
  	return true
  end
  
  return _M