From c95f6835ca3183b6152b52f2daed44ffd40ed0dc Mon Sep 17 00:00:00 2001 From: drkthunder02 Date: Mon, 22 Feb 2021 19:47:57 +0900 Subject: [PATCH] fetch mining taxes ledgers job --- .../Commands/MiningTaxes/MiningTaxesLedgers.php | 14 +++++++++++++- .../Commands/MiningTaxes/MiningTaxesObservers.php | 2 +- 2 files changed, 14 insertions(+), 2 deletions(-) diff --git a/app/Console/Commands/MiningTaxes/MiningTaxesLedgers.php b/app/Console/Commands/MiningTaxes/MiningTaxesLedgers.php index ab936a4f4..56dc26721 100644 --- a/app/Console/Commands/MiningTaxes/MiningTaxesLedgers.php +++ b/app/Console/Commands/MiningTaxes/MiningTaxesLedgers.php @@ -9,6 +9,9 @@ use Log; //Application Library use Commands\Library\CommandHelper; +//Models +use App\Models\MiningTax\Observer; + //Jobs use App\Jobs\Commands\MiningTaxes\FetchMiningTaxesLedgersJob; @@ -50,7 +53,16 @@ class MiningTaxesLedgers extends Command //Set the task as started $task->SetStartStatus(); - FetchMiningTaxesLedgersJob::dispatch()->onQueue('miningtaxes'); + //Get the site configuration which holds some data we need + $config = config('esi'); + //Get the observers from the database + $observers = Observer::all(); + + //For each of the observers, send a job to fetch the mining ledger + foreach($observers as $obs) { + //Dispatch the mining taxes ledger jobs + FetchMiningTaxesLedgersJob::dispatch($config['corporation'], $obs->observer_id)->onQueue('miningtaxes'); + } //Return 0 return 0; diff --git a/app/Console/Commands/MiningTaxes/MiningTaxesObservers.php b/app/Console/Commands/MiningTaxes/MiningTaxesObservers.php index db9b0fdc1..c68492214 100644 --- a/app/Console/Commands/MiningTaxes/MiningTaxesObservers.php +++ b/app/Console/Commands/MiningTaxes/MiningTaxesObservers.php @@ -104,7 +104,7 @@ class MiningTaxesObservers extends Command /** * Cleanup stale data that hasn't been updated in at least 1 week. */ - $date = Carbon::now()->subDay(7); + $date = Carbon::now()->subMonths(2); Observer::where('last_updated', '<', $date)->delete();