ProxyPanel/app/Console/Commands/AutoResetUserTraffic.php

<?php

namespace App\Console\Commands;

use Illuminate\Console\Command;
use App\Http\Models\Config;
use App\Http\Models\Order;
use App\Http\Models\User;
use Log;

class AutoResetUserTraffic extends Command
{
    protected $signature = 'autoResetUserTraffic';
    protected $description = '自动重置用户可用流量';

    public function __construct()
    {
        parent::__construct();
    }

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

        $config = $this->systemConfig();

        if ($config['reset_traffic']) {
            $userList = User::query()->where('status', '>=', 0)->where('enable', 1)->get();
            if (!$userList->isEmpty()) {
                foreach ($userList as $user) {
                    if (!$user->traffic_reset_day) {
                        continue;
                    }

                    // 取出用户最后购买的有效套餐 TODO:需要改掉，不应该是最后购买的套餐
                    $order = Order::query()->with(['user', 'goods'])->whereHas('goods', function ($q) {
                        $q->where('type', 2);
                    })->where('user_id', $user->id)->where('is_expire', 0)->orderBy('oid', 'desc')->first();

                    if (!$order) {
                        continue;
                    }

                    // TODO：需要改掉，改成下一次重置日，每月不定时，类似搬瓦工
                    $today = abs(date('d'));
                    $reset_days = [$today, 29, 30, 31];
                    if (in_array($order->user->traffic_reset_day, $reset_days)) {
                        // 跳过本月，防止异常重置
                        if (date('m') == date('m', strtotime($order->expire_at))) {
                            continue;
                        }

                        if (date('m') == date('m', strtotime($order->created_at))) {
                            continue;
                        }

                        User::query()->where('id', $user->id)->update(['u' => 0, 'd' => 0]);
                    }
                }
            }
        }

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

        Log::info('定时任务【' . $this->description . '】耗时' . $jobUsedTime . '秒');
    }

    // 系统配置
    private function systemConfig()
    {
        $config = Config::query()->get();
        $data = [];
        foreach ($config as $vo) {
            $data[$vo->name] = $vo->value;
        }

        return $data;
    }
}