custom/plugins/DvsnReturnShipment/src/Subscriber/Core/Checkout/Order/OrderEventsSubscriber.php line 98

Open in your IDE?
  1. <?php
  3. /**
  4.  * digitvision
  5.  *
  6.  * @category  digitvision
  7.  * @package   Shopware\Plugins\DvsnReturnShipment
  8.  * @copyright (c) 2020 digitvision
  9.  */
  11. namespace Dvsn\ReturnShipment\Subscriber\Core\Checkout\Order;
  13. use Dvsn\ReturnShipment\Core\Checkout\Order\Aggregate\ReturnShipment\ReturnShipmentStruct;
  14. use Dvsn\ReturnShipment\Core\Checkout\ReturnShipment\ReturnShipmentEntity;
  15. use Dvsn\ReturnShipment\Service\DeadlineValidatorServiceInterface;
  16. use Dvsn\ReturnShipment\Service\Order\ValidatorServiceInterface;
  17. use Shopware\Core\Checkout\Order\OrderEntity;
  18. use Shopware\Core\Checkout\Order\OrderEvents;
  19. use Shopware\Core\Framework\Context;
  20. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  21. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  22. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  23. use Shopware\Core\System\SystemConfig\SystemConfigService;
  24. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  25. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  27. class OrderEventsSubscriber implements EventSubscriberInterface
  28. {
  29.     /**
  30.      * ...
  31.      *
  32.      * @var EntityRepository
  33.      */
  34.     protected $returnShipmentRepository;
  36.     /**
  37.      * ...
  38.      *
  39.      * @var EntityRepository
  40.      */
  41.     protected $returnShipmentLineItemRepository;
  43.     /**
  44.      * ...
  45.      *
  46.      * @var SystemConfigService
  47.      */
  48.     protected $systemConfigService;
  50.     /**
  51.      * ...
  52.      *
  53.      * @var ValidatorServiceInterface
  54.      */
  55.     protected $orderValidatorService;
  57.     /**
  58.      * ...
  59.      *
  60.      * @var DeadlineValidatorServiceInterface
  61.      */
  62.     protected $deadlineValidatorService;
  64.     /**
  65.      * ...
  66.      *
  67.      * @param EntityRepository $returnShipmentRepository
  68.      * @param EntityRepository $returnShipmentLineItemRepository
  69.      * @param SystemConfigService $systemConfigService
  70.      * @param ValidatorServiceInterface $orderValidatorService
  71.      * @param DeadlineValidatorServiceInterface $deadlineValidatorService
  72.      */
  73.     public function __construct(EntityRepository $returnShipmentRepository, EntityRepository $returnShipmentLineItemRepository, SystemConfigService $systemConfigService, ValidatorServiceInterface $orderValidatorService, DeadlineValidatorServiceInterface $deadlineValidatorService)
  74.     {
  75.         // set params
  76.         $this->returnShipmentRepository = $returnShipmentRepository;
  77.         $this->returnShipmentLineItemRepository = $returnShipmentLineItemRepository;
  78.         $this->systemConfigService = $systemConfigService;
  79.         $this->orderValidatorService = $orderValidatorService;
  80.         $this->deadlineValidatorService = $deadlineValidatorService;
  81.     }
  83.     /**
  84.      * {@inheritDoc}
  85.      */
  86.     public static function getSubscribedEvents(): array
  87.     {
  88.         return [
  89.             OrderEvents::ORDER_LOADED_EVENT => 'onOrdersLoaded'
  90.         ];
  91.     }
  93.     /**
  94.      * ...
  95.      *
  96.      * @param EntityLoadedEvent $event
  97.      */
  98.     public function onOrdersLoaded(EntityLoadedEvent $event): void
  99.     {
  100.         /** @var OrderEntity $orderEntity */
  101.         foreach ($event->getEntities() as $orderEntity) {
  102.             // try to find a return shipment for this order
  103.             $criteria = (new Criteria())
  104.                 ->addFilter(new EqualsFilter('orderId', $orderEntity->getId()))
  105.                 ->setLimit(1);
  107.             /** @var ReturnShipmentEntity $returnShipment */
  108.             $returnShipment = $this->returnShipmentRepository->search(
  109.                 $criteria,
  110.                 $event->getContext()
  111.             )->first();
  113.             // create a struct to extend the order
  114.             $struct = new ReturnShipmentStruct();
  115.             $struct->setStatus(($returnShipment instanceof ReturnShipmentEntity));
  116.             $struct->setId(($returnShipment instanceof ReturnShipmentEntity) ? $returnShipment->getId() : null);
  117.             $struct->setIsValid($this->isValid(
  118.                 $orderEntity,
  119.                 $returnShipment,
  120.                 $event->getContext(),
  121.                 $this->systemConfigService->get('DvsnReturnShipment.config', $orderEntity->getSalesChannelId())
  122.             ));
  124.             // add to order
  125.             $orderEntity->addExtension(
  126.                 'dvsn_return_shipment',
  127.                 $struct
  128.             );
  129.         }
  130.     }
  132.     /**
  133.      * ...
  134.      *
  135.      * @param OrderEntity $orderEntity
  136.      * @param ReturnShipmentEntity $returnShipment
  137.      * @param Context $context
  138.      * @param array $config
  139.      *
  140.      * @return bool
  141.      */
  142.     private function isValid(OrderEntity $orderEntity, ?ReturnShipmentEntity $returnShipment, Context $context, array $config): bool
  143.     {
  144.         if ($returnShipment instanceof ReturnShipmentEntity) {
  145.             return
  146.                 $this->orderValidatorService->isValid($orderEntity) &&
  147.                 $this->deadlineValidatorService->isValid($orderEntity->getId(), [
  148.                     'status' => (bool) $this->systemConfigService->get('DvsnReturnShipment.config.deadlineStatus', $orderEntity->getSalesChannelId()),
  149.                     'type' => (string) $this->systemConfigService->get('DvsnReturnShipment.config.deadlineType', $orderEntity->getSalesChannelId()),
  150.                     'daysDate' => (string) trim($this->systemConfigService->get('DvsnReturnShipment.config.deadlineDaysDate', $orderEntity->getSalesChannelId())),
  151.                     'orderDeliveryStatus' => (string) $this->systemConfigService->get('DvsnReturnShipment.config.deadlineOrderDeliveryStatus', $orderEntity->getSalesChannelId())
  152.                 ], $context);
  153.         }
  155.         return $this->orderValidatorService->isValid($orderEntity);
  156.     }
  157. }