local ipairs = ipairs
  local table = table
  local math = math
  local redisproxy = redisproxy
  local MsgPack = MsgPack

  local httpc = require("http.httpc")
  local remoteUrl = skynet.getenv("codeurl")

  
  
  local _M = {}

  local _pvpBattleInfoCacheC = {}  --查询列表 缓存pvp战斗相关数据缓存
  local _pvpStartBattleCache = nil -- 

  local _pvpRecordInfoCache = {} -- 记录缓存
  local _pvpRecordBattleInfoCache = {} -- 记录战斗数据缓存

  local _revengeRecord = {} -- 复仇对单人1分钟间隔
  local RevengeWaitTime = 60

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

  	local roleId = role:getProperty("id")

  	local msg = MsgPack.unpack(data)

  	local pvpTC = role:getProperty("pvpTC")

  	for slot, heroId in pairs(msg.heros or {}) do

  		if not role.heros[heroId] then
  			return
  		end
  	end

  	if not msg.heros or not next(msg.heros) then

  		return

  	end

  	table.clear(pvpTC)
  	pvpTC.heros = {}
  	for slot, heroId in pairs(msg.heros) do
  		pvpTC.heros[slot] = heroId
  	end
  	pvpTC.leader = msg.leader
  	
  	role:savePvpCTeam(pvpTC)

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

  local function getMatchInfo(role, pvpList, battleCache)

  	table.clear(battleCache)
  	local redret = redisproxy:pipelining(function(red)
  		for _, info in ipairs(pvpList) do
  			if info.t == 1 then
  				red:zscore(RANK_PVP_COMMON, info.id)
  			end
  		end
  	end)
  
  	local matches = {}
  	local curIdx = 1
  	for idx, info in ipairs(pvpList) do
  		local curInfo = {idx = idx}
  		if info.t == 1 then --玩家
  			curInfo.roleId = info.id

  			curInfo.score = role:unpackPvpScore(redret[curIdx] or 0)

  			curIdx = curIdx + 1
  			-- name, level, headId, battleV, heros
  			local online, roleInfo = rpcRole(curInfo.roleId, "pvpCInfo")
  			for k , v in pairs(roleInfo) do
  				if k == "battleInfo" then
  					battleCache[curInfo.roleId] = v
  				else
  					curInfo[k] = v
  				end
  			end
  		elseif info.t == 2 then  	-- robot
  			curInfo.robot = info.id
  		end
  		table.insert(matches, curInfo)
  	end
  	return matches
  end
  
  -- 获取pvp信息
  function _M.infoRpc(agent, data)

  	local role = agent.role

  	local roleId = role:getProperty("id")

  	local msg = MsgPack.unpack(data)

  	local ptype = msg.ptype or 1

  	local response = {}
  	if ptype == 1 then -- 普通pvp
  		local redret = redisproxy:pipelining(function(red)
  			red:zscore(RANK_PVP_COMMON, roleId)
  			red:zrevrank(RANK_PVP_COMMON, roleId)
  		end)

  		local score = role:unpackPvpScore(redret[1] or 0)

  		local rank = tonumber(redret[2] or -2) + 1  --排名 1 - ...  -1 未上榜 没打过pvp

  		if rank == -1 then
  			score = globalCsv.pvp_base_score
  		end

  		local pvpMC = role:getProperty("pvpMC")
  		if not next(pvpMC) then --没有分配过对手
  			role:refreshPvpMatchC(score)
  			pvpMC = role:getProperty("pvpMC")
  		end
  		if not next(pvpMC) then return end
  		

  		response.rank = rank

  		response.score = score

  		response.matches = getMatchInfo(role, pvpMC, _pvpBattleInfoCacheC)

  	elseif ptype == 2 then -- 高级pvp
  		return
  	else
  		return
  	end
  	SendPacket(actionCodes.Pvp_infoRpc, MsgPack.pack(response))

  	return true
  end
  

  function _M.refreshMatchCRpc(agent, data)

  	local role = agent.role
  	local msg = MsgPack.unpack(data)

  	role:refreshPvpMatchC()
  
  	local pvpMC = role:getProperty("pvpMC")

  	local matches = getMatchInfo(role, pvpMC, _pvpBattleInfoCacheC)

  	SendPacket(actionCodes.Pvp_refreshMatchCRpc, MsgPack.pack({matches = matches}))

  	return true
  end
  
  function _M.buyCountRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)

  	local count = msg.count

  	if math.illegalNum(count, 1, math.huge) then
  		return 1
  	end
  
  	local cost = {[ItemId.Diamond] = globalCsv.pvp_buy_cost * count}
  	if not role:checkItemEnough(cost) then return 2 end
  	role:costItems(cost)
  	role:award({[ItemId.PvpKey] = count})

  
  	SendPacket(actionCodes.Pvp_buyCountRpc, '')
  	return true
  end
  
  function _M.startBattleRpc(agent, data)

  	local role = agent.role
  	local msg = MsgPack.unpack(data)

  	local idx = msg.idx
  	local revenge = msg.revenge
  

  	local pvpTC = role:getProperty("pvpTC")
  	if not pvpTC.heros or not next(pvpTC.heros) then return 1 end
  

  	local matchInfo, result, key, wait

  	local now = skynet.timex()

  	if revenge then  --复仇

  		local temp = _pvpRecordInfoCache[idx]

  		if not temp then return 2 end

  		if not _revengeRecord[temp.id] or now >= _revengeRecord[temp.id] then

  			if temp.t == 1 then
  				matchInfo = _pvpRecordBattleInfoCache[temp.id]
  			elseif temp.t == 2 then
  				matchInfo = {robot = temp.id}
  			end
  		else
  			result = 1

  			wait = _revengeRecord[temp.id] - now

  		end
  	else  --打正常
  		local pvpMC = role:getProperty("pvpMC")

  		if not pvpMC[idx] then return 3 end

  		if pvpMC[idx].t == 1 then
  			matchInfo = _pvpBattleInfoCacheC[pvpMC[idx].id]
  		elseif pvpMC[idx].t == 2 then
  			matchInfo = {robot = pvpMC[idx].id}
  		end
  	end
  

  	if not result and not matchInfo then return 4 end

  
  	if not result then
  		-- 次数扣一波
  		local pvpFree = role.dailyData:getProperty("pvpFree")
  		if pvpFree >= globalCsv.pvp_battle_free_count then
  			local cost = {[ItemId.PvpKey] = 1}

  			if not role:checkItemEnough(cost) then return 5 end

  			role:costItems(cost)
  		else
  			role.dailyData:updateProperty({field = "pvpFree", delta = 1})
  		end

  		key = tostring(math.random())
  		_pvpStartBattleCache = {idx = idx, key = key, revenge = revenge}

  
  		role:checkTaskEnter("PvpBattle")

  	end
  

  	SendPacket(actionCodes.Pvp_startBattleRpc, MsgPack.pack({matchInfo = matchInfo, key = key, result = result, wait = wait}))

  	return true

  end
  
  function _M.endBattleRpc(agent, data)

  	local role = agent.role
  	local roleId = role:getProperty("id")
  	local msg = MsgPack.unpack(data)

  	if not msg.key or not _pvpStartBattleCache or msg.key ~= _pvpStartBattleCache.key then 
  		return 1
  	end

  
  	if not msg.idx or msg.idx ~= _pvpStartBattleCache.idx then

  		return 2
  	end

  	local isWin = msg.starNum and msg.starNum > 0

  	local now = skynet.timex()

  
  	local revenge = _pvpStartBattleCache.revenge
  	local match
  	if revenge then
  		match = _pvpRecordInfoCache[msg.idx]

  		_revengeRecord[match.id] = now + RevengeWaitTime  -- 1分钟内不能再打

  	else
  		local pvpMC = role:getProperty("pvpMC")
  		match = pvpMC[msg.idx]
  	end
  	
  	if not match then return end
  
  	local temp = string.randWeight(csvdb["player_expCsv"][role:getProperty("level")].pvpBonus, true)
  	local reward = role:award({[temp[1]] = temp[2]})
  	local myScore, matchScore, oldmyScore, oldMatchScore, myRank, oldMyRank = role:changePvpScoreCommon(match.t == 1 and match.id or -1, isWin)
  
  	_pvpBattleInfoCacheC = {}  --重新发阵容了 没毛病
  	_pvpRecordInfoCache = {} -- 记录刷新了
  	_pvpRecordBattleInfoCache = {} -- 取新纪录的时候搞
  	_pvpStartBattleCache = nil
  
  	-- 请求上传录像

  	local params = {
  		["roleid"] = roleId,
  		["key"] = "zhaolugame20191016",
  		["time"] = now,
  	}
  	local status, body = httpc.get(remoteUrl, "/applyvideo?" .. httpGetFormatData(params), {}, {})
  	local video = nil
  	if tonumber(status) == 200 then
  		local result = json.decode(body)
  		video = result.name
  	else
  		skynet.error("applyvideo", "error", status, body, content)
  	end
  
  	-- 加入战斗记录
  	redisproxy:pipelining(function(red)
  		local dbKey = string.format(RECORD_PVP_COMMON, roleId)
  		red:lpush(dbKey, MsgPack.pack({
  			id = match.id,
  			t = match.t,
  			win = isWin,
  			time = now,
  			video = video,
  			sdelta = myScore - oldmyScore,
  		}))
  		red:trim(dbKey, 0, 9)
  		-- 对方加入战斗记录
  		if match.t == 1 then
  			dbKey = string.format(RECORD_PVP_COMMON, match.id)
  			red:lpush(dbKey, MsgPack.pack({
  				id = roleId,
  				t = 1,
  				win = not isWin,
  				time = now,
  				video = video,
  				sdelta = matchScore - oldMatchScore,
  			}))
  			red:trim(dbKey, 0, 9)
  		end
  	end)

  
  	if isWin then
  		role:checkTaskEnter("PvpWin", {score = myScore})
  	end

  	SendPacket(actionCodes.Pvp_endBattleRpc, MsgPack.pack({
  		reward = reward,
  		myScore = myScore,
  		matchScore = matchScore,
  		oldmyScore = oldmyScore,
  		oldMatchScore = oldMatchScore,
  		myRank = myRank,
  		oldMyRank = oldMyRank,
  		video = video,
  	}))
  	return true
  end
  
  function _M.rankListRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")

  	local msg = MsgPack.unpack(data)

  	local ptype = msg.ptype or 1
  
  	local response = {}
  	if ptype == 1 then -- 普通pvp
  		local redret = redisproxy:pipelining(function(red)
  			red:zscore(RANK_PVP_COMMON, roleId)
  			red:zrevrank(RANK_PVP_COMMON, roleId)
  			red:zrevrange(RANK_PVP_COMMON, 0, 99, "WITHSCORES")
  		end)

  		local score = role:unpackPvpScore(redret[1] or 0)

  		local rank = tonumber(redret[2] or -2) + 1  --排名 1 - ...  -1 未上榜 没打过pvp

  		if rank == -1 then
  			score = globalCsv.pvp_base_score
  		end

  		local rankList = {}
  		for i = 1, #redret[3], 2 do

  			local roleId = tonumber(redret[3][i])
  			local score = role:unpackPvpScore(redret[3][i + 1])

  			local online, curInfo = rpcRole(roleId, "friendSInfo")
  			curInfo.score = score
  			curInfo.roleId = roleId
  			table.insert(rankList, curInfo)
  		end
  		
  		response.score = score
  		response.rank = rank
  		response.rankList = rankList
  
  	elseif ptype == 2 then -- 高级pvp
  		return
  	else
  		return
  	end
  	SendPacket(actionCodes.Pvp_rankListRpc, MsgPack.pack(response))
  	return true
  end
  
  function _M.recordListRpc(agent, data)
  	local role = agent.role
  	local roleId = role:getProperty("id")
  	local ptype = msg.ptype or 1
  
  	local recordList = {}
  	local now = skynet.timex()
  	if ptype == 1 then -- 普通pvp
  		local rlist = redisproxy:lrange(string.format(RECORD_PVP_COMMON, roleId), 0 , 9)
  		local tempList = {}
  		for _, temp in ipairs(rlist) do
  			local one = MsgPack.unpack(temp)

  			if now - one.time <= globalCsv.pvp_record_keep_time then -- 大于一天的弃之

  				table.insert(tempList, one)
  			end
  		end
  		_pvpRecordInfoCache = tempList
  

  		recordList = getMatchInfo(role, tempList, _pvpRecordBattleInfoCache)

  		for idx, info in ipairs(recordList) do
  			local temp = tempList[idx]
  			info.win = temp.win
  			info.time = temp.time
  			info.video = temp.video
  			info.sdelta = temp.sdelta
  		end
  		
  	elseif ptype == 2 then -- 高级pvp
  		return
  	else
  		return
  	end
  	SendPacket(actionCodes.Pvp_recordListRpc, MsgPack.pack({list = recordList}))
  	return true

  end
  
  return _M