#!/usr/bin/python
|
# -*- coding: utf-8 -*-
|
# @todo: 玩家列表
|
|
import CommFunc
|
import DBOperate
|
import ConfigParser
|
|
import json
|
import mylog
|
import logging
|
|
cfg = ConfigParser.ConfigParser()
|
cfg.read("../../InterfaceConfig.php")
|
ServerPath = cfg.get("ServerInfo", "ServerPath")
|
|
|
def queryPlayerList(argvDict):
|
|
dboper = DBOperate.DBOper(ServerPath)
|
col = dboper.db["tagDBPlayer"]
|
TotalCount = col.count()
|
spec = {}
|
fields = {'_id':0, "AccID":1, "PlayerName":1, "PlayerID":1, "LV":1, "CreateRoleTime":1, "ChangeCoinPointTotal":1, "VIPLv":1}
|
Ret = col.find(spec, fields).sort([("LV", -1)]).limit(1000)
|
|
retData = []
|
accIDList = []
|
for dataInfo in Ret:
|
retData.append(dataInfo)
|
accIDList.append(dataInfo["AccID"])
|
|
col = dboper.db["tagDSAccount"]
|
spec = {"ACCID":{"$in":accIDList}}
|
fields = {'_id':0, "ACCID":1, "ClientVersion":1}
|
accRet = col.find(spec, fields)
|
# 关闭
|
dboper.close()
|
|
accountInfo = {} # 账号表的关联信息
|
for ad in accRet:
|
accID = ad.pop("ACCID", "")
|
if accID:
|
accountInfo[accID] = ad
|
|
# 合并数据
|
for dataInfo in retData:
|
accID = dataInfo["AccID"]
|
dataInfo.update(accountInfo.get(accID, {}))
|
|
ret = {"OK":1, "Data":retData, "TotalCount":TotalCount}
|
logging.info("ret:%s" % ret)
|
print json.dumps(ret, ensure_ascii=False, default=lambda obj: obj.__dict__)
|
return
|
|
def main():
|
CommFunc.setdefaultencoding()
|
argvDict = CommFunc.parse_args()
|
mylog.InitMyLog(argvDict.get("eventType", ""))
|
queryPlayerList(argvDict)
|
return
|
|
if __name__ == "__main__":
|
try:
|
main()
|
except:
|
CommFunc.printExceptionError()
|
