319 lines
8.2 KiB
SQL
319 lines
8.2 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 vSizeLimit INT;
|
|
DECLARE vTicketVolume DECIMAL;
|
|
DECLARE vMaxTickets INT;
|
|
DECLARE vStateCode VARCHAR(45);
|
|
DECLARE vFirstTicketFk INT;
|
|
DECLARE vWorkerCode VARCHAR(3);
|
|
DECLARE vWagonCounter INT DEFAULT 1;
|
|
DECLARE vTicketFk INT;
|
|
DECLARE vItemPackingTypeFk VARCHAR(1);
|
|
DECLARE vHasAssignedTickets BOOL;
|
|
DECLARE vHasUniqueCollectionTime BOOL;
|
|
DECLARE vHeight INT;
|
|
DECLARE vVolume INT;
|
|
DECLARE vLiters INT;
|
|
DECLARE vLines INT;
|
|
DECLARE vTotalLines INT DEFAULT 0;
|
|
DECLARE vTotalVolume INT DEFAULT 0;
|
|
DECLARE vFreeWagonFk INT;
|
|
DECLARE vDone INT DEFAULT FALSE;
|
|
|
|
DECLARE vTickets CURSOR FOR
|
|
SELECT ticketFk, `lines`, m3
|
|
FROM tmp.productionBuffer
|
|
ORDER BY HH,
|
|
mm,
|
|
productionOrder DESC,
|
|
m3 DESC,
|
|
agency,
|
|
zona,
|
|
routeFk,
|
|
ticketFk
|
|
LIMIT vMaxTickets;
|
|
|
|
DECLARE CONTINUE HANDLER FOR NOT FOUND SET vDone = TRUE;
|
|
|
|
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
|
|
INTO vMaxTickets,
|
|
vHasUniqueCollectionTime,
|
|
vWorkerCode,
|
|
vWarehouseFk,
|
|
vItemPackingTypeFk,
|
|
vStateCode,
|
|
vWagons,
|
|
vTrainFk,
|
|
vLinesLimit,
|
|
vVolumeLimit,
|
|
vSizeLimit
|
|
FROM worker w
|
|
JOIN operator o ON o.workerFk = w.id
|
|
JOIN state st ON st.`code` = 'ON_PREPARATION'
|
|
JOIN productionConfig pc
|
|
WHERE w.id = vUserFk;
|
|
|
|
-- 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;
|
|
|
|
INSERT INTO tTrain (wagon, shelve, liters, `lines`, height)
|
|
WITH RECURSIVE wagonSequence AS (
|
|
SELECT vWagonCounter wagon
|
|
UNION ALL
|
|
SELECT wagon + 1 wagon
|
|
FROM wagonSequence
|
|
WHERE wagon < vWagonCounter + vWagons -1
|
|
)
|
|
SELECT ws.wagon, cv.`level`, cv.liters, cv.`lines`, cv.height
|
|
FROM wagonSequence ws
|
|
JOIN vn.collectionVolumetry cv ON cv.trainFk = vTrainFk
|
|
AND cv.itemPackingTypeFk = vItemPackingTypeFk;
|
|
|
|
-- Esto desaparecerá cuando tengamos la table cache.ticket
|
|
|
|
CALL productionControl(vWarehouseFk, 0);
|
|
|
|
ALTER TABLE tmp.productionBuffer
|
|
ADD COLUMN liters INT,
|
|
ADD COLUMN height INT;
|
|
|
|
-- 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%';
|
|
|
|
-- Si hay tickets asignados, nos centramos exclusivamente en esos tickets
|
|
-- y los sacamos independientemente de problemas o tamaños
|
|
|
|
SELECT EXISTS (
|
|
SELECT TRUE
|
|
FROM tmp.productionBuffer pb
|
|
JOIN state s ON s.id = pb.state
|
|
WHERE s.code = 'PICKER_DESIGNED'
|
|
AND pb.workerCode = vWorkerCode
|
|
LIMIT 1
|
|
) INTO vHasAssignedTickets;
|
|
|
|
-- 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
|
|
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;
|
|
|
|
-- Hay que excluir aquellos que no tengan la misma hora de preparacion, si procede
|
|
IF vHasUniqueCollectionTime THEN
|
|
|
|
SELECT ticketFk INTO vFirstTicketFk
|
|
FROM tmp.productionBuffer
|
|
ORDER BY HH,
|
|
mm,
|
|
productionOrder DESC,
|
|
m3 DESC,
|
|
agency,
|
|
zona,
|
|
routeFk,
|
|
ticketFk
|
|
LIMIT 1;
|
|
|
|
DELETE pb
|
|
FROM tmp.productionBuffer pb
|
|
JOIN tmp.productionBuffer pb2 ON pb2.ticketFk = vFirstTicketFk
|
|
AND (pb.HH <> pb2.HH OR pb.mm <> pb2.mm);
|
|
|
|
END IF;
|
|
|
|
OPEN vTickets;
|
|
l: LOOP
|
|
SET vDone = FALSE;
|
|
FETCH vTickets INTO vTicketFk, vTicketLines, vTicketVolume;
|
|
|
|
IF vDone THEN
|
|
LEAVE l;
|
|
END IF;
|
|
|
|
-- Buscamos un ticket que cumpla con los requisitos en el listado
|
|
|
|
IF (vLinesLimit IS NULL OR (vTotalLines + vTicketLines) <= vLinesLimit)
|
|
AND (vVolumeLimit IS NULL OR (vTotalVolume + vTicketVolume) <= vVolumeLimit) THEN
|
|
|
|
CALL ticket_splitItemPackingType(vTicketFk, vItemPackingTypeFk);
|
|
DROP TEMPORARY TABLE tmp.ticketIPT;
|
|
|
|
SELECT COUNT(*), SUM(litros), MAX(i.`size`), SUM(sv.volume)
|
|
INTO vLines, vLiters, vHeight, vVolume
|
|
FROM saleVolume sv
|
|
JOIN sale s ON s.id = sv.saleFk
|
|
JOIN item i ON i.id = s.itemFk
|
|
WHERE sv.ticketFk = vTicketFk;
|
|
|
|
SET vTotalVolume = vTotalVolume + vVolume,
|
|
vTotalLines = vTotalLines + vLines;
|
|
|
|
UPDATE tmp.productionBuffer pb
|
|
SET pb.liters = vLiters,
|
|
pb.`lines` = vLines,
|
|
pb.height = vHeight
|
|
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, intentamos darle un carro entero libre
|
|
|
|
IF NOT (SELECT COUNT(*) FROM tTrain WHERE ticketFk) THEN
|
|
SELECT wagon INTO vFreeWagonFk
|
|
FROM tTrain
|
|
GROUP BY wagon
|
|
HAVING SUM(IFNULL(ticketFk, 0)) = 0
|
|
ORDER BY wagon
|
|
LIMIT 1;
|
|
|
|
IF vFreeWagonFk THEN
|
|
UPDATE tTrain
|
|
SET ticketFk = vFirstTicketFk
|
|
WHERE wagon = vFreeWagonFk;
|
|
|
|
-- Se anulan el resto de carros libres,
|
|
-- máximo un carro con pedido excesivo
|
|
|
|
DELETE tt
|
|
FROM tTrain tt
|
|
JOIN (SELECT wagon
|
|
FROM tTrain
|
|
GROUP BY wagon
|
|
HAVING SUM(IFNULL(ticketFk, 0)) = 0
|
|
) sub ON sub.wagon = tt.wagon;
|
|
END IF;
|
|
END IF;
|
|
END IF;
|
|
END LOOP;
|
|
CLOSE vTickets;
|
|
|
|
IF (SELECT COUNT(*) FROM tTrain WHERE ticketFk) THEN
|
|
-- Se obtiene nº de colección
|
|
|
|
INSERT INTO collection
|
|
SET itemPackingTypeFk = vItemPackingTypeFk,
|
|
trainFk = vTrainFk,
|
|
wagons = vWagons,
|
|
warehouseFk = vWarehouseFk;
|
|
|
|
SELECT LAST_INSERT_ID() INTO 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, vStateCode);
|
|
|
|
-- Aviso para la preparacion previa
|
|
|
|
INSERT INTO ticketDown(ticketFk, collectionFk)
|
|
SELECT tc.ticketFk, tc.collectionFk
|
|
FROM ticketCollection tc
|
|
WHERE tc.collectionFk = vCollectionFk;
|
|
|
|
CALL collection_mergeSales(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
|
|
SET vCollectionFk = NULL;
|
|
END IF;
|
|
|
|
DROP TEMPORARY TABLE
|
|
tTrain,
|
|
tmp.productionBuffer;
|
|
END$$
|
|
DELIMITER ;
|