index.js

/* Authors: 
  Arthur Pires
  Fábio S. Takaki
  Lucas Martins
  Ming
*/
//          
var express = require('express');
var app = express();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var mysql = require('mysql');

// Arquivos estaticos.
app.use("/assets", express.static(__dirname + '/assets'));

//------------------------------//
//----------- ROTAS ------------//
//------------------------------//
// QUANDO CHAMAR O URL:1234 QUE ARQUIVO VOU RENDERIZAR ?
app.get('/', function(req, res){
  res.sendFile(__dirname + '/index.html');
});

// SERVIDOR HTTP
http.listen(1234, function(){
  console.log('Listening on *:1234');
});

// SOCKETS
io.on('connection', function(socket){
  var idWaiter = 0;

  // imprime os bytes lidos, acho que não tem necessidade.
  //console.log('Bytes Read:' + socket.request.connection._handle.bytesRead);

  console.log('New User Conected:', socket.request.connection._peername);

  // Quando houver uma conexão socket, começo a conexão com o banco de dados
  var con = mysql.createConnection({
    host: "localhost",
    user: "atividade",
    password: "atividade123",
    database: "atividade"
  });

  // Verifico se a conexão com o banco de dados foi sucedida e printo.
  con.connect(function(err){
    if(err){
      console.log('Error connecting to Database');
      return;
    }
    console.log('Connection established with Database');
  });

  // quando é desconectado
  socket.on('disconnect', function(){

    // Se esse socket estiver conectado com um garçom, devo tirar o status de conectado.
    if(idWaiter != 0){
      con.query(
        'UPDATE waiters SET connected = ? Where idWaiter = ?',
        ["N", idWaiter],
        function (err, result) {
          if (err) throw err;

          console.log('Changed ' + result.changedRows + ' rows');
          console.log('User disconnected', socket.request.connection._peername);
          console.log('200 GAR-DISCONNECT');
        }
      );
    }

    // Mando a listagem de Garçons para todos os outros
    // identificarem quem está online
    con.query('SELECT * FROM waiters',function(err,rows){
      // Se caso der erro, envio um 51 GAR-LIST-NOT
      if(err){
        console.log('51 GAR-LIST-NOT');
         socket.broadcast.emit('51 GAR-LIST-NOT');
         return;
      }

      console.log('50 GAR-LIST-OK');
       socket.broadcast.emit('50 GAR-LIST-OK', rows);
    });

    // encerro a conexão do banco de dados
    con.end(function(err) {
      console.log('Database closed conection');
      // The connection is terminated gracefully
      // Ensures all previously enqueued queries are still
      // before sending a COM_QUIT packet to the MySQL server.
    });

  });

  // Função que devolve os garçons do banco de dados
  socket.on('10 GAR-LIST', function(){
    // Mando a listagem de Garçons para a página
    con.query('SELECT * FROM waiters',function(err,rows){

      // Se caso der erro, envio um 51 GAR-LIST-NOT
      if(err){
        console.log('51 GAR-LIST-NOT');
        io.emit('51 GAR-LIST-NOT');
        return;
      }

      console.log('50 GAR-LIST-OK');
      io.emit('50 GAR-LIST-OK', rows);
    });
  });


  //--------------------------------//
  //----------- FUNÇÕES ------------//
  //--------------------------------//

  //--------------------------------//
  //--- Atualiza Listagem da Mesa --//
  //--------------------------------//
  function updateListTables(){
    // Mando a listagem de mesas para todos que estão na listagem de mesas
    con.query('SELECT * FROM tables',function(err,rows){

      // Se caso der erro, envio um 1051 TBL-LIST-NOT
      if(err){
        console.log('1051 TBL-LIST-NOT');
        socket.to('tables').emit('1051 TBL-LIST-NOT');
        return;
      }

      console.log('1050 TBL-LIST-OK');
      socket.to('tables').emit('1050 TBL-LIST-OK', rows);
    });
  }

  //--------------------------------//
  //---- Verifica Status da Mesa ---//
  //--------------------------------//
  function verifyStatus(table){
    // Se a quantidade de pedidos for 0, eu fecho a mesa
    con.query('SELECT COUNT(*) AS count FROM orders WHERE idTable = '+table,function(err,result3){
      if(result3[0].count == 0){
        // Atualizo a mesa para fechada !
        con.query(
          'UPDATE tables SET status = ? Where idTable = ?',
          ["F", table],
          function (err, result) {
            if (err){
              console.log('1252 TBL-STATUS-NOT');
              socket.emit('1252 TBL-STATUS-NOT');
              return;
            }

            console.log('Changed ' + result.changedRows + ' rows');
            console.log('1253 TBL-STATUS-OK');

            socket.emit('1253 TBL-STATUS-OK');

            // Mando a listagem de mesas para todos que estão na listagem de mesas
            con.query('SELECT * FROM tables',function(err,rows){

              // Se caso der erro, envio um 1051 TBL-LIST-NOT
              if(err){
                console.log('1051 TBL-LIST-NOT');
                socket.to('tables').emit('1051 TBL-LIST-NOT');
              }

              console.log('1050 TBL-LIST-OK');
              socket.to('tables').emit('1050 TBL-LIST-OK', rows);
            });
          }
        );
      }else{
        // Atualizo a mesa para aberta !
        con.query(
          'UPDATE tables SET status = ? Where idTable = ?',
          ["A", table],
          function (err, result) {
            if (err){
              console.log('1252 TBL-STATUS-NOT');
              socket.emit('1252 TBL-STATUS-NOT');
              return;
            }

            console.log('Changed ' + result.changedRows + ' rows');
            console.log('1253 TBL-STATUS-OK');

            socket.emit('1253 TBL-STATUS-OK');

            // Mando a listagem de mesas para todos que estão na listagem de mesas
            updateListTables();
          }
        );
      }
    });
  }

  //------------------------------//
  //----- Identifica Garçom ------//
  //------------------------------//
  socket.on('100 GAR-WAITER', function(id){
    console.log('100 GAR-WAITER ' + id);
    
    // Se o ID for nulo, ou não existir no banco, responde com 151 GAR-WAITER-NOT
    if(id == null){
      console.log('151 GAR-WAITER-NOT');
      socket.emit('151 GAR-WAITER-NOT');
      return;
    }

    // consulto e vejo se o garçom existe e se ele não está conectado
    con.query('SELECT * FROM waiters WHERE idWaiter='+id ,function(err,row){
      if(err){
        console.log('151 GAR-WAITER-NOT');
        socket.emit('151 GAR-WAITER-NOT');
        return;
      }

      // se o garçom estiver conectado !
      if(row[0].connected == 'S'){
        console.log('153 GAR-CONNECT-NOT');
        socket.emit('153 GAR-CONNECT-NOT');
        return;
      
      // senão atualizo para conectado e envio o sucesso da conexão do garçom.
      }else{ 
        con.query(
          'UPDATE waiters SET connected = ? Where idWaiter = ?',
          ["S", id],
          function (err, result) {
            if (err){
              console.log('153 GAR-CONNECT-NOT');
              socket.emit('153 GAR-CONNECT-NOT');
              return;
            }

            idWaiter = id;
            console.log('Changed ' + result.changedRows + ' rows');
            console.log('152 GAR-CONNECT-OK');

            socket.emit('152 GAR-CONNECT-OK');

            // Mando a listagem de Garçons para todos os outros
            // identificarem quem está online
            con.query('SELECT * FROM waiters',function(err,rows){
              // Se caso der erro, envio um 51 GAR-LIST-NOT
              if(err){
                console.log('51 GAR-LIST-NOT');
                 socket.broadcast.emit('51 GAR-LIST-NOT');
              }

              console.log('50 GAR-LIST-OK');
               socket.broadcast.emit('50 GAR-LIST-OK', rows);
            });
          }
        );
      }
    });

  });
  // Fim da identificação do garçom

  //------------------------------//
  //----- Listagem de Mesas ------//
  //------------------------------//
  socket.on('1000 TBL-LIST', function(table){
    // Saiu da sala de pedidos
    socket.leave('orders'+table);

    // Crio uma sala pra quem está na listagem de mesas
    socket.join('tables');

    // Mando a listagem de mesas para a página
    con.query('SELECT * FROM tables',function(err,rows){

      // Se caso der erro, envio um 1051 TBL-LIST-NOT
      if(err){
        console.log('1051 TBL-LIST-NOT');
        socket.emit('1051 TBL-LIST-NOT');
        return;
      }

      console.log('1050 TBL-LIST-OK');
      socket.emit('1050 TBL-LIST-OK', rows);
    });

  });

  //------------------------------//
  //-- Listagem de Mesas SELECT --//
  //------------------------------//
  socket.on('1300 TBL-LIST-SELECT', function(table){

    // Mando a listagem de mesas para a página
    con.query('SELECT * FROM tables',function(err,rows){

      // Se caso der erro..
      if(err){
        console.log('1351 TBL-LIST-SELECT-NOT');
        socket.emit('1351 TBL-LIST-SELECT-NOT');
        return;
      }

      console.log('1350 TBL-LIST-SELECT-OK');
      socket.emit('1350 TBL-LIST-SELECT-OK', rows);
    });

  });

  //------------------------------//
  //----- Listagem de Produtos ---//
  //------------------------------//
  // Função que devolve os produtos do banco de dados
  socket.on('1100 PRO-LIST', function(){
    // Mando a listagem de produtos para a página
    con.query('SELECT * FROM products',function(err,rows){

      // Se caso der erro, envio um 1100 PRO-LIST-NOT
      if(err){
        console.log('1151 PRO-LIST-NOT');
        socket.emit('1151 PRO-LIST-NOT');
        return;
      }

      console.log('1150 PRO-LIST-OK');
      socket.emit('1150 PRO-LIST-OK', rows);
    });
  });

  //------------------------------//
  //----- Listagem de Pedidos ----//
  //------------------------------//
  socket.on('400 ORD-CONSULT', function(table){
    // Saiu da sala de mesas
    socket.leave('tables');

    // entro na sala de pedidos
    socket.join('orders'+table);

    // Mando a listagem de mesas para a página
    con.query('SELECT * FROM orders WHERE idTable='+table ,function(err,rows){
      var data = [];
      data.push(table);
      // Se caso der erro, envio um 451 ORD-CONSULT-NOT
      if(err){
        console.log('451 ORD-CONSULT-NOT');
        socket.emit('451 ORD-CONSULT-NOT');
        return;
      }
      data.push(rows);

      // mando todos os produtos dessa mesa
      var query;
      query = 'SELECT o.*, p.`name`, p.`price` FROM `orders` AS o ';
      query += 'INNER JOIN `orders_products` AS op ON o.`idOrder` = op.`idOrder` ';
      query += 'INNER JOIN `products` AS p ON p.`idProduct` = op.`idProduct` ';
      query += 'WHERE o.idTable = '+ table +' ORDER BY o.idOrder';

      con.query(query, function(err, products){
        // Se caso der erro, envio um 451 ORD-CONSULT-NOT
        if(err){
          console.log('451 ORD-CONSULT-NOT');
          socket.emit('451 ORD-CONSULT-NOT');
          return;
        }
        console.log(products);

        data.push(products);
        console.log('450 ORD-CONSULT-OK');
        socket.emit('450 ORD-CONSULT-OK', data);
      
      });
    });
  });


  //------------------------------//
  //----- Visualiza Pedido -------//
  //------------------------------//
  socket.on('600 ORD-SHOW', function(idOrder){
    var data = [];
    var query;
    query = 'SELECT o.*, p.`name`, p.`price` FROM `orders` AS o ';
    query += 'INNER JOIN `orders_products` AS op ON o.`idOrder` = op.`idOrder` ';
    query += 'INNER JOIN `products` AS p ON p.`idProduct` = op.`idProduct` ';
    query += 'WHERE o.idOrder ='+idOrder;
    // Mando a listagem de mesas para a página
    con.query(query ,function(err,row){
      // Se caso der erro, envio um 451 ORD-CONSULT-NOT
      if(err){
        console.log('651 ORD-SHOW-NOT');
        socket.emit('651 ORD-SHOW-NOT');
        return;
      }
      data.push(row);

      var query1 = 'SELECT SUM(p.price) AS total FROM `orders` AS o ';
      query1 += 'INNER JOIN `orders_products` AS op ON o.`idOrder` = op.`idOrder` ';
      query1 += 'INNER JOIN `products` AS p ON p.`idProduct` = op.`idProduct` ';
      query1 += 'WHERE o.idOrder ='+idOrder;
      con.query(query1 ,function(err,row1){
        // Se caso der erro, envio um 451 ORD-CONSULT-NOT
        if(err){
          console.log('651 ORD-SHOW-NOT');
          socket.emit('651 ORD-SHOW-NOT');
          return;
        }
        data.push(row1);
        console.log('650 ORD-SHOW-OK');
        socket.emit('650 ORD-SHOW-OK', data);
      }); // fimm da busca do total
    });
  });


  //------------------------------//
  //----- Visualiza Editar -------//
  //------------------------------//
  socket.on('800 ORD-EDIT-SHOW', function(idOrder){
    var data = [];
    var query;
    query = 'SELECT o.*, op.`idProduct` FROM `orders` AS o ';
    query += 'INNER JOIN `orders_products` AS op ON o.`idOrder` = op.`idOrder` ';
    query += 'WHERE o.idOrder ='+idOrder;
    // Mando a listagem de mesas para a página
    con.query(query ,function(err,row){
      // Se caso der erro, envio um 451 ORD-CONSULT-NOT
      if(err){
        console.log('851 ORD-EDIT-SHOW-NOT');
        socket.emit('851 ORD-EDIT-SHOW-NOT');
        return;
      }

      data.push(row);

      // Mando a listagem de produtos para a página
      con.query('SELECT * FROM products',function(err,products){

        // Se caso der erro, envio um 851 ORD-EDIT-SHOW-NOT
        if(err){
          console.log('851 ORD-EDIT-SHOW-NOT');
          socket.emit('851 ORD-EDIT-SHOW-NOT');
        }
        data.push(products);

        console.log('850 ORD-EDIT-SHOW-OK');
        socket.emit('850 ORD-EDIT-SHOW-OK', data);
      });

    });
  });

  //------------------------------//
  //-----  Edita de uma vez ------//
  //------------------------------//
  socket.on('801 ORD-EDIT', function(data){
    
    var idOrder = data[0];
    var orders_products = data[1];

    // deleto todos os produtos do pedido para adicionar os novos
    con.query(
      'DELETE FROM orders_products WHERE idOrder = ?',
      [idOrder],
      function (err, result2) {
        if (err){
          console.log('852 ORD-EDIT-NOT');
          socket.emit('852 ORD-EDIT-NOT');
          return;
        }else{

          // Adiciono os novos produtos no pedido
          for(var i=0; i<orders_products.length; i++){
            console.log('1200 ORD-PRODUCT');
            var order_product = { idProduct: orders_products[i], idOrder: idOrder };
            con.query('INSERT INTO orders_products SET ?', order_product, function(err,res2){

              if(err){
                console.log('1251 ORD-PRODUCT-NOT');
                socket.emit('1251 ORD-PRODUCT-NOT');
              }else{
                console.log('1250 ORD-PRODUCT-OK');
              }
            });
          }

          // Mando a listagem de pedidos
          con.query('SELECT * FROM orders WHERE idTable='+data[2] ,function(err,rows){
            var orders_data = [];
            orders_data.push(data[2]);
            // Se caso der erro, envio um 451 ORD-CONSULT-NOT
            if(err){
              console.log('451 ORD-CONSULT-NOT');
              socket.emit('451 ORD-CONSULT-NOT');
              return;
            }
            orders_data.push(rows);

            // mando todos os produtos dessa mesa
            var query;
            query = 'SELECT o.*, p.`name`, p.`price` FROM `orders` AS o ';
            query += 'INNER JOIN `orders_products` AS op ON o.`idOrder` = op.`idOrder` ';
            query += 'INNER JOIN `products` AS p ON p.`idProduct` = op.`idProduct` ';
            query += 'WHERE o.idTable = '+ data[2] +' ORDER BY o.idOrder';

            con.query(query, function(err, products){
              // Se caso der erro, envio um 451 ORD-CONSULT-NOT
              if(err){
                console.log('451 ORD-CONSULT-NOT');
                socket.emit('451 ORD-CONSULT-NOT');
                return;
              }

              orders_data.push(products);
              console.log('450 ORD-CONSULT-OK');
              io.in('orders'+data[2]).emit('450 ORD-CONSULT-OK', orders_data);
            });
          });

          console.log('850 ORD-EDIT-OK');
          socket.emit('850 ORD-EDIT-OK');

        }
      }
    );

  });

  //------------------------------//
  //------- Adiciona Pedido ------//
  //------------------------------//
  socket.on('300 ORD-CREATE', function(data){
    
    // Se não foi enviado nenhum produto, não adiciono e retorno o NOT
    if(data[1].length == 0){
      console.log('351 ORD-CREATE-NOT');
      socket.emit('351 ORD-CREATE-NOT');
      return;
    }

    // Atualizo a mesa para aberta !
    con.query(
      'UPDATE tables SET status = ? Where idTable = ?',
      ["A", data[0]],
      function (err, result) {
        if (err){
          console.log('1252 TBL-STATUS-NOT');
          socket.emit('1252 TBL-STATUS-NOT');
        }

        console.log('Changed ' + result.changedRows + ' rows');
        console.log('1253 TBL-STATUS-OK');

        socket.emit('1253 TBL-STATUS-OK');
      }
    );

    //insiro o pedido
    var order = { idTable: data[0]};
    con.query('INSERT INTO orders SET ?', order, function(err,res){

      if(err){
        console.log('351 ORD-CREATE-NOT');
        socket.emit('351 ORD-CREATE-NOT');
        return;
      }else{
        console.log('350 ORD-CREATE-OK');

        var order_id = res.insertId;
        // adiciono os produtos nos pedidos
        for(var i=0; i<data[1].length; i++){
          console.log('1200 ORD-PRODUCT');
          var order_product = { idProduct: data[1][i], idOrder: order_id };
          con.query('INSERT INTO orders_products SET ?', order_product, function(err,res2){

            if(err){
              console.log('1251 ORD-PRODUCT-NOT');
              socket.emit('1251 ORD-PRODUCT-NOT');
            }else{
              console.log('1250 ORD-PRODUCT-OK');
            }
          });
        }

        // Mando a listagem de mesas para todos que estão na listagem de mesas
        updateListTables();

        // Mando a listagem de mesas para a página
        con.query('SELECT * FROM orders WHERE idTable='+data[0] ,function(err,rows){
          var orders_list = [];

          orders_list.push(data[0]);
          // Se caso der erro, envio um 451 ORD-CONSULT-NOT
          if(err){
            console.log('451 ORD-CONSULT-NOT');
            io.in('orders'+data[0]).emit('451 ORD-CONSULT-NOT');
            return;
          }
          orders_list.push(rows);

          // mando todos os produtos dessa mesa
          var query;
          query = 'SELECT o.*, p.`name`, p.`price` FROM `orders` AS o ';
          query += 'INNER JOIN `orders_products` AS op ON o.`idOrder` = op.`idOrder` ';
          query += 'INNER JOIN `products` AS p ON p.`idProduct` = op.`idProduct` ';
          query += 'WHERE o.idTable = '+ data[0] +' ORDER BY o.idOrder';

          con.query(query, function(err, products){
            // Se caso der erro, envio um 451 ORD-CONSULT-NOT
            if(err){
              console.log('451 ORD-CONSULT-NOT');
              io.in('orders'+data[0]).emit('451 ORD-CONSULT-NOT');
              return;
            }

            orders_list.push(products);
            console.log('450 ORD-CONSULT-OK');
            io.in('orders'+data[0]).emit('450 ORD-CONSULT-OK', orders_list);
          
          });
        });


      }
    });

  });

  //------------------------------//
  //------- Deleta o Pedido ------//
  //------------------------------//
  socket.on('700 ORD-DELETE', function(data){
    // agora deleto o pedido
    con.query(
      'DELETE FROM orders WHERE idOrder = ?',
      [data[1]],
      function (err, result2) {
        if (err){
          console.log('751 ORD-DELETE-NOT');
          socket.emit('751 ORD-DELETE-NOT');
          return;
        }else{

          // Mando a listagem de mesas para a página
          con.query('SELECT * FROM orders WHERE idTable='+data[0] ,function(err,rows){
            var orders_list = [];

            orders_list.push(data[0]);
            // Se caso der erro, envio um 451 ORD-CONSULT-NOT
            if(err){
              console.log('451 ORD-CONSULT-NOT');
              io.in('orders'+data[0]).emit('451 ORD-CONSULT-NOT');
              return;
            }
            orders_list.push(rows);

            // mando todos os produtos dessa mesa
            var query;
            query = 'SELECT o.*, p.`name`, p.`price` FROM `orders` AS o ';
            query += 'INNER JOIN `orders_products` AS op ON o.`idOrder` = op.`idOrder` ';
            query += 'INNER JOIN `products` AS p ON p.`idProduct` = op.`idProduct` ';
            query += 'WHERE o.idTable = '+ data[0] +' ORDER BY o.idOrder';

            con.query(query, function(err, products){
              // Se caso der erro, envio um 451 ORD-CONSULT-NOT
              if(err){
                console.log('451 ORD-CONSULT-NOT');
                io.in('orders'+data[0]).emit('451 ORD-CONSULT-NOT');
                return;
              }

              orders_list.push(products);
              console.log('450 ORD-CONSULT-OK');
              io.in('orders'+data[0]).emit('450 ORD-CONSULT-OK', orders_list);
            
            });
          });

          // Se a quantidade de pedidos for 0, eu fecho a mesa
          verifyStatus(data[0]);

          console.log('750 ORD-DELETE-OK');
          socket.emit('750 ORD-DELETE-OK');
          console.log('Deleted ' + result2.affectedRows + ' rows');
        }

      }
    );
  });


  //------------------------------//
  //-- Transferencia de Pedidos --//
  //------------------------------//
  socket.on('500 ORD-TRANSFER', function(data){
    var table = data[0];
    var order = data[1];
    var old_table = data[2];
    con.query(
      'UPDATE orders SET idTable = ? Where idOrder = ?',
      [table, order],
      function (err, result) {
        if (err){
          console.log('551 ORD-TRANSFER-NOT');
          socket.emit('551 ORD-TRANSFER-NOT');
          return;
        }

        console.log('Changed ' + result.changedRows + ' rows');
        console.log('550 ORD-TRANSFER-OK');

        socket.emit('550 ORD-TRANSFER-OK');

        // Mando a listagem de pedidos
        con.query('SELECT * FROM orders WHERE idTable='+table ,function(err,rows){
          var orders_data = [];
          orders_data.push(table);
          // Se caso der erro, envio um 451 ORD-CONSULT-NOT
          if(err){
            console.log('451 ORD-CONSULT-NOT');
            socket.emit('451 ORD-CONSULT-NOT');
            return;
          }
          orders_data.push(rows);

          // mando todos os produtos dessa mesa
          var query;
          query = 'SELECT o.*, p.`name`, p.`price` FROM `orders` AS o ';
          query += 'INNER JOIN `orders_products` AS op ON o.`idOrder` = op.`idOrder` ';
          query += 'INNER JOIN `products` AS p ON p.`idProduct` = op.`idProduct` ';
          query += 'WHERE o.idTable = '+ table +' ORDER BY o.idOrder';

          con.query(query, function(err, products){
            // Se caso der erro, envio um 451 ORD-CONSULT-NOT
            if(err){
              console.log('451 ORD-CONSULT-NOT');
              socket.emit('451 ORD-CONSULT-NOT');
              return;
            }

            orders_data.push(products);
            console.log('450 ORD-CONSULT-OK');
            io.in('orders'+table).emit('450 ORD-CONSULT-OK', orders_data); 
          });

        });

        // Mando a listagem de pedidos
        con.query('SELECT * FROM orders WHERE idTable='+old_table ,function(err,rows){
          var orders_data = [];
          orders_data.push(old_table);
          // Se caso der erro, envio um 451 ORD-CONSULT-NOT
          if(err){
            console.log('451 ORD-CONSULT-NOT');
            socket.emit('451 ORD-CONSULT-NOT');
            return;
          }
          orders_data.push(rows);

          // mando todos os produtos dessa mesa
          var query;
          query = 'SELECT o.*, p.`name`, p.`price` FROM `orders` AS o ';
          query += 'INNER JOIN `orders_products` AS op ON o.`idOrder` = op.`idOrder` ';
          query += 'INNER JOIN `products` AS p ON p.`idProduct` = op.`idProduct` ';
          query += 'WHERE o.idTable = '+ old_table +' ORDER BY o.idOrder';

          con.query(query, function(err, products){
            // Se caso der erro, envio um 451 ORD-CONSULT-NOT
            if(err){
              console.log('451 ORD-CONSULT-NOT');
              socket.emit('451 ORD-CONSULT-NOT');
              return;
            }

            orders_data.push(products);
            console.log('450 ORD-CONSULT-OK');
            io.in('orders'+old_table).emit('450 ORD-CONSULT-OK', orders_data);
          });

        });

        verifyStatus(table);
        verifyStatus(old_table);


      }
    );

  });



  //------------------------------//
  //----- Fechamento de Conta ----//
  //------------------------------//
  socket.on('900 TBL-CLOSE', function(idTable){
    // deleto os pedidos da mesa primeiro
    con.query(
      'DELETE FROM orders WHERE idTable = ?',
      [idTable],
      function (err, result1) {
        if (err){
          console.log('951 TBL-CLOSE-NOT');
          socket.emit('951 TBL-CLOSE-NOT');
          return;
        }else{
          console.log('Deleted ' + result1.affectedRows + ' rows');

          // Devolvo a listagem de pedidos pra todo mundo que esta na de pedidos
          con.query('SELECT * FROM orders WHERE idTable='+idTable ,function(err,rows){

            var orders_list = [];
            orders_list.push(idTable);
            // Se caso der erro, envio um 451 ORD-CONSULT-NOT
            if(err){
              console.log('451 ORD-CONSULT-NOT');
              io.in('orders'+idTable).emit('451 ORD-CONSULT-NOT');
            }

            orders_list.push(rows);
            console.log('450 ORD-CONSULT-OK');
            io.in('orders'+idTable).emit('450 ORD-CONSULT-OK', orders_list);
          });

          // Se a quantidade de pedidos for 0, eu fecho a mesa
          con.query('SELECT COUNT(*) AS count FROM orders WHERE idTable = '+idTable,function(err,result3){
            if(result3[0].count == 0){
              // Atualizo a mesa para fechada !
              con.query(
                'UPDATE tables SET status = ? Where idTable = ?',
                ["F", idTable],
                function (err, result) {
                  if (err){
                    console.log('1252 TBL-STATUS-NOT');
                    socket.emit('1252 TBL-STATUS-NOT');
                    return;
                  }

                  console.log('Changed ' + result.changedRows + ' rows');
                  console.log('1253 TBL-STATUS-OK');

                  socket.emit('1253 TBL-STATUS-OK');

                  // Mando a listagem de mesas para todos que estão na listagem de mesas
                  updateListTables();

                }
              );
            }
          });

          console.log('950 TBL-CLOSE-OK');
          socket.emit('950 TBL-CLOSE-OK');
          console.log('Deleted ' + result1.affectedRows + ' rows');

        } // fim else
      }
    );
  });


});