10263 【越南】【BT】增加后台执行命令清除本服榜单某个玩家ID数据： ClearBillboardData

hxp

2025-06-11 2334c75ef35c5ef5432f883c0eb2f4a22209a94a

 ServerPython/CoreServerGroup/GameServer/Script/GameWorld.py

@@ -118,6 +118,14 @@
    except ValueError:

        return defValue

    

def ToFloat(input, defValue = 0):

    try:

        result = float(input)

        return result

    
    except ValueError:

        return defValue

    
## 判断2个对象是否同国籍 

#  @param srcObj 起点对象 

#  @param desObj 目标对象 

@@ -413,6 +421,31 @@
    ## 服务器组ID，必须唯一，代表这台物理服务器

    return ToIntDef(ReadChConfig.GetPyMongoConfig("platform", "GroupID"), 0)



def GetMainServerID(serverID):

    ## 获取服务器ID所属主服ID

    ServerIDMainServerDict = IpyGameDataPY.GetConfigEx("ServerIDMainServerDict")

    if ServerIDMainServerDict == None:

        filePath = ChConfig.GetDBPath() + ("\\MixServerMap_%s.json" % GetPlatform())

        if not os.path.isfile(filePath):

            SendGameErrorEx("GetMainServerIDError", "file can not found. %s" % filePath)

        else:

            fileObj = open(filePath, 'rb')

            content = fileObj.read()

            fileObj.close()

            MixServerMapDict = eval(content)

            
            ServerIDMainServerDict = {}

            for mainServerIDStr, serverIDList in MixServerMapDict.items():

                mainServerID = int(mainServerIDStr)

                for sID in serverIDList:

                    ServerIDMainServerDict[sID] = mainServerID

            IpyGameDataPY.SetConfigEx("ServerIDMainServerDict", ServerIDMainServerDict)

            Log("加载 ServerIDMainServerDict=%s" % ServerIDMainServerDict)

            
    if not ServerIDMainServerDict:

        return serverID

    return ServerIDMainServerDict.get(serverID, serverID)



def GetPlatformServerNum(platform):

    # 获取服务器的平台编号

    platformNumDict = ReadChConfig.GetDBEvalChConfig("DBPlatformNum")

@@ -449,10 +482,10 @@
##获取玩家所属区服ID

# @param curPlayer

# @return

def GetPlayerServerID(curPlayer):

    accID = curPlayer.GetAccID()

def GetPlayerServerID(curPlayer): return GetAccIDServerID(curPlayer.GetAccID())

def GetAccIDServerID(accID):

    infoList = accID.split(Def_AccID_Split_Sign)

    return 0 if len(infoList) < 3 else int(infoList[-1][1:])

    return 0 if len(infoList) < 3 else ToIntDef(infoList[-1][1:])



def GetPlayerServerSID(curPlayer):

    # 返回含s的serverID

@@ -468,6 +501,17 @@
        return mainServerID

    return 0



def CheckServerIDInList(serverID, serverIDList):

    if serverIDList == None:

        return False

    if not serverIDList:

        return True

    for serverIDInfo in serverIDList:

        if (isinstance(serverIDInfo, tuple) and serverIDInfo[0] <= serverID <= serverIDInfo[1]) \

            or (isinstance(serverIDInfo, list) and serverIDInfo[0] <= serverID <= serverIDInfo[1]) \

            or (isinstance(serverIDInfo, int) and serverIDInfo == serverID):

            return True

    return False



#===============================================================================

# ƽ̨ID = appid

@@ -538,6 +582,47 @@


#---------------------------------------------------------------------



def GetTemplateID(ipyData, cfgID, dayIndex):

    if cfgID == None or dayIndex == None or not ipyData:

        return 0

    templateIDList = ipyData.GetTemplateIDList()

    if not templateIDList:

        return 0

    templateID = templateIDList[-1] if dayIndex >= len(templateIDList) else templateIDList[dayIndex]

    return templateID



def GetTemplateIDByList(templateIDList, dayIndex):

    if dayIndex == None:

        return 0

    if not templateIDList:

        return 0

    templateID = templateIDList[-1] if dayIndex >= len(templateIDList) else templateIDList[dayIndex]

    return templateID



def GetOperationActionLoopDate(startDateStr, endDateStr, curDateTime):

    ## 获取运营活动配置日期循环的具体活动时间

    # @return: 开始日期, 结束日期, 返回的日期是第x次循环

    startSplitList = startDateStr.split("_")

    loopDays = int(startSplitList[0][1:])

    startLoopDateStr = startSplitList[1]

    startLoopDateTime = ChangeStrToDatetime(startLoopDateStr, ChConfig.TYPE_Time_YmdFormat)

    
    endSplitList = endDateStr.split("_") # 可不配Lx_开头，防误配，做兼容

    endLoopDateStr = endSplitList[0] if len(endSplitList) == 1 else endSplitList[1]

    endLoopDateTime = ChangeStrToDatetime(endLoopDateStr, ChConfig.TYPE_Time_YmdFormat)

    
    if curDateTime >= startLoopDateTime:

        passDays = (curDateTime - startLoopDateTime).days

        loopTimes = passDays / loopDays + 1 # 第x次循环

        loopTimeMax = (endLoopDateTime - startLoopDateTime).days / loopDays + 1 # 最大循环次数

        loopTimes = min(loopTimes, loopTimeMax)

    else:

        loopTimes = 1 # 还未开始取第一次

        
    startDateTime = startLoopDateTime + datetime.timedelta((loopTimes - 1)*loopDays)

    endDateTime = startDateTime + datetime.timedelta(days=(loopDays - 1))

    return startDateTime, endDateTime, loopTimes



def GetOperationActionDateStr(ipyData):

    ## 获取运营活动对应日期，存数字代表开服天配置，需要转化为对应的日期

    curDateTime = datetime.datetime.today()

@@ -549,7 +634,7 @@
        endDateStr = "%d-%d-%d" % (curDateTime.year, curDateTime.month, curDateTime.day)

        

    # 日期直接返回

    if startDateStr.count("-") == 2 and "W" not in startDateStr:

    if startDateStr.count("-") == 2 and "W" not in startDateStr and not startDateStr.startswith("L"):

        return startDateStr, endDateStr

    

    # 开服天

@@ -596,7 +681,10 @@
            # 只配置结束日期的时候可能导致开始日期计算出来比结束日期还大，即当前时间超过结束日期，且 配置还存在的情况

            if startDateTime > endDateTime:

                startDateTime = endDateTime # 反正都无法开启，随便给个日期，不超过结束日期即可

                
    # 按日期循环

    elif startDateStr.startswith("L"):

        startDateTime, endDateTime, _ = GetOperationActionLoopDate(startDateStr, endDateStr, curDateTime)

        
    # 默认

    else:

        startDateTime = curDateTime

@@ -675,6 +763,15 @@
    return pastTimeDelta.days * 24 * 60 * 60 + pastTimeDelta.seconds



#---------------------------------------------------------------------



def GetDiff_Day(timeA , timeB):

    ## 获取 timeA - timeB 相差的日期天数

    dateTimeA = ChangeTimeNumToDatetime(timeA)

    dateTimeA = datetime.datetime(dateTimeA.year, dateTimeA.month, dateTimeA.day, 0, 0, 0)

    dateTimeB = ChangeTimeNumToDatetime(timeB)

    dateTimeB = datetime.datetime(dateTimeB.year, dateTimeB.month, dateTimeB.day, 0, 0, 0)

    return (dateTimeA - dateTimeB).days



##设置世界服务器字典

# @param key 字典值

# @param tick 时间戳

@@ -918,6 +1015,17 @@
        return ReadChConfig.GetPyMongoConfig("Merge", "CrossZoneName")

    return PyGameData.g_crossZoneName



def GetCrossServerTimeStr():

    ## 跨服服务器时间

    if IsCrossServer():

        return GetCurrentDataTimeStr()

    lastCrossServerTime, lastServerTime, _ = PyGameData.g_crossServerTimeInfo

    if not lastCrossServerTime:

        return GetCurrentDataTimeStr()

    curTime = int(time.time())

    crossServerTime = lastCrossServerTime + (curTime - lastServerTime)

    return ChangeTimeNumToStr(crossServerTime)



## 获取玩家的区服名，仅在跨服有效

#  @param curPlayer 玩家实例

#  @return: 区服名

@@ -959,6 +1067,28 @@
    

    return fullName



def MergeItemList(itemList):

    ## 合并物品列表，将相同物品数量合并

    itemDict = {}

    for itemInfo in itemList:

        if len(itemInfo) == 3:

            itemID, itemCount, isAuctionItem = itemInfo

        elif len(itemInfo) == 2:

            itemID, itemCount = itemInfo

            isAuctionItem = None

        else:

            continue

        key = (itemID, isAuctionItem)

        itemDict[key] = itemDict.get(key, 0) + itemCount

        
    mItemList = []

    for key, itemCount in itemDict.items():

        itemID, isAuctionItem = key

        if isAuctionItem == None:

            mItemList.append([itemID, itemCount])

        else:

            mItemList.append([itemID, itemCount, isAuctionItem])

    return mItemList



## 从列表中产生物品，[[几率，object], ....],万分率

#  @param itemList 待选列表

@@ -1080,7 +1210,7 @@
#  @param order 名次，从1开始

#  @param isDefaultLast 找不到的名次是否默认取最后一名的

#  @return obj or None

def GetOrderValueByDict(orderDict, order, isDefaultLast=True):

def GetOrderValueByDict(orderDict, order, isDefaultLast=True, defaultValue=None):

    if order in orderDict:

        return orderDict[order]

    

@@ -1091,7 +1221,99 @@
                return orderDict[dOrder]

        

    # 找不到的默认取最后一名

    return orderDict[orderList[-1]] if isDefaultLast else None

    return orderDict[orderList[-1]] if isDefaultLast else defaultValue



def GetActBillboardTempAward(playerID, billID, billRank, awardTemplateID, billValue=None, fmLV=None):

    '''获取玩家活动榜单领奖奖励

    @param playerID: 领奖玩家ID

    @param billID: 上榜ID，不一定是玩家ID，比如仙盟ID

    @param billRank: 上榜名次

    @param awardTemplateID: 活动奖励模版ID

    @param billValue: 榜单上榜值，None时不处理

    @param fmLV: 活动时的仙盟成员等级，None时不处理

    '''

    playerAwardItemList = []

    if not billRank:

        return playerAwardItemList

    ipyDataList = IpyGameDataPY.GetIpyGameDataList("ActBillboardAwardTemp", awardTemplateID)

    if not ipyDataList:

        ErrLog("活动榜单奖励模版找不到模版! billID=%s,billRank=%s,awardTemplateID=%s,billValue=%s,fmLV=%s" 
               % (billID, billRank, awardTemplateID, billValue, fmLV), playerID)

        return playerAwardItemList

    
    for ipyData in ipyDataList:

        rank = ipyData.GetRank()

        if billRank > rank:

            continue

        needValue = ipyData.GetNeedValue()

        if needValue and billValue != None and billValue < needValue:

            continue

        
        awardItemList = ipyData.GetAwardItemList()

        leaderAwardItemList = ipyData.GetLeaderAwardItemList()

        eliteAwardItemList = ipyData.GetEliteAwardItemList()

        
        if fmLV != None and fmLV == IPY_GameServer.fmlLeader and leaderAwardItemList:

            playerAwardItemList += leaderAwardItemList

        elif fmLV != None and fmLV > IPY_GameServer.fmlMember and eliteAwardItemList:

            playerAwardItemList += eliteAwardItemList

        else:

            playerAwardItemList += awardItemList

            
        valueAwardEx = ipyData.GetValueAwardEx()

        if valueAwardEx and billValue != None:

            valueAwardExList = valueAwardEx.keys()

            valueAwardExList.sort()

            awardItemExList = []

            for valueEx in valueAwardExList:

                if billValue < valueEx:

                    break

                awardItemExList = valueAwardEx[valueEx] # 取最大满足条件的一档

            playerAwardItemList += awardItemExList

            
        return playerAwardItemList

    
    ErrLog("活动榜单奖励模版找不到奖励! billID=%s,billRank=%s,awardTemplateID=%s,billValue=%s,fmLV=%s" 
           % (billID, billRank, awardTemplateID, billValue, fmLV), playerID)

    return playerAwardItemList



def GetActGuessRightRankAwardIDDict(guessTemplateID):

    ## 获取活动竞猜默认猜中名次对应奖励ID信息

    # @return: {(名次, ...):awardID, ...} 用于 StatActGuessRet 统计竞猜结果

    rightRankAwardIDDict = {}

    guessIpyDataList = IpyGameDataPY.GetIpyGameDataList("ActGuess", guessTemplateID)

    if guessIpyDataList:

        for ipyData in guessIpyDataList:

            awardID = ipyData.GetAwardID()

            rightRankList = ipyData.GetRightRankList()

            rightRankAwardIDDict[tuple(rightRankList)] = awardID

    return rightRankAwardIDDict



def StatActGuessRet(playerID, playerGuessIDList, finalRankIDList, rightRankAwardIDDict, statGuessRetDict, actName=""):

    '''统计活动竞猜结果

    @param playerID: 参与竞猜的玩家ID

    @param playerGuessIDList: 玩家竞猜选择的ID顺序列表

    @param finalRankIDList: 活动最终排名顺序列表

    @param rightRankAwardIDDict: GetActGuessRightRankAwardIDDict 返回值

    @param statGuessRetDict: 统计结果 {awardID:[猜中的玩家ID, ...], ...}

    @param actName: 活动名称，可选参数，输出日志用

    '''

    rightRankList = [] # 玩家猜中的名次列表

    for index, finalID in enumerate(finalRankIDList):

        rank = index + 1

        guessID = playerGuessIDList[index] if len(playerGuessIDList) > index else 0

        if guessID == finalID:

            rightRankList.append(rank)

            
    rightRankTuple = tuple(rightRankList)

    awardID = rightRankAwardIDDict.get(rightRankTuple, 0)

    if awardID not in statGuessRetDict:

        statGuessRetDict[awardID] = []

    rightPlayerIDList = statGuessRetDict[awardID]

    rightPlayerIDList.append(playerID)

    DebugLog("    %s统计玩家竞猜结果: playerID=%s,rightRankTuple=%s,awardID=%s,%s" 
             % (actName, playerID, rightRankTuple, awardID, len(rightPlayerIDList)))

    return



##概率相关, 这个事件是否能够出现

# @param rate 基础几率

@@ -1104,15 +1326,46 @@
    

    return 0



def DebugAnswer(curPlayer, text):

def DebugAnswer(curPlayer, text, isLog=True):

    '''转码后再发DebugAnswer'''

    #===========================================================================

    # if not GetGameWorld().GetDebugLevel():

    #    return

    #===========================================================================

    if IsCrossServer():

        DebugAnswerCross(0, 0, text)

        return

    if isLog:

        DebugLog(text)

    text = text.decode(ShareDefine.Def_Game_Character_Encoding).encode(GetCharacterEncoding())

    if curPlayer:

        curPlayer.DebugAnswer(text)

    return



def CrossServerMsg_DebugAnswer(msgData):

    playerID, text = msgData

    if not playerID:

        playerManager = GetPlayerManager()

        for i in xrange(playerManager.GetActivePlayerCount()):

            player = playerManager.GetActivePlayerAt(i)

            if player == None:

                continue

            player.DebugAnswer(text)

        return

    curPlayer = GetPlayerManager().FindPlayerByID(playerID)

    if not curPlayer:

        return

    curPlayer.DebugAnswer(text)

    return



def DebugAnswerCross(playerID, serverGroupID, text):

    DebugLog(text)

    text = text.decode(ShareDefine.Def_Game_Character_Encoding).encode(GetCharacterEncoding())

    curPlayer.DebugAnswer(text)

    
    import CrossRealmMsg

    dataMsg = [playerID, text]

    serverGroupIDList = [serverGroupID] if serverGroupID else []

    CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_DebugAnswer, dataMsg, serverGroupIDList)

    return



def GetMap(mapID): return IpyGameDataPY.GetIpyGameData("ChinMap", mapID)

@@ -1168,6 +1421,14 @@
        SendGameError("GameServerRaiseException", errorMsg)

    return



def SendGameErrorEx(errType, msgInfo="", playerID=0):

    ErrLog("SendGameErrorEx: %s -> %s" % (errType, msgInfo), playerID)

    if GetGameWorld().GetDebugLevel():

        raise Exception("%s -> %s" % (errType, msgInfo))

    else:

        SendGameError(errType, msgInfo)

    return



def SendGameError(errType, msgInfo=""):

    ''' 向运维发送邮件，用于需要紧急处理的信息

    @param errType: 错误类型，自定义即可