52 lines
1.6 KiB
JavaScript
52 lines
1.6 KiB
JavaScript
|
|
module.exports = Self => {
|
|
Self.remoteMethodCtx('add', {
|
|
description: 'Add activity if the activity is different or is the same but have exceed time for break',
|
|
accessType: 'WRITE',
|
|
accepts: [
|
|
{
|
|
arg: 'code',
|
|
type: 'string',
|
|
description: 'Code for activity'
|
|
},
|
|
{
|
|
arg: 'model',
|
|
type: 'string',
|
|
description: 'Origin model from insert'
|
|
},
|
|
|
|
],
|
|
http: {
|
|
path: `/add`,
|
|
verb: 'POST'
|
|
}
|
|
});
|
|
|
|
Self.add = async(ctx, code, model, options) => {
|
|
const userId = ctx.req.accessToken.userId;
|
|
|
|
const result = await await Self.rawSql(`
|
|
INSERT INTO workerActivity (workerFk, workerActivityTypeFk, model)
|
|
SELECT ?,
|
|
?,
|
|
?
|
|
FROM workerTimeControlParams wtcp
|
|
LEFT JOIN (
|
|
SELECT wa.workerFk,
|
|
wa.created,
|
|
wat.code
|
|
FROM workerActivity wa
|
|
LEFT JOIN workerActivityType wat ON wat.code = wa.workerActivityTypeFk
|
|
WHERE wa.workerFk = ?
|
|
ORDER BY wa.created DESC
|
|
LIMIT 1
|
|
) sub ON TRUE
|
|
WHERE sub.workerFk IS NULL
|
|
OR sub.code <> ?
|
|
OR TIMESTAMPDIFF(SECOND, sub.created, util.VN_NOW()) > wtcp.dayBreak;`
|
|
, [userId, code, model, userId, code]);
|
|
|
|
return result;
|
|
};
|
|
};
|