marellocommerce / magento2-marello-bridge Goto Github PK

<sequence>
    <module name="Magento_Sales"/>
 </sequence>

Magento\Rma\Model\RmaRepository
Magento\Rma\Model\ResourceModel\Item\Collection
Magento\Rma\Model\ResourceModel\Item\CollectionFactory

/**
     * {@inheritdoc}
     * @return $this
     */
    protected function getQueueCollection($curPage = 1)
    {
        $entityQueueCollection = $this->entityQueueFactory->create()->getCollection();
        $entityQueueCollection->addFilter('processed', ['eq' => 0]);
        return $entityQueueCollection->setPageSize($this->getBatchSize())->setCurPage($curPage);
    }

    /**
     * {@inheritdoc}
     * @return bool
     * @throws \Magento\Framework\Exception\LocalizedException
     */
    public function processQueue()
    {
        $allLoaded = FALSE;
        $curPage = 1;
        $i = 1;
                    
        while(!$allLoaded) {
            $collection = $this->getQueueCollection($curPage);

            if($collection->getSize() >= $i) {
                try {
                    foreach ($collection as $queueItem) {
                        $eventType = $queueItem->getEventType();
                        $processor = null;
                        if ($eventType) {
                            $processor = $this->getEntityProcessor($eventType);
                        }
                        $entityData = $this->getEntityData($queueItem);
                        $result = $processor->process($entityData);
                        var_dump($result);
                        if ($result) {
                            $queueItem->setProcessed(1);
                            $queueItem->setProcessedAt(new \DateTime('now'));
                            $this->entityQueueRepository->save($queueItem);
                        }
                        $i++;
                    }
                } catch (\Exception $e) {
                    throw new \Magento\Framework\Exception\LocalizedException(__('Could not process Queue item'));
                    return false;
                }

                $curPage++;
            } else {
                $allLoaded = TRUE;
            }
        }
        
        return true;
    }

$websiteId = $order->getStore()->getWebsite()->getId();
$customer = $this->customerRepository->get($order->getCustomerEmail(), $websiteId);