Richdynamix\PersonalisedProducts\Console\Command\AbstractOrdersCommand

Complexity

Total Complexity

15

Size/Duplication

Total Lines	138
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	_sendCustomerBuyProductData()	0	19	4
A	_getOrderCollection()	0	10	1
A	_getCustomerProductCollection()	0	16	3
A	_getCustomerCount()	0	4	1
A	_getProductCount()	0	9	2
A	_sendPurchaseEvent()	0	10	3

<?php

namespace Richdynamix\PersonalisedProducts\Console\Command;

use \Symfony\Component\Console\Command\Command;
use \Magento\Sales\Model\OrderFactory;
use \Richdynamix\PersonalisedProducts\Model\PredictionIO\EventClient\Client;
use \Symfony\Component\Config\Definition\Exception\Exception;

/**
 * Class AbstractOrdersCommand
 *
 * @category  Richdynamix
 * @package   PersonalisedProducts
 * @author    Steven Richardson (steven@richdynamix.com) @mage_gizmo
 */
abstract class AbstractOrdersCommand extends Command
{

    /**
     * @var OrderFactory
     */
    private $_orderFactory;

    /**
     * @var Client
     */
    private $_eventClient;

    /**
     * @var
     */
    private $_productCollection;

    /**
     * AbstractOrdersCommand constructor.
     * @param OrderFactory $orderFactory
     * @param Client $eventClient
     */
    public function __construct(OrderFactory $orderFactory, Client $eventClient)
    {
        $this->_orderFactory = $orderFactory;
        $this->_eventClient = $eventClient;
        parent::__construct();
    }

    /**
     * Prepare each order for customer and product data to send to PredictionIO
     *
     * @param $collection
     * @return int
     */
    protected function _sendCustomerBuyProductData($collection)
    {
        $collectionCount = count($collection);
        $sentEventCount = 0;

        foreach ($collection as $customerId => $products) {
            $sentEvent = $this->_sendPurchaseEvent($customerId, $products);
            if ($sentEvent) {
                ++$sentEventCount;
            }
        }

        if ($collectionCount != $sentEventCount) {
            throw new Exception('There was a problem sending the event data, check the log file for more information');
        }

        return $sentEventCount;

    }

    /**
     * Get a collection of all completed orders from logged in customers
     *
     * @return array
     */
    protected function _getOrderCollection()
    {
        $order = $this->_orderFactory->create();
        $ordersCollection = $order->getCollection()
            ->addFieldToSelect(['entity_id', 'customer_id'])
            ->addFieldToFilter('state', ['eq' => 'complete'])
            ->addFieldToFilter('customer_id', array('neq' => 'NULL' ));

        return $ordersCollection->getData();
    }

    /**
     * Get a collection of all products in the orders
     *
     * @param $ordersCollection
     * @return array
     */
    protected function _getCustomerProductCollection($ordersCollection)
    {
        $purchasedProducts = [];
        foreach ($ordersCollection as $order) {
            $order = $this->_orderFactory->create()->load($order['entity_id']);
            $itemCollection = $order->getItems();

            foreach ($itemCollection as $item) {
                $purchasedProducts[$order['customer_id']][] = $item->getProductId();
            }
        }

        $this->_productCollection = $purchasedProducts;

        return $purchasedProducts;
    }

    /**
     * Count the number of customers in all the orders
     *
     * @return int
     */
    protected function _getCustomerCount()
    {
        return count($this->_productCollection);
    }

    /**
     * Count all the products across all the orders
     *
     * @return int
     */
    protected function _getProductCount()
    {
        $productCount = 0;
        foreach ($this->_productCollection as $products) {
            $productCount += count($products);
        }

        return $productCount;
    }

    /**
     * Send customer-buys-item events to PredictionIO for all existing orders
     *
     * @param $customerId
     * @param $products
     * @return bool
     */
    protected function _sendPurchaseEvent($customerId, $products)
    {
        foreach ($products as $productId) {
            if (!$this->_eventClient->saveCustomerBuyProduct($customerId, $productId)) {
                return false;
            }
        }

        return true;
    }
}