TierPriceRepository::findOneByEntityIdAndAllGroupsAndCustomerGroupIdAndQtyAndWebsiteId()

Complexity

Conditions	1
Paths	1

Size

Total Lines	15
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	TierPriceRepository::getPrimaryKeyUtil()	0	3	1

<?php

/**
 * TechDivision\Import\Product\TierPrice\Repositories\TierPriceRepository
 *
 * NOTICE OF LICENSE
 *
 * This source file is subject to the Open Software License (OSL 3.0)
 * that is available through the world-wide-web at this URL:
 * http://opensource.org/licenses/osl-3.0.php
 *
 * PHP version 5
 *
 * @author    Klaas-Tido Rühl <kr@refusion.com>
 * @author    Tim Wagner <t.wagner@techdivision.com>
 * @copyright 2019 REFUSiON GmbH <info@refusion.com>
 * @license   http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
 * @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\Utils\PrimaryKeyUtilInterface;

The type TechDivision\Import\Utils\PrimaryKeyUtilInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use TechDivision\Import\Connection\ConnectionInterface;
use TechDivision\Import\Repositories\AbstractRepository;
use TechDivision\Import\Product\TierPrice\Utils\MemberNames;
use TechDivision\Import\Product\TierPrice\Utils\SqlStatementKeys;
use TechDivision\Import\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   http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0)
 * @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\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\Connection\ConnectionInterface               $connection             The connection instance
     * @param \TechDivision\Import\Repositories\SqlStatementRepositoryInterface $sqlStatementRepository The SQL repository instance
     * @param \TechDivision\Import\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\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\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);
    }
}