QueuePruner::run() - Code Metrics - glooby/task-bundle - Measure and Improve Code Quality continuously with Scrutinizer

QueuePruner::run() A
last analyzed 2019-10-18 08:22 UTC

↳ Parent: QueuePruner

Complexity

Conditions	1
Paths	1

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	15
rs	9.7666
c	0
b	0
f	0
cc	1
nc	1
nop	1

<?php

namespace Glooby\TaskBundle\Queue;

use Doctrine\Common\Persistence\ManagerRegistry;
use Doctrine\DBAL\Connection;
use Glooby\TaskBundle\Annotation\Schedule;
use Glooby\TaskBundle\Task\TaskInterface;

/**
 * This task is used to test that the whole scheduling chain works.
 *
 * @Schedule("@daily")
 *
 * @author Emil Kilhage
 */
class QueuePruner implements TaskInterface
{
    /**
     * @var ManagerRegistry
     */
    protected $doctrine;

    /**
     * @param ManagerRegistry $doctrine
     */
    public function setDoctrine($doctrine)
    {
        $this->doctrine = $doctrine;
    }

    /**
     * {@inheritdoc}
     */
    public function run(array $params = [])
    {
        /** @var Connection $connection */
        $connection = $this->doctrine->getConnection();

        $deleted = $connection->exec('DELETE FROM task_queue
            WHERE resolution = "success"
              AND created <= DATE_SUB(NOW(), INTERVAL 1 MONTH)');

        $deleted += $connection->exec('DELETE FROM task_queue
            WHERE resolution != "success"
              AND created <= DATE_SUB(NOW(), INTERVAL 3 MONTH)');

        return sprintf('%d deleted', $deleted);
    }

    /**
     *
     */
    public function all()
    {
        /** @var Connection $connection */
        $connection = $this->doctrine->getConnection();
        $deleted = $connection->exec('DELETE FROM task_queue');
        return sprintf('%d deleted', $deleted);
    }
}


1			<?php
2
3			namespace Glooby\TaskBundle\Queue;
4
5			use Doctrine\Common\Persistence\ManagerRegistry;
6			use Doctrine\DBAL\Connection;
7			use Glooby\TaskBundle\Annotation\Schedule;
8			use Glooby\TaskBundle\Task\TaskInterface;
9
10			/**
11			* This task is used to test that the whole scheduling chain works.
12			*
13			* @Schedule("@daily")
14			*
15			* @author Emil Kilhage
16			*/
17			class QueuePruner implements TaskInterface
18			{
19			/**
20			* @var ManagerRegistry
21			*/
22			protected $doctrine;
23
24			/**
25			* @param ManagerRegistry $doctrine
26			*/
27			public function setDoctrine($doctrine)
28			{
29			$this->doctrine = $doctrine;
30			}
31
32			/**
33			* {@inheritdoc}
34			*/
35			public function run(array $params = [])
36			{
37			/** @var Connection $connection */
38			$connection = $this->doctrine->getConnection();
39
40			$deleted = $connection->exec('DELETE FROM task_queue
41			WHERE resolution = "success"
42			AND created <= DATE_SUB(NOW(), INTERVAL 1 MONTH)');
43
44			$deleted += $connection->exec('DELETE FROM task_queue
45			WHERE resolution != "success"
46			AND created <= DATE_SUB(NOW(), INTERVAL 3 MONTH)');
47
48			return sprintf('%d deleted', $deleted);
49			}
50
51			/**
52			*
53			*/
54			public function all()
55			{
56			/** @var Connection $connection */
57			$connection = $this->doctrine->getConnection();
58			$deleted = $connection->exec('DELETE FROM task_queue');
59			return sprintf('%d deleted', $deleted);
60			}
61			}
62

glooby / task-bundle

QueuePruner::run() A last analyzed 2019-10-18 08:22 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

QueuePruner::run() A
last analyzed 2019-10-18 08:22 UTC