const db = require('vn-print/core/database');
const Report = require('vn-print/core/report');
const Email = require('vn-print/core/email');
const smtp = require('vn-print/core/smtp');
const config = require('vn-print/core/config');
const storage = require('vn-print/core/storage');

module.exports = {
    async start(tickets, reqArgs) {
        if (tickets.length == 0) return;

        const failedtickets = [];
        for (const ticket of tickets) {
            try {
                await db.rawSql(`CALL vn.ticket_closeByTicket(?)`, [ticket.id]);

                const invoiceOut = await db.findOne(`
                    SELECT io.id, io.ref, io.serial, cny.code companyCode, io.issued
                        FROM ticket t
                            JOIN invoiceOut io ON io.ref = t.refFk
                            JOIN company cny ON cny.id = io.companyFk
                        WHERE t.id = ?
                `, [ticket.id]);

                const mailOptions = {
                    overrideAttachments: true,
                    attachments: []
                };

                const isToBeMailed = ticket.recipient && ticket.salesPersonFk && ticket.isToBeMailed;

                if (invoiceOut) {
                    const args = Object.assign({
                        refFk: invoiceOut.ref,
                        recipientId: ticket.clientFk,
                        recipient: ticket.recipient,
                        replyTo: ticket.salesPersonEmail
                    }, reqArgs);

                    const invoiceReport = new Report('invoice', args);
                    const stream = await invoiceReport.toPdfStream();

                    const issued = invoiceOut.issued;
                    const year = issued.getFullYear().toString();
                    const month = (issued.getMonth() + 1).toString();
                    const day = issued.getDate().toString();

                    const fileName = `${year}${invoiceOut.ref}.pdf`;

                    // Store invoice
                    storage.write(stream, {
                        type: 'invoice',
                        path: `${year}/${month}/${day}`,
                        fileName: fileName
                    });

                    await db.rawSql('UPDATE invoiceOut SET hasPdf = true WHERE id = ?', [invoiceOut.id]);

                    if (isToBeMailed) {
                        const invoiceAttachment = {
                            filename: fileName,
                            content: stream
                        };

                        if (invoiceOut.serial == 'E' && invoiceOut.companyCode == 'VNL') {
                            const exportation = new Report('exportation', args);
                            const stream = await exportation.toPdfStream();
                            const fileName = `CITES-${invoiceOut.ref}.pdf`;

                            mailOptions.attachments.push({
                                filename: fileName,
                                content: stream
                            });
                        }

                        mailOptions.attachments.push(invoiceAttachment);

                        const email = new Email('invoice', args);
                        await email.send(mailOptions);
                    }
                } else if (isToBeMailed) {
                    const args = Object.assign({
                        ticketId: ticket.id,
                        recipientId: ticket.clientFk,
                        recipient: ticket.recipient,
                        replyTo: ticket.salesPersonEmail
                    }, reqArgs);

                    const email = new Email('delivery-note-link', args);
                    await email.send();
                }

                // Incoterms authorization
                const {firstOrder} = await db.findOne(`
                    SELECT COUNT(*) as firstOrder
                        FROM ticket t 
                            JOIN client c ON c.id = t.clientFk
                        WHERE t.clientFk = ?
                            AND NOT t.isDeleted
                            AND c.isVies
                `, [ticket.clientFk]);

                if (firstOrder == 1) {
                    const args = Object.assign({
                        ticketId: ticket.id,
                        recipientId: ticket.clientFk,
                        recipient: ticket.recipient,
                        replyTo: ticket.salesPersonEmail
                    }, reqArgs);

                    const email = new Email('incoterms-authorization', args);
                    await email.send();

                    const sample = await db.findOne(
                        `SELECT id 
                            FROM sample 
                            WHERE code = 'incoterms-authorization'`);

                    await db.rawSql(`
                        INSERT INTO clientSample (clientFk, typeFk, companyFk) VALUES(?, ?, ?)
                    `, [ticket.clientFk, sample.id, ticket.companyFk]);
                }
            } catch (error) {
                // Domain not found
                if (error.responseCode == 450)
                    return invalidEmail(ticket);

                // Save tickets on a list of failed ids
                failedtickets.push({
                    id: ticket.id,
                    stacktrace: error
                });
            }
        }

        // Send email with failed tickets
        if (failedtickets.length > 0) {
            let body = 'This following tickets have failed:<br/><br/>';

            for (const ticket of failedtickets) {
                body += `Ticket: <strong>${ticket.id}</strong>
                    <br/> <strong>${ticket.stacktrace}</strong><br/><br/>`;
            }

            smtp.send({
                to: config.app.reportEmail,
                subject: '[API] Nightly ticket closure report',
                html: body
            });
        }
    },
};

async function invalidEmail(ticket) {
    await db.rawSql(`UPDATE client SET email = NULL WHERE id = ?`, [
        ticket.clientFk
    ]);

    const oldInstance = `{"email": "${ticket.recipient}"}`;
    const newInstance = `{"email": ""}`;
    await db.rawSql(`
        INSERT INTO clientLog (originFk, userFk, action, changedModel, oldInstance, newInstance) 
            VALUES (?, NULL, 'UPDATE', 'Client', ?, ?)`, [
        ticket.clientFk,
        oldInstance,
        newInstance
    ]);

    const body = `No se ha podido enviar el albarán <strong>${ticket.id}</strong> 
    al cliente <strong>${ticket.clientFk} - ${ticket.clientName}</strong> 
    porque la dirección de email <strong>"${ticket.recipient}"</strong> no es correcta 
    o no está disponible.<br/><br/>
    Para evitar que se repita este error, se ha eliminado la dirección de email de la ficha del cliente. 
    Actualiza la dirección de email con una correcta.`;

    smtp.send({
        to: ticket.salesPersonEmail,
        subject: 'No se ha podido enviar el albarán',
        html: body
    });
}