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 httpc = require("http.httpc")
  
  local WAVE_HERO_NUMS = 150
  local WAVE_EQUIP_NUMS = 150
  
  local function validName(name)
  	name = string.upper(name)
  	local exist = redisproxy:exists(string_format("user:%s", name))
  	if exist then return "existed" end
  
  	local SERV = string_format("NAMED%d", math.random(1, 5))
  	local legal = skynet.call(SERV, "lua", "check", name)
  	return legal and "ok" or "illegal"
  end
  
  -- 随机玩家名
  local function randomRoleName()
  	-- 过滤已经存在的名字
  	local name
  	repeat
  		name = getRandomName()
  	until validName(name) == "ok"
  	return name
  end
  
  local function setRoleName(uid, roleId)
  	local result
  	local name
  	local dbName
  	repeat
  		name = randomRoleName()
  		dbName = string.upper(name)
  		result = redisproxy:setnx(string_format("user:%s", dbName), roleId)
  	until result == 1
  	redisproxy:set(string_format("uid:%s", uid), dbName)
  	return name
  end
  
  local _M = {}
  function _M.loginRpc( agent, data )
  	local msg = MsgPack.unpack(data)
  	local response = {}
  
  	if msg.version ~= globalCsv.version then
  		response.result = "UPDATE_TIP"
  		SendPacket(actionCodes.Role_loginRpc, MsgPack.pack(response))
  		return true
  	end
  
  	-- 1.
  	local roleId = redisproxy:get(string_format("user:%s", string.upper(msg.name)))
  	if not roleId then
  		response.result = "NOT_EXIST"
  		SendPacket(actionCodes.Role_loginRpc, MsgPack.pack(response))
  		return true
  	end
  
  	roleId = tonumber(roleId)
  
  	--维护不能登录
  	local maintain = tonumber(redisproxy:hget("autoincrement_set", "maintain"))
  	if maintain and maintain > 0 then
  		if tonumber(redisproxy:hget(string_format("role:%d", roleId), "ignoreMaintain")) ~= 1 then
  			response.result = "MAINTAIN_TIP"
  			SendPacket(actionCodes.Role_loginRpc, MsgPack.pack(response))
  			return true
  		end
  	end
  
  	local now = skynet.timex()
  	local role = agent.role
  	-- 2
  	if not role then
  		local roleKey = string_format("role:%d", roleId)
  		if not redisproxy:exists(roleKey) then
  			response.result = "DB_ERROR"
  			SendPacket(actionCodes.Role_loginRpc, MsgPack.pack(response))
  			return true
  		end
  		-- 2a
  		role = require("models.Role").new({key = roleKey})
  		role:load()
  		role:loadAll()
  	else
  		role:reloadWhenLogin()
  	end
  	
  	if not msg.isGMlogin then
  		local banTime = role:getProperty("banTime")
  		if banTime > now then
  			response.result = "BAN_TIP"
  			response.banTime = banTime
  			response.banType = role:getProperty("banType")
  			response.roleId = roleId
  			SendPacket(actionCodes.Role_loginRpc, MsgPack.pack(response))
  			return true
  		end
  		if banTime ~= 0 then
  			-- 清除封号状态
  			role:setBan(0)
  		end
  	end
  	SERV_OPEN = redisproxy:hget("autoincrement_set", "server_start")
  	local lastLoginTime = role:getProperty("lastLoginTime")
  
  	-- 跨天登陆事件
  	if not role:onCrossDay(now) then
  		role:checkActivityStatus(lastLoginTime, now)
  		if role:getProperty("carbonDouble") == "" then
  			role:initCarbonDouble()
  		end
  	end
  	-- 登陆回复
  	role:onRecoverLogin(now)
  	-- 引导是否连续
  	role:checkGuide()
  
  
  	role:setProperty("lastLoginTime", now)
  	if msg.device and type(msg.device) == "string" then
  		role:setProperty("device", msg.device)
  	end
  
  	response.role = role:data()
  	response.result = "SUCCESS"
  	response.serverTime = now
  
  	-- 需要加载模块数据
  	local modules = {
  		"carbons","maps",
  	}
  
  	local heroIds = {}
  	for heroId, _ in pairs(role.heros) do
  		table.insert(heroIds, heroId)
  	end
  	local heroWave = math.ceil(#heroIds / WAVE_HERO_NUMS)
  
  	local equipIds = {}
  	for equipId, _ in pairs(role.equips) do
  		table.insert(equipIds, equipId)
  	end
  	local equipWave = math.ceil(#equipIds / WAVE_EQUIP_NUMS)
  
  	if #heroIds <= 50 then
  		heroWave = 0
  		table_insert(modules, "heros")
  	end
  	if #equipIds <= 50 then
  		equipWave = 0
  		table_insert(modules, "equips")
  	end
  
  	for _, name in ipairs(modules) do
  		response[name] = {}
  		for id, unit in pairs(role[name]) do
  			response[name][id] = unit:data()
  		end
  	end
  	response.wave = 1 + heroWave + equipWave
  
  	SendPacket(actionCodes.Role_loginRpc, MsgPack.pack(response))
  
  	local heroIndex = 1
  	for index = 2, 1 + heroWave do
  		local heroResponse = {heros = {}}
  		for i = heroIndex, heroIndex + WAVE_HERO_NUMS do
  			local heroId = heroIds[i]
  			if not heroId then
  				break
  			end
  			local hero = role.heros[heroId]
  			table_insert(heroResponse.heros, hero:data())
  			heroIndex = heroIndex + 1
  		end
  		heroResponse.heroWave = index
  		SendPacket(actionCodes.Role_loginRpc, MsgPack.pack(heroResponse))
  	end
  	local equipIndex = 1
  	for index = 2 + heroWave, 1 + heroWave + equipWave  do
  		local equipResponse = {equips = {}}
  		for i = equipIndex, equipIndex + WAVE_EQUIP_NUMS do
  			local equipId = equipIds[i]
  			if not equipId then
  				break
  			end
  			local equip = role.equips[equipId]
  			table_insert(equipResponse.equips, equip:data())
  			equipIndex = equipIndex + 1
  		end
  		equipResponse.equipWave = index
  		SendPacket(actionCodes.Role_loginRpc, MsgPack.pack(equipResponse))
  	end
  
  	-- role:log("login", { ip = agent.ip, diamond = role:getProperty("diamond"), reDiamond = role:getProperty("reDiamond")})
  
  	datacenter.set("agent", roleId, {
  		serv = skynet.self(),
  		fd = agent.client_fd,
  		gate_serv = agent.gate_serv,
  	})
  	agent.role = role
  	role.lessmsg = false
  	
  	start_agent_timer()
  	-- 注册全服广播
  	local channel = math.randomInt(1, 1)
  	local w_channel = datacenter.get( ("MC_W_CHANNEL" .. channel) )
  	if w_channel then
  		mcast_util.sub_world(w_channel)
  	end
  	return true
  end
  
  function _M.createRpc(agent, data)
  	local msg = MsgPack.unpack(data)
  	local response = {}
  
  	-- 再次检查uid
  	local uid = tostring(msg.uid)
  	local user = redisproxy:get(string_format("uid:%s", uid))
  	if user then
  		response.result = "SUCCESS"
  		response.roleName = user
  		SendPacket(actionCodes.Role_createRpc, MsgPack.pack(response))
  		return true
  	end
  
  	local roleId = getNextRoleId()
  	if not roleId then
  		response.result = "DB_FULL"
  		SendPacket(actionCodes.Role_createRpc, MsgPack.pack(response))
  		return true
  	end
  	local roleName = setRoleName(msg.uid, roleId)
  
  	local newRole = require("models.Role").new({
  		key = string_format("role:%d", roleId),
  		id = roleId,
  		uid = tostring(msg.uid),
  		subId = msg.subId or 0,
  		name = roleName,
  		uname = msg.uname or "",
  		device = tostring(msg.device)
  	})
  
  	if newRole:create() then
  		--更新USER表
  		response.result = "SUCCESS"
  		response.roleId = roleId
  		response.roleName = string.upper(roleName)
  	else
  		response.result = "DB_ERROR"
  		SendPacket(actionCodes.Role_createRpc, MsgPack.pack(response))
  		return true
  	end
  
  	-- 给角色自动加载当前副本数据
  	newRole:addCarbon({carbonId = 10101, status = 0, starNum = 0})
  	-- 给角色自动加载农场信息
  	newRole:addFarm()
  	-- 给角色自动加载爬塔信息
  	newRole:addTower()
  	-- 给角色增加pvpInfo
  	newRole:addPvpInfo()
  	--给新角色增加diner
  	newRole:addDiner()
  	-- 关闭 锁定新食灵
  	local autoStatus = newRole:getProperty("autoStatus")
  	newRole:setProperty("autoStatus", autoStatus:setv(3,1))
  
  	for index, hero in ipairs(globalCsv["birthHero"]) do
  		hero.notNotify = true
  		hero.desc = "birth_award"
  		local heroId = newRole:awardHero(hero.type, hero)
  		if index == 1 then
  			local newHero = newRole.heros[heroId]
  			newHero:setProperty("lock", 1)
  			newHero:setProperty("formation", 1)
  			newRole:setProperty("crown", heroId)
  			newRole:setProperty("formationJson", json.encode({["1"] = {list = {["1"] = heroId}, pos = {["1"] = heroId}, lock = {}}}))
  		end
  	end
  	-- 出生道具
  	local ucode = getActionCode(newRole)
  	for id, num in pairs(globalCsv["birthItem"]:toNumMap()) do
  		newRole:awardItemCsv(id, {count = num, desc = "birth_award", notNotify = true, ucode = ucode})
  	end
  
  	-- 欢迎邮件
  	-- redisproxy:insertEmail({roleId = roleId, emailId = 1})
  	-- redisproxy:insertEmail({roleId = roleId, emailId = 2})
  
  	newRole:log("create", { ip = agent.ip, ucode = ucode})
  
  	SendPacket(actionCodes.Role_createRpc, MsgPack.pack(response))
  	return true
  end
  
  function _M.syncTimeRpc(agent, data)
  	SendPacket(actionCodes.Role_syncTimeRpc, MsgPack.pack({nowTime = skynet.timex()}))
  	return true
  end
  
  return _M