From 40236fdb7bac7b299e6118e51b12cc0a69fbf226 Mon Sep 17 00:00:00 2001
From: jorgep <jorgep@verdnatura.es>
Date: Thu, 30 Nov 2023 13:23:10 +0100
Subject: [PATCH] refs #6276 itemShelvingMake_multi

---
 .../back/methods/item-shelving/makeMulti.js   | 74 +++++++++++++++++++
 modules/item/back/models/item-shelving.js     |  1 +
 modules/item/back/models/item-shelving.json   |  2 +-
 3 files changed, 76 insertions(+), 1 deletion(-)
 create mode 100644 modules/item/back/methods/item-shelving/makeMulti.js

diff --git a/modules/item/back/methods/item-shelving/makeMulti.js b/modules/item/back/methods/item-shelving/makeMulti.js
new file mode 100644
index 0000000000..d4b4517605
--- /dev/null
+++ b/modules/item/back/methods/item-shelving/makeMulti.js
@@ -0,0 +1,74 @@
+module.exports = Self => {
+    Self.remoteMethod('makeMulti', {
+        description: 'Add a record or update it if it already exists.',
+        accessType: 'WRITE',
+        accepts: [{
+            arg: 'shelvingFk',
+            type: 'number',
+            required: true,
+        },
+        {
+            arg: 'items',
+            type: ['number'],
+            required: true,
+            description: 'array of item foreign keys'
+        },
+        {
+            arg: 'warehouseFk',
+            type: 'number',
+            required: true
+        }],
+
+        http: {
+            path: `/makeMulti`,
+            verb: 'POST'
+        }
+    });
+
+    Self.makeMulti = async(shelvingFk, items, warehouseFk, options) => {
+        const myOptions = {};
+        let tx;
+
+        if (typeof options == 'object')
+            Object.assign(myOptions, options);
+
+        if (!myOptions.transaction) {
+            tx = await Self.beginTransaction({});
+            myOptions.transaction = tx;
+        }
+
+        const discardItems = [];
+
+        try {
+            for (let item of items) {
+                if (!discardItems.includes(item)) {
+                    let quantity = items.reduce((acc, cur) => {
+                        return acc + (cur === item ? 1 : 0);
+                    }, 0);
+                    discardItems.push(item);
+
+                    let [result] = await Self.rawSql('SELECT vn.itemPacking(?, ?)', [item, warehouseFk]);
+                    let packing;
+
+                    if (result) packing = Object.values(result)[0];
+                    if (!packing) packing = 1;
+
+                    quantity = quantity * packing;
+
+                    await Self.rawSql('CALL vn.itemShelving_add(?, ?, ?, NULL, NULL, ?, ?)',
+                        [shelvingFk,
+                            item,
+                            quantity,
+                            packing,
+                            warehouseFk]
+                    );
+                }
+            }
+
+            if (tx) await tx.commit();
+        } catch (e) {
+            if (tx) await tx.rollback();
+            throw e;
+        }
+    };
+};
diff --git a/modules/item/back/models/item-shelving.js b/modules/item/back/models/item-shelving.js
index 98ff189319..4684d49e26 100644
--- a/modules/item/back/models/item-shelving.js
+++ b/modules/item/back/models/item-shelving.js
@@ -1,4 +1,5 @@
 module.exports = Self => {
     require('../methods/item-shelving/deleteItemShelvings')(Self);
     require('../methods/item-shelving/getInventory')(Self);
+    require('../methods/item-shelving/makeMulti')(Self);
 };
diff --git a/modules/item/back/models/item-shelving.json b/modules/item/back/models/item-shelving.json
index bb1a141c42..61d05539e1 100644
--- a/modules/item/back/models/item-shelving.json
+++ b/modules/item/back/models/item-shelving.json
@@ -1,6 +1,6 @@
 {
 	"name": "ItemShelving",
-	"base": "Loggable",
+	"base": "VnModel",
 	"options": {
 		"mysql": {
 			"table": "itemShelving"