116 lines
3.2 KiB
MySQL
116 lines
3.2 KiB
MySQL
|
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 Id_Cliente, max(Fecha) as maxFecha
|
||
|
|
FROM vn2008.Facturas
|
||
|
|
GROUP BY Id_Cliente
|
||
|
|
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 Id_Cliente, sum(Importe) as Greuge
|
||
|
|
FROM vn2008.Greuges
|
||
|
|
where Fecha <= datFEC
|
||
|
|
group by Id_Cliente
|
||
|
|
) 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 ;
|