Dtc\QueueBundle\Model\Job

Complexity

Total Complexity

58

Size/Duplication

Total Lines	473
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

51 Methods

Rating	Name	Duplication	Size	Complexity
A	getMessage()	0	4	1
A	setMessage()	0	4	1
A	getStatus()	0	4	1
A	getLocked()	0	4	1
A	getLockedAt()	0	4	1
A	getExpire()	0	4	1
A	setStatus()	0	4	1
A	setLocked()	0	4	1
A	setLockedAt()	0	4	1
A	setExpire()	0	4	1
A	getId()	0	4	1
A	getWorkerName()	0	4	1
A	getClassName()	0	4	1
A	getMethod()	0	4	1
A	getArgs()	0	4	1
A	getBatch()	0	4	1
A	getPriority()	0	4	1
A	getCrcHash()	0	4	1
A	getWhen()	0	4	1
A	getCreatedAt()	0	4	1
A	getUpdatedAt()	0	4	1
A	getJobManager()	0	4	1
A	setId()	0	4	1
A	setWorkerName()	0	4	1
A	setClassName()	0	4	1
A	setMethod()	0	4	1
A	getStartedAt()	0	4	1
A	setStartedAt()	0	4	1
A	getFinishedAt()	0	4	1
A	setFinishedAt()	0	4	1
A	getMaxDuration()	0	4	1
A	setMaxDuration()	0	4	1
A	setArgs()	0	8	2
A	recursiveValidArgs()	0	14	4
A	setBatch()	0	4	1
A	setPriority()	0	4	1
A	setCrcHash()	0	4	1
A	setWhen()	0	4	1
A	setCreatedAt()	0	4	1
A	setUpdatedAt()	0	4	1
A	setJobManager()	0	4	1
A	__construct()	0	14	3
A	__call()	0	16	2
A	getDelay()	0	4	1
A	getWorker()	0	4	1
A	setDelay()	0	4	1
A	setWorker()	0	4	1
A	getElapsed()	0	4	1
A	setElapsed()	0	4	1
A	toMessage()	0	10	1
A	fromMessage()	0	7	1

<?php

namespace Dtc\QueueBundle\Model;

class Job
{
    const STATUS_SUCCESS = 'success';
    const STATUS_ERROR = 'error';
    const STATUS_NEW = 'new';

    protected $id;
    protected $workerName;
    protected $className;
    protected $method;
    protected $args;
    protected $batch;
    protected $status;
    protected $message;
    protected $priority;
    protected $crcHash;
    protected $locked;
    protected $lockedAt;
    protected $when;
    protected $expire;
    protected $createdAt;
    protected $updatedAt;
    protected $delay;
    protected $startedAt;
    protected $finishedAt;
    protected $maxDuration;
    protected $elapsed;

    /**
     * @var JobManagerInterface
     */
    protected $jobManager;

    /**
     * @return
     */
    public function getMessage()
    {
        return $this->message;
    }

    /**
     * @param $message
     */
    public function setMessage($message)
    {
        $this->message = $message;
    }

    /**
     * @return $status

The doc-type $status could not be parsed: Unknown type name "$status" at position 0. (view supported doc-types)

     */
    public function getStatus()
    {
        return $this->status;
    }

    /**
     * @return $locked

The doc-type $locked could not be parsed: Unknown type name "$locked" at position 0. (view supported doc-types)

     */
    public function getLocked()
    {
        return $this->locked;
    }

    /**
     * @return $lockedAt

The doc-type $lockedAt could not be parsed: Unknown type name "$lockedAt" at position 0. (view supported doc-types)

     */
    public function getLockedAt()
    {
        return $this->lockedAt;
    }

    /**
     * @return $expire

The doc-type $expire could not be parsed: Unknown type name "$expire" at position 0. (view supported doc-types)

     */
    public function getExpire()
    {
        return $this->expire;
    }

    /**
     * @param $status
     */
    public function setStatus($status)
    {
        $this->status = $status;
    }

    /**
     * @param $locked
     */
    public function setLocked($locked)
    {
        $this->locked = $locked;
    }

    /**
     * @param $lockedAt
     */
    public function setLockedAt($lockedAt)
    {
        $this->lockedAt = $lockedAt;
    }

    /**
     * @param $expire
     */
    public function setExpire($expire)
    {
        $this->expire = $expire;
    }

    /**
     * @return $id

The doc-type $id could not be parsed: Unknown type name "$id" at position 0. (view supported doc-types)

     */
    public function getId()
    {
        return $this->id;
    }

    /**
     * @return $workerName

The doc-type $workerName could not be parsed: Unknown type name "$workerName" at position 0. (view supported doc-types)

     */
    public function getWorkerName()
    {
        return $this->workerName;
    }

    /**
     * @return $className

The doc-type $className could not be parsed: Unknown type name "$className" at position 0. (view supported doc-types)

     */
    public function getClassName()
    {
        return $this->className;
    }

    /**
     * @return $method

The doc-type $method could not be parsed: Unknown type name "$method" at position 0. (view supported doc-types)

     */
    public function getMethod()
    {
        return $this->method;
    }

    /**
     * @return array
     */
    public function getArgs()
    {
        return $this->args;
    }

    /**
     * @return $batch

The doc-type $batch could not be parsed: Unknown type name "$batch" at position 0. (view supported doc-types)

     */
    public function getBatch()
    {
        return $this->batch;
    }

    /**
     * @return $priority

The doc-type $priority could not be parsed: Unknown type name "$priority" at position 0. (view supported doc-types)

     */
    public function getPriority()
    {
        return $this->priority;
    }

    /**
     * @return $crcHash

The doc-type $crcHash could not be parsed: Unknown type name "$crcHash" at position 0. (view supported doc-types)

     */
    public function getCrcHash()
    {
        return $this->crcHash;
    }

    /**
     * @return $when

The doc-type $when could not be parsed: Unknown type name "$when" at position 0. (view supported doc-types)

     */
    public function getWhen()
    {
        return $this->when;
    }

    /**
     * @return $createdAt

The doc-type $createdAt could not be parsed: Unknown type name "$createdAt" at position 0. (view supported doc-types)

     */
    public function getCreatedAt()
    {
        return $this->createdAt;
    }

    /**
     * @return $updatedAt

The doc-type $updatedAt could not be parsed: Unknown type name "$updatedAt" at position 0. (view supported doc-types)

     */
    public function getUpdatedAt()
    {
        return $this->updatedAt;
    }

    /**
     * @return $jobManager

The doc-type $jobManager could not be parsed: Unknown type name "$jobManager" at position 0. (view supported doc-types)

     */
    public function getJobManager()
    {
        return $this->jobManager;
    }

    /**
     * @param $id
     */
    public function setId($id)
    {
        $this->id = $id;
    }

    /**
     * @param $workerName
     */
    public function setWorkerName($workerName)
    {
        $this->workerName = $workerName;
    }

    /**
     * @param string $className
     */
    public function setClassName($className)
    {
        $this->className = $className;
    }

    /**
     * @param $method
     */
    public function setMethod($method)
    {
        $this->method = $method;
    }

    /**
     * @return mixed
     */
    public function getStartedAt()
    {
        return $this->startedAt;
    }

    /**
     * @param mixed $startedAt
     */
    public function setStartedAt(\DateTime $startedAt)
    {
        $this->startedAt = $startedAt;
    }

    /**
     * @return mixed
     */
    public function getFinishedAt()
    {
        return $this->finishedAt;
    }

    /**
     * @param mixed $finishedAt
     */
    public function setFinishedAt($finishedAt)
    {
        $this->finishedAt = $finishedAt;
    }

    /**
     * @return mixed
     */
    public function getMaxDuration()
    {
        return $this->maxDuration;
    }

    /**
     * @param mixed $maxDuration
     */
    public function setMaxDuration($maxDuration)
    {
        $this->maxDuration = $maxDuration;
    }

    /**
     * @param $args
     */
    public function setArgs($args)
    {
        if (!$this->recursiveValidArgs($args)) {
            throw new \Exception('Args must not contain object');
        }

        $this->args = $args;
    }

    protected function recursiveValidArgs($args)
    {
        if (is_array($args)) {
            foreach ($args as $key => $value) {
                if (!$this->recursiveValidArgs($value)) {
                    return false;
                }
            }

            return true;
        } else {
            return !is_object($args);
        }
    }

    /**
     * @param $batch
     */
    public function setBatch($batch)
    {
        $this->batch = $batch;
    }

    /**
     * @param $priority
     */
    public function setPriority($priority)
    {
        $this->priority = $priority;
    }

    /**
     * @param $crcHash
     */
    public function setCrcHash($crcHash)
    {
        $this->crcHash = $crcHash;
    }

    /**
     * @param $when
     */
    public function setWhen($when)
    {
        $this->when = $when;
    }

    /**
     * @param $createdAt
     */
    public function setCreatedAt($createdAt)
    {
        $this->createdAt = $createdAt;
    }

    /**
     * @param $updatedAt
     */
    public function setUpdatedAt($updatedAt)
    {
        $this->updatedAt = $updatedAt;
    }

    /**
     * @param $jobManager
     */
    public function setJobManager($jobManager)
    {
        $this->jobManager = $jobManager;
    }

    protected $worker;

    public function __construct(Worker $worker = null, $batch = false, $priority = 10, \DateTime $when = null)
    {
        $this->worker = $worker;
        if ($worker) {
            $this->jobManager = $worker->getJobManager();
            $this->className = get_class($worker);
            $this->workerName = $worker->getName();
        }

        $this->when = $when;
        $this->batch = $batch ? true : false;
        $this->priority = $priority;
        $this->status = self::STATUS_NEW;
    }

    public function __call($method, $args)
    {
        $this->method = $method;
        $this->setArgs($args);
        $this->createdAt = new \DateTime();
        $this->updatedAt = new \DateTime();

        // Make sure the method exists - job should not be created
        if (!method_exists($this->worker, $method)) {
            throw new \Exception("{$this->className}->{$method}() does not exist");
        }

        $this->jobManager->save($this);

        return $this;
    }

    /**
     * @return $delay

The doc-type $delay could not be parsed: Unknown type name "$delay" at position 0. (view supported doc-types)

     */
    public function getDelay()
    {
        return $this->delay;
    }

    /**
     * @return $worker

The doc-type $worker could not be parsed: Unknown type name "$worker" at position 0. (view supported doc-types)

     */
    public function getWorker()
    {
        return $this->worker;
    }

    /**
     * @param $delay
     */
    public function setDelay($delay)
    {
        $this->delay = $delay;
    }

    /**
     * @param Worker $worker
     */
    public function setWorker($worker)
    {
        $this->worker = $worker;
    }

    /**
     * @return $elapsed

The doc-type $elapsed could not be parsed: Unknown type name "$elapsed" at position 0. (view supported doc-types)

     */
    public function getElapsed()
    {
        return $this->elapsed;
    }

    /**
     * @param $elapsed
     */
    public function setElapsed($elapsed)
    {
        $this->elapsed = $elapsed;
    }

    public function toMessage()
    {
        $arr = array(
            'worker' => $this->getWorkerName(),
            'args' => $this->getArgs(),
            'method' => $this->getMethod(),
        );

        return json_encode($arr);
    }

    public function fromMessage($message)
    {
        $arr = json_decode($message, true);
        $this->setWorkerName($arr['worker']);
        $this->setArgs($arr['args']);
        $this->setMethod($arr['method']);
    }
}