charId = $jpa->charId; $this->corpId = $jpa->corpId; $this->page = $jpa->page; //Set the connection for the job $this->connection = 'redis'; } /** * Execute the job. * The job's task is to get all fo the information for all of the assets in * a structure and store them in the database. This task can take a few seconds * therefore we want the Horizon job queue to take care of the request rather * than the cronjob. * * @return void */ public function handle() { //Declare the asset helper $aHelper = new AssetHelper($this->charId, $this->corpId); //Get a page of assets $assets = $aHelper->GetAssetsByPage($this->page); //Cycle through the assets, and attmept to store them. foreach($assets as $asset) { //Attempt to store the asset $aHelper->StoreNewAsset($asset); } //Purge Stale Data $aHelper->PurgeStaleData(); } }