| | |
|---|
| | |
|
|---|
| | | 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
|
|---|
| | |
|
|---|
