bot-28/app/Console/Commands/SyncUserLevels.php

<?php

namespace App\Console\Commands;

use App\Models\Level;
use App\Models\User;
use App\Services\BalanceLogService;
use Illuminate\Console\Command;

class SyncUserLevels extends Command
{
    protected $signature = 'users:sync-levels {--member= : Only this member_id}';
    protected $description = 'Raise users.level to match cumulative recharge (经验); never lowers a level';

    public function handle(): int
    {
        if ($member = $this->option('member')) return $this->syncOne($member);
        $changed = 0;
        User::query()->select('member_id')->orderBy('id')->chunk(500, function ($users) use (&$changed) {
            foreach ($users as $user) {
                [$before, $after] = BalanceLogService::syncLevel($user->member_id);
                if ($after === $before) continue;
                $changed++;
                $this->line("{$user->member_id}: {$before} -> {$after}");
            }
        });
        $this->info("updated {$changed} users");
        return self::SUCCESS;
    }

    // 单个用户输出计算依据，便于排查为什么没升级
    private function syncOne(string $member): int
    {
        if (!User::where('member_id', $member)->exists()) {
            $this->error("member_id {$member} 不存在（请确认传的是 users.member_id，不是 users.id）");
            return self::FAILURE;
        }
        $total = BalanceLogService::getTotalRecharge($member);
        $this->line('计入等级的类型：' . implode('、', BalanceLogService::$levelRechargeTypes));
        $this->line("累计充值：{$total}，按累计充值计算等级：" . BalanceLogService::calculateLevel($total));
        $this->line('等级门槛：' . Level::orderBy('level')->get(['level', 'recharge'])
            ->map(fn ($l) => "{$l->level}={$l->recharge}")->implode(', '));
        [$before, $after] = BalanceLogService::syncLevel($member);
        $this->info("当前等级：{$before} -> {$after}" . ($after === $before ? '（未变化，只升不降）' : ''));
        return self::SUCCESS;
    }
}