Jh\DataImportMagento\Writer\ReturnsWriter

Complexity

Total Complexity

23

Size/Duplication

Total Lines	222
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
C	writeItem()	0	74	8
A	getOrder()	0	17	2
A	getActualRefundCount()	0	16	4
A	getItemsRefunded()	0	18	4
A	validateItemsToBeRefunded()	0	16	3
A	getServiceForOrder()	0	4	1

<?php
namespace Jh\DataImportMagento\Writer;

use Ddeboer\DataImport\Exception\WriterException;
use Ddeboer\DataImport\Writer\AbstractWriter;
use Jh\DataImportMagento\Exception\MagentoSaveException;

/**
 * Class ReturnsWriter
 * @package Jh\DataImportMagento\Writer
 * @author Aydin Hassan <aydin@hotmail.co.uk>
 */
class ReturnsWriter extends AbstractWriter
{

    /**
     * @var \Mage_Core_Model_Resource_Transaction
     */
    protected $transactionResourceModel;

    /**
     * @var \Mage_Sales_Model_Order
     */
    protected $orderModel;

    /**
     * @var array
     */
    protected $options = [
        'order_id_field'            => 'increment_id',
        'send_credit_memo_email'    => true,
    ];

    /**
     * @param \Mage_Sales_Model_Order $orderModel
     * @param \Mage_Core_Model_Resource_Transaction $transactionResourceModel
     */
    public function __construct(
        \Mage_Sales_Model_Order $orderModel,
        \Mage_Core_Model_Resource_Transaction $transactionResourceModel
    ) {
        $this->orderModel                   = $orderModel;
        $this->transactionResourceModel     = $transactionResourceModel;
    }

    /**
     * @param array $item
     * @return \Ddeboer\DataImport\Writer\WriterInterface|void
     * @throws \Ddeboer\DataImport\Exception\WriterException
     * @throws \Jh\DataImportMagento\Exception\MagentoSaveException
     */
    public function writeItem(array $item)
    {
        if (!isset($item['orderId'])) {
            throw new WriterException('order_id must be set');
        }

        $order      = $this->getOrder($item['orderId']);
        $service    = $this->getServiceForOrder($order);

        $quantities         = $this->validateItemsToBeRefunded($order, $item['items']);
        $alreadyReturned    = $this->getItemsRefunded($order);
        //TODO: Make this configurable - Some Returns will not include the total qty's returned
        //TODO: Just the exact qty to return.
        $returnQuantities    = $this->getActualRefundCount($alreadyReturned, $quantities);

        if (!count($returnQuantities)) {
            throw new WriterException(
                sprintf(
                    'Credit Memo cannot be created with no Items to Refund. Order ID: "%s"',
                    $item['orderId']
                )
            );
        }

        try {
            /** @var \Mage_Sales_Model_Order_Creditmemo $creditMemo */
            $creditMemo = $service->prepareCreditmemo([
                'qtys'              => $returnQuantities,
                //TODO: Make this configurable - have an option whether to refund shipping or not
                //TODO: if yes, then grab the amount from the input data
                'shipping_amount'   => 0,
            ]);
        } catch (\Mage_Core_Exception $e) {
            //Probably something to do trying to refund
            //quantities which don't add up
            throw new MagentoSaveException($e->getMessage());
        }

        //don't actually perform refund.
        //TODO: Make this configurable ^
        $creditMemo->addData([
            'offline_requested' => true,
        ]);

        if (isset($item['comment'])) {
            $creditMemo->addComment($item['comment']);
        }

        $creditMemo->register();

        try {
            $transactionSave = clone $this->transactionResourceModel;
            $transactionSave
                ->addObject($creditMemo)
                ->addObject($creditMemo->getOrder())
                ->save();

            //if there is a custom status for the order
            //set it - we do it here, because somewhere in the save process
            //Magento sets the order to complete.
            if (isset($item['orderStatus'])) {
                //$order->setStatus(strtolower($item['orderStatus']));
                $order->addStatusHistoryComment("Returned", strtolower($item['orderStatus']));
                $order->save();
            }

        } catch (\Exception $e) {
            throw new MagentoSaveException($e->getMessage());
        }

        if ($this->options['send_credit_memo_email']) {
            $creditMemo->sendEmail(true);
        }
    }

    /**
     * @param int $orderId
     * @throws WriterException
     * @return \Mage_Sales_Model_Order
     */
    public function getOrder($orderId)
    {
        $order = clone $this->orderModel;
        $order->load($orderId, $this->options['order_id_field']);

        if (!$order->getId()) {
            throw new WriterException(
                sprintf(
                    'Cannot find order with id: "%s", using: "%s" as id field',
                    $orderId,
                    $this->options['order_id_field']
                )
            );
        }

        return $order;
    }

    /**
     * If we have an item which has a qty of 7 to be refunded. What this actually means is we
     * have refunded a total amount of 7, but part of that qty could have been refunded at an earlier time.
     * So we need to get the total of that item already refunded and minus it from the qty to be refunded.
     *
     * Imagine we receive an refund with qty of 7 to refund. We have already refunded 4 so we want to refund the
     * other 3. SO: QtyToRefund - AlreadyRefunded === ActualQtyToRefund.
     *
     * @param array $alreadyRefunded
     * @param array $toRefund
     * @return array
     */
    public function getActualRefundCount(array $alreadyRefunded, array $toRefund)
    {
        $actualRefund = [];
        foreach ($toRefund as $itemId => $qty) {
            if (isset($alreadyRefunded[$itemId])) {
                $actualRefund[$itemId] = $qty - $alreadyRefunded[$itemId];
            } else {
                $actualRefund[$itemId] = $qty;
            }

            if ($actualRefund[$itemId] == 0) {
                unset($actualRefund[$itemId]);
            }
        }
        return $actualRefund;
    }

    /**
     * @param \Mage_Sales_Model_Order $order
     * @return array
     */
    public function getItemsRefunded(\Mage_Sales_Model_Order $order)
    {
        $items = [];

        /** @var \Mage_Sales_Model_Order_Creditmemo $creditMemo */
        foreach ($order->getCreditmemosCollection() as $creditMemo) {
            /** @var \Mage_Sales_Model_Order_Creditmemo_Item $item */
            foreach ($creditMemo->getAllItems() as $item) {
                if (!isset($items[$item->getData('order_item_id')])) {
                    $items[$item->getData('order_item_id')] = $item->getQty();
                } else {
                    $items[$item->getData('order_item_id')] += $item->getQty();
                }
            }
        }

        return $items;
    }

    /**
     * @param \Mage_Sales_Model_Order $order
     * @param array $items
     * @return array
     * @throws WriterException
     */
    public function validateItemsToBeRefunded(\Mage_Sales_Model_Order $order, array $items)
    {
        $return = [];
        foreach ($items as $item) {
            $orderItem = $order->getItemsCollection()->getItemByColumnValue('sku', $item['sku']);
            if (null === $orderItem) {
                throw new WriterException(
                    sprintf('Item with SKU: "%s" does not exist in Order: "%s"', $item['sku'], $order->getIncrementId())
                );
            }

            $return[$orderItem->getId()] = $item['qty'];
        }

        return $return;
    }


    /**
     * @param \Mage_Sales_Model_Order $order
     * @return \Mage_Sales_Model_Service_Order
     */
    public function getServiceForOrder(\Mage_Sales_Model_Order $order)
    {
        return \Mage::getModel('sales/service_order', $order);

The expression \Mage::getModel('sales/service_order', $order); of type object|false adds false to the return on line 232 which is incompatible with the return type documented by Jh\DataImportMagento\Writer\ReturnsWriter::getServiceForOrder of type Mage_Sales_Model_Service_Order. It seems like you forgot to handle an error condition.

    }
}