#!/usr/bin/python
# -*- coding: utf-8 -*-
# @todo: 玩家物品查询

import CommFunc
import ConfigParser
import DBOperate
import mylog
import logging

cfg = ConfigParser.ConfigParser()
cfg.read("../../InterfaceConfig.php")
ServerPath = cfg.get("ServerInfo", "ServerPath")

def queryPlayerItemInfo(argvDict):
    ## 查询玩家物品信息
    
    startDate = argvDict.get("startDate", "")
    endDate = argvDict.get("endDate", "")
    
    recordType = argvDict.get("recordType")
    if not recordType:
        print _(u"需指定查询选项")
        return
    
    itemIDList = []
    if argvDict.get("itemIDInfo", "") != "":
        itemIDList = [CommFunc.toInt(itemIDStr) for itemIDStr in argvDict.get("itemIDInfo", "").split(",")]
        
    # 查询中心备份的
    if CommFunc.isQueryCenterbak(argvDict):
        queryPlayerItemInfo_CenterBak(startDate, endDate, argvDict, recordType, itemIDList)
        return
    
    playerFind = argvDict.get("playerFind", "")
    if not playerFind:
        print _(u"需要指定要查询的玩家")
        return
    
    queryType = argvDict.get("queryType", "")
    
    dboper = DBOperate.DBOper(ServerPath)
    if queryType == "playerName":
        findDBRet = dboper.findPlayerInfoByName([playerFind])
    else:
        findDBRet = dboper.findPlayerInfoByAccID([playerFind])
    dboper.close()
    if findDBRet and findDBRet.count():
        dbPlayer = findDBRet[0]
        playerID = CommFunc.encode(dbPlayer["PlayerID"])
        queryAccID = CommFunc.encode(dbPlayer["AccID"])
        playerName = CommFunc.encode(dbPlayer["PlayerName"])
    elif queryType == "accID":
        queryAccID = playerFind
        playerID = 0
        playerName = ""
    else:
        print "%s!<br/>%s<br/>" % (_(u"找不到该玩家"), playerFind)
        return
    
    drList = []
    needQueryCenterbak = CommFunc.loopMainServerDR(cfg, startDate, endDate, argvDict, checkDrFileNeedParseFunc, 
                                                   parseLineFunc, drList, queryAccID, recordType, itemIDList)
    
    if needQueryCenterbak:
        argvDict["queryAccID"] = queryAccID
        bakDataList = CommFunc.queryBackupCenterDR(cfg, argvDict)
        if bakDataList == None:
            return
        drList = bakDataList + drList
        
    packTypeNameDict = CommFunc.getCfgKeyNameDict("packType", argvDict)
    itemNameDict = CommFunc.getCfgKeyNameDict("item", argvDict)
    useNameDict = CommFunc.getCfgKeyNameDict("item_enent_use", argvDict)
    giveNameDict = CommFunc.getCfgKeyNameDict("item_enent_give", argvDict)
    moneyNameDict = CommFunc.getCfgKeyNameDict("money", argvDict)

    drList = sorted(drList, key=lambda dr:dr["time"], reverse=False) # 按time升序排
    for drDict in drList:
        ItemID = drDict['ItemID']
        auctionItemStr = "[%s]" % _(u"拍品") if drDict.get('IsBind') else ""
        itemName = itemNameDict.get(str(ItemID), "")
        if itemName:
            itemName = "%s %s(%s)" % (auctionItemStr, itemName, ItemID)
        else:
            itemName = "<font color='red'>%s %s(%s)</font>" % (auctionItemStr, _(u"未知物品"), ItemID)
        drDict['ItemName'] = itemName
        
        eventNameCh = ""
        eventName = drDict['eventName']
        ItemCount = drDict['ItemCount']
        if "-" in ItemCount:
            eventNameCh = useNameDict.get(eventName)
        elif "+" in ItemCount:
            eventNameCh = giveNameDict.get(eventName)
        if eventNameCh:
            drDict['eventName'] = "%s %s" % (eventNameCh, CommFunc.encode(eventName))
            
        if drDict.get("PayPrice", 0) > 0 or drDict.get("CouponMoney", 0) > 0:
            moneyType = drDict.get("MoneyType", 0)
            moneyName = moneyNameDict.get(str(moneyType), str(moneyType))
            payMoneyInfo = "%s %s:%s" % (_(u"支付"), moneyName, drDict.get("PayPrice", 0))
            if drDict.get("CouponMoney", 0) > 0:
                payMoneyInfo = "%s %s:%s" % (payMoneyInfo,  _(u"抵扣"), drDict.get("CouponMoney", 0))
            drDict['eventName'] = "%s %s" % (drDict['eventName'], payMoneyInfo)

        reason_name_son = drDict.get("reason_name_son")
        if reason_name_son:
            itemID = reason_name_son
            itemName = itemNameDict.get(str(itemID), "")
            if itemName:
                drDict['eventName'] = "%s %s(%s)" % (drDict['eventName'], itemName, itemID)
            else:
                drDict['eventName'] = "%s %s" % (drDict['eventName'], reason_name_son)
                
        packType = drDict.get('PackType', "")
        drDict['PackName'] = packTypeNameDict.get(str(packType), packType)
        
    if not playerName and drList:
        drDict = drList[-1]
        playerID = drDict.get("PlayerID", playerID)
        #playerName = CommFunc.encodePych(drDict.get("PlayerName", ""))
        
    printStr = "<center><p>%s</p></center>" % _(u"物品记录")
    printStr += "%s: %s<br/>" % (_(u"玩家ID"), playerID)
    printStr += "%s: %s<br/>" % (_(u"玩家账号"), queryAccID)
    printStr += "%s: %s<br/>" % (_(u"玩家名称"), playerName)
    
    if startDate:
        printStr += "%s: %s<br/>" % (_(u"开始日期"), startDate)
    if endDate:
        printStr += "%s: %s<br/>" % (_(u"结束日期"), endDate)

    if itemIDList:
        printStr += "%s: %s<br/>" % (_(u"指定物品ID"), itemIDList)
        
    # 表格输出
    printStr += CommFunc.editTableHtml(drList, ["ItemName", "ItemCount", "AfterCount", "PackName", "eventName", "ItemGUID", "time"], _(u"编号"),
                                       styleInfo={"ItemName":{"align":"right", "title":_(u"物品名")},
                                                  "ItemCount":{"align":"right", "title":_(u"变化个数")},
                                                  "AfterCount":{"align":"right", "title":_(u"剩余个数")},
                                                  "PackName":{"title":_(u"所属背包")},
                                                  "eventName":{"align":"left"},
                                                  })
    
    # 只会返回最后一个print的内容
    print printStr
    return

def queryPlayerItemInfo_CenterBak(startDate, endDate, argvDict, recordType, itemIDList):
    drList = []
    queryAccID = argvDict.get("queryAccID", "")
    
    if not CommFunc.loopCenterbakRarDR(cfg, startDate, endDate, argvDict, checkDrFileNeedParseFunc, 
                                       parseLineFunc, drList, queryAccID, recordType, itemIDList):
        return
    
    return CommFunc.queryBackupCenterOK(drList)

def checkDrFileNeedParseFunc(drFileName, *parseArgs, **kv):
    ''' 检查流向是否需要处理
    @param drFileName: 流向文件名  xxx_日期.txt
    @param *parseArgs: 自定义参数
    @return: isNeed, checkNeedParseRetInfo
    '''
    
    _, _, recordType, _ = parseArgs
    
    queryUse = recordType in ["All", "Use"]
    queryGive = recordType in ["All", "Give"]
    
    changeType = ""
    if queryGive:
        if drFileName.startswith("GivePlayerItem_"):
            changeType = "+"
            
    if queryUse:
        if drFileName.startswith("DeleteItem_"):
            changeType = "-"
            
    if not changeType:
        return False, None
    return True, changeType

def parseLineFunc(drName, dateStr, checkNeedParseRetInfo, line, *parseArgs, **kv):
    ''' 解析流向行内容
    @param drName: 流向名
    @param dateStr: 对应日期字符串
    @param checkNeedParseRetInfo: checkDrFileNeedParseFunc 返回的内容
    @param line: 本行内容
    @param *parseArgs: 自定义参数
    '''
    
    changeType = checkNeedParseRetInfo
    drList, queryAccID, _, itemIDList = parseArgs
    
    if queryAccID not in line:
        # 直接验证账号字符，省去eval消耗
        return
    
    if itemIDList:
        isIn = False
        for itemID in itemIDList:
            if str(itemID) in line:
                isIn = True
                break
        if not isIn:
            return
        
    drDict = eval(line)
    accID = drDict["AccID"]
    if accID != queryAccID:
        return
    
    if itemIDList and drDict["ItemID"] not in itemIDList:
        return
    
    eventName = drName[drName.index("_") + 1:]
    drDict["ItemCount"] = "%s %s" % (changeType, drDict["ItemCount"])
    drDict["eventName"] = CommFunc.encode(eventName)
    drList.append(drDict)
    return

def main():
    CommFunc.setdefaultencoding()
    argvDict = CommFunc.parse_args()
    mylog.InitMyLog(argvDict.get("eventType", ""))
    CommFunc.gettextInstall(argvDict.get("lang", ""))
    queryPlayerItemInfo(argvDict)
    return

if __name__ == "__main__":
    try:
        main()
    except:
        CommFunc.printExceptionError()