fannie/modules/plugins2.0/CommentTracker/CommentSummaryTask.php from CORE-POS/IS4C

fannie/modules/plugins2.0/CommentTracker/CommentSummaryTask.php
Summary

Maintainability

5 hrs
Test Coverage

Issues
<?php

use COREPOS\Fannie\API\data\pipes\OutgoingEmail;

class CommentSummaryTask extends FannieTask
{
    public $name = 'Comment Tracker Summary';

    public $description = 'Summarizes comments received in the last day';

    public function run()
    {
        $settings = $this->config->get('PLUGIN_SETTINGS');
        $dbc = FannieDB::get($settings['CommentDB']);
        $cmP = $dbc->prepare("SELECT * FROM Comments WHERE categoryID=? AND ccNotified=0");
        $upP = $dbc->prepare("UPDATE Comments SET ccNotified=1 WHERE commentID=?");
        $rsP = $dbc->prepare('SELECT * FROM Responses WHERE commentID=? ORDER BY tdate');
        $query = "
            SELECT c.categoryID, t.name, t.notifyAddress, t.ccAddress,
                COUNT(*) AS numberOfComments
            FROM Comments AS c
                INNER JOIN Categories AS t ON c.categoryID=t.categoryID
            WHERE c.categoryID > 0
                AND ccNotified=0
            GROUP BY c.categoryID, t.name, t.notifyAddress, t.ccAddress";
        $prep = $dbc->prepare($query);
        $res = $dbc->execute($prep);
        $notified = array();
        while ($row = $dbc->fetchRow($res)) {
            $mail = OutgoingEmail::get();
            $mail->From = 'comments@wholefoods.coop';
            $mail->FromName = 'Comment Tracker';
            $mail->Subject = $row['name'] . ' Comment Summary';
            $mail->isHTML(true);
            $address = $row['ccAddress'];
            foreach (explode(',', $address) as $a) {
                $mail->addAddress(trim($a));
            }
            $body = <<<HTML
<p>WFC received {$row['numberOfComments']} {$row['name']} comments</p>
HTML;
            $cmR = $dbc->execute($cmP, array($row['categoryID']));
            while ($cmW = $dbc->fetchRow($cmR)) {
                $body .= '<hr />';
                $body .= '<p>Comment from ' . $cmW['email'] . '</p>';
                $body .= '<p>';
                $body .= nl2br($cmW['comment']);
                $body .= '</p>';
                $resp = $dbc->getAllRows($rsP, array($cmW['commentID']));
                if (count($resp) == 0) {
                    $body .= '<p><a href="http://key/git/fannie/modules/plugins2.0/CommentTracker/ManageComments.php?id='
                        . $cmW['commentID'] . '">Add Response</a></p>';
                } else {
                    $body .= '<p>WFC Response(s)</p>';
                    foreach ($resp as $r) {
                        $body .= '<p>' . nl2br($r['response']) . '</p>';
                    }
                }
                $notified[] = $cmW['commentID'];
            }
            $body .= <<<HTML
<p>This is a summary of comments from a category that someone else is responsible for
but you might still want to be aware of. If you don't want summaries for this particular
category please tell IT.</p> 
HTML;
            $mail->Body = $body;
            $sent = false;
            if ($address != '') {
                $sent = $mail->send();
            }
            if ($sent || $address == '') {
                foreach ($notified as $id) {
                    $dbc->execute($upP, array($id));
                }
            }
        }

        $cutoff = date('Y-m-d', strtotime('2 days ago'));
        $spamP = $dbc->prepare("DELETE FROM Comments WHERE categoryID=-1 AND tdate <= ?");
        $dbc->execute($spamP, array($cutoff));
    }
}