src/V4/Controller/Quote/QuoteDataPersisterAction.php line 16

Open in your IDE?
  1. <?php
  3. namespace App\V4\Controller\Quote;
  5. use App\DataPersister\CustomerFile\CustomerFileDataPersister;
  6. use App\Model\CustomerFile\CustomerFile;
  7. use App\V4\Controller\AbstractDataPersisterAction;
  8. use App\V4\DataPersister\Quote\QuoteDataPersister;
  9. use App\V4\Logger\SentryLogger;
  10. use App\V4\Model\Quote\Quote;
  11. use ReflectionException;
  12. use Symfony\Component\HttpFoundation\Request;
  13. use Symfony\Component\HttpFoundation\Response;
  14. use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
  16. class QuoteDataPersisterAction extends AbstractDataPersisterAction
  17. {
  18.     /**
  19.      * @var CustomerFileDataPersister
  20.      */
  21.     private $customerFileDataPersister;
  23.     /**
  24.      * @var SentryLogger
  25.      */
  26.     private $sentryLogger;
  28.     /**
  29.      * @param QuoteDataPersister        $quoteDataPersister
  30.      * @param CustomerFileDataPersister $customerFileDataPersister
  31.      * @param SentryLogger              $sentryLogger
  32.      */
  33.     public function __construct(
  34.         QuoteDataPersister $quoteDataPersister,
  35.         CustomerFileDataPersister $customerFileDataPersister,
  36.         SentryLogger $sentryLogger
  37.     ) {
  38.         parent::__construct($quoteDataPersister);
  39.         $this->customerFileDataPersister = $customerFileDataPersister;
  40.         $this->sentryLogger = $sentryLogger;
  41.     }
  43.     /**
  44.      * {@inheritdoc}
  45.      */
  46.     public function __invoke(Request $request, $data = null, ?string $id = null)
  47.     {
  48.         /** @var Quote|Response $quoteOrResponse */
  49.         $quoteOrResponse = parent::__invoke($request, $data, $id);
  50.         if (null === $quoteOrResponse) {
  51.             return [];
  52.         }
  54.         if ($quoteOrResponse instanceof Response && !$quoteOrResponse->isSuccessful()) {
  55.             return $quoteOrResponse;
  56.         }
  58.         $this->handleFiles($request, $quoteOrResponse);
  60.         return $quoteOrResponse;
  61.     }
  63.     /**
  64.      * @param Request $request
  65.      * @param Quote   $quote
  66.      *
  67.      * @return void
  68.      *
  69.      * @throws \Exception
  70.      */
  71.     private function handleFiles(Request $request, Quote $quote): void
  72.     {
  73.         // Handle files: should delete current files ?
  74.         foreach ($request->request->get('customerFiles', []) as $key => $currentCustomerFile) {
  75.             if ($currentCustomerFile['shouldDelete'] ?? false) {
  76.                 try {
  77.                     $realCustomerFile = $quote->getCustomerFiles()[$key] ?? null;
  78.                     if (null !== $realCustomerFile && null !== $realCustomerFile->getId()) {
  79.                         $this->customerFileDataPersister->remove($realCustomerFile);
  80.                         $quote->removeCustomerFile($realCustomerFile);
  81.                     }
  82.                 } catch (TransportExceptionInterface $e) {
  83.                     $this->sentryLogger->captureException(
  84.                         SentryLogger::CHANNEL_DATA_PERSISTER,
  85.                         $e,
  86.                         [
  87.                             'catchOnClass' => self::class,
  88.                             'customerFileId' => $realCustomerFile->getId(),
  89.                         ]
  90.                     );
  91.                 }
  92.             }
  93.         }
  95.         // Handle files: should upload new files
  96.         foreach ($request->files->get('customerFiles', []) as $key => $newCustomerFile) {
  97.             $customerFileData = ['quoteId' => $quote->getId()];
  98.             try {
  99.                 $realCustomerFile = $this->customerFileDataPersister->persistCustomerFile($customerFileData, $newCustomerFile['customerFile']['file']);
  100.                 $quote->addCustomerFile((new CustomerFile())->importFromData($realCustomerFile));
  102.                 $allCF = $quote->getCustomerFiles();
  103.                 unset($allCF[$key]);
  104.                 $quote->setCustomerFiles($allCF);
  105.             } catch (TransportExceptionInterface | ReflectionException $e) {
  106.                 $this->sentryLogger->captureException(
  107.                     SentryLogger::CHANNEL_DATA_PERSISTER,
  108.                     $e,
  109.                     [
  110.                         'catchOnClass' => self::class,
  111.                         'quoteId' => $quote->getId(),
  112.                     ]
  113.                 );
  114.             }
  115.         }
  116.     }
  117. }