mirror of
https://github.com/firefly-iii/firefly-iii.git
synced 2025-01-24 15:26:33 -06:00
119 lines
2.9 KiB
PHP
119 lines
2.9 KiB
PHP
<?php
|
|
/**
|
|
* Import.php
|
|
* Copyright (C) 2016 thegrumpydictator@gmail.com
|
|
*
|
|
* This software may be modified and distributed under the terms of the
|
|
* Creative Commons Attribution-ShareAlike 4.0 International License.
|
|
*
|
|
* See the LICENSE file for details.
|
|
*/
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace FireflyIII\Console\Commands;
|
|
|
|
use FireflyIII\Import\Logging\CommandHandler;
|
|
use FireflyIII\Import\Routine\ImportRoutine;
|
|
use FireflyIII\Models\ImportJob;
|
|
use Illuminate\Console\Command;
|
|
use Illuminate\Support\MessageBag;
|
|
use Log;
|
|
|
|
/**
|
|
* Class Import
|
|
*
|
|
* @package FireflyIII\Console\Commands
|
|
*/
|
|
class Import extends Command
|
|
{
|
|
/**
|
|
* The console command description.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $description = 'This will start a new import.';
|
|
|
|
/**
|
|
* The name and signature of the console command.
|
|
*
|
|
* @var string
|
|
*/
|
|
protected $signature = 'firefly:start-import {key}';
|
|
|
|
/**
|
|
* Create a new command instance.
|
|
*
|
|
*/
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
}
|
|
|
|
/**
|
|
* Run the import routine.
|
|
*/
|
|
public function handle()
|
|
{
|
|
Log::debug('Start start-import command');
|
|
$jobKey = $this->argument('key');
|
|
$job = ImportJob::where('key', $jobKey)->first();
|
|
if (is_null($job)) {
|
|
$this->error(sprintf('No job found with key "%s"', $jobKey));
|
|
|
|
return;
|
|
}
|
|
if (!$this->isValid($job)) {
|
|
Log::error('Job is not valid for some reason. Exit.');
|
|
|
|
return;
|
|
}
|
|
|
|
$this->line(sprintf('Going to import job with key "%s" of type "%s"', $job->key, $job->file_type));
|
|
|
|
$monolog = Log::getMonolog();
|
|
$handler = new CommandHandler($this);
|
|
$monolog->pushHandler($handler);
|
|
|
|
/** @var ImportRoutine $routine */
|
|
$routine = app(ImportRoutine::class);
|
|
$routine->setJob($job);
|
|
$routine->run();
|
|
|
|
/** @var MessageBag $error */
|
|
foreach ($routine->errors as $index => $error) {
|
|
$this->error(sprintf('Error importing line #%d: %s', $index, $error));
|
|
}
|
|
|
|
$this->line(sprintf('The import has finished. %d transactions have been imported out of %d records.', $routine->journals->count(), $routine->lines));
|
|
|
|
return;
|
|
}
|
|
|
|
/**
|
|
* Check if job is valid to be imported.
|
|
*
|
|
* @param ImportJob $job
|
|
*
|
|
* @return bool
|
|
*/
|
|
private function isValid(ImportJob $job): bool
|
|
{
|
|
if (is_null($job)) {
|
|
Log::error('This job does not seem to exist.');
|
|
$this->error('This job does not seem to exist.');
|
|
|
|
return false;
|
|
}
|
|
|
|
if ($job->status !== 'configured') {
|
|
Log::error(sprintf('This job is not ready to be imported (status is %s).', $job->status));
|
|
$this->error('This job is not ready to be imported.');
|
|
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
}
|