hiqdev\billing\hiapi\repositories\PlanRepository

Complexity

Total Complexity

4

Size/Duplication

Total Lines	77
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	14	1
A	findAll()	0	14	1
B	extendWithPrices()	0	27	2

<?php

namespace hiqdev\billing\hiapi\repositories;

use hiapi\components\ConnectionInterface;
use hiapi\query\QueryMutator;
use hiapi\query\Specification;
use yii\db\Query;

class PlanRepository extends \hiapi\repositories\BaseRepository
{
    /**
     * @var ConnectionInterface
     */
    private $db;
    /**
     * @var PlanFactory
     */
    private $planFactory;
    /**
     * @var PlanHydrator
     */
    private $planHydrator;
    /**
     * @var PriceHydrator
     */
    private $priceHydrator;

    public function __construct(
        ConnectionInterface $db,
        PlanFactory $planFactory,
        PlanHydrator $planHydrator,
        PriceHydrator $priceHydrator,
        array $config = []
    ) {
        parent::__construct($config);

        $this->db = $db;
        $this->planFactory = $planFactory;
        $this->planHydrator = $planHydrator;
        $this->priceHydrator = $priceHydrator;
    }

    public function findAll(Specification $specification)
    {
        $mutator = (new QueryMutator((new Query())
            ->select(['p.obj_id as id', 'p.name'])
            ->from('tariff p')
        ))->apply($specification);

        $rows = $mutator->getQuery()->createCommand($this->db)->queryAll();
        $this->extendWithPrices($rows);

        $plans = $this->planHydrator->hydrateMultiple($this->planFactory->createPrototype(), $rows);

        return $plans;
    }

    private function extendWithPrices(&$rows)
    {
        $tariff_ids = array_column($rows, 'id');

        $pricesRows = (new Query())
            ->select([
                'tr.id', 'tr.tariff_id',
                'tr.object_id as target_id', 'ob.label as target_name', 'tt.obj_id as target_type_id', 'tt.name as target_type_name',
                'rt.obj_id as type_id', 'rt.name as type',
                'tr.quantity', 'tu.name as unit',
                'cu.name as currency', 'round(tr.price)' // todo: do not round
            ])
            ->from('tariff_resource tr')
            ->leftJoin('zref rt', 'rt.obj_id = tr.type_id')
            ->leftJoin('obj ob', 'ob.obj_id = tr.object_id')
            ->leftJoin('zref tt', 'tt.obj_id = ob.class_id')
            ->leftJoin('zref tu', 'tu.obj_id = tr.unit_id')
            ->leftJoin('zref cu', 'cu.obj_id = tr.currency_id')
            ->where(['tr.tariff_id' => $tariff_ids])
            ->createCommand($this->db)->queryAll();

$this->db is of type object<hiapi\components\ConnectionInterface>, but the function expects a object<yii\db\Connection>|null.

        foreach ($rows as &$plan) {
            $plan['prices'] = $this->priceHydrator->hydrateMultiple(array_filter($pricesRows, function ($row) use ($plan) {
                return $row['tariff_id'] === $plan['id'];
            }));
        }
    }
}