116 lines
2.6 KiB
PHP
116 lines
2.6 KiB
PHP
<?php
|
|
|
|
namespace App\Services;
|
|
|
|
use App\Interfaces\Service;
|
|
use Carbon\Carbon;
|
|
use Illuminate\Database\QueryException;
|
|
use Illuminate\Support\Facades\DB;
|
|
use Symfony\Component\Yaml\Yaml;
|
|
use Webpatser\Uuid\Uuid;
|
|
|
|
/**
|
|
* Class DatabaseService
|
|
* @package App\Services
|
|
*/
|
|
class DatabaseService extends Service
|
|
{
|
|
protected $time_fields = [
|
|
'created_at',
|
|
'updated_at'
|
|
];
|
|
|
|
protected $uuid_tables = [
|
|
'acars',
|
|
'flights',
|
|
'pireps',
|
|
];
|
|
|
|
/**
|
|
* @return string
|
|
*/
|
|
protected function time(): string
|
|
{
|
|
return Carbon::now('UTC'); //->format('Y-m-d H:i:s');
|
|
}
|
|
|
|
/**
|
|
* @param $yaml_file
|
|
* @param bool $ignore_errors
|
|
* @return array
|
|
* @throws \Exception
|
|
*/
|
|
public function seed_from_yaml_file($yaml_file, $ignore_errors = false): array
|
|
{
|
|
$yml = file_get_contents($yaml_file);
|
|
return $this->seed_from_yaml($yml, $ignore_errors);
|
|
}
|
|
|
|
/**
|
|
* @param $yml
|
|
* @param bool $ignore_errors
|
|
* @return array
|
|
* @throws \Exception
|
|
*/
|
|
public function seed_from_yaml($yml, $ignore_errors = false): array
|
|
{
|
|
$imported = [];
|
|
$yml = Yaml::parse($yml);
|
|
foreach ($yml as $table => $rows) {
|
|
$imported[$table] = 0;
|
|
|
|
foreach ($rows as $row) {
|
|
try {
|
|
$row = $this->insert_row($table, $row);
|
|
} catch(QueryException $e) {
|
|
if ($ignore_errors) {
|
|
continue;
|
|
}
|
|
|
|
throw $e;
|
|
}
|
|
|
|
++$imported[$table];
|
|
}
|
|
}
|
|
|
|
return $imported;
|
|
}
|
|
|
|
/**
|
|
* @param $table
|
|
* @param $row
|
|
* @return mixed
|
|
* @throws \Exception
|
|
*/
|
|
public function insert_row($table, $row) {
|
|
# see if this table uses a UUID as the PK
|
|
# if no ID is specified
|
|
if (\in_array($table, $this->uuid_tables, true)) {
|
|
if (!array_key_exists('id', $row)) {
|
|
$row['id'] = Uuid::generate()->string;
|
|
}
|
|
}
|
|
|
|
# encrypt any password fields
|
|
if (array_key_exists('password', $row)) {
|
|
$row['password'] = bcrypt($row['password']);
|
|
}
|
|
|
|
# if any time fields are == to "now", then insert the right time
|
|
foreach($row as $column => $value) {
|
|
if(strtolower($value) === 'now') {
|
|
$row[$column] = $this->time();
|
|
}
|
|
}
|
|
|
|
try {
|
|
DB::table($table)->insert($row);
|
|
} catch (QueryException $e) {
|
|
throw $e;
|
|
}
|
|
|
|
return $row;
|
|
}
|
|
}
|