256 lines
11 KiB
Lua
256 lines
11 KiB
Lua
|
local skynet = require "skynet"
|
||
|
|
local oo = require "Class"
|
||
|
|
local log = require "Log"
|
||
|
|
local pb = require "pb"
|
||
|
|
local dataType = require "DataType"
|
||
|
|
local serverId = tonumber(skynet.getenv "serverId")
|
||
|
|
local Activity = oo.class()
|
||
|
|
|
||
|
|
Activity.UpdateTime = 0
|
||
|
|
Activity.ActivityInitHandler = {} --注册的活动初始化函数集合
|
||
|
|
Activity.ActivityCloseHandler = {} --注册的活动关闭函数集合
|
||
|
|
Activity.InProgressActivity = {} --进行中的活动
|
||
|
|
|
||
|
|
function Activity:Init()
|
||
|
|
if not skynet.server.clusterServer:IsGameServer( serverId ) then
|
||
|
|
return
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
--每5秒调一次
|
||
|
|
function Activity:On5SecTimer()
|
||
|
|
if not skynet.server.clusterServer:IsGameServer( serverId ) then
|
||
|
|
return
|
||
|
|
end
|
||
|
|
|
||
|
|
local nowTime = skynet.GetTime()
|
||
|
|
if math.abs(nowTime - self.UpdateTime) >= 60 then
|
||
|
|
self:ServerActivityWatch()
|
||
|
|
local playerList = skynet.server.playerCenter:GetPlayerList()
|
||
|
|
for userId, value in pairs(playerList) do
|
||
|
|
--每1分钟检查一次
|
||
|
|
if skynet.server.playerCenter.Status_Playing == value.status and skynet.server.activityManage:ChangeData(value.player, false) then
|
||
|
|
--该玩家有新的活动开启是主动推送当前活动信息
|
||
|
|
local data = {}
|
||
|
|
data.activityInfos = skynet.server.activity:GetAllActivityInfo(value.player)
|
||
|
|
skynet.server.gameServer:SendMsgToUser(value.player.userId, "CMD_S2C_UpdateShowUI", data)
|
||
|
|
end
|
||
|
|
end
|
||
|
|
self.UpdateTime = nowTime
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
--注册需要服务器活动的初始化函数
|
||
|
|
function Activity:RegisterInitHandler(handler,describe,activityType)
|
||
|
|
self.ActivityInitHandler[activityType] = handler
|
||
|
|
log.info("活动初始化函数注册：" ..describe.."成功！")
|
||
|
|
end
|
||
|
|
|
||
|
|
--取消注册初始化事件
|
||
|
|
function Activity:UnregisterInitHandler(activityType)
|
||
|
|
self.ActivityInitHandler[activityType] = nil
|
||
|
|
end
|
||
|
|
|
||
|
|
--注册需要服务器活动的关闭函数
|
||
|
|
function Activity:RegisterCloeseHandler(handler,describe,activityType)
|
||
|
|
self.ActivityCloseHandler[activityType] = handler
|
||
|
|
log.info("活动关闭函数注册：" ..describe.."成功！")
|
||
|
|
end
|
||
|
|
|
||
|
|
--取消注册关闭事件
|
||
|
|
function Activity:UnregisterCloeseHandler(activityType)
|
||
|
|
self.ActivityCloseHandler[activityType] = nil
|
||
|
|
end
|
||
|
|
|
||
|
|
--服务器获取当前开启的活动，执行该活动的初始化函数
|
||
|
|
function Activity:ServerActivityWatch()
|
||
|
|
local cfgActivity = skynet.server.gameConfig:GetAllCfg("Activity")
|
||
|
|
local startTime = 0
|
||
|
|
local endTime = 0
|
||
|
|
local nowTime = skynet.GetTime()
|
||
|
|
local cacheList = {}
|
||
|
|
--遍历活动表，将开启的并且注册在集合中的活动执行初始化函数
|
||
|
|
for k, v in pairs(cfgActivity) do
|
||
|
|
if v.startTime ~= nil and v.startTime ~= "" and v.endTime ~= nil and v.endTime ~= "" then
|
||
|
|
startTime = skynet.server.common:GetTime(v.startTime)
|
||
|
|
endTime = skynet.server.common:GetTime(v.endTime)
|
||
|
|
end
|
||
|
|
--判断是不是当前时间开启的活动,如果是判断该活动需不需需要执行服务器初始化逻辑
|
||
|
|
if nowTime >= startTime and nowTime <= endTime then
|
||
|
|
if next(self.ActivityInitHandler) ~= nil and self.ActivityInitHandler[v.activityType] ~= nil then
|
||
|
|
local handler = self.ActivityInitHandler[v.activityType]
|
||
|
|
local isDo,callData = pcall( handler, v.activityId)
|
||
|
|
if not isDo then
|
||
|
|
--打印错误日志
|
||
|
|
local debugInfo = debug.getinfo(handler)
|
||
|
|
if debugInfo then
|
||
|
|
log.error("活动管理器初始化函数执行错误，相关信息", callData,debugInfo.source,debugInfo.linedefined)
|
||
|
|
end
|
||
|
|
else
|
||
|
|
--table.insert(cacheList,v.activityType)
|
||
|
|
--table.insert(self.InProgressActivity,v.activityType)
|
||
|
|
cacheList[v.activityType] = v.activityId
|
||
|
|
self.InProgressActivity[v.activityType] = v.activityId
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
--检查正在进行的活动列表，将已经关闭的活动执行关闭函数并且移除(如果有的话)
|
||
|
|
for i, v in pairs(self.InProgressActivity) do
|
||
|
|
local inProgress = false
|
||
|
|
for i2, v2 in pairs(cacheList) do
|
||
|
|
if i == i2 then
|
||
|
|
inProgress = true
|
||
|
|
break
|
||
|
|
end
|
||
|
|
end
|
||
|
|
if not inProgress then
|
||
|
|
if self.ActivityCloseHandler[i] ~= nil then
|
||
|
|
local handler = self.ActivityCloseHandler[i]
|
||
|
|
local isDo,callData = pcall(handler)
|
||
|
|
if not isDo then
|
||
|
|
--打印错误日志
|
||
|
|
local debugInfo = debug.getinfo(handler)
|
||
|
|
if debugInfo then
|
||
|
|
log.error("活动管理器关闭活动执行错误，相关信息", callData,debugInfo.source,debugInfo.linedefined)
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
self.InProgressActivity[i] = nil
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
end
|
||
|
|
|
||
|
|
--获取当前开启活动的id,开始和结束时间
|
||
|
|
function Activity:GetActivityInfo(player, activityType, subType)
|
||
|
|
subType = subType or 0
|
||
|
|
local cfgActivity = skynet.server.gameConfig:GetPlayerAllCfg(player, "Activity")
|
||
|
|
local activityId = 0
|
||
|
|
local startTime = 0
|
||
|
|
local endTime = 0
|
||
|
|
local nowTime = skynet.GetTime()
|
||
|
|
local id = 0
|
||
|
|
|
||
|
|
for k, v in pairs(cfgActivity) do
|
||
|
|
if v.activityType == activityType then
|
||
|
|
startTime = skynet.server.common:GetTime(v.startTime)
|
||
|
|
endTime = skynet.server.common:GetTime(v.endTime)
|
||
|
|
--判断是不是当前时间开启的活动
|
||
|
|
if nowTime >= startTime and nowTime <= endTime and subType == v.subType then
|
||
|
|
activityId = v.activityId
|
||
|
|
id = v.id
|
||
|
|
break
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
--判断是否需要关闭玩家该活动
|
||
|
|
if self:CloseSomeActivity(player,id) then
|
||
|
|
activityId = 0
|
||
|
|
startTime = 0
|
||
|
|
endTime = 0
|
||
|
|
end
|
||
|
|
return activityId, startTime, endTime , id
|
||
|
|
end
|
||
|
|
|
||
|
|
--获取当前玩家可以进行显示的活动的相关信息
|
||
|
|
function Activity:GetAllActivityInfo(player)
|
||
|
|
local activityInfo = {}
|
||
|
|
--新人签到单独处理
|
||
|
|
if skynet.GetTime() < player.gameData.playerLand.endTime and player.gameData.playerLand.isShow then
|
||
|
|
table.insert(activityInfo, { id = 3, startTime = 0, endTime = player.gameData.playerLand.endTime })
|
||
|
|
end
|
||
|
|
|
||
|
|
--新手限时设计单独处理
|
||
|
|
local cfgNewPlayerRaffle = skynet.server.activityNewPlayerRaffle:CheckData(player)
|
||
|
|
if player:IsUnlockSystem( dataType.UnlockSystem_ActivityNewPlayerRaffle ) and cfgNewPlayerRaffle ~= nil then
|
||
|
|
table.insert(activityInfo, { id = 130, startTime = player.gameData.NewPlayerRaffleMap[cfgNewPlayerRaffle.id].activityOpenTime, endTime = skynet.server.activityNewPlayerRaffle:GetActivityEndTime(player.gameData.NewPlayerRaffleMap[cfgNewPlayerRaffle.id].activityOpenTime) })
|
||
|
|
end
|
||
|
|
|
||
|
|
local cfgAllActivity = skynet.server.gameConfig:GetPlayerAllCfg(player, "Activity")
|
||
|
|
for k, v in pairs(cfgAllActivity) do
|
||
|
|
|
||
|
|
--处理分层礼包，已经购买不添加
|
||
|
|
if v.activityType == dataType.ActivityType_ActivityLevelPack and not skynet.server.activityLevelPack:isCanBuy(player) then
|
||
|
|
goto continue
|
||
|
|
end
|
||
|
|
|
||
|
|
--进阶礼包
|
||
|
|
if v.activityType == dataType.ActivityType_ActivityStagePack and skynet.server.activityStagePack:isActivityEnd(player) then
|
||
|
|
goto continue
|
||
|
|
end
|
||
|
|
|
||
|
|
--存钱罐
|
||
|
|
if v.activityType == dataType.ActivityType_SavingPot and skynet.server.activitySavingPot:isActivityEnd(player) then
|
||
|
|
goto continue
|
||
|
|
end
|
||
|
|
|
||
|
|
if player.gameData.level >= v.level and v.activityType == dataType.ActivityType_Raffle and (v.subType == 3 or v.subType == 4 )then
|
||
|
|
local startTime = skynet.server.common:GetTime(v.startTime)
|
||
|
|
local endTime = skynet.server.common:GetTime(v.endTime)
|
||
|
|
if skynet.GetTime() >= startTime and skynet.GetTime() < endTime and not self:CloseSomeActivity(player, v.id) then
|
||
|
|
table.insert(activityInfo, { id = v.id, startTime = startTime, endTime = endTime })
|
||
|
|
end
|
||
|
|
elseif player.gameData.level >= v.level and v.activityType ~= dataType.ActivityType_Raffle then
|
||
|
|
if v.startTime ~= "" and v.endTime ~= "" then
|
||
|
|
local startTime = skynet.server.common:GetTime(v.startTime)
|
||
|
|
local endTime = skynet.server.common:GetTime(v.endTime)
|
||
|
|
if skynet.GetTime() >= startTime and skynet.GetTime() < endTime and not self:CloseSomeActivity(player, v.id) then
|
||
|
|
table.insert(activityInfo, { id = v.id, startTime = startTime, endTime = endTime })
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
::continue::
|
||
|
|
end
|
||
|
|
return activityInfo
|
||
|
|
end
|
||
|
|
|
||
|
|
--活动即将过期 发送邮件
|
||
|
|
function Activity:ActivityExpiredSendMail(player)
|
||
|
|
--从开启的活动中 查找是否有活动需要进行发送邮件
|
||
|
|
for k, v in pairs(player.gameData.activityManage) do
|
||
|
|
if v.id > 0 then
|
||
|
|
local cfgOneActivity = skynet.server.gameConfig:GetPlayerCurCfg(player, "Activity", v.id)
|
||
|
|
--开启的活动中是否满足邮件的发送时间
|
||
|
|
if cfgOneActivity and "" ~= cfgOneActivity.mailTime and cfgOneActivity.mailId > 0 and skynet.GetTime() >= skynet.server.common:GetTime(cfgOneActivity.mailTime) then
|
||
|
|
local mailId = "HDGQ-" .. cfgOneActivity.activityType .. "-" .. cfgOneActivity.activityId
|
||
|
|
--判断是否已经发送过该邮件
|
||
|
|
local showSend = true
|
||
|
|
for k1, v1 in pairs(player.gameData.mail.historyMail) do
|
||
|
|
if v1 == mailId then
|
||
|
|
showSend = false
|
||
|
|
break
|
||
|
|
end
|
||
|
|
end
|
||
|
|
if showSend then
|
||
|
|
local cfgOneMail = skynet.server.gameConfig:GetPlayerCurCfg(player, "Mail", cfgOneActivity.mailId)
|
||
|
|
--邮件对应奖励
|
||
|
|
local award = skynet.server.playerLand:GetRewardInfo(player, cfgOneMail.mailReward)
|
||
|
|
local mailInfo = { mailType = "奖励", mailTitle = cfgOneMail.mailTitle, mailText = cfgOneMail.mailContent, mailEffectiveTime = 7 }
|
||
|
|
skynet.server.mail:AddMail(player, mailId, mailInfo, award, false)
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
--是否关闭该玩家的对应活动
|
||
|
|
function Activity:CloseSomeActivity(player, id)
|
||
|
|
local gameCgi = "chenzong_dwelstgz" --要关闭的玩家cgi
|
||
|
|
local ids = { 58, 59, 60, 61, 62, 81 } --要关闭的活动
|
||
|
|
if player==nil or player.basicInfo.gameCgi ~= gameCgi then
|
||
|
|
return false
|
||
|
|
else
|
||
|
|
for k, v in pairs(ids) do
|
||
|
|
if v == id then
|
||
|
|
return true
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
return false
|
||
|
|
end
|
||
|
|
|
||
|
|
skynet.server.activity = Activity
|
||
|
|
return Activity
|