Osticket & waste refactor

back/methods/osticket/osTicketReportEmail.js

@@ -0,0 +1,29 @@
+const {Email} = require('vn-print');
+
+module.exports = Self => {
+    Self.remoteMethodCtx('osTicketReportEmail', {
+        description: 'Sends the buyer waste email',
+        accessType: 'WRITE',
+        accepts: [],
+        returns: {
+            type: ['object'],
+            root: true
+        },
+        http: {
+            path: '/osticket-report-email',
+            verb: 'POST'
+        }
+    });
+
+    Self.osTicketReportEmail = async ctx => {
+        const models = Self.app.models;
+        const printConfig = await models.PrintConfig.findOne();
+
+        const email = new Email('osticket-report', {
+            recipient: printConfig.itRecipient,
+            lang: ctx.req.getLocale()
+        });
+
+        return email.send();
+    };
+};

back/model-config.json

@@ -118,6 +118,9 @@
     },
     "Edi": {
         "dataSource": "vn"
+    },
+    "PrintConfig": {
+        "dataSource": "vn"
     }
 }
 

back/models/osticket.js

@@ -0,0 +1,3 @@
+module.exports = Self => {
+    require('../methods/osticket/osTicketReportEmail')(Self);
+};

back/models/osticket.json

@@ -1,12 +1,5 @@
 {
     "name": "OsTicket",
-    "base": "VnModel",
-    "acls": [{
-        "property": "validations",
-        "accessType": "EXECUTE",
-        "principalType": "ROLE",
-        "principalId": "$everyone",
-        "permission": "ALLOW"
-	}]
+    "base": "VnModel"
 }
   

back/models/print-config.json

@@ -0,0 +1,29 @@
+{
+    "name": "PrintConfig",
+    "description": "Print config",
+    "base": "VnModel",
+    "options": {
+        "mysql": {
+            "table": "salix.printConfig"
+        }
+    },
+    "properties": {
+        "id": {
+            "id": true,
+            "type": "number",
+            "description": "Identifier"
+        },
+        "itRecipient": {
+            "type": "string"
+        },
+        "incidencesEmail": {
+            "type": "string"
+        }
+    },
+    "acls": [{
+        "accessType": "READ",
+        "principalType": "ROLE",
+        "principalId": "$everyone",
+        "permission": "ALLOW"
+    }]
+}

db/changes/10490-august/00-ACL.sql

@@ -23,4 +23,6 @@ INSERT INTO `salix`.`ACL` (model, property, accessType, permission, principalTyp
     ('Supplier', 'campaignMetricsEmail', 'WRITE', 'ALLOW', 'ROLE', 'employee'),
     ('Travel', 'extraCommunityPdf', 'READ', 'ALLOW', 'ROLE', 'employee'),
     ('Travel', 'extraCommunityEmail', 'WRITE', 'ALLOW', 'ROLE', 'employee'),
-    ('Entry', 'entryOrderPdf', 'READ', 'ALLOW', 'ROLE', 'employee');
+    ('Entry', 'entryOrderPdf', 'READ', 'ALLOW', 'ROLE', 'employee'),
+    ('OsTicket', 'osTicketReportEmail', 'WRITE', 'ALLOW', 'ROLE', 'system'),
+    ('Item', 'buyerWasteEmail', 'WRITE', 'ALLOW', 'ROLE', 'system');

db/changes/10490-august/00-itemConfig.sql

@@ -0,0 +1,5 @@
+ALTER TABLE `vn`.`itemConfig`
+    ADD id int null PRIMARY KEY first;
+
+ALTER TABLE `vn`.`itemConfig`
+    ADD wasteRecipients VARCHAR(50) NOT NULL comment 'Weekly waste report schedule recipients';

db/changes/10490-august/00-printConfig.sql

@@ -0,0 +1,10 @@
+create table `salix`.`printConfig`
+(
+    id              int auto_increment,
+    itRecipient     varchar(50) null comment 'IT recipients for report mailing',
+    incidencesEmail varchar(50) null comment 'CAU destinatary email',
+    constraint printConfig_pk
+        primary key (id)
+)
+    comment 'Print service config';
+

db/dump/fixtures.sql

@@ -13,6 +13,10 @@ INSERT INTO `salix`.`AccessToken` (`id`, `ttl`, `created`, `userId`)
     VALUES 
         ('DEFAULT_TOKEN', '1209600', util.VN_CURDATE(), 66);
 
+INSERT INTO `salix`.`printConfig` (`id`, `itRecipient`, `incidencesEmail`)
+    VALUES 
+        (1, 'it@gotamcity.com', 'incidences@gotamcity.com');
+
 INSERT INTO `vn`.`ticketConfig` (`id`, `scopeDays`) 
     VALUES
         ('1', '6');

loopback/server/datasources.json

@@ -19,8 +19,16 @@
         "waitForConnections": true
     },
     "osticket": {
-        "connector": "memory",
-        "timezone": "local"
+        "connector": "vn-mysql",
+        "database": "osticket",
+        "debug": false,
+        "host": "swarm.verdnatura.es",
+        "port": "40003",
+        "username": "osticket",
+        "password": "gfKmwsHJ2Q5H3Aem",
+        "connectTimeout": 180000,
+        "acquireTimeout": 60000,
+        "waitForConnections": true
     },
     "tempStorage": {
         "name": "tempStorage",

modules/item/back/methods/item/buyerWasteEmail.js

@@ -4,55 +4,25 @@ module.exports = Self => {
     Self.remoteMethodCtx('buyerWasteEmail', {
         description: 'Sends the buyer waste email',
         accessType: 'WRITE',
-        accepts: [
-            {
-                arg: 'id',
-                type: 'number',
-                required: true,
-                description: 'The client id',
-                http: {source: 'path'}
-            },
-            {
-                arg: 'recipient',
-                type: 'string',
-                description: 'The recipient email',
-                required: true,
-            },
-            {
-                arg: 'replyTo',
-                type: 'string',
-                description: 'The sender email to reply to',
-                required: false
-            },
-            {
-                arg: 'recipientId',
-                type: 'number',
-                description: 'The recipient id to send to the recipient preferred language',
-                required: false
-            }
-        ],
+        accepts: [],
         returns: {
             type: ['object'],
             root: true
         },
         http: {
-            path: '/:id/buyer-waste-email',
+            path: '/buyer-waste-email',
             verb: 'POST'
         }
     });
 
-    Self.clientDebtStatementEmail = async ctx => {
-        const args = Object.assign({}, ctx.args);
-        const params = {
-            recipient: args.recipient,
+    Self.buyerWasteEmail = async ctx => {
+        const models = Self.app.models;
+        const itemConfig = await models.ItemConfig.findOne();
+
+        const email = new Email('buyer-week-waste', {
+            recipient: itemConfig.wasteRecipients,
             lang: ctx.req.getLocale()
-        };
-
-        delete args.ctx;
-        for (const param in args)
-            params[param] = args[param];
-
-        const email = new Email('buyer-week-waste', params);
+        });
 
         return email.send();
     };

modules/item/back/model-config.json

@@ -23,6 +23,9 @@
     "ItemCategory": {
         "dataSource": "vn"
     },
+    "ItemConfig": {
+        "dataSource": "vn"
+    },
     "ItemFamily": {
         "dataSource": "vn"
     },

modules/item/back/models/item-config.json

@@ -0,0 +1,21 @@
+{
+    "name": "ItemConfig",
+    "base": "VnModel",
+    "options": {
+        "mysql": {
+            "table": "itemConfig"
+        }
+    },
+    "properties": {
+        "isItemTagTriggerDisabled": {
+            "type": "boolean"
+        },
+        "monthToDeactivate": {
+            "type": "boolean"
+        },
+        "wasteRecipients": {
+            "type": "string",
+            "description": "Buyers waste report recipients"
+        }
+    }
+}

modules/item/back/models/item.js

@@ -15,6 +15,7 @@ module.exports = Self => {
     require('../methods/item/getWasteByItem')(Self);
     require('../methods/item/createIntrastat')(Self);
     require('../methods/item/activeBuyers')(Self);
+    require('../methods/item/buyerWasteEmail')(Self);
 
     Self.validatesPresenceOf('originFk', {message: 'Cannot be blank'});
 

print/core/database.js

@@ -2,21 +2,22 @@ const mysql = require('mysql2');
 const config = require('./config.js');
 const fs = require('fs-extra');
 const path = require('path');
-const PoolConnection = mysql.PoolConnection;
 
 module.exports = {
-    init(pool) {
-        if (!this.pool) {
-            // const datasources = config.datasources;
-            // const pool = mysql.createPoolCluster();
+    defaultDataSource: 'vn',
 
-            // for (let datasource of datasources)
-            //     pool.add(datasource.name, datasource.options);
+    init(dataSource) {
+        if (!this.connections) {
+            this.connections = [];
 
-            this.pool = pool;
+            const dataSources = ['vn', 'osticket'];
+            for (const name of dataSources)
+                this.connections[name] = dataSource[name].connector.client;
+
+            this.pool = this.connections[this.defaultDataSource];
         }
 
-        return this.pool;
+        return this.connections;
     },
 
     /**
@@ -25,15 +26,8 @@ module.exports = {
      *
      * @return {Object} - Pool connection
      */
-    getConnection(name = 'default') {
-        let pool = this.pool;
-        return new Promise((resolve, reject) => {
-            pool.getConnection(name, function(error, connection) {
-                if (error) return reject(error);
-
-                resolve(connection);
-            });
-        });
+    getConnection(name = this.defaultDataSource) {
+        return this.connections[name];
     },
 
     /**
@@ -44,9 +38,12 @@ module.exports = {
      *
      * @return {Object} - Result promise
      */
-    rawSql(query, params) {
+    rawSql(query, params, connection) {
         return new Promise((resolve, reject) => {
-            this.pool.query(query, params, (error, rows) => {
+            let db = this.getConnection();
+            if (connection) db = connection;
+
+            db.query(query, params, (error, rows) => {
                 if (error) return reject(error);
                 resolve(rows);
             });
@@ -71,23 +68,25 @@ module.exports = {
      * Returns the first row from a given raw sql
      * @param {String} query - The raw SQL query
      * @param {Object} params - Parameterized values
+     * @param {Object} connection - Optional pool connection
      *
      * @return {Object} - Result promise
      */
-    findOne(query, params) {
-        return this.rawSql(query, params).then(([row]) => row);
+    findOne(query, params, connection) {
+        return this.rawSql(query, params, connection)
+            .then(([row]) => row);
     },
 
     /**
      * Returns the first row from a given SQL file
      * @param {String} queryName - The SQL file name
      * @param {Object} params - Parameterized values
+     * @param {Object} connection - Optional pool connection
      *
      * @return {Object} - Result promise
      */
-    findOneFromDef(queryName, params) {
-        console.log(path.resolve('queryName'));
-        return this.rawSqlFromDef(queryName, params)
+    findOneFromDef(queryName, params, connection) {
+        return this.rawSqlFromDef(queryName, params, connection)
             .then(([row]) => row);
     },
 
@@ -95,11 +94,12 @@ module.exports = {
      * Returns the first property from a given raw sql
      * @param {String} query - The raw SQL query
      * @param {Object} params - Parameterized values
+     * @param {Object} connection - Optional pool connection
      *
      * @return {Object} - Result promise
      */
-    findValue(query, params) {
-        return this.findOne(query, params).then(row => {
+    findValue(query, params, connection) {
+        return this.findOne(query, params, connection).then(row => {
             return Object.values(row)[0];
         });
     },
@@ -108,13 +108,13 @@ module.exports = {
      * Returns the first property from a given SQL file
      * @param {String} queryName - The SQL file name
      * @param {Object} params - Parameterized values
+     * @param {Object} connection - Optional pool connection
      *
      * @return {Object} - Result promise
      */
-    findValueFromDef(queryName, params) {
-        return this.findOneFromDef(queryName, params).then(row => {
-            return Object.values(row)[0];
-        });
+    findValueFromDef(queryName, params, connection) {
+        return this.findOneFromDef(queryName, params, connection)
+            .then(row => Object.values(row)[0]);
     },
 
     /**

print/index.js

@@ -8,13 +8,8 @@ const componentsPath = path.resolve(__dirname, './core/components');
 module.exports = {
     async boot(app) {
         // Init database instance
-        const conn = app.dataSources.vn.connector.client;
-        conn.query('SELECT 1', function(error, rows) {
-            if (error) return error;
-            console.log(rows);
-        });
-        // console.log(app.dataSource.vn.connector.executeStmt('SELECT 1'));
-        require('./core/database').init(conn);
+
+        require('./core/database').init(app.dataSources);
         require('./core/smtp').init();
         require('./core/mixins');
         require('./core/filters');

print/templates/email/osticket-report/assets/css/import.js

@@ -1,9 +1,13 @@
-const Stylesheet = require(`${appPath}/core/stylesheet`);
+const Stylesheet = require(`vn-print/core/stylesheet`);
+
+const path = require('path');
+const vnPrintPath = path.resolve('print');
 
 module.exports = new Stylesheet([
-    `${appPath}/common/css/spacing.css`,
-    `${appPath}/common/css/misc.css`,
-    `${appPath}/common/css/layout.css`,
-    `${appPath}/common/css/email.css`,
+    `${vnPrintPath}/common/css/spacing.css`,
+    `${vnPrintPath}/common/css/misc.css`,
+    `${vnPrintPath}/common/css/layout.css`,
+    `${vnPrintPath}/common/css/email.css`,
     `${__dirname}/style.css`])
     .mergeStyles();
+

print/templates/email/osticket-report/osticket-report.js

@@ -1,4 +1,4 @@
-const Component = require(`${appPath}/core/component`);
+const Component = require(`vn-print/core/component`);
 const emailHeader = new Component('email-header');
 const emailFooter = new Component('email-footer');