Deprecated: Constant E_STRICT is deprecated in /home/pastorz/old-espace-client/vendor/symfony/error-handler/ErrorHandler.php on line 58

Deprecated: Constant E_STRICT is deprecated in /home/pastorz/old-espace-client/vendor/symfony/error-handler/ErrorHandler.php on line 76
Symfony Profiler

src/Service/ColissimoService.php line 78

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  5. use App\Entity\Batch;
  6. use App\Entity\Carrier;
  7. use App\Entity\CarrierInsurancePriceRange;
  8. use App\Entity\DeliveryNote;
  9. use App\Entity\EstimationRequest;
  10. use App\Entity\SupportRequest;
  11. use App\Twig\FormatExtension;
  12. use Com\Tecnick\Color\Exception;
  13. use Doctrine\Common\Collections\Collection;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use setasign\Fpdi\PdfParser\CrossReference\CrossReferenceException;
  16. use setasign\Fpdi\PdfParser\Filter\FilterException;
  17. use setasign\Fpdi\PdfParser\PdfParserException;
  18. use setasign\Fpdi\PdfParser\Type\PdfTypeException;
  19. use setasign\Fpdi\PdfReader\PdfReaderException;
  20. use setasign\Fpdi\Tcpdf\Fpdi;
  21. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  22. use Symfony\Component\HttpFoundation\Response;
  23. use Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface;
  24. use Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface;
  25. use Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface;
  26. use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
  27. use Symfony\Contracts\HttpClient\HttpClientInterface;
  28. use Symfony\Contracts\HttpClient\ResponseInterface;
  29. use Throwable;
  31. class ColissimoService
  32. {
  33.     private const BASE_URL = 'https://ws.colissimo.fr';
  34.     private const ENDPOINTS = array(
  35.         'getToken' => '/widget-colissimo/rest/authenticate.rest',
  36.         'generateLabel' => '/sls-ws/SlsServiceWSRest/2.0/generateLabel',
  37.         'checkGenerateLabel' => '/sls-ws/SlsServiceWSRest/2.0/checkGenerateLabel',
  38.     );
  40.     public function __construct(
  41.         private ParameterBagInterface  $parameterBag,
  42.         private BrandService           $brandService,
  43.         private HttpClientInterface    $httpClient,
  44.         private EntityManagerInterface $em,
  45.         private PdfGenerationService   $pdfGenerationService,
  46.         private LabelService           $labelService
  47.     )
  48.     {
  49.     }
  51.     public function getBaseUrl(): string
  52.     {
  53.         return self::BASE_URL;
  54.     }
  56.     /**
  57.      * @return array|null
  58.      * @throws ClientExceptionInterface
  59.      * @throws RedirectionExceptionInterface
  60.      * @throws ServerExceptionInterface
  61.      * @throws TransportExceptionInterface
  62.      */
  63.     public function getToken(): ?array
  64.     {
  65.         $response = $this->call('POST', self::ENDPOINTS[__FUNCTION__], array('login' => $this->parameterBag->get("colissimo.login"), 'password' => $this->parameterBag->get("colissimo.password")));
  67.         return json_decode($response->getContent(), true);
  68.     }
  70.     /**
  71.      * @param string $method
  72.      * @param string $endpoint
  73.      * @param array|null $bodyParams
  74.      * @param array $queryParams
  75.      * @return ResponseInterface
  76.      * @throws TransportExceptionInterface
  77.      */
  78.     private function call(string $method, string $endpoint, array $bodyParams = null, array $queryParams = array(), array $batchesIds = null): ResponseInterface
  79.     {
  80.         $params = array(
  81.             'json' => $bodyParams
  82.         );
  84.         if (isset($bodyParams['letter'])) {
  85.             $params['user_data'] = [
  86.                 'productCode' => $bodyParams['letter']['service']['productCode'],
  87.                 'batchesIds' => $batchesIds
  88.             ];
  89.         }
  91.         return $this->httpClient->request($method, self::BASE_URL . $endpoint . '?' . http_build_query($queryParams), $params);
  92.     }
  94.     /**
  95.      * @param DeliveryNote|null $note
  96.      * @param bool|null $generateOneOnly
  97.      * @param Collection|null $batches
  98.      * @param bool|null $isReturnLabel
  99.      * @return Response
  100.      * @throws ClientExceptionInterface
  101.      * @throws CrossReferenceException
  102.      * @throws Exception
  103.      * @throws FilterException
  104.      * @throws PdfParserException
  105.      * @throws PdfReaderException
  106.      * @throws PdfTypeException
  107.      * @throws RedirectionExceptionInterface
  108.      * @throws ServerExceptionInterface
  109.      * @throws TransportExceptionInterface
  110.      */
  111.     public function generateLabel(?DeliveryNote $note = null, ?bool $generateOneOnly = false, ?Collection $batches = null, ?bool $isReturnLabel = false, ?bool $debug = false): Response
  112.     {
  113.         if (!$note && !$batches) throw new Exception("DeliveryNote null, Batches null");
  115.         //Has to generate labels for each batch, and then merge them together
  116.         $allParcels = $this->getAllParcelParams($note?->getBatches() ?? $batches, $isReturnLabel);
  117.         if ($generateOneOnly) {
  118.             $allParcels = array_slice($allParcels, 0, 1);
  119.             $allParcels[0]['letter']['parcel']['weight'] = 1;
  120.         }else if(!$isReturnLabel){
  121.             ($note ?? $batches->first()->getDeliveryNote())->getShipment()->setTrackingNumbers([]);
  122.         }
  124.         if ($debug) return $this->checkGenerateLabel($allParcels[0]);
  126.         //Download and merge all parcel labels
  127.         return $this->concurrentMergeDownloads($allParcels, $note);
  128.     }
  130.     /**
  131.      * @param mixed $batches
  132.      * @param bool|null $isReturnLabel
  133.      * @return array|null
  134.      */
  135.     private function getAllParcelParams(mixed $batches, ?bool $isReturnLabel = false): array|null
  136.     {
  137.         if ($batches->isEmpty()) return null;
  139.         $parcels = ['combinedParcels' => []];
  141.         foreach ($batches as $key => $batch) {
  142.             if ($batch->isIndividualShipment()) $parcels[$key] = [$batch];
  143.             else $parcels['combinedParcels'][] = $batch;
  144.         }
  146.         $parcelParams = [];
  148.         foreach ($parcels as $key => $parcel) {
  149.             if ($parcel) $parcelParams[] = $this->getParcelParams($parcel, $isReturnLabel);
  150.         }
  152.         return $parcelParams;
  153.     }
  155.     /**
  156.      * @param array $parcel
  157.      * @param bool|null $isReturnLabel
  158.      * @return array
  159.      */
  160.     private function getParcelParams(array $parcel, ?bool $isReturnLabel = false): array
  161.     {
  162.         /** @var DeliveryNote $note */
  163.         $note = $parcel[0]->getDeliveryNote();
  165.         if ($isReturnLabel) $productCode = 'CORE';
  166.         else if (isset($note->getShipment()->getDeliveryAddress()['productCode'])) {
  167.             $productCode = $note->getShipment()->getDeliveryAddress()['productCode'];
  168.         } else {
  169.             $productCode = $note->getShipment()->isDeliveryAgainstSignature() || $note->getShipment()->isInsurance() ? 'DOS' : 'DOM';
  170.         }
  172.         if (in_array(strtoupper($productCode), ['ACP', 'CDI'])) $productCode = 'BPR';
  174.         $brandAddress = $isReturnLabel ? $this->brandService->getBrand()->getWarehouseAddress() : $this->brandService->getBrand()->getAddress();
  176.         $senderAddress = [
  177.             "companyName" => $this->brandService->getBrand()->getCompanyName(),
  178.             "line2" => $brandAddress->getAddress(),
  179.             "countryCode" => $brandAddress->getCountry()->getCode(),
  180.             "city" => $brandAddress->getCity(),
  181.             "zipCode" => preg_replace('/\s/', '', $brandAddress->getZipcode())
  182.         ];
  184.         $addresseeFirstname = trim($note->getShipment() ? $note->getShipment()->getDeliveryAddress()['firstname'] : $note->getUser()->getLastname());
  185.         $addresseeLastname = trim($note->getShipment() ? $note->getShipment()->getDeliveryAddress()['lastname'] : $note->getUser()->getLastname());
  187.         $countryCode = isset($note->getShipment()?->getDeliveryAddress()['countryCode']) ? $note->getShipment()?->getDeliveryAddress()['countryCode'] : 'FR';
  188.         $zipcode = preg_replace('/\s/', '', $note->getShipment() ? $note->getShipment()->getDeliveryAddress()['zipcode'] : $note->getUser()->getFallbackAddress()->getZipcode());
  189.         if ($countryCode === 'FR') $zipcode = FormatExtension::formatZipCode($zipcode);
  191.         $addresseeAddress = [
  192.             "lastName" => strlen($addresseeFirstname) ? $addresseeFirstname : '.',
  193.             "firstName" => strlen($addresseeLastname) ? $addresseeLastname : '.',
  194.             "line0" => $note->getShipment() ? $note->getShipment()->getDeliveryAddress()['address_line2'] ?? '' : $note->getUser()->getFallbackAddress()->getAddressLine2(),
  195.             "line1" => $note->getShipment() ? $note->getShipment()->getDeliveryAddress()['address_line1'] ?? '' : $note->getUser()->getFallbackAddress()->getAddressLine1(),
  196.             "line2" => $note->getShipment() ? $note->getShipment()->getDeliveryAddress()['address'] : $note->getUser()->getFallbackAddress()->getAddress(),
  197.             "countryCode" => $countryCode,
  198.             "city" => $note->getShipment() ? $note->getShipment()->getDeliveryAddress()['city'] : $note->getUser()->getFallbackAddress()->getCity(),
  199.             "zipCode" => $zipcode,
  200.             "mobileNumber" => $note->getUser()->getPhone(),
  201.             "email" => $note->getUser()->getEmail()
  202.         ];
  204.         $weight = array_sum(array_map(fn(Batch $b) => $b->getWeight(), $parcel));
  206.         if(!$isReturnLabel){
  207.             $maxInsuranceValue = max($note->getShipment()->getCarrier()->getInsurancePriceRanges()->map(fn(CarrierInsurancePriceRange $priceRange) => $priceRange->getInsuranceValue())->toArray());
  208.         }
  210.         $data = array(
  211.             "contractNumber" => $this->parameterBag->get('colissimo.login'),
  212.             "password" => $this->parameterBag->get('colissimo.password'),
  213.             "outputFormat" => [
  214.                 "x" => 0,
  215.                 "y" => 0,
  216.                 "outputPrintingType" => "PDF_10x15_300dpi"
  217.             ],
  218.             "letter" => [
  219.                 "service" => [
  220.                     "productCode" => $productCode,
  221.                     "depositDate" => (new \DateTime())->format('Y-m-d'),
  222.                     "orderNumber" => $note->getId(),
  223.                     "commercialName" => $this->brandService->getBrand()->getName()
  224.                 ],
  225.                 "parcel" => [
  226.                     "insuranceValue" => !$isReturnLabel && $note->getShipment()->isInsurance() ? intval(min($maxInsuranceValue, $note->getShipment()->getInsuredValue() ?? array_sum(array_map(fn(Batch $batch) => $batch->getTotalAmount(), $note->getBatches()->toArray()))) * 100) : "0",
  227.                     "weight" => $weight ?: 1,
  228.                 ],
  229.                 "sender" => [
  230.                     "senderParcelRef" => ($isReturnLabel ? "SAV_" : "") . $note->getCode(),
  231.                     "address" => $isReturnLabel ? $addresseeAddress : $senderAddress
  232.                 ],
  233.                 "addressee" => [
  234.                     "addresseeParcelRef" => ($isReturnLabel ? "SAV_" : "") . $note->getCode(),
  235.                     "address" => $isReturnLabel ? $senderAddress : $addresseeAddress
  236.                 ]
  237.             ]
  238.         );
  240.         if (!$isReturnLabel && $note->getShipment()->getCarrier()->getIsServicePoint()) {
  241.             $data['letter']['parcel']['pickupLocationId'] = $note->getShipment()->getDeliveryAddress()['pickupLocationId'];
  242.         }
  244.         return ['data' => $data, 'batchesIds' => array_map(fn(Batch $b) => $b->getId(), $parcel)];
  245.     }
  247.     /**
  248.      * @param array $parcel
  249.      * @return Response
  250.      * @throws ClientExceptionInterface
  251.      * @throws RedirectionExceptionInterface
  252.      * @throws ServerExceptionInterface
  253.      * @throws TransportExceptionInterface
  254.      */
  255.     private function checkGenerateLabel(array $parcel): Response
  256.     {
  257.         return new Response($this->call('POST', endpoint: self::ENDPOINTS[__FUNCTION__], bodyParams: $parcel['data'], batchesIds: $parcel['batchesIds'])->getContent());
  258.     }
  260.     /**
  261.      * @param array $parcels
  262.      * @param DeliveryNote|null $note
  263.      * @return Response
  264.      * @throws ClientExceptionInterface
  265.      * @throws CrossReferenceException
  266.      * @throws Exception
  267.      * @throws FilterException
  268.      * @throws PdfParserException
  269.      * @throws PdfReaderException
  270.      * @throws PdfTypeException
  271.      * @throws RedirectionExceptionInterface
  272.      * @throws ServerExceptionInterface
  273.      * @throws TransportExceptionInterface
  274.      * @throws \Exception
  275.      */
  276.     public function concurrentMergeDownloads(array $parcels, ?DeliveryNote $note = null): Response
  277.     {
  278.         $outPut = new Fpdi();
  279.         $outPut->setPrintFooter(false);
  280.         $outPut->setPrintHeader(false);
  282.         //Send all requests
  283.         $responses = [];
  285.         foreach ($parcels as $parcel) {
  286.             $responses[] = $this->call('POST', endpoint: self::ENDPOINTS['generateLabel'], bodyParams: $parcel['data'], batchesIds: $parcel['batchesIds']);
  287.         }
  289.         //Asynchronously handle them
  290.         foreach ($this->httpClient->stream($responses) as $response => $chunk) {
  291.             if ($chunk->isLast()) {
  292.                 $isBiggerLabel = in_array($response->getInfo('user_data')['productCode'], ['A2P']);
  293.                 $isReturnLabel = in_array($response->getInfo('user_data')['productCode'], ['CORE']);
  295.                 $batchesIds = $response->getInfo('user_data')['batchesIds'];
  297.                 $raw = $response->getContent();
  298.                 $content = $this->getResponseSlicedToPDF($raw);
  299.                 $fileName = uniqid() . "_label.pdf";
  300.                 file_put_contents(ConstantsService::TMP_PDFS_DIR . $fileName, $content);
  302.                 $outPut->AddPage(format: [100, 150]);
  303.                 $outPut->setSourceFile(ConstantsService::TMP_PDFS_DIR . $fileName);
  304.                 $tplId = $outPut->importPage(1);
  305.                 $outPut->Rect(0, 0, 100, 150, style: 'F', fill_color: [255, 255, 255]);
  307.                 if ($isReturnLabel) $yOffset = 3;
  308.                 else $yOffset = $isBiggerLabel ? 5 : 15;
  310.                 $outPut->useTemplate($tplId, x: $isBiggerLabel ? 0 : 3, y: $yOffset, height: 140);
  312.                 if (!$isReturnLabel) {
  313.                     foreach ($batchesIds as $key => $value) {
  314.                         $batch = $this->em->getRepository(Batch::class)->find($value);
  315.                         $trackingNumber = $this->getTrackingNumber($raw);
  316.                         $batch->getDeliveryNote()->getShipment()->addTrackingNumber($trackingNumber);
  317.                         $this->labelService->generateLabel($batch->getDeliveryNote()->getShipment(), $trackingNumber);
  319.                         $this->em->persist($batch);
  320.                         $this->em->persist($batch->getDeliveryNote()->getShipment());
  321.                     }
  322.                 }
  324.                 unlink(ConstantsService::TMP_PDFS_DIR . $fileName);
  325.             }
  326.         }
  328.         $result = $outPut->Output(dest: "S");
  330.         $this->em->flush();
  332.         return new Response($result, Response::HTTP_OK, [
  333.             'Content-Type' => 'application/pdf',
  334.             'Content-Disposition' => 'inline; filename=label' . ($note ? '_' . $note->getCode() : '') . '.pdf'
  335.         ]);
  336.     }
  338.     private function getResponseSlicedToPDF(string $input): string|Response
  339.     {
  340.         $start_tag = "%PDF-1.3";
  341.         $end_tag = "%%EOF";
  342.         $output = "";
  344.         $start_pos = strpos($input, $start_tag);
  345.         $end_pos = strpos($input, $end_tag);
  347.         if ($start_pos !== false && $end_pos !== false) {
  348.             $end_pos += strlen($end_tag);
  349.             $output = substr($input, $start_pos, $end_pos - $start_pos);
  350.         }
  352.         return $output;
  353.     }
  355.     private function getTrackingNumber(string $input): string
  356.     {
  357.         preg_match('/\{"messages".*"pdfUrl":.*}}/', $input, $matches);
  359.         if (!$matches) throw new Exception("Error while parsing tracking number.");
  361.         $json = json_decode($matches[0]);
  363.         if (!isset($json->labelV2Response) || !isset($json->labelV2Response->parcelNumber)) throw new Exception("No tracking number found.");
  365.         return $json->labelV2Response->parcelNumber;
  366.     }
  368.     /**
  369.      * @param EstimationRequest $estimationRequest
  370.      * @return array
  371.      * @throws Exception
  372.      */
  373.     public function generateEstimationLabels(EstimationRequest $estimationRequest): array
  374.     {
  375.         try {
  376.             $trackingNumbers = [];
  377.             $pdfs = [];
  379.             for ($i = 0; $i < $estimationRequest->getLabelQuantity(); $i++) {
  380.                 ['pdf' => $pdf, 'trackingNumber' => $trackingNumber] = $this->generateEstimationLabel($estimationRequest);
  381.                 $pdfs[] = $pdf;
  382.                 $trackingNumbers[] = $trackingNumber;
  383.             }
  385.             $pdf = $this->pdfGenerationService->mergePdfs($pdfs);
  387.             return ['pdf' => $pdf, 'trackingNumbers' => $trackingNumbers];
  388.         } catch (Throwable) {
  389.             throw new Exception('Erreur lors de la génération des étiquettes');
  390.         }
  391.     }
  393.     private function generateEstimationLabel(EstimationRequest $estimationRequest): array
  394.     {
  395.         $maxInsuranceValue = max($this->em->getRepository(Carrier::class)->findOneByInternalId(ConstantsService::CARRIER_ID_COLISSIMO)->getInsurancePriceRanges()->map(fn(CarrierInsurancePriceRange $priceRange) => $priceRange->getInsuranceValue())->toArray());
  397.         $data = array(
  398.             "contractNumber" => $this->parameterBag->get('colissimo.login'),
  399.             "password" => $this->parameterBag->get('colissimo.password'),
  400.             "outputFormat" => [
  401.                 "x" => 0,
  402.                 "y" => 0,
  403.                 "outputPrintingType" => "PDF_10x15_300dpi"
  404.             ],
  405.             "letter" => [
  406.                 "service" => [
  407.                     "productCode" => 'CORE',
  408.                     "depositDate" => (new \DateTime())->format('Y-m-d'),
  409.                     "orderNumber" => $estimationRequest->getId(),
  410.                     "commercialName" => $this->brandService->getBrand()->getName()
  411.                 ],
  412.                 "parcel" => [
  413.                     "insuranceValue" => $estimationRequest->getInsuredPrice() ? intval(min($estimationRequest->getInsuredPrice(), $maxInsuranceValue) * 100) : "0",
  414.                     "weight" => $estimationRequest->getWeight(),
  415.                 ],
  416.                 "sender" => [
  417.                     "senderParcelRef" => "ESTIM_" . $estimationRequest->getId(),
  418.                     "address" => $this->getEstimationLabelSender($estimationRequest)
  419.                 ],
  420.                 "addressee" => [
  421.                     "addresseeParcelRef" => "ESTIM_" . $estimationRequest->getId(),
  422.                     "address" => $this->getEstimationLabelAddressee()
  423.                 ]
  424.             ]
  425.         );
  427.         $content = $this->call('POST', endpoint: self::ENDPOINTS['generateLabel'], bodyParams: $data)->getContent();
  429.         $pdf = $this->getResponseSlicedToPDF($content);
  430.         $trackingNumber = $this->getTrackingNumber($content);
  432.         return ['pdf' => $pdf, 'trackingNumber' => $trackingNumber];
  433.     }
  435.     private function getEstimationLabelSender(EstimationRequest $estimationRequest): array
  436.     {
  437.         $addresseeFirstname = trim($estimationRequest->getAddress()['firstname']);
  438.         $addresseeLastname = trim($estimationRequest->getAddress()['lastname']);
  440.         return [
  441.             "lastName" => strlen($addresseeLastname) ? $addresseeLastname : '.',
  442.             "firstName" => strlen($addresseeFirstname) ? $addresseeFirstname : '.',
  443.             "line0" => $estimationRequest->getAddress()['address_line2'] ?? '',
  444.             "line1" => $estimationRequest->getAddress()['address_line1'] ?? '',
  445.             "line2" => $estimationRequest->getAddress()['address'],
  446.             "countryCode" => $estimationRequest->getAddress()['countryCode'],
  447.             "city" => $estimationRequest->getAddress()['city'],
  448.             "zipCode" => FormatExtension::formatZipCode($estimationRequest->getAddress()['zipcode']),
  449.             "mobileNumber" => '0600000000',
  450.             "email" => $estimationRequest->getUser()->getEmail()
  451.         ];
  452.     }
  454.     private function getEstimationLabelAddressee(): array
  455.     {
  456.         $brand = $this->brandService->getBrand();
  458.         return [
  459.             "companyName" => $brand->getCompanyName(),
  460.             "line2" => $brand->getAddress()->getAddress(),
  461.             "countryCode" => $brand->getAddress()->getCountry()->getCode(),
  462.             "city" => $brand->getAddress()->getCity(),
  463.             "zipCode" => $brand->getAddress()->getZipcode(),
  464.             "mobileNumber" => $brand->getPhone(),
  465.             "email" => $brand->getContact()
  466.         ];
  467.     }
  469.     /**
  470.      * @param SupportRequest $supportRequest
  471.      * @return array
  472.      * @throws Exception
  473.      */
  474.     public function generateSupportLabels(SupportRequest $supportRequest): array
  475.     {
  476.         try {
  477.             $trackingNumbers = [];
  478.             $pdfs = [];
  479.             $parcels = $this->getAllParcelParams($supportRequest->getBatches(), isReturnLabel: true);
  480.             foreach ($parcels as $parcel) {
  481.                 ['pdf' => $pdf, 'trackingNumber' => $trackingNumber] = $this->generateSupportLabel($parcel['data']);
  482.                 $pdfs[] = $pdf;
  483.                 $trackingNumbers[] = $trackingNumber;
  484.             }
  486.             $pdf = $this->pdfGenerationService->mergePdfs($pdfs);
  488.             return ['pdf' => $pdf, 'trackingNumbers' => $trackingNumbers];
  489.         } catch (Throwable $e) {
  490.             throw new Exception('Erreur lors de la génération des étiquettes');
  491.         }
  492.     }
  494.     private function generateSupportLabel(array $parcel): array
  495.     {
  496.         $content = $this->call('POST', endpoint: self::ENDPOINTS['generateLabel'], bodyParams: $parcel)->getContent();
  498.         $pdf = $this->getResponseSlicedToPDF($content);
  499.         $trackingNumber = $this->getTrackingNumber($content);
  501.         return ['pdf' => $pdf, 'trackingNumber' => $trackingNumber];
  502.     }
  503. }