webstatement/app/Jobs/BiayaKartu.php

<?php

    namespace Modules\Webstatement\Jobs;

    use Exception;
    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\Http;
    use Illuminate\Support\Facades\Log;
    use Modules\Webstatement\Models\Atmcard;

    class BiayaKartu implements ShouldQueue
    {
        use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

        /**
         * API dan database constants
         */
        private const API_BASE_PATH      = '/restgateway/services/IGATEToCoreBankingServices';
        private const API_INQUIRY_PATH   = '/InquiryBalanceService';
        private const DB_TABLE           = 'IST77.VW_CMS_VCARD';
        private const BATCH_SIZE         = 100;
        private const MAX_EXECUTION_TIME = 86400; // 24 jam dalam detik

        /**
         * Execute the job.
         */
        public function handle()
        : void
        {
            set_time_limit(self::MAX_EXECUTION_TIME);
            $this->syncAtmCards();
        }

        /**
         * Synchronize ATM cards data from Oracle database
         *
         * @return void
         */
        private function syncAtmCards()
        : void
        {
            try {
                $offset         = 0;
                $hasMoreRecords = true;

                while ($hasMoreRecords) {
                    $cards = $this->fetchCardBatch($offset);
                    $this->processCardBatch($cards);

                    $hasMoreRecords = count($cards) === self::BATCH_SIZE;
                    $offset         += self::BATCH_SIZE;
                }

                Log::info('Sinkronisasi kartu ATM berhasil diselesaikan');
            } catch (Exception $e) {
                Log::error('BiayaKartu: syncAtmCards: ' . $e->getMessage(), [
                    'file' => $e->getFile(),
                    'line' => $e->getLine()
                ]);
            }
        }

        /**
         * Fetch a batch of ATM cards from the database
         *
         * @param int $offset
         *
         * @return \Illuminate\Support\Collection
         */
        private function fetchCardBatch(int $offset)
        {
            return DB::connection('oracle')
                     ->table(self::DB_TABLE)
                     ->where('crsts', 1)
                     ->whereNotNull('ACCFLAG')
                     ->where('ACCFLAG', '>', 0)
                     ->skip($offset)
                     ->take(self::BATCH_SIZE)
                     ->get();
        }

        /**
         * Process a batch of ATM cards
         *
         * @param \Illuminate\Support\Collection $cards
         *
         * @return void
         */
        private function processCardBatch($cards)
        : void
        {
            foreach ($cards as $card) {
                try {
                    $accountInfo = $this->getAccountInfo($card->accflag);
                    $this->updateOrCreateAtmCard($card, $accountInfo);
                } catch (Exception $e) {
                    Log::warning("Gagal memproses kartu {$card->crdno}: " . $e->getMessage());
                }
            }
        }

        /**
         * Get account information from the API
         *
         * @param string $accountNumber
         *
         * @return array
         */
        private function getAccountInfo(string $accountNumber)
        : array
        {
            $url  = env('FIORANO_URL') . self::API_BASE_PATH;
            $path = self::API_INQUIRY_PATH;
            $data = [
                'accountNo' => $accountNumber
            ];

            $response = Http::post($url . $path, $data);

            return $response->json();
        }

        /**
         * Update or create ATM card record
         *
         * @param object $card
         * @param array  $accountInfo
         *
         * @return void
         */
        private function updateOrCreateAtmCard(object $card, array $accountInfo)
        : void
        {
            Atmcard::updateOrCreate(
                ['crdno' => $card->crdno],
                [
                    'accflag'     => $card->accflag,
                    'cracc1'      => $card->cracc1,
                    'cracc2'      => $card->cracc2,
                    'cracc3'      => $card->cracc3,
                    'cracc4'      => $card->cracc4,
                    'cracc5'      => $card->cracc5,
                    'craccnam1'   => $card->craccnam1,
                    'craccnam2'   => $card->craccnam2,
                    'craccnam3'   => $card->craccnam3,
                    'craccnam4'   => $card->craccnam4,
                    'craccnam5'   => $card->craccnam5,
                    'crsts'       => $card->crsts,
                    'cttype'      => $card->cttype,
                    'ctdesc'      => $card->ctdesc,
                    'last_update' => $card->lastupdate,
                    'crdate'      => $card->crdate,
                    'branch'      => $accountInfo['acctCompany'],
                    'currency'    => $accountInfo['acctCurrency'],
                ]
            );
        }
    }