salix/services/client/common/methods/client/salesperson.js

module.exports = (Client) => {
    Client.remoteMethod('activeSalesPerson', {
        description: 'returns actives employees with salesperson role',
        accessType: 'READ',
        accepts: [{
            arg: 'filter',
            type: 'Object',
            required: false,
            description: 'Filter defining where and paginated data',
            http: {source: 'query'}
        }],
        returns: {
            arg: 'data',
            type: 'Employee',
            root: true
        },
        http: {
            path: `/activeSalesPerson`,
            verb: 'get'
        }
    });

    Client.activeSalesPerson = (filter, callback) => {
        let skip = filter.skip || 0;
        let limit = filter.limit || 10;
        let where = getCondition(filter.where, limit, skip);

        let query = `SELECT  em.id, em.name, em.surname 
                    FROM Employee em 
                    JOIN Account ac ON em.userFk = ac.id
                    JOIN Role ON Role.id = ac.roleFK
                    WHERE ac.active AND Role.\`name\`='salesPerson' ${where.sql}
                    ORDER BY em.name ASC
                    LIMIT ? OFFSET ?`;

        Client.rawSql(query, where.params, callback)
        .then(response => {
            callback(null, formatSalesPerson(response));
        })
        .catch(reject => {
            callback(reject, null);
        });
    };

    function getCondition(where, limit, skip) {
        let out = {
            sql: '',
            params: []
        };
        if (where && where.or) {
            out.sql = `AND (em.name regexp ? OR em.surname regexp ?)`;
            where.or.forEach(val => {
                Object.keys(val).forEach(key => {
                    out.params.push(val[key].regexp);
                });
            });
        }
        out.params.push(parseInt(limit, 10));
        out.params.push(parseInt(skip, 10));
        return out;
    }

    function formatSalesPerson(response) {
        let results = [];

        response.forEach(person => {
            results.push({
                id: person.id,
                name: `${person.name} ${person.surname}`
            });
        });

        return results;
    }
};