372 lines
9.7 KiB
SQL
372 lines
9.7 KiB
SQL
DELIMITER $$
|
|
CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`collection_new`(vUserFk INT, OUT vCollectionFk INT)
|
|
BEGIN
|
|
/**
|
|
* Genera colecciones de tickets sin asignar trabajador.
|
|
*
|
|
* @param vUserFk Identificador de account.user
|
|
*/
|
|
DECLARE vWarehouseFk INT;
|
|
DECLARE vWagons INT;
|
|
DECLARE vTrainFk INT;
|
|
DECLARE vLinesLimit INT;
|
|
DECLARE vTicketLines INT;
|
|
DECLARE vVolumeLimit DECIMAL;
|
|
DECLARE vTicketVolume DECIMAL;
|
|
DECLARE vSizeLimit INT;
|
|
DECLARE vMaxTickets INT;
|
|
DECLARE vStateFk VARCHAR(45);
|
|
DECLARE vFirstTicketFk INT;
|
|
DECLARE vHour INT;
|
|
DECLARE vMinute INT;
|
|
DECLARE vWorkerCode VARCHAR(3);
|
|
DECLARE vWagonCounter INT DEFAULT 0;
|
|
DECLARE vTicketFk INT;
|
|
DECLARE vItemPackingTypeFk VARCHAR(1);
|
|
DECLARE vHasAssignedTickets BOOLEAN;
|
|
DECLARE vHasUniqueCollectionTime BOOL;
|
|
DECLARE vDone INT DEFAULT FALSE;
|
|
DECLARE vLockName VARCHAR(215);
|
|
DECLARE vLockTime INT DEFAULT 30;
|
|
DECLARE vFreeWagonFk INT;
|
|
DECLARE vErrorNumber INT;
|
|
DECLARE vErrorMsg TEXT;
|
|
|
|
DECLARE c1 CURSOR FOR
|
|
SELECT ticketFk, `lines`, m3
|
|
FROM tmp.productionBuffer
|
|
WHERE ticketFk <> vFirstTicketFk
|
|
ORDER BY HH,
|
|
mm,
|
|
productionOrder DESC,
|
|
m3 DESC,
|
|
agency,
|
|
zona,
|
|
routeFk,
|
|
ticketFk
|
|
LIMIT vMaxTickets;
|
|
|
|
DECLARE CONTINUE HANDLER FOR NOT FOUND SET vDone = TRUE;
|
|
|
|
DECLARE EXIT HANDLER FOR SQLEXCEPTION
|
|
BEGIN
|
|
GET DIAGNOSTICS CONDITION 1
|
|
vErrorNumber = MYSQL_ERRNO,
|
|
vErrorMsg = MESSAGE_TEXT;
|
|
|
|
CALL util.debugAdd('collection_new', JSON_OBJECT(
|
|
'errorNumber', vErrorNumber,
|
|
'errorMsg', vErrorMsg,
|
|
'lockName', vLockName,
|
|
'userFk', vUserFk,
|
|
'ticketFk', vTicketFk
|
|
)); -- Tmp
|
|
|
|
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,
|
|
o.numberOfWagons,
|
|
o.trainFk,
|
|
o.linesLimit,
|
|
o.volumeLimit,
|
|
o.sizeLimit,
|
|
pc.collection_new_lockname
|
|
INTO vMaxTickets,
|
|
vHasUniqueCollectionTime,
|
|
vWorkerCode,
|
|
vWarehouseFk,
|
|
vItemPackingTypeFk,
|
|
vStateFk,
|
|
vWagons,
|
|
vTrainFk,
|
|
vLinesLimit,
|
|
vVolumeLimit,
|
|
vSizeLimit,
|
|
vLockName
|
|
FROM productionConfig pc
|
|
JOIN worker w ON w.id = vUserFk
|
|
JOIN state st ON st.`code` = 'ON_PREPARATION'
|
|
JOIN operator o ON o.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 prepara el tren, con tantos vagones como sea necesario.
|
|
CREATE OR REPLACE TEMPORARY TABLE tTrain
|
|
(wagon INT,
|
|
shelve INT,
|
|
liters INT,
|
|
`lines`INT,
|
|
height INT,
|
|
ticketFk INT,
|
|
PRIMARY KEY(wagon, shelve))
|
|
ENGINE = MEMORY;
|
|
|
|
WHILE vWagons > vWagonCounter DO
|
|
SET vWagonCounter = vWagonCounter + 1;
|
|
|
|
INSERT INTO tTrain(wagon, shelve, liters, `lines`, height)
|
|
SELECT vWagonCounter, cv.`level` , cv.liters , cv.`lines` , cv.height
|
|
FROM collectionVolumetry cv
|
|
WHERE cv.trainFk = vTrainFk
|
|
AND cv.itemPackingTypeFk = vItemPackingTypeFk;
|
|
END WHILE;
|
|
|
|
-- Esto desaparecerá cuando tengamos la table cache.ticket
|
|
CALL productionControl(vWarehouseFk, 0);
|
|
|
|
ALTER TABLE tmp.productionBuffer
|
|
ADD COLUMN liters INT,
|
|
ADD COLUMN height INT;
|
|
|
|
-- Se obtiene nº de colección.
|
|
INSERT INTO collection
|
|
SET itemPackingTypeFk = vItemPackingTypeFk,
|
|
trainFk = vTrainFk,
|
|
wagons = vWagons,
|
|
warehouseFk = vWarehouseFk;
|
|
|
|
SELECT LAST_INSERT_ID() INTO vCollectionFk;
|
|
|
|
-- Los tickets de recogida en Algemesí sólo se sacan si están asignados.
|
|
-- Los pedidos con riesgo no se sacan aunque se asignen.
|
|
DELETE pb.*
|
|
FROM tmp.productionBuffer pb
|
|
JOIN state s ON s.id = pb.state
|
|
WHERE (pb.agency = 'REC_ALGEMESI'
|
|
AND s.code <> 'PICKER_DESIGNED')
|
|
OR pb.problem LIKE '%RIESGO%';
|
|
|
|
-- Comprobamos si hay tickets asignados. En ese caso, nos centramos
|
|
-- exclusivamente en esos tickets y los sacamos independientemente
|
|
-- de problemas o tamaños
|
|
SELECT COUNT(*) INTO vHasAssignedTickets
|
|
FROM tmp.productionBuffer pb
|
|
JOIN state s ON s.id = pb.state
|
|
WHERE s.code = 'PICKER_DESIGNED'
|
|
AND pb.workerCode = vWorkerCode;
|
|
|
|
-- Se dejan en la tabla tmp.productionBuffer sólo aquellos tickets adecuados
|
|
IF vHasAssignedTickets THEN
|
|
DELETE pb.*
|
|
FROM tmp.productionBuffer pb
|
|
JOIN state s ON s.id = pb.state
|
|
WHERE s.code <> 'PICKER_DESIGNED'
|
|
OR pb.workerCode <> vWorkerCode;
|
|
ELSE
|
|
DELETE pb.*
|
|
FROM tmp.productionBuffer pb
|
|
JOIN state s ON s.id = pb.state
|
|
JOIN agencyMode am ON am.id = pb.agencyModeFk
|
|
JOIN agency a ON a.id = am.agencyFk
|
|
LEFT JOIN (
|
|
SELECT pb.ticketFk, MAX(i.`size`) maxSize
|
|
FROM tmp.productionBuffer pb
|
|
JOIN ticket t ON t.id = pb.ticketfk
|
|
JOIN sale s ON s.ticketFk = t.id
|
|
JOIN item i ON i.id = s.itemFk
|
|
GROUP BY pb.ticketFk
|
|
) sub ON sub.ticketFk = pb.ticketFk
|
|
JOIN productionConfig pc
|
|
WHERE pb.shipped <> util.VN_CURDATE()
|
|
OR (pb.ubicacion IS NULL AND a.isOwn)
|
|
OR (NOT s.isPreparable AND NOT s.isPrintable)
|
|
OR pb.collectionH IS NOT NULL
|
|
OR pb.collectionV IS NOT NULL
|
|
OR pb.collectionN IS NOT NULL
|
|
OR (NOT pb.H AND pb.V > 0 AND vItemPackingTypeFk = 'H')
|
|
OR (NOT pb.V AND vItemPackingTypeFk = 'V')
|
|
OR (pc.isPreviousPreparationRequired AND pb.previousWithoutParking)
|
|
OR LENGTH(pb.problem) > 0
|
|
OR pb.lines > vLinesLimit
|
|
OR pb.m3 > vVolumeLimit
|
|
OR sub.maxSize > vSizeLimit;
|
|
END IF;
|
|
|
|
-- Es importante que el primer ticket se coja en todos los casos
|
|
SELECT ticketFk,
|
|
HH,
|
|
mm,
|
|
`lines`,
|
|
m3
|
|
INTO vFirstTicketFk,
|
|
vHour,
|
|
vMinute,
|
|
vTicketLines,
|
|
vTicketVolume
|
|
FROM tmp.productionBuffer
|
|
ORDER BY HH,
|
|
mm,
|
|
productionOrder DESC,
|
|
m3 DESC,
|
|
agency,
|
|
zona,
|
|
routeFk,
|
|
ticketFk
|
|
LIMIT 1;
|
|
|
|
-- Hay que excluir aquellos que no tengan la misma hora de preparacion, si procede
|
|
IF vHasUniqueCollectionTime THEN
|
|
DELETE FROM tmp.productionBuffer
|
|
WHERE HH <> vHour
|
|
OR mm <> vMinute;
|
|
END IF;
|
|
|
|
SET vTicketFk = vFirstTicketFk;
|
|
SET @lines = 0;
|
|
SET @volume = 0;
|
|
|
|
OPEN c1;
|
|
read_loop: LOOP
|
|
SET vDone = FALSE;
|
|
|
|
-- Buscamos un ticket que cumpla con los requisitos en el listado
|
|
IF ((vTicketLines + @lines) <= vLinesLimit OR vLinesLimit IS NULL)
|
|
AND ((vTicketVolume + @volume) <= vVolumeLimit OR vVolumeLimit IS NULL) THEN
|
|
|
|
CALL ticket_splitItemPackingType(vTicketFk, vItemPackingTypeFk);
|
|
DROP TEMPORARY TABLE tmp.ticketIPT;
|
|
|
|
UPDATE tmp.productionBuffer pb
|
|
JOIN (
|
|
SELECT SUM(litros) liters,
|
|
@lines:= COUNT(*) + @lines,
|
|
COUNT(*) `lines`,
|
|
MAX(i.`size`) height,
|
|
@volume := SUM(sv.volume) + @volume,
|
|
SUM(sv.volume) volume
|
|
FROM saleVolume sv
|
|
JOIN sale s ON s.id = sv.saleFk
|
|
JOIN item i ON i.id = s.itemFk
|
|
WHERE sv.ticketFk = vTicketFk
|
|
) sub
|
|
SET pb.liters = sub.liters,
|
|
pb.`lines` = sub.`lines`,
|
|
pb.height = sub.height
|
|
WHERE pb.ticketFk = vTicketFk;
|
|
|
|
UPDATE tTrain tt
|
|
JOIN tmp.productionBuffer pb ON pb.ticketFk = vTicketFk
|
|
SET tt.ticketFk = pb.ticketFk
|
|
WHERE tt.liters >= pb.liters
|
|
AND tt.`lines` >= pb.`lines`
|
|
AND (tt.height >= pb.height OR vItemPackingTypeFk <> 'V')
|
|
AND tt.ticketFk IS NULL
|
|
ORDER BY wagon,
|
|
shelve,
|
|
tt.liters,
|
|
tt.`lines`,
|
|
tt.height
|
|
LIMIT 1;
|
|
|
|
-- Si no le encuentra una balda adecuada, intentamos darle un carro entero si queda alguno libre
|
|
IF NOT (SELECT COUNT(*) FROM tTrain WHERE ticketFk) THEN
|
|
SELECT tt.wagon
|
|
INTO vFreeWagonFk
|
|
FROM tTrain tt
|
|
LEFT JOIN (
|
|
SELECT DISTINCT wagon
|
|
FROM tTrain
|
|
WHERE ticketFk IS NOT NULL
|
|
) nn ON nn.wagon = tt.wagon
|
|
WHERE nn.wagon IS NULL
|
|
ORDER BY wagon
|
|
LIMIT 1;
|
|
|
|
IF vFreeWagonFk THEN
|
|
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
|
|
WHERE ticketFk IS NOT NULL
|
|
) nn ON nn.wagon = tt.wagon
|
|
WHERE nn.wagon IS NULL;
|
|
END IF;
|
|
END IF;
|
|
|
|
FETCH c1 INTO vTicketFk, vTicketLines, vTicketVolume;
|
|
IF vDone OR NOT (SELECT COUNT(*) FROM tTrain WHERE ticketFk IS NULL) THEN
|
|
LEAVE read_loop;
|
|
END IF;
|
|
ELSE
|
|
FETCH c1 INTO vTicketFk, vTicketLines, vTicketVolume;
|
|
IF vDone THEN
|
|
LEAVE read_loop;
|
|
END IF;
|
|
END IF;
|
|
END LOOP;
|
|
CLOSE c1;
|
|
|
|
IF (SELECT COUNT(*) FROM tTrain WHERE ticketFk) THEN
|
|
UPDATE collection c
|
|
JOIN state st ON st.code = 'ON_PREPARATION'
|
|
SET c.stateFk = st.id
|
|
WHERE c.id = vCollectionFk;
|
|
|
|
-- Asigna las bandejas
|
|
INSERT IGNORE INTO ticketCollection(ticketFk, collectionFk, `level`, wagon, liters)
|
|
SELECT tt.ticketFk, vCollectionFk, tt.shelve, tt.wagon, tt.liters
|
|
FROM tTrain tt
|
|
WHERE tt.ticketFk IS NOT NULL
|
|
ORDER BY tt.wagon, tt.shelve;
|
|
|
|
-- Actualiza el estado de los tickets
|
|
CALL collection_setState(vCollectionFk, vStateFk);
|
|
|
|
-- Aviso para la preparacion previa
|
|
INSERT INTO ticketDown(ticketFk, collectionFk)
|
|
SELECT tc.ticketFk, tc.collectionFk
|
|
FROM ticketCollection tc
|
|
WHERE tc.collectionFk = vCollectionFk;
|
|
|
|
CALL sales_mergeByCollection(vCollectionFk);
|
|
|
|
UPDATE `collection` c
|
|
JOIN (
|
|
SELECT COUNT(*) saleTotalCount,
|
|
SUM(s.isPicked <> 0) salePickedCount
|
|
FROM ticketCollection tc
|
|
JOIN sale s ON s.ticketFk = tc.ticketFk
|
|
WHERE tc.collectionFk = vCollectionFk
|
|
AND s.quantity > 0
|
|
) sub
|
|
SET c.saleTotalCount = sub.saleTotalCount,
|
|
c.salePickedCount = sub.salePickedCount
|
|
WHERE c.id = vCollectionFk;
|
|
|
|
ELSE
|
|
DELETE FROM `collection`
|
|
WHERE id = vCollectionFk;
|
|
SET vCollectionFk = NULL;
|
|
END IF;
|
|
|
|
DO RELEASE_LOCK(vLockName);
|
|
|
|
DROP TEMPORARY TABLE
|
|
tTrain,
|
|
tmp.productionBuffer;
|
|
END$$
|
|
DELIMITER ;
|