salix/db/routines/stock/procedures/stock_refreshAll.sql

DELIMITER $$
CREATE OR REPLACE DEFINER=`vn`@`localhost` PROCEDURE `stock`.`stock_refreshAll`()
BEGIN
/**
 * Recalculates the entire cache. It takes a considerable time,
 * please avoid calls to this procedure from commonly used operations.
 */
	DECLARE vDone BOOL;
	DECLARE vId INT;

	DECLARE vBuys CURSOR FOR
		SELECT lotFk FROM vn.buy WHERE isAlive;

	DECLARE vTickets CURSOR FOR
		SELECT id FROM vn.ticket WHERE isAlive;

	DECLARE vOrders CURSOR FOR
		SELECT lotFk FROM hedera.orderRow WHERE isReserved;

	DECLARE CONTINUE HANDLER FOR NOT FOUND
		SET vDone = TRUE;

	DECLARE EXIT HANDLER FOR SQLEXCEPTION
	BEGIN
		DO RELEASE_LOCK('stock.stock_refreshAll');
		RESIGNAL;
	END;

	IF NOT GET_LOCK('stock.stock_refreshAll', 30) THEN
		CALL util.throw('Lock timeout exceeded');
	END IF;

	-- Prune cache

	DELETE p FROM buyPick p JOIN buyLot l USING(lotFk);
	TRUNCATE TABLE buyLot;
	TRUNCATE TABLE buyOut;

	-- Populate cache

	OPEN vBuys;
	buyLoop: LOOP
		SET vDone = FALSE;
		FETCH vBuys INTO vId;

		IF vDone THEN
			LEAVE buyLoop;
		END IF;

		CALL buyOut_refreshBuy('lot', vId);
	END LOOP;
	CLOSE vBuys;

	OPEN vOrders;
	orderLoop: LOOP
		SET vDone = FALSE;
		FETCH vOrders INTO vId;

		IF vDone THEN
			LEAVE orderLoop;
		END IF;

		CALL buyOut_refreshOrder('lot', vId);
	END LOOP;
	CLOSE vOrders;

	OPEN vTickets;
	saleLoop: LOOP
		SET vDone = FALSE;
		FETCH vTickets INTO vId;

		IF vDone THEN
			LEAVE saleLoop;
		END IF;

		CALL buyOut_refreshSale('ticket', vId);
	END LOOP;
	CLOSE vTickets;

	-- Synchronize

	UPDATE buyOut SET isSync = TRUE;
	CALL stock_sync;

	DO RELEASE_LOCK('stock.stock_refreshAll');
END$$
DELIMITER ;