Ndtyjky

please help, I might be doing or understood something wrong.
I am creating a mass upload to database, which takes a little bit of time so I decided to make async all and proccess it in background using Laravel Queues.

In controller I create an associated list, which is passed to Laravel Job.

foreach($data as $row)

    {

        $instantArray = array();

        $orderDate = PHPExcel_Shared_Date::ExcelToPHPObject($row[3]);

        $issueDate = PHPExcel_Shared_Date::ExcelToPHPObject($row[4]);

        $orderRow = array(

            'invoice_no' => trim($row[0]),

            'agent_id' => $row[1],

            'issued_at' => $orderDate->format('Y-m-d'),

            'received_at' => $issueDate->format('Y-m-d'),

        );

        $gameArray = array();

        $invoiceOrdersArray = $orderRow;

    }



$job = (new Import($invoiceOrdersArray));

dispatch($job);

In Laravel Job I am trying to create an entyty and upload it to database

class Import implements ShouldQueue

{

  use InteractsWithQueue, SerializesModels, Queueable, Dispatchable;

  protected $importData;

  public function __construct($importData)

  {

      $this->importData = $importData;

  }



  public function handle()

  {

      foreach($this->importData as $insert)

      {

         InvoicesOrder::create($insert);

      }

}

However, every time I am trying I can see in my logs:

 #0 appUtilitiesUpdater.php(18): IlluminateFoundationBootstrapHandleExceptions->handleError(8, 'Trying to get p...', '...', 18, Array)

 #1 vendorlaravelframeworksrcIlluminateEventsDispatcher.php(348): ModulesAccountingEntitiesInvoicesOrder::AppUtilities{closure}(Object(ModulesAccountingEntitiesInvoicesOrder))

 #2 vendorlaravelframeworksrcIlluminateEventsDispatcher.php(199): IlluminateEventsDispatcher->IlluminateEvents{closure}('eloquent.creati...', Array)

 #3 vendorlaravelframeworksrcIlluminateEventsDispatcher.php(159): IlluminateEventsDispatcher->dispatch('eloquent.creati...', Array, true)

 #4 vendorlaravelframeworksrcIlluminateDatabaseEloquentConcernsHasEvents.php(148): IlluminateEventsDispatcher->until('eloquent.creati...', Object(ModulesAccountingEntitiesInvoicesOrder))

 #5 vendorlaravelframeworksrcIlluminateDatabaseEloquentModel.php(636): IlluminateDatabaseEloquentModel->fireModelEvent('creating')

 #6 vendorlaravelframeworksrcIlluminateDatabaseEloquentModel.php(522): IlluminateDatabaseEloquentModel->performInsert(Object(IlluminateDatabaseEloquentBuilder))

 #7 ModulesAccountingJobsImportFiles.php(39): IlluminateDatabaseEloquentModel->save()

 #8 [internal function]: ModulesAccountingJobsImportFiles->handle()

 #9 vendorlaravelframeworksrcIlluminateContainerBoundMethod.php(29): call_user_func_array(Array, Array)

 #10 vendorlaravelframeworksrcIlluminateContainerBoundMethod.php(87): IlluminateContainerBoundMethod::IlluminateContainer{closure}()

 #11 vendorlaravelframeworksrcIlluminateContainerBoundMethod.php(31): IlluminateContainerBoundMethod::callBoundMethod(Object(IlluminateFoundationApplication), Array, Object(Closure))

 #12 vendorlaravelframeworksrcIlluminateContainerContainer.php(539): IlluminateContainerBoundMethod::call(Object(IlluminateFoundationApplication), Array, Array, NULL)

 #13 vendorlaravelframeworksrcIlluminateBusDispatcher.php(94): IlluminateContainerContainer->call(Array)

 #14 vendorlaravelframeworksrcIlluminatePipelinePipeline.php(114): IlluminateBusDispatcher->IlluminateBus{closure}(Object(ModulesAccountingJobsImportFiles))

 #15 vendorlaravelframeworksrcIlluminatePipelinePipeline.php(102): IlluminatePipelinePipeline->IlluminatePipeline{closure}(Object(ModulesAccountingJobsImportFiles))

 #16 vendorlaravelframeworksrcIlluminateBusDispatcher.php(98): IlluminatePipelinePipeline->then(Object(Closure))

 #17 vendorlaravelframeworksrcIlluminateQueueCallQueuedHandler.php(42): IlluminateBusDispatcher->dispatchNow(Object(ModulesAccountingJobsImportFiles), false)

 #18 vendorlaravelframeworksrcIlluminateQueueJobsJob.php(69): IlluminateQueueCallQueuedHandler->call(Object(IlluminateQueueJobsRedisJob), Array)

 #19 vendorlaravelframeworksrcIlluminateQueueWorker.php(317): IlluminateQueueJobsJob->fire()

Whenever I do it in controller it works fine, it just loads very long.
Maybe it is not possible to save entities in Job using queues?

Thank you.

In your job you insert the data in the $this->importData property.

but in the handle method, you're looping over $invoiceOrdersArray, where does that come from?

Should your loop, not look like this?

foreach($this->importData as $insert)

{

     InvoicesOrder::create($insert);

}

You don't even need the unused $order variable in the handle method.

Also, I think you need to use the InvoicesOrder class in the job. So the whole thing might look like this.

use namespace/to/InvoicesOrder;



class Import implements ShouldQueue

{

    use InteractsWithQueue, SerializesModels, Queueable, Dispatchable;



    protected $importData;

    public function __construct($importData)

    {

         $this->importData = $importData;

    }



    public function handle()

    {

        foreach($$this->importData as $insert)

        {

            InvoicesOrder::create($insert);

        }

    }

}

If anyone bumps into the similar problem, check in your entity if you are using any kind of presenters (I was using presentable trait), which adds fields like created/updated by. And what do we get from Auth::user()->id... Trying to get a property of non object, as queue is not an user.

Since queue workers are long-lived processes, they will not pick up changes to your code without being restarted. So, the simplest way to deploy an application using queue workers is to restart the workers during your deployment process. You may gracefully restart all of the workers by issuing the queue:restart command:

php artisan queue:restart