src/EventSubscriber/StatusSubscriber.php line 87

  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Logger\CronLogger;
  6. use App\Entity\Order;
  7. use App\Entity\Shipment;
  8. use App\Event\OrderStatusChangedEvent;
  9. use App\Event\ReceivingOrderStatusChangedEvent;
  10. use App\Event\ReturnOrderStatusChangedEvent;
  11. use App\Event\ShipmentStatusChangedEvent;
  12. use App\Service\InventoryService;
  13. use App\Service\Logger\CronLoggerService;
  14. use App\Service\OrderService;
  15. use App\Service\ReturnOrderService;
  16. use App\Service\ShipmentLabelService;
  17. use App\Service\ShipmentService;
  18. use App\Service\ScanOrderService;
  19. use Doctrine\ORM\EntityManagerInterface;
  20. use Exception;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. use App\EventSubscriber\Traits\OrderStatusHandlerTrait;
  24. class StatusSubscriber implements EventSubscriberInterface
  25. {
  26.     use OrderStatusHandlerTrait;
  28.     /**
  29.      * @param EntityManagerInterface $em
  30.      * @param OrderService $orderService
  31.      * @param ShipmentService $shipmentService
  32.      * @param ShipmentLabelService $shipmentLabelService
  33.      * @param InventoryService $inventoryService
  34.      * @param ReturnOrderService $returnOrderService
  35.      * @param ScanOrderService $orderScanningService
  36.      * @param CronLoggerService $cronLoggerService
  37.      */
  38.     public function __construct(
  39.         private readonly EntityManagerInterface $em,
  40.         private readonly OrderService           $orderService,
  41.         private readonly ShipmentService        $shipmentService,
  42.         private readonly ShipmentLabelService   $shipmentLabelService,
  43.         private readonly InventoryService       $inventoryService,
  44.         private readonly ReturnOrderService     $returnOrderService,
  45.         private readonly ScanOrderService       $orderScanningService,
  46.         private readonly CronLoggerService      $cronLoggerService
  47.     )
  48.     {
  49.     }
  51.     /**
  52.      * @return array
  53.      */
  54.     public static function getSubscribedEvents(): array
  55.     {
  56.         return [
  57.             ReceivingOrderStatusChangedEvent::class => ['receivingOrderStatusChangedAction'],
  58.             OrderStatusChangedEvent::class => ['orderStatusChangedAction'],
  59.             ShipmentStatusChangedEvent::class => ['shipmentStatusChangedAction'],
  60.             ReturnOrderStatusChangedEvent::class => ['returnOrderStatusChangedAction'],
  61.         ];
  62.     }
  64.     /**
  65.      * @throws Exception
  66.      */
  67.     public function receivingOrderStatusChangedAction(ReceivingOrderStatusChangedEvent $event)
  68.     {
  69.         $receivingOrder = $event->getReceivingOrder();
  71.         if ($receivingOrder->isArrivedStatus()) {
  72.             foreach ($receivingOrder->getReceivingOrderItems() as $orderItem) {
  73.                 $this->inventoryService->refillProduct(
  74.                     $orderItem->getProduct(),
  75.                     $orderItem->getQuantity()
  76.                 );
  78.                 $this->orderService->activateNotEnoughReservationQuantityOrders($orderItem->getProduct());
  79.             }
  80.         }
  81.     }
  83.     /**
  84.      * @noinspection PhpUnused
  85.      * @throws Exception
  86.      */
  87.     public function orderStatusChangedAction(OrderStatusChangedEvent $event): void
  88.     {
  89.         $order = $event->getOrder();
  91.         if ($order->isPendingStatus()) {
  92.             $this->inventoryService->orderProductsReservation($order);
  93.             return;
  94.         }
  96.         if ($order->isProcessingStatus()) {
  97.             $this->inventoryService->orderProductsReservation($order);
  98.             $this->moveOrderToPickingStatus($order);
  99.             return;
  100.         }
  102.         if ($order->isPickingStatus()) {
  103.             $this->handleChangedOrderStatusToPicking($order);
  104.             return;
  105.         }
  107.         if ($order->isCompletedStatus()) {
  108.             $this->handleChangedOrderStatusToCompleted($order);
  109.             return;
  110.         }
  112.         if ($order->isDeliveredStatus()) {
  113.             $this->shipmentService->fillOrderDeliveredAt($order);
  114.             foreach ($order->getShipments() as $shipment) {
  115.                 $this->shipmentService->changeStatus($shipment, Shipment::STATUS_DELIVERED);
  116.             }
  117.             return;
  118.         }
  120.         if ($order->isReturnedStatus()) {
  121.             $this->handleChangedOrderStatusToReturned($order);
  122.             return;
  123.         }
  125.         if ($order->isUnsuccessfulStatus()
  126.             || $order->isCanceledStatus()
  127.             || $order->isDuplicateStatus()
  128.             || $order->isInvalidDeliveryDataStatus()
  129.         ) {
  130.             try {
  131.                 $this->inventoryService->cancelOrderProductsReservation($order);
  132.             } catch (\Exception $exception) {
  133.                 $this->cronLoggerService->addLog(
  134.                     CronLogger::COMMAND_INVENTORY_UPDATED,
  135.                     "Order #"
  136.                     . $order->getId()
  137.                     . ": "
  138.                     . $exception->getMessage()
  139.                     . ", stack trace: "
  140.                     . $exception->getTraceAsString()
  141.                     . ", \ndebug trace: "
  142.                     . json_encode(debug_backtrace()),
  143.                     CronLogger::STATUS_FAILED,
  144.                     $order->getShop(),
  145.                 );
  146.             }
  147.         }
  149.         if ($order->isInvalidDeliveryDataStatus()
  150.             && $order->getPreviousStatus()
  151.             && $order->getPreviousStatus() === Order::STATUS_PICKING
  152.         ) {
  153.             $this->rollBackAlreadyPickedOrder($order);
  154.         }
  155.     }
  157.     /**
  158.      * @throws Exception
  159.      */
  160.     public function shipmentStatusChangedAction(ShipmentStatusChangedEvent $event)
  161.     {
  162.         $shipment = $event->getShipment();
  163.         $order = $shipment->getOrder();
  165.         if ($shipment->isOnItsWayStatus()) {
  166.             $this->shipmentService->createShipmentProducts($shipment);
  167.             return;
  168.         }
  170.         if ($shipment->isAcceptedStatus()) {
  171.             $this->shipmentService->fillApiAcceptedAt($order);
  172.             return;
  173.         }
  175.         if ($shipment->isDeliveredStatus() && $order->isAllShipmentDelivered()) {
  176.             $this->orderService->changeStatus($order, Order::STATUS_DELIVERED);
  177.             return;
  178.         }
  180.         if ($shipment->isReturnedStatus() && $order->isAllShipmentReturned()) {
  181.             $this->orderService->changeStatus($order, Order::STATUS_RETURNED);
  182.             return;
  183.         }
  185.         if ($shipment->isUnsuccessfulStatus()) {
  186.             $this->orderService->changeStatus($order, Order::STATUS_UNSUCCESSFUL);
  187.         }
  188.     }
  190.     /**
  191.      * @throws Exception
  192.      */
  193.     public function returnOrderStatusChangedAction(ReturnOrderStatusChangedEvent $event)
  194.     {
  195.         $returnOrder = $event->getReturnOrder();
  197.         if ($returnOrder->isConfirmedStatus()) {
  198.             foreach ($returnOrder->getReturnOrderProducts() as $returnOrderProduct) {
  199.                 $this->inventoryService->refillProduct(
  200.                     $returnOrderProduct->getProduct(),
  201.                     $returnOrderProduct->getQuantity()
  202.                 );
  204.                 $this->orderService->activateNotEnoughReservationQuantityOrders($returnOrderProduct->getProduct());
  205.             }
  206.         }
  207.     }
  208. }