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

<?php

namespace App\Console\Commands;

use App\Models\BalanceLog;
use App\Services\ShareCommissionDiagnostics;
use App\Services\ShareCommissionRecorder;
use Carbon\Carbon;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;

class BackfillShareCommissions extends Command
{
    protected $signature = 'share:backfill-commissions
        {--start-date= : 返现入账起始日 Y-m-d，默认结束日前30天}
        {--end-date= : 返现入账结束日 Y-m-d，默认今天}
        {--chunk=500 : 每批读取条数，1至2000}
        {--all : 查询全部历史，不能与日期选项同时使用}
        {--diagnose : 只读诊断数据来源与各级筛选，不登记或发奖}
        {--write : 实际登记佣金明细；不传时只预览}';

    protected $description = '从已有充值返现流水补记分享佣金明细，不修改钱包或再次发奖';

    public function handle(ShareCommissionRecorder $recorder): int
    {
        try {
            $all = (bool)$this->option('all');
            $diagnose = (bool)$this->option('diagnose');
            $write = (bool)$this->option('write');
            if ($diagnose && $write) throw new \InvalidArgumentException('--diagnose 为只读诊断，不能与 --write 同时使用');
            if ($all && ($this->option('start-date') !== null || $this->option('end-date') !== null)) {
                throw new \InvalidArgumentException('--all 不能与日期选项同时使用');
            }
            $range = null;
            if (!$all) {
                $end = $this->parseDate((string)($this->option('end-date') ?: date('Y-m-d')));
                $start = $this->parseDate((string)($this->option('start-date') ?: $end->copy()->subDays(30)->toDateString()));
                if ($start->gt($end) || $start->diffInDays($end) > 366) {
                    throw new \InvalidArgumentException('日期范围须先后有效，单次不超过366天');
                }
                $range = [$start->toDateString() . ' 00:00:00', $end->toDateString() . ' 23:59:59'];
            }
            $chunk = filter_var($this->option('chunk'), FILTER_VALIDATE_INT);
            if ($chunk === false || $chunk < 1 || $chunk > 2000) {
                throw new \InvalidArgumentException('chunk 必须是1至2000的整数');
            }
            $label = $all ? '全部历史（无日期过滤）' : $start->toDateString() . ' 至 ' . $end->toDateString();
            if ($diagnose) return $this->diagnose($range, $label);
            $counts = ['scanned' => 0, 'created' => 0, 'pending' => 0, 'existing' => 0, 'skipped' => 0, 'incomplete_metadata' => 0];
            $reasons = [];
            $this->info(($write ? '写入登记' : '只读预览') . '：' . $label);
            $query = BalanceLog::where('change_type', '充值返现')->where('type', 1)->where('amount', '>', 0);
            if ($range !== null) $query->whereBetween('created_at', $range);
            $query->chunkById($chunk, function ($rows) use ($recorder, $write, &$counts, &$reasons) {
                    foreach ($rows as $row) {
                        $result = $write ? $recorder->record($row) : $recorder->preview($row);
                        $counts['scanned']++;
                        $counts[$result['status']]++;
                        if (!empty($result['incomplete_metadata'])) $counts['incomplete_metadata']++;
                        if ($result['status'] === 'skipped') {
                            $reason = $result['reason'];
                            $reasons[$reason] = ($reasons[$reason] ?? 0) + 1;
                        }
                    }
                });
            $this->table(['项目', '条数'], array_map(fn ($key, $count) => [$key, $count], array_keys($counts), array_values($counts)));
            foreach ($reasons as $reason => $count) $this->line("跳过 {$reason}: {$count}");
            if (!$counts['scanned']) {
                $this->warn('没有扫描到符合条件的返现流水；省略日期仍默认最近31天。可运行 --diagnose --all 定位上游数据。');
            }
            if (!$write) $this->info('预览未写入数据；确认后使用相同日期并加 --write 登记，钱包不会再次入账。');
            return self::SUCCESS;
        } catch (\Throwable $e) {
            $this->error($e->getMessage());
            return self::FAILURE;
        }
    }

    private function diagnose(?array $range, string $label): int
    {
        $this->info('只读诊断：' . $label);
        $this->line('database: ' . DB::connection()->getDatabaseName());
        $this->line('table_prefix: ' . DB::getTablePrefix());
        $data = (new ShareCommissionDiagnostics())->inspect($range);
        foreach (['recharge_rate', 'share_enabled', 'benefit_enabled', 'valid_member_min_deposit', 'valid_member_min_effective_bet', 'first_rebate_at', 'last_rebate_at'] as $key) {
            $this->line($key . ': ' . ($data[$key] ?? '(无)'));
        }
        $this->table(['检查项', '条数'], array_map(fn ($key, $count) => [$key, $count], array_keys($data['counts']), array_values($data['counts'])));
        $counts = $data['counts'];
        if (!$counts['rebate_logs_all']) $this->warn('全部历史没有“充值返现”流水，回填没有来源；需检查实际返现是否发生。');
        elseif (!$counts['positive_type1_rebate_logs_all']) $this->warn('存在返现流水，但没有 type=1 且金额大于0的可登记流水。');
        elseif (!$counts['selected_rebate_logs']) $this->warn('全历史有可登记返现，但当前日期范围没有；按原入账日期查询或使用 --all。');
        if ($data['recharge_rate'] === null || !is_numeric($data['recharge_rate']) || (float)$data['recharge_rate'] <= 0) {
            $this->warn('当前 recharge_rate 缺失、无效或为0，现有邀请充值返现路径不会产生正数返现。');
        }
        if ($counts['invited_members_all'] && !$counts['real_invited_members_all']) $this->warn('有推荐注册，但没有 from=1 的真实被邀请会员。');
        if ($counts['real_invited_members_all'] && !$counts['linked_real_invited_members_all']) $this->warn('真实被邀请会员的邀请码未匹配到有效推广人。');
        if ($counts['real_invited_members_all'] && !$counts['real_invitee_deposit_logs_all']) $this->warn('真实被邀请会员没有正数“充值/三方充值”流水；人工充值不触发现有邀请返现。');
        if ($counts['linked_real_invitee_deposit_logs_all'] && !$counts['with_promoter_wallet_deposit_logs_all']) $this->warn('有推荐充值，但推广人钱包缺失。');
        $this->line('实际旧充值返现使用 config.recharge_rate；新分享投注佣金与其独立。');
        $this->line('上游数量按当前关系统计，仅供排查，不代表历史应付佣金；本诊断未写入记录或发钱。');
        return self::SUCCESS;
    }

    private function parseDate(string $value): Carbon
    {
        $date = Carbon::createFromFormat('!Y-m-d', $value, config('app.timezone', 'Asia/Shanghai'));
        if (!$date || $date->format('Y-m-d') !== $value) {
            throw new \InvalidArgumentException('日期必须为有效的 Y-m-d');
        }
        return $date;
    }
}