exchange-2.0/app/Classes/Jobs/Commands/V2/ProcessSalesInvoiceReportV2CommandJob.php

<?php

namespace App\Classes\Jobs\Commands\V2;

use App\Classes\Modules\Accounts\DataTransferObjects\KeyValuePairObject;
use App\Classes\Modules\Accounts\Services\CreatesKeyValuePair;
use App\Classes\Modules\Accounts\Services\UpdatesKeyValuePair;
use App\Classes\Modules\Bookings\Processors\RegenerateInvoiceBookingProcessor;
use App\Classes\ValueObjects\Constants\KVPKey;
use Carbon\Carbon;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use App\Models\Booking;
use Illuminate\Support\Facades\Log;


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

    /** @var object */
    private $details;

    /**
     * ProcessSalesInvoiceReportV2CommandJob constructor.
     * @param object $details
     */
    public function __construct(object $details)
    {
        $this->details = $details;
    }

    public function handle()
    {
        Log::info(Carbon::now() . ': Start job - Processing single record for E-Invoice from Sales Invoice Report Import.');
        $start   = new Carbon();

        $docNo = $this->details[0] ?? null;
        $docDate = $this->details[1] ?? null;
        $debtorCode = $this->details[2] ?? null;
        $ref = $this->details[3] ?? null;
        $shipInfo = $this->details[4] ?? null;
        $accNo = $this->details[5] ?? null;
        $detailDescription = $this->details[6] ?? null;
        $furtherDescription = $this->details[7] ?? null;
        $classification = $this->details[8] ?? null;
        $deptNo = $this->details[9] ?? null;
        $qty = $this->details[10] ?? null;
        $unitPrice = $this->details[11] ?? null;
        $submitEinvoice = $this->details[12] ?? null;
        $consolidatedEinvoice = $this->details[13] ?? null;
        $eInvoiceValidationLink = $this->details[14] ?? null; // Safe access for the new column

        Log::info("ProcessSalesInvoiceReportV2CommandJob Details:", [
            'DocNo' => $docNo,
            'DocDate' => $docDate,
            'DebtorCode' => $debtorCode,
            'Ref' => $ref,
            'ShipInfo' => $shipInfo,
            'AccNo' => $accNo,
            'DetailDescription' => $detailDescription,
            'FurtherDescription' => $furtherDescription,
            'Classification' => $classification,
            'DeptNo' => $deptNo,
            'Qty' => $qty,
            'UnitPrice' => $unitPrice,
            'SubmitEinvoice' => $submitEinvoice,
            'ConsolidatedEinvoice' => $consolidatedEinvoice,
            'EInvoiceValidationLink' => $eInvoiceValidationLink,
        ]);

        $booking = Booking::where('marking', $ref)->first();
        if($booking){
            if($docNo != "" && $docNo != "<<New>>"){
                $this->updateOrCreateKeyValuePair($booking, KVPKey::AUTOCOUNT_DOCNO_INVOICE, $docNo);
            }
            if($eInvoiceValidationLink){
                $this->updateOrCreateKeyValuePair($booking, KVPKey::AUTOCOUNT_EINVOICE_VALIDATION_LINK, $eInvoiceValidationLink);
            }
        }

        $end = new Carbon();
        $elapsedTime = $start->diff($end)->format('%H:%I:%S');
        Log::info(Carbon::now() . ': End job - Processing single record for E-Invoice from Sales Invoice Report Import. ElapsedTime: ' . $elapsedTime . '.');
    }


    private function updateOrCreateKeyValuePair($booking, $key, $value)
    {
        $keyValuePairObject = new KeyValuePairObject($key, $value);
        $metadata = $booking->attributesKVP()->where('key', $key)->first();

        if ($metadata) {
            (App()->make(UpdatesKeyValuePair::class))->execute($metadata, $keyValuePairObject);
        } else {
            (App()->make(CreatesKeyValuePair::class))->execute($booking, $keyValuePairObject);
        }
    }
}