ilCronJobRepositoryImpl Class Reference

Inheritance diagram for ilCronJobRepositoryImpl:

Collaboration diagram for ilCronJobRepositoryImpl:

Public Member Functions
	__construct (private readonly ilDBInterface $db, private readonly ilSetting $setting, private readonly ilLogger $logger, private readonly ilComponentRepository $componentRepository, private readonly 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, ?CronJobScheduleType $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
	activateJob (ilCronJob $job, DateTimeImmutable $when, ilObjUser $actor, bool $wasManuallyExecuted=false)

Private Attributes
const	TYPE_PLUGINS = 'Plugins'

Detailed Description

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

Constructor & Destructor Documentation

__construct()

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

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

      {
    }

Member Function Documentation

activateJob()

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

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

References ilCronJob\getId().

Referenced by createDefaultEntry().

     : 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);
    }

Here is the call graph for this function:

Here is the caller graph for this function:

createDefaultEntry()

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

Implements ilCronJobRepository.

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

References $res, activateJob(), ilCronJob\activationWasToggled(), ilCronJob\getDefaultScheduleType(), ilCronJob\getDefaultScheduleValue(), ilCronJob\getId(), ilCronJob\hasAutoActivation(), ilCronJob\hasFlexibleSchedule(), ILIAS\Repository\logger(), and updateJobSchedule().

Referenced by getJobInstanceById(), getPluginJobs(), and registerJob().

     : 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_value = $row['schedule_type'] ?? null;
        $schedule_type = is_numeric($schedule_type_value) ? CronJobScheduleType::tryFrom((int) $schedule_type_value) : 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);
            }
        } elseif ($schedule_type === null && $job->hasFlexibleSchedule()) {
            // existing job - but schedule is flexible now
            $this->updateJobSchedule(
                $job,
                $job->getDefaultScheduleType(),
                $job->getDefaultScheduleValue()
            );
        } elseif ($schedule_type !== null && !$job->hasFlexibleSchedule()) {
            // existing job - but schedule is not flexible anymore
            $this->updateJobSchedule($job, null, null);
        }
    }

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 369 of file class.ilCronJobRepositoryImpl.php.

References ilCronJob\getId(), and ilObject\getId().

     : 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);
    }

Here is the call graph for this function:

findAll()

ilCronJobRepositoryImpl::findAll

(

)

Implements ilCronJobRepository.

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

References getCronJobData(), getJobInstance(), and getPluginJobs().

                             : 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;
    }

Here is the call graph for this function:

getCronJobData()

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

Get cron job configuration/execution data.

Parameters

list<string>|string|null

$id

Returns

list<array<string, mixed>>

Implements ilCronJobRepository.

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

References $id, $res, ilDBConstants\T_INTEGER, and ilDBConstants\T_TEXT.

Referenced by findAll(), getJobInstanceById(), and getPluginJobs().

                                                                                     : 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, ilDBConstants::T_TEXT);
        } else {
            $where[] = 'class != ' . $this->db->quote(self::TYPE_PLUGINS, ilDBConstants::T_TEXT);
        }
        if (!$withInactiveJobsIncluded) {
            $where[] = 'job_status = ' . $this->db->quote(1, ilDBConstants::T_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;
    }

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 86 of file class.ilCronJobRepositoryImpl.php.

References ilCronJob\getId().

Referenced by findAll(), getJobInstanceById(), and registerJob().

     : ?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;
    }

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 36 of file class.ilCronJobRepositoryImpl.php.

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

                                                  : ?ilCronJob
    {
        // plugin
        if (str_starts_with($id, 'pl__')) {
            $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) {
                    // 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;
    }

Here is the call graph for this function:

getPluginJobs()

ilCronJobRepositoryImpl::getPluginJobs

(

bool

$withOnlyActive = false

)

Returns

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

Implements ilCronJobRepository.

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

References XapiProxy\$plugin, $res, createDefaultEntry(), and getCronJobData().

Referenced by findAll().

                                                               : 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;
    }

Here is the call graph for this function:

Here is the caller graph for this function:

registerJob()

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

Implements ilCronJobRepository.

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

References createDefaultEntry(), and getJobInstance().

     : 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);
        }
    }

Here is the call graph for this function:

resetJob()

ilCronJobRepositoryImpl::resetJob

(

ilCronJob

$job

)

Implements ilCronJobRepository.

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

References ilCronJob\getId().

                                            : 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')
        );
    }

Here is the call graph for this function:

unregisterJob()

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

Implements ilCronJobRepository.

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

References $res.

                                                                            : 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')
                );
            }
        }
    }

updateJobResult()

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

Implements ilCronJobRepository.

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

References $user_id, ilCronJobResult\getCode(), ilCronJobResult\getDuration(), ilCronJob\getId(), ilObject\getId(), ilCronJobResult\getMessage(), and ilCronJobResult\getStatus().

     : 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);
    }

Here is the call graph for this function:

updateJobSchedule()

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

Implements ilCronJobRepository.

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

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

Referenced by createDefaultEntry().

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

Here is the call graph for this function:

Here is the caller graph for this function:

updateRunInformation()

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

Implements ilCronJobRepository.

Definition at line 325 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

TYPE_PLUGINS

const ilCronJobRepositoryImpl::TYPE_PLUGINS = 'Plugins'

private

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

---

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

• components/ILIAS/Cron/classes/class.ilCronJobRepositoryImpl.php