CleanerTask.php

Go to the documentation of this file.

<?php
namespace TYPO3\CMS\Recycler\Task;

/*
 * This file is part of the TYPO3 CMS project.
 *
 * It is free software; you can redistribute it and/or modify it under
 * the terms of the GNU General Public License, either version 2
 * of the License, or any later version.
 *
 * For the full copyright and license information, please read the
 * LICENSE.txt file that was distributed with this source code.
 *
 * The TYPO3 project - inspiring people to share!
 */
use TYPO3\CMS\Core\Utility\GeneralUtility;

class CleanerTask extends \TYPO3\CMS\Scheduler\Task\AbstractTask
{
    protected $period = 0;

    protected $tcaTables = array();

    protected $databaseConnection = null;

    public function execute()
    {
        $success = true;
        $tables = $this->getTcaTables();
        foreach ($tables as $table) {
            if (!$this->cleanTable($table)) {
                $success = false;
            }
        }

        return $success;
    }

    protected function cleanTable($tableName)
    {
        $queryParts = array();
        if (isset($GLOBALS['TCA'][$tableName]['ctrl']['delete'])) {
            $queryParts[] = $GLOBALS['TCA'][$tableName]['ctrl']['delete'] . ' = 1';
            if ($GLOBALS['TCA'][$tableName]['ctrl']['tstamp']) {
                $dateBefore = $this->getPeriodAsTimestamp();
                $queryParts[] = $GLOBALS['TCA'][$tableName]['ctrl']['tstamp'] . ' < ' . $dateBefore;
            }
            $where = implode(' AND ', $queryParts);

            $this->checkFileResourceFieldsBeforeDeletion($tableName, $where);

            $this->getDatabaseConnection()->exec_DELETEquery($tableName, $where);
        }

        return $this->getDatabaseConnection()->sql_error() === '';
    }

    public function getAdditionalInformation()
    {
        $message = '';

        $message .= sprintf(
            $this->getLanguageService()->sL('LLL:EXT:recycler/Resources/Private/Language/locallang_tasks.xlf:cleanerTaskDescriptionTables'),
            implode(', ', $this->getTcaTables())
        );

        $message .= '; ';

        $message .= sprintf(
            $this->getLanguageService()->sL('LLL:EXT:recycler/Resources/Private/Language/locallang_tasks.xlf:cleanerTaskDescriptionDays'),
            $this->getPeriod()
        );

        return $message;
    }

    public function setPeriod($period)
    {
        $this->period = (int)$period;
    }

    public function getPeriod()
    {
        return $this->period;
    }

    public function getPeriodAsTimestamp()
    {
        return strtotime('-' . $this->getPeriod() . ' days');
    }

    public function setTcaTables($tcaTables = array())
    {
        $this->tcaTables = $tcaTables;
    }

    public function getTcaTables()
    {
        return $this->tcaTables;
    }

    public function setDatabaseConnection($databaseConnection)
    {
        $this->databaseConnection = $databaseConnection;
    }

    protected function checkFileResourceFieldsBeforeDeletion($table, $where)
    {
        $fieldList = $this->getFileResourceFields($table);
        if (!empty($fieldList)) {
            $this->deleteFilesForTable($table, $where, $fieldList);
        }
    }

    protected function deleteFilesForTable($table, $where, array $fieldList)
    {
        $rows = $this->getDatabaseConnection()->exec_SELECTgetRows(
            implode(',', $fieldList),
            $table,
            $where
        );
        foreach ($rows as $row) {
            foreach ($fieldList as $fieldName) {
                $uploadDir = PATH_site . $GLOBALS['TCA'][$table]['columns'][$fieldName]['config']['uploadfolder'] . '/';
                $fileList = GeneralUtility::trimExplode(',', $row[$fieldName]);
                foreach ($fileList as $fileName) {
                    @unlink($uploadDir . $fileName);
                }
            }
        }
    }

    protected function getFileResourceFields($table)
    {
        $result = array();
        if (isset($GLOBALS['TCA'][$table]['columns'])) {
            foreach ($GLOBALS['TCA'][$table]['columns'] as $fieldName => $fieldConfiguration) {
                if ($fieldConfiguration['config']['type'] === 'group'
                    && $fieldConfiguration['config']['internal_type'] === 'file'
                ) {
                    $result[] = $fieldName;
                    break;
                }
            }
        }
        return $result;
    }

    protected function getDatabaseConnection()
    {
        if ($this->databaseConnection === null) {
            $this->databaseConnection = $GLOBALS['TYPO3_DB'];
        }
        return $this->databaseConnection;
    }

    protected function getLanguageService()
    {
        return $GLOBALS['LANG'];
    }
}