src/Salesforce/EventListener/SalesForceComplaintSubscriber.php line 24

Open in your IDE?
  1. <?php
  3. namespace App\Salesforce\EventListener;
  5. use App\Entity\CustomerComplaint;
  6. use App\Event\CustomerComplaintEvent;
  7. use App\Salesforce\Api;
  8. use Psr\Log\LoggerInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. class SalesForceComplaintSubscriber implements EventSubscriberInterface
  12. {
  13.     public function __construct(private readonly Api\ClientInterface $sfClient, private readonly LoggerInterface $logger)
  14.     {
  15.     }
  17.     public static function getSubscribedEvents()
  18.     {
  19.         return [
  20.             CustomerComplaintEvent::NAME => 'onNewCustomerComplaint',
  21.         ];
  22.     }
  24.     public function onNewCustomerComplaint(CustomerComplaintEvent $event): void
  25.     {
  26.         $complaint = $event->getEntity();
  28.         if (!($complaint instanceof CustomerComplaint)) {
  29.             return;
  30.         }
  32.         $this->sfClient->initiate();
  34.         if (null !== $complaint->getUser()->getSalesman()) {
  35.             $data = $this->sfClient->findOne(['Id'], 'User', ['Email' => $complaint->getUser()->getSalesman()->getEmail()]);
  36.             $owner = $data->Id ?? null;
  37.         }
  39.         if (false !== $this->sfClient->exists('Adjudication__c', ['ExternalId__c' => $complaint->getReference()])) {
  40.             $upSCase = (object) array_filter([
  41.                 'Adjudication__r' => (object) ['ExternalId__c' => $complaint->getReference()],
  42.                 'AccountId' => $complaint->getUser()->getSfAccountId(),
  43.                 'num_dossier__c' => $complaint->getReference(),
  44.                 'ExternalId__c' => $complaint->getReference(),
  45.                 'Origin' => 'Web',
  46.                 'Subject' => 'RECLAMATION',
  47.                 'Motif_de_la_reclamation__c' => $complaint->getSubject(),
  48.                 'Pr_cisez_votre_demande__c' => $complaint->getDescription(),
  49.                 'OwnerId' => $owner,
  50.             ]);
  52.             foreach ($complaint->getFiles() as $key => $file) {
  53.                 $upSCase->{'Piece_justificative_'.++$key.'__c'} = $file;
  54.             }
  56.             $this->sfClient->upsert('ExternalId__c', $upSCase, 'Case');
  58.             return;
  59.         }
  61.         $this->logger->error(sprintf('Adjudication cannot be found for reference %s', $complaint->getReference()));
  62.     }
  63. }