From 27d223cbab099ff9bd73d97d1872401dd5cc1962 Mon Sep 17 00:00:00 2001
From: jorgep <jorgep@verdnatura.es>
Date: Wed, 29 Nov 2023 16:25:15 +0100
Subject: [PATCH] refs #6276 machineWorker_add

---
 back/methods/machine-worker/add.js          | 68 +++++++++++++++++++++
 back/methods/machine-worker/updateInTime.js |  2 +-
 back/models/machine-worker.js               |  1 +
 db/changes/235001/00-newWareHouse.sql       |  1 +
 4 files changed, 71 insertions(+), 1 deletion(-)
 create mode 100644 back/methods/machine-worker/add.js

diff --git a/back/methods/machine-worker/add.js b/back/methods/machine-worker/add.js
new file mode 100644
index 000000000..3da236cb8
--- /dev/null
+++ b/back/methods/machine-worker/add.js
@@ -0,0 +1,68 @@
+module.exports = Self => {
+    Self.remoteMethodCtx('add', {
+        description: 'Insert log if the worker has not logged anything in the last 12 hours',
+        accessType: 'READ',
+        accepts: [
+            {
+                arg: 'plate',
+                type: 'string',
+            }
+        ],
+        http: {
+            path: `/add`,
+            verb: 'POST'
+        }
+    });
+
+    Self.add = async(ctx, plate, options) => {
+        const models = Self.app.models;
+        const userId = ctx.req.accessToken.userId;
+
+        let tx;
+        const myOptions = {};
+
+        if (typeof options == 'object')
+            Object.assign(myOptions, options);
+
+        if (!myOptions.transaction) {
+            tx = await Self.beginTransaction({});
+            myOptions.transaction = tx;
+        }
+
+        try {
+            const machine = await models.Machine.findOne({
+                fields: ['id', 'plate'],
+                where: {plate}
+            }, myOptions);
+
+            if (!machine) throw new Error(`plate ${plate} does not exist`);
+
+            const twelveHoursAgo = Date.vnNew();
+            twelveHoursAgo.setHours(twelveHoursAgo.getHours() - 12);
+
+            const isRegistered = await models.MachineWorker.findOne({
+                where: {
+                    and: [
+                        {machineFk: machine.id},
+                        {workerFk: userId},
+                        {outTime: {gte: twelveHoursAgo}}
+                    ]
+                }
+            }, myOptions);
+            console.log(isRegistered);
+            if (!isRegistered) await models.MachineWorker.create({machineFk: machine.id, workerFk: userId}, myOptions);
+            else {
+                await models.MachineWorker.updateAll(
+                    {or: [{workerFk: userId}, {machineFk: machine.id}]},
+                    {outTime: Date.vnNew()},
+                    myOptions
+                );
+            }
+
+            if (tx) await tx.commit();
+        } catch (e) {
+            if (tx) await tx.rollback();
+            throw e;
+        }
+    };
+};
diff --git a/back/methods/machine-worker/updateInTime.js b/back/methods/machine-worker/updateInTime.js
index b8e2becf2..917733686 100644
--- a/back/methods/machine-worker/updateInTime.js
+++ b/back/methods/machine-worker/updateInTime.js
@@ -1,6 +1,6 @@
 module.exports = Self => {
     Self.remoteMethodCtx('updateInTime', {
-        description: '',
+        description: 'Updates the corresponding registry if the worker has been registered in the last few hours',
         accessType: 'WRITE',
         accepts: [
             {
diff --git a/back/models/machine-worker.js b/back/models/machine-worker.js
index cbc5fd53e..b44cb1fb6 100644
--- a/back/models/machine-worker.js
+++ b/back/models/machine-worker.js
@@ -1,3 +1,4 @@
 module.exports = Self => {
     require('../methods/machine-worker/updateInTime')(Self);
+    require('../methods/machine-worker/add')(Self);
 };
diff --git a/db/changes/235001/00-newWareHouse.sql b/db/changes/235001/00-newWareHouse.sql
index 9111a8a04..05003d8ec 100644
--- a/db/changes/235001/00-newWareHouse.sql
+++ b/db/changes/235001/00-newWareHouse.sql
@@ -3,4 +3,5 @@ INSERT INTO `salix`.`ACL` (model, property, accessType, permission, principalTyp
         ('Collection', 'assignCollection', 'WRITE', 'ALLOW', 'ROLE', 'employee'),
         ('ExpeditionPallet', 'getPallet', 'READ', 'ALLOW', 'ROLE', 'employee'),
         ('MachineWorker','updateInTime','WRITE','ALLOW','ROLE','employee'),
+        ('MachineWorker','add','READ','ALLOW','ROLE','employee'),
         ('MobileAppVersionControl','getVersion','READ','ALLOW','ROLE','employee');
\ No newline at end of file