class.ilMailCronOrphanedMailsDeletionProcessor.php

Go to the documentation of this file.

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

require_once './Services/Logging/classes/public/class.ilLoggerFactory.php';

class ilMailCronOrphanedMailsDeletionProcessor
{
        protected $collector;

        public function __construct(ilMailCronOrphanedMailsDeletionCollector $collector)
        {
                $this->collector = $collector;
        }
        
        private function deleteAttachments()
        {
                global $ilDB;

                $attachment_paths = array();

                $res = $ilDB->query('
                                SELECT path, COUNT(mail_id) cnt_mail_ids
                                FROM mail_attachment 
                                WHERE '. $ilDB->in('mail_id', $this->collector->getMailIdsToDelete(), false, 'integer').'
                                GROUP BY path');
                
                while($row = $ilDB->fetchAssoc($res))
                {
                        $usage_res = $ilDB->queryF('SELECT mail_id, path FROM mail_attachment WHERE path = %s', 
                                array('text'), array($row['path']));
                        
                        $num_rows = $ilDB->numRows($usage_res);
                        
                        if($row['cnt_mail_ids'] >= $num_rows)
                        {
                                // collect path to delete attachment file
                                $attachment_paths[$row['mail_id']] = $row['path'];
                        }
                }

                foreach($attachment_paths as $mail_id => $path)
                {
                        try
                        {
                                $path = CLIENT_DATA_DIR.'/mail/'.$path;
                                $iter = new RecursiveIteratorIterator(
                                        new RecursiveDirectoryIterator($path), RecursiveIteratorIterator::CHILD_FIRST);

                                foreach($iter as $file)
                                {
                                        $path_name = $file->getPathname();
                                        if($file->isDir())
                                        {
                                                @rmdir($path_name);
                                                ilLoggerFactory::getLogger('mail')->info(sprintf(
                                                        'Attachment directory (%s) deleted for mail_id:  %s', $path_name, $mail_id
                                                ));
                                        }
                                        else
                                        {
                                                @unlink($path_name);
                                                ilLoggerFactory::getLogger('mail')->info(sprintf(
                                                        'Attachment file (%s) deleted for mail_id:  %s', $path_name, $mail_id
                                                ));
                                        }
                                }
                                @rmdir($path);
                                ilLoggerFactory::getLogger('mail')->info(sprintf(
                                        'Attachment directory (%s) deleted for mail_id:  %s', $path, $mail_id
                                ));
                        }
                        catch(Exception $e) { }
                }

                $ilDB->manipulate('DELETE FROM mail_attachment WHERE '. $ilDB->in('mail_id', $this->collector->getMailIdsToDelete(), false, 'integer'));
        }
        
        private function deleteMails()
        {
                global $ilDB;
                
                $ilDB->manipulate('DELETE FROM mail WHERE ' . $ilDB->in('mail_id', $this->collector->getMailIdsToDelete(), false, 'integer'));
        }
        
        private function deleteMarkedAsNotified()
        {
                global $ilDB, $ilSetting;
        
                if((int)$ilSetting->get('mail_notify_orphaned') >= 1)
                {
                        $ilDB->manipulate('DELETE FROM mail_cron_orphaned WHERE ' . $ilDB->in('mail_id', $this->collector->getMailIdsToDelete(), false, 'integer'));
                }
                else
                {
                        $ilDB->manipulate('DELETE FROM mail_cron_orphaned');
                }
        }
        
        public function processDeletion()
        {       
                if(count($this->collector->getMailIdsToDelete()) > 0)
                {
                        // delete possible attachments ... 
                        $this->deleteAttachments();

                        $this->deleteMails();
                        require_once './Services/Logging/classes/public/class.ilLoggerFactory.php';
                        ilLoggerFactory::getLogger('mail')->info(sprintf(
                                'Deleted mail_ids: %s',  implode(', ', $this->collector->getMailIdsToDelete())
                        ));

                        $this->deleteMarkedAsNotified();
                        ilLoggerFactory::getLogger('mail')->info(sprintf(
                                'Deleted mail_cron_orphaned mail_ids: %s', implode(', ', $this->collector->getMailIdsToDelete())
                        ));
                }
        }
}