Merge branch 'develop' into tr/qa

熊润斐
2 parents bde0b30d a5660239
Showing 46 changed files with 1178 additions and 235 deletions Show diff stats
robot/robot.conf
robot/robot.lua
robot/robot_config.lua
robot/robot_main.lua
robot/robot_pool.lua
robot/start.lua
robot/unitTest/adv.lua
robot/unitTest/hero.lua
robot/unitTest/item.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/HttpAction.lua
src/actions/PvpAction.lua
src/actions/RadioAction.lua
 root = "./"
-thread = 8
+thread = 4
 logger = nil
 harbor = 0
-start = "start"	-- main script
+start = "robot_main"	-- main script
 bootstrap = "snlua bootstrap"	-- The service for bootstrap
  
 lua_path = root .."skynet/lualib/?.lua;"..root.."robot/?.lua;"..root.."src/?.lua"
@@ -16,6 +16,7 @@ local eventListener = {}
  
 local ignoreListener = {
 	["Role.updateProperty"] = function(data)
+		if not client.role then return end
 		local msg = MsgPack.unpack(data)
 		for _, one in pairs(msg) do
 			client.role[one.key] = one.newValue
@@ -80,7 +81,7 @@ function triggerListener(listener, data)
 			ignoreListener[listener](data)
 		end
 	else
-		log(listener .. " no handle!!!")
+		-- log(listener .. " no handle!!!")
 	end
 end
  
@@ -103,8 +104,8 @@ function sendServer(actionCode, bin)
 end
  
 function requestServer(actionCode, bin, callback, isKeep)
-	sendServer(actionCode, bin)
 	addListener(actionCode, callback, isKeep)
+	sendServer(actionCode, bin)
 end
  
 local function heartBeat()
@@ -120,7 +121,7 @@ local function startUnit(unit)
  
 	local ok, unitTest = pcall(require, "unitTest." .. unit)
 	if not ok then
-		print("unitTest load error : " .. unitTest)
+		log("unitTest load error : " .. unitTest)
 	end
  
 	unitTest.new(client):startTest()
@@ -130,6 +131,8 @@ end
 -- 登录成功开始任务
 function CMD.task()
 	heartBeat()
+	-- 20 秒后开始执行任务 错开登录
+	skynet.sleep(math.randomInt(2000, 3000))
 	startUnit()
 end
  
@@ -142,7 +145,7 @@ function CMD.start(fd, id)
 	client.uname = uname
 	local status, body = httpc.get(config.http, "/login?" .. httpGetFormatData({token = uname, device = "test", channel = "develop"}))
 	if tonumber(status) ~= 200 then
-		print("http get error", uname, body)
+		log("http get error", uname, body)
 		return
 	end
 	local servInfo = json.decode(body)
@@ -170,7 +173,7 @@ skynet.register_protocol {
 	dispatch = function(session, address, cmd, data)
 		local actionName = actionHandlers[cmd]
 		if not actionName then
-			print("actionName not exist", actionName)
+			log("actionName not exist", actionName)
 			return
 		end
  
@@ -10,7 +10,7 @@ end
  
  
 return {
-	http = "http://106.13.60.20:9090", -- 登录服
+	http = "http://192.168.0.199:9090", -- 登录服
 	host = "127.0.0.1", --服务器地址
 	port = 12001,  	-- 服务器端口
  
@@ -20,15 +20,15 @@ return {
 	max = 200, 	-- 最大玩家数 必须大于 online 数
 	online_time = {10 * 60, 20 * 60}, -- 在线时间控制 秒
  
-	uname_prefix = "robot", --机器名称前缀
+	uname_prefix = "robothehe", --机器名称前缀
  
  
 	-- 机器上线后的行为
 	units = {
 		chat = {weight = 100}, -- 聊天
 		item = {weight = 100}, -- 物品操作
-		hero = {weight = 500}, -- 英雄 
-		hang = {weight = 1000}, -- 挂机战斗 
+		hero = {weight = 500}, -- 英雄
+		hang = {weight = 1000}, -- 挂机战斗
 		tower = {weight = 500}, -- 爬塔
 		car = {weight = 100}, -- 爬塔
 		pvp = {weight = 500}, -- pvp
@@ -0,0 +1,21 @@
+local skynet = require "skynet"
+local config = require "robot_config"
+
+local preOnlineCount = 10
+
+
+skynet.start(function()
+	local need = math.ceil(config.online / preOnlineCount)
+	local inpre = math.ceil(config.inpre / need)
+	local idRange = math.ceil(config.max / need)
+	local curId = 1
+	local poold = skynet.newservice("robot_pool")
+	local pooldObj = skynet.call(poold, "lua", "start", config.online + preOnlineCount)
+
+	for i = 1, need do
+		local start = skynet.newservice("start")
+		skynet.send(start, "lua", "start", poold, pooldObj, preOnlineCount, curId, curId + idRange - 1, inpre)
+		curId = curId + idRange
+	end
+	skynet.exit()	
+end)
 \ No newline at end of file
@@ -0,0 +1,46 @@
+--[[
+	deque 为了减少锁竞争，尽量保证 a服务 push；b服务 pop
+]]
+local skynet = require "skynet"
+local deque = require "deque"
+
+local CMD = {}
+local factory
+
+local PRE_FEED_COUNT = 5
+local dead = 0
+-- agent死亡，通知poold补充，当累计到5个agent时，马上生成5个agent放入poold中
+-- 当然这里也可以写得更复杂，参考redis落地规则
+function CMD.feed()
+	dead = dead + 1
+	if dead == PRE_FEED_COUNT then
+		dead = 0
+		for i=1, PRE_FEED_COUNT do
+			factory:push(skynet.newservice("robot"))
+		end
+	end
+end
+
+-- 系统启动，生成count个agent放入双端队列中
+function CMD.start(count)
+	factory, addr = deque.new(count)
+
+	for i = 1, count do
+		factory:push(skynet.newservice("robot"))
+	end
+
+	return addr
+end
+
+local function __init__()
+	skynet.dispatch("lua", function (_, _, command, ...)
+		local f = CMD[command]
+		if command == "start" then
+			skynet.ret(skynet.pack(f(...)))
+			return
+		end
+		f(...)
+	end)
+end
+
+skynet.start(__init__)
@@ -5,32 +5,37 @@ local config = require &quot;robot_config&quot;
 local skynet = require "skynet"
 local netpack = require "skynet.netpack"
 local socketdriver = require "skynet.socketdriver"
+local deque = require "deque"
 local string_format = string.format
  
+local poold, pooldObj, onlineCount, startId, endId, inpre
+local factory
+
 local queue = {}
 local fd2serv = {}
 local id2fd = {}
 local MSG = {}
-local id_max = 0 -- robot id
+local id_max 
  
  
 function MSG.open( ... )
-	print("open", ...)
+	log("open", ...)
 end
  
 function MSG.close(fd)
 	if fd2serv[fd] and not fd2serv[fd].closing then
 		fd2serv[fd].closing = true
 		skynet.call(fd2serv[fd].agent, "lua", "exit")
-		log(string_format("logout %s", fd2serv[fd].id))
+		pcall(skynet.send, poold, "lua", "feed")
  
+		log(string_format("logout %s", fd2serv[fd].id))
 		id2fd[fd2serv[fd].id] = nil
 		fd2serv[fd] = nil
 	end
 end
  
 function MSG.error(fd, msg)
-	print("MSG.error", fd, msg)
+	log("MSG.error", fd, msg)
 	MSG.close(fd)
 end
  
@@ -72,13 +77,14 @@ skynet.register_protocol {
 }
  
 local function add_robot()
-	local robot = skynet.newservice("robot")
+	local time = skynet.time()
+	local robot = factory:pop()
 	local fd = socketdriver.connect(config.host, config.port)
 	socketdriver.start(fd)
 	local id
-	if id_max >= config.max then
+	if id_max >= endId then
 		while true do
-			id = math.randomInt(1, config.max)
+			id = math.randomInt(startId, endId)
 			if not id2fd[id] then
 				break
 			end
@@ -89,9 +95,8 @@ local function add_robot()
 	end
 	fd2serv[fd] = {agent = robot, id = id}
 	id2fd[id] = fd
-	pcall(skynet.call, robot, "lua", "start", fd, id)
+	pcall(skynet.call, robot, "lua", "start", fd, id, prefix)
 	log(string_format("login %s", fd2serv[fd].id))
-
 	-- 定时下线
 	skynet.timeout(math.randomInt(config.online_time[1], config.online_time[2]) * 100, function()
 		MSG.close(fd)
@@ -106,8 +111,8 @@ local function online()
 	end
  
 	-- 及时补充人数
-	if curCount < config.online then
-		for i = curCount + 1, config.online do
+	if curCount < onlineCount then
+		for i = curCount + 1, onlineCount do
 			add_robot()
 		end
 	end
@@ -116,11 +121,18 @@ local function online()
 	skynet.timeout(100, online)
 end
  
-local function start()
+local function start(pooldp, pooldObj, onlineCountp, startIdp, endIdp, inprep)
 	log("start testing ...")
  
-	for i = 1, config.online, config.inpre do
-		for j = 1, config.inpre do
+	factory = deque.clone(pooldObj)
+	poold, onlineCount, startId, endId, inpre = pooldp, onlineCountp, startIdp, endIdp, inprep
+	id_max = startId - 1
+
+	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)
@@ -131,5 +143,10 @@ local function start()
 end
  
 skynet.start(function()
-	skynet.fork(start)
+	skynet.dispatch("lua", function (_, _, command, ...)
+		if command == "start" then
+			start(...)
+			return
+		end
+	end)
 end)
 \ No newline at end of file
@@ -8,6 +8,8 @@ local _M = class(&quot;hang&quot;, require(&quot;unitTest.unitTest&quot;))
  
 function _M:start()
 	sendServer(actionCodes.Gm_clientRequest,  MsgPack.pack({cmd = "fb", pm1 = 10606}))
+	requestServer(actionCodes.Adv_roleFormatRpc,  MsgPack.pack({index = 1, title = "hehe", leader = 1, leader2 = 2, heros = {[1] = 1, [2] = 2}}))
+	requestServer(actionCodes.Adv_selectTeamRpc,  MsgPack.pack({index = 1}))
 	self:task()
 end
  
@@ -24,8 +26,8 @@ function _M:task()
 end
  
 function _M:startAdv()
-	sendServer(actionCodes.Gm_clientRequest,  MsgPack.pack({cmd = "advf", pm1 = 10606}))
-	requestServer(actionCodes.Adv_startAdvRpc,  MsgPack.pack({chapterId = 101, format = {leader = 1, leader2 = 2, heros = {[1] = 1, [2] = 2}}}))
+	sendServer(actionCodes.Gm_clientRequest,  MsgPack.pack({cmd = "advf"}))
+	requestServer(actionCodes.Adv_startAdvRpc,  MsgPack.pack({chapterId = 101}))
 	requestServer(actionCodes.Adv_exitAdvRpc, '')
 end
  
@@ -35,8 +35,8 @@ function _M:drawHero10()
 end
  
 function _M:createHeroRandom()
-	sendServer(actionCodes.Gm_clientRequest,  MsgPack.pack({cmd = "get", pm1 = 703, pm2 = 20}))
-	requestServer(actionCodes.Hero_createHeroRandomRpc, MsgPack.pack({itemId = 703}))
+	sendServer(actionCodes.Gm_clientRequest,  MsgPack.pack({cmd = "get", pm1 = 722, pm2 = 40}))
+	requestServer(actionCodes.Hero_createHeroRandomRpc, MsgPack.pack({itemId = 722}))
 end
  
  
@@ -14,7 +14,7 @@ end
 local taskMap = {
 	saleItem = {100},
 	openItem = {100},
-	openTimeBox = {100},
+	-- openTimeBox = {100},
 }
  
 function _M:task()
@@ -31,8 +31,8 @@ end
  
  
 function _M:openItem()
-	sendServer(actionCodes.Gm_clientRequest,  MsgPack.pack({cmd = "get", pm1 = 701, pm2 = 20}))
-	requestServer(actionCodes.Role_openItemRpc, MsgPack.pack({itemId = 701, count = 1}))
+	sendServer(actionCodes.Gm_clientRequest,  MsgPack.pack({cmd = "get", pm1 = 831, pm2 = 1}))
+	requestServer(actionCodes.Role_openItemRpc, MsgPack.pack({itemId = 831, count = 1}))
 end
  
 function _M:openTimeBox()
@@ -136,6 +136,7 @@ ItemId = {
 	AdvKey = 80, -- 冒险钥匙
 	BoxKey = 60, -- 拆解工具
 	AdvPower = 4701, -- 拾荒体力
+	CrisisScore = 8010, -- 积分
 }
  
 TimeReset = {
@@ -292,6 +293,10 @@ CardType = {
 	BattlePassCard = 7, -- 探索指令
 }
  
+ShopPackType = {
+	ActShopPack = 5,	-- 活动礼包
+}
+
 HeroQuality = {
 	N = 1,
 	R = 2,
@@ -223,6 +223,12 @@ actionCodes = {
 	Activity_exchangeRpc = 657,
 	Activity_gachakonRpc = 658,
 	Activity_hangDropRpc = 659,
+	Activity_startBattleRpc = 660,
+	Activity_endBattleRpc = 661,
+	Activity_battleRankRpc = 662,
+	Activity_battleMilestoneRpc = 663,
+	Activity_bossRewardRpc = 664,
+	Activity_crisisMilestoneRpc = 665,
  
 	Radio_startQuestRpc = 700,
 	Radio_finishQuestRpc = 701,
@@ -15,6 +15,12 @@ R_STORE = &quot;role:%d:store&quot;   -- 商店
 R_ORDERS = "role:%d:orders" -- 订单
 R_ORDER = "order:%d:%d"
  
+-- 通用排行榜
+RANK_COMMON 	= "rank:common:"
+RANK_TYPE = {
+    ActBattleBoss = "act_battle_boss",
+    ActCrisis = "crisis",
+}
  
 -- rank
 RANK_TOWER 	= "rank:tower"
@@ -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,10 +325,10 @@ 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
-		print("-----------------, ", i)
 		for id, cfg in pairs(tmpCfg) do
 			local num = gachakonInfo[id] or 0
 			num = cfg.amount >= num and cfg.amount - num or 0
@@ -327,7 +336,7 @@ function _M.gachakonRpc(agent, data)
 			if cfg.weight > 0 then
 				remain = remain + num
 			end
-			print("num ".. num, id, cfg.weight, cfg.amount)
+			--print("num ".. num, id, cfg.weight, cfg.amount)
 		end
 		if remain == 0 then
 			break
@@ -336,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
@@ -350,13 +360,13 @@ function _M.gachakonRpc(agent, data)
 	role:costItems(cost, {log = {desc = "actGachakon", int1 = actid, int2 = count}})
  
 	local reward, change = role:award(award, {log = {desc = "actGachakon", int1 = actid, int2 = count}})
-	if remain <= count then
+	--print("-----------", remain, count)
+	if remain <= 1 then
 		gachakonInfo = {}
-		print("hahaha")
 	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
  
@@ -364,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
@@ -381,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
@@ -408,11 +418,409 @@ function _M.hangDropRpc(agent, data)
  
 	reward, change  = role:award(reward, {log = {desc = "actHangDrop", int1 = actid, int2 = num}})
  
-	role.activity:updateActData("HangDrop", timeNow)
+	if num < 8 then
+		actData = actData + num * period
+	else
+		actData = timeNow
+	end
+
+	role.activity:updateActData("HangDrop", actData)
  
 	SendPacket(actionCodes.Activity_hangDropRpc, MsgPack.pack(role:packReward(reward, change)))
  
 	return true
 end
  
+local function getStarCount(cfg, data)
+	local count = 0
+	for i = 0, #(cfg.sweep_condition:toTableArray(true)) do
+		if (1 << i & data) > 0 then
+			count = count + 1
+		end
+	end
+
+	return count
+end
+
+function _M.startBattleRpc(agent, data)
+	local role = agent.role
+	local msg = MsgPack.unpack(data)
+	local actid = msg.actid
+	local id = msg.id
+	local count = msg.count
+	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
+
+	local actData = role.activity:getActData("ChallengeLevel") or {}
+
+	local preArr = battleCfg.prepose:toArray(true, "=")
+	for _, v in ipairs(preArr) do
+		local battleInfo = actData[v]
+		if not battleInfo then
+			return 4
+		end
+		local star = battleInfo["star"] or 0
+		if star <= 0 then
+			return 4
+		end
+	end
+	-- check cost
+	local changeFlag = false
+	local ticket = actData["ticket"]
+	local num = 0	-- cost num
+	if battleCfg.type ~= "" then
+		role.activity:getBattleTicket(actid)
+		num = battleCfg.type:toArray(true, "=")[3]
+		if count and count > 0 then
+			if battleCfg.rank == 0 then
+				return 7
+			end
+			local bi = actData[id]
+			if not bi then return 8 end
+			local star = bi["star"] or 0
+			if star < 1 then
+				return 9
+			end
+			num = num * count
+		end
+		if ticket < num then
+			return 6
+		end
+		changeFlag = true
+	end
+	-- 解锁活动剧情
+	role:checkStoryStatus(false, 5, id)
+
+	if not count then
+		role.__actBattleCache = {
+			key = tostring(math.random()),
+			actid = actid,
+			id = id,
+		}
+		SendPacket(actionCodes.Activity_startBattleRpc, MsgPack.pack({key = role.__actBattleCache.key}))
+	else
+		if count <= 0 then
+			return
+		end
+		if battleCfg.rank == 0 then
+			return 7
+		end
+		local bi = actData[id]
+		local star = bi["star"]
+		local award = battleCfg.item_clear:toNumMap()
+		if getStarCount(battleCfg, star) == 3 then
+			local aw = battleCfg.perfect_reward:toNumMap()
+			for k, v in pairs(aw) do
+				award[k] = (award[k] or 0) + v
+			end
+		end
+		for k, v in pairs(award) do
+			award[k] = v * count
+		end
+		local reward, change  = role:award(award, {log = {desc = "actBattle", int1 = actid, int2 = count or 0}})
+		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
+
+		local rankVal = 0
+		if battleCfg.rank == 1 then
+			rankVal = bi["sum"]
+		elseif battleCfg.rank == 2 then
+			rankVal = bi["top"]
+		end
+		role:updateRankCommon(RANK_TYPE.ActBattleBoss, rankVal)
+	end
+	if changeFlag then
+		role.activity:updateActData("ChallengeLevel", actData)
+	end
+
+	return true
+end
+
+function _M.endBattleRpc(agent, data)
+	local role = agent.role
+	local msg = MsgPack.unpack(data)
+	local actid = msg.actid
+	local id = msg.id
+	local key = msg.key
+	local isWin = msg.isWin
+	local heros = msg.heros
+	local support = msg.support
+	if not role.activity:isOpenById(actid, "ChallengeLevel") then return 1 end
+
+	if not role.__actBattleCache then return 2 end
+	
+	if role.__actBattleCache.id ~= id or role.__actBattleCache.key ~= key and role.__actBattleCache.actid ~= actid then 
+		SendPacket(actionCodes.Activity_endBattleRpc, MsgPack.pack({errorCode = 1}))
+	end
+
+	local actCfg = csvdb["activity_battleCsv"][actid]
+	if not actCfg then return 3 end
+
+	local battleCfg = actCfg[id]
+	if not battleCfg then return 4 end
+
+	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 {}
+	local curStar = 0
+ 	if isWin then
+ 		local herosInfo = msg.heros
+
+ 		local check = {}
+ 		-- 1 通关
+		check[1] = function(_)
+			return true
+		end
+		-- 2 阵亡人数 <= N
+		check[2] = function(_, cond)
+			return msg.info.dead and msg.info.dead <= cond
+		end
+		-- 3 全员存活
+		check[3] = function(_)
+			return msg.info.dead and msg.info.dead == 0
+		end
+		-- 4 指定种族 >= N
+		check[4] = function(_, cond)
+			local count = 0
+			for _, one in pairs(herosInfo) do
+				local heroData = csvdb["unitCsv"][one.type]
+				if heroData.camp == cond then
+					count = count + 1
+				end
+			end
+			return count >= cond
+		end
+		-- 5 指定职业 >= N
+		check[5] = function(_, cond)
+			local count = 0
+			for _, one in pairs(herosInfo) do
+				local heroData = csvdb["unitCsv"][one.type]
+				if heroData.job == cond then
+					count = count + 1
+				end
+			end
+			return count >= cond
+		end
+		-- 6 含有指定角色 
+		check[6] = function(_, cond)
+			for _, one in pairs(herosInfo) do
+				if one.type == cond then
+					return true
+				end
+			end
+			return false
+		end
+		-- 7 通关耗时 <= X 秒  msg.info.atime
+		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
+ 			if check[cond[1]] and check[cond[1]](table.unpack(cond)) then
+ 				curStar = curStar + (1 << (i - 1))
+ 			end
+ 		end
+	 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)
+	if  newStarNum > oldStarNum then
+		battleInfo["star"] = curStar
+	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)
+
+		-- 更新排行榜 最高伤害
+		battleInfo["top"] = math.max(battleInfo["top"] or 0, dmg)
+		battleInfo["sum"] = (battleInfo["sum"] or 0) + dmg
+		local rankVal = 0
+		if battleCfg.rank == 1 then
+			rankVal = battleInfo["sum"]
+		elseif battleCfg.rank == 2 then
+			rankVal = battleInfo["top"]
+		end
+		if rankVal > 0 then
+			role:updateRankCommon(RANK_TYPE.ActBattleBoss, rankVal)
+		end
+	end
+	actData[id] = battleInfo
+	role.activity:updateActData("ChallengeLevel", actData)
+
+	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 and newStarNum == 3) then
+		local aw = battleCfg.perfect_reward:toNumMap()
+		for k, v in pairs(aw) do
+			reward[k] = (reward[k] or 0) + v
+		end
+	end
+
+ 	role:checkBattle("act_battle", {
+		cfg = battleCfg,
+		star = newStarNum,
+		isWin = isWin,
+		info = msg.info,
+		reward = reward,
+		heros = heros,
+		supports = support,
+	})
+
+	-- 解锁活动剧情
+	if newStarNum >= 3 then
+		role:checkStoryStatus(false, 5, id)
+	end
+
+	reward, change  = role:award(reward, {log = {desc = "actBattle", int1 = actid, int2 = newStarNum}})
+
+	SendPacket(actionCodes.Activity_endBattleRpc, MsgPack.pack({
+		reward = reward,
+		change = change
+	}))
+
+	return true
+end
+
+function _M.battleRankRpc(agent, data)
+	local role = agent.role
+	local msg = MsgPack.unpack(data)
+	local actid = msg.actid
+	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
+
+function _M.battleMilestoneRpc(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_mileageCsv"][actid]
+	if not actCfg then return 3 end
+
+	local mileCfg = actCfg[index]
+	if not mileCfg then return 4 end
+
+	local actData = role.activity:getActData("ChallengeLevel") or {}
+	local battleInfo = actData[id] or {}
+	local val = 0
+	if mileCfg.type == 1 then
+		val = battleInfo["sum"] or 0
+	elseif mileCfg.type == 2 then
+		val = battleInfo["top"] or 0
+	end
+
+	local record = battleInfo["r"] or ""
+	local flag = string.char(string.getbit(record, index))
+	if flag == "1" then return 5 end
+	if mileCfg.condition > val then return 6 end
+
+	battleInfo["r"] = string.setbit(record, index)
+	actData[id] = battleInfo
+	role.activity:updateActData("ChallengeLevel", actData)
+
+	local award = mileCfg.reward:toNumMap()
+	local reward, change = role:award(award, {log = {desc = "actMilestone", int1 = actid, int2 = index}})
+	SendPacket(actionCodes.Activity_battleMilestoneRpc, MsgPack.pack(role:packReward(reward, change)))
+
+	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.award, {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.boss_reward_id == 0 then return 4 end
+
+	--local award = mileCfg.reward:toNumMap()
+	--local reward, change = role:award(award, {log = {desc = "actMilestone", int1 = actid, int2 = index}})
+	--SendPacket(actionCodes.Activity_battleMilestoneRpc, 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
@@ -502,6 +502,11 @@ function _M.guide(role, pms)
 				end
 			end
 		end
+		for _, data in pairs(csvdb["guide_unlockCsv"]) do
+			if data.type == 0 or data.type == 3 then
+				str = str:setv(data.id,1)
+			end
+		end
 		role:updateProperty({field = "funcGuide", value = str})
 		role:mylog("gm_action", {desc = "sguide", key1 = pms.sender})
  
@@ -524,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
@@ -535,6 +550,7 @@ function _M.test(role, pms)
 	--hero.unlockPoolRpc({role = role}, MsgPack.pack({type = id}))
  
 	--role:sendMail(13, nil, "1=2", {111})
+	dump(redisproxy:zrevrange("rank:tower", 0 , 10, "WITHSCORES"))
 	return "成功"
 end
  
@@ -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 通关
@@ -632,7 +637,7 @@ function _M.endBonusBattleRpc(agent, data)
 		check[4] = function(_, cond)
 			local count = 0
 			for _, one in pairs(herosInfo) do
-				local heroData = csv["unitCsv"][one.type]
+				local heroData = csvdb["unitCsv"][one.type]
 				if heroData.camp == cond then
 					count = count + 1
 				end
@@ -643,7 +648,7 @@ function _M.endBonusBattleRpc(agent, data)
 		check[5] = function(_, cond)
 			local count = 0
 			for _, one in pairs(herosInfo) do
-				local heroData = csv["unitCsv"][one.type]
+				local heroData = csvdb["unitCsv"][one.type]
 				if heroData.job == cond then
 					count = count + 1
 				end
@@ -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,18 +481,14 @@ function _M.referEquipsRpc(agent, data)
 	-- 更新角色
 	hero:updateProperty({field = "equip", value = curEquip})
  
-	role:finishGuide(23)
-
-	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
@@ -714,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心愿卡池
@@ -726,11 +727,32 @@ function _M.drawHeroRpc(agent, data)
 		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]
@@ -947,12 +969,12 @@ 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
+	if (buildTypeData["can_feedback"] or 0) == 1 then
 		-- 达到一定次数，给响应奖励
 		local oldVal = role:getProperty("repayHero") or 0
 		local newVal = oldVal + drawCount[drawType]
@@ -1092,6 +1114,9 @@ function _M.itemComposeRpc(agent, data)
 	if not config then return 2 end
  
 	local cost = config.cost:toNumMap()
+	for k, v in pairs(cost) do
+		cost[k] = v * count
+	end
 	if not role:checkItemEnough(cost) then return 2 end
 	role:costItems(cost, {log = {desc = "itemCompose", int1 = itemId, int2 = count}})
 	role:award({[itemId] = count}, {log = {desc = "itemCompose"}})
@@ -187,6 +187,9 @@ function _M.online(query)
 	return count
 end
  
+function _M.dbqlen(query)
+	return skynet.call(redisd, "debug", "INFO")
+end
  
 function _M.account_init(query, body)
 	if not query.id  or not body or body == "" then return "指令不存在" 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
@@ -69,7 +69,7 @@ function _M.startQuestRpc(agent, data)
             needHeroCnt = it[2]
         end
     end
-    for _, heroId in ipairs(heros) do
+    for _, heroId in pairs(heros) do
         local hero = role.heros[heroId]
         if hero then
             needHeroCnt = needHeroCnt - 1
@@ -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
  
@@ -724,11 +724,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 +808,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
@@ -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
@@ -356,11 +356,6 @@ skynet.start(function()
 		return info
 	end)
  
-	redisd = skynet.localname(".redis")
-	if tonumber(skynet.getenv "logd") == 1 then
-		logd = skynet.localname(".log")
-	end
-
 	cs = queue()
  
 	pvpd = skynet.localname(".pvpcross")
-Subproject commit 295feade86593a4793972e2cd2d83135d8aee247
+Subproject commit 591f2b4097214f9f5bf3b746f86ac704cbc9ea44
@@ -2,23 +2,41 @@ local skynet = require &quot;skynet&quot;
  
 local max_client = tonumber(skynet.getenv("max_client"))
 local max_queue = tonumber(skynet.getenv("max_queue"))
+local work_count = tonumber(skynet.getenv("thread"))
+local use_logd = tonumber(skynet.getenv("logd"))
  
 skynet.start(function()
 	print("Server start")
 	skynet.newservice("debug_console", tonumber(skynet.getenv("debug_port")))
  
+
+	-- 启动redis
+	for i = 1, work_count do
+		local redisd = skynet.newservice("services/redisd", i)
+		skynet.call(redisd, "lua", "open", {
+			redishost = skynet.getenv("redis_host"),
+			redisport = tonumber(skynet.getenv("redis_port")),
+			redisdb = tonumber(skynet.getenv("redis_db")),
+			auth = skynet.getenv("redis_auth")
+		})
+	end
+
+	--启动log
+	if use_logd == 1 then
+		for i = 1, work_count * 2 do
+			local logd = skynet.newservice("services/logd", i)
+			skynet.call(logd, "lua", "open")
+		end
+	end
+
 	local httpd = skynet.newservice("services/httpweb", tonumber(skynet.getenv("httpweb_port")))
 	local watchdog = skynet.newservice("services/watchdog", max_client)
  
+
 	skynet.call(watchdog, "lua", "start", {
 		port = tonumber(skynet.getenv("server_port")),
 		maxclient = max_client + max_queue + 10,
 		httpd = httpd,
-
-		redishost = skynet.getenv("redis_host"),
-		redisport = tonumber(skynet.getenv("redis_port")),
-		redisdb = tonumber(skynet.getenv("redis_db")),
-		auth = skynet.getenv("redis_auth"),
 	})
  
 	skynet.exit()
@@ -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,8 @@ Activity.schema = {
 	act18		= {"table", {}, true},	  -- {id=兑换数量}
 	act19		= {"number", 0},	  -- {挂机信息}
 	act20		= {"table", {}},	  -- {id=扭蛋抽出数量}
+
+	act26 		= {"table", {}},	-- {task = {id = count}, socre = {id = status}}
 }
  
 function Activity:data()
@@ -153,7 +167,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
  
@@ -179,6 +198,7 @@ function Activity:checkActivityStatus(now, isCrossDay, notify)
  
 		if isOpen then
 			if actime[actId] and actime[actId] == startTime then -- 还是之前的状态 开放中
+				self:onLoginActivity(actId)
 			else  -- 重置
 				actime[actId] = startTime
 				self:closeActivity(actId, notify, true)
@@ -419,7 +439,8 @@ activityFunc[Activity.ActivityType.CalendaTask] = {
 		local towerInfo = role:getProperty("towerInfo")
 		role:checkTaskEnter("TowerPass", {level = towerInfo.l})
 		--"PvpWin"
-		role:checkTaskEnter("HangPass", {})
+		--role:checkTaskEnter("HangPass", {id = 0})
+		role:checkCalendaTask(true, 15, 3)
 		role:checkTaskEnter("HeroStarCollect", {})
 		role:checkTaskEnter("RuneQualityCollect", {})
  
@@ -475,7 +496,8 @@ activityFunc[Activity.ActivityType.Gachakon] = {
 activityFunc[Activity.ActivityType.HangDrop] = {
 	["init"] = function(self, actType, isCrossDay, notify, actId)
 		local actime = self:getProperty("actime")
-		local startTime = actime[actId]
+		local ctime = self.owner:getProperty("ctime")
+		local startTime = math.max(actime[actId], ctime)
 		local actData = self:getActData(actType) or 0
 		local cfg = csvdb["activity_putCsv"][actId]
 		if not cfg then return end
@@ -484,11 +506,30 @@ activityFunc[Activity.ActivityType.HangDrop] = {
 	end
 }
  
+--ChallengeLevel
+activityFunc[Activity.ActivityType.ChallengeLevel] = {
+	["init"] = function(self, actType, isCrossDay, notify, actId)
+		self:getBattleTicket(actId)
+	end,
+	["login"] = function(self, actType, actId)
+		self:getBattleTicket(actId)
+	end
+}
+
+function Activity:onLoginActivity(actId)
+	local actData = csvdb["activity_ctrlCsv"][actId]
+	if not actData then return end
+	local actType = actData.showType
+	if activityFunc[actType] and activityFunc[actType]['login'] then
+		activityFunc[actType]["login"](self, actType, actId)
+	end
+end
+
 function Activity:initActivity(actId, isCrossDay, notify)
 	local actData = csvdb["activity_ctrlCsv"][actId]
 	if not actData then return end
 	local actType = actData.showType
-	if activityFunc[actType] and activityFunc[actType]['close'] then
+	if activityFunc[actType] and activityFunc[actType]['init'] then
 		activityFunc[actType]["init"](self, actType, isCrossDay, notify, actId)
 	end
 end
@@ -633,5 +674,93 @@ function Activity:recycleActItem(actId)
 	end
 end
  
+-- 活动挑战关卡计算门票
+function Activity:getBattleTicket(actId)
+	local role = self.owner
+	local createTs = role:getProperty("ctime")
+	local actCfg = csvdb["activity_ctrlCsv"][actId]
+	if not actCfg then return 0 end
+
+	local actStartTime = 0
+	local openTimes = actCfg.time:toArray(false, "=")
+	actStartTime = toUnixtime(openTimes[1]..string_format("%02x", RESET_TIME))
+	local actData = self:getActData("ChallengeLevel") or {}
+	local startTs = actData["ts"] or math.max(actStartTime, createTs)
+	local timeNow = skynet.timex()
+	local modify = false
+	local arr = actCfg.condition2:toArray(true, "=")
+
+	local ticketId, init, limit, duration = arr[1] or 0, arr[2] or 0, arr[3] or 0, arr[4] or 10000
+
+	local count = actData["ticket"] or init
+	local add = math.max(math.floor((timeNow - startTs) / (duration * 60)), 0)
+
+	local newCount= math.min(count + add, limit)
+	if newCount ~= count or newCount >= limit then
+		modify = true
+	end
+	add = newCount - count
+
+	if modify or not next(actData) then
+		actData["ticket"] = newCount
+		actData["ts"] = newCount >= limit and timeNow or (startTs + add * duration * 60)
+		self:updateActData("ChallengeLevel", actData)
+	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 = csvData["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
@@ -16,6 +16,7 @@ local BattleType = {
 	bonus = 300,
 	pvpc = 500,
 	pvph = 501,
+	act_battle = 502,
 }
  
 RoleBattle.bind = function (Role)
@@ -43,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")
@@ -58,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)
@@ -73,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)
@@ -86,8 +87,22 @@ function Role:checkBattle(battleType, params)
 				enemylist[#enemylist + 1] = one["unitType"]
 			end
 		end,
+		act_battle = function()
+			for slot, hero in pairs(self:getTeamHerosInfo(params).heros) do
+				selflist[slot] = hero.type
+			end
+			heroscore = self:getTeamBattleValue(params.heros)
+			for slot , one in pairs(params.supports) do
+				teamskill[one[1]] = one[2]
+			end
+			local carbonData = params.cfg
+			local monsterData = csvdb[carbonData.monster:match("/([^/]*)$") .. "Csv"]
+			for slot, one in pairs(monsterData[1]) do
+				enemylist[#enemylist + 1] = one["unitType"]
+			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")
@@ -109,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
@@ -163,7 +178,7 @@ function Role:checkBattle(battleType, params)
 		mission_starttime = clientInfo.start or 0, -- 战斗开始时间，格式 unixtime 秒级
 		mission_roundtime = clientInfo.atime or 0, -- 对局时长(秒)
 		mission_result = params.isWin and 1 or 2, -- 战斗结果(0-无效，1-胜利，2-失败)
-		mission_star = 0, -- 战斗完成星数，无星级的话填写0
+		mission_star = params.star or 0, -- 战斗完成星数，无星级的话填写0
 		mission_restriction = 0, -- 周期内参与限制(0表示没有上限)
 		mission_difficulty = 0, -- 关卡困难度，无难度区分的话填写0
 		mission_strength = 1, -- 消耗的体力或次数
@@ -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
 local serverId = skynet.getenv("servId")
 local server_id = (skynet.getenv("serverType") or "localtest") .. "_" .. serverId
+local logproxy = require "shared.logproxy"
  
 --[[
 	100	购买/兑换行为			
@@ -47,6 +48,8 @@ local ItemReason = {
 	actGachakon = 132, 	-- 扭蛋活动
 	totalRecharge = 133, -- 累计充值奖励
 	actHangDrop = 134, -- 掉落活动奖励
+	actBattle = 135, -- 活动关卡
+	actMilestone = 136,	-- 活动关卡boss伤害里程碑
  
  
 	advHang = 301, -- 拾荒挂机
@@ -249,13 +252,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", -- 铭文装备编号，用以关联一次装备时产生的多条日志
@@ -285,7 +281,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 = { --装备穿戴与卸载
@@ -293,8 +289,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，用以关联一次性装备时候产生的多条记录
 	},
@@ -411,6 +407,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
@@ -502,6 +499,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)
@@ -763,8 +781,7 @@ function RoleLog.bind(Role)
 				end
 			end
 		end
-		if not logd then return end
-		pcall(skynet.send, logd, "lua", "log", doc, "bi")
+		logproxy:log(doc, "bi")
 	end
  
 	function Role:logItems(itemId, before, after, log)
@@ -823,8 +840,7 @@ function RoleLog.bind(Role)
 			end
 		end
 		doc["@type"] = logType
-		if not logd then return end
-		pcall(skynet.send, logd, "lua", "log", doc, "log")
+		logproxy:log(doc, "log")
 	end
  
  
@@ -1014,6 +1014,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 +1177,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 +1325,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 +1336,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 +1357,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 +1405,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 +1421,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
@@ -1578,7 +1583,12 @@ function RolePlugin.bind(Role)
 	    local rechargeRecord = self:getProperty("payR") or {}
 	    if limit ~= 0 and limit <= (rechargeRecord[rechargeId] or 0) then
 	        return ""
-	    end
+		end
+		
+		--判断是否是活动商品
+		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
  
 	    local orderId = redisproxy:hget(string.format(R_ORDERS, roleId), rechargeId)
 	    if orderId then
@@ -1596,6 +1606,7 @@ function RolePlugin.bind(Role)
 			key = orderKey, 
 			order = partnerOrderId, 
 			rechargeId = rechargeId, 
+			createTime = skynet.timex(),
 		})
 		order:create()
 		-- 正在进行中的订单 缓存
@@ -1639,7 +1650,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)
@@ -1929,6 +1940,53 @@ function RolePlugin.bind(Role)
 		end
 		deleteNotify({pattern = pattern})
 	end
+
+	local CommonRankTime = toUnixtime("2019010100")
+	local CommonCoef1 = 10000
+	local CommonCoef2 = 10000
+	function Role:updateRankCommon(rankType, rankVal, reserve)
+		if not rankType then return end
+		reserve = reserve or 0
+		local now = skynet.timex()
+		local ct = math.ceil((now - CommonRankTime) / 86400) --按天计算  365 * 27 < 10000  可以维持 27 年
+		ct = 10000 - ct  -- 越早的排名越靠前
+		local score = (rankVal * CommonCoef1 + ct) * CommonCoef2 + reserve
+
+		local roleId = self:getProperty("id")
+		redisproxy:pipelining(function (red)
+			red:zadd(RANK_COMMON..rankType, score, roleId)	--更新分数
+		end)
+	end
+
+	function Role:getRankInfoCommon(rankType)
+		if not rankType then return end
+		local list = {}
+		local rankKey = RANK_COMMON .. rankType
+		local ids = redisproxy:zrevrange(rankKey, 0 , 99, "WITHSCORES")
+		for i = 1, #ids, 2 do
+			local roleId = tonumber(ids[i])
+			local rankVal = tonumber(ids[i + 1])
+			rankVal = math.floor(math.floor(rankVal / CommonCoef2) / CommonCoef1)
+			table.insert(list, {roleId = roleId, player = rankVal})
+		end
+
+		for _, v in ipairs(list) do
+			local _, curInfo = rpcRole(v.roleId, "friendSInfo")
+			curInfo.ltime = nil
+			curInfo.rankVal = v.player
+			v.player = curInfo
+		end
+
+		local rank = redisproxy:ZREVRANK(rankKey, self:getProperty("id"))
+		if not rank then
+			rank = -1
+		else
+			rank = rank + 1
+		end
+		return {list = list, rank = rank}
+	end
+
+
 end
  
 return RolePlugin
 \ No newline at end of file
@@ -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})
@@ -6,6 +6,7 @@ local xxtea = require &quot;xxtea&quot;
 local deque = require "deque"
 local datacenter = require "skynet.datacenter"
 local agent_queued = require "services.agent_queued"
+local logproxy = require "shared.logproxy"
  
 local pcall = pcall
 local string_format = string.format
@@ -139,11 +140,11 @@ function _M:check_agent_status()
 		end
 	end
  
-	if now >= next_log_time and now % 60 == 0 and logd then
+	if now >= next_log_time and now % 60 == 0 then
 		next_log_time = now + 60
 		local count = table_nums(self.u2f)
 		datacenter.set("onlineCount", count)
-		pcall(skynet.send, logd, "lua", "log", {["@type"] = "online", count = count}, "log")
+		logproxy:log({["@type"] = "online", count = count}, "log")
 	end
 end
  
@@ -34,8 +34,6 @@ local steps = {
 }
  
 skynet.start(function ()
-	redisd = skynet.localname(".redis")
-
 	redisproxy = require("shared.redisproxy")
  
 	local new = redisproxy:hsetnx("autoincrement_set", "server_start", os.date("%Y%m%d", skynet.timex())) == 1
@@ -7,6 +7,7 @@ require &quot;shared.init&quot;
 require "utils.init"
 require "RedisKeys"
 require "skynet.manager"
+require "GlobalVar"
  
  
 local ipairs = ipairs
@@ -16,6 +17,7 @@ local string_format = string.format
  
  
 local CHECK_MAIL_STATUS_INTERVAL 	= 100 * 60
+local CHECK_BATTLE_ACT_CLOSE_INTERVAL = 100 * 1
 local function mailQuene()
 	local delayEmail = tonum(redisproxy:hget("autoincrement_set", "delay_email"))
 	if delayEmail == 0 then
@@ -91,6 +93,64 @@ local function check_mail_queue()
 	skynet.timeout(CHECK_MAIL_STATUS_INTERVAL, check_mail_queue)
 end
  
+-- @desc: 检测关卡活动结束 排行榜奖励发放
+local lastCheckBattleActTs = 0
+local function check_battle_act_close()
+	local csvdb = require "shared.csvdata"
+	local act = require "models.Activity"
+	local st = 0
+	local et = 0
+	local actId = 0
+	local timeNow = skynet.timex()
+	for k, v in pairs(csvdb["activity_ctrlCsv"]) do
+		if v.showType == act.ActivityType.ChallengeLevel then
+			local openTimes = v.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
+			actId = k
+			break
+		end
+	end
+	if st ~= 0 and et ~= 0 and actId ~= 0 then
+		-- close
+		if lastCheckBattleActTs < et and timeNow >= et then
+			-- check rank key exist
+			local rankKey = RANK_COMMON..RANK_TYPE.ActBattleBoss
+			local flag = redisproxy:exists(rankKey)
+			if flag then
+				local actData = csvdb["activity_groupCsv"][actId]
+				local lastRank = actData[#actData].rank
+
+				local ids = redisproxy:zrevrange(rankKey, 0 , lastRank - 1)
+				local rankIndex = 0
+				for roleId in pairs(ids) do
+					rankIndex = rankIndex + 1
+					for _, cfg in pairs(actData) do
+						if rankIndex <= cfg.rank then
+							redisproxy:insertEmail({
+								roleId = roleId,
+								emailId = cfg.email_1,
+								attachments = cfg.reward_1,
+								contentPms = {rankIndex},
+							})
+							break
+						end
+					end
+				end
+
+				redisproxy:del(rankKey..":bak")
+				redisproxy:rename(rankKey, rankKey..":bak")
+			end
+		end
+	end
+	lastCheckBattleActTs = skynet.timex()
+	skynet.timeout(CHECK_BATTLE_ACT_CLOSE_INTERVAL, check_battle_act_close)
+end
+
  
  
 local CMD = {}
@@ -115,6 +175,7 @@ end
  
 function CMD.start()
 	check_mail_queue()
+	check_battle_act_close()
 end
  
 local function __init__()
@@ -129,7 +190,6 @@ local function __init__()
 			end
 		end
 	end)
-	redisd = skynet.localname(".redis")
 	skynet.register(".globald")
  
 end
@@ -53,12 +53,8 @@ end
 local CMD = require "actions.HttpAction"
  
 local function start()
-	redisd = skynet.localname(".redis")
 	globalCsv = csvdb["GlobalDefineCsv"]
  
-	if tonumber(skynet.getenv "logd") == 1 then
-		logd = skynet.localname(".log")
-	end
  
 	local listen_socket = socket.listen("0.0.0.0", port)
 	print("Listen web port " .. port)
@@ -77,11 +73,11 @@ local function start()
 					return 
 				end
 				local query = urllib.parse_query(query)
-				if query.key ~= key then
-					response(id, 404)
-					socket.close(id) 
-					return 
-				end
+				-- if query.key ~= key then
+				-- 	response(id, 404)
+				-- 	socket.close(id) 
+				-- 	return 
+				-- end
 				local content = CMD[cmd](query, body)
 				if not content then
 					code = 404
@@ -2,12 +2,12 @@ local skynet = require &quot;skynet&quot;
 local queue = require "skynet.queue"
 local bson = require "bson"
 local socketdriver = require "skynet.socketdriver"
-
 local serverId = tonumber(skynet.getenv("servId"))
  
 require "shared.init"
 require "skynet.manager"
  
+local logdIdx = ...
 local table_insert = table.insert
 local pairs = pairs
 local ipairs = ipairs
@@ -15,6 +15,7 @@ local string_format = string.format
  
 local logId = 0
 local CMD, cs = {}
+local prefix = "wasteland" .. logdIdx .. "S" .. serverId ..  "C" 
  
 local logHandle = {
 	bi = {
@@ -33,7 +34,7 @@ local logHandle = {
 			doc["game_name"] = "wasteland"
 			doc["env"] = "cb"
 			doc["game_name_type"] = "guaji"
-			doc["log_id"] = "wastelandC" .. logId .. "S" .. serverId .. "T" ..  now
+			doc["log_id"] = prefix .. logId .. "T" ..  now
 			logId = (logId + 1) % 10000000
 		end
 	},
@@ -135,7 +136,7 @@ local function __init__()
 	end)
 	cs = queue()
  
-	skynet.register(".log")
+	skynet.register(".logd" .. logdIdx)
 end
  
 skynet.start(__init__)
@@ -289,7 +289,6 @@ end
  
 ------------------------------------------------------
 function CMD.start()
-	redisd = skynet.localname(".redis")
 	globalCsv = csvdb["GlobalDefineCsv"]
  
 	pvpInfo = require("models.Pvpd").new({key = "cross:pvpInfo"})
@@ -3,7 +3,7 @@ require &quot;skynet.manager&quot;
 local redis = require "skynet.db.redis"
  
 local db
-
+local idx = ...
 local command = {}
  
 function command.open(conf)
@@ -25,7 +25,7 @@ skynet.start(function()
 		end
 	end)
 	skynet.info_func(function()
-		skynet.ret(skynet.pack(skynet.call(skynet.self(), "debug", "STAT")))
+		return skynet.stat("mqlen")
 	end)
-	skynet.register ".redis"
+	skynet.register(".redis" .. idx)
 end)
 \ No newline at end of file
 local skynet = require "skynet"
 require "skynet.manager"
-local redisproxy = require "shared.redisproxy"
 local socket = require "skynet.socket"
 local netpack = require "skynet.netpack"
 local datacenter = require "skynet.datacenter"
@@ -47,7 +46,7 @@ function SOCKET.data(fd, msg)
  	end
 end
  
-local use_logd = tonumber(skynet.getenv "logd")
+
  
 -- @desc: agent状态定时检测
 function check_agent_status()
@@ -65,11 +64,7 @@ end
  
 function CMD.start(conf)
 	skynet.call(gate_serv, "lua", "open" , conf)
-	skynet.call(redisd, "lua", "open", conf)
-
-	if use_logd == 1 then
-		skynet.call(logd, "lua", "open")
-	end
+	
 	skynet.call(pvpd, "lua", "start")
 	-- 开启agent状态检测定时器
 	check_agent_status()
@@ -110,17 +105,11 @@ skynet.start(function()
 		end
 	end)
 	skynet.register ".watchdog"
-	-- 数据库服务
-	redisd = skynet.newservice("services/redisd")
  
 	-- 提前加载好
 	csvdata.init()
 	print("launch csvdatad ...")
  
-	-- 日志服务
-	if use_logd == 1 then
-		logd = skynet.newservice("services/logd")
-	end
 	-- pvp 服务
 	pvpd = skynet.newservice("services/pvpd")
 	cluster.register("pvpd", pvpd)
@@ -0,0 +1,23 @@
+
+local skynet = require "skynet"
+local logd_count = tonumber(skynet.getenv("thread")) * 2
+local use_logd = tonumber(skynet.getenv("logd"))
+
+
+local logd
+skynet.init(function()
+	if use_logd then
+		local idx = math.randomInt(1, logd_count)
+		logd = skynet.localname(".logd" .. idx)
+	end
+end)
+
+local logproxy = {}
+
+function logproxy:log(doc, logTo)
+	if use_logd and logd then
+		pcall(skynet.send, logd, "lua", "log", doc, logTo)
+	end
+end
+
+return logproxy
 \ No newline at end of file
 local skynet = require "skynet"
-local harbor = require "skynet.harbor"
+require "utils.init"
+
+local redisd_count = tonumber(skynet.getenv("thread"))
+local redisd
+skynet.init(function()
+	local idx = math.randomInt(1, redisd_count)
+	redisd = skynet.localname(".redis" .. idx)
+end)
  
 local table_insert = table.insert
  
 local redisproxy = {}
  
-
 local isUsePika = false