src/App/EventListener/Client/Store/StoreMoveListener.php line 25

Open in your IDE?
  1. <?php
  3. namespace App\EventListener\Client\Store;
  5. use App\Entity\Client\Store\StoreHeader;
  6. use App\Entity\Client\Store\StoreMove;
  7. use App\EventListener\GenericEvent;
  8. use App\Service\AppManager;
  9. use App\Service\Client\Store\StoreHeaderManager;
  10. use Symfony\Component\HttpFoundation\JsonResponse;
  11. use Symfony\Component\HttpFoundation\Response;
  13. class StoreMoveListener
  14. {
  16.     private $appManager;
  17.     private $storeHeaderManager;
  19.     public function __construct(StoreHeaderManager $storeHeaderManager, AppManager $appManager)
  20.     {
  21.         $this->appManager = $appManager;
  22.         $this->storeHeaderManager = $storeHeaderManager;
  23.     }
  25.     public function addMove(GenericEvent $genericEvent)
  26.     {
  27.         $storeMove = $genericEvent->getSubject();
  28.         if (!$storeMove instanceof StoreMove) {
  29.             return;
  30.         }
  32.         $storeHeader = $storeMove->getHeader();
  33.         if (!$storeHeader instanceof StoreHeader) {
  34.             return;
  35.         }
  37.         if (!$storeHeader->isTemporary()){
  38.             $genericEvent->setResponse(new JsonResponse(json_encode(['message' => 'Header is locked', 'errorCode' => '1001']), 403, [], true));
  39.             $genericEvent->stopPropagation();
  40.             return;
  41.         }
  43.         $allowedTypes = [StoreHeader::STORE_HEADER_WAREHOUSE_RECEIPT, StoreHeader::STORE_HEADER_WAREHOUSE_RECEIPT_RETURN, StoreHeader::STORE_HEADER_STORE_TRANSFER];
  44.         if (!in_array($storeHeader->getType(), $allowedTypes)) {
  45.             return;
  46.         }
  48.         $haveProductInMoves = $storeHeader->getMoves()->filter(function (StoreMove $existStoreMove) use ($storeMove) {
  49.             return $existStoreMove->getProduct()->getId() === $storeMove->getProduct()->getId() && $existStoreMove->getId() !== $storeMove->getId();
  50.         });
  52.         foreach ($haveProductInMoves as $haveProductInMove) {
  53.             $storeHeader->removeMove($haveProductInMove);
  54.         }
  56.         $this->appManager->eventPersist($storeHeader, AppManager::UPDATE, 'move_add');
  58.         $genericEvent->setResponse(new Response($storeMove->getId(), 201));
  59.         $genericEvent->stopPropagation();
  61.     }
  63.     public function removeMove(GenericEvent $genericEvent)
  64.     {
  65.         $storeMove = $genericEvent->getSubject();
  66.         if (!$storeMove instanceof StoreMove) {
  67.             return;
  68.         }
  70.         $storeHeader = $storeMove->getHeader();
  71.         if (!$storeHeader instanceof StoreHeader) {
  72.             return;
  73.         }
  75.         $this->isLocked($storeHeader, $genericEvent);
  76.         if ($genericEvent->isPropagationStopped()){
  77.             return;
  78.         }
  80.         if(!StoreHeaderManager::isWarehouseType($storeHeader->getType())){
  81.             return;
  82.         }
  84.         $haveProductInMoves = $storeHeader->getMoves()->filter(function (StoreMove $existStoreMove) use ($storeMove) {
  85.             return $existStoreMove->getProduct()->getId() === $storeMove->getProduct()->getId() && $existStoreMove->getId() !== $storeMove->getId();
  86.         });
  88.         foreach ($haveProductInMoves as $haveProductInMove) {
  89.             $storeHeader->removeMove($haveProductInMove);
  90.         }
  92.         $this->appManager->eventPersist($storeHeader, AppManager::UPDATE, 'move_delete');
  94.         $genericEvent->setResponse(new Response(null, 204));
  95.         $genericEvent->stopPropagation();
  96.     }
  98.     private function isLocked(StoreHeader $storeHeader, GenericEvent $genericEvent)
  99.     {
  100.         if (!$storeHeader->isTemporary()){
  101.             $genericEvent->setResponse(new JsonResponse(json_encode(['message' => 'Header is locked', 'errorCode' => '1001']), 403, [], true));
  102.             $genericEvent->stopPropagation();
  103.         }
  104.     }
  106. }