<?php

namespace App\Controllers;

use CodeIgniter\HTTP\IncomingRequest;
use CodeIgniter\HTTP\RequestInterface;
use CodeIgniter\HTTP\ResponseInterface;
use Psr\Log\LoggerInterface;
use App\Helpers\sendMailNotification;
use App\Helpers\MailHelper;

use CodeIgniter\API\ResponseTrait;

use App\Models\MessageModel;
use App\Models\UserMessageModel;
use App\Models\ClientModel;
use App\Models\PolicyTransactionModel;

use App\Models\JobModel;
use App\Models\ClientPolicyModel;
use App\Models\NotificationModel;
use App\Models\EmployeePolicyModel;
use App\Controllers\PendingActionsContrller;
use App\Controllers\EmpDataServiceController;
use App\Models\TicketMasterModel;
use App\Models\LeadsModel;
use App\Models\TicketClaimStatusModel;
use App\Models\FileModel;
use App\Models\BatchFileModel;
use App\Models\SalesActivityModel;
use App\Models\SalesActualLeadModel;


class DashboardController extends AdminController
{

    use ResponseTrait;
    protected $messageModel;
    protected $clientModel;
    protected $userMessageModel;
    protected $clientPolicyModel;
    protected $notificationModel;
    protected $employeePolicyModel;
    protected $policyTransactionModel;
    protected $leadModel;
    protected $ticketModel;
    protected $ticketStatusModel;
    protected $policyStatus;
    protected $colorShades;
    protected $claimDashLimit;
    protected $filesModel;
    protected $batchFilesModel;
    protected $leadsModel;
    protected $ticketMasterModel;
    protected $ticketClaimStatusModel;
    protected $salesActivityModel;
    protected $salesActualModel;

    protected $myLogger;

    public function __construct()
    {
        set_session_context('Dashboard');
        $this->messageModel        = new MessageModel();
        $this->userMessageModel    = new UserMessageModel();
        $this->clientPolicyModel   = new ClientPolicyModel();
        $this->notificationModel   = new NotificationModel();
        $this->employeePolicyModel = new EmployeePolicyModel();
        $this->clientModel         = new ClientModel();
        $this->policyTransactionModel         = new PolicyTransactionModel();
        $this->ticketModel = new TicketMasterModel();
        $this->leadModel = new LeadsModel();
        $this->ticketStatusModel = new TicketClaimStatusModel();
        $this->filesModel = new FileModel();
        $this->batchFilesModel = new BatchFileModel();
        $this->leadsModel = new LeadsModel();
        $this->ticketMasterModel = new TicketMasterModel();
        $this->ticketClaimStatusModel = new TicketClaimStatusModel();
        $this->salesActivityModel = new SalesActivityModel();
        $this->salesActualModel = new SalesActualLeadModel();

        $this->myLogger = \Config\Services::mylogger();

        $this->claimDashLimit = [
            1 => [
                'non_id' => 3,
                'id_not_generated' => 3,
                'cda' => 3,
                'information_required' => 3,
                'under_process' => 3,
                'rejected' => 3,
                'approved' => 3,
                'payment_initiated' => 3,
                'settled' => 3,
                'closed' => 3,
                'cancelled' => 3,
                'returned' => 3
            ],

            2 => [
                'claim_intimation' => 3,
                'intimation_to_insurer' => 3,
                'client_pending' => 3,
                'insurer_pending' => 3,
                'investigation' => 3,
                'approved' => 3,
                'closed' => 3,
                'not_covered' => 3,
                'settled' => 3,
                'coverage_check' => 3,
                'cancelled' => 3,
                'returned' => 3,
                'rejected' => 3,
                'dv_sent_to_insured' => 3
            ],
            3   => [
                'claim_intimation' => 3,
                'intimation_to_insurer' => 3,
                'client_pending' => 3,
                'insurer_pending' => 3,
                'investigation' => 3,
                'approved' => 3,
                'closed' => 3,
                'not_covered' => 3,
                'settled' => 3,
                'coverage_check' => 3,
                'cancelled' => 3,
                'returned' => 3,
                'rejected' => 3
            ],
            4 => [
                'claim_intimation' => 3,
                'intimation_to_insurer' => 3,
                'client_pending' => 3,
                'insurer_pending' => 3,
                'investigation' => 3,
                'approved' => 3,
                'closed' => 3,
                'not_covered' => 3,
                'settled' => 3,
                'coverage_check' => 3,
                'cancelled' => 3,
                'returned' => 3,
                'rejected' => 3
            ]
        ];

        $this->policyStatus = [
            'under_process' => 'Under Process',
            'client_pending' => 'Client Pending',
            'insurer_pending' => 'Insurer Pending',
            'co_insurer_pending' => 'Co-Insurer Pending',
            'tpa_pending' => 'TPA Pending',
            'validated' => 'Validated',
            'cancelled' => 'Cancelled',
            'instalment_pending' => 'Instalment Pending',
            'completed' => 'Completed',
        ];

        $this->colorShades = [

            [
                'linear-gradient(45deg, #66e9eb, #5cc7d2)', // Lighter shade 1
                'linear-gradient(45deg, #4ce2e5, #45bcc9)', // Lighter shade 2
                'linear-gradient(45deg, #33dbe0, #2baebd)', // Original shade (slightly lighter)
                'linear-gradient(45deg, #00d6db, #00a8b5)', // Original
                'linear-gradient(45deg, #00bfc4, #00929f)', // Darker shade 1
                'linear-gradient(45deg, #009ea1, #00767a)'  // Darker shade 2
            ],
            // Shades for Grenadier
            [
                'linear-gradient(45deg, #ff9d37, #ff7a10)', // Grenadier shade 1
                'linear-gradient(45deg, #ff8b30, #ff7310)', // Grenadier shade 2
                'linear-gradient(45deg, #ff8020, #ff5a00)', // Grenadier shade 3
                'linear-gradient(45deg, #f06d15, #e05505)', // Grenadier shade 4
                'linear-gradient(45deg, #d85f10, #c04805)', // Grenadier shade 5
                'linear-gradient(45deg, #b85606, #a04605)'  // Grenadier shade 6
            ],
            // Shades for SilverChalice
            [
                'linear-gradient(45deg, #a3a8a8, #8f9494)', // SilverChalice shade 1
                'linear-gradient(45deg, #989d9d, #848989)', // SilverChalice shade 2
                'linear-gradient(45deg, #7e8484, #686e6e)', // SilverChalice shade 3
                'linear-gradient(45deg, #6c7676, #545e5e)', // SilverChalice shade 4
                'linear-gradient(45deg, #5c6363, #434949)', // SilverChalice shade 5
                'linear-gradient(45deg, #494f4f, #353d3d)'  // SilverChalice shade 6
            ]
        ];
    }

    public function dashboard()
    {

        $data = [];

        if (in_array(get_role_id(), [1, 2, 3, 5]) || (in_array(MANAGEMENT_TEAM_ID, user_team()) || in_array(FINANCE_TEAM_ID, user_team()) || in_array(BUSINESS_TEAM_ID, user_team()))) {

            $db = db_connect();
            $sql = "SELECT 
                    clients.id AS client_id, 
                    clients.client_name, 
                    clients.short_name,
                    client_branch.id AS client_branch_id, 
                    client_branch.branch_name, 
                    client_branch.branch_code,
                    
                    COUNT(employees.id) AS total_employees,  
                    SUM(CASE WHEN employees.emp_status = 'draft' THEN 1 ELSE 0 END) AS draft_count,  
                    SUM(CASE WHEN employees.emp_status IN ('enrolled', 'active') THEN 1 ELSE 0 END) AS enrolled_count,  

                    SUM(CASE WHEN auth_history.user_id IS NOT NULL THEN 1 ELSE 0 END) AS logged_in_count,  
                    SUM(CASE WHEN auth_history.user_id IS NULL THEN 1 ELSE 0 END) AS not_logged_in_count,

                    CASE 
                        WHEN EXISTS (
                            SELECT 1 FROM client_policy 
                            WHERE client_policy.client_branch_id = client_branch.id 
                            AND client_policy.is_active = 1 
                            AND client_policy.open_for_enrollment = 1
                        ) THEN 1 
                        ELSE 0 
                    END AS open_or_close_enrollment  

                FROM clients
                LEFT JOIN client_branch ON clients.id = client_branch.client_id
                LEFT JOIN employees ON client_branch.id = employees.client_branch_id
                LEFT JOIN (
                    SELECT user_id, user_type 
                    FROM auth_history 
                    WHERE user_type = 'employee' 
                    GROUP BY user_id
                ) AS auth_history ON employees.id = auth_history.user_id

                WHERE employees.relationship = 'Self'
                AND employees.emp_status IN ('draft', 'enrolled', 'active')
                AND employees.is_active = 1
                AND clients.is_active = 1
                AND client_branch.is_active = 1

                GROUP BY clients.id, client_branch.id";

            $query = $db->query($sql);
            $results = $query->getResultArray();

            $pendingActionsController = new PendingActionsController;
            $pendingActionsData = $pendingActionsController->getPendingActionsForDashBoard();

            //BDS dashboard data
            // $businessTeamData = $this->policyTransactionModel->getBusinessReportList();
            // $financeTeamData = $this->policyTransactionModel->getFinanceReportList();
            // $businessTeamStatusData = $this->data_construct_for_bds($businessTeamData);
            // $financeTeamStatusData = $this->data_construct_for_bds($financeTeamData);
            $businessTeamData = [];
            $financeTeamData = [];
            $businessTeamStatusData = [];
            $financeTeamStatusData = [];

            $data['client_branch_emp_list'] = $results;
            $session = \Config\Services::session();
            // $session->set('enrollment_data', json_encode($data));

            $data['pendingActionsData'] = $pendingActionsData;
            $data['businessTeamCount'] = count($businessTeamData) ?? 0;
            $data['financeTeamCount'] = count($financeTeamData) ?? 0;
            $data['businessTeamStatusData'] = $businessTeamStatusData;
            $data['financeTeamStatusData'] = $financeTeamStatusData;
            $data['policyStatus'] =  $this->policyStatus;
            $data['colorShades'] =  $this->colorShades;
        }
        if ((get_role_id() == STAFF_ROLE_ID && in_array(CLAIMS_TEAM_ID,user_team())) || in_array(get_role_id(),[1,5])){
            $data['claim_data'] = $this->getClaimData();
            $data['colorShades'] =  $this->colorShades;

        }
        if ((get_role_id() == STAFF_ROLE_ID && in_array(ENROLLMENT_TEAM_ID,user_team())) || in_array(get_role_id(),[1,5])){
            $data['lead_data'] = $this->leadModel->getDashData();
            $data['bds_renewal'] = $this->policyTransactionModel->getBDSRenewalData();
            $data['colorShades'] =  $this->colorShades;

        }

        // dd(get_role_id(),user_team());
        // dd($data);
        $data['tab_name'] = 'Dashboard';
        $data['page_name'] = 'Dashboard';

        echo view('layout/header',  $data);
        echo view('DashBoard', $data);
        echo view('layout/footer');
    }


    public function getClaimData()
    {

        $results = $this->ticketStatusModel
            ->select("ticket_type as ticket_type_id, claim_status")
            ->where("is_active", 1)
            ->findAll();

        $claim_status = [];

        foreach ($results as $row) {
            if (empty($row['ticket_type_id']) || empty($row['claim_status'])) {
                continue; // Skip if either value is empty
            }
            $typeId = $row['ticket_type_id'];
            $status = $row['claim_status'];

            // Initialize if not set
            if (!isset($claim_status[$typeId])) {
                $claim_status[$typeId] = [];
            }

            $claim_status[$typeId][$status] = true;
        }

        // Convert set-like structure to plain array
        foreach ($claim_status as $typeId => $statuses) {
            $claim_status[$typeId] = array_keys($statuses);
        }
        $data = $this->ticketModel->getDashData($claim_status, $this->claimDashLimit);


        return $data;
    }


    public function getDashboardNotifications()
    {
        // Pull notifications for the dashboard, especially for file upload cases.
        $userId = get_session_userid();
        $roleId = 5;
        $teamId = 1;

        if ($userId != null && $roleId != null && $teamId != null) {
            $messages = $this->messageModel->getMessagesForUser($userId, $roleId, $teamId);
            return $this->respond(['status' => true, 'code' => 200, 'message' => $messages], 200);
        } else {
            $this->myLogger->logme('error', 'The session is not set correctly. USER_ID : {user_id},  ROLE_ID : {role_id},  TEAM_ID : {team_id}', ['user_id' => $userId, 'role_id' => $roleId, 'team_id' => $teamId]);
            return $this->respond(['status' => false, 'code' => 404, 'message' => 'No data found'], 200);
        }
    }


    public function acknowledgeMessage($messageId)
    {
        $userId = get_session_userid();

        $this->userMessageModel->markAsRead($userId, $messageId);

        return $this->respond(['status' => 'success']);
    }


    public function updatePolicyEnrollmentStatus()
    {
        $clientPolicyModel = new ClientPolicyModel();
        $myLogger = \Config\Services::mylogger();

        $client_policy_data = $clientPolicyModel->getPolicyDetailsForEnrollment();
        $myLogger->logme('error', 'Fetched client policy data for Enrollment Status update');

        // dd($client_policy_data);

        $currentDate = date('d-m-Y');
        $openEnrollment = [];
        $closeEnrollment = [];

        // Update policy status based on start and end dates
        foreach ($client_policy_data as $client_policy) {

            $id = $client_policy['id'];
            $openDate = date('d-m-Y', strtotime($client_policy['open_date']));
            $closeDate = date('d-m-Y', strtotime($client_policy['close_date']));

            if ($currentDate == $openDate) {
                $clientPolicyModel->update($id, ['open_for_enrollment' => 1]);
                $openEnrollment[] = $id;
                $myLogger->logme('error', 'Updated policy ID ' . $id . ' to open for enrollment.');
            }

            if ($closeDate < $currentDate) {
                $clientPolicyModel->update($id, ['open_for_enrollment' => 0]);
                $closeEnrollment[] = $id;
                $myLogger->logme('error', 'Updated policy ID ' . $id . ' to close for enrollment.');
            }
        }

        $myLogger->logme('error', 'enrollment_status function completed');
        $myLogger->logme('error', 'updated Open Enrollment Policy count : "' . count($openEnrollment) . '" and Close Enrollment Policy count : "' . count($closeEnrollment) . '"');

        return $this->respond([
            'status' => true,
            'message' => 'updated Open and Close Enrollment successfully',
            'open_policy_count' => count($openEnrollment),
            'close_policy_count'  => count($closeEnrollment),
            'open_policy_ids' => $openEnrollment,
            'close_policy_ids'  => $closeEnrollment,
        ]);
    }

    public function sendCroneRemainderMail()
    {
        $clientPolicyModel = new ClientPolicyModel();
        $myLogger = \Config\Services::mylogger();


        $client_policy_data = $clientPolicyModel->getPolicyDetailsForRemainder();
        $myLogger->logme('error', 'Fetched client policy data');
        // dd($client_policy_data);    

        // Mail send function 
        $result =  $this->sendRemainderMail($client_policy_data, 'crone');

        $myLogger->logme('error', 'sendCroneRemainderMail function completed');

        if ($result) {
            return json_encode(['status' => true,  'message' => 'Mail send successfully']);
        } else {
            return json_encode(['status' => false, 'message' => 'There is no data to send']);
        }
    }

    public function featch_dashboard_data($type)
    {
        $pendingActionsController = new PendingActionsController;
        $pendingActionsData = $pendingActionsController->getPendingActionsForClientData();

        $data = [];

        if ($type == 'insurer') {

            $data = $pendingActionsData['uhid'];
        } else if ($type == 'TPA') {
            $data = $pendingActionsData['tpa'];
        } else if ($type == 'I') {
            $data = $pendingActionsData['inception'];
        } else if ($type == 'D') {
            $data = $pendingActionsData['deletion'];
        } else if ($type == 'C') {
            $data = $pendingActionsData['correction'];
        } else if ($type == 'SI') {
            $data = $pendingActionsData['si_enhancement'];
        } else if ($type == 'policy') {
            $data = $pendingActionsData['policy'];
        } else if ($type == 'ticket') {
            $data = $pendingActionsData['uhid'];
        }

        return $this->respond(['status' => true, 'data' => $data], 200);
    }

    public function sendRemainderMail($client_policy_data, $send_mail_for_manual_or_crone = null)
    {
        // $this->myLogger->logme('error', 'sendRemainderMail function called');    

        // dd($client_policy_data, $send_mail_for_manual_or_crone);

        $reminder_whole_mail = [];

        foreach ($client_policy_data as $client_policy) {

            // Fetch client data
            $client_data = $this->clientModel->find((int)$client_policy['client_id']);

            // Fetch notification settings
            $notification_data = $this->notificationModel
                ->where('client_id', $client_policy['client_id'])
                ->where('template_name', 'member_reminder_mail')
                ->first();

            if ($notification_data && $notification_data['enabled'] == 1 && !empty($notification_data['mail_content'])) {

                //manaual
                if (empty($send_mail_for_manual_or_crone)) {

                    // Check if notification should be sent
                    $this->myLogger->logme('error', 'Notification should be sent for client policy ID: ' . $client_policy['id']);

                    $employees = [];
                    if (in_array($client_policy['policy_type_id'], [2, 4]) || ($client_policy['policy_type_id'] == 3 && $client_policy['is_addon'] == 1)) {

                        // Fetch all employees related to the client policy
                        $employees = $this->employeePolicyModel
                            ->select('employees.*, employee_polices.id as emp_policy_id')
                            ->join('employees', 'employee_polices.employee_id = employees.id', 'left')
                            ->where('employee_polices.client_policy_id', $client_policy['id'])
                            ->where('employees.is_active', 1)
                            ->where('employee_polices.is_active', 1)
                            ->where('employees.emp_status', 'draft')
                            ->where('employee_polices.status', 'draft')
                            ->where('employees.relationship', 'Self')
                            ->where("employees.email_corporate IS NOT NULL AND employees.email_corporate != ''")
                            ->findAll();

                        // dd($employees, 'first');

                    } else if (($client_policy['policy_type_id'] == 3 && $client_policy['is_addon'] == 3) || $client_policy['policy_type_id'] == 5) {

                        $empDependentData = $this->employeePolicyModel
                            ->select('employees.*, employee_polices.id as emp_policy_id')
                            ->join('employees', 'employee_polices.employee_id = employees.id', 'left')
                            ->where('employee_polices.client_policy_id', $client_policy['id'])
                            ->where('employees.is_active', 1)
                            ->where('employee_polices.is_active', 1)
                            ->where('employees.emp_status', 'draft')
                            ->where('employee_polices.status', 'draft')
                            ->where('employees.relationship !=', 'Self')
                            ->findAll();

                        $empCodes = array_column($empDependentData, 'emp_code');

                        // dd($empDependentData, $empCodes,'second');

                        if (!empty($empCodes)) {

                            $empSelfData = $this->employeePolicyModel
                                ->select('employees.*, employee_polices.id as emp_policy_id')
                                ->join('employees', 'employee_polices.employee_id = employees.id', 'left')
                                ->whereIn('employees.emp_code', $empCodes)
                                ->where('employees.is_active', 1)
                                ->where('employee_polices.is_active', 1)
                                ->where('employees.relationship', 'Self')
                                ->where("employees.email_corporate IS NOT NULL AND employees.email_corporate != ''")
                                ->findAll();

                            $employees = array_merge($employees, $empSelfData);
                        }
                    }

                    // dd($employees);

                    // Process each employee
                    if (!empty($employees) && count($employees) > 0) {

                        foreach ($employees as $employee) {

                            $this->myLogger->logme('error', 'Employee status and relationship check passed for employee ID: ' . $employee['id']);

                            // Mail params
                            $params['emp_data'] = $employee;
                            $params['client_data'] = $client_data;
                            $params['notification_data'] = $notification_data;
                            $params['common'] = [
                                'client_id' => $client_policy['client_id'],
                                'client_branch_id' => $client_policy['client_branch_id'],
                                'client_policy_id' => $client_policy['id'],
                                'employee_policy_id' => $employee['emp_policy_id'],
                                'employee_id' => $employee['id'],
                                'mail_type' => 'member_reminder_mail',
                            ];

                            // Send the mail notification
                            $mail_result = sendMailNotification::sendMailNotification('member_reminder_mail', $params);
                            // dd($mail_result);
                            // $this->myLogger->logme('error', 'Mail sent result: ' . json_encode($mail_result));
                            $reminder_whole_mail[] = $mail_result;
                        }
                    }
                } else { // crone

                    if (!empty($client_policy['reminder_date'])) {

                        $currentDate = date('d');
                        $remainder_dates = explode(",", $client_policy['reminder_date']);

                        foreach ($remainder_dates as $date) {

                            if ($currentDate == $date) {

                                $this->myLogger->logme('error', 'Notification should be sent for client policy ID: ' . $client_policy['id']);

                                // Fetch all employees related to the client policy
                                $employees = [];
                                if (in_array($client_policy['policy_type_id'], [2, 4]) || ($client_policy['policy_type_id'] == 3 && $client_policy['is_addon'] == 1)) {

                                    $employees = $this->employeePolicyModel
                                        ->select('employees.*, employee_polices.id as emp_policy_id')
                                        ->join('employees', 'employee_polices.employee_id = employees.id', 'left')
                                        ->where('employee_polices.client_policy_id', $client_policy['id'])
                                        ->where('employees.is_active', 1)
                                        ->where('employee_polices.is_active', 1)
                                        ->where('employees.emp_status', 'draft')
                                        ->where('employee_polices.status', 'draft')
                                        ->where('employees.relationship', 'Self')
                                        ->where("employees.email_corporate IS NOT NULL AND employees.email_corporate != ''")
                                        ->findAll();

                                    // dd($employees, 'first');

                                } else if (($client_policy['policy_type_id'] == 3 && $client_policy['is_addon'] == 3) || $client_policy['policy_type_id'] == 5) {

                                    $empDependentData = $this->employeePolicyModel
                                        ->select('employees.*, employee_polices.id as emp_policy_id')
                                        ->join('employees', 'employee_polices.employee_id = employees.id', 'left')
                                        ->where('employee_polices.client_policy_id', $client_policy['id'])
                                        ->where('employees.is_active', 1)
                                        ->where('employee_polices.is_active', 1)
                                        ->where('employees.emp_status', 'draft')
                                        ->where('employee_polices.status', 'draft')
                                        ->where('employees.relationship !=', 'Self')
                                        ->findAll();

                                    $empCodes = array_column($empDependentData, 'emp_code');

                                    // dd($empDependentData, $empCodes,'second');

                                    if (!empty($empCodes)) {

                                        $empSelfData = $this->employeePolicyModel
                                            ->select('employees.*, employee_polices.id as emp_policy_id')
                                            ->join('employees', 'employee_polices.employee_id = employees.id', 'left')
                                            ->whereIn('employees.emp_code', $empCodes)
                                            ->where('employees.is_active', 1)
                                            ->where('employee_polices.is_active', 1)
                                            ->where('employees.relationship', 'Self')
                                            ->where("employees.email_corporate IS NOT NULL AND employees.email_corporate != ''")
                                            ->findAll();

                                        $employees = array_merge($employees, $empSelfData);
                                    }
                                }

                                // dd($employees);

                                // Process each employee
                                foreach ($employees as $employee) {

                                    $this->myLogger->logme('error', 'Employee status and relationship check passed for employee ID: ' . $employee['id']);

                                    // Mail params
                                    $params['emp_data'] = $employee;
                                    $params['client_data'] = $client_data;
                                    $params['notification_data'] = $notification_data;
                                    $params['common'] = [
                                        'client_id' => $client_policy['client_id'],
                                        'client_branch_id' => $client_policy['client_branch_id'],
                                        'client_policy_id' => $client_policy['id'],
                                        'employee_policy_id' => $employee['emp_policy_id'],
                                        'employee_id' => $employee['id'],
                                        'mail_type' => 'member_reminder_mail',
                                    ];

                                    // Send the mail notification
                                    $mail_result = sendMailNotification::sendMailNotification('member_reminder_mail', $params);
                                    // $this->myLogger->logme('error', 'Mail sent result: ' . json_encode($mail_result));
                                    $reminder_whole_mail[] = $mail_result;
                                }
                            }
                        }
                    } else {
                        $this->myLogger->logme('error', "SEND REMAINDER CRONE ---  Remainder date is empty()");
                    }
                }
            } else {

                $this->myLogger->logme('error', 'Notification setup not found or not enabled');
                $this->myLogger->logme('error', 'Notification was not sent for this Client ID: ' . $client_policy['client_id']);
            }
        }

        // dd($reminder_whole_mail);
        // print_rr($reminder_whole_mail); die;

        // Process and queue bulk emails
        if (!empty($reminder_whole_mail) && count($reminder_whole_mail) > 0) {

            $reminder_whole_mail = array_chunk($reminder_whole_mail, 20);
            foreach ($reminder_whole_mail as $key => $value) {
                // $job_details  = new Jobs();
                $r = Jobs::addJob(['job_name' => 'bulk_mail', 'payload' => $value]);
            }
        }

        if (count($reminder_whole_mail) > 0) {
            return true;
        } else {
            return false;
        }
    }

    public function sendManualReminder($client_id, $client_branch_id, $client_policy_id = null)
    {
        $this->myLogger->logme('error', 'Log Works');

        $this->myLogger->logme('error', "sendManualRemainder called with client_id: {$client_id}, client_branch_id: {$client_branch_id}");

        $client_policy_data = $this->clientPolicyModel->getPolicyDetailsForRemainder($client_id, $client_branch_id, $client_policy_id);
        // print_r($client_policy_data); die;
        // print_r($this->clientPolicyModel->getLastQuery()); die;
        // $this->myLogger->logme('error', "Policy details fetched: " . json_encode($client_policy_data));

        if ($client_policy_data) {
            $result = $this->sendRemainderMail($client_policy_data);
            log_message('error', json_encode($result));
            $this->myLogger->logme('error', $result);
            $this->myLogger->logme('error', "Manual Remainder Mail sending result: " . ($result ? 'success' : 'failure'));

            if ($result) {
                $this->myLogger->logme('error', 'Manual Remainder Mail sent successfully');
                return $this->respond(['status' => true, 'code' => 200, 'message' => 'Mail sent successfully'], 200);
            } else {
                $this->myLogger->logme('error', 'Failed to send manual remainder mail, no data to send');
                return $this->respond(['status' => false, 'code' => 200, 'message' => 'There is no data to send', 'message2' => 'Failed'], 200);
            }
        } else {
            $this->myLogger->logme('error', 'No policy data found to send');
            return $this->respond(['status' => false, 'code' => 200, 'message' => 'There is no data to send', 'message2' => 'No policy data found to send'], 200);
        }
    }

    public function sendManualEcard($client_id, $client_branch_id, $policy_id)
    {
        $this->myLogger->logme('error', "sendManualEcard called with client_id: {$client_id}, client_branch_id: {$client_branch_id}, policy id : {$policy_id}");

        $notification = $this->notificationModel->where('client_id', $client_id)->where('template_name', 'member_ecard_mail')->first();
        // print_r(($notification)); die;
        if ($notification && $notification['enabled'] == 0 && $notification['mail_content'] == '') {
            return $this->respond(['status' => false, 'code' => 400, 'message' => 'No template found', 'message2' => 'Failed'], 200);
        }

        $emp_data = $this->employeePolicyModel->getEmployeePolicyForEcard($policy_id);
        if (count($emp_data) == 0) {
            return $this->respond(['status' => false, 'code' => 400, 'message' => 'No employees found', 'message2' => 'Failed'], 200);
        }
        $ids = array_column($emp_data, 'id');


        $client_policy_data = $this->clientPolicyModel->where('id', $policy_id)->first();
        $sendMail = false;

        if ($client_policy_data['policy_type_id'] == 3 && $client_policy_data['is_addon'] == 3) {
            $sendMail = true;
        } else {
            $relationships = array_column($emp_data, 'relationship');
            if (in_array('Self', $relationships)) {
                $sendMail = true;
            }
        }
        
        if ($sendMail) {
            $message = 'Mail Queued';
            Jobs::addJob(['job_name' => 'sendMailForDownloadingECard','payload' => ['ids' => $ids,'client_policy_id' => $policy_id]]);
            $this->myLogger->logme('error', 'sendManualEcard - Mail Queued');
        } else {
            $message = 'E-card has already been sent to those employees.';
            $this->myLogger->logme('error', 'sendManualEcard - E-card has already been sent to those employees.');
        }

        // print_r(($ids)); die;
        // print_r($this->clientPolicyModel->getLastQuery()); die;
        // $this->myLogger->logme('error', "Policy details fetched: " . json_encode($client_policy_data));
        // Jobs::addJob(['job_name' => 'sendMailForDownloadingECard', 'payload' => ['ids' => $ids, 'client_policy_id' => $policy_id]]);
        // $empEmpDataServiceController = new EmpDataServiceController();
        // $empEmpDataServiceController->sendMailForDownloadingECard($ids);


        return $this->respond(['status' => true, 'code' => 200, 'message' => $message], 200);
    }

    public function data_construct_for_bds($data)
    {

        $groupedData = [
            'under_process' => [],
            'client_pending' => [],
            'insurer_pending' => [],
            'co_insurer_pending' => [],
            'tpa_pending' => [],
            'validated' => [],
            'cancelled' => [],
            'instalment_pending' => [],
        ];

        // Loop through results and group them by their status
        foreach ($data as $row) {
            switch ($row['status']) {
                case 'completed':
                    $groupedData['completed'][] = $row;
                    break;
                case 'cancelled':
                    $groupedData['cancelled'][] = $row;
                    break;
                case 'client_pending':
                    $groupedData['client_pending'][] = $row;
                    break;
                case 'insurer_pending':
                    $groupedData['insurer_pending'][] = $row;
                    break;
                case 'co_insurer_pending':
                    $groupedData['co_insurer_pending'][] = $row;
                    break;
                case 'tpa_pending':
                    $groupedData['tpa_pending'][] = $row;
                    break;
                case 'validated':
                    $groupedData['validated'][] = $row;
                    break;
                case 'instalment_pending':
                    $groupedData['instalment_pending'][] = $row;
                    break;
                case 'under_process':
                    $groupedData['under_process'][] = $row;
                    break;
                default:
                    break;
            }
        }
        return $groupedData;
    }

    public function prepareClaimSearchData()
    {

        $received_data = $this->request->getPost();
        $ticketTypeId = $received_data['ticketTypeId'];
        $status = $received_data['status'];

        $status = strtoupper($status);
        $status = str_replace('_', ' ', $status);

        $data = $this->ticketModel
            ->select("tcs.id as claim_status_id")
            ->join("ticket_claim_status tcs", "tcs.ticket_type = " . (int)$ticketTypeId)
            ->where("tcs.claim_status", $status)
            ->first();
        $data['ticket_type_id'] = $ticketTypeId;
        return $this->respond(['status' => "success", "data" => $data], 200);
    }

    public function croneDailyActivityReport()
    {

        // $today = date('Y-m-d');
        $today = date('Y-m-d', strtotime('-1 day'));

        // Inception & endorsement counts (file uploads)
        $total_inception_count = $this->filesModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->where('action', 'inception')
            ->where('status', 'success')
            ->countAllResults();

        $total_endorsement_count = $this->filesModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->where('action !=', 'inception')
            ->where('status', 'success')
            ->countAllResults();

        // TPA & Insurer batch file counts
        $total_tpa_incetion_count = $this->batchFilesModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->where('event_type', 'inception')
            ->where('insurer_or_tpa', 'tpa')
            ->where('status', 'success')
            ->countAllResults();

        $total_tpa_endorsement_count = $this->batchFilesModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->where('event_type !=', 'inception')
            ->where('insurer_or_tpa', 'tpa')
            ->where('status', 'success')
            ->countAllResults();

        $total_insurer_incetion_count = $this->batchFilesModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->where('event_type', 'inception')
            ->where('insurer_or_tpa', 'insurer')
            ->where('status', 'success')
            ->countAllResults();

        $total_insurer_endorsement_count = $this->batchFilesModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->where('event_type !=', 'inception')
            ->where('insurer_or_tpa', 'insurer')
            ->where('status', 'success')
            ->countAllResults();

        // Claim counts
        $total_claim_count = $this->ticketMasterModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->countAllResults();

        $total_gmc_status_wise_claim_count = $this->ticketMasterModel
            ->select('tcs.claim_status, count(*) as count')
            ->join('ticket_claim_status tcs', 'tcs.id = ticket_master.claim_status_id', 'left')
            ->where('ticket_master.is_active', 1)
            ->where('ticket_master.ticket_type_id', 1)
            // ->where('DATE(ticket_master.created_at)', $today)
            ->where('tcs.is_active', 1)
            ->groupBy('tcs.claim_status')
            ->findAll();

        $total_gpa_status_wise_claim_count = $this->ticketMasterModel
            ->select('tcs.claim_status, count(*) as count')
            ->join('ticket_claim_status tcs', 'tcs.id = ticket_master.claim_status_id', 'left')
            ->where('ticket_master.is_active', 1)
            ->where('ticket_master.ticket_type_id', 2)
            // ->where('DATE(ticket_master.created_at)', $today)
            ->where('tcs.is_active', 1)
            ->groupBy('tcs.claim_status')
            ->findAll();

        $total_edli_status_wise_claim_count = $this->ticketMasterModel
            ->select('tcs.claim_status, count(*) as count')
            ->join('ticket_claim_status tcs', 'tcs.id = ticket_master.claim_status_id', 'left')
            ->where('ticket_master.is_active', 1)
            ->where('ticket_master.ticket_type_id', 3)
            // ->where('DATE(ticket_master.created_at)', $today)
            ->where('tcs.is_active', 1)
            ->groupBy('tcs.claim_status')
            ->findAll();

        $total_gtli_status_wise_claim_count = $this->ticketMasterModel
            ->select('tcs.claim_status, count(*) as count')
            ->join('ticket_claim_status tcs', 'tcs.id = ticket_master.claim_status_id', 'left')
            ->where('ticket_master.is_active', 1)
            ->where('ticket_master.ticket_type_id', 4)
            // ->where('DATE(ticket_master.created_at)', $today)
            ->where('tcs.is_active', 1)
            ->groupBy('tcs.claim_status')
            ->findAll();

        // Sales / lead counts
        $total_opportunity_count = $this->leadsModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->countAllResults();

        $total_rfq_created_count = $this->leadsModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->where('status', 'rfq_created')
            ->countAllResults();

        $total_rfq_insurer_send_count = $this->leadsModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->where('status', 'rfq_sent')
            ->countAllResults();

        $total_qcr_created_count = $this->leadsModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->where('status', 'qcr_created')
            ->countAllResults();

        $total_qcr_client_send_count = $this->leadsModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->where('status', 'qcr_sent')
            ->countAllResults();

        $total_placement_count = $this->leadsModel
            ->where('is_active', 1)
            ->where('DATE(created_at)', $today)
            ->where('status', 'won')
            ->countAllResults();

        $total_activity_count = $this->salesActivityModel
            ->where('DATE(created_at)', $today)
            ->countAllResults();

        $total_lead_count = $this->salesActualModel
            ->where('DATE(created_at)', $today)
            ->countAllResults();

        $total_bds_count = $this->policyTransactionModel
            ->select('pt_co_share_details.*')
            ->join('pt_co_share_details', 'policy_transaction.id = pt_co_share_details.pt_id')
            ->where('DATE(policy_transaction.created_at)', $today)
            ->where('pt_co_share_details.is_active', 1)
            ->where('policy_transaction.is_active', 1)
            ->countAllResults();

        $total_bds_policy_wise_count = $this->policyTransactionModel
            ->select('pt_co_share_details.*')
            ->join('pt_co_share_details', 'policy_transaction.id = pt_co_share_details.pt_id')
            ->where('DATE(policy_transaction.created_at)', $today)
            ->where('pt_co_share_details.is_active', 1)
            ->where('policy_transaction.action_type', 'inception')
            ->where('policy_transaction.is_active', 1)
            ->countAllResults();


        $total_bds_endorsement_wise_count = $this->policyTransactionModel
            ->select('pt_co_share_details.*')
            ->join('pt_co_share_details', 'policy_transaction.id = pt_co_share_details.pt_id')
            ->where('DATE(policy_transaction.created_at)', $today)
            ->where('pt_co_share_details.is_active', 1)
            ->where('policy_transaction.action_type !=', 'inception')
            ->where('policy_transaction.is_active', 1)
            ->countAllResults();

        $total_bds_policy_type_wise_count = $this->policyTransactionModel
            ->select('policy_type.policy_type, count(*) as count')
            ->join('pt_co_share_details', 'policy_transaction.id = pt_co_share_details.pt_id')
            ->join('policy_type', 'policy_transaction.policy_type_id = policy_type.id')
            ->where('DATE(policy_transaction.created_at)', $today)
            ->where('pt_co_share_details.is_active', 1)
            ->where('policy_transaction.is_active', 1)
            ->groupBy('policy_transaction.policy_type_id')
            ->findAll();

        // Connect Pre DB for Employee Enrollment Count

        $db2 = \Config\Database::connect('preDB');

        $total_employee_draft_count = $db2->table('employee_polices')
            ->join('employees', 'employees.id = employee_polices.employee_id')
            ->where('DATE(employee_polices.created_at)', $today)
            ->where('employee_polices.is_active', 1)
            ->where('employees.is_active', 1)
            ->where('employee_polices.status', 'draft')
            ->countAllResults();

        $total_employee_enrolled_count = $db2->table('employee_polices')
            ->join('employees', 'employees.id = employee_polices.employee_id')
            ->where('DATE(employee_polices.created_at)', $today)
            ->where('employee_polices.is_active', 1)
            ->where('employees.is_active', 1)
            ->where('employee_polices.status', 'enrolled')
            ->countAllResults();

        $total_open_for_enrollemnt_policy_count = $db2->table('client_policy')
            ->where('open_date <=', $today)
            ->where('close_date >=', $today)
            ->where('is_active', 1)
            ->where('policy_status', 1)
            ->countAllResults();

        $data = [
            'total_inception_count' => $total_inception_count,
            'total_endorsement_count' => $total_endorsement_count,
            'total_tpa_incetion_count' => $total_tpa_incetion_count,
            'total_tpa_endorsement_count' => $total_tpa_endorsement_count,
            'total_insurer_incetion_count' => $total_insurer_incetion_count,
            'total_insurer_endorsement_count' => $total_insurer_endorsement_count,
            'total_claim_count' => $total_claim_count,
            'total_gmc_status_wise_claim_count' => $total_gmc_status_wise_claim_count,
            'total_gpa_status_wise_claim_count' => $total_gpa_status_wise_claim_count,
            'total_edli_status_wise_claim_count' => $total_edli_status_wise_claim_count,
            'total_gtli_status_wise_claim_count' => $total_gtli_status_wise_claim_count,
            'total_opportunity_count' => $total_opportunity_count,
            'total_rfq_created_count' => $total_rfq_created_count,
            'total_rfq_insurer_send_count' => $total_rfq_insurer_send_count,
            'total_qcr_created_count' => $total_qcr_created_count,
            'total_qcr_client_send_count' => $total_qcr_client_send_count,
            'total_placement_count' => $total_placement_count,
            'total_activity_count' => $total_activity_count,
            'total_lead_count' => $total_lead_count,
            'total_bds_count' => $total_bds_count,
            'total_bds_policy_wise_count' => $total_bds_policy_wise_count,
            'total_bds_endorsement_wise_count' => $total_bds_endorsement_wise_count,
            'total_bds_policy_type_wise_count' => $total_bds_policy_type_wise_count,
            'total_employee_draft_count' => $total_employee_draft_count,
            'total_employee_enrolled_count' => $total_employee_enrolled_count,
            'total_open_for_enrollemnt_policy_count' => $total_open_for_enrollemnt_policy_count,
        ];

        // dd($data);

        $today = date('d-m-Y', strtotime($today));
        $data['today'] = $today;

        // Render the HTML email using the dedicated view
        $message = view('daily_report_email_template', $data);
        // return $message;

        // Recipients: prefer dedicated env, fallback to BDS report emails if not set
        $emailList = getenv('activity.dailyReportEmails') ?: getenv('bds.dailyReportEmails') ?: '';
        $recipientEmails = array_filter(array_map('trim', explode(',', $emailList)));

        if (empty($recipientEmails)) {
            $this->myLogger->logme('error', 'croneDailyActivityReport: No recipients configured (set activity.dailyReportEmails in .env).');
            return $this->respond([
                'status' => 'success',
                'message' => 'Daily activity data prepared but no recipients configured.',
                'data' => $data,
            ], 200);
        }

        $subject = "Daily Activity Report - {$today}";

        $res = MailHelper::send_email([
            'mail' => $recipientEmails,
            'subject' => $subject,
            'message' => $message,
        ]);

        $resDecoded = is_string($res) ? json_decode($res, true) : $res;

        if (isset($resDecoded['status']) && $resDecoded['status'] === 'success') {
            $this->myLogger->logme('error', 'croneDailyActivityReport: Report email sent to ' . count($recipientEmails) . ' recipients');
            return $this->respond([
                'status' => true,
                'message' => 'Daily activity report emailed successfully.',
                'recipients' => count($recipientEmails),
            ], 200);
        }

        $this->myLogger->logme('error', 'croneDailyActivityReport: Email send failed - ' . json_encode($resDecoded));
        return $this->respond([
            'status' => false,
            'message' => 'Daily activity data prepared but email send failed.',
            'data' => $data,
        ], 500);
    }

}