49 lines
1.5 KiB
PHP
49 lines
1.5 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs;
|
|
|
|
use App\Lib\CafelApi\Models\CafelMepPoultry;
|
|
use App\Models\CafelPoultryMiseEnPlace;
|
|
|
|
class CafelMepPoultryJob extends CafelJobs
|
|
{
|
|
/**
|
|
* Execute the job.
|
|
*
|
|
* @return void
|
|
*/
|
|
public function handle()
|
|
{
|
|
$dateDebut = now()->subDays(config('cafel.mises_en_places_retain', 370));
|
|
$this->syncWithCafelApi(
|
|
CafelMepPoultry::class,
|
|
'cafel.ldc.mepoeufs',
|
|
[
|
|
'dateDebut' => $dateDebut->format('Y-m-d'),
|
|
'dateFin' => now()->format('Y-m-d')
|
|
],
|
|
function (array $row) {
|
|
// * Validate row data
|
|
CafelMepPoultry::validateDataRow($row);
|
|
|
|
/** @var array Unique Key columns */
|
|
$uniqueColumnsKey = [];
|
|
foreach (CafelMepPoultry::UNIQUE_COLUMN_KEYS as $uField) {
|
|
$uniqueColumnsKey[$uField] = $row[$uField];
|
|
}
|
|
|
|
forward_static_call_array(
|
|
[CafelPoultryMiseEnPlace::class, 'updateOrCreate'],
|
|
[$uniqueColumnsKey, $row]
|
|
);
|
|
}
|
|
);
|
|
$this->mailInvalidRows(CafelMepPoultry::UNIQUE_COLUMN_KEYS, CafelMepPoultry::class);
|
|
|
|
// * DeleteOld MEPs
|
|
// * Garder une interstice de X jours entre la suppression et ce qu'on récupère de CAFEL
|
|
CafelPoultryMiseEnPlace::whereDate('transfert_date', '<', $dateDebut->subDays(
|
|
config('cafel.mises_en_places_retain', 370)
|
|
))->delete();
|
|
}
|
|
}
|