migrations/Version20241030075504.php line 1

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace DoctrineMigrations;
  7. use App\Entity\InsuranceCompany;
  8. use Doctrine\DBAL\Schema\Schema;
  9. use Doctrine\Migrations\AbstractMigration;
  10. use Symfony\Component\DependencyInjection\ContainerAwareInterface;
  11. use Symfony\Component\DependencyInjection\ContainerAwareTrait;
  13. final class Version20241030075504 extends AbstractMigration implements ContainerAwareInterface
  14. {
  15.     use ContainerAwareTrait;
  17.     public function getDescription(): string
  18.     {
  19.         return 'Import all insurances from a CSV file';
  20.     }
  22.     /**
  23.      * @throws \Exception
  24.      */
  25.     public function up(Schema $schema): void
  26.     {
  27.         $csvFile = __DIR__ . '/../var/insurances/list.csv';
  29.         if (!file_exists($csvFile) || !is_readable($csvFile)) {
  30.             throw new \Exception('File not found or not readable');
  31.         }
  33.         $em = $this->container->get('doctrine.orm.entity_manager');
  35.         if (($handle = fopen($csvFile, 'r')) !== false) {
  36.             $headers = fgetcsv($handle, 1000, ',');
  37.             $line = 1;
  38.             while (($data = fgetcsv($handle, 1000, ';')) !== false) {
  39.                 $insurance = $em->getRepository(InsuranceCompany::class)->find($line);
  40.                 $streetNumber = $this->extractStreetNumber($data[2]);
  41.                 if ($insurance) {
  42.                     $this->addSql('UPDATE insurance_company SET gmaps_address = ?, city = ?, zipCode = ?, streetNumber = ?, address = ?, name = ?, site = ?, bp = ?, phone = ?, email = ? WHERE id = ?', [
  43.                         $data[7],
  44.                         strtoupper($data[5]),
  45.                         $data[4],
  46.                         $streetNumber,
  47.                         $data[2],
  48.                         $data[0],
  49.                         'https://',
  50.                         $data[3],
  51.                         '0102030405',
  52.                         null,
  53.                         $line,
  54.                     ]);
  55.                 } else {
  56.                     $datetime = new \DateTime();
  57.                     $this->addSql('INSERT INTO insurance_company (id, is_deleted, createdAt, gmaps_address, city, zipCode, streetNumber, address, name, site, bp, phone, email) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)', [
  58.                         $line,
  59.                         0,
  60.                         $datetime->format('Y-m-d H:i:s'),
  61.                         $data[7],
  62.                         strtoupper($data[5]),
  63.                         $data[4],
  64.                         $streetNumber,
  65.                         $data[2],
  66.                         $data[0],
  67.                         'https://',
  68.                         $data[3],
  69.                         '0102030405',
  70.                         null
  71.                     ]);
  72.                 }
  73.                 $line++;
  74.             }
  75.             fclose($handle);
  76.         }
  77.     }
  79.     public function down(Schema $schema): void
  80.     {
  82.     }
  84.     /**
  85.      * @param string $address
  86.      * @return int|null
  87.      */
  88.     private function extractStreetNumber(string $address): ?int
  89.     {
  90.         $address = ltrim($address);
  91.         $pattern = '/^(\d+)/';
  93.         if (preg_match($pattern, $address, $matches)) {
  94.             return (int)$matches[1];
  95.         } else {
  96.             return null;
  97.         }
  98.     }
  99. }