WorkflowReminderJob

Complexity

Total Complexity

13

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getTitle()	0	3	1
A	getSignature()	0	3	1
A	__construct()	0	7	3
C	process()	0	62	8

<?php

if (class_exists('AbstractQueuedJob')) {
/**
 * @author <marcus@silverstripe.com.au>
 * @license BSD License http://www.silverstripe.org/bsd-license
 */
class WorkflowReminderJob extends AbstractQueuedJob {

PSR1 recommends that each class must be in a namespace of at least one level to avoid collisions.

	const DEFAULT_REPEAT = 600;
	
	/**
	 *
	 * @var QueuedJobService
	 */
	public $queuedJobService;
	
	public function __construct($repeatInterval = 0) {
		if (!$this->repeatInterval) {
			$this->repeatInterval = $repeatInterval ? $repeatInterval : self::DEFAULT_REPEAT;
			$this->totalSteps = 2;
			$this->currentStep = 1;
		}
	}
	
	public function getTitle() {
		return _t('AdvancedWorkflow.WORKFLOW_REMINDER_JOB', 'Workflow Reminder Job');
	}
	
	/**
	 * We only want one instance of this job ever
	 * 
	 * @return string
	 */
	public function getSignature() {
		return md5($this->getTitle());
	}
	
	public function process() {
		$sent   = 0;
		$filter = array(
			'WorkflowStatus'						=> array('Active', 'Paused'),
			'Definition.RemindDays:GreaterThan'		=> 0
		);
		
		$active = WorkflowInstance::get()->filter($filter);
		
		foreach ($active as $instance) {
			$edited = strtotime($instance->LastEdited);
			$days   = $instance->Definition()->RemindDays;

			if ($edited + ($days * 3600 * 24) > time()) {
				continue;
			}

			$email   = new Email();
			$bcc     = '';

$bcc is not used, you could remove the assignment.

			$members = $instance->getAssignedMembers();
			$target  = $instance->getTarget();

			if (!$members || !count($members)) {
				continue;
			}

			$email->setSubject("Workflow Reminder: $instance->Title");
			$email->setBcc(implode(', ', $members->column('Email')));
			$email->setTemplate('WorkflowReminderEmail');
			$email->populateTemplate(array(
				'Instance' => $instance,
				'Link'     => $target instanceof SiteTree ? "admin/show/$target->ID" : ''
			));

			$email->send();
			$sent++;

			// add a comment to the workflow if possible
			$action = $instance->CurrentAction();
			
			$currentComment = $action->Comment;
			$action->Comment = sprintf(_t('AdvancedWorkflow.JOB_REMINDER_COMMENT', '%s: Reminder email sent\n\n'), date('Y-m-d H:i:s')) . $currentComment;
			try {
				$action->write();
			} catch (Exception $ex) {
				SS_Log::log($ex, SS_Log::WARN);
			}

			$instance->LastEdited = time();
			try {
				$instance->write();
			} catch (Exception $ex) {
				SS_Log::log($ex, SS_Log::WARN);
			}
		}

		$this->currentStep = 2;
		$this->isComplete = true;
		
		$nextDate = date('Y-m-d H:i:s', time() + $this->repeatInterval);
		$this->queuedJobService->queueJob(new WorkflowReminderJob($this->repeatInterval), $nextDate);
	}
}
}