#!/usr/bin/python # -*- coding: GBK -*- #------------------------------------------------------------------------------- # ##@package AuctionHouse # # @todo:ÅÄÂôÐÐ # @author hxp # @date 2019-03-04 # @version 1.0 # # ÏêϸÃèÊö: ÅÄÂôÐÐ # #------------------------------------------------------------------------------- #"""Version = 2019-03-04 17:00""" #------------------------------------------------------------------------------- import GameWorld import PyDataManager import PlayerControl import DataRecordPack import PyGameDataStruct import PlayerCompensation import ChPyNetSendPack import IpyGameDataPY import NetPackCommon import PlayerBourse import PlayerFamily import ShareDefine import ChConfig import operator import time import math import json # ÅÄÂô¼Ç¼ÀàÐͶ¨Òå AuctionRecordTypeList = ( AuctionRecordType_MyAuction, # ÎÒµÄÅÄÆ· AuctionRecordType_FamilyAuction, # ÏÉÃËÅÄÆ· AuctionRecordType_MyBid, # ÎҵľºÅÄ ) = range(3) # ÅÄÂô¼Ç¼½á¹û¶¨Òå AuctionRecordResultList = ( AuctionRecordResult_SellFail, # Á÷ÅÄ AuctionRecordResult_SellOK, # ÅÄÂô³É½» AuctionRecordResult_Recycle, # ϵͳ»ØÊÕ AuctionRecordResult_BidOK, # ¾º¼Û³É¹¦ AuctionRecordResult_BidFail, # ¾º¼Ûʧ°Ü AuctionRecordResult_MoveToWorld, # ÏÉÃËÅÄƷתÒƵ½È«·þÅÄÆ· ) = range(6) # µ±Ç°ÅÄÆ·¹éÀà 0-È«·þÅÄÆ· 1-ÏÉÃË˽ÓÐÅÄÆ· AuctionType_World = 0 AuctionType_Family = 1 ''' ¾º¼ÛÁ÷³Ì: 1. MapServer ÏÈÑéÖ¤¼Û¸ñÊÇ·ñ¹» 2. GameServer ÑéÖ¤ÊÇ·ñ¿ÉÒÔ¾º¼Û 3. MapServer ¿Û³ýÍæ¼Ò»õ±Ò 4. GameServer ½øÐоº¼Û£¬±ä¸üÏ´ξº¼Û¼Û¸ñ »ùÓÚÒÔÉÏÁ÷³Ì£¬ËùÒÔÍæ¼Ò¾º¼ÛʱÐèÏÈËø¶¨ÎïÆ·£¬·ÀÖ¹¾º¼ÛÁ÷³ÌδÍê½áʱÆäËûÍæ¼ÒÇëÇ󾺼ÛͬһÅÄÆ·ÅжϾº¼Û¼Û¸ñ´íÎó Ëø¶¨Ê±³¤Í¬ÑùÊÊÓÃÓÚÅÄÆ·¾º¼Ûʱ¼ä½áÊøʱµÄ±£»¤Ê±¼ä ''' BiddingQueryLockTick = 10000 #ÅÄÂôÐÐ״̬¿ª¹Ø def GetAuctionHouseState(): return PlayerBourse.GetOpenState() def OnPlayerLogin(curPlayer): Sync_PlayerAuctionItemInfo(curPlayer) Sync_FamilyAuctionItemInfo(curPlayer, curPlayer.GetFamilyID()) Sync_PlayerBiddingItemInfo(curPlayer) Sync_PlayerAttentionAuctionItemID(curPlayer, False) return def OnPlayerLeaveServer(curPlayer): playerID = curPlayer.GetPlayerID() auctionItemMgr = PyDataManager.GetAuctionItemManager() auctionItemMgr.myAttentionItemDict.pop(playerID, None) return ##--------------------------------------- ÅÄÂô¼Ç¼ ------------------------------------------------- def GetMyAuctionItemRecord(playerID): ## »ñÈ¡ÎÒµÄÅÄÆ·¼Ç¼ return PyDataManager.GetAuctionRecordManager().myAuctionItemRecordDict.get(playerID, []) def GetMyBiddingItemRecord(playerID): ## »ñÈ¡ÎҵľºÅļǼ return PyDataManager.GetAuctionRecordManager().myBidItemRecordDict.get(playerID, []) def GetFamilyAuctionItemRecord(familyID): ## »ñÈ¡ÏÉÃËÅÄÆ·¼Ç¼ return PyDataManager.GetAuctionRecordManager().familyAuctionItemRecordDict.get(familyID, []) def AddAuctionRecord(auctionItem, recordResult): ''' Ìí¼ÓÅÄÂôÐмǼ @param auctionItem: Ïà¹ØµÄÅÄƷʵÀý @param recordResult: ¼Ç¼½á¹û 0-Á÷ÅÄ 1-ÅÄÂô³É½» 2-»ØÊÕ 3-¾º¼Û³É¹¦ 4-¾º¼Ûʧ°Ü ''' if not auctionItem: return playerID, familyID, bidderID = auctionItem.PlayerID, auctionItem.FamilyID, auctionItem.BidderID recordPlayerID, recordFamilyID = 0, 0 if recordResult in [AuctionRecordResult_BidOK, AuctionRecordResult_BidFail]: recordType = AuctionRecordType_MyBid recordPlayerID = bidderID else: if familyID: recordType = AuctionRecordType_FamilyAuction recordFamilyID = familyID else: recordType = AuctionRecordType_MyAuction recordPlayerID = playerID if not recordPlayerID and not recordFamilyID: return newRecordData = PyGameDataStruct.tagDBAuctionRecord() newRecordData.ItemGUID = auctionItem.ItemGUID newRecordData.PlayerID = recordPlayerID newRecordData.FamilyID = recordFamilyID newRecordData.RecordType = recordType newRecordData.RecordResult = recordResult newRecordData.RecordTime = GameWorld.GetCurrentDataTimeStr() newRecordData.BidderPrice = auctionItem.BidderPrice newRecordData.BidderName = auctionItem.BidderName newRecordData.ItemID = auctionItem.ItemID newRecordData.Count = auctionItem.Count newRecordData.UserData = auctionItem.UserData newRecordData.UserDataLen = auctionItem.UserDataLen AddNewAuctionRecord(newRecordData) if recordFamilyID: Sync_PlayerAuctionRecordInfo(None, recordType, newRecordData, recordFamilyID) elif recordPlayerID: recordPlayer = GameWorld.GetPlayerManager().FindPlayerByID(recordPlayerID) if recordPlayer and not PlayerControl.GetIsTJG(recordPlayer): Sync_PlayerAuctionRecordInfo(recordPlayer, recordType, newRecordData) return def AddNewAuctionRecord(newRecordData): playerID = newRecordData.PlayerID familyID = newRecordData.FamilyID recordType = newRecordData.RecordType if recordType == AuctionRecordType_MyAuction: keyID = playerID recordDict = PyDataManager.GetAuctionRecordManager().myAuctionItemRecordDict elif recordType == AuctionRecordType_FamilyAuction: keyID = familyID recordDict = PyDataManager.GetAuctionRecordManager().familyAuctionItemRecordDict elif recordType == AuctionRecordType_MyBid: keyID = playerID recordDict = PyDataManager.GetAuctionRecordManager().myBidItemRecordDict else: return recordList = recordDict.get(keyID, []) maxCount = min(50, IpyGameDataPY.GetFuncCfg("AuctionHouse", 3)) if len(recordList) >= maxCount: del recordList[0] recordList.append(newRecordData) recordDict[keyID] = recordList return ##-------------------------------------- ÅÄÂô¹Ø×¢ ------------------------------------------------ def GetPlayerAuctionAttention(attentionMgr, playerID): ## »ñÈ¡Íæ¼Ò¹Ø×¢µÄÎïÆ·IDÁбí if playerID not in attentionMgr.playerAttentionDict: return [] attentionObj = attentionMgr.playerAttentionDict[playerID] attentionItemIDList = attentionObj.AttentionItemIDList return attentionItemIDList def AddPlayerAuctionAttention(attentionMgr, playerID, itemID): ## Ìí¼ÓÍæ¼Ò¹Ø×¢µÄÎïÆ·ID if playerID not in attentionMgr.playerAttentionDict: dbData = PyGameDataStruct.tagDBAuctionAttention() dbData.PlayerID = playerID __InitAuctionAttentionAttrEx(dbData) attentionMgr.playerAttentionDict[playerID] = dbData attentionObj = attentionMgr.playerAttentionDict[playerID] attentionItemIDList = attentionObj.AttentionItemIDList if len(attentionItemIDList) >= IpyGameDataPY.GetFuncCfg("AuctionHouse", 5): GameWorld.DebugLog("¹Ø×¢ÅÄÆ·Êý´ïµ½ÉÏÏÞ!", playerID) return if itemID in attentionItemIDList: return True attentionItemIDList.append(itemID) attentionObj.AttentionInfo = str(attentionItemIDList) attentionObj.AttentionLen = len(attentionObj.AttentionInfo) return True def DelPlayerAuctionAttention(attentionMgr, playerID, itemID): ## ɾ³ýÍæ¼Ò¹Ø×¢µÄÎïÆ·ID if playerID not in attentionMgr.playerAttentionDict: return attentionObj = attentionMgr.playerAttentionDict[playerID] attentionItemIDList = attentionObj.AttentionItemIDList if itemID not in attentionItemIDList: return attentionItemIDList.remove(itemID) attentionObj.AttentionInfo = str(attentionItemIDList) attentionObj.AttentionLen = len(attentionObj.AttentionInfo) return True def OnLoadAuctionAttentionDataEx(attentionData): ## ¼ÓÔØÅÄÂô¹Ø×¢±íʱ¸½¼Ó´¦Àí __InitAuctionAttentionAttrEx(attentionData) return def __InitAuctionAttentionAttrEx(attentionData): ## ³õʼ»¯ÅÄÂô¹ØעʵÀý¸½¼ÓÊôÐÔ setattr(attentionData, "AttentionItemIDList", [] if not attentionData.AttentionInfo else json.loads(attentionData.AttentionInfo)) return ##------------------------------------------------------------------------------------------------- def OnLoadAuctionItemDataEx(dbData): ## ¼ÓÔØÅÄÂôÎïÆ·±íʱ¸½¼Ó´¦Àí __InitAuctionItemAttrEx(dbData) playerID = dbData.PlayerID familyID = dbData.FamilyID bidderID = dbData.BidderID pyAuctionItemMgr = PyDataManager.GetAuctionItemManager() pyAuctionItemMgr.allAuctionItemByEndTimeList.append(dbData) if dbData.AuctionType == AuctionType_World: pyAuctionItemMgr.worldAuctionItemList.append(dbData) if familyID: familyItemList = pyAuctionItemMgr.familyAuctionItemDict.get(familyID, []) familyItemList.append(dbData) pyAuctionItemMgr.familyAuctionItemDict[familyID] = familyItemList if playerID: myItemList = pyAuctionItemMgr.myAuctionItemDict.get(playerID, []) myItemList.append(dbData) pyAuctionItemMgr.myAuctionItemDict[playerID] = myItemList if str(playerID) in dbData.BidderIDInfo: if playerID == bidderID: nowBidItemList = pyAuctionItemMgr.nowBiddingAuctionItemDict.get(playerID, []) nowBidItemList.append(dbData) pyAuctionItemMgr.nowBiddingAuctionItemDict[playerID] = nowBidItemList else: hisBidItemList = pyAuctionItemMgr.hisBiddingAuctionItemDict.get(playerID, []) hisBidItemList.append(dbData) pyAuctionItemMgr.hisBiddingAuctionItemDict[playerID] = hisBidItemList return def OnLoadAuctionItemDataOK(): ## ¼ÓÔØÅÄÂôÎïÆ·±íÍê³ÉºóµÄ´¦Àí __SortAuctionitem() return def __InitAuctionItemAttrEx(auctionItem, ipyData=None): ## ³õʼ»¯ÅÄƷʵÀý¸½¼ÓÊôÐÔ if not ipyData: ipyData = IpyGameDataPY.GetIpyGameData("AuctionItem", auctionItem.ItemID) setattr(auctionItem, "Sortpriority", 99999 - (0 if not ipyData else ipyData.GetSortpriority())) # ÅÅÐòÓÅÏȼ¶¹é×é setattr(auctionItem, "BiddingQueryID", 0) # µ±Ç°ÕýÔÚ¾º¼ÛµÄÍæ¼ÒID setattr(auctionItem, "BiddingQueryTick", 0) # µ±Ç°ÕýÔÚ¾º¼ÛµÄtick setattr(auctionItem, "EndTime", 0) # ½áÊø¾º¼ÛtimeÖµ __SetAuctionItemEndTime(auctionItem, ipyData) return True def __SetAuctionItemEndTime(auctionItem, ipyData): ## ¸üÐÂÅÄÆ·½áÊø¾º¼ÛtimeÖµ if not ipyData: return addTimeStr = auctionItem.AddTime auctionType = auctionItem.AuctionType addTime = GameWorld.ChangeTimeStrToNum(addTimeStr) noticeMinutes = ipyData.GetNoticeSaleMinutes() saleMinutes = ipyData.GetFamilySaleMinutes() if auctionType == AuctionType_Family else ipyData.GetWorldSaleMinutes() auctionItem.EndTime = addTime + (noticeMinutes + saleMinutes) * 60 __AddAuctionItemEndTimeByBid(auctionItem) return def __AddAuctionItemEndTimeByBid(auctionItem): # ¸ù¾Ý×îºóÒ»´Î¾º¼Ûʱ¼ä½øÐмÓʱ if not auctionItem.BidderPrice: return bidTime = GameWorld.ChangeTimeStrToNum(auctionItem.BiddingTime) endTime = bidTime + IpyGameDataPY.GetFuncCfg("AuctionHouse", 4) if endTime <= auctionItem.EndTime: return GameWorld.DebugLog("ÅÄÆ·¼Óʱ: EndTime=%s,updEndTime=%s" % (auctionItem.EndTime, endTime)) auctionItem.EndTime = endTime return True def __GetAuctionItemDRDict(auctionItem): drDict = {"GUID":auctionItem.ItemGUID, "PlayerID":auctionItem.PlayerID, "FamilyID":auctionItem.FamilyID, "ItemID":auctionItem.ItemID, "Count":auctionItem.Count, "AuctionType":auctionItem.AuctionType, "AddTime":auctionItem.AddTime, "BiddingTime":auctionItem.BiddingTime, "BidderID":auctionItem.BidderID, "BidderPrice":auctionItem.BidderPrice, "UserData":auctionItem.UserData, "EndTime":"" if not auctionItem.EndTime else GameWorld.ChangeTimeNumToStr(auctionItem.EndTime), "FamilyPlayerIDInfo":auctionItem.FamilyPlayerIDInfo, "BidderIDInfo":auctionItem.BidderIDInfo} return drDict def GetAuctionItem(itemGUID): ## »ñÈ¡ÅÄƷʵÀý return PyDataManager.GetAuctionItemManager().allAuctionItemDict.get(itemGUID) def GetPlayerAuctionItemList(playerID): ## Íæ¼ÒÅÄÂôÖеÄÅÄÆ·Áбí return PyDataManager.GetAuctionItemManager().myAuctionItemDict.get(playerID, []) def GetFamilyAuctionItemList(familyID): ## ÏÉÃËÅÄÂôÖеÄÅÄÆ·Áбí return PyDataManager.GetAuctionItemManager().familyAuctionItemDict.get(familyID, []) def IsFamilyMemberBiddingAuctionItem(familyID, memberID): ## ÏÉÃ˳ÉÔ±ÊÇ·ñ×î¸ß¾º¼ÛÅÄÆ·ÖÐ familyAuctionItemList = GetFamilyAuctionItemList(familyID) for auctionItem in familyAuctionItemList: if auctionItem.BidderID == memberID: return True return False def OnAuctionItemTimeProcess(curTime, tick): ## ÅÄÂôÐÐÅÄÆ·¶¨Ê±´¦Àí£¬Ã¿Ãë´¥·¢Ò»´Î allAuctionItemByEndTimeList = PyDataManager.GetAuctionItemManager().allAuctionItemByEndTimeList if not allAuctionItemByEndTimeList: return index = 0 endItemList = [] # ½áÊø¾º¼ÛµÄÅÄÆ·Áбí moveToWorldItemList = [] # תÒƵ½È«·þÅÄÂôµÄÏÉÃËÅÄÆ·Áбí doCount = len(allAuctionItemByEndTimeList) while doCount > 0 and allAuctionItemByEndTimeList: doCount -= 1 auctionItem = allAuctionItemByEndTimeList[index] if curTime <= auctionItem.EndTime: break if auctionItem.BiddingQueryTick and tick - auctionItem.BiddingQueryTick < BiddingQueryLockTick: index += 1 continue allAuctionItemByEndTimeList.pop(index) # ûÓÐÈ˾º¼ÛµÄÏÉÃËÅÄÆ· if not auctionItem.BidderPrice and auctionItem.FamilyID and auctionItem.AuctionType == AuctionType_Family: moveToWorldItemList.append(auctionItem) else: endItemList.append(auctionItem) __EndAuctionItem(endItemList, "ByTime") __MoveFamilyAuctionItemToWorld(moveToWorldItemList) return def __MoveFamilyAuctionItemToWorld(auctionItemList): ## ÏÉÃËÅÄƷתÒƵ½È«·þ if not auctionItemList: return curTimeStr = GameWorld.GetCurrentDataTimeStr() attentionMgr = PyDataManager.GetAuctionAttentionManager() auctionItemMgr = PyDataManager.GetAuctionItemManager() notifyWorldAddItemList = [] # ÐÂÔöÈ«·þÅÄƷ֪ͨ [[itemGUID, itemID, playerID], ...] for auctionItem in auctionItemList: itemGUID = auctionItem.ItemGUID itemID = auctionItem.ItemID itemCount = auctionItem.Count playerID = auctionItem.PlayerID familyID = auctionItem.FamilyID ipyData = IpyGameDataPY.GetIpyGameData("AuctionItem", itemID) auctionItem.AuctionType = AuctionType_World auctionItem.AddTime = curTimeStr __SetAuctionItemEndTime(auctionItem, ipyData) auctionItemMgr.allAuctionItemByEndTimeList.append(auctionItem) auctionItemMgr.worldAuctionItemList.append(auctionItem) notifyWorldAddItemList.append([itemGUID, itemID, playerID]) AddAuctionRecord(auctionItem, AuctionRecordResult_MoveToWorld) # Ìí¼Ó½øÎҵĹØ×¢ for attentionPlayerID, attentionList in auctionItemMgr.myAttentionItemDict.items(): if itemID not in GetPlayerAuctionAttention(attentionMgr, attentionPlayerID): continue if auctionItem not in attentionList: attentionList.append(auctionItem) if ipyData.GetNeedWorldNotify(): PlayerControl.WorldNotify(0, "Paimai4", [itemID, ipyData.GetNoticeSaleMinutes()]) drDict = {"AuctionItemInfo":__GetAuctionItemDRDict(auctionItem)} DR_AuctionHouse(None, "FamilyToWorld", drDict) GameWorld.DebugLog("ÏÉÃËÅÄƷתÒƵ½È«·þ: itemID=%s,itemCount=%s,familyID=%s,itemGUID=%s" % (itemID, itemCount, familyID, itemGUID)) __SortAuctionitem() __SyncRefreshAuctionItem(auctionItemList) __NotifyAuctionPlayerAddItem(notifyWorldAddItemList) return def __SortAuctionitem(isSortWorldItem=True): ''' Ë¢ÐÂÈ«²¿ÅÄÆ·ÅÅÐò ºó¶ËÅÅÐò 1.È«·þÅÄÆ·£º ÒòΪȫ·þÅÄÆ·ÊýÁ¿±È½Ï´ó£¬²ÉÓÃÖ»²éѯָ¶¨¸öÊýÅÄÆ·£¬ËùÒÔÖ»ÄÜÓɺó¶ËÅÅÐòºóͬ²½ 2.È«²¿ÅÄÆ·¾º¼Û½áÊøʱ¼ä£ººó¶ËÐèÒª´¦Àí¾º¼Û½áÊø Ç°¶ËÅÅÐò£º 1.¸öÈËÅÄÆ·£º¸öÊý½ÏÉÙ£¬È«²¿Í¬²½£¬ÓÉÇ°¶Ë×Ô¼ºÅÅÐò 2.ÏÉÃËÅÄÆ·£º¸öÊý½ÏÉÙ£¬È«²¿Í¬²½£¬ÓÉÇ°¶Ë×Ô¼ºÅÅÐò 3.¾º¼ÛÅÄÆ·£º¸öÊý½ÏÉÙ£¬È«²¿Í¬²½£¬ÓÉÇ°¶Ë×Ô¼ºÕûºÏÅÅÐò£¬Çø·Ö×î¸ß¾º¼Û¡¢ÀúÊ·¾º¼Û 4.¹Ø×¢ÅÄÆ·£º¸öÊý½ÏÉÙ£¬È«²¿Í¬²½£¬ÓÉÇ°¶Ë×Ô¼ºÅÅÐò ´¥·¢ÅÅÐòʱ»ú£º 1-ÉϼÜÐÂÈ«·þÅÄÆ· 2-ÏÉÃËÅÄƷתÒÆÈ«·þÅÄÆ·£¬Ï൱ÓÚÉϼÜÐÂÈ«·þÅÄÆ· 3-¾º¼ÛÅÄÆ·´¥·¢¼Óʱʱ£¬ÐèÒª¶Ô½áÊøʱ¼äÖØÅÅ£¬¾º¼Û¼ÓʱµÄÖ»´¥·¢¼Óʱ£¬¶ÔÈ«·þÅÄÆ·µÄÅÅÐòûÓÐÓ°Ï죬¹Ê¿É²»ÖØÅÄÈ«·þÅÄÆ· ''' auctionItemMgr = PyDataManager.GetAuctionItemManager() auctionItemMgr.allAuctionItemByEndTimeList.sort(key=operator.attrgetter("EndTime")) if isSortWorldItem: auctionItemMgr.worldAuctionItemList.sort(key=operator.attrgetter("Sortpriority", "AddTime")) auctionItemMgr.worldAuctionItemQueryDict = {} # ÖØÖÃÈ«·þÅÄÆ·Ìõ¼þ²éѯ£¬Ï´ÎÓÐÍæ¼Ò²éѯʱÔÙÖØÐÂˢРreturn def __EndAuctionItem(endItemList, endEvent): ''' ½áÊøÅÄÆ·¾ºÅÄ @param delItemStateDict: ɾ³ýµÄÅÄÆ·¾ºÅÄ״̬ ''' if not endItemList: return 0 auctionItemMgr = PyDataManager.GetAuctionItemManager() clearAuctionItemList = [] for auctionItem in endItemList: if not auctionItem: continue itemGUID = auctionItem.ItemGUID itemID = auctionItem.ItemID itemCount = auctionItem.Count playerID = auctionItem.PlayerID familyID = auctionItem.FamilyID bidderID = auctionItem.BidderID # µ±Ç°¾º¼ÛÍæ¼ÒID bidderPrice = auctionItem.BidderPrice # µ±Ç°¾º¼Û£¬ÓÐÈ˾º¼ÛµÄ»°´ú±í¾ºÅijɹ¦ endType = "" # ÓÐÈ˾º¼Û£¬³É½» if bidderID and bidderPrice: endType = "OK" # ¾ºÅijɹ¦Óʼþ£¬·¢·ÅÎïÆ· paramList = [bidderPrice] detail = {"ItemGUID":itemGUID} addItemList = [{"ItemID":itemID, "Count":itemCount, "IsAuctionItem":False, "UserData":auctionItem.UserData}] PlayerCompensation.SendMailByKey("PaimaiMail3", [bidderID], addItemList, paramList, detail=detail) AddAuctionRecord(auctionItem, AuctionRecordResult_BidOK) # ÅÄÂô³É¹¦ÊÕÒ棬¶¼ÒÔÍæ¼ÒÊÕÒæÏòÉÏÈ¡Õû if familyID and auctionItem.FamilyPlayerIDInfo: familyPlayerIDList = json.loads(auctionItem.FamilyPlayerIDInfo) taxRate = IpyGameDataPY.GetFuncCfg("AuctionTaxrate", 2) # ÏÉÃËÅÄÆ·Ë°ÂÊ°Ù·Ö±È personMaxRate = IpyGameDataPY.GetFuncCfg("AuctionTaxrate", 3) # ÏÉÃËÅÄÆ·¸öÈË×î´óÊÕÒæ°Ù·Ö±È taxGold = max(1, int(bidderPrice * taxRate / 100.0)) # ×îÉÙÊÕË°1 giveTotalGold = max(0, bidderPrice - taxGold) giveMaxGold = int(math.ceil(giveTotalGold * personMaxRate / 100.0)) memCount = len(familyPlayerIDList) giveGoldAverage = min(giveMaxGold, int(math.ceil(giveTotalGold * 1.0 / memCount))) # ÓÐÊÕÒæµÄÈËƽ·Ö # ÏÉÃËÅÄÆ·ÊÕÒæÓʼþ detail = {"ItemGUID":itemGUID, "ItemID":itemID, "Count":itemCount, "BidderPrice":bidderPrice, "FamilyPlayerIDList":familyPlayerIDList} paramList = [itemID, itemID, auctionItem.BidderName, bidderPrice, taxRate, giveGoldAverage, personMaxRate] PlayerCompensation.SendMailByKey("PaimaiMail6", familyPlayerIDList, [], paramList, gold=giveGoldAverage, detail=detail, moneySource=ChConfig.Def_GiveMoney_AuctionGain) elif playerID: taxRate = IpyGameDataPY.GetFuncCfg("AuctionTaxrate", 1) # È«·þÅÄÆ·Ë°ÂÊ°Ù·Ö±È taxGold = max(1, int(bidderPrice * taxRate / 100.0)) # ×îÉÙÊÕË°1 givePlayerGold = max(0, bidderPrice - taxGold) # ¸öÈËÅÄÂôÊÕÒæÓʼþ detail = {"ItemGUID":itemGUID, "ItemID":itemID, "Count":itemCount, "BidderPrice":bidderPrice} paramList = [itemID, itemID, auctionItem.BidderName, bidderPrice, taxRate, givePlayerGold] PlayerCompensation.SendMailByKey("PaimaiMail5", [playerID], [], paramList, gold=givePlayerGold, detail=detail, moneySource=ChConfig.Def_GiveMoney_AuctionGain) AddAuctionRecord(auctionItem, AuctionRecordResult_SellOK) ipyData = IpyGameDataPY.GetIpyGameData("AuctionItem", itemID) if ipyData and ipyData.GetNeedWorldNotify(): PlayerControl.WorldNotify(0, "Paimai6", [auctionItem.BidderName, bidderID, auctionItem.AuctionType, bidderPrice, itemID]) else: # ÏÉÃËÅÄÆ·»ØÊÕ if familyID: endType = "Recycle" AddAuctionRecord(auctionItem, AuctionRecordResult_Recycle) # ¸öÈËÅÄÆ·Á÷ÅÄ£¬ÎïÆ··µ»¹ else: endType = "Return" # Á÷ÅÄ·µ»¹ÎïÆ·Óʼþ paramList = [] detail = {"ItemGUID":itemGUID} addItemList = [{"ItemID":itemID, "Count":itemCount, "IsAuctionItem":False, "UserData":auctionItem.UserData}] PlayerCompensation.SendMailByKey("PaimaiMail4", [playerID], addItemList, paramList, detail=detail) AddAuctionRecord(auctionItem, AuctionRecordResult_SellFail) drDict = {"AuctionItemInfo":__GetAuctionItemDRDict(auctionItem), "EndType":endType, "EndEvent":endEvent} DR_AuctionHouse(None, "EndAuctionItem", drDict) GameWorld.DebugLog("½áÊø¾ºÅÄ: itemID=%s,itemCount=%s,familyID=%s,endType=%s,endEvent=%s,itemGUID=%s" % (itemID, itemCount, familyID, endType, endEvent, itemGUID), playerID) auctionItemMgr.allAuctionItemDict.pop(itemGUID, None) if auctionItem in auctionItemMgr.allAuctionItemByEndTimeList: auctionItemMgr.allAuctionItemByEndTimeList.remove(auctionItem) if auctionItem in auctionItemMgr.worldAuctionItemList: auctionItemMgr.worldAuctionItemList.remove(auctionItem) for queryItemList in auctionItemMgr.worldAuctionItemQueryDict.values(): if auctionItem in queryItemList: queryItemList.remove(auctionItem) if familyID and familyID in auctionItemMgr.familyAuctionItemDict: familyItemList = auctionItemMgr.familyAuctionItemDict[familyID] if auctionItem in familyItemList: familyItemList.remove(auctionItem) for nowBiddingItemList in auctionItemMgr.nowBiddingAuctionItemDict.values(): if auctionItem in nowBiddingItemList: nowBiddingItemList.remove(auctionItem) for hisBiddingItemList in auctionItemMgr.hisBiddingAuctionItemDict.values(): if auctionItem in hisBiddingItemList: hisBiddingItemList.remove(auctionItem) if playerID and playerID in auctionItemMgr.myAuctionItemDict: playerItemList = auctionItemMgr.myAuctionItemDict[playerID] if auctionItem in playerItemList: playerItemList.remove(auctionItem) for attentionItemList in auctionItemMgr.myAttentionItemDict.values(): if auctionItem in attentionItemList: attentionItemList.remove(auctionItem) clearItem = ChPyNetSendPack.tagGCClearAuctionItem() clearItem.ItemGUID = itemGUID clearAuctionItemList.append(clearItem) if not clearAuctionItemList: return 0 clearCount = len(clearAuctionItemList) clientPack = ChPyNetSendPack.tagGCClearAuctionItemInfo() clientPack.ClearAuctionItemList = clearAuctionItemList clientPack.ClearCount = len(clientPack.ClearAuctionItemList) playerManager = GameWorld.GetPlayerManager() for i in xrange(playerManager.GetActivePlayerCount()): player = playerManager.GetActivePlayerAt(i) if player == None: continue if PlayerControl.GetIsTJG(player): continue NetPackCommon.SendFakePack(player, clientPack) return clearCount def MapServer_AuctionHouseLogic(curPlayer, msgList, tick): ## µØͼÍæ¼ÒÅÄÂô´¦Àí playerID = 0 if not curPlayer else curPlayer.GetPlayerID() queryType, queryData = msgList result = [] GameWorld.Log("ÊÕµ½µØͼÅÄÂôÐÐÐÅÏ¢: queryType=%s,queryData=%s" % (queryType, queryData), playerID) if not GetAuctionHouseState(): if curPlayer: PlayerControl.NotifyCode(curPlayer, "AuctionHouseClose") return # ²éѯÍæ¼Ò¿É·ñÉÏ¼Ü if queryType == "AddAuctionItemQuery": canSell = __CheckPlayerCanAddAuctionItem(curPlayer) if not canSell: return result = [canSell] # Ö´ÐÐÉϼÜÎïÆ· elif queryType == "AddAuctionItem": addAuctionItemList = queryData __AddAuctionItemByList(curPlayer, addAuctionItemList) return # ²éѯÍæ¼Ò¿É·ñ¾º¼ÛÎïÆ· elif queryType == "BidAuctionItemQuery": itemGUID, biddingPrice = queryData itemID, errInfo = __DoPlayerBidAuctionItem(curPlayer, itemGUID, biddingPrice, tick, True) GameWorld.DebugLog(" itemID=%s,errInfo=%s" % (itemID, errInfo), playerID) if errInfo: return if not itemID: return result = [itemID] # Ö´ÐÐÍæ¼Ò¾º¼ÛÎïÆ· elif queryType == "BidAuctionItem": itemGUID, biddingPrice = queryData itemID, errInfo = __DoPlayerBidAuctionItem(curPlayer, itemGUID, biddingPrice, tick, False) if errInfo: GameWorld.DebugLog(" errInfo=%s" % errInfo, playerID) drDict = {"ItemGUID":itemGUID, "BiddingPrice":biddingPrice, "ErrInfo":errInfo} DR_AuctionHouse(curPlayer, "BidAuctionItemError", drDict) return elif queryType == "ClearAuctionItem": __DoGMClearAuctionItem(curPlayer) return elif queryType == "PrintAuctionItem": __DoGMPrintAuctionItem(curPlayer) return resultMsg = str([queryType, queryData, result]) if curPlayer: curPlayer.MapServer_QueryPlayerResult(0, 0, "AuctionHouse", resultMsg, len(resultMsg)) return def __CheckPlayerCanAddAuctionItem(curPlayer): ## ¼ì²éÍæ¼Ò¿É·ñÉϼÜÅÄÆ· playerID = curPlayer.GetPlayerID() maxSellCount = IpyGameDataPY.GetFuncCfg("AuctionHouse", 2) if maxSellCount: playerAuctionItemList = GetPlayerAuctionItemList(playerID) playerSellCount = len(playerAuctionItemList) canSell = playerSellCount < maxSellCount if not canSell: PlayerControl.NotifyCode(curPlayer, "SellCountLimit") return canSell return True def __AddAuctionItemByList(curPlayer, addAuctionItemList): ''' ÅúÁ¿Ìí¼ÓÅÄÆ· @param curPlayer: ¿ÉÄÜΪNone ''' isSortWorldItem = False notifyAddItemList = [] # ÐÂÔöÅÄƷ֪ͨ [[itemGUID, itemID, playerID], ...] notifyFamilyAddItemDict = {} # ÐÂÔöÏÉÃËÅÄƷ֪ͨ {familyID:[auctionItem, ...], ...} for playerID, familyID, familyPlayerIDList, itemData in addAuctionItemList: if not playerID and not familyID: continue auctionItem = __DoAddAuctionItem(curPlayer, playerID, familyID, familyPlayerIDList, itemData) if not auctionItem: continue itemGUID = auctionItem.ItemGUID itemID = auctionItem.ItemID notifyAddItemList.append([itemGUID, itemID, playerID]) if familyID: familyAddItemList = notifyFamilyAddItemDict.get(familyID, []) familyAddItemList.append(auctionItem) notifyFamilyAddItemDict[familyID] = familyAddItemList else: isSortWorldItem = True if notifyAddItemList: __SortAuctionitem(isSortWorldItem=isSortWorldItem) # ֪ͨÐÂÔöÏÉÃËÅÄÆ· for familyID, familyAddItemList in notifyFamilyAddItemDict.items(): Sync_FamilyAuctionItemInfo(None, familyID, familyAddItemList) # ֪ͨÅÄÆ·¹Ø×¢Íæ¼Ò __NotifyAuctionPlayerAddItem(notifyAddItemList) return def __DoAddAuctionItem(curPlayer, playerID, familyID, familyPlayerIDList, itemData): ## Ìí¼ÓÅÄÆ· itemID = itemData.get("ItemID", 0) ipyData = IpyGameDataPY.GetIpyGameData("AuctionItem", itemID) if not ipyData: return itemGUID = itemData.get("GUID", "") auctionItem = PyGameDataStruct.tagDBAuctionItem() auctionItem.ItemGUID = itemGUID auctionItem.PlayerID = playerID auctionItem.FamilyID = familyID auctionItem.ItemID = itemID auctionItem.Count = itemData.get("ItemCount", 0) auctionItem.AddTime = GameWorld.GetCurrentDataTimeStr() auctionItem.ItemType = itemData.get("ItemType", 0) auctionItem.ItemJobLimit = itemData.get("ItemJobLimit", 0) auctionItem.ItemClassLV = itemData.get("ItemClassLV", 0) auctionItem.UserData = itemData.get("UserData", "") auctionItem.UserDataLen = len(auctionItem.UserData) auctionItem.FamilyPlayerIDInfo = str(familyPlayerIDList) auctionItem.FamilyPlayerIDLen = len(auctionItem.FamilyPlayerIDInfo) if not __InitAuctionItemAttrEx(auctionItem): return auctionItemMgr = PyDataManager.GetAuctionItemManager() auctionItemMgr.allAuctionItemDict[auctionItem.ItemGUID] = auctionItem auctionItemMgr.allAuctionItemByEndTimeList.append(auctionItem) if familyID: auctionItem.AuctionType = AuctionType_Family familyItemList = auctionItemMgr.familyAuctionItemDict.get(familyID, []) familyItemList.append(auctionItem) auctionItemMgr.familyAuctionItemDict[familyID] = familyItemList else: auctionItem.AuctionType = AuctionType_World auctionItemMgr.worldAuctionItemList.append(auctionItem) # Ìí¼Ó½øÎÒµÄÅÄÂô if playerID: myAuctionItemList = auctionItemMgr.myAuctionItemDict.get(playerID, []) myAuctionItemList.append(auctionItem) auctionItemMgr.myAuctionItemDict[playerID] = myAuctionItemList if curPlayer: Sync_PlayerAuctionItemInfo(curPlayer, auctionItem) # Ìí¼Ó½øÎҵĹØ×¢ attentionMgr = PyDataManager.GetAuctionAttentionManager() for attentionPlayerID, attentionList in auctionItemMgr.myAttentionItemDict.items(): if itemID not in GetPlayerAuctionAttention(attentionMgr, attentionPlayerID): continue if auctionItem not in attentionList: attentionList.append(auctionItem) if ipyData.GetNeedWorldNotify(): PlayerControl.WorldNotify(0, "Paimai4", [itemID, ipyData.GetNoticeSaleMinutes()]) drDict = {"AuctionItemInfo":__GetAuctionItemDRDict(auctionItem)} DR_AuctionHouse(curPlayer, "AddAuctionItem", drDict) GameWorld.DebugLog("ÉϼÜÅÄÆ·: playerID=%s,familyID=%s,%s" % (playerID, familyID, drDict), playerID) GameWorld.DebugLog("¸üÐÂÅÄÆ·Êý: %s" % len(auctionItemMgr.allAuctionItemDict)) return auctionItem def __NotifyAuctionPlayerAddItem(notifyAddItemList): ## ֪ͨ¹Ø×¢ÎïÆ·µÄÍæ¼ÒÐÂÉϼÜÎïÆ·ÁË if not notifyAddItemList: return attentionMgr = PyDataManager.GetAuctionAttentionManager() playerManager = GameWorld.GetPlayerManager() for i in xrange(playerManager.GetActivePlayerCount()): player = playerManager.GetActivePlayerAt(i) if player == None: continue if PlayerControl.GetIsTJG(player): continue playerAttentionIDList = GetPlayerAuctionAttention(attentionMgr, player.GetPlayerID()) if not playerAttentionIDList: continue infoPack = None for itemGUID, itemID, playerID in notifyAddItemList: if playerID and playerID == player.GetPlayerID(): # ×Ô¼ºÉϼܵÄÎïÆ·²»Í¨Öª continue if itemID not in playerAttentionIDList: continue if not infoPack: infoPack = ChPyNetSendPack.tagGCAddAuctionItemInfo() itemInfo = ChPyNetSendPack.tagGCAddAuctionItem() itemInfo.ItemGUID = itemGUID itemInfo.ItemID = itemID infoPack.AddAuctionItemList.append(itemInfo) if infoPack: infoPack.AddCount = len(infoPack.AddAuctionItemList) NetPackCommon.SendFakePack(player, infoPack) return def __DoPlayerBidAuctionItem(curPlayer, itemGUID, biddingPrice, tick, isOnlyCheck): ''' Íæ¼Ò¾º¼ÛÎïÆ· @param curPlayer: ¾º¼ÛµÄÍæ¼Ò @param itemGUID: ÅÄÆ·GUID @param biddingPrice: ¾º¼Û @param isOnlyCheck: ÊÇ·ñ½ö¼ì²é¿É·ñ¾º¼Û ''' errInfo = "" itemID = 0 auctionItem = GetAuctionItem(itemGUID) if not auctionItem: # ÅÄÆ·²»´æÔÚ PlayerControl.NotifyCode(curPlayer, "Paimai3") errInfo = "not auctionItem" return itemID, errInfo itemID = auctionItem.ItemID ipyData = IpyGameDataPY.GetIpyGameData("AuctionItem", itemID) if not ipyData: errInfo = "not ipyData" return itemID, errInfo playerID = curPlayer.GetPlayerID() addTimeStr = auctionItem.AddTime auctionType = auctionItem.AuctionType # 0-È«·þÅÄÆ·£¬1-ÏÉÃËÅÄÆ· addTime = GameWorld.ChangeTimeStrToNum(addTimeStr) curTime = int(time.time()) passMinutes = (curTime - addTime) / 60 noticeMinutes = ipyData.GetNoticeSaleMinutes() if passMinutes < noticeMinutes: GameWorld.ErrLog("ÅÄÆ·ÉÐ먦·Å¾º¼Û! itemGUID=%s,itemID=%s,addTimeStr=%s" % (itemGUID, itemID, addTimeStr), playerID) errInfo = "in notice time" return itemID, errInfo if auctionType == AuctionType_Family: itemFamilyID = auctionItem.FamilyID playerFamilyID = curPlayer.GetFamilyID() if not playerFamilyID or playerFamilyID != itemFamilyID: GameWorld.ErrLog("¸ÃÅÄƷΪÏÉÃË˽ÓÐÅÄÆ·£¬·Ç±¾ÏÉÃËÈËÔ±²»¿É¾ºÅÄ! itemGUID=%s,itemID=%s,itemFamilyID=%s,playerFamilyID=%s" % (itemGUID, itemID, itemFamilyID, playerFamilyID), playerID) errInfo = "is family auction item" return itemID, errInfo if curTime > auctionItem.EndTime: GameWorld.ErrLog("ÅÄÆ·ÒѽáÊø¾º¼Û! itemGUID=%s,itemID=%s,addTimeStr=%s" % (itemGUID, itemID, addTimeStr), playerID) errInfo = "end bid" return itemID, errInfo nextPrice = ipyData.GetBasePrice() * auctionItem.Count if not auctionItem.BidderPrice else (auctionItem.BidderPrice + ipyData.GetBiddingAdd() * auctionItem.Count) buyoutPrice = ipyData.GetBuyoutPrice() * auctionItem.Count # ÔÊÐíûÓÐÒ»¿Ú¼ÛµÄ£¬´ú±í¿ÉÒÔÒ»Ö±¾º¼Û nextPrice = nextPrice if not buyoutPrice else min(nextPrice, buyoutPrice) # ²»³¬¹ýÒ»¿Ú¼Û if not (biddingPrice == nextPrice or (buyoutPrice and biddingPrice == buyoutPrice)): # ¾º¼Û¼Û¸ñ´íÎó PlayerControl.NotifyCode(curPlayer, "Paimai2") errInfo = "bid price error! biddingPrice=%s,nextPrice=%s,buyoutPrice=%s,itemGUID=%s,itemID=%s" % (biddingPrice, nextPrice, buyoutPrice, itemGUID, itemID) return itemID, errInfo if isOnlyCheck: queryTick = auctionItem.BiddingQueryTick if queryTick and tick - queryTick < BiddingQueryLockTick: # ÓÐÍæ¼ÒÕýÔÚ¾º¼Û£¬ÇëÉÔµÈ PlayerControl.NotifyCode(curPlayer, "Paimai1") errInfo = "other player bidding" return itemID, errInfo auctionItem.BiddingQueryID = playerID auctionItem.BiddingQueryTick = tick return itemID, errInfo if auctionItem.BiddingQueryID != playerID: PlayerControl.NotifyCode(curPlayer, "Paimai2") errInfo = "bidding player error" return itemID, errInfo lastBidderID = auctionItem.BidderID lastBidderPrice = auctionItem.BidderPrice itemCount = auctionItem.Count isBuyout = buyoutPrice and biddingPrice >= buyoutPrice # ´óÓÚµÈÓÚÒ»¿Ú¼Û£¬Ö±½Ó³É½» auctionItemMgr = PyDataManager.GetAuctionItemManager() nowBiddingAuctionItemDict = auctionItemMgr.nowBiddingAuctionItemDict hisBiddingAuctionItemDict = auctionItemMgr.hisBiddingAuctionItemDict # Óʼþ·µ»¹Éϸö¾º¼ÛÕß if lastBidderID and lastBidderPrice: detail = {"ItemID":itemID, "ItemGUID":itemGUID, "Count":itemCount} if isBuyout: # ¾ºÅÄʧ°Ü£¬½ö֪ͨ paramList = [itemID, itemID, lastBidderPrice] PlayerCompensation.SendMailByKey("PaimaiMail2", [lastBidderID], [], paramList, gold=lastBidderPrice, detail=detail, moneySource=ChConfig.Def_GiveMoney_AuctionBidReturn) else: # ¾ºÅÄʧ°Ü£¬¿É¼ÌÐø¾º¼ÛÓʼþ paramList = [itemID, itemID, lastBidderPrice, itemGUID] PlayerCompensation.SendMailByKey("PaimaiMail1", [lastBidderID], [], paramList, gold=lastBidderPrice, detail=detail, moneySource=ChConfig.Def_GiveMoney_AuctionBidReturn) AddAuctionRecord(auctionItem, AuctionRecordResult_BidFail) isSyncBiddingItem = False nowBiddingAuctionItemList = nowBiddingAuctionItemDict.get(lastBidderID, []) if auctionItem in nowBiddingAuctionItemList: nowBiddingAuctionItemList.remove(auctionItem) nowBiddingAuctionItemDict[lastBidderID] = nowBiddingAuctionItemList isSyncBiddingItem = True hisBiddingAuctionItemList = hisBiddingAuctionItemDict.get(lastBidderID, []) if auctionItem not in hisBiddingAuctionItemList: hisBiddingAuctionItemList.append(auctionItem) hisBiddingAuctionItemDict[lastBidderID] = hisBiddingAuctionItemList isSyncBiddingItem = True if isSyncBiddingItem: lastBidder = GameWorld.GetPlayerManager().FindPlayerByID(lastBidderID) if lastBidder and not PlayerControl.GetIsTJG(lastBidder): Sync_PlayerBiddingItemInfo(lastBidder, auctionItem) # ¸üоº¼ÛÐÅÏ¢ auctionItem.BiddingQueryID = 0 auctionItem.BiddingQueryTick = 0 auctionItem.BiddingTime = GameWorld.GetCurrentDataTimeStr() auctionItem.BidderID = playerID auctionItem.BidderName = curPlayer.GetName() auctionItem.BidderPrice = biddingPrice isSyncBiddingItem = False nowBiddingAuctionItemList = nowBiddingAuctionItemDict.get(playerID, []) if auctionItem not in nowBiddingAuctionItemList: nowBiddingAuctionItemList.append(auctionItem) nowBiddingAuctionItemDict[playerID] = nowBiddingAuctionItemList isSyncBiddingItem = True hisBiddingAuctionItemList = hisBiddingAuctionItemDict.get(playerID, []) if auctionItem in hisBiddingAuctionItemList: hisBiddingAuctionItemList.remove(auctionItem) hisBiddingAuctionItemDict[playerID] = hisBiddingAuctionItemList isSyncBiddingItem = True if isSyncBiddingItem: Sync_PlayerBiddingItemInfo(curPlayer, auctionItem) # Ìí¼ÓÀúÊ·¾º¼ÛÕß if str(playerID) not in auctionItem.BidderIDInfo: auctionItem.BidderIDInfo += "%s|" % playerID auctionItem.BidderIDLen = len(auctionItem.BidderIDInfo) GameWorld.DebugLog("Íæ¼Ò¾º¼ÛÅÄÆ·: itemGUID=%s,itemID=%s,isBuyout=%s,lastBidderID=%s,lastBidderPrice=%s,bidderIDInfo=%s" % (itemGUID, itemID, isBuyout, lastBidderID, lastBidderPrice, auctionItem.BidderIDInfo), playerID) if isBuyout: __EndAuctionItem([auctionItem], "Buyout") else: if __AddAuctionItemEndTimeByBid(auctionItem): __SortAuctionitem(isSortWorldItem=False) drDict = {"AuctionItemInfo":__GetAuctionItemDRDict(auctionItem)} DR_AuctionHouse(curPlayer, "BidAuctionItem", drDict) __SyncRefreshAuctionItem([auctionItem]) return itemID, errInfo def __SyncRefreshAuctionItem(auctionItemList): ''' // B5 08 ÅÄÂôÐÐË¢ÐÂÅÄÆ· #tagGCRefreshAuctionItemInfo 1-ÏÉÃËÅÄƷתÒƵ½È«·þʱ֪ͨ£» 2-ÅÄÆ·ÓÐÈ˾º¼ÛʱˢР''' refreshAuctionItemList = [] for auctionItem in auctionItemList: refreshItem = ChPyNetSendPack.tagGCRefreshAuctionItem() refreshItem.ItemGUID = auctionItem.ItemGUID refreshItem.AuctionType = auctionItem.AuctionType refreshItem.AddTime = auctionItem.AddTime refreshItem.BidderID = auctionItem.BidderID refreshItem.BidderPrice = auctionItem.BidderPrice refreshItem.BiddingTime = auctionItem.BiddingTime refreshAuctionItemList.append(refreshItem) if not refreshAuctionItemList: return clientPack = ChPyNetSendPack.tagGCRefreshAuctionItemInfo() clientPack.RefreshAuctionItemList = refreshAuctionItemList clientPack.RefreshCount = len(clientPack.RefreshAuctionItemList) playerManager = GameWorld.GetPlayerManager() for i in xrange(playerManager.GetActivePlayerCount()): player = playerManager.GetActivePlayerAt(i) if player == None: continue if PlayerControl.GetIsTJG(player): continue NetPackCommon.SendFakePack(player, clientPack) return def __DoGMClearAuctionItem(curPlayer): if curPlayer.GetGMLevel() != 90: return allAuctionItemByEndTimeList = PyDataManager.GetAuctionItemManager().allAuctionItemByEndTimeList if not allAuctionItemByEndTimeList: GameWorld.DebugAnswer(curPlayer, "µ±Ç°Ã»ÓÐÅÄÆ·!") return endItemList = [] for auctionItem in allAuctionItemByEndTimeList: endItemList.append(auctionItem) clearCount = __EndAuctionItem(endItemList, "GMClear") GameWorld.DebugAnswer(curPlayer, "Çå¿ÕÅÄÆ·Êý=%s" % clearCount) return def __DoGMPrintAuctionItem(curPlayer): if curPlayer.GetGMLevel() != 90: return auctionItemMgr = PyDataManager.GetAuctionItemManager() allAuctionItemByEndTimeList = auctionItemMgr.allAuctionItemByEndTimeList GameWorld.DebugLog("TimeList×ÜÅÄÆ·Êý: =%s" % len(allAuctionItemByEndTimeList)) for i, auctionItem in enumerate(allAuctionItemByEndTimeList): GameWorld.DebugLog(" i=%s, %s" % (i, __GetAuctionItemDRDict(auctionItem))) GameWorld.DebugLog("AllDict×ÜÅÄÆ·Êý: =%s" % len(auctionItemMgr.allAuctionItemDict)) GameWorld.DebugLog("È«·þÅÄÆ·¸öÊý: =%s" % len(auctionItemMgr.worldAuctionItemList)) for familyID, familyItemList in auctionItemMgr.familyAuctionItemDict.items(): GameWorld.DebugLog("ÏÉÃËÅÄÆ·¸öÊý: familyID=%s, %s" % (familyID, len(familyItemList))) for playerID, myItemList in auctionItemMgr.myAuctionItemDict.items(): GameWorld.DebugLog("Íæ¼ÒÅÄÆ·¸öÊý: playerID=%s, %s" % (playerID, len(myItemList))) for playerID, nowBiddingItemList in auctionItemMgr.nowBiddingAuctionItemDict.items(): GameWorld.DebugLog("Íæ¼Ò×î¸ß¾º¼ÛÅÄÆ·¸öÊý: playerID=%s, %s" % (playerID, len(nowBiddingItemList))) for playerID, hisBiddingItemList in auctionItemMgr.hisBiddingAuctionItemDict.items(): GameWorld.DebugLog("Íæ¼ÒÀúÊ·¾º¼ÛÅÄÆ·¸öÊý: playerID=%s, %s" % (playerID, len(hisBiddingItemList))) for playerID, attentionItemList in auctionItemMgr.myAttentionItemDict.items(): GameWorld.DebugLog("Íæ¼Ò¹Ø×¢ÅÄÆ·¸öÊý: playerID=%s, %s" % (playerID, len(attentionItemList))) return #// B5 10 ÅÄÂôÐвéѯÅÄÂôÖеÄÎïÆ· #tagCGQueryAuctionItem # #struct tagCGQueryAuctionItem #{ # tagHead Head; # BYTE Job; //¹ýÂËÖ°Òµ£¬0Ϊ²»ÏÞÖÆ # BYTE ItemTypeCount; # DWORD ItemTypeList[ItemTypeCount]; //Ö¸¶¨µÄÎïÆ·ÀàÐÍ # BYTE ClassLV; //¹ýÂ˽×Êý£¬0Ϊ²»ÏÞÖÆ # BYTE SpecItemIDCount; //Ö¸¶¨ÎïÆ·ID¸öÊý # DWORD SpecItemIDList[SpecItemIDCount]; //Ö¸¶¨ÎïÆ·ID # char FromItemGUID[40]; //´ÓÄĸöÎïÆ·¿ªÊ¼²éѯ # BYTE QueryDir; //²éѯ·½Ïò£¬1-Íùºó²é£¬2-ÍùÇ°²é # BYTE QueryCount; //²éѯ¸öÊý£¬0Ϊȫ²¿ #}; def OnQueryAuctionItem(index, clientData, tick): curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index) job = clientData.Job itemTypeList = clientData.ItemTypeList classLV = clientData.ClassLV specItemIDList = clientData.SpecItemIDList fromItemGUID = clientData.FromItemGUID queryDir = clientData.QueryDir queryCount = clientData.QueryCount __Sync_WorldAuctionItemQueryResult(curPlayer, job, itemTypeList, classLV, specItemIDList, fromItemGUID, queryDir, queryCount) return #// B5 17 ÅÄÂôÐвéѯ¶¨Î»Ä¿±êÅÄÆ· #tagCGQueryTagAuctionItem # #struct tagCGQueryTagAuctionItem #{ # tagHead Head; # char ItemGUID[40]; # DWORD ItemID; #}; def OnQueryTagAuctionItem(index, clientData, tick): curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index) tagItemGUID = clientData.ItemGUID queryDir = 3 __Sync_WorldAuctionItemQueryResult(curPlayer, fromItemGUID=tagItemGUID, queryDir=queryDir, isNotify=True) return def __Sync_WorldAuctionItemQueryResult(curPlayer, job=0, itemTypeList=[], classLV=0, specItemIDList=[], fromItemGUID="", queryDir=1, queryCount=10, isNotify=False): ## ¸ù¾Ý¹ýÂËÌõ¼þͬ²½È«·þÅÄÆ·ÁÐ±í£¬Ä¿Ç°½öÈ«·þÅÄÆ·ÐèҪͨ¹ý²éѯ·þÎñÆ÷»ñµÃ£¬¸öÈËÅÄÆ·¼°ÏÉÃËÅÄÆ·ÓÉÓÚ¸öÊý½ÏÉÙÖ±½ÓÓÉÉÏÏß»ò±ä¸üʱÖ÷¶¯Í¬²½ fromAuctionItem = None if fromItemGUID: fromAuctionItem = GetAuctionItem(fromItemGUID) if not fromAuctionItem: GameWorld.DebugLog("²éѯµÄÄ¿±êÅÄÆ·²»´æÔÚ! fromItemGUID=%s" % fromItemGUID) if isNotify: PlayerControl.NotifyCode(curPlayer, "Paimai5") return # {(job, (itemType, ...), itemClassLV, (itemID, ...)):[tagDBAuctionItem, ...], ...} queryKey = (job, tuple(itemTypeList), classLV, tuple(specItemIDList)) auctionItemMgr = PyDataManager.GetAuctionItemManager() worldAuctionItemQueryDict = auctionItemMgr.worldAuctionItemQueryDict if queryKey not in worldAuctionItemQueryDict: # ÔØÈë¶ÔÓ¦²éѯÌõ¼þÅÄÆ·»º´æ auctionItemQueryList = [] for worldAuctionItem in auctionItemMgr.worldAuctionItemList: if job and worldAuctionItem.ItemJobLimit != job and worldAuctionItem.ItemJobLimit: continue if itemTypeList and worldAuctionItem.ItemType not in itemTypeList: continue if classLV and worldAuctionItem.ItemClassLV != classLV: continue if specItemIDList and worldAuctionItem.ItemID not in specItemIDList: continue auctionItemQueryList.append(worldAuctionItem) worldAuctionItemQueryDict[queryKey] = auctionItemQueryList else: auctionItemQueryList = worldAuctionItemQueryDict[queryKey] queryTotalCount = len(auctionItemQueryList) fromIndex = 0 if fromAuctionItem: if fromAuctionItem not in auctionItemQueryList: GameWorld.ErrLog("²éѯµÄÄ¿±êÅÄÆ·²»ÔÚËùÔڵĹýÂ˵ÄÌõ¼þÀï! fromItemGUID=%s" % fromItemGUID) if isNotify: PlayerControl.NotifyCode(curPlayer, "Paimai5") return fromIndex = auctionItemQueryList.index(fromAuctionItem) # ÏòÇ°²é£¬ÆäËûµÄĬÈÏÏòºó²é if queryDir == 2: startIndex = max(0, fromIndex - queryCount + 1) syncItemList = auctionItemQueryList[startIndex:fromIndex + 1] queryRemainlCount = startIndex # Ïòºó²é else: syncItemList = auctionItemQueryList[fromIndex:fromIndex + queryCount] queryRemainlCount = max(0, queryTotalCount - fromIndex - queryCount) clientPack = ChPyNetSendPack.tagGCAuctionItemInfo() clientPack.Job = job clientPack.ItemTypeList = itemTypeList clientPack.ItemTypeCount = len(clientPack.ItemTypeList) clientPack.ClassLV = classLV clientPack.SpecItemIDList = specItemIDList clientPack.SpecItemIDCount = len(clientPack.SpecItemIDList) clientPack.FromItemGUID = fromItemGUID clientPack.QueryDir = queryDir clientPack.QueryCount = queryCount clientPack.QueryRemainlCount = queryRemainlCount clientPack.AuctionItemList = [] for auctionItem in syncItemList: itemInfo = ChPyNetSendPack.tagGCAuctionItem() itemInfo.ItemGUID = auctionItem.ItemGUID itemInfo.FamilyID = auctionItem.FamilyID itemInfo.ItemID = auctionItem.ItemID itemInfo.ItemCount = auctionItem.Count itemInfo.AddTime = auctionItem.AddTime itemInfo.BidderPrice = auctionItem.BidderPrice itemInfo.BiddingTime = auctionItem.BiddingTime itemInfo.UserData = auctionItem.UserData itemInfo.UserDataLen = auctionItem.UserDataLen clientPack.AuctionItemList.append(itemInfo) clientPack.AuctionItemCount = len(clientPack.AuctionItemList) NetPackCommon.SendFakePack(curPlayer, clientPack) return #// B5 12 ÅÄÂôÐвéѯÅÄÂô¼Ç¼ #tagCGQueryAuctionRecord # #struct tagCGQueryAuctionRecord #{ # tagHead Head; # BYTE RecordType; //¼Ç¼ÀàÐÍ 0-ÎÒµÄÅÄÆ·¼Ç¼ 1-ÏÉÃËÅÄÆ·¼Ç¼ 2-ÎҵľºÅļǼ #}; def OnQueryAuctionRecord(index, clientData, tick): curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index) recordType = clientData.RecordType Sync_PlayerAuctionRecordInfo(curPlayer, recordType, None, curPlayer.GetFamilyID()) return #// B5 16 ÅÄÂôÐвéѯ¹Ø×¢ÖеÄÅÄÆ· #tagCGQueryAttentionAuctionItem # #struct tagCGQueryAttentionAuctionItem #{ # tagHead Head; #}; def OnQueryAttentionAuctionItem(index, clientData, tick): curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index) playerID = curPlayer.GetPlayerID() auctionItemMgr = PyDataManager.GetAuctionItemManager() myAttentionItemDict = auctionItemMgr.myAttentionItemDict if playerID in myAttentionItemDict: attentionItemList = myAttentionItemDict[playerID] else: attentionItemList = [] attentionMgr = PyDataManager.GetAuctionAttentionManager() attentionItemIDList = GetPlayerAuctionAttention(attentionMgr, playerID) if attentionItemIDList: for auctionItem in auctionItemMgr.worldAuctionItemList: if auctionItem.ItemID not in attentionItemIDList: continue attentionItemList.append(auctionItem) myAttentionItemDict[playerID] = attentionItemList clientPack = ChPyNetSendPack.tagGCAttentionAuctionItemInfo() clientPack.AuctionItemList = [] for attentionItem in attentionItemList: itemObj = ChPyNetSendPack.tagGCAttentionAuctionItem() itemObj.ItemGUID = attentionItem.ItemGUID itemObj.FamilyID = attentionItem.FamilyID itemObj.ItemID = attentionItem.ItemID itemObj.ItemCount = attentionItem.Count itemObj.AddTime = attentionItem.AddTime itemObj.BidderPrice = attentionItem.BidderPrice itemObj.BiddingTime = attentionItem.BiddingTime itemObj.UserData = attentionItem.UserData itemObj.UserDataLen = attentionItem.UserDataLen clientPack.AuctionItemList.append(itemObj) clientPack.AuctionItemCount = len(clientPack.AuctionItemList) NetPackCommon.SendFakePack(curPlayer, clientPack) return #// B5 18 ÅÄÂôÐÐÐ޸ĹØ×¢ÎïÆ· #tagCGAttentionAuctionItemChange # #struct tagCGAttentionAuctionItemChange #{ # tagHead Head; # DWORD ItemID; # BYTE IsAttention; //ÊÇ·ñ¹Ø×¢£¬È¡Ïû¹Ø×¢·¢0 #}; def OnAttentionAuctionItemChange(index, clientData, tick): curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index) playerID = curPlayer.GetPlayerID() itemID = clientData.ItemID isAttention = clientData.IsAttention attentionMgr = PyDataManager.GetAuctionAttentionManager() if isAttention: if not AddPlayerAuctionAttention(attentionMgr, playerID, itemID): return else: if not DelPlayerAuctionAttention(attentionMgr, playerID, itemID): return Sync_PlayerAttentionAuctionItemID(curPlayer, True) # ¹Ø×¢ÐÅÏ¢±ä¸ü£¬Çå¿Õ¹Ø×¢ÅÄƷʵÀý»º´æ auctionItemMgr = PyDataManager.GetAuctionItemManager() auctionItemMgr.myAttentionItemDict.pop(playerID, None) return def Sync_FamilyAuctionItemInfo(curPlayer, familyID, itemInfoList=[]): # // B5 05 ÅÄÂôÐÐÏÉÃËÅÄÂôÖеÄÎïÆ·ÐÅÏ¢ #tagGCFamilyAuctionItemInfo if not familyID: return if not itemInfoList: itemInfoList = GetFamilyAuctionItemList(familyID) if not itemInfoList: return itemInfoPack = ChPyNetSendPack.tagGCFamilyAuctionItemInfo() itemInfoPack.AuctionItemList = [] for auctionItem in itemInfoList: packItem = ChPyNetSendPack.tagGCFamilyAuctionItem() packItem.ItemGUID = auctionItem.ItemGUID packItem.FamilyID = auctionItem.FamilyID packItem.ItemID = auctionItem.ItemID packItem.ItemCount = auctionItem.Count packItem.AddTime = auctionItem.AddTime packItem.BidderPrice = auctionItem.BidderPrice packItem.BiddingTime = auctionItem.BiddingTime packItem.UserData = auctionItem.UserData packItem.UserDataLen = auctionItem.UserDataLen packItem.FamilyPlayerIDInfo = auctionItem.FamilyPlayerIDInfo packItem.FamilyPlayerIDLen = auctionItem.FamilyPlayerIDLen packItem.AuctionType = auctionItem.AuctionType itemInfoPack.AuctionItemList.append(packItem) itemInfoPack.AuctionItemCount = len(itemInfoPack.AuctionItemList) if curPlayer: NetPackCommon.SendFakePack(curPlayer, itemInfoPack) else: PlayerFamily.SendFamilyFakePack(familyID, itemInfoPack) return def Sync_PlayerAuctionItemInfo(curPlayer, auctionItem=None): # // B5 02 ÅÄÂôÐÐÍæ¼ÒÅÄÂôÖеÄÎïÆ·ÐÅÏ¢ #tagGCPlayerAuctionItemInfo if auctionItem: syncItemList = [auctionItem] else: syncItemList = GetPlayerAuctionItemList(curPlayer.GetPlayerID()) if not syncItemList: return itemInfoPack = ChPyNetSendPack.tagGCPlayerAuctionItemInfo() itemInfoPack.AuctionItemList = [] for auctionItem in syncItemList: packItem = ChPyNetSendPack.tagGCPlayerAuctionItem() packItem.ItemGUID = auctionItem.ItemGUID packItem.FamilyID = auctionItem.FamilyID packItem.ItemID = auctionItem.ItemID packItem.ItemCount = auctionItem.Count packItem.AddTime = auctionItem.AddTime packItem.BidderPrice = auctionItem.BidderPrice packItem.BiddingTime = auctionItem.BiddingTime packItem.UserData = auctionItem.UserData packItem.UserDataLen = auctionItem.UserDataLen itemInfoPack.AuctionItemList.append(packItem) itemInfoPack.AuctionItemCount = len(itemInfoPack.AuctionItemList) NetPackCommon.SendFakePack(curPlayer, itemInfoPack) return def Sync_PlayerAuctionRecordInfo(curPlayer, recordType, newRecordData=None, familyID=0): ## B5 03 ÅÄÂôÐÐÍæ¼ÒÅÄÂô¼Ç¼ #tagGCPlayerAuctionRecordInfo if recordType == AuctionRecordType_MyAuction and curPlayer: syncRecordList = [newRecordData] if newRecordData else GetMyAuctionItemRecord(curPlayer.GetPlayerID()) elif recordType == AuctionRecordType_FamilyAuction and familyID: syncRecordList = [newRecordData] if newRecordData else GetFamilyAuctionItemRecord(familyID) elif recordType == AuctionRecordType_MyBid and curPlayer: syncRecordList = [newRecordData] if newRecordData else GetMyBiddingItemRecord(curPlayer.GetPlayerID()) else: return clientPack = ChPyNetSendPack.tagGCPlayerAuctionRecordInfo() clientPack.AuctionRecordList = [] for recordData in syncRecordList: record = ChPyNetSendPack.tagGCPlayerAuctionRecord() record.ItemGUID = recordData.ItemGUID record.FamilyID = recordData.FamilyID record.RecordType = recordData.RecordType record.RecordResult = recordData.RecordResult record.RecordTime = recordData.RecordTime record.BidderPrice = recordData.BidderPrice record.BidderName = recordData.BidderName record.ItemID = recordData.ItemID record.ItemCount = recordData.Count record.UserData = recordData.UserData record.UserDataLen = recordData.UserDataLen clientPack.AuctionRecordList.append(record) clientPack.Count = len(clientPack.AuctionRecordList) if curPlayer: NetPackCommon.SendFakePack(curPlayer, clientPack) elif familyID and recordType == AuctionRecordType_FamilyAuction: PlayerFamily.SendFamilyFakePack(familyID, clientPack) return def Sync_PlayerBiddingItemInfo(curPlayer, auctionItem=None): #// B5 10 ÅÄÂôÐÐÍæ¼Ò¾º¼ÛÖеÄÎïÆ·ÐÅÏ¢ #tagGCBiddingItemInfo # ÉÏÏßͬ²½¡¢Íæ¼ÒÏà¹ØµÄ¾º¼ÛÅÄÆ·¾º¼Û±ä¸üʱͬ²½ if auctionItem: syncItemList = [auctionItem] else: playerID = curPlayer.GetPlayerID() auctionItemMgr = PyDataManager.GetAuctionItemManager() nowBiddingAuctionItemList = auctionItemMgr.nowBiddingAuctionItemDict.get(playerID, []) hisBiddingAuctionItemList = auctionItemMgr.hisBiddingAuctionItemDict.get(playerID, []) syncItemList = nowBiddingAuctionItemList + hisBiddingAuctionItemList if not syncItemList: return itemInfoPack = ChPyNetSendPack.tagGCBiddingItemInfo() itemInfoPack.AuctionItemList = [] for auctionItem in syncItemList: packItem = ChPyNetSendPack.tagGCBiddingItem() packItem.ItemGUID = auctionItem.ItemGUID packItem.FamilyID = auctionItem.FamilyID packItem.ItemID = auctionItem.ItemID packItem.ItemCount = auctionItem.Count packItem.AddTime = auctionItem.AddTime packItem.BidderID = auctionItem.BidderID packItem.BidderPrice = auctionItem.BidderPrice packItem.BiddingTime = auctionItem.BiddingTime packItem.UserData = auctionItem.UserData packItem.UserDataLen = auctionItem.UserDataLen itemInfoPack.AuctionItemList.append(packItem) itemInfoPack.AuctionItemCount = len(itemInfoPack.AuctionItemList) NetPackCommon.SendFakePack(curPlayer, itemInfoPack) return def Sync_PlayerAttentionAuctionItemID(curPlayer, isForce=False): # // B5 07 ÅÄÂôÐйØ×¢µÄÎïÆ·ID #tagGCAttentionAuctionItemID attentionMgr = PyDataManager.GetAuctionAttentionManager() attentionItemIDList = GetPlayerAuctionAttention(attentionMgr, curPlayer.GetPlayerID()) if not attentionItemIDList and not isForce: return clientPack = ChPyNetSendPack.tagGCAttentionAuctionItemID() clientPack.AttentionItemIDList = attentionItemIDList clientPack.AttentionCount = len(clientPack.AttentionItemIDList) NetPackCommon.SendFakePack(curPlayer, clientPack) return def DR_AuctionHouse(curPlayer, eventName, drDict): accID = "" if not curPlayer else curPlayer.GetAccID() playerID = 0 if not curPlayer else curPlayer.GetPlayerID() dataDict = {"EventName":eventName, "PlayerID":playerID, "AccID":accID} dataDict.update(drDict) DataRecordPack.SendEventPack("AuctionHouse", dataDict, curPlayer) return def DoAddFamilyAuctionItem(mapID, familyAuctionItemDict): ''' ÉϼÜÏÉÃËÅÄÆ·£¬ÒòΪÏÉÃËÅÄƷĬÈÏÉϼܣ¬ËùÒÔʹÓÃÅúÁ¿ÉÏ¼Ü @param familyAuctionItemDict: {ÏÉÃËID:[[ÏíÊÜÊÕÒæµÄ³ÉÔ±ID, ...], [[ÅÄÆ·ID,¸öÊý], [ÅÄÆ·ID,¸öÊý,ÊÇ·ñÅÄÆ·], ...]], ...} ''' GameWorld.Log("·¢Ë͵ØͼÉϼÜÏÉÃËÅÄÆ·: mapID=%s, %s" % (mapID, familyAuctionItemDict)) GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_AddFamilyAuctionItem, [mapID, familyAuctionItemDict]) return