397 lines
11 KiB
Lua
397 lines
11 KiB
Lua
local LoginManager = class("LoginManager", BaseModule)
|
|
|
|
LoginManager.TRY_LOGIN_TIME = 5
|
|
LoginManager.SERVER_LIST = {}
|
|
LoginManager.selectIndex = 0
|
|
|
|
function LoginManager:showLoginUI()
|
|
if not Platform:getIsPublishChannel() then
|
|
self:showTestLoginUI()
|
|
return
|
|
end
|
|
UIManager:showUI("app/module/login/login_ui")
|
|
end
|
|
|
|
function LoginManager:showTestLoginUI()
|
|
UIManager:showUI("app/module/login/test_login_ui")
|
|
end
|
|
|
|
---- 登录界面资源加载完毕后调用
|
|
function LoginManager:loginGame()
|
|
-- adjust 打开应用事件识别码
|
|
BIReport:postAdjustSimpleTrackEvent("xbszrl", {})
|
|
ModuleManager.MaincityManager:firstEnterMainCity()
|
|
end
|
|
|
|
function LoginManager:goToLoginScene()
|
|
ModuleManager.BattleManager:clearOnExitScene()
|
|
UIManager:backToLoginWithoutLogout()
|
|
DataManager:clear()
|
|
end
|
|
|
|
function LoginManager:getClientInfo()
|
|
local clientInfo = {}
|
|
local bundleId = Platform:getIdentifier()
|
|
local version = Platform:getClientVersion()
|
|
local device = DeviceHelper:getDeviceModel()
|
|
local deviceId = DeviceHelper:getDeviceId()
|
|
local deviceOS = DeviceHelper:getOSVersion()
|
|
local platform = Platform:getPlatform()
|
|
local accountType = SDKManager.LOGIN_TYPE[LocalData:getInt(LocalData.KEYS.SDK_LOGIN_TYPE, SDKManager.BF_LOGIN_TYPE.GUEST)]
|
|
local ip = LocalData:getLastLoginIp()
|
|
local networkType = DeviceHelper:getNetworkType()
|
|
local language = I18N:getLanguageAndArea()
|
|
local timezone = SDKManager:getTimeZone()
|
|
clientInfo.bundle_id = bundleId
|
|
clientInfo.version = version
|
|
clientInfo.device = device
|
|
clientInfo.device_id = deviceId
|
|
clientInfo.os_version = deviceOS
|
|
clientInfo.platform = platform
|
|
clientInfo.account_type = accountType
|
|
clientInfo.ip = ip
|
|
clientInfo.network_type = networkType
|
|
clientInfo.language = language
|
|
clientInfo.timezone = timezone
|
|
return clientInfo
|
|
end
|
|
|
|
|
|
function LoginManager:initSocket()
|
|
local isConnected = NetManager:isConnected(NetManager.MAIN_SOCKET_NAME)
|
|
if EDITOR_MODE then
|
|
Logger.logHighlight("LoginMgr:initSocket:%s", isConnected)
|
|
end
|
|
if not isConnected then
|
|
NetManager:init(
|
|
function()
|
|
self:connectByChannel(
|
|
function()
|
|
if EDITOR_MODE then
|
|
Logger.logHighlight("主链接链接成功")
|
|
end
|
|
self:_login()
|
|
end
|
|
)
|
|
end
|
|
)
|
|
end
|
|
end
|
|
|
|
function LoginManager:connectByChannel(callback, socketName)
|
|
socketName = socketName or NetManager.MAIN_SOCKET_NAME
|
|
local domain
|
|
local port
|
|
if socketName == NetManager.MAIN_SOCKET_NAME then
|
|
local gate = LocalData:getString(LocalData.KEYS.GATE)
|
|
local arr = string.split(gate, ":")
|
|
domain = arr[1]
|
|
port = arr[2]
|
|
else
|
|
domain = NetManager:getChatDomain()
|
|
port = NetManager:getChatPort()
|
|
end
|
|
NetManager:connect(domain, port, function()
|
|
if callback then
|
|
callback()
|
|
end
|
|
end, socketName)
|
|
end
|
|
|
|
function LoginManager:goToLoginScene()
|
|
ModuleManager.BattleManager:clearOnExitScene()
|
|
NetManager:closeAndClear()
|
|
UIManager:backToLoginWithoutLogout()
|
|
DataManager:clear()
|
|
end
|
|
|
|
|
|
function LoginManager:_login()
|
|
LocalData:saveEmptySendQueue()
|
|
|
|
local skipGuide = nil
|
|
if EDITOR_MODE then
|
|
-- skipGuide = LocalData:getSkipTutorial()
|
|
end
|
|
local clientInfo = self:getClientInfo()
|
|
if EDITOR_MODE then
|
|
print("LoginReq===============================xxxx1")
|
|
for k, v in pairs(clientInfo) do
|
|
print(k, " = ", v)
|
|
end
|
|
print("LoginReq===============================xxxx2")
|
|
end
|
|
local args = {
|
|
client_info = clientInfo,
|
|
skip_guide = skipGuide,
|
|
}
|
|
self:sendMessage(
|
|
ProtoMsgType.FromMsgEnum.LoginReq,
|
|
args,
|
|
{},
|
|
self.loginFinish
|
|
)
|
|
end
|
|
|
|
function LoginManager:loginFinish(data)
|
|
if data.status == 0 then
|
|
UIManager:clearUIPrefabCache() -- 先清理下缓存
|
|
ConfigManager:preLoadConfig()
|
|
ServerPushManager:initWhenLogin()
|
|
DataManager:initWithServerData(data)
|
|
|
|
local data = {}
|
|
data.max_chapter = DataManager.ChapterData:getNewChapterId()
|
|
-- data.ads_num = DataManager.PlayerData:getAdCount()
|
|
-- data.pay_money = DataManager.PlayerData:getPaymentCount()
|
|
data.play_days = DataManager.PlayerData:getLoginDay()
|
|
data.now_version = Platform:getClientVersion()
|
|
CS.ThinkingAnalytics.ThinkingAnalyticsAPI.UserSet(data)
|
|
|
|
EventManager:dispatchEvent(EventManager.CUSTOM_EVENT.LOGIN_REQ_SUCCESS)
|
|
-- ModuleManager.MailManager:getMailList(true)
|
|
DataManager:setLoginSuccess(true)
|
|
BIReport:postGameLoginFinish()
|
|
|
|
local info = LocalData:getLastLoginInfo()
|
|
BIReport:postAccountLoginFinish(info.type)
|
|
else
|
|
local info = LocalData:getLastLoginInfo()
|
|
BIReport:postAccountLoginFailed(info.type, data.err_code)
|
|
end
|
|
end
|
|
|
|
function LoginManager:saveAuthArgs(name)
|
|
local args = LocalData:getLastLoginInfo()
|
|
if name then
|
|
args.type = NetManager.LOGIN_TYPE.ANONYMOUS
|
|
args.id = name
|
|
args.token = nil
|
|
LocalData:setLastLoginName(name)
|
|
LocalData:setLastLoginInfo(args.type, args.id, args.token)
|
|
end
|
|
|
|
args.client_info = self:getClientInfo()
|
|
local sendQueue = LocalData:getSendQueue()
|
|
args.sync =
|
|
{
|
|
pip = GFunc.getArray()
|
|
}
|
|
|
|
if sendQueue and sendQueue[1] then
|
|
local ProtoMsgDispatch = require "app/proto/proto_msg_dispatch"
|
|
local pb = require "pb"
|
|
for _, info in ipairs(sendQueue) do
|
|
local curParams = info.params
|
|
local needAd = false
|
|
if info.msgName == ProtoMsgType.FromMsgEnum.PipedReq then
|
|
local msgName = ProtoMsgDispatch:getReqMsgNameByMsgId(curParams.msg_id)
|
|
if msgName then
|
|
local fullMsgName = ProtoMsgDispatch:getMsgFullNameByMsgName(msgName)
|
|
if fullMsgName then
|
|
if curParams.data and type(curParams.data) == "table" then
|
|
local ok, pbData = pcall(function()
|
|
return pb.encode(fullMsgName, curParams.data)
|
|
end)
|
|
if ok then
|
|
needAd = true
|
|
curParams.data = pbData
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|
|
if needAd then
|
|
table.insert(args.sync.pip, curParams)
|
|
end
|
|
end
|
|
end
|
|
|
|
NetManager:saveAuthArgs(args)
|
|
end
|
|
|
|
|
|
function LoginManager:resetServerListStartTime()
|
|
self.accountLoginSuccess = false
|
|
self.connectStartTimes = os.clock()
|
|
self.retryTimes = 0
|
|
end
|
|
|
|
function LoginManager:addServerListCallback(callback)
|
|
self.loginCallback = callback
|
|
end
|
|
|
|
function LoginManager:removeAllLoginData()
|
|
self.loginCallback = nil
|
|
self.versionInfoStr = nil
|
|
self.versionInfo = nil
|
|
-- self.connectStartTimes = nil
|
|
self.retryTimes = 0
|
|
end
|
|
|
|
function LoginManager:showServerNotOpenMessage()
|
|
local params = {
|
|
content = I18N:getGlobalText(I18N.GlobalConst.SERVER_MAINTAINED),
|
|
boxType = GConst.MESSAGE_BOX_TYPE.MB_OK,
|
|
okText = I18N:getGlobalText(I18N.GlobalConst.BTN_TEXT_OK),
|
|
okFunc = function()
|
|
self:checkServerOpen()
|
|
end,
|
|
}
|
|
GFunc.showMessageBox(params)
|
|
end
|
|
|
|
function LoginManager:getIsNeedHotUpdate()
|
|
local serverVersion = self.versionInfo.version
|
|
local clientVersion = CS.BF.BFMain.Instance.GameLaunchMgr:GetCurrentVersion()
|
|
if serverVersion == nil or serverVersion == "" or clientVersion == nil or clientVersion == "" then
|
|
return true
|
|
end
|
|
return serverVersion ~= clientVersion
|
|
end
|
|
|
|
function LoginManager:showNewVersionFoundMessage()
|
|
local params = {
|
|
content = I18N:getGlobalText(I18N.GlobalConst.NEW_VERSION_FOUND),
|
|
boxType = GConst.MESSAGE_BOX_TYPE.MB_OK,
|
|
okText = I18N:getGlobalText(I18N.GlobalConst.BTN_TEXT_OK),
|
|
okFunc = function()
|
|
local storeUrl = self.versionInfo.store_url
|
|
if storeUrl == nil or storeUrl == "" then
|
|
CS.UnityEngine.Application.Quit()
|
|
else
|
|
CS.UnityEngine.Application.OpenURL(storeUrl)
|
|
end
|
|
end,
|
|
}
|
|
GFunc.showMessageBox(params)
|
|
end
|
|
|
|
function LoginManager:getIsclientLessThanMinVersion()
|
|
local minVersion = self.versionInfo.min_version
|
|
local clientVersion = CS.BF.BFMain.Instance.GameLaunchMgr:GetCurrentVersion()
|
|
if minVersion == nil or minVersion == "" or clientVersion == nil or clientVersion == "" then
|
|
return true
|
|
end
|
|
if minVersion == clientVersion then
|
|
return false
|
|
end
|
|
|
|
local update, bigVersion = GFunc.compareVersionThan(minVersion, clientVersion, false)
|
|
|
|
return bigVersion or false
|
|
end
|
|
|
|
function LoginManager:checkServerOpen()
|
|
local serverOpenTime = tonumber(self.versionInfo.open_time or 0)
|
|
local clientTime = os.time()*1000
|
|
if clientTime < serverOpenTime then -- 未开服
|
|
self:showServerNotOpenMessage()
|
|
return
|
|
end
|
|
|
|
if EDITOR_MODE or GConst.SKIP_VERSION then
|
|
CS.BF.BFMain.Instance.GameLaunchMgr.LaunchRequester:SetVersionInfo(self.versionInfoStr)
|
|
if self.loginCallback and self.versionInfo then
|
|
self.loginCallback(self.versionInfo.game_urls)
|
|
end
|
|
else
|
|
-- 需要更新整包
|
|
if self:getIsclientLessThanMinVersion() then
|
|
self:showNewVersionFoundMessage()
|
|
elseif self:getIsNeedHotUpdate() then -- 需要热更新
|
|
Game:destroyAll()
|
|
CS.BF.BFMain.Instance.GameLaunchMgr:LaunchForRelogin(self.versionInfoStr)
|
|
else
|
|
CS.BF.BFMain.Instance.GameLaunchMgr.LaunchRequester:SetVersionInfo(self.versionInfoStr)
|
|
if self.loginCallback then
|
|
self.loginCallback(self.versionInfo.game_urls)
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
function LoginManager:getServerList(callback)
|
|
if self.accountLoginSuccess then
|
|
if self.authSid then
|
|
self:unscheduleGlobal(self.authSid)
|
|
self.authSid = nil
|
|
end
|
|
return
|
|
end
|
|
self.loginCenterUrl = CS.BF.BFPlatform.GetLoginCenterURL()
|
|
self.retryTimes = self.retryTimes + 1
|
|
|
|
SDKManager:getServerList(function(isSuccess, data)
|
|
if self.accountLoginSuccess then
|
|
if self.authSid then
|
|
self:unscheduleGlobal(self.authSid)
|
|
self.authSid = nil
|
|
end
|
|
return
|
|
end
|
|
if isSuccess and data and data ~= "" then
|
|
self.versionInfoStr = data
|
|
local jsonData = json.decode(data or "")
|
|
if not jsonData.game_urls[1] then -- 保证服务器列表中必须有一个服务器
|
|
local params = {
|
|
content = I18N:getGlobalText(I18N.GlobalConst.GET_SEVER_ERROR),
|
|
okText = I18N:getGlobalText(I18N.GlobalConst.BTN_TEXT_OK),
|
|
noShowClose = true,
|
|
okFunc = function()
|
|
self:getServerList()
|
|
end,
|
|
boxType = GConst.MESSAGE_BOX_TYPE.MB_OK,
|
|
top = true,
|
|
}
|
|
GFunc.showMessageBox(params)
|
|
return
|
|
end
|
|
|
|
UIManager:hideToast()
|
|
-- BIReport:postRequestVersionSuccess(self.loginCenterUrl, (os.clock() - self.connectStartTimes)*1000, self.retryTimes - 1)
|
|
self.accountLoginSuccess = true
|
|
if self.authSid then
|
|
self:unscheduleGlobal(self.authSid)
|
|
self.authSid = nil
|
|
end
|
|
|
|
self.versionInfo = jsonData
|
|
Logger.printTable(jsonData)
|
|
self:checkServerOpen()
|
|
else
|
|
-- BIReport:postRequestVersionFailed(self.loginCenterUrl, (os.clock() - self.connectStartTimes)*1000, self.retryTimes - 1)
|
|
local params = {
|
|
content = I18N:getGlobalText(I18N.GlobalConst.GET_SEVER_ERROR),
|
|
okText = I18N:getGlobalText(I18N.GlobalConst.BTN_TEXT_OK),
|
|
noShowClose = true,
|
|
okFunc = function()
|
|
self:getServerList()
|
|
end,
|
|
boxType = GConst.MESSAGE_BOX_TYPE.MB_OK,
|
|
top = true,
|
|
}
|
|
GFunc.showMessageBox(params)
|
|
end
|
|
end)
|
|
|
|
if self.authSid then
|
|
self:unscheduleGlobal(self.authSid)
|
|
end
|
|
self.authSid = self:performWithDelayGlobal(function()
|
|
-- BIReport:postRequestVersionFailed(self.loginCenterUrl, (os.clock() - self.connectStartTimes)*1000, self.retryTimes - 1)
|
|
local params = {
|
|
content = I18N:getGlobalText(I18N.GlobalConst.GET_SEVER_ERROR),
|
|
okText = I18N:getGlobalText(I18N.GlobalConst.BTN_TEXT_OK),
|
|
noShowClose = true,
|
|
okFunc = function()
|
|
self:getServerList()
|
|
end,
|
|
boxType = GConst.MESSAGE_BOX_TYPE.MB_OK,
|
|
top = true,
|
|
}
|
|
GFunc.showMessageBox(params)
|
|
end, 5)
|
|
end
|
|
|
|
return LoginManager |