| | |
| | | import IPY_GameWorld
|
| | | import DataRecordPack
|
| | | import PlayerEventCounter
|
| | | import PlayerViewCache
|
| | | import GameLogic_Qunying
|
| | | import GameWorldAction
|
| | | import PlayerControl
|
| | | import NetPackCommon
|
| | | import PlayerOnline
|
| | |
| | | DBDataMgr.OnServerStart() # 优先加载公共数据
|
| | | #ItemCommon.InitPyItem() # 改为放 InitItem 加载
|
| | | LoadDBPlayer()
|
| | | PlayerViewCache.LoadRobot()
|
| | | #PlayerViewCache.LoadRobot()
|
| | | PyGameData.g_initGameTime = int(time.time()) # 放到加载数据之后
|
| | | |
| | | # 检查跨服中心唯一性
|
| | | GameWorld.CheckCrossCenterUniquenessErr()
|
| | |
|
| | | if DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_FamilyTransDataTime):
|
| | | DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_FamilyTransDataTime, 0)
|
| | |
| | | __DoMixServerInit()
|
| | |
|
| | | # 其他功能初始化
|
| | | |
| | | GameLogic_Qunying.OnServerStart()
|
| | |
|
| | | # 最后触发检查是否完全启动成功
|
| | | PyGameData.g_initGameWorldOK = True
|
| | |
| | | #PlayerDBOper.FindDBOper(PlayerDBOper.Table_DBPlayer, {}, {"PlayerID":1, "AccID":1, "_id":0}, LoadDBPlayerRet)
|
| | | return
|
| | |
|
| | | def GMSetOpenServerTime(openServerTime):
|
| | | '''GM设置开服时间
|
| | | @param openServerTime: 开服时间戳
|
| | | @return: 1-成功;-1-设置的时间异常;-2-已经设置过且开服了,不能重复设置
|
| | | '''
|
| | | serverID = GameWorld.GetGameWorld().GetServerID()
|
| | | curTime = int(time.time())
|
| | | if openServerTime < curTime:
|
| | | GameWorld.ErrLog("当前时间已经超过设置的开服时间,不能设置! serverID=%s" % serverID)
|
| | | #GMCommon.GMCommandResult(orderId, gmCmdDict, GMCommon.Def_InvalidTime, "The set time is less than the current time.")
|
| | | return -1
|
| | | setOpenServerTime = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_SetOpenServerTime)
|
| | | if setOpenServerTime and curTime > setOpenServerTime:
|
| | | GameWorld.ErrLog("已经设置过且开服了,不能重复设置! serverID=%s" % serverID)
|
| | | #GMCommon.GMCommandResult(orderId, gmCmdDict, GMCommon.Def_ServerAlreadyOpen, "The server has been opened.")
|
| | | return -2
|
| | | |
| | | DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_SetOpenServerTime, openServerTime)
|
| | | GameWorld.Log("GM设置开服时间: serverID=%s,%s,%s" % (serverID, GameWorld.ChangeTimeNumToStr(openServerTime), openServerTime))
|
| | | if openServerTime == curTime:
|
| | | OnNewServerOpen(GameWorld.GetGameWorld().GetTick())
|
| | | |
| | | return 1
|
| | |
|
| | | def DoCheckNewServerOpen(tick):
|
| | | setOpenServerTime = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_SetOpenServerTime)
|
| | | if not setOpenServerTime:
|
| | |
| | | DBDataMgr.GetMailMgr().DelAllMail()
|
| | | DBDataMgr.GetPlayerViewCacheMgr().DelAllCache()
|
| | |
|
| | | # 设置允许跨服,该函数为自动开服会触发,所以要设置为允许跨服,手动开服的需后台手动设置为允许
|
| | | DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_CanCross, 1)
|
| | | SetInitOpenServerTime(setOpenServerTime)
|
| | | AllMapServerInitOK(tick)
|
| | |
|
| | | GameWorld.GetGameWorld().SaveGameServerData()
|
| | | #强制备档一次、入库
|
| | | DBDataMgr.BackupGameWorldData(saveToDB=True)
|
| | | #GameWorld.GetGameWorld().SaveGameServerData()
|
| | | GameWorld.SendGameError("ClearOpenServerOK")
|
| | | return
|
| | |
|
| | |
| | | DoCheckNewServerOpen(tick)
|
| | | DBDataMgr.OnMinute(curTime)
|
| | | DoLogic_GameWorldEvenByTime(tick)
|
| | | GameWorldAction.OnProcessGameAction(curTime)
|
| | |
|
| | | #每5分钟
|
| | | if curMinute % 5 == 0:
|
| | | OnMinute_5(curTime, tick)
|
| | |
|
| | | #其他功能逻辑
|
| | | #GameWorldActionControl.Dispose_OperationActionState()
|
| | | #GameWorldActionControl.Dispose_DailyActionState()
|
| | | #GameWorldActionControl.Dispose_FBStateTime()
|
| | | PlayerControl.OnMinute(curTime)
|
| | | PlayerFamily.OnMinute()
|
| | | PlayerOnline.OnMinute()
|
| | |
| | | gameWorld.SetGameWorldDict("OnlineCntM", curMinute)
|
| | | activePlayerCount = GameWorld.GetPlayerManager().OnlineCount()
|
| | | DataRecordPack.DR_OnLinePlayerCount(activePlayerCount) # 总在线
|
| | | return
|
| | |
|
| | | def OnGM_CrossCenterEvent(gmEvent):
|
| | | if not GameWorld.IsCrossCenter():
|
| | | return
|
| | | serverEventValue = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_CrossCenterEvent)
|
| | | if DoLogic_CrossCenterEvent(serverEventValue, gmEvent=gmEvent):
|
| | | CrossMgr.SendCrossServerEvent(gmEvent=gmEvent)
|
| | | return
|
| | |
|
| | | def DoLogic_GameWorldEvenByTime(tick):
|
| | |
| | | PlayerEventCounter.DoLogic_OnYear(tick)
|
| | | return
|
| | |
|
| | | def DoLogic_CrossCenterEvent(centerEventValue, centerServerID=0):
|
| | | def DoLogic_CrossCenterEvent(centerEventValue, centerServerID=0, gmEvent=""):
|
| | | ## 收到跨服中心事件同步,如OnDay等
|
| | | serverEventValue = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_CrossCenterEvent)
|
| | | if not serverEventValue:
|
| | | serverEventValue = centerEventValue
|
| | | DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_CrossCenterEvent, centerEventValue)
|
| | | |
| | | if centerServerID:
|
| | | GameWorld.Log("处理跨服中心事件值! serverEventValue=%s,centerEventValue=%s,centerServerID=%s" % (serverEventValue, centerEventValue, centerServerID))
|
| | | |
| | | if serverEventValue == centerEventValue:
|
| | | GameWorld.DebugLog("跨服中心事件值不变! serverEventValue=%s,centerEventValue=%s,centerServerID=%s" % (serverEventValue, centerEventValue, centerServerID))
|
| | | #第一次也要执行一次
|
| | | #if not serverEventValue:
|
| | | # serverEventValue = centerEventValue
|
| | | # DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_CrossCenterEvent, centerEventValue)
|
| | | |
| | | if serverEventValue == centerEventValue and not gmEvent:
|
| | | if centerServerID:
|
| | | GameWorld.Log("本服与跨服中心事件值相同不处理! serverEventValue=%s,centerEventValue=%s,centerServerID=%s" % (serverEventValue, centerEventValue, centerServerID))
|
| | | return
|
| | |
|
| | | serverEventTime = GameWorld.ChangeStrToDatetime("%s:%02d:%02d" % serverEventValue, ChConfig.TYPE_Time_Format_YmdHMS)
|
| | | centerEventTime = GameWorld.ChangeStrToDatetime("%s:%02d:%02d" % centerEventValue, ChConfig.TYPE_Time_Format_YmdHMS)
|
| | | if centerServerID:
|
| | | GameWorld.Log("本服与跨服中心事件值变化! serverEventValue=%s,centerEventValue=%s,centerServerID=%s,gmEvent=%s" % (serverEventValue, centerEventValue, centerServerID, gmEvent))
|
| | | else:
|
| | | GameWorld.Log("跨服中心服务器事件值变化! serverEventValue=%s,centerEventValue=%s,gmEvent=%s" % (serverEventValue, centerEventValue, gmEvent))
|
| | | |
| | | serverEventTime = GameWorld.ChangeStrToDatetime("%s" % serverEventValue, ChConfig.TYPE_Time_Format_YmdH)
|
| | | centerEventTime = GameWorld.ChangeStrToDatetime("%s" % centerEventValue, ChConfig.TYPE_Time_Format_YmdH)
|
| | |
|
| | | serverHour = serverEventTime.hour
|
| | | serverDay = serverEventTime.day
|
| | |
| | | isEvent = False
|
| | |
|
| | | #OnHour事件
|
| | | if (serverHour != centerHour or serverDay != centerDay or serverMonth != centerMonth or serverYear != centerYear):
|
| | | if (serverHour != centerHour or serverDay != centerDay or serverMonth != centerMonth or serverYear != centerYear or gmEvent == "GMOnHour"):
|
| | | isEvent = True
|
| | | PlayerEventCounter.DoLogic_CrossCenterOnHour(centerEventValue)
|
| | |
|
| | | #OnDay事件
|
| | | if (serverDay != centerDay or serverMonth != centerMonth or serverYear != centerYear):
|
| | | if (serverDay != centerDay or serverMonth != centerMonth or serverYear != centerYear or gmEvent == "GMOnDay"):
|
| | | isEvent = True
|
| | | PlayerEventCounter.DoLogic_CrossCenterOnDay(centerEventValue)
|
| | |
|
| | |
| | | #if serverYear != curTimeYear:
|
| | | # OnYear(tick)
|
| | |
|
| | | # 游戏服额外处理玩家
|
| | | if GameWorld.IsMainServer():
|
| | | playerManager = GameWorld.GetPlayerManager()
|
| | | for i in xrange(playerManager.OnlineCount()):
|
| | | curPlayer = playerManager.OnlineAt(i)
|
| | | if not GameWorld.IsNormalPlayer(curPlayer):
|
| | | continue
|
| | | PlayerEventCounter.PlayerOnCrossCenterEvent(curPlayer, centerEventValue, gmEvent=gmEvent)
|
| | | |
| | | return isEvent
|
| | |
|
| | | def __CheckIpyDataRecycle(timeNow):
|