nuhodds_fi4/app/Filament/Imports/StatistikoImporter.php

<?php

namespace App\Filament\Imports;

use App\Models\StatistikoEvent;
use App\Models\StatistikoImport;
use App\Models\StatistikoPlayer;
use Filament\Notifications\Notification;
use Illuminate\Support\Carbon;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\HtmlString;
use Illuminate\Support\LazyCollection;
use Spatie\SimpleExcel\SimpleExcelReader;

class StatistikoImporter
{
    public static float $benchmarkStartTime;

    public static int $benchmarkStartMemory;

    public static int $startRowCount;

    public static int $startQueries;

    public static function run($record): void
    {
        error_reporting(E_ALL);
        ini_set('display_errors', 1);
        ini_set('max_execution_time', -1);

        $table = $record['data_type'];

        $filePath = $record['file_name'];

        self::startBenchmark($table);

        switch ($record['data_type']) {
            case 'player':
                self::importPlayer($filePath);
                break;
            case 'events':
                self::importEvents($filePath);
                break;
            case 'events_player':
                break;
        }

        StatistikoImport::where('id', $record->id)->update(['has_run' => 1]);

        self::endBenchmark($table);
    }

    protected static function startBenchmark(string $table): void
    {
        self::$startRowCount = DB::connection('mongodb')->table($table)->count();
        self::$benchmarkStartTime = microtime(true);
        self::$benchmarkStartMemory = memory_get_usage();
        DB::connection('mongodb')->enableQueryLog();
    }

    protected static function endBenchmark(string $table): void
    {
        $executionTime = microtime(true) - self::$benchmarkStartTime;
        $memoryUsage = round((memory_get_usage() - self::$benchmarkStartMemory) / 1024 / 1024, 2);

        $logs = DB::connection('mongodb')->getQueryLog();
        $queriesCount = \count($logs);

        // Get row count after we've stopped tracking queries
        $rowDiff = DB::connection('mongodb')->table($table)->count() - self::$startRowCount;

        $formattedTime = match (true) {
            $executionTime >= 60 => sprintf('%dm %ds', floor($executionTime / 60), $executionTime % 60),
            $executionTime >= 1 => round($executionTime, 2).'s',
            default => round($executionTime * 1000).'ms',
        };

        $str = '⚡ TIME: '.$formattedTime;
        $str .= '<br/>MEM: '.$memoryUsage.'MB';
        $str .= '<br/>SQL: '.number_format($queriesCount);
        $str .= '<br/>ROWS: '.number_format($rowDiff);

        $recipient = auth()->user();

        Notification::make()
            ->success()
            ->title('Import compleated')
            ->body(new HtmlString($str))
            ->sendToDatabase($recipient);
    }

    private static function importPlayer(string $filePath): void
    {
        $now = now()->format('Y-m-d H:i:s');

        SimpleExcelReader::create(storage_path('app/public/'.$filePath))
            ->getRows()
            ->chunk(1000)
            ->each(function (LazyCollection $chunk) use ($now) {

                foreach ($chunk as $row) {

                    $row = array_values($row);

                    StatistikoPlayer::where('player_id', $row[0])
                        ->update(
                            [
                                'name' => $row[1],
                                'birthdate' => Carbon::parse($row[2])->toDateString(),
                                'height' => $row[3],
                                'nationality' => $row[4],
                                'position' => $row[5],
                                'sport_radar_id' => $row[6],
                                'id_squadra_tm' => $row[7],
                                'full_name' => $row[8],
                                'no_specialities' => $row[9],
                                'rigorist' => $row[10],
                                'national_team_id' => $row[11],
                                'last_update' => Carbon::parse($row[12])->toDateString(),
                                'league_code' => $row[13],
                                'team_code' => $row[14],
                                'team_name' => $row[15],
                                'created_at' => $now,
                                'updated_at' => $now,
                            ],
                            ['upsert' => true],
                        );

                }
            });
    }

    private static function importEvents(string $filePath): void
    {
        $now = now()->format('Y-m-d H:i:s');

        SimpleExcelReader::create(storage_path('app/public/'.$filePath))
            ->getRows()
            ->chunk(1000)
            ->each(function (LazyCollection $chunk) use ($now) {

                foreach ($chunk as $row) {

                    $row = array_values($row);

                    StatistikoEvent::where('sport_id', 1)
                        ->where('league_id', $row[0])
                        ->where('home_id', $row[1])
                        ->where('away_id', $row[2])
                        ->where('starttime', Carbon::parse($row[3])->toIso8601String())
                        ->update(
                            [
                                'season' => $row[4],
                                'gls_h' => $row[5],
                                'gls_a' => $row[6],
                                'crn_h' => $row[7],
                                'crn_a' => $row[8],
                                'fls_h' => $row[9],
                                'fls_a' => $row[10],
                                'ofs_h' => $row[11],
                                'ofs_a' => $row[12],
                                'snt_h' => $row[13],
                                'snt_a' => $row[14],
                                'tsh_h' => $row[15],
                                'tsh_a' => $row[16],
                                'crd_h' => $row[17],
                                'crd_a' => $row[18],
                                'expgoalshome_value' => $row[19],
                                'expgoalsaway_value' => $row[20],
                                'exp_handicap' => $row[21],
                                'exp_total' => $row[22],
                                'created_at' => $now,
                                'updated_at' => $now,
                            ],
                            ['upsert' => true],
                        );
                }
            });
    }
}