db/routines/bs/procedures/sale_add.sql

@@ -0,0 +1,72 @@
+DELIMITER $$
+CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `bs`.`sale_add`(
+	IN vStarted DATE,
+	IN vEnded DATE)
+BEGIN
+/**
+ * Añade las ventas que se realizaron entre 2 fechas a la tabla bs.sale
+ * 
+ * @param vStarted Fecha de inicio
+ * @param vEnded Fecha de fin
+ *
+ */
+	DECLARE vLoopDate DATE;
+	DECLARE vLoopDateTime DATETIME; 
+	
+	IF vStarted < (util.VN_CURDATE() - INTERVAL 5 YEAR) OR vStarted > vEnded THEN
+		CALL util.throw('Wrong date');
+	END IF;
+	
+	SET vLoopDate = vStarted;
+
+	DELETE FROM sale 
+		WHERE dated BETWEEN vStarted AND vEnded;
+
+	WHILE vLoopDate <= vEnded DO
+		SET vLoopDateTime = util.dayEnd(vLoopDate);
+		
+		REPLACE sale(
+			saleFk,
+			amount,
+			surcharge,
+			dated,
+			typeFk,
+			clientFk,
+			companyFk,
+			margin
+		)WITH calculatedSales AS(
+		SELECT s.id saleFk,
+				SUM(IF(ct.isBase, s.quantity * sc.value, 0)) amount,
+				SUM(IF(ct.isBase, 0, s.quantity * sc.value)) surcharge,
+				s.total pvp,
+				DATE(t.shipped) dated,
+				i.typeFk,
+				t.clientFk,
+				t.companyFk,
+				SUM(IF(ct.isMargin, s.quantity * sc.value, 0 )) marginComponents
+			FROM vn.ticket t
+				STRAIGHT_JOIN vn.sale s ON s.ticketFk = t.id
+				JOIN vn.item i ON i.id = s.itemFk
+				JOIN vn.itemType it ON it.id = i.typeFk
+				JOIN vn.itemCategory ic ON ic.id = it.categoryFk
+				JOIN vn.saleComponent sc ON sc.saleFk = s.id 
+				JOIN vn.component c ON c.id = sc.componentFk
+				JOIN vn.componentType ct ON ct.id = c.typeFk
+			WHERE t.shipped BETWEEN vLoopDate AND vLoopDateTime
+				AND s.quantity <> 0
+				AND ic.merchandise 
+			GROUP BY s.id
+		)SELECT saleFk, 
+				amount, 
+				surcharge, 
+				dated, 
+				typeFk, 
+				clientFk, 
+				companyFk, 
+				marginComponents + amount + surcharge - pvp
+			FROM calculatedSales;
+
+		SET vLoopDate = vLoopDate + INTERVAL 1 DAY;
+	END WHILE;
+END$$
+DELIMITER ;

db/routines/bs/procedures/sales_addLauncher.sql

@@ -1,13 +1,12 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `bs`.`ventas_add_launcher`()
+CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `bs`.`sales_addLauncher`()
 BEGIN
 /**
  * Añade las ventas a la tabla bs.sale que se realizaron desde hace un mes hasta hoy
  * 
  */
-
 	DECLARE vCurDate DATE DEFAULT util.VN_CURDATE();
-	CALL ventas_add(vCurDate - INTERVAL 1 MONTH, vCurDate);
 	
+	CALL sale_add(vCurDate - INTERVAL 1 MONTH, vCurDate);
 END$$
 DELIMITER ;

db/routines/bs/procedures/ventas_add.sql

@@ -1,78 +0,0 @@
-DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `bs`.`ventas_add`(
-	IN vStarted DATETIME,
-	IN vEnded DATETIME)
-BEGIN
-/**
-* Añade las ventas que se realizaron entre
-* vStarted y vEnded
-* 
-* @param vStarted Fecha de inicio
-* @param vEnded Fecha de finalizacion
-*
-**/
-	DECLARE vStartingDate DATETIME;
-	DECLARE vEndingDate DATETIME;
-
-	IF vStarted < TIMESTAMPADD(YEAR,-5,util.VN_CURDATE()) 
-		OR vEnded < TIMESTAMPADD(YEAR,-5,util.VN_CURDATE()) THEN
-		CALL util.throw('fechaDemasiadoAntigua');
-	END IF;
-
-	SET vEnded = util.dayEnd(vEnded);
-	SET vStartingDate = vStarted ;
-	SET vEndingDate = util.dayEnd(vStartingDate);
-
-	DELETE 
-		FROM sale 
-		WHERE dated BETWEEN vStartingDate AND vEnded;
-
-	WHILE vEndingDate <= vEnded DO
-
-		REPLACE ventas(Id_Movimiento, importe, recargo, fecha, tipo_id, Id_Cliente, empresa_id)
-			SELECT saleFk,
-					SUM(IF(ct.isBase, s.quantity * sc.value, 0)) importe,
-					SUM(IF(ct.isBase, 0, s.quantity * sc.value)) recargo,
-					vStartingDate,
-					i.typeFk,
-					a.clientFk,
-					t.companyFk
-				FROM vn.saleComponent sc
-					JOIN vn.component c ON c.id = sc.componentFk
-					JOIN vn.componentType ct ON ct.id = c.typeFk
-					JOIN vn.sale s ON s.id = sc.saleFk
-					JOIN vn.item i ON i.id = s.itemFk
-					JOIN vn.itemType it ON it.id = i.typeFk
-					JOIN vn.itemCategory ic ON ic.id = it.categoryFk
-					JOIN vn.ticket t ON t.id = s.ticketFk
-					JOIN vn.address a ON a.id = t.addressFk 
-					JOIN vn.client cl ON cl.id = a.clientFk
-				WHERE t.shipped BETWEEN vStartingDate AND vEndingDate
-					AND s.quantity <> 0
-					AND s.discount <> 100
-					AND ic.merchandise 
-				GROUP BY sc.saleFk
-				HAVING IFNULL(importe,0) <> 0 OR IFNULL(recargo,0) <> 0;
-
-		UPDATE sale s
-				JOIN (
-					SELECT s.id, 
-							SUM(s.quantity * sc.value ) margen,
-							s.quantity * s.price * (100 - s.discount ) / 100 pvp
-						FROM vn.sale s
-							JOIN vn.ticket t ON t.id = s.ticketFk 
-							JOIN vn.saleComponent sc ON sc.saleFk = s.id
-							JOIN vn.component c ON c.id = sc.componentFk 
-							JOIN vn.componentType ct ON ct.id = c.typeFk 
-						WHERE t.shipped BETWEEN vStartingDate AND vEndingDate
-							AND ct.isMargin = TRUE
-						GROUP BY s.id) sub ON sub.id = s.saleFk 
-			SET s.margin = sub.margen + s.amount + s.surcharge - sub.pvp;
-
-		SET vStartingDate = TIMESTAMPADD(DAY,1, vStartingDate);
-		SET vEndingDate = util.dayEnd(vStartingDate);
-
-	END WHILE;
-
-END$$
-DELIMITER ;

db/versions/11031-aquaPalmetto/00-firstScript.sql

@@ -0,0 +1,4 @@
+
+UPDATE bs.nightTask 
+    SET `procedure` = 'sales_addLauncher'
+    WHERE `procedure` = 'ventas_add_launcher';