src/Controller/Entrain/SubscriptionControllerEntrain.php line 67

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Entrain;
  5. use App\Repository\ContractRepository;
  6. use App\Repository\JsonSurveyRepository;
  7. use App\Service\Entrain\ContractNumberServiceEntrain;
  8. use App\Service\Entrain\MailServiceEntrain;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Exception;
  11. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  12. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpFoundation\Response;
  15. use Symfony\Component\Mailer\MailerInterface;
  16. use Symfony\Component\Routing\Annotation\Route;
  17. use Symfony\Contracts\HttpClient\HttpClientInterface;
  19. class SubscriptionControllerEntrain extends AbstractController
  20. {
  22.     public function __construct(
  23.         ContractRepository           $contractRepository,
  24.         EntityManagerInterface       $entityManager,
  25.         JsonSurveyRepository         $jsonSurveyRepository,
  26.         ParameterBagInterface        $parameterBag,
  27.         MailServiceEntrain           $mailService,
  28.         ContractNumberServiceEntrain $contractNumberService,
  29.         HttpClientInterface          $client
  30.     ) {
  31.         $this->contractRepository = $contractRepository;
  32.         $this->entityManager = $entityManager;
  33.         $this->jsonSurveyRepository = $jsonSurveyRepository;
  34.         $this->parameterBag = $parameterBag;
  35.         $this->mailService = $mailService;
  36.         $this->contractNumberService = $contractNumberService;
  37.         $this->client = $client;
  38.     }
  40.     /**
  41.      * @Route("/subscriptionentrain", name="subscriptionentrain")
  42.      */
  43.     public function index(Request $request, MailerInterface $mailer): Response
  44.     {
  45.         $params = $request->getContent();
  46.         $params = substr($params, 6, strlen($params) - 7);
  47.         $params = json_decode($params);
  49.         try {
  50.             $contract = $this->contractRepository->findOneBy(['folderId' => $params->iddossier]);
  52.             if ($contract->getSubscribed()) {
  53.                 throw new Exception('le contrat a déja été souscrit', 400);
  54.             }
  56.             $survey = $this->jsonSurveyRepository->findBy(['contractId' => $contract]);
  58.             $jsonSurvey = json_decode($survey[0]->getSurvey());
  60.             $contract->setSubscribed(true);
  62.             $this->entityManager->persist($contract);
  63.             $this->entityManager->flush();
  64.         } catch (Exception $e) {
  65.             return $this->json([
  66.                 'message' => $e->getMessage()
  67.             ], $e->getCode());
  68.         }
  70.         $insurer_mails = [(isset($jsonSurvey->question57)) ? $jsonSurvey->question57 : null, (isset($jsonSurvey->question58)) ? $jsonSurvey->question58 : null];
  71.         $statut = $params->statut;
  72.         try {
  73.             foreach ($insurer_mails as $key => $insurer_mail) {
  74.                 if ($statut == "valide" && $insurer_mail != null) {
  75.                     $credentials = [
  76.                         'email' => $insurer_mail,
  77.                         'checkIfUserExist' => 'ask Personal Space Area for User'
  78.                     ];
  80.                     $response = $this->client->request(
  81.                         'POST',
  82.                         $_ENV['NEW_ACCOUNT_PA'],
  83.                         [
  84.                             'headers' => [
  85.                                 'Content-Type' => 'application/json; charset=utf-8',
  86.                                 'Accept' => 'application/json'
  87.                             ],
  88.                             'body' => json_encode($credentials)
  89.                         ]
  90.                     );
  92.                     // check if user already have an account for eventually renew account
  93.                     if ($response->getContent() != "User exist"){
  94.                         $this->mailService->sendTemporaryPassword($contract, $key + 1);
  95.                     }
  96.                 }
  97.             }
  98.         } catch (Exception $e) {
  99.             return $this->json([
  100.                 'message' => $e->getMessage()
  101.             ]);
  102.         } finally {
  103.             // $this->mailService->documentsSenderAfterSubscription($contract);
  104.             $this->mailService->sendClientSubscriptionInformation();
  106.             return $this->json([
  107.                 'info' => 'les documents et informations ont bien été envoyé au(x) prospect(s)!'
  108.             ]);
  109.         }
  110.     }
  111. }