class.ilMailCronOrphanedMailsNotifier.php

Go to the documentation of this file.

<?php
/* Copyright (c) 1998-2015 ILIAS open source, Extended GPL, see docs/LICENSE */

class ilMailCronOrphanedMailsNotifier
{
    protected $collector;

    protected $db;

    protected $threshold = 0;

    protected $mail_notify_orphaned = 0;

    public function __construct(ilMailCronOrphanedMailsNotificationCollector $collector, $threshold, $mail_notify_orphaned)
    {
        global $DIC;

        $this->db = $DIC->database();

        $this->collector = $collector;
        $this->threshold = $threshold;
        $this->mail_notify_orphaned = $mail_notify_orphaned;
    }

    private function markAsNotified(ilMailCronOrphanedMailsNotificationCollectionObj $collection_obj)
    {
        if ($this->threshold > $this->mail_notify_orphaned) {
            $notify_days_before = $this->threshold - $this->mail_notify_orphaned;
        } else {
            $notify_days_before = 1;
        }

        $ts_delete = strtotime("+ " . $notify_days_before . " days");
        $ts_for_deletion = mktime(0, 0, 0, date('m', $ts_delete), date('d', $ts_delete), date('Y', $ts_delete));

        foreach ($collection_obj->getFolderObjects() as $folder_obj) {
            $folder_id = $folder_obj->getFolderId();
            
            foreach ($folder_obj->getOrphanedMailObjects() as $mail_obj) {
                $mail_id = $mail_obj->getMailId();
            
                $this->db->insert(
                    'mail_cron_orphaned',
                    array(
                        'mail_id' => array('integer', $mail_id),
                        'folder_id' => array('integer', $folder_id),
                        'ts_do_delete' => array('integer', $ts_for_deletion))
                );
            }
        }
    }

    private function sendMail(ilMailCronOrphanedMailsNotificationCollectionObj $collection_obj)
    {
        include_once './Services/Mail/classes/class.ilMailCronOrphanedMailsNotification.php';
        $mail = new ilMailCronOrphanedMailsNotification();

        $mail->setRecipients(array($collection_obj->getUserId()));
        $mail->setAdditionalInformation(array('mail_folders' => $collection_obj->getFolderObjects()));
        $mail->send();
    }

    public function processNotification()
    {
        foreach ($this->collector->getCollection() as $collection_obj) {
            $this->sendMail($collection_obj);
            $this->markAsNotified($collection_obj);
        }
    }
}