From 3f0b93755905cef314b40b1800920b352a6c7634 Mon Sep 17 00:00:00 2001
From: hxp <ale99527@vip.qq.com>
Date: 星期三, 21 五月 2025 19:49:13 +0800
Subject: [PATCH] 16 卡牌服务端（优化开关服：公共数据备档、db加载、入库逻辑；删除无用公共数据表；）
---
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/CollectionDefine.py | 15
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GameWorldLogic/GameWorldEvent.py | 57
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/CommFunc.py | 11
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyGameData.py | 4
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/LogicProcess/UserCtrlDB.py | 122 +
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBDataMgr.py | 135 +
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/DataServerPlayerData.py | 3226 ++++++++++++++++++++++++++++++++++++++----------
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/index/GameUser.txt | 332 ----
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBStruct.py | 9
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/ChConfig.py | 1
10 files changed, 2,862 insertions(+), 1,050 deletions(-)
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/ChConfig.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/ChConfig.py
index eaf0090..0e29885 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/ChConfig.py
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/ChConfig.py
@@ -2593,6 +2593,7 @@
#玩家时间的记录格式
TYPE_Time_Format = "%Y-%m-%d %H:%M:%S"
TYPE_Time_Format_Day = "%Y-%m-%d"
+TYPE_Time_Format_YmdHMS = "%Y%m%d%H%M%S"
#---------------------------------------------------------------------
#无限封存时间(10年)
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/CommFunc.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/CommFunc.py
index 0a1b958..7f0f50b 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/CommFunc.py
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/CommFunc.py
@@ -29,6 +29,7 @@
import binascii
import GameWorld
import traceback
+import shutil
import zlib
#---------------------------------------------------------------------
#全局变量
@@ -414,6 +415,16 @@
return data
+def DelFolder(path, makeDir=False):
+ ## 删除文件夹
+ if os.path.exists(path):
+ # 删除整个目录（包括自身）
+ shutil.rmtree(path)
+ if makeDir:
+ # 重新创建空目录（保留原目录名）
+ os.makedirs(path)
+ return
+
#提示除零错误的EVAL
##
# @param 参数
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBDataMgr.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBDataMgr.py
index f5ea998..75e7d11 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBDataMgr.py
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBDataMgr.py
@@ -16,10 +16,13 @@
#-------------------------------------------------------------------------------
import CommFunc
+import DBStruct
+import ChConfig
import GameWorld
import PyGameData
-import DBEventTrig
+import PyMongoMain
import DBPlayerViewCache
+import DBEventTrig
import DBBillboard
import DBFamily
import DBMail
@@ -28,43 +31,56 @@
import os
BakRoot = "C:\ServerRealTimeBackup"
-BakFileType = ".bak"
-BackupCopyMax = 3
+BakFileType = ".rtb"
+BackupCopyMax = 5 # 保留历史备档文件数
+BackupInterval = 30 # 备档频率，分钟，暂定每30分钟
-g_loadErr = False
-
def OnServerStart():
+ ##启动服务器数据处理
GameWorld.DebugLog("地图服务器启动")
- LoadServerDataBackup()
+ if not LoadGameWorldDataFromBackup():
+ LoadGameWorldDataFromDB()
return
def OnServerClose():
+ ##关服服务器数据处理
+ SaveGameWorldDataToDB()
return
def OnMinute(curTime):
- #curMinute = curTime.minute
- ServerDataBackup()
+ if PyGameData.g_serverClosing:
+ return
DBFamily.OnMinute()
DBBillboard.OnMinute()
+
+ #备档、入库放最后，等数据都处理完后再保存，每天 [[时,分], ...]，尽量岔开整点、5分
+ if [curTime.hour, curTime.minute] in [[3, 6]]:
+ BackupGameWorldData(True)
+ else:
+ BackupGameWorldData(False)
return
#------------------------------------------- 备档 ---------------------------------------------------
def GetBakFileSortList(bakPath):
- ## 按备档时间倒序排序返回 [[bakTime, filePath], ...]
+ ## 按备档时间倒序排序返回 [[bakTime, 数据版本号, filePath], ...]
bakFileList = []
for parent, _, filenames in os.walk(bakPath):
for filename in filenames:
if not filename.endswith(BakFileType):
continue
fullPath = os.path.join(parent, filename)
- bakTime = GameWorld.ToIntDef(filename[:filename.index(".")].split("_")[1])
- bakFileList.append([bakTime, fullPath])
+ bakInfo = filename[:filename.index(".")].split("_")
+ if len(bakInfo) != 3:
+ continue
+ dataVersionNO = GameWorld.ToIntDef(bakInfo[1]) # 数据版本号
+ bakTime = GameWorld.ToIntDef(bakInfo[2]) # yyyyMMddhhmmss
+ bakFileList.append([bakTime, dataVersionNO, fullPath])
bakFileList.sort(reverse=True)
return bakFileList
-def LoadServerDataBackup():
- ## 服务器公共数据备档加载
- global g_loadErr
+def LoadGameWorldDataFromBackup():
+ ## 备档加载服务器公共数据
+ # @return: 是否存在备档成功加载
serverID = GameWorld.GetGameWorld().GetServerID()
serverName = "S%s" % serverID
BakDir = os.path.join(BakRoot, serverName)
@@ -73,26 +89,42 @@
if not bakFileList:
GameWorld.Log("不存在备档!")
return
- bakFilePath = bakFileList[0][1] # 取第一个为最近的一次备档
+ finalBakInfo = bakFileList[0] # 排序后的第一个为最新备档数据
+ bakVersionNO = finalBakInfo[1]
+ bakFilePath = finalBakInfo[2]
+ if bakVersionNO != DBStruct.GAMEWORLD_DATA_VERSION_NO:
+ GameWorld.ErrLog("备档数据版本号校验失败，请使用正确版本服务器启动重新导入数据! bakVersionNO=%s, GAMEWORLD_DATA_VERSION_NO=%s"
+ % (bakVersionNO, DBStruct.GAMEWORLD_DATA_VERSION_NO))
+ raise
+
GameWorld.Log("读取备档: %s" % bakFilePath)
f = open(bakFilePath, 'rb')
compressed_data = f.read()
f.close()
- bakData = CommFunc.Decompress(compressed_data)
- if not bakData:
- g_loadErr = True
- raise
+ saveData = CommFunc.Decompress(compressed_data)
+ if not saveData:
+ raise
- LoadPyGameData(bakData, 0)
- return
+ LoadPyGameData(saveData, 0)
+ SaveGameWorldDataToDB(saveData) # 如果是从备档读取的则直接入库
+ return True
-def ServerDataBackup():
+def BackupGameWorldData(saveToDB=False):
## 服务器公共数据定时备档，暂时直接存盘
- if g_loadErr:
- GameWorld.ErrLog("加载备档已异常，暂时不再存储备档，防止已经错误加载的数据覆盖")
+ # @param saveToDB: 是否附带入库，为确保备档数据存在时一定优于db库数据，故常规入库时必须附带先备档一次
+ if PyGameData.g_serverClosing:
return
+ if not PyGameData.g_loadDataOK:
+ GameWorld.Log("加载数据未完成，不存储备档")
+ return
+ curTime = int(time.time())
+ if saveToDB:
+ if curTime - PyGameData.g_lastRTBTime < BackupInterval * 60:
+ GameWorld.Log("备档冷却中!")
+ return
+
serverID = GameWorld.GetGameWorld().GetServerID()
serverName = "S%s" % serverID
BakDir = os.path.join(BakRoot, serverName)
@@ -101,11 +133,12 @@
if not os.path.exists(BakDir):
os.makedirs(BakDir)
- curTime = int(time.time())
- 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)
+ dataVersionNO = DBStruct.GAMEWORLD_DATA_VERSION_NO
+ bakTiemStr = GameWorld.ChangeTimeNumToStr(curTime, ChConfig.TYPE_Time_Format_YmdHMS)
+ bakFilePath = os.path.join(BakDir, "%s_%s_%s%s" % (serverName, dataVersionNO, bakTiemStr, BakFileType))
+ saveData = GetSavePyData()
+ GameWorld.Log("Bak:%s, len=%s, %s" % (serverName, len(saveData), bakFilePath))
+ compressed_data = CommFunc.Compress(saveData) # 备档数据才进行压缩
if not compressed_data:
GameWorld.SendGameError("ServerDataBackupError")
return
@@ -118,15 +151,42 @@
except:
return
+ PyGameData.g_lastRTBTime = curTime
bakFileList = GetBakFileSortList(BakDir)
# 删除多余备档
- for _, filePath in bakFileList[BackupCopyMax:]:
+ for bakInfo in bakFileList[BackupCopyMax:]:
+ filePath = bakInfo[-1]
os.remove(filePath)
GameWorld.Log("删除多余备档文件: %s" % filePath)
+ if saveToDB:
+ SaveGameWorldDataToDB(saveData)
+ return
+
+def ClearBackupFile():
+ ## 清空备档文件
+ serverID = GameWorld.GetGameWorld().GetServerID()
+ serverName = "S%s" % serverID
+ BakDir = os.path.join(BakRoot, serverName)
+ GameWorld.Log("清空备档: %s" % BakDir)
+ CommFunc.DelFolder(BakDir, True)
return
#--------------------------------------------------------------------------------------------------
+
+def LoadGameWorldDataFromDB():
+ ## 直接从db读取公共数据
+ GameWorld.Log("没有备档数据，直接从db加载数据!")
+ serverData = PyMongoMain.GetUserCtrlDB().readGameWorldData()
+ LoadPyGameData(serverData, 0)
+ return
+
+def SaveGameWorldDataToDB(saveData=""):
+ ## 公共数据入库
+ if not saveData:
+ saveData = GetSavePyData()
+ PyMongoMain.GetUserCtrlDB().saveGameWorldData(saveData)
+ return
def GetSavePyData():
@@ -146,33 +206,36 @@
#加载数据后，一些功能转化为功能业务数据
#...
+
+ #放最后
+ PyGameData.g_loadDataOK = True
return pos
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()
+ self.MailMgr = DBMail.MailMgr()
+ self.FamilyMgr = DBFamily.FamilyMgr()
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()
+ buff += self.MailMgr.GetSaveData()
+ buff += self.FamilyMgr.GetSaveData()
return buff
def LoadGameData(self, gameBuffer, pos):
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)
+ pos = self.MailMgr.LoadPyGameData(gameBuffer, pos, dataslen)
+ pos = self.FamilyMgr.LoadPyGameData(gameBuffer, pos, dataslen)
return pos
def GetDBDataMgr():
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBStruct.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBStruct.py
index 5f67798..8353749 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBStruct.py
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/DBStruct.py
@@ -10,6 +10,7 @@
# @version 1.0
#
# 详细描述: CodeMaker PyGameServerSaveData.py生成
+# 注： 修改表结构、增删表时需同步修改 GAMEWORLD_DATA_VERSION_NO
#
#-------------------------------------------------------------------------------
#"""Version = 2025-05-09 12:20"""
@@ -1897,3 +1898,11 @@
else:
self.Name2 = Str[:65]
+
+#服务器世界数据表版本号
+GAMEWORLD_DATA_VERSION_NO = ctypes.c_ulong (\
+ sizeof(tagDBEventTrig) + sizeof(tagDBFamily) + sizeof(tagDBFamilyMem) + sizeof(tagDBFamilyAction) +
+ sizeof(tagDBPlayerViewCache) + sizeof(tagDBMailPersonal) + sizeof(tagDBMailServer) + sizeof(tagDBMailItem) +
+ sizeof(tagDBMailPlayerRec) + sizeof(tagDBBillboard)
+ ).value
+
\ No newline at end of file
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GameWorldLogic/GameWorldEvent.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GameWorldLogic/GameWorldEvent.py
index 318d0f4..ed0e8f0 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GameWorldLogic/GameWorldEvent.py
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GameWorldLogic/GameWorldEvent.py
@@ -18,11 +18,13 @@
import DBDataMgr
import GameWorld
import IpyGameDataPY
+import IPY_GameWorld
import PlayerEventCounter
+import PlayerControl
+import NetPackCommon
import ShareDefine
import PlayerTeam
import PyGameData
-import NetPackCommon
import datetime
import time
@@ -231,6 +233,11 @@
if tick - PyGameData.g_highProcessTick < 1000:
return
PyGameData.g_highProcessTick = tick
+
+ if PyGameData.g_serverClosing:
+ CheckCloseMapOK()
+ return
+
OnMinute(tick)
# 其他逻辑
@@ -367,15 +374,43 @@
# 关闭地图通知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
- #初始化数据库, 恢复备档（按区服记录）， 加载静态表
- try:
- pass
- finally:
- #回发地图 处理完成,必须被调用地图才能正常关闭
- data = ''
- data = CommFunc.WriteBYTE(data, CommonDefine.dgPlayerSaveGameServerData)
- NetPackCommon.SendPyPackToMapServerSelf(data, len(data))
- GameWorld.Log("python 已处理地图关闭逻辑")
- return
\ No newline at end of file
+ data = ''
+ data = CommFunc.WriteBYTE(data, CommonDefine.dgPlayerSaveGameServerData)
+ NetPackCommon.SendPyPackToMapServerSelf(data, len(data))
+ GameWorld.Log("python 已处理地图关闭逻辑")
+ PyGameData.g_serverClosing = 2
+ return
+
\ No newline at end of file
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyGameData.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyGameData.py
index 3754746..8eed522 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyGameData.py
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyGameData.py
@@ -15,10 +15,14 @@
#"""Version = 2017-09-05 21:30"""
#-------------------------------------------------------------------------------
+g_loadDataOK = False # 是否成功加载数据，备档、db数据
+g_lastRTBTime = 0 # 上一次备档时间戳
g_initGameTime = 0 # 开始初始化服务器时间戳
g_serverInitOK = False # 服务器是否启动成功
g_highProcessTick = 0 # 每秒触发一次，上次Tick
g_minuteProcess = -1 # 每分钟触发一次，上次处理的分钟
+g_serverClosing = 0 # 是否关服中 0-非关服中；1-关服中；2-关服结束
+g_closeSaveDataOK = False # 关服数据入库是否成功
g_pyGameDataManager = None
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/CollectionDefine.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/CollectionDefine.py
index 423207d..886a20c 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/CollectionDefine.py
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/CollectionDefine.py
@@ -4,6 +4,19 @@
#
#-------------------------------------------------------------------------------
#
+#卡牌服务器表
+UCN_DBFamilyAction="tagDBFamilyAction"
+UCN_DBFamilyMem="tagDBFamilyMem"
+UCN_DBFamily="tagDBFamily"
+UCN_DBMailItem="tagDBMailItem"
+UCN_DBMailPersonal="tagDBMailPersonal"
+UCN_DBMailPlayerRec="tagDBMailPlayerRec"
+UCN_DBMailServer="tagDBMailServer"
+UCN_DBBillboard="tagDBBillboard"
+UCN_DBPlayerViewCache="tagDBPlayerViewCache"
+UCN_DBEventTrig="tagDBEventTrig"
+
+#MMO旧表
UCN_DBPlayerPackData="tagDBPlayerPackData"
UCN_DBGameRec="tagDBGameRec"
UCN_DBPyFuncTeam="tagDBPyFuncTeam"
@@ -45,7 +58,6 @@
UCN_BattleFormation="tagBattleFormation"
UCN_AccCoins="tagAccCoins"
UCN_AccIDSendPrize="tagAccIDSendPrize"
-UCN_DBBillboard="tagDBBillboard"
UCN_DBCountryFamilyWarRace="tagDBCountryFamilyWarRace"
UCN_DBCountryFamilyWarRequest="tagDBCountryFamilyWarRequest"
UCN_DBCountryFamilyWarResult="tagDBCountryFamilyWarResult"
@@ -87,7 +99,6 @@
UCN_DBPlayer="tagDBPlayer"
UCN_DSAccount="tagDSAccount"
UCN_RoleItem="tagRoleItem"
-UCN_DBFamilyAction="tagDBFamilyAction"
UCN_GameFBPassRec="tagGameFBPassRec"
UCN_UniversalGameRec="tagUniversalGameRec"
UCN_DBNewGuyCardState="tagDBNewGuyCardState"
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/DataServerPlayerData.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/DataServerPlayerData.py
index 5ada8ed..75fc0a3 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/DataServerPlayerData.py
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/Collections/DataServerPlayerData.py
@@ -5369,415 +5369,6 @@
#------------------------------------------------------
-#排行榜#tagDBBillboard
-class tagDBBillboard(Structure):
- _pack_ = 1
- _fields_ = [
- ('Type', ctypes.c_ubyte),
- ('ID', ctypes.c_ulong),
- ('ID2', ctypes.c_ulong),
- ('Name1', ctypes.c_char * 33),
- ('Name2', ctypes.c_char * 65),
- ('Type2', ctypes.c_ubyte),
- ('Value1', ctypes.c_ulong),
- ('Value2', ctypes.c_ulong),
- ('Value3', ctypes.c_ulong),
- ('Value4', ctypes.c_ulong),
- ('Value5', ctypes.c_ulong),
- ('Value6', ctypes.c_ulong),
- ('Value7', ctypes.c_ulong),
- ('Value8', ctypes.c_ulong),
- ('CmpValue', ctypes.c_ulong),
- ('CmpValue2', ctypes.c_ulong),
- ('CmpValue3', ctypes.c_ulong),
- ('DataLen', ctypes.c_ushort),
- ('UserData', ctypes.c_char_p),
- ('ADOResult', ctypes.c_ulong),
- ]
-
- def __init__(self):
- Structure.__init__(self)
- self.clear()
-
- def clear(self):
- self.Type = 0
- self.ID = 0
- self.ID2 = 0
- self.Name1 = ''
- self.Name2 = ''
- self.Type2 = 0
- self.Value1 = 0
- self.Value2 = 0
- self.Value3 = 0
- self.Value4 = 0
- self.Value5 = 0
- self.Value6 = 0
- self.Value7 = 0
- self.Value8 = 0
- self.CmpValue = 0
- self.CmpValue2 = 0
- self.CmpValue3 = 0
- self.DataLen = 0
- self.UserData = ''
-
- def readData(self, buf, pos = 0, length = 0):
- if not pos <= length:
- msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
- mylog.error(msg)
- return -1
- if len(buf) < pos + self.getLength():
- msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
- mylog.error(msg)
- self.clear()
- self.Type, pos = CommFunc.ReadBYTE(buf, pos)
- self.ID, pos = CommFunc.ReadDWORD(buf, pos)
- self.ID2, pos = CommFunc.ReadDWORD(buf, pos)
- self.Name1, pos = CommFunc.ReadString(buf, pos, 33)
- self.Name2, pos = CommFunc.ReadString(buf, pos, 65)
- self.Type2, pos = CommFunc.ReadBYTE(buf, pos)
- self.Value1, pos = CommFunc.ReadDWORD(buf, pos)
- self.Value2, pos = CommFunc.ReadDWORD(buf, pos)
- self.Value3, pos = CommFunc.ReadDWORD(buf, pos)
- self.Value4, pos = CommFunc.ReadDWORD(buf, pos)
- self.Value5, pos = CommFunc.ReadDWORD(buf, pos)
- self.Value6, pos = CommFunc.ReadDWORD(buf, pos)
- self.Value7, pos = CommFunc.ReadDWORD(buf, pos)
- self.Value8, pos = CommFunc.ReadDWORD(buf, pos)
- self.CmpValue, pos = CommFunc.ReadDWORD(buf, pos)
- self.CmpValue2, pos = CommFunc.ReadDWORD(buf, pos)
- self.CmpValue3, pos = CommFunc.ReadDWORD(buf, pos)
- self.DataLen, pos = CommFunc.ReadWORD(buf, pos)
- tmp, pos = CommFunc.ReadString(buf, pos, self.DataLen)
- self.UserData = ctypes.c_char_p(tmp)
- return self.getLength()
-
- def getBuffer(self):
- buf = ''
- buf = CommFunc.WriteBYTE(buf, self.Type)
- buf = CommFunc.WriteDWORD(buf, self.ID)
- buf = CommFunc.WriteDWORD(buf, self.ID2)
- buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.Name1)
- buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 65, self.Name2)
- buf = CommFunc.WriteBYTE(buf, self.Type2)
- buf = CommFunc.WriteDWORD(buf, self.Value1)
- buf = CommFunc.WriteDWORD(buf, self.Value2)
- buf = CommFunc.WriteDWORD(buf, self.Value3)
- buf = CommFunc.WriteDWORD(buf, self.Value4)
- buf = CommFunc.WriteDWORD(buf, self.Value5)
- buf = CommFunc.WriteDWORD(buf, self.Value6)
- buf = CommFunc.WriteDWORD(buf, self.Value7)
- buf = CommFunc.WriteDWORD(buf, self.Value8)
- buf = CommFunc.WriteDWORD(buf, self.CmpValue)
- buf = CommFunc.WriteDWORD(buf, self.CmpValue2)
- buf = CommFunc.WriteDWORD(buf, self.CmpValue3)
- buf = CommFunc.WriteWORD(buf, self.DataLen)
- buf = CommFunc.WriteString(buf, self.DataLen, self.UserData)
- return buf
-
- def getLength(self):
- length = 0
- length += sizeof(ctypes.c_ubyte)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_char) * 33
- length += sizeof(ctypes.c_char) * 65
- length += sizeof(ctypes.c_ubyte)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ushort)
- length += self.DataLen
- return length
-
- def getRecord(self):
- '''组织存储记录'''
- rec = {}
- rec[u'Type'] = self.Type
- rec[u'ID'] = self.ID
- rec[u'ID2'] = self.ID2
- rec[u'Name1'] = fix_incomingText(self.Name1)
- rec[u'Name2'] = fix_incomingText(self.Name2)
- rec[u'Type2'] = self.Type2
- rec[u'Value1'] = self.Value1
- rec[u'Value2'] = self.Value2
- rec[u'Value3'] = self.Value3
- rec[u'Value4'] = self.Value4
- rec[u'Value5'] = self.Value5
- rec[u'Value6'] = self.Value6
- rec[u'Value7'] = self.Value7
- rec[u'Value8'] = self.Value8
- rec[u'CmpValue'] = self.CmpValue
- rec[u'CmpValue2'] = self.CmpValue2
- rec[u'CmpValue3'] = self.CmpValue3
- rec[u'DataLen'] = self.DataLen
- rec[u'UserData'] = fix_incomingText(self.UserData)
- return rec
-
- def readRecord(self, rec):
- '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
- self.Type = rec.get(u'Type', 0)
- self.ID = rec.get(u'ID', 0)
- self.ID2 = rec.get(u'ID2', 0)
- self.Name1 = fix_outgoingText(rec.get(u'Name1', u''))
- self.Name2 = fix_outgoingText(rec.get(u'Name2', u''))
- self.Type2 = rec.get(u'Type2', 0)
- self.Value1 = rec.get(u'Value1', 0)
- self.Value2 = rec.get(u'Value2', 0)
- self.Value3 = rec.get(u'Value3', 0)
- self.Value4 = rec.get(u'Value4', 0)
- self.Value5 = rec.get(u'Value5', 0)
- self.Value6 = rec.get(u'Value6', 0)
- self.Value7 = rec.get(u'Value7', 0)
- self.Value8 = rec.get(u'Value8', 0)
- self.CmpValue = rec.get(u'CmpValue', 0)
- self.CmpValue2 = rec.get(u'CmpValue2', 0)
- self.CmpValue3 = rec.get(u'CmpValue3', 0)
- self.DataLen = rec.get(u'DataLen', 0)
- self.UserData = fix_outgoingText(rec.get(u'UserData', u''))
-
- def adoLoad(self, collection):
- '''使用KEY查找并读取'''
- resultCollection = collection.find({'Type':self.Type,'ID':self.ID,})
-
- if resultCollection.count() <= 0:
- return False
- #由于是KEY查找，所有如果存在就只有一条记录
- rec = resultCollection[0]
- #读取数据
- self.readRecord(rec)
- return True
-
-
- def adoInsert(self, collection):
- '''执行插入'''
-
- trycnt = 0
- rec = self.getRecord()
- while(True):
- try:
- collection.insert(rec, False, True)
- break
- except pymongo.errors.OperationFailure, err:
-
- if(DBConfig.TryCntOnWriteFail > trycnt):
- trycnt += 1
- continue
-
- addADOExceptionCount()
- mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
- msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!Type = %s, error = %s, trycnt = %d'%(self.Type, err, trycnt))
- mylog.error(msg)
-
- return False
- return True
-
-
- def adoUpdate(self, collection):
- '''执行更新'''
- trycnt = 0
- rec = self.getRecord()
- while(True):
- try:
- collection.update({'Type':self.Type,'ID':self.ID,}, {'$set':rec}, False, False, True, True)
- break
- except pymongo.errors.OperationFailure, err:
- if(DBConfig.TryCntOnWriteFail > trycnt):
- trycnt += 1
- continue
-
- addADOExceptionCount()
- mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
- msg = error.formatMsg('error', error.ERROR_NO_153, 'Update failed!Type = %s, error = %s, trycnt = %d'%(self.Type, err, trycnt))
- mylog.error(msg)
-
- return False
- return True
-
-
- def adoUpdateEx(self, collection, spec):
- '''执行更新'''
- trycnt = 0
- rec = self.getRecord()
- while(True):
- try:
- collection.update(spec, {'$set':rec}, False, False, True, True)
- break
- except pymongo.errors.OperationFailure, err:
- if(DBConfig.TryCntOnWriteFail > trycnt):
- trycnt += 1
- continue
- addADOExceptionCount()
- mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
- msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!Type = %s, error = %s, trycnt = %d'%(self.Type, err, trycnt))
- mylog.error(msg)
-
- return False
- return True
-
-
- def adoCheckUpdate(self, collection):
- '''根据情况执行插入或更新'''
- resultCollection = collection.find({'Type':self.Type,'ID':self.ID,})
-
- if resultCollection.count() <= 0:
- return self.adoInsert(collection)
- return self.adoUpdate(collection)
-
-
- def adoCheckUpdateEx(self, collection, spec):
- '''根据情况执行插入或更新'''
- resultCollection = collection.find(spec)
-
- if resultCollection.count() <= 0:
- return self.adoInsert(collection)
- return self.adoUpdateEx(collection, spec)
-
-
- def getAdoRecords(self, resultCollection):
- '''查询结果打包成二进制流'''
- result = ''
- result = CommFunc.WriteDWORD(result, resultCollection.count())
- for rec in resultCollection:
- self.readRecord(rec)
- result += self.getBuffer()
- return result
-
-
- def adoQueryIndex(self, collection):
- '''用索引字段查找'''
- resultCollection = collection.find({'Type':self.Type})
-
- return self.getAdoRecords(resultCollection)
-
-
- def adoQueryCustom(self, collection, queryDict):
- '''自定义查询'''
- resultCollection = collection.find(queryDict)
-
- return self.getAdoRecords(resultCollection)
-
-
- def adoQueryAll(self, collection):
- '''查询所有'''
- resultCollection = collection.find()
-
- return self.getAdoRecords(resultCollection)
-
-
- def adoDeleteByIndex(self, collection):
- '''根据索引删除'''
- trycnt = 0
- while(True):
- try:
- collection.remove({'Type':self.Type})
- break
- except pymongo.errors.OperationFailure, err:
- if(DBConfig.TryCntOnWriteFail > trycnt):
- trycnt += 1
- continue
- addADOExceptionCount()
- mylog.info("%s.%s:Type = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.Type))
- msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.Type = %s, error = %s, trycnt = %d'%(self.Type, err, trycnt))
- mylog.error(msg)
-
- return False
- return True
-
- def outputString(self):
- output = '''//排行榜#tagDBBillboard:
- Type = %s,
- ID = %s,
- ID2 = %s,
- Name1 = %s,
- Name2 = %s,
- Type2 = %s,
- Value1 = %s,
- Value2 = %s,
- Value3 = %s,
- Value4 = %s,
- Value5 = %s,
- Value6 = %s,
- Value7 = %s,
- Value8 = %s,
- CmpValue = %s,
- CmpValue2 = %s,
- CmpValue3 = %s,
- DataLen = %s,
- UserData = %s,
- ADOResult = %s,
- '''%(
- self.Type,
- self.ID,
- self.ID2,
- self.Name1,
- self.Name2,
- self.Type2,
- self.Value1,
- self.Value2,
- self.Value3,
- self.Value4,
- self.Value5,
- self.Value6,
- self.Value7,
- self.Value8,
- self.CmpValue,
- self.CmpValue2,
- self.CmpValue3,
- self.DataLen,
- self.UserData,
- self.ADOResult,
- )
- return output
-
- def dumpString(self):
- output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
- self.Type,
- self.ID,
- self.ID2,
- self.Name1,
- self.Name2,
- self.Type2,
- self.Value1,
- self.Value2,
- self.Value3,
- self.Value4,
- self.Value5,
- self.Value6,
- self.Value7,
- self.Value8,
- self.CmpValue,
- self.CmpValue2,
- self.CmpValue3,
- self.DataLen,
- self.UserData,
- )
- return output
-
- #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
- def SetName1(self,Str):
- if len(Str)<=33:
- self.Name1 = Str
- else:
- self.Name1 = Str[:33]
-
- def SetName2(self,Str):
- if len(Str)<=65:
- self.Name2 = Str
- else:
- self.Name2 = Str[:65]
-
-
-
-
-#------------------------------------------------------
#国家家族战排位赛表#tagDBCountryFamilyWarRace
class tagDBCountryFamilyWarRace(Structure):
_pack_ = 1
@@ -6676,288 +6267,7 @@
else:
self.KingName = Str[:33]
-#------------------------------------------------------
-#家族行为表#tagDBFamilyAction
-class tagDBFamilyAction(Structure):
- _pack_ = 1
- _fields_ = [
- ('FamilyID', ctypes.c_ulong),
- ('ActionType', ctypes.c_ubyte),
- ('Name', ctypes.c_char * 33),
- ('Time', ctypes.c_double),
- ('Value1', ctypes.c_ulong),
- ('Value2', ctypes.c_ulong),
- ('Value3', ctypes.c_ulong),
- ('Value4', ctypes.c_ulong),
- ('Value5', ctypes.c_ulong),
- ('Value6', ctypes.c_ulong),
- ('DataLen', ctypes.c_ushort),
- ('Data', ctypes.c_char_p),
- ('ADOResult', ctypes.c_ulong),
- ]
- def __init__(self):
- Structure.__init__(self)
- self.clear()
-
- def clear(self):
- self.FamilyID = 0
- self.ActionType = 0
- self.Name = ''
- self.Time = 0.0
- self.Value1 = 0
- self.Value2 = 0
- self.Value3 = 0
- self.Value4 = 0
- self.Value5 = 0
- self.Value6 = 0
- self.DataLen = 0
- self.Data = ''
-
- def readData(self, buf, pos = 0, length = 0):
- if not pos <= length:
- msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
- mylog.error(msg)
- return -1
- if len(buf) < pos + self.getLength():
- msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
- mylog.error(msg)
- self.clear()
- self.FamilyID, pos = CommFunc.ReadDWORD(buf, pos)
- self.ActionType, pos = CommFunc.ReadBYTE(buf, pos)
- self.Name, pos = CommFunc.ReadString(buf, pos, 33)
- self.Time, pos = CommFunc.ReadDouble(buf, pos)
- self.Value1, pos = CommFunc.ReadDWORD(buf, pos)
- self.Value2, pos = CommFunc.ReadDWORD(buf, pos)
- self.Value3, pos = CommFunc.ReadDWORD(buf, pos)
- self.Value4, pos = CommFunc.ReadDWORD(buf, pos)
- self.Value5, pos = CommFunc.ReadDWORD(buf, pos)
- self.Value6, pos = CommFunc.ReadDWORD(buf, pos)
- self.DataLen, pos = CommFunc.ReadWORD(buf, pos)
- tmp, pos = CommFunc.ReadString(buf, pos, self.DataLen)
- self.Data = ctypes.c_char_p(tmp)
- return self.getLength()
-
- def getBuffer(self):
- buf = ''
- buf = CommFunc.WriteDWORD(buf, self.FamilyID)
- buf = CommFunc.WriteBYTE(buf, self.ActionType)
- buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.Name)
- buf = CommFunc.WriteDouble(buf, self.Time)
- buf = CommFunc.WriteDWORD(buf, self.Value1)
- buf = CommFunc.WriteDWORD(buf, self.Value2)
- buf = CommFunc.WriteDWORD(buf, self.Value3)
- buf = CommFunc.WriteDWORD(buf, self.Value4)
- buf = CommFunc.WriteDWORD(buf, self.Value5)
- buf = CommFunc.WriteDWORD(buf, self.Value6)
- buf = CommFunc.WriteWORD(buf, self.DataLen)
- buf = CommFunc.WriteString(buf, self.DataLen, self.Data)
- return buf
-
- def getLength(self):
- length = 0
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ubyte)
- length += sizeof(ctypes.c_char) * 33
- length += sizeof(ctypes.c_double)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ulong)
- length += sizeof(ctypes.c_ushort)
- length += self.DataLen
- return length
-
- def getRecord(self):
- '''组织存储记录'''
- rec = {}
- rec[u'FamilyID'] = self.FamilyID
- rec[u'ActionType'] = self.ActionType
- rec[u'Name'] = fix_incomingText(self.Name)
- rec[u'Time'] = self.Time
- rec[u'Value1'] = self.Value1
- rec[u'Value2'] = self.Value2
- rec[u'Value3'] = self.Value3
- rec[u'Value4'] = self.Value4
- rec[u'Value5'] = self.Value5
- rec[u'Value6'] = self.Value6
- rec[u'DataLen'] = self.DataLen
- rec[u'Data'] = fix_incomingText(self.Data)
- return rec
-
- def readRecord(self, rec):
- '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
- self.FamilyID = rec.get(u'FamilyID', 0)
- self.ActionType = rec.get(u'ActionType', 0)
- self.Name = fix_outgoingText(rec.get(u'Name', u''))
- self.Time = rec.get(u'Time', 0)
- self.Value1 = rec.get(u'Value1', 0)
- self.Value2 = rec.get(u'Value2', 0)
- self.Value3 = rec.get(u'Value3', 0)
- self.Value4 = rec.get(u'Value4', 0)
- self.Value5 = rec.get(u'Value5', 0)
- self.Value6 = rec.get(u'Value6', 0)
- self.DataLen = rec.get(u'DataLen', 0)
- self.Data = fix_outgoingText(rec.get(u'Data', u''))
-
-#Can not implement adoLoadStr method:No key defined!
-
- def adoInsert(self, collection):
- '''执行插入'''
-
- trycnt = 0
- rec = self.getRecord()
- while(True):
- try:
- collection.insert(rec, False, True)
- break
- except pymongo.errors.OperationFailure, err:
-
- if(DBConfig.TryCntOnWriteFail > trycnt):
- trycnt += 1
- continue
-
- addADOExceptionCount()
- mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
- msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!FamilyID = %s, error = %s, trycnt = %d'%(self.FamilyID, err, trycnt))
- mylog.error(msg)
-
- return False
- return True
-
-#Can not implement adoUpdateStr method:No key defined!
-
- def adoUpdateEx(self, collection, spec):
- '''执行更新'''
- trycnt = 0
- rec = self.getRecord()
- while(True):
- try:
- collection.update(spec, {'$set':rec}, False, False, True, True)
- break
- except pymongo.errors.OperationFailure, err:
- if(DBConfig.TryCntOnWriteFail > trycnt):
- trycnt += 1
- continue
- addADOExceptionCount()
- mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
- msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!FamilyID = %s, error = %s, trycnt = %d'%(self.FamilyID, err, trycnt))
- mylog.error(msg)
-
- return False
- return True
-
-#Can not implement adoCheckUpdateStr method:No key defined!
-#Can not implement adoCheckUpdateExStr method:No key defined!
-
- def getAdoRecords(self, resultCollection):
- '''查询结果打包成二进制流'''
- result = ''
- result = CommFunc.WriteDWORD(result, resultCollection.count())
- for rec in resultCollection:
- self.readRecord(rec)
- result += self.getBuffer()
- return result
-
-
- def adoQueryIndex(self, collection):
- '''用索引字段查找'''
- resultCollection = collection.find({'FamilyID':self.FamilyID})
-
- return self.getAdoRecords(resultCollection)
-
-
- def adoQueryCustom(self, collection, queryDict):
- '''自定义查询'''
- resultCollection = collection.find(queryDict)
-
- return self.getAdoRecords(resultCollection)
-
-
- def adoQueryAll(self, collection):
- '''查询所有'''
- resultCollection = collection.find()
-
- return self.getAdoRecords(resultCollection)
-
-
- def adoDeleteByIndex(self, collection):
- '''根据索引删除'''
- trycnt = 0
- while(True):
- try:
- collection.remove({'FamilyID':self.FamilyID})
- break
- except pymongo.errors.OperationFailure, err:
- if(DBConfig.TryCntOnWriteFail > trycnt):
- trycnt += 1
- continue
- addADOExceptionCount()
- mylog.info("%s.%s:FamilyID = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.FamilyID))
- msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.FamilyID = %s, error = %s, trycnt = %d'%(self.FamilyID, err, trycnt))
- mylog.error(msg)
-
- return False
- return True
-
- def outputString(self):
- output = '''//家族行为表#tagDBFamilyAction:
- FamilyID = %s,
- ActionType = %s,
- Name = %s,
- Time = %s,
- Value1 = %s,
- Value2 = %s,
- Value3 = %s,
- Value4 = %s,
- Value5 = %s,
- Value6 = %s,
- DataLen = %s,
- Data = %s,
- ADOResult = %s,
- '''%(
- self.FamilyID,
- self.ActionType,
- self.Name,
- self.Time,
- self.Value1,
- self.Value2,
- self.Value3,
- self.Value4,
- self.Value5,
- self.Value6,
- self.DataLen,
- self.Data,
- self.ADOResult,
- )
- return output
-
- def dumpString(self):
- output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
- self.FamilyID,
- self.ActionType,
- self.Name,
- self.Time,
- self.Value1,
- self.Value2,
- self.Value3,
- self.Value4,
- self.Value5,
- self.Value6,
- self.DataLen,
- self.Data,
- )
- return output
-
- #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
- def SetName(self,Str):
- if len(Str)<=33:
- self.Name = Str
- else:
- self.Name = Str[:33]
-
#------------------------------------------------------
#帮会科技表#tagDBFamilyTech
@@ -26851,3 +26161,2539 @@
)
return output
+# 事件触发表 #tagDBEventTrig
+class tagDBEventTrig(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('EventLen', ctypes.c_ulong),
+ ('EventID', ctypes.c_char_p),
+ ('EventValue', ctypes.c_ulong),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+ def clear(self):
+ self.EventLen = 0
+ self.EventID = ''
+ self.EventValue = 0
+
+ def readData(self, buf, pos = 0, length = 0):
+ if not pos <= length:
+ msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
+ mylog.error(msg)
+ return -1
+ if len(buf) < pos + self.getLength():
+ msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
+ mylog.error(msg)
+ self.clear()
+ self.EventLen, pos = CommFunc.ReadDWORD(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.EventLen)
+ self.EventID = ctypes.c_char_p(tmp)
+ self.EventValue, pos = CommFunc.ReadDWORD(buf, pos)
+ return self.getLength()
+
+ def getBuffer(self):
+ buf = ''
+ buf = CommFunc.WriteDWORD(buf, self.EventLen)
+ buf = CommFunc.WriteString(buf, self.EventLen, self.EventID)
+ buf = CommFunc.WriteDWORD(buf, self.EventValue)
+ return buf
+
+ def getLength(self):
+ length = 0
+ length += sizeof(ctypes.c_ulong)
+ length += self.EventLen
+ length += sizeof(ctypes.c_ulong)
+ return length
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'EventLen'] = self.EventLen
+ rec[u'EventID'] = fix_incomingText(self.EventID)
+ rec[u'EventValue'] = self.EventValue
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.EventLen = rec.get(u'EventLen', 0)
+ self.EventID = fix_outgoingText(rec.get(u'EventID', u''))
+ self.EventValue = rec.get(u'EventValue', 0)
+
+ def adoLoad(self, collection):
+ '''使用KEY查找并读取'''
+ resultCollection = collection.find({'EventID':fix_incomingText(self.EventID)})
+
+ if resultCollection.count() <= 0:
+ return False
+ #由于是KEY查找，所有如果存在就只有一条记录
+ rec = resultCollection[0]
+ #读取数据
+ self.readRecord(rec)
+ return True
+
+
+ def adoInsert(self, collection):
+ '''执行插入'''
+
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.insert(rec, False, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!EventID = %s, error = %s, trycnt = %d'%(self.EventID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+
+ def adoUpdate(self, collection):
+ '''执行更新'''
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.update({'EventID':fix_incomingText(self.EventID)}, {'$set':rec}, False, False, True, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_153, 'Update failed!EventID = %s, error = %s, trycnt = %d'%(self.EventID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+
+ def adoUpdateEx(self, collection, spec):
+ '''执行更新'''
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.update(spec, {'$set':rec}, False, False, True, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!EventID = %s, error = %s, trycnt = %d'%(self.EventID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+
+ def adoCheckUpdate(self, collection):
+ '''根据情况执行插入或更新'''
+ resultCollection = collection.find({'EventID':fix_incomingText(self.EventID)})
+
+ if resultCollection.count() <= 0:
+ return self.adoInsert(collection)
+ return self.adoUpdate(collection)
+
+
+ def adoCheckUpdateEx(self, collection, spec):
+ '''根据情况执行插入或更新'''
+ resultCollection = collection.find(spec)
+
+ if resultCollection.count() <= 0:
+ return self.adoInsert(collection)
+ return self.adoUpdateEx(collection, spec)
+
+
+ def getAdoRecords(self, resultCollection):
+ '''查询结果打包成二进制流'''
+ result = ''
+ result = CommFunc.WriteDWORD(result, resultCollection.count())
+ for rec in resultCollection:
+ self.readRecord(rec)
+ result += self.getBuffer()
+ return result
+
+
+ def adoQueryIndex(self, collection):
+ '''用索引字段查找'''
+ resultCollection = collection.find({'EventID':fix_incomingText(self.EventID)})
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryCustom(self, collection, queryDict):
+ '''自定义查询'''
+ resultCollection = collection.find(queryDict)
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryAll(self, collection):
+ '''查询所有'''
+ resultCollection = collection.find()
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoDeleteByIndex(self, collection):
+ '''根据索引删除'''
+ trycnt = 0
+ while(True):
+ try:
+ collection.remove({'EventID':fix_incomingText(self.EventID)})
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+ addADOExceptionCount()
+ mylog.info("%s.%s:EventID = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.EventID))
+ msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.EventID = %s, error = %s, trycnt = %d'%(self.EventID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+ def outputString(self):
+ output = '''// 事件触发表 #tagDBEventTrig:
+ EventLen = %s,
+ EventID = %s,
+ EventValue = %s,
+ ADOResult = %s,
+ '''%(
+ self.EventLen,
+ self.EventID,
+ self.EventValue,
+ self.ADOResult,
+ )
+ return output
+
+ def dumpString(self):
+ output = '''%1s\t%1s\t%1s'''%(
+ self.EventLen,
+ self.EventID,
+ self.EventValue,
+ )
+ return output
+
+
+# 玩家查看缓存表 #tagDBPlayerViewCache
+class tagDBPlayerViewCache(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('PlayerID', ctypes.c_ulong),
+ ('AccID', ctypes.c_char * 65),
+ ('PlayerName', ctypes.c_char * 33),
+ ('LV', ctypes.c_int),
+ ('Job', ctypes.c_int),
+ ('RealmLV', ctypes.c_ubyte),
+ ('Face', ctypes.c_int),
+ ('FacePic', ctypes.c_int),
+ ('FamilyID', ctypes.c_ulong),
+ ('FamilyName', ctypes.c_char * 33),
+ ('FamilyEmblemID', ctypes.c_ushort),
+ ('TitleID', ctypes.c_ulong),
+ ('FightPower', ctypes.c_ulong),
+ ('FightPowerEx', ctypes.c_ulong),
+ ('ServerID', ctypes.c_ulong),
+ ('OffTime', ctypes.c_ulong),
+ ('PlusDataSize', ctypes.c_ulong),
+ ('PlusData', ctypes.c_char_p),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+ def clear(self):
+ self.PlayerID = 0
+ self.AccID = ''
+ self.PlayerName = ''
+ self.LV = 0
+ self.Job = 0
+ self.RealmLV = 0
+ self.Face = 0
+ self.FacePic = 0
+ self.FamilyID = 0
+ self.FamilyName = ''
+ self.FamilyEmblemID = 0
+ self.TitleID = 0
+ self.FightPower = 0
+ self.FightPowerEx = 0
+ self.ServerID = 0
+ self.OffTime = 0
+ self.PlusDataSize = 0
+ self.PlusData = ''
+
+ def readData(self, buf, pos = 0, length = 0):
+ if not pos <= length:
+ msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
+ mylog.error(msg)
+ return -1
+ if len(buf) < pos + self.getLength():
+ msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
+ mylog.error(msg)
+ self.clear()
+ self.PlayerID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.AccID, pos = CommFunc.ReadString(buf, pos, 65)
+ self.PlayerName, pos = CommFunc.ReadString(buf, pos, 33)
+ self.LV, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Job, pos = CommFunc.ReadDWORD(buf, pos)
+ self.RealmLV, pos = CommFunc.ReadBYTE(buf, pos)
+ self.Face, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FacePic, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FamilyID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FamilyName, pos = CommFunc.ReadString(buf, pos, 33)
+ self.FamilyEmblemID, pos = CommFunc.ReadWORD(buf, pos)
+ self.TitleID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FightPower, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FightPowerEx, pos = CommFunc.ReadDWORD(buf, pos)
+ self.ServerID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.OffTime, pos = CommFunc.ReadDWORD(buf, pos)
+ self.PlusDataSize, pos = CommFunc.ReadDWORD(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.PlusDataSize)
+ self.PlusData = ctypes.c_char_p(tmp)
+ return self.getLength()
+
+ def getBuffer(self):
+ buf = ''
+ buf = CommFunc.WriteDWORD(buf, self.PlayerID)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 65, self.AccID)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.PlayerName)
+ buf = CommFunc.WriteDWORD(buf, self.LV)
+ buf = CommFunc.WriteDWORD(buf, self.Job)
+ buf = CommFunc.WriteBYTE(buf, self.RealmLV)
+ buf = CommFunc.WriteDWORD(buf, self.Face)
+ buf = CommFunc.WriteDWORD(buf, self.FacePic)
+ buf = CommFunc.WriteDWORD(buf, self.FamilyID)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.FamilyName)
+ buf = CommFunc.WriteWORD(buf, self.FamilyEmblemID)
+ buf = CommFunc.WriteDWORD(buf, self.TitleID)
+ buf = CommFunc.WriteDWORD(buf, self.FightPower)
+ buf = CommFunc.WriteDWORD(buf, self.FightPowerEx)
+ buf = CommFunc.WriteDWORD(buf, self.ServerID)
+ buf = CommFunc.WriteDWORD(buf, self.OffTime)
+ buf = CommFunc.WriteDWORD(buf, self.PlusDataSize)
+ buf = CommFunc.WriteString(buf, self.PlusDataSize, self.PlusData)
+ return buf
+
+ def getLength(self):
+ length = 0
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_char) * 65
+ length += sizeof(ctypes.c_char) * 33
+ length += sizeof(ctypes.c_int)
+ length += sizeof(ctypes.c_int)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_int)
+ length += sizeof(ctypes.c_int)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_char) * 33
+ length += sizeof(ctypes.c_ushort)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += self.PlusDataSize
+ return length
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'PlayerID'] = self.PlayerID
+ rec[u'AccID'] = fix_incomingText(self.AccID)
+ rec[u'PlayerName'] = fix_incomingText(self.PlayerName)
+ rec[u'LV'] = self.LV
+ rec[u'Job'] = self.Job
+ rec[u'RealmLV'] = self.RealmLV
+ rec[u'Face'] = self.Face
+ rec[u'FacePic'] = self.FacePic
+ rec[u'FamilyID'] = self.FamilyID
+ rec[u'FamilyName'] = fix_incomingText(self.FamilyName)
+ rec[u'FamilyEmblemID'] = self.FamilyEmblemID
+ rec[u'TitleID'] = self.TitleID
+ rec[u'FightPower'] = self.FightPower
+ rec[u'FightPowerEx'] = self.FightPowerEx
+ rec[u'ServerID'] = self.ServerID
+ rec[u'OffTime'] = self.OffTime
+ rec[u'PlusDataSize'] = self.PlusDataSize
+ rec[u'PlusData'] = fix_incomingText(self.PlusData)
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.PlayerID = rec.get(u'PlayerID', 0)
+ self.AccID = fix_outgoingText(rec.get(u'AccID', u''))
+ self.PlayerName = fix_outgoingText(rec.get(u'PlayerName', u''))
+ self.LV = rec.get(u'LV', 0)
+ self.Job = rec.get(u'Job', 0)
+ self.RealmLV = rec.get(u'RealmLV', 0)
+ self.Face = rec.get(u'Face', 0)
+ self.FacePic = rec.get(u'FacePic', 0)
+ self.FamilyID = rec.get(u'FamilyID', 0)
+ self.FamilyName = fix_outgoingText(rec.get(u'FamilyName', u''))
+ self.FamilyEmblemID = rec.get(u'FamilyEmblemID', 0)
+ self.TitleID = rec.get(u'TitleID', 0)
+ self.FightPower = rec.get(u'FightPower', 0)
+ self.FightPowerEx = rec.get(u'FightPowerEx', 0)
+ self.ServerID = rec.get(u'ServerID', 0)
+ self.OffTime = rec.get(u'OffTime', 0)
+ self.PlusDataSize = rec.get(u'PlusDataSize', 0)
+ self.PlusData = fix_outgoingText(rec.get(u'PlusData', u''))
+
+#Can not implement adoLoadStr method:No key defined!
+
+ def adoInsert(self, collection):
+ '''执行插入'''
+
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.insert(rec, False, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+#Can not implement adoUpdateStr method:No key defined!
+
+ def adoUpdateEx(self, collection, spec):
+ '''执行更新'''
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.update(spec, {'$set':rec}, False, False, True, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+#Can not implement adoCheckUpdateStr method:No key defined!
+#Can not implement adoCheckUpdateExStr method:No key defined!
+
+ def getAdoRecords(self, resultCollection):
+ '''查询结果打包成二进制流'''
+ result = ''
+ result = CommFunc.WriteDWORD(result, resultCollection.count())
+ for rec in resultCollection:
+ self.readRecord(rec)
+ result += self.getBuffer()
+ return result
+
+
+ def adoQueryIndex(self, collection):
+ '''用索引字段查找'''
+ resultCollection = collection.find({'PlayerID':self.PlayerID})
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryCustom(self, collection, queryDict):
+ '''自定义查询'''
+ resultCollection = collection.find(queryDict)
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryAll(self, collection):
+ '''查询所有'''
+ resultCollection = collection.find()
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoDeleteByIndex(self, collection):
+ '''根据索引删除'''
+ trycnt = 0
+ while(True):
+ try:
+ collection.remove({'PlayerID':self.PlayerID})
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+ addADOExceptionCount()
+ mylog.info("%s.%s:PlayerID = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.PlayerID))
+ msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+ def outputString(self):
+ output = '''// 玩家查看缓存表 #tagDBPlayerViewCache:
+ PlayerID = %s,
+ AccID = %s,
+ PlayerName = %s,
+ LV = %s,
+ Job = %s,
+ RealmLV = %s,
+ Face = %s,
+ FacePic = %s,
+ FamilyID = %s,
+ FamilyName = %s,
+ FamilyEmblemID = %s,
+ TitleID = %s,
+ FightPower = %s,
+ FightPowerEx = %s,
+ ServerID = %s,
+ OffTime = %s,
+ PlusDataSize = %s,
+ PlusData = %s,
+ ADOResult = %s,
+ '''%(
+ self.PlayerID,
+ self.AccID,
+ self.PlayerName,
+ self.LV,
+ self.Job,
+ self.RealmLV,
+ self.Face,
+ self.FacePic,
+ self.FamilyID,
+ self.FamilyName,
+ self.FamilyEmblemID,
+ self.TitleID,
+ self.FightPower,
+ self.FightPowerEx,
+ self.ServerID,
+ self.OffTime,
+ self.PlusDataSize,
+ self.PlusData,
+ self.ADOResult,
+ )
+ return output
+
+ def dumpString(self):
+ output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
+ self.PlayerID,
+ self.AccID,
+ self.PlayerName,
+ self.LV,
+ self.Job,
+ self.RealmLV,
+ self.Face,
+ self.FacePic,
+ self.FamilyID,
+ self.FamilyName,
+ self.FamilyEmblemID,
+ self.TitleID,
+ self.FightPower,
+ self.FightPowerEx,
+ self.ServerID,
+ self.OffTime,
+ self.PlusDataSize,
+ self.PlusData,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetAccID(self,Str):
+ if len(Str)<=65:
+ self.AccID = Str
+ else:
+ self.AccID = Str[:65]
+
+ def SetPlayerName(self,Str):
+ if len(Str)<=33:
+ self.PlayerName = Str
+ else:
+ self.PlayerName = Str[:33]
+
+ def SetFamilyName(self,Str):
+ if len(Str)<=33:
+ self.FamilyName = Str
+ else:
+ self.FamilyName = Str[:33]
+
+
+# 排行榜表 #tagDBBillboard
+class tagDBBillboard(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('GroupValue1', ctypes.c_ulong),
+ ('GroupValue2', ctypes.c_ulong),
+ ('BillboardType', ctypes.c_ubyte),
+ ('ID', ctypes.c_ulong),
+ ('ID2', ctypes.c_ulong),
+ ('Name1', ctypes.c_char * 33),
+ ('Name2', ctypes.c_char * 65),
+ ('Type2', ctypes.c_ubyte),
+ ('Value1', ctypes.c_ulong),
+ ('Value2', ctypes.c_ulong),
+ ('Value3', ctypes.c_ulong),
+ ('Value4', ctypes.c_ulong),
+ ('Value5', ctypes.c_ulong),
+ ('Value6', ctypes.c_ulong),
+ ('Value7', ctypes.c_ulong),
+ ('Value8', ctypes.c_ulong),
+ ('CmpValue', ctypes.c_ulong),
+ ('CmpValue2', ctypes.c_ulong),
+ ('CmpValue3', ctypes.c_ulong),
+ ('DataLen', ctypes.c_ushort),
+ ('UserData', ctypes.c_char_p),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+ def clear(self):
+ self.GroupValue1 = 0
+ self.GroupValue2 = 0
+ self.BillboardType = 0
+ self.ID = 0
+ self.ID2 = 0
+ self.Name1 = ''
+ self.Name2 = ''
+ self.Type2 = 0
+ self.Value1 = 0
+ self.Value2 = 0
+ self.Value3 = 0
+ self.Value4 = 0
+ self.Value5 = 0
+ self.Value6 = 0
+ self.Value7 = 0
+ self.Value8 = 0
+ self.CmpValue = 0
+ self.CmpValue2 = 0
+ self.CmpValue3 = 0
+ self.DataLen = 0
+ self.UserData = ''
+
+ def readData(self, buf, pos = 0, length = 0):
+ if not pos <= length:
+ msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
+ mylog.error(msg)
+ return -1
+ if len(buf) < pos + self.getLength():
+ msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
+ mylog.error(msg)
+ self.clear()
+ self.GroupValue1, pos = CommFunc.ReadDWORD(buf, pos)
+ self.GroupValue2, pos = CommFunc.ReadDWORD(buf, pos)
+ self.BillboardType, pos = CommFunc.ReadBYTE(buf, pos)
+ self.ID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.ID2, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Name1, pos = CommFunc.ReadString(buf, pos, 33)
+ self.Name2, pos = CommFunc.ReadString(buf, pos, 65)
+ self.Type2, pos = CommFunc.ReadBYTE(buf, pos)
+ self.Value1, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value2, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value3, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value4, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value5, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value6, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value7, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value8, pos = CommFunc.ReadDWORD(buf, pos)
+ self.CmpValue, pos = CommFunc.ReadDWORD(buf, pos)
+ self.CmpValue2, pos = CommFunc.ReadDWORD(buf, pos)
+ self.CmpValue3, pos = CommFunc.ReadDWORD(buf, pos)
+ self.DataLen, pos = CommFunc.ReadWORD(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.DataLen)
+ self.UserData = ctypes.c_char_p(tmp)
+ return self.getLength()
+
+ def getBuffer(self):
+ buf = ''
+ buf = CommFunc.WriteDWORD(buf, self.GroupValue1)
+ buf = CommFunc.WriteDWORD(buf, self.GroupValue2)
+ buf = CommFunc.WriteBYTE(buf, self.BillboardType)
+ buf = CommFunc.WriteDWORD(buf, self.ID)
+ buf = CommFunc.WriteDWORD(buf, self.ID2)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.Name1)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 65, self.Name2)
+ buf = CommFunc.WriteBYTE(buf, self.Type2)
+ buf = CommFunc.WriteDWORD(buf, self.Value1)
+ buf = CommFunc.WriteDWORD(buf, self.Value2)
+ buf = CommFunc.WriteDWORD(buf, self.Value3)
+ buf = CommFunc.WriteDWORD(buf, self.Value4)
+ buf = CommFunc.WriteDWORD(buf, self.Value5)
+ buf = CommFunc.WriteDWORD(buf, self.Value6)
+ buf = CommFunc.WriteDWORD(buf, self.Value7)
+ buf = CommFunc.WriteDWORD(buf, self.Value8)
+ buf = CommFunc.WriteDWORD(buf, self.CmpValue)
+ buf = CommFunc.WriteDWORD(buf, self.CmpValue2)
+ buf = CommFunc.WriteDWORD(buf, self.CmpValue3)
+ buf = CommFunc.WriteWORD(buf, self.DataLen)
+ buf = CommFunc.WriteString(buf, self.DataLen, self.UserData)
+ return buf
+
+ def getLength(self):
+ length = 0
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_char) * 33
+ length += sizeof(ctypes.c_char) * 65
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ushort)
+ length += self.DataLen
+ return length
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'GroupValue1'] = self.GroupValue1
+ rec[u'GroupValue2'] = self.GroupValue2
+ rec[u'BillboardType'] = self.BillboardType
+ rec[u'ID'] = self.ID
+ rec[u'ID2'] = self.ID2
+ rec[u'Name1'] = fix_incomingText(self.Name1)
+ rec[u'Name2'] = fix_incomingText(self.Name2)
+ rec[u'Type2'] = self.Type2
+ rec[u'Value1'] = self.Value1
+ rec[u'Value2'] = self.Value2
+ rec[u'Value3'] = self.Value3
+ rec[u'Value4'] = self.Value4
+ rec[u'Value5'] = self.Value5
+ rec[u'Value6'] = self.Value6
+ rec[u'Value7'] = self.Value7
+ rec[u'Value8'] = self.Value8
+ rec[u'CmpValue'] = self.CmpValue
+ rec[u'CmpValue2'] = self.CmpValue2
+ rec[u'CmpValue3'] = self.CmpValue3
+ rec[u'DataLen'] = self.DataLen
+ rec[u'UserData'] = fix_incomingText(self.UserData)
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.GroupValue1 = rec.get(u'GroupValue1', 0)
+ self.GroupValue2 = rec.get(u'GroupValue2', 0)
+ self.BillboardType = rec.get(u'BillboardType', 0)
+ self.ID = rec.get(u'ID', 0)
+ self.ID2 = rec.get(u'ID2', 0)
+ self.Name1 = fix_outgoingText(rec.get(u'Name1', u''))
+ self.Name2 = fix_outgoingText(rec.get(u'Name2', u''))
+ self.Type2 = rec.get(u'Type2', 0)
+ self.Value1 = rec.get(u'Value1', 0)
+ self.Value2 = rec.get(u'Value2', 0)
+ self.Value3 = rec.get(u'Value3', 0)
+ self.Value4 = rec.get(u'Value4', 0)
+ self.Value5 = rec.get(u'Value5', 0)
+ self.Value6 = rec.get(u'Value6', 0)
+ self.Value7 = rec.get(u'Value7', 0)
+ self.Value8 = rec.get(u'Value8', 0)
+ self.CmpValue = rec.get(u'CmpValue', 0)
+ self.CmpValue2 = rec.get(u'CmpValue2', 0)
+ self.CmpValue3 = rec.get(u'CmpValue3', 0)
+ self.DataLen = rec.get(u'DataLen', 0)
+ self.UserData = fix_outgoingText(rec.get(u'UserData', u''))
+
+#Can not implement adoLoadStr method:No key defined!
+#Can not implement adoInsertStr method:No key defined!
+#Can not implement adoUpdateStr method:No key defined!
+#Can not implement adoUpdateStr method:No key defined!
+#Can not implement adoCheckUpdateStr method:No key defined!
+#Can not implement adoCheckUpdateExStr method:No key defined!
+
+ def getAdoRecords(self, resultCollection):
+ '''查询结果打包成二进制流'''
+ result = ''
+ result = CommFunc.WriteDWORD(result, resultCollection.count())
+ for rec in resultCollection:
+ self.readRecord(rec)
+ result += self.getBuffer()
+ return result
+
+#Can not implement adoQueryIndexStr method:No key defined!
+
+ def adoQueryCustom(self, collection, queryDict):
+ '''自定义查询'''
+ resultCollection = collection.find(queryDict)
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryAll(self, collection):
+ '''查询所有'''
+ resultCollection = collection.find()
+
+ return self.getAdoRecords(resultCollection)
+
+#Can not implement adoDeleteByIndexStr method:No key defined!
+ def outputString(self):
+ output = '''// 排行榜表 #tagDBBillboard:
+ GroupValue1 = %s,
+ GroupValue2 = %s,
+ BillboardType = %s,
+ ID = %s,
+ ID2 = %s,
+ Name1 = %s,
+ Name2 = %s,
+ Type2 = %s,
+ Value1 = %s,
+ Value2 = %s,
+ Value3 = %s,
+ Value4 = %s,
+ Value5 = %s,
+ Value6 = %s,
+ Value7 = %s,
+ Value8 = %s,
+ CmpValue = %s,
+ CmpValue2 = %s,
+ CmpValue3 = %s,
+ DataLen = %s,
+ UserData = %s,
+ ADOResult = %s,
+ '''%(
+ self.GroupValue1,
+ self.GroupValue2,
+ self.BillboardType,
+ self.ID,
+ self.ID2,
+ self.Name1,
+ self.Name2,
+ self.Type2,
+ self.Value1,
+ self.Value2,
+ self.Value3,
+ self.Value4,
+ self.Value5,
+ self.Value6,
+ self.Value7,
+ self.Value8,
+ self.CmpValue,
+ self.CmpValue2,
+ self.CmpValue3,
+ self.DataLen,
+ self.UserData,
+ self.ADOResult,
+ )
+ return output
+
+ def dumpString(self):
+ output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
+ self.GroupValue1,
+ self.GroupValue2,
+ self.BillboardType,
+ self.ID,
+ self.ID2,
+ self.Name1,
+ self.Name2,
+ self.Type2,
+ self.Value1,
+ self.Value2,
+ self.Value3,
+ self.Value4,
+ self.Value5,
+ self.Value6,
+ self.Value7,
+ self.Value8,
+ self.CmpValue,
+ self.CmpValue2,
+ self.CmpValue3,
+ self.DataLen,
+ self.UserData,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetName1(self,Str):
+ if len(Str)<=33:
+ self.Name1 = Str
+ else:
+ self.Name1 = Str[:33]
+
+ def SetName2(self,Str):
+ if len(Str)<=65:
+ self.Name2 = Str
+ else:
+ self.Name2 = Str[:65]
+
+
+# 邮件个人邮件表 #tagDBMailPersonal
+class tagDBMailPersonal(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('PlayerID', ctypes.c_ulong),
+ ('GUID', ctypes.c_char * 36),
+ ('Type', ctypes.c_ubyte),
+ ('CreateTime', ctypes.c_char * 30),
+ ('LimitDays', ctypes.c_ubyte),
+ ('TitleLen', ctypes.c_ubyte),
+ ('Title', ctypes.c_char_p),
+ ('TextLen', ctypes.c_ushort),
+ ('Text', ctypes.c_char_p),
+ ('MailState', ctypes.c_ubyte),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+ def clear(self):
+ self.PlayerID = 0
+ self.GUID = ''
+ self.Type = 0
+ self.CreateTime = ''
+ self.LimitDays = 0
+ self.TitleLen = 0
+ self.Title = ''
+ self.TextLen = 0
+ self.Text = ''
+ self.MailState = 0
+
+ def readData(self, buf, pos = 0, length = 0):
+ if not pos <= length:
+ msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
+ mylog.error(msg)
+ return -1
+ if len(buf) < pos + self.getLength():
+ msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
+ mylog.error(msg)
+ self.clear()
+ self.PlayerID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.GUID, pos = CommFunc.ReadString(buf, pos, 36)
+ self.Type, pos = CommFunc.ReadBYTE(buf, pos)
+ self.CreateTime, pos = CommFunc.ReadString(buf, pos, 30)
+ self.LimitDays, pos = CommFunc.ReadBYTE(buf, pos)
+ self.TitleLen, pos = CommFunc.ReadBYTE(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.TitleLen)
+ self.Title = ctypes.c_char_p(tmp)
+ self.TextLen, pos = CommFunc.ReadWORD(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.TextLen)
+ self.Text = ctypes.c_char_p(tmp)
+ self.MailState, pos = CommFunc.ReadBYTE(buf, pos)
+ return self.getLength()
+
+ def getBuffer(self):
+ buf = ''
+ buf = CommFunc.WriteDWORD(buf, self.PlayerID)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 36, self.GUID)
+ buf = CommFunc.WriteBYTE(buf, self.Type)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 30, self.CreateTime)
+ buf = CommFunc.WriteBYTE(buf, self.LimitDays)
+ buf = CommFunc.WriteBYTE(buf, self.TitleLen)
+ buf = CommFunc.WriteString(buf, self.TitleLen, self.Title)
+ buf = CommFunc.WriteWORD(buf, self.TextLen)
+ buf = CommFunc.WriteString(buf, self.TextLen, self.Text)
+ buf = CommFunc.WriteBYTE(buf, self.MailState)
+ return buf
+
+ def getLength(self):
+ length = 0
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_char) * 36
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_char) * 30
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ubyte)
+ length += self.TitleLen
+ length += sizeof(ctypes.c_ushort)
+ length += self.TextLen
+ length += sizeof(ctypes.c_ubyte)
+ return length
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'PlayerID'] = self.PlayerID
+ rec[u'GUID'] = fix_incomingText(self.GUID)
+ rec[u'Type'] = self.Type
+ rec[u'CreateTime'] = fix_incomingText(self.CreateTime)
+ rec[u'LimitDays'] = self.LimitDays
+ rec[u'TitleLen'] = self.TitleLen
+ rec[u'Title'] = fix_incomingText(self.Title)
+ rec[u'TextLen'] = self.TextLen
+ rec[u'Text'] = fix_incomingText(self.Text)
+ rec[u'MailState'] = self.MailState
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.PlayerID = rec.get(u'PlayerID', 0)
+ self.GUID = fix_outgoingText(rec.get(u'GUID', u''))
+ self.Type = rec.get(u'Type', 0)
+ self.CreateTime = fix_outgoingText(rec.get(u'CreateTime', u''))
+ self.LimitDays = rec.get(u'LimitDays', 0)
+ self.TitleLen = rec.get(u'TitleLen', 0)
+ self.Title = fix_outgoingText(rec.get(u'Title', u''))
+ self.TextLen = rec.get(u'TextLen', 0)
+ self.Text = fix_outgoingText(rec.get(u'Text', u''))
+ self.MailState = rec.get(u'MailState', 0)
+
+#Can not implement adoLoadStr method:No key defined!
+#Can not implement adoInsertStr method:No key defined!
+#Can not implement adoUpdateStr method:No key defined!
+#Can not implement adoUpdateStr method:No key defined!
+#Can not implement adoCheckUpdateStr method:No key defined!
+#Can not implement adoCheckUpdateExStr method:No key defined!
+
+ def getAdoRecords(self, resultCollection):
+ '''查询结果打包成二进制流'''
+ result = ''
+ result = CommFunc.WriteDWORD(result, resultCollection.count())
+ for rec in resultCollection:
+ self.readRecord(rec)
+ result += self.getBuffer()
+ return result
+
+#Can not implement adoQueryIndexStr method:No key defined!
+
+ def adoQueryCustom(self, collection, queryDict):
+ '''自定义查询'''
+ resultCollection = collection.find(queryDict)
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryAll(self, collection):
+ '''查询所有'''
+ resultCollection = collection.find()
+
+ return self.getAdoRecords(resultCollection)
+
+#Can not implement adoDeleteByIndexStr method:No key defined!
+ def outputString(self):
+ output = '''// 邮件个人邮件表 #tagDBMailPersonal:
+ PlayerID = %s,
+ GUID = %s,
+ Type = %s,
+ CreateTime = %s,
+ LimitDays = %s,
+ TitleLen = %s,
+ Title = %s,
+ TextLen = %s,
+ Text = %s,
+ MailState = %s,
+ ADOResult = %s,
+ '''%(
+ self.PlayerID,
+ self.GUID,
+ self.Type,
+ self.CreateTime,
+ self.LimitDays,
+ self.TitleLen,
+ self.Title,
+ self.TextLen,
+ self.Text,
+ self.MailState,
+ self.ADOResult,
+ )
+ return output
+
+ def dumpString(self):
+ output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
+ self.PlayerID,
+ self.GUID,
+ self.Type,
+ self.CreateTime,
+ self.LimitDays,
+ self.TitleLen,
+ self.Title,
+ self.TextLen,
+ self.Text,
+ self.MailState,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetGUID(self,Str):
+ if len(Str)<=36:
+ self.GUID = Str
+ else:
+ self.GUID = Str[:36]
+
+ def SetCreateTime(self,Str):
+ if len(Str)<=30:
+ self.CreateTime = Str
+ else:
+ self.CreateTime = Str[:30]
+
+
+# 邮件全服邮件表 #tagDBMailServer
+class tagDBMailServer(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('GUID', ctypes.c_char * 36),
+ ('Type', ctypes.c_ubyte),
+ ('CreateTime', ctypes.c_char * 30),
+ ('LimitDays', ctypes.c_ubyte),
+ ('TitleLen', ctypes.c_ubyte),
+ ('Title', ctypes.c_char_p),
+ ('TextLen', ctypes.c_ushort),
+ ('Text', ctypes.c_char_p),
+ ('LimitLV', ctypes.c_ushort),
+ ('LimitLVType', ctypes.c_ubyte),
+ ('CheckState', ctypes.c_ubyte),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+ def clear(self):
+ self.GUID = ''
+ self.Type = 0
+ self.CreateTime = ''
+ self.LimitDays = 0
+ self.TitleLen = 0
+ self.Title = ''
+ self.TextLen = 0
+ self.Text = ''
+ self.LimitLV = 0
+ self.LimitLVType = 0
+ self.CheckState = 0
+
+ def readData(self, buf, pos = 0, length = 0):
+ if not pos <= length:
+ msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
+ mylog.error(msg)
+ return -1
+ if len(buf) < pos + self.getLength():
+ msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
+ mylog.error(msg)
+ self.clear()
+ self.GUID, pos = CommFunc.ReadString(buf, pos, 36)
+ self.Type, pos = CommFunc.ReadBYTE(buf, pos)
+ self.CreateTime, pos = CommFunc.ReadString(buf, pos, 30)
+ self.LimitDays, pos = CommFunc.ReadBYTE(buf, pos)
+ self.TitleLen, pos = CommFunc.ReadBYTE(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.TitleLen)
+ self.Title = ctypes.c_char_p(tmp)
+ self.TextLen, pos = CommFunc.ReadWORD(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.TextLen)
+ self.Text = ctypes.c_char_p(tmp)
+ self.LimitLV, pos = CommFunc.ReadWORD(buf, pos)
+ self.LimitLVType, pos = CommFunc.ReadBYTE(buf, pos)
+ self.CheckState, pos = CommFunc.ReadBYTE(buf, pos)
+ return self.getLength()
+
+ def getBuffer(self):
+ buf = ''
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 36, self.GUID)
+ buf = CommFunc.WriteBYTE(buf, self.Type)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 30, self.CreateTime)
+ buf = CommFunc.WriteBYTE(buf, self.LimitDays)
+ buf = CommFunc.WriteBYTE(buf, self.TitleLen)
+ buf = CommFunc.WriteString(buf, self.TitleLen, self.Title)
+ buf = CommFunc.WriteWORD(buf, self.TextLen)
+ buf = CommFunc.WriteString(buf, self.TextLen, self.Text)
+ buf = CommFunc.WriteWORD(buf, self.LimitLV)
+ buf = CommFunc.WriteBYTE(buf, self.LimitLVType)
+ buf = CommFunc.WriteBYTE(buf, self.CheckState)
+ return buf
+
+ def getLength(self):
+ length = 0
+ length += sizeof(ctypes.c_char) * 36
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_char) * 30
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ubyte)
+ length += self.TitleLen
+ length += sizeof(ctypes.c_ushort)
+ length += self.TextLen
+ length += sizeof(ctypes.c_ushort)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ubyte)
+ return length
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'GUID'] = fix_incomingText(self.GUID)
+ rec[u'Type'] = self.Type
+ rec[u'CreateTime'] = fix_incomingText(self.CreateTime)
+ rec[u'LimitDays'] = self.LimitDays
+ rec[u'TitleLen'] = self.TitleLen
+ rec[u'Title'] = fix_incomingText(self.Title)
+ rec[u'TextLen'] = self.TextLen
+ rec[u'Text'] = fix_incomingText(self.Text)
+ rec[u'LimitLV'] = self.LimitLV
+ rec[u'LimitLVType'] = self.LimitLVType
+ rec[u'CheckState'] = self.CheckState
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.GUID = fix_outgoingText(rec.get(u'GUID', u''))
+ self.Type = rec.get(u'Type', 0)
+ self.CreateTime = fix_outgoingText(rec.get(u'CreateTime', u''))
+ self.LimitDays = rec.get(u'LimitDays', 0)
+ self.TitleLen = rec.get(u'TitleLen', 0)
+ self.Title = fix_outgoingText(rec.get(u'Title', u''))
+ self.TextLen = rec.get(u'TextLen', 0)
+ self.Text = fix_outgoingText(rec.get(u'Text', u''))
+ self.LimitLV = rec.get(u'LimitLV', 0)
+ self.LimitLVType = rec.get(u'LimitLVType', 0)
+ self.CheckState = rec.get(u'CheckState', 0)
+
+#Can not implement adoLoadStr method:No key defined!
+#Can not implement adoInsertStr method:No key defined!
+#Can not implement adoUpdateStr method:No key defined!
+#Can not implement adoUpdateStr method:No key defined!
+#Can not implement adoCheckUpdateStr method:No key defined!
+#Can not implement adoCheckUpdateExStr method:No key defined!
+
+ def getAdoRecords(self, resultCollection):
+ '''查询结果打包成二进制流'''
+ result = ''
+ result = CommFunc.WriteDWORD(result, resultCollection.count())
+ for rec in resultCollection:
+ self.readRecord(rec)
+ result += self.getBuffer()
+ return result
+
+#Can not implement adoQueryIndexStr method:No key defined!
+
+ def adoQueryCustom(self, collection, queryDict):
+ '''自定义查询'''
+ resultCollection = collection.find(queryDict)
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryAll(self, collection):
+ '''查询所有'''
+ resultCollection = collection.find()
+
+ return self.getAdoRecords(resultCollection)
+
+#Can not implement adoDeleteByIndexStr method:No key defined!
+ def outputString(self):
+ output = '''// 邮件全服邮件表 #tagDBMailServer:
+ GUID = %s,
+ Type = %s,
+ CreateTime = %s,
+ LimitDays = %s,
+ TitleLen = %s,
+ Title = %s,
+ TextLen = %s,
+ Text = %s,
+ LimitLV = %s,
+ LimitLVType = %s,
+ CheckState = %s,
+ ADOResult = %s,
+ '''%(
+ self.GUID,
+ self.Type,
+ self.CreateTime,
+ self.LimitDays,
+ self.TitleLen,
+ self.Title,
+ self.TextLen,
+ self.Text,
+ self.LimitLV,
+ self.LimitLVType,
+ self.CheckState,
+ self.ADOResult,
+ )
+ return output
+
+ def dumpString(self):
+ output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
+ self.GUID,
+ self.Type,
+ self.CreateTime,
+ self.LimitDays,
+ self.TitleLen,
+ self.Title,
+ self.TextLen,
+ self.Text,
+ self.LimitLV,
+ self.LimitLVType,
+ self.CheckState,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetGUID(self,Str):
+ if len(Str)<=36:
+ self.GUID = Str
+ else:
+ self.GUID = Str[:36]
+
+ def SetCreateTime(self,Str):
+ if len(Str)<=30:
+ self.CreateTime = Str
+ else:
+ self.CreateTime = Str[:30]
+
+
+# 邮件全服记录表 #tagDBMailPlayerRec
+class tagDBMailPlayerRec(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('PlayerID', ctypes.c_ulong),
+ ('GUID', ctypes.c_char * 36),
+ ('MailState', ctypes.c_ubyte),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+
+ def clear(self):
+ memset(addressof(self), 0, self.getLength())
+
+ def readData(self, buf, pos = 0, length = 0):
+ if not pos <= length:
+ msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
+ mylog.error(msg)
+ return -1
+ if len(buf) < pos + self.getLength():
+ msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
+ mylog.error(msg)
+ self.clear()
+ self.PlayerID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.GUID, pos = CommFunc.ReadString(buf, pos, 36)
+ self.MailState, pos = CommFunc.ReadBYTE(buf, pos)
+ return self.getLength()
+
+
+ def getBuffer(self):
+ buf = create_string_buffer(self.getLength())
+ memmove(addressof(buf), addressof(self), self.getLength())
+ return string_at(addressof(buf), self.getLength())
+
+ def getLength(self):
+ return sizeof(tagDBMailPlayerRec)
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'PlayerID'] = self.PlayerID
+ rec[u'GUID'] = fix_incomingText(self.GUID)
+ rec[u'MailState'] = self.MailState
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.PlayerID = rec.get(u'PlayerID', 0)
+ self.GUID = fix_outgoingText(rec.get(u'GUID', u''))
+ self.MailState = rec.get(u'MailState', 0)
+
+#Can not implement adoLoadStr method:No key defined!
+#Can not implement adoInsertStr method:No key defined!
+#Can not implement adoUpdateStr method:No key defined!
+#Can not implement adoUpdateStr method:No key defined!
+#Can not implement adoCheckUpdateStr method:No key defined!
+#Can not implement adoCheckUpdateExStr method:No key defined!
+
+ def getAdoRecords(self, resultCollection):
+ '''查询结果打包成二进制流'''
+ result = ''
+ result = CommFunc.WriteDWORD(result, resultCollection.count())
+ for rec in resultCollection:
+ self.readRecord(rec)
+ result += self.getBuffer()
+ return result
+
+#Can not implement adoQueryIndexStr method:No key defined!
+
+ def adoQueryCustom(self, collection, queryDict):
+ '''自定义查询'''
+ resultCollection = collection.find(queryDict)
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryAll(self, collection):
+ '''查询所有'''
+ resultCollection = collection.find()
+
+ return self.getAdoRecords(resultCollection)
+
+#Can not implement adoDeleteByIndexStr method:No key defined!
+ def outputString(self):
+ output = '''// 邮件全服记录表 #tagDBMailPlayerRec:
+ PlayerID = %s,
+ GUID = %s,
+ MailState = %s,
+ ADOResult = %s,
+ '''%(
+ self.PlayerID,
+ self.GUID,
+ self.MailState,
+ self.ADOResult,
+ )
+ return output
+
+ def dumpString(self):
+ output = '''%1s\t%1s\t%1s'''%(
+ self.PlayerID,
+ self.GUID,
+ self.MailState,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetGUID(self,Str):
+ if len(Str)<=36:
+ self.GUID = Str
+ else:
+ self.GUID = Str[:36]
+
+
+# 邮件物品表 #tagDBMailItem
+class tagDBMailItem(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('GUID', ctypes.c_char * 36),
+ ('ItemID', ctypes.c_ulong),
+ ('Count', ctypes.c_ulong),
+ ('IsBind', ctypes.c_ubyte),
+ ('UserDataLen', ctypes.c_ushort),
+ ('UserData', ctypes.c_char_p),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+ def clear(self):
+ self.GUID = ''
+ self.ItemID = 0
+ self.Count = 0
+ self.IsBind = 0
+ self.UserDataLen = 0
+ self.UserData = ''
+
+ def readData(self, buf, pos = 0, length = 0):
+ if not pos <= length:
+ msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
+ mylog.error(msg)
+ return -1
+ if len(buf) < pos + self.getLength():
+ msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
+ mylog.error(msg)
+ self.clear()
+ self.GUID, pos = CommFunc.ReadString(buf, pos, 36)
+ self.ItemID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Count, pos = CommFunc.ReadDWORD(buf, pos)
+ self.IsBind, pos = CommFunc.ReadBYTE(buf, pos)
+ self.UserDataLen, pos = CommFunc.ReadWORD(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.UserDataLen)
+ self.UserData = ctypes.c_char_p(tmp)
+ return self.getLength()
+
+ def getBuffer(self):
+ buf = ''
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 36, self.GUID)
+ buf = CommFunc.WriteDWORD(buf, self.ItemID)
+ buf = CommFunc.WriteDWORD(buf, self.Count)
+ buf = CommFunc.WriteBYTE(buf, self.IsBind)
+ buf = CommFunc.WriteWORD(buf, self.UserDataLen)
+ buf = CommFunc.WriteString(buf, self.UserDataLen, self.UserData)
+ return buf
+
+ def getLength(self):
+ length = 0
+ length += sizeof(ctypes.c_char) * 36
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ushort)
+ length += self.UserDataLen
+ return length
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'GUID'] = fix_incomingText(self.GUID)
+ rec[u'ItemID'] = self.ItemID
+ rec[u'Count'] = self.Count
+ rec[u'IsBind'] = self.IsBind
+ rec[u'UserDataLen'] = self.UserDataLen
+ rec[u'UserData'] = fix_incomingText(self.UserData)
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.GUID = fix_outgoingText(rec.get(u'GUID', u''))
+ self.ItemID = rec.get(u'ItemID', 0)
+ self.Count = rec.get(u'Count', 0)
+ self.IsBind = rec.get(u'IsBind', 0)
+ self.UserDataLen = rec.get(u'UserDataLen', 0)
+ self.UserData = fix_outgoingText(rec.get(u'UserData', u''))
+
+#Can not implement adoLoadStr method:No key defined!
+#Can not implement adoInsertStr method:No key defined!
+#Can not implement adoUpdateStr method:No key defined!
+#Can not implement adoUpdateStr method:No key defined!
+#Can not implement adoCheckUpdateStr method:No key defined!
+#Can not implement adoCheckUpdateExStr method:No key defined!
+
+ def getAdoRecords(self, resultCollection):
+ '''查询结果打包成二进制流'''
+ result = ''
+ result = CommFunc.WriteDWORD(result, resultCollection.count())
+ for rec in resultCollection:
+ self.readRecord(rec)
+ result += self.getBuffer()
+ return result
+
+#Can not implement adoQueryIndexStr method:No key defined!
+
+ def adoQueryCustom(self, collection, queryDict):
+ '''自定义查询'''
+ resultCollection = collection.find(queryDict)
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryAll(self, collection):
+ '''查询所有'''
+ resultCollection = collection.find()
+
+ return self.getAdoRecords(resultCollection)
+
+#Can not implement adoDeleteByIndexStr method:No key defined!
+ def outputString(self):
+ output = '''// 邮件物品表 #tagDBMailItem:
+ GUID = %s,
+ ItemID = %s,
+ Count = %s,
+ IsBind = %s,
+ UserDataLen = %s,
+ UserData = %s,
+ ADOResult = %s,
+ '''%(
+ self.GUID,
+ self.ItemID,
+ self.Count,
+ self.IsBind,
+ self.UserDataLen,
+ self.UserData,
+ self.ADOResult,
+ )
+ return output
+
+ def dumpString(self):
+ output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
+ self.GUID,
+ self.ItemID,
+ self.Count,
+ self.IsBind,
+ self.UserDataLen,
+ self.UserData,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetGUID(self,Str):
+ if len(Str)<=36:
+ self.GUID = Str
+ else:
+ self.GUID = Str[:36]
+
+
+# 家族表 #tagDBFamily
+class tagDBFamily(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('ID', ctypes.c_ulong),
+ ('Name', ctypes.c_char * 33),
+ ('LeaderID', ctypes.c_ulong),
+ ('LV', ctypes.c_ubyte),
+ ('Exp', ctypes.c_ulong),
+ ('JoinReview', ctypes.c_ubyte),
+ ('JoinLVMin', ctypes.c_ushort),
+ ('CreateTime', ctypes.c_ulong),
+ ('ServerID', ctypes.c_ulong),
+ ('BroadcastLen', ctypes.c_ubyte),
+ ('Broadcast', ctypes.c_char_p),
+ ('FightPower', ctypes.c_ulong),
+ ('FightPowerEx', ctypes.c_ulong),
+ ('EmblemID', ctypes.c_ushort),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+ def clear(self):
+ self.ID = 0
+ self.Name = ''
+ self.LeaderID = 0
+ self.LV = 0
+ self.Exp = 0
+ self.JoinReview = 0
+ self.JoinLVMin = 0
+ self.CreateTime = 0
+ self.ServerID = 0
+ self.BroadcastLen = 0
+ self.Broadcast = ''
+ self.FightPower = 0
+ self.FightPowerEx = 0
+ self.EmblemID = 0
+
+ def readData(self, buf, pos = 0, length = 0):
+ if not pos <= length:
+ msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
+ mylog.error(msg)
+ return -1
+ if len(buf) < pos + self.getLength():
+ msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
+ mylog.error(msg)
+ self.clear()
+ self.ID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Name, pos = CommFunc.ReadString(buf, pos, 33)
+ self.LeaderID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.LV, pos = CommFunc.ReadBYTE(buf, pos)
+ self.Exp, pos = CommFunc.ReadDWORD(buf, pos)
+ self.JoinReview, pos = CommFunc.ReadBYTE(buf, pos)
+ self.JoinLVMin, pos = CommFunc.ReadWORD(buf, pos)
+ self.CreateTime, pos = CommFunc.ReadDWORD(buf, pos)
+ self.ServerID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.BroadcastLen, pos = CommFunc.ReadBYTE(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.BroadcastLen)
+ self.Broadcast = ctypes.c_char_p(tmp)
+ self.FightPower, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FightPowerEx, pos = CommFunc.ReadDWORD(buf, pos)
+ self.EmblemID, pos = CommFunc.ReadWORD(buf, pos)
+ return self.getLength()
+
+ def getBuffer(self):
+ buf = ''
+ buf = CommFunc.WriteDWORD(buf, self.ID)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.Name)
+ buf = CommFunc.WriteDWORD(buf, self.LeaderID)
+ buf = CommFunc.WriteBYTE(buf, self.LV)
+ buf = CommFunc.WriteDWORD(buf, self.Exp)
+ buf = CommFunc.WriteBYTE(buf, self.JoinReview)
+ buf = CommFunc.WriteWORD(buf, self.JoinLVMin)
+ buf = CommFunc.WriteDWORD(buf, self.CreateTime)
+ buf = CommFunc.WriteDWORD(buf, self.ServerID)
+ buf = CommFunc.WriteBYTE(buf, self.BroadcastLen)
+ buf = CommFunc.WriteString(buf, self.BroadcastLen, self.Broadcast)
+ buf = CommFunc.WriteDWORD(buf, self.FightPower)
+ buf = CommFunc.WriteDWORD(buf, self.FightPowerEx)
+ buf = CommFunc.WriteWORD(buf, self.EmblemID)
+ return buf
+
+ def getLength(self):
+ length = 0
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_char) * 33
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ushort)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ubyte)
+ length += self.BroadcastLen
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ushort)
+ return length
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'ID'] = self.ID
+ rec[u'Name'] = fix_incomingText(self.Name)
+ rec[u'LeaderID'] = self.LeaderID
+ rec[u'LV'] = self.LV
+ rec[u'Exp'] = self.Exp
+ rec[u'JoinReview'] = self.JoinReview
+ rec[u'JoinLVMin'] = self.JoinLVMin
+ rec[u'CreateTime'] = self.CreateTime
+ rec[u'ServerID'] = self.ServerID
+ rec[u'BroadcastLen'] = self.BroadcastLen
+ rec[u'Broadcast'] = fix_incomingText(self.Broadcast)
+ rec[u'FightPower'] = self.FightPower
+ rec[u'FightPowerEx'] = self.FightPowerEx
+ rec[u'EmblemID'] = self.EmblemID
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.ID = rec.get(u'ID', 0)
+ self.Name = fix_outgoingText(rec.get(u'Name', u''))
+ self.LeaderID = rec.get(u'LeaderID', 0)
+ self.LV = rec.get(u'LV', 0)
+ self.Exp = rec.get(u'Exp', 0)
+ self.JoinReview = rec.get(u'JoinReview', 0)
+ self.JoinLVMin = rec.get(u'JoinLVMin', 0)
+ self.CreateTime = rec.get(u'CreateTime', 0)
+ self.ServerID = rec.get(u'ServerID', 0)
+ self.BroadcastLen = rec.get(u'BroadcastLen', 0)
+ self.Broadcast = fix_outgoingText(rec.get(u'Broadcast', u''))
+ self.FightPower = rec.get(u'FightPower', 0)
+ self.FightPowerEx = rec.get(u'FightPowerEx', 0)
+ self.EmblemID = rec.get(u'EmblemID', 0)
+
+ def adoLoad(self, collection):
+ '''使用KEY查找并读取'''
+ resultCollection = collection.find({'ID':self.ID})
+
+ if resultCollection.count() <= 0:
+ return False
+ #由于是KEY查找，所有如果存在就只有一条记录
+ rec = resultCollection[0]
+ #读取数据
+ self.readRecord(rec)
+ return True
+
+
+ def adoInsert(self, collection):
+ '''执行插入'''
+
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.insert(rec, False, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!ID = %s, error = %s, trycnt = %d'%(self.ID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+
+ def adoUpdate(self, collection):
+ '''执行更新'''
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.update({'ID':self.ID}, {'$set':rec}, False, False, True, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_153, 'Update failed!ID = %s, error = %s, trycnt = %d'%(self.ID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+
+ def adoUpdateEx(self, collection, spec):
+ '''执行更新'''
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.update(spec, {'$set':rec}, False, False, True, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!ID = %s, error = %s, trycnt = %d'%(self.ID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+
+ def adoCheckUpdate(self, collection):
+ '''根据情况执行插入或更新'''
+ resultCollection = collection.find({'ID':self.ID})
+
+ if resultCollection.count() <= 0:
+ return self.adoInsert(collection)
+ return self.adoUpdate(collection)
+
+
+ def adoCheckUpdateEx(self, collection, spec):
+ '''根据情况执行插入或更新'''
+ resultCollection = collection.find(spec)
+
+ if resultCollection.count() <= 0:
+ return self.adoInsert(collection)
+ return self.adoUpdateEx(collection, spec)
+
+
+ def getAdoRecords(self, resultCollection):
+ '''查询结果打包成二进制流'''
+ result = ''
+ result = CommFunc.WriteDWORD(result, resultCollection.count())
+ for rec in resultCollection:
+ self.readRecord(rec)
+ result += self.getBuffer()
+ return result
+
+
+ def adoQueryIndex(self, collection):
+ '''用索引字段查找'''
+ resultCollection = collection.find({'ID':self.ID})
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryCustom(self, collection, queryDict):
+ '''自定义查询'''
+ resultCollection = collection.find(queryDict)
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryAll(self, collection):
+ '''查询所有'''
+ resultCollection = collection.find()
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoDeleteByIndex(self, collection):
+ '''根据索引删除'''
+ trycnt = 0
+ while(True):
+ try:
+ collection.remove({'ID':self.ID})
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+ addADOExceptionCount()
+ mylog.info("%s.%s:ID = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.ID))
+ msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.ID = %s, error = %s, trycnt = %d'%(self.ID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+ def outputString(self):
+ output = '''// 家族表 #tagDBFamily:
+ ID = %s,
+ Name = %s,
+ LeaderID = %s,
+ LV = %s,
+ Exp = %s,
+ JoinReview = %s,
+ JoinLVMin = %s,
+ CreateTime = %s,
+ ServerID = %s,
+ BroadcastLen = %s,
+ Broadcast = %s,
+ FightPower = %s,
+ FightPowerEx = %s,
+ EmblemID = %s,
+ ADOResult = %s,
+ '''%(
+ self.ID,
+ self.Name,
+ self.LeaderID,
+ self.LV,
+ self.Exp,
+ self.JoinReview,
+ self.JoinLVMin,
+ self.CreateTime,
+ self.ServerID,
+ self.BroadcastLen,
+ self.Broadcast,
+ self.FightPower,
+ self.FightPowerEx,
+ self.EmblemID,
+ self.ADOResult,
+ )
+ return output
+
+ def dumpString(self):
+ output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
+ self.ID,
+ self.Name,
+ self.LeaderID,
+ self.LV,
+ self.Exp,
+ self.JoinReview,
+ self.JoinLVMin,
+ self.CreateTime,
+ self.ServerID,
+ self.BroadcastLen,
+ self.Broadcast,
+ self.FightPower,
+ self.FightPowerEx,
+ self.EmblemID,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetName(self,Str):
+ if len(Str)<=33:
+ self.Name = Str
+ else:
+ self.Name = Str[:33]
+
+
+# 家族成员表 #tagDBFamilyMem
+class tagDBFamilyMem(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('PlayerID', ctypes.c_ulong),
+ ('FamilyID', ctypes.c_ulong),
+ ('JoinTime', ctypes.c_ulong),
+ ('PlayerName', ctypes.c_char * 33),
+ ('LV', ctypes.c_int),
+ ('Job', ctypes.c_int),
+ ('RealmLV', ctypes.c_ubyte),
+ ('Face', ctypes.c_int),
+ ('FacePic', ctypes.c_int),
+ ('FightPower', ctypes.c_ulong),
+ ('FightPowerEx', ctypes.c_ulong),
+ ('ServerID', ctypes.c_ulong),
+ ('OffTime', ctypes.c_ulong),
+ ('FmLV', ctypes.c_ubyte),
+ ('ContribTotal', ctypes.c_ulong),
+ ('ContribWeek', ctypes.c_ulong),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+
+ def clear(self):
+ memset(addressof(self), 0, self.getLength())
+
+ def readData(self, buf, pos = 0, length = 0):
+ if not pos <= length:
+ msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
+ mylog.error(msg)
+ return -1
+ if len(buf) < pos + self.getLength():
+ msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
+ mylog.error(msg)
+ self.clear()
+ self.PlayerID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FamilyID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.JoinTime, pos = CommFunc.ReadDWORD(buf, pos)
+ self.PlayerName, pos = CommFunc.ReadString(buf, pos, 33)
+ self.LV, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Job, pos = CommFunc.ReadDWORD(buf, pos)
+ self.RealmLV, pos = CommFunc.ReadBYTE(buf, pos)
+ self.Face, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FacePic, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FightPower, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FightPowerEx, pos = CommFunc.ReadDWORD(buf, pos)
+ self.ServerID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.OffTime, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FmLV, pos = CommFunc.ReadBYTE(buf, pos)
+ self.ContribTotal, pos = CommFunc.ReadDWORD(buf, pos)
+ self.ContribWeek, pos = CommFunc.ReadDWORD(buf, pos)
+ return self.getLength()
+
+
+ def getBuffer(self):
+ buf = create_string_buffer(self.getLength())
+ memmove(addressof(buf), addressof(self), self.getLength())
+ return string_at(addressof(buf), self.getLength())
+
+ def getLength(self):
+ return sizeof(tagDBFamilyMem)
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'PlayerID'] = self.PlayerID
+ rec[u'FamilyID'] = self.FamilyID
+ rec[u'JoinTime'] = self.JoinTime
+ rec[u'PlayerName'] = fix_incomingText(self.PlayerName)
+ rec[u'LV'] = self.LV
+ rec[u'Job'] = self.Job
+ rec[u'RealmLV'] = self.RealmLV
+ rec[u'Face'] = self.Face
+ rec[u'FacePic'] = self.FacePic
+ rec[u'FightPower'] = self.FightPower
+ rec[u'FightPowerEx'] = self.FightPowerEx
+ rec[u'ServerID'] = self.ServerID
+ rec[u'OffTime'] = self.OffTime
+ rec[u'FmLV'] = self.FmLV
+ rec[u'ContribTotal'] = self.ContribTotal
+ rec[u'ContribWeek'] = self.ContribWeek
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.PlayerID = rec.get(u'PlayerID', 0)
+ self.FamilyID = rec.get(u'FamilyID', 0)
+ self.JoinTime = rec.get(u'JoinTime', 0)
+ self.PlayerName = fix_outgoingText(rec.get(u'PlayerName', u''))
+ self.LV = rec.get(u'LV', 0)
+ self.Job = rec.get(u'Job', 0)
+ self.RealmLV = rec.get(u'RealmLV', 0)
+ self.Face = rec.get(u'Face', 0)
+ self.FacePic = rec.get(u'FacePic', 0)
+ self.FightPower = rec.get(u'FightPower', 0)
+ self.FightPowerEx = rec.get(u'FightPowerEx', 0)
+ self.ServerID = rec.get(u'ServerID', 0)
+ self.OffTime = rec.get(u'OffTime', 0)
+ self.FmLV = rec.get(u'FmLV', 0)
+ self.ContribTotal = rec.get(u'ContribTotal', 0)
+ self.ContribWeek = rec.get(u'ContribWeek', 0)
+
+ def adoLoad(self, collection):
+ '''使用KEY查找并读取'''
+ resultCollection = collection.find({'PlayerID':self.PlayerID})
+
+ if resultCollection.count() <= 0:
+ return False
+ #由于是KEY查找，所有如果存在就只有一条记录
+ rec = resultCollection[0]
+ #读取数据
+ self.readRecord(rec)
+ return True
+
+
+ def adoInsert(self, collection):
+ '''执行插入'''
+
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.insert(rec, False, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+
+ def adoUpdate(self, collection):
+ '''执行更新'''
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.update({'PlayerID':self.PlayerID}, {'$set':rec}, False, False, True, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_153, 'Update failed!PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+
+ def adoUpdateEx(self, collection, spec):
+ '''执行更新'''
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.update(spec, {'$set':rec}, False, False, True, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+
+ def adoCheckUpdate(self, collection):
+ '''根据情况执行插入或更新'''
+ resultCollection = collection.find({'PlayerID':self.PlayerID})
+
+ if resultCollection.count() <= 0:
+ return self.adoInsert(collection)
+ return self.adoUpdate(collection)
+
+
+ def adoCheckUpdateEx(self, collection, spec):
+ '''根据情况执行插入或更新'''
+ resultCollection = collection.find(spec)
+
+ if resultCollection.count() <= 0:
+ return self.adoInsert(collection)
+ return self.adoUpdateEx(collection, spec)
+
+
+ def getAdoRecords(self, resultCollection):
+ '''查询结果打包成二进制流'''
+ result = ''
+ result = CommFunc.WriteDWORD(result, resultCollection.count())
+ for rec in resultCollection:
+ self.readRecord(rec)
+ result += self.getBuffer()
+ return result
+
+
+ def adoQueryIndex(self, collection):
+ '''用索引字段查找'''
+ resultCollection = collection.find({'PlayerID':self.PlayerID})
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryCustom(self, collection, queryDict):
+ '''自定义查询'''
+ resultCollection = collection.find(queryDict)
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryAll(self, collection):
+ '''查询所有'''
+ resultCollection = collection.find()
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoDeleteByIndex(self, collection):
+ '''根据索引删除'''
+ trycnt = 0
+ while(True):
+ try:
+ collection.remove({'PlayerID':self.PlayerID})
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+ addADOExceptionCount()
+ mylog.info("%s.%s:PlayerID = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.PlayerID))
+ msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.PlayerID = %s, error = %s, trycnt = %d'%(self.PlayerID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+ def outputString(self):
+ output = '''// 家族成员表 #tagDBFamilyMem:
+ PlayerID = %s,
+ FamilyID = %s,
+ JoinTime = %s,
+ PlayerName = %s,
+ LV = %s,
+ Job = %s,
+ RealmLV = %s,
+ Face = %s,
+ FacePic = %s,
+ FightPower = %s,
+ FightPowerEx = %s,
+ ServerID = %s,
+ OffTime = %s,
+ FmLV = %s,
+ ContribTotal = %s,
+ ContribWeek = %s,
+ ADOResult = %s,
+ '''%(
+ self.PlayerID,
+ self.FamilyID,
+ self.JoinTime,
+ self.PlayerName,
+ self.LV,
+ self.Job,
+ self.RealmLV,
+ self.Face,
+ self.FacePic,
+ self.FightPower,
+ self.FightPowerEx,
+ self.ServerID,
+ self.OffTime,
+ self.FmLV,
+ self.ContribTotal,
+ self.ContribWeek,
+ self.ADOResult,
+ )
+ return output
+
+ def dumpString(self):
+ output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
+ self.PlayerID,
+ self.FamilyID,
+ self.JoinTime,
+ self.PlayerName,
+ self.LV,
+ self.Job,
+ self.RealmLV,
+ self.Face,
+ self.FacePic,
+ self.FightPower,
+ self.FightPowerEx,
+ self.ServerID,
+ self.OffTime,
+ self.FmLV,
+ self.ContribTotal,
+ self.ContribWeek,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetPlayerName(self,Str):
+ if len(Str)<=33:
+ self.PlayerName = Str
+ else:
+ self.PlayerName = Str[:33]
+
+
+# 家族行为表 #tagDBFamilyAction
+class tagDBFamilyAction(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('FamilyID', ctypes.c_ulong),
+ ('ActionType', ctypes.c_ubyte),
+ ('Name', ctypes.c_char * 33),
+ ('Time', ctypes.c_ulong),
+ ('Value1', ctypes.c_ulong),
+ ('Value2', ctypes.c_ulong),
+ ('Value3', ctypes.c_ulong),
+ ('Value4', ctypes.c_ulong),
+ ('Value5', ctypes.c_ulong),
+ ('Value6', ctypes.c_ulong),
+ ('DataLen', ctypes.c_ushort),
+ ('Data', ctypes.c_char_p),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+ def clear(self):
+ self.FamilyID = 0
+ self.ActionType = 0
+ self.Name = ''
+ self.Time = 0
+ self.Value1 = 0
+ self.Value2 = 0
+ self.Value3 = 0
+ self.Value4 = 0
+ self.Value5 = 0
+ self.Value6 = 0
+ self.DataLen = 0
+ self.Data = ''
+
+ def readData(self, buf, pos = 0, length = 0):
+ if not pos <= length:
+ msg = error.formatMsg('error', error.ERROR_NO_148, '(pos = %s) > (length = %s)'%(pos, length))
+ mylog.error(msg)
+ return -1
+ if len(buf) < pos + self.getLength():
+ msg = error.formatMsg('error', error.ERROR_NO_149, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
+ mylog.error(msg)
+ self.clear()
+ self.FamilyID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.ActionType, pos = CommFunc.ReadBYTE(buf, pos)
+ self.Name, pos = CommFunc.ReadString(buf, pos, 33)
+ self.Time, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value1, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value2, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value3, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value4, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value5, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Value6, pos = CommFunc.ReadDWORD(buf, pos)
+ self.DataLen, pos = CommFunc.ReadWORD(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.DataLen)
+ self.Data = ctypes.c_char_p(tmp)
+ return self.getLength()
+
+ def getBuffer(self):
+ buf = ''
+ buf = CommFunc.WriteDWORD(buf, self.FamilyID)
+ buf = CommFunc.WriteBYTE(buf, self.ActionType)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.Name)
+ buf = CommFunc.WriteDWORD(buf, self.Time)
+ buf = CommFunc.WriteDWORD(buf, self.Value1)
+ buf = CommFunc.WriteDWORD(buf, self.Value2)
+ buf = CommFunc.WriteDWORD(buf, self.Value3)
+ buf = CommFunc.WriteDWORD(buf, self.Value4)
+ buf = CommFunc.WriteDWORD(buf, self.Value5)
+ buf = CommFunc.WriteDWORD(buf, self.Value6)
+ buf = CommFunc.WriteWORD(buf, self.DataLen)
+ buf = CommFunc.WriteString(buf, self.DataLen, self.Data)
+ return buf
+
+ def getLength(self):
+ length = 0
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_char) * 33
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ushort)
+ length += self.DataLen
+ return length
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'FamilyID'] = self.FamilyID
+ rec[u'ActionType'] = self.ActionType
+ rec[u'Name'] = fix_incomingText(self.Name)
+ rec[u'Time'] = self.Time
+ rec[u'Value1'] = self.Value1
+ rec[u'Value2'] = self.Value2
+ rec[u'Value3'] = self.Value3
+ rec[u'Value4'] = self.Value4
+ rec[u'Value5'] = self.Value5
+ rec[u'Value6'] = self.Value6
+ rec[u'DataLen'] = self.DataLen
+ rec[u'Data'] = fix_incomingText(self.Data)
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.FamilyID = rec.get(u'FamilyID', 0)
+ self.ActionType = rec.get(u'ActionType', 0)
+ self.Name = fix_outgoingText(rec.get(u'Name', u''))
+ self.Time = rec.get(u'Time', 0)
+ self.Value1 = rec.get(u'Value1', 0)
+ self.Value2 = rec.get(u'Value2', 0)
+ self.Value3 = rec.get(u'Value3', 0)
+ self.Value4 = rec.get(u'Value4', 0)
+ self.Value5 = rec.get(u'Value5', 0)
+ self.Value6 = rec.get(u'Value6', 0)
+ self.DataLen = rec.get(u'DataLen', 0)
+ self.Data = fix_outgoingText(rec.get(u'Data', u''))
+
+#Can not implement adoLoadStr method:No key defined!
+
+ def adoInsert(self, collection):
+ '''执行插入'''
+
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.insert(rec, False, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_152, 'Insert failed!FamilyID = %s, error = %s, trycnt = %d'%(self.FamilyID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+#Can not implement adoUpdateStr method:No key defined!
+
+ def adoUpdateEx(self, collection, spec):
+ '''执行更新'''
+ trycnt = 0
+ rec = self.getRecord()
+ while(True):
+ try:
+ collection.update(spec, {'$set':rec}, False, False, True, True)
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+ addADOExceptionCount()
+ mylog.info("%s.%s:rec = %s"%(self.__class__.__name__, inspect.stack()[0][3], rec))
+ msg = error.formatMsg('error', error.ERROR_NO_154, 'Update failed!FamilyID = %s, error = %s, trycnt = %d'%(self.FamilyID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+#Can not implement adoCheckUpdateStr method:No key defined!
+#Can not implement adoCheckUpdateExStr method:No key defined!
+
+ def getAdoRecords(self, resultCollection):
+ '''查询结果打包成二进制流'''
+ result = ''
+ result = CommFunc.WriteDWORD(result, resultCollection.count())
+ for rec in resultCollection:
+ self.readRecord(rec)
+ result += self.getBuffer()
+ return result
+
+
+ def adoQueryIndex(self, collection):
+ '''用索引字段查找'''
+ resultCollection = collection.find({'FamilyID':self.FamilyID})
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryCustom(self, collection, queryDict):
+ '''自定义查询'''
+ resultCollection = collection.find(queryDict)
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoQueryAll(self, collection):
+ '''查询所有'''
+ resultCollection = collection.find()
+
+ return self.getAdoRecords(resultCollection)
+
+
+ def adoDeleteByIndex(self, collection):
+ '''根据索引删除'''
+ trycnt = 0
+ while(True):
+ try:
+ collection.remove({'FamilyID':self.FamilyID})
+ break
+ except pymongo.errors.OperationFailure, err:
+ if(DBConfig.TryCntOnWriteFail > trycnt):
+ trycnt += 1
+ continue
+ addADOExceptionCount()
+ mylog.info("%s.%s:FamilyID = %s"%(self.__class__.__name__, inspect.stack()[0][3], self.FamilyID))
+ msg = error.formatMsg('error', error.ERROR_NO_155, 'delete failure!self.FamilyID = %s, error = %s, trycnt = %d'%(self.FamilyID, err, trycnt))
+ mylog.error(msg)
+
+ return False
+ return True
+
+ def outputString(self):
+ output = '''// 家族行为表 #tagDBFamilyAction:
+ FamilyID = %s,
+ ActionType = %s,
+ Name = %s,
+ Time = %s,
+ Value1 = %s,
+ Value2 = %s,
+ Value3 = %s,
+ Value4 = %s,
+ Value5 = %s,
+ Value6 = %s,
+ DataLen = %s,
+ Data = %s,
+ ADOResult = %s,
+ '''%(
+ self.FamilyID,
+ self.ActionType,
+ self.Name,
+ self.Time,
+ self.Value1,
+ self.Value2,
+ self.Value3,
+ self.Value4,
+ self.Value5,
+ self.Value6,
+ self.DataLen,
+ self.Data,
+ self.ADOResult,
+ )
+ return output
+
+ def dumpString(self):
+ output = '''%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s\t%1s'''%(
+ self.FamilyID,
+ self.ActionType,
+ self.Name,
+ self.Time,
+ self.Value1,
+ self.Value2,
+ self.Value3,
+ self.Value4,
+ self.Value5,
+ self.Value6,
+ self.DataLen,
+ self.Data,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetName(self,Str):
+ if len(Str)<=33:
+ self.Name = Str
+ else:
+ self.Name = Str[:33]
+
+
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/LogicProcess/UserCtrlDB.py b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/LogicProcess/UserCtrlDB.py
index b776e47..95d7abf 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/LogicProcess/UserCtrlDB.py
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/LogicProcess/UserCtrlDB.py
@@ -18,6 +18,7 @@
from MangoDBCommon import (getADOExceptionCount, getSIDErrorCnt, addADOExceptionCount, seq, fix_outgoingText, fix_incomingText)
from ServerClientShareDefine import *
import ConfigParser
+import IpyGameDataPY
#import IPY_GameWorld
#from Config import (DBConfig,)
DBConfig = __import__('Config.DBConfig')
@@ -479,19 +480,19 @@
return True
#GameServer保存数据
- if requestType == CommonDefine.gstSaveGameServerData:
- oFuncGrade = self.GetFuncGrade("gstSaveGameServerData")
- oFuncGrade.Start()
- self.onSaveGameServerData(db, pack)
- oFuncGrade.End()
- return True
+ #if requestType == CommonDefine.gstSaveGameServerData:
+ # oFuncGrade = self.GetFuncGrade("gstSaveGameServerData")
+ # oFuncGrade.Start()
+ # self.onSaveGameServerData(db, pack)
+ # oFuncGrade.End()
+ # return True
#GameServer读取玩家数据
- if requestType == CommonDefine.gstGetGameServerPlayerData:
- oFuncGrade = self.GetFuncGrade("gstGetGameServerPlayerData")
- oFuncGrade.Start()
- self.onGetGameServerPlayerData(db, pack)
- oFuncGrade.End()
- return True
+ #if requestType == CommonDefine.gstGetGameServerPlayerData:
+ # oFuncGrade = self.GetFuncGrade("gstGetGameServerPlayerData")
+ # oFuncGrade.Start()
+ # self.onGetGameServerPlayerData(db, pack)
+ # oFuncGrade.End()
+ # return True
#GameServer读取GM命令列表
if requestType == CommonDefine.gstGMCommandListReq:
oFuncGrade = self.GetFuncGrade("gstGMCommandListReq")
@@ -2394,8 +2395,9 @@
msg = error.formatMsg('error', error.ERROR_NO_65, 'PlayerID Dispatch failed!accid = %s'%createPlayer.AccID)
mylog.error(msg)
return 0, disDataBaseError, createPlayer.AccID, ''
+ nameFormat = IpyGameDataPY.GetFuncCfg("CreateRole", 1)
createPlayer.PlayerID = newPlayerID
- createPlayer.PlayerName = "role" + str(newPlayerID)
+ createPlayer.PlayerName = (nameFormat % newPlayerID).decode('gbk').encode(DBConfig.encoding)
#校验通过，往数据库中插入角色
mylog.debug('Before insert role!accid = %s, PlayerName = %s'%(createPlayer.AccID, createPlayer.PlayerName))
if not createPlayer.adoInsertC(collection):
@@ -3348,7 +3350,100 @@
#已废除
pass
+ def readGameWorldData(self):
+ '''读取服务器公共数据
+ 【注】：新建的表往后添加
+ '''
+ db = self.db
+
+ data = ''
+ mylog.info('readGameWorldData Start...')
+
+ collection = db[UCN_DBEventTrig]
+ DBEventTrig = DataServerPlayerData.tagDBEventTrig()
+ data += DBEventTrig.adoQueryAll(collection)
+ mylog.info("tagDBEventTrig ok")
+
+ collection = db[UCN_DBPlayerViewCache]
+ DBPlayerViewCache = DataServerPlayerData.tagDBPlayerViewCache()
+ data += DBPlayerViewCache.adoQueryAll(collection)
+ mylog.info("tagDBPlayerViewCache ok")
+
+ collection = db[UCN_DBBillboard]
+ DBBillboard = DataServerPlayerData.tagDBBillboard()
+ data += DBBillboard.adoQueryAll(collection)
+ mylog.info("tagDBBillboard ok")
+
+ collection = db[UCN_DBMailServer]
+ DBMailServer = DataServerPlayerData.tagDBMailServer()
+ data += DBMailServer.adoQueryAll(collection)
+ mylog.info("tagDBMailServer ok")
+
+ collection = db[UCN_DBMailPlayerRec]
+ DBMailPlayerRec = DataServerPlayerData.tagDBMailPlayerRec()
+ data += DBMailPlayerRec.adoQueryAll(collection)
+ mylog.info("tagDBMailPlayerRec ok")
+
+ collection = db[UCN_DBMailPersonal]
+ DBMailPersonal = DataServerPlayerData.tagDBMailPersonal()
+ data += DBMailPersonal.adoQueryAll(collection)
+ mylog.info("tagDBMailPersonal ok")
+
+ collection = db[UCN_DBMailItem]
+ DBMailItem = DataServerPlayerData.tagDBMailItem()
+ data += DBMailItem.adoQueryAll(collection)
+ mylog.info("tagDBMailItem ok")
+
+ collection = db[UCN_DBFamily]
+ DBFamily = DataServerPlayerData.tagDBFamily()
+ data += DBFamily.adoQueryAll(collection)
+ mylog.info("tagDBFamily ok")
+
+ collection = db[UCN_DBFamilyMem]
+ DBFamilyMem = DataServerPlayerData.tagDBFamilyMem()
+ data += DBFamilyMem.adoQueryAll(collection)
+ mylog.info("tagDBFamilyMem ok")
+
+ collection = db[UCN_DBFamilyAction]
+ DBFamilyAction = DataServerPlayerData.tagDBFamilyAction()
+ data += DBFamilyAction.adoQueryAll(collection)
+ mylog.info("tagDBFamilyAction ok")
+
+ mylog.info('readGameWorldData len:%s' % len(data))
+ return data
+
+ def saveGameWorldData(self, saveData):
+ ## 保存服务器公共数据
+
+ db = self.db
+ dataLen = len(saveData)
+ mylog.info('saveGameWorldData, len = %s!saving...'%dataLen)
+ gameDataReadPos = 0
+ try:
+ gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBEventTrig, DataServerPlayerData.tagDBEventTrig, db)
+ gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBPlayerViewCache, DataServerPlayerData.tagDBPlayerViewCache, db)
+ gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBBillboard, DataServerPlayerData.tagDBBillboard, db)
+ gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBMailServer, DataServerPlayerData.tagDBMailServer, db)
+ gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBMailPlayerRec, DataServerPlayerData.tagDBMailPlayerRec, db)
+ gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBMailPersonal, DataServerPlayerData.tagDBMailPersonal, db)
+ gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBMailItem, DataServerPlayerData.tagDBMailItem, db)
+ gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBFamily, DataServerPlayerData.tagDBFamily, db)
+ gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBFamilyMem, DataServerPlayerData.tagDBFamilyMem, db)
+ gameDataReadPos = self.savegameServerWorldData(saveData, gameDataReadPos, UCN_DBFamilyAction, DataServerPlayerData.tagDBFamilyAction, db)
+
+ mylog.info('saveGameWorldData ok!')
+
+ # 如果是关服中的，设置关服保存数据处理完毕
+ if PyGameData.g_serverClosing:
+ PyGameData.g_closeSaveDataOK = True
+ except:
+ msg = error.formatMsg('error', error.ERROR_NO_81, '%s'%traceback.format_exc())
+ mylog.error(msg)
+
+ return
+
def onGetGameServerPlayerData(self, db, pack):
+ ## 废弃，改为使用 readGameWorldData
data = ''
#玩家打包数据表较大，不同步GameServer，由db自己管理
@@ -3735,6 +3830,7 @@
self.saveGameServerGameData(db, pack, pack.getBuffer(), pos, type, needReturn)
def saveGameServerGameData(self, db, pack, data, pos, saveType, needReturn):
+ ##废弃，改为使用 saveGameWorldData
if saveType == CommonDefine.dgGameServerCrashData:
#FileLog.getLogger('GameServerDataRestoreLog').info('解析崩溃数据中。。。')
#tagGDGameServerGameData
diff --git a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/index/GameUser.txt b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/index/GameUser.txt
index feabbcd..f183fb0 100644
--- a/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/index/GameUser.txt
+++ b/ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/index/GameUser.txt
@@ -1,110 +1,46 @@
#数据库的索引字典
{
- 'tagDBPyXMZZ': #表名
- {
- 'PlayerID_1': #索引名
+ 'tagDBMailItem': #表名
{
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
- 'tagDBPySealDemonRecord': #表名
- {
- 'PlayerID_1': #索引名
+ 'GUID_1': #索引名
+ {
+ 'key':[('GUID', 1)] #索引的字典和递增(1)或递减(-1)
+ }
+ },
+
+ 'tagDBMailPersonal': #表名
{
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
- 'tagDBPyBossAttention': #表名
- {
- 'PlayerID_1': #索引名
- {
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
- 'tagDBPyBourseItemLastPrice': #表名
- {
- 'ItemID_1': #索引名
- {
- 'key':[('ItemID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
- 'tagDBPyBourseRecord': #表名
- {
- 'PlayerID_1': #索引名
- {
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
- 'tagDBPyFamilyStoreItem': #表名
- {
- 'FamilyID_1': #索引名
- {
- 'key':[('FamilyID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
- 'tagDBPlayerInfoLog': #表名
- {
- 'AccID_1': #索引名
- {
- 'key':[('AccID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
- 'tagDBGateServerIP': #表名
- {
- 'LineID_1': #索引名
- {
- 'key':[('LineID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
- 'tagDBPyPlayerFriend': #表名
- {
- 'PlayerID_1': #索引名
- {
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
- 'tagPlayerEnemy': #表名
- {
- 'PlayerID_1': #索引名
- {
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
- 'tagDBPyPlayerBlack': #表名
- {
- 'PlayerID_1': #索引名
- {
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
- 'tagDBPyPlayerContacts': #表名
- {
- 'PlayerID_1': #索引名
- {
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
- 'tagPersonalSocial': #表名
- {
'PlayerID_1': #索引名
{
- 'unique':True,
'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- },
+ }
+ },
+
+ 'tagDBFamilyMem': #表名
+ {
+ 'PlayerID_1': #索引名
+ {
+ 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
+ }
+ },
+
+ 'tagDBPlayerViewCache': #表名
+ {
+ 'PlayerID_1': #索引名
+ {
+ 'unique':True,
+ 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
+ }
},
+ 'tagDBMapServerInfo': #表名
+ {
+ 'LogIndex_1': #索引名
+ {
+ 'key':[('LogIndex', 1)] #索引的字典和递增(1)或递减(-1)
+ }
+ },
+
'tagRoleMission': #表名
{
'PlayerID_1': #索引名
@@ -235,197 +171,6 @@
}
},
-'tagDBPlayerRecall': #表名
- {
- 'PlayerID_1': #索引名
- {
- 'unique':True,
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBVsReward': #表名
- {
- 'PlayerID_1': #索引名
- {
- 'unique':True,
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagAccCoins': #表名
- {
- 'AccID_1': #索引名
- {
- 'unique':True,
- 'key':[('AccID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagAccIDSendPrize': #表名
- {
- 'CheckValue_1': #索引名
- {
- 'unique':True,
- 'key':[('CheckValue', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBBillboard': #表名
- {
- 'Type_1_ID_1': #索引名
- {
- 'unique':True,
- 'key':[('Type', 1), ('ID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBCountryFamilyWarRequest': #表名
- {
- 'FamilyID_1': #索引名
- {
- 'unique':True,
- 'key':[('FamilyID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBCountryFamilyWarResult': #表名
- {
- 'FamilyID_1': #索引名
- {
- 'unique':True,
- 'key':[('FamilyID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBCountryInfo': #表名
- {
- 'CountryID_1': #索引名
- {
- 'unique':True,
- 'key':[('CountryID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBGameServerEventTrig': #表名
- {
- 'EventID_1': #索引名
- {
- 'unique':True,
- 'key':[('EventID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBGMCommandList': #表名
- {
- 'CmdIndex_1': #索引名
- {
- 'unique':True,
- 'key':[('CmdIndex', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBGoldOrderForm': #表名
- {
- 'PlayerID_1': #索引名
- {
- 'unique':True,
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBImpeach': #表名
- {
- 'ImpeachIndex_1': #索引名
- {
- 'unique':True,
- 'key':[('ImpeachIndex', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBMailList': #表名
- {
- 'MailID_1': #索引名
- {
- 'unique':True,
- 'key':[('MailID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBMapServerInfo': #表名
- {
- 'LogIndex_1': #索引名
- {
- 'key':[('LogIndex', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBOverdueGoldOrderForm': #表名
- {
- 'PlayerID_1': #索引名
- {
- 'unique':True,
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagDBPlayerChangeNameLog': #表名
- {
- 'PlayerID_1': #索引名
- {
- 'unique':True,
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagExpiation': #表名
- {
- 'AccID_1': #索引名
- {
- 'key':[('AccID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagFamilyInfo': #表名
- {
- 'ID_1': #索引名
- {
- 'unique':True,
- 'key':[('ID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagGameWorldEvent': #表名
- {
- 'EventID_1': #索引名
- {
- 'unique':True,
- 'key':[('EventID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagPetExpiation': #表名
- {
- 'ExpiationIndex_1': #索引名
- {
- 'unique':True,
- 'key':[('ExpiationIndex', 1)] #索引的字典和递增(1)或递减(-1)
- },
- 'AccID_1': #索引名
- {
- 'key':[('AccID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
-'tagPlayerFamily': #表名
- {
- 'PlayerID_1': #索引名
- {
- 'unique':True,
- 'key':[('PlayerID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- },
-
'tagRolePet': #表名
{
'PlayerID_1': #索引名
@@ -437,13 +182,4 @@
'key':[('PetID', 1)] #索引的字典和递增(1)或递减(-1)
}
},
-
-'tagPlayerTeamTable': #表名
- {
- 'TeamID_1': #索引名
- {
- 'unique':True,
- 'key':[('TeamID', 1)] #索引的字典和递增(1)或递减(-1)
- }
- }
}
--
Gitblit v1.8.0