module.exports = Self => {
    Self.remoteMethodCtx('getTickets', {
        description: 'Make a new collection of tickets',
        accessType: 'WRITE',
        accepts: [{
            arg: 'id',
            type: 'number',
            description: 'The collection id',
            required: true,
            http: {source: 'path'}
        }, {
            arg: 'print',
            type: 'boolean',
            description: 'True if you want to print'
        }],
        returns: {
            type: ['object'],
            root: true
        },
        http: {
            path: `/:id/getTickets`,
            verb: 'POST'
        }
    });

    Self.getTickets = async(ctx, id, print, options) => {
        const userId = ctx.req.accessToken.userId;
        const url = await Self.app.models.Url.getUrl();
        const $t = ctx.req.__;
        const myOptions = {};

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

        myOptions.userId = userId;

        const promises = [];
        const [tickets] = await Self.rawSql(`CALL vn.collection_getTickets(?)`, [id], myOptions);
        const sales = await Self.rawSql(`
            SELECT s.ticketFk,
                    sgd.saleGroupFk,
                    s.id saleFk,
                    s.itemFk,
                    i.longName,
                    i.size,
                    ic.color,
                    o.code origin,
                    ish.packing,
                    ish.grouping,
                    s.isAdded,
                    s.originalQuantity,
                    s.quantity saleQuantity,
                    iss.quantity reservedQuantity,
                    SUM(iss.quantity) OVER (PARTITION BY s.id ORDER BY ish.id) accumulatedQuantity,
                    ROW_NUMBER () OVER (PARTITION BY s.id ORDER BY pickingOrder) currentItemShelving,
                    COUNT(*) OVER (PARTITION BY s.id ORDER BY s.id) totalItemShelving,
                    sh.code,
                    IFNULL(p2.code, p.code) parkingCode,
                    IFNULL(p2.pickingOrder, p.pickingOrder) pickingOrder,
                    iss.id itemShelvingSaleFk,
                    iss.isPicked
                FROM ticketCollection tc
                    LEFT JOIN collection c ON c.id = tc.collectionFk
                    JOIN ticket t ON t.id = tc.ticketFk
                    JOIN sale s ON s.ticketFk = t.id
                    LEFT JOIN saleGroupDetail sgd ON sgd.saleFk = s.id
                    LEFT JOIN saleGroup sg ON sg.id = sgd.saleGroupFk
                    LEFT JOIN parking p2 ON p2.id = sg.parkingFk
                    JOIN item i ON i.id = s.itemFk
                    LEFT JOIN itemShelvingSale iss ON iss.saleFk = s.id
                    LEFT JOIN itemShelving ish ON ish.id = iss.itemShelvingFk
                    LEFT JOIN shelving sh ON sh.code = ish.shelvingFk
                    LEFT JOIN parking p ON p.id = sh.parkingFk
                    LEFT JOIN itemColor ic ON ic.itemFk = s.itemFk
                    LEFT JOIN origin o ON o.id = i.originFk
                WHERE tc.collectionFk = ?
                GROUP BY s.id, ish.id, p.code, p2.code
                ORDER BY pickingOrder;`, [id], myOptions);

        if (print)
            await Self.rawSql(`CALL vn.collection_printSticker(?, ?)`, [id, null], myOptions);

        const collection = {collectionFk: id, tickets: []};
        if (tickets && tickets.length) {
            for (const ticket of tickets) {
                const ticketId = ticket.ticketFk;
                if (ticket.observaciones != '') {
                    for (observation of ticket.observaciones.split(' ')) {
                        if (['#', '@'].includes(observation.charAt(0))) {
                            promises.push(Self.app.models.Chat.send(ctx, observation,
                                $t('The ticket is in preparation', {
                                    ticketId: ticketId,
                                    ticketUrl: `${url}ticket/${ticketId}/summary`,
                                    salesPersonId: ticket.salesPersonFk
                                })));
                        }
                    }
                }
                if (sales && sales.length) {
                    const barcodes = await Self.rawSql(`
                        SELECT s.id saleFk, b.code, c.id
                            FROM vn.sale s
                                LEFT JOIN vn.itemBarcode b ON b.itemFk = s.itemFk
                                LEFT JOIN vn.buy c ON c.itemFk = s.itemFk
                                LEFT JOIN vn.entry e ON e.id = c.entryFk
                                LEFT JOIN vn.travel tr ON tr.id = e.travelFk
                            WHERE s.ticketFk = ?
                                AND tr.landed >= util.VN_CURDATE() - INTERVAL 1 YEAR`,
                    [ticketId], myOptions);
                    ticket.sales = [];
                    for (const sale of sales) {
                        if (sale.ticketFk === ticketId) {
                            sale.Barcodes = [];
                            if (barcodes && barcodes.length) {
                                for (const barcode of barcodes) {
                                    if (barcode.saleFk === sale.saleFk) {
                                        for (const prop in barcode) {
                                            if (['id', 'code'].includes(prop) && barcode[prop])
                                                sale.Barcodes.push(barcode[prop].toString(), '0' + barcode[prop]);
                                        }
                                    }
                                }
                            }
                            ticket.sales.push(sale);
                        }
                    }
                }
                collection.tickets.push(ticket);
            }
        }
        await Promise.all(promises);
        return collection;
    };
};