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

DELIMITER $$
CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`collection_assign`(
	vUserFk INT,
	OUT vCollectionFk INT
)
BEGIN   
/**
 * Comprueba si existen colecciones libres que se ajustan
 * al perfil del usuario y le asigna la más antigua.
 * Añade un registro al semillero de colecciones.
 *
 * @param vUserFk Id de usuario
 * @param vCollectionFk Id de colección
 */
	DECLARE vHasTooMuchCollections BOOL;
	DECLARE vItemPackingTypeFk VARCHAR(1);
	DECLARE vWarehouseFk INT;
	DECLARE vLockName VARCHAR(215);
	DECLARE vLockTime INT DEFAULT 30;
	DECLARE vErrorNumber INT;
	DECLARE vErrorMsg TEXT;

	DECLARE EXIT HANDLER FOR SQLEXCEPTION
	BEGIN
		GET DIAGNOSTICS CONDITION 1
			vErrorNumber = MYSQL_ERRNO,
			vErrorMsg = MESSAGE_TEXT;

		IF vLockName IS NOT NULL THEN
			DO RELEASE_LOCK(vLockName);
			CALL util.debugAdd('collection_assign', JSON_OBJECT(
					'errorNumber', vErrorNumber,
					'errorMsg', vErrorMsg,
					'lockName', vLockName,
					'userFk', vUserFk
				)); -- Tmp
		END IF;
		
		RESIGNAL;
	END;

	-- Si hay colecciones sin terminar, sale del proceso
	CALL collection_get(vUserFk);

	SELECT (pc.maxNotReadyCollections - COUNT(*)) <= 0, 
			collection_assign_lockname
		INTO vHasTooMuchCollections,
			vLockName
		FROM productionConfig pc
			LEFT JOIN tmp.collection ON TRUE;

	DROP TEMPORARY TABLE tmp.collection;

	IF vHasTooMuchCollections THEN
		CALL util.throw('Hay colecciones pendientes');
	END IF;

	SELECT warehouseFk, itemPackingTypeFk
		INTO vWarehouseFk, vItemPackingTypeFk
		FROM operator
		WHERE workerFk = vUserFk;

	SET vLockName = CONCAT_WS('/',
		vLockName,
		vWarehouseFk,
		vItemPackingTypeFk
	);

	IF NOT GET_LOCK(vLockName, vLockTime) THEN
		CALL util.throw(CONCAT('Cannot get lock: ', vLockName));
	END IF;

	-- Se eliminan las colecciones sin asignar que estan obsoletas
	INSERT INTO ticketTracking(stateFk, ticketFk)
			SELECT s.id, tc.ticketFk
				FROM `collection` c
					JOIN ticketCollection tc ON tc.collectionFk = c.id
					JOIN `state` s ON s.code = 'PRINTED_AUTO'
					JOIN productionConfig pc 
			WHERE c.workerFk IS NULL 
				AND TIMEDIFF(util.VN_NOW(), c.created) > pc.maxNotAssignedCollectionLifeTime;

	DELETE c.*
		FROM `collection` c
			JOIN productionConfig pc 
		WHERE c.workerFk IS NULL 
			AND TIMEDIFF(util.VN_NOW(), c.created) > pc.maxNotAssignedCollectionLifeTime;

	-- Se añade registro al semillero
	INSERT INTO collectionHotbed(userFk)
		VALUES(vUserFk);

	-- Comprueba si hay colecciones disponibles que se ajustan a su configuracion
	SELECT MIN(c.id) INTO vCollectionFk
		FROM `collection` c 
			JOIN operator o
				ON (o.itemPackingTypeFk = c.itemPackingTypeFk OR c.itemPackingTypeFk IS NULL)
				AND o.numberOfWagons = c.wagons
				AND o.trainFk = c.trainFk
				AND o.warehouseFk = c.warehouseFk
				AND c.workerFk IS NULL
				AND (c.saleTotalCount <= o.linesLimit OR o.linesLimit IS NULL)
			JOIN (
				SELECT tc.collectionFk, SUM(sv.volume) volume
					FROM ticketCollection tc
						JOIN saleVolume sv ON sv.ticketFk = tc.ticketFk
					WHERE sv.shipped >= util.VN_CURDATE()
					GROUP BY tc.collectionFk
			) sub ON sub.collectionFk = c.id
				AND (volume <= o.volumeLimit OR o.volumeLimit IS NULL)
		WHERE o.workerFk = vUserFk;

	IF vCollectionFk IS NULL THEN
		CALL collection_new(vUserFk, vCollectionFk);
	END IF;

	UPDATE `collection`
		SET workerFk = vUserFk
		WHERE id = vCollectionFk;

	DO RELEASE_LOCK(vLockName);
END$$
DELIMITER ;