三国卡牌服务端代码仓库
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
hch
2025-05-16 680c639d3a9d7db70f53932cdf69237033f0c460 
 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