Compare commits
10 Commits
d9d8eaafcd
...
6378ba0f98
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
6378ba0f98 | ||
|
|
2c8136dcf3 | ||
|
|
3315e1d4b6 | ||
|
|
37fb5c90d5 | ||
|
|
ff994a7c95 | ||
|
|
a2275758b1 | ||
|
|
783250d99a | ||
|
|
19057c7e81 | ||
|
|
9dfb8727dc | ||
|
|
bef7bcfa8f |
228
app/Console/Commands/CleanupInspeksiDataCommand.php
Normal file
228
app/Console/Commands/CleanupInspeksiDataCommand.php
Normal file
@@ -0,0 +1,228 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Modules\Lpj\Console\Commands;
|
||||||
|
|
||||||
|
use Illuminate\Console\Command;
|
||||||
|
use Illuminate\Support\Facades\DB;
|
||||||
|
use Illuminate\Support\Facades\Log;
|
||||||
|
use Modules\Lpj\Jobs\CleanupInspeksiDataJob;
|
||||||
|
use Modules\Lpj\Models\Inspeksi;
|
||||||
|
use Modules\Lpj\Services\InspeksiCleanupService;
|
||||||
|
|
||||||
|
class CleanupInspeksiDataCommand extends Command
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* The name and signature of the console command.
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $signature = 'lpj:cleanup-inspeksi
|
||||||
|
{--permohonan-id= : ID permohonan yang akan di-cleanup (opsional)}
|
||||||
|
{--sync : Jalankan secara synchronous}
|
||||||
|
{--dry-run : Tampilkan preview tanpa menjalankan cleanup}
|
||||||
|
{--force : Jalankan tanpa konfirmasi}';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The console command description.
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $description = 'Cleanup data inspeksi lama yang tidak memiliki dokument_id';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Execute the console command.
|
||||||
|
*/
|
||||||
|
public function handle(): int
|
||||||
|
{
|
||||||
|
Log::info('CleanupInspeksiDataCommand: Memulai proses cleanup data inspeksi', [
|
||||||
|
'options' => $this->options()
|
||||||
|
]);
|
||||||
|
|
||||||
|
try {
|
||||||
|
$permohonanId = $this->option('permohonan-id');
|
||||||
|
$sync = $this->option('sync');
|
||||||
|
$dryRun = $this->option('dry-run');
|
||||||
|
$force = $this->option('force');
|
||||||
|
|
||||||
|
// Validasi opsi
|
||||||
|
if ($dryRun && $sync) {
|
||||||
|
$this->error('Opsi --dry-run dan --sync tidak dapat digunakan bersamaan.');
|
||||||
|
return Command::FAILURE;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Tampilkan header
|
||||||
|
$this->info('=== Cleanup Data Inspeksi ===');
|
||||||
|
$this->newLine();
|
||||||
|
|
||||||
|
// Ambil data yang akan di-cleanup
|
||||||
|
$cleanupData = $this->getCleanupData($permohonanId);
|
||||||
|
|
||||||
|
if ($cleanupData->isEmpty()) {
|
||||||
|
$this->info('Tidak ada data yang perlu di-cleanup.');
|
||||||
|
return Command::SUCCESS;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Tampilkan preview data
|
||||||
|
$this->displayPreview($cleanupData);
|
||||||
|
|
||||||
|
if ($dryRun) {
|
||||||
|
$this->info('Mode dry-run: Tidak ada perubahan yang dilakukan.');
|
||||||
|
return Command::SUCCESS;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Konfirmasi jika tidak force
|
||||||
|
if (!$force && !$this->confirm('Lanjutkan dengan cleanup?')) {
|
||||||
|
$this->info('Cleanup dibatalkan.');
|
||||||
|
return Command::SUCCESS;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Jalankan cleanup
|
||||||
|
$this->runCleanup($cleanupData, $sync);
|
||||||
|
|
||||||
|
$this->info('Proses cleanup selesai.');
|
||||||
|
return Command::SUCCESS;
|
||||||
|
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
Log::error('CleanupInspeksiDataCommand: Terjadi error saat proses cleanup', [
|
||||||
|
'error' => $e->getMessage(),
|
||||||
|
'trace' => $e->getTraceAsString()
|
||||||
|
]);
|
||||||
|
|
||||||
|
$this->error('Terjadi kesalahan: ' . $e->getMessage());
|
||||||
|
return Command::FAILURE;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Ambil data yang akan di-cleanup
|
||||||
|
*/
|
||||||
|
private function getCleanupData(?int $permohonanId = null)
|
||||||
|
{
|
||||||
|
$this->info('Mencari data yang akan di-cleanup...');
|
||||||
|
|
||||||
|
$query = DB::table('inspeksi as i')
|
||||||
|
->select(
|
||||||
|
'i.permohonan_id',
|
||||||
|
'i.created_by',
|
||||||
|
DB::raw('COUNT(CASE WHEN i.dokument_id IS NOT NULL AND i.deleted_at IS NULL THEN 1 END) as new_data_count'),
|
||||||
|
DB::raw('COUNT(CASE WHEN i.dokument_id IS NULL AND i.deleted_at IS NULL THEN 1 END) as old_data_count')
|
||||||
|
)
|
||||||
|
->whereNull('i.deleted_at')
|
||||||
|
->groupBy('i.permohonan_id', 'i.created_by');
|
||||||
|
|
||||||
|
if ($permohonanId) {
|
||||||
|
$query->where('i.permohonan_id', $permohonanId);
|
||||||
|
}
|
||||||
|
|
||||||
|
$results = $query->havingRaw('new_data_count > 0 AND old_data_count > 0')
|
||||||
|
->get();
|
||||||
|
|
||||||
|
return $results;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Tampilkan preview data
|
||||||
|
*/
|
||||||
|
private function displayPreview($cleanupData): void
|
||||||
|
{
|
||||||
|
$this->info('Data yang akan di-cleanup:');
|
||||||
|
$this->table(
|
||||||
|
['Permohonan ID', 'Created By', 'Data Baru', 'Data Lama'],
|
||||||
|
$cleanupData->map(function ($item) {
|
||||||
|
return [
|
||||||
|
$item->permohonan_id,
|
||||||
|
$item->created_by,
|
||||||
|
$item->new_data_count,
|
||||||
|
$item->old_data_count
|
||||||
|
];
|
||||||
|
})->toArray()
|
||||||
|
);
|
||||||
|
|
||||||
|
$totalPermohonan = $cleanupData->count();
|
||||||
|
$totalOldData = $cleanupData->sum('old_data_count');
|
||||||
|
|
||||||
|
$this->info("Total permohonan: {$totalPermohonan}");
|
||||||
|
$this->info("Total data lama yang akan dihapus: {$totalOldData}");
|
||||||
|
$this->newLine();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Jalankan cleanup
|
||||||
|
*/
|
||||||
|
private function runCleanup($cleanupData, bool $sync): void
|
||||||
|
{
|
||||||
|
$this->info('Memulai proses cleanup...');
|
||||||
|
$this->newLine();
|
||||||
|
|
||||||
|
$progressBar = $this->output->createProgressBar($cleanupData->count());
|
||||||
|
$progressBar->setFormat('Processing: %current%/%max% [%bar%] %percent:3s%% %message%');
|
||||||
|
$progressBar->start();
|
||||||
|
|
||||||
|
$totalDeleted = 0;
|
||||||
|
$totalErrors = 0;
|
||||||
|
|
||||||
|
foreach ($cleanupData as $data) {
|
||||||
|
try {
|
||||||
|
$progressBar->setMessage("Permohonan ID: {$data->permohonan_id}");
|
||||||
|
|
||||||
|
// Ambil data baru untuk mendapatkan dokument_id
|
||||||
|
$newInspeksi = Inspeksi::where('permohonan_id', $data->permohonan_id)
|
||||||
|
->where('created_by', $data->created_by)
|
||||||
|
->whereNotNull('dokument_id')
|
||||||
|
->whereNull('deleted_at')
|
||||||
|
->first();
|
||||||
|
|
||||||
|
if (!$newInspeksi) {
|
||||||
|
$this->warn("Tidak ditemukan data baru untuk permohonan {$data->permohonan_id}");
|
||||||
|
$progressBar->advance();
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Jalankan cleanup
|
||||||
|
if ($sync) {
|
||||||
|
// Jalankan sync
|
||||||
|
$job = new CleanupInspeksiDataJob(
|
||||||
|
$data->permohonan_id,
|
||||||
|
$data->created_by,
|
||||||
|
$newInspeksi->dokument_id
|
||||||
|
);
|
||||||
|
$job->handle();
|
||||||
|
} else {
|
||||||
|
// Dispatch ke queue
|
||||||
|
CleanupInspeksiDataJob::dispatch(
|
||||||
|
$data->permohonan_id,
|
||||||
|
$data->created_by,
|
||||||
|
$newInspeksi->dokument_id
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
$totalDeleted += $data->old_data_count;
|
||||||
|
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
Log::error('CleanupInspeksiDataCommand: Error pada permohonan', [
|
||||||
|
'permohonan_id' => $data->permohonan_id,
|
||||||
|
'created_by' => $data->created_by,
|
||||||
|
'error' => $e->getMessage()
|
||||||
|
]);
|
||||||
|
|
||||||
|
$this->error("Error pada permohonan {$data->permohonan_id}: {$e->getMessage()}");
|
||||||
|
$totalErrors++;
|
||||||
|
}
|
||||||
|
|
||||||
|
$progressBar->advance();
|
||||||
|
}
|
||||||
|
|
||||||
|
$progressBar->finish();
|
||||||
|
$this->newLine();
|
||||||
|
$this->newLine();
|
||||||
|
|
||||||
|
// Tampilkan hasil
|
||||||
|
$this->info('=== Hasil Cleanup ===');
|
||||||
|
$this->info("Data lama yang dihapus: {$totalDeleted}");
|
||||||
|
$this->info("Error: {$totalErrors}");
|
||||||
|
|
||||||
|
if (!$sync) {
|
||||||
|
$this->info('Job telah di-dispatch ke queue. Monitor progress di log.');
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
192
app/Console/Commands/CleanupInspeksiStatusCommand.php
Normal file
192
app/Console/Commands/CleanupInspeksiStatusCommand.php
Normal file
@@ -0,0 +1,192 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Modules\Lpj\Console\Commands;
|
||||||
|
|
||||||
|
use Illuminate\Console\Command;
|
||||||
|
use Illuminate\Support\Facades\DB;
|
||||||
|
use Illuminate\Support\Facades\Log;
|
||||||
|
use Modules\Lpj\Models\Inspeksi;
|
||||||
|
|
||||||
|
class CleanupInspeksiStatusCommand extends Command
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* The name and signature of the console command.
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $signature = 'lpj:cleanup-inspeksi-status
|
||||||
|
{--permohonan-id= : Filter berdasarkan permohonan ID}
|
||||||
|
{--created-by= : Filter berdasarkan user ID}
|
||||||
|
{--detailed : Tampilkan detail data}';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The console command description.
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $description = 'Cek status data inspeksi yang memerlukan cleanup';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Execute the console command.
|
||||||
|
*/
|
||||||
|
public function handle(): int
|
||||||
|
{
|
||||||
|
try {
|
||||||
|
$permohonanId = $this->option('permohonan-id');
|
||||||
|
$createdBy = $this->option('created-by');
|
||||||
|
$detailed = $this->option('detailed');
|
||||||
|
|
||||||
|
$this->info('=== Status Data Inspeksi ===');
|
||||||
|
$this->newLine();
|
||||||
|
|
||||||
|
// Ambil statistik umum
|
||||||
|
$this->showGeneralStats();
|
||||||
|
|
||||||
|
// Ambil data yang memerlukan cleanup
|
||||||
|
$this->showCleanupStats($permohonanId, $createdBy);
|
||||||
|
|
||||||
|
if ($detailed) {
|
||||||
|
$this->showDetailedData($permohonanId, $createdBy);
|
||||||
|
}
|
||||||
|
|
||||||
|
return Command::SUCCESS;
|
||||||
|
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
Log::error('CleanupInspeksiStatusCommand: Terjadi error', [
|
||||||
|
'error' => $e->getMessage(),
|
||||||
|
'trace' => $e->getTraceAsString()
|
||||||
|
]);
|
||||||
|
|
||||||
|
$this->error('Terjadi kesalahan: ' . $e->getMessage());
|
||||||
|
return Command::FAILURE;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Tampilkan statistik umum
|
||||||
|
*/
|
||||||
|
private function showGeneralStats(): void
|
||||||
|
{
|
||||||
|
$this->info('Statistik Umum:');
|
||||||
|
|
||||||
|
$totalData = Inspeksi::count();
|
||||||
|
$activeData = Inspeksi::whereNull('deleted_at')->count();
|
||||||
|
$deletedData = Inspeksi::whereNotNull('deleted_at')->count();
|
||||||
|
$dataWithDokument = Inspeksi::whereNotNull('dokument_id')->count();
|
||||||
|
$dataWithoutDokument = Inspeksi::whereNull('dokument_id')->count();
|
||||||
|
|
||||||
|
$this->table(
|
||||||
|
['Metrik', 'Jumlah'],
|
||||||
|
[
|
||||||
|
['Total Data', number_format($totalData)],
|
||||||
|
['Data Aktif', number_format($activeData)],
|
||||||
|
['Data Terhapus (Soft)', number_format($deletedData)],
|
||||||
|
['Data dengan Dokument ID', number_format($dataWithDokument)],
|
||||||
|
['Data tanpa Dokument ID', number_format($dataWithoutDokument)],
|
||||||
|
]
|
||||||
|
);
|
||||||
|
|
||||||
|
$this->newLine();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Tampilkan statistik cleanup
|
||||||
|
*/
|
||||||
|
private function showCleanupStats(?int $permohonanId = null, ?int $createdBy = null): void
|
||||||
|
{
|
||||||
|
$this->info('Data yang Memerlukan Cleanup:');
|
||||||
|
|
||||||
|
$query = DB::table('inspeksi as i')
|
||||||
|
->select(
|
||||||
|
'i.permohonan_id',
|
||||||
|
'i.created_by',
|
||||||
|
DB::raw('COUNT(CASE WHEN i.dokument_id IS NOT NULL AND i.deleted_at IS NULL THEN 1 END) as new_data_count'),
|
||||||
|
DB::raw('COUNT(CASE WHEN i.dokument_id IS NULL AND i.deleted_at IS NULL THEN 1 END) as old_data_count'),
|
||||||
|
DB::raw('MIN(i.created_at) as oldest_data'),
|
||||||
|
DB::raw('MAX(i.created_at) as newest_data')
|
||||||
|
)
|
||||||
|
->whereNull('i.deleted_at')
|
||||||
|
->groupBy('i.permohonan_id', 'i.created_by');
|
||||||
|
|
||||||
|
if ($permohonanId) {
|
||||||
|
$query->where('i.permohonan_id', $permohonanId);
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($createdBy) {
|
||||||
|
$query->where('i.created_by', $createdBy);
|
||||||
|
}
|
||||||
|
|
||||||
|
$results = $query->havingRaw('new_data_count > 0 AND old_data_count > 0')
|
||||||
|
->orderBy('old_data_count', 'desc')
|
||||||
|
->limit(20)
|
||||||
|
->get();
|
||||||
|
|
||||||
|
if ($results->isEmpty()) {
|
||||||
|
$this->info('Tidak ada data yang memerlukan cleanup.');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
$this->table(
|
||||||
|
['Permohonan ID', 'Created By', 'Data Baru', 'Data Lama', 'Data Terlama', 'Data Terbaru'],
|
||||||
|
$results->map(function ($item) {
|
||||||
|
return [
|
||||||
|
$item->permohonan_id,
|
||||||
|
$item->created_by,
|
||||||
|
$item->new_data_count,
|
||||||
|
$item->old_data_count,
|
||||||
|
$item->oldest_data,
|
||||||
|
$item->newest_data,
|
||||||
|
];
|
||||||
|
})->toArray()
|
||||||
|
);
|
||||||
|
|
||||||
|
$totalPermohonan = $results->count();
|
||||||
|
$totalOldData = $results->sum('old_data_count');
|
||||||
|
|
||||||
|
$this->info("Total permohonan yang perlu cleanup: {$totalPermohonan}");
|
||||||
|
$this->info("Total data lama yang akan dihapus: {$totalOldData}");
|
||||||
|
$this->newLine();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Tampilkan detail data
|
||||||
|
*/
|
||||||
|
private function showDetailedData(?int $permohonanId = null, ?int $createdBy = null): void
|
||||||
|
{
|
||||||
|
$this->info('Detail Data (20 data terbaru):');
|
||||||
|
|
||||||
|
$query = Inspeksi::with(['permohonan', 'dokument'])
|
||||||
|
->whereNull('deleted_at');
|
||||||
|
|
||||||
|
if ($permohonanId) {
|
||||||
|
$query->where('permohonan_id', $permohonanId);
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($createdBy) {
|
||||||
|
$query->where('created_by', $createdBy);
|
||||||
|
}
|
||||||
|
|
||||||
|
$data = $query->orderBy('created_at', 'desc')
|
||||||
|
->limit(20)
|
||||||
|
->get();
|
||||||
|
|
||||||
|
if ($data->isEmpty()) {
|
||||||
|
$this->info('Tidak ada data untuk ditampilkan.');
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
$this->table(
|
||||||
|
['ID', 'Permohonan ID', 'Created By', 'Dokument ID', 'Status', 'Created At'],
|
||||||
|
$data->map(function ($item) {
|
||||||
|
return [
|
||||||
|
$item->id,
|
||||||
|
$item->permohonan_id,
|
||||||
|
$item->created_by,
|
||||||
|
$item->dokument_id ?? '-',
|
||||||
|
$item->status,
|
||||||
|
$item->created_at,
|
||||||
|
];
|
||||||
|
})->toArray()
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
99
app/Console/Commands/CleanupSingleInspeksiCommand.php
Normal file
99
app/Console/Commands/CleanupSingleInspeksiCommand.php
Normal file
@@ -0,0 +1,99 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Modules\Lpj\Console\Commands;
|
||||||
|
|
||||||
|
use Illuminate\Console\Command;
|
||||||
|
use Illuminate\Support\Facades\Log;
|
||||||
|
use Modules\Lpj\Jobs\CleanupInspeksiDataJob;
|
||||||
|
use Modules\Lpj\Services\InspeksiCleanupService;
|
||||||
|
|
||||||
|
class CleanupSingleInspeksiCommand extends Command
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* The name and signature of the console command.
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $signature = 'lpj:cleanup-single-inspeksi
|
||||||
|
{permohonan-id : ID permohonan yang akan di-cleanup}
|
||||||
|
{created-by : ID user yang membuat data}
|
||||||
|
{--sync : Jalankan secara synchronous}
|
||||||
|
{--force : Jalankan tanpa konfirmasi}';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* The console command description.
|
||||||
|
*
|
||||||
|
* @var string
|
||||||
|
*/
|
||||||
|
protected $description = 'Cleanup data inspeksi untuk 1 permohonan dan user tertentu';
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Execute the console command.
|
||||||
|
*/
|
||||||
|
public function handle(): int
|
||||||
|
{
|
||||||
|
Log::info('CleanupSingleInspeksiCommand: Memulai proses cleanup', [
|
||||||
|
'permohonan_id' => $this->argument('permohonan-id'),
|
||||||
|
'created_by' => $this->argument('created-by'),
|
||||||
|
'sync' => $this->option('sync')
|
||||||
|
]);
|
||||||
|
|
||||||
|
try {
|
||||||
|
$permohonanId = (int) $this->argument('permohonan-id');
|
||||||
|
$createdBy = (int) $this->argument('created-by');
|
||||||
|
$sync = $this->option('sync');
|
||||||
|
$force = $this->option('force');
|
||||||
|
|
||||||
|
// Validasi input
|
||||||
|
if ($permohonanId <= 0) {
|
||||||
|
$this->error('Permohonan ID harus angka positif.');
|
||||||
|
return Command::FAILURE;
|
||||||
|
}
|
||||||
|
|
||||||
|
if ($createdBy <= 0) {
|
||||||
|
$this->error('Created By harus angka positif.');
|
||||||
|
return Command::FAILURE;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Tampilkan info
|
||||||
|
$this->info('=== Cleanup Single Inspeksi ===');
|
||||||
|
$this->info("Permohonan ID: {$permohonanId}");
|
||||||
|
$this->info("Created By: {$createdBy}");
|
||||||
|
$this->info("Mode: " . ($sync ? 'Synchronous' : 'Queue'));
|
||||||
|
$this->newLine();
|
||||||
|
|
||||||
|
// Konfirmasi jika tidak force
|
||||||
|
if (!$force && !$this->confirm('Lanjutkan dengan cleanup?')) {
|
||||||
|
$this->info('Cleanup dibatalkan.');
|
||||||
|
return Command::SUCCESS;
|
||||||
|
}
|
||||||
|
|
||||||
|
// Jalankan cleanup
|
||||||
|
$cleanupService = new InspeksiCleanupService();
|
||||||
|
|
||||||
|
if ($sync) {
|
||||||
|
$this->info('Menjalankan cleanup secara synchronous...');
|
||||||
|
$cleanupService->cleanupSync($permohonanId, $createdBy);
|
||||||
|
$this->info('Cleanup selesai.');
|
||||||
|
} else {
|
||||||
|
$this->info('Mengirim job ke queue...');
|
||||||
|
$cleanupService->cleanupAsync($permohonanId, $createdBy);
|
||||||
|
$this->info('Job telah di-dispatch ke queue.');
|
||||||
|
$this->info('Monitor progress di log.');
|
||||||
|
}
|
||||||
|
|
||||||
|
return Command::SUCCESS;
|
||||||
|
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
Log::error('CleanupSingleInspeksiCommand: Terjadi error saat proses cleanup', [
|
||||||
|
'permohonan_id' => $this->argument('permohonan-id'),
|
||||||
|
'created_by' => $this->argument('created-by'),
|
||||||
|
'error' => $e->getMessage(),
|
||||||
|
'trace' => $e->getTraceAsString()
|
||||||
|
]);
|
||||||
|
|
||||||
|
$this->error('Terjadi kesalahan: ' . $e->getMessage());
|
||||||
|
return Command::FAILURE;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
123
app/Console/README.md
Normal file
123
app/Console/README.md
Normal file
@@ -0,0 +1,123 @@
|
|||||||
|
# Console Commands untuk Cleanup Data Inspeksi
|
||||||
|
|
||||||
|
## Daftar Command
|
||||||
|
|
||||||
|
### 1. `lpj:cleanup-inspeksi`
|
||||||
|
Command utama untuk cleanup data inspeksi secara batch.
|
||||||
|
|
||||||
|
**Usage:**
|
||||||
|
```bash
|
||||||
|
php artisan lpj:cleanup-inspeksi [options]
|
||||||
|
```
|
||||||
|
|
||||||
|
**Options:**
|
||||||
|
- `--permohonan-id=ID` - Filter berdasarkan permohonan ID (opsional)
|
||||||
|
- `--sync` - Jalankan secara synchronous
|
||||||
|
- `--dry-run` - Tampilkan preview tanpa menjalankan cleanup
|
||||||
|
- `--force` - Jalankan tanpa konfirmasi
|
||||||
|
|
||||||
|
**Contoh Penggunaan:**
|
||||||
|
```bash
|
||||||
|
# Preview data yang akan di-cleanup
|
||||||
|
php artisan lpj:cleanup-inspeksi --dry-run
|
||||||
|
|
||||||
|
# Cleanup semua data (dengan konfirmasi)
|
||||||
|
php artisan lpj:cleanup-inspeksi
|
||||||
|
|
||||||
|
# Cleanup untuk permohonan tertentu
|
||||||
|
php artisan lpj:cleanup-inspeksi --permohonan-id=123 --force
|
||||||
|
|
||||||
|
# Jalankan secara sync
|
||||||
|
php artisan lpj:cleanup-inspeksi --sync --force
|
||||||
|
```
|
||||||
|
|
||||||
|
### 2. `lpj:cleanup-single-inspeksi`
|
||||||
|
Command untuk cleanup 1 permohonan dan user tertentu.
|
||||||
|
|
||||||
|
**Usage:**
|
||||||
|
```bash
|
||||||
|
php artisan lpj:cleanup-single-inspeksi <permohonan-id> <created-by> [options]
|
||||||
|
```
|
||||||
|
|
||||||
|
**Arguments:**
|
||||||
|
- `permohonan-id` - ID permohonan yang akan di-cleanup (required)
|
||||||
|
- `created-by` - ID user yang membuat data (required)
|
||||||
|
|
||||||
|
**Options:**
|
||||||
|
- `--sync` - Jalankan secara synchronous
|
||||||
|
- `--force` - Jalankan tanpa konfirmasi
|
||||||
|
|
||||||
|
**Contoh Penggunaan:**
|
||||||
|
```bash
|
||||||
|
# Cleanup untuk permohonan 123 oleh user 456
|
||||||
|
php artisan lpj:cleanup-single-inspeksi 123 456
|
||||||
|
|
||||||
|
# Jalankan secara sync tanpa konfirmasi
|
||||||
|
php artisan lpj:cleanup-single-inspeksi 123 456 --sync --force
|
||||||
|
```
|
||||||
|
|
||||||
|
### 3. `lpj:cleanup-inspeksi-status`
|
||||||
|
Command untuk mengecek status data inspeksi dan melihat statistik cleanup.
|
||||||
|
|
||||||
|
**Usage:**
|
||||||
|
```bash
|
||||||
|
php artisan lpj:cleanup-inspeksi-status [options]
|
||||||
|
```
|
||||||
|
|
||||||
|
**Options:**
|
||||||
|
- `--permohonan-id=ID` - Filter berdasarkan permohonan ID
|
||||||
|
- `--created-by=ID` - Filter berdasarkan user ID
|
||||||
|
- `--detailed` - Tampilkan detail data
|
||||||
|
|
||||||
|
**Contoh Penggunaan:**
|
||||||
|
```bash
|
||||||
|
# Lihat statistik umum
|
||||||
|
php artisan lpj:cleanup-inspeksi-status
|
||||||
|
|
||||||
|
# Filter berdasarkan permohonan
|
||||||
|
php artisan lpj:cleanup-inspeksi-status --permohonan-id=123
|
||||||
|
|
||||||
|
# Tampilkan detail data
|
||||||
|
php artisan lpj:cleanup-inspeksi-status --detailed
|
||||||
|
```
|
||||||
|
|
||||||
|
## Scheduling
|
||||||
|
|
||||||
|
Command cleanup otomatis dijalankan setiap hari jam 2 pagi dan setiap minggu. Konfigurasi scheduling ada di `LpjServiceProvider.php`.
|
||||||
|
|
||||||
|
## Monitoring
|
||||||
|
|
||||||
|
Semua aktivitas cleanup dicatat di log file:
|
||||||
|
- `storage/logs/laravel.log` - Log umum
|
||||||
|
- `storage/logs/cleanup-inspeksi.log` - Log cleanup harian
|
||||||
|
- `storage/logs/cleanup-inspeksi-weekly.log` - Log cleanup mingguan
|
||||||
|
|
||||||
|
## Alur Kerja Cleanup
|
||||||
|
|
||||||
|
1. **Identifikasi**: Cari data inspeksi yang memiliki:
|
||||||
|
- Data baru dengan `dokument_id` (tidak null)
|
||||||
|
- Data lama tanpa `dokument_id` (null)
|
||||||
|
- Sama `permohonan_id` dan `created_by`
|
||||||
|
|
||||||
|
2. **Proses**: Soft delete data lama menggunakan Laravel SoftDeletes
|
||||||
|
|
||||||
|
3. **Logging**: Catat setiap operasi untuk audit trail
|
||||||
|
|
||||||
|
4. **Transaction**: Gunakan DB transaction untuk konsistensi data
|
||||||
|
|
||||||
|
## Troubleshooting
|
||||||
|
|
||||||
|
### Command tidak muncul
|
||||||
|
Pastikan service provider sudah diregister dengan benar:
|
||||||
|
```bash
|
||||||
|
php artisan list | grep lpj
|
||||||
|
```
|
||||||
|
|
||||||
|
### Data tidak ter-cleanup
|
||||||
|
- Cek log untuk error
|
||||||
|
- Pastikan ada data yang memenuhi kriteria
|
||||||
|
- Gunakan `--dry-run` untuk preview
|
||||||
|
- Gunakan `--detailed` untuk melihat detail data
|
||||||
|
|
||||||
|
### Performance
|
||||||
|
Untuk data besar, gunakan mode queue (default) daripada `--sync`
|
||||||
239
app/Http/Controllers/InspeksiController.php
Normal file
239
app/Http/Controllers/InspeksiController.php
Normal file
@@ -0,0 +1,239 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Modules\Lpj\Http\Controllers;
|
||||||
|
|
||||||
|
use App\Http\Controllers\Controller;
|
||||||
|
use Illuminate\Http\Request;
|
||||||
|
use Illuminate\Support\Facades\Auth;
|
||||||
|
use Illuminate\Support\Facades\DB;
|
||||||
|
use Illuminate\Support\Facades\Log;
|
||||||
|
use Modules\Lpj\Models\Inspeksi;
|
||||||
|
use Modules\Lpj\Services\InspeksiCleanupService;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Controller contoh untuk menunjukkan penggunaan InspeksiCleanupService
|
||||||
|
*
|
||||||
|
* Controller ini berisi contoh method untuk membuat dan update data inspeksi
|
||||||
|
* dengan otomatis menjalankan cleanup data lama yang tidak memiliki dokument_id
|
||||||
|
*/
|
||||||
|
class InspeksiController extends Controller
|
||||||
|
{
|
||||||
|
protected InspeksiCleanupService $cleanupService;
|
||||||
|
|
||||||
|
public function __construct(InspeksiCleanupService $cleanupService)
|
||||||
|
{
|
||||||
|
$this->cleanupService = $cleanupService;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Contoh method untuk membuat data inspeksi baru
|
||||||
|
*
|
||||||
|
* @param Request $request
|
||||||
|
* @return \Illuminate\Http\JsonResponse
|
||||||
|
*/
|
||||||
|
public function store(Request $request)
|
||||||
|
{
|
||||||
|
$validated = $request->validate([
|
||||||
|
'permohonan_id' => 'required|integer|exists:permohonan,id',
|
||||||
|
'dokument_id' => 'nullable|integer|exists:dokumen_jaminan,id',
|
||||||
|
'data_form' => 'required|json',
|
||||||
|
'foto_form' => 'nullable|json',
|
||||||
|
'denah_form' => 'nullable|json',
|
||||||
|
'name' => 'required|string|max:255',
|
||||||
|
'status' => 'required|string|max:50',
|
||||||
|
]);
|
||||||
|
|
||||||
|
DB::beginTransaction();
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Buat data inspeksi baru
|
||||||
|
$inspeksi = Inspeksi::create(array_merge($validated, [
|
||||||
|
'created_by' => Auth::id(),
|
||||||
|
'updated_by' => Auth::id(),
|
||||||
|
]));
|
||||||
|
|
||||||
|
Log::info('InspeksiController: Data inspeksi berhasil dibuat', [
|
||||||
|
'inspeksi_id' => $inspeksi->id,
|
||||||
|
'permohonan_id' => $inspeksi->permohonan_id,
|
||||||
|
'dokument_id' => $inspeksi->dokument_id,
|
||||||
|
'created_by' => $inspeksi->created_by
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Commit transaksi utama
|
||||||
|
DB::commit();
|
||||||
|
|
||||||
|
// Jalankan cleanup secara async jika ada dokument_id
|
||||||
|
// Ini akan menghapus data lama yang tidak memiliki dokument_id
|
||||||
|
if ($inspeksi->dokument_id) {
|
||||||
|
Log::info('InspeksiController: Memulai cleanup data lama', [
|
||||||
|
'permohonan_id' => $inspeksi->permohonan_id,
|
||||||
|
'created_by' => $inspeksi->created_by,
|
||||||
|
'dokument_id' => $inspeksi->dokument_id
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Dispatch job cleanup secara async
|
||||||
|
$this->cleanupService->cleanupAsync(
|
||||||
|
$inspeksi->permohonan_id,
|
||||||
|
$inspeksi->created_by,
|
||||||
|
$inspeksi->dokument_id
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
return response()->json([
|
||||||
|
'success' => true,
|
||||||
|
'message' => 'Data inspeksi berhasil dibuat',
|
||||||
|
'data' => $inspeksi->load(['permohonan', 'dokument'])
|
||||||
|
], 201);
|
||||||
|
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
DB::rollBack();
|
||||||
|
|
||||||
|
Log::error('InspeksiController: Gagal membuat data inspeksi', [
|
||||||
|
'error' => $e->getMessage(),
|
||||||
|
'trace' => $e->getTraceAsString()
|
||||||
|
]);
|
||||||
|
|
||||||
|
return response()->json([
|
||||||
|
'success' => false,
|
||||||
|
'message' => 'Gagal membuat data inspeksi: ' . $e->getMessage()
|
||||||
|
], 500);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Contoh method untuk update data inspeksi
|
||||||
|
*
|
||||||
|
* @param Request $request
|
||||||
|
* @param int $id
|
||||||
|
* @return \Illuminate\Http\JsonResponse
|
||||||
|
*/
|
||||||
|
public function update(Request $request, $id)
|
||||||
|
{
|
||||||
|
$validated = $request->validate([
|
||||||
|
'dokument_id' => 'nullable|integer|exists:dokumen_jaminan,id',
|
||||||
|
'data_form' => 'required|json',
|
||||||
|
'foto_form' => 'nullable|json',
|
||||||
|
'denah_form' => 'nullable|json',
|
||||||
|
'name' => 'required|string|max:255',
|
||||||
|
'status' => 'required|string|max:50',
|
||||||
|
]);
|
||||||
|
|
||||||
|
DB::beginTransaction();
|
||||||
|
|
||||||
|
try {
|
||||||
|
$inspeksi = Inspeksi::findOrFail($id);
|
||||||
|
|
||||||
|
// Simpan data lama untuk logging
|
||||||
|
$oldDokumentId = $inspeksi->dokument_id;
|
||||||
|
|
||||||
|
// Update data
|
||||||
|
$inspeksi->update(array_merge($validated, [
|
||||||
|
'updated_by' => Auth::id(),
|
||||||
|
]));
|
||||||
|
|
||||||
|
Log::info('InspeksiController: Data inspeksi berhasil diupdate', [
|
||||||
|
'inspeksi_id' => $inspeksi->id,
|
||||||
|
'permohonan_id' => $inspeksi->permohonan_id,
|
||||||
|
'old_dokument_id' => $oldDokumentId,
|
||||||
|
'new_dokument_id' => $inspeksi->dokument_id,
|
||||||
|
'updated_by' => $inspeksi->updated_by
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Commit transaksi utama
|
||||||
|
DB::commit();
|
||||||
|
|
||||||
|
// Jalankan cleanup jika dokument_id berubah dari null ke ada nilai
|
||||||
|
if (!$oldDokumentId && $inspeksi->dokument_id) {
|
||||||
|
Log::info('InspeksiController: Dokument ID berubah dari null, memulai cleanup', [
|
||||||
|
'inspeksi_id' => $inspeksi->id,
|
||||||
|
'permohonan_id' => $inspeksi->permohonan_id,
|
||||||
|
'created_by' => $inspeksi->created_by,
|
||||||
|
'new_dokument_id' => $inspeksi->dokument_id
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Dispatch job cleanup secara async
|
||||||
|
$this->cleanupService->cleanupAsync(
|
||||||
|
$inspeksi->permohonan_id,
|
||||||
|
$inspeksi->created_by,
|
||||||
|
$inspeksi->dokument_id
|
||||||
|
);
|
||||||
|
}
|
||||||
|
|
||||||
|
return response()->json([
|
||||||
|
'success' => true,
|
||||||
|
'message' => 'Data inspeksi berhasil diupdate',
|
||||||
|
'data' => $inspeksi->load(['permohonan', 'dokument'])
|
||||||
|
]);
|
||||||
|
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
DB::rollBack();
|
||||||
|
|
||||||
|
Log::error('InspeksiController: Gagal update data inspeksi', [
|
||||||
|
'inspeksi_id' => $id,
|
||||||
|
'error' => $e->getMessage(),
|
||||||
|
'trace' => $e->getTraceAsString()
|
||||||
|
]);
|
||||||
|
|
||||||
|
return response()->json([
|
||||||
|
'success' => false,
|
||||||
|
'message' => 'Gagal update data inspeksi: ' . $e->getMessage()
|
||||||
|
], 500);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Contoh method untuk menjalankan cleanup secara manual
|
||||||
|
*
|
||||||
|
* @param Request $request
|
||||||
|
* @return \Illuminate\Http\JsonResponse
|
||||||
|
*/
|
||||||
|
public function cleanup(Request $request)
|
||||||
|
{
|
||||||
|
$validated = $request->validate([
|
||||||
|
'permohonan_id' => 'required|integer|exists:permohonan,id',
|
||||||
|
'created_by' => 'required|integer|exists:users,id',
|
||||||
|
'sync' => 'boolean', // Opsional, default false (async)
|
||||||
|
]);
|
||||||
|
|
||||||
|
try {
|
||||||
|
$permohonanId = $validated['permohonan_id'];
|
||||||
|
$createdBy = $validated['created_by'];
|
||||||
|
$sync = $validated['sync'] ?? false;
|
||||||
|
|
||||||
|
Log::info('InspeksiController: Menjalankan cleanup manual', [
|
||||||
|
'permohonan_id' => $permohonanId,
|
||||||
|
'created_by' => $createdBy,
|
||||||
|
'sync' => $sync
|
||||||
|
]);
|
||||||
|
|
||||||
|
if ($sync) {
|
||||||
|
// Jalankan secara sync
|
||||||
|
$this->cleanupService->cleanupSync($permohonanId, $createdBy);
|
||||||
|
|
||||||
|
return response()->json([
|
||||||
|
'success' => true,
|
||||||
|
'message' => 'Cleanup selesai dijalankan secara synchronous'
|
||||||
|
]);
|
||||||
|
} else {
|
||||||
|
// Dispatch ke queue
|
||||||
|
$this->cleanupService->cleanupAsync($permohonanId, $createdBy);
|
||||||
|
|
||||||
|
return response()->json([
|
||||||
|
'success' => true,
|
||||||
|
'message' => 'Cleanup job berhasil di-dispatch ke queue'
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
Log::error('InspeksiController: Gagal menjalankan cleanup manual', [
|
||||||
|
'error' => $e->getMessage(),
|
||||||
|
'trace' => $e->getTraceAsString()
|
||||||
|
]);
|
||||||
|
|
||||||
|
return response()->json([
|
||||||
|
'success' => false,
|
||||||
|
'message' => 'Gagal menjalankan cleanup: ' . $e->getMessage()
|
||||||
|
], 500);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -9,9 +9,11 @@ use Maatwebsite\Excel\Facades\Excel;
|
|||||||
use Modules\Lpj\Exports\BasicDataSurveyorExport;
|
use Modules\Lpj\Exports\BasicDataSurveyorExport;
|
||||||
use Illuminate\Support\Facades\DB;
|
use Illuminate\Support\Facades\DB;
|
||||||
use Illuminate\Support\Facades\Auth;
|
use Illuminate\Support\Facades\Auth;
|
||||||
|
use Illuminate\Support\Facades\Log;
|
||||||
use Barryvdh\DomPDF\Facade\Pdf;
|
use Barryvdh\DomPDF\Facade\Pdf;
|
||||||
use Illuminate\Support\Facades\Storage;
|
use Illuminate\Support\Facades\Storage;
|
||||||
use Illuminate\Support\Carbon;
|
use Illuminate\Support\Carbon;
|
||||||
|
use Exception;
|
||||||
use Modules\Lpj\Models\Debiture;
|
use Modules\Lpj\Models\Debiture;
|
||||||
use Modules\Lpj\Models\LaporanExternal;
|
use Modules\Lpj\Models\LaporanExternal;
|
||||||
use Modules\Lpj\Models\Permohonan;
|
use Modules\Lpj\Models\Permohonan;
|
||||||
@@ -106,6 +108,9 @@ class SurveyorController extends Controller
|
|||||||
$provinces = Province::all();
|
$provinces = Province::all();
|
||||||
$bentukTanah = BentukTanah::all();
|
$bentukTanah = BentukTanah::all();
|
||||||
|
|
||||||
|
// Jalankan cleanup inspeksi otomatis untuk permohonan ini
|
||||||
|
$this->cleanupInspeksiData($id);
|
||||||
|
|
||||||
// Get all inspeksi data for this permohonan
|
// Get all inspeksi data for this permohonan
|
||||||
if (strtolower($permohonan->tujuanPenilaian->name) == 'rap') {
|
if (strtolower($permohonan->tujuanPenilaian->name) == 'rap') {
|
||||||
$inspeksiData = Inspeksi::where('permohonan_id', $id)
|
$inspeksiData = Inspeksi::where('permohonan_id', $id)
|
||||||
@@ -237,7 +242,7 @@ class SurveyorController extends Controller
|
|||||||
], 200);
|
], 200);
|
||||||
|
|
||||||
} catch (\Exception $e) {
|
} catch (\Exception $e) {
|
||||||
\Log::error('Denah Store Error: ' . $e->getMessage());
|
Log::error('Denah Store Error: ' . $e->getMessage());
|
||||||
return response()->json([
|
return response()->json([
|
||||||
'success' => false,
|
'success' => false,
|
||||||
'message' => 'Gagal menyimpan data: ' . $e->getMessage()
|
'message' => 'Gagal menyimpan data: ' . $e->getMessage()
|
||||||
@@ -1063,7 +1068,7 @@ class SurveyorController extends Controller
|
|||||||
return null;
|
return null;
|
||||||
|
|
||||||
} catch (\Exception $e) {
|
} catch (\Exception $e) {
|
||||||
\Log::error('File upload error: ' . $e->getMessage());
|
Log::error('File upload error: ' . $e->getMessage());
|
||||||
throw new \Exception("Gagal mengupload file: " . $e->getMessage());
|
throw new \Exception("Gagal mengupload file: " . $e->getMessage());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -2893,5 +2898,99 @@ class SurveyorController extends Controller
|
|||||||
]);
|
]);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Fungsi untuk cleanup data inspeksi otomatis
|
||||||
|
* Menghapus data inspeksi tanpa dokument_id jika ada data lain dengan dokument_id yang sama
|
||||||
|
*/
|
||||||
|
private function cleanupInspeksiData($permohonanId)
|
||||||
|
{
|
||||||
|
try {
|
||||||
|
Log::info('SurveyorController: Memulai cleanup inspeksi otomatis', [
|
||||||
|
'permohonan_id' => $permohonanId,
|
||||||
|
'user_id' => Auth::id()
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Ambil data inspeksi yang memiliki dokument_id (data lengkap)
|
||||||
|
$dataWithDokument = Inspeksi::where('permohonan_id', $permohonanId)
|
||||||
|
->whereNotNull('dokument_id')
|
||||||
|
->whereNull('deleted_at')
|
||||||
|
->get();
|
||||||
|
|
||||||
|
// Ambil data inspeksi yang tidak memiliki dokument_id (data yang akan di-cleanup)
|
||||||
|
$dataWithoutDokument = Inspeksi::where('permohonan_id', $permohonanId)
|
||||||
|
->whereNull('dokument_id')
|
||||||
|
->whereNull('deleted_at')
|
||||||
|
->get();
|
||||||
|
|
||||||
|
// Jika ada data tanpa dokument_id, cek apakah ada data dengan dokument_id yang sama
|
||||||
|
if ($dataWithoutDokument->isNotEmpty() && $dataWithDokument->isNotEmpty()) {
|
||||||
|
|
||||||
|
// Group data dengan dokument_id by created_by
|
||||||
|
$groupedDataWithDokument = $dataWithDokument->groupBy('created_by');
|
||||||
|
|
||||||
|
// Group data tanpa dokument_id by created_by
|
||||||
|
$groupedDataWithoutDokument = $dataWithoutDokument->groupBy('created_by');
|
||||||
|
|
||||||
|
// Proses cleanup untuk setiap user
|
||||||
|
foreach ($groupedDataWithDokument as $userId => $userDataWithDokument) {
|
||||||
|
|
||||||
|
// Cek apakah user ini juga memiliki data tanpa dokument_id
|
||||||
|
if (isset($groupedDataWithoutDokument[$userId])) {
|
||||||
|
|
||||||
|
// Ambil salah satu data dengan dokument_id sebagai referensi untuk logging
|
||||||
|
$referenceData = $userDataWithDokument->first();
|
||||||
|
|
||||||
|
Log::info('SurveyorController: Menemukan data lengkap untuk user, akan menghapus data tidak lengkap', [
|
||||||
|
'user_id' => $userId,
|
||||||
|
'permohonan_id' => $permohonanId,
|
||||||
|
'reference_dokument_id' => $referenceData->dokument_id,
|
||||||
|
'data_count_to_delete' => $groupedDataWithoutDokument[$userId]->count()
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Ambil semua data tanpa dokument_id untuk user ini
|
||||||
|
$userDataWithoutDokument = $groupedDataWithoutDokument[$userId];
|
||||||
|
|
||||||
|
// Soft delete data tanpa dokument_id
|
||||||
|
foreach ($userDataWithoutDokument as $dataToDelete) {
|
||||||
|
DB::beginTransaction();
|
||||||
|
try {
|
||||||
|
// Soft delete data
|
||||||
|
$dataToDelete->delete();
|
||||||
|
|
||||||
|
Log::info('SurveyorController: Data inspeksi berhasil di-soft delete', [
|
||||||
|
'id' => $dataToDelete->id,
|
||||||
|
'permohonan_id' => $dataToDelete->permohonan_id,
|
||||||
|
'dokument_id' => $dataToDelete->dokument_id,
|
||||||
|
'created_by' => $dataToDelete->created_by,
|
||||||
|
'deleted_at' => now()
|
||||||
|
]);
|
||||||
|
|
||||||
|
DB::commit();
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
DB::rollback();
|
||||||
|
Log::error('SurveyorController: Gagal menghapus data inspeksi', [
|
||||||
|
'id' => $dataToDelete->id,
|
||||||
|
'error' => $e->getMessage()
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Log::info('SurveyorController: Cleanup inspeksi otomatis selesai', [
|
||||||
|
'permohonan_id' => $permohonanId,
|
||||||
|
'data_with_dokument' => $dataWithDokument->count(),
|
||||||
|
'data_without_dokument' => $dataWithoutDokument->count()
|
||||||
|
]);
|
||||||
|
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
Log::error('SurveyorController: Error saat cleanup inspeksi otomatis', [
|
||||||
|
'permohonan_id' => $permohonanId,
|
||||||
|
'error' => $e->getMessage(),
|
||||||
|
'trace' => $e->getTraceAsString()
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
156
app/Jobs/CleanupInspeksiDataJob.php
Normal file
156
app/Jobs/CleanupInspeksiDataJob.php
Normal file
@@ -0,0 +1,156 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Modules\Lpj\Jobs;
|
||||||
|
|
||||||
|
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\Log;
|
||||||
|
use Modules\Lpj\Models\Inspeksi;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Job untuk membersihkan data inspeksi yang tidak memiliki dokument_id
|
||||||
|
*
|
||||||
|
* Case: Jika ada data inspeksi yang masuk dengan permohonan_id yang sama
|
||||||
|
* tetapi memiliki dokument_id dan user created_by yang sama, maka
|
||||||
|
* data lama (tanpa dokument_id) akan di-soft delete
|
||||||
|
*/
|
||||||
|
class CleanupInspeksiDataJob implements ShouldQueue
|
||||||
|
{
|
||||||
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
||||||
|
|
||||||
|
public $timeout = 300; // 5 menit
|
||||||
|
public $tries = 3;
|
||||||
|
public $maxExceptions = 3;
|
||||||
|
public $backoff = [60, 120, 300]; // Exponential backoff dalam detik
|
||||||
|
|
||||||
|
protected int $permohonanId;
|
||||||
|
protected int $createdBy;
|
||||||
|
protected ?int $dokumentId;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Create a new job instance.
|
||||||
|
*
|
||||||
|
* @param int $permohonanId
|
||||||
|
* @param int $createdBy
|
||||||
|
* @param int|null $dokumentId
|
||||||
|
*/
|
||||||
|
public function __construct(int $permohonanId, int $createdBy, ?int $dokumentId = null)
|
||||||
|
{
|
||||||
|
$this->permohonanId = $permohonanId;
|
||||||
|
$this->createdBy = $createdBy;
|
||||||
|
$this->dokumentId = $dokumentId;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Execute the job.
|
||||||
|
*
|
||||||
|
* @return void
|
||||||
|
* @throws \Exception
|
||||||
|
*/
|
||||||
|
public function handle(): void
|
||||||
|
{
|
||||||
|
Log::info('CleanupInspeksiDataJob: Memulai proses cleanup data inspeksi', [
|
||||||
|
'permohonan_id' => $this->permohonanId,
|
||||||
|
'created_by' => $this->createdBy,
|
||||||
|
'dokument_id' => $this->dokumentId
|
||||||
|
]);
|
||||||
|
|
||||||
|
DB::beginTransaction();
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Cari data inspeksi yang memiliki dokument_id (data baru)
|
||||||
|
$newInspeksi = Inspeksi::where('permohonan_id', $this->permohonanId)
|
||||||
|
->where('created_by', $this->createdBy)
|
||||||
|
->whereNotNull('dokument_id')
|
||||||
|
->whereNull('deleted_at')
|
||||||
|
->first();
|
||||||
|
|
||||||
|
if (!$newInspeksi) {
|
||||||
|
Log::warning('CleanupInspeksiDataJob: Tidak ditemukan data inspeksi baru dengan dokument_id', [
|
||||||
|
'permohonan_id' => $this->permohonanId,
|
||||||
|
'created_by' => $this->createdBy
|
||||||
|
]);
|
||||||
|
DB::rollBack();
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
Log::info('CleanupInspeksiDataJob: Data inspeksi baru ditemukan', [
|
||||||
|
'inspeksi_id' => $newInspeksi->id,
|
||||||
|
'dokument_id' => $newInspeksi->dokument_id
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Cari data inspeksi lama yang tidak memiliki dokument_id
|
||||||
|
$oldInspeksiList = Inspeksi::where('permohonan_id', $this->permohonanId)
|
||||||
|
->where('created_by', $this->createdBy)
|
||||||
|
->whereNull('dokument_id')
|
||||||
|
->whereNull('deleted_at')
|
||||||
|
->where('id', '!=', $newInspeksi->id) // Jangan hapus data yang baru saja ditemukan
|
||||||
|
->get();
|
||||||
|
|
||||||
|
if ($oldInspeksiList->isEmpty()) {
|
||||||
|
Log::info('CleanupInspeksiDataJob: Tidak ditemukan data inspeksi lama tanpa dokument_id', [
|
||||||
|
'permohonan_id' => $this->permohonanId,
|
||||||
|
'created_by' => $this->createdBy
|
||||||
|
]);
|
||||||
|
DB::commit();
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
$deletedCount = 0;
|
||||||
|
foreach ($oldInspeksiList as $oldInspeksi) {
|
||||||
|
// Soft delete data lama
|
||||||
|
$oldInspeksi->delete(); // Menggunakan soft delete karena model menggunakan SoftDeletes trait
|
||||||
|
|
||||||
|
Log::info('CleanupInspeksiDataJob: Data inspeksi lama berhasil di-soft delete', [
|
||||||
|
'old_inspeksi_id' => $oldInspeksi->id,
|
||||||
|
'permohonan_id' => $oldInspeksi->permohonan_id,
|
||||||
|
'created_by' => $oldInspeksi->created_by,
|
||||||
|
'deleted_at' => now()->toDateTimeString()
|
||||||
|
]);
|
||||||
|
|
||||||
|
$deletedCount++;
|
||||||
|
}
|
||||||
|
|
||||||
|
DB::commit();
|
||||||
|
|
||||||
|
Log::info('CleanupInspeksiDataJob: Proses cleanup selesai', [
|
||||||
|
'permohonan_id' => $this->permohonanId,
|
||||||
|
'created_by' => $this->createdBy,
|
||||||
|
'deleted_count' => $deletedCount,
|
||||||
|
'new_inspeksi_id' => $newInspeksi->id
|
||||||
|
]);
|
||||||
|
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
DB::rollBack();
|
||||||
|
|
||||||
|
Log::error('CleanupInspeksiDataJob: Terjadi error saat proses cleanup', [
|
||||||
|
'permohonan_id' => $this->permohonanId,
|
||||||
|
'created_by' => $this->createdBy,
|
||||||
|
'error' => $e->getMessage(),
|
||||||
|
'trace' => $e->getTraceAsString()
|
||||||
|
]);
|
||||||
|
|
||||||
|
throw $e;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Handle a job failure.
|
||||||
|
*
|
||||||
|
* @param \Throwable $exception
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
public function failed(\Throwable $exception): void
|
||||||
|
{
|
||||||
|
Log::error('CleanupInspeksiDataJob: Job gagal dieksekusi', [
|
||||||
|
'permohonan_id' => $this->permohonanId,
|
||||||
|
'created_by' => $this->createdBy,
|
||||||
|
'error' => $exception->getMessage(),
|
||||||
|
'trace' => $exception->getTraceAsString()
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -32,25 +32,46 @@
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Register commands in the format of Command::class
|
* Register commands in the format of Command::class
|
||||||
*/
|
*/
|
||||||
protected function registerCommands()
|
protected function registerCommands()
|
||||||
: void
|
: void
|
||||||
{
|
{
|
||||||
// $this->commands([]);
|
$this->commands([
|
||||||
}
|
\Modules\Lpj\Console\Commands\CleanupInspeksiDataCommand::class,
|
||||||
|
\Modules\Lpj\Console\Commands\CleanupSingleInspeksiCommand::class,
|
||||||
|
\Modules\Lpj\Console\Commands\CleanupInspeksiStatusCommand::class,
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Register command Schedules.
|
* Register command Schedules.
|
||||||
*/
|
*/
|
||||||
protected function registerCommandSchedules()
|
protected function registerCommandSchedules()
|
||||||
: void
|
: void
|
||||||
{
|
{
|
||||||
// $this->app->booted(function () {
|
$this->app->booted(function () {
|
||||||
// $schedule = $this->app->make(Schedule::class);
|
$schedule = $this->app->make(\Illuminate\Console\Scheduling\Schedule::class);
|
||||||
// $schedule->command('inspire')->hourly();
|
|
||||||
// });
|
// Jalankan cleanup inspeksi setiap hari jam 2 pagi
|
||||||
}
|
$schedule->command('lpj:cleanup-inspeksi --force')
|
||||||
|
->dailyAt('02:00')
|
||||||
|
->withoutOverlapping()
|
||||||
|
->onOneServer()
|
||||||
|
->runInBackground()
|
||||||
|
->appendOutputTo(storage_path('logs/cleanup-inspeksi.log'));
|
||||||
|
|
||||||
|
// Backup cleanup setiap minggu
|
||||||
|
$schedule->command('lpj:cleanup-inspeksi --force')
|
||||||
|
->weekly()
|
||||||
|
->sundays()
|
||||||
|
->at('03:00')
|
||||||
|
->withoutOverlapping()
|
||||||
|
->onOneServer()
|
||||||
|
->runInBackground()
|
||||||
|
->appendOutputTo(storage_path('logs/cleanup-inspeksi-weekly.log'));
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Register translations.
|
* Register translations.
|
||||||
|
|||||||
83
app/Services/InspeksiCleanupService.php
Normal file
83
app/Services/InspeksiCleanupService.php
Normal file
@@ -0,0 +1,83 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Modules\Lpj\Services;
|
||||||
|
|
||||||
|
use Illuminate\Support\Facades\Log;
|
||||||
|
use Modules\Lpj\Jobs\CleanupInspeksiDataJob;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Service untuk membersihkan data inspeksi yang tidak memiliki dokument_id
|
||||||
|
*
|
||||||
|
* Class ini menyediakan method untuk menjalankan cleanup data inspeksi
|
||||||
|
* ketika ada data baru dengan dokument_id yang sama
|
||||||
|
*/
|
||||||
|
class InspeksiCleanupService
|
||||||
|
{
|
||||||
|
/**
|
||||||
|
* Dispatch job untuk cleanup data inspeksi
|
||||||
|
*
|
||||||
|
* @param int $permohonanId
|
||||||
|
* @param int $createdBy
|
||||||
|
* @param int|null $dokumentId
|
||||||
|
* @param bool $sync
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
public function cleanupInspeksiData(int $permohonanId, int $createdBy, ?int $dokumentId = null, bool $sync = false): void
|
||||||
|
{
|
||||||
|
Log::info('InspeksiCleanupService: Memulai cleanup data inspeksi', [
|
||||||
|
'permohonan_id' => $permohonanId,
|
||||||
|
'created_by' => $createdBy,
|
||||||
|
'dokument_id' => $dokumentId,
|
||||||
|
'sync' => $sync
|
||||||
|
]);
|
||||||
|
|
||||||
|
try {
|
||||||
|
$job = new CleanupInspeksiDataJob($permohonanId, $createdBy, $dokumentId);
|
||||||
|
|
||||||
|
if ($sync) {
|
||||||
|
// Jalankan secara synchronous (langsung)
|
||||||
|
$job->handle();
|
||||||
|
Log::info('InspeksiCleanupService: Cleanup selesai dijalankan secara sync');
|
||||||
|
} else {
|
||||||
|
// Dispatch ke queue
|
||||||
|
dispatch($job);
|
||||||
|
Log::info('InspeksiCleanupService: Cleanup job berhasil di-dispatch ke queue');
|
||||||
|
}
|
||||||
|
} catch (\Exception $e) {
|
||||||
|
Log::error('InspeksiCleanupService: Gagal menjalankan cleanup', [
|
||||||
|
'permohonan_id' => $permohonanId,
|
||||||
|
'created_by' => $createdBy,
|
||||||
|
'error' => $e->getMessage(),
|
||||||
|
'trace' => $e->getTraceAsString()
|
||||||
|
]);
|
||||||
|
|
||||||
|
throw $e;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Dispatch job untuk cleanup data inspeksi secara async (default)
|
||||||
|
*
|
||||||
|
* @param int $permohonanId
|
||||||
|
* @param int $createdBy
|
||||||
|
* @param int|null $dokumentId
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
public function cleanupAsync(int $permohonanId, int $createdBy, ?int $dokumentId = null): void
|
||||||
|
{
|
||||||
|
$this->cleanupInspeksiData($permohonanId, $createdBy, $dokumentId, false);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Jalankan cleanup data inspeksi secara sync
|
||||||
|
*
|
||||||
|
* @param int $permohonanId
|
||||||
|
* @param int $createdBy
|
||||||
|
* @param int|null $dokumentId
|
||||||
|
* @return void
|
||||||
|
*/
|
||||||
|
public function cleanupSync(int $permohonanId, int $createdBy, ?int $dokumentId = null): void
|
||||||
|
{
|
||||||
|
$this->cleanupInspeksiData($permohonanId, $createdBy, $dokumentId, true);
|
||||||
|
}
|
||||||
|
}
|
||||||
272
tests/Jobs/CleanupInspeksiDataJobTest.php
Normal file
272
tests/Jobs/CleanupInspeksiDataJobTest.php
Normal file
@@ -0,0 +1,272 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace Modules\Lpj\Tests\Jobs;
|
||||||
|
|
||||||
|
use Illuminate\Foundation\Testing\RefreshDatabase;
|
||||||
|
use Illuminate\Support\Facades\Log;
|
||||||
|
use Modules\Lpj\Jobs\CleanupInspeksiDataJob;
|
||||||
|
use Modules\Lpj\Models\Inspeksi;
|
||||||
|
use Modules\Lpj\Models\Permohonan;
|
||||||
|
use Modules\Lpj\Models\DokumenJaminan;
|
||||||
|
use Tests\TestCase;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Unit test untuk CleanupInspeksiDataJob
|
||||||
|
*/
|
||||||
|
class CleanupInspeksiDataJobTest extends TestCase
|
||||||
|
{
|
||||||
|
use RefreshDatabase;
|
||||||
|
|
||||||
|
protected $permohonan;
|
||||||
|
protected $dokumenJaminan;
|
||||||
|
protected $userId = 1;
|
||||||
|
|
||||||
|
protected function setUp(): void
|
||||||
|
{
|
||||||
|
parent::setUp();
|
||||||
|
|
||||||
|
// Setup data test
|
||||||
|
$this->permohonan = Permohonan::factory()->create();
|
||||||
|
$this->dokumenJaminan = DokumenJaminan::factory()->create([
|
||||||
|
'permohonan_id' => $this->permohonan->id
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Test cleanup berhasil menghapus data lama tanpa dokument_id
|
||||||
|
*/
|
||||||
|
public function test_cleanup_successfully_deletes_old_data_without_dokument_id()
|
||||||
|
{
|
||||||
|
// Buat data lama tanpa dokument_id
|
||||||
|
$oldInspeksi1 = Inspeksi::factory()->create([
|
||||||
|
'permohonan_id' => $this->permohonan->id,
|
||||||
|
'dokument_id' => null,
|
||||||
|
'created_by' => $this->userId,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
|
||||||
|
$oldInspeksi2 = Inspeksi::factory()->create([
|
||||||
|
'permohonan_id' => $this->permohonan->id,
|
||||||
|
'dokument_id' => null,
|
||||||
|
'created_by' => $this->userId,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Buat data baru dengan dokument_id
|
||||||
|
$newInspeksi = Inspeksi::factory()->create([
|
||||||
|
'permohonan_id' => $this->permohonan->id,
|
||||||
|
'dokument_id' => $this->dokumenJaminan->id,
|
||||||
|
'created_by' => $this->userId,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Pastikan data awal ada
|
||||||
|
$this->assertDatabaseHas('inspeksi', [
|
||||||
|
'id' => $oldInspeksi1->id,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
$this->assertDatabaseHas('inspeksi', [
|
||||||
|
'id' => $oldInspeksi2->id,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
$this->assertDatabaseHas('inspeksi', [
|
||||||
|
'id' => $newInspeksi->id,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Jalankan job
|
||||||
|
$job = new CleanupInspeksiDataJob(
|
||||||
|
$this->permohonan->id,
|
||||||
|
$this->userId,
|
||||||
|
$this->dokumenJaminan->id
|
||||||
|
);
|
||||||
|
$job->handle();
|
||||||
|
|
||||||
|
// Cek hasil: data lama harus soft deleted
|
||||||
|
$this->assertSoftDeleted('inspeksi', [
|
||||||
|
'id' => $oldInspeksi1->id
|
||||||
|
]);
|
||||||
|
$this->assertSoftDeleted('inspeksi', [
|
||||||
|
'id' => $oldInspeksi2->id
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Data baru tetap ada
|
||||||
|
$this->assertDatabaseHas('inspeksi', [
|
||||||
|
'id' => $newInspeksi->id,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Test cleanup tidak menghapus data jika tidak ada data baru dengan dokument_id
|
||||||
|
*/
|
||||||
|
public function test_cleanup_does_not_delete_if_no_new_data_with_dokument_id()
|
||||||
|
{
|
||||||
|
// Buat data lama tanpa dokument_id
|
||||||
|
$oldInspeksi = Inspeksi::factory()->create([
|
||||||
|
'permohonan_id' => $this->permohonan->id,
|
||||||
|
'dokument_id' => null,
|
||||||
|
'created_by' => $this->userId,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Jangan buat data baru dengan dokument_id
|
||||||
|
|
||||||
|
// Jalankan job
|
||||||
|
$job = new CleanupInspeksiDataJob(
|
||||||
|
$this->permohonan->id,
|
||||||
|
$this->userId,
|
||||||
|
null
|
||||||
|
);
|
||||||
|
$job->handle();
|
||||||
|
|
||||||
|
// Data lama tetap ada (tidak dihapus)
|
||||||
|
$this->assertDatabaseHas('inspeksi', [
|
||||||
|
'id' => $oldInspeksi->id,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Test cleanup tidak menghapus data dengan created_by berbeda
|
||||||
|
*/
|
||||||
|
public function test_cleanup_does_not_delete_data_with_different_created_by()
|
||||||
|
{
|
||||||
|
$otherUserId = 2;
|
||||||
|
|
||||||
|
// Buat data lama dengan created_by berbeda
|
||||||
|
$oldInspeksi = Inspeksi::factory()->create([
|
||||||
|
'permohonan_id' => $this->permohonan->id,
|
||||||
|
'dokument_id' => null,
|
||||||
|
'created_by' => $otherUserId, // User berbeda
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Buat data baru dengan created_by yang sama dengan job
|
||||||
|
$newInspeksi = Inspeksi::factory()->create([
|
||||||
|
'permohonan_id' => $this->permohonan->id,
|
||||||
|
'dokument_id' => $this->dokumenJaminan->id,
|
||||||
|
'created_by' => $this->userId, // User sama dengan job
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Jalankan job
|
||||||
|
$job = new CleanupInspeksiDataJob(
|
||||||
|
$this->permohonan->id,
|
||||||
|
$this->userId,
|
||||||
|
$this->dokumenJaminan->id
|
||||||
|
);
|
||||||
|
$job->handle();
|
||||||
|
|
||||||
|
// Data lama dengan created_by berbeda tetap ada
|
||||||
|
$this->assertDatabaseHas('inspeksi', [
|
||||||
|
'id' => $oldInspeksi->id,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Data baru tetap ada
|
||||||
|
$this->assertDatabaseHas('inspeksi', [
|
||||||
|
'id' => $newInspeksi->id,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Test cleanup tidak menghapus data yang sudah di-soft delete
|
||||||
|
*/
|
||||||
|
public function test_cleanup_does_not_delete_already_soft_deleted_data()
|
||||||
|
{
|
||||||
|
// Buat data lama yang sudah di-soft delete
|
||||||
|
$oldInspeksi = Inspeksi::factory()->create([
|
||||||
|
'permohonan_id' => $this->permohonan->id,
|
||||||
|
'dokument_id' => null,
|
||||||
|
'created_by' => $this->userId,
|
||||||
|
'deleted_at' => now() // Sudah di-soft delete
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Buat data baru dengan dokument_id
|
||||||
|
$newInspeksi = Inspeksi::factory()->create([
|
||||||
|
'permohonan_id' => $this->permohonan->id,
|
||||||
|
'dokument_id' => $this->dokumenJaminan->id,
|
||||||
|
'created_by' => $this->userId,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Jalankan job
|
||||||
|
$job = new CleanupInspeksiDataJob(
|
||||||
|
$this->permohonan->id,
|
||||||
|
$this->userId,
|
||||||
|
$this->dokumenJaminan->id
|
||||||
|
);
|
||||||
|
$job->handle();
|
||||||
|
|
||||||
|
// Data lama tetap soft deleted (tidak berubah)
|
||||||
|
$this->assertSoftDeleted('inspeksi', [
|
||||||
|
'id' => $oldInspeksi->id
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Data baru tetap ada
|
||||||
|
$this->assertDatabaseHas('inspeksi', [
|
||||||
|
'id' => $newInspeksi->id,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Test job handle exception properly
|
||||||
|
*/
|
||||||
|
public function test_job_handles_exception_and_rolls_back()
|
||||||
|
{
|
||||||
|
// Buat data lama tanpa dokument_id
|
||||||
|
$oldInspeksi = Inspeksi::factory()->create([
|
||||||
|
'permohonan_id' => $this->permohonan->id,
|
||||||
|
'dokument_id' => null,
|
||||||
|
'created_by' => $this->userId,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Buat data baru dengan dokument_id
|
||||||
|
$newInspeksi = Inspeksi::factory()->create([
|
||||||
|
'permohonan_id' => $this->permohonan->id,
|
||||||
|
'dokument_id' => $this->dokumenJaminan->id,
|
||||||
|
'created_by' => $this->userId,
|
||||||
|
'deleted_at' => null
|
||||||
|
]);
|
||||||
|
|
||||||
|
// Jalankan job dengan data yang valid
|
||||||
|
$job = new CleanupInspeksiDataJob(
|
||||||
|
$this->permohonan->id,
|
||||||
|
$this->userId,
|
||||||
|
$this->dokumenJaminan->id
|
||||||
|
);
|
||||||
|
|
||||||
|
// Job seharusnya berhasil dijalankan tanpa exception
|
||||||
|
$job->handle();
|
||||||
|
|
||||||
|
// Cek hasil: data lama harus soft deleted
|
||||||
|
$this->assertSoftDeleted('inspeksi', [
|
||||||
|
'id' => $oldInspeksi->id
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Test failed method logs error properly
|
||||||
|
*/
|
||||||
|
public function test_failed_method_logs_error()
|
||||||
|
{
|
||||||
|
// Test bahwa method failed dapat dijalankan tanpa error
|
||||||
|
$job = new CleanupInspeksiDataJob(
|
||||||
|
$this->permohonan->id,
|
||||||
|
$this->userId,
|
||||||
|
$this->dokumenJaminan->id
|
||||||
|
);
|
||||||
|
|
||||||
|
$exception = new \Exception('Test failure');
|
||||||
|
|
||||||
|
// Method failed seharusnya dapat dijalankan
|
||||||
|
$job->failed($exception);
|
||||||
|
|
||||||
|
// Jika tidak ada exception yang di-throw, test dianggap berhasil
|
||||||
|
$this->assertTrue(true);
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user