salix/modules/client/back/methods/client/transactions.js

const ParameterizedSQL = require('loopback-connector').ParameterizedSQL;
const buildFilter = require('vn-loopback/util/filter').buildFilter;
const mergeFilters = require('vn-loopback/util/filter').mergeFilters;

module.exports = Self => {
    Self.remoteMethodCtx('transactions', {
        description: 'Returns customer transactions',
        accessType: 'READ',
        accepts: [
            {
                arg: 'filter',
                type: 'object',
                description: 'Filter defining where, order, offset, and limit - must be a JSON-encoded string',
            },
            {
                arg: 'orderFk',
                type: 'number',
            },
            {
                arg: 'clientFk',
                type: 'number',
            },
            {
                arg: 'amount',
                type: 'number',
            },
            {
                arg: 'from',
                type: 'date',
            },
            {
                arg: 'to',
                type: 'date',
            }
        ],
        returns: {
            type: ['object'],
            root: true
        },
        http: {
            path: `/transactions`,
            verb: 'GET'
        }
    });

    Self.transactions = async(ctx, filter, orderFk, clientFk, amount, from, to, options) => {
        const myOptions = {};

        if (typeof options == 'object')
            Object.assign(myOptions, options);

        if (to) to.setHours(23, 59, 59, 999);

        const where = buildFilter({orderFk, clientFk, amount, from, to}, (param, value) => {
            switch (param) {
            case 'orderFk':
                return {'t.id': value};
            case 'clientFk':
                return {'t.clientFk': value};
            case 'amount':
                return {'t.amount': (value * 100)};
            case 'from':
                return {'t.created': {gte: value}};
            case 'to':
                return {'t.created': {lte: value}};
            }
        });

        filter = mergeFilters(filter, {where});

        const conn = Self.dataSource.connector;
        const stmt = new ParameterizedSQL(`
            SELECT 
                t.id, 
                t.clientFk, 
                c.name AS customerName,
                t.created, 
                t.amount / 100 amount,
                t.receiptFk IS NOT NULL AS isConfirmed,
                tt.message responseMessage,
                te.message errorMessage
            FROM hedera.tpvTransaction t
                JOIN client c ON c.id = t.clientFk
                JOIN hedera.tpvMerchant m ON m.id = t.merchantFk
                LEFT JOIN hedera.tpvResponse tt ON tt.id = t.response
                LEFT JOIN hedera.tpvError te ON te.code = errorCode`);

        stmt.merge(conn.makeSuffix(filter, 't'));

        return Self.rawStmt(stmt, myOptions);
    };
};