CORE-POS/IS4C

<?php

namespace COREPOS\Fannie\API\jobs;
use \FannieConfig;
use \FannieDB;
use \FannieLogger;
use \COREPOS\common\ErrorHandler;
use \COREPOS\common\mvc\ValueContainer;
use \COREPOS\Fannie\API\data\pipes\OutgoingEmail;


/**
 * @class QueuedReport
 * 
 * Run a report in the background if it might take awhile
 * and dispatch the result via email
 *
 * Data format:
 * {
 *     'reportFile': <string>,
 *     'reportClass': <string>,
 *     'email': <string>
 *     'formData': {
 *          'key': 'val',
 *          'key': 'val',
 *          ...
 *     }
 * }
 */
class QueuedReport extends Job
{
    public function run()
    {
        if (!class_exists('\\' . $this->data['reportClass'])) {
            include($this->data['reportFile']);
        }
        $pClass = $this->data['reportClass'];
        $page = new $pClass(array());

        $config = FannieConfig::factory();
        $logger = FannieLogger::factory();
        $op_db = $config->get('OP_DB');
        $dbc = FannieDB::get($op_db);
        // This will fail in SQLite but should work in MySQL, SQL Server, & Postgres
        // There's probably not a real scenario where you'd queue a report
        // because the underlying query will take a long time, and also you're
        // running CORE on top of SQLite.
        $dbc->query('SET TRANSACTION ISOLATION LEVEL READ UNCOMMITTED');
        ErrorHandler::setLogger($logger);
        ErrorHandler::setErrorHandlers();
        $page->setConfig($config);
        $page->setLogger($logger);
        $page->setConnection($dbc);

        $values = new ValueContainer();
        $values->setMany($this->data['formData']);
        $page->setForm($values);
        $page->setFormat('csv');

        $csv = $page->report_content();

        $mail = OutgoingEmail::get();
        $mail->isSMTP();
        $mail->Host = '127.0.0.1';
        $mail->Port = 25;
        $mail->SMTPAuth = false;
        $mail->SMTPAutoTLS = false;
        $mail->FromName = 'Queued Report';
        $mail->From = $config->get('PO_EMAIL');
        $mail->Body = 'The requested report is attached.';
        $mail->Subject = 'Queued Report';
        $mail->addStringAttachment(
            $csv,
            $this->data['reportClass'] . '.csv',
            'base64',
            'text/csv'
        );
        $mail->addAddress($this->data['email']);
        $mail->send();
    }
}