<?php

namespace App\Services\WeldLogTriggers\Triggers;

use App\Services\WeldLogTriggers\Base\BaseTrigger;
use App\Models\TestPackage;
use App\Models\TestPackBaseStatus;
use App\Helpers\TransactionHelper;
use Illuminate\Support\Facades\Log;

/**
 * Test Pack Base Status Changer Trigger
 * 
 * Updates test package base statuses including:
 * - WDI (Weld Diameter Inch) calculations
 * - Welding progress
 * - Repair statistics
 * - Shop/Field weld tracking
 */
class TestPackBaseStatusChangerTrigger extends BaseTrigger
{
    public function getName(): string
    {
        return 'Test Pack Base Status Changer';
    }
    
    public function getOrder(): int
    {
        return 9;
    }
    
    public function getDependentFields(): array
    {
        return [
            'test_package_no',
            'iso_number',
            'line_number',
            'welding_date',
            'type_of_joint',
            'nps_1'
        ];
    }
    
    protected function process($data, $beforeData, array $context): array
    {
        $testPackageNo = $data->test_package_no;
        $lineNumber = $data->line_number;
        
        $testPackages = TestPackage::where("test_package_number", $testPackageNo)->get();
        $testPackagesIso = TestPackBaseStatus::where("test_package_no", $testPackageNo)->get();

        $weldLogs = db("weld_logs")
            ->where("test_package_no", $testPackageNo)
            ->get();

        $repairLogs = db("repair_logs")
            ->where("test_package_no", $testPackageNo)
            ->get();

        $testPackagesSummary = [];
        $testPackagesIsoSummary = [];

        $totalFields = [
            'total_wdi',
            'total_complated_wdi',
            'welding_progress',
            'total_shop_wdi',
            'total_complated_shop_wdi',
            'total_field_wdi',
            'total_complated_field_wdi',
        ];

        // Calculate repair log summaries
        $repairSummaries = $this->calculateRepairSummaries($repairLogs);

        // Calculate weld log summaries
        foreach($weldLogs AS $weldLog) {
            foreach($totalFields AS $field) {
                if(!isset($testPackagesSummary[$weldLog->test_package_no][$field]))
                    $testPackagesSummary[$weldLog->test_package_no][$field] = 0;

                if(!isset($testPackagesIsoSummary[$weldLog->iso_number][$weldLog->test_package_no][$field]))
                    $testPackagesIsoSummary[$weldLog->iso_number][$weldLog->test_package_no][$field] = 0;
            }
            
            $wdi = (float) $weldLog->nps_1;

            $testPackagesSummary[$weldLog->test_package_no]['total_wdi'] += $wdi ;
            $testPackagesIsoSummary[$weldLog->iso_number][$weldLog->test_package_no]['total_wdi'] += $wdi;

            if($weldLog->type_of_joint == "F") {
                $testPackagesSummary[$weldLog->test_package_no]['total_field_wdi'] += $wdi;
                $testPackagesIsoSummary[$weldLog->iso_number][$weldLog->test_package_no]['total_field_wdi'] += $wdi ;

                if(!rejected_date($weldLog->welding_date)) {
                    $testPackagesSummary[$weldLog->test_package_no]['total_complated_field_wdi'] += $wdi;
                    $testPackagesIsoSummary[$weldLog->iso_number][$weldLog->test_package_no]['total_complated_field_wdi'] += $wdi;
                }
            }
             
            if($weldLog->type_of_joint == "S") {
                $testPackagesSummary[$weldLog->test_package_no]['total_shop_wdi'] += $wdi;
                $testPackagesIsoSummary[$weldLog->iso_number][$weldLog->test_package_no]['total_shop_wdi'] += $wdi;

                if(!rejected_date($weldLog->welding_date)) {
                    $testPackagesSummary[$weldLog->test_package_no]['total_complated_shop_wdi'] += $wdi;
                    $testPackagesIsoSummary[$weldLog->iso_number][$weldLog->test_package_no]['total_complated_shop_wdi'] += $wdi;
                }
            }

            if(!rejected_date($weldLog->welding_date)) {
                $testPackagesSummary[$weldLog->test_package_no]['total_complated_wdi'] += $wdi;
                $testPackagesIsoSummary[$weldLog->iso_number][$weldLog->test_package_no]['total_complated_wdi'] += $wdi;
            }

            // Welding progress calculation
            $totalWdi = $testPackagesSummary[$weldLog->test_package_no]['total_wdi'];
            $totalComplatedWdi = $testPackagesSummary[$weldLog->test_package_no]['total_complated_wdi'];

            if ($totalWdi > 0) {
                $testPackagesSummary[$weldLog->test_package_no]['welding_progress'] = 
                    round(($totalComplatedWdi * 100) / $totalWdi, 2);
            } else {
                $testPackagesSummary[$weldLog->test_package_no]['welding_progress'] = 0;
            }
        }

        // Update test pack base statuses
        $this->updateTestPackBaseStatuses($testPackagesIsoSummary, $repairSummaries);

        // Update test packages summary
        $this->updateTestPackagesSummary($testPackagesSummary, $repairSummaries['repairLogsSummary2']);

        // Update test packages with WDI fields and status
        $processedCount = $this->updateTestPackagesWDI($testPackages, $testPackagesSummary, $totalFields);

        return [
            'success' => true,
            'processed_records' => $processedCount
        ];
    }
    
    /**
     * Calculate repair log summaries
     */
    protected function calculateRepairSummaries($repairLogs): array
    {
        $repairLogsSummary = [];
        $repairLogsSummary2 = [];
        $repairLogsSummaryCompleted = [];
        $repairLogsSummaryCompleted2 = [];
        $repairLogsSummaryRemaining = [];
        $repairLogsSummaryRemaining2 = [];

        foreach($repairLogs AS $repairLog) {
            if(!isset($repairLogsSummary[$repairLog->iso_number][$repairLog->test_package_no]))
                $repairLogsSummary[$repairLog->iso_number][$repairLog->test_package_no] = 0;

            if(!isset($repairLogsSummary2[$repairLog->test_package_no]))
                $repairLogsSummary2[$repairLog->test_package_no] = 0;

            if(!isset($repairLogsSummaryCompleted[$repairLog->iso_number][$repairLog->test_package_no]))
                $repairLogsSummaryCompleted[$repairLog->iso_number][$repairLog->test_package_no] = 0;

            if(!isset($repairLogsSummaryRemaining[$repairLog->iso_number][$repairLog->test_package_no]))
                $repairLogsSummaryRemaining[$repairLog->iso_number][$repairLog->test_package_no] = 0;

            if(!isset($repairLogsSummaryCompleted2[$repairLog->test_package_no]))
                $repairLogsSummaryCompleted2[$repairLog->test_package_no] = 0;

            if(!isset($repairLogsSummaryRemaining2[$repairLog->test_package_no]))
                $repairLogsSummaryRemaining2[$repairLog->test_package_no] = 0;

            if($repairLog->repair_status == "Not Done") {
                $repairLogsSummary[$repairLog->iso_number][$repairLog->test_package_no]++;
                $repairLogsSummary2[$repairLog->test_package_no]++;
            }

            if(!rejected_date($repairLog->repair_date)) {
                $repairLogsSummaryCompleted[$repairLog->iso_number][$repairLog->test_package_no]++;
                $repairLogsSummaryCompleted2[$repairLog->test_package_no]++;
            } else {
                $repairLogsSummaryRemaining[$repairLog->iso_number][$repairLog->test_package_no]++;
                $repairLogsSummaryRemaining2[$repairLog->test_package_no]++;
            }
        }

        return [
            'repairLogsSummary' => $repairLogsSummary,
            'repairLogsSummary2' => $repairLogsSummary2,
            'repairLogsSummaryCompleted' => $repairLogsSummaryCompleted,
            'repairLogsSummaryCompleted2' => $repairLogsSummaryCompleted2,
            'repairLogsSummaryRemaining' => $repairLogsSummaryRemaining,
            'repairLogsSummaryRemaining2' => $repairLogsSummaryRemaining2,
        ];
    }
    
    /**
     * Update test pack base statuses
     */
    protected function updateTestPackBaseStatuses($testPackagesIsoSummary, $repairSummaries)
    {
        TransactionHelper::retryTransaction(function () use ($testPackagesIsoSummary, $repairSummaries) {
            foreach($testPackagesIsoSummary AS $isoNumber => $data) {
                foreach($data AS $tpNo => $data2) {
            
                    if($data2['total_complated_wdi'] == $data2['total_wdi']) {
                        $status = "Completed";
                    }
            
                    if($data2['total_complated_wdi'] < $data2['total_wdi']) {
                        $status = "On Going";
                    }
            
                    if($data2['total_complated_wdi'] == 0) {
                        $status = "Waiting";
                    } 
            
                    $updateData = [
                        'welding_status' => $status,
                        'repair_qty' => @$repairSummaries['repairLogsSummary'][$isoNumber][$tpNo],
                        'repair_completed' => @$repairSummaries['repairLogsSummaryCompleted'][$isoNumber][$tpNo],
                        'repair_remaining' => @$repairSummaries['repairLogsSummaryRemaining'][$isoNumber][$tpNo],
                    ];
            
                    db("test_pack_base_statuses")
                        ->where("drawing_no", $isoNumber)
                        ->where("test_package_no", $tpNo)
                        ->update($updateData);
                    
                    $updateData = [
                        'welding_status' => $status,
                        'repair_qty' => @$repairSummaries['repairLogsSummary2'][$tpNo],
                        'repair_completed' => @$repairSummaries['repairLogsSummaryCompleted2'][$tpNo],
                        'repair_remaining' => @$repairSummaries['repairLogsSummaryRemaining2'][$tpNo],
                    ];
            
                    db("test_packages")
                        ->where("test_package_number", $tpNo)
                        ->update($updateData);
                }
            }
        }, 5);
    }
    
    /**
     * Update test packages summary
     */
    protected function updateTestPackagesSummary($testPackagesSummary, $repairLogsSummary2)
    {
        TransactionHelper::retryTransaction(function () use ($testPackagesSummary, $repairLogsSummary2) {
            foreach($testPackagesSummary AS $tpNo => $data2) {
                if($data2['total_complated_wdi'] == $data2['total_wdi']) {
                    $status = "Completed";
                }

                if($data2['total_complated_wdi'] < $data2['total_wdi']) {
                    $status = "On Going";
                }

                if($data2['total_complated_wdi'] == 0) {
                    $status = "Waiting";
                } 

                db("test_packages")
                    ->where("test_package_number", $tpNo)
                    ->update([
                        'welding_status' => $status,
                        'repair_status_total' => @$repairLogsSummary2[$tpNo]
                    ]);
            }
        }, 5);
    }
    
    /**
     * Update test packages with WDI fields and status
     */
    protected function updateTestPackagesWDI($testPackages, $testPackagesSummary, $totalFields): int
    {
        $k = 0;
        
        TransactionHelper::retryTransaction(function () use ($testPackages, $testPackagesSummary, $totalFields, &$k) {
            foreach($testPackages AS $testPackage) {
                $updateData = [];

                if(isset($testPackagesSummary[$testPackage->test_package_number])) {
                    foreach($totalFields AS $field) {
                        $testPackage->$field = $testPackagesSummary[$testPackage->test_package_number][$field];
                        $updateData[$field] = $testPackagesSummary[$testPackage->test_package_number][$field];
                    }
                }

                $updateData = array_merge($updateData, updateTestPackageStatus($testPackage));

                db("test_packages")->where("id", $testPackage->id)
                    ->update($updateData);

                db("test_pack_base_statuses")->where("test_package_no", $testPackage->test_package_number)
                    ->update([
                        'tp_status' => $updateData['status'] ?? 'Waiting',
                        'priority' => $testPackage->priority,
                        'priority_info' => $testPackage->priority_info,
                        'responsible_person' => $testPackage->responsible_test,
                        'target_test_date' => $testPackage->planned_test_date,
                    ]);

                $k++;
            }
            
            return $k;
        }, 5);
        
        return $k;
    }
}