app.js

const express = require('express');
const { pool, getProductoras, getFloristerias, getCatalogoProductoraById, getDetalleFlores,getFloresValoraciones,getInformacionFlor,getFacturas, getFlorCortes, getContratosProductora } = require('./db');
const path = require('path');

const app = express();

// Configurar el motor de plantillas EJS (si es necesario)
app.set('view engine', 'ejs');
app.set('views', path.join(__dirname, 'view'));

// Servir archivos estáticos desde la carpeta 'view'
app.use(express.static(path.join(__dirname, 'view')));

app.get('/test', async (req, res) => {
  try {
    const result = await pool.query('SELECT NOW()');
    res.json(result.rows);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).send('Error querying the database');
  }
});

// Ruta para servir el archivo HTML principal
app.get('/', (req, res) => {
  res.sendFile(path.join(__dirname, 'view', 'index.html'));
});

// Nueva ruta para obtener datos de las productoras
app.get('/api/productoras', async (req, res) => {
  try {
    const productoras = await getProductoras();
    
    res.json(productoras);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).json({ error: 'Error querying the database' });
  }
});

app.get('/api/catalogoProductor/:id', async (req, res) => {
  const { id } = req.params;
  try {
    const catalogoProductor = await getCatalogoProductoraById(id);
    res.json(catalogoProductor);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).json({ error: 'Error querying the database' });
  }
});

app.get('/api/detalleFlores/:florId/:productorId', async (req, res) => {
  const { florId,productorId } = req.params;
  try {
    const detalleFlores = await getDetalleFlores(florId,productorId);
    res.json(detalleFlores);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).json({ error: 'Error querying the database' });
  }
});



// Nueva ruta para obtener datos de las floristerias
app.get('/api/floristerias', async (req, res) => {
  try {
    const floristerias = await getFloristerias();
    res.json(floristerias);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).json({ error: 'Error querying the database' });
  }
});

app.get('/api/floresValoraciones/:idFloristeria', async (req, res) => {
  const { idFloristeria } = req.params;
  try {
    console.log(`Fetching flores con valoraciones for floristeria ID: ${idFloristeria}`);
    const flores = await getFloresValoraciones(idFloristeria);
    
    res.json(flores);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).json({ error: 'Error querying the database' });
  }
});

app.get('/api/informacionFlor/:idFloristeria/:idFlor', async (req, res) => {
  const { idFloristeria, idFlor } = req.params;
  try {
    const informacionFlor = await getInformacionFlor(idFloristeria, idFlor);
    res.json(informacionFlor);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).json({ error: 'Error querying the database' });
  }
});

app.get('/api/facturas', async (req, res) => {
  try {
    const facturas = await getFacturas();
    res.json(facturas);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).json({ error: 'Error querying the database' });
  }
});

app.get('/api/florCortes', async (req, res) => {
  try {
    console.log('Received request to get flor cortes');
    const florCortes = await getFlorCortes();
    res.json(florCortes);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).json({ error: 'Error querying the database' });
  }
});

app.get('/api/coloresDeCorte/:corteId', async (req, res) => {
  const { corteId } = req.params;
  try {
    const result = await pool.query('SELECT colores FROM FLOR_CORTES WHERE corteId = $1', [corteId]);
    if (result.rows.length === 0) {
      return res.status(404).json({ error: 'Corte no encontrado' });
    }
    const colores = result.rows[0].colores.split(',').map(color => color.trim());
    res.json(colores);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).json({ error: 'Error querying the database' });
  }
});

app.get('/api/coloresDeCortePorNombre/:nombre', async (req, res) => {
  const { nombre } = req.params;
  try {
    const result = await pool.query('SELECT colores FROM FLOR_CORTES WHERE LOWER(nombrecomun) = LOWER($1)', [nombre]);
    if (result.rows.length === 0) {
      return res.status(404).json({ error: 'Corte no encontrado' });
    }
    const colores = result.rows[0].colores.split(',').map(color => color.trim());
    res.json(colores);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).json({ error: 'Error querying the database' });
  }
});

app.get('/api/obtener-contratos-productora', async (req, res) => {
  const { productoraId } = req.query;
  if (!productoraId) {
    return res.status(400).json({ error: 'productoraId is required' });
  }

  try {
    const contratos = await getContratosProductora(productoraId);
    res.json(contratos);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).json({ error: 'Error querying the database' });
  }
});

app.get('/api/informacionFactura/:facturaId', async (req, res) => {
  const { facturaId } = req.params;
  try {
    const result = await pool.query('SELECT * FROM obtener_informacion_factura($1)', [facturaId]);
    const facturaInfo = result.rows[0];

    const lotesResult = await pool.query('SELECT * FROM traer_lotes($1)', [facturaId]);
    facturaInfo.lotes = lotesResult.rows;

    res.json(facturaInfo);
  } catch (err) {
    console.error('Error querying the database:', err);
    res.status(500).json({ error: 'Error querying the database' });
  }
});

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`Server is running on port ${PORT}`);
  console.log(`Click here to open: http://localhost:${PORT}`);
});