neiyou_user_web/app/Console/Commands/DailyJob.php

<?php

namespace App\Console\Commands;

use App\Components\Helpers;
use App\Components\PushNotification;
use App\Models\Invite;
use App\Models\Order;
use App\Models\Ticket;
use App\Models\User;
use App\Models\UserBanedLog;
use App\Services\OrderService;
use Illuminate\Console\Command;
use Log;

class DailyJob extends Command {
	protected $signature = 'dailyJob';
	protected $description = '每日任务';

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

		// 过期用户处理
		$this->expireUser();

		// 关闭超过72小时未处理的工单
		$this->closeTickets();

		// 重置用户流量
		if(sysConfig('reset_traffic')){
			$this->resetUserTraffic();
		}

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

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

	private function expireUser(): void {
		// 过期用户处理
		$userList = User::activeUser()->where('expired_at', '<', date('Y-m-d'))->get();
		$isBanStatus = sysConfig('is_ban_status');
		foreach($userList as $user){
			if($isBanStatus){
				$user->update([
					'u'               => 0,
					'd'               => 0,
					'transfer_enable' => 0,
					'enable'          => 0,
					'reset_time'      => null,
					'ban_time'        => null,
					'status'          => -1
				]);

				$this->addUserBanLog($user->id, 0, '【禁止登录，清空账户】-账号已过期');

				// 废除其名下邀请码
				Invite::whereInviterId($user->id)->whereStatus(0)->update(['status' => 2]);

				// 写入用户流量变动记录
				Helpers::addUserTrafficModifyLog($user->id, 0, $user->transfer_enable, 0, '[定时任务]账号已过期(禁止登录，清空账户)');
			}else{
				$user->update([
					'u'               => 0,
					'd'               => 0,
					'transfer_enable' => 0,
					'enable'          => 0,
					'reset_time'      => null,
					'ban_time'        => null
				]);

				$this->addUserBanLog($user->id, 0, '【封禁代理，清空账户】-账号已过期');

				// 写入用户流量变动记录
				Helpers::addUserTrafficModifyLog($user->id, 0, $user->transfer_enable, 0, '[定时任务]账号已过期(封禁代理，清空账户)');
			}
		}
	}

	/**
	 * 添加用户封禁日志
	 *
	 * @param  int     $userId       用户ID
	 * @param  int     $time         封禁时长，单位分钟
	 * @param  string  $description  封禁理由
	 * @return bool
	 */
	private function addUserBanLog($userId, $time, $description): bool {
		$log = new UserBanedLog();
		$log->user_id = $userId;
		$log->time = $time;
		$log->description = $description;
		return $log->save();
	}

	// 关闭超过72小时未处理的工单
	private function closeTickets(): void {
		$ticketList = Ticket::where('updated_at', '<=', date('Y-m-d', strtotime("-3 days")))->whereStatus(1)->get();
		foreach($ticketList as $ticket){
			$ret = Ticket::whereId($ticket->id)->update(['status' => 2]);
			if($ret){
				PushNotification::send('工单关闭提醒', '工单：ID'.$ticket->id.'超过72小时未处理，系统已自动关闭');
			}
		}
	}

	// 重置用户流量
	private function resetUserTraffic(): void {
		$userList = User::where('status', '<>', -1)
		                ->where('expired_at', '>', date('Y-m-d'))
		                ->where('reset_time', '<=', date('Y-m-d'))
		                ->get();
		foreach($userList as $user){
			// 跳过 没有重置日期的账号
			if(!$user->reset_time){
				continue;
			}

			// 取出用户正在使用的套餐
			$order = Order::userActivePlan($user->id)->first();

			// 无订单用户跳过
			if(!$order){
				continue;
			}

			// 过期生效中的加油包
			Order::userActivePackage($user->id)->update(['is_expire' => 1]);

			$oldData = $user->transfer_enable;
			// 重置流量与重置日期 TODO 可用流量变动日志加入至UserObserver
			$ret = $user->update((new OrderService($order))->resetTimeAndData($user->expired_at));
			if($ret){
				// 可用流量变动日志
				Helpers::addUserTrafficModifyLog($order->user_id, $order->id, $oldData, $user->transfer_enable,
					'【流量重置】重置可用流量');
				Log::info('用户[ID：'.$user->id.'  昵称： '.$user->username.'  邮箱： '.$user->email.'] 流量重置为 '.flowAutoShow($user->transfer_enable).'. 重置日期为 '.($user->reset_time?: '【无】'));
			}else{
				Log::error('用户[ID：'.$user->id.'  昵称： '.$user->username.'  邮箱： '.$user->email.'] 流量重置失败');
			}
		}
	}
}