From c4a89283031373e5a651f95efb5c651b2d56965b Mon Sep 17 00:00:00 2001 From: hxp <ale99527@vip.qq.com> Date: 星期五, 29 十一月 2024 17:30:50 +0800 Subject: [PATCH] 10318 【英文】【越南】【BT】【砍树】统一增加奖励获得封包(增加战令领奖通知,eventName为Zhanling) --- ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py | 317 +++++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 250 insertions(+), 67 deletions(-) diff --git a/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py b/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py index bfee180..3905dd4 100644 --- a/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py +++ b/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py @@ -33,7 +33,12 @@ import PlayerFamilyRedPacket import PlayerFairyCeremony import PlayerNewFairyCeremony +import PlayerActFamilyCTGAssist import PlayerActGarbageSorting +import PlayerActBossTrial +import PlayerActXianXiaMJ +import PlayerActGubao +import PlayerActHorsePetTrain import PlayerUniversalGameRec import GameWorldAverageLv import PlayerFamilyBoss @@ -108,10 +113,11 @@ def SendMapServerOperationActionState(): # 地图启动成功时通知本日运行活动相关状态 + CrossActionControl.SendMapServerCrossActionState() + if GameWorld.IsCrossServer(): # 跨服不处理运营活动 return - CrossActionControl.SendMapServerCrossActionState() isReload, OperationActionInfo = __GetOperationActionInfo() mapServerInfoDict = OperationActionInfo[OperationAction_MapServerInfo] @@ -141,7 +147,7 @@ 活动分组编号 = 活动类型 * 10 + 不同界面编号 ''' - if ipyData and hasattr(ipyData, "ActNum"): + if ipyData and hasattr(ipyData, "GetActNum"): return ipyData.GetActNum() # 原节日活动的还是默认节日活动 @@ -241,13 +247,14 @@ GameWorld.Log("加载运营活动: actName=%s,platform=%s,serverGroupID=%s" % (actName, platform, serverGroupID)) curServerActIpyDataList = __GetOperationActionServerIpyDataList(ipyDataMgr, platform, serverGroupID, actName) GameWorld.Log(" 可处理条数=%s" % (len(curServerActIpyDataList))) - actNumDisableWeekIpyDataInfo, disableWeekCfgIDDict = __GetOperationActionDisableWeekIpyDataInfo(actName, curDateTime, curServerActIpyDataList) - + coverDisableLoopIpyDataInfo, disableLoopCfgIDDict, otherLoopCfgIDDict, coverDisableWeekIpyDataInfo, disableWeekCfgIDDict = \ + __GetOperationActionDisableIpyDataInfo(actName, curDateTime, curServerActIpyDataList) + for ipyData in curServerActIpyDataList: - platformList = [] if not hasattr(ipyData, "PlatformList") else ipyData.GetPlatformList() - serverGroupIDList = [] if not hasattr(ipyData, "ServerGroupIDList") else ipyData.GetServerGroupIDList() - serverGroupIDListExcept = [] if not hasattr(ipyData, "ServerGroupIDListExcept") else ipyData.GetServerGroupIDListExcept() + platformList = [] if not hasattr(ipyData, "GetPlatformList") else ipyData.GetPlatformList() + serverGroupIDList = [] if not hasattr(ipyData, "GetServerGroupIDList") else ipyData.GetServerGroupIDList() + serverGroupIDListExcept = [] if not hasattr(ipyData, "GetServerGroupIDListExcept") else ipyData.GetServerGroupIDListExcept() cfgID = ipyData.GetCfgID() startDateStr = ipyData.GetStartDate() endDateStr = ipyData.GetEndDate() @@ -257,6 +264,7 @@ % (cfgID, actNum, startDateStr, endDateStr, openServerDay, isMixServer, mixServerDay, curDateTime, platformList, serverGroupIDList, serverGroupIDListExcept)) actIDDateTimeSpec = None # 特殊指定的活动ID日期 + startDateSync = None # 特殊同步前端显示用的开始日期,一般用于与开服前X天交叉的活动 if actName in ShareDefine.MultiActNumOperationActNameList: # 多活动分组编号的需要把所有配置的 actNum 都登记进来,以确保地图能正确进行逻辑 if actNum not in mapServerOperationActionDict[actName]: @@ -273,10 +281,30 @@ endDateStr = "%d-%d-%d" % (serverTime.year, serverTime.month, serverTime.day) GameWorld.Log(" 结束日期为空,默认每天,今日为: endDateStr=%s" % endDateStr) - # 开服常规: 开服天 > 日期 > 周x (不受合服天影响,合服活动新增一套独立的活动,还是走运营活动配置) + actByLoopYmd = startDateStr.startswith("L") # 按日期循环 + # 根据日期循环的通用 + if actByLoopYmd: + if cfgID in coverDisableLoopIpyDataInfo: + loopStartDate, loopEndDate, ymdCfgID, ymdStartDate, ymdEndDate = coverDisableLoopIpyDataInfo[cfgID] + GameWorld.Log(" 按日期循环的在按日期开启的时间内,不处理! cfgID=%s,%s(%s) ~ %s(%s) in ymdCfgID=%s,%s ~ %s" + % (cfgID, loopStartDate, startDateStr, loopEndDate, endDateStr, ymdCfgID, ymdStartDate, ymdEndDate)) + continue + + if cfgID in disableLoopCfgIDDict: + GameWorld.Log(" 按日期循环的未到开启循环日期或已结束循环日期,不处理! cfgID=%s,startDateStr=%s,endDateStr=%s" % (cfgID, startDateStr, endDateStr)) + continue + + if cfgID in otherLoopCfgIDDict: + loopCfgIDList, startDateStr, endDateStr, loopIndex, loopTimes = otherLoopCfgIDDict[cfgID] + GameWorld.Log(" 按日期循环的还未循环到当前配置,不处理! cfgID=%s,startDateStr=%s,endDateStr=%s,loopCfgIDList=%s,loopIndex=%s,loopTimes=%s" + % (cfgID, startDateStr, endDateStr, loopCfgIDList, loopIndex, loopTimes)) + continue + startDateStr, endDateStr = GameWorld.GetOperationActionDateStr(ipyData) + + # 开服常规: 开服天 > 日期 > 周x=日期循环 (不受合服天影响,合服活动新增一套独立的活动,还是走运营活动配置) if actType == ShareDefine.ActType_OpenComm: actByWeek = (startDateStr.startswith("W") and endDateStr.startswith("W")) # 按周x开 - actByDate = (not actByWeek and startDateStr.count("-") == 2 and endDateStr.count("-") == 2) # 按日期开 + actByDate = (not actByLoopYmd and not actByWeek and startDateStr.count("-") == 2 and endDateStr.count("-") == 2) # 按日期开 # 开服天的 if startDateStr.isdigit() and endDateStr.isdigit(): @@ -292,21 +320,20 @@ GameWorld.Log(" 开服天转化为日期: %s ~ %s" % (startDateStr, endDateStr)) # 常规配置: 开服前X天不开,不受合服影响,功能配置表可配置 开服前X天后交叉可开,每日重置的活动默认可开 - elif actByWeek or actByDate: + elif actByWeek or actByDate or actByLoopYmd: if openServerDay <= customMaxServerDay: GameWorld.Log(" 按日期/周开的在开服定制限制天内,不处理! cfgID=%s,%s ~ %s,openServerDay=%s" % (cfgID, startDateStr, endDateStr, openServerDay)) continue - disableWeekIpyDataInfo = actNumDisableWeekIpyDataInfo.get(actNum, {}) - if cfgID in disableWeekIpyDataInfo: - startWeekDate, endWeekDate, ymdCfgID, ymdStartDate, ymdEndDate = disableWeekIpyDataInfo[cfgID] + if cfgID in coverDisableWeekIpyDataInfo: + startWeekDate, endWeekDate, ymdCfgID, ymdStartDate, ymdEndDate = coverDisableWeekIpyDataInfo[cfgID] GameWorld.Log(" 常规活动,按星期开启的在按日期开启的时间内,不处理! cfgID=%s,%s(%s) ~ %s(%s) in ymdCfgID=%s,%s ~ %s" % (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])) + % (cfgID, startDateStr, endDateStr, str(disableWeekCfgIDDict[cfgID]))) continue if actByWeek: @@ -331,6 +358,14 @@ % (customMaxServerDateTime.year, customMaxServerDateTime.month, customMaxServerDateTime.day), ChConfig.TYPE_Time_Format) + datetime.timedelta(days=1) GameWorld.Log(" 开服天后可开启的非每日重置活动! 活动ID日期特殊设置为开服定制天结束后一天! cfgID=%s,actIDDateTimeSpec=%s" % (cfgID, actIDDateTimeSpec)) + + # 特殊同步的开始日期,无视是否每日重置 + if actName in startDateInCustomCanOpenList: + startDateSync = datetime.datetime.strptime("%d-%d-%d 00:00:00" + % (customMaxServerDateTime.year, customMaxServerDateTime.month, customMaxServerDateTime.day), + ChConfig.TYPE_Time_Format) + datetime.timedelta(days=1) + startDateSync = "%d-%d-%d" % (startDateSync.year, startDateSync.month, startDateSync.day) + else: GameWorld.Log(" 开服常规活动,配置时间格式不支持,不处理! cfgID=%s,startDateStr=%s,endDateStr=%s" % (cfgID, startDateStr, endDateStr)) continue @@ -364,6 +399,13 @@ GameWorld.Log(" 非法配置,未知活动类型,不处理! cfgID=%s,actNum=%s" % (cfgID, actNum)) continue + if hasattr(ipyData, "GetJoinStartTime") and hasattr(ipyData, "GetJoinEndTime"): + joinStartTimeStr = ipyData.GetJoinStartTime() + joinEndTimeStr = ipyData.GetJoinEndTime() + else: + joinStartTimeStr = "" + joinEndTimeStr = "" + if hasattr(ipyData, "GetStartTimeList") and hasattr(ipyData, "GetEndTimeList"): startHMStrList = ipyData.GetStartTimeList() endHMStrList = ipyData.GetEndTimeList() @@ -380,6 +422,7 @@ % (actName, cfgID, startHMStrList, endHMStrList)) continue + isDayRest = 0 if not hasattr(ipyData, "GetIsDayReset") else ipyData.GetIsDayReset() resetType = 0 if not hasattr(ipyData, "GetResetType") else ipyData.GetResetType() # 重置类型,0-0点重置;1-5点重置 if resetType == 1: startDayDate = datetime.datetime.strptime("%s 05:00:00" % (startDateStr), ChConfig.TYPE_Time_Format) @@ -487,6 +530,17 @@ GameWorld.Log(" startList=%s" % (startList)) GameWorld.Log(" end List=%s" % (endList)) + joinStartTimeList, joinEndTimeList = [], [] # 可指定活动可参与的时间点,不影响活动状态,只影响活动某些功能的参与时机,如上榜类 + if joinStartTimeStr: + if isDayRest: + joinStartTimeList.append(datetime.datetime.strptime("%d-%d-%d %s:00" % (curDateTime.year, curDateTime.month, curDateTime.day, joinStartTimeStr), ChConfig.TYPE_Time_Format)) + joinEndTimeList.append(datetime.datetime.strptime("%d-%d-%d %s:00" % (curDateTime.year, curDateTime.month, curDateTime.day, joinEndTimeStr), ChConfig.TYPE_Time_Format)) + else: + joinStartTimeList.append(datetime.datetime.strptime("%s %s:00" % (startDateStr, joinStartTimeStr), ChConfig.TYPE_Time_Format)) + joinEndTimeList.append(datetime.datetime.strptime("%s %s:00" % (endDateStr, joinEndTimeStr), ChConfig.TYPE_Time_Format)) + GameWorld.Log(" joinStartTimeList=%s" % (joinStartTimeList)) + GameWorld.Log(" joinEndTime List=%s" % (joinEndTimeList)) + for dtIndex, startDateTime in enumerate(startList): endDateTime = endList[dtIndex] # 广播 - 相对实际开始时间 @@ -532,9 +586,9 @@ if actName in ShareDefine.MultiActNumOperationActNameList: if actName not in operationTodayActionDict: operationTodayActionDict[actName] = {} # 今日有需要处理的才初始化 - operationTodayActionDict[actName][actNum] = [ipyData, startList, endList, notifyDict] + operationTodayActionDict[actName][actNum] = [ipyData, startList, endList, notifyDict, joinStartTimeList, joinEndTimeList] else: - operationTodayActionDict[actName] = [ipyData, startList, endList, notifyDict] + operationTodayActionDict[actName] = [ipyData, startList, endList, notifyDict, joinStartTimeList, joinEndTimeList] if isActTime: activityInfoDict = {ShareDefine.ActKey_CfgID:cfgID, ShareDefine.ActKey_ActNum:actNum} @@ -542,9 +596,12 @@ #活动每天的世界等级 activityInfoDict[ShareDefine.ActKey_WorldLVList] = GameWorldAverageLv.GetWorldLVListByTime(startDayDate, (endDayDate - startDayDate).days) + if startDateSync: + activityInfoDict[ShareDefine.ActKey_StartDateSync] = startDateSync + GameWorld.Log(" startDateSync=%s" % (startDateSync)) + dayIndex = (curDateTime - startDayDate).days actIDDateTime = startDayDate - isDayRest = 0 if not hasattr(ipyData, "GetIsDayReset") else ipyData.GetIsDayReset() # 按时段开的默认每天重置 if isDayRest or (startHMStrList and endHMStrList): actIDDateTime += datetime.timedelta(days=dayIndex) @@ -585,9 +642,9 @@ actCfgCount = getattr(ipyDataMgr, "Get%sCount" % actName)() for cfgIndex in xrange(actCfgCount): ipyData = getattr(ipyDataMgr, "Get%sByIndex" % actName)(cfgIndex) - platformList = [] if not hasattr(ipyData, "PlatformList") else ipyData.GetPlatformList() - serverGroupIDList = [] if not hasattr(ipyData, "ServerGroupIDList") else ipyData.GetServerGroupIDList() - serverGroupIDListExcept = [] if not hasattr(ipyData, "ServerGroupIDListExcept") else ipyData.GetServerGroupIDListExcept() + platformList = [] if not hasattr(ipyData, "GetPlatformList") else ipyData.GetPlatformList() + serverGroupIDList = [] if not hasattr(ipyData, "GetServerGroupIDList") else ipyData.GetServerGroupIDList() + serverGroupIDListExcept = [] if not hasattr(ipyData, "GetServerGroupIDListExcept") else ipyData.GetServerGroupIDListExcept() if platformList and platform not in platformList: continue @@ -616,11 +673,16 @@ return curServerActIpyDataList -def __GetOperationActionDisableWeekIpyDataInfo(actName, curDateTime, curServerActIpyDataList): +def __GetOperationActionDisableIpyDataInfo(actName, curDateTime, curServerActIpyDataList): ## 获取不可用的按星期X开启的配置数据信息,按星期X开启的 活动优先级小于按日期的,当有重叠时以日期的为准 - #curWeekday = curDateTime.weekday() + 1 # 今天星期几, 1代表星期1 - actNumWeekYMDIpyDataInfo = {} # {actNum:[weekIpyDataList, ymdIpyDatList], ...} - disableWeekCfgIDDict = {} # {cfgID:[startDateStr, endDateStr], ...} + # 优先级 日期 > 按日期循环 > 按星期循环 + + actNumYMDIpyDataInfo = {} # {actNum:ymdIpyDataList, ...} # 配置日期的 + actNumLoopIpyDataInfo = {} # {actNum:{loopKey:[loopCfgIDList, loopDateInfo]}, ...} # 按日期循环的 + actNumWeekIpyDataInfo = {} # {actNum:weekIpyDataList, ...} # 按星期循环的 + + disableWeekCfgIDDict = {} # {cfgID:[startDateStr, endDateStr], ...} # 未开始循环的星期 + disableLoopCfgIDDict = {} # {cfgID:[startDateStr, endDateStr], ...} # 未开始循环的日期 curDateTimeYmdStr = "%d-%d-%d" % (curDateTime.year, curDateTime.month, curDateTime.day) curDateTimeYmd = GameWorld.ChangeStrToDatetime(curDateTimeYmdStr, ChConfig.TYPE_Time_YmdFormat) @@ -630,50 +692,90 @@ startDateStr = ipyData.GetStartDate() endDateStr = ipyData.GetEndDate() actNum = GetOperationActNum(actName, ipyData) - actType = GetOperationActType(actNum) - # 这里只处理常规运营活动,日期优先级大于周 - if actType != ShareDefine.ActType_OpenComm: - continue - - if actNum not in actNumWeekYMDIpyDataInfo: - weekIpyDataList, ymdIpyDatList = [], [] - actNumWeekYMDIpyDataInfo[actNum] = [weekIpyDataList, ymdIpyDatList] - weekIpyDataList, ymdIpyDatList = actNumWeekYMDIpyDataInfo[actNum] # 按星期X的 if startDateStr.startswith("W"): + if actNum not in actNumWeekIpyDataInfo: + actNumWeekIpyDataInfo[actNum] = [] + weekIpyDataList = actNumWeekIpyDataInfo[actNum] 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]) + weekIpyDataList.append([cfgID, startWeekDate, endWeekDate]) + # 按日期循环 + elif startDateStr.startswith("L"): + loopStartDate, loopEndDate, loopTimes = GameWorld.GetOperationActionLoopDate(startDateStr, endDateStr, curDateTime) + if loopStartDate > curDateTimeYmd or curDateTimeYmd > loopEndDate: # 还未开始的循环 or 已经强制结束的循环 + disableLoopCfgIDDict[cfgID] = [startDateStr, endDateStr] + else: + loopKey = (startDateStr, endDateStr) # 同个循环周期的视为同一组 + if actNum not in actNumLoopIpyDataInfo: + actNumLoopIpyDataInfo[actNum] = {} + loopIpyDataDict = actNumLoopIpyDataInfo[actNum] + if loopKey not in loopIpyDataDict: + loopCfgIDList, loopDateInfo = [], [loopStartDate, loopEndDate, loopTimes] + loopIpyDataDict[loopKey] = [loopCfgIDList, loopDateInfo] + loopCfgIDList, loopDateInfo = loopIpyDataDict[loopKey] + loopCfgIDList.append(cfgID) + # 按日期的 elif startDateStr.count("-") == 2: - ymdIpyData = ipyData - ymdStartDate = datetime.datetime.strptime("%s %02d:%02d:00" % (startDateStr, curDateTime.hour, curDateTime.minute), ChConfig.TYPE_Time_Format) - ymdEndDate = datetime.datetime.strptime("%s %02d:%02d:00" % (endDateStr, curDateTime.hour, curDateTime.minute), ChConfig.TYPE_Time_Format) - ymdIpyDatList.append([ymdIpyData, ymdStartDate, ymdEndDate]) + if actNum not in actNumYMDIpyDataInfo: + actNumYMDIpyDataInfo[actNum] = [] + ymdIpyDataList = actNumYMDIpyDataInfo[actNum] + ymdStartDate = GameWorld.ChangeStrToDatetime(startDateStr, ChConfig.TYPE_Time_YmdFormat) + ymdEndDate = GameWorld.ChangeStrToDatetime(endDateStr, ChConfig.TYPE_Time_YmdFormat) + ymdIpyDataList.append([cfgID, ymdStartDate, ymdEndDate]) else: - # 只处理按星期、按日期的,其他的不处理 + # 其他的不处理 pass - actNumDisableWeekIpyDataInfo = {} # {actNum:{cfgID:[info], ...}, ...} - for actNum, weekYMDIpyDataInfo in actNumWeekYMDIpyDataInfo.items(): - weekIpyDataList, ymdIpyDatList = weekYMDIpyDataInfo - for ipyData, startWeekDate, endWeekDate in weekIpyDataList: - cfgID = ipyData.GetCfgID() - for ymdIpyData, ymdStartDate, ymdEndDate in ymdIpyDatList: - if ymdStartDate <= startWeekDate <= ymdEndDate or ymdStartDate <= endWeekDate <= ymdEndDate: - if actNum not in actNumDisableWeekIpyDataInfo: - actNumDisableWeekIpyDataInfo[actNum] = {} - ymdCfgID = ymdIpyData.GetCfgID() - actNumDisableWeekIpyDataInfo[actNum][cfgID] = [startWeekDate, endWeekDate, ymdCfgID, ymdStartDate, ymdEndDate] + nowLoopYMDIpyDataInfo = {} # {actNum:loopIpyDataList, ...} # # 日期循环中当前在循环的 + otherLoopCfgIDDict = {} # {cfgID:[info], ...} # 日期循环中不是当前循环的其他循环 + coverDisableLoopIpyDataInfo = {} # {cfgID:[info], ...} # 被日期覆盖的日期循环 + for actNum, loopIpyDataDict in actNumLoopIpyDataInfo.items(): + ymdIpyDataList = actNumYMDIpyDataInfo.get(actNum, []) + if actNum not in nowLoopYMDIpyDataInfo: + nowLoopYMDIpyDataInfo[actNum] = [] + loopIpyDataList = nowLoopYMDIpyDataInfo[actNum] + for loopKey, loopInfo in loopIpyDataDict.items(): + startDateStr, endDateStr = loopKey + loopCfgIDList, loopDateInfo = loopInfo + loopStartDate, loopEndDate, loopTimes = loopDateInfo + loopIndex = (loopTimes - 1) % len(loopCfgIDList) # 当前循环次数对应的循环索引 + curLoopCfgID = 0 + for index, loopCfgID in enumerate(loopCfgIDList): + if index == loopIndex: # 当前循环的 + curLoopCfgID = loopCfgID + loopIpyDataList.append([loopCfgID, loopStartDate, loopEndDate]) + else: + otherLoopCfgIDDict[loopCfgID] = [loopCfgIDList, startDateStr, endDateStr, loopIndex, loopTimes] - return actNumDisableWeekIpyDataInfo, disableWeekCfgIDDict + for ymdCfgID, ymdStartDate, ymdEndDate in ymdIpyDataList: + if ymdStartDate <= loopStartDate <= ymdEndDate or ymdStartDate <= loopEndDate <= ymdEndDate: + coverDisableLoopIpyDataInfo[curLoopCfgID] = [loopStartDate, loopEndDate, ymdCfgID, ymdStartDate, ymdEndDate] + + coverDisableWeekIpyDataInfo = {} # {cfgID:[info], ...} # 被日期覆盖的星期循环 + for actNum, weekIpyDataList in actNumWeekIpyDataInfo.items(): + ymdIpyDataList = actNumYMDIpyDataInfo.get(actNum, []) + loopIpyDatList = nowLoopYMDIpyDataInfo.get(actNum, []) + for weekCfgID, startWeekDate, endWeekDate in weekIpyDataList: + # 被常规日期覆盖的 + for ymdCfgID, ymdStartDate, ymdEndDate in ymdIpyDataList: + if ymdStartDate <= startWeekDate <= ymdEndDate or ymdStartDate <= endWeekDate <= ymdEndDate: + coverDisableWeekIpyDataInfo[weekCfgID] = [startWeekDate, endWeekDate, ymdCfgID, ymdStartDate, ymdEndDate] + + # 被循环日期覆盖的 + for loopCfgID, loopStartDate, loopEndDate in loopIpyDatList: + if loopStartDate <= startWeekDate <= loopEndDate or loopStartDate <= endWeekDate <= loopEndDate: + coverDisableWeekIpyDataInfo[weekCfgID] = [startWeekDate, endWeekDate, loopCfgID, loopStartDate, loopEndDate] + + return coverDisableLoopIpyDataInfo, disableLoopCfgIDDict, otherLoopCfgIDDict, coverDisableWeekIpyDataInfo, disableWeekCfgIDDict def Dispose_OperationActionState(reloadRefresh=False): # 运营活动状态处理, 每天0点会强制同步当天的运营活动详情到地图服务器 @@ -708,6 +810,7 @@ for sendMapServerMsgDict in curActMapInfoDictList: state = 0 # 默认关闭 + stateJoin = ShareDefine.ActStateJoin_None # 可参与状态,0-参与前;1-可参与;2-参与结束 ipyData = None actNum = sendMapServerMsgDict.get(ShareDefine.ActKey_ActNum, 0) @@ -720,12 +823,12 @@ else: todayActInfoList = operationTodayActionDict[actName] - if isinstance(todayActInfoList, list) and len(todayActInfoList) == 4: + if isinstance(todayActInfoList, list) and len(todayActInfoList) == 6: #startList = [] # [startDateTime, ...] #endList = [] # [endDateTime, ...] #notifyDict = {} # {notifyDateTime:[notifyKey, [参数]], ...} #ipyData 可能为 None - ipyData, startList, endList, notifyDict = todayActInfoList + ipyData, startList, endList, notifyDict, joinStartTimeList, joinEndTimeList = todayActInfoList # 状态 for dIndex, startDateTime in enumerate(startList): @@ -733,6 +836,17 @@ if startDateTime <= curDateTime < endDateTime: state = dIndex + 1 # 代表第几个时间段 break + + if joinStartTimeList: + for jIndex, joinStartDateTime in enumerate(joinStartTimeList): + endJoinDateTime = joinEndTimeList[jIndex] + if joinStartDateTime <= curDateTime < endJoinDateTime: + stateJoin = ShareDefine.ActStateJoin_Start + break + elif curDateTime >= endJoinDateTime: + stateJoin = ShareDefine.ActStateJoin_End + else: + stateJoin = ShareDefine.ActStateJoin_Start if state else ShareDefine.ActStateJoin_None # 全服广播提示信息 if curDateTime in notifyDict: @@ -743,12 +857,19 @@ if actName in ShareDefine.MultiActNumOperationActNameList: dictName += "_%s" % actNum preState = gameWorld.GetDictByKey(dictName) - if not isReload and preState == state: + + dictNameJoin = ChConfig.Def_WorldKey_OperationActionStateJoin % actName + if actName in ShareDefine.MultiActNumOperationActNameList: + dictNameJoin += "_%s" % actNum + preStateJoin = gameWorld.GetDictByKey(dictNameJoin) + + if not isReload and preState == state and preStateJoin == stateJoin: #已经是这个状态了 continue - GameWorld.Log("运营活动变更: actName=%s,actNum=%s,preState=%s,state=%s,dictName=%s" % (actName, actNum, preState, state, dictName)) + GameWorld.Log("运营活动变更: actName=%s,actNum=%s,preState=%s,state=%s,preStateJoin=%s,stateJoin=%s" % (actName, actNum, preState, state, preStateJoin, stateJoin)) #更新字典值 gameWorld.SetDict(dictName, state) + gameWorld.SetDict(dictNameJoin, stateJoin) dbOperationActIDKey = PlayerDBGSEvent.Def_OperationActID % actName dbOperationActWorldLVKey = PlayerDBGSEvent.Def_OActWorldLV % actName @@ -763,6 +884,17 @@ GameWorld.Log(" dbActID变更: dbActID=%s,curActID=%s" % (dbActID, curActID)) PlayerDBGSEvent.SetDBGSTrig_ByKey(dbOperationActIDKey, curActID) + # 结束旧的 + if dbActID: + if actName == ShareDefine.OperationActionName_BossTrial: + PlayerActBossTrial.OnActEnd(actNum, ipyData, dayIndex) + elif actName == ShareDefine.OperationActionName_XianXiaMJ: + PlayerActXianXiaMJ.OnActEnd(actNum, ipyData, dayIndex) + elif actName == ShareDefine.OperationActionName_Gubao: + PlayerActGubao.OnActEnd(actNum, ipyData, dayIndex) + elif actName == ShareDefine.OperationActionName_HorsePetTrain: + PlayerActHorsePetTrain.OnActEnd(actNum, ipyData, dayIndex) + if curActID: if actName in ShareDefine.NeedWorldLVOperationActNameList: #记录开启时世界等级 @@ -790,6 +922,16 @@ PlayerStore.ResetFlashSaleBuyCnt(ipyData) elif actName == ShareDefine.OperationActionName_GarbageSorting: PlayerActGarbageSorting.OnActStart(actNum) + elif actName == ShareDefine.OperationActionName_BossTrial: + PlayerActBossTrial.OnActStart(actNum) + elif actName == ShareDefine.OperationActionName_XianXiaMJ: + PlayerActXianXiaMJ.OnActStart(actNum, ipyData) + elif actName == ShareDefine.OperationActionName_Gubao: + PlayerActGubao.OnActStart(actNum, ipyData) + elif actName == ShareDefine.OperationActionName_HorsePetTrain: + PlayerActHorsePetTrain.OnActStart(actNum, ipyData) + elif actName == ShareDefine.OperationActionName_FamilyCTGAssist: + PlayerActFamilyCTGAssist.OnActStart(actNum) else: if actName == ShareDefine.OperationActionName_GarbageSorting: PlayerActGarbageSorting.OnActEnd(actNum) @@ -797,6 +939,34 @@ else: GameWorld.Log(" dbActID不变: dbActID=%s,curActID=%s" % (dbActID, curActID)) + # 活动中刷新,每次都需要刷新的逻辑,包含重读配置等 + if state: + if actName == ShareDefine.OperationActionName_BossTrial: + PlayerActBossTrial.OnActInStateRefresh(actNum, ipyData, dayIndex) + elif actName == ShareDefine.OperationActionName_XianXiaMJ: + PlayerActXianXiaMJ.OnActInStateRefresh(actNum, ipyData) + elif actName == ShareDefine.OperationActionName_Gubao: + PlayerActGubao.OnActInStateRefresh(actNum, ipyData) + elif actName == ShareDefine.OperationActionName_HorsePetTrain: + PlayerActHorsePetTrain.OnActInStateRefresh(actNum, ipyData) + + # 仅活动有配置参与时间段的会触发 + if curActID and dbActID == curActID and preStateJoin != stateJoin: + GameWorld.Log(" 参与状态变更: preStateJoin=%s,stateJoin=%s" % (preStateJoin, stateJoin)) + # 参与开始 + if stateJoin == ShareDefine.ActStateJoin_Start: + pass + # 参与结束 + elif stateJoin == ShareDefine.ActStateJoin_End: + if actName == ShareDefine.OperationActionName_BossTrial: + PlayerActBossTrial.OnActJoinEnd(actNum, ipyData, dayIndex) + elif actName == ShareDefine.OperationActionName_XianXiaMJ: + PlayerActXianXiaMJ.OnActJoinEnd(actNum, ipyData, dayIndex) + elif actName == ShareDefine.OperationActionName_Gubao: + PlayerActGubao.OnActJoinEnd(actNum, ipyData, dayIndex) + elif actName == ShareDefine.OperationActionName_HorsePetTrain: + PlayerActHorsePetTrain.OnActJoinEnd(actNum, ipyData, dayIndex) + if ipyData and actName in ShareDefine.NeedWorldLVOperationActNameList: actWorldLV = PlayerDBGSEvent.GetDBGSTrig_ByKey(dbOperationActWorldLVKey) sendMapServerMsgDict[ShareDefine.ActKey_WorldLV] = actWorldLV @@ -838,6 +1008,7 @@ #GameWorld.SendMapServerMsgEx(dictName, state) # 运营活动不单独通知活动状态,需与活动信息整合后一起通知 sendMapServerMsgDict[ShareDefine.ActKey_State] = state + sendMapServerMsgDict[ShareDefine.ActKey_StateJoin] = stateJoin GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_OperationActionInfo % actName, sendMapServerMsgDict) GameWorld.Log(" sendMapServerMsgDict: %s" % (sendMapServerMsgDict)) @@ -929,7 +1100,7 @@ curDateStr = GameWorld.ChangeTimeNumToStr(curTime, ChConfig.TYPE_Time_YmdFormat) # 当天日期 openServerWeekday = GameWorldProcess.GetOpenServerWeekday() # 服务器开服时是星期几 - curMaxCustomServerDay = IpyGameDataPY.GetFuncCfg("OperationAction", 1) - openServerWeekday + 1 # 最大有效定制开服天 + curMaxCustomServerDay = IpyGameDataPY.GetFuncCfg("OperationAction", 1) # 最大有效定制开服天 maxCustomServerDayMix = IpyGameDataPY.GetFuncCfg("MixServer", 1) GameWorld.Log("===== 加载今天日常活动信息 =====") GameWorld.Log("开服是星期%s, 开服第%s天, 当前星期%s" % (openServerWeekday, openServerDay, weekDay)) @@ -943,7 +1114,7 @@ customIpyDataList = IpyGameDataPY.GetIpyGameDataListNotLog("DailyActionCustom", openServerWeekday) if not customIpyDataList: customIpyDataList = [] - GameWorld.Log(" 本周定制的开服日常活动条数: %s" % len(customIpyDataList)) + GameWorld.Log(" 定制的开服日常活动条数: %s" % len(customIpyDataList)) customIDList = [] todayCustomIDList = [] for customIpyData in customIpyDataList: @@ -957,8 +1128,8 @@ customType = 1 dailyTimeInfoList.append([customType, customIpyData.GetOpenTimeList(), customIpyData]) GameWorld.Log(" 增加本日开服日常活动信息: customType=%s,dailyID=%s,dataID=%s" % (customType, dailyID, dataID)) - GameWorld.Log(" 本周定制的开服日常配置表ID列表: %s" % (customIDList)) - GameWorld.Log(" 本周定制的开服日常活动ID列表: %s" % (customDailyIDList)) + GameWorld.Log(" 定制的开服日常配置表ID列表: %s" % (customIDList)) + GameWorld.Log(" 定制的开服日常活动ID列表: %s" % (customDailyIDList)) GameWorld.Log(" 今天定制的开服日常表ID列表=%s" % (todayCustomIDList)) elif isMixServer and mixServerDay <= maxCustomServerDayMix: todayCustomIDList = [] # 今天定制的数据表ID @@ -1057,6 +1228,9 @@ def Dispose_DailyActionState(): # 日常活动状态变更检查处理 + if GameWorld.IsCrossServer(): + CrossActionControl.Dispose_CrossDailyActionState() + todayDailyActionInfo = __GetTodayDailyActionInfo() if not todayDailyActionInfo: return @@ -1122,11 +1296,20 @@ def SendMapServerDailyActionState(): # 地图启动成功时通知本日进行中的日常活动状态 + gameWorld = GameWorld.GetGameWorld() + if GameWorld.IsCrossServer(): + CrossActionControl.SendMapServerCrossDailyActionState() + else: + for dailyActionID in ShareDefine.CrossDailyActionIDList: + dictName = ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % dailyActionID + state = gameWorld.GetDictByKey(dictName) + if state: + GameWorld.SendMapServerMsgEx(dictName, state) + todayDailyActionInfo = __GetTodayDailyActionInfo() if not todayDailyActionInfo: return - gameWorld = GameWorld.GetGameWorld() for actionInfo in todayDailyActionInfo: dailyActionID = actionInfo[0] dictName = ShareDefine.Def_Notify_WorldKey_DailyActionState % dailyActionID @@ -1235,7 +1418,7 @@ GameWorld.ErrLog("获取开服是星期几数据错误!openServerWeekday=%s" % openServerWeekday) return [] - curMaxCustomServerDay = IpyGameDataPY.GetFuncCfg("OperationAction", 1) - openServerWeekday + 1 # 最大有效定制开服天 + curMaxCustomServerDay = IpyGameDataPY.GetFuncCfg("OperationAction", 1) # 最大有效定制开服天 maxCustomServerDayMix = IpyGameDataPY.GetFuncCfg("MixServer", 1) GameWorld.Log("===== 加载今天副本状态时间表 =====") GameWorld.Log("开服是星期%s, 开服第%s天, 当前星期%s,%s点%s分 !" % (openServerWeekday, openServerDay, curWeekDay, curHour, curMinute)) @@ -1244,15 +1427,15 @@ ipyDataMgr = IpyGameDataPY.IPY_Data() - customMapIDList = [] # 本周有定制的副本数据地图ID列表 + customMapIDList = [] # 有定制的副本数据地图ID列表 fbStateTimeInfoList = [] # 暂固定前2周定制有效, 为方便GM命令测试,这里用开服天做判断,不用开服周 if openServerDay <= curMaxCustomServerDay: customIpyDataList = IpyGameDataPY.GetIpyGameDataListNotLog("FBStateTimeCustom", openServerWeekday) if not customIpyDataList: customIpyDataList = [] - GameWorld.Log(" 本周定制的开服副本活动条数: %s" % len(customIpyDataList)) - customIDList = [] # 本周定制的数据表ID + GameWorld.Log(" 定制的开服副本活动条数: %s" % len(customIpyDataList)) + customIDList = [] # 定制的数据表ID todayCustomIDList = [] # 今天定制的数据表ID for customIpyData in customIpyDataList: dataID = customIpyData.GetID() @@ -1265,8 +1448,8 @@ customType, startWeekDay, endWeekDay = 1, curWeekDay, curWeekDay fbStateTimeInfoList.append([customType, startWeekDay, endWeekDay, customIpyData]) GameWorld.Log(" 今天要处理的开服副本状态配置: customType=%s,dataID=%s" % (customType, dataID)) - GameWorld.Log(" 本周定制的开服副本表ID列表: %s" % (customIDList)) - GameWorld.Log(" 本周定制的开服副本地图列表: %s" % (customMapIDList)) + GameWorld.Log(" 定制的开服副本表ID列表: %s" % (customIDList)) + GameWorld.Log(" 定制的开服副本地图列表: %s" % (customMapIDList)) GameWorld.Log(" 今天定制的开服副本表ID列表=%s" % (todayCustomIDList)) elif isMixServer and mixServerDay <= maxCustomServerDayMix: todayCustomIDList = [] # 今天定制的数据表ID @@ -1294,7 +1477,7 @@ dataMapID = fbStateTimeIpyData.GetDataMapID() # 是当天开服天定制活动的不处理常规活动 if dataMapID in customMapIDList: - GameWorld.Log(" dataID=%s,dataMapID=%s, 在本周定制的副本地图列表里,不处理!" % (dataID, dataMapID)) + GameWorld.Log(" dataID=%s,dataMapID=%s, 在定制的副本地图列表里,不处理!" % (dataID, dataMapID)) continue # 暂不支持跨天的活动 customType, startWeekDay, endWeekDay = 0, fbStateTimeIpyData.GetStartWeekday(), fbStateTimeIpyData.GetStartWeekday() -- Gitblit v1.8.0