From 562f3491c2f87a55fe333d855cd5737223562731 Mon Sep 17 00:00:00 2001
From: hxp <ale99527@vip.qq.com>
Date: 星期五, 25 六月 2021 16:13:47 +0800
Subject: [PATCH] 8921 【主干】【BT2】【后端】H.活动-节日活动-垃圾分类(修复仙匣秘境没有同步大奖已抽次数bug)

---
 ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py |  135 ++++++++++++++++++++++++++++++++++++--------
 1 files changed, 110 insertions(+), 25 deletions(-)

diff --git a/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py b/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldActionControl.py
index 3b62025..43dd8b1 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
@@ -151,6 +152,43 @@
     ## 运营活动类型
     return actNum / 10
 
+def __SaveActWorldLVLimitInfo(actWorldLVLimitInfo):
+    GameWorld.GetUniversalRecMgr().Delete(ShareDefine.Def_UniversalGameRecType_ActWorldLVLimitInfo)
+    recDataList = GameWorld.GetUniversalRecMgr().GetTypeList(ShareDefine.Def_UniversalGameRecType_ActWorldLVLimitInfo)
+    GameWorld.Log("保存运营活动世界等级限制开启信息: %s" % len(actWorldLVLimitInfo))
+    for actName, cfgLimitInfoDict in actWorldLVLimitInfo.items():
+        for cfgID, limitInfo in cfgLimitInfoDict.items():
+            recStartDateStr, recEndDateStr, recLimitWorldLV, recWorldLV = limitInfo
+            recData = recDataList.AddRec()
+            recData.SetStrValue1(recStartDateStr)
+            recData.SetStrValue2(recEndDateStr)
+            recData.SetStrValue3(actName)
+            recData.SetValue1(cfgID)
+            recData.SetValue2(recLimitWorldLV)
+            recData.SetValue3(recWorldLV)
+            GameWorld.Log("    actName=%s,cfgID=%s,recStartDateStr=%s,recEndDateStr=%s,recLimitWorldLV=%s,recWorldLV=%s" 
+                          % (actName, cfgID, recStartDateStr, recEndDateStr, recLimitWorldLV, recWorldLV))
+    return
+
+def __GetActWorldLVLimitInfo():
+    actWorldLVLimitInfo = {}
+    recDataList = GameWorld.GetUniversalRecMgr().GetTypeList(ShareDefine.Def_UniversalGameRecType_ActWorldLVLimitInfo)
+    GameWorld.Log("加载运营活动世界等级限制开启信息: %s" % recDataList.Count())
+    for index in xrange(recDataList.Count()):
+        recData = recDataList.At(index)
+        recStartDateStr = recData.GetStrValue1()
+        recEndDateStr = recData.GetStrValue2()
+        actName = recData.GetStrValue3()
+        cfgID = recData.GetValue1()
+        recLimitWorldLV = recData.GetValue2()
+        recWorldLV = recData.GetValue3()
+        if actName not in actWorldLVLimitInfo:
+            actWorldLVLimitInfo[actName] = {}
+        actWorldLVLimitInfo[actName][cfgID] = [recStartDateStr, recEndDateStr, recLimitWorldLV, recWorldLV]
+        GameWorld.Log("    actName=%s,cfgID=%s,recStartDateStr=%s,recEndDateStr=%s,recLimitWorldLV=%s,recWorldLV=%s" 
+                      % (actName, cfgID, recStartDateStr, recEndDateStr, recLimitWorldLV, recWorldLV))
+    return actWorldLVLimitInfo
+
 def __GetOperationActionInfo(isRefreshState=True):
     # @return: isReload, OperationActionInfo
     
@@ -180,10 +218,13 @@
     serverGroupID = GameWorld.GetServerGroupID()
     ipyDataMgr = IpyGameDataPY.IPY_Data()
     curWeekday = curDateTime.weekday() + 1 # 今天星期几, 1代表星期1
+    curWorldLV = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_WorldAverageLv)
+    actWorldLVLimitInfoOld = __GetActWorldLVLimitInfo()
+    actWorldLVLimitInfoNew = {}
     
     GameWorld.Log("===== 加载本日运营活动信息: %s, serverGroupID=%s,openServerDay=%s,customMaxServerDay=%s,isMixServer=%s,mixServerDay=%s,maxCustomServerDayMix=%s,reloadSign=%s =====" 
                   % (curDateTime, serverGroupID, openServerDay, customMaxServerDay, isMixServer, mixServerDay, maxCustomServerDayMix, reloadSign))
-    GameWorld.Log("    今日周%s" % (curWeekday))
+    GameWorld.Log("    今日周%s, curWorldLV=%s" % (curWeekday, curWorldLV))
     
     for actName in ShareDefine.OperationActionNameList:
         
@@ -194,7 +235,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:
             
@@ -228,7 +269,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():
@@ -256,13 +297,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)) # 开服第一天的日期
@@ -338,7 +379,7 @@
             advanceMinutes = 0 if not hasattr(ipyData, "GetAdvanceMinutes") else ipyData.GetAdvanceMinutes() # 提前通知时间,分钟,暂只支持按天的
             GameWorld.Log("        resetType=%s,startDayDate=%s,endDayDate=%s,startHMStrList=%s,endHMStrList=%s,advanceMinutes=%s" 
                           % (resetType, startDayDate, endDayDate, startHMStrList, endHMStrList, advanceMinutes))
-            
+                
             advanceNoticeDateTime = None
             startDayDateJudge = startDayDate # 用于判断是否需要处理的起始时间,一般是活动开始时间,如果有提前广播或预告则时间会提前
             # 提前预告
@@ -363,6 +404,29 @@
                               % (activityIpyData.GetCfgID(), cfgID, advanceMinutes, minNotifyStartMinute, startDayDateJudge))
                 continue
             
+            # 在需要处理的时间内附加世界等级开启限制,未达到最低世界等级要求的不开,活动时间从未达到到达到也不开
+            limitWorldLV = 0 if not hasattr(ipyData, "GetLimitWorldLV") else ipyData.GetLimitWorldLV() # 限制开启世界等级
+            if limitWorldLV:
+                GameWorld.Log("        limitWorldLV=%s,curWorldLV=%s" % (limitWorldLV, curWorldLV))
+                recInfoType = ""
+                worldLVLimitInfo = actWorldLVLimitInfoOld.get(actName, {})
+                # 注: 该逻辑是在活动时间内的额外处理,所以需要判断此逻辑的前提理论上都在活动时间内,故只要有记录则以当时的记录为准
+                if cfgID in worldLVLimitInfo:
+                    recInfoType = "Old"
+                    recStartDateStr, recEndDateStr, recLimitWorldLV, recWorldLV = worldLVLimitInfo[cfgID]
+                else:
+                    recInfoType = "New"
+                    recStartDateStr, recEndDateStr, recLimitWorldLV, recWorldLV = startDateStr, endDateStr, limitWorldLV, curWorldLV
+                    
+                if actName not in actWorldLVLimitInfoNew:
+                    actWorldLVLimitInfoNew[actName] = {}
+                actWorldLVLimitInfoNew[actName][cfgID] = [recStartDateStr, recEndDateStr, recLimitWorldLV, recWorldLV]
+                
+                if recLimitWorldLV > recWorldLV:
+                    GameWorld.Log("        活动时间内,但服务器世界等级未达到开启活动世界等级,不处理!recLimitWorldLV=%s > recWorldLV=%s %s" 
+                                  % (recLimitWorldLV, recWorldLV, recInfoType))
+                    continue
+                
             startList = [] # [startDateTime, ...]
             endList = [] # [endDateTime, ...]
             startNotifyDict = {} # {notifyDateTime:notifyInfo, ...}
@@ -476,6 +540,7 @@
                     mapServerOperationActionDict[actName] = activityInfoDict
                     
     OperationActionInfo = IpyGameDataPY.SetConfigEx(key, [reloadSign, operationTodayActionDict, mapServerOperationActionDict])
+    __SaveActWorldLVLimitInfo(actWorldLVLimitInfoNew)
     
     GameWorld.Log("本日运营活动信息加载完毕!reloadSign=%s,isRefreshState=%s" % (reloadSign, isRefreshState))
     GameWorld.Log("    operationTodayActionDict=%s" % operationTodayActionDict)
@@ -530,10 +595,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)
@@ -549,11 +619,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
@@ -577,7 +650,7 @@
                     ymdCfgID = ymdIpyData.GetCfgID()
                     actNumDisableWeekIpyDataInfo[actNum][cfgID] = [startWeekDate, endWeekDate, ymdCfgID, ymdStartDate, ymdEndDate]
                     
-    return actNumDisableWeekIpyDataInfo
+    return actNumDisableWeekIpyDataInfo, disableWeekCfgIDDict
 
 def TransferOperationActDBKeyValue():
     '''  服务器启动时调用
@@ -774,10 +847,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))
@@ -789,7 +868,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)
@@ -827,11 +912,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]
@@ -860,11 +945,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()

--
Gitblit v1.8.0