81 lines
3.2 KiB
PHP
81 lines
3.2 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
namespace App\Jobs;
|
||
|
|
|
||
|
|
use App\Models\Song;
|
||
|
|
use App\Models\SongLibraryCache;
|
||
|
|
use Illuminate\Bus\Queueable;
|
||
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
||
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
||
|
|
use Illuminate\Queue\InteractsWithQueue;
|
||
|
|
use Illuminate\Queue\SerializesModels;
|
||
|
|
use Illuminate\Support\Facades\DB;
|
||
|
|
use Illuminate\Support\Facades\Schema;
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
class ExportSqliteSongLibraryCacheJob implements ShouldQueue
|
||
|
|
{
|
||
|
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
||
|
|
|
||
|
|
public function handle()
|
||
|
|
{
|
||
|
|
// 安全清空資料（兼容 SQLite 和其他資料庫）
|
||
|
|
if (Schema::hasTable('song_library_cache')) {
|
||
|
|
if (DB::getDriverName() === 'sqlite') {
|
||
|
|
SongLibraryCache::query()->delete();
|
||
|
|
} else {
|
||
|
|
DB::table('song_library_cache')->truncate();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
$totalInserted = 0;
|
||
|
|
|
||
|
|
Song::with(['artists', 'categories'])->chunk(500, function ($songs) use (&$totalInserted) {
|
||
|
|
$rows = [];
|
||
|
|
|
||
|
|
foreach ($songs as $song) {
|
||
|
|
$sortedArtists = $song->artists->sortBy('id')->values();
|
||
|
|
$artistA = $sortedArtists->get(0);
|
||
|
|
$artistB = $sortedArtists->get(1);
|
||
|
|
|
||
|
|
$rows[] = [
|
||
|
|
'song_id' => $song->id,
|
||
|
|
'song_name' => $song->name,
|
||
|
|
'song_simplified' => $song->simplified,
|
||
|
|
'phonetic_abbr' => $song->phonetic_abbr ?? '',
|
||
|
|
'pinyin_abbr' => $song->pinyin_abbr ?? '',
|
||
|
|
'strokes_abbr' => $song->strokes_abbr ?? 0,
|
||
|
|
'song_number' => $song->song_number ?? 0,
|
||
|
|
'artistA' => $artistA?->name,
|
||
|
|
'artistB' => $artistB?->name,
|
||
|
|
'artistA_simplified' => $artistA?->simplified,
|
||
|
|
'artistB_simplified' => $artistB?->simplified,
|
||
|
|
'artistA_category' => $artistA?->category?->value ?? '未定義',
|
||
|
|
'artistB_category' => $artistB?->category?->value ?? '未定義',
|
||
|
|
'artist_category' => in_array(\App\Enums\ArtistCategory::Group->value, [
|
||
|
|
$artistA?->category?->value,
|
||
|
|
$artistB?->category?->value,
|
||
|
|
]) ? '團' : '未定義',
|
||
|
|
'song_filename' => $song->filename,
|
||
|
|
'song_category' => $song->categories->pluck('code')->unique()->sort()->implode(', '),
|
||
|
|
'language_name' => $song->language_type ?? '未定義',
|
||
|
|
'add_date' => $song->adddate,
|
||
|
|
'situation' => $song->situation?->value ?? '未定義',
|
||
|
|
'vocal' => $song->vocal,
|
||
|
|
'db_change' => $song->db_change,
|
||
|
|
'song_counts' => $song->song_counts ?? 0,
|
||
|
|
'updated_at' => now(),
|
||
|
|
];
|
||
|
|
}
|
||
|
|
|
||
|
|
collect($rows)->chunk(1000)->each(function ($chunk) use (&$totalInserted) {
|
||
|
|
SongLibraryCache::insert($chunk->toArray());
|
||
|
|
$totalInserted += $chunk->count();
|
||
|
|
});
|
||
|
|
});
|
||
|
|
// 你也可以 log 或通知插入結果
|
||
|
|
// logger("Exported {$totalInserted} songs to cache.");
|
||
|
|
}
|
||
|
|
}
|