drkthunder02/w4rpservices
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

framework for processing assets

Browse Source
This commit is contained in:
drkthunder02
2019-05-28 03:26:33 -05:00
parent 414f35e353
commit 1e43122c3d
5 changed files with 77 additions and 163 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
app/Console/Commands/GetAssets.php Normal file
View File

@@ -0,0 +1,58 @@
<?php
namespace App\Console\Commands;
use Illuminate\Console\Command;
use DB;
use Log;
//Job
use App\Jobs\ProcessAssetsJob;
//Library
use App\Library\Esi\Esi;
use Seat\Eseye\Cache\NullCache;
use Seat\Eseye\Configuration;
use Seat\Eseye\Containers\EsiAuthentication;
use Seat\Eseye\Eseye;
//Models
use App\Models\Jobs\JobProcessAssets;
class GetAssets extends Command
{
/**
* The name and signature of the console command.
*
* @var string
*/
protected $signature = 'services:GetAssets';
/**
* The console command description.
*
* @var string
*/
protected $description = 'Gets all of the assets of a corporation.';
/**
* Create a new command instance.
*
* @return void
*/
public function __construct()
{
parent::__construct();
}
/**
* Execute the console command.
*
* @return mixed
*/
public function handle()
{
//
}
}

9
app/Console/Commands/GetStructures.php
View File

@@ -7,7 +7,7 @@ use DB;
use Log;
//Job
use App\Jobs\ProcessStructureJob;
//Library
use App\Library\Esi\Esi;
@@ -16,6 +16,9 @@ use Seat\Eseye\Configuration;
use Seat\Eseye\Containers\EsiAuthentication;
use Seat\Eseye\Eseye;
//Models
use App\Models\Jobs\JobProcessStructure;
class GetStructures extends Command
{
/**
@@ -23,7 +26,7 @@ class GetStructures extends Command
*
* @var string
*/
protected $signature = 'command:GetStructures';
protected $signature = 'services:GetStructures';
/**
* The console command description.
@@ -103,7 +106,7 @@ class GetStructures extends Command
$job->charId = 93738489;
$job->corpId = 98287666;
$job->structure = $structure;
JobProcessStructure::dispatch($job)->onQueue('default');
ProcessStructureJob::dispatch($job)->onQueue('default');
}
} while ($currentPage < $totalPages);

9
app/Jobs/ProcessStocksJob.php → app/Jobs/ProcessAssetsJob.php
View File

@@ -8,7 +8,7 @@ use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
class ProcessStocksJob implements ShouldQueue
class ProcessAssetsJob implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
@@ -19,7 +19,7 @@ class ProcessStocksJob implements ShouldQueue
*/
public function __construct()
{
$this->connection = 'redis';
//
}
/**
@@ -29,9 +29,6 @@ class ProcessStocksJob implements ShouldQueue
*/
public function handle()
{
//Delcare the class variable we need for processing
$stock = new StructureStockHelper;
//
}
}

154
app/Library/Structures/JumpBridgeFuel.php
View File

@@ -1,154 +0,0 @@
<?php
namespace App\Library\Structures;
use App\Library\Esi\Esi;
use App\Models\Esi\EsiScope;
use App\Models\Esi\EsiToken;
use Seat\Eseye\Configuration;
use Seat\Eseye\Containers\EsiAuthentication;
use Seat\Eseye\Eseye;
use Seat\Eseye\Exceptions\RequestFailedException;
class JumpBridgeFuel {
private $charId;
private $corpId;
private $hasScopes;
public function construct($charId, $corpId) {
$this->charId = $charId;
$this->corpId = $corpId;
//Set ESI Scopes true or false whether we have the correct ones
$esi = new Esi();
if($esi->HaveEsiScope($this->charId, 'esi-assets.read_corporation_assets.v1') &&
$esi->HaveEsiScope($this->charId, 'esi-corporations.read_structures.v1')) {
$this->hasScopes = true;
} else {
$this->hasScopes = false;
}
}
public function GetCorrrectScopes() {
return $this->hasScopes;
}
public function GetStructureFuel() {
}
private function GetStructures($charId, $corpId) {
//Delcare the data array for returning
$data = array();
//Get a list of structures.
$config = config('esi');
//Get the token from the database
$token = EsiToken::where(['character_id' => $charId])->get(['refresh_token']);
//Setup the ESI authentication container
$authentication = new EsiAuthentication([
'client_id' => $config['client_id'],
'secret' => $config['secret'],
'refresh_token' => $token[0]->refresh_token,
]);
//Setup the ESI authentication container
$esi = new Eseye($authentication);
//set the ESI version we need to work with
$esi->setVersion('v3');
//Set our current page
$currentPage = 1;
//Set our default total pages, and will refresh this later
$totalPages = 1;
//If more than one page is found, decode the first, then the second
do {
//Try to gather the structures from ESI
try {
$structures = $esi->page($currentPage)
->invoke('get', '/corporations/{corporation_id}/structures/', [
'corporation_id' => $corpId,
]);
} catch(RequestFailedException $e) {
return null;
}
//Set the actual total pages after we performed the esi call
$totalPages = $structures->pages;
foreach($structures as $structure) {
if($structure->type_id == 35841) {
$data = array_push($data, $structure);
}
}
} while ($currentPage < $totalPages);
//Add structures to a data array for just jump bridge type, and return the data array
return $data;
}
private function GetAssets($corpId, $structures) {
//Delcare the data array for returning
$data = array();
//Get a list of structures.
$config = config('esi');
//Get the token from the database
$token = EsiToken::where(['character_id' => $charId])->get(['refresh_token']);
//Setup the ESI authentication container
$authentication = new EsiAuthentication([
'client_id' => $config['client_id'],
'secret' => $config['secret'],
'refresh_token' => $token[0]->refresh_token,
]);
//Setup the ESI authentication container
$esi = new Eseye($authentication);
//set the ESI version we need to work with
$esi->setVersion('v3');
//Set our current page
$currentPage = 1;
//Set our default total pages, and will refresh this later
$totalPages = 1;
//If more than one page is available we want to get all the pages
do {
try {
//Try to pull the data from ESI
$assets = $esi->page($currentPage)
->invoke('get', '/corporations/{corporation_id}/assets/', [
'corporation_id' => $corpId,
]);
} catch(RequestFailedException $e) {
//If ESI fails, we just return null
return null;
}
//Set the total number of pages
$totalPages = $assets->pages;
//For each entry, we only want to save the entries
foreach($assets as $asset) {
if($asset->type_id == 16273) {
//If the type id is correct then push the data onto the array
$data = array_push($data, $asset);
}
}
} while($currentPage < $totalPages);
//Return the list of assets, the structure the asset is in, and the division,
//to the calling function
return $data;
}
}
?>

10
app/Models/Jobs/JobProcessAssets.php Normal file
View File

@@ -0,0 +1,10 @@
<?php
namespace App;
use Illuminate\Database\Eloquent\Model;
class JobProcessAssets extends Model
{
//
}