nuhodds_fi4/app/Filament/Imports/StatistikoImporter.php

<?php

namespace App\Filament\Imports;

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;
        }
        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) {

                $data = [];

                foreach ($chunk as $row) {

                    $row = array_values($row);

                    // check if name exists
                    if (is_string(preg_replace("'\W'", '', $row[1]))) {
                        $data[] = [
                            'player_id' => $row[0],
                            '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,
                        ];
                    }
                }
                StatistikoPlayer::upsert($data, 'player_id');
            });
    }

    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) {

                $data = [];

                foreach ($chunk as $row) {

                    // print_r($row);

                    $row = array_values($row);

                    // dd($row);
                    /***
                    [LEAGUE] => 1
                    [HOME] => 2133
                    [AWAY] => 3024
                    [SS_STARTTIME_VALUE] => DateTimeImmutable Object ( [date] => 2022-08-05 18:00:00.000000 [timezone_type] => 3 [timezone] => Europe/Vienna )
                    [SS_SEASON_VALUE] => 2022/2023
                    [GLS_H] => 0
                    [GLS_A] => 0
                    [CRN_H] => 3
                    [CRN_A] => 6
                    [FLS_H] => 5
                    [FLS_A] => 8
                    [OFS_H] => 0
                    [OFS_A] => 2
                    [SNT_H] => 2
                    [SNT_A] => 1
                    [TSH_H] => 11
                    [TSH_A] => 13
                    [CRD_H] => 1
                    [CRD_A] => 1
                    [EXPGOALSHOME_VALUE] => 1.6350036183338
                    [EXPGOALSAWAY_VALUE] => 0.97303070109903
                    [EXP_HANDICAP] => -0.66197291723478
                    [EXP_TOTAL] => 2.6080343194328
                     */
                    $data[] = [
                        'sport_id' => 1,
                        'league_id' => $row[0],
                        'home_id' => $row[1],
                        'away_id' => $row[2],
                        'starttime' => Carbon::parse($row[3])->toIso8601String(),
                        'season' => $row[4],
                        'gls_h' => $row[6],
                        'gls_a' => $row[7],
                        'crn_h' => $row[8],
                        'fls_h' => $row[9],
                        'ofs_h' => $row[10],
                        'snt_h' => $row[11],
                        'tsh_h' => $row[12],
                        'crd_h' => $row[13],
                        'crn_a' => $row[14],
                        'fls_a' => $row[15],
                        'ofs_a' => $row[16],
                        'snt_a' => $row[17],
                        'tsh_a' => $row[18],
                        'crd_a' => $row[19],
                        'expgoalshome_value' => $row[20],
                        'expgoalsaway_value' => $row[21],
                        'exp_handicap' => $row[22],
                        'exp_total' => $row[23],
                        'created_at' => $now,
                        'updated_at' => $now,
                    ];
                }
                StatistikoPlayer::upsert($data, 'player_id');
            });
    }
}