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

<?php

namespace App\Classes\Jobs\Commands\V2;

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 Illuminate\Support\Facades\Log;
use App\Classes\ValueObjects\Constants\ApprovalStatus;
use App\Classes\ValueObjects\Constants\PaymentMethodType;
use App\Classes\ValueObjects\Constants\TransactionType;
use App\Models\Booking;
use App\Models\Company;
use App\Models\Transaction;
use App\Models\Wallet;
use Illuminate\Support\Facades\DB;
use Mccarlosen\LaravelMpdf\Facades\LaravelMpdf;
use App\Classes\General\AWSS3Helper;
use Illuminate\Support\Facades\Storage;

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


    public function handle()
    {
        Log::info(Carbon::now() . ': Start job - This is a test to run a long query that generates a pdf file to be uploaded to S3 bucket.');
        $start   = new Carbon();

        ////https://dev.exchange.izyim.com/company/2294/false/transaction/export
        $companyId = '2294'; //$request->route('id');
        $isPrecise = false; //$request->route('is_precise');
        $company = Company::find($companyId);

        $transactions = Transaction::where(function ($query) use ($companyId) {
            $query
                ->where('type', TransactionType::PAYMENT)
                ->where('owner_type', Booking::class)
                ->whereIn('status', [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED])
                ->where('payment_method', '!=', PaymentMethodType::WALLET)
                ->whereHas('booking', function ($q) use ($companyId) {
                    $q->where('company_id', $companyId);
                });
            })
            ->orWhere(function ($query) use ($companyId) {
                $query->whereHas('owner', function ($q) use ($companyId) {
                    $q->where('owner_id', $companyId);
                    $q->where('owner_type', Company::class);
                })
                ->where('owner_type', Wallet::class)
                ->whereIn('status', [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED]);
            })
            ->orWhere(function ($query) use ($companyId) {
                $query
                    ->where('type', TransactionType::INVOICE)
                    ->where('owner_type', Booking::class)
                    ->whereIn('status', [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED])
                    ->where('payment_method', '!=', PaymentMethodType::WALLET)
                    ->whereHas('booking', function ($q) use ($companyId) {
                        $q->where('company_id', $companyId);
                });
            })
            ->groupBy(
                DB::raw(
                    'if (transactions.type = 2,transactions.owner_id,transactions.id)'
                ),
                DB::raw(
                    'if (transactions.type = 2,transactions.type,transactions.id)'
                )
            )
            ->whereIn('status', [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED])
            ->orderBy('created_at', 'asc')
            ->get();

        $total_incoming = Transaction::where(function ($query) use ($companyId) {
            $query->whereHas('owner', function ($q) use ($companyId) {
                    $q->where('owner_id', $companyId);
                    $q->where('owner_type', Company::class);
                })
                ->where('owner_type', Wallet::class)
                ->whereIn('status', [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED])
                ->where('type', '!=', TransactionType::PAYMENT);
            })
            ->orWhere(function ($query) use ($companyId, $transactions) {
                $query
                    ->where('type', TransactionType::INVOICE)
                    ->where('owner_type', Booking::class)
                    ->whereIn('status', [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED])
                    ->where('payment_method', '!=', PaymentMethodType::WALLET)
                    ->whereHas('booking', function ($q) use ($companyId) {
                        $q->where('company_id', $companyId);
                    });
                })
            ->groupBy(
                DB::raw(
                    'if (transactions.type = 2,transactions.owner_id,transactions.id)'
                ),
                DB::raw(
                    'if (transactions.type = 2,transactions.type,transactions.id)'
                )
            )->get();

        $total_incoming = $total_incoming->sum(function ($transaction) {
            if ($transaction->type === TransactionType::INVOICE) {
                return $transaction->amount / $transaction->currency_rate + $transaction->service_charge;
            }

            return $transaction->amount;
        });

        $total_outgoing = Transaction::where(function ($query) use ($companyId) {
            $query
                ->where('type', TransactionType::PAYMENT)
                ->where('payment_method', '!=', PaymentMethodType::WALLET)
                ->where('owner_type', Booking::class)
                ->whereIn('status', [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED])
                ->whereHas('booking', function ($q) use ($companyId) {
                    $q->where('company_id', $companyId);
                });
            })
            ->orWhere(function ($query) use ($companyId) {
                $query->whereHas('owner', function ($q) use ($companyId) {
                        $q->where('owner_id', $companyId);
                        $q->where('owner_type', Company::class);
                    })
                    ->where('owner_type', Wallet::class)
                    ->whereIn('status', [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED])
                    ->where('type', TransactionType::PAYMENT);
                })
            ->sum('transactions.amount');

        $currentBalance = $total_incoming - $total_outgoing;

        $pdf = LaravelMpdf::loadView('pages.pdfs.company_account_statement_transaction', ['transactions' => $transactions, 'runningBalance' => $currentBalance, 'company' => $company, 'isPrecise' => $isPrecise == 'true']);

        $exportFileName = "{$company->reference}_account_statement_transactions.pdf";
        $filesystemDriver = Storage::getDefaultDriver();
        if($filesystemDriver === 's3'){
            $pdfContent = $pdf->output();
            $temporaryUrl = AWSS3Helper::S3PDF($exportFileName, $pdfContent);
            Log::info('Temporary S3 Url: ' .  $temporaryUrl );
        }


        $end = new Carbon();
        $elapsedTime = $start->diff($end)->format('%H:%I:%S');
        Log::info(Carbon::now() . ': End job - This is a test to run a long query that generates a pdf file to be uploaded to S3 bucket. ElapsedTime: ' . $elapsedTime . '.');
    }
}