<?php

namespace App\Http\Controllers\Accounting;

use App\Classes\Jobs\CreateBankStatementDetails;
use App\Classes\Modules\Accounting\ControllersLogic\ListBankStatementDetailsLogic;
use App\Classes\Modules\Accounting\ControllersLogic\UpdateBankStatementDetailLogic;
use App\Classes\Modules\Imports\Services\BankStatementImport;
use App\Classes\Modules\Imports\Services\ImportsBankRecord;
use App\Classes\ValueObjects\Constants\ApprovalStatus;
use App\Classes\ValueObjects\Constants\PaymentMethodType;
use App\Classes\ValueObjects\Constants\TransactionType;
use App\Models\StatementAccount;
use App\Models\AccountStatement;
use App\Models\StatementTransaction;
use App\Models\Booking;
use App\Models\Company;
use App\Models\Group;
use App\Models\StatementTransactionsDetail;
use App\Models\Transaction;
use App\Models\Wallet;
use App\Http\Controllers\Controller;
use Maatwebsite\Excel\Facades\Excel;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Carbon;
use Illuminate\Support\Facades\Log;
use DateTime;


use PhpOffice\PhpSpreadsheet\Shared\Date;

class BankStatementController extends Controller
{
    public function index(Request $request)
    {
        $selectedAccount = $request->input('account');
        $search = $request->input('search');

        $accounts = StatementAccount::all();

        $statementsQuery = AccountStatement::query();

        if ($selectedAccount) {
            $statementsQuery->where('statement_account_id', $selectedAccount);
        }

        if ($search) {
            $statementsQuery->where(function ($query) use ($search) {
                $query->where('date_from', 'LIKE', "%$search%")
                    ->orWhere('date_to', 'LIKE', "%$search%")
                    ->orWhere('total_amount', 'LIKE', "%$search%")
                    ->orWhere('begin_balance', 'LIKE', "%$search%")
                    ->orWhere('end_balance', 'LIKE', "%$search%");
            });
        }

        $statements = $statementsQuery->paginate(10);

        return view('pages.accounting.bank-statements.index', compact('accounts', 'selectedAccount', 'search', 'statements'));
    }

    public function import(Request $request)
    {

        $request->validate([
            'file' => 'required|mimes:csv,txt'
        ]);

        $file = $request->file('file');

        $collection = Excel::toCollection(null, $file, null, null, true);

        $sheet = $collection->first()->skip(1);

        $statementDetails = $sheet->first();

        $accountNumber = $statementDetails[0];
        $accountType = $statementDetails[1];
        $accountName = $statementDetails[2];
        $accountCurrency = $statementDetails[3];
        $dateFrom = carbon::parse(str_replace(' MY (UTC+08:00)', '', $statementDetails[4]));
        $dateTo = carbon::parse(str_replace(' MY (UTC+08:00)', '', $statementDetails[5]));
        $totalDebit = $statementDetails[6];
        $totalCredit = $statementDetails[7];
        $beginBalance = $statementDetails[8];
        $endBalance = $statementDetails[9];
        $account = StatementAccount::updateOrCreate(
            ['number' => $accountNumber],
            [
                'type' => $accountType,
                'name' => $accountName,
                'currency' => $accountCurrency,
            ]
        );

        $statement = AccountStatement::where('date_from', $dateFrom)
                    ->where('date_to', $dateTo)
                    ->where('total_amount', $totalDebit ?: $totalCredit,)
                    ->where('begin_balance', $beginBalance)
                    ->where('end_balance', $endBalance)->first();


        if(!$statement){
            $statement = new AccountStatement([
                'date_from' => $dateFrom,
                'date_to' => $dateTo,
                'total_amount' => $totalDebit ?: $totalCredit,
                'begin_balance' => $beginBalance,
                'end_balance' => $endBalance,
            ]);
        }

        // $existingStatement = AccountStatement::where('date_from', $dateFrom)
        //     ->where('date_to', $dateTo)
        //     ->where('statement_account_id', $account->id)
        //     ->first();

        // // if ($existingStatement) {
        // //     return redirect()->back()->with('error', 'This statement has already been imported.');
        // // }

        $account->statements()->save($statement);

        CreateBankStatementDetails::dispatch($statement)->delay(30);


        // $account = null;
        $newTransactions = $sheet->map(function ($row) use ($statement, $account) {
            $transactionRef = $row[15];
            $amount = $row[17] !== '-' ? ((float) str_replace(',', '', $row[17])) : (-((float) str_replace(',', '', $row[16])));
            $transactionDate = $row[10] !== '-' ? carbon::parse(str_replace(' MY (UTC+08:00)', '', $row[10]) . $row[11]) : null;
            $postingDate = carbon::createFromFormat('d/M/Y H:i', str_replace(' MY (UTC+08:00)', '', $row[12]) . str_replace(' MY (UTC+08:00)', '', $row[13]));
            $transactionDescription = is_numeric($row[14]) ? (int) sprintf('%.2f', $row[14]) : $row[14];
            $tellerId = $row[19];
            $branchChannel = $row[20];
            $transactionCode = $row[21];
            $endBalance = $row[22];
            $description2 = $row[25];
            $description3 = $row[26];
            $description4 = $row[27];
            $description5 = $row[28];
            $transaction = new StatementTransaction([
                'transaction_ref' => $transactionRef,
                'amount' => $amount,
                'transaction_date' => $transactionDate,
                'posting_date' => $postingDate,
                'transaction_description' => $transactionDescription,
                'teller_id' => $tellerId,
                'branch_channel' => $branchChannel,
                'transaction_code' => $transactionCode,
                'end_balance' => $endBalance,
                'transaction_description_2' => $description2,
                'transaction_description_3' => $description3,
                'transaction_description_4' => $description4,
                'transaction_description_5' => $description5,
            ]);

            // Check if the transaction already exists for this statement
            $existingTransaction = StatementTransaction::where('transaction_ref', $transactionRef)
                ->where('posting_date', $postingDate)
                ->where('amount', $amount)
                ->where('transaction_description', $transactionDescription)
                ->where('teller_id', $tellerId)
                ->where('branch_channel', $branchChannel)
                ->where('transaction_code', $transactionCode)
                ->where('end_balance', $endBalance)
                ->first();

            if (!$existingTransaction) {
                $statement->transactions()->save($transaction);
            }

            return $transaction;
        });


        // dd(json_encode($newTransactions));
        return redirect()->back()->with('success', 'Statement imported successfully.')->with('newTransactions', $newTransactions);
    }

    public function rerun(AccountStatement $statement, Request $request)
    {
        CreateBankStatementDetails::dispatch($statement)->delay(30);
        return redirect()->back()->with('success', 'Rerun triggered successfully');
    }

    public function show(AccountStatement $statement, Request $request)
    {
        $transactions = $statement->transactions();
        // $account = $statement->account();
        // dd(json_encode($account->where('id', '>=', 1)->first()));
        // dd(json_encode($transactions->where('id', '>=', 1)->first()));
        if ($request->get('transaction_filter')) {
            $transactionFilter = $request->get('transaction_filter');
            $transactions = $transactions->where('transaction_description', 'LIKE', "%$transactionFilter%");
        }

        if ($request->get('from_amount_filter')) {
            $fromAmountFilter = $request->get('from_amount_filter');
            $transactions = $transactions->where('amount', '>=', $fromAmountFilter);
        }

        if ($request->get('to_amount_filter')) {
            $toAmountFilter = $request->get('to_amount_filter');
            $transactions = $transactions->where('amount', '<=', $toAmountFilter);
        }

        // $transactions = $transactions->paginate(100);
        $transactions = $transactions->get();
        echo $this->process3_merged($transactions);

        //return view('pages.accounting.bank-statements.show', compact('statement', 'transactions'));
    }

    public function download(AccountStatement $statement)
    {
        $transactions = $statement->transactions;

        $csvExporter = new \Laracsv\Export();
        $csvExporter->build($transactions, ['transaction_date', 'transaction_time', 'posting_date', 'transaction_description', 'transaction_ref', 'debit', 'credit'])
            ->download($statement->date_from->format('Y-m-d') . '_' . $statement->date_to->format('Y-m-d') . '_statement.csv');
    }

    public function fetch(Request $request, ListBankStatementDetailsLogic $logic): JsonResponse
    {
        return $logic->execute($request);
    }

    public function update(Request $request, UpdateBankStatementDetailLogic $logic): JsonResponse
    {
        return $logic->execute($request);
    }

    private function process3_merged($transactions){

        // $statement = $transactions[0]->statement();
        // dd(json_encode($statement->first()));

        $headers = [
            'Date',
            'Bank',
            'Description',
            'Credit',
            'Debit',
            'Pay For',
            'System',
            'System Reference',
            'Human Reference',
            'Multiple',
            'Match?',
            'System Amount'
        ];

        $branches = [
            0 => 'MBB Cyber',
            1 => 'MBB SS2',
        ];

        $yes = 'Yes';
        $no = 'No';

        $table = '<table><tr><th>'.implode('</th><th>', $headers).'</th></tr>';
        $count = 0;

        foreach ($transactions as $row) {
            $isExist = StatementTransactionsDetail::where('statement_transaction_id', $row->id)->first();

            if ($isExist) {
                continue;
            }

            $count++;
            $credit = 0.00;
            $debit = 0.00;

            // dd(json_encode($row['posting_date']));
            $date = new DateTime($row['posting_date']);
            $description = $row['transaction_description_2'];

            if($row['amount'] < 0){
                $debit = (float) $row['amount'];
            }
            else{
                $credit = (float) $row['amount'];
            }

            $creditTransactions = [];
            $debitTransactions = [];

            $system = '';
            $systemReference = null;
            $systemAmount = null;

            if($credit){
                $creditTransactions = $this->getTransactions($date, $credit, TransactionType::PAYMENT, Booking::class, PaymentMethodType::WALLET, [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED]);
                foreach ($creditTransactions as $transaction) {
                    $systemReference[] = $transaction->owner instanceof Booking ? $transaction->owner->marking : $transaction->bill_no;
                    $systemAmount[] = $transaction->amount;
                    $system[] = 'EXCHANGE';
                }

                $creditTransactions = $this->getTransactions($date, $credit, TransactionType::TOP_UP, Wallet::class, null, [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED]);
                foreach ($creditTransactions as $transaction) {
                    $systemReference[] = $transaction->owner instanceof Booking ? $transaction->owner->marking : $transaction->bill_no;
                    $systemAmount[] = $transaction->amount;
                    $system[] = 'EXCHANGE';
                }

                $creditTransactions = $this->getTransactionsFromShippingPortal($credit, $this->getDateRange($row['posting_date']));
                foreach ($creditTransactions as $transaction) {
                    $systemReference[] = $transaction['order']['reference'];
                    $systemAmount[] = $transaction['amount'];
                    $system[] = 'SHIPPING';
                }
            }

            if($debit){
                $debitTransactions = $this->getTransactions($date, $debit, null, null, null, [ApprovalStatus::APPROVED, ApprovalStatus::COMPLETED], Group::class);

                if(!count($debitTransactions)) {
                    foreach (['YSN', 'HCK', 'ATVANTIC', 'HIGH HILL'] as $reference){
                        if(str_contains($description, $reference)) {
                            $paymentDate = date('Y-m-d', strtotime('+1 day', strtotime($row['posting_date']))); //$date->addDays(1)->format('Y-m-d');

                            if($reference = 'ATVANTIC'){
                                $paymentDate =  date('Y-m-d', strtotime($row['posting_date']));//$date->format('Y-m-d');
                            }
                            $issuer = Company::where('name', 'like', '%'.$reference.'%')->get()->pluck('id');
                            $debitTransactions = Group::whereIn('issuer', $issuer)->whereDate('created_at', $paymentDate)->get();
                            break;
                        }
                    }

                }

                foreach ($debitTransactions as $transaction) {
                    $systemReference[] = $transaction->reference;
                    $systemAmount[] = $transaction->amount;
                    $system[] = 'EXCHANGE';
                }
            }


            $multiple = count($creditTransactions) + count($debitTransactions) > 1 ? $yes : $no;


            $systemReference = $systemReference ? implode(',', $systemReference) : null;
            $systemAmount = $systemAmount ? implode(',', $systemAmount) : null;

            $matches = $systemReference == $row['remarkreferences'] ? $yes : $no;

            $table .= '<tr>
                <td>'.$date->format('d-m-Y').'</td>
                <td>branch</td>
                <td>'.$description.'</td>
                <td>'.$credit.'</td>
                <td>'.$debit.'</td>
                <td>'.$row['pay_for'].'</td>
                <td>'.$system.'</td>
                <td>'.$systemReference.'</td>
                <td>'.$row['remarkreferences'].'</td>
                <td>'.$multiple.'</td>
                <td>'.$matches.'</td>
                <td>'.$systemAmount.'</td>
            </tr>';

            //AccountStatement
            // $row->statement()->first()->id)

            $statementTransactionsDetail = new StatementTransactionsDetail([
                'date' => $date,
                'statement_transaction_id' =>  $row->id,
                'description' => is_null($description) ? "" : $description,
                'credit' => $credit,
                'debit' => $debit,
                'pay_for' => $system,
                'system_references' => is_null($systemReference) ? "" : $systemReference,
                'remark_references' => is_null($row['remarkreferences']) ? "" : $row['remarkreferences'],
                'is_multiple' => $multiple == "Yes" ? 1 : 0,
                'is_matches' => $matches == "Yes" ? 1 : 0,
                'system_amounts'=> is_null($systemAmount) ? "" : $systemAmount,
            ]);

            $statementTransactionsDetail->save();

            if($count == 10){
                break;
            }
        }

        $table .= '</table>';

        return $table;
    }

    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 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', $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,
        ];
    }

    private function getTransactionsFromShippingPortal($amount, $dateRange){

        $client = new \GuzzleHttp\Client();
        $response = $client->request('GET', 'https://izyim.cief-malaysia.com/public/api/v1/list?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).'}');
        $body = $response->getBody();
        $data = json_decode($body, true);
        $payload = $data['payload'];
        $transactions2 = $payload['data'];
        // $filters = [
        //     ['field' => 'created_at', 'value' => '2023-03-01 08:07:00'],
        // ];
        // $transactions2 = $this->getTransactions3($transactions2, $filters);
        return $transactions2;
    }

}