116 lines
3.2 KiB
SQL
116 lines
3.2 KiB
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 vn.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 a.clientFk Id_Cliente, sum(sc.value * s.quantity) as Importe
|
|
FROM vn.ticket t
|
|
JOIN vn.address a on a.id = t.addressFk
|
|
JOIN vn.sale s on s.ticketFk = t.id
|
|
JOIN vn.saleComponent sc on sc.saleFk = s.id
|
|
WHERE t.shipped >= datFEC
|
|
AND t.shipped < datFEC_TOMORROW
|
|
AND sc.componentFk = 17 -- Recobro
|
|
GROUP BY a.clientFk
|
|
) 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 ;
|