|
|
@@ -0,0 +1,875 @@
|
|
|
+-- 跨服商业活动-巅峰战场
|
|
|
+
|
|
|
+-- db
|
|
|
+-- human.db.ServerCommerce.battleGround = {
|
|
|
+-- heroBag = {}, -- 英雄背包
|
|
|
+-- isHaveNewHero = false, -- 是否获得新英雄
|
|
|
+-- unLockIdx = 0, -- 英雄解锁层数
|
|
|
+-- freeChallengeCnt = 5, -- 免费挑战次数
|
|
|
+-- lastResetTime = 1123156, -- 上一次重置免费挑战次数的时间戳
|
|
|
+-- lineUp = { -- 战斗阵容数据
|
|
|
+-- formation = 1,
|
|
|
+-- heroList = {},
|
|
|
+-- },
|
|
|
+-- matchList = {rank1, rank2, rank3, rank4, rank5}, -- 对手列表
|
|
|
+-- }
|
|
|
+
|
|
|
+local Msg = require("core.Msg")
|
|
|
+local Timer = require("core.Timer")
|
|
|
+local Config = require("Config")
|
|
|
+local Grid = require("bag.Grid")
|
|
|
+local BagLogic = require("bag.BagLogic")
|
|
|
+local ObjHuman = require("core.ObjHuman")
|
|
|
+local MailExcel = require("excel.mail")
|
|
|
+local MailManager = require("mail.MailManager")
|
|
|
+local Util = require("common.Util")
|
|
|
+local Lang = require("common.Lang")
|
|
|
+local Broadcast = require("broadcast.Broadcast")
|
|
|
+local InnerMsg = require("core.InnerMsg")
|
|
|
+local RoleHeadLogic = require("role.RoleHeadLogic")
|
|
|
+local ServerCommerceManager = require("serverCommerce.ServerCommerceManager")
|
|
|
+local ServerCommerceActDefine = require("serverCommerce.ServerCommerceActDefine")
|
|
|
+local battleGroundConfig = require("excel.ServerCommerceBattleGround")
|
|
|
+local MonsterExcel = require("excel.monster")
|
|
|
+local HeroConfig = require("excel.hero").hero
|
|
|
+local HeroDefine = require("hero.HeroDefine")
|
|
|
+local CombatDefine = require("combat.CombatDefine")
|
|
|
+local CombatLogic = require("combat.CombatLogic")
|
|
|
+local CombatPosLogic = require("combat.CombatPosLogic")
|
|
|
+local MiddleCommonLogic = require("middle.MiddleCommonLogic")
|
|
|
+local RoleDBLogic = require("role.RoleDBLogic")
|
|
|
+local Log = require("common.Log")
|
|
|
+
|
|
|
+
|
|
|
+local rankListCache = {}
|
|
|
+local lastGetRankListTime = 0
|
|
|
+local LOGTYPE = "ServerCommerceActBattleGround"
|
|
|
+
|
|
|
+
|
|
|
+local function writeLog(logStr)
|
|
|
+ Log.write(Log.LOGID_OSS_COMMON_ACT, logStr)
|
|
|
+end
|
|
|
+
|
|
|
+-- 玩家排名下降, 通过邮件通知
|
|
|
+local function rankReduceMail(mailId, receiverUuid, arg)
|
|
|
+ if not mailId or not receiverUuid then
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ local mailCfg = MailExcel.mail[mailId]
|
|
|
+ local content = mailCfg.content
|
|
|
+ if arg then
|
|
|
+ content = Util.format(content, arg[1], arg[2], arg[3])
|
|
|
+ end
|
|
|
+ MailManager.add(MailManager.SYSTEM, receiverUuid, mailCfg.title, content, nil, mailCfg.senderName or "GM")
|
|
|
+end
|
|
|
+
|
|
|
+-- 排行奖励邮件
|
|
|
+local function sendAwardMail(mailId, receiverUuid, itemArray)
|
|
|
+ local mailCfg = MailExcel.mail[mailId]
|
|
|
+ local content = mailCfg.content
|
|
|
+ MailManager.add(MailManager.SYSTEM, receiverUuid, mailCfg.title, content, itemArray, mailCfg.senderName or "GM")
|
|
|
+end
|
|
|
+
|
|
|
+-- 创建一个发奖queue
|
|
|
+local function createRewardQueue()
|
|
|
+ local issueRewardQueue = {
|
|
|
+ playerArray = {},
|
|
|
+ insertMaxNum = 100, -- 一次最多插入数据库的邮件数量
|
|
|
+ repeatMaxTimes = 3, -- 重试次数
|
|
|
+ repeatTb = {},
|
|
|
+ extraInfo = {},
|
|
|
+ }
|
|
|
+
|
|
|
+ function issueRewardQueue:add(playerInfo)
|
|
|
+ table.insert(self.playerArray, playerInfo)
|
|
|
+ end
|
|
|
+
|
|
|
+ function issueRewardQueue:insertDB()
|
|
|
+ local maxNum = math.min(self.insertMaxNum, #self.playerArray)
|
|
|
+ local mailId = battleGroundConfig.var[1].rankAwardMailId
|
|
|
+ for i=1, maxNum do
|
|
|
+ local resTag = ServerCommerceActDefine.BG_MAIL_SUCC_TAG
|
|
|
+ local playerInfo = table.remove(self.playerArray)
|
|
|
+ local rank = playerInfo[1]
|
|
|
+ local playerUuid = playerInfo[2]
|
|
|
+
|
|
|
+ local ok, err = pcall(sendAwardMail, mailId, playerUuid, playerInfo[3])
|
|
|
+
|
|
|
+ if not ok then
|
|
|
+ if not self.repeatTb[playerUuid] or self.repeatTb[playerUuid] < self.repeatMaxTimes then
|
|
|
+ issueRewardQueue:add(playerInfo)
|
|
|
+ self.repeatTb[playerUuid] = (self.repeatTb[playerUuid] or 0) + 1
|
|
|
+ end
|
|
|
+
|
|
|
+ resTag = ServerCommerceActDefine.BG_MAIL_FAIL_TAG
|
|
|
+ end
|
|
|
+
|
|
|
+ -- 写入日志
|
|
|
+ local str = string.format("ServerCommerceActBattleGround PrizeAward result: %s, playerUuid: %s, insertErrTimes: %d, errInfo: %s",
|
|
|
+ resTag, playerUuid, self.repeatTb[playerUuid] or 0, err)
|
|
|
+
|
|
|
+ writeLog(str)
|
|
|
+ end
|
|
|
+
|
|
|
+ if #self.playerArray > 0 then
|
|
|
+ Timer.addLater(2, self.insertDB, self)
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ return issueRewardQueue
|
|
|
+end
|
|
|
+
|
|
|
+
|
|
|
+-- 是否处于活动中
|
|
|
+local function isRunning()
|
|
|
+ return true == ServerCommerceManager.CommerceAct_IsRun()
|
|
|
+end
|
|
|
+
|
|
|
+-- 生成对手算法
|
|
|
+local function matchListAlgorithm(rank)
|
|
|
+ -- 输入验证
|
|
|
+ if not rank or type(rank) ~= "number" or rank < 1 or rank > ServerCommerceActDefine.COMMERCEACT_NPC_CNT then
|
|
|
+ return {} -- 返回空列表或根据需求处理错误
|
|
|
+ end
|
|
|
+
|
|
|
+ local matchList = {}
|
|
|
+ local usedRanks = {}
|
|
|
+
|
|
|
+ -- 确保玩家自己不会被选为对手
|
|
|
+ usedRanks[rank] = true
|
|
|
+
|
|
|
+ -- 计算抽取范围
|
|
|
+ local minRank = math.max(1, rank - 50)
|
|
|
+ local maxRank = math.min(ServerCommerceActDefine.COMMERCEACT_NPC_CNT, rank + 10)
|
|
|
+
|
|
|
+ -- 生成所有可能的对手排名
|
|
|
+ local possibleRanks = {}
|
|
|
+ for i = minRank, maxRank do
|
|
|
+ if not usedRanks[i] then
|
|
|
+ table.insert(possibleRanks, i)
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ -- 如果可用对手不足5个，则返回所有可能的对手
|
|
|
+ local numToSelect = math.min(5, #possibleRanks)
|
|
|
+
|
|
|
+ if numToSelect == 0 then
|
|
|
+ return {}
|
|
|
+ end
|
|
|
+
|
|
|
+ -- 随机抽取指定数量的对手
|
|
|
+ for i = 1, numToSelect do
|
|
|
+ -- 从剩余可选排名中随机选择一个
|
|
|
+ local randomIndex = math.random(#possibleRanks)
|
|
|
+ local selectedRank = possibleRanks[randomIndex]
|
|
|
+
|
|
|
+ -- 添加到匹配列表
|
|
|
+ table.insert(matchList, selectedRank)
|
|
|
+
|
|
|
+ -- 从可选列表中移除已选中的排名
|
|
|
+ table.remove(possibleRanks, randomIndex)
|
|
|
+
|
|
|
+ -- 标记为已使用
|
|
|
+ usedRanks[selectedRank] = true
|
|
|
+ end
|
|
|
+
|
|
|
+ return matchList
|
|
|
+end
|
|
|
+
|
|
|
+-- 填充协议英雄数据
|
|
|
+local function populateHeroMsg(net, heroId, heroConfig, heroLv, heroStar)
|
|
|
+ net.heroHeadId = heroConfig.head
|
|
|
+ net.heroName = heroConfig.name
|
|
|
+ net.heroCamp = heroConfig.camp
|
|
|
+ net.heroLv = heroLv
|
|
|
+ net.heroStar = heroStar
|
|
|
+ net.heroGrade = heroConfig.grade
|
|
|
+ net.heroBodyId = heroConfig.body
|
|
|
+ net.heroId = heroId
|
|
|
+end
|
|
|
+
|
|
|
+-- 获取可以解锁的英雄信息
|
|
|
+local function getUnlockHeroInfoByRank(rank)
|
|
|
+ local unLockHero = battleGroundConfig.unLockHero
|
|
|
+ for idx, cfg in ipairs(unLockHero) do
|
|
|
+ if rank >= cfg.unLockRankArea[1] and rank <= cfg.unLockRankArea[2] then
|
|
|
+ return idx, cfg.unLockHeroInfo
|
|
|
+ end
|
|
|
+ end
|
|
|
+end
|
|
|
+
|
|
|
+-- 解锁英雄
|
|
|
+local function unlockHero(human, unlockHeroInfo, isInit)
|
|
|
+ human.db.ServerCommerce.battleGround = human.db.ServerCommerce.battleGround or {}
|
|
|
+ local battleGroundData = human.db.ServerCommerce.battleGround
|
|
|
+ battleGroundData.heroBag = battleGroundData.heroBag or {}
|
|
|
+ local heroBagData = battleGroundData.heroBag
|
|
|
+
|
|
|
+ if #unlockHeroInfo == 0 then
|
|
|
+ for heroId, heroCfg in pairs(HeroConfig) do
|
|
|
+ if heroCfg.grade >= HeroDefine.HERO_SSR_GRADE and not table.find(heroBagData, heroId) then
|
|
|
+ heroBagData[#heroBagData+1] = heroId
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ battleGroundData.isHaveNewHero = true
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ local heroList = {}
|
|
|
+ for heroId, heroCfg in pairs(HeroConfig) do
|
|
|
+ if heroCfg.grade >= HeroDefine.HERO_SSR_GRADE and not table.find(heroBagData, heroId) then
|
|
|
+ heroList[heroId] = heroCfg
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ for _, heroCond in ipairs(unlockHeroInfo) do
|
|
|
+ local campCond = heroCond[1] or 0
|
|
|
+ local numCond = heroCond[2] or 0
|
|
|
+ for i=1, numCond do
|
|
|
+ for heroId, heroCfg in pairs(heroList) do
|
|
|
+ if heroCfg.camp == campCond and not table.find(heroBagData, heroId) then
|
|
|
+ heroBagData[#heroBagData+1] = heroId
|
|
|
+ break
|
|
|
+ end
|
|
|
+ end
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ battleGroundData.isHaveNewHero = true
|
|
|
+ if isInit then
|
|
|
+ battleGroundData.isHaveNewHero = false
|
|
|
+ end
|
|
|
+end
|
|
|
+
|
|
|
+-- 获取上阵英雄
|
|
|
+local function getLineupHeroArr(human)
|
|
|
+ local heroArr
|
|
|
+ local battleGroundData = human.db.ServerCommerce.battleGround
|
|
|
+ local lineUpData = battleGroundData.lineUpData
|
|
|
+ for _, heroId in ipairs(lineUpData.heroList) do
|
|
|
+ if heroId and heroId ~= 0 then
|
|
|
+ heroArr = heroArr or {}
|
|
|
+ heroArr[#heroArr+1] = heroId
|
|
|
+ end
|
|
|
+ end
|
|
|
+ return heroArr
|
|
|
+end
|
|
|
+
|
|
|
+-- 生成玩家的展示数据
|
|
|
+local function populatePlayerShowData(human, showData, rank)
|
|
|
+ showData.rank = rank
|
|
|
+ showData.serverId = Config.SVR_INDEX
|
|
|
+ showData.playerUuid = human.db._id
|
|
|
+ showData.name = human.db.name
|
|
|
+ showData.bodyId = RoleHeadLogic.GetRoleAdornInfo(human, RoleHeadLogic.HEAD_TYPE_3) or 0
|
|
|
+ showData.headId = RoleHeadLogic.GetRoleAdornInfo(human, RoleHeadLogic.HEAD_TYPE_1) or 0
|
|
|
+ showData.headFrameId = RoleHeadLogic.GetRoleAdornInfo(human, RoleHeadLogic.HEAD_TYPE_2) or 0
|
|
|
+ showData.heroArr = {}
|
|
|
+
|
|
|
+ showData.heroArr = getLineupHeroArr(human)
|
|
|
+end
|
|
|
+
|
|
|
+-- 战斗结束处理
|
|
|
+local function fightEndHanle(human, result)
|
|
|
+ local msgData = InnerMsg.lw.LW_BATTLEGROUND_CHALLENGE_END
|
|
|
+ msgData.sourceServerId = Config.SVR_INDEX
|
|
|
+ msgData.playerUuid = human.db._id
|
|
|
+ msgData.atkRank = human.battleGroundRank
|
|
|
+ msgData.defRank = human.battleGroundCache.defRank
|
|
|
+ msgData.challengeRes = CombatDefine.RESULT_WIN
|
|
|
+ msgData.playerShowData = {}
|
|
|
+
|
|
|
+ local varCfg = battleGroundConfig.var[1]
|
|
|
+ local challengeAward = varCfg.defeatAward
|
|
|
+
|
|
|
+ if result == CombatDefine.RESULT_WIN then
|
|
|
+ human.battleGroundRank = human.battleGroundCache.defRank
|
|
|
+ local newMatchList = matchListAlgorithm(human.battleGroundRank)
|
|
|
+
|
|
|
+ -- 更新对手列表
|
|
|
+ local battleGroundData = human.db.ServerCommerce.battleGround
|
|
|
+ battleGroundData.matchList = newMatchList
|
|
|
+
|
|
|
+ -- 检查是否能解锁新英雄
|
|
|
+ local idx, unlockHeroInfo = getUnlockHeroInfoByRank(human.battleGroundRank)
|
|
|
+ if idx ~= battleGroundData.unLockIdx then
|
|
|
+ unlockHero(human, unlockHeroInfo)
|
|
|
+ battleGroundData.unLockIdx = idx
|
|
|
+ end
|
|
|
+
|
|
|
+ -- 展示数据
|
|
|
+ populatePlayerShowData(human, msgData.playerShowData, human.battleGroundCache.defRank)
|
|
|
+
|
|
|
+ -- 挑战奖励
|
|
|
+ challengeAward = varCfg.winAward
|
|
|
+ end
|
|
|
+
|
|
|
+ -- 发放挑战奖励
|
|
|
+ local finalAwardArr = {}
|
|
|
+ for i, itemInfo in ipairs(challengeAward) do
|
|
|
+ finalAwardArr[i] = {itemInfo[1], itemInfo[2]}
|
|
|
+ end
|
|
|
+ BagLogic.addItemList(human, finalAwardArr, LOGTYPE)
|
|
|
+
|
|
|
+ -- 通知跨服更新数据
|
|
|
+ InnerMsg.sendMsg(0, msgData)
|
|
|
+end
|
|
|
+
|
|
|
+-- 获取排名奖励
|
|
|
+local function getRankAward(rank)
|
|
|
+ local itemArr
|
|
|
+ for i, cfg in ipairs(battleGroundConfig.rankAward) do
|
|
|
+ if rank >= cfg.rankArea[1] and rank <= cfg.rankArea[1] then
|
|
|
+ itemArr = {}
|
|
|
+ for k, itemInfo in ipairs(cfg.rankAward) do
|
|
|
+ itemArr[k] = {itemInfo[1], itemInfo[2]}
|
|
|
+ end
|
|
|
+
|
|
|
+ break
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ return itemArr
|
|
|
+end
|
|
|
+
|
|
|
+
|
|
|
+function updateDaily(human)
|
|
|
+ if not isRunning() then
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ local battleGroundData = human.db.ServerCommerce and human.db.ServerCommerce.battleGround
|
|
|
+ if not battleGroundData then
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ local lastResetTime = battleGroundData.lastResetTime
|
|
|
+ if not Util.isSameDay(lastResetTime) then
|
|
|
+ battleGroundData.freeChallengeCnt = ServerCommerceActDefine.COMMERCEACT_DAILY_FREECHALLENGETIMES
|
|
|
+ battleGroundData.lastResetTime = os.time()
|
|
|
+ end
|
|
|
+end
|
|
|
+
|
|
|
+
|
|
|
+-- 推送主界面信息
|
|
|
+local function sendMainPageData(human)
|
|
|
+ local msgRet = Msg.gc.GC_SERVEERCOMMERCE_ACT_BATTLEGROUND_MAINPAGE_QUERY
|
|
|
+ msgRet.myRank = human.battleGroundRank or (ServerCommerceActDefine.COMMERCEACT_NPC_CNT + 1)
|
|
|
+ msgRet.freeChallengeCnt = 0
|
|
|
+ msgRet.showBodyId = RoleHeadLogic.GetRoleAdornInfo(human, RoleHeadLogic.HEAD_TYPE_3) or 0
|
|
|
+
|
|
|
+ local battleGroundData = human.db.ServerCommerce and human.db.ServerCommerce.battleGround
|
|
|
+ msgRet.freeChallengeCnt = battleGroundData and battleGroundData.freeChallengeCnt or ServerCommerceActDefine.COMMERCEACT_DAILY_FREECHALLENGETIMES
|
|
|
+ Msg.send(msgRet, human.fd)
|
|
|
+end
|
|
|
+
|
|
|
+-- 推送排行榜数据
|
|
|
+local function sendRankListData(human)
|
|
|
+ local msgRet = Msg.gc.GC_SERVEERCOMMERCE_ACT_BATTLEGROUND_RANK_QUERY
|
|
|
+ msgRet.rankList[0] = 0
|
|
|
+ msgRet.isEnd = 0
|
|
|
+ msgRet.myRankInfo.rank = human.battleGroundRank
|
|
|
+ msgRet.myRankInfo.serverId = Config.SVR_INDEX
|
|
|
+ msgRet.myRankInfo.name = human.db.name
|
|
|
+ msgRet.myRankInfo.heroHeadId = RoleHeadLogic.GetRoleAdornInfo(human, RoleHeadLogic.HEAD_TYPE_1) or 0
|
|
|
+ msgRet.myRankInfo.heroHeadFrameId = RoleHeadLogic.GetRoleAdornInfo(human, RoleHeadLogic.HEAD_TYPE_2) or 0
|
|
|
+
|
|
|
+ local msgMaxLen = 20
|
|
|
+ local len = 0
|
|
|
+ local rankNum = #rankListCache
|
|
|
+
|
|
|
+ for rank, rankInfo in ipairs(rankListCache) do
|
|
|
+ len = len + 1
|
|
|
+ msgRet.rankList[0] = len
|
|
|
+ msgRet.rankList[len].rank = rank
|
|
|
+ msgRet.rankList[len].serverId = rankInfo.serverId or 0
|
|
|
+ msgRet.rankList[len].name = rankInfo.name
|
|
|
+ msgRet.rankList[len].heroHeadId = rankInfo.heroHeadId
|
|
|
+ msgRet.rankList[len].heroHeadFrameId = rankInfo.heroHeadFrameId
|
|
|
+
|
|
|
+ if len >= msgMaxLen then
|
|
|
+ rankNum = rankNum - len
|
|
|
+
|
|
|
+ if rankNum <= 0 then
|
|
|
+ msgRet.isEnd = 1
|
|
|
+ return Msg.send(msgRet, human.fd)
|
|
|
+ end
|
|
|
+
|
|
|
+ Msg.send(msgRet, human.fd)
|
|
|
+ len = 0
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ if len > 0 then
|
|
|
+ msgRet.isEnd = 1
|
|
|
+ Msg.send(msgRet, human.fd)
|
|
|
+ end
|
|
|
+end
|
|
|
+
|
|
|
+-- 主界面信息查询
|
|
|
+function BattleGround_MainPage_Query(human)
|
|
|
+ if not isRunning() then
|
|
|
+ return Broadcast.sendErr(human, Lang.ACT_NOT_START)
|
|
|
+ end
|
|
|
+
|
|
|
+ if not human.battleGroundRank then
|
|
|
+ local msgData = InnerMsg.lw.LW_BATTLEGROUND_PLAYER_RANK_QUERY
|
|
|
+ msgData.sourceServerId = Config.SVR_INDEX
|
|
|
+ msgData.playerUuid = human.db._id
|
|
|
+ return InnerMsg.sendMsg(0, msgData)
|
|
|
+ end
|
|
|
+
|
|
|
+ sendMainPageData(human)
|
|
|
+end
|
|
|
+
|
|
|
+-- 匹配界面信息查询
|
|
|
+function BattleGround_MatchPage_Query(human)
|
|
|
+ if not isRunning() then
|
|
|
+ return Broadcast.sendErr(human, Lang.ACT_NOT_START)
|
|
|
+ end
|
|
|
+
|
|
|
+ local battleGroundData = human.db.ServerCommerce.battleGround
|
|
|
+ if not battleGroundData.matchList then
|
|
|
+ battleGroundData.matchList = matchListAlgorithm(human.battleGroundRank)
|
|
|
+ end
|
|
|
+
|
|
|
+ local msgData = InnerMsg.lw.LW_BATTLEGROUND_MATCHLIST_QUERY
|
|
|
+ msgData.sourceServerId = Config.SVR_INDEX
|
|
|
+ msgData.playerUuid = human.db._id
|
|
|
+ msgData.matchList = {}
|
|
|
+
|
|
|
+ for _, rank in ipairs(battleGroundData.matchList) do
|
|
|
+ msgData.matchList[#msgData.matchList+1] = rank
|
|
|
+ end
|
|
|
+
|
|
|
+ InnerMsg.sendMsg(0, msgData)
|
|
|
+end
|
|
|
+
|
|
|
+-- 匹配对手查询
|
|
|
+function BattleGround_Player_Query(human, targetRank)
|
|
|
+ if not isRunning() then
|
|
|
+ return Broadcast.sendErr(human, Lang.ACT_NOT_START)
|
|
|
+ end
|
|
|
+
|
|
|
+ local battleGroundData = human.db.ServerCommerce.battleGround
|
|
|
+ if not table.find(battleGroundData.matchList, targetRank) then
|
|
|
+ return Broadcast.sendErr(human, Lang.BG_MATCHLIST_ERR)
|
|
|
+ end
|
|
|
+
|
|
|
+ local msgData = InnerMsg.lw.LW_BATTLEGROUND_PLAYER_DATA_QUERY
|
|
|
+ msgData.sourceServerId = Config.SVR_INDEX
|
|
|
+ msgData.playerUuid = human.db._id
|
|
|
+ msgData.playerRank = targetRank
|
|
|
+
|
|
|
+ InnerMsg.sendMsg(0, msgData)
|
|
|
+end
|
|
|
+
|
|
|
+-- 英雄背包查询
|
|
|
+function BattleGround_HeroBag_Query(human)
|
|
|
+ if not isRunning() then
|
|
|
+ return Broadcast.sendErr(human, Lang.ACT_NOT_START)
|
|
|
+ end
|
|
|
+
|
|
|
+ local battleGroundData = human.db.ServerCommerce.battleGround
|
|
|
+ if not battleGroundData.heroBag then
|
|
|
+ local idx, unlockHeroInfo = getUnlockHeroInfoByRank(human.battleGroundRank)
|
|
|
+ if unlockHeroInfo then
|
|
|
+ unlockHero(human, unlockHeroInfo, true)
|
|
|
+ battleGroundData.unLockIdx = idx
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ local msgRet = Msg.gc.GC_SERVEERCOMMERCE_ACT_BATTLEGROUND_HEROBAG_QUERY
|
|
|
+ msgRet.heroArr[0] = 0
|
|
|
+ msgRet.isEnd = 0
|
|
|
+
|
|
|
+
|
|
|
+ local len, msgMaxLen = 0, 0
|
|
|
+ local heroNum = #battleGroundData.heroBag
|
|
|
+ for _, heroId in ipairs(battleGroundData.heroBag) do
|
|
|
+ len = len + 1
|
|
|
+ msgRet.heroArr[0] = len
|
|
|
+ local heroConfig = HeroConfig[heroId]
|
|
|
+ populateHeroMsg(msgRet.heroArr[len], heroId, heroConfig, ServerCommerceActDefine.COMMERCEACT_HERO_LV, ServerCommerceActDefine.COMMERCEACT_HERO_STAR)
|
|
|
+
|
|
|
+ if len >= msgMaxLen then
|
|
|
+ heroNum = heroNum - len
|
|
|
+ if heroNum <= 0 then
|
|
|
+ msgRet.isEnd = 1
|
|
|
+ return Msg.send(msgRet, human.fd)
|
|
|
+ end
|
|
|
+
|
|
|
+ Msg.send(msgRet, human.fd)
|
|
|
+ len = 0
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ if len > 0 then
|
|
|
+ msgRet.isEnd = 1
|
|
|
+ Msg.send(msgRet, human.fd)
|
|
|
+ end
|
|
|
+end
|
|
|
+
|
|
|
+-- 排行榜查询
|
|
|
+function BattleGround_RankList_Query(human)
|
|
|
+ if not isRunning() then
|
|
|
+ return Broadcast.sendErr(human, Lang.ACT_NOT_START)
|
|
|
+ end
|
|
|
+
|
|
|
+ local now = os.time()
|
|
|
+ if #rankListCache == 0 or now - lastGetRankListTime >= ServerCommerceActDefine.COMMERCEACT_RANKUPDATE then
|
|
|
+ local msgData = InnerMsg.lw.LW_BATTLEGROUND_RANKLIST_QUERY
|
|
|
+ msgData.sourceServerId = Config.SVR_INDEX
|
|
|
+ msgData.playerUuid = human.db._id
|
|
|
+ return InnerMsg.sendMsg(0, msgData)
|
|
|
+ end
|
|
|
+
|
|
|
+ sendRankListData(human)
|
|
|
+end
|
|
|
+
|
|
|
+-- 排行奖励查询
|
|
|
+function BattleGround_RankAward_Query(human)
|
|
|
+ if not isRunning() then
|
|
|
+ return Broadcast.sendErr(human, Lang.ACT_NOT_START)
|
|
|
+ end
|
|
|
+
|
|
|
+ local msgRet = Msg.gc.GC_SERVEERCOMMERCE_ACT_BATTLEGROUND_RANKAWARD_QUERY
|
|
|
+ msgRet.rankAwardList[0] = 0
|
|
|
+
|
|
|
+ msgRet.rankAwardList[0] = #battleGroundConfig.rankAward
|
|
|
+ for i, cfg in ipairs(battleGroundConfig.rankAward) do
|
|
|
+ msgRet.rankAwardList[i].minRank = cfg.rankArea[1]
|
|
|
+ msgRet.rankAwardList[i].maxRank = cfg.rankArea[2]
|
|
|
+ msgRet.rankAwardList[i].rankAward[0] = #cfg.rankAward
|
|
|
+
|
|
|
+ for k, itemInfo in ipairs(cfg.rankAward) do
|
|
|
+ Grid.makeItem(msgRet.rankAwardList[i].rankAward[k], itemInfo[1], itemInfo[2])
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ Msg.send(msgRet, human.fd)
|
|
|
+end
|
|
|
+
|
|
|
+-- 更新阵容数据
|
|
|
+function BattleGround_Lineup_Update(human, msg)
|
|
|
+ if not isRunning() then
|
|
|
+ return Broadcast.sendErr(human, Lang.ACT_NOT_START)
|
|
|
+ end
|
|
|
+
|
|
|
+ local battleGroundData = human.db.ServerCommerce.battleGround
|
|
|
+
|
|
|
+ local formation = msg.formation
|
|
|
+ local posList = CombatPosLogic.getPosList(formation)
|
|
|
+ local heroList = Util.split(msg.heroList, ",", true)
|
|
|
+
|
|
|
+ local reapetTb = {}
|
|
|
+ for i = 1, CombatDefine.COMBAT_HERO_CNT do
|
|
|
+ local heroId = heroList[i]
|
|
|
+ if heroId > 0 then
|
|
|
+ -- 英雄Id检测
|
|
|
+ if HeroConfig[heroId] then
|
|
|
+ return Broadcast.sendErr(human, Lang.FUWEN_HERO_GRID_ERR)
|
|
|
+ end
|
|
|
+
|
|
|
+ -- 英雄背包检测
|
|
|
+ if not battleGroundData.heroBag or not table.find(battleGroundData.heroBag, heroId) then
|
|
|
+ return Broadcast.sendErr(human, Lang.FUWEN_HERO_GRID_ERR)
|
|
|
+ end
|
|
|
+
|
|
|
+ -- 相同英雄检测
|
|
|
+ if reapetTb[heroId] then
|
|
|
+ return Broadcast.sendErr(human, Lang.HERO_SAME)
|
|
|
+ end
|
|
|
+
|
|
|
+ -- 位置检测
|
|
|
+ if posList[i] == nil and i ~= CombatDefine.COMBAT_HERO_CNT then
|
|
|
+ return Broadcast.sendErr(human, Lang.POS_ERROR)
|
|
|
+ end
|
|
|
+
|
|
|
+ reapetTb[heroId] = true
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ battleGroundData.lineUp = battleGroundData.lineUp or {}
|
|
|
+ battleGroundData.lineUp.formation = formation
|
|
|
+ battleGroundData.lineUp.heroList = heroList
|
|
|
+
|
|
|
+ -- 通知跨服更新
|
|
|
+ if human.battleGroundRank and human.battleGroundRank <= ServerCommerceActDefine.COMMERCEACT_NPC_CNT then
|
|
|
+ local msgData = InnerMsg.lw.LW_BATTLEGROUND_LINEUP_UPDATE
|
|
|
+ msgData.sourceServerId = Config.SVR_INDEX
|
|
|
+ msgData.playerUuid = human.db._id
|
|
|
+ msgData.heroArr = getLineupHeroArr(human)
|
|
|
+ InnerMsg.sendMsg(0, msgData)
|
|
|
+ end
|
|
|
+end
|
|
|
+
|
|
|
+-- 活动结束
|
|
|
+function Act_End()
|
|
|
+ local msgData = InnerMsg.lw.LW_BATTLEGROUND_ACT_END
|
|
|
+ msgData.sourceServerId = Config.SVR_INDEX
|
|
|
+ InnerMsg.sendMsg(0, msgData)
|
|
|
+end
|
|
|
+
|
|
|
+-----------------------------------------------C2N-------------------------------------------------------
|
|
|
+
|
|
|
+-- 跨服返回玩家排名数据
|
|
|
+function BG_C2N_PlayerRank_Res(msg)
|
|
|
+ local human = ObjHuman.onlineUuid[msg.playerUuid]
|
|
|
+ if not human then
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ human.battleGroundRank = msg.playerRank
|
|
|
+ sendMainPageData(human)
|
|
|
+end
|
|
|
+
|
|
|
+-- 跨服返回对手列表数据
|
|
|
+function BG_C2N_MatchList_Res(msg)
|
|
|
+ local human = ObjHuman.onlineUuid[msg.playerUuid]
|
|
|
+ if not human then
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ local msgRet = Msg.gc.GC_SERVEERCOMMERCE_ACT_BATTLEGROUND_MATCHLIST_QUERY
|
|
|
+ msgRet.myRank = human.battleGroundRank or (ServerCommerceActDefine.COMMERCEACT_NPC_CNT + 1)
|
|
|
+ msgRet.freeChallengeCnt = 0
|
|
|
+ msgRet.isGetNew = 0
|
|
|
+ msgRet.matchList[0] = 0
|
|
|
+
|
|
|
+ local battleGroundData = human.db.ServerCommerce and human.db.ServerCommerce.battleGround
|
|
|
+
|
|
|
+ local costItem = battleGroundConfig.var[1].cost
|
|
|
+ Grid.makeItem(msgRet.exchangeCost, costItem[1], costItem[2])
|
|
|
+
|
|
|
+ msgRet.freeChallengeCnt = battleGroundData and battleGroundData.freeChallengeCnt or ServerCommerceActDefine.COMMERCEACT_DAILY_FREECHALLENGETIMES
|
|
|
+ msgRet.isGetNew = battleGroundData and battleGroundData.isHaveNewHero and 1 or 0
|
|
|
+
|
|
|
+ msgRet.matchList[0] = #msg.playerInfoList
|
|
|
+ for i, rankInfo in ipairs(msg.playerInfoList) do
|
|
|
+ msgRet.matchList[i].rank = rankInfo.rank
|
|
|
+ msgRet.matchList[i].serverId = rankInfo.serverId or 0
|
|
|
+ msgRet.matchList[i].name = rankInfo.name
|
|
|
+ msgRet.matchList[i].showBodyId = rankInfo.showBodyId
|
|
|
+ end
|
|
|
+
|
|
|
+ Msg.send(msgRet, human.fd)
|
|
|
+end
|
|
|
+
|
|
|
+-- 跨服返回单个对手数据
|
|
|
+function BG_C2N_PlayerData_Res(msg)
|
|
|
+ local human = ObjHuman.onlineUuid[msg.playerUuid]
|
|
|
+ if not human then
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ local playerInfo = msg.playerInfo
|
|
|
+ local msgRet = Msg.gc.GC_SERVEERCOMMERCE_ACT_BATTLEGROUND_PLAYER_QUERY
|
|
|
+ msgRet.serverId = playerInfo.serverId or 0
|
|
|
+ msgRet.name = playerInfo.name
|
|
|
+ msgRet.heroHeadId = playerInfo.heroHeadId
|
|
|
+ msgRet.heroHeadFrameId = playerInfo.heroHeadFrameId
|
|
|
+ msgRet.heroArr[0] = 0
|
|
|
+
|
|
|
+ if playerInfo.monsteroutId == 0 then -- 真实玩家
|
|
|
+ msgRet.heroArr[0] = #playerInfo.heroArr
|
|
|
+ for i, heroId in ipairs(playerInfo.heroArr) do
|
|
|
+ local heroConfig = HeroConfig[heroId]
|
|
|
+ populateHeroMsg(msgRet.heroArr[i], heroId, heroConfig, ServerCommerceActDefine.COMMERCEACT_HERO_LV, ServerCommerceActDefine.COMMERCEACT_HERO_STAR)
|
|
|
+ end
|
|
|
+ else
|
|
|
+ local monsterOutConfig = MonsterExcel.monsterOut[playerInfo.monsteroutId]
|
|
|
+ msgRet.heroArr[0] = #monsterOutConfig.member
|
|
|
+ for i, monsterInfo in ipairs(monsterOutConfig.member) do
|
|
|
+ local monsterID = monsterInfo[1]
|
|
|
+ local mcf = MonsterExcel.monster[monsterID]
|
|
|
+ populateHeroMsg(msgRet.heroArr[i], monsterID, mcf, monsterInfo[2], mcf.star)
|
|
|
+ end
|
|
|
+ end
|
|
|
+end
|
|
|
+
|
|
|
+-- 跨服返回排行榜数据
|
|
|
+function BG_C2N_RankList_Res(msg)
|
|
|
+ rankListCache = msg.rankList
|
|
|
+ lastGetRankListTime = os.time()
|
|
|
+
|
|
|
+ local human = ObjHuman.onlineUuid[msg.playerUuid]
|
|
|
+ if not human then
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ sendRankListData(human)
|
|
|
+end
|
|
|
+
|
|
|
+-- 跨服返回请求战斗结果
|
|
|
+function BG_C2N_Challenge_Res(msg)
|
|
|
+ local human = ObjHuman.onlineUuid[msg.playerUuid]
|
|
|
+ if not human then
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ if msg.errCode ~= 0 then
|
|
|
+ return Broadcast.sendErr(human, Lang.BG_MATCHLIST_ERR)
|
|
|
+ end
|
|
|
+
|
|
|
+ local playerUuid = msg.playerInfo.playerUuid
|
|
|
+ local defServerId = msg.playerInfo.defServerId
|
|
|
+
|
|
|
+ human.battleGroundCache = {
|
|
|
+ defRank = msg.playerInfo.rank
|
|
|
+ }
|
|
|
+
|
|
|
+ if defServerId ~= 0 then -- 真实玩家
|
|
|
+ local args = {
|
|
|
+ combatType = CombatDefine.COMBAT_TYPE37,
|
|
|
+ nServerIndex = defServerId,
|
|
|
+ param = playerUuid
|
|
|
+ }
|
|
|
+ MiddleCommonLogic.MiddleCommonLogic_CombatBegin_LW(human, args)
|
|
|
+ else
|
|
|
+ CombatLogic.combatBegin(human, nil, {playerUuid}, CombatDefine.COMBAT_TYPE37)
|
|
|
+ end
|
|
|
+end
|
|
|
+
|
|
|
+-- 跨服通知玩家排名下降
|
|
|
+function BG_C2N_RankReduce(msg)
|
|
|
+ local human = ObjHuman.onlineUuid[msg.playerUuid]
|
|
|
+ if not human then
|
|
|
+ local db = RoleDBLogic.getDb(msg.playerUuid)
|
|
|
+ if not db then
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ human = {}
|
|
|
+ human.db = db
|
|
|
+ end
|
|
|
+
|
|
|
+ -- 更新对手列表
|
|
|
+ local battleGroundData = human.db.ServerCommerce.battleGround
|
|
|
+ battleGroundData.matchList = matchListAlgorithm(msg.newRank)
|
|
|
+
|
|
|
+ -- 邮件通知
|
|
|
+ local varCfg = battleGroundConfig.var[1]
|
|
|
+ local arg = {msg.atkeServerId - 810537, msg.atkName, msg.newRank}
|
|
|
+ rankReduceMail(varCfg.defeatMailId, human.db.id, arg)
|
|
|
+
|
|
|
+ -- 玩家在线
|
|
|
+ if human.fd then
|
|
|
+ human.battleGroundRank = msg.newRank
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ -- 玩家不在线，则保存数据
|
|
|
+ ObjHuman.save(human)
|
|
|
+end
|
|
|
+
|
|
|
+-- 跨服通知发奖
|
|
|
+function BG_C2N_PrizeAward(msg)
|
|
|
+ local playerArr = msg.playerArr
|
|
|
+ if not next(playerArr) then
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ local issueRewardQueue = createRewardQueue()
|
|
|
+
|
|
|
+ for _, playerInfo in ipairs(playerArr) do
|
|
|
+ local itemArr = getRankAward(playerInfo[1])
|
|
|
+ if itemArr then
|
|
|
+ playerInfo[3] = itemArr
|
|
|
+ issueRewardQueue:add(itemArr)
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ issueRewardQueue:insertDB()
|
|
|
+end
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+----------------------------------战斗-----------------------------------
|
|
|
+
|
|
|
+function fight(human, args, combatType)
|
|
|
+ if combatType ~= CombatDefine.COMBAT_TYPE37 then
|
|
|
+ return Broadcast.sendErr(human, Lang.BG_COMBAT_TYPE_ERR)
|
|
|
+ end
|
|
|
+
|
|
|
+ local targetRank = tonumber(args[1])
|
|
|
+ local battleGroundData = human.db.ServerCommerce.battleGround
|
|
|
+ if not targetRank or not table.find(battleGroundData.matchList, targetRank) then
|
|
|
+ return Broadcast.sendErr(human, Lang.BG_MATCHLIST_ERR)
|
|
|
+ end
|
|
|
+
|
|
|
+ if not battleGroundData.lineUp then
|
|
|
+ return Broadcast.sendErr(human, Lang.SEAL_GROUND_COMBAT_HERO_ERR)
|
|
|
+ end
|
|
|
+
|
|
|
+ if battleGroundData.freeChallengeCnt <= 0 then
|
|
|
+ local costItem = battleGroundConfig.var[1].cost
|
|
|
+ local itemId, itemNum = costItem[1], costItem[2]
|
|
|
+ if BagLogic.getItemCnt(human, itemId) < itemNum then
|
|
|
+ return Broadcast.sendErr(human, Lang.BG_CONDITION_ERR)
|
|
|
+ end
|
|
|
+
|
|
|
+ BagLogic.delItem(human, itemId, itemNum, LOGTYPE)
|
|
|
+ else
|
|
|
+ battleGroundData.freeChallengeCnt = battleGroundData.freeChallengeCnt - 1
|
|
|
+ end
|
|
|
+
|
|
|
+ local msgData = InnerMsg.lw.LW_BATTLEGROUND_CHALLENGE_QUERY
|
|
|
+ msgData.sourceServerId = Config.SVR_INDEX
|
|
|
+ msgData.playerUuid = human.db._id
|
|
|
+ msgData.rank = targetRank
|
|
|
+ InnerMsg.sendMsg(0, msgData)
|
|
|
+end
|
|
|
+
|
|
|
+function getCombatMonsterOutID(human, side, args)
|
|
|
+ if side ~= CombatDefine.DEFEND_SIDE then return end
|
|
|
+ return args[1]
|
|
|
+end
|
|
|
+
|
|
|
+
|
|
|
+function getCombatObjList(human, side, args, combatType)
|
|
|
+ if side == CombatDefine.ATTACK_SIDE and not human then return end
|
|
|
+
|
|
|
+ if side == CombatDefine.DEFEND_SIDE and human then
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ if not human then
|
|
|
+ local uuid = args[1]
|
|
|
+ local db = RoleDBLogic.getDb(uuid)
|
|
|
+ if not db then
|
|
|
+ return
|
|
|
+ end
|
|
|
+ human = {}
|
|
|
+ human.db = db
|
|
|
+ end
|
|
|
+
|
|
|
+ local battleGroundData = human.db.ServerCommerce.battleGround
|
|
|
+ local lineUpData = battleGroundData.lineUp
|
|
|
+ if not lineUpData.heroList or not lineUpData.formation then
|
|
|
+ return
|
|
|
+ end
|
|
|
+
|
|
|
+ local fakeHuman = {}
|
|
|
+ local objList = {}
|
|
|
+ for i = 1, CombatDefine.COMBAT_HERO_CNT do
|
|
|
+ local heroId = lineUpData.heroList[i]
|
|
|
+ if heroId and heroId ~= 0 then
|
|
|
+ objList[i] = CombatLogic.createHeroObj(fakeHuman, heroId, ServerCommerceActDefine.COMMERCEACT_HERO_LV, ServerCommerceActDefine.COMMERCEACT_HERO_STAR, i)
|
|
|
+ end
|
|
|
+ end
|
|
|
+
|
|
|
+ local rolebase = CombatLogic.createRoleBaseByDB(human.db)
|
|
|
+ return objList, nil, rolebase, lineUpData.formation
|
|
|
+end
|
|
|
+
|
|
|
+function onFightEnd(human, result, type, cbParam, combatInfo)
|
|
|
+ local battleGroundCache = human.battleGroundCache
|
|
|
+ if not battleGroundCache then
|
|
|
+ return Broadcast.sendErr(human, Lang.DATA_ERR)
|
|
|
+ end
|
|
|
+
|
|
|
+ fightEndHanle(human, result)
|
|
|
+end
|
gitxsm