portrino/svconnector_csv_extended

<?php

namespace Portrino\SvconnectorCsvExtended\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 Cobweb\ExternalImport\Domain\Repository\SchedulerRepository;
use Cobweb\ExternalImport\Task\AutomatedSyncTask;
use Portrino\SvconnectorCsvExtended\Importer;
use TYPO3\CMS\Core\Utility\GeneralUtility;
use TYPO3\CMS\Scheduler\ProgressProviderInterface;

/**
 * Class AutomatedSyncTaskWithProgress
 * @package Portrino\SvconnectorCsvExtended\Task
 */
class AutomatedSyncTaskWithProgress extends AutomatedSyncTask implements ProgressProviderInterface
{
    /**
     * Gets the progress of a task / tableConfiguratio.
     *
     * @param array $tableConfiguration
     *
     * @return float Progress of the task as a two decimal precision float. f.e. 44.87
     */
    public function getProgress()
    {
        $result = 100.00;

        /** @var Importer $importer */
        $importer = GeneralUtility::makeInstance(Importer::class);

        if ($this->table === 'all') {
            $result = $importer->getProgressForAllTables();
            if ($result === false) {
                $result = 100.00;
                if ($this->isExecutionRunning() ||
                    $this->isDisabled()) {
                    $result = 0.00;
                }
            }
        }

        if ($this->table !== 'all') {
            $result = $importer->getProgressForTable($this->table, $this->index);
            if ($result === false) {
                /** @var SchedulerRepository $schedulerRepository */
                $schedulerRepository = GeneralUtility::makeInstance(SchedulerRepository::class);
                $tasks = $schedulerRepository->fetchAllTasks();
                $taskKey = $this->table . '/' . $this->index;
                if (isset($tasks[$taskKey])) {
                    $task = $tasks[$taskKey];
                    // set progressbar to zero if task is running,
                    // disabled, has no nextexecution or is late - otherwise set the task to 100%
                    $result = 100.00;
                    if ($this->isExecutionRunning() ||
                        $this->isDisabled() ||
                        empty($task['nextexecution_tstamp']) ||
                        $task['nextexecution_tstamp'] < $GLOBALS['EXEC_TIME']) {
                        $result = 0.00;
                    }
                }
            }
        }

        return (double)$result;
    }
}