update
This commit is contained in:
@@ -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);
|
||||
|
||||
Reference in New Issue
Block a user