304 lines
8.0 KiB
MySQL
304 lines
8.0 KiB
MySQL
|
DELIMITER $$
|
||
|
|
CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`collection_new`(vUserFk INT, OUT vCollectionFk INT)
|
||
|
|
proc:BEGIN
|
||
|
|
/**
|
||
|
|
* Genera colecciones de tickets sin asignar trabajador.
|
||
|
|
*
|
||
|
|
* @param vUserFk Identificador de account.user
|
||
|
|
*/
|
||
|
|
DECLARE vWarehouseFk INT;
|
||
|
|
DECLARE vWagons INT;
|
||
|
|
DECLARE vTrainFk 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 15;
|
||
|
|
DECLARE vFreeWagonFk INT;
|
||
|
|
DECLARE cur1 CURSOR FOR
|
||
|
|
SELECT ticketFk
|
||
|
|
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;
|
||
|
|
|
||
|
|
SELECT
|
||
|
|
pc.ticketTrolleyMax * o.numberOfWagons,
|
||
|
|
pc.hasUniqueCollectionTime,
|
||
|
|
w.code,
|
||
|
|
o.warehouseFk,
|
||
|
|
o.itemPackingTypeFk,
|
||
|
|
st.code,
|
||
|
|
CONCAT('collection_new', o.warehouseFk, ':',o.itemPackingTypeFk),
|
||
|
|
o.numberOfWagons,
|
||
|
|
o.trainFk
|
||
|
|
INTO
|
||
|
|
vMaxTickets,
|
||
|
|
vHasUniqueCollectionTime,
|
||
|
|
vWorkerCode,
|
||
|
|
vWarehouseFk,
|
||
|
|
vItemPackingTypeFk,
|
||
|
|
vStateFk,
|
||
|
|
vLockName,
|
||
|
|
vWagons,
|
||
|
|
vTrainFk
|
||
|
|
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;
|
||
|
|
|
||
|
|
IF NOT GET_LOCK(vLockName,vLockTime) THEN
|
||
|
|
LEAVE proc;
|
||
|
|
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
|
||
|
|
JOIN productionConfig pc
|
||
|
|
WHERE pb.shipped <> util.VN_CURDATE()
|
||
|
|
OR (pb.ubicacion IS NULL AND a.isOwn = TRUE)
|
||
|
|
OR (s.isPreparable = FALSE AND s.isPrintable = FALSE)
|
||
|
|
OR pb.collectionH IS NOT NULL
|
||
|
|
OR pb.collectionV IS NOT NULL
|
||
|
|
OR pb.collectionN IS NOT NULL
|
||
|
|
OR (pb.H = 0 AND pb.V > 0 AND vItemPackingTypeFk = 'H')
|
||
|
|
OR (pb.V = 0 AND vItemPackingTypeFk = 'V')
|
||
|
|
OR (pc.isPreviousPreparationRequired AND pb.previousWithoutParking)
|
||
|
|
OR LENGTH(pb.problem) > 0;
|
||
|
|
END IF;
|
||
|
|
|
||
|
|
-- Es importante que el primer ticket se coja en todos los casos
|
||
|
|
SELECT ticketFk, HH, mm
|
||
|
|
INTO vFirstTicketFk, vHour, vMinute
|
||
|
|
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;
|
||
|
|
|
||
|
|
OPEN cur1;
|
||
|
|
|
||
|
|
read_loop: LOOP
|
||
|
|
SET vDone = FALSE;
|
||
|
|
|
||
|
|
CALL ticket_splitItemPackingType(vTicketFk, vItemPackingTypeFk);
|
||
|
|
|
||
|
|
DROP TEMPORARY TABLE tmp.ticketIPT;
|
||
|
|
|
||
|
|
UPDATE tmp.productionBuffer pb
|
||
|
|
JOIN (SELECT @litros:= SUM(litros) liters, COUNT(*) `lines`, MAX(i.`size`) height
|
||
|
|
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 cur1 INTO vTicketFk;
|
||
|
|
|
||
|
|
IF vDone OR NOT (SELECT COUNT(*) FROM tTrain WHERE ticketFk IS NULL) THEN
|
||
|
|
LEAVE read_loop;
|
||
|
|
END IF;
|
||
|
|
END LOOP;
|
||
|
|
|
||
|
|
CLOSE cur1;
|
||
|
|
|
||
|
|
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
|
||
|
|
|
||
|
|
-- CALL util.throw('No ha sido posible obtener colección');
|
||
|
|
DELETE FROM collection WHERE id = vCollectionFk;
|
||
|
|
SET vCollectionFk = NULL;
|
||
|
|
|
||
|
|
END IF;
|
||
|
|
|
||
|
|
DO RELEASE_LOCK(vLockName);
|
||
|
|
|
||
|
|
DROP TEMPORARY TABLE
|
||
|
|
tTrain,
|
||
|
|
tmp.productionBuffer;
|
||
|
|
END$$
|
||
|
|
DELIMITER ;
|