135 lines
4.4 KiB
PHP
135 lines
4.4 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs;
|
|
|
|
use App\Models\BreedersDatas;
|
|
use Illuminate\Bus\Queueable;
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
|
use Illuminate\Queue\InteractsWithQueue;
|
|
use Illuminate\Queue\SerializesModels;
|
|
use Illuminate\Support\Carbon;
|
|
use Illuminate\Support\Facades\Log;
|
|
use Illuminate\Support\Str;
|
|
use Illuminate\Support\Facades\Storage;
|
|
use SimpleXMLElement;
|
|
|
|
class XmlEleveursReader implements ShouldQueue
|
|
{
|
|
use Dispatchable;
|
|
use InteractsWithQueue;
|
|
use Queueable;
|
|
use SerializesModels;
|
|
|
|
public $console = null;
|
|
|
|
public function handle()
|
|
{
|
|
$this->log(__CLASS__ . ' Démarrage du traitement');
|
|
$files = Storage::disk('eleveur')->files();
|
|
|
|
// Suppression des fichiers dans archives qui ont plus de 2j
|
|
$archives = Storage::disk('eleveur')->files('archives');
|
|
foreach ($archives as $archive) {
|
|
if ($archive == ".gitignore" || $archive == ".gitkeep") {
|
|
continue;
|
|
}
|
|
if (Storage::disk('eleveur')->lastModified($archive) < strtotime(Carbon::now()->subDays(2))) {
|
|
Storage::disk('eleveur')->delete($archive);
|
|
}
|
|
}
|
|
|
|
$progress = 0;
|
|
$total = count($files) - 1;
|
|
foreach ($files as $filename) {
|
|
if ($filename == ".gitignore" || $filename == ".gitkeep") {
|
|
continue;
|
|
}
|
|
// ---- Récupération du contenu
|
|
$file = Storage::disk('eleveur')->get($filename);
|
|
$fileContent = simplexml_load_string($file, null, LIBXML_NOCDATA);
|
|
|
|
// Transforme le fichier en tableau de données
|
|
$eleveurs = $this->extract($fileContent);
|
|
|
|
// Mise en BDD des données du fichier xml
|
|
$fields = [];
|
|
foreach ($eleveurs['ELEVEURS'] as $eleveur) {
|
|
$fields[] = $this->processFields($eleveur);
|
|
}
|
|
|
|
// Mise en base des données
|
|
foreach ($fields as $field) {
|
|
$checkFields = ['code' => $field["code"], 'code_eleveur' => $field['code_eleveur']];
|
|
BreedersDatas::updateOrCreate($checkFields, $field);
|
|
}
|
|
|
|
Storage::disk('eleveur')->move($filename, 'archives/' . $filename);
|
|
$this->log(__CLASS__ . sprintf(' traitement %d sur %s ', $progress++, $total));
|
|
}
|
|
$this->log(__CLASS__ . ' Fin du traitement');
|
|
}
|
|
|
|
private function log(string $message)
|
|
{
|
|
if ($this->console) {
|
|
$this->console->info($message);
|
|
}
|
|
Log::debug($message);
|
|
}
|
|
|
|
private function extract($sxe = null)
|
|
{
|
|
if (!$sxe instanceof SimpleXMLElement) {
|
|
return array();
|
|
}
|
|
|
|
$extract = array();
|
|
|
|
foreach ($sxe->children() as $key => $value) {
|
|
if (array_key_exists($key, $extract)) {
|
|
if (!isset($extract[$key][0])) {
|
|
$tmp_extract = $extract[$key];
|
|
$extract[$key] = array();
|
|
$extract[$key][0] = $tmp_extract;
|
|
} else {
|
|
$extract[$key] = (array)$extract[$key];
|
|
}
|
|
}
|
|
|
|
if ($value->count()) {
|
|
if (isset($extract[$key]) && is_array($extract[$key])) {
|
|
$extract[$key][] = $this->extract($value);
|
|
} else {
|
|
$extract[$key] = $this->extract($value);
|
|
}
|
|
} else {
|
|
if (isset($extract[$key]) && is_array($extract[$key])) {
|
|
$extract[$key][] = empty(strval($value)) ? null : strval($value);
|
|
} else {
|
|
$extract[$key] = empty(strval($value)) ? null : strval($value);
|
|
}
|
|
}
|
|
}
|
|
|
|
return $extract;
|
|
}
|
|
|
|
private function processFields($fields)
|
|
{
|
|
$result = [];
|
|
foreach ($fields as $key => $field) {
|
|
// Gestion des balises CodeOpa et OPA
|
|
if (is_array($field)) {
|
|
if (isset($field['OPA'])) {
|
|
$result['code_opa'] = $field['OPA']['code'];
|
|
$result['nom'] = $field['OPA']['Nom'];
|
|
}
|
|
} else {
|
|
// Le ctype_upper est la pour les balise entièrement en majuscule
|
|
$result[Str::snake(ctype_upper($key) ? strtolower($key) : $key)] = $field;
|
|
}
|
|
}
|
|
return $result;
|
|
}
|
|
}
|