Merge branch 'tr/develop' into cn/develop

chenyueqi
2 parents 34b196c0 d9d63fa0
Showing 5 changed files with 143 additions and 13 deletions Show diff stats
src/actions/ActivityAction.lua
src/actions/StoreAction.lua
src/models/Order.lua
src/models/RolePlugin.lua
src/services/globald.lua
@@ -140,6 +140,13 @@ function _M.signRpc(agent, data)
 	role:changeUpdates({{type = "sign", field = curDay, value = yearMonth}})
 	role:checkTaskEnter("SignIn")
+	if monthData[curDay].daily_sign_email ~= "" then
+		local emails = monthData[curDay].daily_sign_email:toArray(true,"=")
+		for _, emailId in pairs(emails) do
+			redisproxy:insertEmail({roleId = role:getProperty("id"), emailId = emailId})
+		end
+	end
+
 	SendPacket(actionCodes.Activity_signRpc, MsgPack.pack(role:packReward(reward, change)))
 	return true
 end
@@ -7,12 +7,13 @@ function _M.rechargeRpc(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")
 	--创建订单号
-	local partnerOrderId = role:getPurchaseOrder(id)
+	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
 	if partnerOrderId == "" then
 		return 1
 	end
@@ -161,13 +162,14 @@ function _M.googleRechargeRpc(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)
+	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
 	-- 签名
 	-- local secret_key = "b7657fa7ccd44c16a35e3f454ac7a075"
 	local secret_key = "8920e9dcf0cb4ebca87393ce48021ead"
@@ -189,13 +191,14 @@ function _M.myCardRechargeRpc(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)
+	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
 	-- 签名
 	local secret_key = "48759e07540f46d9af17ec82669b4272"
 	local need = {
@@ -215,13 +218,14 @@ function _M.iosRechargeRpc(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)
+	local partnerOrderId = role:getPurchaseOrder(id,nil,choose)
 	-- 签名
 	local secret_key = "1916d62251dd4a8aa5e452121eefc9a1"
 	local need = {
@@ -13,6 +13,7 @@ Order.schema = {
     finishTime 	= {"number", 0},	-- 服务端验证完成时间
     status 		= {"string", "create"},
     sid 		= {"number",0}, 	-- 创建单号的设备的sid
+    choose 		= {"string", ""}, -- 自选奖励
 }
 Order.fields = {
@@ -23,6 +24,7 @@ Order.fields = {
 	finishTime = true,
 	status = true,
 	sid = true,
+	choose = true,
 }
 return Order
 \ No newline at end of file
@@ -1349,8 +1349,7 @@ function RolePlugin.bind(Role)
 			local donate = seaport.donate or {}
 			if not reset and (not donate[1] or not donate[2]) then
 				local result = self:getSeaportServerProgress()
-				local seaportCsv = csvdb["seaport_purchaseCsv"]
-				for idx, set in ipairs(seaportCsv) do
+				for idx, set in ipairs(csvdb["seaport_purchaseCsv"]) do
 					local done = true
 					for id, data in ipairs(set) do
 						if donate[id] or not result[idx] or not result[idx][id] or result[idx][id] < data.need_num then
@@ -1360,7 +1359,12 @@ function RolePlugin.bind(Role)
 					end
 					if done then
 						update = true
-						self:award(set[1].phase_award, {log = {desc = "seaportReward", int1 = set[1].phase, int2 = set[1].id}})
+						redisproxy:insertEmail({
+							roleId = self:getProperty("id"),
+							emailId = idx == 1 and 361 or 362,
+							attachments = set[1].phase_award,
+						})
+						-- self:award(set[1].phase_award, {log = {desc = "seaportReward", int1 = set[1].phase, int2 = set[1].id}})
 						donate[idx] = 1
 					end
 				end
@@ -1397,6 +1401,8 @@ function RolePlugin.bind(Role)
 				local expCarbonId = self:getProperty("hangInfo").expCarbonId
 				local taskCsv = csvdb["seaport_taskCsv"]
 				local endTime = openTime0 + 86400 * 2
+				local reward = {}
+
 				for slot, set in pairs(taskCsv) do
 					if collect[slot] then
 						update = true
@@ -1433,9 +1439,28 @@ function RolePlugin.bind(Role)
 						            itemReward[key] = math.ceil(1.5 * value)
 						        end
 						    end
-							self:award(itemReward, {log = {desc = "seaportTask", int1 = slot, int2 = level}})
+
+						    for itemId, value in pairs(itemReward) do
+						    	reward[itemId] = (reward[itemId] or 0) + value
+						    end
+							-- self:award(itemReward, {log = {desc = "seaportTask", int1 = slot, int2 = level}})
+						end
+					end
+				end
+
+				if next(reward) then
+					local rewardStr = ""
+					for itemId, value in pairs(reward) do
+						if rewardStr ~= "" then
+							rewardStr = rewardStr .. " "
 						end
+						rewardStr = rewardStr .. string.format("%s=%s",itemId,value)
 					end
+					redisproxy:insertEmail({
+						roleId = self:getProperty("id"),
+						emailId = 363,
+						attachments = rewardStr,
+					})
 				end
 			end
 			seaport.collect = {}
@@ -2022,7 +2047,7 @@ function RolePlugin.bind(Role)
 					return "error money"
 				end
 				-- 发现需要的id
-				local partnerOrderId = self:getPurchaseOrder(k, params.transactionId)
+				local partnerOrderId = self:getPurchaseOrder(k, params.transactionId, params.choose)
 				if partnerOrderId == "" then
 					return "no product"
 				end
@@ -2032,7 +2057,7 @@ function RolePlugin.bind(Role)
 	end
 	-- 获取充值订单号
-	function Role:getPurchaseOrder(rechargeId, transactionId)
+	function Role:getPurchaseOrder(rechargeId, transactionId, choose)
 		local roleId = self:getProperty("id")
 		local rechargeData = csvdb["shop_rechargeCsv"][rechargeId]
 		if not rechargeData then
@@ -2044,7 +2069,24 @@ function RolePlugin.bind(Role)
 	    if limit ~= 0 and limit <= (rechargeRecord[rechargeId] or 0) then
 	        return ""
 		end
-		
+		-- 检查礼包自选奖励合法
+		if choose and choose ~= "" then
+			if rechargeData.itemgift == "" then return "" end
+			local slot = rechargeData.itemdirect or 0
+			local set = choose:toTableArray(true)
+			if slot ~= #set then return "" end
+			local pass = {}
+			local groups = rechargeData.itemgift:toTableArray(true)
+			for idx, item in ipairs(set) do
+				for _, group in ipairs(groups) do
+					if group[2] == item[1] and group[3] == item[2] and idx == group[1] then
+						pass[group[1]] = 1
+						break
+					end
+				end
+			end
+			if #pass ~= slot then return "" end
+		end
 		--判断是否是活动商品
 		if rechargeData.activity_id ~= 0 then
 			local actCfg = csvdb["activity_ctrlCsv"][rechargeData.activity_id]
@@ -2071,6 +2113,7 @@ function RolePlugin.bind(Role)
 			createTime = skynet.timex(),
 			transactionId = transactionId,
 			sid = self:getProperty("sid"),
+			choose = choose or "",
 		})
 		order:create()
 		-- 正在进行中的订单 缓存
@@ -2139,7 +2182,7 @@ function RolePlugin.bind(Role)
 			})
 		end
-		return true, rechargeId, sid
+		return true, rechargeId, sid, orderObject:getProperty("choose")
 	end
 	-- 充值 --
@@ -2157,7 +2200,7 @@ function RolePlugin.bind(Role)
 		local roleId = self:getProperty("id")
 		local partnerOrderStr = params.order
-		local status, back, sid = self:updatePurchaseOrder(partnerOrderStr, params.transactionId, "finsh")
+		local status, back, sid, choose = self:updatePurchaseOrder(partnerOrderStr, params.transactionId, "finsh")
 		if not status then
 			if back == "finsh" then
 				-- 订单已经处理
@@ -2180,6 +2223,7 @@ function RolePlugin.bind(Role)
 			pay_time = params.pay_time,
 			order = partnerOrderStr,
 			sid = sid,
+			choose = choose,
 		})
 		if not status then
@@ -2227,6 +2271,17 @@ function RolePlugin.bind(Role)
 			return 3
 		end
+		-- 自选奖励部分
+		if params.choose and params.choose ~= "" then
+			local tReward, tChange = self:award(params.choose, {log = {desc = "recharge", int1 = id}})
+			for itemId, value in pairs(tReward) do
+				reward[itemId] = (reward[itemId] or 0) + value
+			end
+			for itemId, value in pairs(tChange or {}) do
+				reward[itemId] = (reward[itemId] or 0) + value
+			end
+		end
+
 		if diamondCount > 0 then
 			reward[ItemId.Diamond] = (reward[ItemId.Diamond] or 0) + diamondCount
 		end
@@ -184,6 +184,67 @@ local function check_trade_seaport_status()
 	skynet.timeout(interval, check_trade_seaport_status)
 end
+-- @desc: 海港贸易捐赠作弊
+local seaportTimes = {}
+local function check_trade_seaport_donate()
+	local time1 = tonumber(redisproxy:hget("autoincrement_set", "seaportTime1")) or 0
+	local time2 = tonumber(redisproxy:hget("autoincrement_set", "seaportTime2")) or 0
+	if time1 == 0 and time2 == 0 then
+		seaportTimes = {}
+		skynet.timeout(360000, check_trade_seaport_donate)
+		return
+	end
+
+	local csvdb = require "shared.csvdata"
+	local donateCsv = csvdb["seaport_purchaseCsv"]
+
+	local times = {time1, time2}
+	for phase, open in ipairs(times) do
+		if open == 1 and not seaportTimes[phase] then
+			seaportTimes[phase] = {}
+			for _, _ in ipairs(donateCsv[phase]) do
+				table.insert(seaportTimes[phase],math.randomInt(1800, 3600))
+			end
+		end
+	end
+
+	local interval = 3600
+	local phase, id = 0, 0
+
+	for key1, data in ipairs(seaportTimes) do
+		for key2, temp in pairs(data) do
+			if times[key1] == 1 and temp < interval then
+				interval = temp
+				phase = key1
+				id = key2
+			end
+		end
+	end
+
+	for _, data in ipairs(seaportTimes) do
+		for id, temp in pairs(data) do
+			data[id] = temp - interval
+			if data[id] == 0 then
+				data[id] = math.randomInt(1800, 3600)
+			end
+		end
+	end
+
+	if phase ~= 0 and id ~= 0 then
+		local redisKeys = {SEAPORT_TRADE_TASK_1,SEAPORT_TRADE_TASK_2}
+		local all = donateCsv[phase][id].need_num
+		local old = tonumber(redisproxy:hget(redisKeys[phase],id)) or 0
+		local add = math.min(math.randomInt(math.floor(all/20),math.floor(all/12)),all - old)
+		if add > 0 then
+			redisproxy:hincrby(redisKeys[phase],id,add)
+		else
+			seaportTimes[phase][id] = nil
+		end
+	end
+
+	skynet.timeout(interval * 100, check_trade_seaport_donate)
+end
+
 local CMD = {}
@@ -208,6 +269,7 @@ function CMD.start()
 	check_mail_queue()
 	--check_battle_act_close()
 	check_trade_seaport_status()
+	check_trade_seaport_donate()
 end
 local function __init__()