back/methods/collection/getSalesFromTicketOrCollection.js

@@ -0,0 +1,146 @@
+module.exports = Self => {
+    Self.remoteMethodCtx('getSalesFromTicketOrCollection', {
+        description: 'Get sales from ticket or collection',
+        accessType: 'READ',
+        accepts: [
+            {
+                arg: 'collectionOrTicketFk',
+                type: 'number',
+                required: true
+            },
+            {
+                arg: 'sectorFk',
+                type: 'number',
+                required: true
+            },
+            {
+                arg: 'printFk',
+                type: 'number',
+                required: true
+            },
+            {
+                arg: 'source',
+                type: 'string',
+                required: true
+            },
+
+        ],
+        returns: {
+            type: 'Object',
+            root: true
+        },
+        http: {
+            path: `/getSalesFromTicketOrCollection`,
+            verb: 'GET'
+        },
+    });
+
+    Self.getSalesFromTicketOrCollection = async(ctx, collectionOrTicketFk, sectorFk, printFk, source, options) => {
+        const models = Self.app.models;
+        const myOptions = {};
+
+        if (typeof options == 'object')
+            Object.assign(myOptions, options);
+
+        const [collectionOrTicket] = await Self.rawSql('SELECT vn.ticket_get(?) as id', [collectionOrTicketFk]);
+
+        const [tickets] = await Self.rawSql('CALL vn.collection_getTickets(?)', [collectionOrTicket.id]);
+
+        if (source == 'PRECHECKER' || source == 'ON_CHECKING') {
+            await Self.rawSql(
+                'CALL vn.ticketStateToday_setState(?,?)',
+                [collectionOrTicket.id, source]
+            );
+        }
+
+        const [sales] = await Self.rawSql('CALL vn.sale_getFromTicketOrCollection(?)', [collectionOrTicket.id]);
+
+        const isPicker = source == 'CHECKER';
+        const [placements] = await Self.rawSql(
+            'CALL vn.collectionPlacement_get(?, ?)', [collectionOrTicket.id, isPicker]
+        );
+
+        if (printFk == 1) await Self.rawSql('CALL vn.collection_printSticker(?,NULL)', [collectionOrTicket.id]);
+
+        if (tickets.length) await sendRocketTickets(tickets);
+
+        return getCollection(collectionOrTicket.id, tickets, sales, placements);
+
+        async function sendRocketTickets(tickets) {
+            for (let ticket of tickets) {
+                let observations = ticket.observaciones.split(' ');
+
+                for (let observation of observations) {
+                    const salesMan = ticket.salesPersonFk;
+
+                    if (!observation.startsWith('#') && !observation.startsWith('@')) return;
+
+                    await models.Chat.send(ctx,
+                        observation,
+                        `El ticket ${ticket.ticketFk} del comercial ${salesMan} está en preparación.(mensaje creado automáticamente)`
+                    );
+                }
+            }
+        }
+
+        async function getCollection(id, tickets, sales, placements) {
+            const collection = {
+                collectionFk: id,
+                tickets: [],
+            };
+            for (let ticket of tickets) {
+                const {ticketFk} = ticket;
+                ticket.sales = [];
+
+                const barcodes = await getBarcodes(ticketFk);
+                await Self.rawSql(
+                    'CALL util.log_add(?, ?, ?, ?, ?, ?, ?, ?)',
+                    ['vn', 'ticket', 'Ticket', ticketFk, ticketFk, 'select', null, null]
+                );
+
+                for (let sale of sales) {
+                    if (sale.ticketFk == ticketFk) {
+                        sale.placements = placements.filter(placement =>
+                            placement.saleFk == sale.saleFk && placement.order
+                        );
+
+                        sale.barcodes = [];
+                        for (const barcode of barcodes) {
+                            if (barcode.movementId) {
+                                if (barcode.code) {
+                                    sale.barcodes.push(barcode.code);
+                                    sale.barcodes.push(`0 ${barcode.code}`);
+                                }
+
+                                if (barcode.id) {
+                                    sale.barcodes.push(barcode.id);
+                                    sale.barcodes.push(`0 ${barcode.id}`);
+                                }
+                            }
+                        }
+
+                        ticket.sales.push(sale);
+                    }
+                }
+                collection.tickets.push(ticket);
+            }
+
+            return collection;
+        }
+
+        async function getBarcodes(ticketId) {
+            const query =
+                `SELECT s.id movementId, 
+                        b.code, 
+                        c.id
+                    FROM vn.sale s
+                        LEFT JOIN vn.itemBarcode b ON b.itemFk = s.itemFk
+                        LEFT JOIN vn.buy c ON c.itemFk = s.itemFk
+                        LEFT JOIN vn.entry e ON e.id = c.entryFk
+                        LEFT JOIN vn.travel tr ON tr.id = e.travelFk
+                    WHERE s.ticketFk = ? 
+                        AND tr.landed >= DATE_SUB(CURDATE(), INTERVAL 1 YEAR)`;
+            return Self.rawSql(query, [ticketId]);
+        }
+    };
+};

back/models/collection.js

@@ -6,4 +6,5 @@ module.exports = Self => {
     require('../methods/collection/getTickets')(Self);
     require('../methods/collection/assignCollection')(Self);
     require('../methods/collection/addItem')(Self);
+    require('../methods/collection/getSalesFromTicketOrCollection')(Self);
 };