TechDivision\Import\Customer\Repositories\CustomerRepository

Complexity

Total Complexity

7

Size/Duplication

Total Lines	149
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	findOneByEmailAndWebsiteId()	0	12	1
A	loadCustomerByWebsiteIdAndIncrementId()	0	12	1
A	init()	0	14	1
A	findDirectoryCountryRegions()	0	17	2
A	load()	0	6	1
A	findAll()	0	5	1

<?php

/**
 * TechDivision\Import\Customer\Repositories\CustomerRepository
 *
 * PHP version 7
 *
 * @author    Tim Wagner <t.wagner@techdivision.com>
 * @copyright 2018 TechDivision GmbH <info@techdivision.com>
 * @license   https://opensource.org/licenses/MIT
 * @link      https://github.com/techdivision/import-customer
 * @link      http://www.techdivision.com
 */

namespace TechDivision\Import\Customer\Repositories;

use TechDivision\Import\Customer\Utils\MemberNames;
use TechDivision\Import\Customer\Utils\SqlStatementKeys;
use TechDivision\Import\Dbal\Collection\Repositories\AbstractRepository;

/**
 * Repository implementation to load customer data.
 *
 * @author    Tim Wagner <t.wagner@techdivision.com>
 * @copyright 2018 TechDivision GmbH <info@techdivision.com>
 * @license   https://opensource.org/licenses/MIT
 * @link      https://github.com/techdivision/import-customer
 * @link      http://www.techdivision.com
 */
class CustomerRepository extends AbstractRepository implements CustomerRepositoryInterface
{

    /**
     * The prepared statement to load a customer with the passed entity ID.
     *
     * @var \PDOStatement
     */
    protected $customerStmt;

    /**
     * The prepared statement to load a customer with the passed email and website ID.
     *
     * @var \PDOStatement
     */
    protected $customerByEmailAndWebsiteIdStmt;

    /**
     * The prepared statement to load a customer with the passed email and website ID.
     *
     * @var \PDOStatement
     */
    protected $customerByWebsiteIdAndIncrementIdStmt;

    /**
     * The prepared statement to load the existing customers.
     *
     * @var \PDOStatement
     */
    protected $customersStmt;

    /**
     * @var PDOStatement

The type TechDivision\Import\Customer\Repositories\PDOStatement was not found. Did you mean PDOStatement? If so, make sure to prefix the type with \.

     */
    protected $directoryCountryRegionsStatement;
    /**
     * Initializes the repository's prepared statements.
     *
     * @return void
     */
    public function init()
    {

        // initialize the prepared statements
        $this->customerStmt =
            $this->getConnection()->prepare($this->loadStatement(SqlStatementKeys::CUSTOMER));
        $this->customerByEmailAndWebsiteIdStmt =
            $this->getConnection()->prepare($this->loadStatement(SqlStatementKeys::CUSTOMER_BY_EMAIL_AND_WEBSITE_ID));
        $this->customerByWebsiteIdAndIncrementIdStmt =
            $this->getConnection()->prepare($this->loadStatement(SqlStatementKeys::CUSTOMER_BY_WEBSITE_ID_AND_INCREMET_ID));
        $this->customersStmt =
            $this->getConnection()->prepare($this->loadStatement(SqlStatementKeys::CUSTOMERS));
        $this->directoryCountryRegionsStatement =
            $this->getConnection()->prepare($this->loadStatement(SqlStatementKeys::SELECT_DIRECTORY_COUNTRY_REGIONS));

It seems like $this->getConnection()->prepare($this->loadStatement(TechDivision\Import\Customer\Utils\SqlStatementKeys::SELECT_DIRECTORY_COUNTRY_REGIONS)) of type PDOStatement is incompatible with the declared type TechDivision\Import\Customer\Repositories\PDOStatement of property $directoryCountryRegionsStatement.

    }

    /**
     * Return's the available customers.
     *
     * @return array The available customers
     */
    public function findAll()
    {
        // load and return the available customers
        $this->customersStmt->execute();
        return $this->customersStmt->fetchAll(\PDO::FETCH_ASSOC);
    }

    /**
     * Return's the customer with the passed entity ID.
     *
     * @param integer $id The entity ID of the customer to return
     *
     * @return array|null The customer
     */
    public function load($id)
    {

        // if not, try to load the customer with the passed entity ID
        $this->customerStmt->execute(array(MemberNames::ENTITY_ID => $id));
        return $this->customerStmt->fetch(\PDO::FETCH_ASSOC);
    }

    /**
     * Return's the customer with the passed email and website ID.
     *
     * @param string $email     The email of the customer to return
     * @param string $websiteId The website ID of the customer to return
     *
     * @return array|null The customer
     */
    public function findOneByEmailAndWebsiteId($email, $websiteId)
    {

        // initialize the params
        $params = array(
            MemberNames::EMAIL      => $email,
            MemberNames::WEBSITE_ID => $websiteId
        );

        // if not, try to load the customer with the passed email and website ID
        $this->customerByEmailAndWebsiteIdStmt->execute($params);
        return $this->customerByEmailAndWebsiteIdStmt->fetch(\PDO::FETCH_ASSOC);
    }

    /**
     * Return's the customer with the passed email, website ID and increment id.
     *
     * @param string $websiteId    The website ID of the customer to return
     * @param string $increment_id The website ID of the customer to return
     *
     * @return array|null The customer
     */
    public function loadCustomerByWebsiteIdAndIncrementId($websiteId, $increment_id)
    {

        // initialize the params
        $params = array(
            MemberNames::WEBSITE_ID => $websiteId,
            MemberNames::INCREMENT_ID => $increment_id
        );

        // if not, try to load the customer with the passed email and website ID
        $this->customerByWebsiteIdAndIncrementIdStmt->execute($params);
        return $this->customerByWebsiteIdAndIncrementIdStmt->fetch(\PDO::FETCH_ASSOC);
    }

    /**
     * Return's all country regions from directory
     *
     * @return array
     */
    public function findDirectoryCountryRegions()
    {
        $directoryCountryRegions = [];

        // execute the prepared statement
        $this->directoryCountryRegionsStatement->execute();

        // load the available customer groups
        $avalaibleDirectoryCountryRegions = $this->directoryCountryRegionsStatement->fetchAll();

        // fetch the directory regions and assemble them as array with the codes as key
        foreach ($avalaibleDirectoryCountryRegions as $countryRegion) {
            $directoryCountryRegions[$countryRegion[\TechDivision\Import\Customer\Address\Utils\MemberNames::DIRECTORY_REGION_CODE]] = $countryRegion;

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

        }

        // return the customer groups
        return $directoryCountryRegions;
    }
}