const controlador = {};
const fs = require('fs');

controlador.verItemsJson = (req, res) => {
  req.getConnection((err, conn) => {
    conn.query('SELECT * FROM productos order by codigo_prdcto DESC  LIMIT 100', (err, rows) => {//se obtiene error o consulta filas(rows)
    //conn.query('SELECT * FROM clientes LIMIT 62668,15', (err, rows) => {//se obtiene error o consulta filas(rows)
      if(err){
        res.json(err);
        //next(err);
      }
      //console.log(rows);
      res.json(rows);
      //res.render('clientesV',{       data:rows      });
    });
  });
};

controlador.verItemsJsonApp = (req, res) => {
  req.getConnection((err, conn) => {
    conn.query('SELECT codigo_prdcto, detalle_prdcto, describe_prdcto FROM productos order by codigo_prdcto DESC', (err, rows) => {//se obtiene error o consulta filas(rows)
    //conn.query('SELECT * FROM clientes LIMIT 62668,15', (err, rows) => {//se obtiene error o consulta filas(rows)
      if(err){
        res.json(err);
        //next(err);
      }
      //console.log(rows);
      //var test = {"Items":[{"idt_prdcto":"1","codigo_prdcto":"CODIGOTEST","detalle_prdcto":"ITEM GENERADO","describe_prdcto":"DESCRIPCION DE ITEMS"}]};
      var itemsD = {Items:rows};
      res.json(itemsD);
      //res.render('clientesV',{       data:rows      });
    });
  });
};

controlador.verItemPanel = (req, res) => {
  req.getConnection((err, conn) => {
    conn.query('SELECT codigo_prdcto, detalle_prdcto, describe_prdcto FROM productos order by codigo_prdcto DESC', (err, rows) => {//se obtiene error o consulta filas(rows)
    //conn.query('SELECT * FROM clientes LIMIT 62668,15', (err, rows) => {//se obtiene error o consulta filas(rows)
      if(err){
        res.json(err);
        //next(err);
      }
      //console.log(rows);
      //var test = {"Items":[{"idt_prdcto":"1","codigo_prdcto":"CODIGOTEST","detalle_prdcto":"ITEM GENERADO","describe_prdcto":"DESCRIPCION DE ITEMS"}]};
      var itemsD = {Items:rows};
      res.json(itemsD);
      //res.render('clientesV',{       data:rows      });
    });
  });
};

controlador.verInventarioJsonApp = (req, res) => {
  req.getConnection((err, conn) => {
    conn.query('SELECT codigo_prdcto, detalle_prdcto, describe_prdcto, idcostos_valores FROM ver_productosPrecios', (err, rows) => {//se obtiene error o consulta filas(rows)
    //conn.query('SELECT * FROM clientes LIMIT 62668,15', (err, rows) => {//se obtiene error o consulta filas(rows)
      if(err){
        res.json(err);
        //next(err);
      }
      //console.log(rows);
      //var test = {"Items":[{"idt_prdcto":"1","codigo_prdcto":"CODIGOTEST","detalle_prdcto":"ITEM GENERADO","describe_prdcto":"DESCRIPCION DE ITEMS"}]};
      var itemsD = {Items:rows};
      res.json(itemsD);
      //res.render('clientesV',{       data:rows      });
    });
  });
};

//********* CONSULTA ITEMS modo like ********//
controlador.autocompletado_itemsJson = (req,res) => {
  console.log(req.params);
  const datBuscar = req.params.dat_busq;
  req.getConnection((err, conn) => {
    //console.log(datBuscar);
    conn.query("SELECT detalle_prdcto,describe_prdcto FROM productos WHERE detalle_prdcto like '%"+datBuscar+"%'",(err,rows)=>{
      res.json(rows);
    });
  });
};

//********* CONSULTA ITEMS ********//
controlador.verItemJson = (req,res) => {
  console.log(req.params);
  const codItem = req.params.codigo_item;
  req.getConnection((err, conn) => {
    conn.query('SELECT * FROM productos WHERE codigo_prdcto = ?',[codItem],(err,rows)=>{
      res.json(rows);
      //res.render('clientesV',{    data:rows     });
    });
  });
};
controlador.verItemJsonPost = (req,res) => {
  const {codigo_prdcto} = req.params;
  const codigo_prdctoB = req.body;
  console.log(codigo_prdcto);
  res.send('working...');
  /*req.getConnection((err, conn) => {
    conn.query('SELECT * FROM productos WHERE codigo_prdcto = ?',[codItem],(err,rows)=>{
      //res.json(rows);
      res.send('working...');
    });
  });*/
};
//********* INGRESO ITEMS ********//
controlador.guardaItem = (req, res) => {
  //console.log(req.body);
  const data = req.body;
  console.log(data.item);
  let json = JSON.parse(data.item);
  console.log(json.Items);
  req.getConnection((err,conn)=>{
    /*conn.query('INSERT INTO productos set ?',[data],(err,rows)=>{
      if(err){
        res.json(err);
      }else{
        res.json("ok");
      }
    console.log(rows);
    //res.send('working...');
    res.redirect('/');//redireciona a la ruta inical de la app
  });*/
  //set ? => data
  });
  res.json("'resp':'ok'");
  //res.send('working...');
};

controlador.guardarItems = (req, res) => {
  const data = req.body;
  //console.log(req);
  //console.log(data);
  let json = JSON.parse(data.json_item);
  //let json = parse.Items;
  //console.log(json.length);
  for(var i=0;i<json.length;i++){
    var item = json[i];
    //console.log(item);

    req.getConnection((err,conn)=>{
      conn.query('INSERT INTO productos_cloud set ?',[item],(err,rows)=>{
          console.log(item);
        });//set ? => data
    });
  }
  res.json("'resp':'ok'");
  };

controlador.json = (req, res) => {
  res.render('api_json',{

  })
}

//********* CONSULTA ITEMS APP-SIGMA********//
controlador.app_consultaItemsPrecios = (req,res) => {
  const data = req.query;
  const item = "%"+req.query.consulta+"%";
  const grupo = req.query.gp_precio;
  //let data =  req.stringify;
  console.log(req.body);
  console.log(req.query);

  //const codItem = req.params.consulta;
  req.getConnection((err, conn) => {
    //codigo_prdcto
    //conn.query('SELECT codigo_prdcto,detalle_prdcto,describe_prdcto FROM productos WHERE detalle_prdcto like  ? or describe_prdcto like ?',[item,item],(err,rows)=>{
    conn.query(`SELECT
      codigo as codigo_prdcto,
      nombre as detalle_prdcto,
      descripcion as describe_prdcto,
      precio,
      img as imagen
      FROM ver_inventario_precios_app
      where grupo_precio = ? and (nombre like ? or descripcion like ?)`
      ,[grupo,item,item],(err,rows)=>{
      //res.json(rows);
      //if(err) return res.status(500).send("Error en Consulta de Items");
      rows.map(
        dat => {
          //console.log(blob_a_b64(dat.imagen));
          dat.imagen = blob_a_b64(dat.imagen);
          //fs.writeFileSync(path.join(__dirname,"../img/db_img"+image.codigo_prdcto+".png"),image.imagen);
        }
      )
      res.json(rows);
      console.log(err);
      //res.render('clientesV',{    data:rows     });
    });
  });
};

function blob_a_b64(blob) {
  var b64;
  if(blob!=null){
    b64 = blob.toString('base64');
  }else{
    b64="";
  }
  return b64;
}

//********* CONSULTA ADICIONALES X MODIFICAR ********//
controlador.cierresCaja = (req, res) => {
  req.getConnection((err, conn) => {
    conn.query('SELECT * FROM cont_cierreCaja', (err, rows) => {//se obtiene error o consulta filas(rows)
    //conn.query('SELECT * FROM clientes LIMIT 62668,15', (err, rows) => {//se obtiene error o consulta filas(rows)
      if(err){
        res.json(err);
        //next(err);
      }
      //console.log(rows);
      //var test = {"Items":[{"idt_prdcto":"1","codigo_prdcto":"CODIGOTEST","detalle_prdcto":"ITEM GENERADO","describe_prdcto":"DESCRIPCION DE ITEMS"}]};
      var itemsD = {CierreCaja:rows};
      res.json(itemsD);
      //res.render('clientesV',{       data:rows      });
    });
  });
};

module.exports = controlador;