Untitled


var express = require('express')
var app = express()
var bodyParser = require('body-parser')
var core_use = require('cors');
var pg = require('pg');

app.use(core_use());
app.use(bodyParser.urlencoded({ extended: false }))
app.use(bodyParser.json())

var config = {
  user: 'gmello', //env var: PGUSER
  database: 'HOME_HELPER', //env var: PGDATABASE
  password: '123456', //env var: PGPASSWORD
  port: 5432, //env var: PGPORT
  max: 10, // max number of clients in the pool
  idleTimeoutMillis: 30000, // how long a client is allowed to remain idle before being closed
};

var pool = new pg.Pool(config);

//--------------------------------------------------CATEGORIAS----------------------------------------------------//
// rota com protocolo GET para seleção no banco de dados
app.get('/consultaCategoria', function (req, res) {

  pool.connect(function(err, client, done) {
    if(err) {
    return console.error('error fetching client from pool', err);
    }
    client.query('SELECT * FROM tb_categorias order by id_categoria', function(err, result) {
    done();

    if(err) {
      return console.error('error running query', err);
    }
    res.setHeader('Access-Control-Allow-Origin','*');
    console.log(result.rows);
    res.json(result.rows);
    });
  });
});


// rota com protocolo POST para inserção no banco de dados
app.post('/insereCategoria', function (req, res) {

     var descricao = req.body.descricao;
     var tipo = req.body.tipo;
     var id_categoria = req.body.id_categoria

    pool.connect(function(err, client, done) {
      if(err) {
        return console.error('error fetching client from pool', err);
      }
      client.query("insert into tb_categorias (id_categoria, descricao, tipo) values ($1, $2, $3 )", [id_categoria, descricao, tipo], function(err, result) {
        //call `done()` to release the client back to the pool
        done();

        if(err) {
          console.log('Descricao da categoria' + req.body.descricao);
          console.log('Descricao da categoria' + req.body.tipo);
          return console.error('error running query', err);
        }

	res.send("Categoria Inserida com sucesso");
      });
    });
});

// rota com protocolo DELETE para remoção no banco de dados
app.delete('/removeCategoria/:id_categoria', function (req, res) {

  var id_categoria = req.params.id_categoria
    pool.connect(function(err, client, done) {
      if(err) {
        return console.error('error fetching client from pool', err);
      }
      client.query('delete from td_categorias where id_categoria = ' +
      id_categoria, function(err, result) {
        //call `done()` to release the client back to the pool
        done();

        if(err) {
          return console.error('error running query', err);
        }

        res.setHeader('Access-Control-Allow-Origin','*');
        res.json(result.rows); // servidor retorna a consulta em formato json
      });
    });
});

// rota com protocolo PUT para atualização no banco de dados
app.put('/atualizaCategorias', function (req, res) {

  pool.connect(function(err, client, done) {
    if(err) {
      return console.error('error fetching client from pool', err);
    }
    client.query('update td_categorias set id_categoria = ' +
      req.body.id_categoria + '\', descricao = ' + req.body.tipo +
      ' where id_categoria = '+
      req.body.id_categoria , function(err, result) {
      //call `done()` to release the client back to the pool
      done();

      if(err) {
        return console.error('error running query', err);
      }
      res.setHeader('Access-Control-Allow-Origin','*');
      res.json(result.rows); // servidor retorna a consulta em formato json
    });
  });
});
//-------------------------------------------------- FIM - CATEGORIAS----------------------------------------------------//


//--------------------------------------------------CONTROLE SUPRIMENTOS-----------------------------------------//

// rota com protocolo GET para seleção no banco de dados
app.get('/consultaSup', function (req, res) {

    pool.connect(function(err, client, done) {
      if(err) {
      return console.error('error fetching client from pool', err);
      }
       client.query('SELECT s.id_suprimento, s.descricao, c.descricao, s.quantidade, s.qnt_mensal, s.valor_unit FROM tb_controle_suprimentos s, tb_categorias c WHERE s.id_categoria = c.id_categoria ORDER BY s.id_suprimento;', function(err, result) {
      //call `done()` to release the client back to the pool
      done();
      if(err) {
        return console.error('error running query', err);
      }
      res.setHeader('Access-Control-Allow-Origin','*');
      console.log(result.rows);
      res.json(result.rows); // servidor retorna a consulta em formato json

      });
    });
});

// rota com protocolo POST para inserção no banco de dados
app.post('/insereSup', function (req, res) {

    pool.connect(function(err, client, done) {
      if(err) {
        return console.error('error fetching client from pool', err);
      }
      client.query('INSERT INTO tb_controle_suprimentos(id_suprimento,id_usuario, id_unidade, descricao, id_categoria, quantidade, qnt_mensal, valor_unit) values (' + req.body.id_suprimento +
        ', '+ req.body.id_unidade +',' + req.body.descricao + ', \' '+ req.body.id_categoria +',' + req.body.quantidade + ','+ req.body.qnt_mensal +', '+ req.body.valor_unit +')', function(err, result) {
        //call `done()` to release the client back to the pool
        done();

        if(err) {
          return console.error('error running query', err);
        }

        res.setHeader('Access-Control-Allow-Origin','*');
        res.json(result.rows); // servidor retorna a consulta em formato json
      });
    });
});

// rota com protocolo DELETE para remoção no banco de dados
app.delete('/removeSup/:id_suprimento', function (req, res) {

  var id_suprimento = req.params.id_suprimento
    pool.connect(function(err, client, done) {
      if(err) {
        return console.error('error fetching client from pool', err);
      }
      client.query('delete from tb_controle_suprimentos where id_suprimento = ' +
      id_suprimento, function(err, result) {
        //call `done()` to release the client back to the pool
        done();

        if(err) {
          return console.error('error running query', err);
        }

        res.setHeader('Access-Control-Allow-Origin','*');
        res.json(result.rows); // servidor retorna a consulta em formato json
      });
    });
});

// rota com protocolo PUT para atualização no banco de dados
app.put('/atualizaSup', function (req, res) {

  pool.connect(function(err, client, done) {
    if(err) {
      return console.error('error fetching client from pool', err);
    }
    client.query('update tb_controle_suprimentos set descricao = \'' +
            req.body.descricao + '\', categoria =' + req.body.categoria + ', quantidade =  ' + req.body.quantidade +
            ', quant_mensal = '+ req.body.quant_mensal + ',' + req.body.valor_unit + ', \'' + req.body.valor_total +
            'where id_suprimento = ' + req.body.id_compras , function(err, result) {
      //call `done()` to release the client back to the pool
      done();

      if(err) {
        return console.error('error running query', err);
      }
      res.setHeader('Access-Control-Allow-Origin','*');
      res.json(result.rows); // servidor retorna a consulta em formato json
    });
  });
});

//--------------------------------------------------fIM - CONTROLE SUPRIMENTOS-----------------------------------------//


//--------------------------------------------------CONTROLE ENERGIA-----------------------------------------//

// rota com protocolo GET para seleção no banco de dados
app.get('/consultaEnergia', function (req, res) {

    pool.connect(function(err, client, done) {
      if(err) {
      return console.error('error fetching client from pool', err);
      }
       client.query('SELECT M.DESCRICAO, A.ANO, E.TARIFA, E.CONSUMO, E.VALOR_CONTA FROM tb_controle_energia e INNER JOIN TB_MES m ON (e.ID_MES = m.ID_MES) INNER JOIN TB_ANO a ON (e.ID_ANO = a.ID_ANO);', function(err, result) {
      //call `done()` to release the client back to the pool
      done();
      if(err) {
        return console.error('error running query', err);
      }
      res.setHeader('Access-Control-Allow-Origin','*');
      console.log(result.rows);
      res.json(result.rows); // servidor retorna a consulta em formato json

      });
    });
});

// rota com protocolo POST para inserção no banco de dados
app.post('/insereEnergia', function (req, res) {

    pool.connect(function(err, client, done) {
      if(err) {
        return console.error('error fetching client from pool', err);
      }
      client.query('INSERT INTO tb_controle_energia(id_mes, id_ano, id_usuario, tarifa, consumo, valor_conta) values (' + req.body.id_mes + ', '+ req.body.id_ano + ', '+ req.body.id_usuario + ', ' + req.body.tarifa + ', ' + req.body.consumo + ', ' + req.body.valor_conta + ')', function(err, result) {
        //call `done()` to release the client back to the pool
        done();

        if(err) {
          return console.error('error running query', err);
        }

        res.setHeader('Access-Control-Allow-Origin','*');
        res.json(result.rows); // servidor retorna a consulta em formato json
      });
    });
});

// rota com protocolo DELETE para remoção no banco de dados
app.delete('/removeEnergia/:id_mes', function (req, res) {

  var id_suprimento = req.params.id_suprimento
    pool.connect(function(err, client, done) {
      if(err) {
        return console.error('error fetching client from pool', err);
      }
      client.query('delete from tb_controle_energia where id_mes = ' +
      id_mes, function(err, result) {
        //call `done()` to release the client back to the pool
        done();

        if(err) {
          return console.error('error running query', err);
        }

        res.setHeader('Access-Control-Allow-Origin','*');
        res.json(result.rows); // servidor retorna a consulta em formato json
      });
    });
});

// rota com protocolo PUT para atualização no banco de dados
app.put('/atualizaEnergia', function (req, res) {

  pool.connect(function(err, client, done) {
    if(err) {
      return console.error('error fetching client from pool', err);
    }
    client.query('update tb_controle_energia set id_mes = \'' +
            req.body.id_mes + '\', id_ano =' + req.body.id_ano + ', tarifa =  ' + req.body.tarifa +
            ', consumo = '+ req.body.consumo + ',' + req.body.valor_conta +
            'where id_mes = ' + req.body.id_mes , function(err, result) {
      //call `done()` to release the client back to the pool
      done();

      if(err) {
        return console.error('error running query', err);
      }
      res.setHeader('Access-Control-Allow-Origin','*');
      res.json(result.rows); // servidor retorna a consulta em formato json
    });
  });
});

//--------------------------------------------------FIM - CONTROLE ENERGIA-----------------------------------------//


app.listen(3000);