src/V4/Service/SyncPreConfiguredExportRunner/SyncPreConfiguredExportRunner.php line 57

Open in your IDE?
  1. <?php
  3. namespace App\V4\Service\SyncPreConfiguredExportRunner;
  5. use App\V4\Entity\PreconfiguredExport;
  6. use Doctrine\DBAL\Driver\Exception;
  7. use Doctrine\ORM\EntityManagerInterface;
  8. use Symfony\Component\HttpFoundation\JsonResponse;
  9. use Symfony\Component\HttpFoundation\Response;
  11. class SyncPreConfiguredExportRunner
  12. {
  13.     private const SQL_KEY_DB_CRM = '{{ db_crm }}';
  14.     private const SQL_KEY_DB_BUSINESS = '{{ db_business }}';
  15.     private const SQL_KEY_DB_PARAM = '{{ db_param }}';
  16.     private const SQL_KEY_DB_USER = '{{ db_user }}';
  17.     private const SQL_KEY_DB_GED = '{{ db_ged }}';
  19.     /**
  20.      * @var EntityManagerInterface
  21.      */
  22.     private $entityManager;
  24.     public function __construct(EntityManagerInterface $entityManager)
  25.     {
  26.         $this->entityManager = $entityManager;
  27.     }
  29.     /**
  30.      * @throws Exception
  31.      * @throws \Doctrine\DBAL\Exception
  32.      */
  33.     public function runExport(PreconfiguredExport $data, array $params): JsonResponse
  34.     {
  35.         $sql = $data->getContent();
  37.         $dbSqlKeys = [
  38.             self::SQL_KEY_DB_CRM => $_ENV['BDD_API_CRM'],
  39.             self::SQL_KEY_DB_BUSINESS => $_ENV['BDD_API_BUSINESS'],
  40.             self::SQL_KEY_DB_PARAM => $_ENV['BDD_API_PARAM'],
  41.             self::SQL_KEY_DB_USER => $_ENV['BDD_API_USER'],
  42.             self::SQL_KEY_DB_GED => $_ENV['BDD_API_GED'],
  43.         ];
  44.         foreach ($dbSqlKeys as $dbSqlKey => $dbName) {
  45.             $sql = str_replace($dbSqlKey, $dbName, $sql);
  46.         }
  48.         $out = [];
  49.         preg_match_all('/{{ ([^{}]+) }}/', $sql, $out);
  50.         foreach ($out[1] as $index => $sqlParam) {
  51.             if (!isset($params[$sqlParam])) {
  52.                 return new JsonResponse(['message' => 'missing_params', 'param_missing' => $sqlParam], Response::HTTP_BAD_REQUEST);
  53.             }
  54.             $sql = str_replace($out[0][$index], ':'.$sqlParam, $sql);
  55.         }
  57.         $result = $this->entityManager->getConnection()->executeQuery($sql, $params);
  59.         return new JsonResponse(['data' => $result->fetchAllAssociative()], Response::HTTP_CREATED);
  60.     }
  61. }