Netlogix.JobQueue.Scheduled/Classes/Service/JobStatusService.php at 7e40f0459c14ba156b3003589a67d3e59affbcc9 · netlogix/Netlogix.JobQueue.Scheduled · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
<?php

namespace Netlogix\JobQueue\Scheduled\Service;

use Doctrine\DBAL\Types\Types;
use Neos\Flow\Annotations as Flow;
use Netlogix\JobQueue\Scheduled\Domain\Scheduler;
use Netlogix\JobQueue\Scheduled\Domain\Model\ScheduledJob;

#[Flow\Scope("singleton")]
abstract class JobStatusService {

    protected const string TOTAL_COUNT_QUERY = "";
    protected const string RUNNING_COUNT_QUERY = "";
    protected const string PENDING_COUNT_QUERY = "";
    protected const string STALE_COUNT_QUERY = "";
    protected const string FAILED_COUNT_QUERY = "";

    #[Flow\Inject]
    protected Scheduler $scheduler;

    public function getTotalJobCount(string $groupName): int {
        return $this->fetchOne(
            static::TOTAL_COUNT_QUERY,
            [
                'groupName' => $groupName
            ],
            [
                'groupName' => Types::STRING
            ]
        );
    }

    public function getRunningJobCount(string $groupName): int {
        return $this->fetchOne(
            static::RUNNING_COUNT_QUERY,
            [
                'groupName' => $groupName,
                'seconds' => $this->scheduler->getStaleJobTimeoutSeconds()
            ],
            [
                'groupName' => Types::STRING,
                'seconds' => Types::INTEGER
            ]
        );
    }

    public function getPendingJobCount(string $groupName): int {
        return $this->fetchOne(
            static::PENDING_COUNT_QUERY,
            [
                'groupName' => $groupName
            ],
            [
                'groupName' => Types::STRING
            ]
        );
    }

    public function getStaleJobCount(string $groupName): int {
        return $this->fetchOne(
            static::STALE_COUNT_QUERY,
            [
                "groupName" => $groupName,
                "seconds" => $this->scheduler->getStaleJobTimeoutSeconds()
            ],
            [
                "groupName" => Types::STRING,
                "seconds" => Types::INTEGER
            ]
        );
    }

    public function getFailedJobCount(string $groupName): int {
        return $this->fetchOne(
            static::FAILED_COUNT_QUERY,
            [
                'groupName' => $groupName
            ],
            [
                'groupName' => Types::STRING
            ]
        );
    }

    protected function fetchOne(string $query, array $params = [], array $types = []) {
        return $this->scheduler->getConnection()->fetchOne($query, $params, $types);
    }

}