SilverStripe\QueuedJobs\Extensions\ScheduledExecutionExtension

Complexity

Total Complexity

13

Size/Duplication

Total Lines	113
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	12

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
B	updateCMSFields()	0	41	2
D	onBeforeWrite()	0	33	10
A	onScheduledExecution()	0	3	1

<?php

namespace SilverStripe\QueuedJobs\Extensions;

use SilverStripe\Forms\DatetimeField;
use SilverStripe\Forms\DropdownField;
use SilverStripe\Forms\FieldGroup;
use SilverStripe\Forms\FieldList;
use SilverStripe\Forms\NumericField;
use SilverStripe\Forms\ReadonlyField;
use SilverStripe\Forms\TextField;
use SilverStripe\ORM\DataExtension;
use SilverStripe\QueuedJobs\Jobs\ScheduledExecutionJob;

/**
 * An extension that can be added to objects that automatically
 * adds scheduled execution capabilities to data objects.
 *
 * Developers who want to use these capabilities can set up
 *
 * @author marcus@silverstripe.com.au
 * @license BSD License http://silverstripe.org/bsd-license/
 */
class ScheduledExecutionExtension extends DataExtension
{
    /**
     * @var array
     */
    private static $db = array(

The property $db is not used and could be removed.

        'FirstExecution' => 'DBDatetime',
        'ExecuteInterval' => 'Int',
        'ExecuteEvery' => "Enum(',Minute,Hour,Day,Week,Fortnight,Month,Year')",
        'ExecuteFree' => 'Varchar',
    );

    /**
     * @var array
     */
    private static $defaults = array(

The property $defaults is not used and could be removed.

        'ExecuteInterval' => 1,
    );

    /**
     * @var array
     */
    private static $has_one = array(

The property $has_one is not used and could be removed.

        'ScheduledJob' => 'SilverStripe\\QueuedJobs\\DataObjects\\QueuedJobDescriptor',
    );

    /**
     * @param FieldSet $fields
     */
    public function updateCMSFields(FieldList $fields)
    {
        $fields->findOrMakeTab(
            'Root.Schedule',
            _t('ScheduledExecution.ScheduleTabTitle', 'Schedule')
        );
        $fields->addFieldsToTab('Root.Schedule', array(
            $dt = DatetimeField::create('FirstExecution', _t('ScheduledExecution.FIRST_EXECUTION', 'First Execution')),
            FieldGroup::create(
                NumericField::create('ExecuteInterval', ''),
                DropdownField::create(
                    'ExecuteEvery',
                    '',
                    array(
                        '' => '',
                        'Minute' => _t('ScheduledExecution.ExecuteEveryMinute', 'Minute'),
                        'Hour' => _t('ScheduledExecution.ExecuteEveryHour', 'Hour'),
                        'Day' => _t('ScheduledExecution.ExecuteEveryDay', 'Day'),
                        'Week' => _t('ScheduledExecution.ExecuteEveryWeek', 'Week'),
                        'Fortnight' => _t('ScheduledExecution.ExecuteEveryFortnight', 'Fortnight'),
                        'Month' => _t('ScheduledExecution.ExecuteEveryMonth', 'Month'),
                        'Year' => _t('ScheduledExecution.ExecuteEveryYear', 'Year'),
                    )
                )
            )->setTitle(_t('ScheduledExecution.EXECUTE_EVERY', 'Execute every')),
            TextField::create(
                'ExecuteFree',
                _t('ScheduledExecution.EXECUTE_FREE', 'Scheduled (in strtotime format from first execution)')
            )
        ));

        if ($this->owner->ScheduledJobID) {
            $jobTime = $this->owner->ScheduledJob()->StartAfter;
            $fields->addFieldsToTab('Root.Schedule', array(
                ReadonlyField::create('NextRunDate', _t('ScheduledExecution.NEXT_RUN_DATE', 'Next run date'), $jobTime)
            ));
        }

        $dt->getDateField()->setConfig('showcalendar', true);
        $dt->getTimeField()->setConfig('showdropdown', true);
    }

    public function onBeforeWrite()
    {
        parent::onBeforeWrite();

        if ($this->owner->FirstExecution) {
            $changed = $this->owner->getChangedFields();
            $changed = (
                isset($changed['FirstExecution'])
                || isset($changed['ExecuteInterval'])
                || isset($changed['ExecuteEvery'])
                || isset($changed['ExecuteFree'])
            );

            if ($changed && $this->owner->ScheduledJobID) {
                if ($this->owner->ScheduledJob()->exists()) {
                    $this->owner->ScheduledJob()->delete();
                }

                $this->owner->ScheduledJobID = 0;
            }

            if (!$this->owner->ScheduledJobID) {
                $job = new ScheduledExecutionJob($this->owner);
                $time = date('Y-m-d H:i:s');
                if ($this->owner->FirstExecution) {
                    $time = date('Y-m-d H:i:s', strtotime($this->owner->FirstExecution));
                }

                $this->owner->ScheduledJobID = singleton('SilverStripe\\QueuedJobs\\Services\\QueuedJobService')
                    ->queueJob($job, $time);
            }
        }
    }

    /**
     * Define your own version of this method in your data objects to be executed EVERY time
     * the scheduled job triggers.
     */
    public function onScheduledExecution()
    {
    }
}