Merge branch 'cn/develop' into cn/publish/release

熊润斐
2 parents 59b56f33 d933495e
Showing 10 changed files with 145 additions and 49 deletions Show diff stats
config/develop.lua
src/actions/CarAction.lua
src/actions/HangAction.lua
src/actions/HeroAction.lua
src/actions/PvpAction.lua
src/actions/TowerAction.lua
src/models/Daily.lua
src/models/RolePlugin.lua
src/models/RoleTask.lua
src/shared/ModelBaseMysql.lua
 include("basic.lua")
-logd = 1 -- 是否开启日志
+logd = 0 -- 是否开启日志
 thread = 4
 codeurl = "192.168.0.199:9090"
 servId = 1
@@ -220,6 +220,16 @@ function _M.saleRuneRpc(agent, data )
 		for k ,v in pairs(one) do
 			reward[k] = (reward[k] or 0) + v
 		end
+
+		--分解铭文返还强化所需铭文碎片的60%
+		local level = rune:getProperty("level")
+		for i = 1, level do
+			local lvData = csvdb["rune_buildCsv"][i]
+			local cost = lvData.cost:toNumMap()
+			for k, v in pairs(cost) do
+				reward[k] = (reward[k] or 0) + v*0.6
+			end
+		end
 	end
 	role:delRunes(backs, {log = {desc = "saleRune"}})
@@ -127,12 +127,12 @@ local function checkReward(role, isTreasure, carbonId)
 	--挂机得到的宝藏加入到挂机奖励
 	if isTreasure or false == true then
-		local treasureList= role.dailyData:checkTreasureList(hangInfo.carbonId) or {}
+		local treasureList= role.dailyData:checkTreasureList(carbonId or hangInfo.carbonId) or {}
 		if next(treasureList) ~= nil then
 			for id, val in pairs(treasureList) do
 				local award  = val.award:toNumMap()
 				for k,v in pairs(award) do
-					items[k] = (award[k] or 0) + v
+					items[k] = (items[k] or 0) + v
 				end
 			end
 		end
@@ -513,6 +513,17 @@ function _M.quickRpc(agent , data)
 		end
 	end
+	--宝藏加速
+	local treasureList= role.dailyData:quickTreasureList(hangInfo.carbonId, time) or {}
+	if next(treasureList) then
+		for id, val in pairs(treasureList) do
+			local award  = val.award:toNumMap()
+			for k,v in pairs(award) do
+				reward[k] = (reward[k] or 0) + v
+			end
+		end
+	end
+
 	local change
 	reward, change = role:award(reward, {log = {desc = "quickHang", int1 = hangInfo.carbonId}})
 	if reward[ItemId.Gold] then
@@ -865,6 +865,11 @@ function _M.drawHeroRpc(agent, data)
 	local unitPool = csvdb["build_unitCsv"][poolId]
 	if not unitPool then return 7 end
+    -- ssr硬性保底
+    local isSSRup = false
+    if unitPool["rare_"..HeroQuality.SSR] or 0 > 0 then
+        isSSRup = true
+    end
 	-- 开始抽
 	local resultPool = {}
@@ -872,21 +877,38 @@ function _M.drawHeroRpc(agent, data)
 		local condition = {"rare"}
 		local values = {}
+        -- check ssr up
+        if isSSRup then
+            local ssrUpMap = role:getProperty("ssrUp") or {}
+            local ssrFloorCnt = ssrUpMap[poolId] or 0
+            if ssrFloorCnt >= (globalCsv.draw_ssr_guarantee or 40) - 1 then
+                values[1] = HeroQuality.SSR
+                ssrUpMap[poolId] = 0
+            else
+                for idx, field in ipairs(condition) do
+                    if not values[idx] then
+                        local lpool = {}
+                        local curIdx = 1
+                        while unitPool[field .. "_" .. curIdx] do
+                            lpool[curIdx] = {unitPool[field .. "_" .. curIdx]}
+                            curIdx = curIdx + 1
+                        end
+
+                        if next(lpool) then
+                            values[idx] =  math.randWeight(lpool, 1)
+                        end
+                    end
+                end
+                if values[1] == HeroQuality.SSR then
+                    ssrUpMap[poolId] = 0
+                else
+                    ssrUpMap[poolId] = ssrFloorCnt + 1
+                end
+            end
+            role:updateProperty({field="ssrUp", value = ssrUpMap, notNotify = true})
+        end
-		for idx, field in ipairs(condition) do
-			if not values[idx] then
-				local lpool = {}
-				local curIdx = 1
-				while unitPool[field .. "_" .. curIdx] do
-					lpool[curIdx] = {unitPool[field .. "_" .. curIdx]}
-					curIdx = curIdx + 1
-				end
-				if next(lpool) then
-					values[idx] =  math.randWeight(lpool, 1)
-				end
-			end
-		end
 		local weight = 0
 		local up_pool = nil
@@ -1291,7 +1313,11 @@ function _M.changeSparkRpc(agent, data)
 		end
 	end
-	SendPacket(actionCodes.Hero_changeSparkRpc, MsgPack.pack({reward = reward}))
+	local change = {}
+	if next(reward) then
+		reward, change = role:award(reward, {log = {desc = "changeSpark"}})
+	end
+	SendPacket(actionCodes.Hero_changeSparkRpc, MsgPack.pack(role:packReward(reward, change)))
 	return true
 end
@@ -243,6 +243,12 @@ function _M.buyCountRpc(agent, data)
 	local cost = {[ItemId.Jade] = globalCsv.pvp_buy_cost * count}
 	if not role:checkItemEnough(cost) then return 2 end
+
+	--限制每天购买次数
+	local pvpBought = role.dailyData:getProperty("pvpBought")
+	if count + pvpBought > globalCsv["pvp_buy_max"] then return 3 end
+	role.dailyData:updateProperty({field = "pvpBought", value = count + pvpBought})
+
 	role:costItems(cost, {log = {desc = "buyPvpKey"}})
 	role:award({[ItemId.PvpKey] = count}, {log = {desc = "buyPvpKey"}})
@@ -115,7 +115,7 @@ function _M.endBattleRpc(agent, data)
 		curLevel = curLevel + 1
 		reward, change = role:award(rewardStr, {log = {desc = "towerBattle", int1 = id}})
 		if towerType == 0 then
-			role:checkTaskEnter("TowerPass", {level = towerInfo.l})
+			role:checkTaskEnter("TowerPass", {level = towerInfo.l, type = towerType + 1})
 		end
 	end
@@ -100,21 +100,9 @@ function Daily:checkUnlock(treaval)
 	local treasureC = treaval.unlock:toArray(true, "=")
 	local show = false
 	if treasureC[1] == 1 then --通关关卡
-		if  self.owner:checkHangPass(treasureC[2]) then show = true end
+		show = self.owner:checkHangPass(treasureC[2])
 	elseif treasureC[1] == 2 then --通关拾荒章节=x层
-		local chapterId = treasureC[2]
-		local layer = 1
-		local advCsv = csvdb["adv_chapterCsv"][chapterId]
-		if not advCsv then return false end --不存在的章节
-		if math.floor(chapterId / 100) ~= 2 then
-			layer = math.min(layer, advCsv.limitlevel)
-		end
-		local advPass = role:getProperty("advPass")
-		if (advPass[chapterId] or 0) < layer then
-			show = false
-		else
-			show = true
-		end
+		show = role:checkAdvChapterPass(treasureC[2])
 	elseif treasureC[1] == 3 then --拥有指定id的角色时
 		local hero = role:getHeroByID(treasureC[2])
 		if hero then show = true end
@@ -145,6 +133,10 @@ function Daily:checkTreasureExpired(treasureAttr, treasureList)
 				end
 				curInfo = clone(treasureAttr)
 			end
+		elseif curInfo["end_time"] then
+			print("end_time")
+			print(curInfo["end_time"])
+			print(skynet.timex())
 		end
 	else
 		curInfo = clone(treasureAttr)
@@ -247,9 +239,9 @@ function Daily:checkTreasureChapterId(curInfo, treasureList, chapterId)
 	local treasure = nil
 	if not curInfo then
-		print("curInfo is nil")
 		return treasure
 	end
+	local treasureBase = self:getProperty("treasureBase")
 	--开始挖宝关卡ID=挂机关卡ID
 	if chapterId == curInfo.chapter_id then
@@ -261,8 +253,12 @@ function Daily:checkTreasureChapterId(curInfo, treasureList, chapterId)
 				if curInfo.cool_time > 1 then
 					--宝藏冷却时间
 					if not curInfo["expire_time"] then
-						treasure = treasureList[curInfo.id]
-						curInfo["expire_time"] = skynet.timex() + curInfo.cool_time * oneDay
+						if treasureBase >= curInfo["treasure_value"] then
+							treasureBase = treasureBase - curInfo["treasure_value"]
+
+							treasure = treasureList[curInfo.id]
+							curInfo["expire_time"] = skynet.timex() + curInfo.cool_time * oneDay
+						end
 					else
 						--已经领取宝藏 检索宝藏冷却时间
 						if skynet.timex() >= curInfo["expire_time"] then
@@ -270,8 +266,12 @@ function Daily:checkTreasureChapterId(curInfo, treasureList, chapterId)
 						end
 					end
 				else
-					treasure = treasureList[curInfo.id]
-					treasureList[curInfo.id] = nil
+					if treasureBase >= curInfo["treasure_value"] then
+						treasureBase = treasureBase - curInfo["treasure_value"]
+
+						treasure = treasureList[curInfo.id]
+						treasureList[curInfo.id] = nil
+					end
 				end
 			end
 		end
@@ -282,8 +282,13 @@ function Daily:checkTreasureChapterId(curInfo, treasureList, chapterId)
 				if curInfo.cool_time > 1 then
 					--宝藏冷却时间
 					if not curInfo["expire_time"] then
-						treasure = treasureList[curInfo.id]
-						curInfo["expire_time"] = skynet.timex() + curInfo.cool_time * oneDay
+						if treasureBase >= curInfo["treasure_value"] then
+							treasureBase = treasureBase - curInfo["treasure_value"]
+
+							treasure = treasureList[curInfo.id]
+							curInfo["expire_time"] = skynet.timex() + curInfo.cool_time * oneDay
+						end
+						
 					else
 						--已经领取宝藏 检索宝藏冷却时间
 						if skynet.timex() >= curInfo["expire_time"] then
@@ -291,8 +296,12 @@ function Daily:checkTreasureChapterId(curInfo, treasureList, chapterId)
 						end
 					end
 				else
-					treasure = treasureList[curInfo.id]
-					treasureList[curInfo.id] = nil
+					if treasureBase >= curInfo["treasure_value"] then
+						treasureBase = treasureBase - curInfo["treasure_value"]
+
+						treasure = treasureList[curInfo.id]
+						treasureList[curInfo.id] = nil
+					end
 				end
 			else
 				curInfo["end_time"]	= nil
@@ -306,12 +315,9 @@ function Daily:buyTreasure(treasureList)
 	local boughtTreasurer = {}
 	local treasureBase = self:getProperty("treasureBase")
 	for id, val in pairs(treasureList) do
-		treasureBase = treasureBase - val.treasure_value
-		if treasureBase < 0 then
-			treasureBase = treasureBase + val.treasure_value
-			return
-		else
+		if treasureBase >= val.treasure_value then
 			boughtTreasurer[id] = val
+			treasureBase = treasureBase - val.treasure_value
 		end
 	end
 	self:updateProperty({field = "treasureBase", value = treasureBase})
@@ -366,6 +372,20 @@ function Daily:checkTreasureList(chapterId)
 	return boughtTreasurer
 end
+--宝藏加速
+function Daily:quickTreasureList(chapterId, time)
+	local treasureList = self:getProperty("treasureList") or {}
+	if next(treasureList) then
+		for id, val in pairs(treasureList) do
+			if val["end_time"] and val["chapter_id"] and chapterId == val["chapter_id"] then
+				val["end_time"] = val["end_time"] - time
+			end
+		end
+	end
+	self:updateProperty({field = "treasureList", value = treasureList})
+	return self:checkTreasureList(chapterId)
+end
+
 function Daily:data()
 	return {
 		hangQC = self:getProperty("hangQC"),
@@ -1304,10 +1304,20 @@ function RolePlugin.bind(Role)
 	function Role:advChapterIsOpen(chapterId)
 		local chapterData = csvdb["adv_chapterCsv"][chapterId]
-		if chapterData.prepose ~= 0 and not self:checkHangPass(chapterData.prepose) then return false end
+		if chapterData.prepose == "" then return true end
+		local prepose = chapterData.prepose:toArray(true,"=")
+		if prepose[1] == 1 then
+			if chapterData.prepose ~= 0 and not self:checkHangPass(prepose[2]) then return false end
+		elseif prepose[1] == 2 then
+			return self:checkAdvChapterPass(prepose[2])
+		elseif prepose[1] == 3 then
+			return self:checkOverGuide(prepose[2])
+		end
 		return true
 	end
+
+
 	function Role:advEventOpenStatus()
 		local openStatus = {}
 		for func , data in pairs(csvdb["unlockCsv"]) do
@@ -2038,6 +2048,13 @@ function RolePlugin.bind(Role)
 		return (hangPass[diff] or 0) >= carbonId
 	end
+	function Role:checkAdvChapterPass(chapterId)
+		local chapterData = csvdb["adv_chapterCsv"][chapterId]
+		local advPass = self:getProperty("advPass") or {}
+		local pass = advPass[chapterId] or 0
+		return pass >= chapterData.limitlevel
+	end
+
 	function Role:hangFinish(carbonId)
 		local hangPass = self:getProperty("hangPass")
 		local diff = math.floor(carbonId / 10000)
@@ -194,7 +194,7 @@ local AchievListener = {
 		[TaskType.OverOderTask] = {{14}},
 		[TaskType.FoodSellGold] = {{15, f("count")}},
 		[TaskType.DinerPopular] = {{16, f("count")}},
-		[TaskType.TowerPass] = {{17, f("level")}},
+		[TaskType.TowerPass] = {{17, f("level"), f("type")}},
 		[TaskType.OpenBox] = {{18, f("count")}},
 		[TaskType.DinerLevelUp] = {{19, f("level"), f("type")}},
 		[TaskType.DinerTalentUp] = {{20, 1, f("type")}},
@@ -289,7 +289,7 @@ local CalendaTaskListener = {
 		[TaskType.PvpWin]= {{10, 2, f("score")}},
 		[TaskType.DinerPopular]= {{11, 2, f("count")}},
 		[TaskType.RoleLevelUp]= {{12, 2, f("level")}},
-		[TaskType.TowerPass]= {{13, 2, f("level")}},
+		[TaskType.TowerPass]= {{13, 3, f("level"), f("type")}},
 		[TaskType.HeroTalent]= {{14, 1}},
 		[TaskType.HangPass]= {{15, 3}},
 		[TaskType.HeroStarCollect]= {{16, 3}},
@@ -809,6 +809,10 @@ function RoleTask.bind(Role)
 								if cfg.condition2 == param1 then
 									calTask[id] = (calTask[id] or 0) + 1
 								end
+							elseif cfg.type == 13 then	-- 挑战电波塔主塔
+								if cfg.condition2 == param1 and param2 == 1 then
+									calTask[id] = (calTask[id] or 0) + 1
+								end
 							end
 						end
 					end
@@ -485,6 +485,8 @@ function ModelBaseMysql:updateFields(fields)
             if next(value) then 
                 local result = mysqlproxy:quote_sql_str(MsgPack.pack(value))
                 params[field] = result
+            else
+                params[field] = mysqlproxy:quote_sql_str(MsgPack.pack({}))
             end
         elseif self.class.schema[field][1] == "string" then
             local result = mysqlproxy:quote_sql_str(value)