src/Salesforce/EventListener/SalesForceImportListener.php line 34

Open in your IDE?
  1. <?php
  3. namespace App\Salesforce\EventListener;
  5. use App\Api\Event\ImportEvent;
  6. use App\Api\Event\ImportEvents;
  7. use App\Entity\Sale;
  8. use App\Entity\Vehicle;
  9. use App\Repository\SaleEventRepository;
  10. use App\Repository\VehicleRepository;
  11. use App\Salesforce\Api\ClientInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. /**
  15.  * SalesForce Event listener for the Import events.
  16.  */
  17. class SalesForceImportListener implements EventSubscriberInterface
  18. {
  19.     public function __construct(private readonly ClientInterface $sfClient, private readonly VehicleRepository $vehicleRepository, private readonly SaleEventRepository $saleEventRepository)
  20.     {
  21.     }
  23.     public static function getSubscribedEvents()
  24.     {
  25.         return [
  26.             ImportEvents::DATA_LAST => 'onLastData',
  27.         ];
  28.     }
  30.     /**
  31.      * DO NOT call $sale->getEvents() or any other form to get the events here, it seems Doctrine isn't fully done with them
  32.      * Use queries from the repository, that works.
  33.      */
  34.     public function onLastData(ImportEvent $event): void
  35.     {
  36.         $object = $event->getObject();
  38.         if (!$object instanceof Vehicle) {
  39.             return;
  40.         }
  42.         $sale = $object->getSale();
  43.         $events = '';
  45.         if (Sale::TYPE_PHYSICAL === $sale->getType()) {
  46.             $events = join(' / ',
  47.                 array_map(
  48.                     fn ($e) => $e->getStartTime().' - '.$e->getTitle()->getName(),
  49.                     $this->saleEventRepository->findAllInSales([$sale])
  50.                 )
  51.             );
  52.         }
  54.         $sSale = array_filter([
  55.             'ExternalId__c' => $sale->getId(),
  56.             'NbrVehiculesProposes__c' => $this->vehicleRepository->countAllActiveBySale($sale),
  57.             'Sous_vente_physique_V2__c' => $events,
  58.         ]);
  60.         $this->sfClient->initiate()->upsert('ExternalId__c', (object) $sSale, 'SessionVente__c');
  61.     }
  62. }