db/dbWatcher.js

@@ -0,0 +1,24 @@
+const fs = require('fs');
+const {spawn} = require('child_process');
+
+function watchDatabaseChanges() {
+    console.log('Watching for changes in db/routines and db/versions');
+    fs.watch('db', {recursive: true}, (eventType, filename) => {
+        if (filename.endsWith('.sql')) {
+            let command;
+            if (filename.startsWith('routines')) command = 'push';
+            else if (filename.startsWith('versions')) command = 'run';
+
+            if (command) {
+                const process = spawn('myt', [command]);
+                process.stdout.on('data', data => console.log(data.toString()));
+                process.stderr.on('data', data => console.error(`stderr: ${data}`));
+                process.on('error', error => console.error(`error: ${error.message}`));
+                process.on('close', () => console.log('Watching for changes in db/routines and db/versions'));
+            }
+        }
+    });
+}
+
+if (require.main === module) watchDatabaseChanges();
+module.exports = watchDatabaseChanges;

db/routines/sage/procedures/clientSupplier_add.sql

@@ -53,7 +53,7 @@ BEGIN
 			IFNULL(c.street, ''),
 			c.accountingAccount,
 			@fi := IF(cu.code = LEFT(TRIM(c.fi), 2) AND c.isVies, MID(TRIM(c.fi), 3, LENGTH(TRIM(c.fi))-1), TRIM(c.fi)),
-            IF(c.isVies, CONCAT(cu.code, @fi ), TRIM(c.fi)),
+            IF(c.isVies, CONCAT(IFNULL(cu.viesCode,cu.code), @fi ), TRIM(c.fi)),
 			IFNULL(c.postcode, ''),
 			IFNULL(c.city, ''),
 			IFNULL(pr.CodigoProvincia, ''),
@@ -91,7 +91,7 @@ BEGIN
 				IFNULL(s.street, ''),
 				s.account,
 				@nif := IF(co.code = LEFT(TRIM(s.nif), 2), MID(TRIM(s.nif), 3, LENGTH(TRIM(s.nif))-1), TRIM(s.nif)),
-				IF(s.isVies, CONCAT(co.code, @nif), TRIM(s.nif)),
+				IF(s.isVies, CONCAT(IFNULL(co.viesCode,co.code), @nif), TRIM(s.nif)),
 				IFNULL(s.postCode,''),
 				IFNULL(s.city, ''),
 				IFNULL(pr.CodigoProvincia, ''),

db/routines/vn/procedures/balance_create.sql

@@ -1,10 +1,11 @@
 DELIMITER $$
 CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`balance_create`(
-	IN vStartingMonth INT,
-	IN vEndingMonth INT,
-	IN vCompany INT,
-	IN vIsConsolidated BOOLEAN,
-	IN vInterGroupSalesIncluded BOOLEAN)
+	vStartingMonth INT,
+	vEndingMonth INT,
+	vCompany INT,
+	vIsConsolidated BOOLEAN,
+	vInterGroupSalesIncluded BOOLEAN
+)
 BEGIN
 /**
  * Crea un balance financiero para una empresa durante 

db/routines/vn/procedures/buy_recalcPricesByBuy.sql

@@ -1,11 +1,13 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`buy_recalcPricesByBuy`(IN vBuyFk INT(11))
+CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`buy_recalcPricesByBuy`(
+	vBuyFk INT(11)
+)
 BEGIN
 /**
  * Recalcula los precios de una compra
  *
  * @param vBuyFk
- */  
+ */
 	DROP TEMPORARY TABLE IF EXISTS tmp.buyRecalc;
 
 	CREATE TEMPORARY TABLE tmp.buyRecalc

db/routines/vn/procedures/buy_recalcPricesByEntry.sql

@@ -1,11 +1,13 @@
 DELIMITER $$
-CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`buy_recalcPricesByEntry`(IN vEntryFk INT(11))
+CREATE OR REPLACE DEFINER=`root`@`localhost` PROCEDURE `vn`.`buy_recalcPricesByEntry`(
+	vEntryFk INT(11)
+)
 BEGIN
 /**
  * Recalcula los precios de una entrada
  *
  * @param vEntryFk
- */  
+ */
 	DROP TEMPORARY TABLE IF EXISTS tmp.buyRecalc;
 
 	CREATE TEMPORARY TABLE tmp.buyRecalc

db/routines/vn/procedures/company_getSuppliersDebt.sql

@@ -188,11 +188,12 @@ BEGIN
 		FROM tPendingDuedates vp
 			LEFT JOIN supplier s ON s.id = vp.supplierFk
 			LEFT JOIN client c ON c.fi = s.nif
-			LEFT JOIN clientRisk cr ON cr.clientFk = c.id 
+			LEFT JOIN clientRisk cr ON cr.clientFk = c.id
 				AND cr.companyFk = vp.companyFk
 			LEFT JOIN supplierAccount sa ON sa.supplierFk = s.id
 			LEFT JOIN bankEntity be ON be.id = sa.bankEntityFk
-			LEFT JOIN country co ON co.id = be.countryFk;
+			LEFT JOIN country co ON co.id = be.countryFk
+		GROUP BY vp.id;
 
 	DROP TEMPORARY TABLE tOpeningBalances;
 	DROP TEMPORARY TABLE tPendingDuedates;

db/routines/vn/procedures/sale_getProblems.sql

@@ -34,7 +34,7 @@ BEGIN
 		ticketFk INT(11),
 		saleFk INT(11),
 		isFreezed INTEGER(1) DEFAULT 0,
-		risk DECIMAL(10,2) DEFAULT 0,
+		risk DECIMAL(10,1) DEFAULT 0,
 		hasHighRisk TINYINT(1) DEFAULT 0,
 		hasTicketRequest INTEGER(1) DEFAULT 0,
 		itemShortage VARCHAR(255),

db/routines/vn/procedures/ticket_doCmr.sql

@@ -7,7 +7,7 @@ BEGIN
 *
 * @param vSelf El id del ticket
 */
-	DECLARE vCmrFk, vPreviousCmrFk, vCurrentCmrFk INT;
+	DECLARE vCmrFk INT;
 	SELECT cmrFk INTO vCmrFk
 		FROM ticket
 		WHERE id = vSelf;
@@ -44,8 +44,6 @@ BEGIN
 				AND t.id = vSelf
 			GROUP BY t.id;
 	
-	START TRANSACTION;
-	
 	IF vCmrFk THEN
 		UPDATE cmr c
 				JOIN tTicket t
@@ -57,9 +55,7 @@ BEGIN
 				c.supplierFk = t.supplierFk,
 				c.ead = t.landed
 			WHERE id = vCmrFk;
-	ELSE
-		SELECT MAX(id) INTO vPreviousCmrFk FROM cmr;
-		
+	ELSE		
 		INSERT INTO cmr (
 			senderInstruccions,
 			truckPlate,
@@ -70,17 +66,14 @@ BEGIN
 			ead
 		)
 			SELECT * FROM tTicket;
-	
-		SELECT MAX(id) INTO vCurrentCmrFk FROM cmr;
 
-		IF vPreviousCmrFk <> vCurrentCmrFk THEN
+		IF (SELECT EXISTS(SELECT * FROM tTicket)) THEN
 			UPDATE ticket
-				SET cmrFk = vCurrentCmrFk
+				SET cmrFk = LAST_INSERT_ID()
 				WHERE id = vSelf;
 		END IF;
 	END IF;
 
-	COMMIT;
 	DROP TEMPORARY TABLE tTicket;
 END$$
 DELIMITER ;

db/routines/vn/triggers/ticket_afterUpdate.sql

@@ -7,6 +7,8 @@ BEGIN
 		UPDATE expedition
 			SET hasNewRoute = TRUE
 			WHERE ticketFk = NEW.id;
+		
+		CALL ticket_doCmr(NEW.id);
 	END IF;
 END$$
 DELIMITER ;

db/versions/10859-pinkGerbera/00-firstScript.sql

@@ -1,6 +1,4 @@
 CREATE OR REPLACE PROCEDURE `vn`.`balance_create`() BEGIN END;
-CREATE OR REPLACE PROCEDURE `vn`.`buy_recalcPricesByEntry`() BEGIN END;
-CREATE OR REPLACE PROCEDURE `vn`.`buy_recalcPricesByBuy`() BEGIN END;
 
 GRANT EXECUTE ON PROCEDURE vn.balance_create TO `financialBoss`, `hrBoss`;
 GRANT EXECUTE ON PROCEDURE vn.buy_recalcPricesByEntry TO `buyer`, `claimManager`, `employee`;

db/versions/11006-chocolateCataractarum/00-firstScript.sql

@@ -0,0 +1,6 @@
+ALTER TABLE vn.country 
+	ADD IF NOT EXISTS viesCode varchar(2) DEFAULT NULL NULL AFTER code;
+
+UPDATE IGNORE vn.country
+	SET viesCode = 'FR'
+	WHERE code = 'MC'; -- Mónaco

db/versions/11034-purpleHydrangea/00-firstScript.sql

@@ -0,0 +1,5 @@
+-- Place your SQL code here
+ALTER TABLE vn.packaging 
+MODIFY COLUMN height decimal(10,2) DEFAULT NULL NULL,
+MODIFY COLUMN `depth` decimal(10,2) DEFAULT NULL NULL,
+MODIFY COLUMN width decimal(10,2) DEFAULT NULL NULL;

db/versions/11037-redPhormium/00-firstScript.sql

@@ -0,0 +1 @@
+REVOKE UPDATE (`size`, longName, name) ON vn.item FROM buyer;

gulpfile.js

@@ -6,6 +6,7 @@ const log = require('fancy-log');
 const Myt = require('@verdnatura/myt/myt');
 const Run = require('@verdnatura/myt/myt-run');
 const Start = require('@verdnatura/myt/myt-start');
+const watchDatabaseChanges = require('./db/dbWatcher');
 
 // Configuration
 
@@ -245,6 +246,7 @@ routes.description = 'Merges all module routes file into one file';
 function watch(done) {
     gulp.watch(routeFiles, gulp.series(routes));
     gulp.watch(localeFiles, gulp.series(locales));
+    watchDatabaseChanges();
     done();
 }
 watch.description = `Watches for changes in routes and locale files`;

modules/ticket/back/methods/ticket-request/confirm.js

@@ -19,6 +19,9 @@ module.exports = Self => {
             type: 'number',
             required: true,
             description: 'The requested item quantity',
+        }, {
+            arg: 'attenderFk',
+            type: 'number'
         }],
         returns: {
             type: 'object',
@@ -73,12 +76,14 @@ module.exports = Self => {
                 ticketFk: request.ticketFk,
                 itemFk: ctx.args.itemFk,
                 quantity: ctx.args.quantity,
+                attenderFk: ctx.args.attenderFk,
                 concept: item.name
             }, myOptions);
             await request.updateAttributes({
                 saleFk: sale.id,
                 itemFk: sale.itemFk,
-                isOk: true
+                isOk: true,
+                attenderFk: sale.attenderFk,
             }, myOptions);
 
             const query = `CALL vn.sale_calculateComponent(?, NULL)`;

package.json

@@ -113,7 +113,8 @@
         "test:e2e": "node e2e/tests.js",
         "test:front": "jest --watch",
         "back": "nodemon --inspect -w modules ./node_modules/gulp/bin/gulp.js back",
-        "lint": "eslint ./ --cache --ignore-pattern .gitignore"
+        "lint": "eslint ./ --cache --ignore-pattern .gitignore",
+        "watch:db": "node ./db/dbWatcher.js"
     },
     "jest": {
         "projects": [