589 lines
18 KiB
JavaScript
589 lines
18 KiB
JavaScript
const app = require('vn-loopback/server/server');
|
|
const ParameterizedSQL = require('loopback-connector').ParameterizedSQL;
|
|
|
|
// #2261 xdescribe dbtest workerTimeControl_check()
|
|
xdescribe('worker workerTimeControl_check()', () => {
|
|
it(`should throw an error if the worker can't sign on that tablet`, async() => {
|
|
let stmts = [];
|
|
let stmt;
|
|
const workerId = 1110;
|
|
const tabletId = 2;
|
|
let err;
|
|
stmts.push('START TRANSACTION');
|
|
try {
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmts.push('ROLLBACK');
|
|
|
|
let sql = ParameterizedSQL.join(stmts, ';');
|
|
await app.models.Worker.rawStmt(sql);
|
|
} catch (e) {
|
|
err = e;
|
|
}
|
|
|
|
expect(err.sqlMessage).toEqual('No perteneces a este departamento.');
|
|
});
|
|
|
|
it('should check that the worker can sign on that tablet', async() => {
|
|
let stmts = [];
|
|
let stmt;
|
|
const workerId = 1110;
|
|
const tabletId = 1;
|
|
let err;
|
|
stmts.push('START TRANSACTION');
|
|
try {
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmts.push('ROLLBACK');
|
|
|
|
let sql = ParameterizedSQL.join(stmts, ';');
|
|
await app.models.Worker.rawStmt(sql);
|
|
} catch (e) {
|
|
err = e;
|
|
}
|
|
|
|
expect(err).not.toBeDefined();
|
|
});
|
|
|
|
it('should throw an error if the worker with a special category has not finished the 9h break', async() => {
|
|
// dayBreak to 9h in postgresql.professional_category
|
|
const workerId = 1110;
|
|
const tabletId = 1;
|
|
let stmts = [];
|
|
let stmt;
|
|
let sql;
|
|
let error;
|
|
|
|
stmts.push('START TRANSACTION');
|
|
stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
|
|
VALUES
|
|
(?,TIMESTAMPADD(HOUR,-17,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(SECOND,-32399,NOW()),0,"out")`, [
|
|
workerId,
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
stmts.push('ROLLBACK');
|
|
sql = ParameterizedSQL.join(stmts, ';');
|
|
|
|
try {
|
|
await app.models.Worker.rawStmt(sql);
|
|
} catch (e) {
|
|
await app.models.Worker.rawSql('ROLLBACK');
|
|
error = e;
|
|
}
|
|
|
|
expect(error.sqlMessage).toEqual('Descansos 9 h');
|
|
});
|
|
|
|
it('should check f the worker with a special category has finished the 9h break', async() => {
|
|
// dayBreak to 9h in postgresql.professional_category
|
|
const workerId = 1110;
|
|
const tabletId = 1;
|
|
let stmts = [];
|
|
let stmt;
|
|
let err;
|
|
stmts.push('START TRANSACTION');
|
|
stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
|
|
VALUES
|
|
(?,TIMESTAMPADD(HOUR,-17,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(SECOND,-32401,NOW()),0,"out")`, [
|
|
workerId,
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
stmts.push('ROLLBACK');
|
|
|
|
let sql = ParameterizedSQL.join(stmts, ';');
|
|
|
|
try {
|
|
await app.models.Worker.rawStmt(sql);
|
|
} catch (e) {
|
|
await app.models.Worker.rawSql('ROLLBACK');
|
|
err = e;
|
|
}
|
|
|
|
expect(err).not.toBeDefined();
|
|
});
|
|
|
|
it('should throw an error if the worker has not finished the 12h break', async() => {
|
|
const workerId = 1109;
|
|
const tabletId = 1;
|
|
let stmts = [];
|
|
let stmt;
|
|
let sql;
|
|
let error;
|
|
|
|
stmts.push('START TRANSACTION');
|
|
stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
|
|
VALUES
|
|
(?,TIMESTAMPADD(HOUR,-20,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(SECOND,-43199,NOW()),0,"out")`, [
|
|
workerId,
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
stmts.push('ROLLBACK');
|
|
sql = ParameterizedSQL.join(stmts, ';');
|
|
|
|
try {
|
|
await app.models.Worker.rawStmt(sql);
|
|
} catch (e) {
|
|
await app.models.Worker.rawSql('ROLLBACK');
|
|
error = e;
|
|
}
|
|
|
|
expect(error.sqlMessage).toEqual('Descansos 12 h');
|
|
});
|
|
|
|
it('should throw an error if the worker has finished the 12h break', async() => {
|
|
const workerId = 1109;
|
|
const tabletId = 1;
|
|
let stmts = [];
|
|
let stmt;
|
|
let err;
|
|
stmts.push('START TRANSACTION');
|
|
stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
|
|
VALUES
|
|
(?,TIMESTAMPADD(HOUR,-20,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(SECOND,-43201,NOW()),0,"out")`, [
|
|
workerId,
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
stmts.push('ROLLBACK');
|
|
|
|
let sql = ParameterizedSQL.join(stmts, ';');
|
|
|
|
try {
|
|
await app.models.Worker.rawStmt(sql);
|
|
} catch (e) {
|
|
await app.models.Worker.rawSql('ROLLBACK');
|
|
err = e;
|
|
}
|
|
|
|
expect(err).not.toBeDefined();
|
|
});
|
|
|
|
it('should throw an error if the worker has odd entry records', async() => {
|
|
const workerId = 1109;
|
|
const tabletId = 1;
|
|
let stmts = [];
|
|
let stmt;
|
|
let err;
|
|
stmts.push('START TRANSACTION');
|
|
stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
|
|
VALUES
|
|
(?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in")`, [
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
stmts.push('ROLLBACK');
|
|
|
|
let sql = ParameterizedSQL.join(stmts, ';');
|
|
|
|
try {
|
|
await app.models.Worker.rawStmt(sql);
|
|
} catch (e) {
|
|
await app.models.Worker.rawSql('ROLLBACK');
|
|
err = e;
|
|
}
|
|
|
|
expect(err.sqlMessage).toEqual('Dias con fichadas impares');
|
|
});
|
|
|
|
it('should throw an error if the worker try to sign on a holiday day', async() => {
|
|
const workerId = 1109;
|
|
const tabletId = 1;
|
|
let stmts = [];
|
|
let stmt;
|
|
let err;
|
|
|
|
stmts.push('START TRANSACTION');
|
|
|
|
stmt = new ParameterizedSQL(`INSERT INTO postgresql.calendar_employee(business_id,calendar_state_id,date)
|
|
VALUES
|
|
(?,1,CURDATE())`, [
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
|
|
VALUES
|
|
(?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-20,NOW()),0,"out")`, [
|
|
workerId,
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
stmts.push('ROLLBACK');
|
|
|
|
let sql = ParameterizedSQL.join(stmts, ';');
|
|
|
|
try {
|
|
await app.models.Worker.rawStmt(sql);
|
|
} catch (e) {
|
|
await app.models.Worker.rawSql('ROLLBACK');
|
|
err = e;
|
|
}
|
|
|
|
expect(err.sqlMessage).toEqual('Holidays');
|
|
});
|
|
|
|
it('should throw an error if the worker try to sign with your contract ended', async() => {
|
|
const workerId = 1109;
|
|
const tabletId = 1;
|
|
let stmts = [];
|
|
let stmt;
|
|
let err;
|
|
|
|
stmts.push('START TRANSACTION');
|
|
|
|
stmt = new ParameterizedSQL(`UPDATE postgresql.business SET date_end=DATE_ADD(CURDATE(), INTERVAL -1 DAY) WHERE business_id=?`, [
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
|
|
VALUES
|
|
(?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-20,NOW()),0,"out")`, [
|
|
workerId,
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
stmts.push('ROLLBACK');
|
|
|
|
let sql = ParameterizedSQL.join(stmts, ';');
|
|
|
|
try {
|
|
await app.models.Worker.rawStmt(sql);
|
|
} catch (e) {
|
|
await app.models.Worker.rawSql('ROLLBACK');
|
|
err = e;
|
|
}
|
|
|
|
expect(err.sqlMessage).toEqual('No hay un contrato en vigor');
|
|
});
|
|
|
|
it('should throw an error if the worker has not finished the 36h weekly break', async() => {
|
|
const workerId = 1109;
|
|
const tabletId = 1;
|
|
let stmts = [];
|
|
let stmt;
|
|
|
|
stmts.push('SET @warn := NULL');
|
|
|
|
stmts.push('START TRANSACTION');
|
|
|
|
stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
|
|
VALUES
|
|
(?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-16,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-48,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-40,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-72,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-64,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-96,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-88,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-120,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-112,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-144,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-136,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-168,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-160,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-192,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-184,NOW()),0,"out")`, [
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
let warningMessageIndex = stmts.push('SELECT @warn AS warning') - 1;
|
|
stmts.push('ROLLBACK');
|
|
let sql = ParameterizedSQL.join(stmts, ';');
|
|
let result = await app.models.Worker.rawStmt(sql);
|
|
|
|
expect(result[warningMessageIndex][0].warning).toEqual('Descansos 36 h');
|
|
});
|
|
|
|
it('should check if the worker has finished the 36h weekly break', async() => {
|
|
const workerId = 1109;
|
|
const tabletId = 1;
|
|
let stmts = [];
|
|
let stmt;
|
|
|
|
stmts.push('SET @warn := NULL');
|
|
|
|
stmts.push('START TRANSACTION');
|
|
|
|
stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
|
|
VALUES
|
|
(?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-16,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-48,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-40,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-72,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-64,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-96,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-88,NOW()),0,"out")`, [
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
stmts.push('ROLLBACK');
|
|
|
|
let warningMessageIndex = stmts.push('SELECT @warn AS warning') - 1;
|
|
|
|
let sql = ParameterizedSQL.join(stmts, ';');
|
|
let result = await app.models.Worker.rawStmt(sql);
|
|
|
|
expect(result[warningMessageIndex][0].warning).toBe(null);
|
|
});
|
|
|
|
it('should throw an error if the worker has not finished the 72h biweekly break', async() => {
|
|
const workerId = 1109;
|
|
const tabletId = 1;
|
|
let stmts = [];
|
|
let stmt;
|
|
let err;
|
|
stmts.push('START TRANSACTION');
|
|
|
|
stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
|
|
VALUES
|
|
(?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-16,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-48,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-40,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-72,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-64,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-96,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-88,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-120,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-112,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-144,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-136,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-168,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-160,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-192,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-184,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-216,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-208,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-240,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-232,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-264,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-256,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-289,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-280,NOW()),0,"out")`, [
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
stmts.push('ROLLBACK');
|
|
|
|
stmts.push('SELECT @warn AS warning') - 1;
|
|
|
|
let sql = ParameterizedSQL.join(stmts, ';');
|
|
|
|
try {
|
|
await app.models.Worker.rawStmt(sql);
|
|
} catch (e) {
|
|
await app.models.Worker.rawSql('ROLLBACK');
|
|
err = e;
|
|
}
|
|
|
|
expect(err.sqlMessage).toEqual('Descansos 72 h');
|
|
});
|
|
|
|
it('should check if the worker has finished the 72h biweekly break', async() => {
|
|
const workerId = 1109;
|
|
const tabletId = 1;
|
|
let stmts = [];
|
|
let stmt;
|
|
let err;
|
|
stmts.push('START TRANSACTION');
|
|
|
|
stmt = new ParameterizedSQL(`INSERT INTO vn.workerTimeControl(userFk,timed,manual,direction)
|
|
VALUES
|
|
(?,TIMESTAMPADD(HOUR,-24,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-16,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-48,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-40,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-72,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-64,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-96,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-88,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-120,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-112,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-144,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-136,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-168,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-160,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-192,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-184,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-216,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-208,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-240,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-232,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-264,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-256,NOW()),0,"out"),
|
|
(?,TIMESTAMPADD(HOUR,-288,NOW()),0,"in"),
|
|
(?,TIMESTAMPADD(HOUR,-280,NOW()),0,"out")`, [
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId,
|
|
workerId
|
|
]);
|
|
stmts.push(stmt);
|
|
|
|
stmt = new ParameterizedSQL('CALL vn.workerTimeControl_check(?, ?, NULL)', [
|
|
workerId,
|
|
tabletId
|
|
]);
|
|
stmts.push(stmt);
|
|
stmts.push('ROLLBACK');
|
|
|
|
stmts.push('SELECT @warn AS warning') - 1;
|
|
|
|
let sql = ParameterizedSQL.join(stmts, ';');
|
|
|
|
try {
|
|
await app.models.Worker.rawStmt(sql);
|
|
} catch (e) {
|
|
await app.models.Worker.rawSql('ROLLBACK');
|
|
err = e;
|
|
}
|
|
|
|
expect(err).not.toBeDefined();
|
|
});
|
|
});
|