CHANGELOG.md

@@ -5,22 +5,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [24.16.01] - 2024-04-18
+
 ## [2414.01] - 2024-04-04
 
-### Added
-
-### Changed
-
-### Fixed
-
 ## [2408.01] - 2024-02-22
 
-### Added
-
-### Changed
-
-### Fixed
-
 ## [2406.01] - 2024-02-08
 
 ### Added

db/changes/240404/00-revokeMailAliasAccount.sql

@@ -1,5 +0,0 @@
-DELETE FROM salix.ACL
-	WHERE model = 'MailAliasAccount'
-		AND property = 'canEditAlias'
-		AND principalType = 'ROLE'
-		AND principalId = 'marketingBoss';

db/dump/fixtures.before.sql

@@ -2400,7 +2400,8 @@ INSERT INTO `vn`.`dmsType`(`id`, `name`, `readRoleFk`, `writeRoleFk`, `code`)
         (18, 'dua',                 NULL,   NULL,   'dua'),
         (19, 'inmovilizado',        NULL,   NULL,   'fixedAssets'),
         (20, 'Reclamación',         1,      1,      'claim'),
-        (21, 'Entrada',             1,      1,      'entry');
+        (21, 'Entrada',             1,      1,      'entry'),
+		(22, 'Proveedor',           1,      1,      'supplier');
 
 INSERT INTO `vn`.`dms`(`id`, `dmsTypeFk`, `file`, `contentType`, `workerFk`, `warehouseFk`, `companyFk`, `hardCopyNumber`, `hasFile`, `reference`, `description`, `created`)
     VALUES
@@ -2412,7 +2413,8 @@ INSERT INTO `vn`.`dms`(`id`, `dmsTypeFk`, `file`, `contentType`, `workerFk`, `wa
         (6, 5,  '6.txt', 'text/plain', 5, 1, 442, NULL, TRUE, 'NotExists',       'DoesNotExists',                               util.VN_CURDATE()),
         (7, 20, '7.jpg', 'image/jpeg', 9, 1, 442, NULL, FALSE, '1',              'TICKET ID  DEL CLIENTE BRUCE WAYNE ID 1101',  util.VN_CURDATE()),
         (8, 20, '8.mp4', 'video/mp4',  9, 1, 442, NULL, FALSE, '1',              'TICKET ID  DEL CLIENTE BRUCE WAYNE ID 1101',  util.VN_CURDATE()),
-        (9, 21, '7.jpg', 'image/jpeg', 9, 1, 442, NULL, FALSE, '1',              'ENTRADA ID 1',                                util.VN_CURDATE());
+        (9, 21, '7.jpg', 'image/jpeg', 9, 1, 442, NULL, FALSE, '1',              'ENTRADA ID 1',                                util.VN_CURDATE()),
+		(10, 21, '7.jpg', 'image/jpeg', 9, 1, 442, NULL, FALSE, '1',             'ENTRADA DE PRUEBA',                          util.VN_CURDATE());
 
 INSERT INTO `vn`.`claimDms`(`claimFk`, `dmsFk`)
     VALUES
@@ -2802,7 +2804,7 @@ INSERT INTO `vn`.`packingSiteConfig` (`id`, `shinobiUrl`, `shinobiToken`, `shino
 INSERT INTO `util`.`notificationConfig`
 	SET `id` = 1,
         `cleanDays` = 90;
-
+TRUNCATE `util`.`notification`;
 INSERT INTO `util`.`notification` (`id`, `name`, `description`)
     VALUES
         (1, 'print-email', 'notification fixture one'),
@@ -2813,6 +2815,7 @@ INSERT INTO `util`.`notification` (`id`, `name`, `description`)
         (6, 'book-entry-deleted', 'accounting entries deleted'),
         (7, 'zone-included','An email to notify zoneCollisions');
 
+TRUNCATE `util`.`notificationAcl`;
 INSERT INTO `util`.`notificationAcl` (`notificationFk`, `roleFk`)
     VALUES
         (1, 9),
@@ -2824,11 +2827,13 @@ INSERT INTO `util`.`notificationAcl` (`notificationFk`, `roleFk`)
         (6, 9),
         (7, 9);
 
+TRUNCATE `util`.`notificationQueue`;
 INSERT INTO `util`.`notificationQueue` (`id`, `notificationFk`, `params`, `authorFk`, `status`, `created`)
     VALUES
         (1, 'print-email', '{"id": "1"}', 9, 'pending', util.VN_CURDATE()),
         (2, 'print-email', '{"id": "2"}', null, 'pending', util.VN_CURDATE()),
         (3, 'print-email', null, null, 'pending', util.VN_CURDATE());
+TRUNCATE `util`.`notificationSubscription`;
 
 INSERT INTO `util`.`notificationSubscription` (`notificationFk`, `userFk`)
     VALUES
@@ -3738,6 +3743,10 @@ INSERT INTO vn.parkingLog(originFk, userFk, `action`, creationDate, description,
 INSERT INTO vn.ticketLog (originFk,userFk,`action`,creationDate,changedModel,newInstance,changedModelId,changedModelValue)
 	VALUES (18,9,'insert','2001-01-01 11:01:00.000','Ticket','{"isDeleted":true}',45,'Super Man');
 
+INSERT INTO `vn`.`supplierDms`(`supplierFk`, `dmsFk`, `editorFk`)
+    VALUES
+        (1, 10, 9);
+
 INSERT INTO `vn`.`accountReconciliation` (supplierAccountFk,operationDated,valueDated,amount,concept,debitCredit,calculatedCode,created) 
 	VALUES
 		(241,'2023-12-13 00:00:00.000','2023-12-07 00:00:00.000',19.36,'BEL 1',1,'2','2023-12-14 08:39:53.000'),

db/routines/hedera/procedures/catalog_calcFromMyAddress.sql

@@ -32,7 +32,7 @@ BEGIN
 			WHERE c.available > 0
 			GROUP BY c.item_id;
  
-	CALL vn.catalog_calculate(vDelivery, vAddress, vAgencyMode);
+	CALL vn.catalog_calculate(vDelivery, vAddress, vAgencyMode, FALSE);
 
 	DROP TEMPORARY TABLE tmp.item;
 END$$

db/routines/hedera/procedures/item_calcCatalog.sql

@@ -16,7 +16,7 @@ BEGIN
 		ENGINE = MEMORY 
 		SELECT vSelf itemFk;
 
-	CALL vn.catalog_calculate(vLanded, vAddressFk, vAgencyModeFk);
+	CALL vn.catalog_calculate(vLanded, vAddressFk, vAgencyModeFk, FALSE);
 
 	SELECT l.warehouseFk, w.name warehouse,
 			p.`grouping`, p.price, p.rate, l.available

db/routines/hedera/procedures/order_calcCatalog.sql

@@ -27,7 +27,7 @@ BEGIN
 			WHERE orderFk = vSelf
 			GROUP BY itemFk;
 		
-	CALL vn.catalog_calculate(vDate, vAddress, vAgencyMode);
+	CALL vn.catalog_calculate(vDate, vAddress, vAgencyMode, FALSE);
 
 	DROP TEMPORARY TABLE tmp.item;
 END$$

db/routines/hedera/procedures/order_calcCatalogFull.sql

@@ -22,7 +22,7 @@ BEGIN
 		FROM `order`
 		WHERE id = vSelf;
 
-	CALL vn.catalog_calculate(vDate, vAddress, vAgencyMode);
+	CALL vn.catalog_calculate(vDate, vAddress, vAgencyMode, FALSE);
 
 	IF account.myUser_getName() = 'visitor' THEN
 		UPDATE tmp.ticketCalculateItem

db/routines/vn/functions/addressTaxArea.sql

@@ -20,6 +20,7 @@ BEGIN
 
 	CALL vn.addressTaxArea();
 	SELECT areaFk INTO vTaxArea FROM tmp.addressTaxArea;
+
 	DROP TEMPORARY TABLE
 		tmp.addressCompany,
 		tmp.addressTaxArea;

db/routines/vn/functions/getSpecialPrice.sql

@@ -8,13 +8,16 @@ BEGIN
 
 	SELECT rate3 INTO price
 		FROM vn.priceFixed
-		WHERE itemFk = vItemFk 
+		WHERE itemFk = vItemFk
 			AND util.VN_CURDATE() BETWEEN started AND ended ORDER BY created DESC LIMIT 1;
 
-	SELECT `value` INTO price 
+	SELECT `value` INTO price
 		FROM vn.specialPrice
-		WHERE itemFk =  vItemFk 
-			AND clientFk = vClientFk ;
+		WHERE itemFk = vItemFk
+			AND (clientFk = vClientFk OR clientFk IS NULL)
+            AND started <= util.VN_CURDATE()
+            AND (ended >= util.VN_CURDATE() OR ended IS NULL)
+        ORDER BY id DESC LIMIT 1;
 RETURN price;
 END$$
 DELIMITER ;

db/routines/vn/procedures/boxPicking_print.sql

@@ -0,0 +1,283 @@
+DELIMITER $$
+$$
+CREATE OR REPLACE PROCEDURE vn.sale_boxPickingPrint(
+	IN vPrinterFk INT,
+	IN vSaleFk INT,
+	IN vPacking INT,
+	IN vSectorFk INT,
+	IN vUserFk INT,
+	IN vPackagingFk INT,
+	IN vPackingSiteFk INT)
+BEGIN
+/** Splits a line of sale to a different ticket and prints the transport sticker
+ */
+	DECLARE vAgencyModeFk INT;
+	DECLARE vConcept VARCHAR(30);
+	DECLARE vExpeditionFk INT;
+	DECLARE vItemFk INT;
+	DECLARE vItemShelvingFk INT;
+	DECLARE vItemShelvingSaleFk INT;
+	DECLARE vItemShelvingSaleFk_old INT;
+	DECLARE vLastExpeditionTimeStamp DATETIME;
+	DECLARE vMaxPhoneLength INT DEFAULT 11;
+	DECLARE vMaxStreetLength INT DEFAULT 36;
+	DECLARE vNewSaleFk INT;
+	DECLARE vNewTicketFk INT;
+	DECLARE vParkingCode VARCHAR(10);
+	DECLARE vQuantity INT;
+	DECLARE vRemainder INT DEFAULT 0;
+	DECLARE vRemainderSaleFk INT;
+	DECLARE vShelving VARCHAR(10);
+	DECLARE vTicketFk INT;
+
+	SELECT 	s.quantity,
+			s.quantity MOD vPacking,
+			s.ticketFk,
+			s.itemFk,
+			s.concept
+		INTO vQuantity,
+			vRemainder,
+			vTicketFk,
+			vItemFk,
+			vConcept
+		FROM sale s
+		WHERE s.id = vSaleFk;
+
+	IF vRemainder THEN
+		UPDATE sale SET quantity = quantity - vRemainder WHERE id = vSaleFk;
+
+		INSERT INTO sale(ticketFk, itemFk, quantity, price, discount, concept)
+			SELECT ticketFk, itemFk, vRemainder, price, discount, concept
+				FROM sale 
+				WHERE id = vSaleFk;
+
+		SET vRemainderSaleFk = LAST_INSERT_ID();
+
+		INSERT INTO saleComponent(saleFk, componentFk, value)
+			SELECT vRemainderSaleFk, componentFk, value
+				FROM saleComponent	
+				WHERE saleFk = vSaleFk;
+	END IF;
+
+w1:	WHILE vQuantity >= vPacking DO
+
+		SET vItemShelvingFk = NULL;
+
+		SELECT sub.id
+			INTO vItemShelvingFk
+			FROM productionConfig pc
+				JOIN (
+					SELECT ish.id,
+						ish.visible - IFNULL(SUM(iss.quantity),0) available,
+						p.pickingOrder,
+						ish.created
+						FROM itemShelving ish 
+							JOIN shelving sh ON sh.code = ish.shelvingFk
+							JOIN parking p ON p.id = sh.parkingFk
+							LEFT JOIN itemShelvingSale iss
+								ON iss.itemShelvingFk = ish.id
+								AND iss.created >= CURDATE()
+								AND iss.isPicked = FALSE
+						WHERE ish.itemFk = vItemFk
+							AND p.sectorFk = vSectorFk
+						GROUP BY ish.id
+						HAVING available >= vPacking) sub
+			ORDER BY IF(pc.orderMode = 'Location',sub.pickingOrder, sub.created)
+			LIMIT 1;
+
+		IF vItemShelvingFk THEN
+			INSERT INTO itemShelvingSale
+				SET itemShelvingFk = vItemShelvingFk,
+					saleFk = vSaleFk,
+					quantity = vPacking,
+					userFk = vUserFk,
+					isPicked = TRUE;
+
+			SET vItemShelvingSaleFk = LAST_INSERT_ID();
+
+			UPDATE sale SET isPicked = FALSE WHERE id = vSaleFk;
+		ELSE
+			LEAVE w1;
+		END IF;
+
+		SET vNewTicketFk = NULL;
+
+		SELECT MAX(t.id) INTO vNewTicketFk
+			FROM ticket t 
+				JOIN ticketLastState tls ON tls.ticketFk = t.id
+				JOIN (SELECT addressFk, clientFk, date(shipped) shipped, warehouseFk
+						FROM ticket 
+						WHERE id = vTicketFk) tt 
+							ON tt.addressFk = t.addressFk
+							AND tt.clientFk = t.clientFk 
+							AND t.shipped BETWEEN tt.shipped AND util.dayend(tt.shipped)
+							AND t.warehouseFk = tt.warehouseFk
+				WHERE tls.name = 'Encajado' ;
+
+		IF ISNULL(vNewTicketFk) THEN
+			INSERT INTO ticket(	clientFk,
+									shipped,
+									addressFk,
+									agencyModeFk,
+									nickname,
+									warehouseFk,
+									companyFk,
+									landed,
+									zoneFk,
+									zonePrice,
+									zoneBonus,
+									routeFk,
+									priority,
+									hasPriority,
+									clonedFrom) 
+				SELECT 	clientFk,
+						shipped,
+						addressFk,
+						agencyModeFk,
+						nickname,
+						warehouseFk,
+						companyFk,
+						landed,
+						zoneFk,
+						zonePrice,
+						zoneBonus,
+						routeFk,
+						priority,
+						hasPriority,
+						id
+					FROM ticket 
+					WHERE id = vTicketFk;
+
+			SET vNewTicketFk = LAST_INSERT_ID();
+
+			INSERT INTO ticketTracking(ticketFk, stateFk, userFk)
+				SELECT vNewTicketFk, id, vUserFk
+					FROM state 
+					WHERE code = 'PACKED';
+		END IF;
+
+		UPDATE sale SET quantity = quantity - vPacking WHERE id = vSaleFk;
+
+		UPDATE itemShelving SET visible = visible - vPacking WHERE id = vItemShelvingFk;
+
+		SET vNewSaleFk = NULL;
+
+		SELECT MAX(id) INTO vNewSaleFk
+			FROM sale
+			WHERE ticketFk = vNewTicketFk
+				AND itemFk = vItemFk;
+
+		IF vNewSaleFk THEN
+			UPDATE sale
+				SET quantity = quantity + vPacking
+				WHERE id = vNewSaleFk;
+
+			SET vItemShelvingSaleFk_old = NULL;
+
+			SELECT MAX(id) INTO vItemShelvingSaleFk_old
+				FROM itemShelvingSale 
+				WHERE itemShelvingFk = vItemShelvingFk
+					AND saleFk = vNewSaleFk;
+
+			IF vItemShelvingSaleFk_old THEN
+				UPDATE itemShelvingSale 
+					SET quantity = quantity + vPacking 
+					WHERE id = vItemShelvingSaleFk_old;
+
+				DELETE FROM itemShelvingSale 
+					WHERE id = vItemShelvingSaleFk;
+
+				SET vItemShelvingSaleFk = vItemShelvingSaleFk_old;
+			ELSE
+				UPDATE itemShelvingSale
+					SET saleFk = vNewSaleFk
+					WHERE id = vItemShelvingSaleFk;
+			END IF;
+		ELSE
+			INSERT INTO sale(ticketFk, itemFk, concept, quantity, discount, price)
+				SELECT vNewTicketFk, itemFk, concept, vPacking, discount, price 
+					FROM sale
+					WHERE id = vSaleFk;
+
+			SET vNewSaleFk = LAST_INSERT_ID();
+
+			INSERT INTO saleComponent(saleFk, componentFk, value, isGreuge)
+				SELECT vNewSaleFk, componentFk, value, isGreuge
+					FROM saleComponent
+					WHERE saleFk = vSaleFk;
+
+			UPDATE itemShelvingSale 
+				SET saleFk = vNewSaleFk
+				WHERE id = vItemShelvingSaleFk;
+		END IF;
+
+		INSERT IGNORE INTO saleTracking(saleFk, isChecked, workerFk, stateFk)
+			SELECT vNewSaleFk, TRUE, vUserFk, id
+				FROM state 
+				WHERE code = 'PREPARED';
+
+		SELECT agencyModeFk INTO vAgencyModeFk
+			FROM ticket 
+			WHERE id = vNewTicketFk;
+
+		INSERT INTO expedition(
+									agencyModeFk,
+									ticketFk,
+									freightItemFk,
+									workerFk,
+									packagingFk,
+									itemPackingTypeFk,
+									hostFk,
+									packingSiteFk,
+									monitorId,
+									started,
+									ended
+								)
+			SELECT	vAgencyModeFk,
+					vNewTicketFk,
+					i.id,
+					vUserFk, 
+					vPackagingFk,
+					ps.code,
+					h.code,
+					vPackingSiteFk,
+					ps.monitorId,
+					IFNULL(vLastExpeditionTimeStamp, NOW()),
+					NOW()
+				FROM packingSite ps
+					JOIN host h ON h.id = ps.hostFk
+					JOIN item i ON i.name = 'Shipping cost'
+				WHERE ps.id = vPackingSiteFk
+				LIMIT 1;
+
+		SET vExpeditionFk = LAST_INSERT_ID();
+
+		SET vLastExpeditionTimeStamp = NOW();
+
+		CALL dipole.expedition_Add(vExpeditionFk,vPrinterFk, TRUE);
+
+		SELECT shelvingFk, p.code 
+			INTO vShelving, vParkingCode
+			FROM itemShelving ish
+				JOIN shelving sh ON sh.code = ish.shelvingFk
+				JOIN parking p ON p.id = sh.parkingFk
+			WHERE ish.id = vItemShelvingFk;
+
+		UPDATE dipole.expedition_PrintOut 
+			SET	isPrinted = FALSE,
+				itemFk = vItemFk,
+				quantity = vPacking,
+				longName = vConcept,
+				shelvingFk = vShelving,
+				parkingCode = vParkingCode,
+				phone = RIGHT(phone,vMaxPhoneLength),
+				street = RIGHT(street, vMAxStreetLength)
+			WHERE expeditionFk = vExpeditionFk;
+
+		DELETE FROM sale
+			WHERE quantity = 0
+				AND id = vSaleFk;
+	END WHILE;
+
+END$$
+DELIMITER ;

db/routines/vn/procedures/catalog_calcFromItem.sql

@@ -20,7 +20,7 @@ BEGIN
 		ENGINE = MEMORY 
 		SELECT vItemFk itemFk;
 
-	CALL catalog_calculate(vLanded, vAddressFk, vAgencyModeFk);
+	CALL catalog_calculate(vLanded, vAddressFk, vAgencyModeFk, TRUE);
 	DROP TEMPORARY TABLE tmp.item;
 END$$
 DELIMITER ;

db/routines/vn/procedures/catalog_calculate.sql

@@ -1,5 +1,9 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`catalog_calculate`(vLanded DATE, vAddressFk INT, vAgencyModeFk INT)
+CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`catalog_calculate`(
+	vLanded DATE,
+	vAddressFk INT,
+	vAgencyModeFk INT,
+	vShowExpiredZones BOOLEAN)
 BEGIN	
 /**
  * Calcula los articulos disponibles y sus precios
@@ -25,7 +29,7 @@ BEGIN
 
 	DECLARE CONTINUE HANDLER FOR NOT FOUND SET vDone = TRUE;
 
-	CALL vn.zone_getShipped (vLanded, vAddressFk, vAgencyModeFk, FALSE);
+	CALL vn.zone_getShipped (vLanded, vAddressFk, vAgencyModeFk, vShowExpiredZones);
 
 	DROP TEMPORARY TABLE IF EXISTS tmp.ticketLot;
 	CREATE TEMPORARY TABLE tmp.ticketLot(

db/routines/vn/procedures/catalog_componentCalculate.sql

@@ -10,7 +10,7 @@ BEGIN
  * Calcula los componentes de los articulos de tmp.ticketLot
  *
  * @param vZoneFk para calcular el transporte
- * @param vAddressFk Consignatario 
+ * @param vAddressFk Consignatario
  * @param vShipped dia de salida del pedido
  * @param vWarehouseFk warehouse de salida del pedido
  * @table tmp.ticketLot (warehouseFk, available, itemFk, buyFk, zoneFk)
@@ -24,7 +24,20 @@ BEGIN
 	SELECT clientFk INTO vClientFK
 		FROM address
 		WHERE id = vAddressFk;
-	
+
+    CREATE OR REPLACE TEMPORARY TABLE tSpecialPrice
+	(INDEX (itemFk))
+    ENGINE = MEMORY
+    SELECT * FROM (
+		SELECT *
+            FROM specialPrice
+            WHERE (clientFk = vClientFk OR clientFk IS NULL)
+                AND started <= vShipped
+                AND (ended >= vShipped OR ended IS NULL)
+            ORDER BY (clientFk = vClientFk) DESC, id DESC
+            LIMIT 10000000000000000000) t
+        GROUP BY itemFk;
+
 	CREATE OR REPLACE TEMPORARY TABLE tmp.ticketComponentCalculate
 	(PRIMARY KEY (itemFk, warehouseFk))
 	ENGINE = MEMORY
@@ -36,7 +49,7 @@ BEGIN
 			IFNULL(pf.packing, GREATEST(b.grouping, b.packing)) packing,
 			IFNULL(pf.`grouping`, b.`grouping`) `grouping`,
 			ABS(IFNULL(pf.box, b.groupingMode)) groupingMode,
-			tl.buyFk, 
+			tl.buyFk,
 			i.typeFk,
 			IF(i.hasKgPrice, b.weight / b.packing, NULL) weightGrouping
 		FROM tmp.ticketLot tl
@@ -44,8 +57,7 @@ BEGIN
 			JOIN item i ON i.id = tl.itemFk
 			JOIN itemType it ON it.id = i.typeFk
 			JOIN itemCategory ic ON ic.id = it.categoryFk
-			LEFT JOIN specialPrice sp ON sp.itemFk = i.id 
-				AND sp.clientFk = vClientFk
+			LEFT JOIN tSpecialPrice sp ON sp.itemFk = i.id
 			LEFT JOIN (
 					SELECT * FROM (
 						SELECT 	pf.itemFk,
@@ -63,7 +75,7 @@ BEGIN
 							LIMIT 10000000000000000000
 								) tpf
 						GROUP BY tpf.itemFk, tpf.warehouseFk
-						) pf ON pf.itemFk = tl.itemFk 
+						) pf ON pf.itemFk = tl.itemFk
 								AND pf.warehouseFk = tl.warehouseFk
 		WHERE b.buyingValue + b.freightValue + b.packageValue + b.comissionValue > 0.01
 			AND ic.merchandise
@@ -95,10 +107,10 @@ BEGIN
 			FROM tmp.ticketComponent tc
 				JOIN tmp.ticketComponentCalculate tcc ON tcc.itemFk = tc.itemFk AND tcc.warehouseFk = tc.warehouseFk
 			GROUP BY tc.itemFk, warehouseFk;
-			
+
 	-- RECOBRO
 	INSERT INTO tmp.ticketComponent(warehouseFk, itemFk, componentFk, cost)
-		SELECT tcb.warehouseFk, tcb.itemFk, c2.id, 
+		SELECT tcb.warehouseFk, tcb.itemFk, c2.id,
 			ROUND(tcb.base *
 							LEAST(
 								MAX(GREATEST(IFNULL(cr.priceIncreasing,0),
@@ -129,29 +141,29 @@ BEGIN
 				ROUND(base * wm.pricesModifierRate, 3) manaAuto
 			FROM tmp.ticketComponentBase tcb
 				JOIN `client` c on c.id = vClientFk
-				JOIN workerMana wm ON c.salesPersonFk = wm.workerFk 
+				JOIN workerMana wm ON c.salesPersonFk = wm.workerFk
 				JOIN vn.component c2 ON c2.code = 'autoMana'
 			WHERE wm.isPricesModifierActivated
 			HAVING manaAuto <> 0;
-	
+
 	-- Precios especiales
 	INSERT INTO tmp.ticketComponent(warehouseFk, itemFk, componentFk, cost)
 		SELECT tcb.warehouseFk,
 				tcb.itemFk,
 				c2.id,
 				GREATEST(
-						IFNULL(ROUND(tcb.base * c2.tax, 4), 0), 
+						IFNULL(ROUND(tcb.base * c2.tax, 4), 0),
 						IF(i.hasMinPrice, i.minPrice,0) - tcc.rate3
 						) cost
 			FROM tmp.ticketComponentBase tcb
 				JOIN vn.component c2 ON c2.code = 'lastUnitsDiscount'
-				JOIN tmp.ticketComponentCalculate tcc ON tcc.itemFk = tcb.itemFk AND tcc.warehouseFk = tcb.warehouseFk 
-				LEFT JOIN specialPrice sp ON sp.clientFk = vClientFk AND sp.itemFk = tcc.itemFk
+				JOIN tmp.ticketComponentCalculate tcc ON tcc.itemFk = tcb.itemFk AND tcc.warehouseFk = tcb.warehouseFk
+				LEFT JOIN tSpecialPrice sp ON sp.itemFk = tcc.itemFk
 				JOIN vn.item i ON i.id = tcb.itemFk
 			WHERE sp.value IS NULL
 				AND i.supplyResponseFk IS NULL;
 
-	-- Individual 
+	-- Individual
 	INSERT INTO tmp.ticketComponent(warehouseFk, itemFk, componentFk, cost)
 		SELECT	tcb.warehouseFk,
 				tcb.itemFk,
@@ -162,14 +174,14 @@ BEGIN
 				JOIN vn.client c ON c.id = vClientFk
 				JOIN vn.businessType bt ON bt.code = c.businessTypeFk
 			WHERE bt.code = 'individual';
-	
+
 	-- Venta por paquetes
 	INSERT INTO tmp.ticketComponent(warehouseFk, itemFk, componentFk, cost)
-		SELECT tcc.warehouseFk, tcc.itemFk, c2.id, tcc.rate2 - tcc.rate3 
+		SELECT tcc.warehouseFk, tcc.itemFk, c2.id, tcc.rate2 - tcc.rate3
 			FROM tmp.ticketComponentCalculate tcc
 				JOIN vn.component c2 ON c2.code = 'salePerPackage'
 				JOIN buy b ON b.id = tcc.buyFk
-			LEFT JOIN specialPrice sp ON sp.clientFk = vClientFk AND sp.itemFk = tcc.itemFk
+			LEFT JOIN tSpecialPrice sp ON sp.itemFk = tcc.itemFk
 		WHERE sp.value IS NULL;
 
 	CREATE OR REPLACE TEMPORARY TABLE tmp.`zone` (INDEX (id))
@@ -177,7 +189,7 @@ BEGIN
 		SELECT vZoneFk id;
 
 	CALL zone_getOptionsForShipment(vShipped, TRUE);
-	
+
 	-- Reparto
 	INSERT INTO tmp.ticketComponent
 		SELECT tcc.warehouseFK,
@@ -191,7 +203,7 @@ BEGIN
 			JOIN agencyMode am ON am.id = z.agencyModeFk
 			JOIN vn.volumeConfig vc
 			JOIN vn.component c2 ON c2.code = 'delivery'
-			LEFT JOIN itemCost ic ON ic.warehouseFk = tcc.warehouseFk 
+			LEFT JOIN itemCost ic ON ic.warehouseFk = tcc.warehouseFk
 				AND ic.itemFk = tcc.itemFk
 			HAVING cost <> 0;
 
@@ -208,7 +220,7 @@ BEGIN
 				sp.value - SUM(tcc.cost) sumCost
 			FROM tmp.ticketComponentCopy tcc
 				JOIN component c ON c.id = tcc.componentFk
-				JOIN specialPrice sp ON sp.clientFk = vClientFK AND sp.itemFk = tcc.itemFk
+				JOIN tSpecialPrice sp ON sp.itemFk = tcc.itemFk
 				JOIN vn.component c2 ON c2.code = 'specialPrices'
 			WHERE c.classRate IS NULL
 				AND tcc.warehouseFk = vWarehouseFk
@@ -244,9 +256,9 @@ BEGIN
 				CAST(SUM(tcs.sumCost) AS DECIMAL(10,2)) price,
 				CAST(SUM(tcs.sumCost) AS DECIMAL(10,2)) / weightGrouping priceKg
 			FROM tmp.ticketComponentCalculate tcc
-				JOIN tmp.ticketComponentSum tcs ON tcs.itemFk = tcc.itemFk 
+				JOIN tmp.ticketComponentSum tcs ON tcs.itemFk = tcc.itemFk
 					AND tcs.warehouseFk = tcc.warehouseFk
-			WHERE IFNULL(tcs.classRate, 1) = 1 
+			WHERE IFNULL(tcs.classRate, 1) = 1
 				AND tcc.groupingMode < 2 AND (tcc.packing > tcc.`grouping` or tcc.groupingMode = 0)
 			GROUP BY tcs.warehouseFk, tcs.itemFk;
 
@@ -283,12 +295,13 @@ BEGIN
 			SELECT * FROM tmp.ticketComponentRate ORDER BY price LIMIT 10000000000000000000
 		) t
 		GROUP BY itemFk, warehouseFk, `grouping`;
-	
+
 	DROP TEMPORARY TABLE
 		tmp.ticketComponentCalculate,
 		tmp.ticketComponentSum,
 		tmp.ticketComponentBase,
 		tmp.ticketComponentRate,
-		tmp.ticketComponentCopy;
+		tmp.ticketComponentCopy,
+        tSpecialPrice;
 END$$
 DELIMITER ;

db/routines/vn/procedures/clean.sql

@@ -12,7 +12,7 @@ BEGIN
 	DECLARE v1Years DATE DEFAULT util.VN_CURDATE() - INTERVAL 1 YEAR;
 	DECLARE v2Years DATE DEFAULT util.VN_CURDATE() - INTERVAL 2 YEAR;
 	DECLARE v4Years DATE DEFAULT util.VN_CURDATE() - INTERVAL 4 YEAR;
-	DECLARE v5Years DATE DEFAULT util.VN_CURDATE() - INTERVAL 5 YEAR;	
+	DECLARE v5Years DATE DEFAULT util.VN_CURDATE() - INTERVAL 5 YEAR;
 	DECLARE vTrashId VARCHAR(15);
 	DECLARE vCompanyBlk INT;
 
@@ -30,8 +30,9 @@ BEGIN
 	DELETE IGNORE FROM expedition WHERE created < v26Months;
 	DELETE FROM sms WHERE created < v18Months;
 	DELETE FROM saleTracking WHERE created < v1Years;
+	DELETE FROM productionError WHERE dated < v1Years;
 	DELETE FROM ticketTracking WHERE created < v18Months;
-	DELETE tobs FROM ticketObservation tobs 
+	DELETE tobs FROM ticketObservation tobs
 		JOIN ticket t ON tobs.ticketFk = t.id
 		WHERE t.shipped < v5Years;
 	DELETE sc.* FROM saleCloned sc JOIN sale s ON s.id = sc.saleClonedFk JOIN ticket t ON t.id = s.ticketFk WHERE t.shipped < v1Years;
@@ -113,12 +114,12 @@ BEGIN
 		FROM travel t
 			LEFT JOIN entry e ON e.travelFk = t.id
 		WHERE t.shipped < v3Months AND e.travelFk IS NULL;
-	
+
 	UPDATE dms d
-			JOIN dmsType dt ON dt.id = d.dmsTypeFk 
-		SET d.dmsTypeFk = vTrashId 
+			JOIN dmsType dt ON dt.id = d.dmsTypeFk
+		SET d.dmsTypeFk = vTrashId
 		WHERE created < util.VN_CURDATE() - INTERVAL dt.monthToDelete MONTH;
-	
+
 	-- borrar entradas sin compras
 	CREATE OR REPLACE TEMPORARY TABLE tEntryToDelete
 		SELECT e.*
@@ -136,7 +137,7 @@ BEGIN
 	CREATE OR REPLACE TEMPORARY TABLE tRouteToDelete
 		SELECT *
 			FROM route r
-			WHERE created < v4Years;   
+			WHERE created < v4Years;
 
 	UPDATE tRouteToDelete tmp
 			JOIN dms d ON d.id = tmp.gestdocFk
@@ -180,7 +181,7 @@ BEGIN
 	DELETE FROM mail WHERE creationDate < v2Months;
 	DELETE FROM split WHERE dated < v18Months;
 	DELETE FROM remittance WHERE dated < v18Months;
-	
+
 	CREATE OR REPLACE TEMPORARY TABLE tTicketDelete
 		SELECT DISTINCT tl.originFk ticketFk
 			FROM ticketLog tl
@@ -189,11 +190,11 @@ BEGIN
 						FROM ticket t
 							JOIN ticketLog tl ON tl.originFk = t.id
 							LEFT JOIN ticketWeekly tw ON tw.ticketFk = t.id
-						WHERE t.shipped BETWEEN '2000-01-01' AND '2000-12-31' 
+						WHERE t.shipped BETWEEN '2000-01-01' AND '2000-12-31'
 							AND t.isDeleted
 							AND tw.ticketFk IS NULL
 						GROUP BY t.id
-				) sub ON sub.ids = tl.id 
+				) sub ON sub.ids = tl.id
 			WHERE tl.creationDate <= v2Months;
 	DELETE t
 		FROM ticket t

db/routines/vn/procedures/collection_new.sql

@@ -28,6 +28,7 @@ proc:BEGIN
 	DECLARE vLockName VARCHAR(215);
 	DECLARE vLockTime INT DEFAULT 15;
 	DECLARE vFreeWagonFk INT;
+
 	DECLARE c1 CURSOR FOR
 		SELECT ticketFk, `lines`, m3
 			FROM tmp.productionBuffer
@@ -44,13 +45,21 @@ proc:BEGIN
 
 	DECLARE CONTINUE HANDLER FOR NOT FOUND SET vDone = TRUE;
 
+	DECLARE EXIT HANDLER FOR SQLEXCEPTION
+	BEGIN
+		IF vLockName IS NOT NULL THEN
+			DO RELEASE_LOCK(vLockName);
+		END IF;
+
+		RESIGNAL;
+	END;
+
 	SELECT pc.ticketTrolleyMax * o.numberOfWagons,
 			pc.hasUniqueCollectionTime,
 			w.code,
 			o.warehouseFk,
 			o.itemPackingTypeFk,
 			st.code,
-			CONCAT('collection_new', o.warehouseFk, ':',o.itemPackingTypeFk),
 			o.numberOfWagons,
 			o.trainFk,
 			o.linesLimit,
@@ -61,7 +70,6 @@ proc:BEGIN
 				vWarehouseFk,
 				vItemPackingTypeFk,
 				vStateFk,
-				vLockName,
 				vWagons,
 				vTrainFk,
 				vLinesLimit,
@@ -71,6 +79,12 @@ proc:BEGIN
 			JOIN state st ON st.`code` = 'ON_PREPARATION'
 			JOIN operator o ON o.workerFk = vUserFk;
 
+	SET vLockName = CONCAT_WS('/',
+		'collection_new',
+		vWarehouseFk,
+		vItemPackingTypeFk
+	);
+
 	IF NOT GET_LOCK(vLockName, vLockTime) THEN
 		LEAVE proc;
 	END IF;
@@ -250,13 +264,13 @@ proc:BEGIN
 					UPDATE tTrain
 						SET ticketFk = vFirstTicketFk
 						WHERE wagon = vFreeWagonFk;
-	
+
 					-- Se anulan el resto de carros libres para que sólo uno lleve un pedido excesivo
 					DELETE tt.*
 						FROM tTrain tt
 							LEFT JOIN (
-								SELECT DISTINCT wagon 
-									FROM tTrain 
+								SELECT DISTINCT wagon
+									FROM tTrain
 									WHERE ticketFk IS NOT NULL
 							) nn ON nn.wagon = tt.wagon
 						WHERE nn.wagon IS NULL;
@@ -271,7 +285,7 @@ proc:BEGIN
 			FETCH c1 INTO vTicketFk, vTicketLines, vTicketVolume;
 			IF vDone THEN
 				LEAVE read_loop;
-			END IF;		
+			END IF;
 		END IF;
 	END LOOP;
 	CLOSE c1;

db/routines/vn/procedures/company_getSuppliersDebt.sql

@@ -7,81 +7,81 @@ BEGIN
  * @param vSelf company id
  * @param vMonthAgo time interval to be consulted
  */
-	DECLARE vStartingDate DATETIME DEFAULT TIMESTAMPADD (MONTH,- vMonthsAgo,util.VN_CURDATE());
-	DECLARE vCurrencyEuroFk INT;
-	DECLARE vStartDate DATE;
-	DECLARE vInvalidBalances DOUBLE;
+    DECLARE vStartingDate DATETIME DEFAULT TIMESTAMPADD (MONTH,- vMonthsAgo,util.VN_CURDATE());
+    DECLARE vCurrencyEuroFk INT;
+    DECLARE vStartDate DATE;
+    DECLARE vInvalidBalances DOUBLE;
 
-	SELECT dated, invalidBalances INTO vStartDate, vInvalidBalances  FROM supplierDebtConfig;
-	SELECT id INTO vCurrencyEuroFk FROM currency WHERE code = 'EUR';
+    SELECT dated, invalidBalances INTO vStartDate, vInvalidBalances  FROM supplierDebtConfig;
+    SELECT id INTO vCurrencyEuroFk FROM currency WHERE code = 'EUR';
 
-	DROP TEMPORARY TABLE IF EXISTS tOpeningBalances;
-	CREATE TEMPORARY TABLE tOpeningBalances (
-		supplierFk INT NOT NULL,
-		companyFk INT NOT NULL,
-		openingBalances DOUBLE NOT NULL,
-		closingBalances DOUBLE NOT NULL,
-		currencyFk INT NOT NULL,
-		PRIMARY KEY (supplierFk, companyFk, currencyFk)
-	) ENGINE = MEMORY;
+    DROP TEMPORARY TABLE IF EXISTS tOpeningBalances;
+    CREATE TEMPORARY TABLE tOpeningBalances (
+        supplierFk INT NOT NULL,
+        companyFk INT NOT NULL,
+        openingBalances DOUBLE NOT NULL,
+        closingBalances DOUBLE NOT NULL,
+        currencyFk INT NOT NULL,
+        PRIMARY KEY (supplierFk, companyFk, currencyFk)
+    ) ENGINE = MEMORY;
 
-	-- Calculates the opening and closing balance for each supplier
-	INSERT INTO tOpeningBalances
-		SELECT supplierFk,
-			companyFk,
-			SUM(amount * isBeforeStarting) AS openingBalances,
-			SUM(amount) closingBalances,
-			currencyFk
-			FROM (
-				SELECT p.supplierFk,
+    -- Calculates the opening and closing balance for each supplier
+    INSERT INTO tOpeningBalances
+        SELECT supplierFk,
+            companyFk,
+            SUM(amount * isBeforeStarting) AS openingBalances,
+            SUM(amount) closingBalances,
+            currencyFk
+            FROM (
+                SELECT p.supplierFk,
                         p.companyFk,
                         IF (p.currencyFk = vCurrencyEuroFk, p.amount, p.divisa) AS amount,
                         p.dueDated < vStartingDate isBeforeStarting,
                         p.currencyFk
-					FROM payment p 
-					WHERE p.received > vStartDate
-						AND p.companyFk = vSelf
-					UNION ALL
-				SELECT r.supplierFk,
+                    FROM payment p
+                    WHERE p.received > vStartDate
+                        AND p.companyFk = vSelf
+                    UNION ALL
+                SELECT r.supplierFk,
                         r.companyFk,
                         - IF (r.currencyFk = vCurrencyEuroFk, rv.amount, rv.foreignValue) AS Total,
                         rv.dueDated < vStartingDate isBeforeStarting,
-                        r.currencyFk 
-					FROM invoiceIn r 
-						INNER JOIN invoiceInDueDay rv ON r.id = rv.invoiceInFk 
-					WHERE r.issued > vStartDate
-						AND r.isBooked
-						AND r.companyFk = vSelf
-			) sub GROUP BY companyFk, supplierFk, currencyFk;
+                        r.currencyFk
+                    FROM invoiceIn r
+                        INNER JOIN invoiceInDueDay rv ON r.id = rv.invoiceInFk
+                    WHERE r.issued > vStartDate
+                        AND r.isBooked
+                        AND r.companyFk = vSelf
+            ) sub GROUP BY companyFk, supplierFk, currencyFk;
 
-	DROP TEMPORARY TABLE IF EXISTS tPendingDuedates;
-	CREATE TEMPORARY TABLE tPendingDuedates (
-		id INT auto_increment,
+    DROP TEMPORARY TABLE IF EXISTS tPendingDuedates;
+    CREATE TEMPORARY TABLE tPendingDuedates (
+        id INT auto_increment,
         expirationId INT,
-		dated DATE,
-		supplierFk INT NOT NULL,
-		companyFk INT NOT NULL,
-		amount DECIMAL(10, 2) NOT NULL,
-		currencyFk INT NOT NULL,
-		pending DECIMAL(10, 2) DEFAULT 0,
-		balance DECIMAL(10, 2) DEFAULT 0,
-		endingBalance DECIMAL(10, 2) DEFAULT 0,
-		isPayment BOOLEAN,
-		isReconciled BOOLEAN,
-		PRIMARY KEY (id),
-		INDEX (supplierFk, companyFk, currencyFk)
-	) ENGINE = MEMORY;
+        dated DATE,
+        supplierFk INT NOT NULL,
+        companyFk INT NOT NULL,
+        amount DECIMAL(10, 2) NOT NULL,
+        currencyFk INT NOT NULL,
+        pending DECIMAL(10, 2) DEFAULT 0,
+        balance DECIMAL(10, 2) DEFAULT 0,
+        endingBalance DECIMAL(10, 2) DEFAULT 0,
+        isPayment BOOLEAN,
+        isReconciled BOOLEAN,
+        PRIMARY KEY (id),
+        INDEX (supplierFk, companyFk, currencyFk)
+    ) ENGINE = MEMORY;
 
-	INSERT INTO tPendingDuedates (
-		expirationId,
-		dated,
-		supplierFk,
-		companyFk,
-		amount,
-		currencyFk,
-		isPayment,
-		isReconciled
-	)SELECT p.id,
+    INSERT INTO tPendingDuedates (
+        expirationId,
+        dated,
+        supplierFk,
+        companyFk,
+        amount,
+        currencyFk,
+        isPayment,
+        isReconciled
+    )SELECT p.id,
             p.dueDated,
             p.supplierFk,
             p.companyFk,
@@ -100,80 +100,80 @@ BEGIN
             -IF (r.currencyFk = vCurrencyEuroFk, rv.amount, rv.foreignValue),
             r.currencyFk,
             FALSE isPayment,
-            TRUE 
-        FROM invoiceIn r 
+            TRUE
+        FROM invoiceIn r
             LEFT JOIN tOpeningBalances si ON r.companyFk = si.companyFk
                 AND r.supplierFk = si.supplierFk
-                AND r.currencyFk = si.currencyFk 
+                AND r.currencyFk = si.currencyFk
             JOIN invoiceInDueDay rv ON r.id = rv.invoiceInFk
         WHERE rv.dueDated >= vStartingDate
             AND (si.closingBalances IS NULL OR si.closingBalances <> 0)
             AND r.isBooked
             AND r.companyFk = vSelf
         ORDER BY supplierFk, companyFk, companyFk, dueDated, isPayment DESC, id;
-	-- Now, we calculate the outstanding amount for each receipt in descending order
-	SET @risk := 0.0;
-	SET @supplier := 0.0;
-	SET @company := 0.0;
-	SET @moneda := 0.0;
-	SET @pending := 0.0;
-	SET @day := util.VN_CURDATE();
+    -- Now, we calculate the outstanding amount for each receipt in descending order
+    SET @risk := 0.0;
+    SET @supplier := 0.0;
+    SET @company := 0.0;
+    SET @moneda := 0.0;
+    SET @pending := 0.0;
+    SET @day := util.VN_CURDATE();
 
-	UPDATE tPendingDuedates vp
-		LEFT JOIN tOpeningBalances si ON vp.companyFk = si.companyFk
-			AND vp.supplierFk = si.supplierFk
-			AND vp.currencyFk = si.currencyFk
-		SET vp.balance = @risk := (
-			IF (
-				@company <> vp.companyFk
-				OR @supplier <> vp.supplierFk
-				OR @moneda <> vp.currencyFk,
-				IFNULL(si.openingBalances, 0),
-				@risk
-				) +
-			vp.amount
-		),
-		-- if there is a change of company or supplier or currency, the balance is reset
-		vp.pending = @pending := IF (
-			@company <> vp.companyFk
-			OR @supplier <> vp.supplierFk
-			OR @moneda <> vp.currencyFk
-			OR @day <> vp.dated,
-			vp.amount * (NOT vp.isPayment),
-			@pending + vp.amount
-		),
-		vp.companyFk = @company := vp.companyFk,
-		vp.supplierFk = @supplier := vp.supplierFk,
-		vp.currencyFk = @moneda := vp.currencyFk,
-		vp.dated = @day := vp.dated,
-		vp.balance = @risk,
-		vp.pending = @pending;
+    UPDATE tPendingDuedates vp
+        LEFT JOIN tOpeningBalances si ON vp.companyFk = si.companyFk
+            AND vp.supplierFk = si.supplierFk
+            AND vp.currencyFk = si.currencyFk
+        SET vp.balance = @risk := (
+            IF (
+                @company <> vp.companyFk
+                OR @supplier <> vp.supplierFk
+                OR @moneda <> vp.currencyFk,
+                IFNULL(si.openingBalances, 0),
+                @risk
+                ) +
+            vp.amount
+        ),
+        -- if there is a change of company or supplier or currency, the balance is reset
+        vp.pending = @pending := IF (
+            @company <> vp.companyFk
+            OR @supplier <> vp.supplierFk
+            OR @moneda <> vp.currencyFk
+            OR @day <> vp.dated,
+            vp.amount * (NOT vp.isPayment),
+            @pending + vp.amount
+        ),
+        vp.companyFk = @company := vp.companyFk,
+        vp.supplierFk = @supplier := vp.supplierFk,
+        vp.currencyFk = @moneda := vp.currencyFk,
+        vp.dated = @day := vp.dated,
+        vp.balance = @risk,
+        vp.pending = @pending;
 
-	CREATE OR REPLACE TEMPORARY TABLE tRowsToDelete ENGINE = MEMORY
-		SELECT expirationId,
-			dated,
-			supplierFk,
-			companyFk,
-			currencyFk,
-			balance
-		FROM tPendingDuedates
-		WHERE balance < vInvalidBalances
-			AND balance > - vInvalidBalances;
-			
-	DELETE vp.*
-		FROM tPendingDuedates vp
-			JOIN tRowsToDelete rd ON (
-				vp.dated < rd.dated
-				OR (vp.dated = rd.dated AND vp.expirationId <= rd.expirationId)
-			)
-			AND vp.supplierFk = rd.supplierFk
-			AND vp.companyFk = rd.companyFk
-			AND vp.currencyFk = rd.currencyFk
-		WHERE vp.isPayment = FALSE;
+    CREATE OR REPLACE TEMPORARY TABLE tRowsToDelete ENGINE = MEMORY
+        SELECT expirationId,
+            dated,
+            supplierFk,
+            companyFk,
+            currencyFk,
+            balance
+        FROM tPendingDuedates
+        WHERE balance < vInvalidBalances
+            AND balance > - vInvalidBalances;
 
-	SELECT vp.expirationId,
-			vp.dated,
-			vp.supplierFk,
+    DELETE vp.*
+        FROM tPendingDuedates vp
+            JOIN tRowsToDelete rd ON (
+                vp.dated < rd.dated
+                OR (vp.dated = rd.dated AND vp.expirationId <= rd.expirationId)
+            )
+            AND vp.supplierFk = rd.supplierFk
+            AND vp.companyFk = rd.companyFk
+            AND vp.currencyFk = rd.currencyFk
+        WHERE NOT vp.isPayment;
+
+    SELECT vp.expirationId,
+            vp.dated,
+            vp.supplierFk,
             vp.companyFk,
             vp.currencyFk,
             vp.amount,
@@ -183,15 +183,19 @@ BEGIN
             vp.isPayment,
             vp.isReconciled,
             vp.endingBalance,
-			cr.amount clientRiskAmount
-		FROM tPendingDuedates vp
-		    LEFT JOIN supplier s ON s.id = vp.supplierFk
-			LEFT JOIN client c ON c.fi = s.nif
-			LEFT JOIN clientRisk cr ON cr.clientFk = c.id 
-				AND cr.companyFk = vp.companyFk;
-	
-	DROP TEMPORARY TABLE tOpeningBalances;
-	DROP TEMPORARY TABLE tPendingDuedates;
-	DROP TEMPORARY TABLE tRowsToDelete;
+            cr.amount clientRiskAmount,
+            co.CEE
+        FROM tPendingDuedates vp
+            LEFT JOIN supplier s ON s.id = vp.supplierFk
+            LEFT JOIN client c ON c.fi = s.nif
+            LEFT JOIN clientRisk cr ON cr.clientFk = c.id
+            LEFT JOIN supplierAccount sa ON sa.supplierFk = s.id
+            LEFT JOIN bankEntity be ON be.id = sa.bankEntityFk
+            LEFT JOIN country co ON co.id = be.countryFk
+                AND cr.companyFk = vp.companyFk;
+
+    DROP TEMPORARY TABLE tOpeningBalances;
+    DROP TEMPORARY TABLE tPendingDuedates;
+    DROP TEMPORARY TABLE tRowsToDelete;
 END$$
 DELIMITER ;

db/routines/vn/procedures/creditInsurance_getRisk.sql

@@ -0,0 +1,42 @@
+DELIMITER $$
+CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`creditInsurance_getRisk`()
+BEGIN
+/**
+ * Devuelve el riesgo de los clientes que estan asegurados
+ */
+	CREATE OR REPLACE TEMPORARY TABLE tmp.client_list
+	    (PRIMARY KEY (Id_Cliente))
+	    ENGINE = MEMORY
+	        SELECT * FROM (
+	                SELECT cc.client Id_Cliente, ci.grade
+	                    FROM creditClassification cc
+	                        JOIN creditInsurance ci ON cc.id = ci.creditClassification
+	                    WHERE dateEnd IS NULL
+	                ORDER BY ci.creationDate DESC
+	                LIMIT 10000000000000000000) t1
+	            GROUP BY Id_Cliente;
+
+	CALL vn2008.risk_vs_client_list(util.VN_CURDATE());
+
+	SELECT
+	        c.id,
+	        c.name,
+	        c.credit clientCredit,
+	        c.creditInsurance solunion,
+	        CAST(r.risk AS DECIMAL(10,0)) risk,
+	        CAST(c.creditInsurance - r.risk AS DECIMAL(10,0)) riskAlive,
+	        cac.invoiced billedAnnually,
+	        c.dueDay,
+	        ci.grade,
+	        c2.country
+	    FROM tmp.client_list ci
+	        LEFT JOIN tmp.risk r ON r.Id_Cliente = ci.Id_Cliente
+	        JOIN client c ON c.id = ci.Id_Cliente
+	        JOIN bs.clientAnnualConsumption cac ON c.id = cac.clientFk
+	        JOIN country c2 ON c2.id = c.countryFk
+	    GROUP BY c.id;
+
+	DROP TEMPORARY TABLE IF EXISTS tmp.risk;
+	DROP TEMPORARY TABLE IF EXISTS tmp.client_list;
+END$$
+DELIMITER ;

db/routines/vn/procedures/productionError_add.sql

@@ -34,16 +34,22 @@ BEGIN
 	-- Rellena la tabla tmp.errorsByChecker con fallos de revisores
 	CREATE OR REPLACE TEMPORARY TABLE tmp.errorsByChecker
 		ENGINE = MEMORY
-			SELECT 	st.workerFk,
-				COUNT(t.id) errors
-			FROM saleMistake sm
-				JOIN saleTracking st ON sm.saleFk = st.saleFk
-				JOIN `state` s2 ON s2.id = st.stateFk
-				JOIN sale s ON s.id = sm.saleFk
-				JOIN ticket t on t.id = s.ticketFk
-			WHERE (t.shipped BETWEEN vDatedFrom AND vDatedTo)
-				AND s2.code IN ('OK','PREVIOUS_PREPARATION','PREPARED','CHECKED')
-			GROUP BY st.workerFk;
+		WITH rankedWorkers AS (
+			SELECT sm.id,
+					st.workerFk,
+					ROW_NUMBER() OVER(PARTITION BY sm.id ORDER BY s2.`order`) rnk
+				FROM vn.saleMistake sm
+					JOIN vn.saleTracking st ON sm.saleFk = st.saleFk
+					JOIN vn.`state` s2 ON s2.id = st.stateFk
+					JOIN vn.sale s ON s.id = sm.saleFk
+					JOIN vn.ticket t ON t.id = s.ticketFk
+				WHERE t.shipped BETWEEN vDatedFrom AND vDatedTo
+					AND s2.code IN ('OK', 'PREVIOUS_PREPARATION', 'PREPARED', 'CHECKED')
+		)
+		SELECT workerFk, COUNT(*) errors
+			FROM rankedWorkers
+			WHERE rnk = 1
+			GROUP BY workerFk;
 
  	-- Rellena la tabla tmp.expeditionErrors con fallos de expediciones
 	CREATE OR REPLACE TEMPORARY TABLE tmp.expeditionErrors

db/routines/vn/procedures/sale_getBoxPickingList.sql

@@ -46,6 +46,7 @@ BEGIN
 			JOIN parking p ON p.id = sh.parkingFk
 			JOIN tmp.productionBuffer pb ON pb.ticketFk = s.ticketFk
 			JOIN agencyMode am ON am.id = pb.agencyModeFk
+			JOIN agency a ON a .id = am.agencyFk
 			LEFT JOIN routesMonitor rm ON rm.routeFk = pb.routeFk
 			LEFT JOIN saleGroupDetail sgd ON sgd.saleFk = s.id
 			LEFT JOIN ticketState ts ON ts.ticketFk = s.ticketFk
@@ -60,6 +61,7 @@ BEGIN
 			AND ((rm.bufferFk AND rm.isPickingAllowed)
 				OR am.code = 'REC_ALG')
 			AND pb.shipped = vDated
+			AND a.isOwn
 		GROUP BY s.id
 		ORDER BY etd;
 

db/routines/vn/procedures/sale_replaceItem.sql

@@ -77,7 +77,9 @@ BEGIN
 		vNewItemFk);
 
 	SELECT price INTO vNewPrice
-		FROM tmp.ticketCalculateItem;
+		FROM tmp.ticketComponentPrice
+		ORDER BY (vQuantity % `grouping`) ASC
+		LIMIT 1;
 
 	IF vNewPrice IS NULL THEN
 		CALL util.throw('price retrieval failed');

db/routines/vn/procedures/solunionRiskRequest.sql

@@ -1,31 +0,0 @@
-DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`solunionRiskRequest`()
-BEGIN
-	
-	DROP TEMPORARY TABLE IF EXISTS tmp.client_list;
-    CREATE TEMPORARY TABLE tmp.client_list
-    (PRIMARY KEY (Id_Cliente))
-		ENGINE = MEMORY
-		SELECT * FROM (SELECT cc.client Id_Cliente, ci.grade FROM vn.creditClassification cc 
-				JOIN vn.creditInsurance ci ON cc.id = ci.creditClassification
-                WHERE dateEnd IS NULL
-                ORDER BY ci.creationDate DESC
-				LIMIT 10000000000000000000) t1 GROUP BY Id_Cliente;
-    
-    CALL vn2008.risk_vs_client_list(util.VN_CURDATE());
-    
-	SELECT 
-		c.Id_Cliente, c.Cliente, c.Credito credito_vn, c.creditInsurance solunion, cast(r.risk as DECIMAL(10,0)) riesgo_vivo,
-        cast(c.creditInsurance - r.risk as decimal(10,0)) margen_vivo,
-		f.Consumo consumo_anual, c.Vencimiento, ci.grade
-	FROM
-		vn2008.Clientes c
-			JOIN tmp.risk r ON r.Id_Cliente = c.Id_Cliente
-			JOIN tmp.client_list ci ON c.Id_Cliente = ci.Id_Cliente
-			JOIN bi.facturacion_media_anual f ON c.Id_Cliente = f.Id_Cliente
-		GROUP BY Id_cliente;
-        
-	DROP TEMPORARY TABLE IF EXISTS tmp.risk;
-    DROP TEMPORARY TABLE IF EXISTS tmp.client_list;
-END$$
-DELIMITER ;

db/routines/vn/procedures/ticketCalculateFromType.sql

@@ -11,7 +11,7 @@ BEGIN
 		SELECT id itemFk FROM vn.item
 			WHERE typeFk = vTypeFk;
             
-	CALL catalog_calculate(vLanded, vAddressFk, vAgencyModeFk);
+	CALL catalog_calculate(vLanded, vAddressFk, vAgencyModeFk, FALSE);
 	DROP TEMPORARY TABLE tmp.item;
 	DROP TEMPORARY TABLE tmp.ticketLot;
 END$$

db/routines/vn/triggers/travel_afterUpdate.sql

@@ -23,9 +23,5 @@ BEGIN
 			CALL buy_checkItem();
 		END IF;
 	END IF;
-
-	IF (NOT(NEW.awbFk <=> OLD.awbFk)) AND NEW.awbFk IS NOT NULL AND NOT travel_hasUniqueAwb(NEW.id) THEN
-		CALL util.throw('The AWB is incorrect, there is a different AWB in the associated entries');
-	END IF;
 END$$
 DELIMITER ;

db/routines/vn/triggers/travel_beforeUpdate.sql

@@ -32,5 +32,9 @@ BEGIN
 			CALL util.throw('The travel has entries with booked invoices');
 		END IF;
 	END IF;	
+	
+	IF (NOT(NEW.awbFk <=> OLD.awbFk)) AND NEW.awbFk IS NOT NULL AND NOT travel_hasUniqueAwb(NEW.id) THEN
+		CALL util.throw('The AWB is incorrect, there is a different AWB in the associated entries');
+	END IF;
 END$$
 DELIMITER ;

db/versions/10964-silverDracena/00-firstScript.sql

@@ -0,0 +1,2 @@
+-- Place your SQL code here
+ALTER TABLE vn.entry CHANGE isBlocked isBlocked__ tinyint(4) DEFAULT 0 NOT NULL COMMENT '@deprecated 27/03/2024';

db/versions/10969-silverCataractarum/00-aclSupplierDms.sql

@@ -0,0 +1,3 @@
+-- Place your SQL code here
+INSERT INTO `salix`.`ACL` (`model`, `property`, `accessType`, `permission`, `principalType`, `principalId`)
+	VALUES('SupplierDms', '*', '*', 'ALLOW', 'ROLE', 'employee');

db/versions/10970-bronzeGerbera/00-specialPrice.sql

@@ -0,0 +1,10 @@
+ALTER TABLE vn.specialPrice MODIFY COLUMN clientFk int(11) NULL;
+ALTER TABLE vn.specialPrice ADD started date NOT NULL DEFAULT '2024-01-01';
+ALTER TABLE vn.specialPrice ADD ended date NULL;
+ALTER TABLE vn.specialPrice MODIFY COLUMN itemFk int(11) NOT NULL;
+ALTER TABLE vn.specialPrice MODIFY COLUMN value DECIMAL(10,2) NOT NULL;
+
+
+ALTER TABLE vn.`specialPrice`
+    ADD CONSTRAINT `check_date_range`
+    CHECK (`ended` IS NULL OR `ended` >= `started`);

front/core/services/file.js

@@ -14,7 +14,7 @@ class File {
      */
     getPath(dmsUrl) {
         const serializedParams = this.$httpParamSerializer({
-            access_token: this.vnToken.token
+            access_token: this.vnToken.tokenMultimedia
         });
 
         return `${dmsUrl}?${serializedParams}`;

front/core/services/report.js

@@ -15,7 +15,7 @@ class Report {
      */
     show(path, params) {
         params = Object.assign({
-            access_token: this.vnToken.token
+            access_token: this.vnToken.tokenMultimedia
         }, params);
         const serializedParams = this.$httpParamSerializer(params);
         const query = serializedParams ? `?${serializedParams}` : '';

modules/claim/back/methods/claim/claimPickupPdf.js

@@ -34,7 +34,8 @@ module.exports = Self => {
         http: {
             path: '/:id/claim-pickup-pdf',
             verb: 'GET'
-        }
+        },
+        accessScopes: ['read:multimedia']
     });
 
     Self.claimPickupPdf = (ctx, id) => Self.printReport(ctx, id, 'claim-pickup-order');

modules/client/back/methods/client/campaignMetricsPdf.js

@@ -45,7 +45,8 @@ module.exports = Self => {
         http: {
             path: '/:id/campaign-metrics-pdf',
             verb: 'GET'
-        }
+        },
+        accessScopes: ['read:multimedia']
     });
 
     Self.campaignMetricsPdf = (ctx, id) => Self.printReport(ctx, id, 'campaign-metrics');

modules/entry/back/methods/entry/entryOrderPdf.js

@@ -33,7 +33,8 @@ module.exports = Self => {
         http: {
             path: '/:id/entry-order-pdf',
             verb: 'GET'
-        }
+        },
+        accessScopes: ['read:multimedia']
     });
 
     Self.entryOrderPdf = (ctx, id) => Self.printReport(ctx, id, 'entry-order');

modules/entry/back/models/entry.json

@@ -57,9 +57,6 @@
 				"columnName": "evaNotes"
 			}
         },
-        "isBlocked": {
-            "type": "boolean"
-        },
         "loadPriority": {
             "type": "number"
         },

modules/invoiceOut/back/methods/invoiceOut/exportationPdf.js

@@ -34,7 +34,8 @@ module.exports = Self => {
         http: {
             path: '/:reference/exportation-pdf',
             verb: 'GET'
-        }
+        },
+        accessScopes: ['read:multimedia']
     });
 
     Self.exportationPdf = (ctx, reference) => Self.printReport(ctx, reference, 'exportation');

modules/invoiceOut/back/methods/invoiceOut/invoiceCsv.js

@@ -37,23 +37,24 @@ module.exports = Self => {
         http: {
             path: '/:reference/invoice-csv',
             verb: 'GET'
-        }
+        },
+        accessScopes: ['read:multimedia']
     });
 
     Self.invoiceCsv = async reference => {
         const sales = await Self.rawSql(`
             SELECT io.ref Invoice,
                     io.issued InvoiceDate,
-                    s.ticketFk Ticket, 
-                    s.itemFk Item, 
-                    s.concept  Description, 
-                    i.size, 
+                    s.ticketFk Ticket,
+                    s.itemFk Item,
+                    s.concept  Description,
+                    i.size,
                     i.subName Producer,
-                    s.quantity Quantity, 
-                    s.price Price, 
-                    s.discount Discount, 
-                    s.created Created, 
-                    tc.code Taxcode, 
+                    s.quantity Quantity,
+                    s.price Price,
+                    s.discount Discount,
+                    s.created Created,
+                    tc.code Taxcode,
                     tc.description TaxDescription,
                     i.tag5,
                     i.value5,
@@ -67,14 +68,14 @@ module.exports = Self => {
                     i.value9,
                     i.tag10,
                     i.value10
-                FROM sale s 
-                    JOIN ticket t ON t.id = s.ticketFk 
-                    JOIN item i ON i.id = s.itemFk 
-                    JOIN supplier s2 ON s2.id = t.companyFk 
-                    JOIN itemTaxCountry itc ON itc.itemFk = i.id 
-                        AND itc.countryFk = s2.countryFk 
-                    JOIN taxClass tc ON tc.id = itc.taxClassFk     
-                    JOIN invoiceOut io ON io.ref = t.refFk 
+                FROM sale s
+                    JOIN ticket t ON t.id = s.ticketFk
+                    JOIN item i ON i.id = s.itemFk
+                    JOIN supplier s2 ON s2.id = t.companyFk
+                    JOIN itemTaxCountry itc ON itc.itemFk = i.id
+                        AND itc.countryFk = s2.countryFk
+                    JOIN taxClass tc ON tc.id = itc.taxClassFk
+                    JOIN invoiceOut io ON io.ref = t.refFk
                 WHERE t.refFk = ?
                 ORDER BY s.ticketFk, s.created`, [reference]);
 

modules/invoiceOut/back/methods/invoiceOut/negativeBasesCsv.js

@@ -39,7 +39,8 @@ module.exports = Self => {
         http: {
             path: '/negativeBasesCsv',
             verb: 'GET'
-        }
+        },
+        accessScopes: ['read:multimedia']
     });
 
     Self.negativeBasesCsv = async(ctx, options) => {

modules/invoiceOut/front/index/index.js

@@ -23,15 +23,16 @@ export default class Controller extends Section {
     }
 
     openPdf() {
+        const access_token = this.vnToken.tokenMultimedia;
         if (this.checked.length <= 1) {
             const [invoiceOutId] = this.checked;
-            const url = `api/InvoiceOuts/${invoiceOutId}/download?access_token=${this.vnToken.tokenMultimedia}`;
+            const url = `api/InvoiceOuts/${invoiceOutId}/download?access_token=${access_token}`;
             window.open(url, '_blank');
         } else {
             const invoiceOutIds = this.checked;
             const invoicesIds = invoiceOutIds.join(',');
             const serializedParams = this.$httpParamSerializer({
-                access_token: this.vnToken.token,
+                access_token,
                 ids: invoicesIds
             });
             const url = `api/InvoiceOuts/downloadZip?${serializedParams}`;

modules/item/front/index.js

@@ -20,7 +20,6 @@ import './botanical';
 import './barcode';
 import './summary';
 import './waste/index/';
-import './waste/detail';
 import './fixed-price';
 import './fixed-price-search-panel';
 import './item-type';

modules/item/front/waste/detail/index.html

@@ -1,43 +0,0 @@
-<vn-crud-model auto-load="true"
-    vn-id="model"
-    url="Items/getWasteByItem"
-    params="$ctrl.$params"
-    data="details">
-</vn-crud-model>
-<vn-data-viewer model="model">
-    <vn-card class="vn-w-md">
-        <section ng-repeat="detail in details" class="vn-pa-md">
-            <vn-horizontal class="header">
-                <h5>{{detail.family}} ({{detail.buyer}})</h5>
-            </vn-horizontal>
-            <vn-table>
-                <vn-thead>
-                    <vn-tr>
-                        <vn-th shrink>Item</vn-th>
-                        <vn-th number>Percentage</vn-th>
-                        <vn-th number>Dwindle</vn-th>
-                        <vn-th number>Total</vn-th>
-                    </vn-tr>
-                </vn-thead>
-                <vn-tbody>
-                    <vn-tr ng-repeat="waste in detail.lines">
-                        <vn-td shrink>
-                            <span 
-                                ng-click="itemDescriptor.show($event, waste.itemFk)"
-                                class="link">
-                                {{::waste.itemFk}}
-                            </span>
-                        </vn-td>
-                        <vn-td number>{{::(waste.percentage / 100) | percentage: 2}}</vn-td>
-                        <vn-td number>{{::waste.dwindle | currency: 'EUR'}}</vn-td>
-                        <vn-td number>{{::waste.total | currency: 'EUR'}}</vn-td>
-                    </vn-tr>
-                </vn-tbody>
-            </vn-table>
-        </section>
-    </vn-card>
-</vn-data-viewer>
-<vn-item-descriptor-popover
-    vn-id="item-descriptor"
-    warehouse-fk="$ctrl.vnConfig.warehouseFk">
-</vn-item-descriptor-popover>

modules/item/front/waste/detail/index.js

@@ -1,7 +0,0 @@
-import ngModule from '../../module';
-import Section from 'salix/components/section';
-
-ngModule.vnComponent('vnItemWasteDetail', {
-    template: require('./index.html'),
-    controller: Section
-});

modules/item/front/waste/detail/style.scss

@@ -1,25 +0,0 @@
-@import "variables";
-
-vn-item-waste {
-    .header {
-        margin-bottom: 16px;
-        text-transform: uppercase;
-        font-size: 1.25rem;
-        line-height: 1;
-        padding: 7px;
-        padding-bottom: 7px;
-        padding-bottom: 4px;
-        font-weight: lighter;
-        background-color: #fde6ca;
-        border-bottom: 1px solid #f7931e;
-        white-space: nowrap;
-        overflow: hidden;
-        text-overflow: ellipsis;
-    }
-
-    vn-table vn-th.waste-family,
-    vn-table vn-td.waste-family {
-        max-width: 64px;
-        width: 64px
-    }
-}

modules/item/front/waste/index/index.html

@@ -1,49 +1,2 @@
-<vn-crud-model auto-load="true"
-    vn-id="model"
-    url="Items/getWasteByWorker"
-    data="details">
-</vn-crud-model>
-<vn-data-viewer model="model">
-    <vn-card>
-        <vn-table>
-            <vn-thead>
-                <vn-tr class="header">
-                    <vn-th class="waste-family">Buyer</vn-th>
-                    <vn-th class="waste-family">Family</vn-th>
-                    <vn-th number>Percentage</vn-th>
-                    <vn-th number>Dwindle</vn-th>
-                    <vn-th number>Total</vn-th>
-                    <vn-th shrink></vn-th>
-                </vn-tr>
-            </vn-thead>
-            <vn-tbody ng-repeat="detail in details" class="vn-mb-md">
-                <vn-tr class="header">
-                    <vn-td>{{::detail.buyer}}</vn-td>
-                    <vn-td>{{::detail.family}}</vn-td>
-                    <vn-td number>{{::(detail.percentage / 100) | percentage: 2}}</vn-td>
-                    <vn-td number>{{::detail.dwindle | currency: 'EUR'}}</vn-td>
-                    <vn-td number>{{::detail.total | currency: 'EUR'}}</vn-td>
-                    <vn-td shrink>
-                        <vn-icon-button
-                            ng-class="{'hidden': !$ctrl.wasteConfig[detail.buyer].hidden}"
-                            class="arrow pointer"
-                            icon="keyboard_arrow_up"
-                            vn-tooltip="Minimize/Maximize"
-                            ng-click="$ctrl.toggleHidePanel(detail)">
-                        </vn-icon-button>
-                    </vn-td>
-                </vn-tr>
-                <a ng-repeat="waste in detail.lines" class="clickable vn-tr"
-                    ui-sref="item.waste.detail({buyer: waste.buyer, family: waste.family})"
-                    ng-show="$ctrl.wasteConfig[detail.buyer].hidden">
-                    <vn-td></vn-td>
-                    <vn-td>{{::waste.family}}</vn-td>
-                    <vn-td number>{{::(waste.percentage / 100) | percentage: 2}}</vn-td>
-                    <vn-td number>{{::waste.dwindle | currency: 'EUR'}}</vn-td>
-                    <vn-td number>{{::waste.total | currency: 'EUR'}}</vn-td>
-                    <vn-td shrink></vn-td>
-                </a>
-            </vn-tbody>
-        </vn-table>
-    </vn-card>
-</vn-data-viewer>
+<vn-card>
+</vn-card>

modules/item/front/waste/index/index.js

@@ -5,27 +5,11 @@ import './style.scss';
 export default class Controller extends Section {
     constructor($element, $) {
         super($element, $);
-
-        this.getWasteConfig();
     }
 
-    getWasteConfig() {
-        return this.wasteConfig = JSON.parse(localStorage.getItem('wasteConfig')) || {};
-    }
-
-    setWasteConfig() {
-        localStorage.setItem('wasteConfig', JSON.stringify(this.wasteConfig));
-    }
-
-    toggleHidePanel(detail) {
-        if (!this.wasteConfig[detail.buyer]) {
-            this.wasteConfig[detail.buyer] = {
-                hidden: true
-            };
-        } else
-            this.wasteConfig[detail.buyer].hidden = !this.wasteConfig[detail.buyer].hidden;
-
-        this.setWasteConfig();
+    async $onInit() {
+        this.$state.go('item.index');
+        window.location.href = 'https://grafana.verdnatura.es/d/TTNXQAxVk';
     }
 }
 

modules/item/front/waste/index/index.spec.js

@@ -1,53 +0,0 @@
-import './index.js';
-import crudModel from 'core/mocks/crud-model';
-
-describe('Item', () => {
-    describe('Component vnItemWasteIndex', () => {
-        let $scope;
-        let controller;
-
-        beforeEach(ngModule('item'));
-
-        beforeEach(inject(($componentController, $rootScope) => {
-            $scope = $rootScope.$new();
-            $scope.model = crudModel;
-            const $element = angular.element('<vn-item-waste-index></vn-item-waste-index>');
-            controller = $componentController('vnItemWasteIndex', {$element, $scope});
-        }));
-
-        describe('getWasteConfig / setWasteConfig', () => {
-            it('should return the local storage wasteConfig', () => {
-                const result = controller.getWasteConfig();
-
-                expect(result).toEqual({});
-            });
-
-            it('should set and return the local storage wasteConfig', () => {
-                controller.wasteConfig = {salesPerson: {hidden: true}};
-                controller.setWasteConfig();
-
-                const result = controller.getWasteConfig();
-
-                expect(result).toEqual(controller.wasteConfig);
-            });
-        });
-
-        describe('toggleHidePanel()', () => {
-            it('should make details hidden by default', () => {
-                controller.wasteConfig = {};
-
-                controller.toggleHidePanel({buyer: 'salesPerson'});
-
-                expect(controller.wasteConfig.salesPerson.hidden).toEqual(true);
-            });
-
-            it('should toggle hidden false', () => {
-                controller.wasteConfig = {salesPerson: {hidden: true}};
-
-                controller.toggleHidePanel({buyer: 'salesPerson'});
-
-                expect(controller.wasteConfig.salesPerson.hidden).toEqual(false);
-            });
-        });
-    });
-});

modules/order/back/methods/order/catalogFilter.js

@@ -92,10 +92,11 @@ module.exports = Self => {
         // Calculate items
         const order = await Self.findById(orderFk, null, myOptions);
         stmts.push(new ParameterizedSQL(
-            'CALL vn.catalog_calculate(?, ?, ?)', [
+            'CALL vn.catalog_calculate(?, ?, ?, ?)', [
                 order.landed,
                 order.address_id,
                 order.agency_id,
+                false
             ]
         ));
 

modules/order/back/methods/order/getItemTypeAvailable.js

@@ -64,10 +64,11 @@ module.exports = Self => {
         stmts.push(stmt);
 
         stmt = new ParameterizedSQL(
-            'CALL vn.catalog_calculate(?, ?, ?)', [
+            'CALL vn.catalog_calculate(?, ?, ?,?)', [
                 order.landed,
                 order.addressFk,
                 order.agencyModeFk,
+                false
             ]
         );
         stmts.push(stmt);

modules/route/front/index/index.js

@@ -35,16 +35,18 @@ export default class Controller extends Section {
 
     showRouteReport() {
         const routesIds = [];
+        const access_token = this.vnToken.tokenMultimedia;
+
         for (let route of this.checked)
             routesIds.push(route.id);
         const stringRoutesIds = routesIds.join(',');
 
         if (this.checked.length <= 1) {
-            const url = `api/Routes/${stringRoutesIds}/driver-route-pdf?access_token=${this.vnToken.tokenMultimedia}`;
+            const url = `api/Routes/${stringRoutesIds}/driver-route-pdf?access_token=${access_token}`;
             window.open(url, '_blank');
         } else {
             const serializedParams = this.$httpParamSerializer({
-                access_token: this.vnToken.token,
+                access_token,
                 id: stringRoutesIds
             });
             const url = `api/Routes/downloadZip?${serializedParams}`;

modules/supplier/back/methods/supplier/campaignMetricsPdf.js

@@ -44,7 +44,8 @@ module.exports = Self => {
         http: {
             path: '/:id/campaign-metrics-pdf',
             verb: 'GET'
-        }
+        },
+        accessScopes: ['read:multimedia']
     });
 
     Self.campaignMetricsPdf = (ctx, id) => Self.printReport(ctx, id, 'supplier-campaign-metrics');

modules/supplier/back/methods/supplier/supplier-dms/downloadFile.js

@@ -0,0 +1,59 @@
+const UserError = require('vn-loopback/util/user-error');
+
+module.exports = Self => {
+    Self.remoteMethodCtx('downloadFile', {
+        description: 'Get the supplier file',
+        accessType: 'READ',
+        accepts: [
+            {
+                arg: 'id',
+                type: 'Number',
+                description: 'The file id',
+                http: {source: 'path'}
+            }
+        ],
+        returns: [
+            {
+                arg: 'body',
+                type: 'file',
+                root: true
+            },
+            {
+                arg: 'Content-Type',
+                type: 'String',
+                http: {target: 'header'}
+            },
+            {
+                arg: 'Content-Disposition',
+                type: 'String',
+                http: {target: 'header'}
+            }
+        ],
+        http: {
+            path: `/:id/downloadFile`,
+            verb: 'GET'
+        }
+    });
+
+    Self.downloadFile = async function(ctx, id) {
+        const models = Self.app.models;
+        const SupplierContainer = models.SupplierContainer;
+        const dms = await models.Dms.findById(id);
+        const pathHash = SupplierContainer.getHash(dms.id);
+        try {
+            await SupplierContainer.getFile(pathHash, dms.file);
+        } catch (e) {
+            if (e.code != 'ENOENT')
+                throw e;
+
+            const error = new UserError(`File doesn't exists`);
+            error.statusCode = 404;
+
+            throw error;
+        }
+
+        const stream = SupplierContainer.downloadStream(pathHash, dms.file);
+
+        return [stream, dms.contentType, `filename="${dms.file}"`];
+    };
+};

modules/supplier/back/methods/supplier/supplier-dms/removeFile.js

@@ -0,0 +1,53 @@
+const UserError = require('vn-loopback/util/user-error');
+
+module.exports = Self => {
+    Self.remoteMethodCtx('removeFile', {
+        description: 'Removes a entry document',
+        accessType: 'WRITE',
+        accepts: {
+            arg: 'id',
+            type: 'number',
+            description: 'The file id',
+            http: {source: 'path'}
+        },
+        returns: {
+            type: 'object',
+            root: true
+        },
+        http: {
+            path: `/:id/removeFile`,
+            verb: 'POST'
+        }
+    });
+
+    Self.removeFile = async(ctx, id, options) => {
+        const myOptions = {};
+        let tx;
+
+        if (typeof options == 'object')
+            Object.assign(myOptions, options);
+
+        if (!myOptions.transaction) {
+            tx = await Self.beginTransaction({});
+            myOptions.transaction = tx;
+        }
+
+        try {
+            const targetSupplierDms = await Self.findById(id, null, myOptions);
+            const targetDms = await Self.app.models.Dms.removeFile(ctx, targetSupplierDms.dmsFk, myOptions);
+
+            if (!targetDms)
+                throw new UserError('Try again');
+
+            const supplierDmsDestroyed = await targetSupplierDms.destroy(myOptions);
+
+            if (tx) await tx.commit();
+
+            return supplierDmsDestroyed;
+        } catch (e) {
+            if (tx) await tx.rollback();
+            throw e;
+        }
+    };
+};
+

modules/supplier/back/methods/supplier/supplier-dms/uploadFile.js

@@ -0,0 +1,86 @@
+
+module.exports = Self => {
+    Self.remoteMethodCtx('uploadFile', {
+        description: 'Upload and attach a file',
+        accessType: 'WRITE',
+        accepts: [{
+            arg: 'id',
+            type: 'number',
+            description: 'The supplier id',
+            http: {source: 'path'}
+        },
+        {
+            arg: 'warehouseId',
+            type: 'number',
+            description: 'The warehouse id',
+            required: true
+        },
+        {
+            arg: 'companyId',
+            type: 'number',
+            description: 'The company id',
+            required: true
+        },
+        {
+            arg: 'dmsTypeId',
+            type: 'number',
+            description: 'The dms type id',
+            required: true
+        },
+        {
+            arg: 'reference',
+            type: 'string',
+            required: true
+        },
+        {
+            arg: 'description',
+            type: 'string',
+            required: true
+        },
+        {
+            arg: 'hasFile',
+            type: 'boolean',
+            description: 'True if has an attached file',
+            required: true
+        }],
+        returns: {
+            type: 'object',
+            root: true
+        },
+        http: {
+            path: `/:id/uploadFile`,
+            verb: 'POST'
+        }
+    });
+
+    Self.uploadFile = async(ctx, id, options) => {
+        const {Dms, SupplierDms} = 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 uploadedFiles = await Dms.uploadFile(ctx, myOptions);
+
+            const promises = uploadedFiles.map(dms => SupplierDms.create({
+                supplierFk: id,
+                dmsFk: dms.id
+            }, myOptions));
+            await Promise.all(promises);
+
+            if (tx) await tx.commit();
+
+            return uploadedFiles;
+        } catch (e) {
+            if (tx) await tx.rollback();
+            throw e;
+        }
+    };
+};

modules/supplier/back/model-config.json

@@ -5,6 +5,9 @@
     "Supplier": {
         "dataSource": "vn"
     },
+    "SupplierDms": {
+        "dataSource": "vn"
+    },
     "SupplierAddress": {
         "dataSource": "vn"
     },

modules/supplier/back/models/supplier-container.json

@@ -0,0 +1,10 @@
+{
+    "name": "SupplierContainer",
+    "base": "Container",
+    "acls": [{
+        "accessType": "READ",
+        "principalType": "ROLE",
+        "principalId": "$everyone",
+        "permission": "ALLOW"
+    }]
+}

modules/supplier/back/models/supplier-dms.js

@@ -0,0 +1,13 @@
+const UserError = require('vn-loopback/util/user-error');
+
+module.exports = Self => {
+    require('../methods/supplier/supplier-dms/removeFile')(Self);
+    require('../methods/supplier/supplier-dms/downloadFile')(Self);
+    require('../methods/supplier/supplier-dms/uploadFile')(Self);
+
+    Self.rewriteDbError(function(err) {
+        if (err.code === 'ER_DUP_ENTRY')
+            return new UserError(`The file is already attached to another entry`);
+        return err;
+    });
+};

modules/supplier/back/models/supplier-dms.json

@@ -0,0 +1,37 @@
+{
+    "name": "SupplierDms",
+    "base": "VnModel",
+    "mixins": {
+        "Loggable": true
+    },
+    "options": {
+        "mysql": {
+            "table": "supplierDms"
+        }
+    },
+    "allowedContentTypes": [
+        "image/png",
+        "image/jpeg",
+        "image/jpg",
+        "application/pdf"
+    ],
+    "properties": {
+        "dmsFk": {
+            "type": "number",
+            "id": true,
+            "required": true
+        }
+    },
+    "relations": {
+        "supplier": {
+            "type": "belongsTo",
+            "model": "Supplier",
+            "foreignKey": "supplierFk"
+        },
+        "dms": {
+            "type": "belongsTo",
+            "model": "Dms",
+            "foreignKey": "dmsFk"
+        }
+    }
+}

modules/ticket/back/methods/ticket-collection/hasUncheckedTicket.js

@@ -0,0 +1,40 @@
+module.exports = Self => {
+    Self.remoteMethod('hasUncheckedTicket', {
+        description:
+            'Get boolean if the collection of ticket has a ticket not checked',
+        accessType: 'READ',
+        accepts: [{
+            arg: 'ticketFk',
+            type: 'integer',
+            required: true,
+            description: 'Ticket id'
+        }],
+        returns: {
+            type: 'boolean',
+            root: true
+        },
+        http: {
+            path: `/hasUncheckedTicket`,
+            verb: 'GET'
+        }
+    });
+
+    Self.hasUncheckedTicket = async(ticketFk, options) => {
+        const myOptions = {};
+
+        if (typeof options == 'object')
+            Object.assign(myOptions, options);
+
+        const result = await Self.rawSql(`
+           SELECT tc2.ticketFk
+                FROM vn.ticketCollection tc
+                    JOIN vn.ticketCollection tc2 ON tc2.collectionFk  = tc.collectionFk
+                    LEFT JOIN vn.ticketState ts ON ts.ticketFk = tc2.ticketFk
+                    JOIN vn.state s ON s.id = ts.stateFk
+                    JOIN vn.state s2 ON s2.code = 'CHECKED'
+                WHERE tc.ticketFk = ? AND s.order < s2.id
+                LIMIT 1;`,
+        [ticketFk], myOptions);
+        return result.length > 0 && result[0]['ticketFk'] > 0;
+    };
+};

modules/ticket/back/methods/ticket-collection/spec/hasUncheckedTicket.spec.js

@@ -0,0 +1,38 @@
+
+const {models} = require('vn-loopback/server/server');
+
+describe('ticketCollection hasUncheckedTicket()', () => {
+    it('should return false because there are not tickets not checked', async() => {
+        const ticketFk = 1;
+        const result = await models.TicketCollection.hasUncheckedTicket(ticketFk);
+
+        expect(result).toBe(false);
+    });
+
+    it('should return true because there is a ticket not checked', async() => {
+        const ticketFk = 1;
+        const stateFkCurrent = 16;
+        const stateFkUpdated = 7;
+
+        const tx = await models.TicketTracking.beginTransaction({});
+        const myOptions = {transaction: tx};
+        const filter = {where: {
+            ticketFk: 1,
+            stateFk: stateFkCurrent}
+        };
+        try {
+            const ticketTracking = await models.TicketTracking.findOne(filter, myOptions);
+            await ticketTracking.updateAttributes({
+                stateFk: stateFkUpdated
+            }, myOptions);
+            const result = await models.TicketCollection.hasUncheckedTicket(ticketFk, myOptions);
+
+            expect(result).toBe(true);
+            await tx.rollback();
+        } catch (e) {
+            await tx.rollback();
+            throw e;
+        }
+    });
+});
+

modules/ticket/back/methods/ticket/deliveryNoteCsv.js

@@ -37,23 +37,24 @@ module.exports = Self => {
         http: {
             path: '/:id/delivery-note-csv',
             verb: 'GET'
-        }
+        },
+        accessScopes: ['read:multimedia']
     });
 
     Self.deliveryNoteCsv = async id => {
         const sales = await Self.rawSql(`
             SELECT  io.ref Invoice,
                     io.issued InvoiceDate,
-                    s.ticketFk Ticket, 
-                    s.itemFk Item, 
-                    s.concept  Description, 
-                    i.size, 
+                    s.ticketFk Ticket,
+                    s.itemFk Item,
+                    s.concept  Description,
+                    i.size,
                     i.subName Producer,
-                    s.quantity Quantity, 
-                    s.price Price, 
-                    s.discount Discount, 
-                    s.created Created, 
-                    tc.code Taxcode, 
+                    s.quantity Quantity,
+                    s.price Price,
+                    s.discount Discount,
+                    s.created Created,
+                    tc.code Taxcode,
                     tc.description TaxDescription,
                     i.tag5,
                     i.value5,
@@ -67,14 +68,14 @@ module.exports = Self => {
                     i.value9,
                     i.tag10,
                     i.value10
-                FROM vn.sale s 
-                    JOIN vn.ticket t ON t.id = s.ticketFk 
-                    JOIN vn.item i ON i.id = s.itemFk 
-                    JOIN vn.supplier s2 ON s2.id = t.companyFk 
-                    JOIN vn.itemTaxCountry itc ON itc.itemFk = i.id 
-                        AND itc.countryFk = s2.countryFk 
-                    JOIN vn.taxClass tc ON tc.id = itc.taxClassFk     
-                    LEFT JOIN vn.invoiceOut io ON io.id = t.refFk 
+                FROM vn.sale s
+                    JOIN vn.ticket t ON t.id = s.ticketFk
+                    JOIN vn.item i ON i.id = s.itemFk
+                    JOIN vn.supplier s2 ON s2.id = t.companyFk
+                    JOIN vn.itemTaxCountry itc ON itc.itemFk = i.id
+                        AND itc.countryFk = s2.countryFk
+                    JOIN vn.taxClass tc ON tc.id = itc.taxClassFk
+                    LEFT JOIN vn.invoiceOut io ON io.id = t.refFk
                 WHERE s.ticketFk = ?
                 ORDER BY s.ticketFk, s.created`, [id]);
         const content = toCSV(sales);

modules/ticket/back/methods/ticket/deliveryNotePdf.js

@@ -41,7 +41,8 @@ module.exports = Self => {
         http: {
             path: '/:id/delivery-note-pdf',
             verb: 'GET'
-        }
+        },
+        accessScopes: ['read:multimedia']
     });
 
     Self.deliveryNotePdf = (ctx, id) => Self.printReport(ctx, id, 'delivery-note');

modules/ticket/back/models/ticket-collection.js

@@ -0,0 +1,3 @@
+module.exports = Self => {
+    require('../methods/ticket-collection/hasUncheckedTicket')(Self);
+};

modules/ticket/back/models/ticket-collection.json

@@ -13,6 +13,9 @@
         },
         "usedShelves": {
             "type": "number"
+        },
+        "collectionFk": {
+            "type": "number"
         }
     },
     "relations": {
@@ -20,6 +23,11 @@
             "type": "belongsTo",
             "model": "Ticket",
             "foreignKey": "ticketFk"
+        },
+        "collection": {
+            "type": "belongsTo",
+            "model": "Collection",
+            "foreignKey": "collectionFk"
         }
     }
 }

modules/travel/back/methods/travel/extraCommunityPdf.js

@@ -78,7 +78,8 @@ module.exports = Self => {
         http: {
             path: '/extra-community-pdf',
             verb: 'GET'
-        }
+        },
+        accessScopes: ['read:multimedia']
     });
 
     Self.extraCommunityPdf = ctx => Self.printReport(ctx, null, 'extra-community');

modules/travel/front/extra-community/index.js

@@ -144,7 +144,7 @@ class Controller extends Section {
         const currentFilter = this.$.model.currentFilter;
 
         return Object.assign({
-            authorization: this.vnToken.token,
+            authorization: this.vnToken.tokenMultimedia,
             filter: currentFilter
         }, userParams);
     }

modules/worker/back/methods/worker-time-control/specs/clockIn.spec.js

@@ -71,6 +71,34 @@ describe('workerTimeControl clockIn()', () => {
         }
     });
 
+    it('should updates the time entry direction and remaining not be manual', async() => {
+        activeCtx.accessToken.userId = HHRRId;
+        const workerId = teamBossId;
+
+        const tx = await models.WorkerTimeControl.beginTransaction({});
+        try {
+            const options = {transaction: tx};
+
+            const entryTime = "2000-12-25T11:00:00.000Z";
+            ctx.args = {timed: entryTime, direction: 'in'};
+            await models.WorkerTimeControl.addTimeEntry(ctx, workerId, options);
+
+            const middleTime ="2000-12-25T16:00:00.000Z";
+            ctx.args = {timed: middleTime, direction: 'middle'};
+            const middleEntryTime = await models.WorkerTimeControl.addTimeEntry(ctx, workerId, options);
+            middleEntryTime.updateAttribute('manual', false);
+            
+            const direction = 'out';
+            const outTimeEntryId = await models.WorkerTimeControl.updateTimeEntry(ctx, middleEntryTime.id, direction, options);
+
+            const outTimeEntry = await models.WorkerTimeControl.findById(outTimeEntryId, null, options);
+            expect(outTimeEntry.manual).toBeFalsy();
+            await tx.rollback();
+        } catch (e) {
+            await tx.rollback();
+        }
+    });
+
     describe('as Role errors', () => {
         it('should add if the current user is team boss and the target user is himself', async() => {
             activeCtx.accessToken.userId = teamBossId;
@@ -144,7 +172,7 @@ describe('workerTimeControl clockIn()', () => {
                 const middleTime = await models.WorkerTimeControl.addTimeEntry(ctx, workerId, options);
                 
                 const direction = 'out';
-                const {id:outTimeEntryId} = await models.WorkerTimeControl.updateTimeEntry(
+                const outTimeEntryId = await models.WorkerTimeControl.updateTimeEntry(
                     ctx, middleTime.id, direction, options
                 );
 

modules/worker/back/methods/worker-time-control/updateTimeEntry.js

@@ -29,7 +29,7 @@ module.exports = Self => {
     Self.updateTimeEntry = async(ctx, timeEntryId, direction, options) => {
         const currentUserId = ctx.req.accessToken.userId;
         const models = Self.app.models;
-        const myOptions = {};
+        const myOptions = {userId: currentUserId};
         let tx;
 
         if (typeof options == 'object')
@@ -41,7 +41,7 @@ module.exports = Self => {
         }
 
         try {
-            const {id, userFk, timed} = await Self.findById(timeEntryId, null, myOptions);
+            const {id, userFk, timed, manual} = await Self.findById(timeEntryId, null, myOptions);
             const isSubordinate = await models.Worker.isSubordinate(ctx, userFk, myOptions);
             const isTeamBoss = await models.ACL.checkAccessAcl(ctx, 'Worker', 'isTeamBoss', 'WRITE');
             const isHimself = currentUserId == userFk;
@@ -50,12 +50,15 @@ module.exports = Self => {
             if (notAllowed) throw new UserError(`You don't have enough privileges`);
 
             await models.WorkerTimeControl.deleteById(id, myOptions);
-            const timeEntryUpdatedId = await Self.clockIn(userFk, timed, direction, null, myOptions);
+            const {id: newTimeEntryId} = await Self.clockIn(
+                userFk, timed, direction, null, myOptions
+            );
 
+            if (!manual) await Self.updateAll({id: newTimeEntryId}, {manual: false}, myOptions);
             await models.WorkerTimeControl.resendWeeklyHourEmail(ctx, userFk, timed, myOptions);
 
             if (tx) await tx.commit();
-            return timeEntryUpdatedId;
+            return newTimeEntryId;
         } catch (e) {
             if (tx) await tx.rollback();
             throw e;

package.json

@@ -1,6 +1,6 @@
 {
     "name": "salix-back",
-    "version": "24.14.0",
+    "version": "24.16.0",
     "author": "Verdnatura Levante SL",
     "description": "Salix backend",
     "license": "GPL-3.0",

print/templates/email/buyer-week-waste/buyer-week-waste.html

@@ -28,10 +28,10 @@
             </table>
             <p v-html="$t('wasteDetailLink')"></p>
             <div class="external-link vn-pa-sm vn-m-md">
-                <a href="https://salix.verdnatura.es/#!/item/waste/index" target="_blank">
-                    https://salix.verdnatura.es/#!/item/waste/index
+                <a href="https://grafana.verdnatura.es/d/TTNXQAxVk" target="_blank">
+                    https://grafana.verdnatura.es/d/TTNXQAxVk
                 </a>
             </div>
         </div>
     </div>
-</email-body>
+</email-body>