src/EventSubscriber/EasyAdminSubscriber.php line 246

  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Order;
  6. use App\Entity\Parcel;
  7. use App\Entity\Product;
  8. use App\Entity\ReceivingOrder;
  9. use App\Entity\Scan\ScanOrderProduct;
  10. use App\Entity\Shipment;
  11. use App\Entity\ShopIntegrationPlatform\SipSettings;
  12. use App\Event\OrderCreatedEvent;
  13. use App\Event\OrderRemovedEvent;
  14. use EasyCorp\Bundle\EasyAdminBundle\Event\AfterEntityDeletedEvent;
  15. use EasyCorp\Bundle\EasyAdminBundle\Event\AfterEntityPersistedEvent;
  16. use EasyCorp\Bundle\EasyAdminBundle\Event\AfterEntityUpdatedEvent;
  17. use App\Service\{InventorySingleProductService,
  18.     Logger\CronLoggerService,
  19.     OrderService,
  20.     InventoryService,
  21.     ReceivingOrderService,
  22.     ScanOrderService,
  23.     ShipmentService,
  24.     TaskService,
  25.     TranslatorService
  26. };
  27. use Doctrine\ORM\EntityManagerInterface;
  28. use EasyCorp\Bundle\EasyAdminBundle\Event\BeforeCrudActionEvent;
  29. use EasyCorp\Bundle\EasyAdminBundle\Event\BeforeEntityPersistedEvent;
  30. use EasyCorp\Bundle\EasyAdminBundle\Event\BeforeEntityUpdatedEvent;
  31. use Exception;
  32. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  33. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  34. use Symfony\Component\HttpFoundation\RequestStack;
  35. use App\EventSubscriber\Traits\{OrderHandlerTrait,
  36.     ParcelHandlerTrait,
  37.     ShipmentHandlerTrait,
  38.     ProductHandlerTrait,
  39.     ScanOrderProductHandlerTrait,
  40.     ShopIntegrationPlatform\SipSettingsProductHandlerTrait,
  41.     ShopIntegrationPlatform\SipSettingsHandlerTrait,
  42.     ReceivingOrderHandlerTrait
  43. };
  44. use App\Service\ShipmentLabelService;
  46. class EasyAdminSubscriber implements EventSubscriberInterface
  47. {
  48.     use OrderHandlerTrait, ParcelHandlerTrait, ShipmentHandlerTrait,
  49.         ProductHandlerTrait, ScanOrderProductHandlerTrait,
  50.         SipSettingsHandlerTrait, SipSettingsProductHandlerTrait, ReceivingOrderHandlerTrait;
  52.     /**
  53.      * @param EntityManagerInterface $em
  54.      * @param RequestStack $requestStack
  55.      * @param TranslatorService $translatorService
  56.      * @param OrderService $orderService
  57.      * @param ShipmentService $shipmentService
  58.      * @param InventoryService $inventoryService
  59.      * @param EventDispatcherInterface $dispatcher
  60.      * @param InventorySingleProductService $inventorySingleProductService
  61.      * @param ShipmentLabelService $shipmentLabelService
  62.      * @param TaskService $taskService
  63.      * @param ReceivingOrderService $receivingOrderService
  64.      * @param ScanOrderService $scanOrderService
  65.      * @param CronLoggerService $cronLoggerService
  66.      */
  67.     public function __construct(
  68.         protected EntityManagerInterface        $em,
  69.         protected RequestStack                  $requestStack,
  70.         protected TranslatorService             $translatorService,
  71.         protected OrderService                  $orderService,
  72.         protected ShipmentService               $shipmentService,
  73.         protected InventoryService              $inventoryService,
  74.         protected EventDispatcherInterface      $dispatcher,
  75.         protected InventorySingleProductService $inventorySingleProductService,
  76.         protected ShipmentLabelService          $shipmentLabelService,
  77.         protected TaskService                   $taskService,
  78.         protected ReceivingOrderService         $receivingOrderService,
  79.         protected ScanOrderService              $scanOrderService,
  80.         protected CronLoggerService             $cronLoggerService,
  81.     )
  82.     {
  83.     }
  85.     /**
  86.      * @return array
  87.      */
  88.     public static function getSubscribedEvents(): array
  89.     {
  90.         return [
  91.             BeforeCrudActionEvent::class => ['beforeCrudAction'],
  92.             AfterEntityPersistedEvent::class => ['afterEntityPersistedAction'],
  93.             BeforeEntityPersistedEvent::class => ['beforeEntityPersistedAction'],
  94.             BeforeEntityUpdatedEvent::class => ['beforeEntityUpdatedAction'],
  95.             AfterEntityDeletedEvent::class => ['afterEntityDeletedAction'],
  96.             AfterEntityUpdatedEvent::class => ['afterEntityUpdatedAction'],
  97.         ];
  98.     }
  100.     /**
  101.      * @throws Exception
  102.      */
  103.     public function beforeCrudAction(BeforeCrudActionEvent $event)
  104.     {
  105.         $context = $event->getAdminContext();
  106.         $entity = $context->getEntity()->getInstance();
  108.         if ($entity instanceof Order) {
  109.             $this->handleBeforeOrderDelete($event, $entity);
  110.             $this->handleBeforeParcelDelete($event, $this->getParcelFromOrder($entity));
  111.             $this->handleOrder($event, $entity);
  112.             $this->handleImpCourierApiCity($entity);
  113.             return;
  114.         }
  116.         if ($entity instanceof Parcel) {
  117.             $this->handleBeforeParcelDelete($event, $entity);
  118.             return;
  119.         }
  121.         if ($entity instanceof ReceivingOrder) {
  122.             $this->processReceivingOrderBeforeUpdate($event, $entity);
  123.             $this->processReceivingOrderBeforeDelete($event, $entity);
  124.         }
  125.     }
  127.     /**
  128.      * @throws Exception
  129.      */
  130.     public function afterEntityPersistedAction(AfterEntityPersistedEvent $event)
  131.     {
  132.         $entity = $event->getEntityInstance();
  134.         /** On create event */
  135.         if ($entity instanceof Order && !$entity->getPreviousStatus()) {
  136.             $event = new OrderCreatedEvent($entity);
  137.             $this->dispatcher->dispatch($event);
  138.             return;
  139.         }
  141.         if ($entity instanceof Product) {
  142.             $this->handleProductPersisted($entity);
  143.         }
  144.     }
  146.     /**
  147.      * @param BeforeEntityPersistedEvent $event
  148.      * @return void
  149.      */
  150.     public function beforeEntityPersistedAction(BeforeEntityPersistedEvent $event): void
  151.     {
  152.         $entity = $event->getEntityInstance();
  154.         if ($entity instanceof Order) {
  155.             $this->handleImpCourierApiCity($entity);
  156.             $this->changeOrderStatus($entity);
  157.             return;
  158.         }
  160.         if ($entity instanceof Shipment) {
  161.             $this->changeShipmentStatus($entity);
  162.         }
  163.     }
  165.     /**
  166.      * @param BeforeEntityUpdatedEvent $event
  167.      * @return void
  168.      * @throws Exception
  169.      */
  170.     public function beforeEntityUpdatedAction(BeforeEntityUpdatedEvent $event): void
  171.     {
  172.         $entity = $event->getEntityInstance();
  174.         if ($entity instanceof Order) {
  175.             $this->logBeforeUpdatingDeliveredOrderEvent($entity);
  176.             $this->processInventoryOfOrderAfterSaving();
  177.             $this->changeOrderStatus($entity);
  178.             return;
  179.         }
  181.         if ($entity instanceof Shipment) {
  182.             $this->changeShipmentStatus($entity);
  183.             return;
  184.         }
  186.         if ($entity instanceof Product) {
  187.             $this->handleProductUpdating($entity);
  188.             return;
  189.         }
  191.         if ($entity instanceof SipSettings) {
  192.             $this->handleSipSettingsSaving($entity);
  193.         }
  194.     }
  196.     /**
  197.      * @param AfterEntityDeletedEvent $event
  198.      * @return void
  199.      * @throws Exception
  200.      */
  201.     public function afterEntityDeletedAction(AfterEntityDeletedEvent $event): void
  202.     {
  203.         try {
  204.             $entity = $event->getEntityInstance();
  206.             if ($entity instanceof Order) {
  207.                 $this->inventoryService->cancelOrderProductsReservation($entity);
  208.                 $this->scanOrderService->removeOrderFromScanning($entity);
  209.                 $this->processDeletedOrder($entity);
  210.                 $this->dispatcher->dispatch(new OrderRemovedEvent($entity));
  211.                 return;
  212.             }
  214.             if ($entity instanceof Parcel) {
  215.                 $this->processDeletedParcel($entity);
  216.                 return;
  217.             }
  219.             if ($entity instanceof Product) {
  220.                 $this->removeSipSettingsProduct($entity);
  221.                 return;
  222.             }
  224.             if ($entity instanceof ReceivingOrder) {
  225.                 $this->processReceivingOrderAfterDelete($entity);
  226.                 return;
  227.             }
  229.             if ($entity instanceof Shipment) {
  230.                 $this->processDeletedShipment($entity);
  231.             }
  233.             /**
  234.              * TODO: SIP - Add removing webhooks on removing connection!
  235.              */
  236.         } catch (\Exception $ex) {
  237.             $this->addFlash('danger', $ex->getMessage());
  238.         }
  239.     }
  241.     /**
  242.      * @param AfterEntityUpdatedEvent $event
  243.      * @return void
  244.      * @throws Exception
  245.      */
  246.     public function afterEntityUpdatedAction(AfterEntityUpdatedEvent $event): void
  247.     {
  248.         try {
  249.             $entity = $event->getEntityInstance();
  251.             if ($entity instanceof Order) {
  252.                 $this->processOrderCourierAfterUpdating($entity);
  253.                 return;
  254.             }
  256.             if ($entity instanceof ScanOrderProduct) {
  257.                 $this->processScanOrderStatus($entity);
  258.                 return;
  259.             }
  261.             if ($entity instanceof ReceivingOrder) {
  262.                 $this->processReceivingOrderAfterUpdate($entity);
  263.             }
  264.         } catch (\Exception $ex) {
  265.             $this->addFlash('danger', $ex->getMessage());
  266.         }
  267.     }
  269.     /** ================================ Additional functions ================================ */
  271.     /**
  272.      * @param string $type
  273.      * @param string $message
  274.      * @return void
  275.      */
  276.     private function addFlash(string $type, string $message): void
  277.     {
  278.         if (!$this->requestStack->getSession()) {
  279.             return;
  280.         }
  282.         $translated = $this->translatorService->trans($message);
  284.         if ($translated === $message) {
  285.             $translated = $this->translatorService->trans($message, [], 'validators');
  286.         }
  288.         $this->requestStack->getSession()->getFlashBag()->add($type, $translated);
  289.     }
  290. }