This commit is contained in:
parent
0054f2d82f
commit
251ed36eca
|
@ -179,7 +179,6 @@ module.exports = Self => {
|
||||||
|
|
||||||
const workerTimeControlConfig = await models.WorkerTimeControlConfig.findOne(null, myOptions);
|
const workerTimeControlConfig = await models.WorkerTimeControlConfig.findOne(null, myOptions);
|
||||||
|
|
||||||
console.log(days[index]);
|
|
||||||
for (let day of days[index]) {
|
for (let day of days[index]) {
|
||||||
if (!myOptions.transaction) {
|
if (!myOptions.transaction) {
|
||||||
tx = await Self.beginTransaction({});
|
tx = await Self.beginTransaction({});
|
||||||
|
@ -374,22 +373,18 @@ module.exports = Self => {
|
||||||
delete myOptions.transaction;
|
delete myOptions.transaction;
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
if (tx) await tx.rollback();
|
|
||||||
delete myOptions.transaction;
|
|
||||||
|
|
||||||
const stmts = [];
|
const stmts = [];
|
||||||
let stmt;
|
let stmt;
|
||||||
stmt = new ParameterizedSQL(`
|
stmt = new ParameterizedSQL(`
|
||||||
INSERT INTO mail (receiver, subject, body)
|
INSERT INTO mail (receiver, subject, body)
|
||||||
SELECT CONCAT(u.name, '@verdnatura.es'),
|
SELECT CONCAT(u.name, '@verdnatura.es'),
|
||||||
CONCAT('Error registro de horas semana ', ?, ' año ', ?) ,
|
CONCAT('Error registro de horas semana ', ?, ' año ', ?) ,
|
||||||
CONCAT('No se ha podido enviar el registro de horas al empleado/s: ',
|
CONCAT('No se ha podido enviar el registro de horas al empleado: ',
|
||||||
GROUP_CONCAT(DISTINCT CONCAT('<br>', w.id, ' ', w.firstName, ' ', w.lastName)))
|
w.id, ' ', w.firstName, ' ', w.lastName, ' por el motivo: ', ?)
|
||||||
FROM worker w
|
FROM worker w
|
||||||
JOIN account.user u ON u.id = w.bossFk
|
JOIN account.user u ON u.id = w.bossFk
|
||||||
WHERE w.id = ?
|
WHERE w.id = ?
|
||||||
GROUP BY w.bossFk
|
`, [args.week, args.year, e.message, day.workerFk]);
|
||||||
`, [args.week, args.year, day.workerFk]);
|
|
||||||
stmts.push(stmt);
|
stmts.push(stmt);
|
||||||
|
|
||||||
const sql = ParameterizedSQL.join(stmts, ';');
|
const sql = ParameterizedSQL.join(stmts, ';');
|
||||||
|
@ -398,6 +393,9 @@ module.exports = Self => {
|
||||||
previousWorkerFk = day.workerFk;
|
previousWorkerFk = day.workerFk;
|
||||||
previousReceiver = day.receiver;
|
previousReceiver = day.receiver;
|
||||||
|
|
||||||
|
if (tx) await tx.rollback();
|
||||||
|
delete myOptions.transaction;
|
||||||
|
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue