statistic on separate page wip
This commit is contained in:
salam committed
1 parent
ad36ba555f
commit
422681df01
34 files changed
+660
-734
No files matched your search
@@ -2,15 +2,11 @@
|
||||
|
||||
namespace App\Filament\Imports;
|
||||
|
||||
use App\Models\StatistikoEvent;
|
||||
use App\Filament\Imports\Helper\ImportBenchmark;
|
||||
use App\Filament\Imports\Helper\ImportEvents;
|
||||
use App\Filament\Imports\Helper\ImportFixtures;
|
||||
use App\Filament\Imports\Helper\ImportPlayer;
|
||||
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
|
||||
{
|
||||
@@ -33,14 +29,17 @@ class StatistikoImporter
|
||||
$filePath = $record['file_name'];
|
||||
$sport_id = $record['sport_id'];
|
||||
|
||||
self::startBenchmark($table);
|
||||
ImportBenchmark::start($table);
|
||||
|
||||
switch ($record['data_type']) {
|
||||
case 'player':
|
||||
self::importPlayer($filePath);
|
||||
ImportPlayer::run($filePath);
|
||||
break;
|
||||
case 'events':
|
||||
self::importEvents($filePath, $sport_id);
|
||||
ImportEvents::run($filePath, $sport_id);
|
||||
break;
|
||||
case 'fixtures':
|
||||
ImportFixtures::run($filePath, $sport_id);
|
||||
break;
|
||||
case 'events_player':
|
||||
break;
|
||||
@@ -48,134 +47,6 @@ class StatistikoImporter
|
||||
|
||||
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, int $sport_id): 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, $sport_id) {
|
||||
|
||||
foreach ($chunk as $row) {
|
||||
|
||||
$row = array_values($row);
|
||||
|
||||
StatistikoEvent::where('sport_id', $sport_id)
|
||||
->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],
|
||||
);
|
||||
}
|
||||
});
|
||||
ImportBenchmark::end($table);
|
||||
}
|
||||
}
|
||||
Reference in new issue
Block a user