RedisQueue::getWorkInfo() - Code Metrics - Inspection of "style(格式修改):" - Graychen/yii2-queue-backend - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#9)

by graychen

created 2017-11-10 09:07 UTC

RedisQueue::getWorkInfo() B

↳ Parent: RedisQueue

Complexity

Conditions	5
Paths	5

Size

Total Lines	17
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	14.6179

Importance

Changes

Metric	Value
dl	0
loc	17
ccs	3
cts	11
cp	0.2727
rs	8.8571
c	0
b	0
f	0
cc	5
eloc	11
nc	5
nop	0
crap	14.6179

<?php

namespace graychen\yii2\queue\backend\models;

use Yii;
use yii\base\Model;
use yii\di\Instance;
use yii\queue\serializers\PhpSerializer;
use yii\queue\serializers\Serializer;

/**
 * Class RedisQueue
 * @package graychen\yii2\queue\backend\models
 * @property integer $total
 * @property integer $done
 * @property integer $waiting
 * @property integer $delayed
 * @property integer $reserved
 */
class RedisQueue extends Model
{
    /**
     * @see Queue::isWaiting()
     */
    const STATUS_WAITING = 1;
    /**
     * @see Queue::isReserved()
     */
    const STATUS_RESERVED = 2;
    /**
     * @see Queue::isDone()
     */
    const STATUS_DONE = 3;
    /**
     * @var Serializer|array
     */
    public $serializer = PhpSerializer::class;

    public $prefix;

    public function __construct(array $config = [])
    {
        $this->getPrefix();
        $this->serializer = Instance::ensure($this->serializer, Serializer::class);
        parent::__construct($config);
    }

    public function setPrefix()
    {
        $this->prefix = Yii::$app->queue->channel;
    }


    public function getPrefix()
    {
        $this->setPrefix();
        return $this->prefix;
    }

    public function setWaiting()
    {
        $this->waiting = Yii::$app->queue->redis->llen("$this->prefix.waiting");
    }

    public function getWaiting()
    {
        $this->setWaiting();
        return $this->waiting;
    }

    public function setDelayed()
    {
        $this->delayed = Yii::$app->queue->redis->zcount("$this->prefix.delayed", '-inf', '+inf');
    }

    public function getDelayed()
    {
        $this->setDelayed();
        return $this->delayed;
    }

    public function setReserved()
    {
        $this->reserved = Yii::$app->queue->redis->zcount("$this->prefix.reserved", '-inf', '+inf');
    }

    public function getReserved()
    {
        $this->setReserved();
        return $this->reserved;
    }

    public function setTotal()
    {
        $this->total = Yii::$app->queue->redis->get("$this->prefix.message_id");
    }

    public function getTotal()
    {
        $this->setTotal();
        return $this->total;
    }

    public function setDone()
    {
        $this->done = $this->total - $this->waiting - $this->delayed - $this->reserved;
    }

    public function getDone()
    {
        $this->setDone();
        return $this->done;
    }

    public function getWorkInfo()
    {
        $workers = [];
        $data = Yii::$app->queue->redis->clientList();
        foreach (explode("\n", trim($data)) as $line) {
            $client = [];
            foreach (explode(' ', trim($line)) as $pair) {
                list($key, $value) = explode('=', $pair, 2);
                $client[$key] = $value;
            }

            if (isset($client['name']) && strpos($client['name'], Yii::$app->queue->channel . '.worker') === 0) {
                $workers[$client['name']] = $client;
            }
        }
        return $workers;
    }

    public function getWaitContent()
    {
        $waitContent = Yii::$app->queue->redis->lrange("$this->prefix.waiting", 0, 10);
        return $waitContent;
    }

    public function getReservedContent()
    {
        return Yii::$app->queue->redis->zrange("$this->prefix.reserved", 0, -1);
    }

    public function getDelayedContent()
    {
        return Yii::$app->queue->redis->zrange("$this->prefix.delayed", 0, -1);
    }

    public function getMessage($id)
    {
        $message = Yii::$app->queue->redis->hget("$this->prefix.messages", $id);
        $strMessage = ltrim($message, '300;');
        return $this->serializer->unserialize($strMessage);
    }

    public function getAttempt($id)
    {
        $attempt = Yii::$app->queue->redis->hget("$this->prefix.attempt", $id);
        $strAttempt = ltrim($attempt, '300;');
        return $this->serializer->unserialize($strAttempt);
    }


    /** 得到执行时间
     * @param $id todo
     */
    public function getExecutionTime($id)

    {
    }

    /** 得到队列的状态
     * @param $id
     * @return int
     */
    public function status($id)
    {
        if (Yii::$app->queue->redis->hexists("$this->prefix.attempts", $id)) {
            return self::STATUS_RESERVED;
        } elseif (Yii::$app->queue->redis->hexists("$this->prefix.messages", $id)) {
            return self::STATUS_WAITING;
        } else {
            return self::STATUS_DONE;
        }
    }
}


1		<?php
2
3		namespace graychen\yii2\queue\backend\models;
4
5		use Yii;
6		use yii\base\Model;
7		use yii\di\Instance;
8		use yii\queue\serializers\PhpSerializer;
9		use yii\queue\serializers\Serializer;
10
11		/**
12		* Class RedisQueue
13		* @package graychen\yii2\queue\backend\models
14		* @property integer $total
15		* @property integer $done
16		* @property integer $waiting
17		* @property integer $delayed
18		* @property integer $reserved
19		*/
20		class RedisQueue extends Model
21		{
22		/**
23		* @see Queue::isWaiting()
24		*/
25		const STATUS_WAITING = 1;
26		/**
27		* @see Queue::isReserved()
28		*/
29		const STATUS_RESERVED = 2;
30		/**
31		* @see Queue::isDone()
32		*/
33		const STATUS_DONE = 3;
34		/**
35		* @var Serializer\|array
36		*/
37		public $serializer = PhpSerializer::class;
38
39		public $prefix;
40
41	5	public function __construct(array $config = [])
42		{
43	5	$this->getPrefix();
44	5	$this->serializer = Instance::ensure($this->serializer, Serializer::class);
45	5	parent::__construct($config);
46	5	}
47
48	5	public function setPrefix()
49		{
50	5	$this->prefix = Yii::$app->queue->channel;
51	5	}
52
53
54	5	public function getPrefix()
55		{
56	5	$this->setPrefix();
57	5	return $this->prefix;
58		}
59
60		public function setWaiting()
61		{
62		$this->waiting = Yii::$app->queue->redis->llen("$this->prefix.waiting");
63		}
64
65		public function getWaiting()
66		{
67		$this->setWaiting();
68		return $this->waiting;
69		}
70
71		public function setDelayed()
72		{
73		$this->delayed = Yii::$app->queue->redis->zcount("$this->prefix.delayed", '-inf', '+inf');
74		}
75
76		public function getDelayed()
77		{
78		$this->setDelayed();
79		return $this->delayed;
80		}
81
82		public function setReserved()
83		{
84		$this->reserved = Yii::$app->queue->redis->zcount("$this->prefix.reserved", '-inf', '+inf');
85		}
86
87		public function getReserved()
88		{
89		$this->setReserved();
90		return $this->reserved;
91		}
92
93	1	public function setTotal()
94		{
95	1	$this->total = Yii::$app->queue->redis->get("$this->prefix.message_id");
96		}
97
98	1	public function getTotal()
99		{
100	1	$this->setTotal();
101		return $this->total;
102		}
103
104	1	public function setDone()
105		{
106	1	$this->done = $this->total - $this->waiting - $this->delayed - $this->reserved;
107		}
108
109	1	public function getDone()
110		{
111	1	$this->setDone();
112		return $this->done;
113		}
114
115	1	public function getWorkInfo()
116		{
117	1	$workers = [];
118	1	$data = Yii::$app->queue->redis->clientList();
119		foreach (explode("\n", trim($data)) as $line) {
120		$client = [];
121		foreach (explode(' ', trim($line)) as $pair) {
122		list($key, $value) = explode('=', $pair, 2);
123		$client[$key] = $value;
124		}
125
126		if (isset($client['name']) && strpos($client['name'], Yii::$app->queue->channel . '.worker') === 0) {
127		$workers[$client['name']] = $client;
128		}
129		}
130		return $workers;
131		}
132
133		public function getWaitContent()
134		{
135		$waitContent = Yii::$app->queue->redis->lrange("$this->prefix.waiting", 0, 10);
136		return $waitContent;
137		}
138
139		public function getReservedContent()
140		{
141		return Yii::$app->queue->redis->zrange("$this->prefix.reserved", 0, -1);
142		}
143
144		public function getDelayedContent()
145		{
146		return Yii::$app->queue->redis->zrange("$this->prefix.delayed", 0, -1);
147		}
148
149	1	public function getMessage($id)
150		{
151	1	$message = Yii::$app->queue->redis->hget("$this->prefix.messages", $id);
152		$strMessage = ltrim($message, '300;');
153		return $this->serializer->unserialize($strMessage);
154		}
155
156		public function getAttempt($id)
157		{
158		$attempt = Yii::$app->queue->redis->hget("$this->prefix.attempt", $id);
159		$strAttempt = ltrim($attempt, '300;');
160		return $this->serializer->unserialize($strAttempt);
161		}
162
163
164		/** 得到执行时间
165		* @param $id todo
166		*/
167		public function getExecutionTime($id)
		0 ignored issues – show Unused Code introduced 2017-11-10 05:20 UTC by Report Bug Copy Issue Report The parameter `$id` is not used and could be removed. This check looks from parameters that have been defined for a function or method, but which are not used in the method body. Loading history...
168		{
169		}
170
171		/** 得到队列的状态
172		* @param $id
173		* @return int
174		*/
175	1	public function status($id)
176		{
177	1	if (Yii::$app->queue->redis->hexists("$this->prefix.attempts", $id)) {
178		return self::STATUS_RESERVED;
179		} elseif (Yii::$app->queue->redis->hexists("$this->prefix.messages", $id)) {
180		return self::STATUS_WAITING;
181		} else {
182		return self::STATUS_DONE;
183		}
184		}
185		}
186

Graychen / yii2-queue-backend

Pull Request — master (#9)

RedisQueue::getWorkInfo() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like