TechDivision\Import\Product\TierPrice\Repositories\TierPriceRepository

Complexity

Total Complexity

6

Size/Duplication

Total Lines	117
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	findAll()	0	5	1
A	__construct()	0	11	1
A	getPrimaryKeyMemberName()	0	3	1
A	getPrimaryKeyUtil()	0	3	1
A	init()	0	7	1
A	findOneByPkAndAllGroupsAndCustomerGroupIdAndQtyAndWebsiteId()	0	15	1

<?php

/**
 * TechDivision\Import\Product\TierPrice\Repositories\TierPriceRepository
 *
 * PHP version 7
 *
 * @author    Klaas-Tido Rühl <kr@refusion.com>
 * @author    Tim Wagner <t.wagner@techdivision.com>
 * @copyright 2019 REFUSiON GmbH <info@refusion.com>
 * @license   https://opensource.org/licenses/MIT
 * @link      https://github.com/techdivision/import-product-tier-price
 * @link      https://www.techdivision.com
 * @link      https://www.refusion.com
 */

namespace TechDivision\Import\Product\TierPrice\Repositories;

use TechDivision\Import\Product\TierPrice\Utils\MemberNames;
use TechDivision\Import\Product\TierPrice\Utils\SqlStatementKeys;
use TechDivision\Import\Dbal\Utils\PrimaryKeyUtilInterface;
use TechDivision\Import\Dbal\Connection\ConnectionInterface;
use TechDivision\Import\Dbal\Collection\Repositories\AbstractRepository;
use TechDivision\Import\Dbal\Repositories\SqlStatementRepositoryInterface;

/**
 * Default implementation of repository for accessing tier price data.
 *
 * @author    Klaas-Tido Rühl <kr@refusion.com>
 * @author    Tim Wagner <t.wagner@techdivision.com>
 * @copyright 2019 REFUSiON GmbH <info@refusion.com>
 * @license   https://opensource.org/licenses/MIT
 * @link      https://github.com/techdivision/import-product-tier-price
 * @link      https://www.techdivision.com
 * @link      https://www.refusion.com
 */
class TierPriceRepository extends AbstractRepository implements TierPriceRepositoryInterface
{

    /**
     * The primary key util instance.
     *
     * @var \TechDivision\Import\Dbal\Utils\PrimaryKeyUtilInterface
     */
    protected $primaryKeyUtil;

    /**
     * The prepared statement to load the existing tier prices.
     *
     * @var \PDOStatement
     */
    protected $tierPricesStmt;

    /**
     * The prepared statement to load an existing tier price by PK, all groups, customer group ID, qty and website ID.
     *
     * @var \PDOStatement
     */
    protected $tierPriceByPkAndAllGroupsAndCustomerGroupIdAndQtyAndWebsiteIdStmt;

    /**
     * Initialize the repository with the passed connection and utility class name.
     * .
     * @param \TechDivision\Import\Dbal\Connection\ConnectionInterface               $connection             The connection instance
     * @param \TechDivision\Import\Dbal\Repositories\SqlStatementRepositoryInterface $sqlStatementRepository The SQL repository instance
     * @param \TechDivision\Import\Dbal\Utils\PrimaryKeyUtilInterface                $primaryKeyUtil         The primary key util instance
     */
    public function __construct(
        ConnectionInterface $connection,
        SqlStatementRepositoryInterface $sqlStatementRepository,
        PrimaryKeyUtilInterface $primaryKeyUtil
    ) {

        // pass the connection and the SQL statement repository through to the parent instance
        parent::__construct($connection, $sqlStatementRepository);

        // set the primary key util
        $this->primaryKeyUtil = $primaryKeyUtil;
    }

    /**
     * Returns the primary key util instance.
     *
     * @return \TechDivision\Import\Dbal\Utils\PrimaryKeyUtilInterface The primary key util instance
     */
    public function getPrimaryKeyUtil()
    {
        return $this->primaryKeyUtil;
    }

    /**
     * Returns the primary key member name for the actual Magento edition.
     *
     * @return string The primary key member name
     * @see \TechDivision\Import\Dbal\Utils\PrimaryKeyUtilInterface::getPrimaryKeyMemberName()
     */
    public function getPrimaryKeyMemberName()
    {
        return $this->getPrimaryKeyUtil()->getPrimaryKeyMemberName();
    }

    /**
     * Initializes the repository's prepared statements.
     *
     * @return void
     */
    public function init()
    {
        // initialize the prepared statements
        $this->tierPricesStmt =
            $this->getConnection()->prepare($this->loadStatement(SqlStatementKeys::TIER_PRICES));
        $this->tierPriceByPkAndAllGroupsAndCustomerGroupIdAndQtyAndWebsiteIdStmt =
            $this->getConnection()->prepare($this->loadStatement(SqlStatementKeys::TIER_PRICE_BY_PK_AND_ALL_GROUPS_AND_CUSTOMER_GROUP_ID_AND_QTY_AND_WEBSITE_ID));
    }

    /**
     * Returns the tier price with the given parameters.
     *
     * @param string  $pk              The PK of the product relation
     * @param integer $allGroups       The flag if all groups are affected or not
     * @param integer $customerGroupId The customer group ID
     * @param integer $qty             The tier price quantity
     * @param integer $websiteId       The website ID the tier price is related to
     *
     * @return array The tier price
     */
    public function findOneByPkAndAllGroupsAndCustomerGroupIdAndQtyAndWebsiteId($pk, $allGroups, $customerGroupId, $qty, $websiteId)
    {

        // initialize the params
        $params = array(
            $this->getPrimaryKeyMemberName() => $pk,
            MemberNames::ALL_GROUPS          => $allGroups,
            MemberNames::CUSTOMER_GROUP_ID   => $customerGroupId,
            MemberNames::QTY                 => $qty,
            MemberNames::WEBSITE_ID          => $websiteId
        );

        // load and return the tier price with the passed params
        $this->tierPriceByPkAndAllGroupsAndCustomerGroupIdAndQtyAndWebsiteIdStmt->execute($params);
        return $this->tierPriceByPkAndAllGroupsAndCustomerGroupIdAndQtyAndWebsiteIdStmt->fetch(\PDO::FETCH_ASSOC);
    }

    /**
     * Returns an array with all the tier prices.
     *
     * @return array The tier prices
     */
    public function findAll()
    {
        // load and return the tier prices
        $this->tierPricesStmt->execute();
        return $this->tierPricesStmt->fetchAll(\PDO::FETCH_ASSOC);
    }
}