<?php // +---------------------------------------------------------------------- // | ThinkPHP [ WE CAN DO IT JUST THINK IT ] // +---------------------------------------------------------------------- // | Copyright (c) 2006-2015 http://thinkphp.cn All rights reserved. // +---------------------------------------------------------------------- // | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 ) // +---------------------------------------------------------------------- // | Author: yunwuxin <448901948@qq.com> // +---------------------------------------------------------------------- namespace think\queue; use DateTime; use think\Config; abstract class Job { /** * The job handler instance. * @var mixed */ protected $instance; /** * The name of the queue the job belongs to. * @var string */ protected $queue; /** * Indicates if the job has been deleted. * @var bool */ protected $deleted = false; /** * Indicates if the job has been released. * @var bool */ protected $released = false; /** * Fire the job. * @return void */ abstract public function fire(); /** * Delete the job from the queue. * @return void */ public function delete() { $this->deleted = true; } /** * Determine if the job has been deleted. * @return bool */ public function isDeleted() { return $this->deleted; } /** * Release the job back into the queue. * @param int $delay * @return void */ public function release($delay = 0) { $this->released = true; } /** * Determine if the job was released back into the queue. * @return bool */ public function isReleased() { return $this->released; } /** * Determine if the job has been deleted or released. * @return bool */ public function isDeletedOrReleased() { return $this->isDeleted() || $this->isReleased(); } /** * Get the number of times the job has been attempted. * @return int */ abstract public function attempts(); /** * Get the raw body string for the job. * @return string */ abstract public function getRawBody(); /** * Resolve and fire the job handler method. * @param array $payload * @return void */ protected function resolveAndFire(array $payload) { list($class, $method) = $this->parseJob($payload['job']); $this->instance = $this->resolve($class); if ($this->instance) { $this->instance->{$method}($this, $payload['data']); } } /** * Parse the job declaration into class and method. * @param string $job * @return array */ protected function parseJob($job) { $segments = explode('@', $job); return count($segments) > 1 ? $segments : [$segments[0], 'fire']; } /** * Resolve the given job handler. * @param string $name * @return mixed */ protected function resolve($name) { if (strpos($name, '\\') === false) { if (strpos($name, '/') === false) { $module = ''; } else { list($module, $name) = explode('/', $name, 2); } $name = Config::get('app_namespace') . ($module ? '\\' . strtolower($module) : '') . '\\job\\' . $name; } if (class_exists($name)) { return new $name(); } } /** * Call the failed method on the job instance. * @return void */ public function failed() { $payload = json_decode($this->getRawBody(), true); list($class, $method) = $this->parseJob($payload['job']); $this->instance = $this->resolve($class); if ($this->instance && method_exists($this->instance, 'failed')) { $this->instance->failed($payload['data']); } } /** * Calculate the number of seconds with the given delay. * @param \DateTime|int $delay * @return int */ protected function getSeconds($delay) { if ($delay instanceof DateTime) { return max(0, $delay->getTimestamp() - $this->getTime()); } return (int) $delay; } /** * Get the current system time. * @return int */ protected function getTime() { return time(); } /** * Get the name of the queued job class. * @return string */ public function getName() { return json_decode($this->getRawBody(), true)['job']; } /** * Get the name of the queue the job belongs to. * @return string */ public function getQueue() { return $this->queue; } }