local Activity = class("Activity", require("shared.ModelBaseMysql"))

  local string_format = string.format

  -- activity_ctr showType

  Activity.ActivityType = {

  	SsrUpPoolChange = 1,	-- 特定英雄活动，切卡池

  	DoubleDrop = 2, -- 双倍掉落

  	Sign = 4,  -- 签到
  	ChangeCG = 5,	-- 客户端使用，切换抽卡界面
  	PaySignIn = 6,	--付费签到
  	ExploreCommand = 7,	-- 探索指令
  	PayBack = 8,	--返利
  
  	BonusDouble = 9,	-- 奖励关卡翻倍
  	CalendaTask = 10,	-- 日历任务
  
  	FoodSell = 11,	--贩卖周 料理
  	DrawHero = 12,	--抽卡周 招募
  	AdvDraw = 13,	--拾荒抽周 资助
  	OpenBox = 14,	--拆解周 时钟箱

  	RaceDraw = 16,  -- 定向招募活动

  
  	ChallengeLevel = 17,	-- 挑战关卡活动
  	Exchange = 18,	-- 兑换活动
  	HangDrop = 19,	-- 挂机掉落活动
  	Gachakon = 20,	-- 扭蛋活动

  
  	WishHeroPool = 23, 	-- 心愿卡池
  	ActHeroPool = 24, -- 活动卡池

  	ActShopGoods = 25, 	-- 活动商品

  	Crisis = 26, -- 宝藏怪活动

  
  	CommonSignIn = 28, 	--通用签到

  	FriendEnergy = 30, -- 好友互赠能量活动 

  	AdvLevel = 33,	-- 拾荒关卡
  	BattleCommand = 34, -- 战令活动

  	NewSign = 36, -- 活动签到，单独的签到界面
  	HeroBackFree = 37, -- 无损耗归还

  	BattleCommandTask = 38, -- 战令任务活动

  	NewUserTask = 41,		-- 新用户任务

  	RegularWorldBoos = 42,	-- 常规世界boos

  	RadioTask = 43,			-- 活动电台任务

  }

  local function checkActivityType(activityType)
  	if type(activityType) == "string" then
  		activityType = Activity.ActivityType[activityType]
  	end

  	return activityType or 0

  end
  
  
  function Activity:ctor(properties)
  	Activity.super.ctor(self, properties)
  

  	self._isOpen = {}

  end

  function Activity:getType(actType)
  	if type(actType) == "string" then
  		actType = Activity.ActivityType[actType]
  	end
  	return actType or 0
  end
  

  Activity.schema = {

  	id 			= {"number", 0, "pri"},		-- 角色id

  	actime 		= {"table", {}},  -- 最近检查某项活动的开始时间  {id = time}

  	round		= {"table", {}},  -- 记录活动到了第几轮  {id = roundnum}

      signInDay   = {"number", 0},    -- 签到天数

  	act4		= {"table", {}},  -- {0 = day, 1= -1, 2 = -1} == 签到活动

  	act6		= {"table", {}},  -- {0 = day, 1 = 1, 2 = 1} == 付费签到活动

  	act8		= {"number", 0},  -- 充值返利 
  
  	act11		= {"table", {}},  -- {0 = 贩卖数量, 1=1, 2=1}  贩卖周活动  1表示领取过该档位的奖励
  	act12		= {"table", {}},  -- {0 = 抽卡次数, 1=1, 2=1}  抽卡周活动  1表示领取过该档位的奖励
  	act13		= {"table", {}},  -- {0 = 拾荒消耗远古金币数量, 1=1, 2=1}  拾荒周活动  1表示领取过该档位的奖励
  	act14		= {"table", {}},  -- {0 = 拆解数量, 1=1, 2=1}  拆解周活动  1表示领取过该档位的奖励

  	act17		= {"table", {}},	  -- {id=关卡星数, totalDmg=Boss总伤害}
  	act18		= {"table", {}, true},	  -- {id=兑换数量}

  	act19		= {"number", 0},	  -- {挂机信息}

  	act20		= {"table", {}},	  -- {id=扭蛋抽出数量}

  
  	act24		= {"table", {}, true},	-- 活动卡池 {id=repaynum}

  	act26 		= {"table", {}},	-- {task = {id = count}, socre = {id = status}}

  
  	act28		= {"table", {}},	-- 每日活跃签到 {0=day, 1=1,2=1,3=1}

  	act30 		= {"table", {}}, -- {magic = 0, limit = 0, reward = {id = 1, id = 1}, giveAE = {}, getAE = {}} 奖励字段1表示领取过奖励

  	act33 		= {"table", {}}, -- 拾荒关卡活动 {id={max=最大积分, pass=1}, r=""}
  

  	act34		= {"table", {}},	-- 战令记录{unlock = 1, freeR = "", payR = "", lvl = 10, sum = 100}

  	act36 		= {"table", {}}, -- 每日活跃签到 {0=day, 1=1,2=1,3=1}

  	act42 		= {"table", {}}, --

  
  	reset20 = {"number", 1}, -- 重置扭蛋机

  }

  function Activity:data()
  	return {

  		actime = self:getProperty("actime"),

  		round = self:getProperty("round"),

  		act4 = self:getProperty("act4"),

  		act6 = self:getProperty("act6"),

  		act8 = self:getProperty("act8"),
  		act11 = self:getProperty("act11"),
  		act12 = self:getProperty("act12"),
  		act13 = self:getProperty("act13"),
  		act14 = self:getProperty("act14"),

  
  		act17 = self:getProperty("act17"),
  		act18 = self:getProperty("act18"),
  		act19 = self:getProperty("act19"),
  		act20 = self:getProperty("act20"),

  		act24 = self:getProperty("act24"),

  		act26 = self:getProperty("act26"),

  
  		act28 = self:getProperty("act28"),

  		act30 = self:getProperty("act30"),

  		act33 = self:getProperty("act33"),
  

  		act34 = self:getProperty("act34"),

  		act36 = self:getProperty("act36"),

  		act42 = self:getProperty("act42"),

  
  		reset20 = self:getProperty("reset20")

  	}

  end
  

  function Activity:updateProperty(params)
  	local type, default = table.unpack(self.schema[params.field])
  
  	if params.delta then
  		self:incrProperty(params.field, params.delta)
  		if not params.notNotify then
  			self.owner:notifyUpdateProperty(params.field, self:getProperty(params.field))
  		end
  		return true
  	end
  	if params.value then
  		self:setProperty(params.field, params.value)
  		if not params.notNotify then
  			self.owner:notifyUpdateProperty(params.field, self:getProperty(params.field))
  		end
  		return true
  	end
  	return false
  end
  

  function Activity:isOpenRaw(activityId, now)
  	activityId = checkActivityType(activityId)
  	local actData = csvdb["activity_ctrlCsv"][activityId]

  	if not actData then return end
  
  	if actData.time == "" then -- 关闭
  		return false
  	end
  
  	local st = 0
  	local et = 0

  	--local now = skynet.timex()

  
  	if actData.ttype == 0 then -- 时间开放
  		local openTimes = actData.time:toArray(false, "=")
  		if openTimes[1] ~= "0" then
  			st = toUnixtime(openTimes[1]..string_format("%02x", RESET_TIME))
  		end
  		if openTimes[2] ~= "0" then
  			et = toUnixtime(openTimes[2]..string_format("%02x", RESET_TIME))
  		end
   	elseif actData.ttype == 1 then -- 周期开放
   		local openTimes = actData.time:toArray(true, "=")
   		local resetTime = toUnixtime(tostring(openTimes[1]) .. string_format("%02x", RESET_TIME))
   		local r = math.floor((now - resetTime) / (openTimes[3] * 86400))
   		st = resetTime + r * (openTimes[3] * 86400)
   		et = st + openTimes[2] * 86400
  	else
  		return
  	end
  
  	if now >= st and (et == 0 or now < et) then
  		return true, st
  	end
  	return false
  end
  
  -- 缓存开放

  function Activity:isOpen(activityType)
  	activityType = checkActivityType(activityType)

  	--return self._isOpen[activityType]
  	local open = false
  	for id, data in pairs(csvdb["activity_ctrlCsv"]) do
  		if data.showType == activityType then
  			open = self._isOpen[data.id]
  			if open then
  				return true, data.id
  			end
  		end
  	end
  	return false

  end
  

  function Activity:isOpenById(id, activityType)
  	activityType = checkActivityType(activityType)
  	local cfg = csvdb["activity_ctrlCsv"][id]
  	if not cfg then return false end

  	if activityType ~= 0 and cfg.showType ~= activityType then return false end

  	return self._isOpen[id]
  end
  

  function Activity:isResetById(id, activityType)
  	activityType = checkActivityType(activityType)
  	local cfg = csvdb["activity_ctrlCsv"][id]
  	if not cfg then return false end
  	if activityType ~= 0 and cfg.showType ~= activityType then return false end
  	return self:getResetData(activityType) == 0
  end
  
  function Activity:getResetData(actType)
  	actType = checkActivityType(actType)
  	return self:getProperty("reset" .. actType)
  end
  
  function Activity:updateResetData(actType, reset)
  	actType = checkActivityType(actType)
  	self:updateProperty({field = "reset" .. actType, value = reset})
  end
  

  function Activity:getActData(actType)
  	actType = checkActivityType(actType)
  	return self:getProperty("act" .. actType)
  end

  function Activity:updateActData(actType, data, notNotify)
  	actType = checkActivityType(actType)
  	self:updateProperty({field = "act" .. actType,  value = data, notNotify = notNotify})

  end
  

  -- 跨天刷新 --登录刷新

  function Activity:checkActivityStatus(now, isCrossDay, notify)
  	self._isOpen = {}

  	local actime = self:getProperty("actime")

  	local change = false

  	for actId, actData in pairs(csvdb["activity_ctrlCsv"]) do
  		local isOpen, startTime = self:isOpenRaw(actId, now)
  		self._isOpen[actId] = isOpen

  
  		if isOpen then

  			if actime[actId] and actime[actId] == startTime then -- 还是之前的状态 开放中

  				self:onLoginActivity(actId)

  			else  -- 重置

  				actime[actId] = startTime
  				self:closeActivity(actId, notify, true)
  				self:initActivity(actId, isCrossDay, notify)

  				change = true
  			end
  		else

  			if actime[actId] then
  				self:closeActivity(actId, notify)
  				actime[actId] = nil

  				change = true
  			end
  		end
  	end
  	if change then

  		self:updateProperty({field = "actime", value = actime, notNotify = not notify})

  	end

  end
  

  local activityFunc = {}

  activityFunc[Activity.ActivityType.Sign] = {
  	-- ["check"] = function(self, actType, notify) -- 检查
  	-- end,
  	["init"] = function(self, actType, isCrossDay, notify)
  		if not isCrossDay then
  			activityFunc[Activity.ActivityType.Sign]["crossDay"](self, actType, notify)
  		end
  	end,
  	-- ["close"] = function(self, actType, notify)
  	-- end,
  	["crossDay"] = function(self, actType, notify)
  		local curData = self:getActData(actType)
  		curData[0] = (curData[0] or 0) + 1

  		local actData = csvdb["new_signInCsv"]

  		if curData[0] > #actData then return end -- 满了就忽略了
  
  		-- 没满更新一下
  		self:updateActData(actType, curData, not notify)
  	end,
  }

  --loop1：累计料理贩卖N次
  --loop2：累计招募N次
  --loop3：累计资助N次
  --loop4：时钟箱拆解N个

  function Activity:checkWeeklyAct(actType, notify, count, pool)

  		local actInfoMap = {
  			[Activity.ActivityType.DrawHero] = {mailId = MailId.ActDrawCardReward, table = "activity_loop2Csv"},
  			[Activity.ActivityType.AdvDraw] = {mailId = MailId.ActAdvDrawReward, table = "activity_loop3Csv"},
  			[Activity.ActivityType.OpenBox] = {mailId = MailId.ActOpenBoxReward, table = "activity_loop4Csv"},
  			[Activity.ActivityType.FoodSell] = {mailId = MailId.ActSellFoodReward, table = "activity_loop1Csv"}
  		}

  		if actType == Activity.ActivityType.DrawHero and pool == DrawCardType.FriendDraw then
  			return
  		end

  		local info = actInfoMap[actType]
  		if not info then return end
  

  		local open, actId = self:isOpen(actType)
  		if not open then
  			return
  		end
  

  		local curData = self:getActData(actType)
  		local roundData = self:getProperty("round")
  		local curRound = roundData[actType] or 0

  		local ctrlData = csvdb["activity_ctrlCsv"][actId]

  		if not ctrlData then return end
  		if curRound >= ctrlData.condition then
  			return
  		end
  		curData[0] = (curData[0] or 0) + count
  		local totalCnt = 0
  		local finishCnt = 0
  		local maxCondition = 0

  		local flag = true
  		while flag do
  			--print("tatal number :", curData[0])
  			for i = 1, #csvdb[info.table] do
  				local cfg = csvdb[info.table][i]
  			--for k, cfg in pairs(csvdb[info.table] or {}) do
  				totalCnt = totalCnt + 1
  				if maxCondition < cfg.condition1 then
  					maxCondition = cfg.condition1
  				end
  				--print("cur condition", cfg.condition1)
  				if curData[0] < cfg.condition1 then
  					flag = false
  					break
  				end

  				--print(curData[0], cfg.condition1)
  				if not curData[cfg.id] and curData[0] >= cfg.condition1 then
  					if info.mailId then 

  						self.owner:log("activity", {
  							activity_id = cfg.id, -- 活动ID（或活动指定任务的ID）
  							activity_type = actType, -- 活动类型，见活动类型枚举表
  							activity_reward = cfg.reward:toNumMap(), -- 活动奖励，json格式记录,{'itemid1':123,'itemid2':456,………...}
  						})

  						self.owner:sendMail(info.mailId, nil, cfg.reward, {cfg.condition1})
  						curData[cfg.id] = 1
  					end
  				end
  				if curData[cfg.id] then
  					finishCnt = finishCnt + 1

  				end
  			end

  			if totalCnt == finishCnt then
  				roundData[actType] = (roundData[actType] or 0) + 1
  				for k,v in pairs(curData) do
  					if k == 0 then
  						curData[k] = curData[0] >= maxCondition and curData[0] - maxCondition or 0
  					else
  						curData[k] = nil
  					end
  				end
  				--print("cur round ".. roundData[actType], ctrlData.condition)
  				if roundData[actType] >= ctrlData.condition then
  					curData[0] = maxCondition
  					flag = false

  				end

  				self:updateProperty({field = "round", value = roundData, notNotify = not notify})

  			end

  		end
  		self:updateActData(actType, curData, not notify)
  end
  
  -- 抽卡周
  activityFunc[Activity.ActivityType.DrawHero] = {

  	["check"] = function(self, actType, notify, count, pool) -- 检查
  		self:checkWeeklyAct(actType, notify, count, pool)

  	end,
  	["init"] = function(self, actType, isCrossDay, notify)
  		local roundData = self:getProperty("round")
  		roundData[actType] = 0
  		self:updateProperty({field = "round",  value = roundData, notNotify = not notify})
  	end,
  	-- ["close"] = function(self, actType, notify)
  	-- end,
  	["crossDay"] = function(self, actType, notify)

  		self.owner:sendMail(MailId.ActDrawCard)
  	end,
  }
  
  -- 售卖周
  activityFunc[Activity.ActivityType.FoodSell] = {
  	["check"] = function(self, actType, notify, count) -- 检查
  		self:checkWeeklyAct(actType, notify, count)
  	end,
  	["init"] = function(self, actType, isCrossDay, notify)
  		local roundData = self:getProperty("round")
  		roundData[actType] = 0
  		self:updateProperty({field = "round",  value = roundData, notNotify = not notify})
  	end,
  	-- ["close"] = function(self, actType, notify)
  	-- end,
  	["crossDay"] = function(self, actType, notify)

  		self.owner:sendMail(MailId.ActSellFood)
  	end,
  }
  
  -- 拾荒周
  activityFunc[Activity.ActivityType.AdvDraw] = {
  	["check"] = function(self, actType, notify, count) -- 检查
  		self:checkWeeklyAct(actType, notify, count)
  	end,
  	["init"] = function(self, actType, isCrossDay, notify)
  		local roundData = self:getProperty("round")
  		roundData[actType] = 0
  		self:updateProperty({field = "round",  value = roundData, notNotify = not notify})
  	end,
  	-- ["close"] = function(self, actType, notify)
  	-- end,
  	["crossDay"] = function(self, actType, notify)

  		self.owner:sendMail(MailId.ActAdvDraw)
  	end,
  }
  
  -- 拆解周
  activityFunc[Activity.ActivityType.OpenBox] = {
  	["check"] = function(self, actType, notify, count) -- 检查
  		self:checkWeeklyAct(actType, notify, count)
  	end,
  	["init"] = function(self, actType, isCrossDay, notify)
  		local roundData = self:getProperty("round")
  		roundData[actType] = 0
  		self:updateProperty({field = "round",  value = roundData, notNotify = not notify})
  	end,
  	-- ["close"] = function(self, actType, notify)
  	-- end,
  	["crossDay"] = function(self, actType, notify)

  		self.owner:sendMail(MailId.ActOpenBox)
  	end,
  }
  

  -- 付费签到
  activityFunc[Activity.ActivityType.PaySignIn] = {
  	["init"] = function(self, actType, isCrossDay, notify)
  		self:updateActData(actType, {}, not notify)
  	end,

  	["crossDay"] = function(self, actType, notify)
  		local curData = self:getActData(actType)
  		curData[0] = (curData[0] or 0) + 1
  		self:updateActData(actType, curData, not notify)
  	end,

  	["close"] = function(self, actType, notify)
  		self.owner.storeData:SetActGoodsFlag("paySignIn", 0)

  		
  		local rechargeRecord = self.owner.storeData:getProperty("payR")
  		for id, cfg in pairs(csvdb["shop_rechargeCsv"]) do
  			if cfg.shop == 2 and cfg.type == CardType.PaySignCard then
  				rechargeRecord[id] = nil
  				break
  			end
  		end
  		self.owner.storeData:updateProperty({field="payR", value=rechargeRecord})

  	end,

  }
  

  -- 充值反馈
  activityFunc[Activity.ActivityType.PayBack] = {
  	["check"] = function(self, actType, notify, twd) -- 检查
  		local oldVal = self:getActData(actType) or 0
  		local newVal = oldVal + twd

  		local gift, checkPoint = self.owner:getPaybackReward(oldVal, newVal)

  		if gift ~= "" then

  			local strCp = table.concat(checkPoint ,"、")

  			self.owner:sendMail(MailId.PayBackAward, nil, gift, {newVal, strCp})

  		end
  		self:updateActData(actType, newVal, not notify)
  	end,
  	["init"] = function(self, actType, isCrossDay, notify)
  		self:updateActData(actType, {}, not notify)
  	end,
  	-- ["close"] = function(self, actType, notify)
  	-- end,
  }
  

  -- 英雄帖
  activityFunc[Activity.ActivityType.CalendaTask] = {
  	["init"] = function(self, actType, isCrossDay, notify)

  		local calTask = self.owner:getProperty("calTask")

  		calTask = {}

  		self.owner:updateProperty({field="calTask", value=calTask})

  		local role = self.owner
  		local buildL = role.dinerData:getProperty("buildL")
  		local curLevel = buildL:getv(1, 1)
  		role:checkTaskEnter("DinerLevelUp", {level = curLevel})
  
  		role:checkTaskEnter("HeroLvlCollect", {})
  		role:checkTaskEnter("HeroQualityCollect", {})
  
  		local curPopular = role.dinerData:getProperty("popular")
  		role:checkTaskEnter("DinerPopular", {count = curPopular})
  
  		local rLevel = role:getProperty("level")
  		role:checkTaskEnter("RoleLevelUp", {level = rLevel})
  
  		local towerInfo = role:getProperty("towerInfo")

  		role:checkTaskEnter("TowerPass", {count = towerInfo.l, type = 1})

  		--"PvpWin"

  		--role:checkTaskEnter("HangPass", {id = 0})
  		role:checkCalendaTask(true, 15, 3)

  		role:checkTaskEnter("HeroStarCollect", {})

  		role:checkTaskEnter("HeroStartSum", {})

  		role:checkTaskEnter("RuneQualityCollect", {})
  
  	end,

  	["crossDay"] = function(self, actType, notify, actId)

  		local actData = self.owner:getProperty("calTask") or {}

  		local record = actData["r"] or {}
  		local actCfg = csvdb["activity_taskCsv"][actId]
  		if not actCfg then return end
  		local change = false
  		for taskId, cfg in pairs(actCfg) do

  			if cfg["resetType"] == 1 then 	-- 每日重置

  				record[taskId] = nil
  				actData[taskId] = nil
  				change = true
  			end
  		end
  		if change then

  			self.owner:updateProperty({field="calTask", value=actData})
  		end
  	end,
  	["crossWeek"] = function(self, actType, notify, actId)
  		local actData = self.owner:getProperty("calTask") or {}
  		local record = actData["r"] or {}
  		local actCfg = csvdb["activity_taskCsv"][actId]
  		if not actCfg then return end
  		local change = false
  		for taskId, cfg in pairs(actCfg) do
  			if cfg["resetType"] == 2 then 	-- 每周重置
  				record[taskId] = nil
  				actData[taskId] = nil
  				change = true
  			end
  		end
  		if change then
  			self.owner:updateProperty({field="calTask", value=actData})

  		end
  	end,

  	["close"] = function(self, actType, notify)

  		self.owner:updateProperty({field="calTask", value={}})

  	end,

  }
  

  -- 活动任务 仅供春节活动使用 防冲突

  activityFunc[Activity.ActivityType.BattleCommandTask] = {

  	["init"] = function(self, actType, isCrossDay, notify)

  		local bcTask = self.owner:getProperty("bcTask")
  		bcTask = {}

  		self.owner:updateProperty({field="bcTask", value=bcTask})

  		local role = self.owner
  		local buildL = role.dinerData:getProperty("buildL")
  		local curLevel = buildL:getv(1, 1)
  		role:checkTaskEnter("DinerLevelUp", {level = curLevel})
  
  		role:checkTaskEnter("HeroLvlCollect", {})
  		role:checkTaskEnter("HeroQualityCollect", {})
  
  		local curPopular = role.dinerData:getProperty("popular")
  		role:checkTaskEnter("DinerPopular", {count = curPopular})
  
  		local rLevel = role:getProperty("level")
  		role:checkTaskEnter("RoleLevelUp", {level = rLevel})
  
  		local towerInfo = role:getProperty("towerInfo")

  		role:checkTaskEnter("TowerPass", {count = towerInfo.l, type = 1})

  		--"PvpWin"
  		--role:checkTaskEnter("HangPass", {id = 0})
  		role:checkCalendaTask(true, 15, 3)
  		role:checkTaskEnter("HeroStarCollect", {})

  		role:checkTaskEnter("HeroStartSum", {})

  		role:checkTaskEnter("RuneQualityCollect", {})
  
  	end,
  	["crossDay"] = function(self, actType, notify, actId)

  		local actData = self.owner:getProperty("bcTask") or {}

  		local record = actData["r"] or {}
  		local actCfg = csvdb["activity_taskCsv"][actId]
  		if not actCfg then return end
  		local change = false
  		for taskId, cfg in pairs(actCfg) do
  			if cfg["resetType"] == 1 then 	-- 每日充值
  				record[taskId] = nil
  				actData[taskId] = nil
  				change = true
  			end
  		end
  		if change then

  			self.owner:updateProperty({field="bcTask", value=actData})
  		end
  	end,
  	["crossWeek"] = function(self, actType, notify, actId)
  		local actData = self.owner:getProperty("bcTask") or {}
  		local record = actData["r"] or {}
  		local actCfg = csvdb["activity_taskCsv"][actId]
  		if not actCfg then return end
  		local change = false
  		for taskId, cfg in pairs(actCfg) do
  			if cfg["resetType"] == 2 then 	-- 每周重置
  				record[taskId] = nil
  				actData[taskId] = nil
  				change = true
  			end
  		end
  		if change then
  			self.owner:updateProperty({field="bcTask", value=actData})

  		end
  	end,
  	["close"] = function(self, actType, notify)

  		self.owner:updateProperty({field="bcTask", value={}})

  	end,
  }
  

  -- 兑换
  activityFunc[Activity.ActivityType.Exchange] = {
  	["init"] = function(self, actType, isCrossDay, notify, actId)

  		local actData = self:getActData(actType) or {}
  		actData[actId] = {}
  		self:updateActData(actType, actData, not notify)
  	end,

  	["login"] = function(self, actType, actId)

  		activityFunc[Activity.ActivityType.Exchange]["crossDay"](self, actType, true, actId)

  	end,

  	["crossDay"] = function(self, actType, notify, actId)
  		local actData = self:getActData(actType) or {}
  		local lastTs = actData["ts"] or 0
  		local timeNow = skynet.timex()
  		local cfg = csvdb["activity_ctrlCsv"][actId]
  		if not cfg then return end
  		local refreshTimes = cfg.condition2:toArray(false, "=")
  		for i = 1, #refreshTimes do

  			local rt = toUnixtime(refreshTimes[i]..string_format("%02x", RESET_TIME))

  			if timeNow >= rt and rt > lastTs then
  				lastTs = rt
  				actData = {}
  			end
  		end

  		if not next(actData) then
  			actData["ts"] = timeNow

  			self:updateActData(actType, actData, not notify)

  		end
  	end,
  	["close"] = function(self, actType, notify, actId)
  		local actData = self:getActData(actType) or {}
  		actData[actId] = nil
  		self:updateActData(actType, actData, not notify)
  	end,
  }
  
  -- 新用户活动任务 
  activityFunc[Activity.ActivityType.NewUserTask] = {
  	["init"] = function(self, actType, isCrossDay, notify)
  		local nbTask = self.owner:getProperty("nbTask")
  		nbTask = {}
  		self.owner:updateProperty({field="nbTask", value=nbTask})
  		local role = self.owner
  		local buildL = role.dinerData:getProperty("buildL")
  		local curLevel = buildL:getv(1, 1)
  		role:checkTaskEnter("DinerLevelUp", {level = curLevel})
  
  		role:checkTaskEnter("HeroLvlCollect", {})
  		role:checkTaskEnter("HeroQualityCollect", {})
  
  		local curPopular = role.dinerData:getProperty("popular")
  		role:checkTaskEnter("DinerPopular", {count = curPopular})
  
  		local rLevel = role:getProperty("level")
  		role:checkTaskEnter("RoleLevelUp", {level = rLevel})
  
  		local towerInfo = role:getProperty("towerInfo")
  		role:checkTaskEnter("TowerPass", {count = towerInfo.l, type = 1})
  		--"PvpWin"
  		--role:checkTaskEnter("HangPass", {id = 0})
  		role:checkCalendaTask(true, 15, 3)
  		role:checkTaskEnter("HeroStarCollect", {})

  		role:checkTaskEnter("HeroStartSum", {})

  		role:checkTaskEnter("RuneQualityCollect", {})
  
  	end,
  	["crossDay"] = function(self, actType, notify, actId)
  		local actData = self.owner:getProperty("nbTask") or {}
  		local record = actData["r"] or {}
  		local actCfg = csvdb["activity_taskCsv"][actId]
  		if not actCfg then return end
  		local change = false
  		for taskId, cfg in pairs(actCfg) do
  			if cfg["resetType"] == 1 then 	-- 每日重置
  				record[taskId] = nil
  				actData[taskId] = nil
  				change = true
  			end
  		end
  		if change then
  			self.owner:updateProperty({field="nbTask", value=actData})
  		end
  	end,
  	["crossWeek"] = function(self, actType, notify, actId)
  		local actData = self.owner:getProperty("nbTask") or {}
  		local record = actData["r"] or {}
  		local actCfg = csvdb["activity_taskCsv"][actId]
  		if not actCfg then return end
  		local change = false
  		for taskId, cfg in pairs(actCfg) do
  			if cfg["resetType"] == 2 then 	-- 每周重置
  				record[taskId] = nil
  				actData[taskId] = nil
  				change = true
  			end
  		end
  		if change then
  			self.owner:updateProperty({field="nbTask", value=actData})
  		end
  	end,
  	["close"] = function(self, actType, notify)
  		self.owner:updateProperty({field="nbTask", value={}})
  	end,
  }
  
  -- 兑换
  activityFunc[Activity.ActivityType.Exchange] = {
  	["init"] = function(self, actType, isCrossDay, notify, actId)
  		local actData = self:getActData(actType) or {}
  		actData[actId] = {}
  		self:updateActData(actType, actData, not notify)
  	end,
  	["login"] = function(self, actType, actId)
  		activityFunc[Activity.ActivityType.Exchange]["crossDay"](self, actType, true, actId)
  	end,
  	["crossDay"] = function(self, actType, notify, actId)
  		local actData = self:getActData(actType) or {}
  		local lastTs = actData["ts"] or 0
  		local timeNow = skynet.timex()
  		local cfg = csvdb["activity_ctrlCsv"][actId]
  		if not cfg then return end
  		local refreshTimes = cfg.condition2:toArray(false, "=")
  		for i = 1, #refreshTimes do
  			local rt = toUnixtime(refreshTimes[i]..string_format("%02x", RESET_TIME))
  			if timeNow >= rt and rt > lastTs then
  				lastTs = rt
  				actData = {}
  			end
  		end
  		if not next(actData) then
  			actData["ts"] = timeNow
  			self:updateActData(actType, actData, not notify)