523 lines
17 KiB
SQL
523 lines
17 KiB
SQL
DELIMITER $$
|
|
CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `edi`.`floramondo_offerRefresh`()
|
|
proc: BEGIN
|
|
DECLARE vLanded DATETIME;
|
|
DECLARE vDone INT DEFAULT FALSE;
|
|
DECLARE vFreeId INT;
|
|
DECLARE vSupplyResponseFk INT;
|
|
DECLARE vLastInserted DATETIME;
|
|
DECLARE vIsAuctionDay BOOLEAN;
|
|
DECLARE vMaxNewItems INT DEFAULT 10000;
|
|
DECLARE vStartingTime DATETIME;
|
|
DECLARE vAalsmeerMarketPlaceID VARCHAR(13) DEFAULT '8713783439043';
|
|
DECLARE vDayRange INT;
|
|
|
|
DECLARE cur1 CURSOR FOR
|
|
SELECT id
|
|
FROM edi.item_free;
|
|
|
|
DECLARE cur2 CURSOR FOR
|
|
SELECT srId
|
|
FROM itemToInsert;
|
|
|
|
DECLARE CONTINUE HANDLER FOR NOT FOUND SET vDone = TRUE;
|
|
DECLARE EXIT HANDLER FOR SQLSTATE '45000'
|
|
BEGIN
|
|
ROLLBACK;
|
|
RESIGNAL;
|
|
END;
|
|
|
|
DECLARE CONTINUE HANDLER FOR SQLEXCEPTION
|
|
BEGIN
|
|
DO RELEASE_LOCK('edi.floramondo_offerRefresh');
|
|
SET @isTriggerDisabled = FALSE;
|
|
RESIGNAL;
|
|
END;
|
|
|
|
IF 'test' = (SELECT environment FROM util.config) THEN
|
|
LEAVE proc;
|
|
END IF;
|
|
|
|
IF !GET_LOCK('edi.floramondo_offerRefresh', 0) THEN
|
|
LEAVE proc;
|
|
END IF;
|
|
|
|
SELECT dayRange INTO vDayRange
|
|
FROM offerRefreshConfig;
|
|
|
|
IF vDayRange IS NULL THEN
|
|
CALL util.throw("Variable vDayRange not declared");
|
|
END IF;
|
|
|
|
SET vStartingTime = util.VN_NOW();
|
|
|
|
TRUNCATE edi.offerList;
|
|
|
|
INSERT INTO edi.offerList(supplier, total)
|
|
SELECT v.name, COUNT(DISTINCT sr.ID) total
|
|
FROM edi.supplyResponse sr
|
|
JOIN edi.VMPSettings v ON v.VMPID = sr.vmpID
|
|
WHERE sr.NumberOfUnits > 0
|
|
AND sr.EmbalageCode != 999
|
|
GROUP BY sr.vmpID;
|
|
|
|
UPDATE edi.offerList o
|
|
JOIN (SELECT v.name, COUNT(*) total
|
|
FROM edi.supplyOffer sr
|
|
JOIN edi.VMPSettings v ON v.VMPID = sr.vmpID
|
|
GROUP BY sr.vmpID) sub ON o.supplier = sub.name
|
|
SET o.`filter` = sub.total;
|
|
|
|
-- Elimina de la lista de items libres aquellos que ya existen
|
|
DELETE itf.*
|
|
FROM edi.item_free itf
|
|
JOIN vn.item i ON i.id = itf.id;
|
|
|
|
CREATE OR REPLACE TEMPORARY TABLE tmp
|
|
(INDEX (`Item_ArticleCode`))
|
|
ENGINE = MEMORY
|
|
SELECT t.*
|
|
FROM (
|
|
SELECT *
|
|
FROM edi.supplyOffer
|
|
ORDER BY (MarketPlaceID = vAalsmeerMarketPlaceID) DESC,
|
|
NumberOfUnits DESC LIMIT 10000000000000000000) t
|
|
GROUP BY t.srId;
|
|
|
|
CREATE OR REPLACE TEMPORARY TABLE edi.offer (INDEX (`srID`), INDEX (`EmbalageCode`),
|
|
INDEX (`ef1`), INDEX (`ef2`), INDEX (`ef3`), INDEX (`ef4`),INDEX (`ef5`), INDEX (`ef6`),
|
|
INDEX (`s1Value`), INDEX (`s2Value`), INDEX (`s3Value`), INDEX (`s4Value`),INDEX (`s5Value`), INDEX (`s6Value`))
|
|
ENGINE = MEMORY
|
|
SELECT so.*,
|
|
ev1.type_description s1Value,
|
|
ev2.type_description s2Value,
|
|
ev3.type_description s3Value,
|
|
ev4.type_description s4Value,
|
|
ev5.type_description s5Value,
|
|
ev6.type_description s6Value,
|
|
eif1.feature ef1,
|
|
eif2.feature ef2,
|
|
eif3.feature ef3,
|
|
eif4.feature ef4,
|
|
eif5.feature ef5,
|
|
eif6.feature ef6
|
|
FROM tmp so
|
|
LEFT JOIN edi.item_feature eif1 ON eif1.item_id = so.Item_ArticleCode
|
|
AND eif1.presentation_order = 1
|
|
AND eif1.expiry_date IS NULL
|
|
LEFT JOIN edi.item_feature eif2 ON eif2.item_id = so.Item_ArticleCode
|
|
AND eif2.presentation_order = 2
|
|
AND eif2.expiry_date IS NULL
|
|
LEFT JOIN edi.item_feature eif3 ON eif3.item_id = so.Item_ArticleCode
|
|
AND eif3.presentation_order = 3
|
|
AND eif3.expiry_date IS NULL
|
|
LEFT JOIN edi.item_feature eif4 ON eif4.item_id = so.Item_ArticleCode
|
|
AND eif4.presentation_order = 4
|
|
AND eif4.expiry_date IS NULL
|
|
LEFT JOIN edi.item_feature eif5 ON eif5.item_id = so.Item_ArticleCode
|
|
AND eif5.presentation_order = 5
|
|
AND eif5.expiry_date IS NULL
|
|
LEFT JOIN edi.item_feature eif6 ON eif6.item_id = so.Item_ArticleCode
|
|
AND eif6.presentation_order = 6
|
|
AND eif6.expiry_date IS NULL
|
|
LEFT JOIN edi.`value` ev1 ON ev1.type_id = eif1.feature
|
|
AND so.s1 = ev1.type_value
|
|
LEFT JOIN edi.`value` ev2 ON ev2.type_id = eif2.feature
|
|
AND so.s2 = ev2.type_value
|
|
LEFT JOIN edi.`value` ev3 ON ev3.type_id = eif3.feature
|
|
AND so.s3 = ev3.type_value
|
|
LEFT JOIN edi.`value` ev4 ON ev4.type_id = eif4.feature
|
|
AND so.s4 = ev4.type_value
|
|
LEFT JOIN edi.`value` ev5 ON ev5.type_id = eif5.feature
|
|
AND so.s5 = ev5.type_value
|
|
LEFT JOIN edi.`value` ev6 ON ev6.type_id = eif6.feature
|
|
AND so.s6 = ev6.type_value
|
|
ORDER BY Price;
|
|
|
|
DROP TEMPORARY TABLE tmp;
|
|
|
|
DELETE o
|
|
FROM edi.offer o
|
|
LEFT JOIN vn.tag t1 ON t1.ediTypeFk = o.ef1 AND t1.overwrite = 'size'
|
|
LEFT JOIN vn.tag t2 ON t2.ediTypeFk = o.ef2 AND t2.overwrite = 'size'
|
|
LEFT JOIN vn.tag t3 ON t3.ediTypeFk = o.ef3 AND t3.overwrite = 'size'
|
|
LEFT JOIN vn.tag t4 ON t4.ediTypeFk = o.ef4 AND t4.overwrite = 'size'
|
|
LEFT JOIN vn.tag t5 ON t5.ediTypeFk = o.ef5 AND t5.overwrite = 'size'
|
|
LEFT JOIN vn.tag t6 ON t6.ediTypeFk = o.ef6 AND t6.overwrite = 'size'
|
|
JOIN vn.floramondoConfig fc ON TRUE
|
|
WHERE (t1.id IS NOT NULL AND CONVERT(s1Value, UNSIGNED) > fc.itemMaxSize)
|
|
OR (t2.id IS NOT NULL AND CONVERT(s2Value, UNSIGNED) > fc.itemMaxSize)
|
|
OR (t3.id IS NOT NULL AND CONVERT(s3Value, UNSIGNED) > fc.itemMaxSize)
|
|
OR (t4.id IS NOT NULL AND CONVERT(s4Value, UNSIGNED) > fc.itemMaxSize)
|
|
OR (t5.id IS NOT NULL AND CONVERT(s5Value, UNSIGNED) > fc.itemMaxSize)
|
|
OR (t6.id IS NOT NULL AND CONVERT(s6Value, UNSIGNED) > fc.itemMaxSize);
|
|
|
|
START TRANSACTION;
|
|
|
|
-- Actualizamos el campo supplyResponseFk para aquellos articulos que ya estan creados y reutilizamos
|
|
UPDATE IGNORE edi.offer o
|
|
JOIN vn.item i
|
|
ON i.name = o.product_name
|
|
AND i.subname <=> o.company_name
|
|
AND i.value5 <=> o.s1Value
|
|
AND i.value6 <=> o.s2Value
|
|
AND i.value7 <=> o.s3Value
|
|
AND i.value8 <=> o.s4Value
|
|
AND i.value9 <=> o.s5Value
|
|
AND i.value10 <=> o.s6Value
|
|
AND i.NumberOfItemsPerCask <=> o.NumberOfItemsPerCask
|
|
AND i.EmbalageCode <=> o.EmbalageCode
|
|
AND i.quality <=> o.Quality
|
|
JOIN vn.itemType it ON it.id = i.typeFk
|
|
LEFT JOIN vn.sale s ON s.itemFk = i.id
|
|
LEFT JOIN vn.ticket t ON t.id = s.ticketFk
|
|
AND t.shipped > (util.VN_CURDATE() - INTERVAL 1 WEEK)
|
|
LEFT JOIN edi.supplyResponse sr ON sr.ID = i.supplyResponseFk
|
|
LEFT JOIN edi.deliveryInformation di ON di.supplyResponseID = sr.ID
|
|
LEFT JOIN edi.putOrder po ON po.supplyResponseID = i.supplyResponseFk
|
|
AND po.OrderTradeLineDateTime > (util.VN_CURDATE() - INTERVAL 1 WEEK)
|
|
SET i.supplyResponseFk = o.srID
|
|
WHERE (sr.ID IS NULL
|
|
OR sr.NumberOfUnits = 0
|
|
OR di.LatestOrderDateTime < util.VN_NOW()
|
|
OR di.ID IS NULL)
|
|
AND it.isInventory
|
|
AND t.id IS NULL
|
|
AND po.id IS NULL;
|
|
|
|
CREATE OR REPLACE TEMPORARY TABLE itemToInsert
|
|
ENGINE = MEMORY
|
|
SELECT o.*, CAST(NULL AS DECIMAL(6,0)) itemFk
|
|
FROM edi.offer o
|
|
LEFT JOIN vn.item i ON i.supplyResponseFk = o.srId
|
|
WHERE i.id IS NULL
|
|
LIMIT vMaxNewItems;
|
|
|
|
-- Reciclado de nº de item
|
|
OPEN cur1;
|
|
OPEN cur2;
|
|
|
|
read_loop: LOOP
|
|
|
|
FETCH cur2 INTO vSupplyResponseFk;
|
|
FETCH cur1 INTO vFreeId;
|
|
|
|
IF vDone THEN
|
|
LEAVE read_loop;
|
|
END IF;
|
|
|
|
UPDATE itemToInsert
|
|
SET itemFk = vFreeId
|
|
WHERE srId = vSupplyResponseFk;
|
|
|
|
END LOOP;
|
|
|
|
CLOSE cur1;
|
|
CLOSE cur2;
|
|
|
|
-- Insertamos todos los items en Articles de la oferta
|
|
INSERT INTO vn.item(id,
|
|
`name`,
|
|
longName,
|
|
subName,
|
|
expenseFk,
|
|
typeFk,
|
|
intrastatFk,
|
|
originFk,
|
|
supplyResponseFk,
|
|
numberOfItemsPerCask,
|
|
embalageCode,
|
|
quality,
|
|
isFloramondo)
|
|
SELECT iti.itemFk,
|
|
iti.product_name,
|
|
iti.product_name,
|
|
iti.company_name,
|
|
iti.expenseFk,
|
|
iti.itemTypeFk,
|
|
iti.intrastatFk,
|
|
iti.originFk,
|
|
iti.`srId`,
|
|
iti.NumberOfItemsPerCask,
|
|
iti.EmbalageCode,
|
|
iti.Quality,
|
|
TRUE
|
|
FROM itemToInsert iti;
|
|
|
|
-- Inserta la foto de los articulos nuevos (prioridad alta)
|
|
INSERT IGNORE INTO vn.itemImageQueue(itemFk, url)
|
|
SELECT i.id, PictureReference
|
|
FROM itemToInsert ii
|
|
JOIN vn.item i ON i.supplyResponseFk = ii.srId
|
|
WHERE PictureReference IS NOT NULL
|
|
AND i.image IS NULL;
|
|
|
|
INSERT INTO edi.`log`(tableName, fieldName,fieldValue)
|
|
SELECT 'itemImageQueue','NumImagenesPtes', COUNT(*)
|
|
FROM vn.itemImageQueue
|
|
WHERE attempts = 0;
|
|
|
|
-- Inserta si se añadiesen tags nuevos
|
|
INSERT IGNORE INTO vn.tag (name, ediTypeFk)
|
|
SELECT description, type_id FROM edi.type;
|
|
|
|
-- Desabilita el trigger para recalcular los tags al final
|
|
SET @isTriggerDisabled = TRUE;
|
|
|
|
-- Inserta los tags sólo en los articulos nuevos
|
|
INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
|
|
SELECT i.id, t.id , ii.product_name, 1
|
|
FROM itemToInsert ii
|
|
JOIN vn.tag t ON t.`name` = 'Producto'
|
|
JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
|
|
WHERE NOT ii.product_name IS NULL;
|
|
|
|
INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
|
|
SELECT i.id, t.id , ii.Quality, 3
|
|
FROM itemToInsert ii
|
|
JOIN vn.tag t ON t.`name` = 'Calidad'
|
|
JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
|
|
WHERE NOT ii.Quality IS NULL;
|
|
|
|
INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
|
|
SELECT i.id, t.id , ii.company_name, 4
|
|
FROM itemToInsert ii
|
|
JOIN vn.tag t ON t.`name` = 'Productor'
|
|
JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
|
|
WHERE NOT ii.company_name IS NULL;
|
|
|
|
INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
|
|
SELECT i.id, t.id , s1Value, 5
|
|
FROM itemToInsert ii
|
|
JOIN vn.tag t ON t.ediTypeFk = ii.ef1
|
|
JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
|
|
WHERE NOT s1Value IS NULL;
|
|
|
|
INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
|
|
SELECT i.id, t.id , s2Value, 6
|
|
FROM itemToInsert ii
|
|
JOIN vn.tag t ON t.ediTypeFk = ii.ef2
|
|
JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
|
|
WHERE NOT s2Value IS NULL;
|
|
|
|
INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
|
|
SELECT i.id, t.id , s3Value, 7
|
|
FROM itemToInsert ii
|
|
JOIN vn.tag t ON t.ediTypeFk = ii.ef3
|
|
JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
|
|
WHERE NOT s3Value IS NULL;
|
|
|
|
INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
|
|
SELECT i.id, t.id , s4Value, 8
|
|
FROM itemToInsert ii
|
|
JOIN vn.tag t ON t.ediTypeFk = ii.ef4
|
|
JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
|
|
WHERE NOT s4Value IS NULL;
|
|
|
|
INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
|
|
SELECT i.id, t.id , s5Value, 9
|
|
FROM itemToInsert ii
|
|
JOIN vn.tag t ON t.ediTypeFk = ii.ef5
|
|
JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
|
|
WHERE NOT s5Value IS NULL;
|
|
|
|
INSERT INTO vn.itemTag(itemFk, tagFk, value, priority)
|
|
SELECT i.id, t.id , s6Value, 10
|
|
FROM itemToInsert ii
|
|
JOIN vn.tag t ON t.ediTypeFk = ii.ef6
|
|
JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
|
|
WHERE NOT s6Value IS NULL;
|
|
|
|
INSERT IGNORE INTO vn.itemTag(itemFk, tagFk, value, priority)
|
|
SELECT i.id, t.id, IFNULL(ink.name, ik.color), 11
|
|
FROM itemToInsert ii
|
|
JOIN vn.item i ON i.supplyResponseFk = ii.`srId`
|
|
JOIN vn.tag t ON t.`name` = 'Color'
|
|
LEFT JOIN edi.feature f ON f.item_id = ii.Item_ArticleCode
|
|
LEFT JOIN edi.`type` tp ON tp.type_id = f.feature_type_id
|
|
AND tp.`description` = 'Hoofdkleur 1'
|
|
LEFT JOIN vn.ink ON ink.dutchCode = f.feature_value
|
|
LEFT JOIN vn.itemInk ik ON ik.longName = i.longName
|
|
WHERE ink.name IS NOT NULL
|
|
OR ik.color IS NOT NULL;
|
|
|
|
CREATE OR REPLACE TABLE tmp.item
|
|
(PRIMARY KEY (id))
|
|
SELECT i.id FROM vn.item i
|
|
JOIN itemToInsert ii ON i.supplyResponseFk = ii.`srId`;
|
|
|
|
CALL vn.item_refreshTags();
|
|
|
|
DROP TABLE tmp.item;
|
|
|
|
SELECT MIN(LatestDeliveryDateTime) INTO vLanded
|
|
FROM edi.supplyResponse sr
|
|
JOIN edi.deliveryInformation di ON di.supplyResponseID = sr.ID
|
|
JOIN edi.marketPlace mp ON mp.id = sr.MarketPlaceID
|
|
JOIN vn.floramondoConfig fc
|
|
WHERE mp.isLatestOrderDateTimeRelevant
|
|
AND di.LatestOrderDateTime > IF(
|
|
fc.MaxLatestOrderHour > HOUR(util.VN_NOW()),
|
|
util.VN_CURDATE(),
|
|
util.VN_CURDATE() + INTERVAL 1 DAY);
|
|
|
|
UPDATE vn.floramondoConfig
|
|
SET nextLanded = vLanded
|
|
WHERE vLanded IS NOT NULL;
|
|
|
|
-- Elimina la oferta obsoleta
|
|
UPDATE vn.buy b
|
|
JOIN vn.entry e ON e.id = b.entryFk
|
|
JOIN vn.travel tr ON tr.id = e.travelFk
|
|
JOIN vn.agencyMode am ON am.id = tr.agencyModeFk
|
|
JOIN vn.item i ON i.id = b.itemFk
|
|
LEFT JOIN edi.supplyResponse sr ON i.supplyResponseFk = sr.ID
|
|
LEFT JOIN edi.deliveryInformation di ON di.ID = b.deliveryFk
|
|
SET b.quantity = 0
|
|
WHERE (IFNULL(di.LatestOrderDateTime,util.VN_NOW()) <= util.VN_NOW()
|
|
OR i.supplyResponseFk IS NULL
|
|
OR sr.NumberOfUnits = 0)
|
|
AND am.name = 'LOGIFLORA'
|
|
AND e.isRaid;
|
|
|
|
-- Localiza las entradas de cada almacen
|
|
UPDATE edi.warehouseFloramondo
|
|
SET entryFk = vn.entry_getForLogiflora(vLanded + INTERVAL travellingDays DAY, warehouseFk);
|
|
|
|
IF vLanded IS NOT NULL THEN
|
|
-- Actualiza la oferta existente
|
|
UPDATE vn.buy b
|
|
JOIN edi.warehouseFloramondo wf ON wf.entryFk = b.entryFk
|
|
JOIN vn.item i ON i.id = b.itemFk
|
|
JOIN edi.offer o ON i.supplyResponseFk = o.`srId`
|
|
SET b.quantity = o.NumberOfUnits * o.NumberOfItemsPerCask,
|
|
b.buyingValue = o.price
|
|
WHERE (b.quantity <> o.NumberOfUnits * o.NumberOfItemsPerCask
|
|
OR b.buyingValue <> o.price);
|
|
|
|
-- Inserta el resto
|
|
SET vLastInserted := util.VN_NOW();
|
|
|
|
-- Inserta la oferta
|
|
INSERT INTO vn.buy (
|
|
entryFk,
|
|
itemFk,
|
|
quantity,
|
|
buyingValue,
|
|
stickers,
|
|
packing,
|
|
`grouping`,
|
|
groupingMode,
|
|
packagingFk,
|
|
deliveryFk)
|
|
SELECT wf.entryFk,
|
|
i.id,
|
|
o.NumberOfUnits * o.NumberOfItemsPerCask quantity,
|
|
o.Price,
|
|
o.NumberOfUnits etiquetas,
|
|
o.NumberOfItemsPerCask packing,
|
|
GREATEST(1, IFNULL(o.MinimumQuantity,0)) * o.NumberOfItemsPerCask `grouping`,
|
|
'packing',
|
|
o.embalageCode,
|
|
o.diId
|
|
FROM edi.offer o
|
|
JOIN vn.item i ON i.supplyResponseFk = o.srId
|
|
JOIN edi.warehouseFloramondo wf
|
|
JOIN vn.packaging p ON p.id
|
|
LIKE o.embalageCode
|
|
LEFT JOIN vn.buy b ON b.itemFk = i.id
|
|
AND b.entryFk = wf.entryFk
|
|
WHERE b.id IS NULL; -- Quitar esta linea y mirar de crear los packages a tiempo REAL
|
|
|
|
INSERT INTO vn.itemCost(
|
|
itemFk,
|
|
warehouseFk,
|
|
cm3,
|
|
cm3delivery)
|
|
SELECT b.itemFk,
|
|
wf.warehouseFk,
|
|
@cm3 := vn.buy_getUnitVolume(b.id),
|
|
IFNULL((vc.standardFlowerBox * 1000) / i.packingOut, @cm3)
|
|
FROM warehouseFloramondo wf
|
|
JOIN vn.volumeConfig vc
|
|
JOIN vn.buy b ON b.entryFk = wf.entryFk
|
|
JOIN vn.item i ON i.id = b.itemFk
|
|
LEFT JOIN vn.itemCost ic ON ic.itemFk = b.itemFk
|
|
AND ic.warehouseFk = wf.warehouseFk
|
|
WHERE (ic.cm3 IS NULL OR ic.cm3 = 0)
|
|
ON DUPLICATE KEY UPDATE cm3 = @cm3, cm3delivery = IFNULL((vc.standardFlowerBox * 1000) / i.packingOut, @cm3);
|
|
|
|
CREATE OR REPLACE TEMPORARY TABLE tmp.buyRecalc
|
|
SELECT b.id
|
|
FROM vn.buy b
|
|
JOIN warehouseFloramondo wf ON wf.entryFk = b.entryFk
|
|
WHERE b.created >= vLastInserted;
|
|
|
|
CALL vn.buy_recalcPrices();
|
|
|
|
UPDATE edi.offerList o
|
|
JOIN (SELECT v.name, COUNT(DISTINCT b.itemFk) total
|
|
FROM vn.buy b
|
|
JOIN vn.item i ON i.id = b.itemFk
|
|
JOIN edi.supplyResponse sr ON sr.ID = i.supplyResponseFk
|
|
JOIN edi.VMPSettings v ON v.VMPID = sr.vmpID
|
|
JOIN edi.warehouseFloramondo wf ON wf.entryFk = b.entryFk
|
|
JOIN vn.warehouse w ON w.id = wf.warehouseFk
|
|
WHERE w.name = 'VNH'
|
|
AND b.quantity > 0
|
|
GROUP BY sr.vmpID) sub ON o.supplier = sub.name
|
|
SET o.vnh = sub.total;
|
|
|
|
UPDATE edi.offerList o
|
|
JOIN (SELECT v.name, COUNT(DISTINCT b.itemFk) total
|
|
FROM vn.buy b
|
|
JOIN vn.item i ON i.id = b.itemFk
|
|
JOIN edi.supplyResponse sr ON sr.ID = i.supplyResponseFk
|
|
JOIN edi.VMPSettings v ON v.VMPID = sr.vmpID
|
|
JOIN edi.warehouseFloramondo wf ON wf.entryFk = b.entryFk
|
|
JOIN vn.warehouse w ON w.id = wf.warehouseFk
|
|
WHERE w.name = 'ALGEMESI'
|
|
AND b.quantity > 0
|
|
GROUP BY sr.vmpID) sub ON o.supplier = sub.name
|
|
SET o.algemesi = sub.total;
|
|
END IF;
|
|
|
|
DROP TEMPORARY TABLE
|
|
edi.offer,
|
|
itemToInsert;
|
|
|
|
SET @isTriggerDisabled = FALSE;
|
|
|
|
COMMIT;
|
|
|
|
-- Esto habria que pasarlo a procesos programados o trabajar con tags y dejar las familias
|
|
UPDATE vn.item i
|
|
SET typeFk = 121
|
|
WHERE i.longName LIKE 'Rosa Garden %'
|
|
AND typeFk = 17;
|
|
|
|
UPDATE vn.item i
|
|
SET typeFk = 156
|
|
WHERE i.longName LIKE 'Rosa ec %'
|
|
AND typeFk = 17;
|
|
|
|
-- Refresca las fotos de los items existentes que mostramos (prioridad baja)
|
|
INSERT IGNORE INTO vn.itemImageQueue(itemFk, url, priority)
|
|
SELECT i.id, sr.PictureReference, 100
|
|
FROM edi.supplyResponse sr
|
|
JOIN vn.item i ON i.supplyResponseFk = sr.ID
|
|
JOIN edi.supplyOffer so ON so.srId = sr.ID
|
|
JOIN hedera.image i2 ON i2.name = i.image
|
|
AND i2.collectionFk = 'catalog'
|
|
WHERE i2.updated <= (UNIX_TIMESTAMP(util.VN_NOW()) - vDayRange)
|
|
AND sr.NumberOfUnits;
|
|
|
|
INSERT INTO edi.`log`
|
|
SET tableName = 'floramondo_offerRefresh',
|
|
fieldName = 'Tiempo de proceso',
|
|
fieldValue = TIMEDIFF(util.VN_NOW(), vStartingTime);
|
|
|
|
DO RELEASE_LOCK('edi.floramondo_offerRefresh');
|
|
END$$
|
|
DELIMITER ;
|