src/EventListener/OperationOrderWorkflowListener.php line 44

Open in your IDE?
  1. <?php
  3. namespace App\EventListener;
  5. use App\Entity\OperationOrder;
  6. use App\Entity\OperationOrderStepVersion;
  7. use App\Service\DataLogger;
  8. use App\Service\OperationOrderService;
  9. use App\Service\QuotaService;
  10. use App\Service\User as UserService;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\Workflow\Event\Event;
  15. class OperationOrderWorkflowListener implements EventSubscriberInterface
  16. {
  17.     private DataLogger $dataLogger;
  18.     private EntityManagerInterface $entityManager;
  19.     private OperationOrderService $operationOrderService;
  20.     private QuotaService $quotaService;
  21.     private UserService $userService;
  23.     public function __construct(EntityManagerInterface $entityManager, UserService $userService, DataLogger $dataLogger, OperationOrderService $operationOrderService, QuotaService $quotaService)
  24.     {
  25.         $this->entityManager = $entityManager;
  26.         $this->dataLogger = $dataLogger;
  27.         $this->operationOrderService = $operationOrderService;
  28.         $this->quotaService = $quotaService;
  29.         $this->userService = $userService;
  30.     }
  32.     public function onEnter(Event $event): void
  33.     {
  34.     }
  36.     public function onTransition(Event $event): void
  37.     {
  38.     }
  40.     public function onEntered(Event $event): void
  41.     {
  42.     }
  44.     public function onCompleted(Event $event): void
  45.     {
  46.         $transitionName = $event->getTransition()->getName();
  47.         $user = $this->userService->getUser();
  48.         $wsResponse = 'none';
  49.         /** @var OperationOrder $operationOrder */
  50.         $operationOrder = $event->getSubject();
  52.         if ('toCanceled' === $transitionName) {
  53.             try {
  54.                 $oldPrice = $operationOrder->getPrice();
  55.                 $operationOrder->setPrice(0.0);
  56.                 $updatedQuota = $this->quotaService->updateQuota($operationOrder, $oldPrice);
  57.             } catch (\Exception) {
  58.                 // echo 'Exception reçue : ',  $e->getMessage(), "\n";
  59.             }
  60.         }
  61.         if (null === $user) {
  62.             $user = $operationOrder->getUser();
  63.         }
  64.         $this->entityManager->persist($operationOrder);
  66.         $operationOrderStepVersion = new OperationOrderStepVersion();
  67.         $operationOrderStepVersion->setDate(new \DateTime());
  68.         $operationOrderStepVersion->setStep(strtolower(substr((string) $transitionName, 2)));
  69.         $operationOrderStepVersion->setUser($user);
  70.         $operationOrderStepVersion->setOperationOrder($operationOrder);
  71.         $this->entityManager->persist($operationOrderStepVersion);
  72.         $this->entityManager->flush();
  73.         $this->dataLogger->add('WS from api for transision : ' . $transitionName, 'operationOrderWorkflow', $event->getSubject(), 'info');
  74.         $this->operationOrderService->notifyAgency($operationOrder, $transitionName);
  75.     }
  77.     public function onLeave(Event $event): void
  78.     {
  79.     }
  81.     public static function getSubscribedEvents(): array
  82.     {
  83.         return [
  84.             'workflow.operation_order_step.leave'     => 'onLeave',
  85.             'workflow.operation_order_step.enter'     => 'onEnter',
  86.             'workflow.operation_order_step.completed' => 'onCompleted',
  87.             'workflow.operation_order_step.entered'   => 'onEntered',
  88.         ];
  89.     }
  90. }