From 680c639d3a9d7db70f53932cdf69237033f0c460 Mon Sep 17 00:00:00 2001
From: hch <305670599@qq.com>
Date: 星期五, 16 五月 2025 15:04:35 +0800
Subject: [PATCH] 0312 屏蔽部分 DataServerLogData 代码
---
ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/PyMongoDB/LogicProcess/UserCtrlDB.py | 270 +++++++++++++++++++++++++++--------------------------
1 files changed, 136 insertions(+), 134 deletions(-)
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 34d0053..0285c5f 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
@@ -2146,26 +2146,27 @@
return pos
def recPlayerLogoff(self, dbPlayer):
- req = DataServerLogData.tagDBPlayerLogInfoOnLogOff()
- req.AccID = dbPlayer.AccID
- req.PlayerName = dbPlayer.PlayerName
- req.AccState = dbPlayer.AccState
- req.LV = dbPlayer.LV
- req.Gold = dbPlayer.Gold
- req.GoldPaper = dbPlayer.GoldPaper
- req.Silver = dbPlayer.Silver
- req.SilverPaper = dbPlayer.SilverPaper
- req.GMLevel = dbPlayer.GMLevel
- req.Job = dbPlayer.Job
- req.TJGTime = dbPlayer.HappyPoint # 脱机挂时间
- req.TJGState = dbPlayer.State # 0正常登录，1脱机登录，2脱机登录死亡
- req.LastLogoffTime = time()
- req.PlayerID = dbPlayer.PlayerID
- req.IsOnline = 0 #默认0因关服时没收到loginserver全部下线包
- sendBuf = ''
- sendBuf = CommFunc.WriteBYTE(sendBuf, CommonDefine.gstSavePlayerInfoLogOnLogOff)
- sendBuf = CommFunc.WriteString(sendBuf, req.getLength(), req.getBuffer())
- self.sendDBRequest(sendBuf)
+ # req = DataServerLogData.tagDBPlayerLogInfoOnLogOff()
+ # req.AccID = dbPlayer.AccID
+ # req.PlayerName = dbPlayer.PlayerName
+ # req.AccState = dbPlayer.AccState
+ # req.LV = dbPlayer.LV
+ # req.Gold = dbPlayer.Gold
+ # req.GoldPaper = dbPlayer.GoldPaper
+ # req.Silver = dbPlayer.Silver
+ # req.SilverPaper = dbPlayer.SilverPaper
+ # req.GMLevel = dbPlayer.GMLevel
+ # req.Job = dbPlayer.Job
+ # req.TJGTime = dbPlayer.HappyPoint # 脱机挂时间
+ # req.TJGState = dbPlayer.State # 0正常登录，1脱机登录，2脱机登录死亡
+ # req.LastLogoffTime = time()
+ # req.PlayerID = dbPlayer.PlayerID
+ # req.IsOnline = 0 #默认0因关服时没收到loginserver全部下线包
+ # sendBuf = ''
+ # sendBuf = CommFunc.WriteBYTE(sendBuf, CommonDefine.gstSavePlayerInfoLogOnLogOff)
+ # sendBuf = CommFunc.WriteString(sendBuf, req.getLength(), req.getBuffer())
+ # self.sendDBRequest(sendBuf)
+ return
def onSavePlayerDataCRCError(self, db, pack, saveDataWithCRC):
@@ -3019,18 +3020,19 @@
# self.sendDBRequest(dbPlayerFobiddenLogReq)
self.sendAccForbiddenLogReq(accid.lower(), isForbidden)
- accForbiddenLogReq = ''
- accForbiddenLogReq = CommFunc.WriteBYTE(accForbiddenLogReq, CommonDefine.gstAccForbiddenLog)
- accForbiddenLog = DataServerLogData.tagAccForbiddenLog()
- accForbiddenLog.AccID = accid.lower()
- accForbiddenLog.PlayerID = playerID
- accForbiddenLog.Oper = isForbidden
- accForbiddenLog.OperTime = operTime
- accForbiddenLog.TimeLimit = timeLimit
- accForbiddenLog.GMAccID = operGMAccid
- accForbiddenLog.Msg = msg
- accForbiddenLogReq = CommFunc.WriteString(accForbiddenLogReq, accForbiddenLog.getLength(), accForbiddenLog.getBuffer())
- self.sendDBRequest(accForbiddenLogReq)
+ # accForbiddenLogReq = ''
+ # accForbiddenLogReq = CommFunc.WriteBYTE(accForbiddenLogReq, CommonDefine.gstAccForbiddenLog)
+ # accForbiddenLog = DataServerLogData.tagAccForbiddenLog()
+ # accForbiddenLog.AccID = accid.lower()
+ # accForbiddenLog.PlayerID = playerID
+ # accForbiddenLog.Oper = isForbidden
+ # accForbiddenLog.OperTime = operTime
+ # accForbiddenLog.TimeLimit = timeLimit
+ # accForbiddenLog.GMAccID = operGMAccid
+ # accForbiddenLog.Msg = msg
+ # accForbiddenLogReq = CommFunc.WriteString(accForbiddenLogReq, accForbiddenLog.getLength(), accForbiddenLog.getBuffer())
+ # self.sendDBRequest(accForbiddenLogReq)
+ return
def extractGMOper(self, accid, gmOper, gmOperData):
pos = 0
@@ -4405,10 +4407,10 @@
#=======================================================================================
# 记录玩家点券变化日志
- oDBPlayerLogInfoOnCoinChange = DataServerLogData.tagDBPlayerLogInfoOnCoinChange()
- oDBPlayerLogInfoOnCoinChange.AccID = oCoinChangeReq.Acc
- oDBPlayerLogInfoOnCoinChange.Coin = oCoinChangeReq.Coin
- self.sendDBRequest(chr(CommonDefine.gstSavePlayerInfoLogOnOnCoinChange) + oDBPlayerLogInfoOnCoinChange.getBuffer())
+ # oDBPlayerLogInfoOnCoinChange = DataServerLogData.tagDBPlayerLogInfoOnCoinChange()
+ # oDBPlayerLogInfoOnCoinChange.AccID = oCoinChangeReq.Acc
+ # oDBPlayerLogInfoOnCoinChange.Coin = oCoinChangeReq.Coin
+ # self.sendDBRequest(chr(CommonDefine.gstSavePlayerInfoLogOnOnCoinChange) + oDBPlayerLogInfoOnCoinChange.getBuffer())
except:
msg = error.formatMsg('error', error.ERROR_NO_88, "OnCoinChange throw exception\n%s"%traceback.format_exc())
mylog.error(msg)
@@ -4568,59 +4570,59 @@
return False
self.sendString(pack, sendPack.GetBuffer())
- #通知写补偿日志
- for i in xrange(sendPack.Count):
- dbData = sendPack.Datas[i]
- saveLog = DataServerLogData.tagExpiationLog()
- saveLog.ReceiveDate = time()
- saveLog.ExpiationIndex = dbData.ExpiationIndex;
- saveLog.AccID = dbData.AccID
- saveLog.MakerName = dbData.MakerName
- saveLog.CreateTime = dbData.CreateTime
- saveLog.ExpiationTime = dbData.ExpiationTime;
- saveLog.Gold = dbData.Gold;
- saveLog.GoldPaper = dbData.GoldPaper;
- saveLog.Silver = dbData.Silver;
- saveLog.SilverPaper = dbData.SilverPaper;
- saveLog.ItemTypeID = dbData.ItemTypeID;
- saveLog.Count = dbData.Count;
- saveLog.IsLocked = dbData.IsLocked;
- saveLog.ItemPlaceType = dbData.ItemPlaceType;
- saveLog.ItemPlaceIndex = dbData.ItemPlaceIndex;
- saveLog.IsBind = dbData.IsBind;
- saveLog.ItemStarLV = dbData.ItemStarLV;
- saveLog.IdentifyPar = dbData.IdentifyPar;
- saveLog.CurDurg = dbData.CurDurg;
- saveLog.MaxDurg = dbData.MaxDurg;
- saveLog.CanPlaceStoneCount = dbData.CanPlaceStoneCount;
- saveLog.ItemProperty = dbData.ItemProperty;
- saveLog.SoulProperty = dbData.SoulProperty;
- saveLog.Maker = dbData.Maker;
- saveLog.Stone1 = dbData.Stone1;
- saveLog.Stone2 = dbData.Stone2;
- saveLog.Stone3 = dbData.Stone3;
- saveLog.Stone4 = dbData.Stone4;
- saveLog.Stone5 = dbData.Stone5;
- saveLog.Stone6 = dbData.Stone6;
- saveLog.Stone7 = dbData.Stone7;
- saveLog.Stone8 = dbData.Stone8;
- saveLog.Stone9 = dbData.Stone9;
- saveLog.RemainHour = dbData.RemainHour;
- saveLog.ElementEffect = dbData.ElementEffect;
- saveLog.IsSuite = dbData.IsSuite;
- saveLog.FitLV = dbData.FitLV;
- saveLog.EquipAddSkillCnt = dbData.EquipAddSkillCnt;
- saveLog.ExpireTime = dbData.ExpireTime;
- saveLog.BaseAtkPlus = dbData.BaseAtkPlus;
- saveLog.BaseDefPlus = dbData.BaseDefPlus;
- saveLog.AddSkillData = dbData.AddSkillData
- saveLog.BaseHP = dbData.BaseHP;
- saveLog.BaseMagicDef = dbData.BaseMagicDef;
- saveLog.EquipMinAtkValue = dbData.EquipMinAtkValue;
- saveLog.Proficiency = dbData.Proficiency;
- saveLog.RelMaxAddSkillCnt = dbData.RelMaxAddSkillCnt;
- saveLog.FamilyActiveValue = dbData.FamilyActiveValue;
- self.sendDBRequest(chr(CommonDefine.gstGetExpiationLog) + saveLog.getBuffer())
+ # #通知写补偿日志
+ # for i in xrange(sendPack.Count):
+ # dbData = sendPack.Datas[i]
+ # saveLog = DataServerLogData.tagExpiationLog()
+ # saveLog.ReceiveDate = time()
+ # saveLog.ExpiationIndex = dbData.ExpiationIndex;
+ # saveLog.AccID = dbData.AccID
+ # saveLog.MakerName = dbData.MakerName
+ # saveLog.CreateTime = dbData.CreateTime
+ # saveLog.ExpiationTime = dbData.ExpiationTime;
+ # saveLog.Gold = dbData.Gold;
+ # saveLog.GoldPaper = dbData.GoldPaper;
+ # saveLog.Silver = dbData.Silver;
+ # saveLog.SilverPaper = dbData.SilverPaper;
+ # saveLog.ItemTypeID = dbData.ItemTypeID;
+ # saveLog.Count = dbData.Count;
+ # saveLog.IsLocked = dbData.IsLocked;
+ # saveLog.ItemPlaceType = dbData.ItemPlaceType;
+ # saveLog.ItemPlaceIndex = dbData.ItemPlaceIndex;
+ # saveLog.IsBind = dbData.IsBind;
+ # saveLog.ItemStarLV = dbData.ItemStarLV;
+ # saveLog.IdentifyPar = dbData.IdentifyPar;
+ # saveLog.CurDurg = dbData.CurDurg;
+ # saveLog.MaxDurg = dbData.MaxDurg;
+ # saveLog.CanPlaceStoneCount = dbData.CanPlaceStoneCount;
+ # saveLog.ItemProperty = dbData.ItemProperty;
+ # saveLog.SoulProperty = dbData.SoulProperty;
+ # saveLog.Maker = dbData.Maker;
+ # saveLog.Stone1 = dbData.Stone1;
+ # saveLog.Stone2 = dbData.Stone2;
+ # saveLog.Stone3 = dbData.Stone3;
+ # saveLog.Stone4 = dbData.Stone4;
+ # saveLog.Stone5 = dbData.Stone5;
+ # saveLog.Stone6 = dbData.Stone6;
+ # saveLog.Stone7 = dbData.Stone7;
+ # saveLog.Stone8 = dbData.Stone8;
+ # saveLog.Stone9 = dbData.Stone9;
+ # saveLog.RemainHour = dbData.RemainHour;
+ # saveLog.ElementEffect = dbData.ElementEffect;
+ # saveLog.IsSuite = dbData.IsSuite;
+ # saveLog.FitLV = dbData.FitLV;
+ # saveLog.EquipAddSkillCnt = dbData.EquipAddSkillCnt;
+ # saveLog.ExpireTime = dbData.ExpireTime;
+ # saveLog.BaseAtkPlus = dbData.BaseAtkPlus;
+ # saveLog.BaseDefPlus = dbData.BaseDefPlus;
+ # saveLog.AddSkillData = dbData.AddSkillData
+ # saveLog.BaseHP = dbData.BaseHP;
+ # saveLog.BaseMagicDef = dbData.BaseMagicDef;
+ # saveLog.EquipMinAtkValue = dbData.EquipMinAtkValue;
+ # saveLog.Proficiency = dbData.Proficiency;
+ # saveLog.RelMaxAddSkillCnt = dbData.RelMaxAddSkillCnt;
+ # saveLog.FamilyActiveValue = dbData.FamilyActiveValue;
+ # self.sendDBRequest(chr(CommonDefine.gstGetExpiationLog) + saveLog.getBuffer())
return True
# curPack = RecvPackProtocol.tagDGetValueByAcc()
# curPack.ReadData(pack.getBuffer())
@@ -4717,26 +4719,26 @@
return False
#存日志
- saveLog = DataServerLogData.tagPetExpiationLog()
- saveLog.ReceiveDate = time();
+ # saveLog = DataServerLogData.tagPetExpiationLog()
+ # saveLog.ReceiveDate = time();
- saveLog.ExpiationIndex = dbData.ExpiationIndex;
- saveLog.AccID = dbData.AccID
- saveLog.ExpiationTime = dbData.ExpiationTime;
- saveLog.NPCID = dbData.NPCID;
- saveLog.Lv = dbData.Lv;
- saveLog.Exp = dbData.Exp;
- saveLog.BindType = dbData.BindType;
- saveLog.UseCreatorDrugCnt = dbData.UseCreatorDrugCnt;
- saveLog.Friendliness = dbData.Friendliness;
- saveLog.SkillIDList = dbData.SkillIDList
- saveLog.HPTalent = dbData.HPTalent;
- saveLog.PhysicAtkTalent = dbData.PhysicAtkTalent;
- saveLog.MagicAtkTalent = dbData.MagicAtkTalent;
- saveLog.PhysicDefTalent = dbData.PhysicDefTalent;
- saveLog.MagicDefTalent = dbData.MagicDefTalent;
+ # saveLog.ExpiationIndex = dbData.ExpiationIndex;
+ # saveLog.AccID = dbData.AccID
+ # saveLog.ExpiationTime = dbData.ExpiationTime;
+ # saveLog.NPCID = dbData.NPCID;
+ # saveLog.Lv = dbData.Lv;
+ # saveLog.Exp = dbData.Exp;
+ # saveLog.BindType = dbData.BindType;
+ # saveLog.UseCreatorDrugCnt = dbData.UseCreatorDrugCnt;
+ # saveLog.Friendliness = dbData.Friendliness;
+ # saveLog.SkillIDList = dbData.SkillIDList
+ # saveLog.HPTalent = dbData.HPTalent;
+ # saveLog.PhysicAtkTalent = dbData.PhysicAtkTalent;
+ # saveLog.MagicAtkTalent = dbData.MagicAtkTalent;
+ # saveLog.PhysicDefTalent = dbData.PhysicDefTalent;
+ # saveLog.MagicDefTalent = dbData.MagicDefTalent;
- self.sendDBRequest(chr(CommonDefine.gstGetPetExpiationLog) + saveLog.getBuffer(), pack)
+ # self.sendDBRequest(chr(CommonDefine.gstGetPetExpiationLog) + saveLog.getBuffer(), pack)
return True
def gstUpdateServerDataVersionNO(self, db, pack):
@@ -4784,28 +4786,28 @@
def OnUpdateTotalSavePoint(self, db, pack):
try:
mylog.info("begin process gstUpdateTotalSavePoint")
- recvPack = RecvPackProtocol.tagBDStringTypeSend()
- recvPack.ReadData(pack.getBuffer())
+ # recvPack = RecvPackProtocol.tagBDStringTypeSend()
+ # recvPack.ReadData(pack.getBuffer())
- dbData = DataServerLogData.tagDBPlayerSaveCoinLog()
- if -1 == dbData.readData(recvPack.Data):
- msg = error.formatMsg('error', error.ERROR_NO_95, "tagDBPlayerSaveCoinLog:lack of pack data:data = %s,datalen = %d"%(b2a_hex(recvPack.Data), len(recvPack.Data)))
- mylog.error(msg)
- return False
+ # dbData = DataServerLogData.tagDBPlayerSaveCoinLog()
+ # if -1 == dbData.readData(recvPack.Data):
+ # msg = error.formatMsg('error', error.ERROR_NO_95, "tagDBPlayerSaveCoinLog:lack of pack data:data = %s,datalen = %d"%(b2a_hex(recvPack.Data), len(recvPack.Data)))
+ # mylog.error(msg)
+ # return False
- col = db[UCN_DSAccount]
- dbDoc = DataServerPlayerData.tagDSAccount()
- dbDoc.AccID = recvPack.AccID
- ret = dbDoc.adoLoadC(col)
- if ret:
- dbDoc.TotalSavePoint += dbData.Coin
- else:
- dbDoc.TotalSavePoint = 0
+ # col = db[UCN_DSAccount]
+ # dbDoc = DataServerPlayerData.tagDSAccount()
+ # dbDoc.AccID = recvPack.AccID
+ # ret = dbDoc.adoLoadC(col)
+ # if ret:
+ # dbDoc.TotalSavePoint += dbData.Coin
+ # else:
+ # dbDoc.TotalSavePoint = 0
- if not dbDoc.adoCheckUpdateC(col):
- msg = error.formatMsg('error', error.ERROR_NO_86, "UpdateTotalSavePoint failed,data = %s,datalen = %d"%(b2a_hex(recvPack.Data), len(recvPack.Data)))
- mylog.error(msg)
- return False
+ # if not dbDoc.adoCheckUpdateC(col):
+ # msg = error.formatMsg('error', error.ERROR_NO_86, "UpdateTotalSavePoint failed,data = %s,datalen = %d"%(b2a_hex(recvPack.Data), len(recvPack.Data)))
+ # mylog.error(msg)
+ # return False
except:
msg = error.formatMsg('error', error.ERROR_NO_96, "OnUpdateTotalSavePoint throw a exception, packdata = %s, packdata len = %d\n%s"(b2a_hex(pack.getBuffer()), len(pack.getBuffer()), traceback.format_exc()))
@@ -5252,14 +5254,14 @@
return False;
#插入ChinLog表记录
- curLog = DataServerLogData.tagAccTransactionLog()
- curLog.TransactionID = doc.CheckValue
- curLog.AccID = recvData.Acc
- curLog.OperReason = "gstAddAccItem"
- curLog.ProcessTime = time();
- curLog.ItemID = recvData.ItemID;
- curLog.ItemCount = recvData.ItemCnt;
- self.sendDBRequest(chr(CommonDefine.gstItemTransactionLog) + curLog.getBuffer())
+ # curLog = DataServerLogData.tagAccTransactionLog()
+ # curLog.TransactionID = doc.CheckValue
+ # curLog.AccID = recvData.Acc
+ # curLog.OperReason = "gstAddAccItem"
+ # curLog.ProcessTime = time();
+ # curLog.ItemID = recvData.ItemID;
+ # curLog.ItemCount = recvData.ItemCnt;
+ # self.sendDBRequest(chr(CommonDefine.gstItemTransactionLog) + curLog.getBuffer())
#回报BalanceServer插入成功
#dgAddAccItemOK
--
Gitblit v1.8.0