From ebf0c525597f65830be5975ec91a157793cba1e9 Mon Sep 17 00:00:00 2001 From: hxp <ale99527@vip.qq.com> Date: 星期一, 23 五月 2022 17:00:25 +0800 Subject: [PATCH] 9415 【BT】【后端】古神战场(优化玩家在战场结算前掉线后逻辑:结算后强制设置玩家为非跨服状态,防止玩家重连导致还会进入跨服地图然后再被踢出去的无效流程) --- ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py | 169 ++++++++++++++++++++----------------------------------- 1 files changed, 62 insertions(+), 107 deletions(-) diff --git a/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py b/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py index bf74fe8..bc415ec 100644 --- a/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py +++ b/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py @@ -33,6 +33,7 @@ import PlayerFamilyRedPacket import PlayerFairyCeremony import PlayerNewFairyCeremony +import PlayerActGarbageSorting import PlayerUniversalGameRec import GameWorldAverageLv import PlayerFamilyBoss @@ -64,7 +65,10 @@ # 跨服不处理运营活动 return - isReload, OperationActionInfo = __GetOperationActionInfo() + # 玩家登录的不触发重载活动,不然刚好在0点服务器处理OnDay之前登录的时候会有问题 + isReload, OperationActionInfo = __GetOperationActionInfo(needReload=False) + if not OperationActionInfo: + return operationActionDict = OperationActionInfo[OperationAction_TodayInfo] if isReload: @@ -188,7 +192,7 @@ % (actName, cfgID, recStartDateStr, recEndDateStr, recLimitWorldLV, recWorldLV)) return actWorldLVLimitInfo -def __GetOperationActionInfo(isRefreshState=True): +def __GetOperationActionInfo(isRefreshState=True, needReload=True): # @return: isReload, OperationActionInfo key = "OperationActionInfo" @@ -202,6 +206,9 @@ reloadSign = [openServerDay, isMixServer, mixServerDay, reloadSignHour] if OperationActionInfo and OperationActionInfo[OperationAction_ReloadSign] == reloadSign: #GameWorld.DebugLog("已经加载过本日运营活动处理信息!openServerDay=%s" % openServerDay) + return False, OperationActionInfo + + if not needReload: return False, OperationActionInfo # 因为后面的时间判断都是精确到分的,而处理此逻辑的时候可能不是0秒,所以这里的datetime取当前时间精确到分的 @@ -234,7 +241,7 @@ GameWorld.Log("加载运营活动: actName=%s,platform=%s,serverGroupID=%s" % (actName, platform, serverGroupID)) curServerActIpyDataList = __GetOperationActionServerIpyDataList(ipyDataMgr, platform, serverGroupID, actName) GameWorld.Log(" 可处理条数=%s" % (len(curServerActIpyDataList))) - actNumDisableWeekIpyDataInfo = __GetOperationActionDisableWeekIpyDataInfo(actName, curDateTime, curServerActIpyDataList) + actNumDisableWeekIpyDataInfo, disableWeekCfgIDDict = __GetOperationActionDisableWeekIpyDataInfo(actName, curDateTime, curServerActIpyDataList) for ipyData in curServerActIpyDataList: @@ -268,7 +275,7 @@ # 开服常规: 开服天 > 日期 > 周x (不受合服天影响,合服活动新增一套独立的活动,还是走运营活动配置) if actType == ShareDefine.ActType_OpenComm: actByWeek = (startDateStr.startswith("W") and endDateStr.startswith("W")) # 按周x开 - actByDate = (startDateStr.count("-") == 2 and endDateStr.count("-") == 2) # 按日期开 + actByDate = (not actByWeek and startDateStr.count("-") == 2 and endDateStr.count("-") == 2) # 按日期开 # 开服天的 if startDateStr.isdigit() and endDateStr.isdigit(): @@ -296,13 +303,13 @@ % (cfgID, startWeekDate, startDateStr, endWeekDate, endDateStr, ymdCfgID, ymdStartDate, ymdEndDate)) continue + if cfgID in disableWeekCfgIDDict: + GameWorld.Log(" 常规活动,按星期开启的未到开启循环日期或已结束循环日期,不处理! cfgID=%s,startDateStr=%s,endDateStr=%s, %s" + % (cfgID, startDateStr, endDateStr, disableWeekCfgIDDict[cfgID])) + continue + if actByWeek: - startWeekday = int(startDateStr[1:]) - endWeekday = int(endDateStr[1:]) - startWeekDate = curDateTime + datetime.timedelta(days=(startWeekday - curWeekday)) - endWeekDate = curDateTime + datetime.timedelta(days=(endWeekday - curWeekday)) - startDateStr = "%d-%d-%d" % (startWeekDate.year, startWeekDate.month, startWeekDate.day) - endDateStr = "%d-%d-%d" % (endWeekDate.year, endWeekDate.month, endWeekDate.day) + startDateStr, endDateStr = GameWorld.GetOperationActionDateStr(ipyData) GameWorld.Log(" 星期X转化为日期: %s ~ %s" % (startDateStr, endDateStr)) curServerOpenDateTime = curDateTime + datetime.timedelta(days=(1 - openServerDay)) # 开服第一天的日期 @@ -401,6 +408,12 @@ ## 防止未真正开始的活动需要提前预告,而导致覆盖掉了实际正在进行中的活动,一般是活动时间配置连续的时候可能出现该情况 GameWorld.Log(" 已经存在需要处理的配置ID(%s)! 当前需要提前通知或广播的活动未达到活动开始时间,不处理!cfgID=%s,advanceMinutes=%s,minNotifyStartMinute=%s,startDayDateJudge=%s" % (activityIpyData.GetCfgID(), cfgID, advanceMinutes, minNotifyStartMinute, startDayDateJudge)) + continue + + #注:刚好是结束的时间点,防范已经有需要处理的配置被覆盖 + if curActTodayInfo and curDateTime == endDayDate: + activityIpyData = curActTodayInfo[0] + GameWorld.Log(" 已经存在需要处理的配置ID(%s)! 当前刚好结束的时间点,不处理!cfgID=%s" % (activityIpyData.GetCfgID(), cfgID)) continue # 在需要处理的时间内附加世界等级开启限制,未达到最低世界等级要求的不开,活动时间从未达到到达到也不开 @@ -594,10 +607,15 @@ def __GetOperationActionDisableWeekIpyDataInfo(actName, curDateTime, curServerActIpyDataList): ## 获取不可用的按星期X开启的配置数据信息,按星期X开启的 活动优先级小于按日期的,当有重叠时以日期的为准 - curWeekday = curDateTime.weekday() + 1 # 今天星期几, 1代表星期1 + #curWeekday = curDateTime.weekday() + 1 # 今天星期几, 1代表星期1 actNumWeekYMDIpyDataInfo = {} # {actNum:[weekIpyDataList, ymdIpyDatList], ...} + disableWeekCfgIDDict = {} # {cfgID:[startDateStr, endDateStr], ...} + + curDateTimeYmdStr = "%d-%d-%d" % (curDateTime.year, curDateTime.month, curDateTime.day) + curDateTimeYmd = GameWorld.ChangeStrToDatetime(curDateTimeYmdStr, ChConfig.TYPE_Time_YmdFormat) for ipyData in curServerActIpyDataList: + cfgID = ipyData.GetCfgID() startDateStr = ipyData.GetStartDate() endDateStr = ipyData.GetEndDate() actNum = GetOperationActNum(actName, ipyData) @@ -613,11 +631,14 @@ # 按星期X的 if startDateStr.startswith("W"): - startWeekday = int(startDateStr[1:]) - endWeekday = int(endDateStr[1:]) - startWeekDate = curDateTime + datetime.timedelta(days=(startWeekday - curWeekday)) - endWeekDate = curDateTime + datetime.timedelta(days=(endWeekday - curWeekday)) - weekIpyDataList.append([ipyData, startWeekDate, endWeekDate]) + startDateStr, endDateStr = GameWorld.GetOperationActionDateStr(ipyData) + startWeekDate = GameWorld.ChangeStrToDatetime(startDateStr, ChConfig.TYPE_Time_YmdFormat) + endWeekDate = GameWorld.ChangeStrToDatetime(endDateStr, ChConfig.TYPE_Time_YmdFormat) + if startWeekDate > curDateTimeYmd or curDateTimeYmd > endWeekDate: # 还未开始的循环 or 已经强制结束的循环 + disableWeekCfgIDDict[cfgID] = [startDateStr, endDateStr] + else: + weekIpyDataList.append([ipyData, startWeekDate, endWeekDate]) + # 按日期的 elif startDateStr.count("-") == 2: ymdIpyData = ipyData @@ -641,89 +662,7 @@ ymdCfgID = ymdIpyData.GetCfgID() actNumDisableWeekIpyDataInfo[actNum][cfgID] = [startWeekDate, endWeekDate, ymdCfgID, ymdStartDate, ymdEndDate] - return actNumDisableWeekIpyDataInfo - -def TransferOperationActDBKeyValue(): - ''' 服务器启动时调用 - 支持多活动的数据转移,旧版本db活动数据转移到新版本,分两种情况 - 1. 原已支持多活动的: 手动根据原编号规则进行指定转移,这个维护一次后代码可删除 - 2. 原不支持多活动的,自动根据原活动类型进行适配转移即可,由于合服相关的独立出来了,所以只需要处理常规的及节日类型 - 这个代码可以一直放着,后续增加支持多活动类型的配置到 MultiActNumOperationActNameList 即可 - - 注:不支持多活动的,暂还是用旧的key记录数据 - ''' - GameWorld.Log("=== 转移运营活动旧版本数据到新版本 ===") - - # 1. 原已支持的 - 维护后过一次后可删除或注释掉,目前只有累计充值、集字,线上版本分支 gt_1.100.4 - transferDict = { - ShareDefine.OperationActionName_TotalRecharge:[ - # 原常规每日累充 转移 到 10 - [PlayerDBGSEvent.Def_OperationActID % ShareDefine.OperationActionName_TotalRecharge, - PlayerDBGSEvent.Def_OperationActID % ShareDefine.OperationActionName_TotalRecharge + "_%s" % 10, - ], - [PlayerDBGSEvent.Def_OActWorldLV % ShareDefine.OperationActionName_TotalRecharge, - PlayerDBGSEvent.Def_OActWorldLV % ShareDefine.OperationActionName_TotalRecharge + "_%s" % 10, - ], - - # 原常规多日累充2 转移 到 11 - [PlayerDBGSEvent.Def_OperationActID % (ShareDefine.OperationActionName_TotalRecharge + "2"), - PlayerDBGSEvent.Def_OperationActID % ShareDefine.OperationActionName_TotalRecharge + "_%s" % 11, - ], - [PlayerDBGSEvent.Def_OActWorldLV % (ShareDefine.OperationActionName_TotalRecharge + "2"), - PlayerDBGSEvent.Def_OActWorldLV % ShareDefine.OperationActionName_TotalRecharge + "_%s" % 11, - ], - - # 原节日多日累充3 转移 到 31 - [PlayerDBGSEvent.Def_OperationActID % (ShareDefine.OperationActionName_TotalRecharge + "3"), - PlayerDBGSEvent.Def_OperationActID % ShareDefine.OperationActionName_TotalRecharge + "_%s" % 31, - ], - [PlayerDBGSEvent.Def_OActWorldLV % (ShareDefine.OperationActionName_TotalRecharge + "3"), - PlayerDBGSEvent.Def_OActWorldLV % ShareDefine.OperationActionName_TotalRecharge + "_%s" % 31, - ], - ], - ShareDefine.OperationActionName_CollectWords:[ - # 只配置了常规日期的,可不处理 - ], - } - for actName, transferKeyList in transferDict.items(): - for oldKey, newKey in transferKeyList: - value = PlayerDBGSEvent.GetDBGSTrig_ByKey(oldKey) - if not value: - continue - GameWorld.Log(" 转移旧运营活动dbKey值到新key: actName=%s,oldKey=%s,newKey=%s,value=%s" % (actName, oldKey, newKey, value)) - PlayerDBGSEvent.SetDBGSTrig_ByKey(newKey, value) - PlayerDBGSEvent.DelDBGSTrig_ByKey(oldKey) - - # 2. 新增支持的 - 可当做常规代码一直留着 - for actName in ShareDefine.MultiActNumOperationActNameList: - if actName in transferDict: - # 特殊处理转化的活动不进行常规处理 - continue - - actIDKeyOld = PlayerDBGSEvent.Def_OperationActID % actName - worldLVKeyOld = PlayerDBGSEvent.Def_OActWorldLV % actName - - actNum = GetOperationActNum(actName) - actIDKeyNew = actIDKeyOld + "_%s" % actNum - worldLVKeyNew = worldLVKeyOld + "_%s" % actNum - - dbActID = PlayerDBGSEvent.GetDBGSTrig_ByKey(actIDKeyOld) - dbWorldLV = PlayerDBGSEvent.GetDBGSTrig_ByKey(worldLVKeyOld) - if not dbActID: - continue - - GameWorld.Log(" 转移旧运营活动dbKey值到新key: actName=%s" % actName) - PlayerDBGSEvent.SetDBGSTrig_ByKey(actIDKeyNew, dbActID) - PlayerDBGSEvent.DelDBGSTrig_ByKey(actIDKeyOld) - GameWorld.Log(" actIDKeyOld=%s,actIDKeyNew=%s,dbActID=%s" % (actIDKeyOld, actIDKeyNew, dbActID)) - - if dbWorldLV: - PlayerDBGSEvent.SetDBGSTrig_ByKey(worldLVKeyNew, dbWorldLV) - PlayerDBGSEvent.DelDBGSTrig_ByKey(worldLVKeyOld) - GameWorld.Log(" worldLVKeyOld=%s,worldLVKeyNew=%s,dbWorldLV=%s" % (worldLVKeyOld, worldLVKeyNew, dbWorldLV)) - - GameWorld.Log("===================================") - return + return actNumDisableWeekIpyDataInfo, disableWeekCfgIDDict def Dispose_OperationActionState(reloadRefresh=False): # 运营活动状态处理, 每天0点会强制同步当天的运营活动详情到地图服务器 @@ -838,10 +777,16 @@ #限时抢购重置购买次数 本次活动每场不能重复 #dayIndex = sendMapServerMsgDict.get(ShareDefine.ActKey_DayIndex, 0) PlayerStore.ResetFlashSaleBuyCnt(ipyData) + elif actName == ShareDefine.OperationActionName_GarbageSorting: + PlayerActGarbageSorting.OnActStart(actNum) + else: + if actName == ShareDefine.OperationActionName_GarbageSorting: + PlayerActGarbageSorting.OnActEnd(actNum) + else: GameWorld.Log(" dbActID不变: dbActID=%s,curActID=%s" % (dbActID, curActID)) - if state and actName in ShareDefine.NeedWorldLVOperationActNameList: + if ipyData and actName in ShareDefine.NeedWorldLVOperationActNameList: actWorldLV = PlayerDBGSEvent.GetDBGSTrig_ByKey(dbOperationActWorldLVKey) sendMapServerMsgDict[ShareDefine.ActKey_WorldLV] = actWorldLV GameWorld.Log(" 活动世界等级: actWorldLV=%s" % (actWorldLV)) @@ -853,7 +798,13 @@ elif actName == ShareDefine.OperationActionName_BossReborn: if isReload and ipyData: GameWorldBoss.SetBossRebornNeedPoint(True) - + + elif actName == ShareDefine.OperationActionName_HorsePetFeast: + if preState != state and state: + relatedID = "%s|%s" % (actName, actNum) + GameWorld.Log(" 骑宠盛宴开始: relatedID=%s" % (relatedID)) + GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_ActionBossRebornSign % relatedID, int(time.time())) + elif actName == ShareDefine.OperationActionName_FairyCeremony: if isReload and ipyData: PlayerFairyCeremony.Sync_OperationAction_FairyCeremony(ipyData) @@ -891,11 +842,11 @@ return if len(ipyData.GetStartTimeList()) != len(ipyData.GetEndTimeList()): return - openServerDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ServerDay) + 1 + startDateStr, endDateStr = GameWorld.GetOperationActionDateStr(ipyData) multiExpRateInfo = ChPyNetSendPack.tagGCMultiExpRateInfo() multiExpRateInfo.Clear() - multiExpRateInfo.StartDate = GameWorld.GetOperationActionDateStr(ipyData.GetStartDate(), openServerDay) - multiExpRateInfo.EndtDate = GameWorld.GetOperationActionDateStr(ipyData.GetEndDate(), openServerDay) + multiExpRateInfo.StartDate = startDateStr + multiExpRateInfo.EndtDate = endDateStr multiExpRateInfo.ActivityTime = [] for i, startTime in enumerate(ipyData.GetStartTimeList()): endTime = ipyData.GetEndTimeList()[i] @@ -924,11 +875,11 @@ ##多倍修行点活动信息通知 if not ipyData: return - openServerDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ServerDay) + 1 + startDateStr, endDateStr = GameWorld.GetOperationActionDateStr(ipyData) multiRealmPointInfo = ChPyNetSendPack.tagGCMultiRealmPointInfo() multiRealmPointInfo.Clear() - multiRealmPointInfo.StartDate = GameWorld.GetOperationActionDateStr(ipyData.GetStartDate(), openServerDay) - multiRealmPointInfo.EndtDate = GameWorld.GetOperationActionDateStr(ipyData.GetEndDate(), openServerDay) + multiRealmPointInfo.StartDate = startDateStr + multiRealmPointInfo.EndtDate = endDateStr multiRealmPointInfo.Multiple = ipyData.GetMultiple() multiRealmPointInfo.LimitLV = ipyData.GetLVLimit() multiRealmPointInfo.LimitPoint = ipyData.GetPointLimit() @@ -1024,6 +975,10 @@ dailyIpyData = ipyDataMgr.GetDailyActionByIndex(i) dailyID = dailyIpyData.GetDailyID() + if dailyID in [ShareDefine.DailyActionID_CrossBattlefield]: + GameWorld.Log(" 不需要处理的日常活动! dailyID=%s" % dailyID) + continue + # 是当天开服天定制活动的不处理常规活动 if dailyID in customDailyIDList: GameWorld.Log(" 常规活动ID配置是今天的定制活动ID,不处理!: dailyID=%s" % dailyID) -- Gitblit v1.8.0