#!/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 queryPlayerMoneyInfo(argvDict):
    ## 查询玩家货币信息
    
    startDate = argvDict.get("startDate", "")
    endDate = argvDict.get("endDate", "")
    
    moneyType = CommFunc.toInt(argvDict.get("moneyType"))
    recordType = argvDict.get("recordType")
    if not moneyType or not recordType:
        print _(u"需指定查询货币类型及选项")
        return
    
    # 查询中心备份的
    if CommFunc.isQueryCenterbak(argvDict):
        queryPlayerMoneyInfo_CenterBak(startDate, endDate, argvDict, moneyType, recordType)
        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, moneyType, recordType)
    if needQueryCenterbak:
        argvDict["queryAccID"] = queryAccID
        bakDataList = CommFunc.queryBackupCenterDR(cfg, argvDict)
        if bakDataList == None:
            return
        drList = bakDataList + drList
        
    itemNameDict = CommFunc.getCfgKeyNameDict("item", argvDict)
    useNameDict = CommFunc.getCfgKeyNameDict("money_enent_use", argvDict)
    giveNameDict = CommFunc.getCfgKeyNameDict("money_enent_give", argvDict)
    giveItemNameDict = CommFunc.getCfgKeyNameDict("item_enent_give", argvDict)
    
    needMoney2 = False
    totalGive, totalUse = 0, 0
    bossTypeNameDict = {0:_(u"世界Boss"), 1:_(u"Boss之家"), 2:_(u"跨服Boss")}
    prayTypeNameDict = {13:_(u"金币"), 14:_(u"经验")}
    drList = sorted(drList, key=lambda dr:(dr["time"], dr['PlayerMoneyCount']), reverse=False) # 按time升序排
    for drDict in drList:
        if not needMoney2 and "PlayerMoneyCount2" in drDict:
            needMoney2 = True
        MoneyCount = drDict['MoneyCount']
        eventName = drDict['eventName']
        reason_name_son = drDict.get("reason_name_son")
        if reason_name_son:
            if eventName in ["UseItem", "BuyStoreItem", "TransformItem"]:
                itemID = reason_name_son
                itemName = itemNameDict.get(str(itemID), "")
                if itemName:
                    drDict["reason_name_son"] = "%s(%s)" % (itemName, itemID)
                    
                # 物品转换的，补上物品来源
                if eventName == "TransformItem" and "GiveItemEvent" in drDict:
                    giveItemEventName = drDict["GiveItemEvent"]
                    giveItemNameCh = giveItemNameDict.get(giveItemEventName, giveItemEventName)
                    drDict["reason_name_son"] = "%s %s:%s" % (drDict["reason_name_son"], _(u"物品来源"), str(giveItemNameCh))
                
                # 抵扣
                if drDict.get("CouponMoney", 0) > 0:
                    drDict["reason_name_son"] = "%s %s:%s %s:%s" % (drDict["reason_name_son"], _(u"原价"), drDict.get("ItemPrice", 0), _(u"抵扣"), drDict["CouponMoney"])

            elif eventName == "BuyKillBossCnt":
                drDict["reason_name_son"] = bossTypeNameDict.get(reason_name_son, reason_name_son)
                
            elif eventName == "Pray":
                drDict["reason_name_son"] = prayTypeNameDict.get(reason_name_son, reason_name_son)
                
        eventNameCh = ""
        if "-" in MoneyCount:
            eventNameCh = useNameDict.get(eventName)
            totalUse += CommFunc.toInt(MoneyCount.replace("-", "").replace(" ", ""))
            
        elif "+" in MoneyCount:
            eventNameCh = giveNameDict.get(eventName)
            totalGive += CommFunc.toInt(MoneyCount.replace("+", "").replace(" ", ""))
        if eventNameCh:
            drDict['eventName'] = "%s %s" % (eventNameCh, CommFunc.encode(eventName))
            
    if not playerName and drList:
        drDict = drList[-1]
        playerID = drDict.get("PlayerID", playerID)
        playerName = CommFunc.encodePych(drDict.get("PlayerName", ""))
        
    moneyNameDict = CommFunc.getCfgKeyNameDict("money", argvDict)
    moneyName = moneyNameDict.get(str(moneyType), str(moneyType))
    printStr = "<center><p>%s%s</p></center>" % (moneyName, _(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 totalGive:
        printStr += "%s: %s<br/>" % (_(u"累计获得"), totalGive)
    if totalUse:
        printStr += "%s: %s<br/>" % (_(u"累计消耗"), totalUse)
    
    maxShowCount = 5000
    drCount = len(drList)
    if drCount > maxShowCount:
        logging.warn("drList len is %s" % drCount)
        drList = drList[:maxShowCount]
        printStr += "<font color='red'><b>%s : %s<b></font><br/>" % (_(u"满足条件总条数过多，请调整查询条件！当前仅展示部分，实际总条数为"), drCount)
        
    # 表格输出
    tdList = ["MoneyCount", "PlayerMoneyCount", "eventName", "reason_name_son", "time"]
    styleInfo = {"MoneyCount":{"align":"right", "title":_(u"变化值")},
                "PlayerMoneyCount":{"align":"right", "title":_(u"剩余")},
                "eventName":{"align":"left"},
                }
    if needMoney2:
        tdList = ["MoneyCount", "PlayerMoneyCount", "PlayerMoneyCount2", "eventName", "reason_name_son", "time"]
        money2TitleDict = {99:"时效"}
        money2Title = _(u"剩余") + money2TitleDict.get(moneyType, "2")
        styleInfo.update({
            "PlayerMoneyCount2":{"align":"right", "title":money2Title},
        })
    printStr += CommFunc.editTableHtml(drList, tdList, _(u"编号"), styleInfo=styleInfo)
    
    # 只会返回最后一个print的内容
    print printStr
    return

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

def checkDrFileNeedParseFunc(drFileName, *parseArgs, **kv):
    ''' 检查流向是否需要处理
    @param drFileName: 流向文件名  xxx_日期.txt
    @param *parseArgs: 自定义参数
    @return: isNeed, checkNeedParseRetInfo
    '''
    
    _, _, moneyType, recordType = parseArgs
    
    queryUse = recordType in ["All", "Use"]
    queryGive = recordType in ["All", "Give"]
    
    changeType = ""
    
    # 仙玉
    if moneyType == 1:
        if queryGive:
            if drFileName.startswith("GiveGold_"):
                changeType = "+"
        if queryUse:
            if drFileName.startswith("UseGold_"):
                changeType = "-"
                
    # 绑玉
    elif moneyType == 2:
        if queryGive:
            if drFileName.startswith("GiveGoldPaper_"):
                changeType = "+"
        if queryUse:
            if drFileName.startswith("UseGoldPaper_"):
                changeType = "-"
                
    # 铜钱
    elif moneyType == 3:
        if queryGive:
            if drFileName.startswith("GiveSilver_"):
                changeType = "+"
        if queryUse:
            if drFileName.startswith("UseSilver_"):
                changeType = "-"
                
    # 神玉
    elif moneyType == 4:
        if queryGive:
            if drFileName.startswith("GiveSilverPaper_"):
                changeType = "+"
        if queryUse:
            if drFileName.startswith("UseSilverPaper_"):
                changeType = "-"
                
    # 代币
    elif moneyType == 99:
        if queryGive:
            if drFileName.startswith("GivePayCoin_"):
                changeType = "+"
        if queryUse:
            if drFileName.startswith("UsePayCoin_"):
                changeType = "-"
                
    # 其他
    else:
        if queryGive:
            if drFileName.startswith("GiveCurrency_%s" % moneyType):
                changeType = "+"
        if queryUse:
            if drFileName.startswith("UseCurrency_%s" % moneyType):
                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, moneyType, _ = parseArgs
    
    if queryAccID not in line:
        # 直接验证账号字符，省去eval消耗
        return
    drDict = eval(line)
    accID = drDict["AccID"]
    if accID != queryAccID:
        return
    
    if moneyType != drDict["MoneyType"]:
        return
    
    drDict["MoneyCount"] = "%s %s" % (changeType, drDict["MoneyCount"])
    drList.append(drDict)
    return

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

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