phpvms/app/Services/DatabaseService.php

72 lines
1.8 KiB
PHP
Raw Normal View History

2017-06-25 00:09:27 +08:00
<?php
namespace App\Services;
use Log;
use Carbon\Carbon;
use Illuminate\Database\QueryException;
2017-06-25 02:20:24 +08:00
use Webpatser\Uuid\Uuid;
use Symfony\Component\Yaml\Yaml;
use Illuminate\Support\Facades\DB;
2017-06-25 00:09:27 +08:00
2017-06-25 02:20:24 +08:00
class DatabaseService extends BaseService
{
2017-06-25 02:30:13 +08:00
protected $time_fields = [
2017-06-25 02:23:30 +08:00
'created_at',
'updated_at'
];
2017-06-25 02:30:13 +08:00
protected $uuid_tables = [
2017-06-25 02:20:24 +08:00
'flights',
2017-06-25 02:20:39 +08:00
'pireps',
2017-06-25 02:20:24 +08:00
];
2017-06-25 00:09:27 +08:00
protected function time(): string
{
return Carbon::now('UTC')->format('Y-m-d H:i:s');
}
2017-06-25 02:20:24 +08:00
public function seed_from_yaml_file($yaml_file)
{
2017-06-25 02:20:24 +08:00
$yml = file_get_contents($yaml_file);
$this->seed_from_yaml($yml);
}
2017-06-25 02:20:24 +08:00
public function seed_from_yaml($yml)
{
$yml = Yaml::parse($yml);
foreach ($yml as $table => $rows) {
foreach ($rows as $row) {
2017-06-25 02:20:24 +08:00
# see if this table uses a UUID as the PK
# if no ID is specified
if(in_array($table, $this->uuid_tables)) {
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
2017-06-25 02:23:30 +08:00
foreach($this->time_fields as $tf) {
if(array_key_exists($tf, $row) && $row[$tf] === 'now') {
$row[$tf] = $this->time();
}
}
try {
DB::table($table)->insert($row);
} catch(QueryException $e) {
Log::info($e->getMessage());
}
}
}
}
2017-06-25 00:09:27 +08:00
}