postServer.js

var Var = require('./variables.js');
var sql = require('./sql.js');
var queue = require('./makeQueue.js');

//Регистрация водителя, пассажира
//На будущее: проверить номера. Номер должен быт 9-значным. Не должен совпадать в базе
Var.app.post('/registration', function(request, response) {
    var body = request.body;
	var name = body['name'];
	var phone = body['phone'];
    var human = body['human'];

    var logTime = new Date().toLocaleTimeString();
    console.log(logTime, " :: /registration", name, phone, human);
    if (phone.length != 11) {
        console.log("phone number is not 11-symbols");
        response.send("phone number is not 11-symbols");
        return;
    }
    
    if (name.length == 0) {
        console.log("name is NULL");
        response.send("name is NULL");
        return;
    }
	
    if (human == 'driver' || human == 'passenger') {
        sql.main('INSERT INTO ' + human + '(name, phone) VALUES ("' + name + '", "' + phone + 
                '") ON DUPLICATE KEY UPDATE name = VALUES(name);', function (error, rows) {
            sql.main("SELECT id FROM " + human + " WHERE phone = " + phone + ";", function (error, rows) {
                console.log("\t\tID: ", rows[0]["id"]);
                if (error) {
                    console.log(error);
                    response.send(JSON.stringify(error));
                    return;
                }
                response.send(JSON.stringify(rows[0]["id"]));
            });
        });
        return;
    }
	response.send("not added");
});

//Встать в очередь
Var.app.post('/qdriver', function(request, response) {
	var body = request.body;
	var id = body["id"] - 0;
	var seats = body["seats"] - 0;
	var time = body["time"] - 0;
    var direction = body["direction"] - 0;
    var date = body["date"];
    var logTime = new Date().toLocaleTimeString();
    var human = "driver";
    console.log(logTime, ":: driverId: " + id + ",\ttime: " + time + ",\tdirection: " + direction + ",\tseats:" + seats);
    
    addingToQueue(response, id, seats, time, direction, date, human);

});

Var.app.post('/qpassenger', function(request, response) {
	var body = request.body;
	var id = body["id"] - 0;
	var booked = body["booked"] - 0;
	var time = body["time"] - 0;
	var direction = body["direction"] - 0;
    var date = body["date"] - 0;
    var logTime = new Date().toLocaleTimeString();
    var human = "passenger";
    console.log(logTime, ":: qpassengerId: " + id + ",\ttime: " + time + ",\tdirection: " + direction + ",\tbooked:" + booked);

    addingToQueue(response, id, booked, time, direction, date, human);
});

//This will be general function, because /qpassenger and /qdriver have lot of identical lines
function addingToQueue(response, id, bookedSeats, time, direction, date, human) {
    //Проверка ошибок
    //Проверка направления
    if (isNaN(direction) || direction < Var.directionMin || direction > Var.directionMax) {
        console.log("\tunknown direction");
        response.send("unknown direction");
        return;
    }
    //Проверка Времени
    if (isNaN(time) || time < 0 || time > 8) {
        console.log("\tincorrect number of time");
        response.send("incorrect number of time");
        return;
    }

    if (isNaN(bookedSeats) || bookedSeats < 0 || bookedSeats > 4) {
        console.log("\tincorrect number of booked");
		response.send("incorrect number of booked");
		return;
    }
    if (isNaN(date) || date < 0) {
        console.log("\tincorrect number of date");
        response.send("incorrect numberof date");
        return;
    }
	sql.main("SELECT id FROM " + human + " WHERE id = " + id + ";", function(error, rows){
		if(rows[0] === undefined)
		{
            console.log("\tno such user", id);
            response.send("error 404: userID");
            return;
        }
        var titleBookedSeats = human == 'driver' ? 'seats' : 'booked';
        var sqlQuery = 'INSERT INTO q' + human + '(id_' + human + ', id_time, id_direction, ' 
            + titleBookedSeats + ', date) VALUES(' + id + ', ' + time + ', ' + direction + ', ' + 
            bookedSeats + ', ' + date + ') ON DUPLICATE KEY UPDATE ' + titleBookedSeats + ' = VALUES(' + titleBookedSeats + ');';

        sql.main(sqlQuery, function (error, rows){
                if (error) {
                    console.log("\tDuplicate key? \t", error);
                    response.send("error with adding " + titleBookedSeats + " to queue");
                    return;
                }
                response.send("success added to Queue");
                console.log("\tsuccess added");
        });
	});
}