InventoryTransferTest.php

Go to the documentation of this file.

<?php
declare(strict_types=1);

namespace Magento\InventoryCatalog\Test\Integration\Bulk;

use Magento\Framework\Api\SearchCriteriaBuilder;
use Magento\InventoryApi\Api\Data\SourceItemInterface;
use Magento\InventoryApi\Api\SourceItemRepositoryInterface;
use Magento\InventoryCatalogApi\Api\BulkInventoryTransferInterface;
use Magento\InventoryCatalogApi\Api\DefaultSourceProviderInterface;
use Magento\TestFramework\Helper\Bootstrap;
use PHPUnit\Framework\TestCase;

class InventoryTransferTest extends TestCase
{
    private $bulkInventoryTransfer;

    private $searchCriteriaBuilder;

    private $sourceItemRepository;

    private $defaultSourceProvider;

    public function setUp()
    {
        parent::setUp();
        $this->bulkInventoryTransfer = Bootstrap::getObjectManager()->get(BulkInventoryTransferInterface::class);
        $this->searchCriteriaBuilder = Bootstrap::getObjectManager()->get(SearchCriteriaBuilder::class);
        $this->sourceItemRepository = Bootstrap::getObjectManager()->get(SourceItemRepositoryInterface::class);
        $this->defaultSourceProvider = Bootstrap::getObjectManager()->get(DefaultSourceProviderInterface::class);
    }

    private function getSourceItemCodesBySku(string $sku): array
    {
        $searchCriteria = $this->searchCriteriaBuilder
            ->addFilter(SourceItemInterface::SKU, $sku)
            ->create();
        $sourceItems = $this->sourceItemRepository->getList($searchCriteria)->getItems();

        $res = [];
        foreach ($sourceItems as $sourceItem) {
            $res[] = $sourceItem->getSourceCode();
        }

        return $res;
    }

    private function getSourceItem(string $sku, string $sourceCode): ?SourceItemInterface
    {
        $searchCriteria = $this->searchCriteriaBuilder
            ->addFilter(SourceItemInterface::SKU, $sku)
            ->addFilter(SourceItemInterface::SOURCE_CODE, $sourceCode)
            ->create();
        $sourceItems = $this->sourceItemRepository->getList($searchCriteria)->getItems();

        if (empty($sourceItems)) {
            return null;
        }

        return current($sourceItems);
    }

    public function testBulkInventoryTransferAndUnassign()
    {
        $skus = ['SKU-1'];

        $this->bulkInventoryTransfer->execute($skus, 'eu-1', 'eu-2', true);

        $sourceItemCodes = $this->getSourceItemCodesBySku('SKU-1');
        self::assertNotContains(
            'eu-1',
            $sourceItemCodes,
            'Products are not unassigned from origin source'
        );

        self::assertEquals(
            8.5,
            $this->getSourceItem('SKU-1', 'eu-2')->getQuantity(),
            'Items were not correctly moved to destination source'
        );
    }

    public function testBulkInventoryTransferWithOutOfStockOrigin()
    {
        $skus = ['SKU-1'];

        $previousSourceStatus = $this->getSourceItem('SKU-1', 'eu-3')->getStatus();

        $this->bulkInventoryTransfer->execute($skus, 'eu-3', 'eu-1', true);

        $sourceItemCodes = $this->getSourceItemCodesBySku('SKU-1');
        self::assertContains(
            'eu-1',
            $sourceItemCodes,
            'Items with out of stock quantity are not transferred to destination'
        );

        self::assertEquals(
            15.5,
            $this->getSourceItem('SKU-1', 'eu-1')->getQuantity(),
            'Items with out of stock quantity were not correctly moved to destination source'
        );
        self::assertEquals(
            $previousSourceStatus,
            $this->getSourceItem('SKU-1', 'eu-1')->getStatus(),
            'Stock status was not copied to existing source when origin was out of stock'
        );
    }

    public function testBulkInventoryTransferToNewSource()
    {
        $skus = ['SKU-1'];

        $previousSourceStatus = $this->getSourceItem('SKU-1', 'eu-1')->getStatus();

        $this->bulkInventoryTransfer->execute($skus, 'eu-1', 'us-1', false);

        $sourceItemCodes = $this->getSourceItemCodesBySku('SKU-1');
        self::assertContains(
            'us-1',
            $sourceItemCodes,
            'Products are not assigned to a new source if transferred'
        );

        self::assertEquals(
            0,
            $this->getSourceItem('SKU-1', 'eu-1')->getQuantity(),
            'Items were not removed from source during inventory transfer'
        );

        self::assertEquals(
            5.5,
            $this->getSourceItem('SKU-1', 'us-1')->getQuantity(),
            'Items were not correctly moved to destination source'
        );
        self::assertEquals(
            $previousSourceStatus,
            $this->getSourceItem('SKU-1', 'us-1')->getStatus(),
            'Destination stock status should have the same configuration as the origin'
        );
    }

    public function testBulkInventoryTransferFromUnassignedOriginSource()
    {
        $skus = ['SKU-1'];

        $previousDestinationStatus = $this->getSourceItem('SKU-1', 'eu-1')->getStatus();

        $this->bulkInventoryTransfer->execute($skus, 'us-1', 'eu-1', false);

        $sourceItemCodes = $this->getSourceItemCodesBySku('SKU-1');
        self::assertNotContains(
            'us-1',
            $sourceItemCodes,
            'Products are assigned to origin source even if they were not'
        );

        self::assertEquals(
            5.5,
            $this->getSourceItem('SKU-1', 'eu-1')->getQuantity(),
            'Destination source is changed even if origin source was not assigned'
        );
        self::assertEquals(
            $previousDestinationStatus,
            $this->getSourceItem('SKU-1', 'eu-1')->getStatus(),
            'Stock status on destination was changed even if the source was not assigned'
        );
    }

    public function testBulkInventoryTransferToAssignedSource()
    {
        $skus = ['SKU-1'];

        $previousSourceStatus = $this->getSourceItem('SKU-1', 'eu-1')->getStatus();

        $this->bulkInventoryTransfer->execute($skus, 'eu-1', 'eu-2', false);

        $sourceItemCodes = $this->getSourceItemCodesBySku('SKU-1');
        self::assertContains(
            'eu-2',
            $sourceItemCodes,
            'Products are not assigned to destination source'
        );

        self::assertEquals(
            0,
            $this->getSourceItem('SKU-1', 'eu-1')->getQuantity(),
            'Items were not removed from source during inventory transfer'
        );
        self::assertEquals(
            SourceItemInterface::STATUS_OUT_OF_STOCK,
            $this->getSourceItem('SKU-1', 'eu-1')->getStatus(),
            'Origin source was not set to out of stock'
        );

        self::assertNotEquals(
            5.5,
            $this->getSourceItem('SKU-1', 'eu-2')->getQuantity(),
            'Item quantity on destination source is not incremented by origin source'
        );
        self::assertEquals(
            8.5,
            $this->getSourceItem('SKU-1', 'eu-2')->getQuantity(),
            'Items were not correctly moved to destination source'
        );
        self::assertEquals(
            $previousSourceStatus,
            $this->getSourceItem('SKU-1', 'eu-2')->getStatus(),
            'Stock status on destination should be the same as the origin'
        );
    }
}