97 lines
2.9 KiB
PHP
Executable File
97 lines
2.9 KiB
PHP
Executable File
<?php
|
|
|
|
namespace JR\NetSuite\Observer;
|
|
|
|
use JR\NetSuite\Logger\Logger;
|
|
use JR\NetSuite\Model\ResourceModel\RmaQueue\CollectionFactory;
|
|
use JR\NetSuite\Model\RmaQueueFactory;
|
|
|
|
class UpdateRmaAfter implements \Magento\Framework\Event\ObserverInterface
|
|
{
|
|
|
|
/**
|
|
* @var Logger
|
|
*/
|
|
protected $logger;
|
|
|
|
/**
|
|
* @var CollectionFactory
|
|
*/
|
|
protected $rmaQueueCollectionFactory;
|
|
|
|
/**
|
|
* @var RmaQueueFactory
|
|
*/
|
|
protected $rmaQueueFactory;
|
|
|
|
/**
|
|
* @var \Mirasvit\Rma\Api\Repository\StatusRepositoryInterface
|
|
*/
|
|
protected $statusRepository;
|
|
|
|
/**
|
|
* @var \Mirasvit\Rma\Api\Service\Rma\RmaManagementInterface
|
|
*/
|
|
private $rmaManagement;
|
|
|
|
public function __construct(
|
|
Logger $logger,
|
|
CollectionFactory $rmaQueueCollectionFactory,
|
|
RmaQueueFactory $rmaQueueFactory,
|
|
\Mirasvit\Rma\Api\Repository\StatusRepositoryInterface $statusRepository,
|
|
\Mirasvit\Rma\Api\Service\Rma\RmaManagementInterface $rmaManagement
|
|
) {
|
|
$this->logger = $logger;
|
|
$this->rmaQueueCollectionFactory = $rmaQueueCollectionFactory;
|
|
$this->rmaQueueFactory = $rmaQueueFactory;
|
|
$this->statusRepository = $statusRepository;
|
|
$this->rmaManagement = $rmaManagement;
|
|
}
|
|
|
|
public function execute(\Magento\Framework\Event\Observer $observer)
|
|
{
|
|
try {
|
|
$rma = $observer->getData('rma');
|
|
$rmaId = $rma->getId();
|
|
if (!$rmaId) {
|
|
return;
|
|
}
|
|
// if RMA status is not pending approval, do nothing
|
|
if ($this->statusRepository->get($rma->getStatusId())?->getName() !== 'Pending Approval') {
|
|
return;
|
|
}
|
|
// find RMA in queue by RMA ID
|
|
$rmaQueueCollection = $this->rmaQueueCollectionFactory->create();
|
|
$rmaQueueCollection->addFieldToFilter('rma_id', $rma->getId());
|
|
$rmaQueue = $rmaQueueCollection->getFirstItem();
|
|
|
|
// if RMA is already queued, do nothing
|
|
if ($rmaQueue?->getId()) {
|
|
return;
|
|
}
|
|
|
|
$rmaQueueCollection = $this->rmaQueueCollectionFactory->create();
|
|
$rmaQueueCollection->addFieldToFilter('status', 'processing');
|
|
|
|
$order = $this->rmaManagement->getOrder($rma);
|
|
|
|
foreach($rmaQueueCollection as $rmaQueue) {
|
|
if ($rmaQueue->getOrderIncrementId() == $order->getRealorderId()) {
|
|
return;
|
|
}
|
|
}
|
|
|
|
// if RMA is not queued, queue RMA
|
|
$rmaQueue = $this->rmaQueueFactory->create();
|
|
$data = [
|
|
'rma_id' => $rma->getId(),
|
|
'status' => 'pending',
|
|
];
|
|
$rmaQueue->setData($data);
|
|
$rmaQueue->save();
|
|
} catch (\Exception $e) {
|
|
$this->logger->error('Update RMA Queue Error: ' . $e->getMessage());
|
|
}
|
|
}
|
|
}
|