TierPriceProcessor::getConnection() - Code Metrics - Inspection of "Merge pull request #4 from wagnert/2.x" - techdivision/import-product-tier-price - Measure and Improve Code Quality continuously with Scrutinizer

Completed
Push — 2.x ( 48ed54...fe246a )

by Tim
created 2019-05-02 19:10 UTC
TierPriceProcessor::getConnection() A

↳ Parent: TierPriceProcessor
Complexity

Conditions	1
Paths	1
Size

Total Lines	3
Code Lines	1
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	0
CRAP Score	2
Importance

Changes
Metric	Value
cc	1
eloc	1
nc	1
nop	0
dl	0
loc	3
ccs	0
cts	3
cp	0
crap	2
rs	10
c	0
b	0
f	0
<?php

/**
 * TechDivision\Import\Product\TierPrice\Services\TierPriceProcessor
 *
 * 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 <[email protected]>
 * @author    Tim Wagner <[email protected]>
 * @copyright 2019 REFUSiON GmbH <[email protected]>
 * @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\Services;

use TechDivision\Import\Actions\ActionInterface;
use TechDivision\Import\Utils\PrimaryKeyUtilInterface;
filter:
    dependency_paths: ["lib/*"]
use TechDivision\Import\Connection\ConnectionInterface;
use TechDivision\Import\Product\TierPrice\Utils\MemberNames;
use TechDivision\Import\Product\Repositories\ProductRepositoryInterface;
use TechDivision\Import\Product\TierPrice\Repositories\TierPriceRepositoryInterface;

/**
 * Default implementation of tier price processor objects, giving access to CRUD methods.
 *
 * @author    Klaas-Tido Rühl <[email protected]>
 * @author    Tim Wagner <[email protected]>
 * @copyright 2019 REFUSiON GmbH <[email protected]>
 * @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 TierPriceProcessor implements TierPriceProcessorInterface
{

    /**
     * A \PDO connection used to load data and handle CRUD functionality.
     *
     * @var \TechDivision\Import\Connection\ConnectionInterface
     */
    protected $connection;

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

    /**
     * The action for tier price  CRUD methods.
     *
     * @var \TechDivision\Import\Actions\ActionInterface
     */
    protected $tierPriceAction;

    /**
     * The repository to load the tier prices with.
     *
     * @var \TechDivision\Import\Product\TierPrice\Repositories\TierPriceRepositoryInterface
     */
    protected $tierPriceRepository;

    /**
     * Caches the existing tier price records referenced by their unique hash.
     *
     * @var array
     */
    protected $tierPricesByHash = null;

    /**
     * Initialize the processor with the necessary assembler and repository instances.
     *
     * @param \TechDivision\Import\Connection\ConnectionInterface                              $connection          The \PDO connnection instance
     * @param \TechDivision\Import\Utils\PrimaryKeyUtilInterface                               $primaryKeyUtil      The primary key util
     * @param \TechDivision\Import\Product\TierPrice\Repositories\TierPriceRepositoryInterface $tierPriceRepository The repository to load the tier prices with
     * @param \TechDivision\Import\Product\Repositories\ProductRepositoryInterface             $productRepository   The repository to load the products with
     * @param \TechDivision\Import\Actions\ActionInterface                                     $tierPriceAction     The action for tier price  CRUD methods
     */
    public function __construct(
        ConnectionInterface $connection,
        PrimaryKeyUtilInterface $primaryKeyUtil,
        TierPriceRepositoryInterface $tierPriceRepository,
        ProductRepositoryInterface $productRepository,
        ActionInterface $tierPriceAction
    ) {
        $this->setConnection($connection);
        $this->setPrimaryKeyUtil($primaryKeyUtil);
        $this->setTierPriceRepository($tierPriceRepository);
        $this->setProductRepository($productRepository);
        $this->setTierPriceAction($tierPriceAction);
    }

    /**
     * Set's the passed connection.
     *
     * @param \TechDivision\Import\Connection\ConnectionInterface $connection The connection to set
     *
     * @return void
     */
    public function setConnection(ConnectionInterface $connection)
    {
        $this->connection = $connection;
    }

    /**
     * Return's the connection.
     *
     * @return \TechDivision\Import\Connection\ConnectionInterface The connection instance
     */
    public function getConnection()
    {
        return $this->connection;
    }

    /**
     * Sets the passed primary key util instance.
     *
     * @param \TechDivision\Import\Utils\PrimaryKeyUtilInterface $primaryKeyUtil The primary key util instance
     *
     * @return void
     */
    public function setPrimaryKeyUtil(PrimaryKeyUtilInterface $primaryKeyUtil)
    {
        $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();
    }

    /**
     * Turns off autocommit mode. While autocommit mode is turned off, changes made to the database via the PDO
     * object instance are not committed until you end the transaction by calling ProductProcessor::commit().
     * Calling ProductProcessor::rollBack() will roll back all changes to the database and return the connection
     * to autocommit mode.
     *
     * @return boolean Returns TRUE on success or FALSE on failure
     * @link http://php.net/manual/en/pdo.begintransaction.php
     */
    public function beginTransaction()
    {
        return $this->connection->beginTransaction();
    }

    /**
     * Commits a transaction, returning the database connection to autocommit mode until the next call to
     * ProductProcessor::beginTransaction() starts a new transaction.
     *
     * @return boolean Returns TRUE on success or FALSE on failure
     * @link http://php.net/manual/en/pdo.commit.php
     */
    public function commit()
    {
        return $this->connection->commit();
class A
{
    function getObject()
    {
        return null;
    }

}

$a = new A();
if ($a->getObject()) {
    }

    /**
     * Rolls back the current transaction, as initiated by ProductProcessor::beginTransaction().
     *
     * If the database was set to autocommit mode, this function will restore autocommit mode after it has
     * rolled back the transaction.
     *
     * Some databases, including MySQL, automatically issue an implicit COMMIT when a database definition
     * language (DDL) statement such as DROP TABLE or CREATE TABLE is issued within a transaction. The implicit
     * COMMIT will prevent you from rolling back any other changes within the transaction boundary.
     *
     * @return boolean Returns TRUE on success or FALSE on failure
     * @link http://php.net/manual/en/pdo.rollback.php
     */
    public function rollBack()
    {
        return $this->connection->rollBack();
    }

    /**
     * Sets the action with the tier price CRUD methods.
     *
     * @param \TechDivision\Import\Actions\ActionInterface $tierPriceAction The action with the tier price CRUD methods
     *
     * @return void
     */
    public function setTierPriceAction(ActionInterface $tierPriceAction)
    {
        $this->tierPriceAction = $tierPriceAction;
    }

    /**
     * Returns the action with the tier price CRUD methods.
     *
     * @return \TechDivision\Import\Actions\ActionInterface The action instance
     */
    public function getTierPriceAction()
    {
        return $this->tierPriceAction;
    }

    /**
     * Sets the repository to load the tier prices with.
     *
     * @param \TechDivision\Import\Product\TierPrice\Repositories\TierPriceRepositoryInterface $tierPriceRepository The repository instance
     *
     * @return void
     */
    public function setTierPriceRepository(TierPriceRepositoryInterface $tierPriceRepository)
    {
        $this->tierPriceRepository = $tierPriceRepository;
    }

    /**
     * Returns the repository to load the tier prices with.
     *
     * @return \TechDivision\Import\Product\TierPrice\Repositories\TierPriceRepositoryInterface The repository instance
     */
    public function getTierPriceRepository()
    {
        return $this->tierPriceRepository;
    }

    /**
     * Sets the repository to load the products with.
     *
     * @param \TechDivision\Import\Product\Repositories\ProductRepositoryInterface $productRepository The repository instance
     *
     * @return void
     */
    public function setProductRepository(ProductRepositoryInterface $productRepository)
    {
        $this->productRepository = $productRepository;

    }

    /**
     * Returns the repository to load the products with.
     *
     * @return \TechDivision\Import\Product\Repositories\ProductRepositoryInterface The repository instance
     */
    public function getProductRepository()
    {
        return $this->productRepository;
    }

    /**
     * Load's and return's the product with the passed SKU.
     *
     * @param string $sku The SKU of the product to load
     *
     * @return array The product
     */
    public function loadProduct($sku)
    {
        return $this->getProductRepository()->findOneBySku($sku);
    }

    /**
     * Returns all tier prices.
     *
     * @return array The array with the tier prices
     */
    public function loadTierPrices()
    {
        return $this->getTierPriceRepository()->findAll();
    }

    /**
     * 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 loadTierPriceByPkAndAllGroupsAndCustomerGroupIdAndQtyAndWebsiteId($pk, $allGroups, $customerGroupId, $qty, $websiteId)
    {
        return $this->getTierPriceRepository()->findOneByPkAndAllGroupsAndCustomerGroupIdAndQtyAndWebsiteId($pk, $allGroups, $customerGroupId, $qty, $websiteId);
    }

    /**
     * Persists the tier price with the passed data.
     *
     * @param array       $row  The tier price to persist
     * @param string|null $name The name of the prepared statement that has to be executed
     *
     * @return string The ID of the persisted entity
     */
    public function persistTierPrice($row, $name = null)
    {
        return $this->getTierPriceAction()->persist($row, $name);
        return $this->getTierPriceAction()->/** @scrutinizer ignore-call */ persist($row, $name);
    }

    /**
     * Deletes the tierprice with the passed attributes.
     *
     * @param array       $row  The attributes of the entity to delete
     * @param string|null $name The name of the prepared statement that has to be executed
     *
     * @return void
     */
    public function deleteTierPrice($row, $name = null)
    {
        $this->getTierPriceAction()->delete($row, $name);
    }

    /**
     * Clean-Up the tier prices after an add-update operation.
     *
     * @param array $processedTierPrices The array with the IDs of the processed tier prices
     *
     * @return void
     */
    public function cleanUpTierPrices(array $processedTierPrices)
    {

        // load the available + the processed tier prices
        $availableTierPrices = $this->loadTierPrices();

        // iterate over the tier prices and delete the obsolete ones
        foreach ($availableTierPrices as $tierPrice) {
            // if imported, we continue
            if (isset($processedTierPrices[$tierPrice[MemberNames::VALUE_ID]])) {
                // if the product has been touched by the import, delete the tier price
                if (in_array($tierPrice[$this->getPrimaryKeyMemberName()], $processedTierPrices[$tierPrice[MemberNames::VALUE_ID]])) {
                    continue;
                }

                // delete the tier price, because the entity is part of the import but the tier price is NOT available any more
                $this->deleteTierPrice([MemberNames::VALUE_ID => $tierPrice[MemberNames::VALUE_ID]]);
            }
        }
    }
}

techdivision / import-product-tier-price

Push — 2.x ( 48ed54...fe246a )

TierPriceProcessor::getConnection() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like
