hnhzServer/http/manage.js

'use strict';

var quick = require('quick-pomelo');
var P = quick.Promise;
var _ = require('lodash');
var url = require('url');
var md5 = require('md5');
var http = require('http');
var uuid = require('node-uuid');
var qs = require('querystring');
var conf = require('./conf.json');
var C = require('../share/constant');
var configCommon = require('../share/configCommon');//////TL++配置相关的公共方法
var logger = quick.logger.getLogger('fhmj', __filename);

// 构造方法
var Controller = function (app) {
	this.app = app;
	this.uptime = Date.now();
	this.port = app.getCurServer().httpPort;
	this.server = http.createServer((req, res) => this.handleAsync(req, res));
	this.server.listen(this.port);
	this.lconfigCommon = new configCommon(this.app);
};

// 导出方法
module.exports = function (app) {
	return new Controller(app);
};

// 原型对象
var proto = Controller.prototype;

// 路由函数
proto.route = function (pathname) {
	switch (pathname) {
		case '/setmyurl.nd': return (query, method, res) => this.setMyUrlAsync(query, method, res);//设置Grade url
		case '/setAllAgenterMyurl.nd': return (query, method, res) => this.setAllAgenterMyurlAsync(query, method, res);//设置所有推广的地址
		case '/setAgenterMyurl.nd': return (query, method, res) => this.setAgenterMyurlAsync(query, method, res);//设置单个推广的地址
		case '/setAgentOther.nd': return (query, method, res) => this.setAgentOtherAsync(query, method, res);//设置单个推广的其他信息
		case '/adddiamond.nd': return (query, method, res) => this.addDiamondAsync(query, method, res);//后台加钻石
		case '/clearUser.nd': return (query, method, res) => this.clearUserAsync(query, method, res);//删除用户
		case '/freetable.nd': return (query, method, res) => this.freeTableAsync(query, method, res);//清空房间
		case '/setPlayerPayTop.nd': return (query, method, res) => this.setPlayerPayTopAsync(query, method, res);//设置玩家充值上限
		case '/setWeiHu.nd': return (query, method, res) => this.setWeiHuAsync(query, method, res);//设置维护
		case '/setPlayerEnable.nd': return (query, method, res) => this.setPlayerEnableAsync(query, method, res);//设置用户是否冻结
		case '/setAgentInfo.nd': return (query, method, res) => this.setAgentInfoAsync(query, method, res);//设置推广信息（java后台用）
		case '/addMail.nd': return (query, method, res) => this.addMailAsync(query, method, res);//后台给玩家发邮件
		case '/sidAridChange.nd': return (query, method, res) => this.sidAridChangeAsync(query, method, res);//显示uid和实际uid互相转换
		case '/addRaceTime.nd': return (query, method, res) => this.addRaceTimeAsync(query, method, res);//后台增加比赛的开始和结束时间
		case '/setRaceTimeOut.nd': return (query, method, res) => this.setRaceTimeOutAsync(query, method, res);//后台设置比赛是否过期
		case '/setNotGameTogther.nd': return (query, method, res) => this.setNotGameTogtherAsync(query, method, res);//后台增设置不能在同一桌游戏的玩家
		case '/setJinSai.nd': return (query, method, res) => this.setJinSaiAsync(query, method, res);//设置禁赛玩家
		case '/setSGJiangChi.nd': return (query, method, res) => this.setSGJiangChiAsync(query, method, res);//设置水果机奖池信息
		case '/getSGATypeAll.nd': return (query, method, res) => this.getSGATypeAllAsync(query, method, res);//得到水果机某个字段的总和
		case '/sgjRWFJOver.nd': return (query, method, res) => this.sgjRWFJOverAsync(query, method, res);//水果机任务发奖完成

	}
};

// 写出数据
proto.writeOut = function (query, res) {
	if (typeof query != 'object') {
		return res.end(String(query));
	}
	return res.end(JSON.stringify(query));
};

// 跨域选项
const ACCESS = {
	"Content-Type": "text/plain;charset=utf-8",
	"Access-Control-Allow-Origin": "*",
	"Access-Control-Allow-Headers": "X-Requested-With",
	"Access-Control-Allow-Methods": "PUT,POST,GET,DELETE,OPTIONS"
};

// 入口函数
proto.handleAsync = P.coroutine(function* (req, res) {
	var pathname = url.parse(req.url).pathname;
	var phandler = this.route(pathname);
	if (!phandler) {
		res.writeHead(404, ACCESS);
		return res.end('WARNING: Not Found!');
	}
	else {
		res.writeHead(200, ACCESS);
		if (req.method.toLowerCase() == 'get') {
			let query = url.parse(req.url, true).query;
			return phandler(query, req.method, res);
		}
		else if (req.method.toLowerCase() == 'post') {
			let data = '';
			req.on('data', (d) => { data += d; });
			req.on('end', () => {
				let query = { __post__: data };
				let regexp = /^\s*{(\s*?".*?":.*\s*)*}\s*$/;
				if (regexp.test(data)) try { query = JSON.parse(data); } catch (e) { }
				else if (data.indexOf('=') != -1) query = qs.parse(data);
				return phandler(query, req.method, res);
			});
		}
	}
});



//ts++ 设置 grade myurl
proto.setMyUrlAsync = P.coroutine(function* (query, method, res) {

	var playerId = query['playerid'];
	if (!playerId) {
		return this.writeOut('fail: userid error!', res);
	}
	var grade = Number(query['grade']);
	if (!grade) {
		return this.writeOut('fail: grade error!', res);
	}
	var myurl = query['myurl'];
	if (!myurl) {
		return this.writeOut('fail: myurl error!', res);
	}
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}

	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {

		var player = yield app.models.Player.findByIdAsync(playerId, 'grade myurl');
		if (player) {
			player.grade = grade;
			player.myurl = myurl;
			yield player.saveAsync();
			console.warn("设置设置 grade -------------------修改");
		}

		return self.writeOut('vvvvvv', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));

});

//设置所有推广的地址
proto.setAllAgenterMyurlAsync = P.coroutine(function* (query, method, res) {
	console.warn("设置所有推广的地址 ");
	var playerId = query['mid'];
	if (!playerId) {
		return this.writeOut('fail: userid error!', res);
	}
	var myurl = query['myurl'];
	if (!myurl) {
		return this.writeOut('fail: myurl error!', res);
	}
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}
	console.warn("设置所有推广的地址222   "+"  playerId  "+playerId+"  myurl  "+myurl);
	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		let msg = '999999'
		console.warn("设置所有推广的地址222 ")
		// //yield app.models.Agenter.updateMany({update: {$set: {myGrade:2}}, upsert:true})
		// let agentArr = yield app.models.Agenter.findMongoAsync({"myGrade" :{$ne :1}});
		// console.warn("设置所有推广的地址3 "+JSON.stringify(agentArr));
		// console.warn("设置所有推广的地址333 "+agentArr.length);
		let agentArr = yield app.models.Agenter.findMongoAsync({"myUrl" :{$ne :myurl}});
		// console.warn("设置所有推广的地址31 "+JSON.stringify(agentArr));
		// console.warn("设置所有推广的地址3331 "+agentArr.length);
		for (var i = 0; i < agentArr.length; i++) {
			let agenter = agentArr[i];
			if (agenter) {
				// agenter.grade = grade;
				let isChange = (agenter.myUrl != myurl)
				if(isChange){
					agenter.myUrl = myurl;
					yield agenter.saveAsync();
				}
				console.warn("设置所有推广的地址444 isChange  "+isChange+"  agenter.myUrl  "+agenter.myUrl);
			}
		}
		if(agentArr.length == 0) msg = 'no need change';
		console.warn("设置所有推广的地址555 ");
		return self.writeOut(msg, res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});

//设置单个推广的地址
proto.setAgenterMyurlAsync = P.coroutine(function* (query, method, res) {
	// console.warn("设置单个推广的地址 ");
	var playerId = query['aid'];
	if (!playerId) {
		return this.writeOut('fail: userid error!', res);
	}
	var type = Number(query['type']);
	if (!type) {
		return this.writeOut('fail: type error!', res);
	}
	var myurl = query['myurl'];
	if (type == 1 && !myurl) {
		return this.writeOut('fail: myurl error!', res);
	}
	var level = query['level'];
	if (type == 2 && !level) {
		return this.writeOut('fail: level error!', res);
	}
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}
	// console.warn("设置单个推广的地址222   "+"  playerId  "+playerId+"  type  "+type+"  myurl  "+myurl+"  level  "+level);
	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		let msg = ''
		// console.warn("设置单个推广的地址333 ");//Agenter
		var player = yield app.models.Agenter.findByIdAsync(playerId, 'myUrl');
		if (player) {
			// player.grade = grade;
			let isChange = false;
			if(type == 1) {
				isChange = (player.myUrl != myurl)
				player.myUrl = myurl;
			}
			if(isChange) yield player.saveAsync();
			msg = '999999'
			// console.warn("设置单个推广的地址444 isChange  "+isChange+"  player.myUrl  "+player.myUrl);
		}
		else msg = 'agent not find'
		// console.warn("设置单个推广的地址555 ");
		return self.writeOut(msg, res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));

});

//设置单个推广的其他信息
proto.setAgentOtherAsync = P.coroutine(function* (query, method, res) {
	// console.warn("设置单个推广的信息 ",query);
	var playerId = query['aid'];
	if (!playerId) {
		return this.writeOut('fail: userid error!', res);
	}
	var change = query['change'];
	if (!change) {
		return this.writeOut('fail: change error!', res);
	}
	var value = query['value'];
	if(change != "parentAgenterId" && change != "playerId"){
		value = Number(value);
	}
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}
	// console.warn("设置单个推广的地址222   "+"  playerId  "+playerId+"  change  "+change+"  value  "+value);
	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		let msg = ''
		// console.warn("设置单个推广的地址333 ");//Agenter
		var player = yield app.models.Agenter.findByIdAsync(playerId, 'levelFlag');
		if (player) {
			let isChange = false;
			if(change == "levelFlag" && player.levelFlag != value)
			{
				isChange=true;
				player.levelFlag = value;
			}
			if(change == "enabled" && (value == 0 || value == 1 ) && player.enabled!=value)
			{
				isChange=true;
				player.enabled = value;
			}
			if(change == "parentAgenterId")
			{
				if(!value){
					if(player.parentAgenterId != ""){
						player.parentAgenterId = "";
						yield player.saveAsync();
						return self.writeOut('999999', res);
					}
					else{
						return self.writeOut('no need change.', res);
					}
				}
				let agenterList = yield app.models.Agenter.findMongoAsync({agentNo:value}, '_id agenterNo levelFlag enabled parentAgenterId');
				if (agenterList.length == 1) {
					if(agenterList[0].levelFlag != 2 || agenterList[0].enabled == 0){
						return self.writeOut('cant add the agent because unenable or level error!', res);
					}
					if(player.parentAgenterId != agenterList[0]._id){
						isChange=true;
						player.parentAgenterId = agenterList[0]._id;
					}
					else{
						return self.writeOut('parent no change !', res);
					}
				}
				else{
					return self.writeOut('agentNo Error!', res);
				}
			}
			if(isChange) yield player.saveAsync();
			msg = '999999'
			// console.warn("设置单个推广的地址444 isChange  "+isChange+"  player.myUrl  "+player.myUrl);
		}
		else msg = 'agent not find'
		// console.warn("设置单个推广的地址555 ");
		return self.writeOut(msg, res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));

});

//ts++ 删除玩家
proto.clearUserAsync = P.coroutine(function* (query, method, res) {
	console.warn("删除玩家-------------------");
	var playerId = query['playerid'];
	if (!playerId) {
		return this.writeOut('', res);//fail: userid error!
	}
	//console.warn("删除玩家-------------------playerId:",playerId);
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('', res);
	}

	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {

		var player = yield app.models.Player.findByIdAsync(playerId);
		if (player) {
			yield player.removeAsync();
			console.warn("删除玩家-------------------成功");
			return self.writeOut('999999', res);
		}
		return self.writeOut('fail: no object !', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});

//ts++ 清空房间
proto.freeTableAsync = P.coroutine(function* (query, method, res) {
	// console.warn("清空房间-------------------");
	var playerId = query['playerId'];
	if (!playerId) {
		return this.writeOut('fail: playerId error!', res);//fail: userid error!
	}
	var change = query['change'];
	if (!change) {
		return this.writeOut('fail: change error!', res);
	}
	console.warn("清空房间-------------------playerId:",playerId,change);
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	//console.warn("清空房间-------------------sign:",sign);
	if (!checkSign(sign)) {
		return this.writeOut('', res);
	}

	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {

		var player = yield app.models.Player.findByIdAsync(playerId, 'tableId rTableId gameId gameServerId tel pwd');
		if (player) {
			if(change == "freeTable"){
				player.rTableId = 0;
				player.tableId = "";
				player.gameId = 0;
				player.gameServerId = "";
			}
			else if(change == "unbindTel"){
				player.tel = '';
				player.pwd = '';
			}
			yield player.saveAsync();
			console.warn("清空房间-------------------修改成功");
		}
		return self.writeOut('999999', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));


});

//////TL++,设置玩家充值上限
proto.setPlayerPayTopAsync = P.coroutine(function* (query, method, res) {
	console.warn("设置玩家充值上限-------------------",query);
	var uppid = query['uppid'];
	if (!uppid) {
		return this.writeOut('fail: uppid error!', res);
	}
	var value = Number(query['value']) || -10;
	if(query['value'] == "0") value = 0;
	if (value < -1) {
		return this.writeOut('fail: value error!', res);
	}
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!!!', res);
	}

	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		let wjsx = yield app.models.PayLimit.findByIdAsync(uppid, 'paytop registerTime');
		if (wjsx) {
			wjsx.paytop = value;
			wjsx.registerTime = Date.now();
			yield wjsx.saveAsync();
			console.warn("设置玩家充值上限成功-------------------uppid:",uppid,value);
		}
		else
		{
			var player = yield app.models.Player.findByIdAsync(uppid, 'userId name');
			if (!player) {
				return this.writeOut('fail: no object !', res);
			}
			let startTime = self.getzdLDSJC(Date.now());
			let jrzcz = 0;
			var endTime = startTime + 86400000;
			var opts = { time: { $gte: startTime, $lt: endTime },playerId: uppid, paystate: { $gte: 1 }};
			var list = yield app.models.PayRecord.findMongoAsync(opts, 'total_fee');
			for (let i = 0; i < list.length; ++i) {
				jrzcz += list[i].total_fee;
			}
			var newwjsx = new app.models.PayLimit({
				_id: uppid,
				userId: player.userId,
				name: player.name,
				paytop: value,
				paytotal: jrzcz,
				dataTime: startTime,
			});
			yield newwjsx.saveAsync();
		}

		return self.writeOut('999999', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});

//////TL++,设置维护
proto.setWeiHuAsync = P.coroutine(function* (query, method, res) {

	console.warn("设置维护-------------------",query);
	//    var playerId = query['playerid'];
	// if (!playerId) {
	// 	return this.writeOut('fail: userid error!', res);
	// }
	var updid = Number(query['updid']);

	var value = query['value'];
	if (!value) {
		return this.writeOut('fail: value error!', res);
	}
	if(updid==1)
	{
		let stateWH = Number(value)||0;
		if (stateWH!=0 && stateWH!=1 && stateWH!=2) {
			return this.writeOut('fail: stateWH error!!!', res);
		}
	}
	else if(updid==2)
	{
	}
	else if(updid==3)
	{
		let rebaterate = Number(value)||0
		if (rebaterate < 0 || rebaterate > 100) {
			return this.writeOut('fail: rebaterate error!', res);
		}
	}
	else if(updid==4){
	}
	else if(updid==5){
		let yxndlbTime = Number(value)||0
		if (yxndlbTime <= 0) {
			return this.writeOut('fail: yxndlbTime error!', res);
		}
	}
	else if(updid==6){
	}
	else
	{
		return this.writeOut('fail: updid error!!!', res);
	}
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	//console.warn("清空房间-------------------sign:",sign);
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!!!', res);
	}

	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		var dataSystemConfig = yield app.models.WHstate.findByIdAsync('wh', 'stateWH whTip rebaterate shareGive yxndlbTime yxndlbTip');
		//console.warn("系统配置",dataSystemConfig);
		if (dataSystemConfig) {
			if(updid==1)
			{
				let stateWH = Number(value)||0;
				dataSystemConfig.stateWH = stateWH;
			}
			else if(updid==2)
			{
				dataSystemConfig.whTip = value;
			}
			else if(updid==3)
			{
				let rebaterate = Number(value)||0
				dataSystemConfig.rebaterate = rebaterate;
			}
			else if(updid==4)
			{
				let shareGive = Number(value)||0
				dataSystemConfig.shareGive = shareGive;
			}
			else if(updid==5)
			{
				let yxndlbTime = Number(value)||0
				dataSystemConfig.yxndlbTime = yxndlbTime;
			}
			else if(updid==6)
			{
				dataSystemConfig.yxndlbTip = value;
			}
			//  	else if(updid==7)
			//  	{
			//  		dataSystemConfig.linkhall = value;
			//  	}
			//  	else if(updid==8)
			//  	{
			//  		var regDiamond = Number(value) ||100;
			//  		if (regDiamond<0) {
			// 	data.msg='注册赠送值为错误';
			// 	return self.writeOut(data, res);
			// }
			// dataSystemConfig.regDiamond = regDiamond;
			//  	}


			//console.warn("修改系统配置",updid,value);
			yield dataSystemConfig.saveAsync();
		}
		else
		{
			return this.writeOut('fail: no object !', res);
		}

		return self.writeOut('999999', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));


});

// 后台增加钻石
proto.addDiamondAsync = P.coroutine(function* (query, method, res) {
	console.warn("590 query:",query)
	var playerId = query['playerid'];
	if (!playerId) {
		return this.writeOut('fail: userid error!', res);
	}
	// console.warn("后台增加钻石-------------------playerId:",playerId);
	var managerId = query['managerid'];

	var diamond = Number(query['diamond']);

	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}

	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}
	console.warn("query:",query)
	// console.warn("后台增加钻石-------------------diamond:",diamond);
	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		//后台增加钻石的话给用户发邮件通知，用户在邮件里领取之后修改玩家钻石，后台扣钻则不发邮件
		if(diamond < 0){
			var player = yield app.models.Player.findByIdAsync(playerId, 'diamond');
			if (player) {
				let dSource=player.diamond;
				let dNow=player.diamond+diamond;
				player.diamond += diamond;
				yield player.saveAsync();
				// 钻石记录
				var diamondrecord = new app.models.DiamondRecord({
					_id: uuid.v1(),
					playerId: playerId,
					dType: 7,//后台
					dSource: dSource,
					dSwap: diamond,
					dNow: dNow,
					tableId: managerId
				});
				yield diamondrecord.saveAsync();
			}
			var SGJUserTongjis = yield app.models.SGJUserTongji.findMongoAsync({todaytime:self.getTodaySJC()})
			var SGJUserTongji = null
			if (SGJUserTongjis.length == 0) {
				SGJUserTongji = app.models.SGJUserTongji({
					_id: uuid.v1(),
					//userId: player.userId,
					houtaiU: diamond,
					todaytime: self.getTodaySJC()
				});
				yield SGJUserTongji.saveAsync()
			}else {
				SGJUserTongji = SGJUserTongjis[0]
				console.warn("SGJUserTongji:",SGJUserTongji)
				//SGJUserTongji.usdt = afterusdt
				SGJUserTongji.houtaiU = (Number(SGJUserTongji.houtaiU) +Number(diamond)).toFixed(2)//下注

				yield SGJUserTongji.saveAsync()
			}
		}
		else if(diamond > 0){
			console.warn("playerId:",playerId)
			var player = yield app.models.Player.findByIdAsync(playerId, 'userId');
			if (player) {
				var mail = yield app.models.Mails.findByIdAsync(playerId, 'mailInfos');
				if (mail) {
					console.warn("638")
					let item = {
						_id: "",
						index: mail.mailInfos.length, // 邮件下标
						tittleT: 3,  // 邮件标题类型 0:未定义 1:普通通知 2:有奖励通知 3:补偿通知 4:版本更新通知
						descT: 3,  // 邮件内容类型 0:未定义 1:普通通知 2:有奖励通知 3:补偿通知 4:版本更新通知
						reward: 1,              // 有无奖励 0:无奖励 1:有奖励
						rewardT: 1,              // 奖励类型 0:未定义 1:钻石,
						rewardC: diamond,              // 奖励数量
						receive: 0,              // 是否领取 0:未领取 1:已领取
						read: 0,              // 是否已读 0:未读 1:已读
						form:managerId,       //邮件来源
						sendTime: Date.now()    // 发送日期
					}
					let newItem = _.clone(mail.mailInfos);
					let newItem2 = [0].concat(newItem);
					newItem2[0] = item;
					if(newItem2.length > 60){
						newItem2 = newItem2.slice(0,60)
					}
					mail.mailInfos = [];
					mail.mailInfos = _.clone(newItem2);
					yield mail.saveAsync();
				}
				else{
					let item = {
						_id: "",
						index: 0, // 邮件下标
						tittleT: 3,  // 邮件标题类型 0:未定义 1:普通通知 2:有奖励通知 3:补偿通知 4:版本更新通知
						descT: 3,  // 邮件内容类型 0:未定义 1:普通通知 2:有奖励通知 3:补偿通知 4:版本更新通知
						reward: 1,              // 有无奖励 0:无奖励 1:有奖励
						rewardT: 1,              // 奖励类型 0:未定义 1:钻石,
						rewardC: diamond,              // 奖励数量
						receive: 0,              // 是否领取 0:未领取 1:已领取
						read: 0,              // 是否已读 0:未读 1:已读
						form:managerId,       //邮件来源
						sendTime: Date.now()    // 发送日期
					}
					let newItem = [];
					newItem[0] = item;
					var newMail = new app.models.Mails({
						_id: playerId,                // 用户id（player表的主键）
						userId: player.userId,              // 用户的userId
						mailInfos: newItem // 该活动的达成条件和奖励信息列表
					});
					yield newMail.saveAsync();
				}
			}
		}
		return self.writeOut('999999', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});

// 设置用户是否禁用
proto.setPlayerEnableAsync = P.coroutine(function* (query, method, res) {
	var playerId = query['playerId'];
	if (!playerId) {
		return this.writeOut('fail: userid error!', res);
	}
	var enable = parseInt(query.enable);
	if (enable != 0 && enable != 1) return this.writeOut('enable value error', res);
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}
	console.warn("设置用户是否禁用-------   playerId:  "+playerId +" enable:  "+enable);
	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		var player = yield app.models.Player.findByIdAsync(playerId, 'enable');
		if (player) {
			player.enable = enable;
			yield player.saveAsync();
		}
		else {
			let msg = 'player not find';
			return self.writeOut(msg, res);
		}
		return self.writeOut('999999', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});

//ts++ 设置代理
proto.setAgentInfoAsync = P.coroutine(function* (query, method, res) {
	// console.warn("设置代理-------------------");
	logger.warn("setAgentInfoAsync000");////cssj
	var agentId = query['agentId'];
	if (!agentId) {
		return this.writeOut('fail: agentId error!', res);
	}

	var agentName = query['agentName'];

	var contact = query['contact'];
	if (!contact) {
		return this.writeOut('fail: contact error!', res);
	}

	var tel = query['tel'];
	if (!tel) {
		return this.writeOut('fail: tel error!', res);
	}

	var rewardRate = query['rewardRate'];
	var parentRate = query['parentRate'];
	var levelFlag = query['levelFlag'];
	var enabled = Number(query['enabled']) || 1;
	var pwd = query['pwd'];

	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	//console.warn("设置代理-------------------sign:",sign);
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}
	// console.warn("设置代理-------------------222 agentId "+agentId);
	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {

		var agenter = yield app.models.Agenter.findByIdAsync(agentId, 'agentName myUrl rewardRate contact tel parentAgenterId parentRate levelFlag enabled pwd');
		if (agenter) {
			let str0s = "setAgentInfoAsync old "+ JSON.stringify(agenter)
			logger.warn(str0s);////cssj
			var upd=false;
			if(agentName!='' && agenter.agentName!=agentName)
			{
				upd=true;
				agenter.agentName = agentName;
			}

			if(contact!='' && agenter.contact!=contact)
			{
				upd=true;
				agenter.contact = contact;
			}

			if(tel!='' && agenter.tel!=tel)
			{
				upd=true;
				agenter.tel = tel;
			}

			if(rewardRate || rewardRate == 0)
			{
				upd=true;
				agenter.rewardRate = parseInt(rewardRate);
			}

			if(parentRate || parentRate == 0)
			{
				upd=true;
				agenter.parentRate = parseInt(parentRate);
			}
			if((levelFlag || levelFlag == 0) && agenter.levelFlag != levelFlag){
				if(levelFlag == 2){
					if(agenter.parentAgenterId.length == 0 ){
						upd=true;
						agenter.levelFlag = levelFlag;
					}
				}
				else{
					upd=true;
					agenter.levelFlag = levelFlag;
				}
			}

			if((enabled == 0 || enabled == 1 ) && agenter.enabled!=enabled)
			{
				upd=true;
				agenter.enabled = enabled;
			}
			if(pwd!='' && agenter.pwd!=pwd)
			{
				upd=true;
				agenter.pwd = pwd;
			}
			// console.warn("设置代理-------------------333 upd "+upd+"  agenter  "+JSON.stringify(agenter));
			if(upd)
			{
				let str1s = "setAgentInfoAsync new "+ JSON.stringify(agenter)
				logger.warn(str1s);////cssj
				yield agenter.saveAsync();
				// console.warn("设置代理-------------------成功");
			}
			else
			{
				// console.warn("设置代理-------------------无修改");
			}
		}
		// console.warn("设置代理-------------------444  ");
		return self.writeOut('999999', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});

//ts++ 设置水果机奖池信息，设置水果机配置
proto.setSGJiangChiAsync = P.coroutine(function* (query, method, res) {
	console.warn("manage设置水果机奖池信息-------------------",query);

	var type = Number(query['type']) || 0;
	if (!type) {
		return this.writeOut('fail: type error!', res);
	}
	var index = Number(query['index']) || 0;
	if (!index || index <= 0 || index > 3) {
		return this.writeOut('fail: index error!', res);
	}

	var dw = Number(query['dw']) || 0;
	if (!dw || dw <= 0 || dw > 3) {
		return this.writeOut('fail: dw error!', res);
	}

	var key = Number(query['key']) || 0;
	if (!key) {
		return this.writeOut('fail: key error!', res);
	}

	var value = Number(query['value']) || 0;
	if (value < 0) {
		return this.writeOut('fail: value error!'+value, res);
	}

	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}
	console.warn("manage设置水果机奖池信息-------------------",type,index,dw,key,value);
	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		let jcPools = yield app.models.SGJJC.findByIdAsync('sgjjcs');
		if (jcPools) {
			console.warn("修改之前",jcPools);
			let isUp = false;
			if(type == 1){//游戏奖池
				if(key >= 1 && key <= 3){
					let list = [jcPools.pools,jcPools.levels,jcPools.cspools]
					console.warn("list:",list)
					console.warn(" index:",index," key:",key)
					if(index > 0 && index <= list[key-1].length && list[key-1][index-1] != value){
						list[key-1][index-1] = value;
						// ✅ 关键：告诉模型数组变了
						console.warn("list:",list)
						console.warn("value:",value)
						console.warn("jcPools.pools:",jcPools.pools)
						isUp = true;
					}
				}
				else if((key >= 4 && key <= 9) && dw > 0 && dw <= 3){
					let list = [jcPools.topLimits1,jcPools.topLimits2,jcPools.topLimits3];
					if(key == 5) list = [jcPools.lowLimits1,jcPools.lowLimits2,jcPools.lowLimits3];
					else if(key == 6) list = [jcPools.paiTopRate1,jcPools.paiTopRate2,jcPools.paiTopRate3];
					else if(key == 7) list = [jcPools.paiLowRate1,jcPools.paiLowRate2,jcPools.paiLowRate3];
					else if(key == 8) list = [jcPools.bsTopRate1,jcPools.bsTopRate2,jcPools.bsTopRate3];
					else if(key == 9) list = [jcPools.bsLowRate1,jcPools.bsLowRate2,jcPools.bsLowRate3];
					if(index > 0 && index <= list[dw-1].length && list[dw-1][index-1] != value){
						list[dw-1][index-1] = value;
						isUp = true;
					}
				}
			}
			else if(type == 2){//押大小奖池
				if(key >= 1 && key <= 3){
					let list = [jcPools.ydxpools,jcPools.ydxlevels,jcPools.ydxcspools]
					if(index > 0 && index <= list[key-1].length && list[key-1][index-1] != value){
						list[key-1][index-1] = value;
						isUp = true;
					}
				}
				else if((key >= 4 && key <= 11) && dw > 0 && dw <= 3){
					if(key >= 6 && key <= 9) return self.writeOut('can not set '+key, res);
					let list = [jcPools.ydxtopLimits1,jcPools.ydxtopLimits2,jcPools.ydxtopLimits3];
					if(key == 5) list = [jcPools.ydxlowLimits1,jcPools.ydxlowLimits2,jcPools.ydxlowLimits3];
					else if(key == 10) list = [jcPools.ydxTopRate1,jcPools.ydxTopRate2,jcPools.ydxTopRate3];
					else if(key == 11) list = [jcPools.ydxLowRate1,jcPools.ydxLowRate2,jcPools.ydxLowRate3];
					if(index > 0 && index <= list[dw-1].length && list[dw-1][index-1] != value){
						list[dw-1][index-1] = value;
						isUp = true;
					}
				}
			}
			if(isUp){
				// jcPools.levels = _.cloneDeep(jcPools.levels)//这样写也不行
				// yield jcPools.saveAsync();
				let jcPools2 = yield app.models.SGJJC.findByIdAsync('sgjjcs');
				if(type == 1){//游戏奖池
					if(key >= 1 && key <= 3){
						console.warn("935 jcpools.pools:",jcPools.pools)
						jcPools2.pools = _.cloneDeep(jcPools.pools);
						console.warn("jcPools:",jcPools)
						jcPools2.levels = _.cloneDeep(jcPools.levels);
						jcPools2.cspools = _.cloneDeep(jcPools.cspools);
					}
					else if(key >= 4 && key <= 9){
						jcPools2.topLimits1 = _.cloneDeep(jcPools.topLimits1);
						jcPools2.topLimits2 = _.cloneDeep(jcPools.topLimits2);
						jcPools2.topLimits3 = _.cloneDeep(jcPools.topLimits3);
						jcPools2.lowLimits1 = _.cloneDeep(jcPools.lowLimits1);
						jcPools2.lowLimits2 = _.cloneDeep(jcPools.lowLimits2);
						jcPools2.lowLimits3 = _.cloneDeep(jcPools.lowLimits3);
						jcPools2.paiTopRate1 = _.cloneDeep(jcPools.paiTopRate1);
						jcPools2.paiTopRate2 = _.cloneDeep(jcPools.paiTopRate2);
						jcPools2.paiTopRate3 = _.cloneDeep(jcPools.paiTopRate3);
						jcPools2.paiLowRate1 = _.cloneDeep(jcPools.paiLowRate1);
						jcPools2.paiLowRate2 = _.cloneDeep(jcPools.paiLowRate2);
						jcPools2.paiLowRate3 = _.cloneDeep(jcPools.paiLowRate3);
						jcPools2.bsTopRate1 = _.cloneDeep(jcPools.bsTopRate1);
						jcPools2.bsTopRate2 = _.cloneDeep(jcPools.bsTopRate2);
						jcPools2.bsTopRate3 = _.cloneDeep(jcPools.bsTopRate3);
						jcPools2.bsLowRate1 = _.cloneDeep(jcPools.bsLowRate1);
						jcPools2.bsLowRate2 = _.cloneDeep(jcPools.bsLowRate2);
						jcPools2.bsLowRate3 = _.cloneDeep(jcPools.bsLowRate3);
					}
				}
				else if(type == 2){//押大小奖池
					if(key >= 1 && key <= 3){
						jcPools2.ydxpools = _.cloneDeep(jcPools.ydxpools);
						jcPools2.ydxlevels = _.cloneDeep(jcPools.ydxlevels);
						jcPools2.ydxcspools = _.cloneDeep(jcPools.ydxcspools);
					}
					else if(key >= 4 && key <= 11){
						jcPools2.ydxtopLimits1 = _.cloneDeep(jcPools.ydxtopLimits1);
						jcPools2.ydxtopLimits2 = _.cloneDeep(jcPools.ydxtopLimits2);
						jcPools2.ydxtopLimits3 = _.cloneDeep(jcPools.ydxtopLimits3);
						jcPools2.ydxlowLimits1 = _.cloneDeep(jcPools.ydxlowLimits1);
						jcPools2.ydxlowLimits2 = _.cloneDeep(jcPools.ydxlowLimits2);
						jcPools2.ydxlowLimits3 = _.cloneDeep(jcPools.ydxlowLimits3);
						jcPools2.ydxTopRate1 = _.cloneDeep(jcPools.ydxTopRate1);
						jcPools2.ydxTopRate2 = _.cloneDeep(jcPools.ydxTopRate2);
						jcPools2.ydxTopRate3 = _.cloneDeep(jcPools.ydxTopRate3);
						jcPools2.ydxLowRate1 = _.cloneDeep(jcPools.ydxLowRate1);
						jcPools2.ydxLowRate2 = _.cloneDeep(jcPools.ydxLowRate2);
						jcPools2.ydxLowRate3 = _.cloneDeep(jcPools.ydxLowRate3);
					}
				}
				console.warn("修改之后 jcPools2:",jcPools2)
				yield jcPools2.saveAsync();
				// console.warn("奖池更新了",jcPools);
				// console.warn("奖池更新了222   ",jcPools2);
				jcPools = null;
			}
			else{
				return self.writeOut('value no change ', res);
			}
		}
		else{
			return self.writeOut('no jcPools! ', res);
		}
		return self.writeOut('999999', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});

//ts++ //得到水果机某个字段的总和
proto.getSGATypeAllAsync = P.coroutine(function* (query, method, res) {
	console.warn("manage得到水果机某个字段的总和-------------------");
	var type = query['type'];
	if (!type) {
		return this.writeOut('fail: type error!', res);
	}
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}
	// let sjk = "SGJUser";
	// var sgjUsers = yield this.app.models[sjk].aggregateAsync([
	//像上面这样动态查询数据库也是可以的
	var sgjUsers = yield this.app.models.SGJUser.aggregateAsync([
		{ $group: { _id: type, count: { $sum: '$'+type } } }
	]);
	console.warn("聚合之后   ",type,JSON.stringify(sgjUsers));
	let result = "error: nofind";
	if(sgjUsers.length > 0) result = sgjUsers[0].count;
	return this.writeOut(result, res);
	// var startTime = 1710866910000;
	// var endTime = 1711007310000;
	// var opts = { registerTime: { $gte: startTime, $lt: endTime } };
	// opts.playerId = "0ab@my2019";//new RegExp('.+@' + '0ab' + '$');
	// var list = yield this.app.models.DiamondRecord.aggregateAsync([
	//     { $match: opts },
	//     { $group: { _id: opts.playerId, count: { $sum: '$dSwap' } } },
	//     { $sort: { registerTime: 1 } }
	// ]);
	// console.warn("聚合之后111   ",list.length,JSON.stringify(list));


	// var startTime = 1710866910000;
	// var endTime = 1711007310000;
	// var opts = { registerTime: { $gte: startTime, $lt: endTime } };
	// // opts.playerId = "0ab@my2019";//new RegExp('.+@' + '0ab' + '$');
	// var list = yield this.app.models.SGJUser.aggregateAsync([
	//     { $match: opts },
	//     { $group: { _id: "xxxxx", count: { $sum: '$cost' } } },
	//     { $sort: { registerTime: 1 } }
	// ]);
	// console.warn("聚合之后111   ",list.length,JSON.stringify(list));



});

//ts++ 水果机任务发奖完成
proto.sgjRWFJOverAsync = P.coroutine(function* (query, method, res) {
	console.warn("manage水果机任务发奖完成-------------------");

	// var fjinfo = query['fjinfo'] || "";
	//  console.warn("manage水果机任务发奖完成-------------------   ",fjinfo);

	var pid = query['pid'];
	if (!pid) {
		return this.writeOut('fail: pid error!', res);
	}
	var type = Number(query['type']) || 0;
	if (!type) {
		return this.writeOut('fail: type error!', res);
	}
	var rwid = query['rwid'];
	if (type == 2 && !rwid) {
		return this.writeOut('fail: rwid error!', res);
	}

	var fqs = Number(query['fqs']) || 0;
	if (type == 2 && !fqs) {
		return this.writeOut('fail: fqs error!', res);
	}

	var fqtime = Number(query['fqtime']) || 0;
	if (!fqtime) {
		return this.writeOut('fail: fqtime error!', res);
	}

	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}
	console.warn("manage水果机任务发奖完成-------------------",pid,type,rwid,fqs,fqtime);

	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		if(type == 1){
			var sgjUser = yield app.models.SGJUser.findByIdAsync(pid, 'zfbAcc zfbName zfbBindTime');
			if (sgjUser) {
				if(Date.now() - sgjUser.zfbBindTime < 86400000 ) return self.writeOut('one day no more once! ', res);
				console.warn("?????找到用户了  ",fqs,fqtime);
				if(fqs){
					sgjUser.zfbBindTime = fqtime;
				}
				else{
					sgjUser.zfbAcc = "";
					sgjUser.zfbName = "";
				}
				yield sgjUser.saveAsync();
			}
			else{
				return self.writeOut('pid value error! ', res);
			}
		}
		else if(type == 2){
			var taskInfo = yield app.models.SGJTask.findByIdAsync(rwid, 'playerId rewards state fjTime');
			if (taskInfo) {
				if(fqs != taskInfo.rewards){
					return self.writeOut('fail: fqs value error!', res);
				}
				if(pid != taskInfo.playerId){
					return self.writeOut('fail: pid value error!', res);
				}
				if(taskInfo.state != 2 || taskInfo.fjTime != 0){
					return self.writeOut('fail: Cannot be claimed repeatedly!', res);
				}
				taskInfo.state = 3;  //任务状态0:未完成，1:已完成，2:发奖中，3:已发奖
				taskInfo.fjTime = fqtime;  //发奖时间
				console.warn("发奖成功之后更新任务状态  ");
				yield taskInfo.saveAsync();
				var sgjUser = yield app.models.SGJUser.findByIdAsync(pid, 'taskReward jxzReward');
				if (sgjUser) {
					sgjUser.jxzReward -= fqs;
					sgjUser.taskReward += fqs;
					yield sgjUser.saveAsync();
				}

			}
			else{
				logger.warn("rwjlzj(rwid) error");////cssj
				return self.writeOut('rwjlzj(rwid) error! :', res);
			}
		}
		return self.writeOut('999999', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});

//ts++ 后台给玩家发邮件
proto.addMailAsync = P.coroutine(function* (query, method, res) {
	// console.warn("后台给玩家发邮件-------------------");

	var playerId = query['playerid'];
	if (!playerId) {
		return this.writeOut('fail: playerid error!', res);
	}

	var userId = query['userid'];
	if (!userId) {
		return this.writeOut('fail: userid error!', res);
	}

	var tittleT = Number(query['tittleT']) || 0;;
	if (!tittleT) {
		return this.writeOut('fail: tittleT error!', res);
	}

	var descT = Number(query['descT']) || 0;;
	if (!descT) {
		return this.writeOut('fail: descT error!', res);
	}

	var reward = Number(query['reward']) || 0;;
	var rewardT = Number(query['rewardT']) || 0;
	var rewardC = Number(query['rewardC']) || 0;
	if (reward) {
		if(!rewardT || !rewardC){
			return this.writeOut('fail: rewardT or rewardC error!', res);
		}
	}
	else{
		if(rewardT){
			return this.writeOut('fail: rewardT error!', res);
		}
		if(rewardC){
			return this.writeOut('fail: rewardC error!', res);
		}
	}
	var form = query['form'];
	if (!form) {
		return this.writeOut('fail: form error!', res);
	}

	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}

	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		let receive = 1;
		if(reward) receive = 0;
		var mail = yield app.models.Mails.findByIdAsync(playerId, 'mailInfos');
		if (mail) {
			let item = {
				_id: "",
				index: mail.mailInfos.length, // 邮件下标
				tittleT: tittleT,  // 邮件标题类型 0:未定义 1:普通通知 2:有奖励通知 3:补偿通知 4:版本更新通知
				descT: descT,  // 邮件内容类型 0:未定义 1:普通通知 2:有奖励通知 3:补偿通知 4:版本更新通知
				reward: reward,              // 有无奖励 0:无奖励 1:有奖励
				rewardT: rewardT,              // 奖励类型 0:未定义 1:钻石,
				rewardC: rewardC,              // 奖励数量
				receive: receive,              // 是否领取 0:未领取 1:已领取
				read: 0,              // 是否已读 0:未读 1:已读
				form:form,       //邮件来源
				sendTime: Date.now()    // 发送日期
			}
			let newItem = _.clone(mail.mailInfos);
			let newItem2 = [0].concat(newItem);
			newItem2[0] = item;
			if(newItem2.length > 60){
				newItem2 = newItem2.slice(0,60)
			}
			mail.mailInfos = [];
			mail.mailInfos = _.clone(newItem2);
			yield mail.saveAsync();
		}
		else{
			let item = {
				_id: "",
				index: 0, // 邮件下标
				tittleT: tittleT,  // 邮件标题类型 0:未定义 1:普通通知 2:有奖励通知 3:补偿通知 4:版本更新通知
				descT: descT,  // 邮件内容类型 0:未定义 1:普通通知 2:有奖励通知 3:补偿通知 4:版本更新通知
				reward: reward,              // 有无奖励 0:无奖励 1:有奖励
				rewardT: rewardT,              // 奖励类型 0:未定义 1:钻石,
				rewardC: rewardC,              // 奖励数量
				receive: receive,              // 是否领取 0:未领取 1:已领取
				read: 0,              // 是否已读 0:未读 1:已读
				form:form,       //邮件来源
				sendTime: Date.now()    // 发送日期
			}
			let newItem = [];
			newItem[0] = item;
			var newMail = new app.models.Mails({
				_id: playerId,                // 用户id（player表的主键）
				userId: userId,              // 用户的userId
				mailInfos: newItem // 该活动的达成条件和奖励信息列表
			});
			yield newMail.saveAsync();
		}
		return self.writeOut('999999', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});

////// ts++ 显示uid和实际uid互相转换
proto.sidAridChangeAsync = P.coroutine(function* (query, method, res) {
	// console.warn("显示uid和实际uid互相转换-------------------");

	var type = Number(query['type']) || 0;;
	if (type != 1 && type != 2) {
		return this.writeOut('fail: type error!', res);
	}

	var id = Number(query['id']) || 0;;
	if (id < 100000 && id > 999999) {
		return this.writeOut('fail: id error!', res);
	}
	// console.warn("显示uid和实际uid互相转换  type  "+type+"  id  "+id);
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}
	let result = "";
	if(type == 1) result = this.jiami(id);
	else if(type == 2) result = ""+this.jiemi(id);
	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {

		let data = {
			code:201,
			newId:0
		}
		if(result.length == 6){
			data.code = 200;
			data.newId = result;
		}
		let dataStr = JSON.stringify(data)
		return self.writeOut(dataStr, res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});

proto.jiami = function (_oldid) {
	let oldid = String(_oldid);
	// console.warn("111    加密参数  oldid  "+oldid);
	let numList = [];
	for (var i = 0; i < oldid.length; i++) {
		// numList[i] = (parseInt(oldid[i])+i+1)%10;
		numList[i] = (parseInt(oldid[i])+i)%10;
		// console.warn("222  numList[i]  "+numList[i]);
	}
	// console.warn("333    "+JSON.stringify(numList));
	//这种交换方式会使加密后结果转换成数字之后是个小于6位数的数字，其中987654这个加密之后是0
	// let jh1 = numList[0];
	// numList[0] = numList[4];
	// numList[4] = jh1;
	let jh1 = numList[1];
	numList[1] = numList[3];
	numList[3] = jh1;
	// console.warn("444  [0]和[4]交换  "+JSON.stringify(numList));
	let jh2 = numList[2];
	numList[2] = numList[5];
	numList[5] = jh2;
	let newid = "";
	// console.warn("555  [2]和[5]交换    "+JSON.stringify(numList));
	for (var i = 0; i < numList.length; i++) {
		newid+=numList[i];
	}
	// console.warn("666   加密最终的    "+newid);
	return newid;
	// return parseInt(newid);
};

proto.jiemi = function (_oldid) {
	let oldid = String(_oldid);
	// console.warn("111   解密参数   oldid  "+oldid);
	let numList = [];
	for (var i = 0; i < oldid.length; i++) {
		numList[i] = parseInt(oldid[i]);
		// console.warn("222  numList[i]  "+numList[i]);
	}
	// console.warn("333    "+JSON.stringify(numList));
	// let jh1 = numList[0];
	// numList[0] = numList[4];
	// numList[4] = jh1;
	let jh1 = numList[1];
	numList[1] = numList[3];
	numList[3] = jh1;
	// console.warn("444  [0]和[4]交换  "+JSON.stringify(numList));
	let jh2 = numList[2];
	numList[2] = numList[5];
	numList[5] = jh2;
	let numList2 = []
	for (var i = 0; i < oldid.length; i++) {
		// numList2[i] = (numList[i]+9-i)%10;
		numList2[i] = (numList[i]+10-i)%10;
		// console.warn("2  numList[i]  "+numList[i]);
	}
	// console.warn("555  [2]和[5]交换    "+JSON.stringify(numList));
	let newid = "";
	for (var i = 0; i < numList2.length; i++) {
		newid+=numList2[i];
	}
	// console.warn("666   解密最终的    "+newid);
	return parseInt(newid);
};

//后台增加比赛的开始和结束时间
proto.addRaceTimeAsync = P.coroutine(function* (query, method, res) {
	console.warn("addRaceTimeAsync     后台增加比赛的开始和结束时间");
	var aid = query['aid'];
	if (!aid) {
		return this.writeOut('fail: aid error!', res);
	}

	var anumber = parseInt(query['anumber']) || 0;
	if (!anumber) {
		return this.writeOut('fail: anumber error!', res);
	}

	var stime = Number(query['stime']) || 0;;
	if (!stime) {
		return this.writeOut('fail: stime error!', res);
	}

	var etime = Number(query['etime']) || 0;;
	if (!etime) {
		return this.writeOut('fail: etime error!', res);
	}

	if(stime >= etime) return this.writeOut('fail: stime or etime error!', res);
	var outTime = Number(query['outTime']) || (etime+90*60000);//默认90分钟之后过期
	if (!outTime) {
		return this.writeOut('fail: outTime error!', res);
	}
	if (outTime < etime+40*60000) {
		return this.writeOut('过期时间必须为结束时间40分钟之后', res);
	}
	var bigRound = Number(query['bigRound']) || 3;
	if (!bigRound) {
		return this.writeOut('fail: bigRound error!', res);
	}
	var gameid = Number(query['gameid']) || 10008;
	if (!gameid) {
		return this.writeOut('fail: gameid error!', res);
	}
	var round = Number(query['round']) || 10;
	if (!round) {
		return this.writeOut('fail: round error!', res);
	}
	var player = Number(query['player']) || 3;
	if (!player) {
		return this.writeOut('fail: player error!', res);
	}
	var other = Number(query['other']) || 74;
	if (!other) {
		return this.writeOut('fail: other error!', res);
	}
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}

	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		let stimeSJC = self.getzdLDSJC(stime);
		var opts = {
			stime: { $gte: stimeSJC, $lt: stimeSJC+86400000},
		};
		opts['aid'] = aid;
		let timelist = yield app.models.RaceTimeInfos.findMongoAsync(opts, 'aid agentNo stime etime bigRound gameId round playerCount other outTime', { sort: { stime: 1 } });
		for (var i = 0; i < timelist.length; i++) {
			if(timelist[i].outTime >= stime){
				return self.writeOut('新开比赛场次开始时间不能小于现有场次的过期时间', res);//一个群推广目前一天只能开一场比赛
			}
		}

		var newRaceTime = new app.models.RaceTimeInfos({
			_id: uuid.v1(),  // UUID 标识
			aid: aid,        // 比赛代理的标识
			agentNo: anumber,// 比赛代理编号
			stime: stime,    // 该次比赛的开始时间
			etime: etime,    // 该次比赛的结束时间
			bigRound: bigRound,// 该次比赛的大局数量，统计战绩时使用
			gameId: gameid,  // 该次比赛的游戏id 10006为长沙麻将，10007为红中麻将，10008为跑得快
			round: round,  // 该次比赛的游戏局数
			playerCount: player,  // 该次比赛的游戏人数
			other: other, // 该次比赛的游戏规则
			outTime: outTime, //1:未过期，2已过期
			yljList: []   // 该次比赛已领奖人员id数组

		});
		yield newRaceTime.saveAsync();

		return self.writeOut('999999', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});


////后台设置比赛是否过期
proto.setRaceTimeOutAsync = P.coroutine(function* (query, method, res) {
	// console.warn("setRaceTimeOutAsync   后台设置比赛是否过期");
	var id = query['id'] || "";//需要修改的比赛场次的id(主键)
	if (!id) {
		return this.writeOut('fail: id error!', res);
	}
	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}
	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		var raceTime = yield app.models.RaceTimeInfos.findByIdAsync(id, '_id aid outTime stime etime yljList');
		if (raceTime) {
			let outTime = Number(query['outTime']) || (raceTime.etime + 6000000);//默认60分钟之后过期
			// console.warn("后台设置比赛是否过期 id "+id+"  etime  "+raceTime.etime+"  outTime  "+raceTime.outTime+"  type  "+type);
			if(raceTime.etime + 2400000 >= outTime){//结束40分钟之后才能设置为过期
				return self.writeOut('过期时间必须为结束时间40分钟之后', res);
			}
			if(self.getzdLDSJC(raceTime.stime) != self.getzdLDSJC(outTime)){//结束40分钟之后才能设置为过期
				return self.writeOut('过期时间和开始时间必须是同一天', res);
			}
			let stimeSJC = self.getzdLDSJC(raceTime.stime);
			var opts = {
				stime: { $gte: stimeSJC, $lt: stimeSJC+86400000},
			};
			opts['aid'] = raceTime.aid;
			let timelist = yield app.models.RaceTimeInfos.findMongoAsync(opts, '_id aid stime etime outTime', { sort: { stime: 1 } });
			// console.warn(">>>>>>>>>>>>>>>..   "+timelist.length);
			for (var i = 0; i < timelist.length; i++) {
				if(raceTime.stime > timelist[i].stime) continue;
				if(raceTime._id == timelist[i]._id) continue;
				if(timelist[i].stime <= outTime){
					return self.writeOut('本场过期时间不能和现有比赛场次的时间重合', res);//一个群推广目前一天只能开一场比赛
				}
			}
			if(raceTime.outTime != outTime){
				raceTime.outTime = outTime;
				yield raceTime.saveAsync();
				// console.warn("设置设置 grade -------------------修改");
			}
			return self.writeOut('999999', res);
		}
		else{
			return self.writeOut('not fid raceTime by id : '+id, res);
		}
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});

//////后台增设置不能在同一桌游戏的玩家
proto.setNotGameTogtherAsync = P.coroutine(function* (query, method, res) {
	// console.warn("setNotGameTogtherAsync     后台增设置不能在同一桌游戏的玩家");
	var type = Number(query['type']) || 0;//操作类型
	var id = query['id'] || "";
	var uid1 = Number(query['uid1']) || 0;
	var uid2 = Number(query['uid2']) || 0;//删除整条的时候此值可不传
	// console.warn("后台增设置不能在同一桌游戏的玩家  type  "+type+"  id  "+id+"  uid1  "+uid1+"  uid2  "+uid2);
	if (type == 1) {//1:增加，2:删除整条，3：删除某条中某一个
		if (!uid1) return this.writeOut('fail: no uid1 !', res);
		if (!uid2) return this.writeOut('fail: no uid2 !', res);
		if (uid1 == uid2) return this.writeOut('fail: uid1 和 uid2 不能相同', res);
	}
	else if (type == 2) {//1:增加，2:删除整条，3：删除某条中某一个
		if (!id) return this.writeOut('fail: no id !', res);
	}
	else if (type == 3) {//1:增加，2:删除整条，3：删除某条中某一个
		if (!id) return this.writeOut('fail: no id。', res);
		if (!uid1) return this.writeOut('fail: no uid1。', res);
	}
	else return this.writeOut('fail: no type !', res);

	var sign = query['sign']||"";
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}

	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		if(type == 1){
			let pid1 = "";
			var players1 = yield app.models.Player.findMongoAsync({ userId: uid1 },'_id userId name');
			if (players1.length == 1) {
				pid1 = players1[0]._id;
			}
			else {
				return self.writeOut('fail: uid1 error!', res);
			}
			let pid2 = "";
			var players2 = yield app.models.Player.findMongoAsync({ userId: uid2 },'_id userId name');
			if (players2.length == 1) {
				pid2 = players2[0]._id;
			}
			else{
				return self.writeOut('fail: uid2 error!', res);
			}
			let newList = [];
			let newPList = [];
			var notTogthers1 = yield app.models.NotGameTogther.findMongoAsync({ uidList: uid1 },'_id uidList pidList');
			if(notTogthers1.length == 0) {
				newList[newList.length] = uid1;
				newPList[newPList.length] = pid1;
			}
			for (var i = 0; i < notTogthers1.length; i++) {
				// console.warn("包含uid1的数组 111      "+i+"  "+JSON.stringify(notTogthers1[i].uidList));
				for (var j = 0; j < notTogthers1[i].uidList.length; j++) {
					let item = notTogthers1[i].uidList[j];
					let itemP = notTogthers1[i].pidList[j];
					if(newList.indexOf(item) == -1){
						newList[newList.length] = item;
						newPList[newPList.length] = itemP;
					}
				}
				yield notTogthers1[i].removeAsync();
			}
			// console.warn("处理完uid1之后的newlist  111  "+JSON.stringify(newList));
			var notTogthers2 = yield app.models.NotGameTogther.findMongoAsync({ uidList: uid2 },'_id uidList pidList');
			if(notTogthers2.length == 0) {
				newList[newList.length] = uid2;
				newPList[newPList.length] = pid2;
			}
			for (var i = 0; i < notTogthers2.length; i++) {
				// console.warn("包含uid1的数组 111      "+i+"  "+JSON.stringify(notTogthers2[i].uidList));
				for (var j = 0; j < notTogthers2[i].uidList.length; j++) {
					let item = notTogthers2[i].uidList[j];
					let itemP = notTogthers2[i].pidList[j];
					if(newList.indexOf(item) == -1){
						newList[newList.length] = item;
						newPList[newPList.length] = itemP;
					}
				}
				yield notTogthers2[i].removeAsync();
			}
			// console.warn("处理完uid2之后的newlist  111  "+JSON.stringify(newList));
			if(newList.length == 0) {
				newList = [uid1,uid2];
				newPList = [pid1,pid2];
			}
			var newNotTogther = new app.models.NotGameTogther({
				_id: uuid.v1(),  // UUID 标识
				uidList: _.cloneDeep(newList),   // 不能在同一桌游戏的玩家userid
				pidList: _.cloneDeep(newPList)   // 不能在同一桌游戏的玩家_id
			});
			yield newNotTogther.saveAsync();
			// console.warn("?????????555  ");
		}
		else if(type == 2){
			var notTogther = yield app.models.NotGameTogther.findByIdAsync(id, '_id uidList');
			if (notTogther) {
				// console.warn("找到了");
				yield notTogther.removeAsync();
			}
			else{
				return self.writeOut('fail: id error!', res);
			}
		}
		else if(type == 3){
			var notTogther = yield app.models.NotGameTogther.findByIdAsync(id, '_id uidList pidList');
			if (notTogther) {
				let newuidList = [];
				let newpidList = [];
				for (var i = 0; i < notTogther.uidList.length; i++) {
					if(notTogther.uidList[i] != uid1){
						newuidList[newuidList.length] = notTogther.uidList[i];
						newpidList[newpidList.length] = notTogther.pidList[i];
					}
				}
				if(newuidList.length == notTogther.uidList.length){
					return self.writeOut('fail: uid1 not find!', res);
				}
				else{
					if(newuidList.length > 1){
						notTogther.uidList = _.cloneDeep(newuidList);
						notTogther.pidList = _.cloneDeep(newpidList);
						yield notTogther.saveAsync();
					}
					else{
						yield notTogther.removeAsync();
					}
				}
			}
			else{
				return self.writeOut('fail: id error!', res);
			}
		}
		return self.writeOut('999999', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});

//后台设置玩家禁赛
proto.setJinSaiAsync = P.coroutine(function* (query, method, res) {
	console.warn("setJinSaiAsync     后台设置玩家禁赛");
	var pid = query['id'];
	if (!pid) {
		return this.writeOut('fail: pid error!', res);
	}

	var uid = parseInt(query['uid']) || 0;
	if (!uid) {
		return this.writeOut('fail: uid error!', res);
	}

	// var stime = Number(query['stime']) || 0;;
	// if (!stime) {
	// 	return this.writeOut('fail: stime error!', res);
	// }

	var sign = query['sign'];
	if (!sign) {
		return this.writeOut('fail: sign error!', res);
	}
	if (!checkSign(sign)) {
		return this.writeOut('fail: sign error!', res);
	}

	var self = this;
	var app = this.app;
	return app.memdb.goose.transactionAsync(P.coroutine(function* () {
		var jinsai = yield app.models.JinSaiInfo.findByIdAsync(pid, '_id userId');
		if (jinsai) {
			yield jinsai.removeAsync();

		}
		else{
			var jinsaiinfo = new app.models.JinSaiInfo({
				_id: pid,  // UUID 标识
				userId: uid        // 比赛代理的标识
			});
			yield jinsaiinfo.saveAsync();
		}
		return self.writeOut('999999', res);
	}), app.getServerId())
		.then(() => app.event.emit('transactionSuccess'), () => app.event.emit('transactionFail'));
});


//TL++,得到指定时间戳（_time）当日0点的时间戳
proto.getzdLDSJC = function (_time){
	var today = new Date(_time);
	today.setHours(0);
	today.setMinutes(0);
	today.setSeconds(0);
	today.setMilliseconds(0);
	let jrsjc = today.getTime();
	// console.warn("111得到今日0点的时间戳   ",jrsjc, typeof jrsjc);
	return jrsjc;
};

//ts++签名验证
function checkSign(sign) {
	var signKey = 'defe6d21422c8b770767f74fcea95';
	if (sign!=signKey) return false;
	return true;
};

proto.getTodaySJC = function (){
	var today = new Date();
	today.setHours(0);
	today.setMinutes(0);
	today.setSeconds(0);
	today.setMilliseconds(0);
	let jrsjc = today.getTime();
	// console.warn("111得到今日0点的时间戳   ",jrsjc, typeof jrsjc);
	return jrsjc;
};