local Passive = require "adv.AdvPassive"
  

  local AdvCommon = require "adv.AdvCommon"
  local AdvMap = require "adv.AdvMap"

  local Buff = require "adv.AdvBuff"

  local Adv = class("Adv")

  local AdvTask = import(".AdvTask")  --任务相关数据搞出去
  AdvTask.bind(Adv)
  

  function Adv:ctor(owner)
  	assert(owner, "Adv instance must have owner(role)")
  	self.owner = owner
  	self.maps = {}

  	self.shopStatus = {}

  	self.battle = nil
  	self.backEvents = {} --发给客户端的事件组

  
  	self.advTask = self.owner:getProperty("advTask")
  	self.advMTask = self.owner:getProperty("advMTask")
  	self.advTaskChange = false -- 任务改变才更新
  

  	self:initByInfo(self.owner:getProperty("advInfo"))

  end
  

  --初始化adv 信息
  function Adv:initByInfo(advInfo)
  	if not next(advInfo) then return end --还没有 开始新地图
  
  	self.chapterId = advInfo.chapterId
  	self.level = advInfo.level or 1

  	self.round = advInfo.round or 0

  	self.score = advInfo.score or {}

  	self.isRelay = advInfo.isRelay

  	self.lastEnemyId = advInfo.lastEId or 1
  	self.mapStack = advInfo.mstack or {}

  	self.lchoose = advInfo.lch or {}

  	self.waitArtifact = advInfo.waitAF

  	self.cacheUnlock = advInfo.cacheUnlock or {}

  	self.shopStatus = advInfo.shopStatus or {}
  

  	self.maps = {}
  	for id, map in ipairs(advInfo.maps or {}) do
  		self.maps[id] = AdvMap.new(self, id, map)

  	end

  
  	self:initBattle()

  end

  -- 找出level 是否存在中继层
  function Adv:isHaveRelay(level, chapterId)

  	level = level or self.level

  	chapterId = chapterId or self.chapterId
  	if level == 1 then return end
  	
  	local campsiteCsv = csvdb["adv_chapter_campsiteCsv"][chapterId]
  	for _, campsite in ipairs(campsiteCsv) do
  		if campsite.floor == level then
  			return campsite
  		end
  	end
  	return nil
  end

  -- 随机新的地图

  function Adv:initByChapter(chapterId, level, isToNext, notNotify, isRelay, isEnter)

  	if not self.chapterId then -- 开始新的章节
  		self.chapterId = chapterId
  		self:checkAchievement(Adv.AchievType.StartBattle, 1)
  	elseif chapterId ~= self.chapterId then  -- 正常不会出现
  		return 
  	end
  	

  	self.level = level or 1

  	self.round = 0

  	self.score = self.score or {}
  	self.lastEnemyId = 1
  	self.mapStack = {1} -- 最后一个为当前的地图

  	self.lchoose = self.lchoose or {}

  	self.cacheUnlock = self.cacheUnlock or {}

  	self.shopStatus = self.shopStatus or {}

  	-- 随机出地图

  	local mapId 
  	if isRelay then
  		local relayData = self:isHaveRelay(level, chapterId)
  		if relayData then 
  			mapId = relayData.map
  		else
  			isRelay = false
  			mapId = self:randomMapId(chapterId, level)
  		end
  	else
  		mapId = self:randomMapId(chapterId, level)
  	end
  	self.isRelay = isRelay
  	local isNewRelay = false
  	if self.isRelay then -- 中继层
  		local advRelay = self.owner:getProperty("advRelay")
  		local chapter = self:isEndless() and -1 or self.chapterId
  		if not (advRelay[chapter] or {})[self.level] then
  			isNewRelay = true
  			advRelay[chapter] = advRelay[chapter] or {}
  			advRelay[chapter][self.level] = 1
  			self.owner:updateProperty({field = advRelay, value = advRelay})
  		end
  	end
  

  	self.maps = {}

  	self.maps[1] = AdvMap.new(self, 1, mapId, isEnter, isNewRelay)

  	self:initBattle()
  

  	self:initLayerTask()
  
  	self:checkTask(Adv.TaskType.Arrive)

  	self:checkAdvUnlock(1, self.level)

  	if isToNext then
  		self.battle.player:afterLayer() -- 玩家的buff 清理一下
  		self:scoreChange(AdvScoreType.Level) --增加层级加分
  	end

  	if not notNotify then
  		self:saveDB(notNotify)

  	end

  end

  function Adv:clear()
  	self.chapterId = nil
  	self.level = nil
  	self.score = {}

  	self.round = 0

  	self.lastEnemyId = 1
  	self.mapStack = {}

  	self.lchoose = {}

  	self.maps = {}
  	self.battle = nil

  	self.waitArtifact = nil

  	self.isRelay = nil

  	self.cacheUnlock = {}

  	self.shopStatus = {}

  end

  function Adv:isRunning()
  	if self.chapterId then return true end
  	return false
  end
  
  -- 强制结束
  function Adv:forceOver(notNotify)
  	if self:isRunning() then
  		self:clear()
  		local advTeam = self.owner:getProperty("advTeam")
  		advTeam.player = nil

  
  		local reward = self.owner:getProperty("advItems"):toNumMap()
  		for itemId, count in pairs(reward) do
  			reward[itemId] = math.ceil(count * globalCsv.adv_fail_reward_ratio / 100) -- 奖励相当于失败
  		end
  		self.owner:award(reward)
  

  		self.owner:updateProperties({
  			advInfo = {}, 
  			advTeam = advTeam,
  			advItems = "",
  			advAFGet = {},
  			advAFWear = {},
  		}, notNotify)
  	end
  end
  

  function Adv:saveDB(notNotify)
  	local advInfo,  advTeam = {}, self.owner:getProperty("advTeam")

  	if self:isRunning() then

  		advInfo.chapterId = self.chapterId
  		advInfo.level = self.level

  		advInfo.round = self.round

  		advInfo.score = self.score

  		advInfo.isRelay = self.isRelay

  		advInfo.lastEId = self.lastEnemyId
  		advInfo.mstack = self.mapStack

  		advInfo.lch = self.lchoose

  		advInfo.waitAF = self.waitArtifact

  		advInfo.cacheUnlock = self.cacheUnlock

  		advInfo.shopStatus = self.shopStatus

  		advInfo.maps = {}

  		self.battle:saveDB()

  		for id , map in ipairs(self.maps) do
  			advInfo.maps[id] = map:getDB()

  		end

  		advTeam.player = self.battle.player:getDB()

  	else
  		advTeam.player = nil

  	end

  
  	self:updateTask(notNotify)

  	self:updateAchievement(notNotify)

  	self.owner:updateProperties({advInfo = advInfo, advTeam = advTeam}, notNotify)

  end
  

  -- 1=抵达x层；2=通关x层；3=完成指定事件；4=完成指定连锁事件
  function Adv:checkAdvUnlock(utype, value)
  	if not self.chapterId then return end
  	local chapter = self.chapterId % 100
  	local reward = {}
  	for id, data in pairs(csvdb["adv_unlockCsv"]) do
  		if data.chapterid == chapter and data.type == utype and value == data.value then
  			--0=立即获得；1=结算时获得
  			if data.time == 0 then
  				reward[data.itemid] = 1
  			elseif data.time == 1 then
  				table.insert(self.cacheUnlock, data.itemid)
  			end
  		end
  	end
  	if next(reward) then
  		self.owner:award(reward)
  	end
  end
  
  function Adv:clearAdvUnlockCache()
  	local reward = {}
  	for _, itemId in ipairs(self.cacheUnlock) do
  		reward[itemId] = 1
  	end
  	if next(reward) then
  		self.owner:award(reward)
  	end
  	self.cacheUnlock = {}
  end
  

  function Adv:initBattle()
  	self.battle = require("adv.AdvBattle").new(self)
  	for _, passiveC in ipairs(self.cachePassiveEvent or {}) do
  		self.battle:triggerPassive(passiveC[1], passiveC[2])

  	end

  	self.cachePassiveEvent = {}

  end
  

  function Adv:triggerPassive(condType, params)
  	self.cachePassiveEvent = self.cachePassiveEvent or {}
  	if not self.battle then
  		table.insert(self.cachePassiveEvent, {condType, params})
  	else
  		self.battle:triggerPassive(condType, params)
  	end

  end
  

  function Adv:getCurMap()
  	return self.maps[self.mapStack[#self.mapStack]]

  end
  

  function Adv:getCurMapIdx()
  	return self.mapStack[#self.mapStack]

  end
  

  function Adv:getRoom(roomId, mapIdx)
  	mapIdx = mapIdx or self:getCurMapIdx()
  	local map = self.maps[mapIdx]
  	if map then
  		return map.rooms[roomId]

  	end

  end
  

  function Adv:getBlock(roomId, blockId, mapIdx)
  	local room = self:getRoom(roomId, mapIdx)
  	if room then
  		return room.blocks[blockId]

  	end

  end
  

  function Adv:isHaveArtifact(id)
  	return self.owner:getProperty("advAFGet")[id]
  end
  
  function Adv:awardArtifact(id, params)
  	if self:isHaveArtifact(id) then return end
  	self.owner:changeUpdates({{type = "advAFGet", field = id, value = 1}}, params.notNotify)

  	self:checkAchievement(Adv.AchievType.GetMWeapon, 1, id)

  	self:pushBackEvent(AdvBackEventType.Artifact, {id = id})

  end
  
  
  function Adv:delArtifactEffect(effect)
  	for _, eff in ipairs(effect:toArray()) do
  		local etype, id = table.unpack(eff:toArray(true, "="))
  		if etype == 1 then
  			self.battle.player:addPassive({id = id})
  		elseif etype == 2 then
  			self.battle.player:addBuff(id)
  		end
  	end
  end
  
  function Adv:addArtifactEffect(effect)
  	for _, eff in ipairs(effect:toArray()) do
  		local etype, id = table.unpack(eff:toArray(true, "="))
  		if etype == 1 then
  			self.battle.player:delPassiveById(id)
  		elseif etype == 2 then
  			self.battle.player:delBuffById(id)
  		end
  	end
  end
  
  function Adv:wearArtifact(slot, id)
  	local advAFGet = self.owner:getProperty("advAFGet")
  	local advAFWear = self.owner:getProperty("advAFWear")
  
  	local curWear = {}
  	for _, _id in pairs(advAFWear) do
  		curWear[_id] = 1
  	end
  	if curWear[id] then return end
  
  	if advAFWear[slot] then
  		local oldData = csvdb["adv_artifactCsv"][advAFWear[slot]][advAFGet[advAFWear[slot]]]
  		self:delArtifactEffect(oldData.effect)
  		if oldData.comboId ~= 0 then
  			local comboData = csvdb["adv_artifact_comboCsv"][oldData.comboId]
  			if comboData then
  				local isHaveCombo = true
  				for _, _id in ipairs(comboData.artifactid:toArray(true)) do
  					if not curWear[_id] then
  						isHaveCombo = false
  						break
  					end
  				end
  				if isHaveCombo then
  					self:delArtifactEffect(comboData.effect)
  				end
  			end
  		end
  		curWear[advAFWear[slot]] = nil
  	end
  	
  	curWear[id] = 1
  	local newData = csvdb["adv_artifactCsv"][id][advAFGet[id]]
  	self:addArtifactEffect(newData.effect)
  	if newData.comboId ~= 0 then
  		local comboData = csvdb["adv_artifact_comboCsv"][newData.comboId]
  		if comboData then
  			local isHaveCombo = true
  			for _, _id in ipairs(comboData.artifactid:toArray(true)) do
  				if not curWear[_id] then
  					isHaveCombo = false
  					break
  				end
  			end
  			if isHaveCombo then
  				self:addArtifactEffect(comboData.effect)
  			end
  		end
  	end

  	self.owner:changeUpdates({{type = "advAFWear", field = slot, value = id}})
  	return true
  end
  

  -- 是否穿着指定神器
  function Adv:isWearAF(id)
  	local advAFWear = self.owner:getProperty("advAFWear")
  	for _, _id in pairs(advAFWear) do
  		if _id == id then
  			return true
  		end
  	end
  	return false
  end
  --是否激活指定神器套装
  function Adv:haveComboAF(id)
  	local advAFGet = self.owner:getProperty("advAFGet")
  	local advAFWear = self.owner:getProperty("advAFWear")
  	local curWear = {}
  	for _, _id in pairs(advAFWear) do
  		curWear[_id] = 1
  	end
  	for _, _id in pairs(advAFWear) do
  		local afData = csvdb["adv_artifactCsv"][_id][advAFGet[_id]]
  		if afData.comboId == id then
  			local comboData = csvdb["adv_artifact_comboCsv"][afData.comboId]
  			if comboData then
  				for _, _id2 in ipairs(comboData.artifactid:toArray(true)) do
  					if not curWear[_id2] then
  						return false
  					end
  				end
  				return true
  			end
  			return false
  		end
  	end
  	return false
  end
  

  function Adv:artifactLevelUp(id, level)
  	level = level or 1

  	local advAFGet = self.owner:getProperty("advAFGet")

  	if not advAFGet[id] then return end

  	local advAFWear = self.owner:getProperty("advAFWear")

  	
  	local newLv = advAFGet[id]
  	for i = 1, level do
  		if not self.owner:isArtifactOpen(id, self:isEndless(), newLv + 1) then break end
  		newLv = newLv + 1
  	end
  	if newLv == advAFGet[id] then return end
  

  	local status = 0

  	if advAFWear[id] then -- 穿着呢
  		local oldData = csvdb["adv_artifactCsv"][id][advAFGet[id]]

  		local newData = csvdb["adv_artifactCsv"][id][newLv]

  		self:delArtifactEffect(oldData.effect)
  		self:addArtifactEffect(newData.effect)
  		status = 1
  	end

  	self.owner:changeUpdates({{type = "advAFGet", field = id, value = newLv}})
  	self:checkAchievement(Adv.AchievType.MWeaponLv, 1, id, newLv)

  	return status
  end
  
  function Adv:waitChooseArtifact()
  	local chooses = {}
  	local pool = {}
  	local count = 3  --需要多少个
  
  	for id, temp in pairs(csvdb["adv_artifactCsv"]) do
  		if not self:isHaveArtifact(id) and self.owner:isArtifactOpen(id, self:isEndless()) then
  			table.insert(pool, id)
  		end
  	end

  	if #pool == 0 then
  		self:award({[ItemId.AdvPoint] = 48})
  	else
  		for i = 1, math.min(count, #pool) do

  			local idx = math.randomInt(1, #pool)
  			table.insert(chooses, pool[idx])
  			table.remove(pool, idx)
  		end

  		self.waitArtifact = chooses
  		self:backChooseArtifact()

  	end

  end
  
  function Adv:isWaitChooseArtifact()
  	return self.waitArtifact
  end
  
  function Adv:chooseArtifact(index)
  	if not self.waitArtifact or not self.waitArtifact[index] then return end

  	self:award({[self.waitArtifact[index]] = 1})
  	self.waitArtifact = nil

  	return true
  end
  
  function Adv:isEndless()
  	return AdvCommon.isEndless(self.chapterId)
  end

  function Adv:getCurFloorData()
  	if not self.chapterId then return end
  	local chapter = self.chapterId % 100
  	return (csvdb["adv_chapter_floorCsv"][chapter] or {})[self.level]
  end
  

  --关卡结束
  function Adv:over(success, rewardRatio)
  	if success then 
  		rewardRatio = rewardRatio or 100
  	else
  		rewardRatio = rewardRatio or globalCsv.adv_fail_reward_ratio
  	end

  	local score = self:getScore()

  	local scoreInfo = self.score

  	self.battle.player:triggerPassive(Passive.ADV_OVER, {score = score, level = self.level})

  
  
  	local reward = self.owner:getProperty("advItems"):toNumMap()
  	for itemId, count in pairs(reward) do
  		reward[itemId] = math.ceil(count * rewardRatio / 100)
  	end
  	reward = self.owner:award(reward)
  

  	if success then

  		self.owner:checkTaskEnter("AdvPass", {id = self.chapterId, level = self.level, score = score})

  		local chapterData = csvdb["adv_chapterCsv"][self.chapterId].limitlevel
  		if not self:isEndless() and self.level >= chapterData then

  			self.owner:checkTaskEnter("AdvAllPass", {id = self.chapterId})
  		end

  		local roleId = self.owner:getProperty("id")
  		local oldMaxScore = tonum(redisproxy:zscore(RANK_ADV, roleId))
  		if score > oldMaxScore then
  			local team = self.owner:getProperty("advTeam")
  			local curInfo = {
  				name = self.owner:getProperty("name"),
  				headId = self.owner:getProperty("headId"),
  				lv = self.owner:getProperty("level"),

  				batteV = self.owner:getTeamBattleValue(team.heros),

  				chapter = self.chapterId,
  				format = self.owner:getTeamHerosInfo(team.heros),
  			}
  			redisproxy:pipelining(function (red)
  				red:zadd(RANK_ADV, score, roleId)	--更新分数
  				red:hset(RANK_ADV_INFO, roleId,  MsgPack.pack(curInfo))
  			end)
  		end

  	end

  	self:clearAdvUnlockCache()

  	self:clear()

  	self.owner:checkTaskEnter("AdvScore", {score = score})

  	self.owner:updateProperties({
  		advItems = "",
  		advAFGet = {},
  		advAFWear = {},
  	})

  	self:backEnd(success, score, scoreInfo, reward)

  end
  

  function Adv:exit()

  	self:over(false)

  	self:saveDB()
  end
  

  function Adv:randomMapId(chapterId, level)
  	local chapterData = csvdb["adv_chapterCsv"][chapterId]
  	if not chapterData then 
  		error("chapterId " .. chapterId .. " dont exist!")
  		return 

  	end

  	if AdvCommon.isEndless(chapterId) then

  		level = AdvCommon.getEndlessDataLv(chapterId, level)

  	else
  		if level > chapterData.limitlevel then 
  			error("level overflow!")
  			return 
  		end

  	end

  	--随出地图Id
  	local raw_pool = chapterData.mapid:toArray(true, "=")

  	local lastMapIds = {}
  	for id, map in ipairs(self.maps or {}) do
  		lastMapIds[map.mapId] = 1

  	end

  	local pool = {}

  	for _, mapId in ipairs(raw_pool) do
  		local temp = csvdb["mapCsv"][mapId]
  		if temp and not lastMapIds[mapId] then
  			if AdvCommon.checkIsIn(level, temp.leveltype, temp.levellimit) then
  				table.insert(pool, mapId)

  			end
  		end
  	end

  	if not next(pool) then 
  		error("mapIds is empty!")
  		return 

  	end

  	return pool[math.randomInt(1, #pool)]

  end
  

  -- 在冒险中获得的物品都发放在冒险背包内
  function Adv:award(gift, params)

  	params = params or {}

  	local tgift = {}
  	if type(gift) == "string" then
  		for _, one in pairs(gift:toTableArray(true)) do
  			tgift[one[1]] = (tgift[one[1]] or 0) + one[2]
  		end
  	else
  		tgift = gift
  	end
  	local items = self.owner:getProperty("advItems")

  	local oldItems = items

  	for itemId, count in pairs(tgift) do

  		if count > 0 then

  			local buffAdd = self.battle.player:getRewardChange(itemId)

  			count = math.floor(math.max(0, (count + buffAdd[0]) * (1 + buffAdd[1]))) --附加 buff 的影响

  			self:scoreChange(AdvScoreType.Item, {itemId, count})

  			self:checkTask(Adv.TaskType.Item, count, itemId)

  			self:checkAchievement(Adv.AchievType.GetItem, count, itemId)

  		end

  		tgift[itemId] = count

  		local origin = items:getv(itemId, 0)
  		local nums = origin + count

  		if csvdb["adv_artifactCsv"][itemId] then -- 获得神器
  			self:awardArtifact(itemId, params)
  		else
  			if nums <= 0 then
  				items = items:delk(itemId)
  				nums = 0
  			else
  				items = items:setv(itemId, nums)

  			end
  		end
  	end

  	if items ~= oldItems then
  		self.owner:updateProperty({field = "advItems", value = items, notNotify = params.notNotify})
  	end
  	return tgift

  end
  
  

  -- 消耗物品 优先冒险背包  --check 只是检查够不够
  function Adv:cost(item, params, check)
  	local items = self.owner:getProperty("advItems")
  	local less = {}
  	local advCost = {}
  	for itemId, count in pairs(item) do
  		advCost[itemId] = - math.min(items:getv(itemId, 0), count)
  		if advCost[itemId] == 0 then
  			advCost[itemId] = nil
  		end
  
  		local last = items:getv(itemId, 0) - count
  		if last < 0 then
  			less[itemId] = -last
  		end
  
  	end
  	if next(less) and not self.owner:checkItemEnough(less) then return end --不够
  	if check then return true end
  	self:award(advCost, params)

  	if next(less) then
  		self.owner:costItems(less, params)
  	end

  	return true
  end
  
  --事件点击处理
  local function clickOut(self, room, block, params)

  	if self:getCurMap():checkOver() then --检查是否可以出去了
  		if #self.mapStack > 1 then -- 处于夹层中
  			table.remove(self.mapStack) --退出夹层

  			self:backLayer(-1)

  		else --处于底层

  
  			local advPass = self.owner:getProperty("advPass")

  			if self:isEndless() then

  				-- 刷新最高层
  				if self.owner:getProperty("advElM") < self.level then
  					self.owner:updateProperty({field = "advElM", value = self.level})
  				end
  			else
  				if self.level > (advPass[self.chapterId] or 0) then
  					self.owner:changeUpdates({{type = "advPass", field = self.chapterId, value = self.level}})
  				end

  			end

  			self:checkAchievement(Adv.AchievType.OverWin, 1, self.level)

  			self:checkAdvUnlock(2, self.level)

  			if not self:isEndless() and (self.level >= csvdb["adv_chapterCsv"][self.chapterId].limitlevel or not self.owner:advChapterIsOpen(self.chapterId, self.level + 1)) then --关卡结束
  				self:over(true)

  			else

  				self.battle.player:triggerPassive(Passive.DOWN_LAYER)

  				local curFloorData = self:getCurFloorData()
  				if curFloorData then
  					self:backReward(self:award({[ItemId.AdvPoint] = curFloorData.exp}))
  				end

  				local isHaveRelay = self:isHaveRelay(self.level)
  				if isHaveRelay and not self.isRelay then 
  					self:initByChapter(self.chapterId, self.level, true, true, true, false)
  				else
  					self:initByChapter(self.chapterId, self.level + 1, true, true, false, false)
  				end

  				self:backNext() --下一关
  			end

  		end

  		return true
  	end
  end
  

  local function clickExit(self, room, block, params)

  	self:over(true)

  	return true
  end
  

  --战斗 普通攻击
  local function clickMonster(self, room, block, params)

  	self.battle:battleBegin(room.roomId, block.blockId, params)

  	return true
  end
  

  local function chooseCommon(self, room, block, chooseData, choose, tag)

  	if not chooseData or not chooseData["button".. choose .."cond"] then return end
  
  	local cond = chooseData["button".. choose .."cond"]:toArray(true, "=")
  	local checkCond = {

  		-- 没有条件
  		[0] = function()
  			return true
  		end,

  		-- 拥有道具
  		[1] = function()
  			if self:cost({[cond[2]] = cond[3]}, {}, true) then
  				return true
  			end
  		end,
  		-- xx角色（todo 队长）
  		[2] = function()

  			local hero = self.owner.heros[self.owner:getProperty("advTeam").leader]
  			if hero and hero:getProperty("type") == cond[2] then
  				return true

  			end
  		end,
  		--消灭所有怪
  		[3] = function()

  			for _, room in pairs(self:getCurMap().rooms) do

  				for _, block in pairs(room.blocks) do

  					if block:isMonster() then

  						return
  					end
  				end
  			end
  			return true
  		end,