#!/usr/bin/python
|
# -*- coding: GBK -*-
|
#---------------------------------------------------------------------
|
#
|
#---------------------------------------------------------------------
|
##@package GameWorldProcess
|
# @todo: ÊÀ½çÂß¼´¥·¢
|
#
|
# @author: eggxp
|
# @date 2010-5-10
|
# @version 6.3
|
#
|
# @note:
|
#---------------------------------------------------------------------
|
# @change: "2011-03-31 17:10" panwei ÐÂÔö¸ß¾«¶È¶¨Ê±Æ÷HighPrecisionProcess, 1ÃëC++µ÷ÓÃÒ»´Î
|
# @change: "2011-07-22 11:00" panwei FindGameFbEventºÍGetGameFbEvent½Ó¿Ú±ä¸üÐÂÔölineID
|
# @change: "2012-03-30 09:00" Alee ͳһʱ¼äµãͳ¼ÆÔÚÏßÈËÊý£¬±ãÓÚ¶à·þÎñͳ¼Æ
|
# @change: "2013-12-06 15:00" hxp Ôö¼Ó֪ͨMapServer¿ª·þÌìÊý£¬¿ª·þ»î¶¯×´Ì¬¸üÐÂ
|
# @change: "2013-12-10 11:21" xmnathan È¥µô¿Í»§¶ËÓû§»úÆ÷Êý¾ÝÿÈÕÊý¾Ý²É¼¯²Ù×÷
|
# @change: "2013-12-26 20:20" Alee ¼õÉÙÁ÷Ïò¼Ç¼
|
# @change: "2013-12-27 22:00" Alee ¹Ø±ÕÿÈÕ³äֵͳ¼Æ£¨¹¦ÄÜ£©£¬¹Ø±Õ¼Ò×åÕù°ÔÕ½
|
# @change: "2014-01-14 20:00" hxp Ôö¼Ó֪ͨMapServerÉÏÒ»³¡Õ½ÃËÕ½»ñʤսÃËid
|
# @change: "2014-01-21 18:30" hxp Ôö¼ÓÄêÊÞÂß¼
|
# @change: "2014-02-11 14:30" hxp Ôö¼ÓÏÊ»¨OnDay´¦ÀíÈë¿Ú
|
# @change: "2014-02-27 12:00" hxp Ôö¼ÓÊÀ½çbossÂß¼
|
# @change: "2014-04-26 19:30" hxp Ôö¼ÓÁìµØÕ½»î¶¯
|
# @change: "2014-06-21 15:20" hxp Ôö¼ÓÌػݻ
|
# @change: "2014-08-04 17:30" xmnathan ÌìÌÝÿÈÕ¸üÐÂ
|
# @change: "2014-08-15 17:00" xmnathan ÐÞ¸ÄOnDayº¯ÊýÄÚµÄÖ´ÐÐ˳Ðò
|
# @change: "2014-10-08 10:30" xmnathan add ¶¨Ê±ÇåÀí¹ýÆÚ²¹³¥
|
# @change: "2014-10-29 22:00" hxp MapServerInitOKÔö¼ÓÀ©Õ¹key״̬֪ͨ
|
# @change: "2014-10-31 15:00" xmnathan MapServerInitOK֪ͨ±ù·âÍõ×ù¹Ú¾üÕ½ÃËÃËÖ÷Ö°Òµµ½µØͼˢжÔÓ¦µñÏñNPC
|
# @change: "2014-11-10 10:30" xmnathan PlayerBillboardͳһ¿½±´ÅÅÐаñ×òÈÕ°ñ
|
# @change: "2014-11-12 21:00" hxp OnDayʱ֪ͨMapServerµ±Ç°¿ª·þÌìÊýʱ»úÌáÇ°µ½MapServerOnDay֮ǰ
|
# @change: "2014-12-02 11:30" hxp Ôö¼ÓºÏ·þ״̬¼°ÌìÊý¼Ç¼; Ôö¼Ó¿ªµØͼͬ²½
|
# @change: "2014-12-03 14:30" hxp Ôö¼Óͬ²½ºÏ·þ»î¶¯×´Ì¬
|
# @change: "2014-12-03 18:00" hxp Ôö¼ÓºÏ·þÊ×´ÎÆô¶¯Êý¾Ý¼ÓÔØ´¦Àí
|
# @change: "2014-12-08 11:00" hxp Ôö¼ÓºÏ·þʱµÄ¿ª·þÌìÊý¼Ç¼
|
# @change: "2014-12-22 15:30" hxp Ôö¼ÓÈ«·þµôÂÊ
|
# @change: "2015-01-08 22:00" hxp µØͼÆô¶¯ok֪ͨbossÐÅÏ¢
|
# @change: "2015-01-15 11:30" hxp Õû5·Öʼþ»ã±¨È«·þÔÚÏßÈËÊý; ¹Ø±ÕµØͼÈËÊý»ã±¨
|
# @change: "2015-01-22 15:00" hxp È¥³ý¸£Àû¶àͬ²½map
|
# @change: "2015-01-24 23:30" hxp ¿ªÆôµØͼͬ²½¹¥³ÇÕ½»ñʤսÃË
|
# @change: "2015-01-29 01:00" hxp ¿ªÆô·þÎñÆ÷ÖØÖÃÅÅÐаñ´¦Àí
|
# @change: "2015-02-04 14:00" hxp ÉñÃØÉ̵괦Àí
|
# @change: "2015-03-22 16:30" hxp Õ½Ã˼ÒÔ°
|
# @change: "2015-05-07 15:00" ljd ºì°ü²ú³ö¿ØÖÆ
|
# @change: "2015-06-05 17:00" hxp ÉÏÒ»´ÎPKÖÜÈüÌì֪ͨ
|
# @change: "2015-06-25 14:30" hxp Ôö¼Ó123457È«·þµôÂÊÔö¼Óʼþ
|
# @change: "2015-09-21 20:00" hxp ºÏ·þÊ×´ÎÆô¶¯Çå³ý¿ç·þ±¨ÃûÕ˺ÅÐÅÏ¢
|
# @change: "2015-10-25 17:00" hxp Ôö¼Ó¿ç·þPK
|
# @change: "2015-11-13 17:30" hxp Ôö¼ÓÍõÕßÕù°Ô
|
# @change: "2016-06-13 10:30" hxp ïÚ³µÐÞ¸ÄΪÏÞʱÍê³É
|
# @change: "2016-07-27 20:00" Alee Ð޸Ĵò¿ªÎļþ³¬Ê±¹Ø±Õ
|
# @change: "2016-08-05 19:00" hxp ½Å±¾ÈȸüÖ§³Ö
|
# @change: "2016-08-29 23:30" hxp ºé»ÄÖ®Á¦
|
# @change: "2016-08-30 16:00" hxp ×Ô¶¨ÒåÔÚÏßͳ¼Æ
|
# @change: "2016-10-26 17:00" hxp Ôö¼ÓÒ°ÍâµôÂä°ó¶¨µÈ¼¶¼ÆËã
|
# @change: "2016-11-03 21:30" hxp ֪ͨսÃ˻µ±ÈÕ¿ªÆô״̬
|
# @change: "2017-05-24 16:00" hxp ¿ç·þ·þÎñÆ÷ÔÚÏßÍæ¼Òͳ¼Æ
|
# @change: "2017-06-05 19:30" hxp ºÏ·þºóÊ×´ÎÆô¶¯·þÎñÆ÷ɾ³ý¹ýÆÚµÄͨÓÃÊý¾Ý
|
# @change: "2017-06-22 15:00" hxp »î¶¯¿ØÖÆ´¥·¢ÆµÂʾ«È·µ½Õû·Ö
|
# @change: "2017-07-01 15:30" hxp ÈËÊýͳ¼ÆÖ§³Ö»ì·þģʽ
|
#---------------------------------------------------------------------
|
import GameWorld
|
import datetime
|
import ChConfig
|
import PlayerTruck
|
import PlayerEventCounter
|
import PlayerControl
|
import GMShell
|
import PlayerDBGSEvent
|
import PlayerFamily
|
import GameLogInfo
|
import GameWorldActionControl
|
import PlayerBillboard
|
#import PlayerExam
|
import IPY_GameServer
|
import GMCommon
|
import time
|
import DataRecordPack
|
import ShareDefine
|
import GameWorldAverageLv
|
import PlayerDBOper
|
import PlayerGeTui
|
#import PlayerManorWar
|
import GameWorldBoss
|
#import HighLadder
|
import PlayerCompensation
|
import ReadChConfig
|
import EventReport
|
#import ReloadModule
|
import CrossRealmPK
|
import CrossRealmMsg
|
import CrossRealmPlayer
|
import PlayerFBHelpBattle
|
import PlayerFamilyRedPacket
|
import IpyGameDataPY
|
import PlayerFamilyParty
|
import GameWorldFamilyWar
|
import AuctionHouse
|
import PlayerXMZZ
|
import PlayerTeam
|
import PyGameData
|
import ChPlayer
|
#---------------------------------------------------------------------
|
|
#---------------------------------------------------------------------
|
## ´¥·¢Ã¿¸öСʱµÄʼþ
|
# @param curTimeStr ʱ¼ä×Ö·û´®
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks ÔÚÿ´ÎOnGameWorldProcessÖУ¬Òò¶Ô±Èʱ¼ä³öÏÖ²îÒ죬˵Ã÷¸Ã´¥·¢ÒÔСʱΪʱ¼ä²îµÄʼþ
|
# ·Ö±ðµ÷Óà Íæ¼ÒµÄOnHourºÍGameWorldµÄOnHour£¬
|
# £¨¶îÍâµÄ£¬Ã¿Ð¡Ê±¿ÉÄܻῪÆô´æ´¢ÈËÎïÐÅÏ¢×ֵ䣬Çå¿Õ±¦ÎïµôÂ䣩
|
# ¸üе±Ç°Ê±¼ä
|
def OnHour(curTimeStr, tick):
|
GameWorld.Log("GameServer -> OnHour!")
|
PlayerEventCounter.DoLogic_GameServer_OnHour(tick)
|
GameWorld.GetGameWorld().OnHour(curTimeStr)
|
#ÿСʱ¸üÐÂÌìÌÝ
|
#HighLadder.OnHour()
|
#ÉèÖôæÈ¡Êý¾Ý¿âKey
|
__SetWorldKey_SavePlayer(curTimeStr)
|
#ÿСʱÇå¿Õ±¦ÎïµôÂä
|
#__ClearTreasureDropCount()
|
#¼Ç¼µ±Ç°Ê±¼ä
|
GameLogInfo.Set_Server_Hour()
|
|
PlayerFamily.FamilyOnHour()
|
return
|
|
## ´¥·¢Ã¿ÈÕʼþ(²ÎÊý -> µ±Ç°Ê±¼ä)
|
# @param curTimeStr ʱ¼ä×Ö·û´®
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def OnDay(curTimeStr, tick):
|
GameWorld.Log("GameServer -> OnDay!")
|
#ÌìÌݾº¼¼³¡£¬·ÅÔÚÅÅÐаñ¸üÐÂ֮ǰ´¦Àí
|
#HighLadder.OnDay()
|
#ÅÅÐаñ¿½±´×òÈÕ°ñµ¥
|
PlayerBillboard.CopyBillboardOnDay()
|
#¿ª·þ»î¶¯£¬·ÅÔÚÅÅÐаñ¿½±´×òÈÕ°ñ¸üкó´¦Àí
|
PlayerEventCounter.DoLogic_GameServer_OnDay(tick)
|
# ֪ͨ¿ª·þÌìÊý, ·ÅÔÚµØͼOnDay֮ǰ´¦Àí, ²»È»µØͼÔÚOnDayʱÐèÒªÓõ½¿ª·þÌìʱ»áÈ¡µ½×òÌìµÄÖµ
|
openServerDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ServerDay)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_ServerDay, openServerDay)
|
isMixServer = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_IsMixServer)
|
mixServerDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_MixServerDay)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_IsMixServer, isMixServer)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_MixServerDay, mixServerDay)
|
GameWorld.GetGameWorld().OnDay(curTimeStr)
|
#¼Ç¼µ±Ç°Ê±¼ä
|
GameLogInfo.Set_Server_Day()
|
#¼Ç¼ÅÅÐаñÐÅÏ¢µ½oss
|
PlayerBillboard.NoteOssBillboardInfoByDay()
|
# ³äÖµ»î¶¯ÏûºÄÔª±¦ÅÅÐаñ¸üÐÂ
|
#GameWorldActionHoliday.GoldActionRank_OnDay(tick)
|
# ondayÖØÉèÈ«·þ³äÖµµãȯÊý£¬×ÜÔÚÏßÈËÊý
|
# GameDataRecord.OnDayResetRecord()
|
# ÏÉÃ˺ì°ü
|
PlayerFamilyRedPacket.DoOnDay()
|
# Íæ¼ÒµÈ¼¶¼Ç¼¸üÐÂ
|
ChPlayer.UpdataPlayerLVInfo()
|
# ֪ͨ¿ª·þÌìÊý
|
#openServerDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ServerDay)
|
#GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_ServerDay, openServerDay)
|
#ÇåÀí¹ýÆÚ²¹³¥
|
PlayerCompensation.ClearUpTimeOutCompensation()
|
PlayerGeTui.ClearFMTGeTuiLimit()
|
import PlayerBourse
|
PlayerBourse.OverTimeItemsDeal()
|
# ÏÉÃËÁªÈü
|
GameWorldFamilyWar.DoOnDay()
|
return
|
|
def OnDayEx(tick):
|
GameWorld.Log("GameServer -> OnDayEx!")
|
PlayerEventCounter.DoLogic_GameServer_OnDayEx(tick)
|
|
__Set_Server_DayEx()
|
|
#ÏÉħ֮Õù
|
PlayerXMZZ.XMZZOndayEx()
|
return
|
|
## ´¥·¢Ã¿ÖÜʼþ(²ÎÊý -> µ±Ç°Ê±¼ä)
|
# @param curTimeStr ʱ¼ä×Ö·û´®
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def OnWeek(curTimeStr, tick):
|
GameWorld.Log("GameServer -> OnWeek!")
|
#¼Ç¼µ±Ç°Ê±¼ä-->½«¼Ç¼ʱ¼äÒƵ½´¦ÀíÍæ¼ÒÖÜÏìӦ֮ǰ£¬ÒòÿÖÜÏìÓ¦ÐèÒª»ñÈ¡×îÐÂServer_Week
|
GameLogInfo.Set_Server_Week()
|
# ´¦ÀíÍæ¼ÒÿÖÜÏìÓ¦
|
PlayerEventCounter.DoLogic_GameServer_OnWeek(tick)
|
GameWorld.GetGameWorld().OnWeek(curTimeStr)
|
return
|
|
def OnWeekEx(tick):
|
GameWorld.Log("GameServer -> OnWeekEx!")
|
PlayerEventCounter.DoLogic_GameServer_OnWeekEx(tick)
|
|
__Set_Server_WeekEx()
|
return
|
|
## ´¥·¢Ã¿ÔÂʼþ(²ÎÊý -> µ±Ç°Ê±¼ä)
|
# @param curTimeStr ʱ¼ä×Ö·û´®
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def OnMonth(curTimeStr, tick):
|
GameWorld.Log("GameServer -> OnMonth!")
|
PlayerEventCounter.DoLogic_GameServer_OnMonth(tick)
|
GameWorld.GetGameWorld().OnMonth(curTimeStr)
|
#¼Ç¼µ±Ç°Ê±¼ä
|
GameLogInfo.Set_Server_Month()
|
return
|
|
def OnMonthEx(tick):
|
GameWorld.Log("GameServer -> OnMonthEx!")
|
PlayerEventCounter.DoLogic_GameServer_OnMonthEx(tick)
|
|
__Set_Server_MonthEx()
|
return
|
|
## ´¥·¢Ã¿Äêʼþ(²ÎÊý -> µ±Ç°Ê±¼ä)
|
# @param curTimeStr ʱ¼ä×Ö·û´®
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def OnYear(curTimeStr, tick):
|
GameWorld.Log("GameServer -> OnYear!")
|
PlayerEventCounter.DoLogic_GameServer_OnYear(tick)
|
GameWorld.GetGameWorld().OnYear(curTimeStr)
|
#¼Ç¼µ±Ç°Ê±¼ä
|
GameLogInfo.Set_Server_Year()
|
return
|
|
#---------------------------------------------------------------------
|
## ÉèÖÃÊÇ·ñ´ò¿ª´¢´æÍæ¼Ò×Öµä
|
# @param curTimeStr ʱ¼ä
|
# @return None
|
# @remarks Èç¹ûÊÇ23µã£¬¾Í´ò¿ª´æ´¢Íæ¼Ò×ֵ䣬·ñÔò¾Í¹Ø±Õ¡£
|
# Õâ¸ö×ÖµäÖµÔÚDispose_MapServer_PlayerSave Àï»áÓõ½¡£
|
# Dispose_MapServer_PlayerSaveÕâ¸öÿ´ÎOnGameProcess¶¼»áµ÷Óã¬
|
# Ö»ÓÐ×ֵ俪ÁË£¬²Å´æ´¢Íæ¼ÒÊý¾Ý
|
def __SetWorldKey_SavePlayer(curTimeStr):
|
#curTimeStr -> 2009-03-05 16:00:00 type -> str
|
#È¡³öµ±Ç°µÄСʱÊý
|
try:
|
timeStr = int(curTimeStr.split()[1].split(':')[0])
|
except BaseException , e:
|
GameWorld.Log('###»ñÈ¡Íæ¼Ò´¢´æ×ÖµäÒì³£ = %s , %s'%(curTimeStr , e))
|
return
|
|
gameWorld = GameWorld.GetGameWorld()
|
#µ±Ç°Ê±¼äÊÇ23µã
|
if timeStr == 23:
|
if not gameWorld.GetDictByKey(ChConfig.Def_WorldKey_SavePlayer):
|
#ÉèÖÿªÆô
|
gameWorld.SetDict(ChConfig.Def_WorldKey_SavePlayer , 1)
|
else:
|
if gameWorld.GetDictByKey(ChConfig.Def_WorldKey_SavePlayer):
|
#»¹Ô×Öµä
|
gameWorld.SetDict(ChConfig.Def_WorldKey_SavePlayer , 0)
|
|
return
|
|
#---------------------------------------------------------------------
|
##¸ß¾«¶È¼ÆʱÆ÷, 1ÃëC++µ÷ÓÃÒ»´Î
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks
|
def HighPrecisionProcess(tick):
|
GameWorld.GetPsycoFunc(__Func_HighPrecisionProcess)(tick)
|
return
|
|
#---------------------------------------------------------------------
|
##¸ß¾«¶È¼ÆʱÆ÷, 1ÃëC++µ÷ÓÃÒ»´Î
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks
|
def __Func_HighPrecisionProcess(tick):
|
if not GameWorld.GetGameWorld().GetDictByKey(ChConfig.Def_WorldKey_IsGameWorldInit):
|
return
|
curTime = int(time.time())
|
|
#ÏÉÃËÑç»á´ðÌⶨʱÆ÷
|
PlayerFamilyParty.FamilyParty_Process(tick)
|
# °ïÖ÷µ¯ÛÀʱÖÓµ÷ÓÃ
|
PlayerFamily.OnLeaderImpeachTick(tick)
|
#¿ç·þÍæ¼Ò
|
CrossRealmPlayer.OnCrossProcess(tick)
|
#¿ç·þPKÆ¥Åä
|
CrossRealmPK.OnPKMatchProcess(tick)
|
|
GameWorldBoss.DoCheckWorldBossReborn(tick)
|
GameWorldBoss.ProcessBossGeTui(tick)
|
PlayerGeTui.ProcessNewGuyCallBackGeTui(tick)
|
#×é¶Ó¸±±¾°æ±¾
|
PlayerTeam.DoTeamProcess(tick)
|
|
#²Ù×÷Python±í
|
PlayerDBOper.PyDBProccess(tick)
|
|
#ÅÄÂôÐÐ
|
AuctionHouse.OnAuctionItemTimeProcess(curTime)
|
|
#ÿÕû·ÖÖÓ´¦ÀíÒ»´Î
|
curDateTime = datetime.datetime.today()
|
curMinute = curDateTime.minute
|
curSecond = curDateTime.second
|
processMinute = curMinute + 1 # .minuteÊÇ0~59£¬ÕâÀïÊÖ¶¯+1
|
lastProcessMinute = GameWorld.GetGameWorld().GetDictByKey(ChConfig.Def_WorldKey_ProcessMinute)
|
if processMinute != lastProcessMinute:
|
GameWorld.GetGameWorld().SetDict(ChConfig.Def_WorldKey_ProcessMinute, processMinute)
|
## ·þÎñÆ÷Æô¶¯Ê±£¬µÚÒ»´ÎÕû·Ö´¦Àí»áÑÓ³Ù 0~59Ãë
|
#if lastProcessMinute != 0:
|
GameWorldProcessOnMinute(curMinute, tick)
|
|
# ÿÕû10Ãë´¦Àí
|
if curSecond % 10 == 0:
|
SendMapCommMapLinePlayerCount()
|
|
return
|
|
def SendMapCommMapLinePlayerCount(isForce=False):
|
# ͬ²½³£¹æµØͼÏß·ÈËÊýÃ÷ϸµ½µØͼ·þÎñÆ÷£¬Ä¿Ç°ÓÃÓÚÇÐͼ·ÖÁ÷ÓÃ
|
if not isForce and not PyGameData.g_needSyncCommMapLinePlayerCount:
|
return
|
|
GameWorld.DebugLog("֪ͨ³£¹æµØͼÍæ¼ÒÈËÊýÐÅÏ¢: isForce=%s,PyGameData.g_commMapLinePlayerCountDict=%s"
|
% (isForce, PyGameData.g_commMapLinePlayerCountDict))
|
|
GameWorld.SendCommMapServerMsg(ShareDefine.Def_Notify_WorldKey_CommMapLinePlayerCount, PyGameData.g_commMapLinePlayerCountDict)
|
|
PyGameData.g_needSyncCommMapLinePlayerCount = False
|
return
|
|
def GameWorldProcessOnMinute(curMinute, tick):
|
# ÿÕû·ÖÖÓ´¥·¢Ò»´Î
|
#¼ì²é·þÎñÆ÷Õýʽ¿ª·þ
|
DoCheckNewServerOpen(tick)
|
|
#´¦ÀíÓÎÏ·ÊÀ½çÖеÄʱ¼äʼþ
|
DisposeGameWorldEvenByTime(tick)
|
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()
|
return
|
|
#---------------------------------------------------------------------
|
## ÓÎÏ·ÊÀ½ç´¦Àí(²ÎÊý -> µ±Ç°Ê±¼ä) -< µ×²ã¶¨Ê±µ÷ÓÃ
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks
|
def OnGameWorldProcess(tick):
|
GameWorld.GetPsycoFunc(__Func_OnGameWorldProcess)(tick)
|
return
|
|
## ÓÎÏ·ÊÀ½ç´¦Àí(²ÎÊý -> µ±Ç°Ê±¼ä) -< µ×²ã¶¨Ê±µ÷ÓÃ
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks
|
def __Func_OnGameWorldProcess(tick):
|
##´¦ÀíÓÎÏ·ÊÀ½çÖеÄʱ¼äʼþ
|
#DisposeGameWorldEvenByTime(tick)
|
#´¦ÀíÓÎÏ·ÊÀ½çÖеÄïÚ³µÊ¼þ
|
DisposeGameWorldEvenByTruck(tick)
|
#´¦ÀíÊÀ½ç¹«¸æ
|
DisposeGameWorldBroadcast(tick)
|
#´¦ÀíÊÀ½ç»î¶¯
|
DisposeGameWorldGame(tick)
|
#»Ø±¨Êý¾Ý¿âµ±Ç°ÔÚÏßÍæ¼ÒÊý
|
DisposeGameActivePlayer(tick)
|
#ͬ²½µØͼ·þÎñÆ÷ʱ¼ä
|
Dispose_MapServer_Time(tick)
|
#±£´æÍæ¼ÒÊý¾Ý
|
Dispose_MapServer_PlayerSave(tick)
|
#ˢеØͼ·þÎñÆ÷״̬
|
DisposeMapServerRunningState(tick)
|
#»Ø±¨Êý¾Ý¿â·þÎñÆ÷״̬£¬¼Ç¼Êý¾Ý¿âÈÕ־ûÓÐÓô¦
|
#DisposeServerState(tick)
|
#¶¨Ê±´æÈ¡Êý¾Ý¿âÖеÄGMÃüÁî
|
Dispose_DataBase_GMShell(tick)
|
##´¦ÀíÖØ¿ª·þÎñÆ÷ºó, »î¶¯¼ÌÐø¿ªÆôÂß¼¸ù¾ÝÌìÊý
|
#GameWorldActionControl.Dispose_Action_GoOn_ByDay(tick)
|
|
#¶¨Ê±ÏòRouteServer·¢ËÍÏûÏ¢
|
Dispose_SendMsg_RouteServer(tick)
|
#¶¨Ê±¼ì²â¹Ø±Õ³¬Ê±Îļþ
|
EventReport.OnTimeCloseScribeTxt()
|
#ÊÀ½çboss¼ÆË㵱ǰÔÚÏßÈËÊý
|
GameWorldBoss.CalcGameWorldBossOnlineCnt(tick)
|
return
|
|
## ¶¨Ê±ÏòRouteServer·¢ËÍÐÅÏ¢
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks SendHeartBeat()¶øÒÑ£¬¼ä¸ôÓÃGetTickByTypeÈ¡µÃ
|
def Dispose_SendMsg_RouteServer(tick):
|
gameWorld = GameWorld.GetGameWorld()
|
|
lastTick = gameWorld.GetTickByType(ChConfig.TYPE_SendMsg_RouteServer)
|
|
if lastTick == -1:
|
#δ³õʼ»¯²»·¢ÐÅÏ¢
|
return
|
|
if tick - lastTick < ChConfig.TYPE_Tick_Time[ChConfig.TYPE_SendMsg_RouteServer]:
|
return
|
|
gameWorld.SetTickByType(ChConfig.TYPE_SendMsg_RouteServer , tick)
|
|
#·¢ËÍÏûÏ¢¸øRouteServer
|
GameWorld.GetGameWorld().SendHeartBeat()
|
return
|
|
|
## ¶¨Ê±´æÈ¡Êý¾Ý¿âÖеÄGMÃüÁî
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks ¼ä¸ôÅжϣ¬´ÓgameWorld.GetTickByTypeÀïÈ¡
|
# gameWorld.GetDBGMCommandListManager() À´²Ù×÷¾ßÌåµÄgmÃüÁî´Ódb»ñÈ¡£¬·¢Ë͸øgmShellÖ´ÐÐ
|
def Dispose_DataBase_GMShell(tick):
|
gameWorld = GameWorld.GetGameWorld()
|
|
if tick - gameWorld.GetTickByType(ChConfig.TYPE_ReadDateBaseGM) < ChConfig.TYPE_Tick_Time[ChConfig.TYPE_ReadDateBaseGM]:
|
return
|
|
gameWorld.SetTickByType(ChConfig.TYPE_ReadDateBaseGM , tick)
|
|
dBGMCommandListManager = gameWorld.GetDBGMCommandListManager()
|
#֪ͨÊý¾Ý¿â×¼±¸»ñÈ¡ÃüÁî
|
dBGMCommandListManager.DataServer_GMCommandReq()
|
|
dBGMCommandListCount = dBGMCommandListManager.GetCount()
|
|
if not dBGMCommandListCount:
|
#Î޼Ǽ
|
return
|
|
#Ö´ÐÐGMÃüÁî
|
for i in range(0 , dBGMCommandListCount):
|
gmCommon = dBGMCommandListManager.GetAt(i)
|
GMShell.DoLogic_DBGMCommon(gmCommon)
|
|
#Çå¿ÕËùÓÐÊý¾Ý¿âµÄGMÇëÇó
|
dBGMCommandListManager.Clear()
|
return
|
|
## ͬ²½µØͼ·þÎñÆ÷ʱ¼ä
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks GetTickByTypeȡʱ¼ä¼ä¸ô£¬gameWorld.OnTimeSyncÀ´Ïò¸÷µØͼ·¢³öͬ²½ÐÅÏ¢
|
def Dispose_MapServer_Time(tick):
|
gameWorld = GameWorld.GetGameWorld()
|
|
if tick - gameWorld.GetTickByType(ChConfig.TYPE_SendTimeToMapServer) < ChConfig.TYPE_Tick_Time[ChConfig.TYPE_SendTimeToMapServer]:
|
return
|
|
gameWorld.SetTickByType(ChConfig.TYPE_SendTimeToMapServer , tick)
|
|
#ͬ²½¼ÆËã»úʱ¼ä
|
gameWorld.OnTimeSync(GameWorld.GetCurrentDataTimeStr())
|
return
|
|
## »Ø±¨Êý¾Ý¿â·þÎñÆ÷״̬
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks gameWorld.DataServer_ServerStateReport() ÏòÊý¾Ý¿â»Ø±¨
|
# GetTickByType È¡¼ä¸ô
|
def DisposeServerState(tick):
|
gameWorld = GameWorld.GetGameWorld()
|
|
if tick - gameWorld.GetTickByType(ChConfig.TYPE_SendServerState) < ChConfig.TYPE_Tick_Time[ChConfig.TYPE_SendServerState]:
|
return
|
|
gameWorld.SetTickByType(ChConfig.TYPE_SendServerState , tick)
|
|
#»Ø±¨Êý¾Ý¿â·þÎñÆ÷״̬
|
gameWorld.DataServer_ServerStateReport()
|
return
|
|
## ±£´æÍæ¼ÒÊý¾Ý
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks GetDictByKey(ChConfig.Def_WorldKey_SavePlayer) Õâ¸ö×ÖµäֵΪ1£¬Ôò±£´æÍæ¼ÒÊý¾Ý
|
# OnHourÀÉèÖÃ23µãʱ£¬½«´ËkeyÉèÖÆΪ¿ÉÒÔ±£´æ¡£curPlayer.MapServer_PlayerSave()·¢Ëͱ£´æÇëÇó
|
def Dispose_MapServer_PlayerSave(tick):
|
if GameWorld.GetGameWorld().GetDictByKey(ChConfig.Def_WorldKey_SavePlayer) != 1:
|
#GameWorld.Log('±£´æ¿ª¹Ø먦Æô')
|
return
|
|
if datetime.datetime.today().minute < 50:
|
#GameWorld.Log('ûµ½50·ÖÖÓ')
|
return
|
|
playerManager = GameWorld.GetPlayerManager()
|
curPlayerList = []
|
for i in range(playerManager.GetActivePlayerCount()):
|
curPlayer = playerManager.GetActivePlayerAt(i)
|
curPlayerList.append(curPlayer)
|
|
#PythonÅÅÐò
|
curPlayerList.sort(key = GetKey)
|
|
for i in range(0, len(curPlayerList)):
|
#³¬¹ý50¸öÍæ¼Ò,²»´¦Àí
|
if i >= 50:
|
break
|
|
curPlayer = curPlayerList[i]
|
curPlayer.MapServer_PlayerSave()
|
#GameWorld.Log('---%s'%curPlayer.GetLV())
|
|
#ÉèÖÃΪÒѾ´¦ÀíÍê±Ï
|
GameWorld.GetGameWorld().SetDict(ChConfig.Def_WorldKey_SavePlayer , 2)
|
return
|
|
## PythonµÄsort×Öµä
|
# @param curPlayer µ±Ç°Ê±¼ä
|
# @return lv
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def GetKey(curPlayer):
|
return curPlayer.GetLV()
|
|
## »Ø±¨µ±Ç°Êý¾Ý¿âÍæ¼ÒÔÚÏßÊýÁ¿
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# ËùÓзþÎñÆ÷ÈËÊýÒª»Ø±¨Ò»´Î£¬ ÿ¸ömapÒ²Òª»Ø±¨Ò»´Î
|
# gameWorld.GetTickByType(0 - n) È¡¼ä¸ô
|
def DisposeGameActivePlayer(tick):
|
gameWorld = GameWorld.GetGameWorld()
|
curMinute = datetime.datetime.today().minute
|
#ΪÁËÿ¸ö·þµÄÊä³öʱ¼äµãͳһһ¸ö·ÖÖӵ㣬±ãÓÚͳ¼Æ
|
if curMinute % 5 != 0:
|
return
|
noteData = gameWorld.GetDictByKey("OnlineCntM")
|
if noteData == curMinute:
|
# ͬһ·ÖÖÓ²»¶à·¢ËÍ£¬´Ë´¦²»½¨ÒéÓÃCD´¦Àí£¬±ÜÃâÁ½CD³åÍ»
|
return
|
gameWorld.SetDict("OnlineCntM", curMinute)
|
|
# È«·þÔÚÏßÈËÊýƽ̨Ã÷ϸ
|
platformOLDict = {} # ƽ̨ÔÚÏßÈËÊý {ƽ̨:ÈËÊý, ...}
|
#mapPlatformOLDict = {} # µØͼƽ̨ÔÚÏßÈËÊý {mapID:{ƽ̨:ÈËÊý, ...}, ...}
|
tjgOnlineCnt = 0 # ÍÑ»ú¹ÒÔÚÏßÍæ¼Ò
|
playerManager = GameWorld.GetPlayerManager()
|
activePlayerCount = playerManager.GetActivePlayerCount()
|
for index in xrange(activePlayerCount):
|
player = playerManager.GetActivePlayerAt(index)
|
if player == None or not player.GetInitOK():
|
continue
|
|
if PlayerControl.GetIsTJG(player):
|
tjgOnlineCnt += 1
|
continue
|
|
platform = GameWorld.GetPlayerPlatform(player)
|
platformOLDict[platform] = platformOLDict.get(platform, 0) + 1 # ÀÛ¼Æƽ̨ÔÚÏßÈËÊý
|
|
# mapID = player.GetMapID()
|
# mapOLDict = mapPlatformOLDict.get(mapID, {})
|
# mapOLDict[platform] = mapOLDict.get(platform, 0) + 1 # ÀۼƵØͼƽ̨ÔÚÏßÈËÊý
|
# mapPlatformOLDict[mapID] = mapOLDict
|
|
#GameWorld.DebugLog("ƽ̨ÔÚÏßÈËÊý: %s" % platformOLDict)
|
#GameWorld.DebugLog("µØͼƽ̨ÔÚÏßÈËÊý: %s" % mapPlatformOLDict)
|
|
# ¼Ç¼·þÎñÆ÷ÈËÊý
|
#activePlayerCount = GameWorld.GetPlayerManager().GetActivePlayerCount()
|
#DataRecordPack.DR_OnLinePlayerCount(activePlayerCount, platformOLDict, tjgOnlineCnt)
|
#===========================================================================
|
for platform, playerCnt in platformOLDict.items():
|
DataRecordPack.DR_OnLinePlayerCount(playerCnt, platform, tjgOnlineCnt) # µ¥Æ½Ì¨
|
EventReport.WriteEvent_concurrency(playerCnt, 0, platform) # µ¥Æ½Ì¨ ´Ë´¦²»ÄÜ´«ÍÑ»ú¹ÒÍæ¼Ò×ÜÊý
|
|
|
#===========================================================================
|
|
DataRecordPack.DR_OnLinePlayerCount(activePlayerCount, {}, tjgOnlineCnt) # ×ÜÔÚÏß
|
#EventReport.WriteEvent_concurrency(activePlayerCount, tjgOnlineCnt)
|
#ˢе±Ç°µØͼ·þÎñÆ÷
|
#===========================================================================
|
# custom_concurrencyMapList = ReadChConfig.GetEvalChConfig("EventReportMapID")
|
# gameMapManager = GameWorld.GetGameWorld().GetGameMapManager()
|
# gameMapManager.RefreshMapPlayer()
|
# mapCnt = gameMapManager.GetCount()
|
# for i in xrange(mapCnt):
|
# curMap = gameMapManager.GetAt(i)
|
# mapID = curMap.GetID()
|
# if mapID not in custom_concurrencyMapList:
|
# continue
|
# #playerCnt = curMap.GetCount()
|
# mapOLDict = mapPlatformOLDict.get(mapID, {})
|
# for platform, playerCnt in mapOLDict.items():
|
# EventReport.WriteEvent_custom_concurrency(platform, playerCnt, "MapID:%s" % mapID)
|
#===========================================================================
|
|
# #ˢе±Ç°µØͼ·þÎñÆ÷
|
# gameMapManager = gameWorld.GetGameMapManager()
|
# #ˢеØͼ·þÎñÆ÷
|
# gameMapManager.RefreshMapPlayer()
|
# for i in range(gameMapManager.GetGameMapByIPCount()):
|
# curIP = gameMapManager.GetGameMapIPAt(i)
|
# curIndex = gameMapManager.GetGameMapIndexByIPAt(i)
|
# # ¼Ç¼µØͼ·þÎñÆ÷ÈËÊý
|
# DataRecordPack.DR_GameMapOnLinePlayerCnt(str(curIP), curIndex, gameMapManager.GetGameMapPlayerCountByIPAt(i))
|
return
|
|
## ´¦ÀíÊÀ½ç»î¶¯
|
# @param tick
|
# @return None
|
# @remarks
|
# ¶Ôµ±Ç°ËùÓл½øÐÐÅжϣ¬Èç¹û¿ªÆô»ò¹Ø±ÕµÄʱ¼äÓÐÒì³££¬»òÕ߻¹ýÆÚ£¬Ôò×¼±¸É¾³ý
|
# Èç¹ûÇ¡ºÃ´¦Ôڻʱ¼äÄÚ£¬Ôò¿ªÆôSetIsProcessing(True) ²¢Í¨ÖªÏàÓ¦map
|
# ×îºó½«ÒªÉ¾³ýµÄ»î¶¯µÄɾ³ý¹¤×÷£¨É¾³ýÇ°ÒªÏȹرջ) ͳһ½»¸ø±ðµÄ ·½·¨À´´¦Àí
|
def DisposeGameWorldGame(tick):
|
eventManager = GameWorld.GetGameWorldEventManager()
|
delList = []
|
todayDateTime = datetime.datetime.today()
|
|
for index in range(eventManager.GetActiveEventCount()):
|
event = eventManager.GetActiveEventByIndex(index)
|
eventID = event.GetEventID()
|
eventEndTime = GameWorld.GetDateTimeByStr(event.GetEndTime())
|
eventStartTime = GameWorld.GetDateTimeByStr(event.GetStartTime())
|
|
if not eventStartTime or not eventEndTime:
|
delList.append(eventID)
|
GameWorld.Log("###---»î¶¯ÉèÖÃʱ¼äÒì³£ , %s , %s , %s"%(eventID , eventStartTime , eventEndTime))
|
continue
|
|
#먦ÆôµÄ»î¶¯
|
if not event.GetIsProcessing():
|
if todayDateTime > eventStartTime and todayDateTime < eventEndTime:
|
#֪ͨµØͼ·þÎñÆ÷
|
event.SetIsProcessing(True)
|
#»ñµÃÄÚÈÝ
|
eventPar = event.GetPar()
|
#֪ͨµØͼ·þÎñÆ÷µ±Ç°»î¶¯
|
__NotifyMapServerProcess(event , eventID , eventPar)
|
|
#Êä³öϵͳÌáʾ
|
sysMsg = GMCommon.GetGameServer_GM_GameOpen_Msg(eventID)
|
if sysMsg != "":
|
PlayerControl.WorldNotify(0, sysMsg)
|
|
if todayDateTime > eventEndTime:
|
delList.append(eventID)
|
|
for delEventID in delList:
|
DoLogic_ProcessEvent_Close(delEventID)
|
|
#ɾ³ýʼþ
|
eventManager.DelActiveEvent(delEventID)
|
|
#Êä³öϵͳÌáʾ
|
sysMsg = GMCommon.GetGameServer_GM_GameClose_Msg(delEventID)
|
if sysMsg != "":
|
PlayerControl.WorldNotify(0, sysMsg)
|
|
return
|
|
## ½«»î¶¯Í¨Öª¸øµØͼ·þÎñÆ÷
|
# @param event »î¶¯
|
# @param eventID »î¶¯ID
|
# @param eventPar ÄÚÈÝ
|
# @return None
|
# @remarks ͨ¹ý»î¶¯ID£¬·Ö±ðµ÷Óò»Í¬µÄ·½·¨À´´¦Àí»î¶¯Âß¼£¬ÕâÀﶼÊÇ¿ªÆô»î¶¯
|
# »î¶¯µÄ²ÎÊýParÕâÀïÓÐÓõ½ ¶øÇÒ²»Í¬µÄ»î¶¯£¬ParµÄº¬ÒåÒ²²»Í¬£¬¿ÉÄÜ»¹Òª½øÐнâÎö
|
def __NotifyMapServerProcess(event , eventID , eventPar):
|
#ÊÇ·ñÊÇÈ«·þË«±¶ÈÎÎñ
|
if eventID == ChConfig.Def_GY_GM_Game_DoubleExp:
|
__DisposeWorldExpEvent(True , int(eventPar))
|
#ÊÇ·ñÊÇÈ«·þµôÂÊÔö¼Ó
|
elif eventID == ChConfig.Def_GY_GM_Game_DropRate:
|
__DisposeWorldDropRateEvent(True , int(eventPar))
|
#ÊÇ·ñÊÇÈ«·þ¹«¸æÈÎÎñ
|
elif eventID == ChConfig.Def_GY_GM_Game_Broadcast:
|
interval , msg = __GetBroseCastStr(eventPar)
|
__DisposeBroadcastEvent(True, msg, interval)
|
else:
|
#֪ͨËùÓеĵØͼ·þÎñÆ÷,Ö´ÐÐÈÎÎñÊý¾Ý½Å±¾
|
event.Notify_AllMapServerProcess()
|
|
return
|
|
#---------------------------------------------------------------------
|
## ¹Ø±ÕÒѾ¿ªÆôµÄ»î¶¯
|
# @param eventID »î¶¯ID
|
# @return None
|
# @remarks Ó뿪Æô»î¶¯Ïà·´£¬ÕâÀïÊǹرջ
|
def DoLogic_ProcessEvent_Close(eventID):
|
#ÊÇ·ñÊÇÈ«·þË«±¶ÈÎÎñ
|
if eventID == ChConfig.Def_GY_GM_Game_DoubleExp:
|
__DisposeWorldExpEvent(False)
|
#ÊÇ·ñÊÇÈ«·þµôÂÊÔö¼Ó
|
elif eventID == ChConfig.Def_GY_GM_Game_DropRate:
|
__DisposeWorldDropRateEvent(False)
|
#ÊÇ·ñÊÇÈ«·þ¹«¸æÈÎÎñ
|
elif eventID == ChConfig.Def_GY_GM_Game_Broadcast:
|
__DisposeBroadcastEvent(False)
|
|
return
|
#---------------------------------------------------------------------
|
|
## ½âÎö¹Ø²¥×Ö·û´®
|
# @param eventPar
|
# @return interval , msg
|
# @remarks ¹ã²¥»î¶¯Á¦µÄPar£¬Í¨¹ý´Ë·½·¨±»½âÎö³É¹ã²¥ÄÚÈݺ͹㲥¼ä¸ô
|
def __GetBroseCastStr(eventPar):
|
index = eventPar.find(":")
|
interval = int(eventPar[:index])
|
msg = eventPar[index + 1:]
|
return interval , msg
|
|
## ÉèÖò¢´¦ÀíÊÀ½ç¾ÑéÂß¼
|
# @param isOpen ÊÇ·ñÉèÖÃ
|
# @param expRate ĬÈÏÍò·ÖÂÊ Õâ¸öÊÇδ¿ªÊ¼»î¶¯µÄĬÈϾÑ鱶ÂÊ
|
# @return None
|
# @remarks ¿ªÆô»òɾ³ýÈ«¸±Ë«±¶»î¶¯£¬½ö½öÉèÖÃgameWorld.SetExpRate¾Í¿ÉÒÔÁË
|
def __DisposeWorldExpEvent(isOpen , expRate = ChConfig.Def_MaxRateValue):
|
gameWorld = GameWorld.GetGameWorld()
|
#¿ªÆô»î¶¯
|
if isOpen:
|
gameWorld.SetExpRate(expRate)
|
else:
|
gameWorld.SetExpRate(expRate)
|
|
return
|
|
## ÉèÖò¢´¦ÀíÊÀ½çµôÂÊÂß¼
|
# @param isOpen ÊÇ·ñÉèÖÃ
|
# @param expRate ĬÈÏÍò·ÖÂÊ Õâ¸öÊÇδ¿ªÊ¼»î¶¯µÄĬÈϾÑ鱶ÂÊ
|
# @return None
|
def __DisposeWorldDropRateEvent(isOpen, expRate=0):
|
#¿ªÆô»î¶¯
|
if isOpen:
|
worldDropRateAdd = max(0, expRate - ChConfig.Def_MaxRateValue)
|
else:
|
worldDropRateAdd = 0 # Èô¹Ø±Õ£¬Ä¬ÈÏΪ0
|
|
SetWorldDropRateAdd(worldDropRateAdd)
|
return
|
|
## ÉèÖò¢Í¨ÖªÊÀ½çµôÂÊÔö¼Ó
|
def SetWorldDropRateAdd(worldDropRateAdd):
|
#===============================================================================================
|
# # ֪ͨÊÀ½çµôÂÊÌáÉý
|
# worldDropRateKey = ShareDefine.Def_Notify_WorldKey_WorldDropRateAdd
|
# GameWorld.GetGameWorld().SetDict(worldDropRateKey, worldDropRateAdd)
|
# GameWorld.SendMapServerMsgEx(worldDropRateKey, worldDropRateAdd)
|
#===============================================================================================
|
return
|
|
#---------------------------------------------------------------------
|
## ´¦ÀíµØͼ¾Ñé×Ö·û´®
|
# @param event »î¶¯
|
# @param mapIDList Ë;ÑéµØͼ×Ö·û´®
|
# @return None
|
# @remarks ֪ͬµØͼ·þÎñÆ÷£¬ÓõÄÊÇ: µ«ÊÇ֪ͨµÄÄÚÈÝÊÇʲôÄØ£¿Ó¦¸ÃÊÇDZ¹æÔò¾ÍÖªµÀÁË¡£¡£¡£
|
# event.Notify_AllMapServerProcess()
|
# ºÍ event.Notify_SelectMapServerProcess(vector)
|
def __DisposeMapGiveExp(event , mapIDList):
|
#×Ö·û´® '[]' -> []
|
mapIDList = eval(mapIDList)
|
|
if not mapIDList:
|
#֪ͨȫ·þÎñÆ÷Ö´ÐÐ
|
event.Notify_AllMapServerProcess()
|
return
|
|
vector = IPY_GameServer.IntVector()
|
for mapID in mapIDList:
|
vector.push_back(int(mapID))
|
|
#ָ֪ͨ¶¨µØͼ·þÎñÆ÷
|
event.Notify_SelectMapServerProcess(vector)
|
return
|
#---------------------------------------------------------------------
|
## ÉèÖÃÊÇ·ñ¿ªÆôÓÎÏ·ÊÀ½çÖеĹ«¸æÕâ¸ö»î¶¯
|
# @param isOpen ÊÇ·ñ¿ªÆô
|
# @param broadcastMsg ¹ã²¥ÄÚÈÝ
|
# @param broadcastTick ¹ã²¥¼ä¸ô
|
# @return None
|
# @remarks ÉèÖÿªÆô»ò¹Ø±ÕÓÎÏ·¹ã²¥µÄ»î¶¯µÄ¿ª¹Ø£¬¿ÉÒÔÉèÖù㲥ÄÚÈݺ͹㲥¼ä¸ô
|
def __DisposeBroadcastEvent(isOpen , broadcastMsg = '' , broadcastTick = 0):
|
gameWorld = GameWorld.GetGameWorld()
|
#ÊÇ·ñ¿ªÆô
|
if isOpen:
|
gameWorld.SetBroadcastMsg(broadcastMsg)
|
gameWorld.SetBroadcastInterval(broadcastTick)
|
|
#ÊÇ·ñ¹Ø±Õ
|
else:
|
gameWorld.SetBroadcastMsg(broadcastMsg)
|
gameWorld.SetBroadcastTick(0)
|
gameWorld.SetBroadcastInterval(0)
|
|
return
|
#---------------------------------------------------------------------
|
## ´¦ÀíÊÀ½ç¹«¸æ
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks
|
# IPY_GameWorldEventManager.FindActiveEvent(int eventID) µÃµ½IPY_GameWorldEvent
|
# ÔÙÅжÏÕâ¸öevent ÊÇ·ñGetIsProcessing() Õâ¸öʼþ¡£¡£¡£Æäʵ¾ÍÊǹ㲥ʼþChConfig.Def_GY_GM_Game_Broadcast
|
# Èç¹û´¦Ôڹ㲥ʼþÏ£ºgameWorld.GetBroadcastTick()»ñÈ¡ÊÇ·ñ´ïµ½¹ã²¥¼ä¸ô
|
# »¹Óй㲥ÄÚÈÝ£¬¹ã²¥³ÖÐøʱ¼äµÈ£¬¶¼´ÓGameWorldÖ±½Ó»ñµÃ
|
# ¶øÓÎÏ·¹ã²¥ÄÚÈÝ£¬Ò²ÊÇÔÚ±¾Ä£¿éÀïµÄÆäËû·½·¨ÀïÇëÇóÌí¼Ó½øÈ¥µÄ
|
def DisposeGameWorldBroadcast(tick):
|
eventManager = GameWorld.GetGameWorldEventManager()
|
broadEvent = eventManager.FindActiveEvent(ChConfig.Def_GY_GM_Game_Broadcast)
|
if not broadEvent:
|
#ÎÞ¹«¸æ
|
return
|
|
if not broadEvent.GetIsProcessing():
|
#δ¼¤»î
|
return
|
|
gameWorld = GameWorld.GetGameWorld()
|
broadcastMsg = gameWorld.GetBroadcastMsg()
|
|
if broadcastMsg == '' :
|
#ÎÞÄÚÈÝ
|
return
|
|
#===============================================================================
|
# ²»ÓÃÕâ¸öÅж¨ÁË,¸ÄΪ¿ªÆôʱ¼ä,½áÊøʱ¼ä
|
# boradcastStartTick = gameWorld.GetBroadcastStartTick()
|
#
|
# if boradcastStartTick == 0:
|
# #ÎÞ¿ªÆôʱ¼ä
|
# return
|
#
|
#
|
# ²»ÓÃÕâ¸öÅж¨ÁË,¸ÄΪ¿ªÆôʱ¼ä,½áÊøʱ¼ä
|
# if tick - boradcastStartTick > gameWorld.GetBroadcastLastTime() * 60 * 1000:
|
# #ÒѾ¹ýÆÚ
|
# return
|
#
|
#===============================================================================
|
|
#¼ä¸ô -> ·ÖÖÓתºÁÃë
|
if tick - gameWorld.GetBroadcastTick() < gameWorld.GetBroadcastInterval() * 60 * 1000:
|
#¼ä¸ôδµ½
|
return
|
|
#¹ã²¥
|
GameWorld.GetPlayerManager().BroadcastInfo(broadcastMsg)
|
#ÉèÖüä¸ô
|
gameWorld.SetBroadcastTick(tick)
|
|
return
|
|
## ´¦ÀíÓÎÏ·ÊÀ½çÖеÄïÚ³µ
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def DisposeGameWorldEvenByTruck(tick) :
|
#½«Éæ¼°µ½C++ÖÐÁбíɾ³ýµÄ¹¦ÄÜ,ͳһ¸Ä³É -> ¸´ÖÆPyÁбíºó,È»ºó½øÐÐɾ³ýÂß¼ (ÒòWhileÓм¸Âʽ«µ¼ÖÂËÀËø)
|
worldTruck_List = []
|
#ïÚ³µ¹ÜÀíÆ÷
|
truckMananger = GameWorld.GetTruckMananger()
|
for index in range(truckMananger.GetTruckCount()):
|
truck = truckMananger.GetTruckByIndex(index)
|
worldTruck_List.append(truck)
|
|
if not worldTruck_List:
|
return
|
|
truckTime = ReadChConfig.GetEvalChConfig("TruckTime") * 60
|
curTime = int(time.time())
|
#·þÎñ¶Ë´¦ÀíïÚ³µ³¬Ê±Îª ʵ¼ÊÔËïÚÏÞÖÆʱ¼ä+µôÏß»º³åʱ¼ä
|
#³¬¹ý´Ëʱ¼äºóïÚ³µÏûʧ£¬ÇÒÎÞ½±Àø
|
disappearTime = truckTime + ChConfig.Def_PlayerTruckLogoffTick / 1000
|
#GameWorld.DebugLog("DisposeGameWorldEvenByTruck count=%s,curTime=%s,truckTime=%s,disappearTime=%s"
|
# % (len(worldTruck_List), curTime, truckTime, disappearTime))
|
|
#´¦ÀíÂß¼
|
for curTruck in worldTruck_List:
|
|
if curTime - curTruck.GetLogoffTick() < disappearTime:
|
#GameWorld.Log(" ÔËïÚʱ¼ä: %d startTime=%d,curTime=%s,truckTime=%s, passTime=%s"
|
# % (curTruck.GetOwnerID(), curTruck.GetLogoffTick(), curTime, truckTime, curTime - curTruck.GetLogoffTick()))
|
continue
|
|
GameWorld.Log("ÔËïÚʱ¼ä³¬Ê±: %d disappear! startTime=%d,curTime=%s,truckTime=%s"
|
% (curTruck.GetOwnerID(), curTruck.GetLogoffTick(), curTime, truckTime))
|
#³¬¹ýʱ¼ä,ïÚ³µÏûʧ
|
PlayerTruck.DelTruck(curTruck)
|
|
# #»ñµÃÖ÷ÈË
|
# curTruckOwnerID = curTruck.GetOwnerID()
|
# curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(curTruckOwnerID)
|
# #Ö÷ÈË»¹ÔÚÏß
|
# if curPlayer != None:
|
# continue
|
#
|
# if curTruck.GetLogoffTick() == 0:
|
# continue
|
#
|
# #Íæ¼Ò²»ÔÚÏß,µ«ïÚ³µÏûʧʱ¼äδµ½,²»Ïûʧ
|
# if tick - curTruck.GetLogoffTick() < ChConfig.Def_PlayerTruckLogoffTick:
|
# continue
|
#
|
# GameWorld.Log("%d disappear! logofftick = %d"%(curTruckOwnerID, curTruck.GetLogoffTick()))
|
# #³¬¹ýʱ¼ä,ïÚ³µÏûʧ
|
# PlayerTruck.DelTruck(curTruck)
|
|
return
|
|
## ´¦ÀíÓÎÏ·ÊÀ½çʱ¼äʼþ
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def DisposeGameWorldEvenByTime(tick) :
|
#Ö´ÐÐʱ¼ä´¦ÀíÂß¼
|
DoLogic_GameWorldEvenByTime(tick)
|
return
|
|
## Ö´ÐÐʱ¼ä´¦ÀíÂß¼
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks ¶Ô±È·þÎñÆ÷µ±Ç°Ê±¼äºÍ·þÎñÆ÷ÉϴμǼµÄʱ¼ä£¬Èç¹ûÓÐСʱ²îÒ죬Ôò˵Ã÷Ó¦´¥·¢Ð¡Ê±Ê¼þ
|
# Èç´ËÀàÍÆ£¬callµ½ËùÓÐÒòʱ¼ä¶ø´¥·¢Ê¼þµÄº¯ÊýÖÐ
|
def DoLogic_GameWorldEvenByTime(tick):
|
lastTick = GameWorld.GetGameWorld().GetTickByType(ChConfig.TYPE_EvenByTime)
|
|
if lastTick == -1:
|
#GameWorld.Log("δ³õʼ»¯·þÎñÆ÷")
|
return
|
|
#·þÎñÆ÷µ±Ç°Ê±¼ä( ×Ö·û´® ) , ÓÃÓڼǼ
|
curTimeStr = GameWorld.GetCurrentDataTimeStr()
|
|
#-----------·þÎñÆ÷µ±Ç°Ê±¼ä
|
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 = GameLogInfo.InitServerTime()
|
|
#-----------¿ªÊ¼±È¶Ôʱ¼ä
|
#OnHourʼþ
|
if (serverHour != curTimeHour or serverDay!= curTimeDay or serverMonth != curTimeMonth or serverYear != curTimeYear):
|
OnHour(curTimeStr, tick)
|
|
#OnDayʼþ
|
if (serverDay != curTimeDay or serverMonth != curTimeMonth or serverYear != curTimeYear):
|
OnDay(curTimeStr, tick)
|
|
#OnDayExʼþ
|
if __Get_Can_OnDayEx():
|
OnDayEx(tick)
|
|
#OnWeekʼþ
|
#²»¿¼ÂǸôÄêÇé¿ö£¬Èç2009,12,31Èչطþ->2010,12,31ÈÕ¿ª·þ(²»´¥·¢OnWeek)
|
if (serverWeek != curTimeWeek):
|
OnWeek(curTimeStr, tick)
|
|
#OnWeekExʼþ
|
if __Get_Can_OnWeekEx():
|
OnWeekEx(tick)
|
|
#OnMonthʼþ
|
if (serverMonth != curTimeMonth or serverYear != curTimeYear):
|
OnMonth(curTimeStr, tick)
|
|
#OnMonthExʼþ
|
if __Get_Can_OnMonthEx():
|
OnMonthEx(tick)
|
|
#OnYearʼþ
|
if serverYear != curTimeYear:
|
OnYear(curTimeStr, tick)
|
|
return
|
|
def __Get_Can_OnDayEx():
|
'''ÅжϿɷñÁ賿Xµã¹ýÌì
|
@return: 0-²»¿É£» 1-¿ÉÒÔ
|
'''
|
curDateTime = GameWorld.GetServerTime()
|
#dateTime_Day = curDateTime.day
|
#dateTime_Month = curDateTime.month
|
#dateTime_Year = curDateTime.year
|
|
# ÉϴιýÌì¼Ç¼¸ñʽ: ÄêÔÂÈÕ, Èç20171027
|
lastOndayEx = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_Server_DayEx)
|
#GameWorld.DebugLog("__Get_Can_OnDayEx lastOndayEx=%s" % (lastOndayEx))
|
if lastOndayEx:
|
lastOndayEx_Year = lastOndayEx / 10000
|
lastOndayEx_Month = lastOndayEx % 10000 / 100
|
lastOndayEx_Day = lastOndayEx % 100
|
#GameWorld.DebugLog("lastOndayEx_Year=%s,lastOndayEx_Month=%s,lastOndayEx_Day=%s" % (lastOndayEx_Year, lastOndayEx_Month, lastOndayEx_Day))
|
|
# ÉϴιýÌìµÄÈÕÆÚ0µã
|
lastDatetime = datetime.datetime(lastOndayEx_Year, lastOndayEx_Month, lastOndayEx_Day, 0, 0, 0)
|
passTime = curDateTime - lastDatetime
|
passDays = passTime.days
|
passSeconds = passTime.seconds
|
|
# Èç¹ûʱ¼ä²îûÓг¬¹ý1Ì죬´ú±í»¹Î´¹ýÌì
|
if passDays == 0:
|
#GameWorld.DebugLog("Èç¹ûʱ¼ä²îûÓг¬¹ý1Ì죬´ú±í»¹Î´¹ýÌì, passDays=%s" % passDays)
|
return 0
|
# µÈÓÚ1ÌìµÄ, ʱ¼ä²îÐè >= Xʱ²Å¿É¹ýÌì, ¼´ X * 3600 Ãë
|
if passDays == 1 and passSeconds < ShareDefine.Def_OnEventHour * 3600:
|
#GameWorld.DebugLog("µÈÓÚ1ÌìµÄ, ʱ¼ä²îÐè >= Xʱ²Å¿É¹ýÌì, ¼´ X * 3600 Ãë, passSeconds=%s" % passSeconds)
|
return 0
|
#if passDays < 0:
|
# GameWorld.DebugLog("ʱ¼äÌì²îСÓÚ0£¬Ò»°ãΪÒì³£Çé¿ö£¬Ö»ÓÐʱ¼äÍù»Øµ÷²Å»Ø³öÏÖ!ĬÈÏÔÊÐí¹ýÌì,passDays=%s" % passDays)
|
# ´óÓÚ1ÌìµÄÎÞÂÛʲôʱ¼äµã¶¼¿ÉÒÔ¹ýÌì
|
|
#GameWorld.DebugLog("¿ÉÒÔ¹ýÌì")
|
return 1
|
|
def __Set_Server_DayEx():
|
onDayDateTime = GameWorld.GetServerTime()
|
# ÌØÊâXµã֮ǰ¹ýÌìµÄ£¬´ú±íÌì²î´óÓÚ1ÌìµÄʱ¼ä¹ýÌ죬ÕâʱºòµÄ¹ýÌìÖµÐèÉèÖÃΪ×òÌì
|
if onDayDateTime.hour < ShareDefine.Def_OnEventHour:
|
onDayDateTime = onDayDateTime - datetime.timedelta(days=1)
|
#GameWorld.Log("SetDayEx ÌØÊâXµã֮ǰ¹ýÌìµÄ£¬´ú±íÌì²î´óÓÚ1ÌìµÄʱ¼ä¹ýÌ죬ÕâʱºòµÄ¹ýÌìÖµÐèÉèÖÃΪ×òÌì %s" % onDayDateTime)
|
|
ondayExValue = onDayDateTime.year * 10000 + onDayDateTime.month * 100 + onDayDateTime.day
|
PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_Server_DayEx, ondayExValue)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_OnDayEx, ondayExValue)
|
GameWorld.Log("Set_Server_DayEx, OnDayExValue=%s" % ondayExValue)
|
return
|
|
def __Get_Can_OnWeekEx():
|
'''ÅжϿɷñÁ賿Xµã¹ýÖÜ
|
@return: 0-²»¿É£» 1-¿ÉÒÔ
|
'''
|
curDateTime = GameWorld.GetServerTime()
|
isocalendar = datetime.datetime.isocalendar(curDateTime)
|
dateTime_year, dateTime_week, dateTime_day = isocalendar
|
|
# ÉϴιýÖܼǼ¸ñʽ: ÄêÖÜ, Èç201752
|
lastOnWeekEx = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_Server_WeekEx)
|
#GameWorld.DebugLog("__Get_Can_OnWeekEx lastOnWeekEx=%s,dateTime_year=%s,week=%s,day=%s"
|
# % (lastOnWeekEx, dateTime_year, dateTime_week, dateTime_day))
|
if lastOnWeekEx:
|
lastOnWeekEx_Year = lastOnWeekEx / 100
|
lastOnWeekEx_Week = lastOnWeekEx % 100
|
# ±¾ÖÜÒѾ¹ýÖܹý
|
if dateTime_year == lastOnWeekEx_Year and dateTime_week == lastOnWeekEx_Week:
|
#GameWorld.DebugLog("±¾ÖÜÒѾ¹ýÖܹý")
|
return 0
|
|
# µ±Ç°ÌìΪÿÖܵÚÒ»ÌìµÄʱºò£¬ÐèÅжÏÖܲîΪ1ʱµ±Ç°Ê±¼äµãÊÇ·ñ³¬¹ý5µã
|
if dateTime_day == 1:
|
preWeekDateTime = curDateTime - datetime.timedelta(days=7) # ÉÏÒ»ÖܵÄdatetime(¼´ÖܲîΪ1)
|
preWeek_year, preWeek_week, preWeek_day = datetime.datetime.isocalendar(preWeekDateTime)
|
|
# ÉϴιýÖܵĸպÃÊÇÖܲî1, ÔòÐèÅжϵ±Ç°Ê±¼äµãÊÇ·ñ³¬¹ýXʱ
|
if preWeek_year == lastOnWeekEx_Year and preWeek_week == lastOnWeekEx_Week:
|
if curDateTime.hour < ShareDefine.Def_OnEventHour:
|
#GameWorld.DebugLog("±¾ÖܵÚÒ»Ì죬δµ½´ï¹ýÖÜʱ¼äµã, hour=%s" % curDateTime.hour)
|
return 0
|
|
# ÖܲΪ1µÄʱºò£¬ÔòÎÞÂÛʲôʱ¼äµã¾ù¿É¹ýÖÜ
|
else:
|
#GameWorld.DebugLog("ÖܲΪ1µÄʱºò£¬ÔòÎÞÂÛʲôʱ¼äµã¾ù¿É¹ýÖÜ, ¿ÉÒÔ¹ýÖÜ")
|
pass
|
|
# ²»ÊÇÿÖܵÚÒ»ÌìµÄʱºò£¬ÔòÎÞÂÛʲôʱ¼äµã¾ù¿É¹ýÖÜ
|
else:
|
#GameWorld.DebugLog("²»ÊÇÿÖܵÚÒ»ÌìµÄʱºò£¬ÔòÎÞÂÛʲôʱ¼äµã¾ù¿É¹ýÖÜ, ¿ÉÒÔ¹ýÖÜ")
|
pass
|
|
#GameWorld.DebugLog("¿ÉÒÔ¹ýÖÜ")
|
return 1
|
|
def __Set_Server_WeekEx():
|
onWeekDateTime = GameWorld.GetServerTime()
|
isocalendar = datetime.datetime.isocalendar(onWeekDateTime)
|
dateTime_year, dateTime_week, dateTime_day = isocalendar
|
# ÌØÊâXµã֮ǰ¹ýÖܵģ¬´ú±íÖܲî´óÓÚ1ÌìµÄʱ¼ä¹ýÌ죬ÕâʱºòµÄ¹ýÌìÖµÐèÉèÖÃΪÉÏÖÜ
|
if dateTime_day == 1 and onWeekDateTime.hour < ShareDefine.Def_OnEventHour:
|
onWeekDateTime = onWeekDateTime - datetime.timedelta(days=7) # ÉÏÒ»ÖܵÄdatetime(¼´ÖܲîΪ1)
|
dateTime_year, dateTime_week, dateTime_day = datetime.datetime.isocalendar(onWeekDateTime)
|
#GameWorld.Log("SetWeekEx ÖÜÒ»ÌØÊâXµã֮ǰ¹ýÌìµÄ£¬´ú±íÖܲî´óÓÚ1µÄÖÜÒ»¹ýÖÜ£¬ÕâʱºòµÄ¹ýÖÜÖµÐèÉèÖÃΪÉÏÖÜ %s" % onWeekDateTime)
|
|
onWeekExValue = dateTime_year * 100 + dateTime_week
|
PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_Server_WeekEx, onWeekExValue)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_OnWeekEx, onWeekExValue)
|
GameWorld.Log("Set_Server_WeekEx, OnWeekExValue=%s" % onWeekExValue)
|
return
|
|
def __Get_Can_OnMonthEx():
|
'''ÅжϿɷñÁ賿Xµã¹ýÔÂ
|
@return: 0-²»¿É£» 1-¿ÉÒÔ
|
'''
|
curDateTime = GameWorld.GetServerTime()
|
dateTime_day = curDateTime.day
|
dateTime_month = curDateTime.month
|
dateTime_year = curDateTime.year
|
|
# ÉϴιýԼǼ¸ñʽ: ÄêÔÂ, Èç201712
|
lastOnMonthEx = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_Server_MonthEx)
|
#GameWorld.DebugLog("__Get_Can_OnMonthEx lastOnMonthEx=%s,dateTime_year=%s,dateTime_month=%s"
|
# % (lastOnMonthEx, dateTime_year, dateTime_month))
|
if lastOnMonthEx:
|
lastOnMonthEx_Year = lastOnMonthEx / 100
|
lastOnMonthEx_Month = lastOnMonthEx % 100
|
# ±¾ÔÂÒѾ¹ýÔ¹ý
|
if dateTime_year == lastOnMonthEx_Year and dateTime_month == lastOnMonthEx_Month:
|
#GameWorld.DebugLog("±¾ÔÂÒѾ¹ýÔ¹ý")
|
return 0
|
|
# µ±Ç°ÌìΪÿÔµÚÒ»ÌìµÄʱºò£¬ÐèÅжÏÔ²îΪ1ʱµ±Ç°Ê±¼äµãÊÇ·ñ³¬¹ý5µã
|
if dateTime_day == 1:
|
preMonth_month = 12 if dateTime_month == 1 else dateTime_month - 1 # ÉÏÒ»ÔÂ
|
preMonth_year = dateTime_year if preMonth_month != 12 else dateTime_year - 1 # ÉÏÒ»ÔÂËùÊôÄê
|
#GameWorld.DebugLog("preMonth_year=%s,preMonth_month=%s,lastOnMonthEx_Year=%s,lastOnMonthEx_Month=%s"
|
# % (preMonth_year, preMonth_month, lastOnMonthEx_Year, lastOnMonthEx_Month))
|
# ÉϴιýÔµĸպÃÊÇÔ²î1, ÔòÐèÅжϵ±Ç°Ê±¼äµãÊÇ·ñ³¬¹ýXʱ
|
if preMonth_year == lastOnMonthEx_Year and preMonth_month == lastOnMonthEx_Month:
|
if curDateTime.hour < ShareDefine.Def_OnEventHour:
|
#GameWorld.DebugLog("±¾ÔµÚÒ»Ì죬δµ½´ï¹ýÔÂʱ¼äµã, hour=%s" % curDateTime.hour)
|
return 0
|
|
# Ô²Ϊ1µÄʱºò£¬ÔòÎÞÂÛʲôʱ¼äµã¾ù¿É¹ýÔÂ
|
else:
|
#GameWorld.DebugLog("Ô²Ϊ1µÄʱºò£¬ÔòÎÞÂÛʲôʱ¼äµã¾ù¿É¹ýÔÂ, ¿ÉÒÔ¹ýÔÂ")
|
pass
|
|
# ²»ÊÇÿÔµÚÒ»ÌìµÄʱºò£¬ÔòÎÞÂÛʲôʱ¼äµã¾ù¿É¹ýÔÂ
|
else:
|
#GameWorld.DebugLog("²»ÊÇÿÔµÚÒ»ÌìµÄʱºò£¬ÔòÎÞÂÛʲôʱ¼äµã¾ù¿É¹ýÔÂ, ¿ÉÒÔ¹ýÔÂ")
|
pass
|
|
#GameWorld.DebugLog("¿ÉÒÔ¹ýÔÂ")
|
return 1
|
|
def __Set_Server_MonthEx():
|
onMonthDateTime = GameWorld.GetServerTime()
|
dateTime_day = onMonthDateTime.day
|
dateTime_month = onMonthDateTime.month
|
dateTime_year = onMonthDateTime.year
|
# ÌØÊâXµã֮ǰ¹ýÔµģ¬´ú±íÔ²î´óÓÚ1ÌìµÄʱ¼ä¹ýÌ죬ÕâʱºòµÄ¹ýÌìÖµÐèÉèÖÃΪÉÏÔÂ
|
if dateTime_day == 1 and onMonthDateTime.hour < ShareDefine.Def_OnEventHour:
|
dateTime_month = 12 if dateTime_month == 1 else dateTime_month - 1 # ÉÏÒ»ÔÂ
|
dateTime_year = dateTime_year if dateTime_month != 12 else dateTime_year - 1 # ÉÏÒ»ÔÂËùÊôÄê
|
GameWorld.Log("SetMonthEx ÔÂ1ºÅÌØÊâXµã֮ǰ¹ýÌìµÄ£¬´ú±íÔ²î´óÓÚ1µÄÔÂ1ºÅ¹ýÔ£¬ÕâʱºòµÄ¹ýÔÂÖµÐèÉèÖÃΪÉÏÔÂ")
|
|
onMonthExValue = dateTime_year * 100 + dateTime_month
|
PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_Server_MonthEx, onMonthExValue)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_OnMonthEx, onMonthExValue)
|
GameWorld.Log("Set_Server_MonthEx, onMonthExValue=%s" % onMonthExValue)
|
return
|
|
#---------------------------------------------------------------------
|
##GameWorldÔ¤³õʼ»¯
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks ±ÈInitGameWorld¸üÔçµÄʱ»ú³õʼ»¯
|
def PreInitGameWorld(tick):
|
#===============================================================================
|
# ÔÚÕâÀï³õʼ»¯Ò»Ð©ºÍÓÎÏ·¶ÔÏóÎ޹صĶ«Î÷£¬Õâ¸ö³õʼ»¯Ê±»úÔ¶±ÈInitGameWorldÔ磬±ÈÈçÕâ´ÎµÄÅÅÐаñÀàÐ;ÍÒªÔÚÕâ¸ö³õʼ»¯ÀïÃæÌí¼Ó
|
# ÔÚÕâ¸ö³õʼ»¯º¯ÊýµÄ×îºó Òªµ÷ÓÃSetPreInitOKº¯Êý ÉèÖóõʼ»¯ÒѾ³É¹¦
|
#===============================================================================
|
#³õʼ»¯ÅÅÐаñ
|
PlayerBillboard.InitServerBillboard()
|
#³õʼ»¯¶ÓÎé×î´óÈËÊý
|
GameWorld.GetTeamManager().SetMaxTeamMemberCount(ChConfig.Def_Team_MaxPlayerCount)
|
|
#ÉèÖóõʼ»¯³É¹¦
|
GameWorld.GetGameWorld().SetPreInitOK(True)
|
return
|
|
## GameWorld³õʼ»¯
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks ÏÈÇëÇóÅÅÐаñÐÅÏ¢£¬È»ºóSetTickTypeCount£¬ÉèÖÃÐèÒª±£´æµÄʱ¼äÖÖÀà
|
def InitGameWorld(tick):
|
#±ê¼ÇGameWorld³õʼ»¯Íê³É
|
GameWorld.GetGameWorld().SetDict(ChConfig.Def_WorldKey_IsGameWorldInit, int(time.time()))
|
#³õʼ»¯ÓÎϷʱÖÓ
|
GameWorld.GetGameWorld().SetTickTypeCount(ChConfig.TYPE_Tick_Count)
|
#³õʼ»°¿ª·þʱ¼ä¡¢ÐÇÆÚ¼¸
|
initOpenServerTime = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_InitOpenServerTime)
|
openServerWeekday = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_OpenServerWeekday)
|
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.SortServerBillboard()
|
#ÅÅÐòÏÉÃË
|
PlayerFamily.DoFamilySort()
|
GameWorldActionControl.Dispose_FBStateTime()
|
#ÏÉÃËÁªÈü
|
GameWorldFamilyWar.OnGameServerInitOK()
|
#²éѯPyTableÐÅÏ¢
|
#PlayerDBOper.QueryAllPyTable()
|
#ʼþ»ã±¨³õʼ»¯
|
EventReport.InitDllAppID()
|
|
#ReloadModule.RefreshModuleFileCMTime(True)
|
#ºÏ·þÊ×´ÎÆô¶¯¼ÓÔØ´¦Àí
|
__DoMixServerInit()
|
#ÏÉħ֮Õù
|
PlayerXMZZ.OnGameServerInitOK()
|
#¼ÓÔØ»îÔ¾Íæ¼ÒµÈ¼¶ÐÅÏ¢
|
ChPlayer.LoadPlayerLVData()
|
#¼ÓÔØÖúÕ½ÐÅÏ¢
|
PlayerFBHelpBattle.OnServerStart()
|
#¿ç·þPK
|
CrossRealmPK.OnGameServerInitOK()
|
#ÊÀ½çboss±»É±´ÎÊýÖØÖÃ
|
#GameWorldBoss.CheckResetBossKilledCntOnServerInit()
|
|
__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):
|
setOpenServerTime = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_SetOpenServerTime)
|
if not setOpenServerTime:
|
#GameWorld.DebugLog("ûÓÐÖ¸¶¨¿ª·þʱ¼ä£¡")
|
return
|
curOpenServerTime = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_InitOpenServerTime)
|
if curOpenServerTime == setOpenServerTime:
|
#GameWorld.DebugLog("ÒѾÕýʽ¿ª·þ¹ýÁË£¡")
|
return
|
curTime = int(time.time())
|
if curTime < setOpenServerTime:
|
#GameWorld.DebugLog("»¹Î´µ½Õýʽ¿ª·þʱ¼ä£¡")
|
return
|
OnNewServerOpen(tick)
|
return
|
|
def OnNewServerOpen(tick):
|
'''зþ¿ªÆôÐèÒª´¦ÀíµÄÂß¼'''
|
GameWorld.Log("Ö´ÐÐÕýʽ¿ª·þÖØÖÃÂß¼...")
|
|
setOpenServerTime = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_SetOpenServerTime)
|
if not setOpenServerTime:
|
return
|
|
#Çå DBGSTrig
|
dbgsTrigKeyDict = {}
|
gsEventTrigManager = GameWorld.GetGameWorld().GetDBGameServerEventTrigManager()
|
for i in xrange(gsEventTrigManager.GetCount()):
|
gsEvent = gsEventTrigManager.GetAt(i)
|
key = gsEvent.GetEventID()
|
value = gsEvent.GetIsEvent()
|
if not value or key in [PlayerDBGSEvent.Def_InitOpenServerTime, PlayerDBGSEvent.Def_SetOpenServerTime]:
|
continue
|
dbgsTrigKeyDict[key] = value
|
for key, value in dbgsTrigKeyDict.items():
|
gsEventTrigManager.DeleteByKey(key)
|
GameWorld.Log("DeleteGameServerEventTrig %s=%s" % (key, value))
|
|
#Çå ÅÅÐаñ
|
for billboardIndex in ShareDefine.BillboardTypeList:
|
billBoard = GameWorld.GetBillboard().FindBillboard(billboardIndex)
|
count = 0 if not billBoard else billBoard.GetCount()
|
if count:
|
PlayerBillboard.ClearBillboardByIndex(billboardIndex)
|
GameWorld.Log("ClearBillboard %s, count=%s" % (billboardIndex, count))
|
|
#Çå ͨÓüǼ
|
universalRecMgr = GameWorld.GetUniversalRecMgr()
|
for recType in ShareDefine.Def_UniversalGameRecTypeList:
|
recordList = universalRecMgr.GetTypeList(recType)
|
recordCount = 0 if not recordList else recordList.Count()
|
universalRecMgr.Delete(recType)
|
if recordCount:
|
GameWorld.Log("DeleteRecData recType=%s, count=%s" % (recType, recordCount))
|
|
#Çå ¼Ò×å
|
familyList = []
|
familyMgr = GameWorld.GetFamilyManager()
|
for i in xrange(familyMgr.GetCount()):
|
familyList.append(familyMgr.GetAt(i))
|
for family in familyList:
|
GameWorld.Log("DeleteFamily familyID=%s" % (family.GetID()))
|
PlayerFamily.DoLogic_DeleteFamily(None, family, tick)
|
|
#ÏÉÃËÁªÈü
|
GameWorldFamilyWar.DoFamilyWarReset()
|
|
PyGameData.g_sortBOSSRefreshList = [] # bossË¢ÐÂÐÅÏ¢¼Ç¼»º´æÖØÖÃ, ²»ÖØÖûᵼÖÂ֪ͨǰ¶ËµÄbossÐÅϢΪ¿Õ
|
|
PlayerDBGSEvent.SetInitOpenServerTime(setOpenServerTime)
|
|
ReadChConfig.ReloadConfig()
|
|
AllMapServerInitOK(tick)
|
return
|
|
## ·þÎñÆ÷¿ª·þʱÊÇÐÇÆÚ¼¸
|
def GetOpenServerWeekday(): return PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_OpenServerWeekday)
|
|
## ËùÓеØͼ·þÎñÆ÷³õʼ»¯³É¹¦ºó(·â°ü×¢²á)
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks µ±Ò»¸ömapServer¿ªÆôʱ£¬
|
def AllMapServerInitOK(tick):
|
#֪ͨËùÓеØͼ·þÎñÆ÷³õʼ»¯³É¹¦, ͬ²½Ê±¼ä
|
GameWorld.GetGameWorld().Notify_AllMapServerInitOK(GameWorld.GetCurrentDataTimeStr())
|
|
#ÉèÖÃÈ«²¿¾Ñ鱶ÂÊ
|
__SetWorldExpRate()
|
__SetWorldDropRateAdd()
|
|
#֪ͨµØͼ·þÎñÆ÷µ±Ç°ÒѾ¼¤»îµÄ»î¶¯
|
__NotifyMapServerEvent()
|
|
#֪ͨ»î¶¯×´Ì¬
|
GameWorldActionControl.SendMapServerOperationActionState()
|
GameWorldActionControl.SendMapServerDailyActionState()
|
GameWorldActionControl.SendMapServerFBFuncState()
|
|
#֪ͨÒѾ·¢²¼µÄÈÎÎñ
|
__NotifyMissionPubEvent()
|
|
#´¥·¢½Ú¼ÙÈջ
|
#GameWorldActionHoliday.ActionHoliday_OpenAndClose(tick, True)
|
|
#֪ͨÊÀ½çµÈ¼¶
|
worldLv = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_WorldAverageLv)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_WorldAverageLv, worldLv)
|
|
# ֪ͨȫ·þ½±Àø
|
#PlayerCanGetReward.SendMapAllPlayerReward()
|
|
# ֪ͨ¿ª·þÌìÊý
|
openServerDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ServerDay)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_ServerDay, openServerDay)
|
openServerWeekday = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_OpenServerWeekday)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_OpenServerWeekday, openServerWeekday)
|
# ºÏ·þ״̬
|
isMixServer = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_IsMixServer)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_IsMixServer, isMixServer)
|
# ºÏ·þÌì
|
mixServerDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_MixServerDay)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_MixServerDay, mixServerDay)
|
# ÉϴκϷþʱµÄ¿ª·þÌìÊý¡¢ÊÀ½çµÈ¼¶
|
lastMixServerDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_LastMixServerDay)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_LastMixServerDay, lastMixServerDay)
|
lastMixServerWorldLV = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_LastMixServerWorldLV)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_LastMixServerWorldLV, lastMixServerWorldLV)
|
|
# ֪ͨսÃËÏà¹Ø»î¶¯¿ªÆô״̬
|
fadState = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_FamilyActivityDayState)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_FamilyActivityDayState, fadState)
|
# ֪ͨ¿ªÆô·þÎñÆ÷ʱ¼ä
|
initGameWorldTime = GameWorld.GetGameWorld().GetDictByKey(ChConfig.Def_WorldKey_IsGameWorldInit)
|
GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_InitGameWorldTime, initGameWorldTime)
|
|
# ֪ͨÊÀ½çboss½±ÀøÐÅÏ¢
|
GameWorldBoss.OnMapServerInitOK()
|
# ֪ͨÊÀ½çµôÂÊÌáÉý
|
#worldDropRateKey = ShareDefine.Def_Notify_WorldKey_WorldDropRateAdd
|
#worldDropRate = GameWorld.GetGameWorld().GetDictByKey(worldDropRateKey)
|
#GameWorld.SendMapServerMsgEx(worldDropRateKey, worldDropRate)
|
|
# ÏÉÃËÁªÈü
|
GameWorldFamilyWar.OnMapServerInitOK()
|
# ÁìµØÕù¶áÕ½
|
#PlayerManorWar.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
|
CrossRealmPK.OnMapServerInitOK()
|
|
SendAllMapGlobalDropInfo() # È«¾ÖµôÂä¿ØÖÆ
|
|
SendMapCommMapLinePlayerCount(True) # ͬ²½Ò»´ÎÆÕͨµØͼÏß·ÈËÊýÐÅÏ¢
|
#Ëæ»ú¼ÙÏÉÃË
|
PlayerFamily.RandomFakeFamily()
|
|
# ¼Ç¼·þÎñÆ÷ÊÇ·ñÕý³£¿ªÆôÍê±Ï
|
getUrl = ReadChConfig.GetPyMongoConfig("EventReport", "OpenStateUrl") + "?Type=MapInit&MapCount=%s"%GameWorld.GetGameWorld().GetGameMapManager().GetCount()
|
GameWorld.GetGameWorld().EventReport_EventReport("", "", "", "", 0, getUrl)
|
return
|
|
## ·þÎñÆ÷ºÏ·þÊ×´ÎÆô¶¯Êý¾Ý¼ÓÔØ´¦Àí
|
# @param None
|
# @return None
|
def __DoMixServerInit():
|
isMixServer = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_IsMixServer)
|
if not isMixServer:
|
GameWorld.DebugLog("·ÇºÏ·þ£¬²»´¦ÀíºÏ·þÊ×´ÎÆô¶¯Êý¾Ý¼ÓÔØ£¡")
|
return
|
|
isMixServerInitOK = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.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)
|
|
# ÏÉÃËÁªÈüÖØÖÃ
|
GameWorldFamilyWar.DoFamilyWarReset()
|
# ÖØÖÃËùÓÐÏÉÃËÁªÈüÆÀ¼¶
|
familyManager = GameWorld.GetFamilyManager()
|
for i in xrange(familyManager.GetCount()):
|
family = familyManager.GetAt(i)
|
PlayerFamily.SetFamilyWarRank(family, 0)
|
PlayerFamily.DoFamilySort()
|
|
# ÉèÖúϷþÊ×´ÎÆô¶¯¼ÓÔسɹ¦
|
PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_IsMixServerInitOK, 1)
|
|
# ÉèÖñ¾´ÎºÏ·þʱµÄ¿ª·þÌìÊý¡¢ÊÀ½çµÈ¼¶
|
serverDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ServerDay)
|
PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_LastMixServerDay, serverDay)
|
worldLV = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_WorldAverageLv)
|
PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_LastMixServerWorldLV, worldLV)
|
GameWorld.Log(" ºÏ·þÊ×´ÎÆô¶¯¼ÓÔسɹ¦! serverDay=%s,worldLV=%s" % (serverDay, worldLV))
|
return
|
|
def __DelOutofdayRecData(universalRecMgr):
|
# ɾ³ý¹ýÆÚµÄͨÓÃÊý¾Ý
|
curTime = int(time.time())
|
delOutofdayRecDataDict = {
|
}
|
GameWorld.Log("Ö´ÐÐɾ³ý¹ýÆÚµÄͨÓÃÊý¾Ý, curTime=%s,delOutofdayRecDataDict=%s" % (curTime, delOutofdayRecDataDict))
|
for otDayRecType, otTime in delOutofdayRecDataDict.items():
|
otRecDataList = universalRecMgr.GetTypeList(otDayRecType)
|
if not otRecDataList:
|
continue
|
delCnt = 0
|
totalCnt = otRecDataList.Count()
|
for index in xrange(totalCnt):
|
delIndex = index - delCnt
|
otRecData = otRecDataList.At(delIndex)
|
if curTime - otRecData.GetTime() >= otTime:
|
otRecDataList.Delete(delIndex)
|
delCnt +=1
|
GameWorld.Log(" ɾ³ý¹ýÆÚÌõÊý: recType=%s,totalCnt=%s,delCnt=%s" % (otDayRecType, totalCnt, delCnt))
|
return
|
|
## ÉèÖÃÈ«²¿¾Ñ鱶ÂÊ£¬ÓÅÏȸù¾Ý»î¶¯¸ÅÂÊ
|
# @param
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def __SetWorldExpRate():
|
eventManager = GameWorld.GetGameWorldEventManager()
|
expRateEvent = eventManager.FindActiveEvent(ChConfig.Def_GY_GM_Game_DoubleExp)
|
|
#ÎÞ¾Ñ鱶ÂÊÉèÖÃ
|
if not expRateEvent:
|
expRate = ChConfig.Def_MaxRateValue
|
#δ¼¤»î
|
elif not expRateEvent.GetIsProcessing():
|
expRate = ChConfig.Def_MaxRateValue
|
else:
|
expRate = int(expRateEvent.GetPar())
|
|
GameWorld.GetGameWorld().SetExpRate(expRate)
|
|
return
|
|
## ÉèÖÃÈ«·þµôÂÊÔö¼Ó¸ÅÂÊ
|
# @param
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def __SetWorldDropRateAdd():
|
eventManager = GameWorld.GetGameWorldEventManager()
|
event = eventManager.FindActiveEvent(ChConfig.Def_GY_GM_Game_DropRate)
|
|
#ÎÞ¾Ñ鱶ÂÊÉèÖÃ
|
if not event:
|
__DisposeWorldDropRateEvent(False)
|
#δ¼¤»î
|
elif not event.GetIsProcessing():
|
__DisposeWorldDropRateEvent(False)
|
else:
|
__DisposeWorldDropRateEvent(True , int(event.GetPar()))
|
return
|
|
## ֪ͨµØͼ·þÎñÆ÷µ±Ç°±£´æµÄ»î¶¯
|
# @param
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def __NotifyMapServerEvent():
|
eventManager = GameWorld.GetGameWorldEventManager()
|
|
for index in range(eventManager.GetActiveEventCount()):
|
event = eventManager.GetActiveEventByIndex(index)
|
#먦ÆôµÄ»î¶¯
|
if not event.GetIsProcessing():
|
continue
|
|
#֪ͨµØͼ·þÎñÆ÷µ±Ç°»î¶¯
|
__NotifyMapServerProcess(event , event.GetEventID() , event.GetPar())
|
|
return
|
|
## µØͼ·þÎñÆ÷Ë¢ÐÂ×Ô¼º×´Ì¬
|
# @param index µØͼË÷Òý
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks ÿ¸ömap ¶¨Ê±Éϱ¨×Ô¼ºµÄmapID£¬lineID£¬curPlayerCnt,maxPlayerCnt ,´æ´¢Èë
|
# GameWorld().GetMapServerStateManager() ¸ñʽÈç mapid 101 , lineid 0, cur 0, max 2000
|
def MapServer_RefreshState(index, tick):
|
pack = IPY_GameServer.IPY_GMapServerState()
|
routeServerIndex = pack.GetRouteServerIndex()
|
mapID = pack.GetMapID()
|
lineID = pack.GetLineID()
|
curPlayerCount = pack.GetCurPlayerCount()
|
maxPlayerCount = pack.GetMaxPlayerCount()
|
#int nRouteServerIndex, int nMapID, int nLineID, int nCurPlayerCnt, int nMaxPlayerCnt
|
GameWorld.GetGameWorld().GetMapServerStateManager().SetZoneServerState(routeServerIndex, mapID, lineID, curPlayerCount, maxPlayerCount)
|
|
PyGameData.g_commMapLineRouteDict[(mapID, lineID)] = routeServerIndex
|
|
#GameWorld.DebugLog("MapServer_RefreshState routeServerIndex=%s,mapID=%s,lineID=%s,curPlayerCount=%s,maxPlayerCount=%s"
|
# % (routeServerIndex, mapID, lineID, curPlayerCount, maxPlayerCount))
|
|
# ÕâÀïÖ»¸üУ¬Í¨ÖªÔÚÆäËûµØ·½´¦Àí
|
linePlayerCountDict = PyGameData.g_commMapLinePlayerCountDict.get(mapID, {})
|
if lineID not in linePlayerCountDict or linePlayerCountDict[lineID] != curPlayerCount:
|
linePlayerCountDict[lineID] = curPlayerCount
|
PyGameData.g_commMapLinePlayerCountDict[mapID] = linePlayerCountDict
|
PyGameData.g_needSyncCommMapLinePlayerCount = True
|
return
|
|
#//////////////////////////////////////////////////////////////
|
#//01 04 ÈÎÎñ·¢²¼#tagGMissionPub
|
#tagGMissionPub * GettagGMissionPub();
|
#
|
#class IPY_GMissionPub
|
#{
|
#public:
|
# //·¢²¼ÈÎÎñID
|
# int GetMissionID();
|
# //·¢²¼ÀàÐÍ(¼Ò×å, ¹ú¼Ò) TMissinoPubType
|
# int GetMissinoPubType();
|
# //·¢²¼ID
|
# int GetPubID();
|
#};
|
|
## ÈÎÎñ·¢²¼±í
|
# @param index µØͼË÷Òý
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def MapServer_MissionPub(index, tick):
|
pack = IPY_GameServer.IPY_GMissionPub()
|
missionPubManager = GameWorld.GetGameWorld().GetDBMissionPubManager()
|
curMissionPub = missionPubManager.AddDBMissionPub(pack.GetMissionID())
|
curMissionPub.SetMissinoPubType(pack.GetMissinoPubType())
|
curMissionPub.SetPubID(pack.GetPubID())
|
curMissionPub.Notify_AllMapServerProcess()
|
return
|
|
## ֪ͨÒѾ·¢²¼µÄÈÎÎñ
|
# @param
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def __NotifyMissionPubEvent():
|
missionPubManager = GameWorld.GetGameWorld().GetDBMissionPubManager()
|
missionPubManager.NotifyAllMapServerMissionPubProcess()
|
return
|
#---------------------------------------------------------------------
|
#//////////////////////////////////////////////////////////////
|
#//04 02 ¼«Æ·µôÂä#tagGTreasureDrop
|
#tagGTreasureDrop * GettagGTreasureDrop();
|
#
|
#class IPY_GTreasureDrop
|
#{
|
#public:
|
#
|
# int GetItemID();
|
#
|
# int GetItemCount();
|
# //µôÂ书ÄÜÀàÐÍ
|
# int GetDropFunctionType();
|
#---------------------------------------------------------------------
|
## ÊÕ°ü£¬µôÂäÎïÆ·
|
# @param index µØͼË÷Òý
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def MapServer_TreasureDrop(index, tick):
|
pack = IPY_GameServer.IPY_GTreasureDrop()
|
itemID = pack.GetItemID()
|
itemCount = pack.GetItemCount()
|
dropFunctionType = pack.GetDropFunctionType()
|
__ProcessFunctionTypeDrop(dropFunctionType, itemID, itemCount)
|
|
if dropFunctionType != IPY_GameServer.dfdAll:
|
#ËùÓеôÂä
|
__ProcessFunctionTypeDrop(IPY_GameServer.dfdAll, itemID, itemCount)
|
|
return
|
|
## ´¦Àí¹¦ÄÜÀàÐ͵ôÂä
|
# @param dropFunctionType µôÂ书ÄÜÀàÐÍ
|
# @param itemID ÎïÆ·ID
|
# @param itemCount ÎïÆ·ÊýÁ¿
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def __ProcessFunctionTypeDrop(dropFunctionType, itemID, itemCount):
|
dropManager = GameWorld.GetGameWorld().GetDBGameWorldDropManager()
|
curDrop = dropManager.FindGameWorldDrop(itemID, dropFunctionType)
|
if curDrop == None:
|
#ÎÞ´ËÀàµôÂä
|
return
|
|
finalCount = curDrop.GetCurrentCount() + itemCount
|
curDrop.SetCurrentCount(finalCount)
|
|
if finalCount >= curDrop.GetDropCount():
|
curDrop.Notify_AllMapServerDropState(0)
|
|
return
|
|
## Çå¿Õ±¦ÎïµôÂä
|
# @param
|
# @return None
|
# @remarks ÿÌìÇå¿ÕÒ»´Î
|
def __ClearTreasureDropCount():
|
#ÿÌìÇå¿Õ±¦ÎïµôÂä
|
dropManager = GameWorld.GetGameWorld().GetDBGameWorldDropManager()
|
for i in range(dropManager.GetCount()):
|
curDrop = dropManager.GetAt(i)
|
curDrop.SetCurrentCount(0)
|
|
dropManager.Notify_AllMapServerClearForbiddenDrop()
|
return
|
|
def SendAllMapGlobalDropInfo():
|
# ͬ²½ËùÓеØͼËùÓÐÈ«·þµôÂä¿ØÖÆÐÅÏ¢
|
globalDropCDDict = IpyGameDataPY.GetFuncEvalCfg("GlobalDropCD", 1) # {ÎïÆ·ID:·ÖÖÓ, ...}
|
globalKilledCountDropDict = IpyGameDataPY.GetFuncEvalCfg("GlobalDropCD", 2) # È«·þ»÷ɱ´ÎÊý±Øµô
|
globalDropRateDict = IpyGameDataPY.GetFuncEvalCfg("NPCGlobalDropRate") # {ÎïÆ·ID:[[npcIDÁбí], "¸ÅÂʹ«Ê½"], ...}
|
|
for itemID in globalDropCDDict.keys():
|
key = ShareDefine.Def_Notify_WorldKey_LastDropTime % itemID
|
dropTime = PlayerDBGSEvent.GetDBGSTrig_ByKey(key)
|
GameWorld.SendMapServerMsgEx(key, dropTime)
|
|
for itemID in globalDropRateDict.keys():
|
key = ShareDefine.Def_Notify_WorldKey_DropNPCKilledCnt % itemID
|
killedCnt = PlayerDBGSEvent.GetDBGSTrig_ByKey(key)
|
GameWorld.SendMapServerMsgEx(key, killedCnt)
|
|
for npcID in globalKilledCountDropDict.keys():
|
key = ShareDefine.Def_Notify_WorldKey_NPCKilledCount % npcID
|
killedCnt = PlayerDBGSEvent.GetDBGSTrig_ByKey(key)
|
GameWorld.SendMapServerMsgEx(key, killedCnt)
|
return
|
|
def UpdGlobalDropCD(msgList):
|
## ¸üÐÂÈ«¾ÖµôÂäCDÎïÆ·×îºóÒ»´ÎµôÂäʱ¼ä
|
itemID, dropTime = msgList
|
key = ShareDefine.Def_Notify_WorldKey_LastDropTime % itemID
|
PlayerDBGSEvent.SetDBGSTrig_ByKey(key, dropTime)
|
GameWorld.SendMapServerMsgEx(key, dropTime)
|
return
|
|
def UpdGlobalDropRate(msgList):
|
## ¸üÐÂÈ«¾Ö»÷ɱ´ÎÊý»»ËãµôÂä¸ÅÂʵÄÎïÆ·ËùÀۼƵĻ÷ɱ´ÎÊý
|
itemID, updKilledCnt = msgList
|
key = ShareDefine.Def_Notify_WorldKey_DropNPCKilledCnt % itemID
|
PlayerDBGSEvent.SetDBGSTrig_ByKey(key, updKilledCnt)
|
GameWorld.SendMapServerMsgEx(key, updKilledCnt)
|
return
|
|
def UpdGlobalKillCount(msgList):
|
## ¸üÐÂÈ«¾Ö»÷ɱ´ÎÊý
|
npcID, updKilledCnt = msgList
|
key = ShareDefine.Def_Notify_WorldKey_NPCKilledCount % npcID
|
PlayerDBGSEvent.SetDBGSTrig_ByKey(key, updKilledCnt)
|
GameWorld.SendMapServerMsgEx(key, updKilledCnt)
|
return
|
|
#---------------------------------------------------------------------
|
#//////////////////////////////////////////////////////////////
|
#//01 05 ×¢²á¸±±¾ÐÅÏ¢#tagGRegisterFBInfo
|
#tagGRegisterFBInfo * GettagGRegisterFBInfo();
|
#
|
#class IPY_GRegisterFBInfo
|
#{
|
#public:
|
#
|
# int GetDataMapID();
|
# //¶Ô¿Í»§¶ËµÄÏßID
|
# int GetClientLineID();
|
# //µ¥Ïß×î´óÍæ¼ÒÊýÄ¿
|
# int GetMaxPlayerCount();
|
#
|
# int GetFbInfoLen();
|
# //size = FbInfoLen
|
# char * GetFbInfo();
|
#};
|
|
|
## ×¢²á¸±±¾ÐÅÏ¢
|
# @param index µØͼË÷Òý
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def MapServer_RegisterFBInfo(index, tick):
|
fbEventMgr = GameWorld.GetGameWorld().GetGameFbEventList()
|
#»ñÈ¡·â°ü²ÎÊý
|
mPack = IPY_GameServer.IPY_GRegisterFBInfo()
|
|
gameFBEvent = fbEventMgr.GetGameFbEvent(mPack.GetLineID(), mPack.GetDataMapID())
|
fbDetail = gameFBEvent.GetGameFbDetail(mPack.GetClientLineID())
|
fbDetail.SetClientLineID(mPack.GetClientLineID())
|
fbDetail.SetMaxPlayerCount(mPack.GetMaxPlayerCount())
|
fbDetail.SetFbInfo(mPack.GetFbInfo())
|
return
|
|
#//////////////////////////////////////////////////////////////
|
#//01 06 ¸±±¾ÐÅϢˢÐÂ#tagGFbInfoRefresh
|
#tagGFbInfoRefresh * GettagGFbInfoRefresh();
|
#
|
#class IPY_GFbInfoRefresh
|
#{
|
#public:
|
#
|
# int GetDataMapID();
|
#
|
# int GetClientLineID();
|
#
|
# int GetPlayerCount();
|
#};
|
|
## ¸±±¾ÐÅϢˢÐÂ
|
# @param index µØͼË÷Òý
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def MapServer_FbInfoRefresh(index, tick):
|
pack = IPY_GameServer.IPY_GFbInfoRefresh()
|
fbEvent = GameWorld.GetGameWorld().GetGameFbEventList()
|
gameFBEvent = fbEvent.FindGameFbEvent(pack.GetLineID(), pack.GetDataMapID())
|
|
if gameFBEvent == None:
|
return
|
|
#2009.5.30
|
#ÐÞ¸Ä: Èç¹û¸±±¾ÐÅϢˢеÄʱºò, ¸±±¾Ã»ÓÐ×¢²áÏêϸÐÅÏ¢, ÄÇô¾Í²»´¦Àí
|
#gameFBEvent = fbEvent.GetGameFbEvent(pack.GetDataMapID())
|
fbDetail = gameFBEvent.GetGameFbDetail(pack.GetClientLineID())
|
fbDetail.SetPlayerCount(pack.GetPlayerCount())
|
return
|
|
#---------------------------------------------------------------------
|
#===============================================================================
|
# //08 07 µØͼ·þÎñÆ÷״̬#tagGMapServerRunningState
|
# tagGMapServerRunningState * GettagGMapServerRunningState();
|
#
|
# class IPY_GMapServerRunningState
|
# {
|
# public:
|
#
|
# // ÔÝʱ¼ÓÔÚ·â°ü
|
# int GetRouteServerIndex();
|
#
|
# int GetMapID();
|
#
|
# int GetState();
|
# };
|
#===============================================================================
|
## ÔËÐÐ״̬ˢÐÂ
|
# @param index µØͼË÷Òý
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks state=3 ÊÇ¿ªÆô 0ÊÇʧȥÁ¬½Ó
|
def MapServer_RunningStateRefresh(index, tick):
|
mapServerPack = IPY_GameServer.IPY_GMapServerRunningState()
|
gameMapManager = GameWorld.GetGameWorld().GetGameMapManager()
|
|
curMap = gameMapManager.Find(mapServerPack.GetRouteServerIndex(), mapServerPack.GetMapID())
|
if curMap == None:
|
return
|
|
if mapServerPack.GetState() not in [0,1,2,3] and curMap.GetState() != mapServerPack.GetState():
|
# ¼Ç¼·þÎñÆ÷ÊÇ·ñÕý³£¿ªÆôÍê±Ï, ±ÜÃâÖظ´·¢ËÍ
|
GameWorld.DebugLog("MapServer_RunningStateRefresh--_%s"%([mapServerPack.GetState(), curMap.GetState(), mapServerPack.GetMapID(), curMap.GetID()]))
|
SendGameError("MapError")
|
|
curMap.SetState(mapServerPack.GetState())
|
curMap.SetRefreshTick(tick)
|
|
return
|
|
|
def SendGameError(state):
|
getUrl = ReadChConfig.GetPyMongoConfig("EventReport", "OpenStateUrl")
|
groupID = ReadChConfig.GetPyMongoConfig("platform", "GroupID")
|
userDBName = ReadChConfig.GetPyMongoConfig("connect", "USER_DB_NAME")
|
getUrl = getUrl + "?Type=%s&groupID=%s&userDBName=%s"%(state, groupID, userDBName)
|
GameWorld.GetGameWorld().EventReport_EventReport("", "", "", "", 0, getUrl)
|
|
## ˢеØͼ·þÎñÆ÷״̬, Èç¹û1·ÖÖÓûÓÐ״̬»Ø±¨, Ë¢ÐÂΪÏûʧ״̬
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks curMap.GetRefreshTick() > 5min Ôò£ºcurMap.SetState£¨Ïûʧ£©
|
def DisposeMapServerRunningState(tick):
|
#¼ä¸ôδµ½
|
if not GameWorld.SetWorldDictKey(ChConfig.TYPE_MapServerRunningState, tick):
|
return
|
|
gameMapManager = GameWorld.GetGameWorld().GetGameMapManager()
|
|
isSendMapClose = False
|
for i in range(0, gameMapManager.GetCount()):
|
curMap = gameMapManager.GetAt(i)
|
|
if curMap.GetState() == IPY_GameServer.mssNone:
|
#µØͼÒѾ»ÒÁË
|
continue
|
|
if tick - curMap.GetRefreshTick() < ChConfig.Def_Tick_MapServer_MssNone:
|
#¼ä¸ôδµ½
|
continue
|
|
curMap.SetState(IPY_GameServer.mssNone)
|
if not isSendMapClose:
|
# ±ÜÃâ¶àµØͼ·¢Ë͹ý¶àÓʼþ, Èç¹Ø·þµÄʱºò
|
SendGameError("MapDisconnect") # ״̬±¨¸æ
|
isSendMapClose = True
|
|
return
|
#---------------------------------------------------------------------
|
#===============================================================================
|
# //01 07 µØͼ·þÎñÆ÷״̬ÐÅÏ¢#tagGMapServerMsg
|
#
|
# struct tagGMapServerMsg
|
# {
|
# tagHead Head;
|
# WORD MsgLen;
|
# char Msg[MsgLen]; //size = MsgLen
|
# };
|
#===============================================================================
|
## µØͼ·þÎñÆ÷״̬ÐÅÏ¢
|
# @param index µØͼË÷Òý
|
# @param tick µ±Ç°Ê±¼ä
|
# @return None
|
# @remarks µØͼ·þÎñÆ÷״̬ÐÅÏ¢.MapServer½Ó¿ÚGameWorld.GetGameWorld().SendGameServerMsg
|
def MapServer_MapServerMsg(index , tick):
|
pack = IPY_GameServer.IPY_GMapServerMsg()
|
msg = pack.GetMsg()
|
|
#MapServer·Ç¸öÈËÇëÇó´¦Àí
|
RunEventFunc(msg)
|
return
|
|
## MapServer·Ç¸öÈËÇëÇó´¦Àí
|
# @param funcName
|
# @return None
|
# @remarks º¯ÊýÏêϸ˵Ã÷.
|
def RunEventFunc(funcName):
|
funcName = "RunEventFunc_" + funcName
|
|
if globals().has_key(funcName):
|
return globals()[funcName]()
|
else:
|
GameWorld.Log("Error : RunEventFunc funcName = %s"%funcName)
|
|
return
|
|
|
## ÓÃÓڹطþ֮ǰPYÒª´¦ÀíµÄÄÚÈÝ£¬×îºóÒ»¶¨ÒªÍ¨ÖªC++¹Ø·þ
|
# @param None
|
# @return None
|
def BeforeClose(tick):
|
PlayerTeam.OnServerClose(tick)
|
ChPlayer.SavePlayerLVData()
|
PlayerFBHelpBattle.OnServerClose()
|
GameWorld.Log("֪ͨC++¹Ø·þ£¡")
|
GameWorld.GetGameWorld().OnServerClose()
|
|
|
def ChangeGameServerState(state):
|
# Ö»½ÓÊÕ´óÓÚµÈÓÚmssPyError
|
GameWorld.DebugLog("ChangeGameServerState:%s"%state)
|
SendGameError("GameServerError")
|
|
|
