updated some mining ledger functions, and removed duplicate functionality

app/Jobs/Commands/MiningTaxes/FetchMiningTaxesLedgersJob.php

@@ -2,24 +2,74 @@
 
 namespace App\Jobs;
 
+//Internal Library
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
+use Carbon\Carbon;
+
+//App Library
+use Seat\Eseye\Exceptions\RequestionFailedException;
+use App\Library\Esi\Esi;
+use App\Library\Lookups\LookupHelper;
+
+//App Models
+use App\Models\MiningTax\Observer;
+use App\Models\MiningTax\Ledger;
 
 class FetchMiningTaxesLedgersJob implements ShouldQueue
 {
     use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
 
+    /**
+     * Timeout in seconds
+     * 
+     * @var int
+     */
+    public $timeout = 3600;
+
+    /**
+     * Number of job retries
+     * 
+     * @var int
+     */
+    public $tries = 3;
+
+    /**
+     * Job Variables
+     */
+    private $charId;
+    private $corpId;
+    private $observerId;
+    private $refreshToken;
+    private $esi;
+
     /**
      * Create a new job instance.
      *
      * @return void
      */
-    public function __construct()
+    public function __construct($corpId, $observerId)
     {
-        //
+        //Set the connection for the job
+        $this->connection = 'redis';
+
+        //Import the variables from the calling function
+        $this->charId = $charId;
+        $this->corpId = $corpId;
+        $this->observerId = $observerId;
+
+        $this->$esi = new Esi;
+
+        //Setup the private esi variables
+        if(!$this->esi->haveEsiScope($this->charId, 'esi-industry.read_corporation_mining.v1')) {
+            Log::critical('Character: ' . $this->charId . ' did not have the correct esi scope in FetchMiningTaxesLedgersJob.');
+            return null;
+        }
+        $this->refreshToken = $this->esi->GetRefreshToken($this->charId);
+        $this->esi = $this->esi->SetupEsiAuthentication($this->refreshToken);
     }
 
     /**
@@ -29,6 +79,50 @@ class FetchMiningTaxesLedgersJob implements ShouldQueue
      */
     public function handle()
     {
-        //
+        //Declare variables
+        $lookup = new LookupHelper;
+        $final = array();
+        $items = array();
+        $notSorted = array();
+
+        //Get the ledger from ESI
+        try {
+            $ledgers = $this->esi->invoke('get', '/corporation/{corporation_id}/mining/observers/{observer_id}/', [
+                'corporation_id' => $this->corpId,
+                'observer_id' => $this->observerId,
+            ]);
+        } catch(RequestFailedException $e) {
+            Log::warning('Failed to get the mining ledger in FetchMiningTaxesLedgersJob for observer id: ' . $this->observerId);
+            return null;
+        }
+
+        //Sort through the array, and create the variables needed for database entries
+        foreach($ledgers as $ledger) {
+            //Get some basic information we need to work with
+            $charName = $lookup->CharacterIdToName($ledger->character_id);
+            $typeName = $lookup->ItemIdToName($ledger->ore);
+            $updated = $this->esi->DecodeDate($ledger->last_updated);
+
+            //Insert or update the entry in the database
+            $item = Ledger::updateOrCreate([
+                'character_id' => $ledger->character_id,
+                'character_name' => $charName,
+                'last_updated' => $updated,
+                'type_id' => $ledger->type_id,
+                'ore_name' => $typeName,
+                'quantity' => $ledger->quantity,
+            ], [
+                'character_id' => $ledger->character_id,
+                'character_name' => $charName,
+                'last_updated' => $updated,
+                'type_id' => $ledger->type_id,
+                'ore_name' => $typeName,
+                'quantity' => $ledger->quantity,
+            ]);
+        }
+
+        //Clean up old data
+        Ledger::where(['updated_at', '<', Carbon::now()->subDays(120)])->delete();
+        
     }
 }