From d58b53c40113b8956c69324029f411784b01616f Mon Sep 17 00:00:00 2001
From: hch <305670599@qq.com>
Date: 星期二, 12 三月 2019 14:46:41 +0800
Subject: [PATCH] 6328 【后端】优化代码eval -- 玩家缓存数据提取常用字段 等级和最后一次发送时间
---
Tool/数据库/ChangeAccount/Collections/DataServerPlayerData.py | 1080 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 1,077 insertions(+), 3 deletions(-)
diff --git "a/Tool/\346\225\260\346\215\256\345\272\223/ChangeAccount/Collections/DataServerPlayerData.py" "b/Tool/\346\225\260\346\215\256\345\272\223/ChangeAccount/Collections/DataServerPlayerData.py"
index 549e0c8..67a0650 100644
--- "a/Tool/\346\225\260\346\215\256\345\272\223/ChangeAccount/Collections/DataServerPlayerData.py"
+++ "b/Tool/\346\225\260\346\215\256\345\272\223/ChangeAccount/Collections/DataServerPlayerData.py"
@@ -18338,6 +18338,7 @@
('Gold', ctypes.c_ulong),
('GoldPaper', ctypes.c_ulong),
('Silver', ctypes.c_ulong),
+ ('ServerID', ctypes.c_ulong),
('ADOResult', ctypes.c_ulong),
]
@@ -18356,6 +18357,7 @@
self.Gold = 0
self.GoldPaper = 0
self.Silver = 0
+ self.ServerID = 0
def readData(self, buf, pos = 0, length = 0):
if not pos <= length:
@@ -18377,6 +18379,7 @@
self.Gold, pos = CommFunc.ReadDWORD(buf, pos)
self.GoldPaper, pos = CommFunc.ReadDWORD(buf, pos)
self.Silver, pos = CommFunc.ReadDWORD(buf, pos)
+ self.ServerID, pos = CommFunc.ReadDWORD(buf, pos)
return self.getLength()
def getBuffer(self):
@@ -18391,6 +18394,7 @@
buf = CommFunc.WriteDWORD(buf, self.Gold)
buf = CommFunc.WriteDWORD(buf, self.GoldPaper)
buf = CommFunc.WriteDWORD(buf, self.Silver)
+ buf = CommFunc.WriteDWORD(buf, self.ServerID)
return buf
def getLength(self):
@@ -18402,6 +18406,7 @@
length += sizeof(ctypes.c_ubyte)
length += sizeof(ctypes.c_ulong)
length += self.TextLen
+ length += sizeof(ctypes.c_ulong)
length += sizeof(ctypes.c_ulong)
length += sizeof(ctypes.c_ulong)
length += sizeof(ctypes.c_ulong)
@@ -18420,6 +18425,7 @@
rec[u'Gold'] = self.Gold
rec[u'GoldPaper'] = self.GoldPaper
rec[u'Silver'] = self.Silver
+ rec[u'ServerID'] = self.ServerID
return rec
def readRecord(self, rec):
@@ -18434,6 +18440,7 @@
self.Gold = rec.get(u'Gold', 0)
self.GoldPaper = rec.get(u'GoldPaper', 0)
self.Silver = rec.get(u'Silver', 0)
+ self.ServerID = rec.get(u'ServerID', 0)
#Can not implement adoLoadStr method:No key defined!
#Can not implement adoInsertStr method:No key defined!
@@ -18479,6 +18486,7 @@
Gold = %s,
GoldPaper = %s,
Silver = %s,
+ ServerID = %s,
ADOResult = %s,
'''%(
self.GUID,
@@ -18491,12 +18499,13 @@
self.Gold,
self.GoldPaper,
self.Silver,
+ self.ServerID,
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'''%(
+ 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.CreateTime,
self.LimitTime,
@@ -18507,6 +18516,7 @@
self.Gold,
self.GoldPaper,
self.Silver,
+ self.ServerID,
)
return output
@@ -18530,8 +18540,6 @@
self.LimitTime = Str[:30]
-
-
#补偿物品个人领取表 #tagDBPersonalCompensation
class tagDBPersonalCompensation(Structure):
_pack_ = 1
@@ -18854,6 +18862,7 @@
else:
self.GUID = Str[:40]
+
#玩家数据查看缓存表#tagPlayerViewCache
class tagPlayerViewCache(Structure):
_pack_ = 1
@@ -19120,6 +19129,7 @@
self.PlusData,
)
return output
+
@@ -21309,3 +21319,1067 @@
self.Name = Str[:33]
+# 跨服竞技场PK排行榜 #tagDBCrossPKBillboard
+class tagDBCrossPKBillboard(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('ZoneID', ctypes.c_ubyte),
+ ('SeasonID', ctypes.c_ubyte),
+ ('PlayerID', ctypes.c_ulong),
+ ('PlayerName', ctypes.c_char * 33),
+ ('Job', ctypes.c_ubyte),
+ ('FightPower', ctypes.c_ulong),
+ ('RealmLV', ctypes.c_ushort),
+ ('PKScore', ctypes.c_ulong),
+ ('DanLV', ctypes.c_ubyte),
+ ('Time', 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_150, '(pos = %s)> (length = %s)'%(pos, length))
+ mylog.error(msg)
+ return -1
+ if len(buf) < pos + self.getLength():
+ msg = error.formatMsg('error', error.ERROR_NO_151, 'len = %s while %s expected!'%(len(buf) - pos, self.getLength()))
+ mylog.error(msg)
+ return -1
+ self.clear()
+ memmove(addressof(self), buf[pos:], self.getLength())
+ 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(tagDBCrossPKBillboard)
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'ZoneID'] = self.ZoneID
+ rec[u'SeasonID'] = self.SeasonID
+ rec[u'PlayerID'] = self.PlayerID
+ rec[u'PlayerName'] = fix_incomingText(self.PlayerName)
+ rec[u'Job'] = self.Job
+ rec[u'FightPower'] = self.FightPower
+ rec[u'RealmLV'] = self.RealmLV
+ rec[u'PKScore'] = self.PKScore
+ rec[u'DanLV'] = self.DanLV
+ rec[u'Time'] = self.Time
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.ZoneID = rec.get(u'ZoneID', 0)
+ self.SeasonID = rec.get(u'SeasonID', 0)
+ self.PlayerID = rec.get(u'PlayerID', 0)
+ self.PlayerName = fix_outgoingText(rec.get(u'PlayerName', u''))
+ self.Job = rec.get(u'Job', 0)
+ self.FightPower = rec.get(u'FightPower', 0)
+ self.RealmLV = rec.get(u'RealmLV', 0)
+ self.PKScore = rec.get(u'PKScore', 0)
+ self.DanLV = rec.get(u'DanLV', 0)
+ self.Time = rec.get(u'Time', 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 = '''// 跨服竞技场PK排行榜 #tagDBCrossPKBillboard:
+ ZoneID = %s,
+ SeasonID = %s,
+ PlayerID = %s,
+ PlayerName = %s,
+ Job = %s,
+ FightPower = %s,
+ RealmLV = %s,
+ PKScore = %s,
+ DanLV = %s,
+ Time = %s,
+ ADOResult = %s,
+ '''%(
+ self.ZoneID,
+ self.SeasonID,
+ self.PlayerID,
+ self.PlayerName,
+ self.Job,
+ self.FightPower,
+ self.RealmLV,
+ self.PKScore,
+ self.DanLV,
+ self.Time,
+ 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.ZoneID,
+ self.SeasonID,
+ self.PlayerID,
+ self.PlayerName,
+ self.Job,
+ self.FightPower,
+ self.RealmLV,
+ self.PKScore,
+ self.DanLV,
+ self.Time,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetPlayerName(self,Str):
+ if len(Str)<=33:
+ self.PlayerName = Str
+ else:
+ self.PlayerName = Str[:33]
+
+
+# 跨服竞技场未通知玩家的比赛结果表 #tagDBCrossPKUnNotifyOverInfo
+class tagDBCrossPKUnNotifyOverInfo(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('ZoneID', ctypes.c_ubyte),
+ ('SeasonID', ctypes.c_ubyte),
+ ('RoomID', ctypes.c_ushort),
+ ('TimeStr', ctypes.c_char * 19),
+ ('OverType', ctypes.c_ubyte),
+ ('PlayerID', ctypes.c_ulong),
+ ('WinnerID', ctypes.c_ulong),
+ ('RoundWinnerLen', ctypes.c_ubyte),
+ ('RoundWinnerInfo', ctypes.c_char_p),
+ ('PKScore', ctypes.c_ulong),
+ ('DanLV', ctypes.c_ubyte),
+ ('CWinCount', ctypes.c_ushort),
+ ('AddScore', ctypes.c_ushort),
+ ('TagPlayerID', ctypes.c_ulong),
+ ('TagPlayerName', ctypes.c_char * 33),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+ def clear(self):
+ self.ZoneID = 0
+ self.SeasonID = 0
+ self.RoomID = 0
+ self.TimeStr = ''
+ self.OverType = 0
+ self.PlayerID = 0
+ self.WinnerID = 0
+ self.RoundWinnerLen = 0
+ self.RoundWinnerInfo = ''
+ self.PKScore = 0
+ self.DanLV = 0
+ self.CWinCount = 0
+ self.AddScore = 0
+ self.TagPlayerID = 0
+ self.TagPlayerName = ''
+
+ 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.ZoneID, pos = CommFunc.ReadBYTE(buf, pos)
+ self.SeasonID, pos = CommFunc.ReadBYTE(buf, pos)
+ self.RoomID, pos = CommFunc.ReadWORD(buf, pos)
+ self.TimeStr, pos = CommFunc.ReadString(buf, pos, 19)
+ self.OverType, pos = CommFunc.ReadBYTE(buf, pos)
+ self.PlayerID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.WinnerID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.RoundWinnerLen, pos = CommFunc.ReadBYTE(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.RoundWinnerLen)
+ self.RoundWinnerInfo = ctypes.c_char_p(tmp)
+ self.PKScore, pos = CommFunc.ReadDWORD(buf, pos)
+ self.DanLV, pos = CommFunc.ReadBYTE(buf, pos)
+ self.CWinCount, pos = CommFunc.ReadWORD(buf, pos)
+ self.AddScore, pos = CommFunc.ReadWORD(buf, pos)
+ self.TagPlayerID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.TagPlayerName, pos = CommFunc.ReadString(buf, pos, 33)
+ return self.getLength()
+
+ def getBuffer(self):
+ buf = ''
+ buf = CommFunc.WriteBYTE(buf, self.ZoneID)
+ buf = CommFunc.WriteBYTE(buf, self.SeasonID)
+ buf = CommFunc.WriteWORD(buf, self.RoomID)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 19, self.TimeStr)
+ buf = CommFunc.WriteBYTE(buf, self.OverType)
+ buf = CommFunc.WriteDWORD(buf, self.PlayerID)
+ buf = CommFunc.WriteDWORD(buf, self.WinnerID)
+ buf = CommFunc.WriteBYTE(buf, self.RoundWinnerLen)
+ buf = CommFunc.WriteString(buf, self.RoundWinnerLen, self.RoundWinnerInfo)
+ buf = CommFunc.WriteDWORD(buf, self.PKScore)
+ buf = CommFunc.WriteBYTE(buf, self.DanLV)
+ buf = CommFunc.WriteWORD(buf, self.CWinCount)
+ buf = CommFunc.WriteWORD(buf, self.AddScore)
+ buf = CommFunc.WriteDWORD(buf, self.TagPlayerID)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.TagPlayerName)
+ return buf
+
+ def getLength(self):
+ length = 0
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ushort)
+ length += sizeof(ctypes.c_char) * 19
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ubyte)
+ length += self.RoundWinnerLen
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ushort)
+ length += sizeof(ctypes.c_ushort)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_char) * 33
+ return length
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'ZoneID'] = self.ZoneID
+ rec[u'SeasonID'] = self.SeasonID
+ rec[u'RoomID'] = self.RoomID
+ rec[u'TimeStr'] = fix_incomingText(self.TimeStr)
+ rec[u'OverType'] = self.OverType
+ rec[u'PlayerID'] = self.PlayerID
+ rec[u'WinnerID'] = self.WinnerID
+ rec[u'RoundWinnerLen'] = self.RoundWinnerLen
+ rec[u'RoundWinnerInfo'] = fix_incomingText(self.RoundWinnerInfo)
+ rec[u'PKScore'] = self.PKScore
+ rec[u'DanLV'] = self.DanLV
+ rec[u'CWinCount'] = self.CWinCount
+ rec[u'AddScore'] = self.AddScore
+ rec[u'TagPlayerID'] = self.TagPlayerID
+ rec[u'TagPlayerName'] = fix_incomingText(self.TagPlayerName)
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.ZoneID = rec.get(u'ZoneID', 0)
+ self.SeasonID = rec.get(u'SeasonID', 0)
+ self.RoomID = rec.get(u'RoomID', 0)
+ self.TimeStr = fix_outgoingText(rec.get(u'TimeStr', u''))
+ self.OverType = rec.get(u'OverType', 0)
+ self.PlayerID = rec.get(u'PlayerID', 0)
+ self.WinnerID = rec.get(u'WinnerID', 0)
+ self.RoundWinnerLen = rec.get(u'RoundWinnerLen', 0)
+ self.RoundWinnerInfo = fix_outgoingText(rec.get(u'RoundWinnerInfo', u''))
+ self.PKScore = rec.get(u'PKScore', 0)
+ self.DanLV = rec.get(u'DanLV', 0)
+ self.CWinCount = rec.get(u'CWinCount', 0)
+ self.AddScore = rec.get(u'AddScore', 0)
+ self.TagPlayerID = rec.get(u'TagPlayerID', 0)
+ self.TagPlayerName = fix_outgoingText(rec.get(u'TagPlayerName', 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 = '''// 跨服竞技场未通知玩家的比赛结果表 #tagDBCrossPKUnNotifyOverInfo:
+ ZoneID = %s,
+ SeasonID = %s,
+ RoomID = %s,
+ TimeStr = %s,
+ OverType = %s,
+ PlayerID = %s,
+ WinnerID = %s,
+ RoundWinnerLen = %s,
+ RoundWinnerInfo = %s,
+ PKScore = %s,
+ DanLV = %s,
+ CWinCount = %s,
+ AddScore = %s,
+ TagPlayerID = %s,
+ TagPlayerName = %s,
+ ADOResult = %s,
+ '''%(
+ self.ZoneID,
+ self.SeasonID,
+ self.RoomID,
+ self.TimeStr,
+ self.OverType,
+ self.PlayerID,
+ self.WinnerID,
+ self.RoundWinnerLen,
+ self.RoundWinnerInfo,
+ self.PKScore,
+ self.DanLV,
+ self.CWinCount,
+ self.AddScore,
+ self.TagPlayerID,
+ self.TagPlayerName,
+ 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'''%(
+ self.ZoneID,
+ self.SeasonID,
+ self.RoomID,
+ self.TimeStr,
+ self.OverType,
+ self.PlayerID,
+ self.WinnerID,
+ self.RoundWinnerLen,
+ self.RoundWinnerInfo,
+ self.PKScore,
+ self.DanLV,
+ self.CWinCount,
+ self.AddScore,
+ self.TagPlayerID,
+ self.TagPlayerName,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetTimeStr(self,Str):
+ if len(Str)<=19:
+ self.TimeStr = Str
+ else:
+ self.TimeStr = Str[:19]
+
+ def SetTagPlayerName(self,Str):
+ if len(Str)<=33:
+ self.TagPlayerName = Str
+ else:
+ self.TagPlayerName = Str[:33]
+
+
+# 拍卖物品表 #tagDBAuctionItem
+class tagDBAuctionItem(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('ItemGUID', ctypes.c_char * 40),
+ ('PlayerID', ctypes.c_ulong),
+ ('FamilyID', ctypes.c_ulong),
+ ('ItemID', ctypes.c_ulong),
+ ('Count', ctypes.c_ushort),
+ ('AuctionType', ctypes.c_ubyte),
+ ('AddTime', ctypes.c_char * 19),
+ ('BiddingTime', ctypes.c_char * 19),
+ ('BidderID', ctypes.c_ulong),
+ ('BidderName', ctypes.c_char * 33),
+ ('BidderPrice', ctypes.c_ulong),
+ ('ItemType', ctypes.c_ubyte),
+ ('ItemJobLimit', ctypes.c_ubyte),
+ ('ItemClassLV', ctypes.c_ubyte),
+ ('UserDataLen', ctypes.c_ushort),
+ ('UserData', ctypes.c_char_p),
+ ('FamilyPlayerIDLen', ctypes.c_ushort),
+ ('FamilyPlayerIDInfo', ctypes.c_char_p),
+ ('BidderIDLen', ctypes.c_ubyte),
+ ('BidderIDInfo', ctypes.c_char_p),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+ def clear(self):
+ self.ItemGUID = ''
+ self.PlayerID = 0
+ self.FamilyID = 0
+ self.ItemID = 0
+ self.Count = 0
+ self.AuctionType = 0
+ self.AddTime = ''
+ self.BiddingTime = ''
+ self.BidderID = 0
+ self.BidderName = ''
+ self.BidderPrice = 0
+ self.ItemType = 0
+ self.ItemJobLimit = 0
+ self.ItemClassLV = 0
+ self.UserDataLen = 0
+ self.UserData = ''
+ self.FamilyPlayerIDLen = 0
+ self.FamilyPlayerIDInfo = ''
+ self.BidderIDLen = 0
+ self.BidderIDInfo = ''
+
+ 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.ItemGUID, pos = CommFunc.ReadString(buf, pos, 40)
+ self.PlayerID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FamilyID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.ItemID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Count, pos = CommFunc.ReadWORD(buf, pos)
+ self.AuctionType, pos = CommFunc.ReadBYTE(buf, pos)
+ self.AddTime, pos = CommFunc.ReadString(buf, pos, 19)
+ self.BiddingTime, pos = CommFunc.ReadString(buf, pos, 19)
+ self.BidderID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.BidderName, pos = CommFunc.ReadString(buf, pos, 33)
+ self.BidderPrice, pos = CommFunc.ReadDWORD(buf, pos)
+ self.ItemType, pos = CommFunc.ReadBYTE(buf, pos)
+ self.ItemJobLimit, pos = CommFunc.ReadBYTE(buf, pos)
+ self.ItemClassLV, 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)
+ self.FamilyPlayerIDLen, pos = CommFunc.ReadWORD(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.FamilyPlayerIDLen)
+ self.FamilyPlayerIDInfo = ctypes.c_char_p(tmp)
+ self.BidderIDLen, pos = CommFunc.ReadBYTE(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.BidderIDLen)
+ self.BidderIDInfo = ctypes.c_char_p(tmp)
+ return self.getLength()
+
+ def getBuffer(self):
+ buf = ''
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 40, self.ItemGUID)
+ buf = CommFunc.WriteDWORD(buf, self.PlayerID)
+ buf = CommFunc.WriteDWORD(buf, self.FamilyID)
+ buf = CommFunc.WriteDWORD(buf, self.ItemID)
+ buf = CommFunc.WriteWORD(buf, self.Count)
+ buf = CommFunc.WriteBYTE(buf, self.AuctionType)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 19, self.AddTime)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 19, self.BiddingTime)
+ buf = CommFunc.WriteDWORD(buf, self.BidderID)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.BidderName)
+ buf = CommFunc.WriteDWORD(buf, self.BidderPrice)
+ buf = CommFunc.WriteBYTE(buf, self.ItemType)
+ buf = CommFunc.WriteBYTE(buf, self.ItemJobLimit)
+ buf = CommFunc.WriteBYTE(buf, self.ItemClassLV)
+ buf = CommFunc.WriteWORD(buf, self.UserDataLen)
+ buf = CommFunc.WriteString(buf, self.UserDataLen, self.UserData)
+ buf = CommFunc.WriteWORD(buf, self.FamilyPlayerIDLen)
+ buf = CommFunc.WriteString(buf, self.FamilyPlayerIDLen, self.FamilyPlayerIDInfo)
+ buf = CommFunc.WriteBYTE(buf, self.BidderIDLen)
+ buf = CommFunc.WriteString(buf, self.BidderIDLen, self.BidderIDInfo)
+ return buf
+
+ def getLength(self):
+ length = 0
+ length += sizeof(ctypes.c_char) * 40
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ushort)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_char) * 19
+ length += sizeof(ctypes.c_char) * 19
+ 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_ubyte)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ushort)
+ length += self.UserDataLen
+ length += sizeof(ctypes.c_ushort)
+ length += self.FamilyPlayerIDLen
+ length += sizeof(ctypes.c_ubyte)
+ length += self.BidderIDLen
+ return length
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'ItemGUID'] = fix_incomingText(self.ItemGUID)
+ rec[u'PlayerID'] = self.PlayerID
+ rec[u'FamilyID'] = self.FamilyID
+ rec[u'ItemID'] = self.ItemID
+ rec[u'Count'] = self.Count
+ rec[u'AuctionType'] = self.AuctionType
+ rec[u'AddTime'] = fix_incomingText(self.AddTime)
+ rec[u'BiddingTime'] = fix_incomingText(self.BiddingTime)
+ rec[u'BidderID'] = self.BidderID
+ rec[u'BidderName'] = fix_incomingText(self.BidderName)
+ rec[u'BidderPrice'] = self.BidderPrice
+ rec[u'ItemType'] = self.ItemType
+ rec[u'ItemJobLimit'] = self.ItemJobLimit
+ rec[u'ItemClassLV'] = self.ItemClassLV
+ rec[u'UserDataLen'] = self.UserDataLen
+ rec[u'UserData'] = fix_incomingText(self.UserData)
+ rec[u'FamilyPlayerIDLen'] = self.FamilyPlayerIDLen
+ rec[u'FamilyPlayerIDInfo'] = fix_incomingText(self.FamilyPlayerIDInfo)
+ rec[u'BidderIDLen'] = self.BidderIDLen
+ rec[u'BidderIDInfo'] = fix_incomingText(self.BidderIDInfo)
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.ItemGUID = fix_outgoingText(rec.get(u'ItemGUID', u''))
+ self.PlayerID = rec.get(u'PlayerID', 0)
+ self.FamilyID = rec.get(u'FamilyID', 0)
+ self.ItemID = rec.get(u'ItemID', 0)
+ self.Count = rec.get(u'Count', 0)
+ self.AuctionType = rec.get(u'AuctionType', 0)
+ self.AddTime = fix_outgoingText(rec.get(u'AddTime', u''))
+ self.BiddingTime = fix_outgoingText(rec.get(u'BiddingTime', u''))
+ self.BidderID = rec.get(u'BidderID', 0)
+ self.BidderName = fix_outgoingText(rec.get(u'BidderName', u''))
+ self.BidderPrice = rec.get(u'BidderPrice', 0)
+ self.ItemType = rec.get(u'ItemType', 0)
+ self.ItemJobLimit = rec.get(u'ItemJobLimit', 0)
+ self.ItemClassLV = rec.get(u'ItemClassLV', 0)
+ self.UserDataLen = rec.get(u'UserDataLen', 0)
+ self.UserData = fix_outgoingText(rec.get(u'UserData', u''))
+ self.FamilyPlayerIDLen = rec.get(u'FamilyPlayerIDLen', 0)
+ self.FamilyPlayerIDInfo = fix_outgoingText(rec.get(u'FamilyPlayerIDInfo', u''))
+ self.BidderIDLen = rec.get(u'BidderIDLen', 0)
+ self.BidderIDInfo = fix_outgoingText(rec.get(u'BidderIDInfo', 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 = '''// 拍卖物品表 #tagDBAuctionItem:
+ ItemGUID = %s,
+ PlayerID = %s,
+ FamilyID = %s,
+ ItemID = %s,
+ Count = %s,
+ AuctionType = %s,
+ AddTime = %s,
+ BiddingTime = %s,
+ BidderID = %s,
+ BidderName = %s,
+ BidderPrice = %s,
+ ItemType = %s,
+ ItemJobLimit = %s,
+ ItemClassLV = %s,
+ UserDataLen = %s,
+ UserData = %s,
+ FamilyPlayerIDLen = %s,
+ FamilyPlayerIDInfo = %s,
+ BidderIDLen = %s,
+ BidderIDInfo = %s,
+ ADOResult = %s,
+ '''%(
+ self.ItemGUID,
+ self.PlayerID,
+ self.FamilyID,
+ self.ItemID,
+ self.Count,
+ self.AuctionType,
+ self.AddTime,
+ self.BiddingTime,
+ self.BidderID,
+ self.BidderName,
+ self.BidderPrice,
+ self.ItemType,
+ self.ItemJobLimit,
+ self.ItemClassLV,
+ self.UserDataLen,
+ self.UserData,
+ self.FamilyPlayerIDLen,
+ self.FamilyPlayerIDInfo,
+ self.BidderIDLen,
+ self.BidderIDInfo,
+ 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'''%(
+ self.ItemGUID,
+ self.PlayerID,
+ self.FamilyID,
+ self.ItemID,
+ self.Count,
+ self.AuctionType,
+ self.AddTime,
+ self.BiddingTime,
+ self.BidderID,
+ self.BidderName,
+ self.BidderPrice,
+ self.ItemType,
+ self.ItemJobLimit,
+ self.ItemClassLV,
+ self.UserDataLen,
+ self.UserData,
+ self.FamilyPlayerIDLen,
+ self.FamilyPlayerIDInfo,
+ self.BidderIDLen,
+ self.BidderIDInfo,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetItemGUID(self,Str):
+ if len(Str)<=40:
+ self.ItemGUID = Str
+ else:
+ self.ItemGUID = Str[:40]
+
+ def SetAddTime(self,Str):
+ if len(Str)<=19:
+ self.AddTime = Str
+ else:
+ self.AddTime = Str[:19]
+
+ def SetBiddingTime(self,Str):
+ if len(Str)<=19:
+ self.BiddingTime = Str
+ else:
+ self.BiddingTime = Str[:19]
+
+ def SetBidderName(self,Str):
+ if len(Str)<=33:
+ self.BidderName = Str
+ else:
+ self.BidderName = Str[:33]
+
+
+# 拍卖记录表 #tagDBAuctionRecord
+class tagDBAuctionRecord(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('ItemGUID', ctypes.c_char * 40),
+ ('PlayerID', ctypes.c_ulong),
+ ('FamilyID', ctypes.c_ulong),
+ ('RecordType', ctypes.c_ubyte),
+ ('RecordResult', ctypes.c_ubyte),
+ ('RecordTime', ctypes.c_char * 19),
+ ('BidderPrice', ctypes.c_ulong),
+ ('BidderName', ctypes.c_char * 33),
+ ('ItemID', ctypes.c_ulong),
+ ('Count', ctypes.c_ushort),
+ ('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.ItemGUID = ''
+ self.PlayerID = 0
+ self.FamilyID = 0
+ self.RecordType = 0
+ self.RecordResult = 0
+ self.RecordTime = ''
+ self.BidderPrice = 0
+ self.BidderName = ''
+ self.ItemID = 0
+ self.Count = 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.ItemGUID, pos = CommFunc.ReadString(buf, pos, 40)
+ self.PlayerID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.FamilyID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.RecordType, pos = CommFunc.ReadBYTE(buf, pos)
+ self.RecordResult, pos = CommFunc.ReadBYTE(buf, pos)
+ self.RecordTime, pos = CommFunc.ReadString(buf, pos, 19)
+ self.BidderPrice, pos = CommFunc.ReadDWORD(buf, pos)
+ self.BidderName, pos = CommFunc.ReadString(buf, pos, 33)
+ self.ItemID, pos = CommFunc.ReadDWORD(buf, pos)
+ self.Count, pos = CommFunc.ReadWORD(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) * 40, self.ItemGUID)
+ buf = CommFunc.WriteDWORD(buf, self.PlayerID)
+ buf = CommFunc.WriteDWORD(buf, self.FamilyID)
+ buf = CommFunc.WriteBYTE(buf, self.RecordType)
+ buf = CommFunc.WriteBYTE(buf, self.RecordResult)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 19, self.RecordTime)
+ buf = CommFunc.WriteDWORD(buf, self.BidderPrice)
+ buf = CommFunc.WriteString(buf, sizeof(ctypes.c_char) * 33, self.BidderName)
+ buf = CommFunc.WriteDWORD(buf, self.ItemID)
+ buf = CommFunc.WriteWORD(buf, self.Count)
+ 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) * 40
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_ubyte)
+ length += sizeof(ctypes.c_char) * 19
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_char) * 33
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ushort)
+ length += sizeof(ctypes.c_ushort)
+ length += self.UserDataLen
+ return length
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'ItemGUID'] = fix_incomingText(self.ItemGUID)
+ rec[u'PlayerID'] = self.PlayerID
+ rec[u'FamilyID'] = self.FamilyID
+ rec[u'RecordType'] = self.RecordType
+ rec[u'RecordResult'] = self.RecordResult
+ rec[u'RecordTime'] = fix_incomingText(self.RecordTime)
+ rec[u'BidderPrice'] = self.BidderPrice
+ rec[u'BidderName'] = fix_incomingText(self.BidderName)
+ rec[u'ItemID'] = self.ItemID
+ rec[u'Count'] = self.Count
+ rec[u'UserDataLen'] = self.UserDataLen
+ rec[u'UserData'] = fix_incomingText(self.UserData)
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.ItemGUID = fix_outgoingText(rec.get(u'ItemGUID', u''))
+ self.PlayerID = rec.get(u'PlayerID', 0)
+ self.FamilyID = rec.get(u'FamilyID', 0)
+ self.RecordType = rec.get(u'RecordType', 0)
+ self.RecordResult = rec.get(u'RecordResult', 0)
+ self.RecordTime = fix_outgoingText(rec.get(u'RecordTime', u''))
+ self.BidderPrice = rec.get(u'BidderPrice', 0)
+ self.BidderName = fix_outgoingText(rec.get(u'BidderName', u''))
+ self.ItemID = rec.get(u'ItemID', 0)
+ self.Count = rec.get(u'Count', 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 = '''// 拍卖记录表 #tagDBAuctionRecord:
+ ItemGUID = %s,
+ PlayerID = %s,
+ FamilyID = %s,
+ RecordType = %s,
+ RecordResult = %s,
+ RecordTime = %s,
+ BidderPrice = %s,
+ BidderName = %s,
+ ItemID = %s,
+ Count = %s,
+ UserDataLen = %s,
+ UserData = %s,
+ ADOResult = %s,
+ '''%(
+ self.ItemGUID,
+ self.PlayerID,
+ self.FamilyID,
+ self.RecordType,
+ self.RecordResult,
+ self.RecordTime,
+ self.BidderPrice,
+ self.BidderName,
+ self.ItemID,
+ self.Count,
+ self.UserDataLen,
+ 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'''%(
+ self.ItemGUID,
+ self.PlayerID,
+ self.FamilyID,
+ self.RecordType,
+ self.RecordResult,
+ self.RecordTime,
+ self.BidderPrice,
+ self.BidderName,
+ self.ItemID,
+ self.Count,
+ self.UserDataLen,
+ self.UserData,
+ )
+ return output
+
+ #Char数组类型Set接口,使用该接口对此类型数据赋值，防止赋值的数据过长报错
+ def SetItemGUID(self,Str):
+ if len(Str)<=40:
+ self.ItemGUID = Str
+ else:
+ self.ItemGUID = Str[:40]
+
+ def SetRecordTime(self,Str):
+ if len(Str)<=19:
+ self.RecordTime = Str
+ else:
+ self.RecordTime = Str[:19]
+
+ def SetBidderName(self,Str):
+ if len(Str)<=33:
+ self.BidderName = Str
+ else:
+ self.BidderName = Str[:33]
+
+# 拍卖关注表 #tagDBAuctionAttention
+class tagDBAuctionAttention(Structure):
+ _pack_ = 1
+ _fields_ = [
+ ('PlayerID', ctypes.c_ulong),
+ ('AttentionLen', ctypes.c_ubyte),
+ ('AttentionInfo', ctypes.c_char_p),
+ ('ADOResult', ctypes.c_ulong),
+ ]
+
+ def __init__(self):
+ Structure.__init__(self)
+ self.clear()
+
+ def clear(self):
+ self.PlayerID = 0
+ self.AttentionLen = 0
+ self.AttentionInfo = ''
+
+ 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.AttentionLen, pos = CommFunc.ReadBYTE(buf, pos)
+ tmp, pos = CommFunc.ReadString(buf, pos, self.AttentionLen)
+ self.AttentionInfo = ctypes.c_char_p(tmp)
+ return self.getLength()
+
+ def getBuffer(self):
+ buf = ''
+ buf = CommFunc.WriteDWORD(buf, self.PlayerID)
+ buf = CommFunc.WriteBYTE(buf, self.AttentionLen)
+ buf = CommFunc.WriteString(buf, self.AttentionLen, self.AttentionInfo)
+ return buf
+
+ def getLength(self):
+ length = 0
+ length += sizeof(ctypes.c_ulong)
+ length += sizeof(ctypes.c_ubyte)
+ length += self.AttentionLen
+ return length
+
+ def getRecord(self):
+ '''组织存储记录'''
+ rec = {}
+ rec[u'PlayerID'] = self.PlayerID
+ rec[u'AttentionLen'] = self.AttentionLen
+ rec[u'AttentionInfo'] = fix_incomingText(self.AttentionInfo)
+ return rec
+
+ def readRecord(self, rec):
+ '''由于MongoDB读出来是unicode,所有字符串需要进行转换'''
+ self.PlayerID = rec.get(u'PlayerID', 0)
+ self.AttentionLen = rec.get(u'AttentionLen', 0)
+ self.AttentionInfo = fix_outgoingText(rec.get(u'AttentionInfo', 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 = '''// 拍卖关注表 #tagDBAuctionAttention:
+ PlayerID = %s,
+ AttentionLen = %s,
+ AttentionInfo = %s,
+ ADOResult = %s,
+ '''%(
+ self.PlayerID,
+ self.AttentionLen,
+ self.AttentionInfo,
+ self.ADOResult,
+ )
+ return output
+
+ def dumpString(self):
+ output = '''%1s\t%1s\t%1s'''%(
+ self.PlayerID,
+ self.AttentionLen,
+ self.AttentionInfo,
+ )
+ return output
+
--
Gitblit v1.8.0