Merge branch 'tr/bugfix' into cn/develop

熊润斐
2 parents 3fbbd115 4a4ea798
Showing 15 changed files with 358 additions and 9 deletions Show diff stats
src/GlobalVar.lua
src/ProtocolCode.lua
src/RedisKeys.lua
src/actions/HangAction.lua
src/actions/RoleAction.lua
src/actions/StoreAction.lua
src/csvdata
src/models/Activity.lua
src/models/Role.lua
src/models/RoleBattle.lua
src/models/RoleLog.lua
src/models/RolePlugin.lua
src/models/RoleTimeReset.lua
src/services/globald.lua
src/utils/CommonFunc.lua
@@ -16,6 +16,12 @@ TIME_ZONE = math.floor(os.difftime(START_RESET_TIME_BASE, os.time(os.date(&quot;!*t&quot;,
  
 START_RESET_TIME = START_RESET_TIME_BASE - TIME_ZONE * 3600
  
+function weekday(now)
+	local day = math.ceil((now - START_RESET_TIME) % 604800 / 86400)
+	if day == 0 then day = 1 end
+	return day
+end
+
 STRUCT_VERSION = 3 -- 数据结构版本
  
 IOS_SID = 4 -- 判断是不是ios设备
@@ -158,6 +164,11 @@ TimeReset = {
 	DrawType1 = 17, -- 变异 抽卡加成
 	DrawType2 = 18, -- 通常 抽卡加成
 	DrawType3 = 19, -- 魔法 抽卡加成
+	WorkBattle1 = 22, -- 夜间玩法 1
+	WorkBattle2 = 23, -- 夜间玩法 2
+	WorkBattle3 = 24, -- 夜间玩法 3
+	WorkBattle4 = 25, -- 夜间玩法 4
+	WorkBattle5 = 26, -- 夜间玩法 5
 }
  
 -- TimeReset 索引数组
@@ -121,6 +121,10 @@ actionCodes = {
 	Hang_bagFieldRpc = 263,
 	Hang_chatLineRpc = 264,
 	Hang_selectTeamRpc = 265,
+	Hang_startWorkBattleRpc = 266,
+	Hang_endWorkBattleRpc = 267,
+	Hang_workBattleInfoRpc = 268,
+	Hang_getWorkRewardRpc = 269,
  
 	Diner_updateProperty = 300,
 	Diner_addSellRpc = 301,
@@ -62,7 +62,7 @@ FRIEND_ENERGY = &quot;role:%d:energy&quot; -- set 送给我活动能量的好友
 FRIEND_RECOMMEND = "friend:recommend" -- sort set 登录排序 获取推荐好友
 CHAT_OFFLINE = "chat:offline:%d" --消息离线缓存
  
-
+WORK_BATTLE_COUNT = "global:workbattle" -- 世界次数统计
 -- FRIEND_DINER_LIKE_KEY = "role:%d:diner:like" -- list
  
 -- UNION_SET = "global:union"
@@ -750,6 +750,251 @@ function _M.endBonusBattleRpc(agent, data)
 	return true
 end
  
+
+
+local function workWinReward(role, bonusData, rewardType, count, sweep)
+	count = count or 1
+	local reward, change = {}
+	
+
+	reward = bonusData.reward:toNumMap()
+	for itemId, c in pairs(reward) do
+		reward[itemId] = c * count
+	end
+	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
+	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
+	reward, change = role:award(reward, {log = {desc = "workBattle", int1 = bonusData.id}})
+	return reward, change
+end
+
+function _M.workBattleInfoRpc(agent, data)
+	local role = agent.role
+	local msg = MsgPack.unpack(data)
+	local workMainCsv = csvdb["work_mainCsv"][msg.type]
+	if not workMainCsv then return 1 end
+	if not role:isTimeResetOpen(TimeReset["WorkBattle" .. msg.type]) then return 2 end
+	SendPacket(actionCodes.Hang_workBattleInfoRpc, MsgPack.pack({count = tonum(redisproxy:hget(WORK_BATTLE_COUNT, role:getTimeResetRound(TimeReset["WorkBattle" .. msg.type]) * 10 + msg.type))}))
+	return true
+end
+
+
+function _M.getWorkRewardRpc(agent, data)
+	local role = agent.role
+	local msg = MsgPack.unpack(data)
+	local workMainCsv = csvdb["work_mainCsv"][msg.type]
+	if not workMainCsv then return 1 end
+	if not role:isTimeResetOpen(TimeReset["WorkBattle" .. msg.type]) then return 2 end
+	local count = tonum(redisproxy:hget(WORK_BATTLE_COUNT,  role:getTimeResetRound(TimeReset["WorkBattle" .. msg.type]) * 10 + msg.type))
+	if count < workMainCsv.target_num then return 3 end
+	local workBattle = role:getProperty("workBattle")
+	if workBattle[msg.type] ~= 1 then
+		return 4
+	end
+	workBattle[msg.type] = -1
+	role:updateProperty({field = "workBattle", value = workBattle})
+	local reward, change = role:award(workMainCsv.phase_award, {log = {desc = "workReward"}})
+	SendPacket(actionCodes.Hang_getWorkRewardRpc, MsgPack.pack({reward = reward, change = change}))
+	return true
+end
+
+function _M.startWorkBattleRpc(agent, data)
+	local role = agent.role
+	local msg = MsgPack.unpack(data)
+	local id = msg.id
+	local count = msg.count or 1
+
+	if not role:isFuncUnlock(FuncUnlock.BonusBattle) then return 1 end
+
+	local bonusData = csvdb["work_battleCsv"][id]
+
+	if not bonusData then return 3 end
+
+	if not role:isTimeResetOpen(TimeReset["WorkBattle" .. bonusData.type]) then return 2 end
+
+	local ticketId = csvdb["work_mainCsv"][bonusData.type].ticket
+	local workStar = role:getProperty("workStar")
+
+	if bonusData.unlock ~= 0 and (not workStar[bonusData.unlock] or workStar[bonusData.unlock] == 0) then return 4 end
+	local workBattle = role:getProperty("workBattle")
+	workBattle[bonusData.type] = workBattle[bonusData.type] or 0
+	local needCount = count - (workBattle[bonusData.type] == 0 and 1 or 0)
+	if needCount ~= 0 and not role:checkItemEnough({[ticketId] = needCount}) then return 11 end
+
+	if workStar[id] and workStar[id] >= (1 << #bonusData.sweep_condition:toTableArray(true)) - 1 then 
+		if workBattle[bonusData.type] == 0 then
+			workBattle[bonusData.type] = 1
+			role:updateProperty({field = "workBattle", value = workBattle})
+		end
+		if needCount > 0 then
+			role:costItems({[ticketId] = needCount}, {log = {desc = "workBattle", int1 = id}})
+		end
+		redisproxy:hincrby(WORK_BATTLE_COUNT,  role:getTimeResetRound(TimeReset["WorkBattle" .. bonusData.type]) * 10 + bonusData.type, count * bonusData.target_add)
+		local reward, change = workWinReward(role, bonusData, 3, count, true)
+		SendPacket(actionCodes.Hang_startWorkBattleRpc, MsgPack.pack({reward = reward, change = change}))
+	else
+		local bTeam = role:getTeamFormatByType(TeamSystemType.BonusBattle)
+		if not next(bTeam) then return 5 end
+		role.__bonusBattleCache = {
+			key = tostring(math.random()),
+			id = id,
+		}
+		SendPacket(actionCodes.Hang_startWorkBattleRpc, MsgPack.pack({key = role.__bonusBattleCache.key}))
+	end
+
+	return true
+end
+
+function _M.endWorkBattleRpc(agent, data)
+	local role = agent.role
+	local msg = MsgPack.unpack(data)
+	local id = msg.id
+	local key = msg.key
+	local starNum = msg.starNum
+	if not role.__bonusBattleCache then return 1 end
+	
+
+	if role.__bonusBattleCache.id ~= id or role.__bonusBattleCache.key ~= key then 
+		SendPacket(actionCodes.Hang_endWorkBattleRpc, MsgPack.pack({errorCode = 1}))
+		return true
+	end
+	role.__bonusBattleCache = nil
+
+	-- 防作弊
+	if not role:checkBattleCheat("work", {
+		id = id,
+		isWin = starNum and starNum > 0,
+		info = msg.info
+	}) then
+		SendPacket(actionCodes.Hang_endWorkBattleRpc, MsgPack.pack({errorCode = 1}))
+		return true
+	end
+
+	local bonusData = csvdb["work_battleCsv"][id]
+	local ticketId = csvdb["work_mainCsv"][bonusData.type].ticket
+	local reward, change = {}
+
+	local workStar = role:getProperty("workStar")
+	local oldStar = workStar[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 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
+		curStar = 0
+		local sweepConds = bonusData.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
+ 		local status
+ 		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
+ 			local workBattle = role:getProperty("workBattle")
+			workBattle[bonusData.type] = workBattle[bonusData.type] or 0
+			local needCount = 1 - (workBattle[bonusData.type] == 0 and 1 or 0)
+			if workBattle[bonusData.type] == 0 then
+				workBattle[bonusData.type] = 1
+				role:updateProperty({field = "workBattle", value = workBattle})
+			end
+			if needCount > 0 then
+				role:costItems({[ticketId] = needCount}, {log = {desc = "workBattle", int1 = id}})
+			end
+			redisproxy:hincrby(WORK_BATTLE_COUNT,  role:getTimeResetRound(TimeReset["WorkBattle" .. bonusData.type]) * 10 + bonusData.type, bonusData.target_add)
+	 		reward, change = workWinReward(role, bonusData, rewardType)
+	 	end
+ 	else
+ 		curStar = oldStar
+ 	end
+ 	if curStar ~= oldStar then
+ 		workStar[id] = curStar
+ 		role:updateProperty({field = "workStar", value = workStar})
+ 	end
+
+ 	role:checkBattle("work", {
+		id = id,
+		isWin = starNum and starNum > 0,
+		info = msg.info,
+		reward = reward,
+	})
+	role:mylog("hang_action", {desc = "workBattle", short1 = msg.starNum > 0 and 1 or 0, int1 = id})
+
+	SendPacket(actionCodes.Hang_endWorkBattleRpc, MsgPack.pack({
+		starNum = starNum, 
+		reward = reward,
+		change = change
+	}))
+	return true
+end
+
 function _M.hangGiftRpc(agent, data)
 	local role = agent.role
 	local msg = MsgPack.unpack(data)
@@ -161,6 +161,9 @@ function _M.loginRpc( agent, data )
 	role:getAdvData(true) -- 清掉不合格的数据
 	role:advEndlessSeasonCheck(true) -- 冒险赛季更新检查
 	role:checkSeaportTrade() -- 检查海港贸易季活动
+	if not next(role:getProperty("workBattle")) then
+		role:setProperty("workBattle", {round = math.floor((now - START_RESET_TIME) / 604800)})
+	end
  
 	-- 跨天登陆事件
 	local resetMode = role:updateTimeReset(now)
@@ -936,7 +939,15 @@ function _M.taskActiveRpc(agent, data)
 		return
 	end
  
-	local reward, change = role:award(taskData.reward, {log = {desc = "taskActive", int1 = taskType, int2 = taskId}})
+	local needReward = taskData.reward:toNumMap()
+	if taskData.reward_2 ~= 0 then
+		local day = weekday(skynet.timex())
+		local workMainCsv = csvdb["work_mainCsv"][day]
+		if workMainCsv then
+			needReward[workMainCsv.ticket] = taskData.reward_2
+		end
+	end
+	local reward, change = role:award(needReward, {log = {desc = "taskActive", int1 = taskType, int2 = taskId}})
 	role:changeUpdates({
 		{ type = roleField[taskType], field = {"at", taskId}, value = -1 }
 	})
@@ -286,7 +286,7 @@ function _M.shopBuyRpc(agent , data)
  
 	local cost = {[dataSet.icon] = dataSet.cost * count}
  
-	local desc = "unknown"
+	local desc = "unknowShop"
 	if dataSet.shop == 1 then		-- 普通商店
 		desc = "dailyShop"
 		local dailySDD = role.dailyData:getProperty("dailySDD")
-Subproject commit ec92ed50d3d5ff9655b1715239e7fda48f8ef5cb
+Subproject commit 2499d73adbdf6ea3562ce3a815d3189e3a3aab7c
@@ -884,6 +884,11 @@ function Activity:getBattleTicket(actId)
 	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
+	if count >= limit then
+		actData["ts"] = timeNow
+		self:updateActData("ChallengeLevel", actData)
+		return
+	end
 	local add = math.max(math.floor((timeNow - startTs) / (duration * 60)), 0)
  
 	local newCount= math.min(count + add, limit)
@@ -120,6 +120,8 @@ Role.schema = {
 	towerTeams 			= {"table", {}}, 	-- 四个电波塔的队伍
  
 	bonusStar			= {"table", {}}, 	-- 奖励关卡 通关星星  {[id] = 1}  三个二进制位 表示三个星 从低到高  (1 << 0) (1 << 1) (1 << 2)  满星 (1 << 3) - 1
+	workStar			= {"table", {}},	-- 夜间玩法 通关星星  {[id] = 1}  三个二进制位 表示三个星 从低到高  (1 << 0) (1 << 1) (1 << 2)  满星 (1 << 3) - 1
+	workBattle 			= {"table", {}},	-- 夜间玩法记录 {[1] = 1, [2] = 1, [3] = 1,  [4] = 1, round = 10} -- 第N天打了多少次 round 轮次
  
 	--引导相关
 	newerGuide 			= {"string","1=1"}, -- 新手引导 master=slave
@@ -379,6 +381,8 @@ function Role:data()
 		towerTeams = self:getProperty("towerTeams"),
  
 		bonusStar = self:getProperty("bonusStar"),
+		workStar = self:getProperty("workStar"),
+		workBattle = self:getProperty("workBattle"),
  
 		newerGuide = self:getProperty("newerGuide"),
 		funcGuide = self:getProperty("funcGuide"),
@@ -17,6 +17,7 @@ local BattleType = {
 	pvpc = 500,
 	pvph = 501,
 	act_battle = 502,
+	work = 301,
 }
  
 RoleBattle.bind = function (Role)
@@ -127,6 +128,18 @@ function Role:checkBattleCheat(battleType, params)
 		-- local carbonData = csvdb["bonus_battleCsv"][params.id]
 		-- enemyServer = packBattleEnemyCommon(carbonData)
 	end
+	cheat["work"] = function()
+		local team = self:getTeamBattleInfo(self:getTeamFormatByType(TeamSystemType.BonusBattle))
+		for slot, hero in pairs(team.heros) do
+			local temp = {}
+			for arr, _ in pairs(checkCheatAttrs) do
+				temp[arr] = hero[arr]
+			end
+			selfTeamServer[hero.type] = temp
+		end
+		-- local carbonData = csvdb["bonus_battleCsv"][params.id]
+		-- enemyServer = packBattleEnemyCommon(carbonData)
+	end
 	cheat["pvpc"] = function()
 		if not params.format then return end
 		local team = self:getTeamBattleInfo(params.format)
@@ -58,6 +58,7 @@ local ItemReason = {
 	newSign = 142,-- 新的活动签到
 	advLevelStage = 143, -- 拾荒活动阶段奖励
 	towerBnous = 144, -- 爬塔到一定层数对某些功能的奖励
+	unknowShop = 145, -- 未知商店
  
  
 	advHang = 301, -- 拾荒挂机
@@ -72,6 +73,8 @@ local ItemReason = {
 	towerBattle = 310, -- 电波塔战斗
 	advOver = 311, -- 冒险结算
 	advUnlock = 312, -- 拾荒解锁
+	workBattle = 313, -- workBattle夜间打工
+	workReward = 314, -- workBattle夜间打工 阶段奖励
  
 	dinerFinishTask = 401, -- 餐厅完成任务
 	storybookReward = 402, -- 剧情奖励
@@ -144,7 +144,9 @@ function RolePlugin.bind(Role)
 				self:addPotion({id = itemId, count = count, notNotify = pms.notNotify, log = pms.log})
 			end,
 			[ItemType.BossTicket] = function ()
-				if not self.activity:isOpen("ChallengeLevel") then return end
+				local isOpen, actId = self.activity:isOpen("ChallengeLevel")
+				if not isOpen then return end
+				self.activity:getBattleTicket(actId)
 				local actData = self.activity:getActData("ChallengeLevel")
 				actData["ticket"] = (actData["ticket"] or 0) + count
 				self.activity:updateActData("ChallengeLevel", actData)
@@ -861,7 +863,6 @@ function RolePlugin.bind(Role)
 			if not params.notNotify then
 				local response = {}
 				table.insert(response, newSpark:data())
-				dump(response)
 				SendPacket(actionCodes.Role_loadSparks, MsgPack.pack(response))
 			end
 			--self:checkTaskEnter("AddRune", {id = params.id, type = params.type, rarity = data.rarity}, params.notNotify)
@@ -1352,7 +1353,7 @@ function RolePlugin.bind(Role)
 				for idx, set in ipairs(csvdb["seaport_purchaseCsv"]) do
 					local done = true
 					for id, data in ipairs(set) do
-						if donate[id] or not result[idx] or not result[idx][id] or result[idx][id] < data.need_num then
+						if donate[idx] or not result[idx] or not result[idx][id] or result[idx][id] < data.need_num then
 							done = false
 							break
 						end
@@ -33,6 +33,38 @@ ResetFunc[&quot;CrossDay&quot;] = function(self, notify, response, now)
 		self:checkReturner()
 	end
  
+	-- 检查 夜间打工
+	local workBattle = self:getProperty("workBattle")
+	local need = {}
+	for i = 1, 5 do
+		if workBattle[i] == 1 then
+			need[#need + 1] = workBattle.round * 10 + i
+		end
+	end
+	local change = false
+	if next(need) then
+		local ret = redisproxy:hmget(WORK_BATTLE_COUNT, table.unpack(need))
+		for idx, v in ipairs(need) do
+			local ctype = v % 10
+			local ccount = tonum(ret[idx])
+			local workMainCsv = csvdb["work_mainCsv"][ctype]
+			if ccount >= workMainCsv.target_num then 
+				self:sendMail(workMainCsv.email, nil, workMainCsv.phase_award)
+			end
+			workBattle[ctype] = -1
+		end
+		change = true
+	end
+	local newRound = math.floor((now - START_RESET_TIME) / 604800)
+	if newRound ~= workBattle.round then
+		workBattle = {round = newRound}
+		change = true
+	end
+	if change then
+		self:setProperty("workBattle", workBattle)
+		response.workBattle = workBattle
+	end
+
 	response.dTask = {}
 	response.advSup = self:getProperty("advSup")
 	self:log("onLogin")
@@ -245,6 +245,23 @@ local function check_trade_seaport_donate()
 	skynet.timeout(interval * 100, check_trade_seaport_donate)
 end
  
+local function check_work_battle()
+	local csvdb = require "shared.csvdata"
+	local now = skynet.timex()
+	local day = weekday(now)
+	local workMainCsv = csvdb["work_mainCsv"][day]
+	if workMainCsv and isSpecTime(now - RESET_TIME * 3600, csvdb["time_resetCsv"][TimeReset["WorkBattle1"]].start / 3600, 24) then
+		local round = math.floor((now - START_RESET_TIME) / 604800)
+		local field = round * 10 + day
+		local count = tonum(redisproxy:hget(WORK_BATTLE_COUNT, field))
+		if count < workMainCsv.target_num then
+			local add = math.floor(workMainCsv.target_num * math.randomInt(3125, 5000) / 100000)
+			redisproxy:hincrby(WORK_BATTLE_COUNT, field, add)
+		end
+	end
+	skynet.timeout(math.randomInt(10 * 60, 15 * 60) * 100, check_work_battle)
+end
+
 local CMD = {}
  
  
@@ -266,10 +283,12 @@ end
  
  
 function CMD.start()
+	math.randomInit(skynet.timex())
 	check_mail_queue()
 	--check_battle_act_close()
 	check_trade_seaport_status()
 	check_trade_seaport_donate()
+	check_work_battle()
 end
  
 local function __init__()
@@ -235,8 +235,9 @@ function specMonday(now)
 	return time - (wday - 1) * 86400
 end
  
-function isSpecTime(startHour, endHour, specday)
-	local tm = os.date("*t", skynet.timex())
+function isSpecTime(ctime, startHour, endHour, specday)
+	ctime = ctime or skynet.timex()
+	local tm = os.date("*t", ctime)
 	if specday then
 		local day = (tm.wday+6)%7
 		if day == 0 then day = 7 end