src/Listener/ProspectQualificationWorflowListener.php line 48

Open in your IDE?
  1. <?php
  2. /**
  3.  * Created by PhpStorm.
  4.  * User: bertrand
  5.  * Date: 29/03/2019
  6.  * Time: 13:53
  7.  */
  9. namespace App\Listener;
  12. use App\Entity\Enum\ProspectOnStoreCreationModeEnum;
  13. use App\Entity\Freelancer;
  14. use App\Entity\ProspectQualification;
  15. use App\Service\DeliveryService;
  16. use App\Service\ProspectService;
  17. use Psr\Log\LoggerInterface;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Symfony\Component\Workflow\Event\Event;
  21. class ProspectQualificationWorflowListener implements EventSubscriberInterface
  22. {
  23.     private $logger;
  24.     private $deliveryService;
  25.     private $prospectService;
  27.     /**
  28.      * ProspectQualificationWorflowListener constructor.
  29.      * @param DeliveryService $deliveryService
  30.      * @param LoggerInterface $logger
  31.      */
  32.     public function __construct(DeliveryService $deliveryService, ProspectService $prospectService, LoggerInterface $logger)
  33.     {
  34.         $this->logger = $logger;
  35.         $this->deliveryService = $deliveryService;
  36.         $this->prospectService = $prospectService;
  37.     }
  39.     public static function getSubscribedEvents()
  40.     {
  41.         return [
  42.             'workflow.prospectQualification.completed.validate' => 'onValidate',
  43.             'workflow.prospectQualification.completed.reject' => 'onReject',
  44.             'workflow.prospectQualification.completed.unreach' => 'onUnreach',
  45.         ];
  46.     }
  48.     public function onValidate(Event $event)
  49.     {
  50.         $this->logger->info('ProspectQualificationWorflowListener onValidate');
  51.         $prospectQualification = $event->getSubject();
  52.         $prospect = $prospectQualification->getProspect();
  53.         $this->logger->info('ProspectQualificationWorflowListener.onValidate Prospect: ' . $prospect->getId());
  55.         $prospectQualification->setEndedAt(new \DateTime());
  57.         //set validation date
  58.         $prospectQualification->setValidatedAt(new \DateTime());
  60.         //deliver prospect
  61.         foreach ($prospect->getProspectsOnStore() as $prospectOnStore) {
  62.             $this->logger->info('Iterate on prospect ' . $prospect->getId() . ' on store ' . $prospectOnStore->getStore()->getId());
  63.             if($prospectOnStore->isWaitingQualification()){
  64.                 $this->logger->info('POS was waiting qualification->deliver');
  65.                 $this->logger->info('deliver this POS');
  66.                 $this->deliveryService->deliver($prospectOnStore);
  67.             }
  69.         }
  70.     }
  72.     public function onReject(Event $event)
  73.     {
  74.         $prospectQualification = $event->getSubject();
  75.         $prospect = $prospectQualification->getProspect();
  76.         $this->logger->info('ProspectQualificationWorflowListener.onReject Prospect: ' . $prospect->getId());
  77.         $prospectQualification->setEndedAt(new \DateTime());
  78.     }
  80.     /**
  81.      * Manage prospect unreachable
  82.      * @param Event $event
  83.      */
  84.     public function onUnReach(Event $event)
  85.     {
  86.         $prospectQualification = $event->getSubject();
  87.         $prospect = $prospectQualification->getProspect();
  88.         $this->logger->info('ProspectQualificationWorflowListener.onUnReach Prospect: ' . $prospect->getId());
  89.         $prospectQualification->setEndedAt(new \DateTime());
  90.         $this->prospectService->deliverProspectOnStoreBelongingToADifferentPartner($prospect, ProspectOnStoreCreationModeEnum::UNREACH);
  92.     }
  93. }