mirror of
https://github.com/firefly-iii/firefly-iii.git
synced 2024-11-27 19:31:01 -06:00
85 lines
2.3 KiB
PHP
85 lines
2.3 KiB
PHP
<?php
|
|
/**
|
|
* ImportProcedure.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\Import;
|
|
|
|
use FireflyIII\Import\Importer\ImporterInterface;
|
|
use FireflyIII\Models\ImportJob;
|
|
use FireflyIII\Repositories\Account\AccountRepositoryInterface;
|
|
use Illuminate\Support\Collection;
|
|
|
|
/**
|
|
* Class ImportProcedure
|
|
*
|
|
* @package FireflyIII\Import
|
|
*/
|
|
class ImportProcedure implements ImportProcedureInterface
|
|
{
|
|
|
|
/**
|
|
* @param ImportJob $job
|
|
*
|
|
* @return Collection
|
|
*/
|
|
public function runImport(ImportJob $job): Collection
|
|
{
|
|
// update job to say we started.
|
|
$job->status = 'import_running';
|
|
$job->save();
|
|
|
|
// create Importer
|
|
$valid = array_keys(config('firefly.import_formats'));
|
|
$class = 'INVALID';
|
|
if (in_array($job->file_type, $valid)) {
|
|
$class = config('firefly.import_formats.' . $job->file_type);
|
|
}
|
|
|
|
/** @var ImporterInterface $importer */
|
|
$importer = app($class);
|
|
$importer->setJob($job);
|
|
|
|
// create import entries
|
|
$collection = $importer->createImportEntries();
|
|
|
|
// validate / clean collection:
|
|
$validator = new ImportValidator($collection);
|
|
$validator->setUser($job->user);
|
|
$validator->setJob($job);
|
|
if ($job->configuration['import-account'] != 0) {
|
|
|
|
/** @var AccountRepositoryInterface $repository */
|
|
$repository = app(AccountRepositoryInterface::class, [$job->user]);
|
|
$validator->setDefaultImportAccount($repository->find($job->configuration['import-account']));
|
|
}
|
|
|
|
$cleaned = $validator->clean();
|
|
|
|
// then import collection:
|
|
$storage = new ImportStorage($job->user, $cleaned);
|
|
$storage->setJob($job);
|
|
|
|
// and run store routine:
|
|
$result = $storage->store();
|
|
|
|
// grab import tag:
|
|
$status = $job->extended_status;
|
|
$status['importTag'] = $storage->importTag->id;
|
|
$job->extended_status = $status;
|
|
$job->status = 'import_complete';
|
|
$job->save();
|
|
|
|
return $result;
|
|
}
|
|
|
|
}
|