|  |  | 
 |  |  | import AuctionHouse
 | 
 |  |  | import PlayerAssist
 | 
 |  |  | import PyGameDataStruct
 | 
 |  |  | import IpyGameDataPY
 | 
 |  |  | import PlayerCharm
 | 
 |  |  | import PlayerLove
 | 
 |  |  | import CommFunc
 | 
 |  |  | import time
 | 
 |  |  | 
 | 
 |  |  | def GetSavePyData():
 | 
 |  |  |     pyGameDataMgr = GetPyGameDataManager()
 | 
 |  |  |     result = pyGameDataMgr.GetSaveData()
 | 
 |  |  |     GameWorld.DebugLog("GetSavePyData!! id = %s-%s"%(id(pyGameDataMgr), len(result)))
 | 
 |  |  |     GameWorld.Log("GetSavePyData!! id = %s-%s"%(id(pyGameDataMgr), len(result)))
 | 
 |  |  |     result = binascii.b2a_hex(result)
 | 
 |  |  |     #GameWorld.DebugLog("GetSavePyData!! result = %s-%s"%(result, len(result)))
 | 
 |  |  |     # 字节码在C++转化会发生错误must be string without null bytes, not str,但是可以正常保存,错误会在下次调用便宜接口才会触发
 | 
 |  |  | 
 |  |  |     
 | 
 |  |  |     # 保存数据 存数据库和realtimebackup
 | 
 |  |  |     def GetSaveData(self):
 | 
 |  |  |         PlayerAssist.RemoveOutofdateAssistThanks()
 | 
 |  |  |         savaData = ""
 | 
 |  |  |         cntData = ""
 | 
 |  |  |         cnt = 0
 | 
 |  |  | 
 |  |  |             PlayerAssist.OnSaveAssistThanksData(dbData)
 | 
 |  |  |             savaData += dbData.getBuffer()
 | 
 |  |  |             
 | 
 |  |  |         GameWorld.Log("Save DBAssistThanks count :%s" % cnt)
 | 
 |  |  |         GameWorld.Log("Save DBAssistThanks count :%s len=%s" % (cnt, len(savaData)))
 | 
 |  |  |         return CommFunc.WriteDWORD(cntData, cnt) + savaData
 | 
 |  |  |     
 | 
 |  |  |     # 从数据库载入数据
 | 
 |  |  | 
 |  |  |     
 | 
 |  |  |     def __init__(self):
 | 
 |  |  |         self.allAssistDict = {} # 所有协助 {GUID:tagDBAssist, ...}
 | 
 |  |  |         self.familyAssistDict = {} # 仙盟协助缓存 {familyID:[tagDBAssist, ...], ...}
 | 
 |  |  |         
 | 
 |  |  |         self.playerNoSaveDBAssistDict = {} # 玩家发布的不存库协助 {playerID:[tagDBAssist, ...], ...}
 | 
 |  |  |         self.playerAssistDict = {} # 玩家发布的协助 {playerID:[tagDBAssist, ...], ...}
 | 
 |  |  |         self.playerAssistingDict = {} # 玩家正在协助中的协助,只能存在一条 {playerID:tagDBAssist, ...}
 | 
 |  |  |         return
 | 
 |  |  |     
 | 
 |  |  | 
 |  |  |             cnt += 1
 | 
 |  |  |             savaData += dbData.getBuffer()
 | 
 |  |  |             
 | 
 |  |  |         GameWorld.Log("Save DBAssist count :%s" % cnt)
 | 
 |  |  |         GameWorld.Log("Save DBAssist count :%s len=%s" % (cnt, len(savaData)))
 | 
 |  |  |         return CommFunc.WriteDWORD(cntData, cnt) + savaData
 | 
 |  |  |     
 | 
 |  |  |     # 从数据库载入数据
 | 
 |  |  | 
 |  |  |             PlayerAssist.OnInitAssistData(dbData, 1)
 | 
 |  |  |             
 | 
 |  |  |             self.allAssistDict[dbData.GUID] = dbData
 | 
 |  |  |             familyID = dbData.FamilyID
 | 
 |  |  |             if familyID not in self.familyAssistDict:
 | 
 |  |  |                 self.familyAssistDict[familyID] = []
 | 
 |  |  |             familyAssistList = self.familyAssistDict[familyID]
 | 
 |  |  |             familyAssistList.append(dbData)
 | 
 |  |  |             PlayerID = dbData.PlayerID
 | 
 |  |  |             if PlayerID not in self.playerAssistDict:
 | 
 |  |  |                 self.playerAssistDict[PlayerID] = []
 | 
 |  |  |             playerAssistList = self.playerAssistDict[PlayerID]
 | 
 |  |  |             playerAssistList.append(dbData)
 | 
 |  |  |             
 | 
 |  |  |         return pos
 | 
 |  |  |     
 | 
 |  |  | 
 |  |  |             cnt += 1
 | 
 |  |  |             savaData += dbData.getBuffer()
 | 
 |  |  |             
 | 
 |  |  |         GameWorld.Log("Save PlayerViewCachePy count :%s" % cnt)
 | 
 |  |  |         GameWorld.Log("Save PlayerViewCachePy count :%s len=%s" % (cnt, len(savaData)))
 | 
 |  |  |         return CommFunc.WriteDWORD(cntData, cnt) + savaData
 | 
 |  |  |     
 | 
 |  |  |     # 从数据库载入数据
 | 
 |  |  | 
 |  |  |         cntData = ""
 | 
 |  |  |         cnt = 0
 | 
 |  |  |         
 | 
 |  |  |         unSaveCnt = 0
 | 
 |  |  |         curTime = int(time.time())
 | 
 |  |  |         vaildSeconds = IpyGameDataPY.GetFuncCfg("AuctionHouse", 1) * 3600 * 24
 | 
 |  |  |         for recordDict in [self.myAuctionItemRecordDict, self.myBidItemRecordDict, self.familyAuctionItemRecordDict]:
 | 
 |  |  |             for recordList in recordDict.values():
 | 
 |  |  |                 for dbData in recordList:
 | 
 |  |  |                     if vaildSeconds:
 | 
 |  |  |                         recordTime = GameWorld.ChangeTimeStrToNum(dbData.RecordTime)
 | 
 |  |  |                         if curTime - recordTime > vaildSeconds:
 | 
 |  |  |                             unSaveCnt += 1
 | 
 |  |  |                             continue
 | 
 |  |  |                     cnt += 1
 | 
 |  |  |                     savaData += dbData.getBuffer()
 | 
 |  |  |                     
 | 
 |  |  |         GameWorld.Log("Save AuctionRecord count :%s" % cnt)
 | 
 |  |  |         GameWorld.Log("Save AuctionRecord count :%s len=%s unSaveCnt=%s" % (cnt, len(savaData), unSaveCnt))
 | 
 |  |  |         return CommFunc.WriteDWORD(cntData, cnt) + savaData
 | 
 |  |  |     
 | 
 |  |  |     # 从数据库载入数据
 | 
 |  |  | 
 |  |  |             cnt += 1
 | 
 |  |  |             savaData += dbData.getBuffer()
 | 
 |  |  |             
 | 
 |  |  |         GameWorld.Log("Save AuctionAttention count :%s" % cnt)
 | 
 |  |  |         GameWorld.Log("Save AuctionAttention count :%s len=%s" % (cnt, len(savaData)))
 | 
 |  |  |         return CommFunc.WriteDWORD(cntData, cnt) + savaData
 | 
 |  |  |     
 | 
 |  |  |     # 从数据库载入数据
 | 
 |  |  | 
 |  |  |             cnt += 1
 | 
 |  |  |             savaData += dbData.getBuffer()
 | 
 |  |  |             
 | 
 |  |  |         GameWorld.Log("Save AuctionItem count :%s" % cnt)
 | 
 |  |  |         GameWorld.Log("Save AuctionItem count :%s len=%s" % (cnt, len(savaData)))
 | 
 |  |  |         return CommFunc.WriteDWORD(cntData, cnt) + savaData
 | 
 |  |  |     
 | 
 |  |  |     # 从数据库载入数据
 | 
 |  |  | 
 |  |  | 
 | 
 |  |  | class PyGameDataManager(object):
 | 
 |  |  |     def __init__(self):
 | 
 |  |  |         self.DBPyCoupleManager = PlayerLove.DBPyCoupleManager()
 | 
 |  |  |         self.DBPyUnNotifyLoveGiftRecManager = PlayerLove.DBPyUnNotifyLoveGiftRecManager()
 | 
 |  |  |         self.DBPyCharmValueRecManager = PlayerCharm.DBPyCharmValueRecManager()
 | 
 |  |  |         self.IntimacyManager = PlayerSocial.IntimacyManager()
 | 
 |  |  |         self.CrossPersonalCompensationManager = PlayerCompensation.CrossPersonalCompensationManager()
 | 
 |  |  |         self.CrossBillboardManager = CrossBillboard.CrossBillboardManager()
 | 
 |  |  |         self.PlayerAssistThanksPyManager = PlayerAssistThanksPyManager()
 | 
 |  |  | 
 |  |  | 
 | 
 |  |  |     def GetSaveData(self):
 | 
 |  |  |         buff = ""
 | 
 |  |  |         buff += self.DBPyCoupleManager.GetSaveData()
 | 
 |  |  |         buff += self.DBPyUnNotifyLoveGiftRecManager.GetSaveData()
 | 
 |  |  |         buff += self.DBPyCharmValueRecManager.GetSaveData()
 | 
 |  |  |         buff += self.IntimacyManager.GetSaveData()
 | 
 |  |  |         buff += self.CrossPersonalCompensationManager.GetSaveData()
 | 
 |  |  |         buff += self.CrossBillboardManager.GetSaveData()
 | 
 |  |  |         buff += self.PlayerAssistThanksPyManager.GetSaveData()
 | 
 |  |  | 
 |  |  |         return buff
 | 
 |  |  |     
 | 
 |  |  |     def LoadGameData(self, gameBuffer, pos):
 | 
 |  |  |         pos = self.DBPyCoupleManager.LoadPyGameData(gameBuffer, pos, len(gameBuffer))
 | 
 |  |  |         pos = self.DBPyUnNotifyLoveGiftRecManager.LoadPyGameData(gameBuffer, pos, len(gameBuffer))
 | 
 |  |  |         pos = self.DBPyCharmValueRecManager.LoadPyGameData(gameBuffer, pos, len(gameBuffer))
 | 
 |  |  |         pos = self.IntimacyManager.LoadPyGameData(gameBuffer, pos, len(gameBuffer))
 | 
 |  |  |         pos = self.CrossPersonalCompensationManager.LoadPyGameData(gameBuffer, pos, len(gameBuffer))
 | 
 |  |  |         pos = self.CrossBillboardManager.LoadPyGameData(gameBuffer, pos, len(gameBuffer))
 | 
 |  |  |         pos = self.PlayerAssistThanksPyManager.LoadPyGameData(gameBuffer, pos, len(gameBuffer))
 | 
 |  |  | 
 |  |  |     pyGameDataMgr = GetPyGameDataManager()
 | 
 |  |  |     return pyGameDataMgr.familyStoreItemManager
 | 
 |  |  | 
 | 
 |  |  | def GetDBPyCoupleManager():
 | 
 |  |  |     # 伴侣管理
 | 
 |  |  |     pyGameDataMgr = GetPyGameDataManager()
 | 
 |  |  |     return pyGameDataMgr.DBPyCoupleManager
 | 
 |  |  | 
 | 
 |  |  | def GetDBPyUnNotifyLoveGiftRecManager():
 | 
 |  |  |     # 未通知的赠送礼物记录
 | 
 |  |  |     pyGameDataMgr = GetPyGameDataManager()
 | 
 |  |  |     return pyGameDataMgr.DBPyUnNotifyLoveGiftRecManager
 | 
 |  |  | 
 | 
 |  |  | def GetDBPyCharmValueRecManager():
 | 
 |  |  |     # 魅力管理
 | 
 |  |  |     pyGameDataMgr = GetPyGameDataManager()
 | 
 |  |  |     return pyGameDataMgr.DBPyCharmValueRecManager
 | 
 |  |  | 
 | 
 |  |  | def GetIntimacyManager():
 | 
 |  |  |     # 亲密管理
 | 
 |  |  |     pyGameDataMgr = GetPyGameDataManager()
 | 
 |  |  |     return pyGameDataMgr.IntimacyManager
 | 
 |  |  | 
 | 
 |  |  | # 好友系统
 | 
 |  |  | def GetFriendManager():
 | 
 |  |  |     pyGameDataMgr = GetPyGameDataManager()
 |