diff --git a/htdocs/app/Console/Commands/ProcessAstmMessages.php b/htdocs/app/Console/Commands/ProcessAstmMessages.php index b212ed56..2c44fc91 100644 --- a/htdocs/app/Console/Commands/ProcessAstmMessages.php +++ b/htdocs/app/Console/Commands/ProcessAstmMessages.php @@ -6,7 +6,6 @@ use Illuminate\Console\Command; use Illuminate\Support\Facades\DB; use App\Services\AstmMessageService; -use App\DataListiner; class ProcessAstmMessages extends Command { @@ -24,13 +23,7 @@ class ProcessAstmMessages extends Command public function handle() { // Ambil data dari DataListener - $dataListener = DataListiner::where('processed', '0')->get(); $dataLocal = DB::table('lis_phoenix')->whereNull('processed')->get(); - if ($dataListener) { - $jumlah = count($dataListener); - $pesan = $this->astmMessageService->processAstmMessages($dataListener); - $this->info($jumlah.' Message processed '.$pesan.' at '.date('Y-m-d H:i:s')); - } if ($dataLocal) { $jumlah = count($dataLocal); $pesan = $this->astmMessageService->processAstmMessagesLokal($dataLocal);