src/Listener/ProspectOnStoreQualificationWorkflowListener.php line 61

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\ProspectOnStore;
  15. use App\Entity\ProspectQualification;
  16. use App\Repository\AcquisitionModeRepository;
  17. use App\Service\DeliveryService;
  18. use App\Service\ProspectOnStoreQualificationService;
  19. use App\Service\ProspectService;
  20. use Psr\Log\LoggerInterface;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  22. use Symfony\Component\Workflow\Event\Event;
  24. class ProspectOnStoreQualificationWorkflowListener implements EventSubscriberInterface
  25. {
  26.     private LoggerInterface $logger;
  27.     private DeliveryService $deliveryService;
  28.     private ProspectService $prospectService;
  29.     private AcquisitionModeRepository $acquisitionModeRepository;
  31.     /**
  32.      * ProspectQualificationWorkflowListener constructor.
  33.      * @param DeliveryService $deliveryService
  34.      * @param ProspectService $prospectService
  35.      * @param ProspectOnStoreQualificationService $prospectOnStoreQualificationService
  36.      * @param AcquisitionModeRepository $acquisitionModeRepository
  37.      * @param LoggerInterface $logger
  38.      */
  39.     public function __construct(
  40.         DeliveryService $deliveryService,
  41.         ProspectService $prospectService,
  42.         ProspectOnStoreQualificationService $prospectOnStoreQualificationService,
  43.         AcquisitionModeRepository $acquisitionModeRepository,
  44.         LoggerInterface $logger)
  45.     {
  46.         $this->logger = $logger;
  47.         $this->deliveryService = $deliveryService;
  48.         $this->prospectService = $prospectService;
  49.         $this->acquisitionModeRepository = $acquisitionModeRepository;
  50.     }
  52.     public static function getSubscribedEvents(): array
  53.     {
  54.         return [
  55.             'workflow.prospectOnStoreQualification.completed.validate' => 'onValidate',
  56.             'workflow.prospectOnStoreQualification.completed.reject' => 'onReject',
  57.             'workflow.prospectOnStoreQualification.completed.unreach' => 'onUnreach',
  58.         ];
  59.     }
  61.     public function onValidate(Event $event)
  62.     {
  63.         $this->logger->info('ProspectOnStoreQualificationWorflowListener onValidate');
  64.         $prospectOnStoreQualification = $event->getSubject();
  65.         $prospectOnStore = $prospectOnStoreQualification->getProspectOnStore();
  66.         $this->logger->info('ProspectOnStoreQualificationWorflowListener.onValidate POS: ' . $prospectOnStore->getId());
  68.         $prospectOnStoreQualification->setEndedAt(new \DateTime());
  70.         //set validation date
  71.         $prospectOnStoreQualification->setValidatedAt(new \DateTime());
  73.         //deliver prospect
  74.         if ($prospectOnStore->isWaitingQualification()) {
  75.             $this->logger->info('POS was waiting qualification->deliver');
  76.             $this->logger->info('deliver this POS');
  77.             $this->deliveryService->deliver($prospectOnStore);
  78.         }
  79.     }
  81.     public function onReject(Event $event)
  82.     {
  83.         $prospectOnStoreQualification = $event->getSubject();
  84.         $prospectOnStore = $prospectOnStoreQualification->getProspectOnStore();
  85.         $this->logger->info('ProspectOnStoreQualificationWorflowListener.onReject POS: ' . $prospectOnStore->getId());
  86.         $prospectOnStoreQualification->setEndedAt(new \DateTime());
  87.     }
  89.     /**
  90.      * Manage prospect unreachable
  91.      * @param Event $event
  92.      */
  93.     public function onUnReach(Event $event)
  94.     {
  95.         $prospectOnStoreQualification = $event->getSubject();
  96.         $prospectOnStore = $prospectOnStoreQualification->getProspectOnStore();
  97.         $this->logger->info('ProspectOnStoreQualificationWorflowListener.onUnReach POS: ' . $prospectOnStore->getId());
  98.         $prospectOnStoreQualification->setEndedAt(new \DateTime());
  100.         $this->redeliverOnCondition($prospectOnStore);
  102.     }
  104.     private function redeliverOnCondition(ProspectOnStore $prospectOnStore)
  105.     {
  106.         $this->logger->info('redeliverOnCondition: '.$prospectOnStore->getId());
  107.         //AcquisitionMode ' . $prospectOnStore->getAcquisitionMode() . ' : ' . $prospectOnStore->getAcquisitionMode()->isRedeliverOnUnReach());
  108.         $this->logger->info('searching with mode='.$prospectOnStore->getAcquisitionMode().' and base='.$prospectOnStore->getAcquisitionBase());
  109.         $acquisitionMode = $this->acquisitionModeRepository->findAcquisitionModeOfPos($prospectOnStore);
  110.         $this->logger->info($acquisitionMode?'acquisitionMode id='.$acquisitionMode->getId():' none find');
  111.         if ($acquisitionMode && $acquisitionMode->isRedeliverOnUnReach()) {
  112.             $this->logger->info('acquisitionMode is isRedeliverOnUnReach');
  113.             $this->prospectService->deliverProspectOnStoreBelongingToADifferentPartner($prospectOnStore->getProspect(), ProspectOnStoreCreationModeEnum::UNREACH);
  114.         }else{
  115.             $this->logger->info('acquisitionMode prevent from delivering');
  116.         }
  117.     }
  118. }