Merge branch 'master' of https://gitea.verdnatura.es/verdnatura/salix into test

back/methods/vn-user/addAlias.js

@@ -0,0 +1,68 @@
+const UserError = require('vn-loopback/util/user-error');
+
+module.exports = Self => {
+    Self.remoteMethod('addAlias', {
+        description: 'Add an alias if the user has the grant',
+        accessType: 'WRITE',
+        accepts: [
+            {
+                arg: 'ctx',
+                type: 'Object',
+                http: {source: 'context'}
+            },
+            {
+                arg: 'id',
+                type: 'number',
+                required: true,
+                description: 'The user id',
+                http: {source: 'path'}
+            },
+            {
+                arg: 'mailAlias',
+                type: 'number',
+                description: 'The new alias for user',
+                required: true
+            }
+        ],
+        http: {
+            path: `/:id/addAlias`,
+            verb: 'POST'
+        }
+    });
+
+    Self.addAlias = async function(ctx, id, mailAlias, options) {
+        const models = Self.app.models;
+        const userId = ctx.req.accessToken.userId;
+
+        const myOptions = {};
+
+        if (typeof options == 'object')
+            Object.assign(myOptions, options);
+
+        const user = await Self.findById(userId, {fields: ['hasGrant']}, myOptions);
+
+        if (!user.hasGrant)
+            throw new UserError(`You don't have grant privilege`);
+
+        const account = await models.Account.findById(userId, {
+            fields: ['id'],
+            include: {
+                relation: 'aliases',
+                scope: {
+                    fields: ['mailAlias']
+                }
+            }
+        }, myOptions);
+
+        const aliases = account.aliases().map(alias => alias.mailAlias);
+
+        const hasAlias = aliases.includes(mailAlias);
+        if (!hasAlias)
+            throw new UserError(`You cannot assign an alias that you are not assigned to`);
+
+        return models.MailAliasAccount.create({
+            mailAlias: mailAlias,
+            account: id
+        }, myOptions);
+    };
+};

back/methods/vn-user/removeAlias.js

@@ -0,0 +1,55 @@
+const UserError = require('vn-loopback/util/user-error');
+
+module.exports = Self => {
+    Self.remoteMethod('removeAlias', {
+        description: 'Remove alias if the user has the grant',
+        accessType: 'WRITE',
+        accepts: [
+            {
+                arg: 'ctx',
+                type: 'Object',
+                http: {source: 'context'}
+            },
+            {
+                arg: 'id',
+                type: 'number',
+                required: true,
+                description: 'The user id',
+                http: {source: 'path'}
+            },
+            {
+                arg: 'mailAlias',
+                type: 'number',
+                description: 'The alias to delete',
+                required: true
+            }
+        ],
+        http: {
+            path: `/:id/removeAlias`,
+            verb: 'POST'
+        }
+    });
+
+    Self.removeAlias = async function(ctx, id, mailAlias, options) {
+        const models = Self.app.models;
+        const userId = ctx.req.accessToken.userId;
+
+        const myOptions = {};
+
+        if (typeof options == 'object')
+            Object.assign(myOptions, options);
+
+        const canRemoveAlias = await models.ACL.checkAccessAcl(ctx, 'VnUser', 'canRemoveAlias', 'WRITE');
+
+        if (userId != id && !canRemoveAlias) throw new UserError(`You don't have grant privilege`);
+
+        const mailAliasAccount = await models.MailAliasAccount.findOne({
+            where: {
+                mailAlias: mailAlias,
+                account: id
+            }
+        }, myOptions);
+
+        await mailAliasAccount.destroy(myOptions);
+    };
+};

back/methods/vn-user/specs/addAlias.spec.js

@@ -0,0 +1,68 @@
+const {models} = require('vn-loopback/server/server');
+
+describe('VnUser addAlias()', () => {
+    const employeeId = 1;
+    const sysadminId = 66;
+    const developerId = 9;
+    const customerId = 2;
+    const mailAlias = 1;
+    it('should throw an error when user not has privileges', async() => {
+        const ctx = {req: {accessToken: {userId: employeeId}}};
+        const tx = await models.VnUser.beginTransaction({});
+
+        let error;
+        try {
+            const options = {transaction: tx};
+
+            await models.VnUser.addAlias(ctx, employeeId, mailAlias, options);
+
+            await tx.rollback();
+        } catch (e) {
+            error = e;
+            await tx.rollback();
+        }
+
+        expect(error.message).toContain(`You don't have grant privilege`);
+    });
+
+    it('should throw an error when user has privileges but not has the role from user', async() => {
+        const ctx = {req: {accessToken: {userId: sysadminId}}};
+        const tx = await models.VnUser.beginTransaction({});
+
+        let error;
+        try {
+            const options = {transaction: tx};
+
+            await models.VnUser.addAlias(ctx, employeeId, mailAlias, options);
+
+            await tx.rollback();
+        } catch (e) {
+            error = e;
+            await tx.rollback();
+        }
+
+        expect(error.message).toContain(`You cannot assign an alias that you are not assigned to`);
+    });
+
+    it('should add an alias', async() => {
+        const ctx = {req: {accessToken: {userId: developerId}}};
+        const tx = await models.VnUser.beginTransaction({});
+
+        let result;
+        try {
+            const options = {transaction: tx};
+
+            const user = await models.VnUser.findById(developerId, null, options);
+            await user.updateAttribute('hasGrant', true, options);
+
+            result = await models.VnUser.addAlias(ctx, customerId, mailAlias, options);
+
+            await tx.rollback();
+        } catch (e) {
+            await tx.rollback();
+        }
+
+        expect(result.mailAlias).toBe(mailAlias);
+        expect(result.account).toBe(customerId);
+    });
+});

back/models/vn-user.js

@@ -12,6 +12,8 @@ module.exports = function(Self) {
     require('../methods/vn-user/privileges')(Self);
     require('../methods/vn-user/validate-auth')(Self);
     require('../methods/vn-user/renew-token')(Self);
+    require('../methods/vn-user/addAlias')(Self);
+    require('../methods/vn-user/removeAlias')(Self);
 
     Self.definition.settings.acls = Self.definition.settings.acls.filter(acl => acl.property !== 'create');
 

db/changes/232601/00-aclAddAlias.sql

@@ -0,0 +1,11 @@
+INSERT INTO `salix`.`ACL` (model, property, accessType, permission, principalType, principalId)
+    VALUES
+        ('VnUser', 'addAlias', 'WRITE', 'ALLOW', 'ROLE', 'employee');
+
+INSERT INTO `salix`.`ACL` (model, property, accessType, permission, principalType, principalId)
+    VALUES
+        ('VnUser', 'removeAlias', 'WRITE', 'ALLOW', 'ROLE', 'employee');
+
+INSERT INTO `salix`.`ACL` (model, property, accessType, permission, principalType, principalId)
+    VALUES
+        ('VnUser', 'canRemoveAlias', 'WRITE', 'ALLOW', 'ROLE', 'itManagement');

db/changes/232601/00-aclInvoiceTickets.sql

@@ -0,0 +1,2 @@
+INSERT INTO `salix`.`ACL` (model, property, accessType, permission, principalType, principalId)
+    VALUES('Ticket', 'invoiceTickets', 'WRITE', 'ALLOW', 'ROLE', 'employee');

loopback/locale/en.json

@@ -177,5 +177,6 @@
 	"Mail not sent": "There has been an error sending the invoice to the client [{{clientId}}]({{{clientUrl}}}), please check the email address",
 	"The renew period has not been exceeded": "The renew period has not been exceeded",
 	"You can not use the same password": "You can not use the same password",
-	"Valid priorities": "Valid priorities: %d"
+	"Valid priorities": "Valid priorities: %d",
+	"Negative basis of tickets": "Negative basis of tickets: {{ticketsIds}}"
 }

loopback/locale/es.json

@@ -303,5 +303,7 @@
 	"Error when sending mail to client": "Error al enviar el correo al cliente",
 	"Mail not sent": "Se ha producido un fallo al enviar la factura al cliente [{{clientId}}]({{{clientUrl}}}), por favor revisa la dirección de correo electrónico",
 	"The renew period has not been exceeded": "El periodo de renovación no ha sido superado",
-	"Valid priorities": "Prioridades válidas: %d"
+	"Valid priorities": "Prioridades válidas: %d",
+	"Negative basis of tickets": "Base negativa para los tickets: {{ticketsIds}}",
+	"You cannot assign an alias that you are not assigned to": "No puede asignar un alias que no tenga asignado"
 }

modules/account/front/aliases/index.html

@@ -17,9 +17,7 @@
                         <vn-icon-button
                             icon="delete"
                             translate-attr="{title: 'Unsubscribe'}"
-                            ng-click="removeConfirm.show(row)"
-                            vn-acl="itManagement"
-                            vn-acl-action="remove">
+                            ng-click="removeConfirm.show(row)">
                         </vn-icon-button>
                     </vn-item-section>
                 </vn-item>
@@ -32,9 +30,7 @@
         translate-attr="{title: 'Add'}"
         vn-bind="+"
         ng-click="$ctrl.onAddClick()"
-        fixed-bottom-right
-        vn-acl="itManagement"
-        vn-acl-action="remove">
+        fixed-bottom-right>
     </vn-float-button>
     <vn-dialog
         vn-id="dialog"

modules/account/front/aliases/index.js

@@ -21,12 +21,11 @@ export default class Controller extends Section {
     }
 
     onAddClick() {
-        this.addData = {account: this.$params.id};
         this.$.dialog.show();
     }
 
     onAddSave() {
-        return this.$http.post(`MailAliasAccounts`, this.addData)
+        return this.$http.post(`VnUsers/${this.$params.id}/addAlias`, this.addData)
             .then(() => this.refresh())
             .then(() => this.vnApp.showSuccess(
                 this.$t('Subscribed to alias!'))
@@ -34,11 +33,12 @@ export default class Controller extends Section {
     }
 
     onRemove(row) {
-        return this.$http.delete(`MailAliasAccounts/${row.id}`)
-            .then(() => {
-                this.$.data.splice(this.$.data.indexOf(row), 1);
-                this.vnApp.showSuccess(this.$t('Unsubscribed from alias!'));
-            });
+        const params = {
+            mailAlias: row.mailAlias
+        };
+        return this.$http.post(`VnUsers/${this.$params.id}/removeAlias`, params)
+            .then(() => this.refresh())
+            .then(() => this.vnApp.showSuccess(this.$t('Data saved!')));
     }
 }
 

modules/account/front/aliases/index.spec.js

@@ -25,8 +25,9 @@ describe('component vnUserAliases', () => {
     describe('onAddSave()', () => {
         it('should add the new row', () => {
             controller.addData = {account: 1};
+            controller.$params = {id: 1};
 
-            $httpBackend.expectPOST('MailAliasAccounts').respond();
+            $httpBackend.expectPOST('VnUsers/1/addAlias').respond();
             $httpBackend.expectGET('MailAliasAccounts').respond('foo');
             controller.onAddSave();
             $httpBackend.flush();
@@ -41,12 +42,14 @@ describe('component vnUserAliases', () => {
                 {id: 1, alias: 'foo'},
                 {id: 2, alias: 'bar'}
             ];
+            controller.$params = {id: 1};
 
-            $httpBackend.expectDELETE('MailAliasAccounts/1').respond();
+            $httpBackend.expectPOST('VnUsers/1/removeAlias').respond();
+            $httpBackend.expectGET('MailAliasAccounts').respond(controller.$.data[1]);
             controller.onRemove(controller.$.data[0]);
             $httpBackend.flush();
 
-            expect(controller.$.data).toEqual([{id: 2, alias: 'bar'}]);
+            expect(controller.$.data).toEqual({id: 2, alias: 'bar'});
             expect(controller.vnApp.showSuccess).toHaveBeenCalled();
         });
     });

modules/client/back/models/client.js

@@ -89,7 +89,7 @@ module.exports = Self => {
         };
         const country = await Self.app.models.Country.findOne(filter);
         const code = country ? country.code.toLowerCase() : null;
-        const countryCode = this.fi.toLowerCase().substring(0, 2);
+        const countryCode = this.fi?.toLowerCase().substring(0, 2);
 
         if (!this.fi || !validateTin(this.fi, code) || (this.isVies && countryCode == code))
             err();

modules/client/front/credit-management/index.html

@@ -68,7 +68,7 @@
                     </span>
                 </vn-td>
                 <vn-td number>{{::clientInforma.rating}}</vn-td>
-                <vn-td>{{::clientInforma.recommendedCredit | currency: 'EUR': 2}}</vn-td>
+                <vn-td number>{{::clientInforma.recommendedCredit | currency: 'EUR'}}</vn-td>
             </vn-tr>
         </vn-tbody>
     </vn-table>

modules/client/front/summary/index.html

@@ -270,7 +270,7 @@
                 info="Invoices minus payments  plus orders not yet invoiced">
             </vn-label-value>
             <vn-label-value label="Credit"
-                value="{{$ctrl.summary.credit | currency: 'EUR':2 }} "
+                value="{{$ctrl.summary.credit | currency: 'EUR'}} "
                 ng-class="{alert: $ctrl.summary.credit > $ctrl.summary.creditInsurance ||
                                 ($ctrl.summary.credit  && $ctrl.summary.creditInsurance == null)}"
                 info="Verdnatura's maximum risk">
@@ -296,6 +296,9 @@
                 value="{{$ctrl.summary.rating}}"
                 info="Value from 1 to 20. The higher the better value">
             </vn-label-value>
+            <vn-label-value label="Recommended credit"
+                value="{{$ctrl.summary.recommendedCredit | currency: 'EUR'}}">
+            </vn-label-value>
         </vn-one>
     </vn-horizontal>
     <vn-horizontal>

modules/invoiceOut/back/methods/invoiceOut/invoiceClient.js

@@ -1,5 +1,3 @@
-const UserError = require('vn-loopback/util/user-error');
-
 module.exports = Self => {
     Self.remoteMethodCtx('invoiceClient', {
         description: 'Make a invoice of a client',
@@ -56,7 +54,6 @@ module.exports = Self => {
         const minShipped = Date.vnNew();
         minShipped.setFullYear(args.maxShipped.getFullYear() - 1);
 
-        let invoiceId;
         try {
             const client = await models.Client.findById(args.clientId, {
                 fields: ['id', 'hasToInvoiceByAddress']
@@ -77,56 +74,21 @@ module.exports = Self => {
                 ], options);
             }
 
-            // Check negative bases
-
-            let query =
-                `SELECT COUNT(*) isSpanishCompany
-                    FROM supplier s
-                        JOIN country c ON c.id = s.countryFk
-                            AND c.code = 'ES'
-                    WHERE s.id = ?`;
-            const [supplierCompany] = await Self.rawSql(query, [
-                args.companyFk
-            ], options);
-
-            const isSpanishCompany = supplierCompany?.isSpanishCompany;
-
-            query = 'SELECT hasAnyNegativeBase() AS base';
-            const [result] = await Self.rawSql(query, null, options);
-
-            const hasAnyNegativeBase = result?.base;
-            if (hasAnyNegativeBase && isSpanishCompany)
-                throw new UserError('Negative basis');
-
-            // Invoicing
-
-            query = `SELECT invoiceSerial(?, ?, ?) AS serial`;
-            const [invoiceSerial] = await Self.rawSql(query, [
-                client.id,
+            const invoiceType = 'G';
+            const invoiceId = await models.Ticket.makeInvoice(
+                ctx,
+                invoiceType,
                 args.companyFk,
-                'G'
-            ], options);
-            const serialLetter = invoiceSerial.serial;
-
-            query = `CALL invoiceOut_new(?, ?, NULL, @invoiceId)`;
-            await Self.rawSql(query, [
-                serialLetter,
-                args.invoiceDate
-            ], options);
-
-            const [newInvoice] = await Self.rawSql(`SELECT @invoiceId id`, null, options);
-            if (!newInvoice)
-                throw new UserError('No tickets to invoice', 'notInvoiced');
-
-            await Self.rawSql('CALL invoiceOutBooking(?)', [newInvoice.id], options);
-            invoiceId = newInvoice.id;
+                args.invoiceDate,
+                options
+            );
 
             if (tx) await tx.commit();
+
+            return invoiceId;
         } catch (e) {
             if (tx) await tx.rollback();
             throw e;
         }
-
-        return invoiceId;
     };
 };

modules/invoiceOut/back/methods/invoiceOut/makePdfAndNotify.js

@@ -14,8 +14,7 @@ module.exports = Self => {
             }, {
                 arg: 'printerFk',
                 type: 'number',
-                description: 'The printer to print',
-                required: true
+                description: 'The printer to print'
             }
         ],
         http: {
@@ -51,7 +50,7 @@ module.exports = Self => {
         const ref = invoiceOut.ref;
         const client = invoiceOut.client();
 
-        if (client.isToBeMailed) {
+        if (client.isToBeMailed || !printerFk) {
             try {
                 ctx.args = {
                     reference: ref,

modules/supplier/back/models/supplier.js

@@ -103,7 +103,7 @@ module.exports = Self => {
         const changes = ctx.data || ctx.instance;
         const orgData = ctx.currentInstance;
         const loopBackContext = LoopBackContext.getCurrentContext();
-        const accessToken = {req: loopBackContext.active.accessToken};
+        const accessToken = {req: loopBackContext.active};
 
         const editPayMethodCheck =
             await Self.app.models.ACL.checkAccessAcl(accessToken, 'Supplier', 'editPayMethodCheck', 'WRITE');

modules/ticket/back/methods/ticket/canBeInvoiced.js

@@ -1,3 +1,5 @@
+const UserError = require('vn-loopback/util/user-error');
+
 module.exports = function(Self) {
     Self.remoteMethodCtx('canBeInvoiced', {
         description: 'Whether the ticket can or not be invoiced',
@@ -21,8 +23,9 @@ module.exports = function(Self) {
         }
     });
 
-    Self.canBeInvoiced = async(ticketsIds, options) => {
+    Self.canBeInvoiced = async(ctx, ticketsIds, options) => {
         const myOptions = {};
+        const $t = ctx.req.__; // $translate
 
         if (typeof options == 'object')
             Object.assign(myOptions, options);
@@ -31,29 +34,43 @@ module.exports = function(Self) {
             where: {
                 id: {inq: ticketsIds}
             },
-            fields: ['id', 'refFk', 'shipped', 'totalWithVat']
+            fields: ['id', 'refFk', 'shipped', 'totalWithVat', 'companyFk']
         }, myOptions);
+        const [firstTicket] = tickets;
+        const companyFk = firstTicket.companyFk;
 
-        const query = `
-            SELECT vn.hasSomeNegativeBase(t.id) AS hasSomeNegativeBase
-                FROM ticket t
-                WHERE id IN(?)`;
-        const ticketBases = await Self.rawSql(query, [ticketsIds], myOptions);
-        const hasSomeNegativeBase = ticketBases.some(
-            ticketBases => ticketBases.hasSomeNegativeBase
-        );
+        const query =
+                `SELECT COUNT(*) isSpanishCompany
+                    FROM supplier s
+                        JOIN country c ON c.id = s.countryFk
+                            AND c.code = 'ES'
+                    WHERE s.id = ?`;
+        const [supplierCompany] = await Self.rawSql(query, [companyFk], options);
+
+        const isSpanishCompany = supplierCompany?.isSpanishCompany;
+
+        const [result] = await Self.rawSql('SELECT hasAnyNegativeBase() AS base', null, options);
+        const hasAnyNegativeBase = result?.base && isSpanishCompany;
+        if (hasAnyNegativeBase)
+            throw new UserError($t('Negative basis of tickets', {ticketsIds: ticketsIds}));
 
         const today = Date.vnNew();
 
-        const invalidTickets = tickets.some(ticket => {
+        tickets.some(ticket => {
             const shipped = new Date(ticket.shipped);
             const shippingInFuture = shipped.getTime() > today.getTime();
-            const isInvoiced = ticket.refFk;
-            const priceZero = ticket.totalWithVat == 0;
+            if (shippingInFuture)
+                throw new UserError(`Can't invoice to future`);
 
-            return isInvoiced || priceZero || shippingInFuture;
+            const isInvoiced = ticket.refFk;
+            if (isInvoiced)
+                throw new UserError(`This ticket is already invoiced`);
+
+            const priceZero = ticket.totalWithVat == 0;
+            if (priceZero)
+                throw new UserError(`A ticket with an amount of zero can't be invoiced`);
         });
 
-        return !(invalidTickets || hasSomeNegativeBase);
+        return true;
     };
 };

modules/ticket/back/methods/ticket/invoiceTickets.js

@@ -0,0 +1,104 @@
+const UserError = require('vn-loopback/util/user-error');
+
+module.exports = function(Self) {
+    Self.remoteMethodCtx('invoiceTickets', {
+        description: 'Make out an invoice from one or more tickets',
+        accessType: 'WRITE',
+        accepts: [
+            {
+                arg: 'ticketsIds',
+                description: 'The tickets id',
+                type: ['number'],
+                required: true
+            }
+        ],
+        returns: {
+            type: ['object'],
+            root: true
+        },
+        http: {
+            path: `/invoiceTickets`,
+            verb: 'POST'
+        }
+    });
+
+    Self.invoiceTickets = async(ctx, ticketsIds, options) => {
+        const models = Self.app.models;
+        const date = Date.vnNew();
+        date.setHours(0, 0, 0, 0);
+
+        const myOptions = {userId: ctx.req.accessToken.userId};
+        let tx;
+
+        if (typeof options === 'object')
+            Object.assign(myOptions, options);
+
+        if (!myOptions.transaction) {
+            tx = await Self.beginTransaction({});
+            myOptions.transaction = tx;
+        }
+
+        let invoicesIds = [];
+        try {
+            const tickets = await models.Ticket.find({
+                where: {
+                    id: {inq: ticketsIds}
+                },
+                fields: ['id', 'clientFk', 'companyFk']
+            }, myOptions);
+
+            const [firstTicket] = tickets;
+            const clientId = firstTicket.clientFk;
+            const companyId = firstTicket.companyFk;
+
+            const isSameClient = tickets.every(ticket => ticket.clientFk === clientId);
+            if (!isSameClient)
+                throw new UserError(`You can't invoice tickets from multiple clients`);
+
+            const client = await models.Client.findById(clientId, {
+                fields: ['id', 'hasToInvoiceByAddress']
+            }, myOptions);
+
+            if (client.hasToInvoiceByAddress) {
+                const query = `
+                    SELECT DISTINCT addressFk
+                        FROM ticket t
+                        WHERE id IN (?)`;
+                const result = await Self.rawSql(query, [ticketsIds], myOptions);
+
+                const addressIds = result.map(address => address.addressFk);
+                for (const address of addressIds)
+                    await createInvoice(ctx, companyId, ticketsIds, address, invoicesIds, myOptions);
+            } else
+                await createInvoice(ctx, companyId, ticketsIds, null, invoicesIds, myOptions);
+
+            if (tx) await tx.commit();
+        } catch (e) {
+            if (tx) await tx.rollback();
+            throw e;
+        }
+
+        for (const invoiceId of invoicesIds)
+            await models.InvoiceOut.makePdfAndNotify(ctx, invoiceId, null);
+
+        return invoicesIds;
+    };
+
+    async function createInvoice(ctx, companyId, ticketsIds, address, invoicesIds, myOptions) {
+        const models = Self.app.models;
+
+        await models.Ticket.rawSql(`
+            CREATE OR REPLACE TEMPORARY TABLE tmp.ticketToInvoice
+            (PRIMARY KEY  (id))
+                ENGINE = MEMORY
+                SELECT id
+                    FROM vn.ticket
+                    WHERE id IN (?)
+                        ${address ? `AND addressFk = ${address}` : ''}
+        `, [ticketsIds], myOptions);
+
+        const invoiceId = await models.Ticket.makeInvoice(ctx, 'R', companyId, Date.vnNew(), myOptions);
+        invoicesIds.push(invoiceId);
+    }
+};
+

modules/ticket/back/methods/ticket/makeInvoice.js

@@ -6,15 +6,26 @@ module.exports = function(Self) {
         accessType: 'WRITE',
         accepts: [
             {
-                arg: 'ticketsIds',
-                description: 'The tickets id',
-                type: ['number'],
+                arg: 'invoiceType',
+                description: 'The invoice type',
+                type: 'string',
+                required: true
+            },
+            {
+                arg: 'companyFk',
+                description: 'The company id',
+                type: 'string',
+                required: true
+            },
+            {
+                arg: 'invoiceDate',
+                description: 'The invoice date',
+                type: 'date',
                 required: true
             }
         ],
         returns: {
-            arg: 'data',
-            type: 'boolean',
+            type: ['object'],
             root: true
         },
         http: {
@@ -23,10 +34,9 @@ module.exports = function(Self) {
         }
     });
 
-    Self.makeInvoice = async(ctx, ticketsIds, options) => {
+    Self.makeInvoice = async(ctx, invoiceType, companyFk, invoiceDate, options) => {
         const models = Self.app.models;
-        const date = Date.vnNew();
-        date.setHours(0, 0, 0, 0);
+        invoiceDate.setHours(0, 0, 0, 0);
 
         const myOptions = {userId: ctx.req.accessToken.userId};
         let tx;
@@ -40,81 +50,50 @@ module.exports = function(Self) {
         }
 
         let serial;
-        let invoiceId;
-        let invoiceOut;
         try {
+            const ticketToInvoice = await Self.rawSql(`
+                SELECT id
+                    FROM tmp.ticketToInvoice`, null, myOptions);
+
+            const ticketsIds = ticketToInvoice.map(ticket => ticket.id);
             const tickets = await models.Ticket.find({
                 where: {
                     id: {inq: ticketsIds}
                 },
-                fields: ['id', 'clientFk', 'companyFk']
+                fields: ['id', 'clientFk']
             }, myOptions);
 
+            await models.Ticket.canBeInvoiced(ctx, ticketsIds, myOptions);
+
             const [firstTicket] = tickets;
             const clientId = firstTicket.clientFk;
-            const companyId = firstTicket.companyFk;
-
-            const isSameClient = tickets.every(ticket => ticket.clientFk == clientId);
-            if (!isSameClient)
-                throw new UserError(`You can't invoice tickets from multiple clients`);
-
             const clientCanBeInvoiced = await models.Client.canBeInvoiced(clientId, myOptions);
             if (!clientCanBeInvoiced)
                 throw new UserError(`This client can't be invoiced`);
 
-            const ticketCanBeInvoiced = await models.Ticket.canBeInvoiced(ticketsIds, myOptions);
-            if (!ticketCanBeInvoiced)
-                throw new UserError(`Some of the selected tickets are not billable`);
-
             const query = `SELECT vn.invoiceSerial(?, ?, ?) AS serial`;
             const [result] = await Self.rawSql(query, [
                 clientId,
-                companyId,
-                'R'
+                companyFk,
+                invoiceType,
             ], myOptions);
             serial = result.serial;
 
-            await Self.rawSql(`
-                DROP TEMPORARY TABLE IF EXISTS tmp.ticketToInvoice;
-                CREATE TEMPORARY TABLE tmp.ticketToInvoice
-                (PRIMARY KEY  (id))
-                    ENGINE = MEMORY
-                    SELECT id FROM vn.ticket
-                        WHERE id IN(?) AND refFk IS NULL
-                `, [ticketsIds], myOptions);
-
-            await Self.rawSql('CALL invoiceOut_new(?, ?, null, @invoiceId)', [serial, date], myOptions);
+            await Self.rawSql('CALL invoiceOut_new(?, ?, null, @invoiceId)', [serial, invoiceDate], myOptions);
 
             const [resultInvoice] = await Self.rawSql('SELECT @invoiceId id', [], myOptions);
+            if (!resultInvoice)
+                throw new UserError('No tickets to invoice', 'notInvoiced');
 
-            invoiceId = resultInvoice.id;
+            if (serial != 'R' && resultInvoice.id)
+                await Self.rawSql('CALL invoiceOutBooking(?)', [resultInvoice.id], myOptions);
 
-            if (serial != 'R' && invoiceId)
-                await Self.rawSql('CALL invoiceOutBooking(?)', [invoiceId], myOptions);
-
-            invoiceOut = await models.InvoiceOut.findById(invoiceId, {
-                include: {
-                    relation: 'client'
-                }
-            }, myOptions);
             if (tx) await tx.commit();
+
+            return resultInvoice.id;
         } catch (e) {
             if (tx) await tx.rollback();
             throw e;
         }
-
-        if (serial != 'R' && invoiceId)
-            await models.InvoiceOut.createPdf(ctx, invoiceId);
-
-        if (invoiceId) {
-            ctx.args = {
-                reference: invoiceOut.ref,
-                recipientId: invoiceOut.clientFk,
-                recipient: invoiceOut.client().email
-            };
-            await models.InvoiceOut.invoiceEmail(ctx, invoiceOut.ref);
-        }
-
-        return {invoiceFk: invoiceId, serial: serial};
     };
 };

modules/ticket/back/methods/ticket/specs/canBeInvoiced.spec.js

@@ -1,61 +1,81 @@
 const models = require('vn-loopback/server/server').models;
-const LoopBackContext = require('loopback-context');
 
 describe('ticket canBeInvoiced()', () => {
     const userId = 19;
     const ticketId = 11;
-    const activeCtx = {
-        accessToken: {userId: userId}
+    const ctx = {req: {accessToken: {userId: userId}}};
+    ctx.req.__ = value => {
+        return value;
     };
 
-    beforeAll(async() => {
-        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
-            active: activeCtx
-        });
-    });
-
     it('should return falsy for an already invoiced ticket', async() => {
         const tx = await models.Ticket.beginTransaction({});
 
+        let error;
         try {
             const options = {transaction: tx};
 
             const ticket = await models.Ticket.findById(ticketId, null, options);
             await ticket.updateAttribute('refFk', 'T1111111', options);
 
-            const canBeInvoiced = await models.Ticket.canBeInvoiced([ticketId], options);
+            await models.Ticket.rawSql(`
+                CREATE OR REPLACE TEMPORARY TABLE tmp.ticketToInvoice
+                (PRIMARY KEY  (id))
+                    ENGINE = MEMORY
+                    SELECT id
+                        FROM vn.ticket
+                        WHERE id IN (?)
+            `, [ticketId], options);
+
+            const canBeInvoiced = await models.Ticket.canBeInvoiced(ctx, [ticketId], options);
 
             expect(canBeInvoiced).toEqual(false);
 
             await tx.rollback();
         } catch (e) {
+            error = e;
             await tx.rollback();
-            throw e;
         }
+
+        expect(error.message).toEqual(`This ticket is already invoiced`);
     });
 
     it('should return falsy for a ticket with a price of zero', async() => {
         const tx = await models.Ticket.beginTransaction({});
 
+        let error;
         try {
             const options = {transaction: tx};
 
             const ticket = await models.Ticket.findById(ticketId, null, options);
             await ticket.updateAttribute('totalWithVat', 0, options);
 
-            const canBeInvoiced = await models.Ticket.canBeInvoiced([ticketId], options);
+            await models.Ticket.rawSql(`
+                CREATE OR REPLACE TEMPORARY TABLE tmp.ticketToInvoice
+                (PRIMARY KEY  (id))
+                    ENGINE = MEMORY
+                    SELECT id
+                        FROM vn.ticket
+                        WHERE id IN (?)
+            `, [ticketId], options);
+
+            const canBeInvoiced = await models.Ticket.canBeInvoiced(ctx, [ticketId], options);
 
             expect(canBeInvoiced).toEqual(false);
 
             await tx.rollback();
         } catch (e) {
+            error = e;
             await tx.rollback();
-            throw e;
         }
+
+        expect(error.message).toEqual(`A ticket with an amount of zero can't be invoiced`);
     });
 
     it('should return falsy for a ticket shipping in future', async() => {
         const tx = await models.Ticket.beginTransaction({});
+
+        let error;
         try {
             const options = {transaction: tx};
 
@@ -66,15 +86,26 @@ describe('ticket canBeInvoiced()', () => {
 
             await ticket.updateAttribute('shipped', shipped, options);
 
-            const canBeInvoiced = await models.Ticket.canBeInvoiced([ticketId], options);
+            await models.Ticket.rawSql(`
+                CREATE OR REPLACE TEMPORARY TABLE tmp.ticketToInvoice
+                (PRIMARY KEY  (id))
+                    ENGINE = MEMORY
+                    SELECT id
+                        FROM vn.ticket
+                        WHERE id IN (?)
+            `, [ticketId], options);
+
+            const canBeInvoiced = await models.Ticket.canBeInvoiced(ctx, [ticketId], options);
 
             expect(canBeInvoiced).toEqual(false);
 
             await tx.rollback();
         } catch (e) {
+            error = e;
             await tx.rollback();
-            throw e;
         }
+
+        expect(error.message).toEqual(`Can't invoice to future`);
     });
 
     it('should return truthy for an invoiceable ticket', async() => {
@@ -83,7 +114,16 @@ describe('ticket canBeInvoiced()', () => {
         try {
             const options = {transaction: tx};
 
-            const canBeInvoiced = await models.Ticket.canBeInvoiced([ticketId], options);
+            await models.Ticket.rawSql(`
+                CREATE OR REPLACE TEMPORARY TABLE tmp.ticketToInvoice
+                (PRIMARY KEY  (id))
+                    ENGINE = MEMORY
+                    SELECT id
+                        FROM vn.ticket
+                        WHERE id IN (?)
+            `, [ticketId], options);
+
+            const canBeInvoiced = await models.Ticket.canBeInvoiced(ctx, [ticketId], options);
 
             expect(canBeInvoiced).toEqual(true);
 

modules/ticket/back/methods/ticket/specs/invoiceTickets.spec.js

@@ -0,0 +1,115 @@
+const models = require('vn-loopback/server/server').models;
+const LoopBackContext = require('loopback-context');
+
+describe('ticket invoiceTickets()', () => {
+    const userId = 19;
+    const clientId = 1102;
+    const activeCtx = {
+        getLocale: () => {
+            return 'en';
+        },
+        accessToken: {userId: userId},
+        headers: {origin: 'http://localhost:5000'},
+    };
+    const ctx = {req: activeCtx};
+
+    beforeAll(async() => {
+        spyOn(LoopBackContext, 'getCurrentContext').and.returnValue({
+            active: activeCtx
+        });
+    });
+
+    it('should throw an error when invoicing tickets from multiple clients', async() => {
+        const invoiceOutModel = models.InvoiceOut;
+        spyOn(invoiceOutModel, 'makePdfAndNotify');
+
+        const tx = await models.Ticket.beginTransaction({});
+
+        let error;
+
+        try {
+            const options = {transaction: tx};
+
+            const ticketsIds = [11, 16];
+            await models.Ticket.invoiceTickets(ctx, ticketsIds, options);
+
+            await tx.rollback();
+        } catch (e) {
+            error = e;
+            await tx.rollback();
+        }
+
+        expect(error.message).toEqual(`You can't invoice tickets from multiple clients`);
+    });
+
+    it(`should throw an error when invoicing a client without tax data checked`, async() => {
+        const invoiceOutModel = models.InvoiceOut;
+        spyOn(invoiceOutModel, 'makePdfAndNotify');
+
+        const tx = await models.Ticket.beginTransaction({});
+
+        let error;
+
+        try {
+            const options = {transaction: tx};
+
+            const client = await models.Client.findById(clientId, null, options);
+            await client.updateAttribute('isTaxDataChecked', false, options);
+
+            const ticketsIds = [11];
+            await models.Ticket.invoiceTickets(ctx, ticketsIds, options);
+
+            await tx.rollback();
+        } catch (e) {
+            error = e;
+            await tx.rollback();
+        }
+
+        expect(error.message).toEqual(`This client can't be invoiced`);
+    });
+
+    it('should invoice a ticket, then try again to fail', async() => {
+        const invoiceOutModel = models.InvoiceOut;
+        spyOn(invoiceOutModel, 'makePdfAndNotify');
+
+        const tx = await models.Ticket.beginTransaction({});
+
+        let error;
+
+        try {
+            const options = {transaction: tx};
+
+            const ticketsIds = [11];
+            await models.Ticket.invoiceTickets(ctx, ticketsIds, options);
+            await models.Ticket.invoiceTickets(ctx, ticketsIds, options);
+
+            await tx.rollback();
+        } catch (e) {
+            error = e;
+            await tx.rollback();
+        }
+
+        expect(error.message).toEqual(`This ticket is already invoiced`);
+    });
+
+    it('should success to invoice a ticket', async() => {
+        const invoiceOutModel = models.InvoiceOut;
+        spyOn(invoiceOutModel, 'makePdfAndNotify');
+
+        const tx = await models.Ticket.beginTransaction({});
+
+        try {
+            const options = {transaction: tx};
+
+            const ticketsIds = [11];
+            const invoicesIds = await models.Ticket.invoiceTickets(ctx, ticketsIds, options);
+
+            expect(invoicesIds.length).toBeGreaterThan(0);
+
+            await tx.rollback();
+        } catch (e) {
+            await tx.rollback();
+            throw e;
+        }
+    });
+});

modules/ticket/back/methods/ticket/specs/makeInvoice.spec.js

@@ -3,8 +3,9 @@ const LoopBackContext = require('loopback-context');
 
 describe('ticket makeInvoice()', () => {
     const userId = 19;
-    const ticketId = 11;
-    const clientId = 1102;
+    const invoiceType = 'R';
+    const companyFk = 442;
+    const invoiceDate = Date.vnNew();
     const activeCtx = {
         getLocale: () => {
             return 'en';
@@ -20,77 +21,6 @@ describe('ticket makeInvoice()', () => {
         });
     });
 
-    it('should throw an error when invoicing tickets from multiple clients', async() => {
-        const invoiceOutModel = models.InvoiceOut;
-        spyOn(invoiceOutModel, 'createPdf');
-
-        const tx = await models.Ticket.beginTransaction({});
-
-        let error;
-
-        try {
-            const options = {transaction: tx};
-            const otherClientTicketId = 16;
-            await models.Ticket.makeInvoice(ctx, [ticketId, otherClientTicketId], options);
-
-            await tx.rollback();
-        } catch (e) {
-            error = e;
-            await tx.rollback();
-        }
-
-        expect(error.message).toEqual(`You can't invoice tickets from multiple clients`);
-    });
-
-    it(`should throw an error when invoicing a client without tax data checked`, async() => {
-        const invoiceOutModel = models.InvoiceOut;
-        spyOn(invoiceOutModel, 'createPdf');
-
-        const tx = await models.Ticket.beginTransaction({});
-
-        let error;
-
-        try {
-            const options = {transaction: tx};
-
-            const client = await models.Client.findById(clientId, null, options);
-            await client.updateAttribute('isTaxDataChecked', false, options);
-
-            await models.Ticket.makeInvoice(ctx, [ticketId], options);
-
-            await tx.rollback();
-        } catch (e) {
-            error = e;
-            await tx.rollback();
-        }
-
-        expect(error.message).toEqual(`This client can't be invoiced`);
-    });
-
-    it('should invoice a ticket, then try again to fail', async() => {
-        const invoiceOutModel = models.InvoiceOut;
-        spyOn(invoiceOutModel, 'createPdf');
-        spyOn(invoiceOutModel, 'invoiceEmail');
-
-        const tx = await models.Ticket.beginTransaction({});
-
-        let error;
-
-        try {
-            const options = {transaction: tx};
-
-            await models.Ticket.makeInvoice(ctx, [ticketId], options);
-            await models.Ticket.makeInvoice(ctx, [ticketId], options);
-
-            await tx.rollback();
-        } catch (e) {
-            error = e;
-            await tx.rollback();
-        }
-
-        expect(error.message).toEqual(`Some of the selected tickets are not billable`);
-    });
-
     it('should success to invoice a ticket', async() => {
         const invoiceOutModel = models.InvoiceOut;
         spyOn(invoiceOutModel, 'createPdf');
@@ -101,10 +31,20 @@ describe('ticket makeInvoice()', () => {
         try {
             const options = {transaction: tx};
 
-            const invoice = await models.Ticket.makeInvoice(ctx, [ticketId], options);
+            const ticketsIds = [11, 16];
+            await models.Ticket.rawSql(`
+                DROP TEMPORARY TABLE IF EXISTS tmp.ticketToInvoice;
+                CREATE TEMPORARY TABLE tmp.ticketToInvoice
+                (PRIMARY KEY  (id))
+                    ENGINE = MEMORY
+                    SELECT id
+                        FROM vn.ticket
+                        WHERE id IN (?)
+            `, [ticketsIds], options);
 
-            expect(invoice.invoiceFk).toBeDefined();
-            expect(invoice.serial).toEqual('T');
+            const invoiceId = await models.Ticket.makeInvoice(ctx, invoiceType, companyFk, invoiceDate, options);
+
+            expect(invoiceId).toBeDefined();
 
             await tx.rollback();
         } catch (e) {

modules/ticket/back/models/ticket-methods.js

@@ -39,4 +39,5 @@ module.exports = function(Self) {
     require('../methods/ticket/collectionLabel')(Self);
     require('../methods/ticket/expeditionPalletLabel')(Self);
     require('../methods/ticket/saveSign')(Self);
+    require('../methods/ticket/invoiceTickets')(Self);
 };

modules/ticket/front/descriptor-menu/index.js

@@ -275,7 +275,7 @@ class Controller extends Section {
             });
         }
 
-        return this.$http.post(`Tickets/makeInvoice`, params)
+        return this.$http.post(`Tickets/invoiceTickets`, params)
             .then(() => this.reload())
             .then(() => this.vnApp.showSuccess(this.$t('Ticket invoiced')));
     }

modules/ticket/front/descriptor-menu/index.spec.js

@@ -191,7 +191,7 @@ describe('Ticket Component vnTicketDescriptorMenu', () => {
             jest.spyOn(controller.vnApp, 'showSuccess');
 
             const expectedParams = {ticketsIds: [ticket.id]};
-            $httpBackend.expectPOST(`Tickets/makeInvoice`, expectedParams).respond();
+            $httpBackend.expectPOST(`Tickets/invoiceTickets`, expectedParams).respond();
             controller.makeInvoice();
             $httpBackend.flush();
 

modules/ticket/front/index/index.js

@@ -163,7 +163,7 @@ export default class Controller extends Section {
 
     makeInvoice() {
         const ticketsIds = this.checked.map(ticket => ticket.id);
-        return this.$http.post(`Tickets/makeInvoice`, {ticketsIds})
+        return this.$http.post(`Tickets/invoiceTickets`, {ticketsIds})
             .then(() => this.$.model.refresh())
             .then(() => this.vnApp.showSuccess(this.$t('Ticket invoiced')));
     }

modules/travel/front/extra-community/index.html

@@ -163,7 +163,7 @@
                         </td>
                         <td number>{{::entry.invoiceAmount | currency: 'EUR': 2}}</td>
                         <td></td>
-                        <td class="td-editable">{{::entry.invoiceNumber}}</td>
+                        <td class="td-editable">{{::entry.reference}}</td>
                         <td number>{{::entry.stickers}}</td>
                         <td number></td>
                         <td number>{{::entry.loadedkg}}</td>