local ipairs = ipairs
  local table = table
  local math = math
  local redisproxy = redisproxy
  local MsgPack = MsgPack
  
  
  local _M = {}
  
  

  
  local function getUpdateTime(lastCount, lastTime)
  	local nextCount, nextTime = lastCount, skynet.timex()
  	if lastTime then
  		local addCount = math.floor((skynet.timex() - lastTime) / (globalCsv.tower_count_up * 60))
  		nextCount = math.min(lastCount + addCount, globalCsv.tower_count_limit)
  		nextTime = lastTime + addCount * (globalCsv.tower_count_up * 60)
  	end
  	return nextCount, nextTime
  end
  
  function _M.startBattleRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id

  	
  	if not role:isFuncUnlock(FuncUnlock.Tower) then return end

  
  	local towerInfo = role:getProperty("towerInfo")
  

  	if towerInfo.l ~= id then return end  -- 层数不对

  
  	if not csvdb["tower_battleCsv"][id] then return end
  	local curCount, nextTime = getUpdateTime(towerInfo.c, towerInfo.t)

  	--if curCount < 1 then return end -- 没有次数返回

  
  	--搞起来
  	towerInfo.c = curCount - 1

  	if curCount == globalCsv.tower_count_limit then --满的情况下的消耗了 恢复时间从当下开始
  		nextTime = skynet.timex()
  	end

  	towerInfo.t = nextTime
  	local key = tostring(math.random())
  	towerInfo.k = key
  
  	role:updateProperty({field = "towerInfo", value = towerInfo})

  	role:checkTaskEnter("TowerBattle", {level = towerInfo.l})

  	role:mylog("tower_action", {desc = "startBattle", int1 = id})

  	SendPacket(actionCodes.Tower_startBattleRpc, '')
  	return true
  end
  
  function _M.endBattleRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local id = msg.id
  	local key = msg.key
  	local passTime = msg.passTime
  
  	local towerInfo = role:getProperty("towerInfo")

  	if towerInfo.l ~= id or not towerInfo.k or towerInfo.k ~= key then 
  		SendPacket(actionCodes.Tower_endBattleRpc, MsgPack.pack({errorCode = 1}))
  		return true
  	end

  	local curTower = csvdb["tower_battleCsv"][id] 

  	if not curTower then return 2 end

  
  	local curCount, nextTime = getUpdateTime(towerInfo.c, towerInfo.t)
  
  

  	local reward, change

  	if msg.starNum and msg.starNum > 0 then --win
  		curCount = math.min(curCount + 1, globalCsv.tower_count_limit) -- 返还次数

  		--排行榜
  		role:setTowerRank(towerInfo.l)
  

  		towerInfo.l = towerInfo.l + 1

  		reward, change = role:award(curTower.reward, {log = {desc = "towerBattle", int1 = id}})

  		role:checkTaskEnter("TowerPass", {level = towerInfo.l - 1})

  	end
  
  	towerInfo.c = curCount
  	towerInfo.t = nextTime
  	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,
  	})

  	role:mylog("tower_action", {desc = "endBattle", short1 = msg.starNum > 0 and 1 or 0, int1 = id})

  	SendPacket(actionCodes.Tower_endBattleRpc, MsgPack.pack({reward = reward, change = change}))

  	return true
  end
  

  function _M.bugCountRpc(agent, data)
  	local role = agent.role

  	local msg = MsgPack.unpack(data)
  	local buyCount = msg.count

  
  	local towerInfo = role:getProperty("towerInfo")
  	local curCount, nextTime = getUpdateTime(towerInfo.c, towerInfo.t)
  	local needCount = globalCsv.tower_count_limit - curCount

  	if needCount > buyCount then
  		needCount = buyCount
  	end

  	if needCount > 0 then -- 补充
  		local cost = globalCsv.tower_chance_item:toNumMap()
  		for k , v in pairs(cost) do
  			cost[k] = v * needCount
  		end
  		if not role:checkItemEnough(cost) then return end

  		role:costItems(cost, {log = {desc = "towerCount"}})

  		curCount = curCount + needCount

  	end
  	towerInfo.c = curCount
  	towerInfo.t = nextTime
  	role:updateProperty({field = "towerInfo", value = towerInfo})

  	role:mylog("tower_action", {desc = "bugCount"})

  	SendPacket(actionCodes.Tower_bugCountRpc, '')
  	return true
  end

  
  function _M.rankRpc(agent , data)
  	local role = agent.role

  	SendPacket(actionCodes.Tower_rankRpc, MsgPack.pack(role:getTowerRank()))
  	return true
  end

  function _M.rankInfoRpc(agent , data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local roleId = msg.roleId
  	SendPacket(actionCodes.Tower_rankInfoRpc, MsgPack.pack({format = role:getTowerRankOneInfo(roleId)}))

  	return true
  end
  
  return _M