Merge branch 'bugfix' into tr/ob

* bugfix: (37 commits) 活动卡池保底出指定英雄拆解术式充能的时候领取道具，获得个数计算错误新手卡池限制30抽给保底抽配置加默认值10 cb 返利重写拆解室功能拆解室功能重写去除globald中发放活动排行奖励世界Boss 增加行动点物资危机bug 物资危机冒险bug 宝藏怪活动世界boss翻牌奖励活动卡池保底单独记录充值天赋升级写日志报错活动剧情解锁充值重复 bug 下一关提前 ... # Conflicts: # src/csvdata

Merge branch 'bugfix' into tr/ob
* bugfix: (37 commits) 活动卡池保底出指定英雄拆解术式充能的时候领取道具，获得个数计算错误新手卡池限制30抽给保底抽配置加默认值10 cb 返利重写拆解室功能拆解室功能重写去除globald中发放活动排行奖励世界Boss 增加行动点物资危机bug 物资危机冒险bug 宝藏怪活动世界boss翻牌奖励活动卡池保底单独记录充值天赋升级写日志报错活动剧情解锁充值重复 bug 下一关提前 ... # Conflicts: # src/csvdata
zhouhaihai
2 parents d541ef92 c8c76cda
Showing 31 changed files with 736 additions and 242 deletions Show diff stats
robot/robot.lua
robot/robot_config.lua
robot/start.lua
src/GlobalVar.lua
src/ProtocolCode.lua
src/RedisKeys.lua
src/actions/ActivityAction.lua
src/actions/DinerAction.lua
src/actions/GmAction.lua
src/actions/HangAction.lua
src/actions/HeroAction.lua
src/actions/PvpAction.lua
src/actions/RadioAction.lua
src/actions/RoleAction.lua
src/actions/StoreAction.lua
src/adv/Adv.lua
src/adv/AdvBuff.lua
src/adv/AdvPassive.lua
src/adv/AdvPlayer.lua
src/agent.lua
@@ -131,6 +131,8 @@ end
 -- 登录成功开始任务
 function CMD.task()
 	heartBeat()
+	-- 20 秒后开始执行任务 错开登录
+	skynet.sleep(math.randomInt(2000, 3000))
 	startUnit()
 end
@@ -18,21 +18,21 @@ return {
 	online = 100,	-- 稳定状态在线人数
 	inpre = 10,		-- 稳定前每秒进入人数  -- 必须小于online数
 	max = 200, 	-- 最大玩家数 必须大于 online 数
-	online_time = {10, 60}, -- 在线时间控制 秒
+	online_time = {10 * 60, 20 * 60}, -- 在线时间控制 秒
 	uname_prefix = "robothehe", --机器名称前缀
 	-- 机器上线后的行为
 	units = {
-		chat = {weight = 1}, -- 聊天
-		item = {weight = 1}, -- 物品操作
-		hero = {weight = 1}, -- 英雄 
-		hang = {weight = 1}, -- 挂机战斗 
-		tower = {weight = 1}, -- 爬塔
-		car = {weight = 1}, -- 爬塔
-		pvp = {weight = 1}, -- pvp
-		email = {weight = 1}, -- 邮件
-		adv = {weight = 1}, -- 冒险
+		chat = {weight = 100}, -- 聊天
+		item = {weight = 100}, -- 物品操作
+		hero = {weight = 500}, -- 英雄
+		hang = {weight = 1000}, -- 挂机战斗
+		tower = {weight = 500}, -- 爬塔
+		car = {weight = 100}, -- 爬塔
+		pvp = {weight = 500}, -- pvp
+		email = {weight = 100}, -- 邮件
+		adv = {weight = 200}, -- 冒险
 	}
 }
@@ -25,7 +25,6 @@ end
 function MSG.close(fd)
 	if fd2serv[fd] and not fd2serv[fd].closing then
 		fd2serv[fd].closing = true
-		print(fd2serv[fd].agent)
 		skynet.call(fd2serv[fd].agent, "lua", "exit")
 		pcall(skynet.send, poold, "lua", "feed")
@@ -131,6 +130,9 @@ local function start(pooldp, pooldObj, onlineCountp, startIdp, endIdp, inprep)
 	for i = 1, onlineCount, inpre do
 		for j = 1, inpre do
+			if i + j - 1 > onlineCount then
+				break
+			end
 			add_robot()
 		end
 		skynet.sleep(100)
@@ -134,8 +134,8 @@ ItemId = {
 	RuneFragment = 24,
 	HeroFC = {700, 701, 702, 703},  --通用角色碎片
 	AdvKey = 80, -- 冒险钥匙
-	BoxKey = 60, -- 拆解工具
 	AdvPower = 4701, -- 拾荒体力
+	CrisisScore = 8010, -- 积分
 }
 TimeReset = {
@@ -292,6 +292,10 @@ CardType = {
 	BattlePassCard = 7, -- 探索指令
 }
+ShopPackType = {
+	ActShopPack = 5,	-- 活动礼包
+}
+
 HeroQuality = {
 	N = 1,
 	R = 2,
@@ -318,6 +322,7 @@ MailId = {
 	PaySignAward = 241,
 	PayBackAward = 242,
+	CBBackAward = 243,
 }
 TriggerEventType = {
@@ -227,6 +227,8 @@ actionCodes = {
 	Activity_endBattleRpc = 661,
 	Activity_battleRankRpc = 662,
 	Activity_battleMilestoneRpc = 663,
+	Activity_bossRewardRpc = 664,
+	Activity_crisisMilestoneRpc = 665,
 	Radio_startQuestRpc = 700,
 	Radio_finishQuestRpc = 701,
@@ -19,6 +19,7 @@ R_ORDER = &quot;order:%d:%d&quot;
 RANK_COMMON 	= "rank:common:"
 RANK_TYPE = {
     ActBattleBoss = "act_battle_boss",
+    ActCrisis = "crisis",
 }
 -- rank
@@ -268,7 +268,8 @@ function _M.exchangeRpc(agent, data)
 	local msg = MsgPack.unpack(data)
 	local actid = msg.actid
 	local id = msg.id
-	if not role.activity:isOpenById(actid) then return 1 end
+	local count = msg.count
+	if not role.activity:isOpenById(actid, "Exchange") then return 1 end
 	local exchangeCfg = csvdb["activity_exchangeCsv"][actid]
 	if not exchangeCfg then return 2 end
@@ -278,18 +279,26 @@ function _M.exchangeRpc(agent, data)
 	local curCount = exchangeData[id] or 0
 	local actCfg = exchangeCfg[id]
 	local limitArr = actCfg.limit:toArray(true, "=")
-	if curCount >= limitArr[2] then return 4 end
+	if curCount + count > limitArr[2] then return 4 end
 	local costs = actCfg.goods:toNumMap()
+	for k,v in pairs(costs) do
+		costs[k] = v * count
+	end
 	if not role:checkItemEnough(costs) then return 5 end
 	role:costItems(costs, {log = {desc = "actExchange", int1 = actid, int2 = id}})
-	curCount = curCount + 1
+	curCount = curCount + count
 	exchangeData[id] = curCount
 	curData[actid] = exchangeData
 	role.activity:updateActData("Exchange", curData)
-	local reward, change = role:award(actCfg.award, {log = {desc = "actExchange", int1 = actid, int2 = id}})
+	local award = actCfg.award:toNumMap()
+	for k,v in pairs(award) do
+		award[k] = v * count
+	end
+
+	local reward, change = role:award(award, {log = {desc = "actExchange", int1 = actid, int2 = id}})
 	SendPacket(actionCodes.Activity_exchangeRpc, MsgPack.pack(role:packReward(reward, change)))
@@ -304,7 +313,7 @@ function _M.gachakonRpc(agent, data)
 	if count > 10 then return end
-	if not role.activity:isOpenById(actid) then return 1 end
+	if not role.activity:isOpenById(actid, "Gachakon") then return 1 end
 	local actCtrlData = csvdb["activity_ctrlCsv"][actid]
 	if not actCtrlData then return 2 end
@@ -316,6 +325,7 @@ function _M.gachakonRpc(agent, data)
 	local gachakonInfo = role.activity:getActData("Gachakon") or {}
 	local award = {}
 	local remain = 0
+	local showAward = {}
 	for i = 1, count do
 		local tmpCfg = clone(actCfg)
 		remain = 0
@@ -335,6 +345,7 @@ function _M.gachakonRpc(agent, data)
 		if not id then return 4 end
 		gachakonInfo[id] = (gachakonInfo[id] or 0) + 1
 		local curAward = tmpCfg[id].award:toNumMap()
+		table.insert(showAward, curAward)
 		for k, v in pairs(curAward) do
 			award[k] = (award[k] or 0) + v
 		end
@@ -355,7 +366,7 @@ function _M.gachakonRpc(agent, data)
 	end
 	role.activity:updateActData("Gachakon", gachakonInfo)
-	SendPacket(actionCodes.Activity_gachakonRpc, MsgPack.pack(role:packReward(reward, change)))
+	SendPacket(actionCodes.Activity_gachakonRpc, MsgPack.pack(showAward))
 	return true
 end
@@ -363,7 +374,7 @@ function _M.hangDropRpc(agent, data)
 	local role = agent.role
 	local msg = MsgPack.unpack(data)
 	local actid = msg.actid
-	if not role.activity:isOpenById(actid) then return 1 end
+	if not role.activity:isOpenById(actid, "HangDrop") then return 1 end
 	local actCfg = csvdb["activity_putCsv"][actid]
 	if not actCfg then return 2 end
@@ -380,7 +391,7 @@ function _M.hangDropRpc(agent, data)
 			if type == 1 then
 				local actId = arr[2]
 				local carbonId = arr[3]
-				if not role.activity:isOpenById(actid) then return 3 end
+				if not role.activity:isOpenById(actId, "ChallengeLevel") then return 3 end
 				local clInfo = role.activity:getActData("ChallengeLevel") or {}
 				if not clInfo[carbonId] then
 					break
@@ -437,7 +448,7 @@ function _M.startBattleRpc(agent, data)
 	local actid = msg.actid
 	local id = msg.id
 	local count = msg.count
-	if not role.activity:isOpenById(actid) then return 1 end
+	if not role.activity:isOpenById(actid, "ChallengeLevel") then return 1 end
 	local actCfg = csvdb["activity_battleCsv"][actid]
 	if not actCfg then return 2 end
@@ -461,9 +472,10 @@ function _M.startBattleRpc(agent, data)
 	-- check cost
 	local changeFlag = false
 	local ticket = actData["ticket"]
+	local num = 0	-- cost num
 	if battleCfg.type ~= "" then
 		role.activity:getBattleTicket(actid)
-		local num = battleCfg.type:toArray(true, "=")[3]
+		num = battleCfg.type:toArray(true, "=")[3]
 		if count and count > 0 then
 			if battleCfg.rank == 0 then
 				return 7
@@ -479,9 +491,10 @@ function _M.startBattleRpc(agent, data)
 		if ticket < num then
 			return 6
 		end
-		actData["ticket"] = ticket - num
 		changeFlag = true
 	end
+	-- 解锁活动剧情
+	role:checkStoryStatus(false, 5, id)
 	if not count then
 		role.__actBattleCache = {
@@ -513,6 +526,7 @@ function _M.startBattleRpc(agent, data)
 		SendPacket(actionCodes.Activity_startBattleRpc, MsgPack.pack(role:packReward(reward, change)))
 		bi["sum"] = bi["sum"] + bi["top"]
+		actData["ticket"] = ticket - num
 		actData[id] = bi
 		changeFlag = true
@@ -540,7 +554,7 @@ function _M.endBattleRpc(agent, data)
 	local isWin = msg.isWin
 	local heros = msg.heros
 	local support = msg.support
-	if not role.activity:isOpenById(actid) then return 1 end
+	if not role.activity:isOpenById(actid, "ChallengeLevel") then return 1 end
 	if not role.__actBattleCache then return 2 end
@@ -556,6 +570,14 @@ function _M.endBattleRpc(agent, data)
 	local actData = role.activity:getActData("ChallengeLevel") or {}
+	-- 总输出
+	local dmg = 0
+	for k, v in pairs(msg.info.damage) do
+		if k % 100 == 2 then
+			dmg = dmg + v
+		end
+	end
+
 	local reward, change = {}, nil
 	local battleInfo = actData[id] or {}
@@ -611,6 +633,10 @@ function _M.endBattleRpc(agent, data)
 		check[7] = function(_, cond)
 			return msg.info.atime and msg.info.atime <= cond
 		end
+		-- 8 总输出值  msg.info.atime
+		check[8] = function(_, cond)
+			return dmg >= cond
+		end
 		curStar = 0
 		local sweepConds = battleCfg.sweep_condition:toTableArray(true)
  		for i, cond in ipairs(sweepConds) do
@@ -618,8 +644,11 @@ function _M.endBattleRpc(agent, data)
  				curStar = curStar + (1 << (i - 1))
  			end
  		end
- 	else
- 		curStar = 0
+	 else
+		curStar = 0
+		if battleCfg.rank ~= 0 then
+			curStar = 1
+		end
 	end
 	local oldStarNum = getStarCount(battleCfg, battleInfo["star"] or 0)
 	local newStarNum = getStarCount(battleCfg, curStar)
@@ -628,13 +657,12 @@ function _M.endBattleRpc(agent, data)
 	end
 	if battleCfg.rank ~= 0 then
+		-- 消耗门票
+		role.activity:getBattleTicket(actid)
+		local num = battleCfg.type:toArray(true, "=")[3]
+		actData["ticket"] = math.max(actData["ticket"] - num, 0)
+
 		-- 更新排行榜 最高伤害
-		local dmg = 0
-		for k, v in pairs(msg.info.damage) do
-			if k % 100 == 2 then
-				dmg = dmg + v
-			end
-		end
 		battleInfo["top"] = math.max(battleInfo["top"] or 0, dmg)
 		battleInfo["sum"] = (battleInfo["sum"] or 0) + dmg
 		local rankVal = 0
@@ -650,10 +678,10 @@ function _M.endBattleRpc(agent, data)
 	actData[id] = battleInfo
 	role.activity:updateActData("ChallengeLevel", actData)
-	if oldStarNum == 0 or battleCfg.rank ~= 0 then
+	if (oldStarNum == 0 and newStarNum > 0) or battleCfg.rank ~= 0 then
 		reward = battleCfg.item_clear:toNumMap()
 	end
-	if (oldStarNum < 3 and newStarNum == 3) or battleCfg.rank ~= 0 then
+	if (oldStarNum < 3 and newStarNum == 3) or (battleCfg.rank ~= 0 and newStarNum == 3) then
 		local aw = battleCfg.perfect_reward:toNumMap()
 		for k, v in pairs(aw) do
 			reward[k] = (reward[k] or 0) + v
@@ -670,6 +698,15 @@ function _M.endBattleRpc(agent, data)
 		supports = support,
 	})
+	-- 解锁活动剧情
+	if newStarNum >= 3 then
+		role:checkStoryStatus(false, 5, id)
+	end
+
+	if battleCfg.worldBoss_award ~= 0 and msg.point then
+		battleInfo["bossP"] = (battleInfo["bossP"] or 0) + msg.point
+	end
+
 	reward, change  = role:award(reward, {log = {desc = "actBattle", int1 = actid, int2 = newStarNum}})
 	SendPacket(actionCodes.Activity_endBattleRpc, MsgPack.pack({
@@ -684,10 +721,15 @@ function _M.battleRankRpc(agent, data)
 	local role = agent.role
 	local msg = MsgPack.unpack(data)
 	local actid = msg.actid
-	if not role.activity:isOpenById(actid) then return 1 end
-
-	local rankInfo = role:getRankInfoCommon(RANK_TYPE.ActBattleBoss)
-
+	local cfg = csvdb["activity_ctrlCsv"][actid]
+	if not cfg then return 1 end
+	if not role.activity:isOpen(cfg.showType) then return 2 end
+	local actTypeToRank = {
+		[role.activity.ActivityType.ChallengeLevel] = RANK_TYPE.ActBattleBoss,
+		[role.activity.ActivityType.Crisis] = RANK_TYPE.ActCrisis,
+	}
+	if not actTypeToRank[cfg.showType] then return end
+	local rankInfo = role:getRankInfoCommon(actTypeToRank[cfg.showType])
 	SendPacket(actionCodes.Activity_battleRankRpc, MsgPack.pack(rankInfo))
 	return true
 end
@@ -699,7 +741,7 @@ function _M.battleMilestoneRpc(agent, data)
 	local id = msg.id
 	local index = msg.index
-	if not role.activity:isOpenById(actid) then return 1 end
+	if not role.activity:isOpenById(actid, "ChallengeLevel") then return 1 end
 	local actCfg = csvdb["activity_mileageCsv"][actid]
 	if not actCfg then return 3 end
@@ -732,4 +774,88 @@ function _M.battleMilestoneRpc(agent, data)
 	return true
 end
+function _M.crisisMilestoneRpc(agent, data)
+	local role = agent.role
+	local msg = MsgPack.unpack(data)
+	local actid = msg.actid
+	local id = msg.id
+	if not role.activity:isOpenById(actid, "Crisis") then return 1 end
+	local actCfg = csvdb["activity_mileageCsv"][actid]
+	if not actCfg then return 3 end
+
+	local curCsv = actCfg[id]
+	if not curCsv then return 4 end
+
+	if role:getItemCount(ItemId.CrisisScore) < curCsv.condition then
+		return 5
+	end
+
+	local actData = role.activity:getActData("Crisis") or {}
+	actData.score = actData.score or {}
+	if actData.score[id] then
+		return 6
+	end
+	actData.score[id] = -1
+	role.activity:updateActData("Crisis", actData)
+
+	local reward, change = role:award(curCsv.reward, {log = {desc = "actMilecrisis", int1 = actid}})
+	SendPacket(actionCodes.Activity_crisisMilestoneRpc, MsgPack.pack(role:packReward(reward, change)))
+	return true
+end
+
+
+function _M.bossRewardRpc(agent, data)
+	local role = agent.role
+	local msg = MsgPack.unpack(data)
+	local actid = msg.actid
+	local id = msg.id
+	local index = msg.index
+
+	if not role.activity:isOpenById(actid, "ChallengeLevel") then return 1 end
+
+	local actCfg = csvdb["activity_battleCsv"][actid]
+	if not actCfg then return 2 end
+
+	local battleCfg = actCfg[id]
+	if not battleCfg then return 3 end
+
+	if battleCfg.worldBoss_award == 0 then return 4 end
+
+	actCfg = csvdb["activity_wordboss_awardCsv"][battleCfg.worldBoss_award]
+	if not actCfg then return 5 end
+	local awardCfg = actCfg[index]
+	if not awardCfg then return 6 end
+
+	local preList = awardCfg.condition1:toArray(true, "=")
+
+	local actData = role.activity:getActData("ChallengeLevel") or {}
+	local battleInfo = actData[id] or {}
+	local bossPoint = battleInfo["bossP"] or 0
+	if bossPoint < 1 then return 7 end
+
+	local bossRecord = battleInfo["bossR"] or ""
+	local ok = false
+	if #preList == 0 then
+		ok = true
+	else
+		for _, i in ipairs(preList) do
+			local flag = string.char(string.getbit(bossRecord, i))
+			if flag == "1" then
+				ok = true
+				break
+			end
+		end
+	end
+	if not ok then return 8 end
+
+	battleInfo["bossR"] = string.setbit(bossRecord, index)
+	actData[id] = battleInfo
+	role.activity:updateActData("ChallengeLevel", actData)
+
+	local award = awardCfg.reward:toNumMap()
+	local reward, change = role:award(award, {log = {desc = "worldBossReward", int1 = actid, int2 = index}})
+	SendPacket(actionCodes.Activity_bossRewardRpc, MsgPack.pack(role:packReward(reward, change)))
+	return true
+end
+
 return _M
 \ No newline at end of file
@@ -598,6 +598,7 @@ function _M.updateTaskRpc( agent, data )
 		restaurant_order_status = cmd, -- 订单任务状态，接受:0, 拒绝:1, 完成:2
 		restaurant_order_rwd = reward or {}, -- 订单完成奖励，json格式记录，{"itemid1":123,"itemid2":12,……….}
 		restaurant_order_lv = taskData.rarity, -- 订单品质等级，普通:0, 稀有:1, 顶级:2, 豪华:3
+		restaurant_order_type = 1, -- 订单任务类型，0:特殊顾客，1:特别订单
 	})
 	role.dinerData:updateProperty({field = "order", value = json.encode(orders)})
@@ -896,6 +897,14 @@ function _M.entrustRpc(agent , data)
 		reward, change = role:award(curData.reward, {log = {desc = "dinerEntrus", int1 = entrustId}})
 		table.remove(entrust, 1)
+
+		role:log("restaurant_order", {
+			restaurant_order_id = entrustId, -- 订单任务ID
+			restaurant_order_status = 2, -- 订单任务状态，接受:0, 拒绝:1, 完成:2
+			restaurant_order_rwd = reward or {}, -- 订单完成奖励，json格式记录，{"itemid1":123,"itemid2":12,……….}
+			restaurant_order_lv = curData.type, -- 订单品质等级，普通:0, 稀有:1, 顶级:2, 豪华:3
+			restaurant_order_type = 0, -- 订单任务类型，0:特殊顾客，1:特别订单
+		})
 	elseif ctype == 2 then		-- 放弃
 		table.remove(entrust, 1)
 	else
@@ -529,6 +529,16 @@ function _M.guide(role, pms)
 	return "成功"
 end
+table.insert(helpDes, {"挑战关卡次数", "actbattle"})
+function _M.actbattle(role, pms)
+	if not role.activity:isOpen("ChallengeLevel") then return end
+	local actData = role.activity:getActData("ChallengeLevel")
+	actData["ticket"] = 100
+	role.activity:updateActData("ChallengeLevel", actData)
+
+	return "成功"
+end
+
 function _M.helpRpc(agent, data)
 	SendPacket(actionCodes.Gm_helpRpc, MsgPack.pack({help = helpDes}))
 	return true
@@ -498,46 +498,49 @@ function _M.buyBonusCountRpc(agent, data)
 	return true
 end
-local function bonusWinReward(role, bonusData, bwin, count)
+local function bonusWinReward(role, bonusData, rewardType, count)
 	count = count or 1
-	local open, actId = role.activity:isOpen("BonusDouble")
-	local actData = csvdb["activity_ctrlCsv"][actId]
-	local extraCnt = role.storeData:getBonusExtraFightCount()
-
-	local coef = 1
-	if open and actData then
-		coef = tonumber(actData.condition2)
-	end
-	local bonusC = role.dailyData:getProperty("bonusC")
-	bonusC[bonusData.type] = bonusC[bonusData.type] or {c = 0, b = 0}
-	if globalCsv.bonus_daily_count * coef + extraCnt - bonusC[bonusData.type]["c"] < count then return false, 1 end
-	bonusC[bonusData.type]["c"] = bonusC[bonusData.type]["c"] + count
-	role.dailyData:updateProperty({field = "bonusC", value = bonusC})
-	local reward, change
-	reward = bonusData.reward:toNumMap()
-	for itemId, c in pairs(reward) do
-		reward[itemId] = c * count
-	end
-	for i = 1, count do
-		local chance = bonusData.chance:randWeight(true)
-		if chance[1] ~= 0 then
-			reward[chance[1]] = (reward[chance[1]] or 0) + chance[2]
+	local reward, change = {}
+	if rewardType == 1 or rewardType == 4 then
+		for k, v in pairs(bonusData.clear_reward:toNumMap()) do
+			reward[k] = (reward[k] or 0) + v
 		end
 	end
-	for k, v  in pairs(reward) do
-		reward[k] = v * (coef > 1 and actData.condition or 1)
-	end
-	
-	if bwin then -- 满星 额外奖励
+	if rewardType == 2 or rewardType == 4 then
 		for k, v in pairs(bonusData.perfect_reward:toNumMap()) do
 			reward[k] = (reward[k] or 0) + v
 		end
 	end
-	reward, change = role:award(reward, {log = {desc = "bonusBattle", int1 = id}})
-	role:checkTaskEnter("BonusPass", {id = id, count = count})
-	return true, reward, change
+
+	if rewardType == 3 then
+		local open, actId = role.activity:isOpen("BonusDouble")
+		local actData
+		if open then
+			actData = csvdb["activity_ctrlCsv"][actId]
+		end
+
+		reward = bonusData.reward:toNumMap()
+		for itemId, c in pairs(reward) do
+			reward[itemId] = c * count
+		end
+		for i = 1, count do
+			local chance = bonusData.chance:randWeight(true)
+			if chance[1] ~= 0 then
+				reward[chance[1]] = (reward[chance[1]] or 0) + chance[2]
+			end
+		end
+		if open and actData then
+			for k, v  in pairs(reward) do
+				reward[k] = v * (actData.condition > 1 and actData.condition or 1)
+			end
+		end
+	end
+	
+	reward, change = role:award(reward, {log = {desc = "bonusBattle", int1 = bonusData.id}})
+	role:checkTaskEnter("BonusPass", {id = bonusData.id, count = count})
+	return reward, change
 end
 function _M.startBonusBattleRpc(agent, data)
@@ -559,23 +562,24 @@ function _M.startBonusBattleRpc(agent, data)
 	if not bonusData then return 3 end
 	if not role:checkHangPass(bonusData.unlock) then return 4 end
-	local bonusC = role.dailyData:getProperty("bonusC")
-	bonusC[bonusData.type] = bonusC[bonusData.type] or {c = 0, b = 0}
-
-	local actData = csvdb["activity_ctrlCsv"][actId]
-
-	local extraCnt = role.storeData:getBonusExtraFightCount()
-	local coef = 1
-	if open and actData then
-		coef = tonumber(actData.condition2)
-	end
-	
-	if math.illegalNum(count, 1, globalCsv.bonus_daily_count * coef + extraCnt - bonusC[bonusData.type]["c"]) then return 7 end
 	local bonusStar = role:getProperty("bonusStar")
 	if bonusStar[id] and bonusStar[id] >= (1 << #bonusData.sweep_condition:toTableArray(true)) - 1 then 
-		local status, reward, change = bonusWinReward(role, bonusData, nil, count)
-		if not status then return 10 * (reward or 0) end
+			local bonusC = role.dailyData:getProperty("bonusC")
+			bonusC[bonusData.type] = bonusC[bonusData.type] or {c = 0, b = 0}
+
+			local actData = csvdb["activity_ctrlCsv"][actId]
+			local extraCnt = role.storeData:getBonusExtraFightCount()
+			local coef = 1
+			if open and actData then
+				coef = tonumber(actData.condition2)
+			end
+			if math.illegalNum(count, 1, globalCsv.bonus_daily_count * coef + extraCnt - bonusC[bonusData.type]["c"]) then return 7 end
+
+			bonusC[bonusData.type]["c"] = bonusC[bonusData.type]["c"] + count
+			role.dailyData:updateProperty({field = "bonusC", value = bonusC})
+
+		local reward, change = bonusWinReward(role, bonusData, 3, count)
 		SendPacket(actionCodes.Hang_startBonusBattleRpc, MsgPack.pack({reward = reward, change = change}))
 	else
 		local bTeam = role:getTeamFormatByType(TeamSystemType.BonusBattle)
@@ -605,15 +609,16 @@ function _M.endBonusBattleRpc(agent, data)
 	end
 	local bonusData = csvdb["bonus_battleCsv"][id]
-	local reward, change
+	local reward, change = {}
 	local bonusStar = role:getProperty("bonusStar")
+	local oldStar = bonusStar[id] or 0
 	local curStar = 0
  	if starNum and starNum > 0 then
  		-- 胜利扣除次数
  		local bTeam = role:getTeamFormatByType(TeamSystemType.BonusBattle)
- 		local herosInfo = role:getTeamHerosInfo(bTeam.heros)
+ 		local herosInfo = role:getTeamHerosInfo(bTeam).heros
  		local check = {}
  		-- 1 通关
@@ -671,12 +676,23 @@ function _M.endBonusBattleRpc(agent, data)
  			end
  		end
  		local status
- 		status, reward, change = bonusWinReward(role, bonusData, curStar >= (1 << #sweepConds) - 1)
- 		if not status then return 10 + (reward or 0) end
+ 		local rewardType = 0
+ 		if curStar >= (1 << #sweepConds) - 1 then -- 满星
+ 			rewardType = 2
+ 			if oldStar == 0 then  --通关
+ 				rewardType = 4
+ 			end
+ 		elseif oldStar == 0 then --通关
+ 			rewardType = 1
+ 		end
+
+ 		if rewardType ~= 0 then
+	 		reward, change = bonusWinReward(role, bonusData, rewardType)
+	 	end
  	else
- 		curStar = 0
+ 		curStar = oldStar
  	end
- 	if curStar ~= bonusStar[id] then
+ 	if curStar ~= oldStar then
  		bonusStar[id] = curStar
  		role:updateProperty({field = "bonusStar", value = bonusStar})
  	end
@@ -146,7 +146,9 @@ function _M.talentRpc(agent, data)
 	local talent = hero:getProperty("talent")
 	local heroCfgId = hero:getProperty("type")
 	local curStage = talent:getv(0, 1)
+	local oldStage = curStage
 	local curLevel = talent:getv(1, 1)
+	local oldLevel = curLevel
 	local curData = csvdb["unit_talent_"..heroCfgId.."Csv"][curStage]
 	if not curData then return 1 end
 	local oldSkillLv = hero:getSkillLevel(1)
@@ -174,13 +176,16 @@ function _M.talentRpc(agent, data)
 	hero:updateProperty({field = "talent", value = talent})
+
 	role:log("hero_talent", {
 		hero_id = hero:getProperty("type"), --英雄ID
-		hero_talent_id = curStage, --天赋ID
-		hero_talent_cost = cost, -- 英雄天赋升级消耗，json格式记录，{道具ID1：消耗数量1,道具ID2：消耗数量2,………...}
-		hero_talent_levelbef = oldSkillLv, -- 英雄技能升级前等级
-		hero_talent_level = hero:getSkillLevel(1), -- 英雄技能升级后等级
+		hero_talent_stagebef = oldStage, --英雄精进升级前停留阶段
+		hero_talent_stage = curStage, --英雄精进升级后停留阶段
+		hero_talent_cost = cost, --英雄精进升级消耗，json格式记录，{道具ID1：消耗数量1,道具ID2：消耗数量2,….}
+		hero_talent_subid = curData[oldLevel].effect, --升级属性ID，生命、攻击、防御、命中、闪避分别对应（0，1，2，3，4）
+		hero_talent_sublevel = curData[oldLevel].level, --升级属性等级，如生命升级从1到2，则记录2
 	})
+
 	hero:mylog({desc = "talent", int1 = talent:getv(0, 1), int2 = talent:getv(1, 1)})
 	SendPacket(actionCodes.Hero_talentRpc, '')
@@ -447,7 +452,6 @@ function _M.referEquipsRpc(agent, data)
 		end
 	end
-	local oldAttr = hero:getTotalAttrs()
 	local oldBattleV = hero:getProperty("battleV")
 	local wear = {}
@@ -477,16 +481,14 @@ function _M.referEquipsRpc(agent, data)
 	-- 更新角色
 	hero:updateProperty({field = "equip", value = curEquip})
-	local curAttr = hero:getTotalAttrs()
-	local attrChange = getChangeAttrJson(oldAttr, curAttr)
 	for typ, data in pairs(wear) do
 		role:log("equip_wear", {
 			hero_id = hero:getProperty("type"), --英雄ID
 			equip_id = data.id, --装备ID
 			equip_wear_action = data.act, --装备操作类型：装备：0，卸载：1
 			equip_wear_part = typ, --装备部位，记录部位ID
-			equip_wear_result = curAttr, --装备操作后结果，记录属性变化，json格式记录，{“aa”:1234,"bb":4567}
-			equip_wear_change = attrChange, --装备操作变化值，记录属性变化，记录正负值，json格式记录，{“aa”:1234,"bb":-45}
+			equip_wear_scorebef = oldBattleV,	--装备前英雄评分
+			equip_wear_score = hero:getProperty("battleV"), --装备后英雄评分
 			equip_wear_mode = isAuto and 0 or 1, --用以区分自动装备还是手动装备，自动记录为0，手动记录为1
 		})
 	end
@@ -712,6 +714,7 @@ end
 function _M.drawHeroRpc(agent, data)
 	local role = agent.role
 	local msg = MsgPack.unpack(data)
+	local actid = msg.actid
 	if not role:isFuncUnlock(FuncUnlock.GetHero) then return 1 end
 	local btype = msg.pool	-- 1 2 3 4 5	卡池类型  4新手卡池 5心愿卡池
@@ -721,14 +724,38 @@ function _M.drawHeroRpc(agent, data)
 		subType = 1
 		if btype == 4 and role:getProperty("newerDraw") >= 10 then
 			subType = 2
+			if(role:getProperty("newerDraw") >= 30) then
+				return 30
+			end
 		end
 	end
+	-- 另开活动卡池
+	if actid then
+		if not role.activity:isOpenById(actid, "ActHeroPool") then return end
+		local cfg = csvdb["activity_ctrlCsv"][actid]
+		if not cfg then return end
+
+		btype = cfg.condition
+	end
+
 	if btype == 1 then
 		-- 判断定向卡池活动开启
 		if not role.activity:isOpen("RaceDraw") then
 			return
 		end
+	elseif btype == 2 then
+		if role:getProperty("newerGuide") ~= "8=1" then
+			-- 判断普通卡池
+			if role.activity:isOpen("WishHeroPool") then
+				return
+			end
+		end
+	elseif btype == 5 then
+		-- 判断心愿单卡池
+		if not role.activity:isOpen("WishHeroPool") then
+			return
+		end
 	end
 	local buildTypeData = csvdb["build_typeCsv"][btype]
@@ -737,7 +764,7 @@ function _M.drawHeroRpc(agent, data)
 	local drawCount = {1, 10} -- 抽取次数
 	if not drawCount[drawType] then return 3 end
-	local draw_floor_back_counts = globalCsv.draw_floor_back_counts[btype]
+	local draw_floor_back_counts = globalCsv.draw_floor_back_counts[btype] or 10
 	local floorHeroCount = role:getProperty("floorHero")[btype] or 0
 	-- 计算抽卡消耗品
@@ -945,16 +972,21 @@ function _M.drawHeroRpc(agent, data)
 		gacha_up = 0, -- 卡池UP角色
 		gacha_times = drawCount[drawType], -- 抽卡次数
 		gacha_reward = logReward, -- 抽卡结果，建议使用json格式记录。示例：{ "XX": "1", "XXX": "3"}
-		currency = cost, -- 购买道具消耗的货币
+		gacha_cost = cost, -- 购买道具消耗的货币
 		gacha_cnt = floorHeroCount,
 	})
 	SendPacket(actionCodes.Hero_drawHeroRpc, MsgPack.pack({reward = reward})) -- 这个 reward 是数组
-	if btype == 1 or btype == 2 then
+	local feedbackId = buildTypeData["can_feedback"] or 0
+	if feedbackId ~= 0 then
 		-- 达到一定次数，给响应奖励
 		local oldVal = role:getProperty("repayHero") or 0
+		if actid then
+			local actData = role.activity:getActData("ActHeroPool")
+			oldVal = actData[btype] or 0
+		end
 		local newVal = oldVal + drawCount[drawType]
-		local drawCardReward, val = role:getDrawCardExtraReward(oldVal, newVal)
+		local drawCardReward, val = role:getDrawCardExtraReward(feedbackId, oldVal, newVal)
 		-- 空字符穿代表直接给英雄  走以前repayHeroRpc
 		if drawCardReward == "" then
 			local repayHeroMaxCount = role:getProperty("repayMaxC") or 0
@@ -964,11 +996,11 @@ function _M.drawHeroRpc(agent, data)
 			local even = repayHeroMaxCount % 2
 			local id = 0
 			if even == 1 then
-				id = math.randWeight(csvdb["build_giftCsv"], "pool_1")
+				id = math.randWeight(csvdb["build_giftCsv"], "pool_"..feedbackId)
 			else
 				local giftHeroSet = {}
 				for gid, cfg in pairs(csvdb["build_giftCsv"]) do
-					if cfg["pool_1"] ~= 0 and not role:isHaveHero(gid - ItemStartId.Hero) then
+					if cfg["pool_"..feedbackId] ~= 0 and not role:isHaveHero(gid - ItemStartId.Hero) then
 						giftHeroSet[gid] = {1}
 					end
 				end
@@ -977,7 +1009,7 @@ function _M.drawHeroRpc(agent, data)
 				end
 			end
 			if id == 0 then
-				id = math.randWeight(csvdb["build_giftCsv"], "pool_1")
+				id = math.randWeight(csvdb["build_giftCsv"], "pool_"..feedbackId)
 			end
 			local r,change = {}
@@ -997,7 +1029,13 @@ function _M.drawHeroRpc(agent, data)
 			r, change = role:award(drawCardReward, {log = {desc = "drawHeroExtraReward", int1 = oldVal, int2 = newVal}})
 			SendPacket(actionCodes.Hero_drawHeroExtraRewardNtf, MsgPack.pack(role:packReward(r, change)))
 		end
-		role:updateProperty({field = "repayHero", value = val})
+		if not actid then
+			role:updateProperty({field = "repayHero", value = val})
+		else
+			local actData = role.activity:getActData("ActHeroPool")
+			actData[btype] = val
+			role.activity:updateActData("ActHeroPool", actData)
+		end
 	end
 	return true
 end
@@ -135,7 +135,7 @@ local function getMatchInfo(role, pvpList, battleCache, dbKey, infoFuncName, inf
 				if k == "battleInfo" then
 					battleCache[curInfo.roleId] = v
 				else
-					if (k == "heros" or k == "battleV") and infoCache then
+					if (k == "team" or k == "battleV") and infoCache then
 						infoCache[curInfo.roleId] = infoCache[curInfo.roleId] or {}
 						infoCache[curInfo.roleId][k] = v
 					end
@@ -705,12 +705,12 @@ function _M.endBattleHRpc(agent, data)
 		info.winId = info.isWin and roleId or match.id
 		info.isWin = nil
 		selfTeam[_idx] = {
-			heros = role:getTeamHerosInfo(_pvpStartBattleCacheH.pvpTH[_idx].heros),
+			team = role:getTeamHerosInfo(_pvpStartBattleCacheH.pvpTH[_idx]),
 			battleV = role:getTeamBattleValue(_pvpStartBattleCacheH.pvpTH[_idx].heros)
 		}
 		if match.t == 1 and _pvpStartBattleCacheH.enemyT then
 			enemyTeam[_idx] = {
-				heros = _pvpStartBattleCacheH.enemyT["heros"][_idx],
+				team = _pvpStartBattleCacheH.enemyT["team"][_idx],
 				battleV = _pvpStartBattleCacheH.enemyT["battleV"][_idx]
 			}
 		end
@@ -158,7 +158,27 @@ function _M.finishQuestRpc(agent, data)
     msg["big"] = bigSuccess
     msg["id"] = id
     msg["heroFaith"] = heroFaithMap
-	SendPacket(actionCodes.Radio_finishQuestRpc, MsgPack.pack(msg))
+    SendPacket(actionCodes.Radio_finishQuestRpc, MsgPack.pack(msg))
+    
+
+    local herolist = {}
+    for _, heroId in ipairs(task.heros) do
+        local hero = role.heros[heroId]
+        if hero then
+            table.insert(herolist, hero:getProperty("type"))
+        end
+    end
+
+	--  讨伐行动 
+	role:log("punitive_action", {
+		mission_id	= id, --关卡ID
+		mission_herolist = herolist, -- 英雄ID，排序以玩家出战设置为准，示例：[111, 222, 333, 444, 555]
+		mission_success_rate = totalCoef, -- 大成功几率
+		mission_reward = r, -- 获得奖励，建议使用json格式记录。示例：{ itemid1: 1,  itemid2: 3,  itemid3: 5}
+		mission_result = 1, -- 战斗结果(0-无效，1-胜利，2-失败)
+		mission_roundtime = config.time, -- 完成耗时（秒）
+	})
+
 	return true
 end
@@ -300,6 +300,7 @@ function _M.loginRpc( agent, data )
 	if msg.newdevice then
 		role:mylog("newdevice", {key1 = agent.ip:toArray(false, ":")[1]})
 	end
+
 	return true
 end
@@ -372,6 +373,34 @@ function _M.createRpc(agent, data)
 	end
 	SendPacket(actionCodes.Role_createRpc, MsgPack.pack(response))
+
+	-- cb付费返利
+	skynet.timeout(0, function()
+		local cbbackd = cluster.query("center", "cbbackd")
+		local uid = newRole:getProperty("uid")
+		local start = uid:find("_")
+		if start then
+			uid = uid:sub(start + 1)
+		end
+		if cbbackd then
+			local status, back = pcall(cluster.call, "center", cbbackd, "getCbBack", {uid = uid, id = roleId})
+			if status then
+				if back and next(back) then
+					local reward = ""
+					for itemId, count in pairs(back) do
+						reward = reward:setv(itemId, count)
+					end
+					redisproxy:insertEmail({roleId = roleId, emailId = MailId.CBBackAward, createtime = skynet.timex(), attachments = reward})
+					newRole:mylog("cbback", {key1 = uid, int2 = roleId})
+				end
+			else
+				skynet.error("[ERROR] cbbackd cant call center uid: " .. uid .. " roleId:" .. roleId)
+			end
+		else
+			skynet.error("[ERROR] cbbackd cant call center uid: " .. uid .. " roleId:" .. roleId)
+		end
+	end)
+	
 	return true
 end
@@ -537,82 +566,131 @@ function _M.openTimeBoxRpc(agent, data)
 	local slot = msg.slot  -- 位置 1 - 6
 	-- 特权卡时间箱额外栏位
-	local privExtraCnt = role.storeData:getTimeBoxSlotExtraCount()
-	if oper == 1 then
-		if math.illegalNum(slot, 1, role:getFuncLv(FuncOpenType.TimeBoxSlot) + privExtraCnt) then return end
-	end
+	-- local privExtraCnt = role.storeData:getTimeBoxSlotExtraCount()
+	-- if oper == 1 then
+	-- 	if math.illegalNum(slot, 1, role:getFuncLv(FuncOpenType.TimeBoxSlot) + privExtraCnt) then return end
+	-- end
 	local boxL = role:getProperty("boxL")
-	local reward, change = {}
-	if oper == 1 then	-- 打开
+	local reward, change
+	if oper == 1 then -- 构建开始(包括切换构建的id)
 		local itemId = msg.itemId
-		if role:getItemCount(itemId) < 1 then return end
 		local itemData = csvdb["itemCsv"][itemId]
-		local randomData = csvdb["item_randomCsv"][itemId]
-		if not itemData or not randomData or randomData.openTime <= 0 then return end
-
-		if boxL[slot] then return end
-		role:costItems({[itemId] = 1}, {log = {desc = "openTimeBox"}})
-		boxL[slot] = {id = itemId, time = skynet.timex() + randomData.openTime}
-		role:pushMsg({type = "box", slot = slot, time = randomData.openTime})
-	elseif oper == 2 then -- 领取
+		if not itemData then return 1 end
+		if not boxL[slot] then
+			boxL[slot] = {}
+		else
+			local oldId, process, time = boxL[slot].id, boxL[slot].process, boxL[slot].time
+			local unitTime = globalCsv.box_key_time[oldId] * 60
+			local doneCnt = math.floor((process + skynet.timex() - time) / unitTime)
+			if doneCnt > 0 then
+				reward = role:award({[oldId] = doneCnt}, {log = {desc = "openTimeBox", int1 = slot}})
+			end
+		end
+		local limit = globalCsv.box_key_max[itemId] or 5
+		if role:getItemCount(itemId) >= limit then return 3 end
+
+		boxL[slot] = {id = itemId, process = 0, time = skynet.timex()}
+		role:pushMsg({type = "box", slot = slot, time = skynet.timex() + globalCsv.box_productLine_time * 3600})
+	elseif oper == 2 then -- 重置运行时间（可以使用加速）
 		local quick = msg.quick
-		if not boxL[slot] then return end
-		local costKey = 0
-		if boxL[slot].time > skynet.timex() then -- 没开完
-			if not quick then return end
+		if not boxL[slot] then return 4 end
+
+		local itemId, process, time = boxL[slot].id, boxL[slot].process, boxL[slot].time
+		local nowTime = skynet.timex()
+		local stopTime = nowTime
+		local itemData = csvdb["itemCsv"][itemId]
+		local unitTime = globalCsv.box_key_time[itemId] * 60
+		if quick then
+			stopTime = time + globalCsv.box_productLine_time * 3600
 			local cost_pre = globalCsv.box_timeOpen_diamond:toArray(true, "=")
-			costKey = math.ceil((boxL[slot].time - skynet.timex()) / (cost_pre[1] * 60)) * cost_pre[2]
-			if not role:checkItemEnough({[ItemId.BoxKey] = costKey}) then return end
-			role:costItems({[ItemId.BoxKey] = costKey}, {log = {desc = "openTimeBox"}})
-			role:pushCancel({type = "box", slot = slot})
+			local costKey = math.ceil((stopTime - nowTime) / (cost_pre[1] * 60)) * cost_pre[2]
+			if not role:checkItemEnough({[ItemId.Diamond] = costKey}) then return 5 end
+			role:costItems({[ItemId.Diamond] = costKey}, {log = {desc = "openTimeBox", int1 = slot}})
+		else
+			stopTime = math.min(nowTime,time + globalCsv.box_productLine_time * 3600)
+		end
+		role:pushCancel({type = "box", slot = slot})
+
+		local doneCnt = math.floor((process + stopTime - time) / unitTime)
+		if doneCnt > 0 then
+			reward = role:award({[itemId] = doneCnt}, {log = {desc = "openTimeBox", int1 = slot}})
+		end
+		if role:getItemCount(itemId) >= globalCsv.box_key_max[itemId] then
+			nowTime = 0
+		end
+
+		boxL[slot] = {id = itemId, process = (process + stopTime - time) % unitTime, time = nowTime}
+		role:pushMsg({type = "box", slot = slot, time = nowTime + globalCsv.box_productLine_time * 3600})
+	elseif oper == 3 then -- 开箱子
+		local costId = msg.costId
+		local costs = (msg.costs or ""):toNumMap()
+		if not costId or not csvdb["itemCsv"][costId] or not next(costs) then return 6 end
+		
+		local costIdData = csvdb["itemCsv"][costId]
+		local count = 0
+		for itemId, num in pairs(costs) do
+			local itemIdData = csvdb["itemCsv"][itemId]
+			if not itemIdData or not csvdb["item_randomCsv"][itemId] or costIdData.quality ~= itemIdData.quality then return 7 end
+			count = count + num
 		end
-		local boxId = boxL[slot].id
-		local itemData = csvdb["itemCsv"][boxId]
-		local randomData = csvdb["item_randomCsv"][itemData.id]
-		local costTime = skynet.timex() - (boxL[slot].time - randomData.openTime)
-		-- 随机奖励
+
+		if role:getItemCount(costId) < count then return 8 end
+
+		role:costItems({[costId] = count}, {log = {desc = "openTimeBox"}})
+
 		reward = {}
-		for i = 1, 10 do
-			local num = randomData["num" .. i] 
-			local gift = randomData["gift" .. i]
-			if num and gift and num > 0 and gift ~= "" then
-				local pool = {}
-				for _, temp in ipairs(gift:toArray()) do
-					local set = temp:toArray(true, "=")
-					table.insert(pool, set)
+		for itemId, value in pairs(costs) do
+			local tempReward = {}
+			local randomData = csvdb["item_randomCsv"][itemId]
+			local itemData = csvdb["itemCsv"][itemId]
+			role:costItems({[itemId] = value}, {log = {desc = "openTimeBox"}})
+			for _ = 1, value do
+				for i = 1, 10 do
+					local num = randomData["num" .. i] 
+					local gift = randomData["gift" .. i]
+					if num and gift and num > 0 and gift ~= "" then
+						local pool = {}
+						for _, temp in ipairs(gift:toArray()) do
+							local set = temp:toArray(true, "=")
+							table.insert(pool, set)
+						end
+
+						local needCount = math.min(#pool, num)
+						for j = 1, needCount do
+							local idx = math.randWeight(pool, 3)
+							tempReward[pool[idx][1]] = (tempReward[pool[idx][1]] or 0) + pool[idx][2]
+							table.remove(pool, idx)
+						end
+					end
 				end
+			end
+			tempReward[0] = nil
+			role:checkTaskEnter("OpenBox", {id = itemId, count=value, quality=itemData.quality})
+			role:log("carriage_dismantle", {
+				item_id = itemId, -- 道具id
+				item_type = itemData.type, -- 道具类型，具体见枚举表中道具类型枚举表
+				item_level = 0, -- 道具等级
+				item_number = 1, -- 道具变化数量的绝对值
+				carriage_dismantle_type = 1, -- 拆解方式，时间到期:0，钥匙开启:1
+				carriage_dismantle_time = 0, -- 拆解耗时，填写实际耗时
+				carriage_dismantle_cost = value, -- 拆解花费钥匙数量，未使用填写0
+				carriage_dismantle_rwd = tempReward, -- 拆解获得物资，json格式记录，{'itemid1':2,'itemid2':3,…………..}
+			})
-				local needCount = math.min(#pool, num)
-				for j = 1, needCount do
-					local idx = math.randWeight(pool, 3)
-					reward[pool[idx][1]] = (reward[pool[idx][1]] or 0) + pool[idx][2]
-					table.remove(pool, idx)
-				end
+			for id, num in pairs(tempReward) do
+				reward[id] = (reward[id] or 0) + num
 			end
 		end
-		reward[0] = nil
-
-		boxL[slot] = nil
-		reward, change = role:award(reward, {log = {desc = "openTimeBox", int1 = boxId}})
-		role:checkTaskEnter("OpenBox", {id = boxId, count=1, quality=itemData.quality})
-
-		role:log("carriage_dismantle", {
-			item_id = boxId, -- 道具id
-			item_type = itemData.type, -- 道具类型，具体见枚举表中道具类型枚举表
-			item_level = 0, -- 道具等级
-			item_number = 1, -- 道具变化数量的绝对值
-			carriage_dismantle_type = quick and 1 or 0, -- 拆解方式，时间到期:0，钥匙开启:1
-			carriage_dismantle_time = costTime, -- 拆解耗时，填写实际耗时
-			carriage_dismantle_cost = costKey, -- 拆解花费钥匙数量，未使用填写0
-			carriage_dismantle_rwd = reward, -- 拆解获得物资，json格式记录，{'itemid1':2,'itemid2':3,…………..}
-		})
+		reward, change = role:award(reward, {log = {desc = "openTimeBox", int1 = costId}})
 	else
 		return
 	end
-	role:setProperty("boxL") --刷新
-	role:changeUpdates({{type = "boxL", field = slot, value = boxL[slot], isOnlyToC = true}}) -- 通知客户端
+	role:setProperty("boxL",boxL) --刷新
+	if slot then
+		role:changeUpdates({{type = "boxL", field = slot, value = boxL[slot], isOnlyToC = true}}) -- 通知客户端
+	end
 	SendPacket(actionCodes.Role_openTimeBoxRpc, MsgPack.pack(role:packReward(reward, change)))
 	return true
 end
@@ -724,11 +802,12 @@ function _M.unLockStoryBookRpc(agent, data)
 	local storyStatus = role:getProperty("storyB")
 	if storyStatus[storyId] and storyStatus[storyId].s then return end  --不需要解锁
-	local cost = storyBookData.lockItem:toNumMap()
-	if not cost or not next(cost) then return end
-	if not role:checkItemEnough(cost) then return end  -- 消耗品不足
-
-	role:costItems(cost, {log = {desc = "unlockStory", int1 = storyId}})
+	if storyBookData.lockItem ~= "free" then
+		local cost = storyBookData.lockItem:toNumMap()
+		if not cost or not next(cost) then return end
+		if not role:checkItemEnough(cost) then return end  -- 消耗品不足
+		role:costItems(cost, {log = {desc = "unlockStory", int1 = storyId}})
+	end
 	-- 解锁
 	storyStatus[storyId] = storyStatus[storyId] or {}
@@ -807,6 +886,12 @@ function _M.taskActiveRpc(agent, data)
 		{ type = roleField[taskType], field = {"at", taskId}, value = -1 }
 	})
+	role:log("task_reward", {
+		task_reward_id = taskId * 100 + taskType, --任务奖励ID
+		task_reward_type = 3, --任务奖励类型，见 任务奖励类型枚举表
+		task_reward_detail = reward, --任务奖励，json格式记录,{'itemid1':123,'itemid2':456,………...}
+	})
+
 	SendPacket(actionCodes.Role_taskActiveRpc, MsgPack.pack(role:packReward(reward, change)))
 	return true
 end
@@ -14,6 +14,9 @@ function _M.rechargeRpc(agent , data)
 	--创建订单号
 	local partnerOrderId = role:getPurchaseOrder(id)
+	if partnerOrderId == "" then
+		return 1
+	end
 	SendPacket(actionCodes.Store_rechargeRpc, MsgPack.pack({ order = partnerOrderId }))
 	-- 测试的 直接发奖励了
@@ -149,25 +149,15 @@ function Adv:initByChapter(params)
 	self.maps = {}
 	self.maps[1] = AdvMap.new(self, 1, mapId, isEnter, isNewRelay)
-	self:initBattle(nil)
+	self:initBattle(nil, isToNext)
 	self:initLayerTask()
-	-- 支援效果生效一些
-	self:activeSomeSupport()
+
 	self:checkTask(Adv.TaskType.Arrive)
 	self:checkAdvUnlock(1, self.level)
-	if isToNext then
-		self.battle.player:afterLayer() -- 玩家的buff 清理一下
-	end
-
-	-- 不是中继层  加上 层 和 地图的buff和被动
-	if not self.isRelay then
-		self.battle:initMapEffect()
-	end
-
 	-- 中继进入奖励
 	if relayData and isEnter then
 		self:awardRelay(relayData, notNotify)
@@ -456,8 +446,20 @@ function Adv:clearAdvUnlockCache()
 	self.cacheUnlock = {}
 end
-function Adv:initBattle(info)
+function Adv:initBattle(info, isToNext)
 	self.battle = require("adv.AdvBattle").new(self)
+	-- 支援效果生效一些
+	self:activeSomeSupport()
+	
+	-- 不是中继层  加上 层 和 地图的buff和被动
+	if not self.isRelay then
+		self.battle:initMapEffect()
+	end
+
+	if isToNext then
+		self.battle.player:afterLayer() -- 玩家的buff 清理一下
+	end
+
 	for _, passiveC in ipairs(self.cachePassiveEvent or {}) do
 		self.battle:triggerPassive(passiveC[1], passiveC[2])
 	end
@@ -468,7 +470,7 @@ function Adv:initBattle(info)
 		map:initBattleAfter()
 	end
 	--下层
-	if not info and self.level ~= 1 then
+	if not info and isToNext then
 		self.battle.player:attrChangeCondBuffCheck(1)
 	end
@@ -820,7 +822,7 @@ function Adv:over(success, rewardRatio, overType)
 				lv = self.owner:getProperty("level"),
 				batteV = self.owner:getTeamBattleValue(team.heros),
 				chapter = self.chapterId,
-				format = self.owner:getTeamHerosInfo(team.heros),
+				format = self.owner:getTeamHerosInfo(team).heros,
 			}
 			redisproxy:pipelining(function (red)
 				red:zadd(self.owner:getAdvRankKey(), score, roleId)	--更新分数
@@ -1094,10 +1096,10 @@ local function clickOut(self, room, block, params, isExit)
 		end
 		if #self.mapStack > 1 then -- 处于夹层中
+			self:backLayer(-1)
 			local oldMapIdx = self:getCurMapIdx()
 			table.remove(self.mapStack) --退出夹层
 			self.battle:iLayerChange(oldMapIdx)
-			self:backLayer(-1)
 		else --处于底层
 			local advPass = self.owner:getProperty("advPass")
@@ -1129,8 +1131,8 @@ local function clickOut(self, room, block, params, isExit)
 				if curFloorData then
 					self:award({[ItemId.AdvPoint] = curFloorData.exp}, {log = {desc = "passReward", int1 = self.chapterId, int2 = self.level}}, {})
 				end
+				self:backNext() --下一关
 				local isHaveRelay = self:isHaveRelay(self.level)
-
 				if isHaveRelay and not self.isRelay then 
 					self:initByChapter({
 						chapterId = self.chapterId, 
@@ -1148,7 +1150,6 @@ local function clickOut(self, room, block, params, isExit)
 						notNotify = true,
 					})
 				end
-				self:backNext() --下一关
 			end
 		end
@@ -1554,6 +1555,7 @@ local function clickBuild(self, room, block, params)
 		end
 		advMine[2].co = mineCo2
 		self.owner:setProperty("advMine", advMine)
+		self.owner:checkTaskEnter("AdvMineLayer")
 	end
 	self:checkTask(Adv.TaskType.Build, 1, oldId)
@@ -1604,6 +1606,7 @@ end
 local function clickLayer(self, room, block, params)
 	local oldMapIdx = self:getCurMapIdx()
+	self:backLayer(1)
 	if block.event.mapIdx then
 		table.insert(self.mapStack, block.event.mapIdx) --进入夹层
 	else
@@ -1620,7 +1623,6 @@ local function clickLayer(self, room, block, params)
 		self:checkAchievement(Adv.AchievType.EnterILayer, 1, mapId)
 	end
 	self.battle:iLayerChange(oldMapIdx)
-	self:backLayer(1)
 	return true
 end
@@ -2051,6 +2053,7 @@ function Adv:enemyDead(enemy, escape)
 				advMine[2].co = mineCo2
 				advMine[2].ch = mineCh
 				self.owner:setProperty("advMine", advMine)
+				self.owner:checkTaskEnter("AdvMineKill")
 			else
 				local toClick = enemy:hadBuff(Buff.CHANGE_DROP_TO_CLICK)
 				if toClick then
@@ -35,7 +35,7 @@ Buff.Buff_NO_PASSIVE_MONSTER = 31 -- 地图被动刷新不出来怪物
 Buff.SNEAK = 32 --潜行
 Buff.DROP_BUFF_BY_ENEMY = 33 -- 怪物掉落加成  -- 怪物使用
 Buff.GET_PASSIVE = 34 -- 获得 passive -- 结束失效
-Buff.OBSTACLE_CHANGE = 35 -- 看守类型改变  -- 怪物使用  0 - 1
+Buff.OBSTACLE_CHANGE = 35 -- 看守类型改变  -- 怪物使用  2 - 1
 Buff.DISABLE_AURA = 36 -- 禁用光环
 Buff.GET_AURA = 37 -- 获得光环
@@ -9,6 +9,7 @@ Filter.BUFF_BY_ID = 6 -- 指定id的buff
 Filter.CAMP = 7 -- 玩家是指定阵营
 Filter.RANGE = 8 -- 筛选范围 （触发是地块）
 Filter.CLASSIFY = 9 -- 标签
+Filter.NO_BUFF_BY_ID = 10 -- 没有指定id的buff
 local FilterFactory = {}
 FilterFactory[Filter.HP_UP_WITH_EQUAL] = function (_Filter)
@@ -47,7 +48,6 @@ FilterFactory[Filter.CAMP] = function (_Filter)
 		return role:getHerosCamp(role:getProperty("advTeam").heros) == self.value
 	end
 end
-
 FilterFactory[Filter.RANGE] = function (_Filter)
 	_Filter._execute = function (self, target, params)
 		if params and self.owner.blockId and self.owner.roomId  and params.blockId and params.roomId then
@@ -57,13 +57,18 @@ FilterFactory[Filter.RANGE] = function (_Filter)
 		return false
 	end
 end
-
 FilterFactory[Filter.CLASSIFY] = function (_Filter)
 	_Filter._execute = function (self, target)
 		return target.isClassify and target:isClassify(self.value)
 	end
 end
+FilterFactory[Filter.NO_BUFF_BY_ID] = function (_Filter)
+	_Filter._execute = function (self, target)
+		return not target:hadBuffById(self.value)
+	end
+end
+
 function Filter:ctor(params)
 	self.owner = params.owner
 	self.skill = params.skill
@@ -87,6 +92,9 @@ function Filter:getTarget(params)
 	if self.oType == 2 and params.releaser then
 		target = params.releaser
 	end
+	if self.oType == 3 then
+		target = self.owner.battle.player
+	end
 	return target
 end
@@ -662,7 +662,7 @@ end
 function Enemy:getObstacle()
 	local obstacle = csvdb["event_monsterCsv"][self.monsterId].obstacle
-	if obstacle == 0 and self:hadBuff(Buff.OBSTACLE_CHANGE) then
+	if obstacle == 2 and self:hadBuff(Buff.OBSTACLE_CHANGE) then
 		obstacle = 1
 	end
 	return obstacle
@@ -15,6 +15,7 @@ redisproxy = require &quot;shared.redisproxy&quot;
 datacenter = require "skynet.datacenter"
 mcast_util = require "services/mcast_util"
 csvdb = require "shared.csvdata"
+cluster = require "skynet.cluster"
 local CMD = {}
 local agentInfo = {}  -- { client_fd, role, gate_serv, open_timer}
@@ -23,7 +23,7 @@ skynet.start(function()
 	--启动log
 	if use_logd == 1 then
-		for i = 1, work_count do
+		for i = 1, work_count * 2 do
 			local logd = skynet.newservice("services/logd", i)
 			skynet.call(logd, "lua", "open")
 		end
@@ -24,8 +24,13 @@ Activity.ActivityType = {
 	Exchange = 18,	-- 兑换活动
 	HangDrop = 19,	-- 挂机掉落活动
 	Gachakon = 20,	-- 扭蛋活动
-}
+	WishHeroPool = 23, 	-- 心愿卡池
+	ActHeroPool = 24, -- 活动卡池
+	ActShopGoods = 25, 	-- 活动商品
+
+	Crisis = 26, -- 宝藏怪活动
+}
 local function checkActivityType(activityType)
 	if type(activityType) == "string" then
@@ -41,6 +46,13 @@ function Activity:ctor(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 = {
 	actime 		= {"table", {}},  -- 最近检查某项活动的开始时间  {id = time}
@@ -58,6 +70,9 @@ Activity.schema = {
 	act18		= {"table", {}, true},	  -- {id=兑换数量}
 	act19		= {"number", 0},	  -- {挂机信息}
 	act20		= {"table", {}},	  -- {id=扭蛋抽出数量}
+
+	act24		= {"table", {}, true},	-- 活动卡池 {id=repaynum}
+	act26 		= {"table", {}},	-- {task = {id = count}, socre = {id = status}}
 }
 function Activity:data()
@@ -76,6 +91,7 @@ function Activity:data()
 		act18 = self:getProperty("act18"),
 		act19 = self:getProperty("act19"),
 		act20 = self:getProperty("act20"),
+		act26 = self:getProperty("act26"),
 	}
 end
@@ -153,7 +169,12 @@ function Activity:isOpen(activityType)
 	return false
 end
-function Activity:isOpenById(id)
+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
@@ -473,6 +494,19 @@ activityFunc[Activity.ActivityType.Gachakon] = {
 	end,
 }
+-- 活动卡池
+activityFunc[Activity.ActivityType.ActHeroPool] = {
+	["init"] = function(self, actType, isCrossDay, notify, actId)
+	end,
+	["close"] = function(self, actType, notify, actId)
+		local actData = self:getActData(actType)
+		local cfg = csvdb["activity_ctrlCsv"][actId]
+		if not cfg then return end
+		actData[cfg.condition] = nil
+		self:updateActData(actType, actData, not notify)
+	end,
+}
+
 -- 挂机掉落
 activityFunc[Activity.ActivityType.HangDrop] = {
 	["init"] = function(self, actType, isCrossDay, notify, actId)
@@ -524,7 +558,9 @@ function Activity:closeActivity(actId, notify, notUpdateAct)
 		self:recycleActItem(actId)
 	end
 	if Activity.schema["act".. actType] then
-		self:updateActData(actType, Activity.schema["act" .. actType][2], not notify or notUpdateAct)
+		if not Activity.schema["act" .. actType][3] then 
+			self:updateActData(actType, Activity.schema["act" .. actType][2], not notify or notUpdateAct)
+		end
 	end
 end
@@ -689,5 +725,59 @@ function Activity:getBattleTicket(actId)
 	end
 end
+activityFunc[Activity.ActivityType.ActShopGoods] = {
+	["init"] = function(self, actType, isCrossDay, notify, actId)
+	end,
+	["close"] = function(self, actType, notify)
+		local rechargeRecord = self.owner.storeData:getProperty("payR")
+		for id, cfg in pairs(csvdb["shop_rechargeCsv"]) do
+			if cfg.shop == 3 and cfg.type == ShopPackType.ActShopPack then
+				rechargeRecord[id] = nil
+			end
+		end
+		self.owner.storeData:updateProperty({field="payR", value=rechargeRecord})
+	end,
+}
+
+
+
+activityFunc[Activity.ActivityType.Crisis] = {
+	["check"] = function(self, actType, notify, atype, count) -- 检查
+		count = count or 1
+		local isOpen, actId = self:isOpen(actType)
+		local actData = self:getActData(actType) or {}
+		actData.task = actData.task or {}
+		local change = false
+		local actCsv = csvdb["activity_crisisCsv"][actId]
+		for id, actSet in pairs(actCsv) do
+			if actSet.type == atype then
+				local status = actData.task[id] or 0
+				status = status + count
+				if status >= actSet.condition1 then
+					local reward
+					if actSet.loop == 1 then
+						local rcount = math.floor(status / actSet.condition1)
+						local reward = actSet.reward:toNumMap()
+						for itemId, itemC in pairs(reward) do
+							reward[itemId] = itemC * rcount
+						end
+						status = status % actSet.condition1
+					else
+						reward = actSet.reward
+						status = -1
+					end
+					self.owner:award(reward, {log = {desc = "activity_crisis"}, notNotify = not notify})
+				end
+				actData.task[id] = status
+				change = true
+			end
+		end
+		if change then
+			-- 更新下排行榜
+			self.owner:updateRankCommon(RANK_TYPE.ActCrisis, self.owner:getItemCount(ItemId.CrisisScore))
+			self:updateActData(actType, actData)
+		end
+	end,
+}
 return Activity
@@ -44,7 +44,7 @@ function Role:checkBattle(battleType, params)
 	local fixData = {
 		hang = function()
-			for slot, hero in pairs(self:getProperty("hangTS")) do
+			for slot, hero in pairs(self:getProperty("hangTS").heros) do
 				selflist[slot] = hero.type
 			end
 			heroscore = self:getProperty("hangTBV")
@@ -59,7 +59,7 @@ function Role:checkBattle(battleType, params)
 		end,
 		tower = function()
 			local towerF = self:getTeamFormatByType(TeamSystemType.Tower)
-			for slot, hero in pairs(self:getTeamHerosInfo(towerF.heros)) do
+			for slot, hero in pairs(self:getTeamHerosInfo(towerF).heros) do
 				selflist[slot] = hero.type
 			end
 			heroscore = self:getTeamBattleValue(towerF.heros)
@@ -74,7 +74,7 @@ function Role:checkBattle(battleType, params)
 		end,
 		bonus = function()
 			local bTeam = self:getTeamFormatByType(TeamSystemType.BonusBattle)
-			for slot, hero in pairs(self:getTeamHerosInfo(bTeam.heros)) do
+			for slot, hero in pairs(self:getTeamHerosInfo(bTeam).heros) do
 				selflist[slot] = hero.type
 			end
 			heroscore = self:getTeamBattleValue(bTeam.heros)
@@ -88,7 +88,7 @@ function Role:checkBattle(battleType, params)
 			end
 		end,
 		act_battle = function()
-			for slot, hero in pairs(self:getTeamHerosInfo(params.heros)) do
+			for slot, hero in pairs(self:getTeamHerosInfo(params).heros) do
 				selflist[slot] = hero.type
 			end
 			heroscore = self:getTeamBattleValue(params.heros)
@@ -102,7 +102,7 @@ function Role:checkBattle(battleType, params)
 			end
 		end,
 		pvpc = function()
-			for slot, hero in pairs(self:getProperty("pvpTSC")) do
+			for slot, hero in pairs(self:getProperty("pvpTSC").heros) do
 				selflist[slot] = hero.type
 			end
 			heroscore = self:getProperty("pvpTBVC")
@@ -124,7 +124,7 @@ function Role:checkBattle(battleType, params)
 		pvph = function()
 			for idx, team in pairs(self:getProperty("pvpTSH")) do
 				selflist[idx] = selflist[idx] or {}
-				for slot, hero in pairs(team) do
+				for slot, hero in pairs(team.heros) do
 					selflist[idx][slot] = hero.type
 				end
 			end
@@ -19,8 +19,8 @@ RoleCross.bind = function (Role)
 	-- 好友详细队伍信息
 	function Role:friendInfo()
 		local info = self:friendSInfo()
-		local heros = self:getProperty("pvpTBVC") ~= 0 and self:getProperty("pvpTSC") or self:getProperty("hangTS")
-		info.heros = heros
+		local team = self:getProperty("pvpTBVC") ~= 0 and self:getProperty("pvpTSC") or self:getProperty("hangTS")
+		info.team = team
 		return info
 	end
@@ -36,7 +36,7 @@ RoleCross.bind = function (Role)
 			level = self:getProperty("level"),
 			headId = self:getProperty("headId"),
 			battleV = self:getProperty("pvpTBVC"),
-			heros = self:getProperty("pvpTSC"),
+			team = self:getProperty("pvpTSC"),
 			battleInfo = self:getProperty("pvpTBC")
 		}
 		return info
@@ -49,7 +49,7 @@ RoleCross.bind = function (Role)
 			level = self:getProperty("level"),
 			headId = self:getProperty("headId"),
 			battleV = self:getProperty("pvpTBVH"),
-			heros = self:getProperty("pvpTSH"),
+			team = self:getProperty("pvpTSH"),
 			battleInfo = self:getProperty("pvpTBH")
 		}
 		return info
@@ -281,7 +281,7 @@ function CMD.friendInfo(roleId)
 		headId = info.headId,
 		ltime = info.ltime,
 		battleV = info.pvpTBVC ~= 0 and info.pvpTBVC or info.hangTBV,
-		heros =  info.pvpTBVC ~= 0 and info.pvpTSC or info.hangTS
+		team =  info.pvpTBVC ~= 0 and info.pvpTSC or info.hangTS
 	}
 end
@@ -297,7 +297,7 @@ function CMD.pvpCInfo(roleId)
 		level = info.level,
 		headId = info.headId,
 		battleV = info.pvpTBVC,
-		heros = info.pvpTSC,
+		team = info.pvpTSC,
 		battleInfo = info.pvpTBC
 	}
 end
@@ -309,7 +309,7 @@ function CMD.pvpHInfo(roleId)
 		level = info.level,
 		headId = info.headId,
 		battleV = info.pvpTBVH,
-		heros = info.pvpTSH,
+		team = info.pvpTSH,
 		battleInfo = info.pvpTBH
 	}
 end
@@ -50,6 +50,7 @@ local ItemReason = {
 	actHangDrop = 134, -- 掉落活动奖励
 	actBattle = 135, -- 活动关卡
 	actMilestone = 136,	-- 活动关卡boss伤害里程碑
+	worldBossReward = 137,	-- 世界boss翻牌奖励
 	advHang = 301, -- 拾荒挂机
@@ -90,6 +91,7 @@ local ItemReason = {
 	actSign = 1007, -- 活动签到
 	actPaySign = 1008, -- 活动付费签到
 	calendaTask = 1009,	-- 英雄帖
+	actMilecrisis = 1010, -- 物资危机
 	-- 餐厅
 	greenHourse = 1101, -- 食材获得
@@ -252,13 +254,6 @@ local MethodType = {
 		hero_break_result = "json", -- 英雄突破效果，可记录效果ID，或json格式记录提升效果，{攻击：20,闪避：20,……..}
 		hero_break_level = true, -- 英雄突破后等级上限
 	},
-	hero_talent = { --英雄天赋升级 
-		hero_id = true, -- 英雄ID
-		hero_talent_cost = "json", -- 英雄天赋升级消耗，json格式记录，{道具ID1：消耗数量1,道具ID2：消耗数量2,………...}
-		hero_talent_levelbef = true, -- 英雄技能升级前等级
-		hero_talent_level = true, -- 英雄技能升级后等级
-		hero_talent_id = true, -- 天赋id
-	},
 	hero_jewel = { --英雄铭文
 		hero_id = true, -- 英雄ID
 		hero_jewel_sequence = "ucode", -- 铭文装备编号，用以关联一次装备时产生的多条日志
@@ -288,7 +283,7 @@ local MethodType = {
 		gacha_up = true, -- 卡池UP角色
 		gacha_times = true, -- 抽卡次数
 		gacha_reward = "json", -- 抽卡结果，建议使用json格式记录。示例：{ "XX": "1", "XXX": "3"}
-		currency = "json", -- 消耗，json格式记录，{道具ID1：消耗数量1,道具ID2：消耗数量2,………...}
+		gacha_cost = "json", -- 消耗，json格式记录，{道具ID1：消耗数量1,道具ID2：消耗数量2,………...}
 		gacha_cnt = true, -- 保底计数
 	},
 	equip_wear = { --装备穿戴与卸载
@@ -296,8 +291,8 @@ local MethodType = {
 		equip_id = true, --装备ID
 		equip_wear_action = true, --装备操作类型：装备：0，卸载：1
 		equip_wear_part = true, --装备部位，记录部位ID
-		equip_wear_result = "json", --装备操作后结果，记录属性变化，json格式记录，{“aa”:1234,"bb":4567}
-		equip_wear_change = "json", --装备操作变化值，记录属性变化，记录正负值，json格式记录，{“aa”:1234,"bb":-45}
+		equip_wear_scorebef = true, --装备前英雄评分
+		equip_wear_score = true, --装备后英雄评分
 		equip_wear_mode = true, --用以区分自动装备还是手动装备，自动记录为0，手动记录为1
 		equip_wear_seqid = "ucode", --自动穿戴时记录的系列ID，用以关联一次性装备时候产生的多条记录
 	},
@@ -414,6 +409,7 @@ local MethodType = {
 		restaurant_order_status = true, -- 订单任务状态，接受:0, 拒绝:1, 完成:2
 		restaurant_order_rwd = "json", -- 订单完成奖励，json格式记录，{"itemid1":123,"itemid2":12,……….}
 		restaurant_order_lv = true, -- 订单品质等级，普通:0, 稀有:1, 顶级:2, 豪华:3
+		restaurant_order_type = true,	-- 订单任务类型，0:特殊顾客，1:特别订单
 	},
 	restaurant_collect = { --餐厅顾客图谱 
 		restaurant_collect_id = true, -- 图谱收集ID
@@ -505,6 +501,27 @@ local MethodType = {
 		mission_pick_fund_beflv = true, -- 资助前资助等级
 		mission_pick_fund_aftlv = true, -- 资助后资助等级
 	},
+	function_open = { -- 功能开启日志	
+		function_id	= true, --功能ID
+	},
+	punitive_action = { --  讨伐行动 --TODO
+		mission_id	= true, --关卡ID
+		mission_herolist = true, -- 英雄ID，排序以玩家出战设置为准，示例：[111, 222, 333, 444, 555]
+		mission_success_rate = true, -- 大成功几率
+		mission_reward = true, -- 获得奖励，建议使用json格式记录。示例：{ itemid1: 1,  itemid2: 3,  itemid3: 5}
+		mission_result = true, -- 战斗结果(0-无效，1-胜利，2-失败)
+		mission_roundtime = true, -- 完成耗时（秒）
+	},
+	hero_talent = { --英雄精进（原英雄天赋升级）  TODO
+		hero_id = true, --英雄ID
+		hero_talent_stagebef = true, --英雄精进升级前停留阶段
+		hero_talent_stage = true, --英雄精进升级后停留阶段
+		hero_talent_cost = "json", --英雄精进升级消耗，json格式记录，{道具ID1：消耗数量1,道具ID2：消耗数量2,….}
+		hero_talent_subid = true, --升级属性ID，生命、攻击、防御、命中、闪避分别对应（0，1，2，3，4）
+		hero_talent_sublevel = true, --升级属性等级，如生命升级从1到2，则记录2
+	},
+
+	
 }
 local function printError(info)
@@ -566,6 +583,7 @@ local LogType = {
 	logout = "common",
 	guide = "common",
 	newdevice = "common",
+	cbback = "common",
 	in_item = "common",
 	out_item = "common",
@@ -362,10 +362,34 @@ function RolePlugin.bind(Role)
 			pms.itemId = itemId
 			pms.count = - count
 			self:addItem(pms)
+			self:itemDeltaEvent(pms)
 		end
 		return true
 	end
+	function Role:itemDeltaEvent(pms)
+		self:eventBoxL(pms)
+	end
+
+	-- 拆解室的生产线启动
+	function Role:eventBoxL(pms)
+		local limit = globalCsv.box_key_max[pms.itemId]
+		if not limit then return end
+
+		local update = false
+		local boxL = self:getProperty("boxL") or {}
+		for slot, data in pairs(boxL) do
+			if data.time == 0 and data.id == pms.itemId and self:getItemCount(pms.itemId) < limit then
+				update = true
+				data.time = skynet.timex()
+			end
+		end
+
+		if update then
+			self:updateProperty({field = "boxL", value = boxL})
+		end
+	end
+
 	function Role:getItemCount(itemId)
 		if itemId == ItemId.Diamond then
 			return self:getAllDiamond()
@@ -1014,6 +1038,7 @@ function RolePlugin.bind(Role)
 		if csvdb["itemCsv"][func] and csvdb["itemCsv"][func].type == ItemType.FuncOpen then
 			local unlockData = csvdb["unlockCsv"][func]
+			self:log("function_open", {function_id = func})
 			if unlockData.type == 4 then -- 解锁神器
 				if self:getProperty("advAFOpen")[unlockData.value1] ~= 1 then
 					self:changeUpdates({{type = "advAFOpen", field = unlockData.value1, value = 1}})
@@ -1176,7 +1201,7 @@ function RolePlugin.bind(Role)
 			lv = self:getProperty("level"),
 			batteV = battleV,
 			level = level,
-			format = self:getTeamHerosInfo(towerTeam.heros),
+			format = self:getTeamHerosInfo(towerTeam).heros,
 		}
 		local roleId = self:getProperty("id")
 		redisproxy:pipelining(function (red)
@@ -1324,9 +1349,10 @@ function RolePlugin.bind(Role)
 		return teamInfo
 	end
-	function Role:getTeamHerosInfo(heroIds)
+	function Role:getTeamHerosInfo(team)
+		local format = {}
 		local heros = {}
-		for slot, heroId in pairs(heroIds or {}) do
+		for slot, heroId in pairs(team.heros or {}) do
 			local hero = self.heros[heroId]
 			heros[slot] = {
 				type = hero:getProperty("type"),
@@ -1334,7 +1360,10 @@ function RolePlugin.bind(Role)
 				wakeL = hero:getProperty("wakeL"),
 			}
 		end
-		return heros
+		format.heros = heros
+		format.supports = team.supports or {}
+		format.tactics = team.tactics or {}
+		return format
 	end
 	function Role:getTeamBattleValue(heros)
@@ -1352,7 +1381,7 @@ function RolePlugin.bind(Role)
 		if not team then return end
 		self:setProperties({
-			hangTS = self:getTeamHerosInfo(team.heros),
+			hangTS = self:getTeamHerosInfo(team),
 			hangTB = self:getTeamBattleInfo(team),
 			hangTBV = self:getTeamBattleValue(team.heros),
 		})
@@ -1400,7 +1429,7 @@ function RolePlugin.bind(Role)
 			self:updateProperty({field = "pvpTC", value = team})
 		end
 		self:setProperties({
-			pvpTSC = self:getTeamHerosInfo(team.heros),
+			pvpTSC = self:getTeamHerosInfo(team),
 			pvpTBC = self:getTeamBattleInfo(team),
 			pvpTBVC = self:getTeamBattleValue(team.heros),
 		})
@@ -1416,7 +1445,7 @@ function RolePlugin.bind(Role)
 		local pvpTSH, pvpTBH, pvpTBVH = {}, {}, {}
 		for i = 1, 3 do
 			if team[i] then
-				pvpTSH[i] = self:getTeamHerosInfo(team[i].heros)
+				pvpTSH[i] = self:getTeamHerosInfo(team[i])
 				pvpTBH[i] = self:getTeamBattleInfo(team[i])
 				pvpTBVH[i] = self:getTeamBattleValue(team[i].heros)
 			end
@@ -1575,10 +1604,17 @@ function RolePlugin.bind(Role)
 			return ""
 		end
 		local limit = rechargeData.limit
-	    local rechargeRecord = self:getProperty("payR") or {}
+	    local rechargeRecord = self.storeData:getProperty("payR") or {}
 	    if limit ~= 0 and limit <= (rechargeRecord[rechargeId] or 0) then
 	        return ""
-	    end
+		end
+		
+		--判断是否是活动商品
+		if rechargeData.activity_id ~= 0 then
+			local actCfg = csvdb["activity_ctrlCsv"][rechargeData.activity_id]
+			if not actCfg then return "" end
+			if not self.activity:isOpenById(rechargeData.activity_id, "ActShopGoods") then return "" end
+		end
 	    local orderId = redisproxy:hget(string.format(R_ORDERS, roleId), rechargeId)
 	    if orderId then
@@ -1596,6 +1632,7 @@ function RolePlugin.bind(Role)
 			key = orderKey, 
 			order = partnerOrderId, 
 			rechargeId = rechargeId, 
+			createTime = skynet.timex(),
 		})
 		order:create()
 		-- 正在进行中的订单 缓存
@@ -1639,7 +1676,7 @@ function RolePlugin.bind(Role)
 		-- 开始下单
 		if status == "success" then
 		elseif status == "fail" then
-			redisproxy:hdel(string.format(R_ORDERS, roleId), rechargeId)
+			-- redisproxy:hdel(string.format(R_ORDERS, roleId), rechargeId)
 		elseif status == "finsh" then
 			orderObject:setProperty("finishTime", skynet.time())
 			redisproxy:hdel(string.format(R_ORDERS, roleId), rechargeId)
@@ -1824,10 +1861,10 @@ function RolePlugin.bind(Role)
 	end
 	-- 抽卡阶段奖励
-	function Role:getDrawCardExtraReward(oldVal, newVal)
+	function Role:getDrawCardExtraReward(feedbackId, oldVal, newVal)
 		local reward = nil
 		local maxCount = 0
-		for k, v in pairs(csvdb["build_extraRewardCsv"]) do
+		for k, v in pairs(csvdb["build_extraRewardCsv"][feedbackId]) do
 			if oldVal < k and newVal >= k then
 				reward = v["reward"] or ""
 			end
@@ -233,7 +233,6 @@ function Role:refreshPvpMatch(score, rank, rankKey)
 		if low < 0 then
 			low = 0
 		end
-		print(low, heigh)
 		local rangeIds = redisproxy:ZREVRANGE(dbKey, low, heigh)
 		local lastRangeIds = {}
 		for idx, one in ipairs(rangeIds) do
@@ -48,6 +48,8 @@ local TaskType = {
 	AdvScore = 410, 			-- 冒险分数			- score		
 	AdvDraw = 411, 				-- 冒险资助			- count		ptype
 	AdvHang	= 412,				-- 代理拾荒次数
+	AdvMineKill = 413,			-- 宝藏怪击杀
+	AdvMineLayer = 414,			-- 宝藏洞激活
 	--爬塔相关
 	TowerPass = 501,			-- 爬塔通关			- level
@@ -218,6 +220,7 @@ local SudokuListener = {
 }
 local Activity = require("models.Activity")
+
 local ActivityListener = {
 	func = "checkActivityTask",
 	listen = {
@@ -226,6 +229,8 @@ local ActivityListener = {
 		[TaskType.AdvDraw] = {{Activity.ActivityType.AdvDraw, f("count")}},
 		[TaskType.OpenBox] = {{Activity.ActivityType.OpenBox, f("count")}},
 		[TaskType.Pay] = {{Activity.ActivityType.PayBack, f("twd")}},
+		[TaskType.AdvMineKill] = {{Activity.ActivityType.Crisis, 1}},
+		[TaskType.AdvMineLayer] = {{Activity.ActivityType.Crisis, 2}},
 	}
 }
@@ -266,7 +271,6 @@ local CalendaTaskListener = {
 	}
 }
-
 local TaskListeners = {
 	StoryListener,
 	CommonListener,
@@ -358,11 +362,22 @@ function RoleTask.bind(Role)
 		return true
 	end
+	local function checkStoryStatusByActBattle(role, data, status, cond1)	-- cond1 carbonId
+		local actid = data.sort
+		if not role.activity:isOpenById(actid) then return end
+		if cond1 and tonumber(data.unlockData) == cond1 then
+			status.s = 1
+			return true
+		end
+		return
+	end
+
 	local checkstoryStatusFunc = {
 		[1] = checkStoryStatusByHang,
 		[2] = checkStoryStatusByLove,
 		[3] = checkStoryStatusByMultStar,
 		[4] = checkStoryStatusByAdv,
+		[5] = checkStoryStatusByActBattle,
 	}
 	function Role:checkStoryStatus(notNotify, stype, cond1, cond2, cond3)
@@ -298,6 +298,8 @@ function Store:resetStoreReored(resetId)
                     end
                 end
             end
+        else
+            payRecord[k] = nil
         end
     end
     self:updateProperty({field = "payR", value = payRecord})
@@ -307,6 +309,8 @@ function Store:resetStoreReored(resetId)
             if config.resetTime == resetId then
                 buyRecord[k] = nil
             end
+        else
+            buyRecord[k] = nil
         end
     end
     self:updateProperty({field = "buyR", value = buyRecord})
@@ -175,7 +175,7 @@ end
 function CMD.start()
 	check_mail_queue()
-	check_battle_act_close()
+	--check_battle_act_close()
 end
 local function __init__()
 local skynet = require "skynet"
-local logd_count = tonumber(skynet.getenv("thread"))
+local logd_count = tonumber(skynet.getenv("thread")) * 2
 local use_logd = tonumber(skynet.getenv("logd"))