Inheritance diagram for ilCronJobRepositoryImpl:

Collaboration diagram for ilCronJobRepositoryImpl:

Public Member Functions
	__construct (ilDBInterface $db, ilSetting $setting, ilLogger $logger, ilComponentRepository $componentRepository, ilComponentFactory $componentFactory)

	getJobInstanceById (string $id)

	getJobInstance (string $a_id, string $a_component, string $a_class, bool $isCreationContext=false)

	getCronJobData ($id=null, bool $withInactiveJobsIncluded=true)
	Get cron job configuration/execution data. More...

	registerJob (string $a_component, string $a_id, string $a_class, ?string $a_path)

	unregisterJob (string $a_component, array $a_xml_job_ids)

	createDefaultEntry (ilCronJob $job, string $component, string $class, ?string $path)

	getPluginJobs (bool $withOnlyActive=false)

	resetJob (ilCronJob $job)

	updateJobResult (ilCronJob $job, DateTimeImmutable $when, ilObjUser $actor, ilCronJobResult $result, bool $wasManualExecution=false)

	updateRunInformation (string $jobId, int $runningTimestamp, int $aliveTimestamp)

	updateJobSchedule (ilCronJob $job, ?int $scheduleType, ?int $scheduleValue)

	activateJob (ilCronJob $job, DateTimeImmutable $when, ?ilObjUser $actor=null, bool $wasManuallyExecuted=false)

	deactivateJob (ilCronJob $job, DateTimeImmutable $when, ilObjUser $actor, bool $wasManuallyExecuted=false)

	findAll ()

Public Member Functions inherited from ilCronJobRepository
	getJobInstanceById (string $id)

	getJobInstance (string $a_id, string $a_component, string $a_class, bool $isCreationContext=false)

	getCronJobData ($id=null, bool $withInactiveJobsIncluded=true)
	Get cron job configuration/execution data. More...

	registerJob (string $a_component, string $a_id, string $a_class, ?string $a_path)

	unregisterJob (string $a_component, array $a_xml_job_ids)

	createDefaultEntry (ilCronJob $job, string $component, string $class, ?string $path)

	getPluginJobs (bool $withOnlyActive=false)

	resetJob (ilCronJob $job)

	updateJobResult (ilCronJob $job, DateTimeImmutable $when, ilObjUser $actor, ilCronJobResult $result, bool $wasManualExecution=false)

	updateRunInformation (string $jobId, int $runningTimestamp, int $aliveTimestamp)

	updateJobSchedule (ilCronJob $job, ?int $scheduleType, ?int $scheduleValue)

	activateJob (ilCronJob $job, DateTimeImmutable $when, ilObjUser $actor, bool $wasManuallyExecuted=false)

	deactivateJob (ilCronJob $job, DateTimeImmutable $when, ilObjUser $actor, bool $wasManuallyExecuted=false)

	findAll ()

Private Attributes
const	TYPE_PLUGINS = 'Plugins'

ilDBInterface	$db

ilSetting	$setting

ilLogger	$logger

ilComponentRepository	$componentRepository

ilComponentFactory	$componentFactory

Detailed Description

Definition at line 21 of file class.ilCronJobRepositoryImpl.php.

Constructor & Destructor Documentation

◆ __construct()

ilCronJobRepositoryImpl::__construct	(	ilDBInterface	$db,
		ilSetting	$setting,
		ilLogger	$logger,
		ilComponentRepository	$componentRepository,
		ilComponentFactory	$componentFactory
	)

Definition at line 31 of file class.ilCronJobRepositoryImpl.php.

      {
        $this->db = $db;
        $this->setting = $setting;
        $this->logger = $logger;
        $this->componentRepository = $componentRepository;
        $this->componentFactory = $componentFactory;
    }

References $componentFactory, $componentRepository, $db, $logger, $setting, and ILIAS\Repository\logger().

Here is the call graph for this function:

Member Function Documentation

◆ activateJob()

ilCronJobRepositoryImpl::activateJob	(	ilCronJob	$job,
		DateTimeImmutable	$when,
		?ilObjUser	$actor = `null`,
		bool	$wasManuallyExecuted = `false`
	)

Definition at line 358 of file class.ilCronJobRepositoryImpl.php.

     : void {
        $usrId = 0;
        if ($wasManuallyExecuted && $actor instanceof ilObjUser) {
            $usrId = $actor->getId();
        }
 
        $query = 'UPDATE cron_job SET ' .
            ' job_status = ' . $this->db->quote(1, 'integer') .
            ' , job_status_user_id = ' . $this->db->quote($usrId, 'integer') .
            ' , job_status_type = ' . $this->db->quote($wasManuallyExecuted, 'integer') .
            ' , job_status_ts = ' . $this->db->quote($when->getTimestamp(), 'integer') .
            ' WHERE job_id = ' . $this->db->quote($job->getId(), 'text');
        $this->db->manipulate($query);
    }

References ilObject\getId().

Here is the call graph for this function:

◆ createDefaultEntry()

ilCronJobRepositoryImpl::createDefaultEntry	(	ilCronJob	$job,
		string	$component,
		string	$class,
		?string	$path
	)

Implements ilCronJobRepository.

Definition at line 201 of file class.ilCronJobRepositoryImpl.php.

     : void {
        $query = "SELECT job_id, schedule_type, component, class, path FROM cron_job" .
            " WHERE job_id = " . $this->db->quote($job->getId(), "text");
        $res = $this->db->query($query);
        $row = $this->db->fetchAssoc($res);
        $job_id = $row['job_id'] ?? null;
        $job_exists = ($job_id === $job->getId());
        $schedule_type = $row["schedule_type"] ?? null;
 
        if (
            $job_exists && (
                $row['component'] !== $component ||
                $row['class'] !== $class ||
                $row['path'] !== $path
            )
        ) {
            $this->db->manipulateF(
                'UPDATE cron_job SET component = %s, class = %s, path = %s WHERE job_id = %s',
                ['text', 'text', 'text', 'text'],
                [$component, $class, $path, $job->getId()]
            );
        }
 
        // new job
        if (!$job_exists) {
            $query = 'INSERT INTO cron_job (job_id, component, class, path)' .
                ' VALUES (' . $this->db->quote($job->getId(), 'text') . ', ' .
                $this->db->quote($component, 'text') . ', ' .
                $this->db->quote($class, 'text') . ', ' .
                $this->db->quote($path, 'text') . ')';
            $this->db->manipulate($query);
 
            $this->logger->info('Cron XML - Job ' . $job->getId() . ' in class ' . $class . ' added.');
 
            // only if flexible
            $this->updateJobSchedule(
                $job,
                $job->getDefaultScheduleType(),
                $job->getDefaultScheduleValue()
            );
 
            if ($job->hasAutoActivation()) {
                $this->activateJob($job, new DateTimeImmutable('@' . time()));
                $job->activationWasToggled($this->db, $this->setting, true);
            } else {
                // to overwrite dependent settings
                $job->activationWasToggled($this->db, $this->setting, false);
            }
        } // existing job - but schedule is flexible now
        elseif (!$schedule_type && $job->hasFlexibleSchedule()) {
            $this->updateJobSchedule(
                $job,
                $job->getDefaultScheduleType(),
                $job->getDefaultScheduleValue()
            );
        } // existing job - but schedule is static now
        elseif ($schedule_type && !$job->hasFlexibleSchedule()) {
            $this->updateJobSchedule($job, null, null);
        }
    }

References $path, and ilCronJob\getId().

Referenced by getJobInstanceById().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ deactivateJob()

ilCronJobRepositoryImpl::deactivateJob	(	ilCronJob	$job,
		DateTimeImmutable	$when,
		ilObjUser	$actor,
		bool	$wasManuallyExecuted = `false`
	)

Implements ilCronJobRepository.

Definition at line 378 of file class.ilCronJobRepositoryImpl.php.

     : void {
        $usrId = $wasManuallyExecuted ? $actor->getId() : 0;
 
        $query = 'UPDATE cron_job SET ' .
            ' job_status = ' . $this->db->quote(0, 'integer') .
            ' , job_result_status = ' . $this->db->quote(null, 'text') .
            ' , job_result_message = ' . $this->db->quote(null, 'text') .
            ' , job_result_type = ' . $this->db->quote(null, 'text') .
            ' , job_result_code = ' . $this->db->quote(null, 'text') .
            ' , job_status_user_id = ' . $this->db->quote($usrId, 'integer') .
            ' , job_status_type = ' . $this->db->quote($wasManuallyExecuted, 'integer') .
            ' , job_status_ts = ' . $this->db->quote($when->getTimestamp(), 'integer') .
            ' WHERE job_id = ' . $this->db->quote($job->getId(), 'text');
        $this->db->manipulate($query);
    }

◆ findAll()

ilCronJobRepositoryImpl::findAll ( )

Implements ilCronJobRepository.

Definition at line 399 of file class.ilCronJobRepositoryImpl.php.

                             : ilCronJobCollection
    {
        $collection = new ilCronJobEntities();
 
        foreach ($this->getCronJobData() as $item) {
            $job = $this->getJobInstance(
                $item['job_id'],
                $item['component'],
                $item['class']
            );
            if ($job) {
                $collection->add(new ilCronJobEntity($job, $item));
            }
        }
 
        foreach ($this->getPluginJobs() as $item) {
            $collection->add(new ilCronJobEntity($item[0], $item[1], true));
        }
 
        return $collection;
    }

◆ getCronJobData()

ilCronJobRepositoryImpl::getCronJobData	(		$id = `null`,
		bool	$withInactiveJobsIncluded = `true`
	)

Get cron job configuration/execution data.

Parameters

array \| string \| null	$id
bool	$withInactiveJobsIncluded

Returns: array<int, array<string, mixed>>

Implements ilCronJobRepository.

Definition at line 123 of file class.ilCronJobRepositoryImpl.php.

                                                                                     : array
    {
        $jobData = [];
 
        if ($id && !is_array($id)) {
            $id = [$id];
        }
 
        $query = "SELECT * FROM cron_job";
        $where = [];
        if ($id) {
            $where[] = $this->db->in('job_id', $id, false, 'text');
        } else {
            $where[] = 'class != ' . $this->db->quote(self::TYPE_PLUGINS, 'text');
        }
        if (!$withInactiveJobsIncluded) {
            $where[] = 'job_status = ' . $this->db->quote(1, 'integer');
        }
        if ($where !== []) {
            $query .= ' WHERE ' . implode(' AND ', $where);
        }
        // :TODO: discuss job execution order
        $query .= ' ORDER BY job_id';
 
        $res = $this->db->query($query);
        while ($row = $this->db->fetchAssoc($res)) {
            $jobData[] = $row;
        }
 
        return $jobData;
    }

References $id, $query, and $res.

Referenced by getJobInstanceById().

Here is the caller graph for this function:

◆ getJobInstance()

ilCronJobRepositoryImpl::getJobInstance	(	string	$a_id,
		string	$a_component,
		string	$a_class,
		bool	$isCreationContext = `false`
	)

Implements ilCronJobRepository.

Definition at line 95 of file class.ilCronJobRepositoryImpl.php.

     : ?ilCronJob {
        if (class_exists($a_class)) {
            if ($isCreationContext) {
                $refl = new ReflectionClass($a_class);
                $job = $refl->newInstanceWithoutConstructor();
            } else {
                $job = new $a_class();
            }
 
            if ($job instanceof ilCronJob && $job->getId() === $a_id) {
                return $job;
            }
        }
 
        return null;
    }

References ilCronJob\getId().

Referenced by getJobInstanceById().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ getJobInstanceById()

ilCronJobRepositoryImpl::getJobInstanceById ( string $id )

Implements ilCronJobRepository.

Definition at line 45 of file class.ilCronJobRepositoryImpl.php.

                                                  : ?ilCronJob
    {
        // plugin
        if (strpos($id, 'pl__') === 0) {
            $parts = explode('__', $id);
            $pl_name = $parts[1];
            $job_id = $parts[2];
 
            foreach ($this->componentRepository->getPlugins() as $pl) {
                if ($pl->getName() !== $pl_name || !$pl->isActive()) {
                    continue;
                }
 
                $plugin = $this->componentFactory->getPlugin($pl->getId());
                if (!$plugin instanceof ilCronJobProvider) {
                    continue;
                }
 
                try {
                    $job = $plugin->getCronJobInstance($job_id);
 
                    // should never happen but who knows...
                    $jobs_data = $this->getCronJobData($job_id);
                    if ($jobs_data === []) {
                        // as job is not 'imported' from xml
                        $this->createDefaultEntry($job, $pl_name, self::TYPE_PLUGINS, '');
                    }
 
                    return $job;
                } catch (OutOfBoundsException $e) {
                    // Maybe a job was removed from plugin, renamed etc.
                }
                break;
            }
        } else {
            $jobs_data = $this->getCronJobData($id);
            if ($jobs_data !== [] && $jobs_data[0]['job_id'] === $id) {
                return $this->getJobInstance(
                    $jobs_data[0]['job_id'],
                    $jobs_data[0]['component'],
                    $jobs_data[0]['class']
                );
            }
        }
 
        $this->logger->info('CRON - job ' . $id . ' seems invalid or is inactive');
 
        return null;
    }

References Vendor\Package\$e, $id, $parts, XapiProxy\$plugin, createDefaultEntry(), getCronJobData(), getJobInstance(), and ILIAS\Repository\logger().

Here is the call graph for this function:

◆ getPluginJobs()

ilCronJobRepositoryImpl::getPluginJobs ( bool $withOnlyActive = false )

Parameters

bool $withOnlyActive

Returns: array<int, array{0: ilCronJob, 1: array<string, mixed>}>

Implements ilCronJobRepository.

Definition at line 271 of file class.ilCronJobRepositoryImpl.php.

                                                               : array
    {
        $res = [];
        foreach ($this->componentRepository->getPlugins() as $pl) {
            if (!$pl->isActive()) {
                continue;
            }
 
            $plugin = $this->componentFactory->getPlugin($pl->getId());
 
            if (!$plugin instanceof ilCronJobProvider) {
                continue;
            }
 
            foreach ($plugin->getCronJobInstances() as $job) {
                $jobs_data = $this->getCronJobData($job->getId());
                $job_data = $jobs_data[0] ?? null;
                if (!is_array($job_data) || $job_data === []) {
                    // as job is not "imported" from xml
                    $this->createDefaultEntry($job, $plugin->getPluginName(), self::TYPE_PLUGINS, '');
                }
 
                $jobs_data = $this->getCronJobData($job->getId());
                $job_data = $jobs_data[0];
 
                // #17941
                if (!$withOnlyActive || (int) $job_data['job_status'] === 1) {
                    $res[$job->getId()] = [$job, $job_data];
                }
            }
        }
 
        return $res;
    }

References XapiProxy\$plugin, and $res.

◆ registerJob()

ilCronJobRepositoryImpl::registerJob	(	string	$a_component,
		string	$a_id,
		string	$a_class,
		?string	$a_path
	)

Implements ilCronJobRepository.

Definition at line 155 of file class.ilCronJobRepositoryImpl.php.

     : void {
        if (!$this->db->tableExists('cron_job')) {
            return;
        }
 
        $job = $this->getJobInstance($a_id, $a_component, $a_class, true);
        if ($job) {
            $this->createDefaultEntry($job, $a_component, $a_class, $a_path);
        }
    }

◆ resetJob()

ilCronJobRepositoryImpl::resetJob ( ilCronJob $job )

Implements ilCronJobRepository.

Definition at line 306 of file class.ilCronJobRepositoryImpl.php.

                                            : void
    {
        $this->db->manipulate('UPDATE cron_job' .
            ' SET running_ts = ' . $this->db->quote(0, 'integer') .
            ' , alive_ts = ' . $this->db->quote(0, 'integer') .
            ' , job_result_ts = ' . $this->db->quote(0, 'integer') .
            ' WHERE job_id = ' . $this->db->quote($job->getId(), 'text'));
    }

References ilCronJob\getId().

Here is the call graph for this function:

◆ unregisterJob()

ilCronJobRepositoryImpl::unregisterJob	(	string	$a_component,
		array	$a_xml_job_ids
	)

Implements ilCronJobRepository.

Definition at line 171 of file class.ilCronJobRepositoryImpl.php.

                                                                            : void
    {
        if (!$this->db->tableExists('cron_job')) {
            return;
        }
 
        $jobs = [];
        $query = 'SELECT job_id FROM cron_job WHERE component = ' . $this->db->quote($a_component, 'text');
        $res = $this->db->query($query);
        while ($row = $this->db->fetchAssoc($res)) {
            $jobs[] = $row['job_id'];
        }
 
        if ($jobs !== []) {
            if ($a_xml_job_ids !== []) {
                foreach ($jobs as $job_id) {
                    if (!in_array($job_id, $a_xml_job_ids, true)) {
                        $this->db->manipulate(
                            'DELETE FROM cron_job' .
                            ' WHERE component = ' . $this->db->quote($a_component, 'text') .
                            ' AND job_id = ' . $this->db->quote($job_id, 'text')
                        );
                    }
                }
            } else {
                $this->db->manipulate('DELETE FROM cron_job WHERE component = ' . $this->db->quote($a_component, 'text'));
            }
        }
    }

References $query, and $res.

◆ updateJobResult()

ilCronJobRepositoryImpl::updateJobResult	(	ilCronJob	$job,
		DateTimeImmutable	$when,
		ilObjUser	$actor,
		ilCronJobResult	$result,
		bool	$wasManualExecution = `false`
	)

Implements ilCronJobRepository.

Definition at line 315 of file class.ilCronJobRepositoryImpl.php.

     : void {
        $user_id = $wasManualExecution ? $actor->getId() : 0;
 
        $query = 'UPDATE cron_job SET ' .
            ' job_result_status = ' . $this->db->quote($result->getStatus(), 'integer') .
            ' , job_result_user_id = ' . $this->db->quote($user_id, 'integer') .
            ' , job_result_code = ' . $this->db->quote($result->getCode(), 'text') .
            ' , job_result_message = ' . $this->db->quote($result->getMessage(), 'text') .
            ' , job_result_type = ' . $this->db->quote((int) $wasManualExecution, 'integer') .
            ' , job_result_ts = ' . $this->db->quote($when->getTimestamp(), 'integer') .
            ' , job_result_dur = ' . $this->db->quote($result->getDuration() * 1000, 'integer') .
            ' WHERE job_id = ' . $this->db->quote($job->getId(), 'text');
        $this->db->manipulate($query);
    }

◆ updateJobSchedule()

ilCronJobRepositoryImpl::updateJobSchedule	(	ilCronJob	$job,
		?int	$scheduleType,
		?int	$scheduleValue
	)

Implements ilCronJobRepository.

Definition at line 344 of file class.ilCronJobRepositoryImpl.php.

                                                                                              : void
    {
        if (
            $scheduleType === null ||
            ($job->hasFlexibleSchedule() && in_array($scheduleType, $job->getValidScheduleTypes(), true))
        ) {
            $query = 'UPDATE cron_job SET ' .
                ' schedule_type = ' . $this->db->quote($scheduleType, 'integer') .
                ' , schedule_value = ' . $this->db->quote($scheduleValue, 'integer') .
                ' WHERE job_id = ' . $this->db->quote($job->getId(), 'text');
            $this->db->manipulate($query);
        }
    }

References $query, ilCronJob\getId(), ilCronJob\getValidScheduleTypes(), and ilCronJob\hasFlexibleSchedule().

Here is the call graph for this function:

◆ updateRunInformation()

ilCronJobRepositoryImpl::updateRunInformation	(	string	$jobId,
		int	$runningTimestamp,
		int	$aliveTimestamp
	)

Implements ilCronJobRepository.

Definition at line 336 of file class.ilCronJobRepositoryImpl.php.

                                                                                                   : void
    {
        $this->db->manipulate('UPDATE cron_job SET' .
            ' running_ts = ' . $this->db->quote($runningTimestamp, 'integer') .
            ' , alive_ts = ' . $this->db->quote($aliveTimestamp, 'integer') .
            ' WHERE job_id = ' . $this->db->quote($jobId, 'text'));
    }

Field Documentation

◆ $componentFactory

ilComponentFactory ilCronJobRepositoryImpl::$componentFactory

private

Definition at line 29 of file class.ilCronJobRepositoryImpl.php.

Referenced by __construct().

◆ $componentRepository

ilComponentRepository ilCronJobRepositoryImpl::$componentRepository

private

Definition at line 28 of file class.ilCronJobRepositoryImpl.php.

Referenced by __construct().

◆ $db

ilDBInterface ilCronJobRepositoryImpl::$db

private

Definition at line 25 of file class.ilCronJobRepositoryImpl.php.

Referenced by __construct().

◆ $logger

ilLogger ilCronJobRepositoryImpl::$logger

private

Definition at line 27 of file class.ilCronJobRepositoryImpl.php.

Referenced by __construct().

◆ $setting

ilSetting ilCronJobRepositoryImpl::$setting

private

Definition at line 26 of file class.ilCronJobRepositoryImpl.php.

Referenced by __construct().

◆ TYPE_PLUGINS

const ilCronJobRepositoryImpl::TYPE_PLUGINS = 'Plugins'

private

Definition at line 23 of file class.ilCronJobRepositoryImpl.php.

The documentation for this class was generated from the following file:

Services/Cron/classes/class.ilCronJobRepositoryImpl.php

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ __construct()

Member Function Documentation

◆ activateJob()

◆ createDefaultEntry()

◆ deactivateJob()

◆ findAll()

◆ getCronJobData()

◆ getJobInstance()

◆ getJobInstanceById()

◆ getPluginJobs()

◆ registerJob()

◆ resetJob()

◆ unregisterJob()

◆ updateJobResult()

◆ updateJobSchedule()

◆ updateRunInformation()

Field Documentation

◆ $componentFactory

◆ $componentRepository

◆ $db

◆ $logger

◆ $setting

◆ TYPE_PLUGINS