<?php

declare(strict_types=1);

namespace App\Console;

use App\Controller\Api\ApiController;
use App\Model\ErrorsModel;
use App\Model\MigrateCustomersModel;
use DateTime;
use Monolog\Handler\StreamHandler;
use Monolog\Logger;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class MigrateCustomerCreateCommand extends Command
{
    protected function configure(): void
    {
        $this
            ->setName('migrate:customer:create')
            ->setDescription('Migrate Customers from Magento DB')
            ->setHelp('This command allows you to load customers to DB from Magento DB');
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        new ApiController();
        $migracion = new MigrateCustomersModel();
        $customers = $migracion->getCustomers();

        if ($customers->num_rows > 0) :
            try {
                $start = new DateTime();
                $output->writeln('Start: ' . date('Y-m-d H:i:s', time()));

                foreach ($customers->rows as $customer) {
                    $customer['firstname'] = str_replace("'", "\'", $customer['firstname']);
                    $migracion->insertCustomer((array) $customer);
                }

                $end = new DateTime();
                $output->writeln('End: ' . date('Y-m-d H:i:s', time()));
                $total = $start->diff($end);
                $output->writeln('Time: ' . $total->format('%H:%I:%S'));
            } catch (Exception $e) {
                $this->debugError($e);
            } 
        else :
            $output->writeln('No new data');
        endif;
        return 0;
    }

    public function logError(object $error): void
    {
        $log = new Logger('MigrateCustomerCreate');
        $log->pushHandler(new StreamHandler(__DIR__ . '/../../logs/products/migrate-error.log', Logger::ERROR));

        $log->error($error);
    }

    public function logInfo(array $info)
    {
    }

    public function debugError(object $error, OutputInterface $output)
    {
        $output->writeln('error');
        $output->writeln($e);
    }
}