salix/db/routines/bi/procedures/Greuge_Evolution_Add.sql

DELIMITER $$
CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `bi`.`Greuge_Evolution_Add`()
BEGIN
/*
	Inserta en la tabla Greuge_Evolution el saldo acumulado de cada cliente,
	así como las ventas acumuladas en los ultimos 365 dias, para poder controlar
	su evolucion.
*/
	DECLARE datFEC DATE;
	DECLARE datFEC_TOMORROW DATE;
	DECLARE datFEC_LASTYEAR DATE;
   
    DECLARE EXIT HANDLER FOR SQLEXCEPTION BEGIN 
	    
		GET DIAGNOSTICS CONDITION 2 @errno = MYSQL_ERRNO, @text = MESSAGE_TEXT;
		SELECT CONCAT('ERROR ', IFNULL(@errno,0), ': ', ifnull(@text,'texto'));
		CALL vn.mail_insert(
			'jgallego@verdnatura.es,pako@verdnatura.es',
			'noreply@verdnatura.es',
			'Greuge_Evolution_Add',
			CONCAT('ERROR ', IFNULL(@errno, 0), ': ', ifnull(@text, 'texto'))
		);
	
	END;
  
	SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED;

	DELETE FROM bi.Greuge_Evolution WHERE Fecha >= TIMESTAMPADD(MONTH,-1,util.VN_CURDATE());

	SELECT 	TIMESTAMPADD(DAY,1,MAX(Fecha)),
			TIMESTAMPADD(DAY,2,MAX(Fecha))
		INTO  datFEC,
				datFEC_TOMORROW
		FROM bi.Greuge_Evolution;

	SET datFEC_LASTYEAR = TIMESTAMPADD(YEAR,-1,datFEC);

	DELETE FROM bi.Greuge_Evolution WHERE Fecha >= datFEC;
    
	DROP TEMPORARY TABLE IF EXISTS maxInvoice;
    
	CREATE TEMPORARY TABLE maxInvoice
		(PRIMARY KEY (Id_Cliente))
		ENGINE = MEMORY
		SELECT DISTINCT clientFk Id_Cliente, max(issued) as maxFecha
			   FROM vn.invoiceOut
			   GROUP BY clientFk
			   HAVING maxFecha < timestampadd(month,-2,datFEC);
    
	WHILE datFEC < util.VN_CURDATE() DO

		REPLACE bi.Greuge_Evolution(Id_Cliente, Fecha, Greuge, Ventas, Fosil)

		SELECT Id_Cliente, datFEC as Fecha, Greuge, Ventas, 0
			FROM (
				SELECT clientFk Id_Cliente, sum(amount) as Greuge
					FROM vn2.greuge
						where shipped <= datFEC
						group by clientFk
			) sub
			RIGHT JOIN
			
				(
				
					SELECT Id_Cliente, sum(Ventas) as Ventas
					FROM
					(
					
						SELECT Id_Cliente, IF (fecha != datFEC, -1,1) * (importe + recargo) as Ventas
							FROM bs.ventas
							WHERE fecha = datFEC or fecha = datFEC_LASTYEAR
						
						UNION ALL
						
						SELECT Id_Cliente, Ventas
							FROM bi.Greuge_Evolution
							WHERE Fecha = TIMESTAMPADD(DAY, -1, datFEC)
						
					) sub
					group by Id_Cliente
					
				) v using(Id_Cliente) 
			;
			
		-- Ahora calcularemos el greuge muerto
		UPDATE bi.Greuge_Evolution ge 
				JOIN maxInvoice m using(Id_Cliente)
			SET FOSIL = GREUGE
			WHERE m.maxFecha < TIMESTAMPADD(MONTH,-2,ge.Fecha);

		-- Recobro
		UPDATE bi.Greuge_Evolution ge 
			JOIN (
				   SELECT cs.Id_Cliente, sum(Valor * Cantidad) as Importe
					   FROM vn2008.Tickets t
					   JOIN vn2008.Consignatarios cs on cs.Id_Consigna = t.Id_Consigna
					   JOIN vn2008.Movimientos m on m.Id_Ticket = t.Id_Ticket
					   JOIN vn2008.Movimientos_componentes mc on mc.Id_Movimiento = m.Id_Movimiento
				   WHERE t.Fecha >= datFEC 
					   AND t.Fecha < datFEC_TOMORROW
					   AND mc.Id_Componente = 17 -- Recobro
				   GROUP BY cs.Id_Cliente
				 ) sub using(Id_Cliente)
			SET Recobro = Importe
			WHERE ge.Fecha = datFEC;
        
		SET datFEC = datFEC_TOMORROW;
		SET datFEC_TOMORROW = TIMESTAMPADD(DAY,1,datFEC_TOMORROW);
		SET datFEC_LASTYEAR = TIMESTAMPADD(YEAR,-1,datFEC);
        
	END WHILE;

	DROP TEMPORARY TABLE IF EXISTS maxInvoice;
END$$
DELIMITER ;