Patriots01
124 lines
3.3 KiB
JavaScript
124 lines
3.3 KiB
JavaScript
require('./config');
|
|
const mariadb = require('mariadb');
|
|
const nodemailer = require('nodemailer');
|
|
|
|
const pool = mariadb.createPool({
|
|
host: process.env.HOST_DB,
|
|
user: process.env.USER_DB,
|
|
password: process.env.PASSWORD_DB,
|
|
database: process.env.SAT_DB,
|
|
connectionLimit: 5,
|
|
acquireTimeout: 60000,
|
|
timeout: 60000,
|
|
});
|
|
|
|
const obtenerDatosUsr = async (numeroCuenta) => {
|
|
let conn;
|
|
try {
|
|
conn = await pool.getConnection();
|
|
const rows = await conn.query(
|
|
`SELECT id_carrera, generacion FROM alumno WHERE id_cuenta = ${numeroCuenta}`
|
|
);
|
|
return rows[0];
|
|
} catch (err) {
|
|
throw new Error('Hubo un problema con el querry.' + err);
|
|
} finally {
|
|
if (conn) conn.end();
|
|
}
|
|
};
|
|
|
|
const buscarProfesorPorNumero = async (numeroTrabajador) => {
|
|
let conn;
|
|
try {
|
|
conn = await pool.getConnection();
|
|
const rows = await conn.query(
|
|
`SELECT nombre, id_cuenta FROM alumno WHERE id_cuenta = ?`,
|
|
[numeroTrabajador]
|
|
);
|
|
|
|
console.log('Este es la info que trae:', rows);
|
|
|
|
console.log(numeroTrabajador);
|
|
if (rows.length === 0) return null;
|
|
return rows[0];
|
|
} catch (err) {
|
|
throw new Error('Error al buscar el profesor: ' + err);
|
|
} finally {
|
|
if (conn) conn.end();
|
|
}
|
|
};
|
|
|
|
const validarPeriodoActivo = async (conn) => {
|
|
return conn
|
|
.query(`SELECT id_periodo FROM periodo WHERE activo = '1' LIMIT 1`)
|
|
.then((rows) => {
|
|
if (!rows || rows.length === 0) {
|
|
console.log('No existe');
|
|
throw new Error('No existe un periodo activo en el sistema');
|
|
}
|
|
console.log('Periodo: ', rows)
|
|
return rows;
|
|
})
|
|
.catch((err) => {
|
|
throw new Error('Error al validar periodo activo: ' + err);
|
|
});
|
|
};
|
|
|
|
const validarAlumnoInscrito = async (idCuenta) => {
|
|
console.log('Validando alumno inscrito con id_cuenta:', idCuenta);
|
|
|
|
const idLimpio = parseInt(idCuenta, 10);
|
|
|
|
if (idLimpio.toString().length > 6) {
|
|
throw new Error('Error: el número de trabajador no existe');
|
|
}
|
|
|
|
let conn;
|
|
try {
|
|
conn = await pool.getConnection();
|
|
const idPeriodoActivo = await validarPeriodoActivo(conn);
|
|
|
|
console.log('id del periodo: ', idPeriodoActivo[0]);
|
|
|
|
const rows = await conn.query(
|
|
`SELECT * FROM alumno_inscrito WHERE id_cuenta = ? AND id_periodo = ?`,
|
|
[idCuenta, idPeriodoActivo[0].id_periodo]
|
|
);
|
|
// const [rows] = await conn.query(
|
|
// `SELECT * FROM alumno_inscrito WHERE id_cuenta = 000031231 AND id_periodo = 43`
|
|
// );
|
|
console.log("rows:", rows);
|
|
console.log("Tipo:", typeof rows);
|
|
console.log("Es arreglo:", Array.isArray(rows));
|
|
|
|
console.log('Esto es dentro de validar alumno inscrito', rows);
|
|
console.log(rows.length)
|
|
|
|
|
|
if (rows.length > 0) {
|
|
return ("El alumno ya se encuentra inscrito en el período actual.");
|
|
}
|
|
|
|
return rows[0];
|
|
} catch (error) {
|
|
throw new Error(`Error al validar alumno inscrito: ${error.message}`);
|
|
} finally {
|
|
if (conn) conn.end();
|
|
}
|
|
};
|
|
|
|
const enviarCorreoInscripcion = async (destinatario, nombreProfesor) => {
|
|
const transporter = nodemailer.createTransport({
|
|
service: 'gmail',
|
|
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 };
|