shipmentrepository.php

<?php
 
namespace Bitrix\Sale\Repository;
 
use Bitrix\Sale;
 
final class ShipmentRepository
{
    private static $instance;
 
    private function __construct()
    {}
 
    public static function getInstance(): ShipmentRepository
    {
        if (is_null(static::$instance))
        {
            static::$instance = new ShipmentRepository();
        }
 
        return static::$instance;
    }
 
    public function getById(int $id): ?Sale\Shipment
    {
        $shipmentClass = Sale\Registry::getInstance(Sale\Registry::REGISTRY_TYPE_ORDER)->getShipmentClassName();
 
        $shipmentRow = $shipmentClass::getList([
            'select' => ['ID', 'ORDER_ID'],
            'filter' => [
                '=ID' => $id
            ]
        ])->fetch();
        if (!$shipmentRow)
        {
            return null;
        }
 
        return static::getInstance()->getByRow($shipmentRow);
    }
 
    public function getByIds(array $ids): array
    {
        $result = [];
 
        $shipmentClass = Sale\Registry::getInstance(Sale\Registry::REGISTRY_TYPE_ORDER)->getShipmentClassName();
 
        $shipmentList = $shipmentClass::getList([
            'select' => ['ID', 'ORDER_ID'],
            'filter' => [
                '=ID' => $ids
            ]
        ]);
 
        while ($shipmentRow = $shipmentList->fetch())
        {
            $shipment = static::getInstance()->getByRow($shipmentRow);
            if (is_null($shipment))
            {
                continue;
            }
 
            $result[] = $shipment;
        }
 
        return $result;
    }
 
    private function getByRow(array $shipmenRow): ?Sale\Shipment
    {
        $orderClassName = Sale\Registry::getInstance(Sale\Registry::REGISTRY_TYPE_ORDER)->getOrderClassName();
 
        $order = $orderClassName::load($shipmenRow['ORDER_ID']);
        if ($order === null)
        {
            return null;
        }
 
        $shipmentCollection = $order->getShipmentCollection();
 
        foreach ($shipmentCollection as $shipment)
        {
            if ($shipment->getId() !== (int)$shipmenRow['ID'])
            {
                continue;
            }
 
            return $shipment;
        }
 
        return null;
    }
}