AbstractImportCommand.php

<?php

namespace App\Command;

use App\Entity\ImportRun;
use App\Service\BaseImporter;
use Doctrine\ORM\EntityManagerInterface;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Helper\ProgressBar;
use Symfony\Component\Console\Output\OutputInterface;

abstract class AbstractImportCommand extends Command
{
    public function __construct(
        protected BaseImporter $importer,
        protected EntityManagerInterface $entityManager)
    {
        parent::__construct();
    }

    /**
     * Run the importer.
     *
     * @throws \Exception
     */
    protected function import(string $type, string $src, OutputInterface $output, bool $progress = false): void
    {
        $success = true;
        $errorMessage = null;

        $progressBar = $progress ? new ProgressBar($output) : null;

        try {
            $this->importer->import($src, $progressBar);
        } catch (\Exception $e) {
            $success = false;
            $errorMessage = $e->getMessage();
            $output->writeln($errorMessage);
        }

        $this->recordImportRun($type, $success, $errorMessage);
    }

    /**
     * Record import run.
     *
     * @param string $type
     *  The type of the import
     * @param bool $success
     *  Success of run
     * @param string|null $output
     *  Output message or null
     *
     * @throws \Exception
     */
    protected function recordImportRun(string $type, bool $success, ?string $output = null): void
    {
        $importRun = new ImportRun();
        $importRun->setDatetime(new \DateTime());
        $importRun->setOutput($output);
        $importRun->setResult($success);
        $importRun->setType($type);

        $this->entityManager->persist($importRun);
        $this->entityManager->flush();
    }
}