From f198885f31c9c7eb19eb28adce562e39e64d581c Mon Sep 17 00:00:00 2001 From: hxp <ale99527@vip.qq.com> Date: 星期五, 18 七月 2025 16:23:11 +0800 Subject: [PATCH] 121 【武将】武将系统-服务端(属性计算、战斗力计算;新角色初始给默认装备、默认阵容武将;) --- ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GameWorldLogic/GameWorldProcess.py | 163 ++++++++++++++++-------------------------------------- 1 files changed, 49 insertions(+), 114 deletions(-) diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GameWorldLogic/GameWorldProcess.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GameWorldLogic/GameWorldProcess.py index d03a9e3..6e04a63 100644 --- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GameWorldLogic/GameWorldProcess.py +++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GameWorldLogic/GameWorldProcess.py @@ -41,16 +41,13 @@ import PlayerControl import FamilyRobBoss import NPCCustomRefresh -import EventShell import FBLogic import FBCommon import EventReport import ItemCommon import PyGameData -import PlayerTeam import GameMap import NPCRealmRefresh -import IpyGameDataPY import GameWorldEvent #--------------------------------------------------------------------- ## 副本开启 @@ -163,7 +160,7 @@ GameWorld.Log("发送未拾取的物品给玩家: %s" % mailItemList, ownerID) if isCrossServer: serverGroupID = playerServerGroupIDDict.get(ownerID, 0) - PlayerControl.SendCrossMail(serverGroupID, "ItemNoPickUp", [ownerID], mailItemList, [gameWorld.GetMapID()]) + # 删除旧版发送邮件,如果功能还有需要,可使用新版本发送邮件 PlayerMail else: PlayerControl.SendMailByKey("ItemNoPickUp", [ownerID], mailItemList, [gameWorld.GetMapID()]) @@ -274,10 +271,7 @@ if playerExistTime < existTime / 2: #这个玩家存在时间过短, 不能触发副本结束的事件 continue - - #副本时间到了, 调用时间到响应 - EventShell.EventResponse_OnFBTimeOut(curPlayer) - + #输出调试信息 GameWorld.Log('__ProcessTimeKickPlayer! LineID = %s, openState = %s'%(gameWorld.GetLineID(), gameWorld.GetOpenState())) @@ -527,6 +521,8 @@ if not gameWorld.GetInitOK() : return + GameWorldEvent.OnHighProcess(tick) + __ProcessOpen(gameWorld, tick) __ProcessTimeKickPlayer(gameWorld, tick) # 处理副本生存周期强关副本 @@ -548,12 +544,6 @@ #通知RouteServer 消息 __ProcessRouteServer(gameWorld, tick) - #每分钟触发 - curTime = GameWorld.GetCurrentTime() - __OnMapMinute(curTime, tick) - __RefreshOnMinute(curTime, tick) - #五分钟触发 - __RefreshOnFiveMinute(tick) #定时检测关闭超时文件 EventReport.OnTimeCloseScribeTxt() @@ -592,10 +582,8 @@ # @return None # @remarks 函数详细说明 每条分线都会触发该函数 def InitGameWorld(tick): - GameWorldEvent.InitGameWorld(tick) gameWorld = GameWorld.GetGameWorld() ItemCommon.InitPyItem() - EventShell.DoReloadRefresh() #处理副本逻辑 FBLogic.OnInit(tick) #初始化地图时钟 @@ -610,13 +598,7 @@ gameWorld.BalanceServer_MapServerInitOK() return -## 初始化共享表(原c++表) -# @param tick 当前时间 -# @return None -def ReadShareData(tick): - from PyMongoDB import PyMongoMain - PyMongoMain.GetUserCtrlDB().OnGetGameData() - return + def GameServer_CommMapServerInitOK(gameWorld): ''' @@ -742,95 +724,48 @@ #--------------------------------------------------------------------- -## 五分钟刷新 -# @param tick -# @return None -def __RefreshOnFiveMinute(tick): - gameWorld = GameWorld.GetGameWorld() - lastTick = gameWorld.GetTickByType(ChConfig.TYPE_Map_Tick_ProcessFiveMinute) - tickInterval = ChConfig.TYPE_Map_Tick_Time[ChConfig.TYPE_Map_Tick_ProcessFiveMinute] - if tick - lastTick < tickInterval: - return - gameWorld.SetTickByType(ChConfig.TYPE_Map_Tick_ProcessFiveMinute, tick) - -# playerManager = GameWorld.GetMapCopyPlayerManager() -# for index in xrange(playerManager.GetPlayerCount()): -# curPlayer = playerManager.GetPlayerByIndex(index) -# if not curPlayer: -# continue + +## 初始化共享表(原c++表) +# @param tick 当前时间 +# @return None +def ReadShareData(tick): + #读取静态表,与数据库无关 不要调用UserCtrlDB + from PyMongoDB.Collections import DataServerGameData + from PyMongoDB.DBCommon import (GlobalFunctions, CommonDefine, error) + from PyMongoDB.Common import (CommFunc, ) + import NetPackCommon + import os + import zlib + sysData = DataServerGameData.sysDBLoadFromFile(DataServerGameData.tagChinNPC, + os.path.join(GlobalFunctions.getServerConfigPath(), + CommonDefine.SYSDB_PATH, + 'tagChinNPC.txt')) + sysData += DataServerGameData.sysDBLoadFromFile(DataServerGameData.tagChinSkill, + os.path.join(GlobalFunctions.getServerConfigPath(), + CommonDefine.SYSDB_PATH, + 'tagChinSkill.txt')) + sysData += DataServerGameData.sysDBLoadFromFile(DataServerGameData.tagChinItem, + os.path.join(GlobalFunctions.getServerConfigPath(), + CommonDefine.SYSDB_PATH, + 'tagChinItem.txt')) + sysData += DataServerGameData.sysDBLoadFromFile(DataServerGameData.tagChinMap, + os.path.join(GlobalFunctions.getServerConfigPath(), + CommonDefine.SYSDB_PATH, + 'tagChinMap.txt')) + + + #压缩 + try: + compressSysData = zlib.compress(sysData, 9) #最大压缩 + + #回发地图 + data = '' + data = CommFunc.WriteBYTE(data, CommonDefine.dgGameData) #1 + data = CommFunc.WriteString(data, len(compressSysData), compressSysData) - return - -## 按分钟刷新 -# @param tick -# @return None -def __RefreshOnMinute(curTime, tick): - gameWorld = GameWorld.GetGameWorld() - lastTick = gameWorld.GetTickByType(ChConfig.TYPE_Map_Tick_ProcessMinute) - tickInterval = ChConfig.TYPE_Map_Tick_Time[ChConfig.TYPE_Map_Tick_ProcessMinute] - if tick - lastTick < tickInterval: - return - gameWorld.SetTickByType(ChConfig.TYPE_Map_Tick_ProcessMinute, tick) - - playerManager = GameWorld.GetMapCopyPlayerManager() - for index in xrange(playerManager.GetPlayerCount()): - curPlayer = playerManager.GetPlayerByIndex(index) - if not curPlayer: - continue - - __ProcessHalfHour(curPlayer, curTime, tick) - return - -def __OnMapMinute(curTime, tick): - ## 地图层级每分钟处理, 每分钟最多只会处理一次, 无视虚拟分线 - if not PyGameData.g_initGameTime: - return - - curMinute = curTime.minute - if curMinute == PyGameData.g_mapLastProcess_Minute: - return - PyGameData.g_mapLastProcess_Minute = curMinute - GameWorldEvent.OnMinute(tick) - - PlayerTeam.OnCheckTeamPlayerDisconnectTimeout(tick) - - __CheckIpyDataRecycle(curTime) - 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 - -## 整半小时触发 <00和30分钟时触发> -# @param curPlayer -# @param curTime 当前时间对象 -# @param tick -# @return None -def __ProcessHalfHour(curPlayer, curTime, tick): - if curTime.minute not in [0, 30]: - return - - EventShell.EventResponse_OnHalfHour(curPlayer) - return + GameWorld.Log('Load game sys data for len = %s - %s ok!'%(len(compressSysData), len(data))) + NetPackCommon.SendPyPackToMapServerSelf(data, len(data)) + except: + msg = error.formatMsg('fatal', error.ERROR_NO_53, 'Compress game sys data failed!error = \n%s'%traceback.format_exc()) + GameWorld.ErrLog(msg) + return \ No newline at end of file -- Gitblit v1.8.0