1047 lines
35 KiB
Lua
1047 lines
35 KiB
Lua
local skynet = require "skynet"
|
||
local oo = require "Class"
|
||
local log = require "Log"
|
||
local pb = require "pb"
|
||
local dataType = require "DataType"
|
||
local errorInfo = require "ErrorInfo"
|
||
local activity = require "Activity"
|
||
local json =require "json"
|
||
local dataType = require "DataType"
|
||
local taskListEvent = require "TaskListEvent"
|
||
local ActivitySeekTreasure = oo.class()
|
||
|
||
ActivitySeekTreasure.ActivityType = dataType.ActivityType_SeekTreasure
|
||
|
||
--构造函数
|
||
function ActivitySeekTreasure:Init()
|
||
|
||
end
|
||
|
||
-- 每次登录需要进行修改的数据
|
||
function ActivitySeekTreasure:LoginInitData(player)
|
||
--判断模块是否开启
|
||
if not player:IsUnlockSystem( dataType.UnlockSystem_ActivitySeekTreasure ) then
|
||
log.debug("限时寻味之旅模块未开启")
|
||
return
|
||
end
|
||
|
||
--活动结束
|
||
local cfgSeekTreasure=self:CheckDataAndGetActivity(player)
|
||
if cfgSeekTreasure == nil then
|
||
log.debug("限时寻味之旅活动已结束")
|
||
return
|
||
end
|
||
|
||
--获取开启的活动
|
||
local activityId, _, _, _ = activity:GetActivityInfo(player, self.ActivityType)
|
||
local seekTreasure = player.gameData.SeekTreasureMap[activityId]
|
||
|
||
--是否跨天补发免费参与次数
|
||
if os.date("%Y-%m-%d",seekTreasure.LoginDate) ~= os.date("%Y-%m-%d",skynet.GetTime()) then
|
||
seekTreasure.conParticipationNum = 1
|
||
seekTreasure.ADSkipCount =cfgSeekTreasure.adSkipPunish
|
||
seekTreasure.LoginDate = skynet.GetTime()
|
||
seekTreasure.isTodayParticipation = false --今日是否参与
|
||
seekTreasure.haveSeekTreasureTasks = {} --已刷新过的任务列表
|
||
seekTreasure.seekTreasureTasks = {} --任务列表
|
||
end
|
||
|
||
-- 处理红点
|
||
skynet.server.msgTips:Reset(player, 113)
|
||
skynet.server.msgTips:Reset(player, 114)
|
||
|
||
log.debug("限时寻味之旅活动进行中")
|
||
end
|
||
|
||
--初始玩家数据，返回活动信息,
|
||
function ActivitySeekTreasure:CheckDataAndGetActivity(player)
|
||
|
||
--默认空活动
|
||
local cfgSeekTreasure = nil
|
||
|
||
if player==nil then
|
||
log.debug("限时寻味之旅CheckDataAndGetActivity， player is nil")
|
||
return cfgSeekTreasure
|
||
end
|
||
|
||
--判断等级是否开启
|
||
if not player:IsUnlockSystem( dataType.UnlockSystem_ActivitySeekTreasure) then
|
||
log.debug("限时寻味之旅等级不足")
|
||
return cfgSeekTreasure
|
||
end
|
||
|
||
--获取开启的活动
|
||
local activityId, _, _, _ = activity:GetActivityInfo(player, self.ActivityType)
|
||
|
||
--没有开启的活动
|
||
if activityId == 0 then
|
||
log.debug("限时寻味之旅未开启-未获取到有效的活动1")
|
||
return cfgSeekTreasure
|
||
end
|
||
|
||
--初始化
|
||
if player.gameData.SeekTreasureMap==nil then
|
||
player.gameData.SeekTreasureMap={}
|
||
log.debug("player.gameData.SeekTreasureMap={}")
|
||
end
|
||
|
||
--获取活动配置
|
||
cfgSeekTreasure=self:GetSeekTreasureConfig(player,activityId)
|
||
|
||
--未获取到有效的活动
|
||
if cfgSeekTreasure == nil then
|
||
log.debug("限时寻味之旅未开启-未获取到有效的活动2")
|
||
return cfgSeekTreasure
|
||
end
|
||
|
||
--如果玩家已经存在活动不需要检查
|
||
if player.gameData.SeekTreasureMap[activityId] then
|
||
|
||
local seekTreasure = player.gameData.SeekTreasureMap[activityId]
|
||
--是否跨天补发免费参与次数
|
||
if os.date("%Y-%m-%d",seekTreasure.LoginDate) ~= os.date("%Y-%m-%d",skynet.GetTime()) then
|
||
seekTreasure.conParticipationNum = 1
|
||
seekTreasure.ADSkipCount =cfgSeekTreasure.adSkipPunish
|
||
seekTreasure.isTodayParticipation = false --今日是否参与
|
||
seekTreasure.haveSeekTreasureTasks = {} --已刷新过的任务列表
|
||
seekTreasure.seekTreasureTasks = {} --任务列表
|
||
end
|
||
|
||
player.gameData.SeekTreasureMap[activityId].LoginDate = skynet.GetTime() --更新登录时间 补发奖励用
|
||
|
||
--删除过期活动，减少数据产生
|
||
local removeKeyList = {}
|
||
for exceedActivityId, _ in pairs(player.gameData.SeekTreasureMap) do
|
||
if exceedActivityId ~= activityId then
|
||
table.insert(removeKeyList, exceedActivityId)
|
||
end
|
||
end
|
||
if next(removeKeyList) then
|
||
for _, removeKey in ipairs(removeKeyList) do
|
||
player.gameData.SeekTreasureMap[removeKey]=nil
|
||
end
|
||
end
|
||
|
||
return cfgSeekTreasure
|
||
end
|
||
|
||
self:InitStage(player,activityId)
|
||
return cfgSeekTreasure
|
||
end
|
||
|
||
--初始化关卡
|
||
function ActivitySeekTreasure:InitStage(player,activityId)
|
||
|
||
--获取活动配置
|
||
local cfgSeekTreasure=self:GetSeekTreasureConfig(player,activityId)
|
||
|
||
--未获取到有效的活动
|
||
if cfgSeekTreasure == nil then
|
||
log.debug("限时寻味之旅未开启-未获取到有效的活动2")
|
||
return cfgSeekTreasure
|
||
end
|
||
|
||
--存在活动初始化玩家数据
|
||
local playerActivityTreasure = {}
|
||
playerActivityTreasure.activityId = cfgSeekTreasure.activityId
|
||
playerActivityTreasure.haveSeekTreasureTasks = {} --已刷新过的任务列表
|
||
playerActivityTreasure.seekTreasureTasks = {} --任务列表
|
||
playerActivityTreasure.conParticipationNum = 1 --可参与次数
|
||
playerActivityTreasure.isFinish = false --是否完成挑战
|
||
playerActivityTreasure.isTodayParticipation = false --今日是否参与
|
||
|
||
--获取最小关卡
|
||
local minStage = 1
|
||
for index, value in ipairs(cfgSeekTreasure.allLevelId) do
|
||
if index ==1 then
|
||
minStage = value
|
||
break
|
||
end
|
||
end
|
||
|
||
playerActivityTreasure.curStage = minStage --当前阶段
|
||
|
||
--获取最小关卡
|
||
local minLevelId = 1
|
||
local minLevelIdList = {}
|
||
|
||
local cfgSeekTreasureLevels=self:GetStageConfigList(player,cfgSeekTreasure.activityId,minStage)
|
||
|
||
local levelOrder = 1
|
||
for index, cfgSeekTreasureLevel in ipairs(cfgSeekTreasureLevels) do
|
||
if levelOrder >= cfgSeekTreasureLevel.levelOrder then
|
||
table.insert(minLevelIdList,cfgSeekTreasureLevel.levelOrder)
|
||
end
|
||
end
|
||
|
||
if #minLevelIdList > 0 then
|
||
table.sort(minLevelIdList)
|
||
minLevelId = minLevelIdList[1]
|
||
end
|
||
|
||
playerActivityTreasure.curLevel = minLevelId --当前阶段
|
||
playerActivityTreasure.curStageState = 0 --当前关卡状态,0:未开启,1:未选择，2：惩罚中
|
||
playerActivityTreasure.curStageRewardId = 0 --当前关卡奖励id,0:惩罚奖励，非0:奖励id
|
||
playerActivityTreasure.lastIsSkipPunish = false --上一次是否跳过惩罚
|
||
playerActivityTreasure.ADSkipCount =cfgSeekTreasure.adSkipPunish--广告跳过次数
|
||
playerActivityTreasure.stageRewardList = {} --奖励列表
|
||
|
||
playerActivityTreasure.LoginDate = skynet.GetTime() --登录天数
|
||
|
||
--更新缓存
|
||
player.gameData.SeekTreasureMap[activityId] = playerActivityTreasure
|
||
end
|
||
|
||
--重置当前阶段
|
||
function ActivitySeekTreasure:ResetStage(player,activityId)
|
||
|
||
--获取活动配置
|
||
local cfgSeekTreasure=self:GetSeekTreasureConfig(player,activityId)
|
||
|
||
--未获取到有效的活动
|
||
if cfgSeekTreasure == nil then
|
||
log.debug("限时寻味之旅未开启-未获取到有效的活动2")
|
||
return cfgSeekTreasure
|
||
end
|
||
|
||
--存在活动初始化玩家数据
|
||
local playerActivityTreasure = player.gameData.SeekTreasureMap[activityId]
|
||
|
||
--获取最小关卡
|
||
local minLevelId = 1
|
||
local minLevelIdList = {}
|
||
|
||
local cfgSeekTreasureLevels=self:GetStageConfigList(player,cfgSeekTreasure.activityId,playerActivityTreasure.curStage )
|
||
|
||
local levelOrder = 1
|
||
for index, cfgSeekTreasureLevel in ipairs(cfgSeekTreasureLevels) do
|
||
if levelOrder >= cfgSeekTreasureLevel.levelOrder then
|
||
table.insert(minLevelIdList,cfgSeekTreasureLevel.levelOrder)
|
||
end
|
||
end
|
||
|
||
if #minLevelIdList > 0 then
|
||
table.sort(minLevelIdList)
|
||
minLevelId = minLevelIdList[1]
|
||
end
|
||
|
||
playerActivityTreasure.curLevel = minLevelId --当前阶段
|
||
playerActivityTreasure.curStageState = 0 --当前关卡状态,0:未开启,1:未选择，2：惩罚中
|
||
playerActivityTreasure.curStageRewardId = 0 --当前关卡奖励id,0:惩罚奖励，非0:奖励id
|
||
playerActivityTreasure.stageRewardList = {} --奖励列表
|
||
|
||
playerActivityTreasure.LoginDate = skynet.GetTime() --登录天数
|
||
|
||
skynet.server.msgTips:ReduceAll(player,114)
|
||
|
||
--更新缓存
|
||
player.gameData.SeekTreasureMap[activityId] = playerActivityTreasure
|
||
end
|
||
|
||
--获取阶段信息
|
||
function ActivitySeekTreasure:GetStageConfigList(player,activityId,level)
|
||
|
||
local cfgSeekTreasureLevel = {}
|
||
|
||
--获取该活动的默认初始关卡
|
||
local cfgSeekTreasureLevels=skynet.server.gameConfig:GetPlayerAllCfg(player, "SeekTreasureLevel")
|
||
if cfgSeekTreasureLevels==nil then
|
||
|
||
log.debug("cfgSeekTreasureLevels is nil")
|
||
return cfgSeekTreasureLevel
|
||
end
|
||
|
||
for _, value in pairs(cfgSeekTreasureLevels) do
|
||
if value.activityId==activityId and value.level == level then
|
||
table.insert(cfgSeekTreasureLevel,value)
|
||
end
|
||
end
|
||
|
||
|
||
return cfgSeekTreasureLevel
|
||
end
|
||
|
||
--是否可以挑战
|
||
function ActivitySeekTreasure:IsConParticipationNum(player)
|
||
|
||
--不存在开启的活动
|
||
local cfgSeekTreasure=self:CheckDataAndGetActivity(player)
|
||
|
||
--活动未开启
|
||
if cfgSeekTreasure == nil then
|
||
log.debug("限时寻味之旅未开启-未获取到有效的活动 IsConParticipationNum")
|
||
return false
|
||
end
|
||
|
||
--获取开启的活动
|
||
local activityId,_,_, _ = activity:GetActivityInfo(player, self.ActivityType)
|
||
|
||
return player.gameData.SeekTreasureMap[activityId].conParticipationNum > 0
|
||
end
|
||
|
||
--是否完成挑战
|
||
function ActivitySeekTreasure:IsEnd(player)
|
||
|
||
--不存在开启的活动
|
||
local cfgSeekTreasure=self:CheckDataAndGetActivity(player)
|
||
|
||
--活动未开启
|
||
if cfgSeekTreasure == nil then
|
||
log.debug("限时寻味之旅未开启-未获取到有效的活动 IsEnd")
|
||
return false
|
||
end
|
||
|
||
--获取开启的活动
|
||
local activityId,_,_, _ = activity:GetActivityInfo(player, self.ActivityType)
|
||
|
||
return player.gameData.SeekTreasureMap[activityId].curStageState ~= 0
|
||
end
|
||
|
||
--获取配置信息
|
||
function ActivitySeekTreasure:GetSeekTreasureConfig(player,activityId)
|
||
|
||
local cfgSeekTreasure=nil
|
||
|
||
--获取该活动的默认初始关卡
|
||
local cfgSeekTreasures=skynet.server.gameConfig:GetPlayerAllCfg(player, "SeekTreasure")
|
||
if cfgSeekTreasures==nil then
|
||
|
||
log.debug("cfgSeekTreasures is nil")
|
||
return cfgSeekTreasure
|
||
end
|
||
|
||
for index, value in pairs(cfgSeekTreasures) do
|
||
if value.id==activityId then
|
||
cfgSeekTreasure=value
|
||
break
|
||
end
|
||
end
|
||
|
||
return cfgSeekTreasure
|
||
end
|
||
|
||
--初始化下一关卡
|
||
function ActivitySeekTreasure:InitNextLevel(player,seekTreasure,activityId)
|
||
|
||
local cfgSeekTreasure = self:GetSeekTreasureConfig(player,activityId)
|
||
if cfgSeekTreasure == nil then
|
||
log.error("关卡配置不存在")
|
||
return false
|
||
end
|
||
|
||
--下一个关卡id
|
||
local nextLevelId = 0
|
||
|
||
local cfgSeekTreasureLevels=self:GetStageConfigList(player,activityId,seekTreasure.curStage)
|
||
|
||
local nextLevelIdList={}
|
||
for _, value in ipairs(cfgSeekTreasureLevels) do
|
||
if value.levelOrder > seekTreasure.curLevel then
|
||
table.insert(nextLevelIdList,value.levelOrder)
|
||
end
|
||
end
|
||
|
||
--找到当前阶段还有下一个节点
|
||
if #nextLevelIdList > 0 then
|
||
table.sort(nextLevelIdList)
|
||
nextLevelId= nextLevelIdList[1]
|
||
|
||
seekTreasure.curLevel=nextLevelId
|
||
seekTreasure.curStageRewardId = 0 --当前关卡奖励id,0:惩罚奖励，非0:奖励id
|
||
--seekTreasure.lastIsSkipPunish = false --上一次是否跳过惩罚
|
||
return true
|
||
end
|
||
|
||
--大奖是否添加成功
|
||
local isAddReward = false
|
||
|
||
--是否是最后一关-添加大奖
|
||
for index, value in ipairs(cfgSeekTreasure.allLevelId) do
|
||
if value == seekTreasure.curStage then
|
||
table.insert(seekTreasure.stageRewardList,{rewardId = cfgSeekTreasure.levelFinalReward[index],count = 1})
|
||
isAddReward=true
|
||
break
|
||
end
|
||
end
|
||
|
||
--添加无限阶段大奖
|
||
if not isAddReward then
|
||
table.insert(seekTreasure.stageRewardList,{rewardId = cfgSeekTreasure.infiniteReward,count = 1})
|
||
end
|
||
|
||
seekTreasure.curStageRewardId = 0 --当前关卡奖励id,0:惩罚奖励，非0:奖励id
|
||
--seekTreasure.lastIsSkipPunish = false --上一次是否跳过惩罚
|
||
seekTreasure.isFinish = true --设置成挑战完成
|
||
|
||
return false
|
||
end
|
||
|
||
--初始化下一阶段
|
||
function ActivitySeekTreasure:InitNextStage(player,seekTreasure,activityId)
|
||
|
||
local cfgSeekTreasure = self:GetSeekTreasureConfig(player,activityId)
|
||
if cfgSeekTreasure == nil then
|
||
log.error("关卡配置不存在")
|
||
return false
|
||
end
|
||
|
||
--下一个阶段,默认是当前
|
||
local nextStageId = seekTreasure.curStage
|
||
|
||
--未找到下一个节点，获取下一个阶段或者 循环当前
|
||
for index, value in ipairs(cfgSeekTreasure.allLevelId) do
|
||
if value == nextStageId then
|
||
nextStageId=cfgSeekTreasure.allLevelId[index+1]
|
||
break
|
||
end
|
||
end
|
||
|
||
|
||
--普通轮次不存在 进入循环轮次
|
||
if nextStageId == nil or nextStageId == seekTreasure.curStagethen then
|
||
nextStageId=cfgSeekTreasure.infiniteLevelId
|
||
end
|
||
|
||
--获取最小关卡
|
||
local minLevelId = 1
|
||
local minLevelIdList = {}
|
||
|
||
local cfgSeekTreasureLevels=self:GetStageConfigList(player,activityId,nextStageId)
|
||
|
||
local levelOrder = 1
|
||
for _, cfgSeekTreasureLevel in ipairs(cfgSeekTreasureLevels) do
|
||
if levelOrder >= cfgSeekTreasureLevel.levelOrder then
|
||
table.insert(minLevelIdList,cfgSeekTreasureLevel.levelOrder)
|
||
end
|
||
end
|
||
|
||
if #minLevelIdList > 0 then
|
||
table.sort(minLevelIdList)
|
||
minLevelId = minLevelIdList[1]
|
||
end
|
||
|
||
seekTreasure.curStage=nextStageId
|
||
seekTreasure.curLevel=minLevelId
|
||
seekTreasure.curStageState = 0 --当前关卡状态,0:未开启,1:未选择，2：惩罚中
|
||
seekTreasure.curStageRewardId = 0 --当前关卡奖励id,0:惩罚奖励，非0:奖励id
|
||
seekTreasure.lastIsSkipPunish = false --上一次是否跳过惩罚
|
||
skynet.server.msgTips:ReduceAll(player,114)
|
||
end
|
||
|
||
--获取关卡配置
|
||
function ActivitySeekTreasure:GetSeekTreasureLevelConfig(player,level,levelOrder)
|
||
|
||
local cfgSeekTreasureLevel =nil
|
||
|
||
--获取该活动的默认初始关卡
|
||
local cfgSeekTreasureLevels=skynet.server.gameConfig:GetPlayerAllCfg(player, "SeekTreasureLevel")
|
||
if cfgSeekTreasureLevels==nil then
|
||
|
||
log.debug("cfgSeekTreasureLevels is nil")
|
||
return cfgSeekTreasureLevel
|
||
end
|
||
|
||
|
||
for _, value in pairs(cfgSeekTreasureLevels) do
|
||
if value.level==level and value.levelOrder == levelOrder then
|
||
cfgSeekTreasureLevel=value
|
||
end
|
||
end
|
||
|
||
return cfgSeekTreasureLevel
|
||
end
|
||
|
||
--开启关卡信息
|
||
function ActivitySeekTreasure:OpenStage(player,seekTreasure,activityId,level,levelOrder)
|
||
|
||
--获取活动配置
|
||
local cfgSeekTreasure=self:GetSeekTreasureConfig(player,activityId)
|
||
|
||
--未获取到有效的活动
|
||
if cfgSeekTreasure == nil then
|
||
log.debug("限时寻味之旅未开启-未获取到有效的活动 OpenStage",level,levelOrder)
|
||
return false
|
||
end
|
||
|
||
local seekTreasureLevel = self:GetSeekTreasureLevelConfig(player,level,levelOrder)
|
||
if seekTreasureLevel == nil then
|
||
log.debug("限时寻味之旅未开启-未获取到有效的活动2 OpenStage",level,levelOrder)
|
||
return false
|
||
end
|
||
|
||
--循环列表
|
||
local readmodeList = {}
|
||
|
||
for _, value in ipairs(seekTreasureLevel.levelReward) do
|
||
table.insert(readmodeList,value)
|
||
end
|
||
|
||
--是否跳过惩罚关卡
|
||
if seekTreasure.lastIsSkipPunish and seekTreasureLevel.punishReplaceReward > 0 then
|
||
table.insert(readmodeList,seekTreasureLevel.punishReplaceReward)
|
||
end
|
||
|
||
--是否需要执行惩罚关卡随机
|
||
if seekTreasureLevel.welfareLevel ~= 1 and #readmodeList < 4 then
|
||
--随机惩罚
|
||
local randomValue = math.random(1,100)
|
||
if tonumber(randomValue) <= tonumber(seekTreasureLevel.punishPossibility*100) then
|
||
seekTreasure.curStageRewardId = 0 --惩罚奖励
|
||
seekTreasure.curStageState = 1--未选择
|
||
skynet.server.msgTips:Add(player,114)
|
||
return true
|
||
end
|
||
end
|
||
|
||
local index = math.random(1,#readmodeList)
|
||
|
||
seekTreasure.curStageRewardId=readmodeList[index]--奖励id
|
||
|
||
--设置成未选择
|
||
seekTreasure.curStageState = 1
|
||
seekTreasure.lastIsSkipPunish = false
|
||
skynet.server.msgTips:Add(player,114)
|
||
|
||
return true
|
||
end
|
||
|
||
--刷新任务列表
|
||
function ActivitySeekTreasure:RefreshTaskList(player,activityId)
|
||
|
||
--获取任务配置
|
||
local cfgSeekTreasureTasks=skynet.server.gameConfig:GetPlayerAllCfg(player, "SeekTreasureTask")
|
||
|
||
--存在配置
|
||
if cfgSeekTreasureTasks == nil or not next(cfgSeekTreasureTasks) then
|
||
|
||
log.debug("限时寻味之旅未开启-未获取到有效的任务配置")
|
||
return false
|
||
end
|
||
|
||
local cfgSeekTreasure=self:CheckDataAndGetActivity(player)
|
||
|
||
local seekTreasure = player.gameData.SeekTreasureMap[activityId]
|
||
|
||
if seekTreasure ==nil
|
||
or seekTreasure.conParticipationNum > 0
|
||
or next(seekTreasure.seekTreasureTasks) then
|
||
|
||
log.debug("限时寻味之旅未开启-不满足刷新任务条件")
|
||
return false
|
||
end
|
||
|
||
--清空
|
||
seekTreasure.seekTreasureTasks={}
|
||
|
||
local cfgJigsawPuzzleTaskList = {}
|
||
for _, cfgJigsawPuzzleTask in ipairs(cfgSeekTreasureTasks) do
|
||
if cfgJigsawPuzzleTask.seekTreasureId == activityId then
|
||
table.insert(cfgJigsawPuzzleTaskList,cfgJigsawPuzzleTask)
|
||
end
|
||
end
|
||
|
||
--可用的任务
|
||
local haveSeekTreasureTaskIds = {}
|
||
for _, cfgSeekTreasureTask in ipairs(cfgJigsawPuzzleTaskList) do
|
||
|
||
for _, taskId in ipairs(seekTreasure.haveSeekTreasureTasks) do
|
||
if cfgSeekTreasureTask.id == taskId then--已经随机过了
|
||
goto continue
|
||
end
|
||
end
|
||
|
||
--添加到可用任务
|
||
table.insert(haveSeekTreasureTaskIds,cfgSeekTreasureTask.id)
|
||
|
||
::continue::
|
||
end
|
||
|
||
--不存在就设置成全部
|
||
if not next(haveSeekTreasureTaskIds) then
|
||
for _, cfgSeekTreasureTask in ipairs(cfgJigsawPuzzleTaskList) do
|
||
--添加到可用任务
|
||
table.insert(haveSeekTreasureTaskIds,cfgSeekTreasureTask.id)
|
||
end
|
||
seekTreasure.haveSeekTreasureTasks={}
|
||
end
|
||
|
||
--循环刷新
|
||
for i = 1, cfgSeekTreasure.taskNum, 1 do
|
||
|
||
--不存在就设置成全部
|
||
if not next(haveSeekTreasureTaskIds) then
|
||
seekTreasure.haveSeekTreasureTasks={}
|
||
for _, cfgSeekTreasureTask in ipairs(cfgJigsawPuzzleTaskList) do
|
||
|
||
for key, _ in pairs(seekTreasure.seekTreasureTasks) do
|
||
if cfgSeekTreasureTask.id==key then
|
||
table.insert( seekTreasure.haveSeekTreasureTasks,key)
|
||
goto continue
|
||
end
|
||
end
|
||
--添加到可用任务
|
||
table.insert(haveSeekTreasureTaskIds,cfgSeekTreasureTask.id)
|
||
|
||
::continue::
|
||
end
|
||
|
||
end
|
||
|
||
local index = math.random(1,#haveSeekTreasureTaskIds)
|
||
|
||
|
||
local id =haveSeekTreasureTaskIds[index]
|
||
seekTreasure.seekTreasureTasks[id]={ id = id , value = 0 ,status=0}
|
||
table.insert(seekTreasure.haveSeekTreasureTasks,haveSeekTreasureTaskIds[index])
|
||
|
||
--移除可用任务
|
||
table.remove(haveSeekTreasureTaskIds,index)
|
||
end
|
||
|
||
return true
|
||
end
|
||
|
||
--任务格式转换
|
||
function ActivitySeekTreasure:GetSeekTreasureTaskInfo(taskList)
|
||
local taskListInfo={}
|
||
|
||
if taskList==nil or not next(taskList) then
|
||
return taskListInfo
|
||
end
|
||
|
||
for _, value in pairs(taskList) do
|
||
table.insert(taskListInfo,{id=value.id,progress=value.value,status=value.status})
|
||
end
|
||
|
||
return taskListInfo
|
||
end
|
||
|
||
--获取限时寻味之旅信息
|
||
function ActivitySeekTreasure:Show( player , c2sData , s2cData )
|
||
c2sData.data = assert(pb.decode("C2SActivitySeekTreasureShow", c2sData.data ))
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_ActivitySeekTreasureShow")
|
||
local data = {}
|
||
|
||
--检查并且获取活动信息
|
||
local cfgSeekTreasure=self:CheckDataAndGetActivity(player)
|
||
|
||
if cfgSeekTreasure == nil then
|
||
s2cData.code = errorInfo.ErrorCode.ActivityClosed
|
||
return
|
||
end
|
||
|
||
--获取开启的活动
|
||
local activityId, _, _, _ = activity:GetActivityInfo(player, self.ActivityType)
|
||
local seekTreasure = player.gameData.SeekTreasureMap[activityId]
|
||
|
||
--刷新任务
|
||
self:RefreshTaskList(player, activityId)
|
||
|
||
data.conParticipationNum=seekTreasure.conParticipationNum
|
||
data.curStage=seekTreasure.curStage
|
||
data.curLevel=seekTreasure.curLevel
|
||
data.curStageState=seekTreasure.curStageState
|
||
data.curStageRewardId=seekTreasure.curStageRewardId
|
||
data.taskList= self:GetSeekTreasureTaskInfo(seekTreasure.seekTreasureTasks)
|
||
data.stageRewardList=seekTreasure.stageRewardList
|
||
data.isFinish=seekTreasure.isFinish
|
||
data.adSkipCount=seekTreasure.ADSkipCount
|
||
|
||
--返回信息
|
||
s2cData.data = assert(pb.encode("S2SActivitySeekTreasureShow", data))
|
||
end
|
||
|
||
--开始寻味之旅
|
||
function ActivitySeekTreasure:Start( player , c2sData , s2cData )
|
||
c2sData.data = assert(pb.decode("C2SActivitySeekTreasureStart", c2sData.data ))
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_ActivitySeekTreasureStart")
|
||
local data = {}
|
||
|
||
--检查并且获取活动信息
|
||
local cfgSeekTreasure=self:CheckDataAndGetActivity(player)
|
||
|
||
if cfgSeekTreasure == nil then
|
||
s2cData.code = errorInfo.ErrorCode.ActivityClosed
|
||
return
|
||
end
|
||
|
||
--获取开启的活动
|
||
local activityId, _, _, _ = activity:GetActivityInfo(player, self.ActivityType)
|
||
|
||
--是否有参与次数
|
||
local seekTreasure = player.gameData.SeekTreasureMap[activityId]
|
||
if seekTreasure.conParticipationNum <= 0 then
|
||
|
||
log.debug("限时寻味之旅 参与次数不足")
|
||
s2cData.code = errorInfo.ErrorCode.NotEnoughParticipateTimes
|
||
return
|
||
end
|
||
|
||
--开启关卡信息
|
||
if self:OpenStage(player,seekTreasure,activityId,seekTreasure.curStage,seekTreasure.curLevel) then
|
||
|
||
--扣除参与次数
|
||
seekTreasure.conParticipationNum = 0
|
||
skynet.server.msgTips:ReduceAll(player,113)
|
||
seekTreasure.isTodayParticipation = true --今日是否参与
|
||
end
|
||
|
||
--挑战红点
|
||
--skynet.server.msgTips:ReduceAll(player, 120)
|
||
|
||
data.conParticipationNum=seekTreasure.conParticipationNum
|
||
data.curStage=seekTreasure.curStage
|
||
data.curLevel=seekTreasure.curLevel
|
||
data.curStageState=seekTreasure.curStageState
|
||
data.curRewardId=seekTreasure.curStageRewardId
|
||
data.stageRewardList=seekTreasure.stageRewardList
|
||
data.adSkipPunish=seekTreasure.adSkipPunish
|
||
|
||
--返回信息
|
||
s2cData.data = assert(pb.encode("S2SActivitySeekTreasureStart", data))
|
||
end
|
||
|
||
--打开宝物
|
||
function ActivitySeekTreasure:Open( player , c2sData , s2cData )
|
||
c2sData.data = assert(pb.decode("C2SActivitySeekTreasureOpen", c2sData.data ))
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_ActivitySeekTreasureOpen")
|
||
local data = {}
|
||
|
||
--检查并且获取活动信息
|
||
local cfgSeekTreasure=self:CheckDataAndGetActivity(player)
|
||
|
||
if cfgSeekTreasure == nil then
|
||
log.debug("限时寻味之旅 活动未开启")
|
||
s2cData.code = errorInfo.ErrorCode.ActivityClosed
|
||
return
|
||
end
|
||
|
||
--获取开启的活动
|
||
local activityId, _, _, _ = activity:GetActivityInfo(player, self.ActivityType)
|
||
|
||
--玩家参与信息
|
||
local seekTreasure = player.gameData.SeekTreasureMap[activityId]
|
||
|
||
--状态是否正确
|
||
if seekTreasure.curStageState ~= 1 then
|
||
log.debug("限时寻味之旅 状态错误")
|
||
s2cData.code = errorInfo.ErrorCode.NotOpenLevel
|
||
return
|
||
end
|
||
|
||
data.curRewardId= seekTreasure.curStageRewardId
|
||
if seekTreasure.curStageRewardId == 0 then
|
||
seekTreasure.curStageState = 2
|
||
data.nextCurStage=0
|
||
data.nextCurLevel=0
|
||
data.nextCurRewardId=0
|
||
data.isFinish=false
|
||
else
|
||
local isUpdate= false
|
||
for index, value in ipairs(seekTreasure.stageRewardList) do
|
||
if value.rewardId == seekTreasure.curStageRewardId then
|
||
seekTreasure.stageRewardList[index]={rewardId = seekTreasure.curStageRewardId,count = value.count+1}
|
||
isUpdate=true
|
||
break
|
||
end
|
||
end
|
||
|
||
if not isUpdate then
|
||
table.insert(seekTreasure.stageRewardList,{rewardId = seekTreasure.curStageRewardId,count = 1})
|
||
end
|
||
|
||
if self:InitNextLevel(player,seekTreasure,activityId) then --初始化下一关卡
|
||
|
||
--开启关卡信息
|
||
self:OpenStage(player,seekTreasure,activityId,seekTreasure.curStage,seekTreasure.curLevel)
|
||
end
|
||
|
||
data.nextCurStage=seekTreasure.curStage
|
||
data.nextCurLevel=seekTreasure.curLevel
|
||
data.nextCurRewardId=seekTreasure.curStageRewardId
|
||
data.isFinish=seekTreasure.isFinish
|
||
end
|
||
|
||
data.stageRewardList= seekTreasure.stageRewardList
|
||
|
||
--返回信息
|
||
s2cData.data = assert(pb.encode("S2SActivitySeekTreasureOpen", data))
|
||
end
|
||
|
||
--领取奖励并且退出
|
||
function ActivitySeekTreasure:GetReward( player , c2sData , s2cData )
|
||
c2sData.data = assert(pb.decode("C2SActivitySeekTreasureGetReward", c2sData.data ))
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_ActivitySeekTreasureGetReward")
|
||
local data = {}
|
||
data.rewardIdList={}
|
||
|
||
--检查并且获取活动信息
|
||
local cfgSeekTreasure=self:CheckDataAndGetActivity(player)
|
||
|
||
if cfgSeekTreasure == nil then
|
||
s2cData.code = errorInfo.ErrorCode.ActivityClosed
|
||
return
|
||
end
|
||
|
||
--获取开启的活动
|
||
local activityId, _, _, _ = activity:GetActivityInfo(player, self.ActivityType)
|
||
|
||
--玩家参与信息
|
||
local seekTreasure = player.gameData.SeekTreasureMap[activityId]
|
||
|
||
if #seekTreasure.stageRewardList > 0 and seekTreasure.curStageState ~= 2 then
|
||
for _, reward in ipairs(seekTreasure.stageRewardList) do
|
||
|
||
--发奖
|
||
local eventId = pb.enum("EnumMoneyChangeEventID","EventID_127")
|
||
player:GiveReward(reward.rewardId ,eventId,reward.count)
|
||
|
||
--添加到返回数据中
|
||
table.insert(data.rewardIdList,reward.rewardId)
|
||
end
|
||
end
|
||
|
||
--重置关卡信息
|
||
self:ResetStage(player,activityId)
|
||
|
||
--返回信息
|
||
s2cData.data = assert(pb.encode("S2SActivitySeekTreasureGetReward", data))
|
||
end
|
||
|
||
--跳过惩罚
|
||
function ActivitySeekTreasure:SkipPunish( player , c2sData , s2cData )
|
||
c2sData.data = assert(pb.decode("C2SActivitySeekTreasureSkipPunish", c2sData.data ))
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_ActivitySeekTreasureSkipPunish")
|
||
local punishType = c2sData.data.punishType
|
||
local data = {}
|
||
|
||
--检查并且获取活动信息
|
||
local cfgSeekTreasure=self:CheckDataAndGetActivity(player)
|
||
|
||
if cfgSeekTreasure == nil then
|
||
s2cData.code = errorInfo.ErrorCode.ActivityClosed
|
||
return
|
||
end
|
||
|
||
--获取开启的活动
|
||
local activityId, _, _, _ = activity:GetActivityInfo(player, self.ActivityType)
|
||
|
||
--玩家参与信息
|
||
local seekTreasure = player.gameData.SeekTreasureMap[activityId]
|
||
|
||
--当前是否处于惩罚中
|
||
if seekTreasure.curStageState ~= 2 then
|
||
s2cData.code = errorInfo.ErrorCode.NotInPunish
|
||
return
|
||
end
|
||
|
||
if punishType ==1 then--广告
|
||
if seekTreasure.ADSkipCount <=0 then
|
||
log.debug("限时寻味之旅 广告次数不足")
|
||
s2cData.code = errorInfo.ErrorCode.NotOpenLevel
|
||
return
|
||
end
|
||
|
||
seekTreasure.ADSkipCount=seekTreasure.ADSkipCount-1
|
||
else
|
||
|
||
local cfgSeekTreasureLevel=self:GetSeekTreasureLevelConfig(player,seekTreasure.curStage,seekTreasure.curLevel)
|
||
if cfgSeekTreasureLevel == nil then
|
||
log.debug("限时寻味之旅 配置错误")
|
||
s2cData.code = errorInfo.ErrorCode.NotOpenLevel
|
||
return
|
||
end
|
||
|
||
local type = cfgSeekTreasureLevel.skipPunishCost[1]
|
||
local count = cfgSeekTreasureLevel.skipPunishCost[2]
|
||
|
||
-- 跳过惩罚消耗
|
||
-- [货币类型,数量]
|
||
-- 1=金币
|
||
-- 2=三叶币
|
||
-- 3=蜗壳币
|
||
|
||
local goodsTypeId =0
|
||
if type == 1 then
|
||
if player.gameData.coin < count then
|
||
log.debug("限时寻味之旅 跳过惩罚消耗不足")
|
||
s2cData.code = errorInfo.ErrorCode.NoEnoughMoney
|
||
return
|
||
end
|
||
goodsTypeId =dataType.GoodsType_Coin
|
||
elseif type ==2 then
|
||
if player.gameData.clovers < count then
|
||
log.debug("限时寻味之旅 跳过惩罚消耗不足")
|
||
s2cData.code = errorInfo.ErrorCode.NoEnoughMoney
|
||
return
|
||
end
|
||
goodsTypeId =dataType.GoodsType_Clovers
|
||
elseif type ==3 then
|
||
if player.gameData.volute < count then
|
||
log.debug("限时寻味之旅 跳过惩罚消耗不足")
|
||
s2cData.code = errorInfo.ErrorCode.VoluteNotEnough
|
||
return
|
||
end
|
||
goodsTypeId =dataType.GoodsType_Volute
|
||
else
|
||
log.debug("限时寻味之旅 跳过惩罚未知类型")
|
||
s2cData.code = errorInfo.ErrorCode.ErrRequestParam
|
||
return
|
||
end
|
||
|
||
local eventId = pb.enum("EnumMoneyChangeEventID","EventID_128" )
|
||
|
||
--扣除消耗
|
||
player:MoneyChange(goodsTypeId, -count ,eventId)
|
||
end
|
||
|
||
--重新选择
|
||
local seekTreasureLevel = self:GetSeekTreasureLevelConfig(player,seekTreasure.curStage,seekTreasure.curLevel)
|
||
if seekTreasureLevel == nil then
|
||
log.debug("限时寻味之旅未开启-未获取到有效的活动2")
|
||
return false
|
||
end
|
||
|
||
local index = math.random(1,#seekTreasureLevel.levelReward)
|
||
|
||
seekTreasure.curStageRewardId=seekTreasureLevel.levelReward[index]--奖励id
|
||
|
||
--设置成未选择
|
||
seekTreasure.curStageState = 1
|
||
seekTreasure.lastIsSkipPunish=true
|
||
|
||
--返回客户端信息
|
||
data.curRewardId=seekTreasure.curStageRewardId
|
||
data.curStage=seekTreasure.curStage
|
||
data.curLevel=seekTreasure.curLevel
|
||
data.curStageState=seekTreasure.curStageState
|
||
data.stageRewardList=seekTreasure.stageRewardList
|
||
data.adSkipPunish=seekTreasure.ADSkipCount
|
||
|
||
--返回信息
|
||
s2cData.data = assert(pb.encode("S2SActivitySeekTreasureSkipPunish", data))
|
||
end
|
||
|
||
--领取结算奖励
|
||
function ActivitySeekTreasure:GetSettleReward( player , c2sData , s2cData )
|
||
c2sData.data = assert(pb.decode("C2SActivitySeekTreasureGetSettleReward", c2sData.data ))
|
||
s2cData.cmd = pb.enum("MsgType","CMD_S2C_ActivitySeekTreasureGetSettleReward")
|
||
local data = {}
|
||
|
||
--检查并且获取活动信息
|
||
local cfgSeekTreasure=self:CheckDataAndGetActivity(player)
|
||
|
||
if cfgSeekTreasure == nil then
|
||
s2cData.code = errorInfo.ErrorCode.ActivityClosed
|
||
return
|
||
end
|
||
|
||
--检查并且获取活动信息
|
||
local cfgSeekTreasure=self:CheckDataAndGetActivity(player)
|
||
|
||
if cfgSeekTreasure == nil then
|
||
s2cData.code = errorInfo.ErrorCode.ActivityClosed
|
||
return
|
||
end
|
||
|
||
--获取开启的活动
|
||
local activityId, _, _, _ = activity:GetActivityInfo(player, self.ActivityType)
|
||
|
||
--玩家参与信息
|
||
local seekTreasure = player.gameData.SeekTreasureMap[activityId]
|
||
|
||
if #seekTreasure.stageRewardList >0 then
|
||
for _, reward in ipairs(seekTreasure.stageRewardList) do
|
||
--发奖
|
||
local eventId = pb.enum("EnumMoneyChangeEventID","EventID_128")
|
||
player:GiveReward(reward.rewardId ,eventId,reward.count)
|
||
end
|
||
end
|
||
|
||
--初始化下一个阶段
|
||
self:InitNextStage(player,seekTreasure,activityId)
|
||
|
||
seekTreasure.curStageState = 0--设置成未开始
|
||
seekTreasure.isFinish = false --设置成未完成
|
||
seekTreasure.stageRewardList = {} --奖励列表
|
||
seekTreasure.seekTreasureTasks = {} --任务清除列表
|
||
|
||
skynet.server.msgTips:ReduceAll(player,114)
|
||
|
||
--返回信息
|
||
s2cData.data = assert(pb.encode("S2SActivitySeekTreasureGetSettleReward", data))
|
||
end
|
||
|
||
-- 定义一个回调函数
|
||
local function onEventFired(player , taskId , count)
|
||
|
||
--判断模块是否开启
|
||
if not player:IsUnlockSystem(dataType.UnlockSystem_ActivitySeekTreasure) then
|
||
return
|
||
end
|
||
|
||
--活动结束
|
||
local cfgSeekTreasure=ActivitySeekTreasure:CheckDataAndGetActivity(player)
|
||
if cfgSeekTreasure == nil then
|
||
return
|
||
end
|
||
|
||
--获取开启的活动
|
||
local activityId, _, _, _ = activity:GetActivityInfo(player, ActivitySeekTreasure.ActivityType)
|
||
|
||
--刷新任务
|
||
ActivitySeekTreasure:RefreshTaskList(player, activityId)
|
||
|
||
--是否需要执行任务
|
||
if not next(player.gameData.SeekTreasureMap[activityId].seekTreasureTasks) then
|
||
log.debug("任务触发，玩家任务列表为空")
|
||
return
|
||
end
|
||
|
||
--获取功能任务配置
|
||
local cfgSeekTreasureTasks = skynet.server.gameConfig:GetPlayerAllCfg(player,"SeekTreasureTask")
|
||
|
||
--存在配置
|
||
if cfgSeekTreasureTasks == nil or not next(cfgSeekTreasureTasks) then
|
||
log.debug("寻味之旅 配置为空")
|
||
return
|
||
end
|
||
|
||
local cfgSeekTreasureTaskList = {}
|
||
for _, cfgSeekTreasureTask in ipairs(cfgSeekTreasureTasks) do
|
||
if cfgSeekTreasureTask.seekTreasureId == activityId then
|
||
table.insert(cfgSeekTreasureTaskList,cfgSeekTreasureTask)
|
||
end
|
||
end
|
||
|
||
--触发完成任务
|
||
local finishIds = taskListEvent:Condition(player , taskId , count , player.gameData.SeekTreasureMap[activityId].seekTreasureTasks , cfgSeekTreasureTaskList)
|
||
|
||
local isAllTaskFinish = true
|
||
|
||
--是否完成所有任务
|
||
for _, value in pairs(player.gameData.SeekTreasureMap[activityId].seekTreasureTasks) do
|
||
if value.status ~= dataType.TaskStatus_Finish then
|
||
isAllTaskFinish =false
|
||
break
|
||
end
|
||
end
|
||
|
||
--是否完成所有任务
|
||
if isAllTaskFinish then
|
||
player.gameData.SeekTreasureMap[activityId].seekTreasureTasks={}
|
||
player.gameData.SeekTreasureMap[activityId].conParticipationNum = 1
|
||
skynet.server.msgTips:Add(player,113)
|
||
end
|
||
end
|
||
|
||
--改变测试数据
|
||
function ActivitySeekTreasure:ChangeTask(player,taskId,count)
|
||
onEventFired(player,taskId,count)
|
||
end
|
||
|
||
-- 注册事件处理函数
|
||
taskListEvent:Register(onEventFired,"寻味之旅")
|
||
|
||
skynet.server.activitySeekTreasure = ActivitySeekTreasure
|
||
return ActivitySeekTreasure |