<?php
/**
 * @copyright: Copyright © 2017 Firebear Studio. All rights reserved.
 * @author   : Firebear Studio <fbeardev@gmail.com>
 */

namespace Firebear\ImportExport\Console\Command;

use Magento\Backend\App\Area\FrontNameResolver;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;
use Magento\Framework\Console\Cli;

/**
 * Command prints list of available currencies
 */
class ExportJobRunCommand extends ExportJobAbstractCommand
{
    const INPUT_KEY_LOG = 'log';
    const SHORTCUT_KEY_LOG = 'l';
    const INPUT_KEY_ADMIN = 'admin';
    const SHORTCUT_KEY_ADMIN = 'a';
    const INPUT_KEY_HISTORY = 'history';
    const SHORTCUT_KEY_HISTORY = 's';

    /**
     * {@inheritdoc}
     */
    protected function configure()
    {
        $this->setName('export:job:run')
            ->setDescription('Generate Firebear Export Jobs')
            ->setDefinition(
                [
                    new InputArgument(
                        self::JOB_ARGUMENT_NAME,
                        InputArgument::OPTIONAL | InputArgument::IS_ARRAY,
                        'Space-separated list of import job ids or omit to generate all jobs.'
                    )
                ]
            );

        parent::configure();
    }

    /**
     * @param InputInterface $input
     * @param OutputInterface $output
     * @return void
     * @throws \Magento\Framework\Exception\LocalizedException
     */
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $isAreaCode = 0;
        try {
            if ($this->state->getAreaCode()) {
                $isAreaCode = 1;
            }
        } catch (\Exception $e) {
            $isAreaCode = 0;
        }
        if (!$isAreaCode) {
            $this->state->setAreaCode(FrontNameResolver::AREA_CODE);
        }
        $timeStart = time();
        $requestedIds = $input->getArgument(self::JOB_ARGUMENT_NAME);
        $requestedIds = array_filter(array_map('trim', $requestedIds), 'strlen');
        $jobCollection = $this->factory->create()->getCollection();
        $jobCollection->addFieldToFilter('is_active', 1);

        if ($requestedIds) {
            $jobCollection->addFieldToFilter('entity_id', ['in' => $requestedIds]);
        }

        if ($jobCollection->getSize()) {
            foreach ($jobCollection as $job) {
                $id = (int)$job->getEntityId();
                $result = false;
                try {
                    $file = $this->helper->beforeRun($id);
                    $history = $this->helper->createExportHistory($id, $file, 'console');
                    $this->processor->debugMode = $this->debugMode = $this->helper->getDebugMode();
                    $this->processor->setLogger($this->helper->getLogger());
                    $this->processor->inConsole = 1;
                    $result = $this->processor->process($id, $history);
                    $timeFinish = time();
                    $totalTime = $timeFinish - $timeStart;
                    if ($result === true) {
                        $this->addLogComment(
                            'Job #' . $id . ' was generated successfully in ' . $totalTime . ' seconds',
                            $output,
                            'info'
                        );
                    } else {
                        $this->addLogComment(
                            is_array($result) ? $result[0] : $result,
                            $output,
                            'error'
                        );
                    }
                    $this->helper->saveFinishExHistory($history);
                } catch (\Exception $e) {
                    $this->addLogComment(
                        'Job #' . $id . ' can\'t be exported. Check if job exist',
                        $output,
                        'error'
                    );
                    $this->addLogComment(
                        $e->getMessage(),
                        $output,
                        'error'
                    );
                    return Cli::RETURN_FAILURE;
                } finally {
                    $this->sender->sendEmail(
                        $job,
                        $file,
                        (int)$result
                    );
                }
            }
        } else {
            $this->addLogComment(
                'No jobs found',
                $output,
                'error'
            );
        }
        return Cli::RETURN_SUCCESS;
    }

    /**
     * @param $jobId
     * @param $lastEntityId
     * @throws \Magento\Framework\Exception\LocalizedException
     */
    protected function updateLastEntityId($jobId, $lastEntityId)
    {
        $exportJob = $this->repository->getById($jobId);
        $sourceData = $exportJob->getExportSource();
        $sourceData = array_merge(
            $sourceData,
            [
                'last_entity_id' => $lastEntityId
            ]
        );
        $exportJob->setExportSource($sourceData);
        $this->repository->save($exportJob);
    }
}