Jabe\Engine\Impl\HistoricJobLogQueryImpl

Complexity

Total Complexity

59

Size/Duplication

Total Lines	375
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

58 Methods

Rating	Name	Duplication	Size	Complexity
A	jobId()	0	5	1
A	getJobDefinitionId()	0	3	1
A	orderByProcessDefinitionKey()	0	4	1
A	orderByJobDueDate()	0	4	1
A	getJobExceptionMessage()	0	3	1
A	jobExceptionMessage()	0	5	1
A	orderByProcessDefinitionId()	0	4	1
A	getDeploymentId()	0	3	1
A	orderByProcessInstanceId()	0	4	1
A	executeList()	0	6	1
A	logId()	0	5	1
A	successLog()	0	4	1
A	orderByHostname()	0	3	1
A	jobDefinitionType()	0	5	1
A	getHostname()	0	3	1
A	processDefinitionKey()	0	5	1
A	getJobId()	0	3	1
A	orderByJobId()	0	4	1
A	orderPartiallyByOccurrence()	0	4	1
A	orderByJobRetries()	0	4	1
A	deploymentId()	0	5	1
A	hostname()	0	5	1
A	getProcessDefinitionId()	0	3	1
A	orderByJobPriority()	0	4	1
A	jobDefinitionId()	0	5	1
A	getTenantIds()	0	3	1
A	deletionLog()	0	4	1
A	jobPriorityLowerThanOrEquals()	0	4	1
A	orderByTimestamp()	0	4	1
A	jobDefinitionConfiguration()	0	5	1
A	tenantIdIn()	0	6	1
A	getState()	0	3	1
A	processInstanceId()	0	5	1
A	executeCount()	0	6	1
A	__construct()	0	3	1
A	getProcessInstanceId()	0	3	1
A	executionIdIn()	0	7	1
A	hasExcludingConditions()	0	4	2
A	getActivityIds()	0	3	1
A	jobPriorityHigherThanOrEquals()	0	4	1
A	orderByTenantId()	0	3	1
A	creationLog()	0	4	1
A	isTenantIdSet()	0	3	1
A	orderByExecutionId()	0	4	1
A	setState()	0	3	1
A	orderByDeploymentId()	0	4	1
A	processDefinitionId()	0	5	1
A	activityIdIn()	0	7	1
A	orderByJobDefinitionId()	0	4	1
A	failureLog()	0	4	1
A	getExecutionIds()	0	3	1
A	getFailedActivityIds()	0	3	1
A	withoutTenantId()	0	5	1
A	getJobDefinitionConfiguration()	0	3	1
A	getProcessDefinitionKey()	0	3	1
A	getJobDefinitionType()	0	3	1
A	orderByActivityId()	0	4	1
A	failedActivityIdIn()	0	7	1

<?php

namespace Jabe\Engine\Impl;

use Jabe\Engine\Exception\NotValidException;
use Jabe\Engine\History\{
    HistoricJobLog,
    HistoricJobLogQueryInterface,
    JobStateImpl,
    JobStateInterface
};
use Jabe\Engine\Impl\Interceptor\{
    CommandContext,
    CommandExecutorInterface
};
use Jabe\Engine\Impl\Util\{
    CollectionUtil,
    CompareUtil,

The type Jabe\Engine\Impl\Util\CompareUtil was not found. Maybe you did not declare it correctly or list all dependencies?

    EnsureUtil

The type Jabe\Engine\Impl\Util\EnsureUtil was not found. Maybe you did not declare it correctly or list all dependencies?

};

class HistoricJobLogQueryImpl extends AbstractQuery implements HistoricJobLogQueryInterface
{
    protected $id;
    protected $jobId;
    protected $jobExceptionMessage;
    protected $jobDefinitionId;
    protected $jobDefinitionType;
    protected $jobDefinitionConfiguration;
    protected $activityIds = [];
    protected $failedActivityIds = [];
    protected $executionIds = [];
    protected $processInstanceId;
    protected $processDefinitionId;
    protected $processDefinitionKey;
    protected $deploymentId;
    protected $state;
    protected $jobPriorityHigherThanOrEqual;
    protected $jobPriorityLowerThanOrEqual;
    protected $tenantIds = [];
    protected $isTenantIdSet;
    protected $hostname;

    public function __construct(CommandExecutorInterface $commandExecutor)
    {
        parent::__construct($commandExecutor);
    }

    public function logId(string $historicJobLogId): HistoricJobLogQueryInterface
    {
        EnsureUtil::ensureNotNull(NotValidException::class, "historicJobLogId", $historicJobLogId);
        $this->id = $historicJobLogId;
        return $this;
    }

    public function jobId(string $jobId): HistoricJobLogQueryInterface
    {
        EnsureUtil::ensureNotNull(NotValidException::class, "jobId", $jobId);
        $this->jobId = $jobId;
        return $this;
    }

    public function jobExceptionMessage(string $jobExceptionMessage): HistoricJobLogQueryInterface
    {
        EnsureUtil::ensureNotNull(NotValidException::class, "jobExceptionMessage", $jobExceptionMessage);
        $this->jobExceptionMessage = $jobExceptionMessage;
        return $this;
    }

    public function jobDefinitionId(string $jobDefinitionId): HistoricJobLogQueryInterface
    {
        EnsureUtil::ensureNotNull(NotValidException::class, "jobDefinitionId", $jobDefinitionId);
        $this->jobDefinitionId = $jobDefinitionId;
        return $this;
    }

    public function jobDefinitionType(string $jobDefinitionType): HistoricJobLogQueryInterface
    {
        EnsureUtil::ensureNotNull(NotValidException::class, "jobDefinitionType", $jobDefinitionType);
        $this->jobDefinitionType = $jobDefinitionType;
        return $this;
    }

    public function jobDefinitionConfiguration(string $jobDefinitionConfiguration): HistoricJobLogQueryInterface
    {
        EnsureUtil::ensureNotNull(NotValidException::class, "jobDefinitionConfiguration", $jobDefinitionConfiguration);
        $this->jobDefinitionConfiguration = $jobDefinitionConfiguration;
        return $this;
    }

    public function activityIdIn(array $activityIds): HistoricJobLogQueryInterface
    {
        $activityIdList = CollectionUtil::asArrayList($activityIds);
        EnsureUtil::ensureNotContainsNull("activityIds", $activityIdList);
        EnsureUtil::ensureNotContainsEmptyString("activityIds", $activityIdList);
        $this->activityIds = $activityIds;
        return $this;
    }

    public function failedActivityIdIn(array $activityIds): HistoricJobLogQueryInterface
    {
        $activityIdList = CollectionUtil::asArrayList($activityIds);
        EnsureUtil::ensureNotContainsNull("activityIds", $activityIdList);
        EnsureUtil::ensureNotContainsEmptyString("activityIds", $activityIdList);
        $this->failedActivityIds = $activityIds;
        return $this;
    }

    public function executionIdIn(array $executionIds): HistoricJobLogQueryInterface
    {
        $executionIdList = CollectionUtil::asArrayList($executionIds);
        EnsureUtil::ensureNotContainsNull("executionIds", $executionIdList);
        EnsureUtil::ensureNotContainsEmptyString("executionIds", $executionIdList);
        $this->executionIds = $executionIds;
        return $this;
    }

    public function processInstanceId(string $processInstanceId): HistoricJobLogQueryInterface
    {
        EnsureUtil::ensureNotNull(NotValidException::class, "processInstanceId", $processInstanceId);
        $this->processInstanceId = $processInstanceId;
        return $this;
    }

    public function processDefinitionId(string $processDefinitionId): HistoricJobLogQueryInterface
    {
        EnsureUtil::ensureNotNull(NotValidException::class, "processDefinitionId", $processDefinitionId);
        $this->processDefinitionId = $processDefinitionId;
        return $this;
    }

    public function processDefinitionKey(string $processDefinitionKey): HistoricJobLogQueryInterface
    {
        EnsureUtil::ensureNotNull(NotValidException::class, "processDefinitionKey", $processDefinitionKey);
        $this->processDefinitionKey = $processDefinitionKey;
        return $this;
    }

    public function deploymentId(string $deploymentId): HistoricJobLogQueryInterface
    {
        EnsureUtil::ensureNotNull(NotValidException::class, "deploymentId", $deploymentId);
        $this->deploymentId = $deploymentId;
        return $this;
    }

    public function jobPriorityHigherThanOrEquals(int $priority): HistoricJobLogQueryInterface
    {
        $this->jobPriorityHigherThanOrEqual = $priority;
        return $this;
    }

    public function jobPriorityLowerThanOrEquals(int $priority): HistoricJobLogQueryInterface
    {
        $this->jobPriorityLowerThanOrEqual = $priority;
        return $this;
    }

    public function tenantIdIn(array $tenantIds): HistoricJobLogQueryInterface
    {
        EnsureUtil::ensureNotNull("tenantIds", "tenantIds", $tenantIds);
        $this->tenantIds = $tenantIds;
        $this->isTenantIdSet = true;
        return $this;
    }

    public function withoutTenantId(): HistoricJobLogQueryInterface
    {
        $this->tenantIds = null;
        $this->isTenantIdSet = true;
        return $this;
    }

    public function hostname(string $hostname): HistoricJobLogQueryInterface
    {
        EnsureUtil::ensureNotEmpty("hostName", "hostname", $hostname);
        $this->hostname = $hostname;
        return $this;
    }

    public function creationLog(): HistoricJobLogQueryInterface
    {
        $this->setState(JobStateImpl::created());
        return $this;
    }

    public function failureLog(): HistoricJobLogQueryInterface
    {
        $this->setState(JobStateImpl::failed());
        return $this;
    }

    public function successLog(): HistoricJobLogQueryInterface
    {
        $this->setState(JobStateImpl::successful());
        return $this;
    }

    public function deletionLog(): HistoricJobLogQueryInterface
    {
        $this->setState(JobStateImpl::deleted());
        return $this;
    }

    protected function hasExcludingConditions(): bool
    {
        return parent::hasExcludingConditions()
        || CompareUtil::areNotInAscendingOrder($this->jobPriorityHigherThanOrEqual, $this->jobPriorityLowerThanOrEqual);
    }

    public function orderByTimestamp(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryProperty::timestamp());

The method timestamp() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

        return $this;
    }

    public function orderByJobId(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryProperty::jobId());

The method jobId() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

        return $this;
    }

    public function orderByJobDueDate(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryPropert::duedate());
        return $this;
    }

    public function orderByJobRetries(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryProperty::retries());

The method retries() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

        return $this;
    }

    public function orderByJobPriority(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryProperty::priority());

The method priority() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

        return $this;
    }

    public function orderByJobDefinitionId(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryProperty::jobDefinitionId());

The method jobDefinitionId() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

        return $this;
    }

    public function orderByActivityId(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryProperty::activityId());

The method activityId() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

        return $this;
    }

    public function orderByExecutionId(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryProperty::executionId());

The method executionId() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

        return $this;
    }

    public function orderByProcessInstanceId(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryProperty::processInstanceId());

The method processInstanceId() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

        return $this;
    }

    public function orderByProcessDefinitionId(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryProperty::processDefinitionId());

The method processDefinitionId() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

        return $this;
    }

    public function orderByProcessDefinitionKey(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryProperty::processDefinitionKey());

The method processDefinitionKey() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

        return $this;
    }

    public function orderByDeploymentId(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryProperty::deploymentId());

The method deploymentId() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

        return $this;
    }

    public function orderPartiallyByOccurrence(): HistoricJobLogQueryInterface
    {
        $this->orderBy(HistoricJobLogQueryProperty::sequenceCounter());

The method sequenceCounter() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

        return $this;
    }

    public function orderByTenantId(): HistoricJobLogQueryInterface
    {
        return orderBy(HistoricJobLogQueryProperty::tenantId());

The method tenantId() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

The function orderBy was not found. Maybe you did not declare it correctly or list all dependencies?

    }

    public function orderByHostname(): HistoricJobLogQueryInterface
    {
        return orderBy(HistoricJobLogQueryProperty::hostname());

The method hostname() does not exist on Jabe\Engine\Impl\HistoricJobLogQueryProperty.

The function orderBy was not found. Maybe you did not declare it correctly or list all dependencies?

    }

    public function executeCount(CommandContext $commandContext): int
    {
        $this->checkQueryOk();
        return $commandContext
            ->getHistoricJobLogManager()
            ->findHistoricJobLogsCountByQueryCriteria($this);
    }

    public function executeList(CommandContext $commandContext, Page $page): array

The type Jabe\Engine\Impl\Page was not found. Maybe you did not declare it correctly or list all dependencies?

    {
        $this->checkQueryOk();
        return $commandContext
            ->getHistoricJobLogManager()
            ->findHistoricJobLogsByQueryCriteria($this, $page);
    }

    public function isTenantIdSet(): bool
    {
        return $this->isTenantIdSet;
    }

    public function getJobId(): string
    {
        return $this->jobId;
    }

    public function getJobExceptionMessage(): string
    {
        return $this->jobExceptionMessage;
    }

    public function getJobDefinitionId(): string
    {
        return $this->jobDefinitionId;
    }

    public function getJobDefinitionType(): string
    {
        return $this->jobDefinitionType;
    }

    public function getJobDefinitionConfiguration(): string
    {
        return $this->jobDefinitionConfiguration;
    }

    public function getActivityIds(): array
    {
        return $this->activityIds;
    }

    public function getFailedActivityIds(): array
    {
        return $this->failedActivityIds;
    }

    public function getExecutionIds(): array
    {
        return $this->executionIds;
    }

    public function getProcessInstanceId(): string
    {
        return $this->processInstanceId;
    }

    public function getProcessDefinitionId(): string
    {
        return $this->processDefinitionId;
    }

    public function getProcessDefinitionKey(): string
    {
        return $this->processDefinitionKey;
    }

    public function getDeploymentId(): string
    {
        return $this->deploymentId;
    }

    public function getState(): JobStateInterface
    {
        return $this->state;
    }

    public function getTenantIds(): array
    {
        return $this->tenantIds;
    }

    public function getHostname(): string
    {
        return $this->hostname;
    }

    protected function setState(JobStateInterface $state): void
    {
        $this->state = $state;
    }
}