hnhzServer/gameRoute.js

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