152 lines
3.5 KiB
PHP
152 lines
3.5 KiB
PHP
<?php
|
|
|
|
namespace App\Services;
|
|
|
|
use App\Contracts\ImportExport;
|
|
use App\Contracts\Service;
|
|
use App\Services\ImportExport\AircraftExporter;
|
|
use App\Services\ImportExport\AirportExporter;
|
|
use App\Services\ImportExport\ExpenseExporter;
|
|
use App\Services\ImportExport\FareExporter;
|
|
use App\Services\ImportExport\FlightExporter;
|
|
use App\Services\ImportExport\SubfleetExporter;
|
|
use Illuminate\Support\Collection;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Illuminate\Support\Facades\Storage;
|
|
use League\Csv\CharsetConverter;
|
|
use League\Csv\Writer;
|
|
|
|
class ExportService extends Service
|
|
{
|
|
/**
|
|
* @param string $path
|
|
*
|
|
* @return Writer
|
|
*/
|
|
public function openCsv($path): Writer
|
|
{
|
|
$writer = Writer::createFromPath($path, 'w+');
|
|
CharsetConverter::addTo($writer, 'utf-8', 'utf-8');
|
|
|
|
return $writer;
|
|
}
|
|
|
|
/**
|
|
* Run the actual importer
|
|
*
|
|
* @param Collection $collection
|
|
* @param ImportExport $exporter
|
|
*
|
|
* @throws \League\Csv\CannotInsertRecord
|
|
*
|
|
* @return string
|
|
*/
|
|
protected function runExport(Collection $collection, ImportExport $exporter): string
|
|
{
|
|
$filename = 'export_'.$exporter->assetType.'.csv';
|
|
|
|
// Create the directory - makes it inside of storage/app
|
|
Storage::makeDirectory('import');
|
|
$path = storage_path('/app/import/export_'.$filename.'.csv');
|
|
|
|
Log::info('Exporting "'.$exporter->assetType.'" to '.$path);
|
|
|
|
$writer = $this->openCsv($path);
|
|
|
|
// Write out the header first
|
|
$writer->insertOne($exporter->getColumns());
|
|
|
|
// Write the rest of the rows
|
|
foreach ($collection as $row) {
|
|
$ins = $exporter->export($row);
|
|
$writer->insertOne($ins);
|
|
}
|
|
|
|
return $path;
|
|
}
|
|
|
|
/**
|
|
* Export all of the aircraft
|
|
*
|
|
* @param Collection $aircraft
|
|
*
|
|
* @throws \League\Csv\CannotInsertRecord
|
|
*
|
|
* @return mixed
|
|
*/
|
|
public function exportAircraft($aircraft)
|
|
{
|
|
return $this->runExport($aircraft, new AircraftExporter());
|
|
}
|
|
|
|
/**
|
|
* Export all of the airports
|
|
*
|
|
* @param Collection $airports
|
|
*
|
|
* @throws \League\Csv\CannotInsertRecord
|
|
*
|
|
* @return mixed
|
|
*/
|
|
public function exportAirports($airports)
|
|
{
|
|
return $this->runExport($airports, new AirportExporter());
|
|
}
|
|
|
|
/**
|
|
* Export all of the airports
|
|
*
|
|
* @param Collection $expenses
|
|
*
|
|
* @throws \League\Csv\CannotInsertRecord
|
|
*
|
|
* @return mixed
|
|
*/
|
|
public function exportExpenses($expenses)
|
|
{
|
|
return $this->runExport($expenses, new ExpenseExporter());
|
|
}
|
|
|
|
/**
|
|
* Export all of the fares
|
|
*
|
|
* @param Collection $fares
|
|
*
|
|
* @throws \League\Csv\CannotInsertRecord
|
|
*
|
|
* @return mixed
|
|
*/
|
|
public function exportFares($fares)
|
|
{
|
|
return $this->runExport($fares, new FareExporter());
|
|
}
|
|
|
|
/**
|
|
* Export all of the flights
|
|
*
|
|
* @param Collection $flights
|
|
*
|
|
* @throws \League\Csv\CannotInsertRecord
|
|
*
|
|
* @return mixed
|
|
*/
|
|
public function exportFlights($flights)
|
|
{
|
|
return $this->runExport($flights, new FlightExporter());
|
|
}
|
|
|
|
/**
|
|
* Export all of the flights
|
|
*
|
|
* @param Collection $subfleets
|
|
*
|
|
* @throws \League\Csv\CannotInsertRecord
|
|
*
|
|
* @return mixed
|
|
*/
|
|
public function exportSubfleets($subfleets)
|
|
{
|
|
return $this->runExport($subfleets, new SubfleetExporter());
|
|
}
|
|
}
|