neiyou_user_web/app/Console/Commands/AutoJob.php

<?php

namespace App\Console\Commands;

use App\Components\Helpers;
use App\Models\Config;
use App\Models\Coupon;
use App\Models\Invite;
use App\Models\Node;
use App\Models\Order;
use App\Models\User;
use App\Models\VerifyCode;
use App\Models\UserHourlyDataFlow;
use App\Models\UserDataFlowLog;
use Illuminate\Console\Command;
use Log;

class AutoJob extends Command
{
    protected $signature = 'autoJob';
    protected $description = '自动化任务';

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

        // 关闭超时未支付本地订单
       // Order::query()->recentUnPay()->update(['status' => -1]);
        Log::info('---开启实执行自动化任务');
        // 封禁账号
        $this->blockUsers();
        Log::info('---开启实执行封禁账号');
        // 解封被封禁的账号
        $this->unblockUsers();
        Log::info('---开启实执行解封被封禁的账号');
        // 端口回收与分配
        if (sysConfig('auto_release_port')) {
            $this->dispatchPort();
            Log::info('---开启实执行端口回收与分配');
        }

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

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

    private function blockUsers(): void
    {
        // 禁用流量超限用户
        User::activeUser()
            ->whereRaw('u + d >= transfer_enable')
            ->chunk(100, function ($users) {
                foreach ($users as $user) {
                    $user->update(['enable' => 0]);
                    Helpers::addUserBanLog($user->id, 0, '【封禁代理】-流量已用完');
                    \Log::info('用户流量超限被封禁', [
                        'user_id' => $user->id,
                        'email' => $user->email,
                        'used_traffic' => $user->u + $user->d,
                        'transfer_enable' => $user->transfer_enable,
                        'ban_time' => now()
                    ]);
                }
            });

        // 封禁最近1小时内流量异常账号（直接用UserDataFlowLog统计）
        if (sysConfig('is_traffic_ban')) {
            $trafficBanTime = sysConfig('traffic_ban_time');
            $trafficBanValue = sysConfig('traffic_ban_value') * GB;
            $oneHourAgo = time() - 3600;

            // 查询最近1小时内流量超限的用户ID
            $abnormalUserIds = UserDataFlowLog::where('log_time', '>=', $oneHourAgo)
                ->selectRaw('user_id, SUM(u + d) as total_traffic')
                ->groupBy('user_id')
                ->having('total_traffic', '>', $trafficBanValue)
                ->pluck('user_id')
                ->toArray();

            if (!empty($abnormalUserIds)) {
                \Log::info('发现流量异常用户', [
                    'count' => count($abnormalUserIds),
                    'user_ids' => $abnormalUserIds
                ]);

                User::activeUser()
                    ->whereIn('id', $abnormalUserIds)
                    ->whereBanTime(null)
                    ->chunk(100, function ($users) use ($trafficBanTime, $trafficBanValue, $oneHourAgo) {
                        foreach ($users as $user) {
                            try {
                                // 重新统计该用户最近1小时的总流量
                                $total = UserDataFlowLog::where('user_id', $user->id)
                                    ->where('log_time', '>=', $oneHourAgo)
                                    ->sum(\DB::raw('u + d'));
                                $banValueStr = flowAutoShow($trafficBanValue);
                                $usedStr = flowAutoShow($total);

                                \Log::warning('⚠️ 用户流量异常封禁 | ID: '.$user->id.' | 邮箱: '.$user->email.' | 1小时内已用流量: '.$usedStr.'，阈值: '.$banValueStr.'（已超限）');

                                $user->update([
                                    'enable' => 0,
                                    'ban_time' => strtotime("+$trafficBanTime minutes")
                                ]);
                                $user->refresh();

                                Helpers::addUserBanLog($user->id, $trafficBanTime, '【临时封禁代理】-1小时内流量异常');
                            } catch (\Exception $e) {
                                \Log::error('封禁流量异常用户失败', [
                                    'user_id' => $user->id,
                                    'error' => $e->getMessage()
                                ]);
                            }
                        }
                    });
            } else {
                \Log::info('未发现流量异常用户');
            }
        }
    }

    private function unblockUsers(): void
    {
        // 解封被临时封禁的账号
        User::whereEnable(0)
            ->where('status', '>=', 0)
            ->whereNotNull('ban_time')
            ->where('ban_time', '<', time())
            ->chunk(100, function ($users) {
                foreach ($users as $user) {
                    $user->update(['status'=>1,'enable' => 1, 'ban_time' => null]);
                    Helpers::addUserBanLog($user->id, 0, '【自动解封】-临时封禁到期');
                    \Log::info('用户临时封禁到期自动解封', [
                        'user_id' => $user->id,
                        'email' => $user->email,
                        'ban_time' => $user->ban_time,
                        'unblock_time' => now(),
                        'reason' => '临时封禁到期'
                    ]);
                }
            });

        // 解封流量恢复的账号
        User::whereEnable(0)
            ->where('status', '>=', 0)
            ->whereBanTime(null)
            ->where('expired_at', '>=', date('Y-m-d H:i:s'))
            ->whereRaw('u + d < transfer_enable')
            ->chunk(100, function ($users) {
                foreach ($users as $user) {
                    $user->update(['status'=>1,'enable' => 1]);
                    Helpers::addUserBanLog($user->id, 0, '【自动解封】-有流量解封');
                    \Log::info('用户流量恢复自动解封', [
                        'user_id' => $user->id,
                        'email' => $user->email,
                        'used_traffic' => $user->u + $user->d,
                        'transfer_enable' => $user->transfer_enable,
                        'expired_at' => $user->expired_at,
                        'unblock_time' => now(),
                        'reason' => '流量恢复'
                    ]);
                }
            });
    }

    private function dispatchPort(): void
    {
        // 被封禁 / 过期一个月 的账号自动释放端口
        User::where('port', '<>', 0)
            ->where(function ($query) {
                $query->where('status', -1)
                    ->orWhere('expired_at', '<=', date('Y-m-d H:i:s', strtotime('-1 months')));
            })
            ->update(['port' => 0]);
    }
}