salix/db/routines/hedera/procedures/order_confirmWithUser.sql

DELIMITER $$
CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `hedera`.`order_confirmWithUser`(
	vSelf INT,
	vUserFk INT
)
BEGIN
/**
 * Confirms an order, creating each of its tickets on
 * the corresponding date, store and user.
 *
 * @param vSelf The order identifier
 * @param vUser The user identifier
 */
	DECLARE vIsOk BOOL;
	DECLARE vDone BOOL;
	DECLARE vWarehouseFk INT;
	DECLARE vShipment DATE;
	DECLARE vTicketFk INT;
	DECLARE vNotes VARCHAR(255);
	DECLARE vItemFk INT;
	DECLARE vConcept VARCHAR(30);
	DECLARE vAmount INT;
	DECLARE vPrice DECIMAL(10,2);
	DECLARE vSaleFk INT;
	DECLARE vRate INT;
	DECLARE vRowFk INT;
	DECLARE vPriceFixed DECIMAL(10,2);
	DECLARE vDelivery DATE;
	DECLARE vAddressFk INT;
	DECLARE vIsConfirmed BOOL;
	DECLARE vClientFk INT;
	DECLARE vCompanyFk INT;
	DECLARE vAgencyModeFk INT;
	DECLARE vCalcFk INT;
	DECLARE vIsLogifloraItem BOOL;
	DECLARE vIsTaxDataChecked BOOL;
	DECLARE vAvailable INT;

	DECLARE cDates CURSOR FOR
		SELECT zgs.shipped, r.warehouseFk
			FROM `order` o
				JOIN orderRow r ON r.orderFk = o.id
				LEFT JOIN tmp.zoneGetShipped zgs ON zgs.warehouseFk = r.warehouseFk
			WHERE o.id = vSelf
				AND r.amount
			GROUP BY r.warehouseFk;

	DECLARE cRows CURSOR FOR
		SELECT r.id, r.itemFk, i.name, r.amount, r.price, r.rate, i.isFloramondo
			FROM orderRow r
				JOIN vn.item i ON i.id = r.itemFk
			WHERE r.amount
				AND r.warehouseFk = vWarehouseFk
				AND r.orderFk = vSelf
			ORDER BY r.rate DESC;

	DECLARE CONTINUE HANDLER FOR NOT FOUND SET vDone = TRUE;

	DECLARE EXIT HANDLER FOR SQLEXCEPTION
	BEGIN
		ROLLBACK;
		RESIGNAL;
	END;

	-- Carga los datos del pedido
	SELECT o.date_send,
			o.address_id,
			o.note,
			a.clientFk,
			o.company_id,
			o.agency_id,
			c.isTaxDataChecked
		INTO vDelivery,
			vAddressFk,
			vNotes,
			vClientFk,
			vCompanyFk,
			vAgencyModeFk,
			vIsTaxDataChecked
		FROM `order` o
			JOIN vn.address a ON a.id = o.address_id
			JOIN vn.client c ON c.id = a.clientFk
		WHERE o.id = vSelf;

	-- Verifica si el cliente tiene los datos comprobados
	IF NOT vIsTaxDataChecked THEN
		CALL util.throw('clientNotVerified');
	END IF;

	-- Carga las fechas de salida de cada almacen
	CALL vn.zone_getShipped(vDelivery, vAddressFk, vAgencyModeFk, FALSE);

	-- Trabajador que realiza la accion
	IF vUserFk IS NULL THEN
		SELECT employeeFk INTO vUserFk FROM orderConfig;
	END IF;

	START TRANSACTION;

	CALL order_checkEditable(vSelf);

	-- Check order is not empty
	SELECT COUNT(*) > 0 INTO vIsOk
		FROM orderRow
		WHERE orderFk = vSelf
			AND amount > 0;

	IF NOT vIsOk THEN
		CALL util.throw('ORDER_EMPTY');
	END IF;

	-- Crea los tickets del pedido
	OPEN cDates;
	lDates:
	LOOP
		SET vTicketFk = NULL;
		SET vDone = FALSE;
		FETCH cDates INTO vShipment, vWarehouseFk;

		IF vDone THEN
			LEAVE lDates;
		END IF;

		-- Busca un ticket existente que coincida con los parametros
		WITH tPrevia AS (
			SELECT DISTINCT s.ticketFk
				FROM vn.sale s
					JOIN vn.saleGroupDetail sgd ON sgd.saleFk = s.id
					JOIN vn.ticket t ON t.id = s.ticketFk
				WHERE t.shipped BETWEEN vShipment AND util.dayend(vShipment)
		)
		SELECT t.id INTO vTicketFk
			FROM vn.ticket t
				JOIN vn.alertLevel al ON al.code = 'FREE'
				LEFT JOIN tPrevia tp ON tp.ticketFk = t.id
				LEFT JOIN vn.ticketState tls on tls.ticketFk = t.id
				JOIN hedera.`order` o ON o.address_id = t.addressFk
					AND vWarehouseFk = t.warehouseFk
					AND o.date_send = t.landed
					AND DATE(t.shipped) = vShipment
			WHERE o.id = vSelf
				AND t.refFk IS NULL
				AND tp.ticketFk IS NULL
				AND (tls.alertLevel IS NULL OR tls.alertLevel = al.id)
			LIMIT 1;

		-- Crea el ticket en el caso de no existir uno adecuado
		IF vTicketFk IS NULL THEN
			SET vShipment = IFNULL(vShipment, util.VN_CURDATE());
			CALL vn.ticket_add(
				vClientFk,
				vShipment,
				vWarehouseFk,
				vCompanyFk,
				vAddressFk,
				vAgencyModeFk,
				NULL,
				vDelivery,
				vUserFk,
				TRUE,
				vTicketFk
			);
		ELSE
			INSERT INTO vn.ticketTracking
				SET ticketFk = vTicketFk,
					userFk = vUserFk,
					stateFk = (SELECT id FROM vn.state WHERE code = 'FREE');
		END IF;

		INSERT IGNORE INTO vn.orderTicket
			SET orderFk = vSelf,
				ticketFk = vTicketFk;

		-- Añade las notas
		IF vNotes IS NOT NULL AND vNotes <> '' THEN
			INSERT INTO vn.ticketObservation SET
					ticketFk = vTicketFk,
					observationTypeFk = (SELECT id FROM vn.observationType WHERE code = 'salesPerson'),
					`description` = vNotes
				ON DUPLICATE KEY UPDATE
					`description` = CONCAT(VALUES(`description`),'. ', `description`);
		END IF;

		-- Añade los movimientos y sus componentes
		OPEN cRows;
		lRows: LOOP
			SET vDone = FALSE;
			FETCH cRows INTO vRowFk, vItemFk, vConcept, vAmount, vPrice, vRate, vIsLogifloraItem;

			IF vDone THEN
				LEAVE lRows;
			END IF;

			SET vSaleFk = NULL;

			SELECT s.id INTO vSaleFk
				FROM vn.sale s
				WHERE ticketFk = vTicketFk
					AND price = vPrice
					AND itemFk = vItemFk
					AND discount = 0
				LIMIT 1;

			IF vSaleFk THEN
				UPDATE vn.sale
					SET quantity = quantity + vAmount,
						originalQuantity = quantity
					WHERE id = vSaleFk;
			ELSE
				-- Obtiene el coste
				SELECT SUM(rc.`price`) valueSum INTO vPriceFixed
					FROM orderRowComponent rc
						JOIN vn.component c ON c.id = rc.componentFk
						JOIN vn.componentType ct ON ct.id = c.typeFk AND ct.isBase
					WHERE rc.rowFk = vRowFk;

				INSERT INTO vn.sale
					SET itemFk = vItemFk,
						ticketFk = vTicketFk,
						concept = vConcept,
						quantity = vAmount,
						price = vPrice,
						priceFixed = vPriceFixed,
						isPriceFixed = TRUE;

				SET vSaleFk = LAST_INSERT_ID();

				INSERT INTO vn.saleComponent (saleFk, componentFk, `value`)
					SELECT vSaleFk, rc.componentFk, rc.price
						FROM orderRowComponent rc
							JOIN vn.component c ON c.id = rc.componentFk
						WHERE rc.rowFk = vRowFk
						GROUP BY vSaleFk, rc.componentFk;
			END IF;

			UPDATE orderRow
				SET saleFk = vSaleFk
				WHERE id = vRowFk;

			-- Inserta en putOrder si la compra es de Floramondo
			IF vIsLogifloraItem THEN
				CALL cache.availableNoRaids_refresh(vCalcFk, FALSE,vWarehouseFk, vShipment);

				SELECT GREATEST(0, available) INTO vAvailable
					FROM cache.availableNoRaids
					WHERE calc_id = vCalcFk
						AND item_id = vItemFk;

				UPDATE cache.availableNoRaids
					SET available = GREATEST(0, available - vAmount)
					WHERE item_id = vItemFk
						AND calc_id = vCalcFk;

				INSERT INTO edi.putOrder (
						deliveryInformationID,
						supplyResponseId,
						quantity ,
						EndUserPartyId,
						EndUserPartyGLN,
						FHAdminNumber,
						saleFk
					)
					SELECT di.ID,
							i.supplyResponseFk,
							CEIL((vAmount - vAvailable)/ sr.NumberOfItemsPerCask),
							o.address_id ,
							vClientFk,
							IFNULL(ca.fhAdminNumber, fhc.defaultAdminNumber),
							vSaleFk
						FROM edi.deliveryInformation di
							JOIN vn.item i ON i.supplyResponseFk = di.supplyResponseID
							JOIN edi.supplyResponse sr ON sr.ID = i.supplyResponseFk
							LEFT JOIN edi.clientFHAdminNumber ca ON ca.clientFk = vClientFk
							JOIN edi.floraHollandConfig fhc
							JOIN `order` o ON o.id = vSelf
						WHERE i.id = vItemFk
							AND di.LatestOrderDateTime > util.VN_NOW()
							AND vAmount > vAvailable
						LIMIT 1;
			END IF;
		END LOOP;
		CLOSE cRows;
	END LOOP;
	CLOSE cDates;

	UPDATE `order`
		SET confirmed = TRUE,
			confirm_date = util.VN_NOW()
		WHERE id = vSelf;

	COMMIT;
END$$
DELIMITER ;