hainan/app/Console/Commands/OrderTimeout.php

<?php

namespace App\Console\Commands;

use App\Common\OrderStatus;
use App\Models\AgentProduct;
use App\Models\AgentProductSpec;
use App\Models\Order;
use App\Models\Product;
use App\Models\ProductSpec;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;

class OrderTimeout extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'order:timeout';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = '订单超时未支付，取消订单并返回库存';

    /**
     * Create a new command instance.
     *
     * @return void
     */
    public function __construct()
    {
        parent::__construct();
    }

	/**
	 * Execute the console command.
	 *
	 * @return int
	 */
    public function handle()
	{
		//需要处理的订单状态
		$status_arr = [OrderStatus::UNPAID, OrderStatus::PAY_EARNEST, OrderStatus::OFFLINE_UNPAID];

		//记录最小ID，下次查询时按ID正序查询，只处理大于该ID的订单，避免重复扫描数据库
		/*$min_id = Order::query()
			->whereIn('status', $status_arr)
			->whereNotNull('timeout')
			->min('id');*/

		$current_id = 0;
    	while (true) {
			Order::with('orderProductItem')
//				->where('id', '>=', $min_id)
				->whereIn('status', $status_arr)
				->whereNotNull('timeout')
				->orderBy('id')
				->chunk(100, function ($order) use (&$current_id) {
					foreach ($order as $v) {
						if (!is_null($v->timeout) && strtotime($v->timeout) < time()) {
							DB::beginTransaction();
							try {
								//取消订单
								$v->status = OrderStatus::CANCEL;
								$v->save();

								//供应商产品加库存
								Product::whereIn('id', explode(',', $v->product_ids))->increment('stock', $v->num);

								//代理商产品加库存
								AgentProduct::where('id', $v->agent_product_id)->increment('stock', $v->num);

								if (!$v->orderProductItem->isEmpty()) {
									$item = $v->orderProductItem->toArray();

									//供应商产品规格加库存
									foreach ($item as $v2) {
										if ($v2['product_spec_id']) {
											if (is_array($v2['product_spec_id'])) {
												ProductSpec::whereIn('id', $v2['product_spec_id'])->increment('stock', $v->num);
											} else {
												ProductSpec::where('id', $v2['product_spec_id'])->increment('stock', $v->num);
											}
										}
									}

									//代理商产品规格加库存
									foreach ($item as $v2) {
										if ($v2['agent_product_spec_id']) {
											if (is_array($v2['agent_product_spec_id'])) {
												AgentProductSpec::whereIn('id', $v2['agent_product_spec_id'])->increment('stock', $v->num);
											} else {
												AgentProductSpec::where('id', $v2['agent_product_spec_id'])->increment('stock', $v->num);
											}
										}
									}
								}

								DB::commit();
								$current_id = $v->id;
							} catch (\Exception $exception) {
								DB::rollBack();
								$this->line("订单ID {$v->id} 错误：" . $exception->getMessage());
							}
						}
					}
				});

			$this->line('[' . date('Y-m-d H:i:s') . "] ID游标:$current_id ，等待下一个任务");
			sleep(5);
		}
		return 0;
    }
}