neiyou_user_web/app/Console/Commands/ServiceTimer.php

<?php

namespace App\Console\Commands;

use App\Components\Helpers;
use App\Http\Controllers\ServiceController;
use App\Models\Order;
use App\Models\User;
use DB;
use Exception;
use Illuminate\Console\Command;
use Log;

class ServiceTimer extends Command {
	protected $signature = 'serviceTimer';
	protected $description = '服务计时器';

	public function handle(): void {
		$jobStartTime = microtime(true);

		// 扣减用户到期商品的流量
		$this->decGoodsTraffic();

		$jobEndTime = microtime(true);
		$jobUsedTime = round(($jobEndTime - $jobStartTime), 4);

		Log::info('---【'.$this->description.'】完成---，耗时'.$jobUsedTime.'秒');
	}

	// 扣减用户到期商品的流量
	private function decGoodsTraffic(): void {
		//获取失效的套餐
		$orderList = Order::query()
		                  ->with(['goods'])
		                  ->whereStatus(2)
		                  ->whereIsExpire(0)
		                  ->whereHas('goods', static function($q) {
			                  $q->whereType(2);
		                  })
		                  ->where('expire_at', '<=', date('Y-m-d H:i:s'))
		                  ->get();
		if($orderList->isNotEmpty()){
			try{
				DB::beginTransaction();
				foreach($orderList as $order){
					// 过期本订单
					Order::query()->whereOid($order->oid)->update(['is_expire' => 1]);

					// 过期生效中的加油包
					Order::query()
					     ->with(['goods'])
					     ->whereUserId($order->user_id)
					     ->whereStatus(2)
					     ->whereIsExpire(0)
					     ->whereHas('goods', static function($q) {
						     $q->whereType(1);
					     })
					     ->update(['is_expire' => 1]);

					if(empty($order->user) || empty($order->goods)){
						continue;
					}

					// 清理全部流量,重置重置日期和等级
					User::query()->whereId($order->user_id)->update([
						'u'               => 0,
						'd'               => 0,
						'transfer_enable' => 0,
						'reset_time'      => null,
						'level'           => 0
					]);
					Helpers::addUserTrafficModifyLog($order->user_id, $order->oid, $order->user->transfer_enable, 0,
						'[定时任务]用户所购商品到期，扣减商品对应的流量');

					// 检查该订单对应用户是否有预支付套餐
					$prepaidOrder = Order::query()
					                     ->whereUserId($order->user_id)
					                     ->whereStatus(3)
					                     ->orderBy('oid')
					                     ->first();

					if($prepaidOrder){
						(new ServiceController)->activePrepaidOrder($prepaidOrder->oid);
					}
				}

				DB::commit();
			}catch(Exception $e){
				Log::error($this->description.'：'.$e);

				DB::rollBack();
			}
		}
	}
}