salix/db/routines/vn/procedures/sale_getProblems.sql

DELIMITER $$
CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`sale_getProblems`(
	vIsTodayRelative tinyint(1)
)
BEGIN
/**
 * Calcula los problemas de cada venta para un conjunto de tickets.
 *
 * @param vIsTodayRelative Indica si se calcula el disponible como si todo saliera hoy
 * @table tmp.sale_getProblems(ticketFk, clientFk, warehouseFk, shipped) Tickets a calcular
 * @return tmp.sale_problems
 */
 	DECLARE vWarehouseFk INT;
	DECLARE vDate DATE;
 	DECLARE vAvailableCache INT;
	DECLARE vVisibleCache INT;
	DECLARE vDone BOOL;
 	DECLARE vCursor CURSOR FOR
		SELECT DISTINCT warehouseFk, IF(vIsTodayRelative, util.VN_CURDATE(), DATE(shipped))
			FROM tmp.sale_getProblems
			WHERE shipped BETWEEN util.VN_CURDATE()
				AND util.dayEnd(util.VN_CURDATE() + INTERVAL IF(vIsTodayRelative, 9.9, 1.9) DAY);

	DECLARE CONTINUE HANDLER FOR NOT FOUND SET vDone = TRUE;

	CREATE OR REPLACE TEMPORARY TABLE tmp.sale_problems (
		ticketFk INT(11),
		saleFk INT(11),
		isFreezed INTEGER(1) DEFAULT 0,
		risk DECIMAL(10,1) DEFAULT 0,
		hasRisk TINYINT(1) DEFAULT 0,
		hasHighRisk TINYINT(1) DEFAULT 0,
		hasTicketRequest INTEGER(1) DEFAULT 0,
		itemShortage VARCHAR(255),
		isTaxDataChecked  INTEGER(1) DEFAULT 1,
		itemDelay VARCHAR(255),
		itemLost VARCHAR(255),
		hasComponentLack INTEGER(1),
		hasRounding VARCHAR(255),
		isTooLittle BOOL DEFAULT FALSE,
		isVip BOOL DEFAULT FALSE,
		PRIMARY KEY (ticketFk, saleFk)
	) ENGINE = MEMORY;

	INSERT INTO tmp.sale_problems(ticketFk,
									saleFk,
									isFreezed,
									risk,
									hasRisk,
									hasHighRisk,
									hasTicketRequest,
									isTaxDataChecked,
									hasComponentLack,
									isTooLittle)
			SELECT sgp.ticketFk,
					s.id,
					IF(FIND_IN_SET('isFreezed', t.problem), TRUE, FALSE) isFreezed,
					t.risk,
					IF(FIND_IN_SET('hasRisk', t.problem), TRUE, FALSE) hasRisk,
					IF(FIND_IN_SET('hasHighRisk', t.problem), TRUE, FALSE) hasHighRisk,
					IF(FIND_IN_SET('hasTicketRequest', t.problem), TRUE, FALSE) hasTicketRequest,
					IF(FIND_IN_SET('isTaxDataChecked', t.problem), FALSE, TRUE) isTaxDataChecked,
					IF(FIND_IN_SET('hasComponentLack', s.problem), TRUE, FALSE) hasComponentLack,
					IF(FIND_IN_SET('isTooLittle', t.problem)
						AND util.VN_NOW() < (util.VN_CURDATE() + INTERVAL HOUR(zc.`hour`) HOUR) + INTERVAL MINUTE(zc.`hour`) MINUTE,
						TRUE, FALSE) isTooLittle
				FROM tmp.sale_getProblems sgp
					JOIN ticket t ON t.id = sgp.ticketFk
					LEFT JOIN sale s ON s.ticketFk = t.id
					LEFT JOIN item i ON i.id = s.itemFk
					LEFT JOIN zoneClosure zc ON zc.zoneFk = t.zoneFk
						AND zc.dated = util.VN_CURDATE()
				WHERE s.problem <> '' OR t.problem <> '' OR t.risk
				GROUP BY t.id, s.id;

	INSERT INTO tmp.sale_problems(ticketFk, isVip)
		SELECT sgp.ticketFk, TRUE
			FROM tmp.sale_getProblems sgp
				JOIN client c ON c.id = sgp.clientFk
			WHERE c.businessTypeFk = 'VIP'
		ON DUPLICATE KEY UPDATE isVIP = TRUE;

	CREATE OR REPLACE TEMPORARY TABLE tItemShelvingStock_byWarehouse
		(INDEX (itemFk, warehouseFk))
		ENGINE = MEMORY
		SELECT ish.itemFk itemFk,
				SUM(ish.visible) visible,
				s.warehouseFk warehouseFk
			FROM itemShelving ish
				JOIN shelving sh ON sh.code = ish.shelvingFk
				JOIN parking p ON p.id = sh.parkingFk
				JOIN sector s ON s.id = p.sectorFk
			GROUP BY ish.itemFk, s.warehouseFk;

	-- Disponible, faltas, inventario y retrasos
	OPEN vCursor;
	l: LOOP
		SET vDone = FALSE;
		FETCH vCursor INTO vWarehouseFk, vDate;

		IF vDone THEN
			LEAVE l;
		END IF;

		-- Disponible: no va a haber suficiente producto para preparar todos los pedidos
		CALL cache.available_refresh(vAvailableCache, FALSE, vWarehouseFk, vDate);
	
		-- Faltas: visible, disponible y ubicado son menores que la cantidad vendida	
		CALL cache.visible_refresh(vVisibleCache, FALSE, vWarehouseFk);

		INSERT INTO tmp.sale_problems(ticketFk, itemShortage, saleFk)
			SELECT ticketFk, problem, saleFk
				FROM (
					SELECT sgp.ticketFk, 
							LEFT(CONCAT('F: ', GROUP_CONCAT(i.id, ' ', i.longName, ' ')), 250) problem, 
							s.id saleFk
						FROM tmp.sale_getProblems sgp
							JOIN ticket t ON t.id = sgp.ticketFk
							JOIN sale s ON s.ticketFk = t.id
							JOIN item i ON i.id = s.itemFk
							JOIN itemType it ON it.id = i.typeFk
							JOIN itemCategory ic ON ic.id = it.categoryFk 
							LEFT JOIN cache.visible v ON v.item_id = i.id
								AND v.calc_id = vVisibleCache
							LEFT JOIN cache.available av ON av.item_id = i.id
								AND av.calc_id = vAvailableCache
							LEFT JOIN tItemShelvingStock_byWarehouse issw ON issw.itemFk = i.id
								AND issw.warehouseFk = t.warehouseFk 
						WHERE IFNULL(v.visible, 0) < s.quantity
							AND IFNULL(av.available, 0) < s.quantity
							AND IFNULL(issw.visible, 0) < s.quantity
							AND NOT s.isPicked
							AND NOT s.reserved
							AND ic.merchandise
							AND IF(vIsTodayRelative, TRUE, DATE(t.shipped) = vDate)
							AND NOT i.generic
							AND util.VN_CURDATE() = vDate
							AND t.warehouseFk = vWarehouseFk
					GROUP BY sgp.ticketFk) sub
					ON DUPLICATE KEY UPDATE itemShortage = sub.problem, saleFk = sub.saleFk;
		
		-- Inventario: Visible suficiente, pero ubicado menor a la cantidad vendida
		INSERT INTO tmp.sale_problems(ticketFk, itemLost, saleFk)
			SELECT ticketFk, problem, saleFk
				FROM (
					SELECT sgp.ticketFk,
							LEFT(GROUP_CONCAT('I: ', i.id, ' ', i.longName, ' '), 250) problem,
							s.id saleFk
						FROM tmp.sale_getProblems sgp
							JOIN ticket t ON t.id = sgp.ticketFk
							JOIN sale s ON s.ticketFk = t.id
							JOIN item i ON i.id = s.itemFk
							JOIN itemType it ON it.id = i.typeFk
							JOIN itemCategory ic ON ic.id = it.categoryFk
							LEFT JOIN cache.visible v ON v.item_id = s.itemFk
								AND v.calc_id = vVisibleCache
							LEFT JOIN tItemShelvingStock_byWarehouse issw ON issw.itemFk = i.id
								AND issw.warehouseFk = t.warehouseFk 
						WHERE IFNULL(v.visible, 0) >= s.quantity
							AND IFNULL(issw.visible, 0) < s.quantity
							AND s.quantity > 0
							AND NOT s.isPicked
							AND NOT s.reserved
							AND ic.merchandise
							AND IF(vIsTodayRelative, TRUE, DATE(t.shipped) = vDate)
							AND NOT i.generic
							AND util.VN_CURDATE() = vDate
							AND t.warehouseFk = vWarehouseFk
						GROUP BY sgp.ticketFk
				) sub
			ON DUPLICATE KEY UPDATE itemLost = sub.problem, saleFk = sub.saleFk;
		
		-- Retraso: Disponible suficiente, pero no visible ni ubicado
		INSERT INTO tmp.sale_problems(ticketFk, itemDelay, saleFk)
			SELECT ticketFk, problem, saleFk
				FROM (
					SELECT sgp.ticketFk,
							LEFT(GROUP_CONCAT('R: ', i.id, ' ', i.longName, ' '), 250) problem,
							s.id saleFk
						FROM tmp.sale_getProblems sgp
							JOIN ticket t ON t.id = sgp.ticketFk
							JOIN sale s ON s.ticketFk = t.id
							JOIN item i ON i.id = s.itemFk
							JOIN itemType it ON it.id = i.typeFk
							JOIN itemCategory ic ON ic.id = it.categoryFk
							LEFT JOIN cache.visible v ON v.item_id = s.itemFk
								AND v.calc_id = vVisibleCache
							LEFT JOIN cache.available av ON av.item_id = i.id
								AND av.calc_id = vAvailableCache
							LEFT JOIN tItemShelvingStock_byWarehouse issw ON issw.itemFk = i.id
								AND issw.warehouseFk = t.warehouseFk 
						WHERE IFNULL(v.visible, 0) < s.quantity
							AND IFNULL(av.available, 0) >= s.quantity
							AND IFNULL(issw.visible, 0) < s.quantity
							AND s.quantity > 0
							AND NOT s.isPicked
							AND NOT s.reserved
							AND ic.merchandise
							AND IF(vIsTodayRelative, TRUE, DATE(t.shipped) = vDate)
							AND NOT i.generic
							AND util.VN_CURDATE() = vDate
							AND t.warehouseFk = vWarehouseFk
						GROUP BY sgp.ticketFk
				) sub
			ON DUPLICATE KEY UPDATE itemDelay = sub.problem, saleFk = sub.saleFk;

		-- Redondeo: cantidad incorrecta con respecto al grouping 
		CALL buyUltimate(vWarehouseFk, vDate);
		INSERT INTO tmp.sale_problems(ticketFk, hasRounding, saleFk)
			SELECT ticketFk, problem, saleFk
				FROM (
					SELECT sgp.ticketFk, 
							s.id saleFk,
							LEFT(GROUP_CONCAT('RE: ',i.id, ' ',  IFNULL(i.longName,'') SEPARATOR ', '), 250) problem
						FROM tmp.sale_getProblems sgp
							JOIN ticket t ON t.id = sgp.ticketFk 
								AND t.warehouseFk = vWarehouseFk
							JOIN sale s ON s.ticketFk = sgp.ticketFk
							JOIN item i ON i.id = s.itemFk
							JOIN tmp.buyUltimate bu ON bu.itemFk = s.itemFk
							JOIN buy b ON b.id = bu.buyFk
						WHERE MOD(s.quantity, b.`grouping`)	
						GROUP BY sgp.ticketFk
				)sub 
			ON DUPLICATE KEY UPDATE hasRounding = sub.problem, saleFk = sub.saleFk;

		DROP TEMPORARY TABLE tmp.buyUltimate;
	END LOOP;
	CLOSE vCursor;

	DROP TEMPORARY TABLE tItemShelvingStock_byWarehouse;
END$$
DELIMITER ;