Jabe\Engine\Impl\HistoricActivityInstanceQueryImpl

Complexity

Total Complexity

55

Size/Duplication

Total Lines	326
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

51 Methods

Rating	Name	Duplication	Size	Complexity
A	processInstanceId()	0	4	1
A	orderByExecutionId()	0	4	1
A	getActivityInstanceState()	0	3	1
A	isUnfinished()	0	3	1
A	taskAssignee()	0	4	1
A	getFinishedAfter()	0	3	1
A	finished()	0	4	1
A	getActivityType()	0	3	1
A	completeScope()	0	8	2
A	processDefinitionId()	0	4	1
A	orderByHistoricActivityInstanceStartTime()	0	4	1
A	orderByActivityName()	0	4	1
A	activityId()	0	4	1
A	unfinished()	0	4	1
A	orderByHistoricActivityInstanceId()	0	4	1
A	orderByActivityType()	0	4	1
A	orderByActivityId()	0	4	1
A	orderByProcessDefinitionId()	0	4	1
A	executeCount()	0	6	1
A	finishedBefore()	0	4	1
A	activityName()	0	4	1
A	executionId()	0	4	1
A	getActivityId()	0	3	1
A	getStartedBefore()	0	3	1
A	orderByHistoricActivityInstanceEndTime()	0	4	1
A	startedAfter()	0	4	1
A	getProcessInstanceId()	0	3	1
A	executeList()	0	6	1
A	withoutTenantId()	0	5	1
A	canceled()	0	7	2
A	activityType()	0	4	1
A	__construct()	0	3	1
A	getAssignee()	0	3	1
A	isFinished()	0	3	1
A	getActivityName()	0	3	1
A	isTenantIdSet()	0	3	1
A	getFinishedBefore()	0	3	1
A	getStartedAfter()	0	3	1
A	hasExcludingConditions()	0	5	3
A	orderByProcessInstanceId()	0	4	1
A	orderByHistoricActivityInstanceDuration()	0	4	1
A	activityInstanceId()	0	4	1
A	getExecutionId()	0	3	1
A	startedBefore()	0	4	1
A	activityNameLike()	0	4	1
A	getProcessDefinitionId()	0	3	1
A	finishedAfter()	0	4	1
A	orderByTenantId()	0	3	1
A	getActivityInstanceId()	0	3	1
A	orderPartiallyByOccurrence()	0	4	1
A	tenantIdIn()	0	6	1

<?php

namespace Jabe\Engine\Impl;

use Jabe\Engine\ProcessEngineException;
use Jabe\Engine\History\HistoricActivityInstanceQueryInterface;
use Jabe\Engine\Impl\Interceptor\{
    CommandContext,
    CommandExecutorInterface
};
use Jabe\Engine\Impl\Pvm\Runtime\ActivityInstanceState;
use Jabe\Engine\Impl\Util\{
    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 HistoricActivityInstanceQueryImpl extends AbstractQuery implements HistoricActivityInstanceQueryInterface
{
    protected $activityInstanceId;
    protected $processInstanceId;
    protected $executionId;
    protected $processDefinitionId;
    protected $activityId;
    protected $activityName;
    protected $activityNameLike;
    protected $activityType;
    protected $assignee;
    protected $finished;
    protected $unfinished;
    protected $startedBefore;
    protected $startedAfter;
    protected $finishedBefore;
    protected $finishedAfter;
    protected $activityInstanceState;
    protected $tenantIds = [];
    protected $isTenantIdSet;

    public function __construct(CommandExecutor $commandExecutor = null)

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

    {
        parent::__construct($commandExecutor);
    }

    public function executeCount(CommandContext $commandContext): int
    {
        $this->checkQueryOk();
        return $commandContext
        ->getHistoricActivityInstanceManager()
        ->findHistoricActivityInstanceCountByQueryCriteria($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
        ->getHistoricActivityInstanceManager()
        ->findHistoricActivityInstancesByQueryCriteria($this, $page);
    }

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

    public function executionId(string $executionId): HistoricActivityInstanceQueryImpl
    {
        $this->executionId = $executionId;
        return $this;
    }

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

    public function activityId(string $activityId): HistoricActivityInstanceQueryImpl
    {
        $this->activityId = $activityId;
        return $this;
    }

    public function activityName(string $activityName): HistoricActivityInstanceQueryImpl
    {
        $this->activityName = $activityName;
        return $this;
    }

    public function activityNameLike(string $activityNameLike): HistoricActivityInstanceQueryImpl
    {
        $this->activityNameLike = $activityNameLike;
        return $this;
    }

    public function activityType(string $activityType): HistoricActivityInstanceQueryImpl
    {
        $this->activityType = $activityType;
        return $this;
    }

    public function taskAssignee(string $assignee): HistoricActivityInstanceQueryImpl
    {
        $this->assignee = $assignee;
        return $this;
    }

    public function finished(): HistoricActivityInstanceQueryImpl
    {
        $this->finished = true;
        return $this;
    }

    public function unfinished(): HistoricActivityInstanceQueryImpl
    {
        $this->unfinished = true;
        return $this;
    }

    public function completeScope(): HistoricActivityInstanceQueryImpl
    {
        if ($this->activityInstanceState != null) {
            throw new ProcessEngineException("Already querying for activity instance state <" . $this->activityInstanceState . ">");
        }

        $this->activityInstanceState = ActivityInstanceState::scopeComplete();
        return $this;
    }

    public function canceled(): HistoricActivityInstanceQueryImpl
    {
        if ($this->activityInstanceState != null) {
            throw new ProcessEngineException("Already querying for activity instance state <" . $activityInstanceState . ">");

The variable $activityInstanceState seems to be never defined.

        }
        $this->activityInstanceState = ActivityInstanceState::canceled();
        return $this;
    }

    public function startedAfter(string $date): HistoricActivityInstanceQueryImpl
    {
        $this->startedAfter = $date;
        return $this;
    }

    public function startedBefore(string $date): HistoricActivityInstanceQueryImpl
    {
        $this->startedBefore = $date;
        return $this;
    }

    public function finishedAfter(string $date): HistoricActivityInstanceQueryImpl
    {
        $this->finishedAfter = $date;
        return $this;
    }

    public function finishedBefore(string $date): HistoricActivityInstanceQueryImpl
    {
        $this->finishedBefore = $date;
        return $this;
    }

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

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

    protected function hasExcludingConditions(): bool
    {
        return parent::hasExcludingConditions()
        || CompareUtil::areNotInAscendingOrder($this->startedAfter, $this->startedBefore)
        || CompareUtil::areNotInAscendingOrder($this->finishedAfter, $this->finishedBefore);
    }

    // ordering /////////////////////////////////////////////////////////////////

    public function orderByHistoricActivityInstanceDuration(): HistoricActivityInstanceQueryImpl
    {
        $this->orderBy(HistoricActivityInstanceQueryProperty::duration());
        return $this;
    }

    public function orderByHistoricActivityInstanceEndTime(): HistoricActivityInstanceQueryImpl
    {
        $this->orderBy(HistoricActivityInstanceQueryProperty::end());
        return $this;
    }

    public function orderByExecutionId(): HistoricActivityInstanceQueryImpl
    {
        $this->orderBy(HistoricActivityInstanceQueryProperty::executionId());
        return $this;
    }

    public function orderByHistoricActivityInstanceId(): HistoricActivityInstanceQueryImpl
    {
        $this->orderBy(HistoricActivityInstanceQueryProperty::historicActivityInstanceId());
        return $this;
    }

    public function orderByProcessDefinitionId(): HistoricActivityInstanceQueryImpl
    {
        $this->orderBy(HistoricActivityInstanceQueryProperty::processDefinitionId());
        return $this;
    }

    public function orderByProcessInstanceId(): HistoricActivityInstanceQueryImpl
    {
        $this->orderBy(HistoricActivityInstanceQueryProperty::processInstanceId());
        return $this;
    }

    public function orderByHistoricActivityInstanceStartTime(): HistoricActivityInstanceQueryImpl
    {
        $this->orderBy(HistoricActivityInstanceQueryProperty::start());
        return $this;
    }

    public function orderByActivityId(): HistoricActivityInstanceQueryInterface
    {
        $this->orderBy(HistoricActivityInstanceQueryProperty::activityId());
        return $this;
    }

    public function orderByActivityName(): HistoricActivityInstanceQueryImpl
    {
        $this->orderBy(HistoricActivityInstanceQueryProperty::activityName());
        return $this;
    }

    public function orderByActivityType(): HistoricActivityInstanceQueryImpl
    {
        $this->orderBy(HistoricActivityInstanceQueryProperty::activityType());
        return $this;
    }

    public function orderPartiallyByOccurrence(): HistoricActivityInstanceQueryInterface
    {
        $this->orderBy(HistoricActivityInstanceQueryProperty::sequenceCounter());
        return $this;
    }

    public function orderByTenantId(): HistoricActivityInstanceQueryInterface
    {
        return orderBy(HistoricActivityInstanceQueryProperty::tenantId());

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

    }

    public function activityInstanceId(string $activityInstanceId): HistoricActivityInstanceQueryImpl
    {
        $this->activityInstanceId = $activityInstanceId;
        return $this;
    }

    // getters and setters //////////////////////////////////////////////////////

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

    public function getExecutionId(): string
    {
        return $this->executionId;
    }

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

    public function getActivityId(): string
    {
        return $this->activityId;
    }

    public function getActivityName(): string
    {
        return $this->activityName;
    }

    public function getActivityType(): string
    {
        return $this->activityType;
    }

    public function getAssignee(): string
    {
        return $this->assignee;
    }

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

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

    public function getActivityInstanceId(): string
    {
        return $this->activityInstanceId;
    }

    public function getStartedAfter(): string
    {
        return $this->startedAfter;
    }

    public function getStartedBefore(): string
    {
        return $this->startedBefore;
    }

    public function getFinishedAfter(): string
    {
        return $this->finishedAfter;
    }

    public function getFinishedBefore(): string
    {
        return $this->finishedBefore;
    }

    public function getActivityInstanceState(): ActivityInstanceState
    {
        return $this->activityInstanceState;
    }

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