local ipairs = ipairs
  local table = table
  local math = math
  local next = next
  local string = string
  local redisproxy = redisproxy
  local MsgPack = MsgPack
  local getRandomName = getRandomName
  local mcast_util = mcast_util
  local string_format = string.format
  local tonumber = tonumber
  local require = require
  local table_insert = table.insert
  local tconcat = table.concat

  local table_unpack = table.unpack

  
  local _M = {}

  local function getChangeAttrJson(oldAttr, newAttr)
  	local change = {}
  	for k, v in pairs(newAttr) do
  		change[k] = v - oldAttr[k]
  		change[k] = math.ceil(change[k])
  		if change[k] == 0 then
  			change[k] = nil
  		end
  	end

  	return change

  end
  

  function _M.levelUpRpc( agent, data )
  	local role = agent.role
  	local msg = MsgPack.unpack(data)

  	local hero = role.heros[msg.id]

  	if not hero then return 1 end

  	if hero:getProperty("level") >= hero:getMaxLevel() then return 2 end

  	local curData = csvdb["unit_expCsv"][hero:getProperty("level")]

  	local cost = {[ItemId.Exp] = curData.exp, [ItemId.Gold] = curData.gold}

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

  	role:costItems(cost, {log = {desc = "heroLevelUp", int1 = msg.id, int2 = hero:getProperty("type")}})

  
  	local oldAttr = hero:getTotalAttrs()
  	local oldBattleV = hero:getProperty("battleV")

  	hero:updateProperty({field = "level", delta = 1})

  	role:log("hero_upgrade", {
  		hero_id = hero:getProperty("type"), --英雄ID

  		hero_upgrade_cost = cost, -- 英雄升级消耗，json格式记录，{道具ID1：消耗数量1,道具ID2：消耗数量2,………...}

  		hero_upgrade_result = getChangeAttrJson(oldAttr, hero:getTotalAttrs()), -- 英雄升级效果，可记录效果ID，或json格式记录提升效果，{攻击：20,闪避：20,……..}
  		hero_upgrade_type = 0, -- 英雄升级方式，连续升级：1，单击升级：0
  		hero_upgrade_score = hero:getProperty("battleV"), -- 英雄升级后评分
  		hero_upgrade_scoreget = hero:getProperty("battleV") - oldBattleV, -- 通过英雄升级提升的评分
  	})

  	hero:mylog({desc = "levelUp", int1 = hero:getProperty("level")})

  	role:checkTaskEnter("HeroLevelUp", {level = hero:getProperty("level")})

  
  	role:checkTaskEnter("HeroLvlCollect", {})

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

  function _M.breakRpc( agent, data )
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local hero = role.heros[msg.id]

  	if not hero then return 1 end

  	if hero:getProperty("level") < hero:getMaxLevel() then return 2 end
  	if hero:getProperty("breakL") >= #csvdb["unit_breakCsv"] then return 3 end

  	local curData = csvdb["unit_breakCsv"][hero:getProperty("breakL")]

  	if hero:getProperty("wakeL") < curData["starLimit"] then return 4 end

  	local cost = {[ItemId.BreakCost] = curData.cost, [ItemId.Gold] = curData.gold}

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

  	role:costItems(cost, {log = {desc = "heroBreak", int1 = msg.id, int2 = hero:getProperty("type")}})

  	local oldAttr = hero:getTotalAttrs()

  	hero:updateProperty({field = "breakL", delta = 1})

  	role:log("hero_break", {
  		hero_id = hero:getProperty("type"), --英雄ID

  		hero_break_cost = cost, -- 英雄突破消耗，json格式记录，{道具ID1：消耗数量1,道具ID2：消耗数量2,………...}

  		hero_break_result = getChangeAttrJson(oldAttr, hero:getTotalAttrs()), -- 英雄突破效果，可记录效果ID，或json格式记录提升效果，{攻击：20,闪避：20,……..}
  		hero_break_level = hero:getMaxLevel(), -- 英雄突破后等级上限
  	})

  	hero:mylog({desc = "break", int1 = hero:getProperty("breakL")})

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

  function _M.wakeRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local hero = role.heros[msg.id]

  	if not hero then return 1 end
  	if hero:getProperty("wakeL") >= #csvdb["unit_wakeCsv"] then return 2 end
  	local typ = hero:getProperty("type")
  	local wakeData = csvdb["unit_wakeCsv"][hero:getProperty("wakeL")]
  	if not wakeData then return 3 end

  	local costMaterial = wakeData.costMaterial:toArray(true,"=")
  	local cost = {[typ] = wakeData.costFigment,[globalCsv.unit_wake_cost[hero:getCamp()][costMaterial[1]]] = costMaterial[2]}

  	if not role:checkItemEnough(cost) then
  		return 4

  	end

  	local curLevel = hero:getProperty("wakeL")
  	local sparkInfo = hero:getProperty("spark")
  	-- 大于等于7的时候需要装备火花才能升
  	if curLevel >= 7 then
  		if #sparkInfo == 0 then
  			return 5
  		end
  		local ok = false
  		for _, info in ipairs(sparkInfo) do
  			local cfg = csvdb["sparkCsv"][info.cfg_id][info.level or 0]
  			if not cfg then return 6 end
  			if cfg.star == curLevel then
  				ok = true
  				break
  			end
  		end
  		if not ok then return 7 end
  	end
  	

  	role:costItems(cost, {log = {desc = "heroWake", int1 = msg.id, int2 = hero:getProperty("type")}})

  	local oldAttr = hero:getTotalAttrs()

  	local oldBattleV = hero:getProperty("battleV")

  	hero:updateProperty({field = "wakeL", delta = 1})
  

  	role:checkTaskEnter("Wake", {heroType = typ, wakeL = curLevel})

  	if curLevel == 3 then -- 解锁cg

  		role:checkTaskEnter("WakeCG", {heroType = typ})
  	end

  	hero:mylog({desc = "wake", int1 = hero:getProperty("wakeL")})

  	role:log("hero_rise", {
  		hero_id = typ, --英雄ID

  		hero_rise_cost = cost, --英雄觉醒消耗，json格式记录，{道具ID1：消耗数量1,道具ID2：消耗数量2,………...}

  		hero_rise_score = hero:getProperty("battleV"), --英雄觉醒后评分提升

  		hero_rise_scoreget = hero:getProperty("battleV") - oldBattleV, --英雄觉醒后评分提升

  		hero_rise_result = getChangeAttrJson(oldAttr, hero:getTotalAttrs()), --英雄觉醒效果，可记录效果ID，或json格式记录提升效果，{攻击：20,闪避：20,……..}
  	})
  

  	if hero:getProperty("type") == 204 then
  		role:finishGuide(7)
  	end
  

  	SendPacket(actionCodes.Hero_wakeRpc, '')

  
  	role:checkTaskEnter("HeroStarCollect", {})

  	return true
  end
  

  
  function _M.talentRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local hero = role.heros[msg.id]

  	if not hero then return 1 end

  	local talent = hero:getProperty("talent")

  	local heroCfgId = hero:getProperty("type")

  	local curStage = talent:getv(0, 1)

  	local oldStage = curStage

  	local curLevel = talent:getv(1, 1)

  	local oldLevel = curLevel

  	local curData = csvdb["unit_talent_"..heroCfgId.."Csv"][curStage]
  	if not curData then return 1 end

  	local oldSkillLv = hero:getSkillLevel(1)
  

  	local cost = {}

  	if curLevel == #curData then
  		talent = talent:setv(0, curStage + 1)
  		talent = talent:setv(1, 1)

  	else

  		if curLevel > #curData then return 2 end

  		local talentData = curData[curLevel]
  		if not talentData then return 3 end

  		if talentData.lvRequire > hero:getProperty("level") then return 4 end

  		cost = talentData.money:toNumMap()

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

  		role:costItems(cost, {log = {desc = "heroTalent", int1 = msg.id, int2 = hero:getProperty("type")}})

  		talent = talent:setv(1, curLevel + 1)

  	end

  	curStage = talent:getv(0, 1)
  	role:checkTaskEnter("HeroTalent", {heroType = hero:getProperty("type"), alv = curStage})

  	hero:updateProperty({field = "talent", value = talent})

  
  	role:log("hero_talent", {
  		hero_id = hero:getProperty("type"), --英雄ID
  		hero_talent_stagebef = oldStage, --英雄精进升级前停留阶段
  		hero_talent_stage = curStage, --英雄精进升级后停留阶段

  		hero_talent_cost = cost, --英雄精进升级消耗，json格式记录，{道具ID1：消耗数量1,道具ID2：消耗数量2,….}

  		hero_talent_subid = curData[oldLevel].effect, --升级属性ID，生命、攻击、防御、命中、闪避分别对应（0，1，2，3，4）
  		hero_talent_sublevel = curData[oldLevel].level, --升级属性等级，如生命升级从1到2，则记录2
  	})
  

  	hero:mylog({desc = "talent", int1 = talent:getv(0, 1), int2 = talent:getv(1, 1)})

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

  -- 暂时没有这个功能
  function _M.likeHeroRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local heroType = msg.type
  	local result = {status = 0}
  	local isLike = false
  	local hadLike = role:getProperty("likeHero"):toArray(true, "=")
  	for _, v in pairs(hadLike) do
  		if v == heroType then
  			isLike = true
  			break
  		end
  	end
  	if isLike then
  		result.status = 1
  	else
  		redisproxy:hincrby("hero:like", "hero:"..heroType, 1)
  		table.insert(hadLike, heroType)
  		role:setProperty("likeHero", table.concat(hadLike, "="))
  	end
  
  	SendPacket(actionCodes.Hero_likeHeroRpc, MsgPack.pack(result))
  	return true
  end
  local RankLikeNum = 5 --热度显示几个
  local TimeLikeNum = 95 -- 时间显示几个
  local function getCommentKey(heroType)
  	return {
  		commentListKey = string.format("list:%d:herocomments", heroType),
  		commentRankKey = string.format("rank:%d:herocomments", heroType),
  		commentKey = string.format("hero:%d:comments", heroType),
  	}
  end
  
  local function trimComment(heroType, commentId) -- 剪裁 CommentList
  	local commentKey = getCommentKey(heroType)
  	local redret = redisproxy:pipelining(function (red)
  		red:lpush(commentKey.commentListKey, commentId)
  		red:lrange(commentKey.commentListKey, TimeLikeNum,-1)
  		red:ltrim(commentKey.commentListKey, 0, TimeLikeNum - 1)
  		red:zrevrange(commentKey.commentRankKey, 0, RankLikeNum - 1)
  	end)
  	local hots = {}
  	for _, hot in pairs(redret[4]) do
  		hots[hot] = 1
  	end
  	redisproxy:pipelining(function (red)
  		local needDel = {}
  		for _, tempId in pairs(redret[2]) do
  			if not hots[tempId] then
  				table.insert(needDel, tempId)
  			end
  		end
  		if #needDel > 0 then
  			red:zrem(commentKey.commentRankKey, table_unpack(needDel))
  			red:hdel(commentKey.commentKey, table_unpack(needDel))
  		end
  	end)
  end
  
  
  function _M.commentHeroRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local heroType = msg.type
  	local content = msg.content
  
  	local result = {status = 0}  -- status 0 成功  1 已经评论过了
  	local curStutus = role.dailyData:getProperty("commentHero")
  	if curStutus:getv(heroType, 0) ~= 0 then
  		result.status = 1
  	else
  		local commentKey = getCommentKey(heroType)

  		local SERV = string.format(".chated%d", math.random(1, 5))

  		local legal, mod = skynet.call(SERV, "lua", "check", content)
  		if not legal then
  			content = mod or ""
  		end
  		local commentId = tostring(redisproxy:hincrby("hero:comment:autoincr", "hero:" .. heroType, 1))
  		local comment = {

  			commentId = commentId,

  			content = content,
  			roleId = role:getProperty("id"),
  			name = role:getProperty("name"),
  			-- time = skynet.timex()
  		}
  		redisproxy:hset(commentKey.commentKey, commentId, json.encode(comment))
  		trimComment(heroType, commentId)
  
  		comment.like = 0
  		result.comment = comment
  		role.dailyData:setProperty("commentHero", curStutus:setv(heroType, 1))

  
  
  		role:log("hero_note", {
  			hero_id = heroType, -- 英雄ID
  			hero_note_action = 0, -- 英雄评价界面操作，发布评论：0，点赞：1，反对：2
  			hero_note_id = commentId, -- 操作的评价ID
  			hero_note_text = content, -- 操作的评价内容
  		})

  	end
  	SendPacket(actionCodes.Hero_commentHeroRpc, MsgPack.pack(result))
  	return true
  end
  
  function _M.getCommentsRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local heroType = msg.type
  	local list = {}  -- 评论列表
  	local commentKey = getCommentKey(heroType)
  	local commentRoleKey = string.format("comment:%d:like", role:getProperty("id"))
  	local redret = redisproxy:pipelining(function (red)
  		red:lrange(commentKey.commentListKey, 0,TimeLikeNum - 1)
  		red:zrevrange(commentKey.commentRankKey, 0, -1, "WITHSCORES") --热门
  		red:hget("hero:like", "hero:"..heroType)
  		red:lrange(commentRoleKey, 0, 999)
  	end)
  
  	local likeMap = {}
  	local idList = {}
  	local liked = {}
  	for i = 1, #redret[2], 2 do
  		likeMap[redret[2][i]] = redret[2][i + 1]
  		if i < RankLikeNum * 2 then
  			table.insert(idList, redret[2][i])
  		end
  	end
  	for i = 1, #redret[1] do
  		table.insert(idList, redret[1][i])
  	end
  	for i = 1, #redret[4] do
  		liked[redret[4][i]] = 1
  	end
  
  	local commentData = redisproxy:pipelining(function (red)
  		for _, commentId in ipairs(idList) do
  			red:hget(commentKey.commentKey, commentId)
  		end
  	end)
  	for _, commentS in ipairs(commentData or {}) do
  		local comment = json.decode(commentS)
  		comment.like = likeMap[tostring(comment.commentId)] or 0
  		comment.liked = liked[heroType .. ":" .. comment.commentId] or 0
  		table.insert(list, comment)
  	end
  	SendPacket(actionCodes.Hero_getCommentsRpc, MsgPack.pack({list = list, like = tonumber(redret[3] or 0)}))
  	return true
  end
  
  function _M.likeCommentRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local actType = msg.actType  -- 1 顶 2 踩
  	local heroType = msg.type
  	local commentId = msg.commentId  --评论id
  	local commentKey = getCommentKey(heroType)
  	local add = 0
  	if actType == 1 then
  		add = 1
  	elseif actType == 2 then
  		add = -1
  	else

  		return

  	end
  

  	local result = {status = 0}
  	local commentIndex = heroType .. ":" .. commentId

  	local commentRoleKey = string.format("comment:%d:like", role:getProperty("id"))
  	local redret = redisproxy:pipelining(function (red)

  		red:hget(commentKey.commentKey, commentId)

  		red:lrem(commentRoleKey, 1, commentIndex)
  		red:lpush(commentRoleKey, commentIndex)
  		red:ltrim(commentRoleKey, 0, 999)
  	end)
  	if (tonumber(redret[2]) or 0) > 0 then
  		result.status = 1
  	else

  		if redret[1] then-- 查不到也返回ture
  			local comment = json.decode(redret[1])

  			local redret2 = redisproxy:pipelining(function (red)
  				red:zrevrange(commentKey.commentRankKey, 0, RankLikeNum - 1) --热门
  				red:zincrby(commentKey.commentRankKey, add, commentId)
  				red:zrevrange(commentKey.commentRankKey, 0, RankLikeNum - 1) --热门
  			end)
  			local out = {}
  			for _, v in pairs(redret2[1]) do
  				out[v] = 1
  			end
  			local new = {}
  			for _, v in pairs(redret2[3]) do
  				if out[v] then
  					out[v] = nil
  				else
  					new[v] = 1
  				end
  			end
  			for tempId, _ in pairs(out) do
  				trimComment(heroType, tempId)
  			end
  			redisproxy:pipelining(function (red)
  				for tempId, _ in pairs(new) do
  					red:lrem(commentKey.commentListKey, 0, tempId)
  				end
  			end)

  
  			role:log("hero_note", {
  				hero_id = heroType, -- 英雄ID
  				hero_note_action = add > 0 and 1 or 2, -- 英雄评价界面操作，发布评论：0，点赞：1，反对：2
  				hero_note_id = commentId, -- 操作的评价ID
  				hero_note_text = comment.content, -- 操作的评价内容
  			})

  		end
  	end
  
  	SendPacket(actionCodes.Hero_likeCommentRpc, MsgPack.pack(result))
  	return true
  end
  

  function _M.createHeroRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local heroType = msg.heroType
  	local unitData = csvdb["unitCsv"][heroType]
  	if not unitData then return end
  	local cost = globalCsv.unit_fragment_cost[unitData["rare"]]
  	if not cost then return end
  	if role:getItemCount(heroType) < cost then return end
  
  	for _, hero in pairs(role.heros) do
  		if hero:getProperty("type") == heroType then return end
  	end
  

  	role:costItems({[heroType] = cost}, {log = {desc = "createHero"}})
  	role:award({[heroType + ItemStartId.Hero] = 1}, {log = {desc = "createHero"}})

  
  	SendPacket(actionCodes.Hero_createHeroRpc, "")
  	return true
  end
  

  -- typ 位置，level等级对应唯一装备,level为0时为移除，不为0时无则装备,有则替换

  function _M.referEquipsRpc(agent, data)

  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local hero = role.heros[msg.id]
  	if not hero then return 10 end
  	local equips = msg.equips

  	local isAuto = msg.isAuto

  	if not equips or not next(equips) then return 11 end
  

  	for typ = 1, 4 do -- 4件装备
  		if equips[typ] and equips[typ] ~= 0 then
  			if role:getEquipCount(typ, equips[typ]) <= 0 then
  				return
  			end

  		end

  	end

  	local oldBattleV = hero:getProperty("battleV")
  	local wear = {}
  

  	local curEquip = hero:getProperty("equip")
  	for typ = 1, 4 do -- 4件装备
  		if equips[typ] then
  			local cur = curEquip:getv(typ, 0)

  			if cur ~= equips[typ] then
  				if equips[typ] == 0 then

  					curEquip = curEquip:delk(typ)

  				else

  					role:addEquip(typ, equips[typ], -1, {log = {desc = "refer"}}) -- 穿上

  					curEquip = curEquip:setv(typ, equips[typ])

  
  					wear[typ] = {id = equips[typ], act = 0}

  				end

  
  				if cur ~= 0 then

  					role:addEquip(typ, cur, 1, {log = {desc = "refer"}}) -- 脱掉

  
  					wear[typ] = {id = cur, act = 1}

  				end

  			end
  		end

  	end

  	-- 更新角色
  	hero:updateProperty({field = "equip", value = curEquip})
  

  	for typ, data in pairs(wear) do

  		role:log("equip_wear", {

  			hero_id = hero:getProperty("type"), --英雄ID
  			equip_id = data.id, --装备ID
  			equip_wear_action = data.act, --装备操作类型：装备：0，卸载：1
  			equip_wear_part = typ, --装备部位，记录部位ID

  			equip_wear_scorebef = oldBattleV,	--装备前英雄评分
  			equip_wear_score = hero:getProperty("battleV"), --装备后英雄评分

  			equip_wear_mode = isAuto and 0 or 1, --用以区分自动装备还是手动装备，自动记录为0，手动记录为1
  		})
  	end

  	SendPacket(actionCodes.Hero_referEquipsRpc, "")
  	return true
  end
  

  -- typ 位置，uid对应唯一符文,uid为0时为移除，不为0时无则装备,有则替换
  function _M.referRunesRpc(agent, data)

  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local hero = role.heros[msg.id]
  	if not hero then return 10 end
  	local runes = msg.runes
  	if not runes or not next(runes) then return 11 end

  	local used = {}

  	for typ = 1, 6 do
  		if runes[typ] and runes[typ] ~= 0 then
  			local ownRune = role.runeBag[runes[typ]]
  			if not ownRune then return end

  			if ownRune:getProperty("refer") ~= 0 then 
  				used[ownRune:getProperty("refer")] = used[ownRune:getProperty("refer")] or {}
  				used[ownRune:getProperty("refer")][runes[typ]] = 1
  			end
  		end
  	end
  
  	for cheroId, cIds in pairs(used) do
  		local chero = role.heros[cheroId] 
  		local hrunes = chero:getProperty("rune")
  		for slot, rId in pairs(hrunes:toNumMap()) do
  			if cIds[rId] then
  				hrunes = hrunes:delk(slot)
  			end

  		end

  		chero:updateProperty({field = "rune", value = hrunes})

  	end

  	local oldAttr = hero:getTotalAttrs()
  	local oldBattleV = hero:getProperty("battleV")
  	local wear = {}

  	local curRune = hero:getProperty("rune")
  	for typ = 1, 6 do
  		if runes[typ] then
  			local cur = curRune:getv(typ, 0)
  			if cur ~= runes[typ] then
  				if runes[typ] == 0 then
  					curRune = curRune:delk(typ)
  				else
  					local newRune = role.runeBag[runes[typ]]
  					newRune:updateProperty({field = "refer",value = hero:getProperty("id")})

  					curRune = curRune:setv(typ, runes[typ])

  					wear[runes[typ]] = typ

  				end

  				if cur ~= 0 then
  					local oldR = role.runeBag[cur]
  					if oldR then
  						oldR:updateProperty({field = "refer",value = 0})
  					end
  				end

  			end

  		end

  	end

  	hero:updateProperty({field = "rune", value = curRune})

  
  	local attrChange = getChangeAttrJson(oldAttr, hero:getTotalAttrs())
  	for runeId, typ in pairs(wear) do
  		local ownRune = role.runeBag[runeId]

  		if ownRune then
  			role:log("hero_jewel", {
  				hero_id = hero:getProperty("type"), -- 英雄ID
  				hero_jewel_id = ownRune:getProperty("id"), -- 铭文ID
  				hero_jewel_part = typ, -- 铭文装备部位
  				hero_jewel_score = hero:getProperty("battleV"), -- 铭文装备后的英雄分值
  				hero_jewel_scorebefore = oldBattleV, -- 铭文装备前的英雄分值
  				hero_jewel_result = attrChange, -- 铭文装备后效果，可记录效果ID，或json格式记录提升效果，{攻击：20,闪避：20,……..}
  			})
  		end

  	end

  
  	role:checkTaskEnter("RuneQualityCollect", {})

  	SendPacket(actionCodes.Hero_referRunesRpc, "")

  	return true
  end
  

  function _M.createHeroRandomRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)
  	local itemId = msg.itemId
  	local itemData = csvdb["itemCsv"][itemId]
  	if not itemData or itemData.type ~= ItemType.HeroFCommon then return end
  	local cost = globalCsv.unit_fragment_cost[itemData.quality]

  	if not cost or role:getItemCount(itemId) < cost then return 1 end

  
  	local randomData = csvdb["item_randomCsv"][tonumber(itemData.use_effect)]

  	if not randomData then return 2 end

  	local temp = randomData.gift1:randWeight(true)

  	if not temp or not next(temp) then return 3 end

  	role:costItems({[itemId] = cost}, {log = {desc = "createHeroRandom"}})

  	local reward, change = role:award({[temp[1]] = 1}, {log = {desc = "createHeroRandom"}})

  
  
  	SendPacket(actionCodes.Hero_createHeroRandomRpc, MsgPack.pack(role:packReward(reward, change)))

  	return true
  end
  

  function _M.getResetRewardRpc(agent, data)
  	local role = agent.role
  	local msg = MsgPack.unpack(data)

  	
  	local hero = role.heros[msg.id]
  	if not hero then return end
  
  	local level = hero:getProperty("level")
  	local breakL = hero:getProperty("breakL")
  	local talent = hero:getProperty("talent")

  	local heroCfgId = hero:getProperty("type")

  	local tmpLevel = level

  	if level <= 1 and talent == "" then return end
  

  	local pay = true

  	if level <= 60 or role.activity:isOpen("HeroBackFree") then

  		pay = false
  	end
  

  	if pay then
  		local costArr = globalCsv.unit_heroBack_cost:toArray(true, "=")
  		local itemCount = role:getItemCount(costArr[1])
  		local totalCost = {}
  		if itemCount >= costArr[2] then
  			totalCost[costArr[1]] = costArr[2]
  		else
  			local diamond = (costArr[2] - itemCount) * costArr[3]
  			if role:getItemCount(ItemId.Diamond) < diamond then
  				return 1
  			end
  			totalCost[costArr[1]] = itemCount
  			totalCost[ItemId.Diamond] = diamond
  		end
  
  		--if pay and not role:costDiamond({count = globalCsv.unit_heroBack_cost or 200, log = {desc = "resetHero", int1 = msg.id}}) then
  		--	return 1
  		--end
  		role:costItems(totalCost, {log = {desc = "resetHero", int1 = msg.id}})

  	end
  

  	local reward = {}
  	while level > 1 do
  		local curData = csvdb["unit_expCsv"][level - 1]
  		reward[ItemId.Exp] = (reward[ItemId.Exp] or 0) + curData.exp
  		reward[ItemId.Gold] = (reward[ItemId.Gold] or 0) + curData.gold
  		level = level - 1
  	end
  
  	while breakL > 0 do
  		local curData = csvdb["unit_breakCsv"][breakL - 1]
  		reward[ItemId.BreakCost] = (reward[ItemId.BreakCost] or 0) + curData.cost
  		reward[ItemId.Gold] = (reward[ItemId.Gold] or 0) + curData.gold
  		breakL = breakL - 1
  	end
  
  	local stage = talent:getv(0, 1)

  	local curTalentLvl = talent:getv(1, 1)
  	--local tlevel = {talent:getv(1, 0), talent:getv(2, 0), talent:getv(3, 0), talent:getv(4, 0)}

  	while stage > 0 do

  		local curData = csvdb["unit_talent_"..heroCfgId.."Csv"][stage]

  		local offset = stage == talent:getv(0,1) and curTalentLvl - 1 or #curData
          for lvl = 1, offset do