99 lines
2.7 KiB
JavaScript
99 lines
2.7 KiB
JavaScript
require('./config');
|
|
const mariadb = require('mariadb');
|
|
|
|
const pool = mariadb.createPool({
|
|
host: process.env.HOST_DB,
|
|
user: process.env.USER_DB,
|
|
password: process.env.PASSWORD_DB,
|
|
database: process.env.SAT_DB,
|
|
});
|
|
|
|
const obtenerDatosUsr = async (numeroCuenta) => {
|
|
const conn = await pool.getConnection().catch((err) => {
|
|
throw new Error('No se pudo conectar con la db. ' + err);
|
|
});
|
|
|
|
return conn
|
|
.query(
|
|
`SELECT id_carrera, generacion FROM alumno WHERE id_cuenta = ${numeroCuenta}`
|
|
)
|
|
.then((rows) => {
|
|
conn.end();
|
|
return rows[0];
|
|
})
|
|
.catch((err) => {
|
|
conn.end();
|
|
throw new Error('Hubo un problema con el querry.' + err);
|
|
});
|
|
};
|
|
|
|
// Agregue para profesores
|
|
const buscarProfesorPorNumero = async (numeroTrabajador) => {
|
|
//console.log("Buscando profesor con numeroCuenta:", numeroTrabajador);
|
|
|
|
const conn = await pool.getConnection().catch((err) => {
|
|
throw new Error('No se pudo conectar con la base de datos. ' + err);
|
|
});
|
|
|
|
return conn
|
|
.query(
|
|
`SELECT nombre, id_cuenta FROM alumno WHERE id_cuenta = ?`,
|
|
[numeroTrabajador] // NUmero de cuenta
|
|
)
|
|
.then((rows) => {
|
|
console.log(numeroTrabajador)
|
|
conn.end();
|
|
if (rows.length === 0) return null;
|
|
//console.log('Resultado de la consulta:', rows); // <--- Aquí
|
|
return rows[0]; // { nombre: 'Juan', rfc: 'JUAP123' }
|
|
})
|
|
.catch((err) => {
|
|
conn.end();
|
|
throw new Error('Error al buscar el profesor: ' + err);
|
|
});
|
|
};
|
|
|
|
const validarAlumnoInscrito = async (idCuenta) => {
|
|
console.log("Validando alumno inscrito con id_cuenta:", idCuenta);
|
|
|
|
const conn = await pool.getConnection().catch((err) => {
|
|
throw new Error('No se pudo conectar con la base de datos. ' + err);
|
|
});
|
|
|
|
return conn
|
|
.query(
|
|
`SELECT * FROM alumno_inscrito WHERE id_cuenta = ? AND id_periodo = 27`,
|
|
[idCuenta]
|
|
)
|
|
.then((rows) => {
|
|
//console.log('Resultado de la consulta alumno_inscrito:', rows);
|
|
|
|
conn.end();
|
|
if (rows.length === 0) return null;
|
|
return rows[0]; // Devuelve el primer registro encontrado
|
|
})
|
|
.catch((err) => {
|
|
conn.end();
|
|
throw new Error('Error al validar alumno inscrito: ' + err);
|
|
});
|
|
};
|
|
|
|
|
|
// Para envios de correos
|
|
const nodemailer = require('nodemailer');
|
|
|
|
const enviarCorreoInscripcion = async (destinatario, nombreProfesor) => {
|
|
const transporter = nodemailer.createTransport({
|
|
service: 'gmail', // o smtp host como 'smtp.mailtrap.io'
|
|
auth: {
|
|
type: 'OAuth2',
|
|
user: process.env.CORREO_ORIGEN,
|
|
clientId: process.env.CLIENT_ID,
|
|
clientSecret: process.env.CLIENT_SECRET,
|
|
refreshToken: process.env.REFRESH_TOKEN,
|
|
},
|
|
});
|
|
};
|
|
|
|
module.exports = { buscarProfesorPorNumero, validarAlumnoInscrito };
|