'use strict'; var _ = require('lodash'); var P = require('quick-pomelo').Promise; var groute = require('./groute'); var gidsRoutes = {}; exports.gameRoute = P.coroutine(function* (session, msg, app, cb) { var uid = session.uid; var args = msg.args[0] || {}; var method = args.route || ''; var body = args.body || {}; var servers = app.getServersByType('game'); //TL++下面这个if,为了实现将game-server-11作为比赛专用服务,普通的手动创房不要占用game-server-11这个服务 if (method.lastIndexOf('createTable') != -1 || method.lastIndexOf('creatOrjoinTable') != -1 ) { let qcbsfuzh = [];//去除比赛服务之后的服务列表 for (var i = 0; i < servers.length; i++) { if(servers[i].id == "game-server-11") continue; qcbsfuzh[qcbsfuzh.length] = servers[i]; } // console.warn("去除比赛专用服务game-server-11 之前 servers "+JSON.stringify(servers)); servers = qcbsfuzh; // console.warn("去除比赛专用服务game-server-11 之后 servers "+JSON.stringify(servers)); } if (method.lastIndexOf('createTable') != -1) { let serverIds = groute[method]; let serverId = serverIds ? _.sample(serverIds) : _.sample(servers).id; if (uid) gidsRoutes[uid] = serverId; return cb(null, serverId); } var tableId = body.tableId; if (tableId) { let num = String(tableId).charAt(0); let num1 = String(tableId).charAt(1);//ts++两位 let serverId = 'game-server-' + num +num1; let pos = _.findIndex(servers, { id: serverId }); if (-1 != pos) { if (uid) gidsRoutes[uid] = serverId; return cb(null, serverId); } } if (uid) { let serverId = gidsRoutes[uid]; if (serverId) return cb(null, serverId); let player = yield app.memdb.goose.transactionAsync(() => app.models.Player.findByIdReadOnlyAsync(uid, 'gameServerId'), app.getServerId()); if (player && player.gameServerId) serverId = player.gameServerId; if (!serverId) serverId = _.sample(servers).id; gidsRoutes[uid] = serverId; return cb(null, serverId); } return cb(null, _.sample(servers).id); });