#!/usr/bin/python
|
# -*- coding: utf-8 -*-
|
# @todo: 个人邮件查询
|
|
import CommFunc
|
import ConfigParser
|
import DBOperate
|
|
import logging
|
import mylog
|
|
cfg = ConfigParser.ConfigParser()
|
cfg.read("../../InterfaceConfig.php")
|
ServerPath = cfg.get("ServerInfo", "ServerPath")
|
|
def queryPlayerMailDRInfo(argvDict):
|
## 查询玩家邮件信息
|
|
startDate = argvDict.get("startDate", "")
|
endDate = argvDict.get("endDate", "")
|
|
queryTempInfo = argvDict.get("queryTempInfo", "")
|
queryTempList = queryTempInfo.split(",") if queryTempInfo != "" else []
|
|
filterInfo = argvDict.get("filterInfo", "")
|
filterList = filterInfo.split(",") if filterInfo != "" else []
|
|
# 查询中心备份的
|
if CommFunc.isQueryCenterbak(argvDict):
|
# 备份数据默认不看拍卖相关邮件
|
if "Paimai" not in filterList:
|
filterList.append("Paimai")
|
queryPlayerMailDRInfo_Centerbak(startDate, endDate, argvDict, queryTempList, filterList)
|
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 not findDBRet or findDBRet.count() == 0:
|
print _(u"找不到该玩家") + "!<br/>%s<br/>" % playerFind
|
return
|
|
dbPlayer = findDBRet[0]
|
playerID = CommFunc.encode(dbPlayer["PlayerID"])
|
queryAccID = CommFunc.encode(dbPlayer["AccID"])
|
playerName = CommFunc.encode(dbPlayer["PlayerName"])
|
|
drList = []
|
giveSuccessDict = {}
|
delGUIDDict = {}
|
needQueryCenterbak = CommFunc.loopMainServerDR(cfg, startDate, endDate, argvDict, checkDrFileNeedParseFunc_MailSend,
|
parseLineFunc_MailSend, drList, playerID, queryTempList, filterList, drNameList=["CompensationPersonal", "CompensationEntire"])
|
# 领取的不限制结束日期
|
CommFunc.loopMainServerDR(cfg, startDate, "", argvDict, checkDrFileNeedParseFunc_MailGiveSuccess,
|
parseLineFunc_MailGiveSuccess, giveSuccessDict, playerID, drNameList=["CompensationGiveSuccess"])
|
CommFunc.loopMainServerDR(cfg, startDate, "", argvDict, checkDrFileNeedParseFunc_MailDel,
|
parseLineFunc_MailDel, delGUIDDict, playerID, drNameList=["CompensationPersonalDel"])
|
|
if needQueryCenterbak:
|
argvDict["playerID"] = playerID
|
bakDataList = CommFunc.queryBackupCenterDR(cfg, argvDict)
|
if bakDataList == None:
|
return
|
drList = bakDataList[0] + drList
|
giveSuccessDict.update(bakDataList[1])
|
delGUIDDict.update(bakDataList[2])
|
|
# 更新邮件标题、领取时间
|
tempTitleDict = CommFunc.getCfgKeyNameDict("mail", argvDict)
|
itemNameDict = CommFunc.getCfgKeyNameDict("item", argvDict)
|
for mailInfo in drList:
|
tempType = mailInfo["Title"]
|
mailInfo["Title"] = tempTitleDict.get(tempType, tempType)
|
# 全服邮件
|
if "PlayerIDList" not in mailInfo:
|
mailInfo["Title"] = "%s%s" % (CommFunc.encode(mailInfo["Title"]), "<font color='red'>[" + _(u"全服") + "]</font>")
|
|
itemInfoStr = ""
|
for itemInfo in mailInfo["ItemList"]:
|
if itemInfoStr:
|
itemInfoStr += "<br/>"
|
itemID = itemInfo["ItemID"]
|
count = itemInfo["Count"]
|
itemName = itemNameDict.get(str(itemID), "")
|
if itemName:
|
itemInfoStr += "%s(%s) x%s%s" % (itemName, itemID, count, _(u"个"))
|
else:
|
itemInfoStr += "<font color='red'>%s(%s) x%s个</font>" % (_(u"未知物品ID"), itemID, count)
|
if itemInfo.get("IsAuctionItem"):
|
itemInfoStr += "(%s)" % _(u"拍品")
|
mailInfo["ItemInfo"] = itemInfoStr
|
|
GUID = mailInfo["GUID"]
|
if GUID in giveSuccessDict:
|
mailInfo["giveTime"] = giveSuccessDict[GUID]
|
elif GUID in delGUIDDict:
|
delTime, delEventName = delGUIDDict[GUID]
|
delTime, delEventName = str(delTime), str(delEventName)
|
if delEventName == "GMT":
|
delEventName = _(u"后台")
|
elif delEventName == "MaxCountLimiit":
|
delEventName = _(u"邮件上限")
|
elif delEventName == "Timeout":
|
delEventName = _(u"过期")
|
elif delEventName == "ClientDel":
|
delEventName = _(u"玩家删除")
|
mailInfo["giveTime"] = "%s <br/> <font color='red'>%s: %s</font>" % (delTime, _(u"被删除"), delEventName)
|
|
printStr = "<center><p>%s</p></center>" % _(u"个人邮件记录")
|
printStr += _(u"玩家ID") + ": %s<br/>" % playerID
|
printStr += _(u"玩家账号") + ": %s<br/>" % queryAccID
|
printStr += _(u"玩家名称") + ": %s<br/>" % playerName
|
|
if startDate:
|
printStr += _(u"开始日期") + ": %s<br/>" % startDate
|
if endDate:
|
printStr += _(u"结束日期") + ": %s<br/>" % endDate
|
|
# 表格输出
|
printStr += CommFunc.editTableHtml(drList, ["Title", "ItemInfo", "Gold", "GoldPaper", "Silver", "time", "giveTime", "GUID"], _(u"编号"),
|
styleInfo={"Title":{"align":"left", "title":_(u"标题")},
|
"ItemInfo":{"align":"left", "title":_(u"物品")},
|
"Gold":{"title":_(u"仙玉")},
|
"GoldPaper":{"title":_(u"灵玉")},
|
"Silver":{"title":_(u"铜钱")},
|
"time":{"title":_(u"发送时间")},
|
"giveTime":{"title":_(u"领取时间")},
|
})
|
|
# 只会返回最后一个print的内容
|
print printStr
|
return
|
|
def queryPlayerMailDRInfo_Centerbak(startDate, endDate, argvDict, queryTempList, filterList):
|
|
drList = []
|
giveSuccessDict = {}
|
delGUIDDict = {}
|
playerID = CommFunc.toInt(argvDict.get("playerID", "0"))
|
|
if not CommFunc.loopCenterbakRarDR(cfg, startDate, endDate, argvDict, checkDrFileNeedParseFunc_MailSend,
|
parseLineFunc_MailSend, drList, playerID, queryTempList, filterList, drNameList=["CompensationPersonal", "CompensationEntire"]):
|
return
|
|
if not CommFunc.loopCenterbakRarDR(cfg, startDate, "", argvDict, checkDrFileNeedParseFunc_MailGiveSuccess,
|
parseLineFunc_MailGiveSuccess, giveSuccessDict, playerID, drNameList=["CompensationGiveSuccess"]):
|
return
|
|
if not CommFunc.loopCenterbakRarDR(cfg, startDate, "", argvDict, checkDrFileNeedParseFunc_MailDel,
|
parseLineFunc_MailDel, delGUIDDict, playerID, drNameList=["CompensationPersonalDel"]):
|
return
|
|
return CommFunc.queryBackupCenterOK([drList, giveSuccessDict, delGUIDDict])
|
|
def checkDrFileNeedParseFunc_MailSend(drFileName, *parseArgs, **kv):
|
''' 检查流向是否需要处理
|
@param drFileName: 流向文件名 xxx_日期.txt
|
@param *parseArgs: 自定义参数
|
@return: isNeed, checkNeedParseRetInfo
|
'''
|
isNeed = drFileName.startswith("CompensationPersonal_") or drFileName.startswith("CompensationEntire_")
|
return isNeed, None
|
|
def parseLineFunc_MailSend(drName, dateStr, checkNeedParseRetInfo, line, *parseArgs, **kv):
|
''' 解析流向行内容
|
@param drName: 流向名
|
@param dateStr: 对应日期字符串
|
@param checkNeedParseRetInfo: checkDrFileNeedParseFunc 返回的内容
|
@param line: 本行内容
|
@param *parseArgs: 自定义参数
|
'''
|
|
drList, playerID, queryTempList, filterList = parseArgs
|
|
if "Text" not in line:
|
return
|
|
if drName == "CompensationEntire":
|
if "Add" not in line and "CheckOK" not in line:
|
return
|
|
else:
|
if str(playerID) not in line:
|
return
|
|
# 减少eval，上面的简单验证，eval后还是要进行严格验证
|
drDict = eval(line)
|
Text = drDict["Text"]
|
|
if drName == "CompensationEntire":
|
if drDict["eventName"] not in ["Add", "CheckOK"]:
|
return
|
|
else:
|
if playerID not in drDict["PlayerIDList"]:
|
return
|
|
# 是否指定查找
|
isQuery = False
|
for queryTemp in queryTempList:
|
if queryTemp in Text:
|
isQuery = True
|
break
|
|
if not isQuery:
|
# 是否过滤掉的
|
isFilter = False
|
for filterStr in filterList:
|
if filterStr in Text:
|
isFilter = True
|
break
|
if isFilter:
|
return
|
|
contentList = Text.split("<$_$>")
|
title = contentList[1]
|
content = contentList[2]
|
drDict["Title"] = title
|
if "</MailTemplate>" in content:
|
tempType = content[content.index("<MailTemplate>") + len("<MailTemplate>"):content.index("</MailTemplate>")]
|
drDict["Title"] = tempType
|
|
drList.append(drDict)
|
return
|
|
|
def checkDrFileNeedParseFunc_MailGiveSuccess(drFileName, *parseArgs, **kv):
|
''' 检查流向是否需要处理
|
@param drFileName: 流向文件名 xxx_日期.txt
|
@param *parseArgs: 自定义参数
|
@return: isNeed, checkNeedParseRetInfo
|
'''
|
isNeed = drFileName.startswith("CompensationGiveSuccess_")
|
return isNeed, None
|
|
def parseLineFunc_MailGiveSuccess(drName, dateStr, checkNeedParseRetInfo, line, *parseArgs, **kv):
|
''' 解析流向行内容
|
@param drName: 流向名
|
@param dateStr: 对应日期字符串
|
@param checkNeedParseRetInfo: checkDrFileNeedParseFunc 返回的内容
|
@param line: 本行内容
|
@param *parseArgs: 自定义参数
|
'''
|
|
giveSuccessDict, playerID = parseArgs
|
if str(playerID) not in line:
|
return
|
drDict = eval(line)
|
if playerID != drDict["PlayerID"]:
|
return
|
giveSuccessDict[drDict["GUID"]] = drDict["time"]
|
return
|
|
def checkDrFileNeedParseFunc_MailDel(drFileName, *parseArgs, **kv):
|
''' 检查流向是否需要处理
|
@param drFileName: 流向文件名 xxx_日期.txt
|
@param *parseArgs: 自定义参数
|
@return: isNeed, checkNeedParseRetInfo
|
'''
|
isNeed = drFileName.startswith("CompensationPersonalDel_")
|
return isNeed, None
|
|
def parseLineFunc_MailDel(drName, dateStr, checkNeedParseRetInfo, line, *parseArgs, **kv):
|
''' 解析流向行内容
|
@param drName: 流向名
|
@param dateStr: 对应日期字符串
|
@param checkNeedParseRetInfo: checkDrFileNeedParseFunc 返回的内容
|
@param line: 本行内容
|
@param *parseArgs: 自定义参数
|
'''
|
|
delGUIDDict, playerID = parseArgs
|
if str(playerID) not in line:
|
return
|
drDict = eval(line)
|
if playerID != drDict["PlayerID"]:
|
return
|
delGUIDDict[drDict["GUID"]] = [drDict["time"], drDict["eventName"]]
|
return
|
|
def main():
|
CommFunc.setdefaultencoding()
|
argvDict = CommFunc.parse_args()
|
mylog.InitMyLog(argvDict.get("eventType", ""))
|
CommFunc.gettextInstall(argvDict.get("lang", ""))
|
queryPlayerMailDRInfo(argvDict)
|
return
|
|
if __name__ == "__main__":
|
try:
|
main()
|
except:
|
CommFunc.printExceptionError()
|
