bot-28/app/Services/Reporting/ReportContext.php

<?php

namespace App\Services\Reporting;

use Carbon\Carbon;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Schema;

/** Captures attribution at creation, never retrospectively guesses from the latest login. */
class ReportContext
{
    public const SOURCES = ['bets', 'lhc_order', 'jisu_game_order', 'sport_game_order', 'sport_order', 'recharges', 'withdraws', 'payment_orders', 'balance_logs', 'agent_withdrawals', 'share_claims'];

    /** Bulk lottery updates bypass model events. Call at the actual terminal transition. */
    public static function lotterySettled(int $orderId): void
    {
        try {
            if (!Schema::hasTable('reporting_contexts')) return;
            $order = DB::table('lhc_order')->where('id', $orderId)->first();
            if (!$order || (int) ($order->is_faker ?? 0) === 1 || !in_array((int) $order->lottery_status, [1, 2, 3, 4], true)) return;
            $at = \App\Services\Sharing\EffectiveBet::time($order->created_at)->setTimezone('Asia/Shanghai')->format('Y-m-d H:i:s');
            $identity = self::identity((array) $order, $at, 'lhc_order');
            DB::table('reporting_contexts')->insertOrIgnore($identity + [
                'source' => 'lhc_order', 'source_id' => (string) $orderId, 'occurred_at' => $at, 'succeeded_at' => null,
            ]);
            DB::table('reporting_contexts')->where('source', 'lhc_order')->where('source_id', (string) $orderId)
                ->whereNull('succeeded_at')->update(['succeeded_at' => now('Asia/Shanghai')->format('Y-m-d H:i:s')]);
        } catch (\Throwable $e) {
            // Reporting must never change whether an already settled bet pays out.
            \Illuminate\Support\Facades\Log::error('reporting_lottery_settlement_failed', ['order_id' => $orderId, 'exception' => get_class($e)]);
        }
    }

    /** Capture the loss batch while the settlement job still holds its source locks. */
    public static function sportGamesSettled(array $orderIds): void
    {
        try {
            if (!$orderIds || !Schema::hasTable('reporting_contexts')) return;
            $now = now('Asia/Shanghai')->format('Y-m-d H:i:s');
            foreach (array_chunk($orderIds, 200) as $chunk) {
                $rows = DB::table('sport_game_order')->whereIn('id', $chunk)->where('status', 1)->get();
                $ids = $rows->map(fn ($row) => (string) $row->id)->all();
                $known = DB::table('reporting_contexts')->where('source', 'sport_game_order')->whereIn('source_id', $ids)->pluck('source_id')->all();
                foreach ($rows as $row) {
                    if (in_array((string) $row->id, $known, true)) continue;
                    try {
                        $at = \App\Services\Sharing\EffectiveBet::time($row->created_at)->setTimezone('Asia/Shanghai')->format('Y-m-d H:i:s');
                        $identity = self::identity((array) $row, $at, 'sport_game_order');
                        DB::table('reporting_contexts')->insertOrIgnore($identity + [
                            'source' => 'sport_game_order', 'source_id' => (string) $row->id, 'occurred_at' => $at, 'succeeded_at' => null,
                        ]);
                    } catch (\Throwable $e) {
                        \Illuminate\Support\Facades\Log::error('reporting_sport_settlement_identity_failed', ['order_id' => $row->id, 'exception' => get_class($e)]);
                    }
                }
                DB::table('reporting_contexts')->where('source', 'sport_game_order')->whereIn('source_id', $ids)
                    ->whereNull('succeeded_at')->update(['succeeded_at' => $now]);
            }
        } catch (\Throwable $e) {
            \Illuminate\Support\Facades\Log::error('reporting_sport_settlement_failed', ['exception' => get_class($e)]);
        }
    }

    public static function captureModel($model): void
    {
        $source = $model->getTable();
        if (!in_array($source, self::SOURCES, true) || !Schema::hasTable('reporting_contexts')) return;
        $row = $model->getAttributes(); $id = (string) $model->getKey();
        if ($id === '') return;
        $now = now('Asia/Shanghai')->format('Y-m-d H:i:s');
        $identity = self::identity($row, $now, $source);
        $platform = 'unknown';
        if ($model->wasRecentlyCreated && !app()->runningInConsole() && (str_starts_with(request()->path(), 'api/') || str_starts_with(request()->path(), 'agent/')) && request()->path() !== 'api/onMessage') {
            $value = request()->header('Platform', request()->input('platform'));
            $platform = is_string($value) && in_array(strtoupper($value), ['PC', 'H5', 'APP'], true) ? strtoupper($value) : 'unknown';
        }
        DB::table('reporting_contexts')->insertOrIgnore(['source' => $source, 'source_id' => $id,
            'user_id' => $identity['user_id'], 'agent_id' => $identity['agent_id'], 'inviter_id' => $identity['inviter_id'],
            'client_platform' => $platform, 'attribution_quality' => $model->wasRecentlyCreated ? 'event_snapshot' : 'historical_current_agent', 'occurred_at' => $now, 'succeeded_at' => null]);
        $success = ($source === 'withdraws' && (int) ($row['status'] ?? -1) === 1)
            || ($source === 'payment_orders' && (int) ($row['status'] ?? -1) === 2)
            || ($source === 'agent_withdrawals' && ($row['status'] ?? '') === 'paid')
            || ($source === 'lhc_order' && in_array((int) ($row['lottery_status'] ?? 0), [1, 2, 3, 4], true))
            || (in_array($source, ['sport_game_order', 'jisu_game_order'], true) && in_array((int) ($row['status'] ?? 0), [1, 2, 3], true))
            || ($source === 'bets' && in_array((int) ($row['status'] ?? 0), [2, 3], true))
            || ($source === 'sport_order' && ((int) ($row['settlement_status'] ?? 0) === 1 || (int) ($row['status'] ?? 0) === 2));
        if ($success && ($model->wasRecentlyCreated || $model->wasChanged(['status', 'lottery_status', 'settlement_status']))) {
            DB::table('reporting_contexts')->where('source', $source)->where('source_id', $id)->whereNull('succeeded_at')->update(['succeeded_at' => $now]);
        }
    }

    public static function identity(array $row, string $at, string $source = ''): array
    {
        $context = isset($row['id']) ? DB::table('reporting_contexts')->where('source', $source)->where('source_id', (string) $row['id'])->first() : null;
        if ($context) return ['user_id' => $context->user_id === null ? null : (int) $context->user_id,
            'agent_id' => $context->agent_id === null ? null : (int) $context->agent_id, 'inviter_id' => $context->inviter_id === null ? null : (int) $context->inviter_id,
            'client_platform' => $context->client_platform, 'attribution_quality' => $context->attribution_quality];
        $member = $row['member_id'] ?? ($source === 'sport_order' ? ($row['user_id'] ?? '') : '');
        $query = DB::table('users');
        if (!empty($row['report_user_id'])) $query->where('id', $row['report_user_id']);
        elseif ($member !== '') $query->where('member_id', (string) $member);
        else return ['user_id' => null, 'agent_id' => $source === 'agent_withdrawals' ? ($row['agent_id'] ?? null) : null,
            'inviter_id' => null, 'client_platform' => 'unknown', 'attribution_quality' => 'unknown'];
        $users = $query->limit(2)->get();
        if ($users->count() !== 1 || (int) ($users[0]->from ?? 0) === 2) throw new \RuntimeException('真实会员身份不明确');
        $user = (array) $users[0]; $inviter = null;
        if (Schema::hasTable('share_members')) {
            $relation = DB::table('share_members')->where('user_id', $user['id'])->where('bound_at', '<=', $at)->first();
            $inviter = $relation && $relation->parent_user_id !== null ? (int) $relation->parent_user_id : null;
        }
        return ['user_id' => (int) $user['id'], 'agent_id' => isset($user['agent_id']) ? (int) $user['agent_id'] : null,
            'inviter_id' => $inviter, 'client_platform' => 'unknown', 'attribution_quality' => 'historical_current_agent'];
    }
}