Spiral\Statistics\Database\Sources\OccurrenceSource

Complexity

Total Complexity

7

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	findByTimestamp()	0	6	1
A	getByTimestamp()	0	9	2
A	createFromTimestamp()	0	12	1
A	findByGroupedInterval()	0	22	2

<?php

namespace Spiral\Statistics\Database\Sources;

use Spiral\Database\Injections\Parameter;
use Spiral\ORM\Entities\RecordSelector;
use Spiral\ORM\Entities\RecordSource;
use Spiral\ORM\ORMInterface;
use Spiral\Statistics\Database\Occurrence;
use Spiral\Statistics\DatetimeConverter;
use Spiral\Statistics\Extract\Range;

class OccurrenceSource extends RecordSource
{
    const RECORD = Occurrence::class;

    /** @var DatetimeConverter */
    private $converter;

    /**
     * OccurrenceSource constructor.
     *
     * @param ORMInterface      $orm
     * @param DatetimeConverter $converter
     */
    public function __construct(ORMInterface $orm, DatetimeConverter $converter)
    {
        parent::__construct(static::RECORD, $orm);

        $this->converter = $converter;
    }

    /**
     * @param \DateTimeInterface $datetime
     * @return Occurrence|null
     */
    public function findByTimestamp(\DateTimeInterface $datetime)
    {
        $entity = $this->findOne(['timestamp' => $datetime]);

        return $entity;
    }

    /**
     * @param \DateTime $datetime
     * @return Occurrence
     */
    public function getByTimestamp(\DateTime $datetime): Occurrence
    {
        $entity = $this->findByTimestamp($datetime);
        if (empty($entity)) {
            $entity = $this->createFromTimestamp($datetime);
        }

        return $entity;
    }

    /**
     * @param \DateTimeInterface $datetime
     * @return Occurrence
     */
    public function createFromTimestamp(\DateTimeInterface $datetime): Occurrence
    {
        $entity = $this->create([
            'timestamp'  => $this->converter->convert($datetime),
            'day_mark'   => $this->converter->convert($datetime, 'day'),
            'week_mark'  => $this->converter->convert($datetime, 'week'),
            'month_mark' => $this->converter->convert($datetime, 'month'),
            'year_mark'  => $this->converter->convert($datetime, 'year'),
        ]);

        return $entity;
    }

    /**
     * @param string             $periodField
     * @param \DateTimeInterface $periodValue
     * @param \DateTimeInterface $start
     * @param \DateTimeInterface $end
     * @param array              $events
     * @return RecordSelector
     */
    public function findByGroupedInterval(
        string $periodField,
        \DateTimeInterface $periodValue,
        \DateTimeInterface $start,
        \DateTimeInterface $end,
        array $events = []
    ): RecordSelector
    {
        $selector = $this->find([
            $periodField => $periodValue,
            'timestamp'  => ['between' => [$start, $end]]
        ]);

        if (!empty($events)) {
            $selector->with(
                'events',
                ['where' => ['{@}.name' => ['IN' => new Parameter($events)]]]
            );
        }

        return $selector;
    }
}