db/changes/10210-summer/00-ticket_close.sql

@@ -0,0 +1,119 @@
+USE `vn`;
+DROP procedure IF EXISTS `ticket_close`;
+
+DELIMITER $$
+USE `vn`$$
+CREATE DEFINER=`root`@`%` PROCEDURE `ticket_close`(vTicketFk INT)
+BEGIN
+/**
+ * Realiza el cierre de todos los 
+ * tickets de la tabla ticketClosure.
+ *
+ * @param vTicketFk Id del ticket
+ */
+	DECLARE vDone BOOL;
+	DECLARE vClientFk INT;
+    DECLARE vCurTicketFk INT;
+	DECLARE vIsTaxDataChecked BOOL;
+	DECLARE vCompanyFk INT;
+	DECLARE vShipped DATE;
+	DECLARE vNewInvoiceId INT;
+	DECLARE vHasDailyInvoice BOOL;
+	DECLARE vWithPackage BOOL;
+    DECLARE vHasToInvoice BOOL;
+
+	DECLARE cur CURSOR FOR
+		SELECT ticketFk FROM tmp.ticketClosure;
+		
+	DECLARE CONTINUE HANDLER FOR NOT FOUND SET vDone = TRUE;
+	DECLARE EXIT HANDLER FOR SQLEXCEPTION BEGIN
+		RESIGNAL;
+	END;
+
+	DROP TEMPORARY TABLE IF EXISTS  tmp.ticketClosure;
+	CREATE TEMPORARY TABLE tmp.ticketClosure
+			SELECT vTicketFk AS ticketFk;
+            
+	INSERT INTO tmp.ticketClosure 
+			SELECT id FROM stowaway s 
+				WHERE s.shipFk = vTicketFk;
+	OPEN cur;
+
+	proc: LOOP
+		SET vDone = FALSE;
+		
+		FETCH cur INTO vCurTicketFk;
+
+		IF vDone THEN
+			LEAVE proc;
+		END IF;
+
+		-- ticketClosure start
+		SELECT
+				c.id,
+				c.isTaxDataChecked,
+				t.companyFk,
+				t.shipped,
+				co.hasDailyInvoice,
+				w.isManaged,
+                c.hasToInvoice
+			INTO vClientFk,
+				vIsTaxDataChecked,
+				vCompanyFk, 
+				vShipped,
+				vHasDailyInvoice,
+				vWithPackage,
+                vHasToInvoice
+			FROM ticket t 
+				JOIN `client` c ON c.id = t.clientFk
+				JOIN province p ON p.id = c.provinceFk
+				JOIN country co ON co.id = p.countryFk
+				JOIN warehouse w ON w.id = t.warehouseFk
+			WHERE t.id = vCurTicketFk;
+
+		INSERT INTO ticketPackaging (ticketFk, packagingFk, quantity)
+			(SELECT vCurTicketFk, p.id, COUNT(*)
+				FROM expedition e 
+					JOIN packaging p ON p.itemFk = e.itemFk
+				WHERE e.ticketFk = vCurTicketFk AND p.isPackageReturnable
+					AND vWithPackage
+				GROUP BY p.itemFk);
+
+		-- No retornables o no catalogados
+		INSERT INTO sale (itemFk, ticketFk, concept, quantity, price, isPriceFixed) 
+			(SELECT e.itemFk, vCurTicketFk, i.name, COUNT(*) AS amount, getSpecialPrice(e.itemFk, vClientFk), 1 
+				FROM expedition e 
+					JOIN item i ON i.id = e.itemFk 
+					LEFT JOIN packaging p ON p.itemFk = i.id
+				WHERE e.ticketFk = vCurTicketFk AND IFNULL(p.isPackageReturnable, 0) = 0
+					AND getSpecialPrice(e.itemFk, vClientFk) > 0
+				GROUP BY e.itemFk);
+                
+		CALL vn.zonePromo_Make();
+			
+		IF(vHasDailyInvoice) AND vHasToInvoice THEN
+
+			-- Facturacion rapida
+			CALL ticketTrackingAdd(vCurTicketFk, 'DELIVERED', NULL);
+			-- Facturar si está contabilizado
+			IF vIsTaxDataChecked THEN
+				CALL invoiceOut_newFromClient(
+					vClientFk, 
+					(SELECT invoiceSerial(vClientFk, vCompanyFk, 'M')), 
+					vShipped, 
+					vCompanyFk, 
+					NULL,
+					vNewInvoiceId);
+			END IF;
+		ELSE
+			CALL ticketTrackingAdd(vCurTicketFk, (SELECT vn.getAlert3State(vCurTicketFk)), NULL);
+		END IF;
+	END LOOP;
+
+	CLOSE cur;
+    
+	DROP TEMPORARY TABLE IF EXISTS  tmp.ticketClosure;
+END$$
+
+DELIMITER ;
+

print/methods/closure.js

@@ -4,42 +4,179 @@ const smtp = require('../core/smtp');
 const config = require('../core/config');
 
 module.exports = app => {
-    app.get('/api/closure/by-ticket', async function(req, res) {
+    app.get('/api/closure/all', async function(req, res, next) {
+        try {
+            res.status(200).json({
+                message: 'Task executed successfully'
+            });
+
+            await db.rawSql(`DROP TEMPORARY TABLE IF EXISTS tmp.ticket_close`);
+            await db.rawSql(`
+            CREATE TEMPORARY TABLE tmp.ticket_close ENGINE = MEMORY (
+                SELECT 
+                    t.id AS ticketFk
+                FROM expedition e
+                    JOIN ticket t ON t.id = e.ticketFk
+                    JOIN warehouse wh ON wh.id = t.warehouseFk AND wh.hasComission
+                    JOIN ticketState ts ON ts.ticketFk = t.id
+                    JOIN alertLevel al ON al.alertLevel = ts.alertLevel
+                WHERE al.code = 'PACKED'
+                    AND DATE(t.shipped) BETWEEN DATE_ADD(CURDATE(), INTERVAL -2 DAY) AND CURDATE()
+                    AND t.refFk IS NULL
+                GROUP BY e.ticketFk)`);
+
+            await closeAll(req.args);
+
+            await db.rawSql(`
+            UPDATE ticket t
+                JOIN ticketState ts ON t.id = ts.ticketFk
+                JOIN alertLevel al ON al.alertLevel = ts.alertLevel
+                JOIN agencyMode am ON am.id = t.agencyModeFk 
+                JOIN deliveryMethod dm ON dm.id = am.deliveryMethodFk
+                JOIN zone z ON z.id = t.zoneFk
+            SET t.routeFk = NULL
+                WHERE shipped BETWEEN CURDATE() AND util.dayEnd(CURDATE())
+                    AND al.code NOT IN('DELIVERED','PACKED')
+                    AND t.routeFk
+                    AND z.name LIKE '%MADRID%'`);
+        } catch (error) {
+            next(error);
+        }
     });
 
-    app.get('/api/closure/all', async function(req, res) {
-        res.status(200).json({
-            message: 'Task executed successfully'
-        });
+    app.get('/api/closure/by-ticket', async function(req, res, next) {
+        try {
+            const reqArgs = req.args;
+            if (!reqArgs.ticketId)
+                throw new Error('The argument ticketId is required');
 
+            res.status(200).json({
+                message: 'Task executed successfully'
+            });
+
+            await db.rawSql(`DROP TEMPORARY TABLE IF EXISTS tmp.ticket_close`);
+            await db.rawSql(`
+            CREATE TEMPORARY TABLE tmp.ticket_close ENGINE = MEMORY (
+                SELECT 
+                    t.id AS ticketFk
+                FROM expedition e
+                    JOIN ticket t ON t.id = e.ticketFk
+                    JOIN ticketState ts ON ts.ticketFk = t.id
+                    JOIN alertLevel al ON al.alertLevel = ts.alertLevel
+                WHERE al.code = 'PACKED'
+                    AND t.id = :ticketId
+                    AND t.refFk IS NULL
+                GROUP BY e.ticketFk)`, {
+                ticketId: reqArgs.ticketId
+            });
+
+            await closeAll(reqArgs);
+        } catch (error) {
+            next(error);
+        }
+    });
+
+    app.get('/api/closure/by-agency', async function(req, res) {
+        try {
+            const reqArgs = req.args;
+            if (!reqArgs.agencyModeId)
+                throw new Error('The argument agencyModeId is required');
+
+            if (!reqArgs.warehouseId)
+                throw new Error('The argument warehouseId is required');
+
+            if (!reqArgs.to)
+                throw new Error('The argument to is required');
+
+            res.status(200).json({
+                message: 'Task executed successfully'
+            });
+
+            await db.rawSql(`DROP TEMPORARY TABLE IF EXISTS tmp.ticket_close`);
+            await db.rawSql(`
+            CREATE TEMPORARY TABLE tmp.ticket_close ENGINE = MEMORY (
+                SELECT 
+                    t.id AS ticketFk
+                FROM expedition e
+                    JOIN ticket t ON t.id = e.ticketFk
+                    JOIN ticketState ts ON ts.ticketFk = t.id
+                    JOIN alertLevel al ON al.alertLevel = ts.alertLevel
+                WHERE al.code = 'PACKED'
+                    AND t.agencyModeFk = :agencyModeId
+                    AND t.warehouseFk = :warehouseId
+                    AND DATE(t.shipped) BETWEEN DATE_ADD(:to, INTERVAL -2 DAY) AND :to
+                    AND t.refFk IS NULL
+                GROUP BY e.ticketFk)`, {
+                agencyModeId: reqArgs.agencyModeId,
+                warehouseId: reqArgs.warehouseId,
+                to: reqArgs.to
+            });
+
+            await closeAll(reqArgs);
+        } catch (error) {
+            next(error);
+        }
+    });
+
+    app.get('/api/closure/by-route', async function(req, res) {
+        try {
+            const reqArgs = req.args;
+            if (!reqArgs.routeId)
+                throw new Error('The argument routeId is required');
+
+            res.status(200).json({
+                message: 'Task executed successfully'
+            });
+
+            await db.rawSql(`DROP TEMPORARY TABLE IF EXISTS tmp.ticket_close`);
+            await db.rawSql(`
+            CREATE TEMPORARY TABLE tmp.ticket_close ENGINE = MEMORY (
+                SELECT 
+                    t.id AS ticketFk
+                FROM expedition e
+                    JOIN ticket t ON t.id = e.ticketFk
+                    JOIN ticketState ts ON ts.ticketFk = t.id
+                    JOIN alertLevel al ON al.alertLevel = ts.alertLevel
+                WHERE al.code = 'PACKED'
+                    AND t.routeFk = :routeId
+                    AND t.refFk IS NULL
+                GROUP BY e.ticketFk)`, {
+                routeId: reqArgs.routeId
+            });
+
+            await closeAll(reqArgs);
+        } catch (error) {
+            next(error);
+        }
+    });
+
+    async function closeAll(reqArgs) {
         const failedtickets = [];
         const tickets = await db.rawSql(`
             SELECT 
                 t.id,
                 t.clientFk,
                 c.email recipient,
-                c.isToBeMailed,
                 c.salesPersonFk,
+                c.isToBeMailed,
+                c.hasToInvoice,
+                co.hasDailyInvoice,
                 eu.email salesPersonEmail
-            FROM expedition e
-                JOIN ticket t ON t.id = e.ticketFk
+            FROM tmp.ticket_close tt
+                JOIN ticket t ON t.id = tt.ticketFk
                 JOIN client c ON c.id = t.clientFk
-                JOIN warehouse wh ON wh.id = t.warehouseFk AND wh.hasComission
-                JOIN ticketState ts ON ts.ticketFk = t.id
-                JOIN alertLevel al ON al.alertLevel = ts.alertLevel
-                LEFT JOIN account.emailUser eu ON eu.userFk = c.salesPersonFk
-            WHERE al.code = 'PACKED'
-                AND DATE(t.shipped) BETWEEN DATE_ADD(CURDATE(), INTERVAL -2 DAY) AND CURDATE()
-                AND t.refFk IS NULL
-            GROUP BY e.ticketFk`);
+                JOIN province p ON p.id = c.provinceFk
+                JOIN country co ON co.id = p.countryFk
+                LEFT JOIN account.emailUser eu ON eu.userFk = c.salesPersonFk`);
 
         for (const ticket of tickets) {
             try {
-                await db.rawSql(`CALL vn.ticket_closeByTicket(:ticketId)`, {
+                await db.rawSql(`CALL vn.ticket_close(:ticketId)`, {
                     ticketId: ticket.id
                 });
 
-                if (!ticket.salesPersonFk || !ticket.isToBeMailed) continue;
+                const hasToInvoice = ticket.hasToInvoice && ticket.hasDailyInvoice;
+                if (!ticket.salesPersonFk || !ticket.isToBeMailed || hasToInvoice) continue;
 
                 if (!ticket.recipient) {
                     const body = `No se ha podido enviar el albarán <strong>${ticket.id}</strong> 
@@ -54,7 +191,6 @@ module.exports = app => {
                     continue;
                 }
 
-                const reqArgs = req.args;
                 const args = Object.assign({
                     ticketId: ticket.id,
                     recipientId: ticket.clientFk,
@@ -88,5 +224,7 @@ module.exports = app => {
                 html: body
             });
         }
-    });
+
+        await db.rawSql(`DROP TEMPORARY TABLE tmp.ticket_close`);
+    }
 };