hxp
2019-02-13 5685e4d493ef5b7570bc20b6037fc2c8603cab85
ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldProcess.py
@@ -83,10 +83,6 @@
import GameWorldAverageLv
import PlayerDBOper
import PlayerGeTui
#import MergeBroadcast
#import GameWorldMixServerCampaign
#import GameWorldMergeKing
#import GameWorldMergePK
#import PlayerManorWar
import GameWorldBoss
#import GameWorldActionTeHui
@@ -96,8 +92,10 @@
import ReadChConfig
import EventReport
#import ReloadModule
import MergeChildMsg
#import MergePlayer
import CrossRealmPK
import CrossRealmMsg
import CrossRealmPlayer
import PlayerFBHelpBattle
import PlayerFamilyRedPacket
import IpyGameDataPY
import PlayerFamilyParty
@@ -129,6 +127,8 @@
    #__ClearTreasureDropCount()
    #记录当前时间
    GameLogInfo.Set_Server_Hour()
    PlayerFamily.FamilyOnHour()
    return
## 触发每日事件(参数 -> 当前时间)
@@ -291,13 +291,10 @@
    PlayerFamilyParty.FamilyParty_Process(tick)
    # 帮主弹劾时钟调用
    PlayerFamily.OnLeaderImpeachTick(tick)
    #跨服广播
    #MergeBroadcast.OnBroadcastProccee(tick)
    #跨服玩家
    CrossRealmPlayer.OnCrossProcess(tick)
    #跨服PK匹配
    #GameWorldMergePK.OnPKMatchProcess(tick)
    #跨服王者争霸
    #GameWorldMergeKing.OnMergeKingProcess(tick)
    CrossRealmPK.OnPKMatchProcess(tick)
    
    GameWorldBoss.DoCheckWorldBossReborn(tick)
    GameWorldBoss.ProcessBossGeTui(tick)
@@ -349,14 +346,18 @@
    GameWorldActionControl.Dispose_OperationActionState()
    GameWorldActionControl.Dispose_DailyActionState()
    GameWorldActionControl.Dispose_FBStateTime()
    #跨服PK
    CrossRealmPK.OnMinuteProcess()
    #处理重开服务器后, 活动继续开启逻辑根据天数
    #GameWorldActionControl.Dispose_Action_GoOn_ByDay(tick)
    #触发世界等级
    GameWorldAverageLv.OpenWorldAverageLv()
    #倒计时离队处理
    PlayerTeam.DoCountdownLeaveTeamLogic(tick)
    #副本助战
    PlayerFBHelpBattle.OnMinuteProcess()
    #红包
    PlayerFamilyRedPacket.OnRedPacketMinuteProcess()
    #每5分钟触发一次仙盟总战力更新
    if curMinute % 5 == 0:
        PlayerFamily.UpdFamilyTotalFightPower()
@@ -386,8 +387,6 @@
    DisposeGameWorldGame(tick)
    #回报数据库当前在线玩家数
    DisposeGameActivePlayer(tick)
    #统计跨服服务器在线玩家
    #MergePlayer.DisposeMergeServerOnlinePlayer()
    #同步地图服务器时间
    Dispose_MapServer_Time(tick)
    #保存玩家数据
@@ -548,22 +547,16 @@
#  所有服务器人数要回报一次,  每个map也要回报一次
#  gameWorld.GetTickByType(0 - n) 取间隔
def DisposeGameActivePlayer(tick):
#    gameWorld = GameWorld.GetGameWorld()
#    lastTick = gameWorld.GetTickByType(ChConfig.TYPE_GetActivePlayerCount)
#
#    if lastTick == -1:
#        #GameWorld.Log("未初始化服务器")
#        return
#
#    if tick - lastTick < ChConfig.TYPE_Tick_Time[ChConfig.TYPE_GetActivePlayerCount]:
#        return
#
#
#    gameWorld.SetTickByType(ChConfig.TYPE_GetActivePlayerCount , tick)
    gameWorld = GameWorld.GetGameWorld()
    curMinute = datetime.datetime.today().minute
    #为了每个服的输出时间点统一一个分钟点,便于统计
    if datetime.datetime.today().minute % 5 != 0:
    if curMinute % 5 != 0:
        return
    noteData = gameWorld.GetDictByKey("OnlineCntM")
    if noteData == curMinute:
        # 同一分钟不多发送,此处不建议用CD处理,避免两CD冲突
        return
    gameWorld.SetDict("OnlineCntM", curMinute)
    
    # 全服在线人数平台明细
    platformOLDict = {} # 平台在线人数 {平台:人数, ...}
@@ -1216,12 +1209,11 @@
    if initOpenServerTime <= 0 or openServerWeekday <= 0:
        #记录首次开发时间(现实时间戳)
        PlayerDBGSEvent.SetInitOpenServerTime(initOpenServerTime if initOpenServerTime else int(time.time()))
    #初始化家族数量
    GameWorld.GetFamilyManager().SetFamilyUpperLimitCount(ChConfig.Def_Family_MaxCnt)
    #排序元宝交易平台
    GameWorld.GetGameWorld().GetDBGoldOrderFormMgr().Sort()
    PlayerBillboard.ClearBillboardOnServerInit()
    #排序排行榜
    PlayerBillboard.SortServerBillboard()
    #排序仙盟
@@ -1241,19 +1233,30 @@
    PlayerXMZZ.OnGameServerInitOK()
    #加载活跃玩家等级信息
    ChPlayer.LoadPlayerLVData()
    #加载助战信息
    PlayerFBHelpBattle.OnServerStart()
    #跨服PK
    CrossRealmPK.OnGameServerInitOK()
    #世界boss被杀次数重置
    #GameWorldBoss.CheckResetBossKilledCntOnServerInit()
    #GameWorldActionTeHui.OnGameServerInitOK() # 特惠活动初始化
    #子服启动成功告知跨服主服
    #===========================================================================
    # serverGroupID = GameWorld.GetServerGroupID()
    # if GameWorld.IsMergeOpen() and not GameWorld.IsMergeServer():
    #    GameWorld.Log("通知跨服主服务器启动成功, 可接收最新跨服活动状态及数据...")
    #    dataMsg = {"Platform":GameWorld.GetPlatform(), "ServerID":GameWorld.GetServerSID(), "ServerGroupID":serverGroupID}
    #    MergeChildMsg.SendMergerChildToCenterStringData(ChConfig.Def_ClientServerInitOK, dataMsg)
    #
    # GameWorld.Log("服务器启动成功: ServerGroupID=%s" % serverGroupID)
    #===========================================================================
    __Func_HighPrecisionProcess(tick) # 主动触发一次高精度的调用,确保服务器启动后一些功能活动等的数据会被加载
    GameWorld.Log("=============================== 服务器启动成功 ===================================")
    isCrossServer = GameWorld.IsCrossServer()
    if isCrossServer:
        isServerClose = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_CrossServerClose)
        isServerOpen = 0 if isServerClose else 1
        GameWorld.GetGameWorld().SetDict(ShareDefine.Def_Notify_WorldKey_CrossServerOpen, isServerOpen)
        GameWorld.Log("跨服服务器启动成功: isServerOpen=%s,crossZoneName=%s" % (isServerOpen, GameWorld.GetCrossZoneName()))
    else:
        serverGroupID = GameWorld.GetServerGroupID()
        GameWorld.Log("服务器启动成功: ServerGroupID=%s" % serverGroupID)
    GameWorld.GetGameWorld().SetDict(ChConfig.Def_WorldKey_GameWorldInitOK, 1)
    # 注意:跨服相关信息的调用需放在最后,不然可能导致服务器未启动功能或者功能未加载成功导致跨服服务器与子服之间的数据同步可能出现异常的情况
    CrossRealmMsg.OnGameServerInitOK()
    return
def DoCheckNewServerOpen(tick):
@@ -1360,8 +1363,6 @@
    
    #触发节假日活动
    #GameWorldActionHoliday.ActionHoliday_OpenAndClose(tick, True)
    #合服活动
    #GameWorldMixServerCampaign.UpdateMixServerCampaignState(True)
    #通知世界等级
    worldLv = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_WorldAverageLv)
@@ -1384,9 +1385,6 @@
    # 上次合服时的开服天数
    lastMixServerDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_LastMixServerDay)
    GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_LastMixServerDay, lastMixServerDay)
    # 上次清除排行榜的标记
    lastSign = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_ClearBillboardSign)
    GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_ClearBillboardSign, lastSign)
    
    # 通知战盟相关活动开启状态
    fadState = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_FamilyActivityDayState)
@@ -1413,9 +1411,13 @@
    # 商店信息
    #GameWorldShopItem.OnMapServerInitOK()
    
    # 跨服服务器状态
    isCrossServerOpen = GameWorld.GetGameWorld().GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossServerOpen)
    GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossServerOpen, isCrossServerOpen)
    GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossZoneName, PyGameData.g_crossZoneName)
    # 跨服PK
    #GameWorldMergePK.OnMapServerInitOK()
    #GameWorldMergeKing.OnMapServerInitOK()
    CrossRealmPK.OnMapServerInitOK()
    
    SendAllMapGlobalDropInfo() # 全局掉落控制
    
@@ -1438,17 +1440,15 @@
        GameWorld.DebugLog("合服首次启动加载已经处理过!")
        return
    
    GameWorld.DebugLog("合服首次启动加载处理...")
    GameWorld.Log("合服首次启动加载处理...")
    
    # 清除指定通用数据
    # 清除指定通用数据,一般是合服工具删,这里可以再做个补充
    universalRecMgr = GameWorld.GetUniversalRecMgr()
    delRecTypeList = [ShareDefine.Def_UniversalGameRecType_ManorWarInfo,
                      #ShareDefine.Def_UniversalGameRecType_MergeRegister,
                      ]
    GameWorld.DebugLog("    清除指定通用数据 delRecTypeList=%s" % str(delRecTypeList))
    delRecTypeList = []
    GameWorld.Log("清除指定通用数据 delRecTypeList=%s" % str(delRecTypeList))
    for delRecType in delRecTypeList:
        universalRecMgr.Delete(delRecType)
    # 删除过期的通用数据
    __DelOutofdayRecData(universalRecMgr)
    
@@ -1461,15 +1461,15 @@
    # 设置本次合服时的开服天数
    serverDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ServerDay)
    PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_LastMixServerDay, serverDay)
    GameWorld.DebugLog("    合服首次启动加载成功...")
    GameWorld.Log("    合服首次启动加载成功!")
    return
    
def __DelOutofdayRecData(universalRecMgr):
    # 删除过期的通用数据
    curTime = int(time.time())
    GameWorld.Log("执行删除过期的通用数据, curTime=%s" % curTime)
    delOutofdayRecDataDict = {ShareDefine.Def_UniversalGameRecType_MergeRegister:31 * 24 * 3600,
    delOutofdayRecDataDict = {
                              }
    GameWorld.Log("执行删除过期的通用数据, curTime=%s,delOutofdayRecDataDict=%s" % (curTime, delOutofdayRecDataDict))
    for otDayRecType, otTime in delOutofdayRecDataDict.items():
        otRecDataList = universalRecMgr.GetTypeList(otDayRecType)
        if not otRecDataList:
@@ -1900,6 +1900,7 @@
def BeforeClose(tick):
    PlayerTeam.OnServerClose(tick)
    ChPlayer.SavePlayerLVData()
    PlayerFBHelpBattle.OnServerClose()
    GameWorld.Log("通知C++关服!")
    GameWorld.GetGameWorld().OnServerClose()