Merge branch 'develop' of 120.26.43.151:wasteland/server into develop

liuzujun
2 parents 56c7a1c5 5bd12066
Showing 11 changed files with 302 additions and 39 deletions Show diff stats
config/develop.lua
src/ProtocolCode.lua
src/actions/HangAction.lua
src/actions/HeroAction.lua
src/actions/PvpAction.lua
src/actions/StoreAction.lua
src/actions/TowerAction.lua
src/adv/AdvPassive.lua
src/models/Role.lua
src/models/RoleBattle.lua
src/models/RoleLog.lua
@@ -15,3 +15,5 @@ redis_host = &quot;127.0.0.1&quot;
 redis_port = 6100
 redis_db = 1
 redis_auth = nil
+
+pay_url = ""
 \ No newline at end of file
@@ -90,6 +90,7 @@ actionCodes = {
 	Hero_drawHeroRpc = 220,
 	Hero_repayHeroRpc = 221,
 	Hero_unlockPoolRpc = 222,
+	Hero_changeCrown = 223,
 	Hang_startRpc = 251,
 	Hang_checkRpc = 252,
@@ -156,6 +156,17 @@ function _M.startRpc( agent, data )
 	end
 	role:updateProperty({field = "hangInfo", value = hangInfo})
+	-- 指定当前引导的步骤
+	if carbonId == 10101 then
+		role:saveGuide(5,11)
+	elseif carbonId == 10102 then
+		role:saveGuide(8,2)
+	elseif carbonId == 10103 then
+		role:saveGuide(9,2)
+	elseif carbonId == 10220 then
+		role:saveGuide(22,1)
+	end
+
 	SendPacket(actionCodes.Hang_startRpc, '')
 	return true
 end
@@ -209,6 +220,7 @@ function _M.endBattleRpc(agent, data)
 		return true
 	end
 	local carbonId = msg.carbonId
+	local isWin = msg.starNum and msg.starNum > 0
 	local carbonData = csvdb["idle_battleCsv"][carbonId]
 	if not carbonData then
 		return 2
@@ -222,8 +234,9 @@ function _M.endBattleRpc(agent, data)
 	if role:checkHangPass(carbonId) then 
 		return 4
 	end
+
 	local reward, change
-	if msg.starNum and msg.starNum > 0 then --win
+	if isWin then --win
 		role:hangFinish(carbonId)
 		if carbonData.main ~= 1 then
 			hangInfo.bossTime = nil
@@ -239,30 +252,35 @@ function _M.endBattleRpc(agent, data)
 		reward, change = role:award(reward, {log = {desc = "hangBattle", int1 = carbonId}})
 		role:checkTaskEnter("HangPass", {id = carbonId})
+		
+		-- 引导
+		if carbonId == 10101 then
+			role:finishGuide(5)
+		elseif carbonId == 10102 then
+			role:finishGuide(8)
+		elseif carbonId == 10103 then
+			role:finishGuide(9)
+		elseif carbonId == 10220 then
+			role:finishGuide(22)
+		end
+		for _, guideData in pairs(csvdb["guide_unlockCsv"]) do
+			if guideData.type == 3 and guideData.carbonId == carbonId then
+				role:saveGuide(guideData.guideId,1,true)
+				break
+			end
+		end
 	end
 	if hangInfo.carbonId < carbonId then
 		hangInfo.carbonId = carbonId
 	end
 	role:updateProperty({field = "hangInfo", value = hangInfo})
-	local team = role:getProperty("pvpTC")
-
-	-- 引导
-	if carbonId == 10101 then
-		role:finishGuide(5)
-	elseif carbonId == 10102 then
-		role:finishGuide(8)
-	elseif carbonId == 10103 then
-		role:finishGuide(9)
-	elseif carbonId == 10220 then
-		role:finishGuide(22)
-	end
-	for _, guideData in pairs(csvdb["guide_unlockCsv"]) do
-		if guideData.type == 3 and guideData.carbonId == carbonId then
-			role:saveGuide(guideData.guideId,1,true)
-			break
-		end
-	end
+	role:checkBattle("hang", {
+		id = carbonId,
+		isWin = isWin,
+		info = msg.info,
+		reward = reward,
+	})
 	SendPacket(actionCodes.Hang_endBattleRpc, MsgPack.pack({
 		starNum = msg.starNum, 
@@ -532,6 +550,12 @@ function _M.endBonusBattleRpc(agent, data)
  		role:checkTaskEnter("BonusPass", {id = id})
  	end
+ 	role:checkBattle("bonus", {
+		id = id,
+		isWin = starNum and starNum > 0,
+		info = msg.info,
+		reward = reward,
+	})
 	SendPacket(actionCodes.Hang_endBonusBattleRpc, MsgPack.pack({
 		starNum = starNum, 
 		reward = reward,
@@ -453,7 +453,7 @@ function _M.referEquipsRpc(agent, data)
 	local hero = role.heros[msg.id]
 	if not hero then return 10 end
 	local equips = msg.equips
-	local isAuto = msg.isAuth
+	local isAuto = msg.isAuto
 	if not equips or not next(equips) then return 11 end
 	for typ = 1, 4 do -- 4件装备
@@ -807,7 +807,7 @@ function _M.drawHeroRpc(agent, data)
 	role:costItems(cost, {log = {desc = "drawHero", int1 = btype, int2 = poolId}})
 	local guideHero
-	if role:checkOverGuide(11) and not role:checkOverGuide(12) then
+	if role:getProperty("newerGuide") == "11=1" then
 		guideHero = 613
 	end
@@ -941,19 +941,18 @@ function _M.unlockPoolRpc(agent, data)
 	return true
 end
-function _M.changeCrownRpc(agnet, data)
+function _M.changeCrown(agnet, data)
 	local role = agent.role
 	local msg = MsgPack.unpack(data)
 	local heroType = msg.heroType
-	if not role:isHaveHero(heroType) then return end
+	if not role:isHaveHero(heroType) then return true end
 	role:setProperty("crown", heroType)
 	role:log("hero_show", {
 		hero_id = heroType,
 	})
-	SendPacket(actionCodes.Hero_changeCrownRpc, "")
 	return true
 end
@@ -335,11 +335,6 @@ function _M.endBattleRpc(agent, data)
 	local reward, change = role:award({[temp[1]] = temp[2]}, {log = {desc = "pvpBattleC"}})
 	local myScore, matchScore, oldmyScore, oldMatchScore, myRank, oldMyRank = role:changePvpScoreCommon(match.t == 1 and match.id or -1, isWin)
-	_pvpBattleInfoCacheC = {}  --重新发阵容了 没毛病
-	_pvpRecordInfoCacheC = {} -- 记录刷新了
-	_pvpRecordBattleInfoCacheC = {} -- 取新纪录的时候搞
-	_pvpStartBattleCacheC = nil
-
 	-- 请求上传录像
 	local params = {
 		["roleid"] = roleId,
@@ -388,7 +383,22 @@ function _M.endBattleRpc(agent, data)
 	if isWin then
 		role:checkTaskEnter("PvpWin", {score = myScore})
 	end
+
+	role:checkBattle("pvpc", {
+		isWin = isWin,
+		info = msg.info,
+		robotId = match.t == 2 and match.id or nil,
+		enemy = match.t == 1 and _pvpBattleInfoCacheC[match.id] or nil,
+		score = myScore,
+		reward = reward,
+		rank = myRank,
+	})
+	_pvpBattleInfoCacheC = {}  --重新发阵容了 没毛病
+	_pvpRecordInfoCacheC = {} -- 记录刷新了
+	_pvpRecordBattleInfoCacheC = {} -- 取新纪录的时候搞
+	_pvpStartBattleCacheC = nil
+
 	SendPacket(actionCodes.Pvp_endBattleRpc, MsgPack.pack({
 		reward = reward,
 		change = change,
@@ -676,6 +686,17 @@ function _M.endBattleHRpc(agent, data)
 		end
 	end)
+	role:checkBattle("pvph", {
+		isWin = isWin,
+		info = msg.info,
+		robotId = match.t == 2 and match.id or nil,
+		enemy = match.t == 1 and (revenge and _pvpRecordBattleInfoCacheH[match.id] or _pvpBattleInfoCacheH[match.id]) or nil,
+		score = myScore,
+		reward = reward,
+		rank = myRank,
+	})
+
+
 	_pvpBattleInfoCacheH = {}  --重新发阵容了 没毛病
 	_pvpRecordInfoCacheH = {} -- 记录刷新了
 	_pvpRecordBattleInfoCacheH = {} -- 取新纪录的时候搞
@@ -686,7 +707,7 @@ function _M.endBattleHRpc(agent, data)
 	if isWin then
 		role:checkTaskEnter("PvpWin", {score = myScore})
 	end
-	
+
 	SendPacket(actionCodes.Pvp_endBattleHRpc, MsgPack.pack({
 		reward = reward,
 		change = change,
@@ -2,6 +2,7 @@ local _M = {}
 local serverId = tonumber(skynet.getenv("servId"))
 local md5 = require "md5"
+local pay_url = skynet.getenv("pay_url") or ""
 local function makeOrder(roleId, rechargeId)
 	local orderId = redisproxy:hincrby("autoincrement_set", "order", 1)
@@ -85,7 +86,7 @@ function _M.googleRechargeRpc(agent, data)
 		money = dataSet.rmb * 100,
 		game_money = dataSet.diamond,
 		product_id = dataSet.productId,
-		notify_url = "http://l11-ts-pub-all-wasteland.komoejoy.com/pay/google"
+		notify_url = pay_url .. "/pay/google"
 	}
 	local sign = signPms(need, secret_key)
@@ -111,7 +112,7 @@ function _M.myCardRechargeRpc(agent, data)
 		out_trade_no = partnerOrderId,
 		money = dataSet.rmb * 100,
 		game_money = dataSet.diamond,
-		notify_url = "http://l11-ts-pub-all-wasteland.komoejoy.com/pay/mycard"
+		notify_url = pay_url .. "/pay/mycard"
 	}
 	local sign = signPms(need, secret_key)
@@ -138,7 +139,7 @@ function _M.iosRechargeRpc(agent, data)
 		money = dataSet.rmb * 100,
 		game_money = dataSet.diamond,
 		product_id = dataSet.iap_product_id,
-		notify_url = "http://l11-ts-pub-all-wasteland.komoejoy.com/pay/ios"
+		notify_url = pay_url .. "/pay/ios"
 	}
 	local sign = signPms(need, secret_key)
@@ -114,6 +114,21 @@ function _M.endBattleRpc(agent, data)
 	towerInfo.k = nil
 	role:updateProperty({field = "towerInfo", value = towerInfo})
+
+	local rank = redisproxy:ZREVRANK(RANK_TOWER, role:getProperty("id"))
+	if not rank then
+		rank = -1
+	else
+		rank = rank + 1
+	end
+	role:checkBattle("tower", {
+		id = id,
+		isWin = msg.starNum and msg.starNum > 0,
+		info = msg.info,
+		reward = reward,
+		rank = rank,
+	})
+
 	SendPacket(actionCodes.Tower_endBattleRpc, MsgPack.pack({reward = reward, change = change}))
 	return true
 end
@@ -521,5 +521,17 @@ function Passive:effect13(eventType, triggerPms, eventId, count)
 	end
 end
+--14=给所有场上怪物增加buff 《 限定 怪 id》 除了自己
+function Passive:effect14(value, triggerPms, enemyId)
+	local aims = self.owner.battle.player:getTeam(2)
+	for k , aim in pairs(aims) do
+		if aim ~= self.owner then
+			if not enemyId or enemyId == 0 or aim.monsterId == enemyId then
+				aim:addBuff(value, self.owner)
+			end
+		end
+	end
+end
+
 return Passive
 \ No newline at end of file
@@ -7,6 +7,7 @@ local RoleTask = import(&quot;.RoleTask&quot;) --角色任务
 local RoleChangeStruct = import(".RoleChangeStruct") --角色数据额结构更改
 local RolePvp = import(".RolePvp")  -- pvp
 local RoleCross = import(".RoleCross") -- 跨服务请求相关
+local RoleBattle = import(".RoleBattle") -- 跨服务请求相关
 RoleLog.bind(Role)
 RolePlugin.bind(Role)
@@ -15,6 +16,7 @@ RoleTask.bind(Role)
 RoleChangeStruct.bind(Role)
 RolePvp.bind(Role)
 RoleCross.bind(Role)
+RoleBattle.bind(Role)
 function Role:ctor( properties )
 	Role.super.ctor(self, properties)
@@ -0,0 +1,185 @@
+local RoleBattle = {}
+
+--[[
+	100	剧情关卡类	
+	200	非剧情类普通关卡	
+	300	每日任务类、日常本类	
+	400	资源获取类关卡	
+	500	PVP关卡	
+	1000	活动期间限定类关卡	
+	2000	其他	
+]]
+
+local BattleType = {
+	hang = 100,
+	tower = 200,
+	bonus = 300,
+	pvpc = 500,
+	pvph = 501,
+}
+
+RoleBattle.bind = function (Role)
+
+
+-- TODO 检查战斗是否作弊
+local function checkBattleCheat()
+
+end
+
+
+
+function Role:checkBattle(battleType, params)
+	local clientInfo = params.info or {}
+
+	if not BattleType[battleType] then
+		print(string.format("NO find battleType: %s", battleType))
+		return
+	end
+
+	local selflist = {}
+	local heroscore = 0
+	local teamskill = {}
+	local enemylist = {}
+
+	local fixData = {
+		hang = function()
+			for slot, hero in pairs(self:getProperty("hangTS")) do
+				selflist[slot] = hero.type
+			end
+			heroscore = self:getProperty("hangTBV")
+			for slot , one in pairs(self:getProperty("hangTB").supports) do
+				teamskill[one[1]] = one[2]
+			end
+			local carbonData = csvdb["idle_battleCsv"][params.id]
+			local monsterData = csvdb[carbonData.monster:match("/([^/]*)$") .. "Csv"]
+			for slot, one in pairs(monsterData[1]) do
+				enemylist[#enemylist + 1] = one["unitType"]
+			end
+		end,
+		tower = function()
+			local towerF = self:getProperty("towerF")
+			for slot, hero in pairs(self:getTeamHerosInfo(towerF.heros)) do
+				selflist[slot] = hero.type
+			end
+			heroscore = self:getTeamBattleValue(towerF.heros)
+			for slot , one in pairs(self:getTeamBattleInfo(towerF).supports) do
+				teamskill[one[1]] = one[2]
+			end
+			local carbonData = csvdb["tower_battleCsv"][params.id]
+			local monsterData = csvdb[carbonData.monster:match("/([^/]*)$") .. "Csv"]
+			for slot, one in pairs(monsterData[1]) do
+				enemylist[#enemylist + 1] = one["unitType"]
+			end
+		end,
+		bonus = function()
+			local bTeam = self:getProperty("bTeam")
+			for slot, hero in pairs(self:getTeamHerosInfo(bTeam.heros)) do
+				selflist[slot] = hero.type
+			end
+			heroscore = self:getTeamBattleValue(bTeam.heros)
+			for slot , one in pairs(self:getTeamBattleInfo(bTeam).supports) do
+				teamskill[one[1]] = one[2]
+			end
+			local carbonData = csvdb["tower_battleCsv"][params.id]
+			local monsterData = csvdb[carbonData.monster:match("/([^/]*)$") .. "Csv"]
+			for slot, one in pairs(monsterData[1]) do
+				enemylist[#enemylist + 1] = one["unitType"]
+			end
+		end,
+		pvpc = function()
+			for slot, hero in pairs(self:getProperty("pvpTSC")) do
+				selflist[slot] = hero.type
+			end
+			heroscore = self:getProperty("pvpTBVC")
+			for slot , one in pairs(self:getProperty("pvpTBC").supports) do
+				teamskill[one[1]] = one[2]
+			end
+			if params.robotId then
+				local carbonData = csvdb["pvp_robotCsv"][params.robotId]
+				local monsterData = csvdb[carbonData.monster:match("/([^/]*)$") .. "Csv"]
+				for slot, one in pairs(monsterData[1]) do
+					enemylist[#enemylist + 1] = one["unitType"]
+				end
+			else
+				for slot, one in pairs((params.enemy or {})["heros"] or {}) do
+					enemylist[slot] = one["type"]
+				end
+			end
+		end,
+		pvph = function()
+			for idx, team in pairs(self:getProperty("pvpTSH")) do
+				selflist[idx] = selflist[idx] or {}
+				for slot, hero in pairs(team) do
+					selflist[idx][slot] = hero.type
+				end
+			end
+			for _, one in pairs(self:getProperty("pvpTBVH")) do
+				heroscore = heroscore + one
+			end
+			for idx, team in pairs(self:getProperty("pvpTBH")) do
+				for slot , one in pairs(team.supports) do
+					teamskill[one[1]] = one[2]
+				end
+			end
+
+			if params.robotId then
+				local carbonData = csvdb["pvp_robot_groupCsv"][params.robotId]
+				for idx = 1, 3 do
+					enemylist[idx] = enemylist[idx] or {}
+					local monsterData = csvdb[carbonData["monster" .. idx]:match("/([^/]*)$") .. "Csv"]
+					for slot, one in pairs(monsterData[1]) do
+						enemylist[idx][#enemylist + 1] = one["unitType"]
+					end
+				end
+			else
+				for idx, team in pairs(params.enemy or {}) do
+					enemylist[idx] = enemylist[idx] or {}
+					for slot, one in pairs(team["heros"] or {}) do
+						enemylist[idx][slot] = one["type"]
+					end
+				end
+			end
+		end
+	}
+
+	if fixData[battleType] then
+		fixData[battleType]()
+	end
+
+	-- robotId = match.t == 2 and match.id or nil,
+	-- enemy = match.t == 1 and (revenge and _pvpRecordBattleInfoCacheH[match.id] or _pvpBattleInfoCacheH[match.id]) or nil,
+	-- score = myScore,
+	-- reward = reward,
+	self:log("mission", {
+		mission_threadid = battleType == "hang" and math.floor((params.id % 100) / 100) or 0, -- 大关卡ID
+		mission_id = params.id or 0, -- 关卡ID
+		mission_type = BattleType[battleType], -- 关卡类型，见关卡类型枚举表
+		mission_herolist = selflist, -- 英雄ID，排序以玩家出战设置为准，PVP多个队伍则记录多个列表。示例：[[1,2,3],[456]]
+		mission_heroscore = heroscore, -- 编队总评分
+		mission_enemylist = enemylist, -- 地方英雄ID，排序以玩家出战设置为准，PVP多个队伍则记录多个列表。示例：[[1,2,3],[456]]
+		mission_damage = clientInfo.damage or {}, -- 英雄输出值。示例：{'heroid1':1000,'heroid2':2000,………..}
+		mission_ultskill = clientInfo.ultskill or {}, -- 大招使用情况。示例：{'heroid1':1000,'heroid2':2000,………..}
+		mission_reward = params.reward or {}, -- 获得奖励，建议使用json格式记录。示例：{ "XX": "1", "XXX": "3"}
+		mission_starttime = clientInfo.start or 0, -- 战斗开始时间，格式 unixtime 秒级
+		mission_roundtime = clientInfo.atime or 0, -- 对局时长(秒)
+		mission_result = params.isWin and 1 or 2, -- 战斗结果(0-无效，1-胜利，2-失败)
+		mission_star = 0, -- 战斗完成星数，无星级的话填写0
+		mission_restriction = 0, -- 周期内参与限制(0表示没有上限)
+		mission_difficulty = 0, -- 关卡困难度，无难度区分的话填写0
+		mission_strength = 1, -- 消耗的体力或次数
+		mission_score = params.score or 0, -- 本局分数，PVP玩法记录为对战后积分，无得分的填0
+		mission_cleartype = 1, -- 1正常通关;2代理拾荒
+		mission_rank = params.rank, -- 对战后排名，适用于PVP玩法和电波塔，其他玩法留空
+		misson_monsterkill = clientInfo.kill or {}, -- 击杀怪物ID和数量，建议使用json格式记录。示例：{ "XX": "1", "XXX": "3"}
+		misson_teamskill = teamskill, -- 编队支援技能和技能等级情况，json格式记录，{"teamskill1":1,"teamskill2":2,………..}
+	})
+end
+
+
+
+
+
+end
+
+
+return RoleBattle
 \ No newline at end of file
@@ -173,16 +173,16 @@ local MethodType = {
 		item_subreason = true, -- 道具流动二级原因，抽卡：卡池ID，装备强化：装备ID，副本掉落：副本ID
 		item_other = true, -- 其他（可包含阶数，强化等级，随机属性）
 	},
-	mission = { --玩家副本完成情况  --TODO
+	mission = { --玩家副本完成情况 
 		mission_threadid = true, -- 大关卡ID
 		mission_id = true, -- 关卡ID
 		mission_type = true, -- 关卡类型，见关卡类型枚举表
 		mission_sequenceid = "ucode", -- 本次对战ID，用于关联一次动作产生多条不同类型的日志
-		mission_herolist = true, -- 英雄ID，排序以玩家出战设置为准，PVP多个队伍则记录多个列表。示例：[[1,2,3],[456]]
+		mission_herolist = "json", -- 英雄ID，排序以玩家出战设置为准，PVP多个队伍则记录多个列表。示例：[[1,2,3],[456]]
 		mission_heroscore = true, -- 编队总评分
-		mission_enemylist = true, -- 地方英雄ID，排序以玩家出战设置为准，PVP多个队伍则记录多个列表。示例：[[1,2,3],[456]]
-		mission_damage = true, -- 英雄输出值。示例：{'heroid1':1000,'heroid2':2000,………..}
-		mission_ultskill = true, -- 大招使用情况。示例：{'heroid1':1000,'heroid2':2000,………..}
+		mission_enemylist = "json", -- 地方英雄ID，排序以玩家出战设置为准，PVP多个队伍则记录多个列表。示例：[[1,2,3],[456]]
+		mission_damage = "json", -- 英雄输出值。示例：{'heroid1':1000,'heroid2':2000,………..}
+		mission_ultskill = "json", -- 大招使用情况。示例：{'heroid1':1000,'heroid2':2000,………..}
 		mission_reward = "json", -- 获得奖励，建议使用json格式记录。示例：{ "XX": "1", "XXX": "3"}
 		mission_starttime = true, -- 战斗开始时间，格式 unixtime 秒级
 		mission_roundtime = true, -- 对局时长(秒)
@@ -198,7 +198,7 @@ local MethodType = {
 		misson_teamskill = "json", -- 编队支援技能和技能等级情况，json格式记录，{"teamskill1":1,"teamskill2":2,………..}
 		misson_teambond = "json", -- 编队羁绊和羁绊等级，json格式记录，{"bondid1":1,"bondid2":2,………..}
 	},
-	residence_reward = { --玩家挂机或排名奖励  --TODO
+	residence_reward = { --玩家挂机或排名奖励 
 		mission_threadid = true, --大关卡ID
 		mission_id = true, --关卡ID
 		mission_type = true, --关卡类型，见关卡类型枚举表
@@ -524,6 +524,7 @@ function RoleLog.bind(Role)
 		})
 	end
+
 	function Role:startActionUcode()
 		if not self._uniqueCount then
 			self._uniqueCount = 0