#!/usr/bin/python
|
# -*- coding: GBK -*-
|
#-------------------------------------------------------------------------------
|
#
|
##@package CrossActionControl
|
#
|
# @todo:¿ç·þ»î¶¯×Ü¿ª¹ØÂß¼
|
# @author hxp
|
# @date 2020-01-13
|
# @version 1.0
|
#
|
# ÏêϸÃèÊö: ¿ç·þ»î¶¯×Ü¿ª¹ØÂß¼
|
# ¿ç·þ»î¶¯µÄʱ¼äÒÔ¿ç·þ·þÎñÆ÷Ϊ׼£¬ËùÓеÄ״̬¿ØÖÆÓÉ¿ç·þ·þÎñÆ÷¿ØÖƲ¢¹ã²¥×Ó·þÎñÆ÷
|
# ×Ó·þ½ö×ö¾ßÌå»î¶¯Âß¼
|
#
|
#-------------------------------------------------------------------------------
|
#"""Version = 2020-01-13 17:00"""
|
#-------------------------------------------------------------------------------
|
|
import GameWorld
|
import ShareDefine
|
import PlayerControl
|
import IpyGameDataPY
|
import CrossActCTGBillboard
|
import PlayerActBossTrial
|
import PlayerActXianXiaMJ
|
import PlayerActGubao
|
import PlayerActHorsePetTrain
|
import PlayerActLianqi
|
import PlayerDBGSEvent
|
import CrossFamilyGCZ
|
import CrossRealmMsg
|
import PyGameData
|
import ChConfig
|
import CommFunc
|
|
import datetime
|
import time
|
|
(
|
CrossAct_ReloadSign, # ÐÅÏ¢ÖØÔرê¼Ç
|
CrossAct_TodayInfo, # µ±ÈյĻÐÅÏ¢
|
CrossAct_CfgIDInfo, # ´¦ÀíµÄcfgIDÐÅÏ¢
|
) = range(3)
|
|
def OnPlayerLogin(curPlayer):
|
return
|
|
def OnServerClose():
|
if not GameWorld.IsCrossServer():
|
return
|
|
GameWorld.GetUniversalRecMgr().Delete(ShareDefine.Def_UniversalGameRecType_CrossActInfo)
|
|
if not PyGameData.g_crossActInfoDict:
|
return
|
GameWorld.Log("±£´æ¿ç·þÔËÓª»î¶¯ÐÅϢͨÓüǼ: ")
|
|
# ±£´æ»î¶¯ÖеÄ
|
recDataList = GameWorld.GetUniversalRecMgr().GetTypeList(ShareDefine.Def_UniversalGameRecType_CrossActInfo)
|
for actName, actInfoDict in PyGameData.g_crossActInfoDict.items():
|
for cfgID, actInfo in actInfoDict.items():
|
if not actInfo.get(ShareDefine.ActKey_State):
|
# ·Ç»î¶¯Öеģ¬ÒѾ½áËã¹ýÁË£¬²»ÐèÒª´æ´¢
|
continue
|
state = actInfo.get(ShareDefine.ActKey_State, 0)
|
stateJoin = actInfo.get(ShareDefine.ActKey_StateJoin, 0)
|
actID = actInfo.get(ShareDefine.ActKey_ID, 0)
|
templateID = actInfo.get(ShareDefine.ActKey_TemplateID, 0)
|
serverIDRangeList = actInfo.get(ShareDefine.ActKey_ServerIDRangeList, "")
|
recData = recDataList.AddRec()
|
recData.SetStrValue1(actName)
|
recData.SetStrValue3(str(serverIDRangeList))
|
recData.SetValue1(cfgID)
|
recData.SetValue2(state)
|
recData.SetValue3(actID)
|
recData.SetValue4(templateID)
|
recData.SetValue5(stateJoin)
|
GameWorld.Log(" actName=%s,cfgID=%s,state=%s,stateJoin=%s,actID=%s,templateID=%s,serverIDRangeList=%s"
|
% (actName, cfgID, state, stateJoin, actID, templateID, serverIDRangeList))
|
|
return
|
|
def GetCrossActZoneID(actName, serverGroupID):
|
## »ñÈ¡×Ó·þIDËùÊô¿ç·þ»î¶¯·ÖÇø£¬ ¿ç·þ¡¢×Ó·þͨÓÃ
|
actInfoDict = GetCrossActInfoByServerGroupID(actName, serverGroupID)
|
if not actInfoDict:
|
return
|
cfgID = actInfoDict.get(ShareDefine.ActKey_CfgID)
|
ipyDataInfo = actInfoDict.get(ShareDefine.ActKey_IpyDataInfo)
|
if not ipyDataInfo:
|
GameWorld.ErrLog("ActKey_IpyDataInfoΪ¿Õ, ÕÒ²»µ½¿ç·þ»î¶¯ËùÊô·ÖÇø! actName=%s, serverGroupID=%s, cfgID=%s"
|
% (actName, serverGroupID, cfgID))
|
return
|
return ipyDataInfo.get("ZoneID")
|
|
def GetCrossActInfoByServerGroupID(actName, serverGroupID):
|
'''»ñÈ¡×Ó·þIDËùÊô¿ç·þ»î¶¯ÐÅÏ¢£¬ ¿ç·þ¡¢×Ó·þͨÓÃ
|
@param serverGroupID: ·þÎñÆ÷ID»ò·þÎñÆ÷·ÖID
|
¿ç·þ»î¶¯±íÅäÖõÄÊÇ·þÎñÆ÷ID£¬¶ø×Ó·þºÏ·þºóÒÔÖ÷·þµÄ·þÎñÆ÷ID×÷Ϊ·þÎñÆ÷×éID£¬ËùÒÔÁ½ÖÖ·þÎñÆ÷IDÔڴ˺¯ÊýÖÐͨÓÃ
|
@return: None or ActKey_IpyDataInfo
|
'''
|
|
crossActInfoDict = PyGameData.g_crossActInfoDict
|
if crossActInfoDict and actName in crossActInfoDict:
|
curActInfoDict = crossActInfoDict[actName]
|
|
for actInfoDict in curActInfoDict.values():
|
if not actInfoDict.get(ShareDefine.ActKey_State, 0):
|
continue
|
serverIDRangeList = actInfoDict.get(ShareDefine.ActKey_ServerIDRangeList)
|
if not serverIDRangeList:
|
continue
|
|
for groupInfo in serverIDRangeList:
|
if (isinstance(groupInfo, int) and serverGroupID == groupInfo) \
|
or ((isinstance(groupInfo, tuple) or isinstance(groupInfo, list)) \
|
and len(groupInfo) == 2 and groupInfo[0] <= serverGroupID <= groupInfo[1]):
|
return actInfoDict
|
|
GameWorld.DebugLog("ÕÒ²»µ½·þÎñÆ÷×éID¶ÔÓ¦¿ç·þ»î¶¯·ÖÇø! actName=%s, serverGroupID=%s" % (actName, serverGroupID))
|
return
|
|
def GetCrossActInfoByCfgID(actName, cfgID, zoneID=None):
|
## »ñÈ¡cfgID¶ÔÓ¦µÄ¿ç·þ»î¶¯×´Ì¬ÐÅÏ¢£¬¿ÉÑ¡ÑéÖ¤zoneIDÊÇ·ñÆ¥Åä
|
crossActInfoDict = GetCrossActInfoDict()
|
if actName not in crossActInfoDict:
|
return
|
curActInfoDict = crossActInfoDict[actName]
|
if cfgID not in curActInfoDict:
|
return
|
actInfo = curActInfoDict[cfgID]
|
if zoneID:
|
# ÑéÖ¤·ÖÇøIDÊÇ·ñÕýÈ·
|
ipyDataDict = actInfo.get(ShareDefine.ActKey_IpyDataInfo, {})
|
if not ipyDataDict:
|
return
|
ipyZoneID = ipyDataDict.get("ZoneID", 0)
|
if zoneID != ipyZoneID:
|
return
|
return actInfo
|
|
def GetCrossActInfoByZoneID(actName, zoneID):
|
## »ñÈ¡·ÖÇøID¶ÔÓ¦µÄ¿ç·þ»î¶¯ÐÅÏ¢
|
crossActInfoDict = GetCrossActInfoDict()
|
if actName not in crossActInfoDict:
|
return
|
curActInfoDict = crossActInfoDict[actName]
|
for actInfo in curActInfoDict.values():
|
ipyDataDict = actInfo.get(ShareDefine.ActKey_IpyDataInfo, {})
|
if not ipyDataDict:
|
return
|
ipyZoneID = ipyDataDict.get("ZoneID", 0)
|
if zoneID == ipyZoneID:
|
return actInfo
|
return
|
|
def GetCrossActZoneIDList(actName):
|
## »ñÈ¡¿ç·þ»î¶¯µ±Ç°ËùÓзÖÇøÁбí
|
crossActInfoDict = GetCrossActInfoDict()
|
if actName not in crossActInfoDict:
|
return []
|
zoneIDList = []
|
curActInfoDict = crossActInfoDict[actName]
|
for actInfo in curActInfoDict.values():
|
ipyDataDict = actInfo.get(ShareDefine.ActKey_IpyDataInfo, {})
|
if not ipyDataDict:
|
return
|
zoneID = ipyDataDict.get("ZoneID", 0)
|
if zoneID and zoneID not in zoneIDList:
|
zoneIDList.append(zoneID)
|
return zoneIDList
|
|
def GetCrossActInfoDict():
|
if PyGameData.g_crossActInfoDict == None:
|
PyGameData.g_crossActInfoDict = {}
|
|
# ÏȼÓÔØͨÓüǼ´æ´¢ÖеĻÐÅÏ¢
|
recDataList = GameWorld.GetUniversalRecMgr().GetTypeList(ShareDefine.Def_UniversalGameRecType_CrossActInfo)
|
GameWorld.Log("¼ÓÔØͨÓüǼÖеĿç·þÔËÓª»î¶¯ÐÅÏ¢: %s" % recDataList.Count())
|
for index in xrange(recDataList.Count()):
|
recData = recDataList.At(index)
|
actName = recData.GetStrValue1()
|
strValue3 = recData.GetStrValue3()
|
serverIDRangeList = eval(strValue3) if strValue3 else []
|
cfgID = recData.GetValue1()
|
state = recData.GetValue2()
|
actID = recData.GetValue3()
|
templateID = recData.GetValue4()
|
stateJoin = recData.GetValue5()
|
if not state:
|
continue
|
if actName not in PyGameData.g_crossActInfoDict:
|
PyGameData.g_crossActInfoDict[actName] = {}
|
actInfoDict = PyGameData.g_crossActInfoDict[actName]
|
# »î¶¯ID¡¢×´Ì¬¡¢Ä£°åÐÅÏ¢µ¥¶À´æ´¢£¬ÖØÖûÅжÏÓÃ
|
dbInfo = {ShareDefine.ActKey_ID:actID, ShareDefine.ActKey_State:state, ShareDefine.ActKey_TemplateID:templateID,
|
ShareDefine.ActKey_CfgID:cfgID, ShareDefine.ActKey_ServerIDRangeList:serverIDRangeList,
|
ShareDefine.ActKey_StateJoin:stateJoin}
|
actInfo = {}
|
actInfo.update(dbInfo)
|
actInfo[ShareDefine.ActKey_DBInfo] = dbInfo
|
actInfoDict[cfgID] = actInfo
|
|
GameWorld.Log(" actName=%s,cfgID=%s, %s" % (actName, cfgID, actInfoDict))
|
|
return PyGameData.g_crossActInfoDict
|
|
def __GetParseIpyDataList(ipyDataMgr, actName, actInfoDict):
|
## »ñÈ¡ÐèÒª´¦ÀíµÄºÏ·¨·Ö×é»î¶¯ÅäÖÃÁÐ±í£¬ÒѾÔڻÖеıØÐëÒª´¦Àí
|
|
groupNameList = [] # È·±£·Ö×é˳Ðò
|
groupInfo = {}
|
actCfgCount = getattr(ipyDataMgr, "Get%sCount" % actName)()
|
for cfgIndex in xrange(actCfgCount):
|
ipyData = getattr(ipyDataMgr, "Get%sByIndex" % actName)(cfgIndex)
|
actGroupName = ipyData.GetActGroupName()
|
if actGroupName not in groupInfo:
|
groupInfo[actGroupName] = []
|
groupNameList.append(actGroupName)
|
groupIpyDataList = groupInfo[actGroupName]
|
groupIpyDataList.append(ipyData)
|
|
parseIpyDataList = []
|
for actGroupName in groupNameList:
|
groupIpyDataList = groupInfo[actGroupName]
|
allOpen = False
|
cfgIDList = []
|
allServerIDRangeList = []
|
for ipyData in groupIpyDataList:
|
cfgID = ipyData.GetCfgID()
|
cfgIDList.append(cfgID)
|
serverIDRangeList = ipyData.GetServerIDRangeList()
|
|
if cfgID in actInfoDict and actInfoDict[cfgID]:
|
actInfo = actInfoDict[cfgID]
|
# ÒѾÔڻÖеļǼ±ØÐëÒª´¦Àí
|
parseIpyDataList.append(ipyData)
|
if actName in ShareDefine.CrossActLockServerGroupIDList:
|
serverIDRangeList = actInfo[ShareDefine.ActKey_ServerIDRangeList]
|
GameWorld.Log(" ʹÓÃÒѾÔڻÖеļǼµÄÇø·þ·Ö×é: cfgID=%s,serverIDRangeList=%s"
|
% (cfgID, serverIDRangeList))
|
|
# ûÅäÖõÄÈ«·þ¿ª·Å
|
if not serverIDRangeList:
|
allOpen = True
|
else:
|
allServerIDRangeList.extend(serverIDRangeList)
|
|
if allOpen and len(groupIpyDataList) > 1:
|
GameWorld.ErrLog(" ͬ×é»î¶¯·þÎñÆ÷IDÅäÖÃÒì³££¬ÓÐÈ«·þ¿ª·ÅµÄ£¬Ö»ÄÜÅäÖÃ1Ìõ£¬²»´¦Àí! actGroupName=%s,cfgIDList=%s" % (actGroupName, cfgIDList))
|
continue
|
|
errorServerIDList = []
|
for i in xrange(len(allServerIDRangeList)):
|
checkIDA, checkIDB = allServerIDRangeList[i]
|
for j in xrange(i):
|
serverIDA, serverIDB = allServerIDRangeList[j]
|
if serverIDA <= checkIDA <= serverIDB:
|
errorServerIDList.append(checkIDA)
|
|
if serverIDA <= checkIDB <= serverIDB:
|
errorServerIDList.append(checkIDB)
|
|
if errorServerIDList:
|
GameWorld.ErrLog(" ͬ×é»î¶¯·þÎñÆ÷IDÅäÖÃÒì³££¬Óн»²æ£¬²»´¦Àí! actGroupName=%s,cfgIDList=%s,errorServerIDList=%s"
|
% (actGroupName, cfgIDList, errorServerIDList))
|
continue
|
|
for ipyData in groupIpyDataList:
|
cfgID = ipyData.GetCfgID()
|
if cfgID in actInfoDict and actInfoDict[cfgID]:
|
continue
|
parseIpyDataList.append(ipyData)
|
|
return parseIpyDataList
|
|
def __GetCrossActInfo(isRefreshState=True):
|
# @return: isReload, CrossActInfo
|
|
key = "CrossActInfo"
|
CrossActInfo = IpyGameDataPY.GetConfigEx(key)
|
serverTime = GameWorld.GetServerTime()
|
curDateStr = "%d-%d-%d" % (serverTime.year, serverTime.month, serverTime.day)
|
curHour = serverTime.hour
|
reloadSignHour = 0 if curHour < 5 else 5
|
reloadSign = "%s %s" % (curDateStr, reloadSignHour)
|
if CrossActInfo and CrossActInfo[CrossAct_ReloadSign] == reloadSign:
|
#GameWorld.DebugLog("ÒѾ¼ÓÔعý±¾ÈÕ¿ç·þÔËÓª»î¶¯´¦ÀíÐÅÏ¢£¡reloadSign=%s" % reloadSign)
|
return False, CrossActInfo
|
|
# ÒòΪºóÃæµÄʱ¼äÅж϶¼ÊǾ«È·µ½·ÖµÄ£¬¶ø´¦Àí´ËÂß¼µÄʱºò¿ÉÄܲ»ÊÇ0Ã룬ËùÒÔÕâÀïµÄdatetimeÈ¡µ±Ç°Ê±¼ä¾«È·µ½·ÖµÄ
|
curDateTimeStr = "%s %02d:%02d:00" % (curDateStr, serverTime.hour, serverTime.minute)
|
curDateTime = datetime.datetime.strptime(curDateTimeStr, ChConfig.TYPE_Time_Format)
|
|
actTimeInfoDict = {}
|
actCfgIDInfoDict = {}
|
ipyDataMgr = IpyGameDataPY.IPY_Data()
|
|
GameWorld.Log("=============================================================")
|
GameWorld.Log("¼ÓÔر¾ÈÕ¿ç·þÔËÓª»î¶¯ÐÅÏ¢: %s, reloadSign=%s =====" % (curDateTime, reloadSign))
|
crossActInfoDict = GetCrossActInfoDict()
|
GameWorld.Log(" crossActInfoDict=%s" % crossActInfoDict)
|
|
for actName in ShareDefine.CrossActNameList:
|
|
# È¡³ö±¾»î¶¯ËùÊô±¾·þIDµÄËùÓÐÅäÖÃ
|
GameWorld.Log("¼ÓÔØ¿ç·þÔËÓª»î¶¯: actName=%s" % (actName))
|
|
if not hasattr(ipyDataMgr, "Get%sCount" % actName):
|
GameWorld.ErrLog(" ûÓиÿç·þÔËÓª»î¶¯ÀàÐͶÔÓ¦»î¶¯Ê±¼ä±í! actName=%s" % actName)
|
continue
|
|
curActInfoDict = crossActInfoDict.get(actName, {})
|
|
# ÑéÖ¤·þÎñÆ÷ID²»Öظ´µÄÅäÖÃ
|
parseIpyDataList = __GetParseIpyDataList(ipyDataMgr, actName, curActInfoDict)
|
for ipyData in parseIpyDataList:
|
cfgID = ipyData.GetCfgID()
|
actGroupName = ipyData.GetActGroupName()
|
startDateStr = ipyData.GetStartDate()
|
endDateStr = ipyData.GetEndDate()
|
GameWorld.Log(" cfgID=%s,actGroupName==%s,startDateStr=%s,endDateStr=%s,curDateTime=%s" % (cfgID, actGroupName, startDateStr, endDateStr, curDateTime))
|
if not startDateStr:
|
startDateStr = curDateStr
|
GameWorld.Log(" ¿ªÊ¼ÈÕÆÚΪ¿Õ£¬Ä¬ÈÏÿÌ죬½ñÈÕΪ: startDateStr=%s" % startDateStr)
|
if not endDateStr:
|
endDateStr = curDateStr
|
GameWorld.Log(" ½áÊøÈÕÆÚΪ¿Õ£¬Ä¬ÈÏÿÌ죬½ñÈÕΪ: endDateStr=%s" % endDateStr)
|
|
actByWeek = (startDateStr.startswith("W") and endDateStr.startswith("W")) # °´ÖÜx¿ª
|
if actByWeek:
|
startDateStr, endDateStr = GameWorld.GetOperationActionDateStr(ipyData)
|
GameWorld.Log(" ÐÇÆÚXת»¯ÎªÈÕÆÚ: %s ~ %s" % (startDateStr, endDateStr))
|
|
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()
|
else:
|
startHMStrList = []
|
endHMStrList = []
|
|
notifyInfoDictStart = ipyData.GetNotifyInfoStart() if hasattr(ipyData, "GetNotifyInfoStart") else {}
|
notifyInfoDictEnd = ipyData.GetNotifyInfoEnd() if hasattr(ipyData, "GetNotifyInfoEnd") else {}
|
notifyInfoLoopInfo = ipyData.GetNotifyInfoLoop() if hasattr(ipyData, "GetNotifyInfoLoop") else [] # [Ñ»··ÖÖÓ, ¹ã²¥key, [¹ã²¥²ÎÊýÁбí¿ÉÑ¡]]
|
|
if len(startHMStrList) != len(endHMStrList):
|
GameWorld.ErrLog(" »î¶¯ÅäÖÿªÊ¼¼°½áÊøʱ¼ä¸öÊý²»Æ¥Åä! actName=%s,cfgID=%s,startHMStrList=%s,endHMStrList=%s"
|
% (actName, cfgID, startHMStrList, endHMStrList))
|
|
isDayReset = 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)
|
endDayDate = datetime.datetime.strptime("%s 05:00:00" % (endDateStr), ChConfig.TYPE_Time_Format) # ½áÊøÈÕÆÚ5µã
|
elif resetType == 2:
|
startDayDate = datetime.datetime.strptime("%s 05:00:00" % (startDateStr), ChConfig.TYPE_Time_Format)
|
endDayDate = datetime.datetime.strptime("%s 00:00:00" % (endDateStr), ChConfig.TYPE_Time_Format) + datetime.timedelta(days=1) # ½áÊøÈÕÆÚ¸ôÌì0µã
|
else:
|
startDayDate = datetime.datetime.strptime("%s 00:00:00" % (startDateStr), ChConfig.TYPE_Time_Format)
|
endDayDate = datetime.datetime.strptime("%s 00:00:00" % (endDateStr), ChConfig.TYPE_Time_Format) + datetime.timedelta(days=1) # ½áÊøÈÕÆÚ¸ôÌì0µã
|
|
GameWorld.Log(" resetType=%s,startDayDate=%s,endDayDate=%s,startHMStrList=%s,endHMStrList=%s"
|
% (resetType, startDayDate, endDayDate, startHMStrList, endHMStrList))
|
|
if curDateTime < startDayDate or curDateTime >= endDayDate:
|
isActTime = False
|
if cfgID not in curActInfoDict or not curActInfoDict[cfgID]:
|
GameWorld.Log(" ·Ç»î¶¯Ê±¼ä£¡²»´¦Àí£¡")
|
continue
|
else:
|
isActTime = True
|
|
GameWorld.Log(" ÐèÒª´¦ÀíµÄ¿ç·þÔËÓª»î¶¯ÐÅÏ¢: cfgID=%s,isActTime=%s" % (cfgID, isActTime))
|
|
startList = [] # [startDateTime, ...]
|
endList = [] # [endDateTime, ...]
|
startNotifyDict = {} # {notifyDateTime:notifyInfo, ...}
|
endNotifyDict = {} # {notifyDateTime:notifyInfo, ...}
|
loopNotifyDict = {} # {notifyDateTime:notifyInfo, ...}
|
notifyDict = {}
|
|
# ûÅäÖÃʱ·ÖµÄ´ú±íÈ«Ìì
|
if not startHMStrList:
|
startDateTime = startDayDate
|
endDateTime = endDayDate
|
|
startList.append(startDateTime)
|
endList.append(endDateTime)
|
|
# ÿÌ찴ʱ¶Î¿ªÆôµÄ£¬Ö§³Ö¶àʱ¶Î
|
else:
|
for hmIndex, startHMStr in enumerate(startHMStrList):
|
if hmIndex >= len(endHMStrList):
|
break
|
endHMStr = endHMStrList[hmIndex]
|
# ÿÌ쿪µÄ, ʵ¼Ê¿ª¹Øʱ¼äֻȡ½ñÌìµÄÈÕÆÚ£» ÕâÀïÓиöÎÊÌ⣬ȫ·þ¹ã²¥µÄʱ¼ä²»ÊǽñÌìµÄ, Ôݲ»×öÖ§³Ö£¬Ö®ºóÕæÓÐÕâÖÖÐèÇóÔÙ˵
|
startTimeStr = "%d-%d-%d %s:00" % (curDateTime.year, curDateTime.month, curDateTime.day, startHMStr)
|
endTimeStr = "%d-%d-%d %s:00" % (curDateTime.year, curDateTime.month, curDateTime.day, endHMStr)
|
startDateTime = datetime.datetime.strptime(startTimeStr, ChConfig.TYPE_Time_Format)
|
endDateTime = datetime.datetime.strptime(endTimeStr, ChConfig.TYPE_Time_Format)
|
|
startList.append(startDateTime)
|
endList.append(endDateTime)
|
|
GameWorld.Log(" startList=%s" % (startList))
|
GameWorld.Log(" end List=%s" % (endList))
|
|
joinStartTimeList, joinEndTimeList = [], [] # ¿ÉÖ¸¶¨»î¶¯¿É²ÎÓëµÄʱ¼äµã£¬²»Ó°Ïì»î¶¯×´Ì¬£¬Ö»Ó°Ïì»î¶¯Ä³Ð©¹¦ÄܵIJÎÓëʱ»ú£¬ÈçÉÏ°ñÀà
|
if joinStartTimeStr:
|
if isDayReset:
|
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]
|
# ¹ã²¥ - Ïà¶Ôʵ¼Ê¿ªÊ¼Ê±¼ä
|
for notifyMinute, notifyInfo in notifyInfoDictStart.items():
|
notifyDateTime = startDateTime + datetime.timedelta(minutes=notifyMinute)
|
if notifyDateTime.year == curDateTime.year and notifyDateTime.month == curDateTime.month and notifyDateTime.day == curDateTime.day:
|
startNotifyDict[notifyDateTime] = notifyInfo
|
|
# ¹ã²¥ - Ïà¶Ôʵ¼Ê½áÊøʱ¼ä
|
for notifyMinute, notifyInfo in notifyInfoDictEnd.items():
|
notifyDateTime = endDateTime + datetime.timedelta(minutes=notifyMinute)
|
if notifyDateTime.year == curDateTime.year and notifyDateTime.month == curDateTime.month and notifyDateTime.day == curDateTime.day:
|
endNotifyDict[notifyDateTime] = notifyInfo
|
|
# ¹ã²¥ - Ñ»·¹ã²¥
|
if notifyInfoLoopInfo and len(notifyInfoLoopInfo) >= 2:
|
loopMinutes, loopNotifyKey = notifyInfoLoopInfo[:2]
|
loopNotifyParamList = notifyInfoLoopInfo[2] if len(notifyInfoLoopInfo) > 2 else []
|
notifyInfo = [loopNotifyKey, loopNotifyParamList] # Ñ»·¹ã²¥µÄĬÈÏÎÞ²ÎÊý
|
loopCount, loopMaxCount = 0, 100
|
while loopMinutes and loopNotifyKey and loopCount < loopMaxCount:
|
loopCount += 1
|
notifyDateTime = curDateTime + datetime.timedelta(minutes=loopMinutes * loopCount)
|
if notifyDateTime >= endDateTime:
|
break
|
if notifyDateTime.year == curDateTime.year and notifyDateTime.month == curDateTime.month and notifyDateTime.day == curDateTime.day:
|
loopNotifyDict[notifyDateTime] = notifyInfo
|
|
if startNotifyDict or endNotifyDict or loopNotifyDict:
|
GameWorld.Log(" startNotifyDict: %s, %s" % (len(startNotifyDict.keys()), sorted(startNotifyDict.keys())))
|
GameWorld.Log(" end NotifyDict: %s, %s" % (len(endNotifyDict.keys()), sorted(endNotifyDict.keys())))
|
GameWorld.Log(" loop NotifyDict: %s, %s" % (len(loopNotifyDict.keys()), sorted(loopNotifyDict.keys())))
|
notifyDict.update(startNotifyDict)
|
notifyDict.update(endNotifyDict)
|
notifyDict.update(loopNotifyDict)
|
|
if actName not in actTimeInfoDict:
|
actTimeInfoDict[actName] = {}
|
actTimeInfoDict[actName][cfgID] = [ipyData, startList, endList, notifyDict, joinStartTimeList, joinEndTimeList]
|
if actName not in actCfgIDInfoDict:
|
actCfgIDInfoDict[actName] = [[], []]
|
endCfgIDList, actCfgIDList = actCfgIDInfoDict[actName]
|
|
if actName not in crossActInfoDict:
|
crossActInfoDict[actName] = {}
|
curActInfoDict = crossActInfoDict[actName]
|
if cfgID not in curActInfoDict:
|
curActInfoDict[cfgID] = {}
|
curCfgActInfoDict = curActInfoDict[cfgID]
|
|
# ipyData »î¶¯Ê±¼ä±íÐÅÏ¢ÓÉ¿ç·þ·þÎñÆ÷ͬ²½×Ó·þ£¬»î¶¯ÄÚÈÝÈ¡×Ó·þ×Ô¼ºµÄ
|
ipyDataDict = {}
|
methods = CommFunc.get_class_method(ipyData, "Get") # »ñÈ¡ËùÓÐGet¿ªÍ·µÄ·½·¨
|
for method_name in methods:
|
if method_name in ["GetNotifyInfoStart", "GetNotifyInfoEnd", "GetNotifyInfoLoop", "GetServerIDRangeList"]:
|
continue
|
ipyDataDict[method_name[3:]] = getattr(ipyData, method_name)()
|
ipyDataDict.update({"StartDate":startDateStr, "EndDate":endDateStr})
|
GameWorld.Log(" ipyDataDict=%s" % ipyDataDict)
|
|
curCfgActInfoDict.update({ShareDefine.ActKey_CfgID:cfgID, ShareDefine.ActKey_IpyDataInfo:ipyDataDict})
|
if ShareDefine.ActKey_ServerIDRangeList not in curCfgActInfoDict or actName not in ShareDefine.CrossActLockServerGroupIDList:
|
# ûÓеĻ°ÔòʹÓÃÅäÖÃÖеģ¬·ÀÖ¹ÅäÖÃÐ޸ĵ¼Ö·þÎñÆ÷ID·ÖÇø±ä¶¯ÒýÆðµÄ»î¶¯Êý¾ÝÒì³££¬³ý·Çºǫ́¹¤¾ßÇ¿ÖÆÐÞ¸Ä
|
curCfgActInfoDict[ShareDefine.ActKey_ServerIDRangeList] = ipyData.GetServerIDRangeList()
|
|
actID, dayIndex, templateID = 0, 0, 0
|
if isActTime:
|
''' ×¢£º ¼ì²éÊÇ·ñÒѾ´æÔڻÖеķÖ×飬ÓеĻ°Ç¿Öƽ«ÆäÖÃΪ½áËã״̬£¬ÓÐÇÒ½öÓÐÒ»¸ö»î¶¯ÖеÄ×飬ºóÃæµÄÇ¿ÖƸ²¸ÇÇ°ÃæµÄ
|
parseIpyDataList È·±£Í¬Ò»»î¶¯×éÃûµÄserverID²»»áÖظ´
|
ÕâÀï½øÒ»²½È·±£²»Í¬»î¶¯×éÃûµÄ²»»áͬʱ¿ªÆô»î¶¯£¬ÓÐÇÒ½öÓÐÒ»¸ö»î¶¯ÖеĻ×é
|
'''
|
for befIpyData in parseIpyDataList:
|
befCfgID = befIpyData.GetCfgID()
|
befActGroupName = befIpyData.GetActGroupName()
|
if befActGroupName == actGroupName:
|
break
|
if befCfgID not in actCfgIDList:
|
continue
|
actCfgIDList.remove(befCfgID)
|
if befCfgID in curActInfoDict:
|
befCfgActInfoDict = curActInfoDict[befCfgID]
|
befCfgActInfoDict[ShareDefine.ActKey_ID] = 0 # »î¶¯IDÇ¿ÖÆÖÃΪ0
|
|
if befCfgID in endCfgIDList:
|
continue
|
endCfgIDList.append(befCfgID)
|
GameWorld.Log(" Ç°Ãæ´æÔڻµÄ·Ö×飬ÔòÇ¿ÖƽáÊø»î¶¯£¡ befCfgID=%s,befActGroupName=%s" % (befCfgID, befActGroupName))
|
if cfgID not in actCfgIDList:
|
actCfgIDList.append(cfgID)
|
|
dayIndex = (curDateTime - startDayDate).days
|
actIDDateTime = startDayDate
|
# °´Ê±¶Î¿ªµÄĬÈÏÿÌìÖØÖÃ
|
if isDayReset or (startHMStrList and endHMStrList):
|
actIDDateTime += datetime.timedelta(days=dayIndex)
|
actID = int(time.mktime(actIDDateTime.timetuple())) # ĬÈÏÈ¡¿ªÊ¼Ê±¼äµãµÄtimeÖµ×÷Ϊ»î¶¯ID
|
GameWorld.Log(" isDayReset=%s,actIDDateTime=%s,actID=%s" % (isDayReset, actIDDateTime, actID))
|
|
# Ä£°åID
|
if hasattr(ipyData, "GetTemplateIDList"):
|
templateIDList = ipyData.GetTemplateIDList()
|
templateID = templateIDList[-1] if dayIndex >= len(templateIDList) else templateIDList[dayIndex]
|
|
# ÆäËûÌØÊâÄ£°åID»ñÈ¡´¦Àí£¬ÓÐÐèÒªµÄµ¥¶À´¦Àí¼´¿É£¬¸ù¾Ý»î¶¯¹æÔò×ÔÐÐÀ©Õ¹...
|
else:
|
if cfgID not in endCfgIDList:
|
endCfgIDList.append(cfgID)
|
|
curCfgActInfoDict.update({ShareDefine.ActKey_ID:actID, ShareDefine.ActKey_TemplateID:templateID,
|
ShareDefine.ActKey_DayIndex:dayIndex})
|
|
CrossActInfo = IpyGameDataPY.SetConfigEx(key, [reloadSign, actTimeInfoDict, actCfgIDInfoDict])
|
|
GameWorld.Log("±¾ÈÕ¿ç·þÔËÓª»î¶¯ÐÅÏ¢¼ÓÔØÍê±Ï!reloadSign=%s,isRefreshState=%s" % (reloadSign, isRefreshState))
|
GameWorld.Log(" actTimeInfoDict=%s" % actTimeInfoDict)
|
GameWorld.Log(" actCfgIDInfoDict=%s" % actCfgIDInfoDict)
|
GameWorld.Log(" crossActInfoDict=%s" % crossActInfoDict)
|
GameWorld.Log("=============================================================")
|
if isRefreshState:
|
Dispose_CrossActState(True)
|
|
return True, CrossActInfo
|
|
def Dispose_CrossActState(reloadRefresh=False):
|
|
isReload, CrossActInfo = __GetCrossActInfo(False) # ÕâÀï±ØÐë´«False
|
isReload = isReload or reloadRefresh
|
actTimeInfoDict = CrossActInfo[CrossAct_TodayInfo]
|
actCfgIDInfoDict = CrossActInfo[CrossAct_CfgIDInfo]
|
|
crossActInfoDict = GetCrossActInfoDict()
|
|
# ÕâÀïʱ¼äÐ辫ȷµ½·ÖÖÓ£¬²»È»ºóÃæµÄ±È½Ï»áÆ¥Åä²»µ½
|
curDateTime = GameWorld.GetServerTime()
|
curDateTime = datetime.datetime.strptime("%d-%d-%d %d:%d:00" % (curDateTime.year, curDateTime.month, curDateTime.day,
|
curDateTime.hour, curDateTime.minute), ChConfig.TYPE_Time_Format)
|
actChangeList = []
|
actStateChangeList = []
|
sysnCrossActInfoDict = {}
|
flowStateErrorResetList = []
|
for actName in ShareDefine.CrossActNameList:
|
if actName not in actTimeInfoDict or actName not in crossActInfoDict or actName not in actCfgIDInfoDict:
|
continue
|
|
timeInfoDict = actTimeInfoDict[actName]
|
endCfgIDList, actCfgIDList = actCfgIDInfoDict[actName]
|
# ¿ÉÄÜÒ»ÌõcfgID´¦Àí½áÊø£¬ÁíÒ»ÌõcfgID´¦Àí¿ªÊ¼£¬Ò²¿ÉÄÜͬһÌõcfgID¼´½áÊøͬʱÓÖ¿ªÊ¼£¨ÈçÿÌìÖØÖõģ©
|
cfgIDList = endCfgIDList + actCfgIDList
|
for cfgID in cfgIDList:
|
if cfgID not in timeInfoDict:
|
continue
|
ipyData, startList, endList, notifyDict, joinStartTimeList, joinEndTimeList = timeInfoDict[cfgID]
|
|
isEnd = True
|
state = 0 # ĬÈϹرÕ
|
stateJoin = ShareDefine.ActStateJoin_None # ¿É²ÎÓë״̬£¬0-²ÎÓëÇ°£»1-¿É²ÎÓ룻2-²ÎÓë½áÊø
|
cfgID = ipyData.GetCfgID()
|
groupName = ipyData.GetActGroupName()
|
zoneID = ipyData.GetZoneID()
|
actFlowID = ipyData.GetActFlowID() if hasattr(ipyData, "GetActFlowID") else 0 # »î¶¯Á÷³ÌID
|
actStartDataTime = None
|
|
if cfgID not in crossActInfoDict[actName]:
|
crossActInfoDict[actName][cfgID] = {}
|
actInfoDict = crossActInfoDict[actName][cfgID]
|
|
# ״̬
|
if cfgID not in endCfgIDList:
|
for dIndex, startDateTime in enumerate(startList):
|
endDateTime = endList[dIndex]
|
if startDateTime <= curDateTime < endDateTime:
|
state = dIndex + 1 # Ò²ÊÇ´ú±íµÚ¼¸¸öʱ¼ä¶Î
|
actStartDataTime = startDateTime
|
break
|
if endList:
|
isEnd = (curDateTime >= endList[-1])
|
|
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
|
|
actID = actInfoDict.get(ShareDefine.ActKey_ID, 0)
|
templateID = actInfoDict.get(ShareDefine.ActKey_TemplateID, 0)
|
serverIDRangeList = actInfoDict.get(ShareDefine.ActKey_ServerIDRangeList)
|
dbInfo = actInfoDict.get(ShareDefine.ActKey_DBInfo, {})
|
|
dbState = dbInfo.get(ShareDefine.ActKey_State, 0)
|
dbStateJoin = dbInfo.get(ShareDefine.ActKey_StateJoin, 0)
|
dbCfgID = dbInfo.get(ShareDefine.ActKey_CfgID, 0)
|
dbActID = dbInfo.get(ShareDefine.ActKey_ID, 0)
|
dbTemplateID = dbInfo.get(ShareDefine.ActKey_TemplateID, 0)
|
dbServerIDRangeList = dbInfo.get(ShareDefine.ActKey_ServerIDRangeList, None)
|
|
forceReset = False
|
if dbCfgID == cfgID and dbServerIDRangeList != serverIDRangeList:
|
forceReset = True
|
|
errStateActID = 0
|
if state and actFlowID: # ÓлÁ÷³ÌIDµÄ£¬Êµ¼Ê״̬°´È¡»î¶¯Á÷³Ì¶ÔӦ״̬
|
errStateActID = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ActFlowStateError % (actName, zoneID))
|
# ÒѾÊDz»Í¬»î¶¯ÁË£¬Ç¿ÖÆÖØÖÃÒ쳣״̬±ê¼Ç£¬·ÀÖ¹Ó°Ïìл
|
if errStateActID and (errStateActID != actID or not dbState):
|
GameWorld.Log("°´Á÷³Ì×ߵĻÁ÷³ÌÉÏ´ÎÒì³££¬Ð»ÖØÖÃ״̬! %s,zoneID=%s,actID=%s,errStateActID=%s,dbState=%s" % (actName, zoneID, actID, errStateActID, dbState))
|
PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ActFlowStateError % (actName, zoneID), 0)
|
errStateActID = 0
|
|
flowStateIndex, flowState, flowStatePre = GetActTimeFlowState(actFlowID, actStartDataTime, curDateTime)
|
# ·ÇµÚÒ»¸öÁ÷³Ì״̬±ä¸üµÄʱºò£¬ÒªÑéÖ¤Á÷³ÌÊÇ·ñÕýÈ·£¬Èç¹ûÒì³££¬ÔòÁ÷³ÌÕÕ×ߣ¬±ê¼ÇÒì³££¬¾ßÌåÒì³£µÄ´¦ÀíÓɸ÷»î¶¯×ÔÐд¦Àí
|
if flowStateIndex > 0 and flowState != dbState and flowStatePre != dbState and not errStateActID:
|
GameWorld.ErrLog("°´Á÷³Ì×ߵĻÁ÷³ÌÒÑÒì³£! %s,zoneID=%s,actID=%s,flowStatePre=%s,dbState=%s" % (actName, zoneID, actID, flowStatePre, dbState))
|
PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ActFlowStateError % (actName, zoneID), actID)
|
errStateActID = actID
|
state = flowState
|
|
# È«·þ¹ã²¥ÌáʾÐÅÏ¢
|
if curDateTime in notifyDict and not flowState and not errStateActID:
|
if serverIDRangeList != None:
|
notifyKey, paramList = notifyDict[curDateTime]
|
country = 0
|
serverGroupIDList = []
|
crossNotifyList = []
|
crossNotifyList.append([ShareDefine.CrossNotify_CrossAct, [country, notifyKey, paramList], serverIDRangeList])
|
PlayerControl.CrossNotifyEx(serverGroupIDList, crossNotifyList)
|
|
if not isReload and dbState == state and dbStateJoin == stateJoin and dbActID == actID and not forceReset:
|
#ÒѾÊÇÕâ¸ö״̬ÁË
|
continue
|
GameWorld.Log("¿ç·þÔËÓª»î¶¯×´Ì¬: actName=%s,cfgID=%s,groupName=%s,zoneID=%s,dbState=%s -> state=%s,isEnd=%s, dbActID=%s -> actID=%s,forceReset=%s, dbStateJoin=%s -> stateJoin=%s"
|
% (actName, cfgID, groupName, zoneID, dbState, state, isEnd, dbActID, actID, forceReset, dbStateJoin, stateJoin))
|
|
# ¸üÐÂ״̬
|
actInfoDict[ShareDefine.ActKey_State] = state
|
actInfoDict[ShareDefine.ActKey_StateJoin] = stateJoin
|
dbInfo = {ShareDefine.ActKey_ID:actID, ShareDefine.ActKey_State:state, ShareDefine.ActKey_TemplateID:templateID,
|
ShareDefine.ActKey_CfgID:cfgID, ShareDefine.ActKey_ServerIDRangeList:serverIDRangeList,
|
ShareDefine.ActKey_StateJoin:stateJoin}
|
if errStateActID:
|
actInfoDict[ShareDefine.ActKey_StateError] = errStateActID
|
|
actInfoDict[ShareDefine.ActKey_DBInfo] = dbInfo
|
#GameWorld.Log(" »î¶¯×´Ì¬Í¬²½ÐÅÏ¢: actName=%s,cfgID=%s,groupName=%s,zoneID=%s,actInfoDict=%s" % (actName, cfgID, groupName, zoneID, actInfoDict))
|
if actName not in sysnCrossActInfoDict:
|
sysnCrossActInfoDict[actName] = {}
|
sysnCrossActInfoDict[actName][cfgID] = actInfoDict
|
|
if dbActID != actID or forceReset:
|
GameWorld.Log(" »î¶¯ID±ä¸ü: actName=%s,cfgID=%s,groupName=%s,zoneID=%s,dbActID=%s -> actID=%s,forceReset=%s,dbTemplateID=%s"
|
% (actName, cfgID, groupName, zoneID, dbActID, actID, forceReset, dbTemplateID))
|
|
if errStateActID:
|
flowStateErrorResetList.append((actName, zoneID))
|
|
if actName == ShareDefine.CrossActName_CTGBillboard:
|
CrossActCTGBillboard.OnActIDChange(cfgID, dbTemplateID, state)
|
|
elif actName == ShareDefine.CrossActName_BossTrial:
|
PlayerActBossTrial.OnCrossActIDChange(cfgID, zoneID, ipyData, state)
|
|
elif actName == ShareDefine.CrossActName_XianXiaMJ:
|
PlayerActXianXiaMJ.OnCrossActIDChange(cfgID, zoneID, ipyData, state)
|
|
elif actName == ShareDefine.CrossActName_Gubao:
|
PlayerActGubao.OnCrossActIDChange(cfgID, zoneID, ipyData, state)
|
|
elif actName == ShareDefine.CrossActName_HorsePetTrain:
|
PlayerActHorsePetTrain.OnCrossActIDChange(cfgID, zoneID, ipyData, state)
|
|
elif actName == ShareDefine.CrossActName_Lianqi:
|
PlayerActLianqi.OnCrossActIDChange(cfgID, zoneID, ipyData, state)
|
|
elif actName == ShareDefine.CrossActName_FamilyGCZ:
|
CrossFamilyGCZ.OnCrossActIDChange(cfgID, zoneID, ipyData, state)
|
|
else:
|
actChangeList.append([actName, ipyData, state, cfgID, groupName, zoneID, dbActID, actID, forceReset, dbTemplateID])
|
|
# »î¶¯ID±ä¸üÇ¿ÖÆÊÓΪ״̬±ä¸ü£¬·Àֹά»¤Ç°ºó״̬һÑù£¬µ«Æäʵ»î¶¯IDÒѾ²»Í¬µÄÇé¿ö»áµ¼ÖÂÎÞ·¨´¥·¢×´Ì¬±ä¸ü
|
actIDChange = True
|
actStateChangeList.append([actName, ipyData, dbState, state, cfgID, groupName, zoneID, actIDChange, actID, dbTemplateID])
|
|
elif dbState != state:
|
actIDChange = False
|
GameWorld.Log(" »î¶¯×´Ì¬±ä¸ü: actName=%s,cfgID=%s,groupName=%s,zoneID=%s,dbState=%s -> state=%s,actIDChange=%s,dbTemplateID=%s"
|
% (actName, cfgID, groupName, zoneID, dbState, state, actIDChange, dbTemplateID))
|
actStateChangeList.append([actName, ipyData, dbState, state, cfgID, groupName, zoneID, actIDChange, actID, dbTemplateID])
|
|
# »î¶¯ÖÐˢУ¬Ã¿´Î¶¼ÐèҪˢеÄÂß¼£¬°üº¬ÖضÁÅäÖõÈ
|
if state:
|
if actName == ShareDefine.CrossActName_BossTrial:
|
PlayerActBossTrial.OnCrossActInStateRefresh(cfgID, zoneID, ipyData)
|
elif actName == ShareDefine.CrossActName_XianXiaMJ:
|
PlayerActXianXiaMJ.OnCrossActInStateRefresh(cfgID, zoneID, ipyData)
|
elif actName == ShareDefine.CrossActName_Gubao:
|
PlayerActGubao.OnCrossActInStateRefresh(cfgID, zoneID, ipyData)
|
elif actName == ShareDefine.CrossActName_HorsePetTrain:
|
PlayerActHorsePetTrain.OnCrossActInStateRefresh(cfgID, zoneID, ipyData)
|
elif actName == ShareDefine.CrossActName_Lianqi:
|
PlayerActLianqi.OnCrossActInStateRefresh(cfgID, zoneID, ipyData)
|
|
# ½ö»î¶¯ÓÐÅäÖòÎÓëʱ¼ä¶ÎµÄ»á´¥·¢
|
if actID and dbActID == actID and dbStateJoin != stateJoin:
|
GameWorld.Log(" ²ÎÓë״̬±ä¸ü: dbStateJoin=%s,stateJoin=%s" % (dbStateJoin, stateJoin))
|
# ²ÎÓ뿪ʼ
|
if stateJoin == ShareDefine.ActStateJoin_Start:
|
pass
|
# ²ÎÓë½áÊø
|
elif stateJoin == ShareDefine.ActStateJoin_End:
|
if actName == ShareDefine.CrossActName_BossTrial:
|
PlayerActBossTrial.OnCrossActJoinEnd(cfgID, zoneID, ipyData)
|
|
elif actName == ShareDefine.CrossActName_XianXiaMJ:
|
PlayerActXianXiaMJ.OnCrossActJoinEnd(cfgID, zoneID, ipyData)
|
|
elif actName == ShareDefine.CrossActName_Gubao:
|
PlayerActGubao.OnCrossActJoinEnd(cfgID, zoneID, ipyData)
|
|
elif actName == ShareDefine.CrossActName_HorsePetTrain:
|
PlayerActHorsePetTrain.OnCrossActJoinEnd(cfgID, zoneID, ipyData)
|
|
elif actName == ShareDefine.CrossActName_Lianqi:
|
PlayerActLianqi.OnCrossActJoinEnd(cfgID, zoneID, ipyData)
|
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossActInfo % actName, crossActInfoDict[actName])
|
# ·Ç»î¶¯ÖеĴ¦ÀíÍê¹Ø±Õºó£¬×îºóɾ³ý
|
if not state and isEnd:
|
del crossActInfoDict[actName][cfgID]
|
if not crossActInfoDict[actName]:
|
del crossActInfoDict[actName]
|
GameWorld.Log(" ÒƳý½áÊøµÄ»î¶¯: actName=%s,cfgID=%s,crossActInfoDict=%s" % (actName, cfgID, crossActInfoDict))
|
|
# ͬ²½×Ó·þÎñÆ÷
|
if sysnCrossActInfoDict:
|
serverGroupIDList = []
|
CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_CrossActInfo, sysnCrossActInfoDict, serverGroupIDList)
|
|
# ÐèÒªµÈ»î¶¯µÈͬ²½µ½×Ó·þºó²Å´¦ÀíÒÔÏÂÂß¼£¬²»È»¿ÉÄܵ¼ÖÂ×Ó·þûÓлʱ¼äÃ÷ϸÒýÆð»î¶¯Òì³£
|
for changeInfo in actChangeList:
|
actName, ipyData, state, cfgID, groupName, zoneID, dbActID, actID, forceReset, dbTemplateID = changeInfo
|
GameWorld.Log(" »î¶¯ID±ä¸ü: actName=%s,cfgID=%s,groupName=%s,zoneID=%s,dbActID=%s -> actID=%s,forceReset=%s,dbTemplateID=%s"
|
% (actName, cfgID, groupName, zoneID, dbActID, actID, forceReset, dbTemplateID))
|
|
if actName == ShareDefine.CrossActName_AllRecharge:
|
import CrossActAllRecharge
|
CrossActAllRecharge.OnActIDChange(ipyData, state)
|
|
for changeInfo in actStateChangeList:
|
actName, ipyData, dbState, state, cfgID, groupName, zoneID, actIDChange, actID, dbTemplateID = changeInfo
|
GameWorld.Log(" »î¶¯×´Ì¬±ä¸ü: actName=%s,cfgID=%s,groupName=%s,zoneID=%s,dbState=%s -> state=%s,actIDChange=%s,dbTemplateID=%s"
|
% (actName, cfgID, groupName, zoneID, dbState, state, actIDChange, dbTemplateID))
|
|
if actName == ShareDefine.CrossActName_LuckyCloudBuy:
|
import CrossLuckyCloudBuy
|
CrossLuckyCloudBuy.OnLuckyCloudBuyStateChange(ipyData, actIDChange, state)
|
elif actName == ShareDefine.CrossActName_FamilyGCZ:
|
CrossFamilyGCZ.OnCrossActStateChange(ipyData, actID, dbState, state)
|
|
for actName, zoneID in flowStateErrorResetList:
|
GameWorld.Log("»î¶¯½áÊøÖØÖð´Á÷³Ì×ߵĻÁ÷³ÌÒ쳣״̬! %s,zoneID=%s" % (actName, zoneID))
|
PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ActFlowStateError % (actName, zoneID), 0)
|
|
return
|
|
def IsActFlowStateError(actName, zoneID):
|
## Á÷³Ì״̬ÊÇ·ñÒÑÒì³£
|
errStateActID = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ActFlowStateError % (actName, zoneID))
|
if errStateActID:
|
GameWorld.ErrLog("»î¶¯Á÷³Ì״̬ÒÑÒì³£! %s,zoneID=%s,errStateActID=%s" % (actName, zoneID, errStateActID))
|
return True
|
return False
|
|
def GetActTimeFlowState(actFlowID, actStartDataTime, curDateTime):
|
## »ñÈ¡»î¶¯Á÷³ÌID¶ÔÓ¦µ±Ç°×´Ì¬
|
ipyDataList = IpyGameDataPY.GetIpyGameDataList("ActTimeFlow", actFlowID)
|
if not ipyDataList:
|
return 0
|
|
flowStatePre = 0
|
flowState = 0
|
flowStateIndex = -1
|
for index, timeIpyData in enumerate(ipyDataList):
|
#dataID = timeIpyData.GetID()
|
startDay, startHour, startMinute = timeIpyData.GetStartDay(), timeIpyData.GetStartHour(), timeIpyData.GetStartMinute()
|
endDay, endHour, endMinute = timeIpyData.GetEndDay(), timeIpyData.GetEndHour(), timeIpyData.GetEndMinute()
|
|
startSeconds = ((startDay - 1) * 24 + startHour) * 3600 + startMinute * 60
|
endSeconds = ((endDay - 1) * 24 + endHour) * 3600 + endMinute * 60
|
startDateTime = actStartDataTime + datetime.timedelta(seconds=startSeconds)
|
endDateTime = actStartDataTime + datetime.timedelta(seconds=endSeconds)
|
if curDateTime < startDateTime or curDateTime > endDateTime:
|
flowStatePre = timeIpyData.GetStateValue()
|
continue
|
flowState = timeIpyData.GetStateValue()
|
flowStateIndex = index
|
#notifyInfoDict = timeIpyData.GetNotifyInfo()
|
#if not stateError and notifyInfoDict:
|
# diffDateTime = curDateTime - startDateTime
|
# diffMinute = (diffDateTime.days * 24 * 3600 + diffDateTime.seconds) / 60 # µ±Ç°Ê±¼äÓ뿪ʼʱ¼äÏà²î·ÖÖÓÊý
|
# GameWorld.DebugLog(" ¹ã²¥ÅжÏ: curDateTime=%s,startDateTime=%s,diffDays=%s,diffSeconds=%s,diffMinute=%s"
|
# % (curDateTime, startDateTime, diffDateTime.days, diffDateTime.seconds, diffMinute))
|
# if diffMinute in notifyInfoDict:
|
# notifyKey, paramList = notifyInfoDict[diffMinute]
|
# PlayerControl.WorldNotifyCross(serverGroupIDList, 0, notifyKey, paramList)
|
break
|
|
if not flowState:
|
flowStatePre = 0
|
return flowStateIndex, flowState, flowStatePre
|
|
def Sync_CrossActInfoToClientServer(serverGroupID=0):
|
''' ͬ²½¿ç·þÔËÓª»î¶¯ÐÅÏ¢µ½×Ó·þÎñÆ÷
|
@param serverGroupID: Ϊ0ʱͬ²½ËùÓÐ×Ó·þ
|
'''
|
|
isReload, _ = __GetCrossActInfo()
|
if isReload:
|
# Èç¹ûÊÇÖضÁµÄ£¬ÔòÔÚÄÚ²ãÒѾͬ²½ÁË£¬´Ë´¦²»Öظ´Í¬²½
|
return
|
|
# ͬ²½×Ó·þÎñÆ÷
|
sysnCrossActInfoDict = GetCrossActInfoDict()
|
serverGroupIDList = [serverGroupID] if serverGroupID else []
|
CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_CrossActInfo, sysnCrossActInfoDict, serverGroupIDList)
|
return
|
|
## ================================================================================================
|
|
def CrossServerMsg_CrossActInfo(sysnCrossActInfoDict):
|
## ÊÕµ½¿ç·þ·þÎñÆ÷ͬ²½µÄ¿ç·þÔËÓª»î¶¯×´Ì¬
|
|
GameWorld.Log("===== ÊÕµ½¿ç·þ·þÎñÆ÷ͬ²½µÄ¿ç·þÔËÓª»î¶¯×´Ì¬: %s" % sysnCrossActInfoDict)
|
if PyGameData.g_crossActInfoDict == None or not sysnCrossActInfoDict:
|
PyGameData.g_crossActInfoDict = {}
|
|
for actName, syncActInfoDict in sysnCrossActInfoDict.items():
|
for cfgID, syncActInfo in syncActInfoDict.items():
|
if actName not in PyGameData.g_crossActInfoDict:
|
PyGameData.g_crossActInfoDict[actName] = {}
|
actInfoDict = PyGameData.g_crossActInfoDict[actName]
|
actInfoDict[cfgID] = syncActInfo
|
|
if actName == ShareDefine.CrossActName_LuckyCloudBuy:
|
import CrossLuckyCloudBuy
|
CrossLuckyCloudBuy.Sync_LuckyCloudBuyRoundInfo(None)
|
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossActInfo % actName, syncActInfoDict)
|
|
# ÒÔÏÂÐèÒªµÈ»î¶¯ÐÅϢͬ²½¸øµØͼºó²Å´¦Àí
|
if actName == ShareDefine.CrossActName_FamilyGCZ:
|
CrossFamilyGCZ.ClientServer_CrossActInfo()
|
|
# ɾ³ý·Ç»î¶¯ÖеÄ
|
for actName, actInfoDict in PyGameData.g_crossActInfoDict.items():
|
for cfgID, actInfo in actInfoDict.items():
|
if not actInfo.get(ShareDefine.ActKey_State, 0):
|
del PyGameData.g_crossActInfoDict[actName][cfgID]
|
|
return
|
|
def GetPlayerCrossActInfo(curPlayer, actName):
|
## »ñÈ¡¿ç·þÍæ¼Ò¶ÔÓ¦µÄ¿ç·þ»î¶¯ÐÅÏ¢
|
if PyGameData.g_crossActInfoDict == None:
|
return {}
|
actInfoDict = PyGameData.g_crossActInfoDict.get(actName, {})
|
if not actInfoDict:
|
return {}
|
playerServerID = GameWorld.GetPlayerServerID(curPlayer)
|
for actInfo in actInfoDict.values():
|
if not actInfo.get(ShareDefine.ActKey_State, 0):
|
continue
|
if ShareDefine.ActKey_ServerIDRangeList not in actInfo:
|
continue
|
serverIDRangeList = actInfo[ShareDefine.ActKey_ServerIDRangeList]
|
if not serverIDRangeList:
|
# È«·þ¿ªÆô
|
return actInfo
|
for serverIDA, serverIDB in serverIDRangeList:
|
if serverIDA <= playerServerID <= serverIDB:
|
return actInfo
|
return {}
|
|
def SendMapServerCrossActionState():
|
# µØͼÆô¶¯³É¹¦Ê±Í¨Öª¿ç·þ»î¶¯Ïà¹Ø״̬ - ±¾·þµØͼ£¬¿ç·þµØͼ²»ÐèҪ֪ͨ
|
|
if PyGameData.g_crossActInfoDict == None:
|
return
|
|
sysnCrossActInfoDict = PyGameData.g_crossActInfoDict
|
for actName in ShareDefine.CrossActNameList:
|
actInfoDict = sysnCrossActInfoDict.get(actName, {})
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossActInfo % actName, actInfoDict)
|
|
return
|
|
## ================================================================================================
|
|
def __GetTodayCrossDailyActionInfo():
|
# »ñÈ¡±¾ÈÕ´ý´¦ÀíµÄÈÕ³£»î¶¯ÐÅÏ¢
|
key = "TodayCrossDailyActionInfo"
|
curTime = int(time.time())
|
curDateStr = GameWorld.ChangeTimeNumToStr(curTime, ChConfig.TYPE_Time_YmdFormat) # µ±ÌìÈÕÆÚ
|
loadSign = curDateStr
|
TodayDailyActionInfo = IpyGameDataPY.GetConfigEx(key)
|
if TodayDailyActionInfo and TodayDailyActionInfo[0] == loadSign:
|
GameWorld.DebugLog("ÒѾ¼ÓÔعý±¾ÈÕ¿ç·þÈÕ³£»î¶¯´¦ÀíÐÅÏ¢£¡loadSign=%s" % loadSign)
|
return TodayDailyActionInfo[1]
|
|
todayActionInfo = []
|
|
dayTime = GameWorld.GetServerTime()
|
weekDay = str(dayTime.weekday() + 1) # ¸ñʽΪjson, µ±Ç°ÐÇÆÚ¼¸, 1´ú±íÐÇÆÚ1
|
|
GameWorld.Log("===== ¼ÓÔؽñÌì¿ç·þÈÕ³£»î¶¯ÐÅÏ¢ =====")
|
GameWorld.Log("µ±Ç°ÐÇÆÚ%s" % weekDay)
|
|
dailyTimeInfoList = []
|
|
ipyDataMgr = IpyGameDataPY.IPY_Data()
|
for i in xrange(ipyDataMgr.GetCrossDailyActionCount()):
|
dailyIpyData = ipyDataMgr.GetCrossDailyActionByIndex(i)
|
dailyID = dailyIpyData.GetDailyID()
|
|
openTimeDict = dailyIpyData.GetOpenTimeDict()
|
# ûÓÐʱ¼ä¿ØÖƵģ¬´ú±íÓÀ¾Ã¿ª·Å
|
if not openTimeDict:
|
todayActionInfo.append([dailyID])
|
GameWorld.Log(" Ôö¼Ó±¾ÈÕ³£¿ª¿ç·þÈÕ³£»î¶¯ÐÅÏ¢: dailyID=%s" % dailyID)
|
continue
|
|
#Èç¹ûÐÇÆÚkeyÖдæÔÚ "0" ´ú±íÿÈÕ¶¼¿ªÆô
|
if "0" not in openTimeDict and weekDay not in openTimeDict:
|
GameWorld.Log(" ²»ÊÇ¿ç·þÈÕ³£»î¶¯¿ªÆôÐÇÆÚ: dailyID=%s,openWeekLimit=%s" % (dailyID, openTimeDict.keys()))
|
continue
|
openTimeList = openTimeDict["0"] if "0" in openTimeDict else openTimeDict[weekDay]
|
dailyTimeInfoList.append([openTimeList, dailyIpyData])
|
|
GameWorld.Log(" -----------------------")
|
for openTimeList, ipyData in dailyTimeInfoList:
|
dailyID = ipyData.GetDailyID()
|
notifyInfoDict = ipyData.GetNotifyInfo()
|
|
openList = [] # [(ʱ,·Ö), ...]
|
overList = [] # [(ʱ,·Ö), ...]
|
goonStateDict = {} # {״̬:[(aDateTime, bDateTime)], ...}
|
notifyDict = {} # {(ʱ,·Ö):[notifyKey, [²ÎÊý]], ...}
|
OpenState = 1 # ¶¨Ò忪Æô״̬Ϊ1
|
|
for hour, minute in openTimeList:
|
openTimeStr = "%s %02d:%02d:%02d" % (curDateStr, hour, minute, 0)
|
|
# ¾«È·¿ªÆôʱ¼ä
|
openDateTime = datetime.datetime.strptime(openTimeStr, ChConfig.TYPE_Time_Format)
|
openList.append((openDateTime.hour, openDateTime.minute))
|
|
# ¾«È·¹Ø±Õʱ¼ä
|
overDateTime = openDateTime + datetime.timedelta(minutes=ipyData.GetDuration())
|
overList.append((overDateTime.hour, overDateTime.minute))
|
|
# goon ¿ªÆô״̬
|
openStateTimeList = goonStateDict.get(OpenState, [])
|
openStateTimeList.append((openDateTime, overDateTime))
|
goonStateDict[OpenState] = openStateTimeList
|
|
# goon ÆäËû״̬£¬´ýÀ©Õ¹
|
# ...
|
|
# ¹ã²¥
|
for notifyMinute, notifyInfo in notifyInfoDict.items():
|
notifyDateTime = openDateTime + datetime.timedelta(minutes=notifyMinute)
|
notifyDict[(notifyDateTime.hour, notifyDateTime.minute)] = notifyInfo
|
|
todayActionInfo.append([dailyID, openList, overList, goonStateDict, notifyDict])
|
GameWorld.Log(" Ôö¼Ó±¾ÈÕ¿ç·þÈÕ³£»î¶¯ÐÅÏ¢: dailyID=%s,openList=%s,overList=%s,goonStateDict=%s,notifyDict=%s"
|
% (dailyID, openList, overList, goonStateDict, notifyDict))
|
|
TodayDailyActionInfo = IpyGameDataPY.SetConfigEx(key, [loadSign, todayActionInfo])
|
GameWorld.Log("±¾ÈÕ¿ç·þÈÕ³£»î¶¯ÐÅÏ¢¼ÓÔØÍê±Ï! loadSign=%s" % loadSign)
|
GameWorld.Log("=============================================================")
|
return TodayDailyActionInfo[1]
|
|
def Dispose_CrossDailyActionState():
|
# ¿ç·þÈÕ³£»î¶¯×´Ì¬±ä¸ü¼ì²é´¦Àí
|
|
todayDailyActionInfo = __GetTodayCrossDailyActionInfo()
|
if not todayDailyActionInfo:
|
return
|
|
gameWorld = GameWorld.GetGameWorld()
|
dayTime = GameWorld.GetServerTime()
|
curHourMinute = (dayTime.hour, dayTime.minute)
|
|
sysnCrossDailyActionStateDict = {}
|
|
for actionInfo in todayDailyActionInfo:
|
dailyActionID = actionInfo[0]
|
state = 0 # ĬÈϹرÕ
|
|
# ³¤¶ÈΪ1µÄ´ú±í³£¿ªµÄ»î¶¯
|
if len(actionInfo) == 1:
|
state = 1
|
else:
|
#openList = [] # [(ʱ,·Ö), ...]
|
#overList = [] # [(ʱ,·Ö), ...]
|
#goonStateDict = {} # {״̬:[(aDateTime, bDateTime)], ...}
|
#notifyDict = {} # {(ʱ,·Ö):[notifyKey, [²ÎÊý]], ...}
|
openList, overList, goonStateDict, notifyDict = actionInfo[1:]
|
|
# ¾«È·Æ¥Å俪Æô
|
if curHourMinute in openList:
|
state = 1
|
# ¾«È·Æ¥Åä¹Ø±Õ
|
elif curHourMinute in overList:
|
state = 0
|
# goon ״̬
|
else:
|
for goonState, openStateTimeList in goonStateDict.items():
|
for dateTimeInfo in openStateTimeList:
|
if dateTimeInfo[0] < dayTime < dateTimeInfo[1]:
|
state = goonState
|
break
|
|
# È«·þ¹ã²¥ÌáʾÐÅÏ¢
|
if curHourMinute in notifyDict:
|
notifyKey, paramList = notifyDict[curHourMinute]
|
serverGroupIDList = []
|
PlayerControl.WorldNotifyCross(serverGroupIDList, 0, notifyKey, paramList)
|
|
dictName = ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % dailyActionID
|
beforeState = gameWorld.GetDictByKey(dictName)
|
if beforeState == state:
|
#ÒѾÊÇÕâ¸ö״̬ÁË
|
continue
|
|
if state:
|
if dailyActionID == ShareDefine.CrossDailyActionID_YaomoBoss:
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_ActionBossRebornSign % dailyActionID, int(time.time()))
|
|
sysnCrossDailyActionStateDict[dailyActionID] = state
|
#֪ͨMapserver,ÉèÖÃ×Öµä
|
GameWorld.SendMapServerMsgEx(dictName, state)
|
#¸üÐÂ×ÖµäÖµ
|
gameWorld.SetDict(dictName, state)
|
GameWorld.Log("¿ç·þÈÕ³£»î¶¯×´Ì¬±ä¸ü: dailyActionID=%s,state=%s,dictName=%s" % (dailyActionID, state, dictName))
|
|
# ͬ²½×Ó·þÎñÆ÷
|
if sysnCrossDailyActionStateDict:
|
serverGroupIDList = []
|
CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_CrossDailyActionState, sysnCrossDailyActionStateDict, serverGroupIDList)
|
|
return
|
|
def SendMapServerCrossDailyActionState():
|
# µØͼÆô¶¯³É¹¦Ê±Í¨Öª±¾ÈÕ½øÐÐÖеÄÈÕ³£»î¶¯×´Ì¬
|
|
todayDailyActionInfo = __GetTodayCrossDailyActionInfo()
|
if not todayDailyActionInfo:
|
return
|
|
gameWorld = GameWorld.GetGameWorld()
|
for actionInfo in todayDailyActionInfo:
|
dailyActionID = actionInfo[0]
|
dictName = ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % dailyActionID
|
state = gameWorld.GetDictByKey(dictName)
|
if state:
|
GameWorld.SendMapServerMsgEx(dictName, state)
|
|
return
|
|
def CrossServerMsg_CrossDailyActionState(msgData):
|
|
gameWorld = GameWorld.GetGameWorld()
|
for dailyActionID, state in msgData.items():
|
dictName = ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % dailyActionID
|
#֪ͨMapserver,ÉèÖÃ×Öµä
|
GameWorld.SendMapServerMsgEx(dictName, state)
|
#¸üÐÂ×ÖµäÖµ
|
gameWorld.SetDict(dictName, state)
|
GameWorld.Log("ÊÕµ½¿ç·þÈÕ³£»î¶¯×´Ì¬±ä¸ü: dailyActionID=%s,state=%s,dictName=%s" % (dailyActionID, state, dictName))
|
|
return
|
|
