#!/usr/bin/python
# -*- coding: GBK -*-
#-------------------------------------------------------------------------------
#
##@package GameWorldLogic.GameWorldEvent
#
# @todo:·þÎñÆ÷ÊÀ½çʼþ
# @author hxp
# @date 2025-05-15
# @version 1.0
#
# ÏêϸÃèÊö: ·þÎñÆ÷ÊÀ½çʼþ
#
#-------------------------------------------------------------------------------
#"""Version = 2025-05-15 10:35"""
#-------------------------------------------------------------------------------

import DBDataMgr
import GameWorld
import PyMongoMain
import PlayerFamily
import IpyGameDataPY
import IPY_GameWorld
import DataRecordPack
import PlayerEventCounter
import PlayerViewCache
import PlayerControl
import NetPackCommon
import PlayerOnline
import ShareDefine
import PyGameData
import ItemCommon
import BattleObj
import ChPlayer
import ObjPool

import datetime
import time

def Get_Server_Year(): return DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_Server_Year)
def Set_Server_Year():
    DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_Server_Year, datetime.datetime.today().year)
    return
def Get_Server_Month(): return DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_Server_Month)
def Set_Server_Month():
    DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_Server_Month, datetime.datetime.today().month)
    return
def Get_Server_Week(): return DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_Server_Week)
def Set_Server_Week():
    DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_Server_Week, datetime.datetime.isocalendar(datetime.datetime.today())[1])
    return
def Get_Server_Day(): return DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_Server_Day)
def Set_Server_Day():
    DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_Server_Day, datetime.datetime.today().day)
    return
def Get_Server_Hour(): return DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_Server_Hour)
def Set_Server_Hour():
    DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_Server_Hour, datetime.datetime.today().hour)
    return

def InitServerTime():
    ## ³õʼ»¯·þÎñÆ÷ʱ¼ä
    if not Get_Server_Year():
        Set_Server_Hour()
        Set_Server_Day()
        Set_Server_Week()
        Set_Server_Month()
        Set_Server_Year()
        GameWorld.Log('###·þÎñÆ÷пª, ³õʼ»¯·þÎñÆ÷ʱ¼ä !')
    
    return Get_Server_Hour(), Get_Server_Day(), Get_Server_Week(), Get_Server_Month(), Get_Server_Year()

#µ÷Óøú¯Êýʱ£¬C++ÒѾ­ÉèÖúÃÇø·þ£¬Èç¹û¸Ä±äÇø·þÐèÖØÆô
def StartDB(tick):
    #³õʼ»¯Êý¾Ý¿â, »Ö¸´±¸µµ£¨°´Çø·þ¼Ç¼£©£¬ ¼ÓÔؾ²Ì¬±í
    #from PyMongoDB import PyMongoMain
    PyMongoMain.StartDB()
    InitGameWorld(tick)
    return

def InitGameWorld(tick):
    ## GameWorld³õʼ»¯
    if PyGameData.g_initGameTime:
        return
    serverID = GameWorld.GetGameWorld().GetServerID()
    GameWorld.Log("·þÎñÆ÷Æô¶¯³õʼ»¯InitGameWorld: serverID=%s" % serverID)
    DBDataMgr.OnServerStart() # ÓÅÏȼÓÔع«¹²Êý¾Ý
    ItemCommon.InitPyItem()
    LoadDBPlayer()
    PlayerViewCache.LoadRobot()
    PyGameData.g_initGameTime = int(time.time()) # ·Åµ½¼ÓÔØÊý¾ÝÖ®ºó
    
    #³õʼ»°¿ª·þʱ¼ä¡¢ÐÇÆÚ¼¸
    initOpenServerTime = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_InitOpenServerTime)
    openServerWeekday = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_OpenServerWeekday)
    if initOpenServerTime <= 0 or openServerWeekday <= 0:
        #¼Ç¼Ê״οª·¢Ê±¼ä(ÏÖʵʱ¼ä´Á)
        SetInitOpenServerTime(initOpenServerTime if initOpenServerTime else int(time.time()))
        
    #ºÏ·þÊ×´ÎÆô¶¯¼ÓÔØ´¦Àí
    __DoMixServerInit()
    
    # ÆäËû¹¦Äܳõʼ»¯
    
    
    OnHighProcess(tick) # Ö÷¶¯´¥·¢Ò»´Î¸ß¾«¶ÈµÄµ÷Óã¬È·±£·þÎñÆ÷Æô¶¯ºóһЩ¹¦ÄܻµÈµÄÊý¾Ý»á±»¼ÓÔØ
    OnMinute(tick)
    
    GameWorld.Log("=============================== ·þÎñÆ÷Æô¶¯³É¹¦ ===================================")
    isCrossServer = GameWorld.IsCrossServer()
    if isCrossServer:
        pass
    else:
        serverGroupID = GameWorld.GetServerGroupID()
        GameWorld.Log("·þÎñÆ÷Æô¶¯³É¹¦: ServerGroupID=%s,serverID=%s" % (serverGroupID, serverID))
    PyGameData.g_serverInitOK = True
    return

def AllMapServerInitOK(tick):
    return

def LoadDBPlayer():
    if GameWorld.IsCrossServer():
        return
    #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:
        #GameWorld.DebugLog("ûÓÐÖ¸¶¨¿ª·þʱ¼ä£¡")
        return
    curOpenServerTime = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_InitOpenServerTime)
    if curOpenServerTime == setOpenServerTime:
        #GameWorld.DebugLog("ÒѾ­Õýʽ¿ª·þ¹ýÁË£¡")
        return
    curTime = int(time.time())
    if curTime < setOpenServerTime:
        #GameWorld.DebugLog("»¹Î´µ½Õýʽ¿ª·þʱ¼ä£¡")
        return
    OnNewServerOpen(tick)
    return
    
def OnNewServerOpen(tick):
    '''зþ¿ªÆôÐèÒª´¦ÀíµÄÂß¼­'''
    
    serverID = GameWorld.GetGameWorld().GetServerID()
    GameWorld.Log("Ö´ÐÐÕýʽ¿ª·þÖØÖÃÂß¼­... serverID=%s" % serverID)
    
    setOpenServerTime = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_SetOpenServerTime)
    if not setOpenServerTime:
        return
    
    #ÇåDBGSTrig
    excludeList = [ShareDefine.Def_InitOpenServerTime, ShareDefine.Def_SetOpenServerTime]
    DBDataMgr.GetEventTrigMgr().DelAllKey(excludeList)
    #Çå¼Ò×å
    DBDataMgr.GetFamilyMgr().DelAllFamily()
    #ÇåÓʼþ
    DBDataMgr.GetMailMgr().DelAllMail()
    DBDataMgr.GetPlayerViewCacheMgr().DelAllCache()
    
    SetInitOpenServerTime(setOpenServerTime)
    AllMapServerInitOK(tick)
    
    GameWorld.GetGameWorld().SaveGameServerData()
    GameWorld.SendGameError("ClearOpenServerOK")
    return

def SetInitOpenServerTime(initTime):
    openDatetime = GameWorld.ChangeTimeNumToDatetime(initTime)
    openServerWeekday = openDatetime.weekday() + 1
    DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_InitOpenServerTime, initTime)
    DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_OpenServerWeekday, openServerWeekday)
    GameWorld.Log("ÉèÖÿª·þʱ¼ä: %s(%s), ÖÜ%s" % (openDatetime, initTime, openServerWeekday))
    # ÐèÒªÕâ¸ö²ÎÊýÖ÷ÒªÊÇGM¹¤¾ß»áÅжÏÊÇ·ñÓÐÉèÖùý£¬ËùÒÔ¸ÃÖµÒ»°ãÖ»ÓÐGMÃüÁî»ò¹¤¾ß²ÅÄÜÉèÖÃ
    setOpenServerTime = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_SetOpenServerTime)
    if setOpenServerTime and setOpenServerTime != initTime:
        DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_SetOpenServerTime, initTime)
        GameWorld.Log("    ͬ²½¸üРDef_SetOpenServerTime=%s" % initTime)
    return

def __DoMixServerInit():
    isMixServer = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_IsMixServer)
    if not isMixServer:
        GameWorld.DebugLog("·ÇºÏ·þ£¬²»´¦ÀíºÏ·þÊ×´ÎÆô¶¯Êý¾Ý¼ÓÔØ£¡")
        return
    
    isMixServerInitOK = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_IsMixServerInitOK)
    if isMixServerInitOK:
        GameWorld.DebugLog("ºÏ·þÊ×´ÎÆô¶¯¼ÓÔØÒѾ­´¦Àí¹ý£¡")
        return
    
    GameWorld.Log("ºÏ·þÊ×´ÎÆô¶¯¼ÓÔØ´¦Àí...")
    
    # Çå³ýÖ¸¶¨Í¨ÓÃÊý¾Ý£¬Ò»°ãÊǺϷþ¹¤¾ßɾ£¬ÕâÀï¿ÉÒÔÔÙ×ö¸ö²¹³ä
    #universalRecMgr = GameWorld.GetUniversalRecMgr()
    #delRecTypeList = []
    #GameWorld.Log("Çå³ýÖ¸¶¨Í¨ÓÃÊý¾Ý delRecTypeList=%s" % str(delRecTypeList))
    #for delRecType in delRecTypeList:
    #    universalRecMgr.Delete(delRecType)
        
    # ɾ³ý¹ýÆÚµÄͨÓÃÊý¾Ý
    #__DelOutofdayRecData(universalRecMgr)
    
    # ÉèÖúϷþÊ×´ÎÆô¶¯¼ÓÔسɹ¦
    DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_IsMixServerInitOK, 1)
    
    # ÉèÖñ¾´ÎºÏ·þʱµÄ¿ª·þÌìÊý¡¢ÊÀ½çµÈ¼¶
    serverDay = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_ServerDay)
    DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_LastMixServerDay, serverDay)
    GameWorld.Log("    ºÏ·þÊ×´ÎÆô¶¯¼ÓÔسɹ¦! serverDay=%s" % (serverDay))
    return

def OnHighProcess(tick):
    ## ÿÃë·ÖÖÓÖ´ÐÐÒ»´Î
    if not PyGameData.g_initGameTime:
        return
    curTime = int(time.time())
    if not PyGameData.g_highProcessTime:
        PyGameData.g_highProcessTime = curTime
        
    if curTime < PyGameData.g_highProcessTime:
        GameWorld.Log("ʱ¼ä»Øµ÷ÁË: lastProcessTime=%s" % (GameWorld.ChangeTimeNumToStr(PyGameData.g_highProcessTime)))
        PyGameData.g_highProcessTime = curTime
        OnFixServerTimeProcess()
        
    passSeconds = curTime - PyGameData.g_highProcessTime
    if passSeconds < 1:
        return
    if passSeconds > 10:
        GameWorld.Log("ʱ¼äÎó²î¹ý´ó: passSeconds=%s,lastProcessTime=%s" % (passSeconds, GameWorld.ChangeTimeNumToStr(PyGameData.g_highProcessTime)))
        OnFixServerTimeProcess()
        
    PyGameData.g_highProcessTime = curTime
    
    if PyGameData.g_serverClosing:
        CheckCloseMapOK()
        return
    
    PyMongoMain.GetUserCtrlDB().onSecondProcess()
    
    OnMinute(tick)
    
    # ÆäËûÂß¼­
    
    
    
    return

def OnFixServerTimeProcess():
    
    # ²¹Í¬²½Ò»´Î·þÎñÆ÷ʱ¼ä¸øÇ°¶Ë
    playerManager = GameWorld.GetPlayerManager()
    for i in xrange(playerManager.GetPlayerCount()):
        curPlayer = playerManager.GetPlayerByIndex(i)
        
        if not GameWorld.IsNormalPlayer(curPlayer):
            continue
        
        ChPlayer.Sync_PyServerDataTimeToClient(curPlayer)
        ChPlayer.Sync_OpenServerDay(curPlayer)
        
    return
        
def OnMinute(tick):
    ## ÿÕû·ÖÖÓÖ´ÐÐÒ»´Î
    curTime = GameWorld.GetCurrentTime()
    curMinute = curTime.minute
    if curMinute == PyGameData.g_minuteProcess:
        return
    PyGameData.g_minuteProcess = curMinute
    
    #¼ì²é·þÎñÆ÷Õýʽ¿ª·þ
    DoCheckNewServerOpen(tick)
    DBDataMgr.OnMinute(curTime)
    DoLogic_GameWorldEvenByTime(tick)
    
    #ÿ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()
    BattleObj.OnMinute()
    ObjPool.OnMinute(curTime)
    
    __CheckIpyDataRecycle(curTime)
    return
    
def OnMinute_5(curTime, tick):
    ## ÿ5·ÖÖÓ
    DisposeGameActivePlayer(curTime, tick)
    return

def DisposeGameActivePlayer(curTime, tick):
    curMinute = curTime.minute
    gameWorld = GameWorld.GetGameWorld()
    noteData = gameWorld.GetGameWorldDictByKey("OnlineCntM")
    if noteData == curMinute:
        # ͬһ·ÖÖÓÖ»´¦Àí1´Î
        return
    gameWorld.SetGameWorldDict("OnlineCntM", curMinute)
    activePlayerCount = GameWorld.GetPlayerManager().OnlineCount()
    DataRecordPack.DR_OnLinePlayerCount(activePlayerCount) # ×ÜÔÚÏß
    return

def DoLogic_GameWorldEvenByTime(tick):
    #-----------·þÎñÆ÷µ±Ç°Ê±¼ä
    curTime = datetime.datetime.today()
    curTimeHour = curTime.hour
    curTimeDay = curTime.day
    curTimeWeek = datetime.datetime.isocalendar(curTime)[1]
    curTimeMonth = curTime.month
    curTimeYear = curTime.year
    
    #-----------·þÎñÆ÷¼Ç¼µÄʱ¼ä
    serverHour , serverDay , serverWeek , serverMonth , serverYear = InitServerTime()
    
    #-----------¿ªÊ¼±È¶Ôʱ¼ä
    #OnHourʼþ
    if (serverHour != curTimeHour or serverDay != curTimeDay or serverMonth != curTimeMonth or serverYear != curTimeYear):
        Set_Server_Hour()
        OnHour(tick)
        
    #OnDayʼþ
    if (serverDay != curTimeDay or serverMonth != curTimeMonth or serverYear != curTimeYear):
        Set_Server_Day()
        OnDay(tick)
        
    #OnWeekʼþ
    #²»¿¼ÂǸôÄêÇé¿ö£¬Èç2009,12,31Èչطþ->2010,12,31ÈÕ¿ª·þ(²»´¥·¢OnWeek)
    if (serverWeek != curTimeWeek):
        Set_Server_Week()
        OnWeek(tick)
        
    #OnMonthʼþ
    if (serverMonth != curTimeMonth or serverYear != curTimeYear):
        Set_Server_Month()
        OnMonth(tick)
        
    #OnYearʼþ
    if serverYear != curTimeYear:
        Set_Server_Year()
        OnYear(tick)
        
    return

def OnHour(tick):
    GameWorld.Log("Server -> OnHour!")
    PlayerEventCounter.DoLogic_OnHour(tick)
    return

def OnDay(tick):
    GameWorld.Log("Server -> OnDay!")
    #É趨·þÎñÆ÷µ±Ç°Ììʼþ
    eventMgr = DBDataMgr.GetEventTrigMgr()
    eventMgr.SetValueIncrement(ShareDefine.Def_ServerDay)
    isMixServer = eventMgr.GetValue(ShareDefine.Def_IsMixServer)
    if isMixServer:
        eventMgr.SetValueIncrement(ShareDefine.Def_MixServerDay)
        
    PlayerEventCounter.DoLogic_OnDay(tick)
    return

def OnWeek(tick):
    GameWorld.Log("Server -> OnWeek!")
    eventMgr = DBDataMgr.GetEventTrigMgr()
    eventMgr.SetValueIncrement(ShareDefine.Def_ServerWeek)
    
    PlayerEventCounter.DoLogic_OnWeek(tick)
    return

def OnMonth(tick):
    GameWorld.Log("Server -> OnMonth!")
    PlayerEventCounter.DoLogic_OnMonth(tick)
    return

def OnYear(tick):
    GameWorld.Log("Server -> OnYear!")
    PlayerEventCounter.DoLogic_OnYear(tick)
    return


def __CheckIpyDataRecycle(timeNow):
    ## ¼ì²éIpyDataÊý¾Ý»ØÊÕ
    playerCount = GameWorld.GetPlayerManager().OnlineCount()
    if playerCount:
        PyGameData.g_ipyDataRecycleCheckTime = 0
        #GameWorld.DebugLog("µØͼ»¹ÓÐÍæ¼ÒÔÚÏß! playerCount=%s" % playerCount)
        return
    
    curTime = GameWorld.ChangeDatetimeToNum(timeNow)
    if not PyGameData.g_ipyDataRecycleCheckTime:
        PyGameData.g_ipyDataRecycleCheckTime = curTime
        #GameWorld.DebugLog("µØͼûÓÐÍæ¼ÒÔÚÏß")
        return
    
    if PyGameData.g_ipyDataRecycleCheckTime == 1:
        # ÒѾ­»ØÊÕÁË
        #GameWorld.DebugLog("±¾´ÎÒѾ­»ØÊÕ¹ýÁË")
        return
    
    if curTime - PyGameData.g_ipyDataRecycleCheckTime < 24 * 3600:
        #GameWorld.DebugLog("»¹Î´µ½´ï»ØÊÕʱ¼ä, passSeconds=%s" % (curTime - PyGameData.g_ipyDataRecycleCheckTime))
        return
    PyGameData.g_ipyDataRecycleCheckTime = 1    
    IpyGameDataPY.IPYData.Recycle()
    return


# ¹Ø±ÕµØͼ֪ͨpy´¦Àí
def CloseMap(tick):
    serverID = GameWorld.GetGameWorld().GetServerID()
    GameWorld.Log("µØͼ·þÎñÆ÷¹Ø±Õ¿ªÊ¼±£´æÊý¾Ý! serverID=%s" % serverID)
    PyGameData.g_serverClosing = 1
    
    playerManager = GameWorld.GetPlayerManager()
    for i in xrange(playerManager.GetPlayerCount()):
        curPlayer = playerManager.GetPlayerByIndex(i)
        if not curPlayer or curPlayer.GetID() == 0 or curPlayer.IsEmpty():
            continue
        
        #¾µÏñÍæ¼Ò»ØÊÕ¡¢ÕæʵÍæ¼ÒÌßÏÂÏß
        if GameWorld.IsMirrorPlayer(curPlayer):
            PlayerControl.DeleteMirror(curPlayer)
        else:
            curPlayer.Kick(IPY_GameWorld.disMapServerClose)
            
    DBDataMgr.OnServerClose()
    return

def CheckCloseMapOK():
    '''¼ì²éµÈ´ý¹Ø·þÊý¾Ý´¦ÀíÍê±Ï
    ûÓÐÍæ¼ÒÁË£¬ÇÒ¹«¹²Êý¾ÝÒÑÈë¿âÍê±Ï
    '''
    if PyGameData.g_serverClosing != 1:
        return
    if not PyGameData.g_closeSaveDataOK:
        return
    if GameWorld.GetPlayerManager().OnlineCount():
        return
    DBDataMgr.ClearBackupFile() # Õý³£¹Ø·þÊý¾Ý´¦ÀíÍê±Ï¿ÉÖ±½Óɾ³ý±¸µµ
    
    from PyMongoDB.DBCommon import CommonDefine
    from PyMongoDB.Common import CommFunc
    data = ''
    data = CommFunc.WriteBYTE(data, CommonDefine.dgPlayerSaveGameServerData)  
    NetPackCommon.SendPyPackToMapServerSelf(data, len(data))
    GameWorld.Log("python ÒÑ´¦ÀíµØͼ¹Ø±ÕÂß¼­")
    PyGameData.g_serverClosing = 2
    return