<?php

namespace App\Http\Controllers\Api;

use App\Http\Controllers\Controller;
use App\Models\JobOffer;
use App\Models\JobApplication;
use App\Models\Worker;
use App\Models\WorkerDocument;
use App\Models\ProfileView;
use App\Models\Conversation;
use App\Models\EmployerProfile;
use App\Models\Announcement;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Storage;
use Illuminate\Support\Facades\Validator;

class WorkerProfileController extends Controller
{
    /**
     * Get authorized worker's profile details.
     *
     * @param  \Illuminate\Http\Request  $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function getProfile(Request $request)
    {
        /** @var Worker $worker */
        $worker = $request->attributes->get('worker');

        $worker->load(['skills', 'documents', 'reviews.employer.employerProfile', 'employerReviews.employer.employerProfile']);

        $worker->makeHidden(['email', 'religion', 'availability', 'bio', 'country', 'city', 'area']);

        return response()->json([
            'success' => true,
            'data' => [
                'worker' => $worker
            ]
        ], 200);
    }

    /**
     * Update authorized worker's profile details.
     *
     * @param  \Illuminate\Http\Request  $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function updateProfile(Request $request)
    {
        /** @var Worker $worker */
        $worker = $request->attributes->get('worker');

        $data = $request->all();
        if (isset($data['passport']) && is_string($data['passport'])) {
            $decoded = json_decode($data['passport'], true);
            if (json_last_error() === JSON_ERROR_NONE && is_array($decoded)) {
                $data['passport'] = $decoded;
            }
        }
        if (isset($data['visa']) && is_string($data['visa'])) {
            $decoded = json_decode($data['visa'], true);
            if (json_last_error() === JSON_ERROR_NONE && is_array($decoded)) {
                $data['visa'] = $decoded;
            }
        }
        $request->merge($data);

        $validator = Validator::make($request->all(), [
            'name'               => 'nullable|string|max:255',
            'phone'              => 'nullable|string|max:50',
            'main_profession'    => 'nullable|string|max:100',
            'age'                => [
                'nullable',
                function ($attribute, $value, $fail) {
                    if (is_numeric($value)) {
                        $intValue = (int)$value;
                        if ($intValue < 18 || $intValue > 100) {
                            $fail('The age must be between 18 and 100.');
                        }
                    } else {
                        if (!in_array($value, ['18-25', '26-35', '36-45', '46-55', '56-60'])) {
                            $fail('The age must be a valid number or one of the ranges: 18-25, 26-35, 36-45, 46-55, 56-60.');
                        }
                    }
                }
            ],
            'nationality'        => 'nullable|string|max:100',
            'language'           => 'nullable|string',
            'salary'             => 'nullable|numeric|min:0',
            'experience'         => 'nullable|string|max:100',
            'skills'             => 'nullable|array',
            'skills.*'           => 'exists:skills,id',
            'in_country'         => 'nullable',
            'visa_status'        => 'nullable|string',
            'preferred_job_type' => 'nullable|string|max:100',
            'gender'             => 'nullable|string|in:male,female,other',
            'live_in_out'        => 'nullable|string|in:live_in,live_out',
            'preferred_location' => 'nullable|string|max:255',
            'fcm_token'          => 'nullable|string|max:255',
            'passport'           => 'nullable|array',
            'passport.passport_number' => [
                'nullable',
                'string',
                \Illuminate\Validation\Rule::unique('worker_documents', 'number')->where(function ($query) use ($worker) {
                    return $query->where('type', 'passport')->where('worker_id', '!=', $worker->id);
                }),
            ],
            'visa'               => 'nullable|array',
        ], [
            'passport.passport_number.unique' => 'This passport number is already registered.',
        ]);

        if ($validator->fails()) {
            return response()->json([
                'success' => false,
                'message' => 'Validation error.',
                'errors' => $validator->errors()
            ], 422);
        }

        if ($request->phone) {
            $exists = Worker::findByPhone($request->phone);
            if ($exists && $exists->id !== $worker->id) {
                return response()->json([
                    'success' => false,
                    'message' => 'Validation error.',
                    'errors' => ['phone' => ['This mobile number is already registered.']]
                ], 422);
            }
        }

        // Document Update Check: Verify passport number matches existing passport number if already verified/saved
        $existingPassport = $worker->documents()->where('type', 'passport')->first();
        if ($existingPassport && $request->has('passport')) {
            $passportData = $request->input('passport');
            if ($passportData) {
                $newPassportNumber = $passportData['passport_number'] ?? $passportData['number'] ?? null;
                if ($newPassportNumber && strcasecmp(trim($existingPassport->number), trim($newPassportNumber)) !== 0) {
                    return response()->json([
                        'success' => false,
                        'message' => 'Validation error.',
                        'errors' => [
                            'passport.passport_number' => ['The passport number cannot be changed. It must match the previously verified passport number.']
                        ]
                    ], 422);
                }
            }
        }

        try {
            DB::transaction(function () use ($request, $worker, $existingPassport) {
                // Update worker attributes
                $updateData = $request->only([
                    'name',
                    'phone',
                    'age',
                    'nationality',
                    'language',
                    'salary',
                    'experience',
                    'visa_status',
                    'preferred_job_type',
                    'gender',
                    'live_in_out',
                    'preferred_location',
                    'fcm_token',
                    'main_profession'
                ]);

                // Filter out null inputs if we want to support partial updates
                $updateData = array_filter($updateData, function ($value) {
                    return !is_null($value);
                });

                if ($request->has('in_country')) {
                    $updateData['in_country'] = filter_var($request->input('in_country'), FILTER_VALIDATE_BOOLEAN);
                }

                $worker->update($updateData);

                // Sync skills if provided
                if ($request->has('skills')) {
                    $worker->skills()->sync($request->skills ?: []);
                }

                // Process passport document creation/update
                if ($request->has('passport')) {
                    $passportDataInput = $request->input('passport');
                    if ($passportDataInput) {
                        $expiryDate  = $passportDataInput['date_of_expiry'] ?? null;
                        $issueDate   = $passportDataInput['date_of_issue'] ?? null;
                        $expiryDateFormatted = $expiryDate ? $this->normaliseDateForController($expiryDate) : null;
                        $issueDateFormatted  = $issueDate ? $this->normaliseDateForController($issueDate) : null;

                        if ($existingPassport) {
                            $updateFields = [
                                'ocr_data' => $passportDataInput,
                            ];
                            if ($expiryDateFormatted) {
                                $updateFields['expiry_date'] = $expiryDateFormatted;
                            }
                            if ($issueDateFormatted) {
                                $updateFields['issue_date'] = $issueDateFormatted;
                            }
                            $existingPassport->update($updateFields);
                        } else {
                            $passportNum = $passportDataInput['passport_number'] ?? $passportDataInput['number'] ?? ('P' . rand(1000000, 9999999));
                            $expiryDateFormatted = $expiryDateFormatted ?: now()->addYears(8)->toDateString();
                            $issueDateFormatted  = $issueDateFormatted ?: now()->subYears(3)->toDateString();

                            $worker->documents()->create([
                                'type'         => 'passport',
                                'number'       => $passportNum,
                                'issue_date'   => $issueDateFormatted,
                                'expiry_date'  => $expiryDateFormatted,
                                'ocr_accuracy' => 99.0,
                                'file_path'    => null,
                                'ocr_data'     => $passportDataInput,
                            ]);
                        }
                    }
                }

                // Process visa document creation/update
                if ($request->has('visa')) {
                    $visaDataInput = $request->input('visa');
                    if ($visaDataInput) {
                        $existingVisa = $worker->documents()->where('type', 'visa')->first();
                        $cleanedVisaOcr = $this->cleanVisaData($visaDataInput);
                        $expiryDate = $cleanedVisaOcr['valid_until'] ?? null;
                        $issueDate  = $cleanedVisaOcr['issue_date'] ?? null;
                        $expiryDateFormatted = $expiryDate ? $this->normaliseDateForController($expiryDate) : null;
                        $issueDateFormatted  = $issueDate ? $this->normaliseDateForController($issueDate) : null;

                        if ($existingVisa) {
                            $updateFields = [
                                'ocr_data' => $cleanedVisaOcr,
                            ];
                            if ($expiryDateFormatted) {
                                $updateFields['expiry_date'] = $expiryDateFormatted;
                            }
                            if ($issueDateFormatted) {
                                $updateFields['issue_date'] = $issueDateFormatted;
                            }
                            if (!empty($cleanedVisaOcr['entry_permit_no'])) {
                                $updateFields['number'] = $cleanedVisaOcr['entry_permit_no'];
                            }
                            $existingVisa->update($updateFields);
                        } else {
                            $visaNum    = $cleanedVisaOcr['entry_permit_no'] ?: ('V' . rand(1000000, 9999999));
                            $expiryDateFormatted = $expiryDateFormatted ?: now()->addYears(2)->toDateString();
                            $issueDateFormatted  = $issueDateFormatted ?: now()->subYears(2)->toDateString();

                            $worker->documents()->create([
                                'type'         => 'visa',
                                'number'       => $visaNum,
                                'issue_date'   => $issueDateFormatted,
                                'expiry_date'  => $expiryDateFormatted,
                                'ocr_accuracy' => isset($visaDataInput['ocr_accuracy']) ? (float)$visaDataInput['ocr_accuracy'] : 99.0,
                                'file_path'    => null,
                                'ocr_data'     => $cleanedVisaOcr,
                            ]);
                        }
                    }
                }
            });

            $worker->load(['skills', 'documents', 'reviews.employer.employerProfile', 'employerReviews.employer.employerProfile']);

            $worker->makeHidden(['email', 'religion', 'availability', 'bio', 'country', 'city', 'area']);

            return response()->json([
                'success' => true,
                'message' => 'Profile updated successfully.',
                'data' => [
                    'worker' => $worker
                ]
            ], 200);

        } catch (\Exception $e) {
            logger()->error('Mobile Worker Profile Update Failure: ' . $e->getMessage());

            return response()->json([
                'success' => false,
                'message' => 'An error occurred while updating your profile.',
                'error' => app()->environment('local') ? $e->getMessage() : 'Internal Server Error'
            ], 500);
        }
    }


    /**
     * S3: Profile Go Live (Status: Active).
     *
     * @param  \Illuminate\Http\Request  $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function goLive(Request $request)
    {
        /** @var Worker $worker */
        $worker = $request->attributes->get('worker');

        try {
            $worker->update([
                'status' => 'active',
                'availability' => 'Immediate'
            ]);

            return response()->json([
                'success' => true,
                'message' => 'Your profile is now live! Status set to Active.',
                'data' => [
                    'worker' => $worker->load(['skills', 'documents', 'reviews.employer.employerProfile', 'employerReviews.employer.employerProfile'])
                ]
            ], 200);
        } catch (\Exception $e) {
            logger()->error('Mobile Worker Go Live Failure: ' . $e->getMessage());
            return response()->json([
                'success' => false,
                'message' => 'Failed to go live. Please try again.'
            ], 500);
        }
    }

    /**
     * S5: Toggle availability - "Still looking for job?".
     * If YES -> Visible (status: active), If NO -> Hidden (status: hidden).
     *
     * @param  \Illuminate\Http\Request  $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function toggleAvailability(Request $request)
    {
        /** @var Worker $worker */
        $worker = $request->attributes->get('worker');

        $validator = Validator::make($request->all(), [
            'still_looking' => 'required|boolean',
        ]);

        if ($validator->fails()) {
            return response()->json([
                'success' => false,
                'message' => 'Validation error.',
                'errors' => $validator->errors()
            ], 422);
        }

        try {
            $stillLooking = (bool) $request->still_looking;
            $newStatus = $stillLooking ? 'active' : 'hidden';

            $worker->update([
                'status' => $newStatus,
                'availability' => $stillLooking ? 'Immediate' : 'Not Available'
            ]);

            return response()->json([
                'success' => true,
                'message' => $stillLooking
                    ? 'Your profile is now Visible in search results.'
                    : 'Your profile has been Hidden from search results.',
                'still_looking' => $stillLooking,
                'status' => $newStatus,
                'data' => [
                    'worker' => $worker->load(['skills', 'documents', 'reviews.employer.employerProfile', 'employerReviews.employer.employerProfile'])
                ]
            ], 200);

        } catch (\Exception $e) {
            logger()->error('Mobile Worker Toggle Availability Failure: ' . $e->getMessage());
            return response()->json([
                'success' => false,
                'message' => 'Failed to update availability status. Please try again.'
            ], 500);
        }
    }

    /**
     * S6: Marked as Hired (Profile removed from search - auto-hidden).
     *
     * @param  \Illuminate\Http\Request  $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function markHired(Request $request)
    {
        /** @var Worker $worker */
        $worker = $request->attributes->get('worker');

        try {
            $worker->update([
                'status' => 'Hired',
                'availability' => 'Hired'
            ]);

            return response()->json([
                'success' => true,
                'message' => 'Congratulations! You have been successfully marked as Hired. Your profile has been automatically removed from active search.',
                'data' => [
                    'worker' => $worker->load(['skills', 'documents', 'reviews.employer.employerProfile', 'employerReviews.employer.employerProfile'])
                ]
            ], 200);
        } catch (\Exception $e) {
            logger()->error('Mobile Worker Mark Hired Failure: ' . $e->getMessage());
            return response()->json([
                'success' => false,
                'message' => 'Failed to mark as hired. Please try again.'
            ], 500);
        }
    }

    /**
     * Get all job offers received by the worker.
     *
     * @param  \Illuminate\Http\Request  $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function getOffers(Request $request)
    {
        /** @var Worker $worker */
        $worker = $request->attributes->get('worker');

        $offers = JobOffer::where('worker_id', $worker->id)
            ->with(['employer.employerProfile']) // Load employer and their profile details
            ->latest()
            ->get();

        return response()->json([
            'success' => true,
            'data' => [
                'offers' => $offers
            ]
        ], 200);
    }

    /**
     * Respond to a specific job offer (Accept or Reject).
     *
     * @param  \Illuminate\Http\Request  $request
     * @param  int  $id
     * @return \Illuminate\Http\JsonResponse
     */
    public function respondToOffer(Request $request, $id)
    {
        /** @var Worker $worker */
        $worker = $request->attributes->get('worker');

        $validator = Validator::make($request->all(), [
            'status' => 'required|string|in:accepted,rejected',
        ], [
            'status.in' => 'Status must be either accepted or rejected.'
        ]);

        if ($validator->fails()) {
            return response()->json([
                'success' => false,
                'message' => 'Validation error.',
                'errors' => $validator->errors()
            ], 422);
        }

        try {
            $offer = JobOffer::where('id', $id)
                ->where('worker_id', $worker->id)
                ->first();

            if (!$offer) {
                return response()->json([
                    'success' => false,
                    'message' => 'Job offer not found.'
                ], 404);
            }

            if ($offer->status !== 'pending') {
                return response()->json([
                    'success' => false,
                    'message' => 'This job offer has already been responded to.'
                ], 400);
            }

            $responseStatus = $request->status;

            DB::transaction(function () use ($offer, $worker, $responseStatus) {
                // Update offer status
                $offer->update(['status' => $responseStatus]);

                // If accepted, change worker status to 'Hired'
                if ($responseStatus === 'accepted') {
                    $worker->update([
                        'status' => 'Hired',
                        'availability' => 'Hired'
                    ]);
                }
            });

            // Dispatch push notification to employer
            $employer = $offer->employer;
            if ($employer) {
                $statusMessage = $responseStatus === 'accepted' ? 'accepted' : 'rejected';
                $employer->notify(new \App\Notifications\GenericNotification(
                    "Job Offer " . ucfirst($statusMessage),
                    "Worker " . ($worker->name ?? "Candidate") . " has " . $statusMessage . " your job offer.",
                    [
                        'type' => 'job_offer_response',
                        'offer_id' => $offer->id,
                        'status' => $responseStatus,
                    ]
                ));
            }

            return response()->json([
                'success' => true,
                'message' => "Job offer successfully " . $responseStatus . ".",
                'data' => [
                    'offer' => $offer,
                    'worker_status' => $worker->fresh()->status
                ]
            ], 200);

        } catch (\Exception $e) {
            logger()->error('Mobile Respond to Offer Failure: ' . $e->getMessage());

            return response()->json([
                'success' => false,
                'message' => 'An error occurred while responding to the job offer.',
                'error' => app()->environment('local') ? $e->getMessage() : 'Internal Server Error'
            ], 500);
        }
    }

    /**
     * Get profile view statistics and employer listing for the worker dashboard.
     * GET /api/workers/dashboard/views
     */
    public function getProfileViews(Request $request)
    {
        /** @var Worker $worker */
        $worker = $request->attributes->get('worker');

        try {
            // Get views count
            $viewsCount = ProfileView::where('worker_id', $worker->id)->count();

            // Get list of employers/sponsors who viewed, with their details
            $views = ProfileView::where('worker_id', $worker->id)
                ->with('employer')
                ->latest('updated_at')
                ->get();

            $list = $views->map(function ($view) {
                $emp = $view->employer;

                $empProfile = null;
                if ($emp) {
                    $empProfile = EmployerProfile::where('user_id', $emp->id)->first();
                }

                return [
                    'id' => $view->id,
                    'employer_id' => $view->employer_id,
                    'employer_name' => $emp->name ?? 'Employer/Sponsor',
                    'company_name' => $empProfile->company_name ?? 'Private Sponsor',
                    'nationality' => $empProfile->nationality ?? 'UAE',
                    'city' => $empProfile->city ?? 'Dubai',
                    'viewed_at' => $view->updated_at->toIso8601String(),
                    'viewed_at_formatted' => $view->updated_at->diffForHumans(),
                ];
            });

            return response()->json([
                'success' => true,
                'data' => [
                    'views_count' => $viewsCount,
                    'views_list' => $list
                ]
            ], 200);

        } catch (\Exception $e) {
            logger()->error('Worker Dashboard Views API Failure: ' . $e->getMessage());

            return response()->json([
                'success' => false,
                'message' => 'An error occurred while fetching profile views statistics.',
                'error' => app()->environment('local') ? $e->getMessage() : 'Internal Server Error'
            ], 500);
        }
    }

    /**
     * Get consolidated worker dashboard details (Requirement: dashboard api).
     * GET /api/workers/dashboard
     */
    public function getDashboard(Request $request)
    {
        /** @var Worker $worker */
        $worker = $request->attributes->get('worker');

        try {
            // 1. Active status
            $activeStatus = $worker->status;

            // 2. Count of sponsors who viewed the profile
            $viewsCount = ProfileView::where('worker_id', $worker->id)->count();

            // Unique count of employers who viewed this profile
            $profileViewed = ProfileView::where('worker_id', $worker->id)->distinct('employer_id')->count('employer_id');

            // Unique count of employers who contacted this worker
            $employerContacted = Conversation::where('worker_id', $worker->id)->distinct('employer_id')->count('employer_id');

            // 3. Currently working sponsor/employer
            $currentSponsor = null;
            $emp = null;
            $hiredAt = null;

            $acceptedOffer = JobOffer::where('worker_id', $worker->id)
                ->whereIn(DB::raw('LOWER(status)'), ['accepted', 'hired'])
                ->with(['employer.employerProfile', 'employer.employerReviews.worker'])
                ->first();

            if ($acceptedOffer) {
                $emp = $acceptedOffer->employer;
                $hiredAt = $acceptedOffer->updated_at;
            } else {
                $hiredApplication = \App\Models\JobApplication::where('worker_id', $worker->id)
                    ->whereIn(DB::raw('LOWER(status)'), ['hired'])
                    ->with(['jobPost.employer.employerProfile', 'jobPost.employer.employerReviews.worker'])
                    ->first();
                if ($hiredApplication && $hiredApplication->jobPost && $hiredApplication->jobPost->employer) {
                    $emp = $hiredApplication->jobPost->employer;
                    $hiredAt = $hiredApplication->updated_at;
                }
            }

            if ($emp) {
                $empProfile = $emp->employerProfile;
                $currentSponsor = [
                    'id' => $emp->id,
                    'name' => $emp->name,
                    'company_name' => $empProfile->company_name ?? 'Private Sponsor',
                    'nationality' => $empProfile->nationality ?? 'UAE',
                    'city' => $empProfile->city ?? 'Dubai',
                    'email' => $emp->email,
                    'phone' => $empProfile->phone ?? $emp->phone,
                    'hired_at' => $hiredAt ? $hiredAt->toIso8601String() : null,
                    'hired_at_formatted' => $hiredAt ? $hiredAt->format('M d, Y') : null,
                    'rating' => $emp->rating,
                    'reviews_count' => $emp->reviews_count,
                    'reviews' => $emp->employerReviews,
                ];
            }

            // 4. Latest charity events / announcements list
            $charityEvents = Announcement::with(['employer.employerProfile', 'sponsor'])
                ->where('status', 'approved')
                ->latest()
                ->limit(5)
                ->get()
                ->map(function ($event) {
                    $postedBy = 'System';
                    $organization = 'Migrant Support';

                    if ($event->sponsor_id) {
                        $postedBy = $event->sponsor->full_name;
                        $organization = $event->sponsor->organization_name;
                    } elseif ($event->employer_id) {
                        $postedBy = $event->employer->name;
                        $organization = $event->employer->employerProfile->company_name ?? 'Employer';
                    }

                    // Decode charity details if they exist in json
                    $charityDetails = null;
                    $content = $event->body;
                    if (strpos($event->body, '{"type":"Charity"') === 0) {
                        $decoded = json_decode($event->body, true);
                        if ($decoded) {
                            $charityDetails = $decoded;
                            $content = $decoded['content'] ?? $event->body;
                        }
                    }

                    return [
                        'id' => $event->id,
                        'title' => $event->title,
                        'body' => $content,
                        'type' => $event->type,
                        'employer_name' => $postedBy,
                        'company_name' => $organization,
                        'created_at' => $event->created_at->toIso8601String(),
                        'time_ago' => $event->created_at->diffForHumans(),
                        'charity_details' => $charityDetails,
                    ];
                });

            return response()->json([
                'success' => true,
                'data' => [
                    'active_status' => $activeStatus,
                    'count_sponsors_viewed' => $viewsCount,
                    'employer_contacted' => $employerContacted,
                    'profile_viewed' => $profileViewed,
                    'currently_working_sponsor' => $currentSponsor,
                    'current_employer' => $currentSponsor,
                    'latest_charity_events_list' => $charityEvents
                ]
            ], 200);

        } catch (\Exception $e) {
            logger()->error('Worker Dashboard API Failure: ' . $e->getMessage());

            return response()->json([
                'success' => false,
                'message' => 'An error occurred while loading the worker dashboard.',
                'error' => app()->environment('local') ? $e->getMessage() : 'Internal Server Error'
            ], 500);
        }
    }

    /**
     * Get list of employers associated with the worker.
     * GET /api/workers/employers
     */
    public function getEmployers(Request $request)
    {
        /** @var Worker $worker */
        $worker = $request->attributes->get('worker');

        try {
            // Fetch JobOffers
            $offers = JobOffer::where('worker_id', $worker->id)
                ->with(['employer.employerProfile', 'employer.employerReviews.worker'])
                ->get();

            // Fetch hired JobApplications
            $applications = JobApplication::where('worker_id', $worker->id)
                ->where('status', 'hired')
                ->with(['jobPost.employer.employerProfile', 'jobPost.employer.employerReviews.worker'])
                ->get();

            // Map JobOffers
            $mappedOffers = $offers->map(function ($offer) {
                $emp = $offer->employer;
                $empProfile = $emp ? $emp->employerProfile : null;

                $statusFormatted = $offer->status;
                if (strtolower($offer->status) === 'accepted') {
                    $statusFormatted = 'Active';
                } else {
                    $statusFormatted = ucfirst($offer->status);
                }

                return [
                    'offer_id' => $offer->id,
                    'joining_date' => $offer->work_date ? $offer->work_date->format('Y-m-d') : null,
                    'joining_date_raw' => $offer->work_date,
                    'location' => $offer->location,
                    'salary' => (int) $offer->salary,
                    'status' => $statusFormatted,
                    'status_raw' => $offer->status,
                    'notes' => $offer->notes,
                    'created_at' => $offer->created_at,
                    'employer' => $emp ? [
                        'id' => $emp->id,
                        'name' => $emp->name,
                        'email' => $emp->email,
                        'phone' => $emp->phone,
                        'company_name' => $empProfile->company_name ?? 'Private Sponsor',
                        'city' => $empProfile->city ?? null,
                        'nationality' => $empProfile->nationality ?? null,
                        'rating' => $emp->rating,
                        'reviews_count' => $emp->reviews_count,
                        'reviews' => $emp->employerReviews,
                    ] : null
                ];
            });

            // Map JobApplications
            $mappedApps = $applications->map(function ($app) {
                $job = $app->jobPost;
                $emp = $job ? $job->employer : null;
                $empProfile = $emp ? $emp->employerProfile : null;

                return [
                    'offer_id' => $app->id,
                    'joining_date' => $app->updated_at ? $app->updated_at->format('Y-m-d') : null,
                    'joining_date_raw' => $app->updated_at,
                    'location' => $job->location ?? null,
                    'salary' => $job ? (int) $job->salary : 0,
                    'status' => 'Active',
                    'status_raw' => 'accepted',
                    'notes' => $app->notes,
                    'created_at' => $app->created_at,
                    'employer' => $emp ? [
                        'id' => $emp->id,
                        'name' => $emp->name,
                        'email' => $emp->email,
                        'phone' => $emp->phone,
                        'company_name' => $empProfile->company_name ?? 'Private Sponsor',
                        'city' => $empProfile->city ?? null,
                        'nationality' => $empProfile->nationality ?? null,
                        'rating' => $emp->rating,
                        'reviews_count' => $emp->reviews_count,
                        'reviews' => $emp->employerReviews,
                    ] : null
                ];
            });

            // Merge and de-duplicate by employer id
            $merged = $mappedOffers->concat($mappedApps)->unique(function ($item) {
                return $item['employer']['id'] ?? null;
            })->values();

            // Filtering by status
            if ($request->filled('status')) {
                $statusInput = strtolower($request->status);
                $merged = $merged->filter(function ($item) use ($statusInput) {
                    $rawStatus = strtolower($item['status_raw'] ?? '');
                    if ($statusInput === 'active') {
                        return $rawStatus === 'accepted' || $rawStatus === 'hired';
                    }
                    return $rawStatus === $statusInput;
                });
            }

            // Sorting
            $sortBy = $request->input('sort_by', 'joining_date');
            $sortOrder = strtolower($request->input('sort_order', 'desc')) === 'asc' ? 'asc' : 'desc';

            $merged = $merged->sort(function ($a, $b) use ($sortBy, $sortOrder) {
                // Priority: status = 'Active' (accepted/hired) comes first
                $aActive = $a['status'] === 'Active' ? 0 : 1;
                $bActive = $b['status'] === 'Active' ? 0 : 1;

                if ($aActive !== $bActive) {
                    return $aActive <=> $bActive;
                }

                $valA = null;
                $valB = null;

                if ($sortBy === 'salary') {
                    $valA = $a['salary'];
                    $valB = $b['salary'];
                } elseif ($sortBy === 'status') {
                    $valA = $a['status'];
                    $valB = $b['status'];
                } elseif ($sortBy === 'created_at') {
                    $valA = $a['created_at'];
                    $valB = $b['created_at'];
                } else {
                    $valA = $a['joining_date_raw'];
                    $valB = $b['joining_date_raw'];
                }

                if ($valA == $valB) {
                    return 0;
                }

                if ($sortOrder === 'asc') {
                    return $valA > $valB ? 1 : -1;
                } else {
                    return $valA < $valB ? 1 : -1;
                }
            });

            // Pagination
            $total = $merged->count();
            $perPage = (int) $request->input('per_page', 15);
            $currentPage = (int) $request->input('page', 1);
            $lastPage = max(1, (int) ceil($total / $perPage));

            $pageItems = $merged->slice(($currentPage - 1) * $perPage, $perPage)->values();

            // Clean up temporary sorting/filtering keys
            $employers = $pageItems->map(function ($item) {
                unset($item['joining_date_raw']);
                unset($item['status_raw']);
                unset($item['created_at']);
                return $item;
            });

            return response()->json([
                'success' => true,
                'data' => [
                    'employers' => $employers,
                    'pagination' => [
                        'total' => $total,
                        'per_page' => $perPage,
                        'current_page' => $currentPage,
                        'last_page' => $lastPage,
                    ]
                ]
            ], 200);

        } catch (\Exception $e) {
            logger()->error('Worker Employers API Failure: ' . $e->getMessage());

            return response()->json([
                'success' => false,
                'message' => 'An error occurred while loading the employers list.',
                'error' => app()->environment('local') ? $e->getMessage() : 'Internal Server Error'
            ], 500);
        }
    }

    /**
     * Change worker's password.
     *
     * @param  \Illuminate\Http\Request  $request
     * @return \Illuminate\Http\JsonResponse
     */
    public function changePassword(Request $request)
    {
        /** @var Worker $worker */
        $worker = $request->attributes->get('worker');

        $validator = Validator::make($request->all(), [
            'current_password' => 'required|string',
            'new_password' => 'required|string|min:8|confirmed',
        ]);

        if ($validator->fails()) {
            return response()->json([
                'success' => false,
                'message' => 'Validation error.',
                'errors' => $validator->errors()
            ], 422);
        }

        if (!\Illuminate\Support\Facades\Hash::check($request->current_password, $worker->password)) {
            return response()->json([
                'success' => false,
                'message' => 'Validation error.',
                'errors' => [
                    'current_password' => ['The current password is incorrect.']
                ]
            ], 422);
        }

        try {
            $worker->update([
                'password' => \Illuminate\Support\Facades\Hash::make($request->new_password)
            ]);

            return response()->json([
                'success' => true,
                'message' => 'Password changed successfully.'
            ], 200);

        } catch (\Exception $e) {
            logger()->error('Mobile Worker Change Password Failure: ' . $e->getMessage());

            return response()->json([
                'success' => false,
                'message' => 'An error occurred while changing password.',
                'error' => app()->environment('local') ? $e->getMessage() : 'Internal Server Error'
            ], 500);
        }
    }

    /**
     * E.g. "14/05/1990" -> "1990-05-14"
     */
    private function normaliseDateForController(?string $raw): ?string
    {
        if (empty($raw)) {
            return null;
        }
        $raw = trim($raw);
        if (preg_match('/^\d{4}-\d{2}-\d{2}$/', $raw)) {
            return $raw;
        }
        try {
            if (preg_match('/^(\d{1,2})[\/\- ]([A-Za-z0-9]+)[\/\- ](\d{4})$/', $raw, $m)) {
                $day   = str_pad($m[1], 2, '0', STR_PAD_LEFT);
                $month = $m[2];
                $year  = $m[3];
                if (is_numeric($month)) {
                    $month = str_pad($month, 2, '0', STR_PAD_LEFT);
                    return "{$year}-{$month}-{$day}";
                }
                $ts = strtotime("{$day} {$month} {$year}");
                return $ts ? date('Y-m-d', $ts) : $raw;
            }
            $dt = new \DateTime($raw);
            return $dt->format('Y-m-d');
        } catch (\Exception $e) {
            return $raw;
        }
    }

    /**
     * Standardize and clean Visa OCR data structure to exactly the 15 required fields.
     */
    private function cleanVisaData(array $visaDataInput): array
    {
        $rawVisaType = $visaDataInput['visa_type'] ?? null;
        if ($rawVisaType) {
            $normalized = strtolower(trim($rawVisaType));
            if (str_contains($normalized, 'residence')) {
                $rawVisaType = 'Residence Visa';
            } elseif (str_contains($normalized, 'employment')) {
                $rawVisaType = 'Employment Visa';
            } else {
                $rawVisaType = 'Tourist Visa';
            }
        } else {
            $rawVisaType = 'Tourist Visa';
        }

        $rawEntryPermitNo = $visaDataInput['entry_permit_no'] ?? $visaDataInput['file_number'] ?? $visaDataInput['id_number'] ?? $visaDataInput['number'] ?? null;
        $rawIssueDate = $visaDataInput['issue_date'] ?? null;
        $rawValidUntil = $visaDataInput['valid_until'] ?? $visaDataInput['expiry_date'] ?? null;
        $rawUidNo = $visaDataInput['uid_no'] ?? $visaDataInput['id_number'] ?? null;
        $rawFullName = $visaDataInput['full_name'] ?? $visaDataInput['name'] ?? null;
        $rawNationality = $visaDataInput['nationality'] ?? null;
        $rawPlaceOfBirth = $visaDataInput['place_of_birth'] ?? null;
        $rawDateOfBirth = $visaDataInput['date_of_birth'] ?? $visaDataInput['dob'] ?? null;
        $rawPassportNo = $visaDataInput['passport_no'] ?? $visaDataInput['passport_number'] ?? null;
        $rawProfession = $visaDataInput['profession'] ?? null;
        $rawSponsorName = $visaDataInput['sponsor_name'] ?? null;

        // Clean sponsor
        $sponsorData = $visaDataInput['sponsor'] ?? [];
        if (is_string($sponsorData)) {
            $sponsorNameFromObj = $sponsorData;
            $sponsorAddress = '';
            $sponsorPhone = '';
        } else {
            $sponsorNameFromObj = $sponsorData['name'] ?? $sponsorData['sponsor_name'] ?? $sponsorData['full_name'] ?? '';
            $sponsorAddress = $sponsorData['address'] ?? '';
            $sponsorPhone = $sponsorData['phone'] ?? $sponsorData['mobile'] ?? $sponsorData['mobile_number'] ?? $sponsorData['phone_number'] ?? '';
        }
        if (empty($rawSponsorName)) {
            $rawSponsorName = $sponsorNameFromObj;
        }

        return [
            'document_type'   => 'uae_visa',
            'country'         => 'United Arab Emirates',
            'visa_type'       => $rawVisaType,
            'entry_permit_no' => $rawEntryPermitNo ?: '',
            'issue_date'      => $rawIssueDate ?: '',
            'valid_until'     => $rawValidUntil ?: '',
            'uid_no'          => $rawUidNo ?: '',
            'full_name'       => $rawFullName ?: '',
            'nationality'     => $rawNationality ?: '',
            'place_of_birth'  => $rawPlaceOfBirth ?: '',
            'date_of_birth'   => $rawDateOfBirth ?: '',
            'passport_no'     => $rawPassportNo ?: '',
            'profession'      => $rawProfession ?: '',
            'sponsor_name'    => $rawSponsorName ?: '',
            'sponsor'         => [
                'name'    => $sponsorNameFromObj ?: '',
                'address' => $sponsorAddress ?: '',
                'phone'   => $sponsorPhone ?: '',
            ]
        ];
    }

    /**
     * Get details of an employer profile for worker view.
     * GET /api/workers/employers/{id}
     */
    public function getEmployerProfile(Request $request, $id)
    {
        /** @var Worker $worker */
        $worker = $request->attributes->get('worker');

        try {
            // Find the employer (role should be 'employer')
            $employer = \App\Models\User::where('id', $id)->where('role', 'employer')->first();

            if (!$employer) {
                return response()->json([
                    'success' => false,
                    'message' => 'Employer not found.'
                ], 404);
            }

            $empProfile = $employer->employerProfile;

            // 1. Check access permissions for contact details
            $hasAccess = false;

            // Check if there is an active/previous JobOffer
            $hasOffer = \App\Models\JobOffer::where('employer_id', $employer->id)
                ->where('worker_id', $worker->id)
                ->exists();

            // Check if the worker has applied to any jobs of this employer
            $hasApplication = \App\Models\JobApplication::where('worker_id', $worker->id)
                ->whereHas('jobPost', function ($query) use ($employer) {
                    $query->where('employer_id', $employer->id);
                })
                ->exists();

            // Check if there is an active/previous conversation
            $hasConversation = \App\Models\Conversation::where('employer_id', $employer->id)
                ->where('worker_id', $worker->id)
                ->exists();

            // If the worker has 'Hired' status (case-insensitive) and is hired by this employer
            $isHiredByThisEmployer = false;
            if (strtolower($worker->status ?? '') === 'hired') {
                $isHiredByThisEmployer = \App\Models\JobOffer::where('employer_id', $employer->id)
                    ->where('worker_id', $worker->id)
                    ->whereIn(DB::raw('LOWER(status)'), ['accepted', 'hired'])
                    ->exists() ||
                    \App\Models\JobApplication::where('worker_id', $worker->id)
                    ->whereHas('jobPost', function ($query) use ($employer) {
                        $query->where('employer_id', $employer->id);
                    })
                    ->where(DB::raw('LOWER(status)'), 'hired')
                    ->exists();
            }

            if ($hasOffer || $hasApplication || $hasConversation || $isHiredByThisEmployer) {
                $hasAccess = true;
            }

            // 2. Fetch active job details (if applicable)
            $activeJobs = \App\Models\JobPost::where('employer_id', $employer->id)
                ->where('status', 'active')
                ->latest()
                ->get()
                ->map(function ($job) {
                    return [
                        'id' => $job->id,
                        'title' => $job->title,
                        'location' => $job->location,
                        'salary' => (int) $job->salary,
                        'job_type' => $job->job_type,
                        'start_date' => $job->start_date ? $job->start_date->format('Y-m-d') : null,
                        'description' => $job->description,
                        'requirements' => $job->requirements,
                        'posted_at' => $job->created_at->toIso8601String(),
                    ];
                });

            // 3. Overall Rating and Review Summary
            $reviewsQuery = \App\Models\EmployerReview::where('employer_id', $employer->id);
            $totalReviews = $reviewsQuery->count();
            $avgRating = $totalReviews > 0 ? round($reviewsQuery->avg('rating'), 1) : 0.0;

            $starsBreakdown = [
                '5' => \App\Models\EmployerReview::where('employer_id', $employer->id)->where('rating', 5)->count(),
                '4' => \App\Models\EmployerReview::where('employer_id', $employer->id)->where('rating', 4)->count(),
                '3' => \App\Models\EmployerReview::where('employer_id', $employer->id)->where('rating', 3)->count(),
                '2' => \App\Models\EmployerReview::where('employer_id', $employer->id)->where('rating', 2)->count(),
                '1' => \App\Models\EmployerReview::where('employer_id', $employer->id)->where('rating', 1)->count(),
            ];

            // 4. Paginated Reviews list
            $perPage = (int) $request->input('per_page', 10);
            $reviewsPaginator = \App\Models\EmployerReview::where('employer_id', $employer->id)
                ->with('worker')
                ->latest()
                ->paginate($perPage);

            $reviews = collect($reviewsPaginator->items())->map(function ($rev) {
                return [
                    'id' => $rev->id,
                    'rating' => $rev->rating,
                    'title' => $rev->title,
                    'comment' => $rev->comment,
                    'created_at' => $rev->created_at->toIso8601String(),
                    'worker' => $rev->worker ? [
                        'id' => $rev->worker->id,
                        'name' => $rev->worker->name,
                        'nationality' => $rev->worker->nationality,
                    ] : null,
                ];
            });

            // 5. Structure the response
            $employerData = [
                'id' => $employer->id,
                'name' => $employer->name,
                'email' => $hasAccess ? $employer->email : null,
                'phone' => $hasAccess ? ($empProfile->phone ?? $employer->phone) : null,
                'company_name' => $empProfile->company_name ?? 'Private Sponsor',
                'city' => $empProfile->city ?? null,
                'district' => $empProfile->district ?? null,
                'nationality' => $empProfile->nationality ?? null,
                'address' => $empProfile->address ?? null,
                'accommodation' => $empProfile->accommodation ?? null,
                'language' => $empProfile->language ?? null,
                'profile_photo_url' => $empProfile->profile_photo_url ?? null,
                'rating' => $avgRating,
                'reviews_count' => $totalReviews,
                'review_summary' => [
                    'total' => $totalReviews,
                    'average' => $avgRating,
                    'stars' => $starsBreakdown,
                ],
                'active_jobs' => $activeJobs,
            ];

            return response()->json([
                'success' => true,
                'data' => [
                    'employer' => $employerData,
                    'reviews' => [
                        'data' => $reviews,
                        'pagination' => [
                            'total' => $reviewsPaginator->total(),
                            'per_page' => $reviewsPaginator->perPage(),
                            'current_page' => $reviewsPaginator->currentPage(),
                            'last_page' => $reviewsPaginator->lastPage(),
                        ]
                    ]
                ]
            ], 200);

        } catch (\Exception $e) {
            logger()->error('Worker View Employer Profile Failure: ' . $e->getMessage());

            return response()->json([
                'success' => false,
                'message' => 'An error occurred while loading the employer profile.',
                'error' => app()->environment('local') ? $e->getMessage() : 'Internal Server Error'
            ], 500);
        }
    }
}