diff --git a/app/Console/ProcessDailyMigration.php b/app/Console/ProcessDailyMigration.php deleted file mode 100644 index a4a35e9..0000000 --- a/app/Console/ProcessDailyMigration.php +++ /dev/null @@ -1,67 +0,0 @@ -option('process_parameter'); - $period = $this->option('period'); - - // Log start of process - Log::info('Starting daily data migration process', [ - 'process_parameter' => $processParameter ?? 'false', - 'period' => $period ?? '-1 day' - ]); - - $this->info('Starting daily data migration process...'); - $this->info('Process Parameter: ' . ($processParameter ?? 'False')); - $this->info('Period: ' . ($period ?? '-1 day (default)')); - - try { - $controller = app(StagingController::class); - $response = $controller->index($processParameter, $period); - - $responseData = json_decode($response->getContent(), true); - $message = $responseData['message'] ?? 'Process completed'; - - $this->info($message); - Log::info('Daily migration process completed successfully', ['message' => $message]); - - return Command::SUCCESS; - } catch (Exception $e) { - $errorMessage = 'Error processing daily migration: ' . $e->getMessage(); - $this->error($errorMessage); - Log::error($errorMessage, ['exception' => $e->getTraceAsString()]); - - return Command::FAILURE; - } - } -} diff --git a/app/Console/ProcessDailyStaging.php b/app/Console/ProcessDailyStaging.php new file mode 100644 index 0000000..b5de63c --- /dev/null +++ b/app/Console/ProcessDailyStaging.php @@ -0,0 +1,85 @@ +option('process_parameter'); + $period = $this->option('period'); + $queueName = $this->option('queue_name'); + + // Log start of process + Log::info('Starting daily data staging process', [ + 'process_parameter' => $processParameter ?? 'false', + 'period' => $period ?? '-1 day', + 'queue_name' => $queueName ?? 'default' + ]); + + $this->info('Starting daily data staging process...'); + $this->info('Process Parameter: ' . ($processParameter ?? 'False')); + $this->info('Period: ' . ($period ?? '-1 day (default)')); + $this->info('Queue Name: ' . ($queueName ?? 'default')); + + try { + $controller = app(StagingController::class); + + // Pass queue name to controller if needed + // Jika controller membutuhkan queue name, bisa ditambahkan sebagai parameter + $response = $controller->index($processParameter, $period, $queueName); + + $responseData = json_decode($response->getContent(), true); + $message = $responseData['message'] ?? 'Process completed'; + + $this->info($message); + Log::info('Daily staging process completed successfully', [ + 'message' => $message, + 'queue_name' => $queueName ?? 'default' + ]); + + return Command::SUCCESS; + } catch (Exception $e) { + $errorMessage = 'Error processing daily staging: ' . $e->getMessage(); + $this->error($errorMessage); + Log::error($errorMessage, [ + 'exception' => $e->getTraceAsString(), + 'queue_name' => $queueName ?? 'default' + ]); + + return Command::FAILURE; + } + } +} diff --git a/app/Providers/WebstatementServiceProvider.php b/app/Providers/WebstatementServiceProvider.php index 7c7a464..83b0bf1 100644 --- a/app/Providers/WebstatementServiceProvider.php +++ b/app/Providers/WebstatementServiceProvider.php @@ -11,7 +11,7 @@ use Modules\Webstatement\Console\{ CombinePdf, ConvertHtmlToPdf, ExportDailyStatements, - ProcessDailyMigration, + ProcessDailyStaging, ExportPeriodStatements, UpdateAllAtmCardsCommand, CheckEmailProgressCommand, @@ -68,7 +68,7 @@ class WebstatementServiceProvider extends ServiceProvider $this->commands([ GenerateBiayakartuCommand::class, GenerateBiayaKartuCsvCommand::class, - ProcessDailyMigration::class, + ProcessDailyStaging::class, ExportDailyStatements::class, CombinePdf::class, ConvertHtmlToPdf::class,