hcsl/app/Jobs/BoxAddJob.php

<?php

namespace App\Jobs;

use App\Model\ErrorTable;
use App\Service\Box\BoxService;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Symfony\Component\Console\Output\ConsoleOutput;
use Symfony\Component\Console\Output\OutputInterface;

class BoxAddJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    //队列名称
    const job = 'hc_box';// 包装 =》 用友产成品入库

    protected $data;
    protected $user;

    public $tries = 0;

    public function __construct($data, $user = [])
    {
        $this->data = $data ?? [];
        $this->user = $user ?? [];
    }

    /**
     *
     * file_put_contents('charge.txt',"标记位置退出".PHP_EOL,8);
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $service = new BoxService();
        try {

            list($status,$msg) = $service->boxInSettle($this->data, $this->user);
            if(! $status) {
                $service->dellimitingSendRequestBackgNeed($service->lock_key); //删除锁
                $this->recordErrorTable($msg);
            }

        } catch (\Throwable $e) {
            $service->dellimitingSendRequestBackgNeed($service->lock_key);//删除锁
            $this->delete();
            $this->recordErrorTable($e->getFile() . $e->getMessage() . $e->getLine());
        }

        //输出信息
        $this->echoMessage(new ConsoleOutput());
    }

    protected function echoMessage(OutputInterface $output)
    {
        //输出消息
        $output->writeln(json_encode($this->data));
    }

    private function recordErrorTable($msg){
        // 连接到指定数据库连接
        ErrorTable::insert([
            'msg' => $msg,
            'data' => json_encode($this->data),
            'user_id' => $this->user['id'] ?? 0,
            'user_operation_time' => time(),
            'type' => 1,
            'order_no' => $data['order_no'] ?? ""
        ]);
    }
}