Merge pull request 'hotFix: workerTimeControl' (!1796) from hotFix_workeTimeControl_sendMail into master
gitea/salix/pipeline/head This commit looks good
Details
gitea/salix/pipeline/head This commit looks good
Details
Reviewed-on: #1796 Reviewed-by: Javi Gallego <jgallego@verdnatura.es> Reviewed-by: Carlos Andrés <carlosap@verdnatura.es>
This commit is contained in:
commit
dbb2372cd3
|
@ -66,46 +66,36 @@ module.exports = Self => {
|
||||||
stmts.push('DROP TEMPORARY TABLE IF EXISTS tmp.timeControlCalculate');
|
stmts.push('DROP TEMPORARY TABLE IF EXISTS tmp.timeControlCalculate');
|
||||||
stmts.push('DROP TEMPORARY TABLE IF EXISTS tmp.timeBusinessCalculate');
|
stmts.push('DROP TEMPORARY TABLE IF EXISTS tmp.timeBusinessCalculate');
|
||||||
|
|
||||||
|
const destroyAllWhere = {
|
||||||
|
timed: {between: [started, ended]},
|
||||||
|
isSendMail: true
|
||||||
|
};
|
||||||
|
const updateAllWhere = {
|
||||||
|
year: args.year,
|
||||||
|
week: args.week
|
||||||
|
};
|
||||||
|
|
||||||
|
const tmpUserSQL = `
|
||||||
|
CREATE OR REPLACE TEMPORARY TABLE tmp.user
|
||||||
|
SELECT id as userFk
|
||||||
|
FROM vn.worker`;
|
||||||
|
let tmpUser = new ParameterizedSQL(tmpUserSQL);
|
||||||
|
|
||||||
if (args.workerId) {
|
if (args.workerId) {
|
||||||
await models.WorkerTimeControl.destroyAll({
|
destroyAllWhere.userFk = args.workerId;
|
||||||
userFk: args.workerId,
|
updateAllWhere.workerFk = args.workerId;
|
||||||
timed: {between: [started, ended]},
|
tmpUser = new ParameterizedSQL(tmpUserSQL + ' WHERE id = ?', [args.workerId]);
|
||||||
isSendMail: true
|
|
||||||
}, myOptions);
|
|
||||||
|
|
||||||
const where = {
|
|
||||||
workerFk: args.workerId,
|
|
||||||
year: args.year,
|
|
||||||
week: args.week
|
|
||||||
};
|
|
||||||
await models.WorkerTimeControlMail.updateAll(where, {
|
|
||||||
updated: Date.vnNew(), state: 'SENDED'
|
|
||||||
}, myOptions);
|
|
||||||
|
|
||||||
stmt = new ParameterizedSQL('DROP TEMPORARY TABLE IF EXISTS tmp.`user`');
|
|
||||||
stmts.push(stmt);
|
|
||||||
stmt = new ParameterizedSQL('CREATE TEMPORARY TABLE tmp.`user` SELECT id userFk FROM account.user WHERE id = ?', [args.workerId]);
|
|
||||||
stmts.push(stmt);
|
|
||||||
} else {
|
|
||||||
await models.WorkerTimeControl.destroyAll({
|
|
||||||
timed: {between: [started, ended]},
|
|
||||||
isSendMail: true
|
|
||||||
}, myOptions);
|
|
||||||
|
|
||||||
const where = {
|
|
||||||
year: args.year,
|
|
||||||
week: args.week
|
|
||||||
};
|
|
||||||
await models.WorkerTimeControlMail.updateAll(where, {
|
|
||||||
updated: Date.vnNew(), state: 'SENDED'
|
|
||||||
}, myOptions);
|
|
||||||
|
|
||||||
stmt = new ParameterizedSQL('DROP TEMPORARY TABLE IF EXISTS tmp.`user`');
|
|
||||||
stmts.push(stmt);
|
|
||||||
stmt = new ParameterizedSQL('CREATE TEMPORARY TABLE IF NOT EXISTS tmp.`user` SELECT id as userFk FROM vn.worker w JOIN account.`user` u ON u.id = w.id WHERE id IS NOT NULL');
|
|
||||||
stmts.push(stmt);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
await models.WorkerTimeControl.destroyAll(destroyAllWhere, myOptions);
|
||||||
|
|
||||||
|
await models.WorkerTimeControlMail.updateAll(updateAllWhere, {
|
||||||
|
updated: Date.vnNew(),
|
||||||
|
state: 'SENDED'
|
||||||
|
}, myOptions);
|
||||||
|
|
||||||
|
stmts.push(tmpUser);
|
||||||
|
|
||||||
stmt = new ParameterizedSQL(
|
stmt = new ParameterizedSQL(
|
||||||
`CALL vn.timeControl_calculate(?, ?)
|
`CALL vn.timeControl_calculate(?, ?)
|
||||||
`, [started, ended]);
|
`, [started, ended]);
|
||||||
|
|
Loading…
Reference in New Issue