Очереди Laravel не сохраняют сущность в БД

Question

, пожалуйста, помогите, возможно, я делаю или понял что-то не так.Я создаю массовую загрузку в базу данных, что занимает немного времени, поэтому я решил сделать асинхронное все и обработать его в фоновом режиме, используя Laravel Queues.

В контроллере я создаю связанный список, который передается в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);

В Laravel Job я пытаюсь создать объект и загрузить его в базу данных

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);
      }
}

Однако каждый раз, когда я пытаюсь это сделать, я вижу в своих журналах:

 #0 app\Utilities\Updater.php(18): Illuminate\Foundation\Bootstrap\HandleExceptions->handleError(8, 'Trying to get p...', '...', 18, Array)
 #1 vendor\laravel\framework\src\Illuminate\Events\Dispatcher.php(348): Modules\Accounting\Entities\InvoicesOrder::App\Utilities\{closure}(Object(Modules\Accounting\Entities\InvoicesOrder))
 #2 vendor\laravel\framework\src\Illuminate\Events\Dispatcher.php(199): Illuminate\Events\Dispatcher->Illuminate\Events\{closure}('eloquent.creati...', Array)
 #3 vendor\laravel\framework\src\Illuminate\Events\Dispatcher.php(159): Illuminate\Events\Dispatcher->dispatch('eloquent.creati...', Array, true)
 #4 vendor\laravel\framework\src\Illuminate\Database\Eloquent\Concerns\HasEvents.php(148): Illuminate\Events\Dispatcher->until('eloquent.creati...', Object(Modules\Accounting\Entities\InvoicesOrder))
 #5 vendor\laravel\framework\src\Illuminate\Database\Eloquent\Model.php(636): Illuminate\Database\Eloquent\Model->fireModelEvent('creating')
 #6 vendor\laravel\framework\src\Illuminate\Database\Eloquent\Model.php(522): Illuminate\Database\Eloquent\Model->performInsert(Object(Illuminate\Database\Eloquent\Builder))
 #7 Modules\Accounting\Jobs\ImportFiles.php(39): Illuminate\Database\Eloquent\Model->save()
 #8 [internal function]: Modules\Accounting\Jobs\ImportFiles->handle()
 #9 vendor\laravel\framework\src\Illuminate\Container\BoundMethod.php(29): call_user_func_array(Array, Array)
 #10 vendor\laravel\framework\src\Illuminate\Container\BoundMethod.php(87): Illuminate\Container\BoundMethod::Illuminate\Container\{closure}()
 #11 vendor\laravel\framework\src\Illuminate\Container\BoundMethod.php(31): Illuminate\Container\BoundMethod::callBoundMethod(Object(Illuminate\Foundation\Application), Array, Object(Closure))
 #12 vendor\laravel\framework\src\Illuminate\Container\Container.php(539): Illuminate\Container\BoundMethod::call(Object(Illuminate\Foundation\Application), Array, Array, NULL)
 #13 vendor\laravel\framework\src\Illuminate\Bus\Dispatcher.php(94): Illuminate\Container\Container->call(Array)
 #14 vendor\laravel\framework\src\Illuminate\Pipeline\Pipeline.php(114): Illuminate\Bus\Dispatcher->Illuminate\Bus\{closure}(Object(Modules\Accounting\Jobs\ImportFiles))
 #15 vendor\laravel\framework\src\Illuminate\Pipeline\Pipeline.php(102): Illuminate\Pipeline\Pipeline->Illuminate\Pipeline\{closure}(Object(Modules\Accounting\Jobs\ImportFiles))
 #16 vendor\laravel\framework\src\Illuminate\Bus\Dispatcher.php(98): Illuminate\Pipeline\Pipeline->then(Object(Closure))
 #17 vendor\laravel\framework\src\Illuminate\Queue\CallQueuedHandler.php(42): Illuminate\Bus\Dispatcher->dispatchNow(Object(Modules\Accounting\Jobs\ImportFiles), false)
 #18 vendor\laravel\framework\src\Illuminate\Queue\Jobs\Job.php(69): Illuminate\Queue\CallQueuedHandler->call(Object(Illuminate\Queue\Jobs\RedisJob), Array)
 #19 vendor\laravel\framework\src\Illuminate\Queue\Worker.php(317): Illuminate\Queue\Jobs\Job->fire()

Всякий раз, когда я делаю это в контроллере, он работает нормально, он просто загружается очень долго.Может быть, невозможно сохранить объекты в Job с помощью очередей?

Спасибо.

Answer 1

Если кто-то сталкивается с подобной проблемой, проверьте свою сущность, используете ли вы какой-либо презентатор (я использовал презентабельную черту), который добавляет поля, такие как созданные / обновленные.И что мы получаем из Auth :: user () -> id ... Попытка получить свойство не объекта, поскольку очередь не является пользователем.

Answer 2

Поскольку работники очереди являются долгоживущими процессами, они не будут воспринимать изменения в вашем коде без перезапуска. Итак, самый простой способ развертывания приложения с использованием работников очереди - это перезапустить работников во время процесса развертывания. Вы можете корректно перезапустить всех рабочих, введя команду queue: restart:

php artisan queue:restart

Answer 3

В вашей работе вы вставляете данные в свойство $this->importData.

но в методе handle вы перебираете $invoiceOrdersArray, откуда это взялось?

Должна ли ваша петля выглядеть не так?

foreach($this->importData as $insert)
{
     InvoicesOrder::create($insert);
}

Вам даже не нужна неиспользуемая переменная $order в методе handle.

Кроме того, я думаю, вам нужно use класс InvoicesOrder в работе. Так что все это может выглядеть так.

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);
        }
    }
}