<?php

namespace App\Classes\Modules\Accounting\Processors;

use App\Classes\ValueObjects\Constants\ApprovalStatus;
use App\Classes\ValueObjects\Constants\PaymentMethodType;
use App\Classes\ValueObjects\Constants\StatementTransactionOwnerType;
use App\Classes\ValueObjects\Constants\TransactionType;
use App\Models\Booking;
use App\Models\Company;
use App\Models\Group;
use App\Models\StatementTransaction;
use App\Models\Transaction;
use App\Models\Wallet;
use Carbon\Carbon;
use Illuminate\Support\Facades\Log;

class CreateBankStatementTransactionOwnersProcessor
{

    /**
     * @return void
     */
   public function execute() {

       $transactions = StatementTransaction::whereDoesntHave('owners', function($query){
           return $query->whereIn('status', [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED]);
       })->orderBy('posting_date')->get();

//       $transactions = StatementTransaction::whereDoesntHave('owners')->where('amount', '<', 0)->get();

        foreach ($transactions as $transaction) {

            if($transaction->amount > 0){

                // Exchange Sales
                $creditTransactions = $this->getTransactions($transaction->posting_date, $transaction->amount, TransactionType::PAYMENT, Booking::class, PaymentMethodType::WALLET, [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED]);
                foreach ($creditTransactions as $creditTransaction) {
                    $transaction->owners()->firstOrCreate([
                            'type' => StatementTransactionOwnerType::SALES,
                            'system' => 'EXCHANGE',
                            'owner_type' => Transaction::class,
                            'owner_id'=> $creditTransaction->id,
                            'owner_reference'=> $creditTransaction->owner->marking,
                    ]);
                }


                // Shipping Portal Sales
                $creditTransactions = $this->getTransactionsFromShippingPortal($transaction->amount, $this->getDateRange($transaction->posting_date), 2);
                foreach ($creditTransactions as $creditTransaction) {
                    if($creditTransaction['owner_type'] === Wallet::class) continue;
                    $transaction->owners()->firstOrCreate([
                        'type' => StatementTransactionOwnerType::SALES,
                        'system' => 'SHIPPING_PORTAL',
                        'owner_type' => $creditTransaction['owner_type'],
                        'owner_id'=> $creditTransaction['owner_id'],
                        'owner_reference'=> $creditTransaction['owner_reference'],
                    ]);
                }

                // Exchange Wallet Top Up
                $creditTransactions = $this->getTransactions($transaction->posting_date, $transaction->amount, TransactionType::TOP_UP, Wallet::class, null, [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED]);
                foreach ($creditTransactions as $creditTransaction) {
                    $transaction->owners()->firstOrCreate([
                            'type' => StatementTransactionOwnerType::WALLET_TOP_UP,
                            'system' => 'EXCHANGE',
                            'owner_type' => Transaction::class,
                            'owner_id'=> $creditTransaction->id,
                            'owner_reference'=> $creditTransaction->owner->owner->reference,
                    ]);
                }

                $creditTransactions = $this->getTransactionsFromShippingPortal($transaction->amount, $this->getDateRange($transaction->posting_date), 5);
                foreach ($creditTransactions as $creditTransaction) {
                    $transaction->owners()->firstOrCreate([
                        'type' => StatementTransactionOwnerType::WALLET_TOP_UP,
                        'system' => 'SHIPPING_PORTAL',
                        'owner_type' => $creditTransaction['owner_type'],
                        'owner_id'=> $creditTransaction['owner_id'],
                        'owner_reference'=> $creditTransaction['owner_reference'],
                    ]);
                }

                // fpx charge refund
                if($transaction->transaction_description === 'DUITNOW S/CHRG REFUND'){
                    $transaction->owners()->firstOrCreate([
                        'type' => StatementTransactionOwnerType::FPX_CHARGE_REFUND
                    ]);
                }

                // Customer Refund

                // INTERNAL_BANK_TRANSFER_IN
                if(str_contains($transaction->transaction_description_2, 'CIEF WORLDWIDE')){
                    $transaction->owners()->firstOrCreate([
                        'type' => StatementTransactionOwnerType::INTERNAL_BANK_TRANSFER_IN
                    ]);
                }


            }

            if($transaction->amount < 0){

                // Supplier Purchase Order Payments
                foreach (['YSN', 'HCK', 'ATVANTIC', 'HIGH HILL'] as $reference){
                    if(str_contains($transaction->transaction_description.' '.$transaction->transaction_description_2.' '.$transaction->transaction_description_3.' '.$transaction->transaction_description_4.' '.$transaction->transaction_description_5 , $reference)) {
                        $paymentDateStart = $transaction->posting_date->startOfDay()->subDays(1);
                        $paymentDateEnd = $transaction->posting_date->endOfDay();

                        if($paymentDateStart->dayOfWeek === Carbon::SUNDAY){
                            $paymentDateStart->subDays(2);
                        }
                        $issuer = Company::where('name', 'like', '%'.$reference.'%')->get()->pluck('id');

                        $debitTransactions = Group::whereIn('issuer', $issuer)->where('amount', '>=', (($transaction->amount * -1) - 0.01))
                            ->where('amount', '<=', (($transaction->amount * -1) + 0.01))->whereDate('created_at', '>=', $paymentDateStart)->whereDate('created_at', '<=', $paymentDateEnd)->get();

                        foreach ($debitTransactions as $debitTransaction) {
                            $transaction->owners()->firstOrCreate([
                                'type' => StatementTransactionOwnerType::SUPPLIER_PAYMENT,
                                'system' => 'EXCHANGE',
                                'owner_type' => Group::class,
                                'owner_id'=> $debitTransaction->id,
                                'owner_reference'=> $debitTransaction->reference
                            ]);
                        }

                    }
                }

                // Exchange Wallet Withdrawal
                $debitTransactions = $this->getTransactions($transaction->posting_date, $transaction->amount, TransactionType::DEBIT_NOTE, Wallet::class, null, [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED]);
                foreach ($debitTransactions as $debitTransaction) {
                    $transaction->owners()->firstOrCreate([
                        'type' => StatementTransactionOwnerType::WALLET_WITHDRAWAL,
                        'system' => 'EXCHANGE',
                        'owner_type' => Transaction::class,
                        'owner_id'=> $debitTransaction->id,
                        'owner_reference'=> $debitTransaction->owner->owner->marking,
                    ]);
                }

                // SALARY

                // STATUTORY
                if(str_contains($transaction->transaction_description_2, 'PEMBANGUNAN SUMBER') || str_contains($transaction->transaction_description_2, 'HASIL') || str_contains($transaction->transaction_description_2, 'PERTUBUHAN KESELAMAT') || str_contains($transaction->transaction_description_2, 'KUMPULAN WANG SIMPAN')){
                    $transaction->owners()->firstOrCreate([
                        'type' => StatementTransactionOwnerType::STATUTORY
                    ]);
                }

                // FPX_CHARGE
                if($transaction->transaction_description === 'DR DUITNOW S/CHRG' || str_contains($transaction->transaction_description, 'Manual FPX') || str_contains($transaction->transaction_description, 'CMS - DR FPX CHG')){
                    $transaction->owners()->firstOrCreate([
                        'type' => StatementTransactionOwnerType::FPX_CHARGE
                    ]);
                }

                // BANK_CHARGE
                if($transaction->transaction_description === 'CMS - DR CORP CHG' || $transaction->transaction_description === 'MONTHLY PROFIT DEBIT'){
                    $transaction->owners()->firstOrCreate([
                        'type' => StatementTransactionOwnerType::BANK_CHARGE
                    ]);
                }

                // CREDIT_CARD_PAYMENT
                if(str_contains($transaction->transaction_description_2, 'VISA CARD')){
                    $transaction->owners()->firstOrCreate([
                        'type' => StatementTransactionOwnerType::CREDIT_CARD_PAYMENT
                    ]);
                }

                // INTERNAL_BANK_TRANSFER_OUT
                if(str_contains($transaction->transaction_description_2, 'CIEF WORLDWIDE') || str_contains($transaction->transaction_description_2, 'CIEF WORLWIDE') || str_contains($transaction->transaction_description_2, 'IZYIM GLOBAL')){
                    $transaction->owners()->firstOrCreate([
                        'type' => StatementTransactionOwnerType::INTERNAL_BANK_TRANSFER_OUT
                    ]);
                }

                // non-operational charges
                if(str_contains($transaction->transaction_description_2, 'HIRE PURCHASE') || str_contains($transaction->transaction_description_2, 'TENAGA NASIONAL') || str_contains($transaction->transaction_description, 'CABLE CHARGE') || str_contains($transaction->transaction_description_2, 'CTOS DATA SYSTEMS') || str_contains($transaction->transaction_description_2, 'MAXIS')){
                    $transaction->owners()->firstOrCreate([
                        'type' => StatementTransactionOwnerType::NON_OPERATIONAL
                    ]);
                }
            }
        }
   }

   private function getTransactions($date, $amount, $type, $ownerType, $paymentMethod, $statuses, $model = Transaction::class) {
        $query = $model::whereIn('status', $statuses)
            ->where(function ($query) use ($ownerType, $paymentMethod, $type) {
                if ($ownerType) {
                    $query->where('owner_type', $ownerType);
                }

                if ($paymentMethod) {
                    $query->where('payment_method', '!=', $paymentMethod);
                }

                if ($type) {
                    $query->where('type', $type);
                }
            })
            ->whereDate('created_at', $date->format('Y-m-d'))
            ->where('amount', '>', ($amount - 0.01))
            ->where('amount', '<', ($amount + 0.01));

        return $query->get();
    }

    private function getTransactionsFromShippingPortal($amount, $dateRange, $type){
       $url = 'https://izyim.cief-malaysia.com/public/api/v1/transactions/mappable/query';
        return $this->getFromShippingPortal($amount, $dateRange, $url, $type);
    }

    private function getGroupsFromShippingPortal($amount, $dateRange, $type){
        $url = 'https://izyim.cief-malaysia.com/public/api/v1/groups/query';
        return $this->getFromShippingPortal($amount, $dateRange, $url, $type);
    }

    private function getFromShippingPortal($amount, $dateRange, $url, $type){
        try{

            $client = new \GuzzleHttp\Client(['verify' => false]);
            $response = $client->request('GET', $url.'?api-key=510acd13d8d24375cf038ad626c282565451461a9c2399357e0b65365300787e&filters={"order_by":{"column":"id","DESC":true},"status_in":[2],"type":2,"created_after":"'.$dateRange['start_date'].'","created_before":"'.$dateRange['end_date'].'","amount_exceed":'.($amount - 0.01).',"amount_short":'.($amount + 0.01).',"type_in:"['.$type.']}');
            $body = $response->getBody();
            $data = json_decode($body, true);
            $payload = $data['payload'];
            $transactions2 = $payload['data'];
            return $transactions2;
        }catch(\Exception $exception){
            Log::error($exception);
            return [];
        }
    }

    private function getDateRange(string $dateStr) {
        // Create a DateTime object from the input string
        $date = strtotime($dateStr);

        // Get the first day of the month
        $today = date('Y-m-d', strtotime('-1 day', $date));

        // Get the first day of the next month
        $nextDay = date('Y-m-d', strtotime('+1 day', $date));

        return [
            'start_date' => $today,
            'end_date' => $nextDay,
        ];
    }
}