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();
	    	}
	    }
		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;
};