15 卡牌服务端搭建 1. 增加地图关闭接口 CloseMap，必须调用处理保存后，地图才能关闭 2. 玩家登录流程在PlayerLogin统一处理，...

hch

2025-05-21 278fa30bb771deab0cc22c3390c2581c004de178

 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBDataMgr.py

@@ -15,25 +15,23 @@
#"""Version = 2025-05-09 12:20"""

#-------------------------------------------------------------------------------



import CommFunc

import GameWorld

import PyGameData

import DBEventTrig

import DBPlayerViewCache

import DBBillboard

import DBFamily

import DBMail



import binascii

import time

import zlib

import os



BakRoot = "C:\ServerRealTimeBackup"

BakFileType = ".bak"

BackupCopyMax = 3



#临时变量，之后优化

g_loadErr = False

Map2ServerID = {

                10010:87,

                10090:89,

                }

    

def OnServerStart():

    GameWorld.DebugLog("地图服务器启动")

@@ -43,9 +41,11 @@
def OnServerClose():

    return



def OnMinute(curMinute):

def OnMinute(curTime):

    #curMinute = curTime.minute

    ServerDataBackup()

    DBFamily.OnMinute(curMinute)

    DBFamily.OnMinute()

    DBBillboard.OnMinute()

    return



#------------------------------------------- 备档 ---------------------------------------------------

@@ -65,10 +65,8 @@
def LoadServerDataBackup():

    ## 服务器公共数据备档加载

    global g_loadErr

    mapID = GameWorld.GetMap().GetMapID()

    if mapID not in Map2ServerID:

        return

    serverName = "S%s" % Map2ServerID[mapID]

    serverID = GameWorld.GetGameWorld().GetServerID()

    serverName = "S%s" % serverID

    BakDir = os.path.join(BakRoot, serverName)

    GameWorld.Log("加载备档: %s" % BakDir)

    bakFileList = GetBakFileSortList(BakDir)

@@ -79,13 +77,11 @@
    GameWorld.Log("读取备档: %s" % bakFilePath)

    

    f = open(bakFilePath, 'rb')

    compressed_data = f.read().strip()

    compressed_data = f.read()

    f.close()

    

    try:

        decompressed_data = zlib.decompress(compressed_data)

        bakData = binascii.a2b_hex(decompressed_data)

    except:

    bakData = CommFunc.Decompress(compressed_data)

    if not bakData:

        g_loadErr = True

        raise 

    

@@ -95,14 +91,11 @@
def ServerDataBackup():

    ## 服务器公共数据定时备档，暂时直接存盘

    if g_loadErr:

        GameWorld.ErrLog("加载备档已异常，暂时不在存储备档")

        GameWorld.ErrLog("加载备档已异常，暂时不再存储备档，防止已经错误加载的数据覆盖")

        return

    mapID = GameWorld.GetMap().GetMapID()

    if mapID not in Map2ServerID:

        return

    serverName = "S%s" % Map2ServerID[mapID]

    serverID = GameWorld.GetGameWorld().GetServerID()

    serverName = "S%s" % serverID

    BakDir = os.path.join(BakRoot, serverName)

    BackupCopyMax = 3

    GameWorld.Log("服务器备档: %s" % serverName)

    

    if not os.path.exists(BakDir):

@@ -112,9 +105,13 @@
    bakFilePath = os.path.join(BakDir, "%s_%s%s" % (serverName, curTime, BakFileType))

    bakData = GetSavePyData()

    GameWorld.Log("Bak:%s, len=%s, %s" % (serverName, len(bakData), bakFilePath))

    compressed_data = CommFunc.Compress(bakData)

    if not compressed_data:

        GameWorld.SendGameError("ServerDataBackupError")

        return

    GameWorld.Log("compress len=%s" % len(compressed_data))

    
    try:

        compressed_data = zlib.compress(bakData, 9)    #最大压缩

        GameWorld.Log("compress len=%s" % len(compressed_data))

        fp = open(bakFilePath, "wb")

        fp.write(compressed_data)

        fp.close()

@@ -139,12 +136,7 @@
    pyGameDataMgr = GetDBDataMgr()

    result = pyGameDataMgr.GetSaveData()

    GameWorld.Log("GetSavePyData!! id = %s-%s"%(id(pyGameDataMgr), len(result)))

    result = binascii.b2a_hex(result)

    #GameWorld.DebugLog("GetSavePyData!! result = %s-%s"%(result, len(result)))

    # 字节码在C++转化会发生错误must be string without null bytes, not str，但是可以正常保存，错误会在下次调用便宜接口才会触发

    # 暂时改成字符串返回，暂无解决方案

    return result

#    return str(len(result)) + "|" + result



def LoadPyGameData(gameBuffer, pos):

    pyGameDataMgr = GetDBDataMgr()

@@ -158,19 +150,29 @@


class PyGameDataManager(object):

    def __init__(self):

        self.EventTrigMgr = DBEventTrig.EventTrigMgr()

        self.PlayerViewCacheMgr = DBPlayerViewCache.PlayerViewCacheMgr()

        self.FamilyMgr = DBFamily.FamilyMgr()

        self.MailMgr = DBMail.MailMgr()

        self.BillboardMgr = DBBillboard.BillboardMgr()

        return

    

    def GetSaveData(self):

        buff = ""

        buff += self.EventTrigMgr.GetSaveData()

        buff += self.PlayerViewCacheMgr.GetSaveData()

        buff += self.FamilyMgr.GetSaveData()

        buff += self.MailMgr.GetSaveData()

        buff += self.BillboardMgr.GetSaveData()

        return buff

    

    def LoadGameData(self, gameBuffer, pos):

        pos = self.PlayerViewCacheMgr.LoadPyGameData(gameBuffer, pos, len(gameBuffer))

        pos = self.FamilyMgr.LoadPyGameData(gameBuffer, pos, len(gameBuffer))

        dataslen = len(gameBuffer)

        pos = self.EventTrigMgr.LoadPyGameData(gameBuffer, pos, dataslen)

        pos = self.PlayerViewCacheMgr.LoadPyGameData(gameBuffer, pos, dataslen)

        pos = self.FamilyMgr.LoadPyGameData(gameBuffer, pos, dataslen)

        pos = self.MailMgr.LoadPyGameData(gameBuffer, pos, dataslen)

        pos = self.BillboardMgr.LoadPyGameData(gameBuffer, pos, dataslen)

        return pos

    

def GetDBDataMgr():

@@ -180,6 +182,11 @@
        pyGameDataMgr = PyGameDataManager()

        PyGameData.g_pyGameDataManager = pyGameDataMgr

    return pyGameDataMgr



def GetEventTrigMgr():

    ## 事件值管理器

    dbDataMgr = GetDBDataMgr()

    return dbDataMgr.EventTrigMgr



def GetPlayerViewCacheMgr():

    ## 玩家查看缓存数据管理器

@@ -195,3 +202,13 @@
    ## 家族Action数据管理器

    return GetFamilyMgr().GetFamilyActionMgr()



def GetMailMgr():

    ## 邮件数据管理器

    dbDataMgr = GetDBDataMgr()

    return dbDataMgr.MailMgr



def GetBillboardMgr():

    ## 排行榜数据管理器

    dbDataMgr = GetDBDataMgr()

    return dbDataMgr.BillboardMgr