DELIMITER $$ CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`collection_getAssigned`( vUserFk INT, OUT vCollectionFk INT) proc: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 y hace la reserva para la colección * @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 EXIT HANDLER FOR SQLEXCEPTION BEGIN IF vLockName IS NOT NULL THEN DO RELEASE_LOCK(vLockName); 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 tCollection JOIN productionConfig pc ; DROP TEMPORARY TABLE tCollection; IF vHasTooMuchCollections THEN CALL util.throw('Hay colecciones pendientes'); LEAVE proc; 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 SET userFk = 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 WHERE o.workerFk = vUserFk; IF vCollectionFk IS NULL THEN CALL collection_new(vUserFk, vCollectionFk); END IF; UPDATE collection SET workerFk = vUserFk WHERE id = vCollectionFk; CALL itemShelvingSale_addByCollection(vCollectionFk); DO RELEASE_LOCK(vLockName); END$$ DELIMITER ;