From 8acd03f1159b70fdde9fd11c99d4b06dc6ca2a20 Mon Sep 17 00:00:00 2001
From: jorgep <jorgep@verdnatura.es>
Date: Mon, 11 Dec 2023 13:01:34 +0100
Subject: [PATCH] refs #6276 saleTrackingReplace

---
 db/changes/235001/00-newWareHouse.sql         |   3 +-
 .../methods/sale-tracking/updateTracking.js   | 100 ++++++++++++++++++
 modules/ticket/back/model-config.json         |   3 +
 modules/ticket/back/models/sale-buy.json      |  33 ++++++
 modules/ticket/back/models/sale-tracking.js   |   1 +
 modules/ticket/back/models/sale-tracking.json |   3 +
 6 files changed, 142 insertions(+), 1 deletion(-)
 create mode 100644 modules/ticket/back/methods/sale-tracking/updateTracking.js
 create mode 100644 modules/ticket/back/models/sale-buy.json

diff --git a/db/changes/235001/00-newWareHouse.sql b/db/changes/235001/00-newWareHouse.sql
index c6f595400..f563ce40c 100644
--- a/db/changes/235001/00-newWareHouse.sql
+++ b/db/changes/235001/00-newWareHouse.sql
@@ -5,4 +5,5 @@ INSERT INTO `salix`.`ACL` (model, property, accessType, permission, principalTyp
         ('MachineWorker','updateInTime','WRITE','ALLOW','ROLE','employee'),
         ('MachineWorker','add','READ','ALLOW','ROLE','employee'),
         ('MobileAppVersionControl','getVersion','READ','ALLOW','ROLE','employee'),
-        ('SaleTracking','deleteTracking','WRITE','ALLOW','ROLE','employee');
\ No newline at end of file
+        ('SaleTracking','deleteTracking','WRITE','ALLOW','ROLE','employee'),
+        ('SaleTracking','updateTracking','WRITE','ALLOW','ROLE','employee');
\ No newline at end of file
diff --git a/modules/ticket/back/methods/sale-tracking/updateTracking.js b/modules/ticket/back/methods/sale-tracking/updateTracking.js
new file mode 100644
index 000000000..1f499022e
--- /dev/null
+++ b/modules/ticket/back/methods/sale-tracking/updateTracking.js
@@ -0,0 +1,100 @@
+module.exports = Self => {
+    Self.remoteMethodCtx('updateTracking', {
+        description: 'Modify a saleTracking record and, if applicable, add a corresponding record in saleBuy.',
+        accessType: 'WRITE',
+        accepts: [
+            {
+                arg: 'saleFk',
+                type: 'number',
+                required: true
+            },
+            {
+                arg: 'originalQuantity',
+                type: 'number',
+                required: true
+            },
+            {
+                arg: 'code',
+                type: 'string',
+                required: true
+            },
+            {
+                arg: 'isChecked',
+                type: 'number',
+                required: true
+            },
+            {
+                arg: 'buyFk',
+                type: 'number',
+                required: true
+            },
+            {
+                arg: 'isScanned',
+                type: 'number',
+            },
+        ],
+        http: {
+            path: `/updateTracking`,
+            verb: 'POST'
+        }
+    });
+
+    Self.updateTracking = async(ctx, saleFk, originalQuantity, code, isChecked, buyFk, isScanned, options) => {
+        const userId = ctx.req.accessToken.userId;
+        const models = Self.app.models;
+        const myOptions = {};
+        let tx;
+
+        if (typeof options == 'object')
+            Object.assign(myOptions, options);
+
+        if (!myOptions.transaction) {
+            tx = await Self.beginTransaction({});
+            myOptions.transaction = tx;
+        }
+
+        try {
+            const state = await models.State.findOne({
+                where: {code},
+            }, myOptions);
+
+            const attributes = {
+                saleFk,
+                isChecked,
+                originalQuantity,
+                workerFk: userId,
+                stateFk: state.id,
+                isScanned,
+            };
+
+            const saleTracking = await models.SaleTracking.findOne({
+                where: attributes,
+            }, myOptions);
+
+            if (!saleTracking)
+                await models.SaleTracking.create(attributes, myOptions);
+
+            else
+                await saleTracking.updateAttributes(attributes, myOptions);
+
+            let isBuy;
+            if (buyFk) {
+                isBuy = await models.Buy.findOne({
+                    where: {
+                        id: buyFk,
+                        itemOriginalFk: {
+                            neq: null
+                        }
+                    }
+                });
+            }
+            if (isBuy)
+                await models.SaleBuy.create({saleFk, buyFk}, myOptions);
+
+            if (tx) await tx.commit();
+        } catch (e) {
+            if (tx) await tx.rollback();
+            throw e;
+        }
+    };
+};
diff --git a/modules/ticket/back/model-config.json b/modules/ticket/back/model-config.json
index 76a289cc3..db90b55e1 100644
--- a/modules/ticket/back/model-config.json
+++ b/modules/ticket/back/model-config.json
@@ -65,6 +65,9 @@
     "SaleTracking": {
         "dataSource": "vn"
     },
+    "SaleBuy": {
+        "dataSource": "vn"
+    },
     "State": {
         "dataSource": "vn"
     },
diff --git a/modules/ticket/back/models/sale-buy.json b/modules/ticket/back/models/sale-buy.json
new file mode 100644
index 000000000..5279e6787
--- /dev/null
+++ b/modules/ticket/back/models/sale-buy.json
@@ -0,0 +1,33 @@
+{
+    "name": "SaleBuy",
+    "base": "VnModel",
+    "options": {
+        "mysql": {
+            "table": "saleBuy"
+        }
+    },
+    "properties": {
+        "saleFk": {
+            "id": true,
+            "type": "number",
+            "forceId": false
+        },
+        "buyFk": {
+            "type": "number"
+        },
+        "created": {
+            "type": "date"
+        },
+        "isChecked": {
+            "type": "number"
+        }
+    },
+    "relations": {
+        "sale": {
+            "type": "belongsTo",
+            "model": "Sale",
+            "foreignKey": "saleFk"
+        }
+    }
+}
+  
\ No newline at end of file
diff --git a/modules/ticket/back/models/sale-tracking.js b/modules/ticket/back/models/sale-tracking.js
index 54a2b5a1a..4b513a716 100644
--- a/modules/ticket/back/models/sale-tracking.js
+++ b/modules/ticket/back/models/sale-tracking.js
@@ -3,4 +3,5 @@ module.exports = Self => {
     require('../methods/sale-tracking/listSaleTracking')(Self);
     require('../methods/sale-tracking/new')(Self);
     require('../methods/sale-tracking/delete')(Self);
+    require('../methods/sale-tracking/updateTracking')(Self);
 };
diff --git a/modules/ticket/back/models/sale-tracking.json b/modules/ticket/back/models/sale-tracking.json
index 4a103ea15..5e512f844 100644
--- a/modules/ticket/back/models/sale-tracking.json
+++ b/modules/ticket/back/models/sale-tracking.json
@@ -26,6 +26,9 @@
         },
         "originalQuantity": {
             "type": "number"
+        },
+        "isScanned": {
+            "type": "number"
         }
     },
     "relations": {