<?php

namespace App\Controllers;

use CodeIgniter\RESTful\ResourceController;
use App\Models\RoleMasterModel;
use App\Models\VehicleTypeMasterModel;
use App\Models\InsurancePlanTypeMasterModel;
use App\Models\ClaimTypeModel;
use App\Models\EndorsementTypeModel;
use App\Models\InsurersModel;
use App\Models\StaffModel;
use App\Models\PartnerBrokerModel;
use App\Models\PaymentModeModel;
use App\Models\PartnerPosModel;


class MasterController extends ResourceController
{
    protected $format    = 'json';
    protected $myLogger;
    protected $RoleMasterModel;
    protected $VehicleTypeMasterModel;
    protected $InsurancePlanTypeMasterModel;
    protected $ClaimTypeModel;
    protected $EndorsementTypeModel;
    protected $InsurersModel;
    protected $StaffModel;
    protected $PartnerBrokerModel;
    protected $PaymentModeModel;
    protected $PartnerPosModel;
   

    public function __construct()
    {
        $this->myLogger = \Config\Services::mylogger();
        $this->RoleMasterModel = new RoleMasterModel();
        $this->VehicleTypeMasterModel = new VehicleTypeMasterModel();
        $this->InsurancePlanTypeMasterModel = new InsurancePlanTypeMasterModel();
        $this->ClaimTypeModel = new ClaimTypeModel();
        $this->EndorsementTypeModel = new EndorsementTypeModel();
        $this->InsurersModel = new InsurersModel();
        $this->StaffModel = new StaffModel();
        $this->PartnerBrokerModel = new PartnerBrokerModel();
        $this->PaymentModeModel = new PaymentModeModel();
        $this->PartnerPosModel = new PartnerPosModel();
       
    }

    public function app_test()
    {

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


    public function getRoleMaster()
    {
        $data = $this->RoleMasterModel->whereIn('id',[1,2,3,4])->findAll();

        if (!$data) {
            return $this->failNotFound('No data found');
        }

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


    public function getInsurancePlanTypeMaster()
    {
        $data = $this->InsurancePlanTypeMasterModel->findAll();

        if (!$data) {
            return $this->failNotFound('No data found');
        }

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

    public function getClaimMaster()
    {
        $data = $this->ClaimTypeModel->select('id,claim_type')->where('is_active',1)->findAll();

        if (!$data) {
            return $this->failNotFound('No data found');
        }

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

    public function getEndorsementMaster()
    {
        $data = $this->EndorsementTypeModel->select('id,endorsement_type')->where('is_active',1)->findAll();

        if (!$data) {
            return $this->failNotFound('No data found');
        }

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

    public function getInsurersMaster()
    {
        $data = $this->InsurersModel->select('id,name,short_name')->where('is_active',1)->where('category','general')->findAll();

        if (!$data) {
            return $this->failNotFound('No data found');
        }

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

    public function getStaffMaster()
    {
        $data = $this->StaffModel->select('id,name')->where('is_active',1)->where('role_id',2)->findAll();

        if (!$data) {
            return $this->failNotFound('No data found');
        }

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

    //Vehicle type CRUD---------------------------------------------------------------------
    public function getVehicleTypeMaster()
    {
        $data = $this->VehicleTypeMasterModel->findAll();

        if (!$data) {
            return $this->failNotFound('No data found');
        }

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

    public function createVehicleType()
    {
        $input = $this->request->getJSON(true);

        if (empty($input['vehicle_type'])) {
            return $this->response->setJSON(['status' => 404, 'message' => 'Value is required']);
        }

        // Duplicate check (case-insensitive)
        $exists = $this->VehicleTypeMasterModel
            ->where('LOWER(vehicle_type)', strtolower($input['vehicle_type']))
            // ->where('is_active', 1)
            ->first();

        if ($exists) {
            return $this->response->setJSON([
                'status' => 404,
                'message' => 'Vehicle Type already exists'
            ]);
        }

        $data = [
            'vehicle_type'  => $input['vehicle_type'],
            'is_active'     => 1,
            'created_by'    => $input['created_by'] ?? null,
        ];

        $this->VehicleTypeMasterModel->insert($data);

        return $this->response->setJSON([
            'status' => 200,
            'message' => 'Vehicle Type created successfully'
        ]);
    }

    public function updateVehicleType($id)
    {
        $input = $this->request->getJSON(true);

        if (!$this->VehicleTypeMasterModel->find((int)$id)) {
            return $this->response->setJSON(['status' => 404, 'message' => 'Record not found']);
        }

        // Duplicate name check (excluding current record)
        $checkDuplicate = $this->VehicleTypeMasterModel
            ->where('LOWER(vehicle_type)', strtolower($input['vehicle_type']))
            ->where('id !=', $id)
            // ->where('is_active', 1)
            ->first();

        if ($checkDuplicate) {
            return $this->response->setJSON([
                'status' => 404,
                'message' => 'Vehicle Type already exists'
            ]);
        }

        $data = [
            'vehicle_type'  => $input['vehicle_type'] ,
            'updated_by'    => $input['updated_by'] ?? null,
        ];

        $this->VehicleTypeMasterModel->update($id, $data);

        return $this->response->setJSON([
            'status' => 200,
            'message' => 'Vehicle Type updated successfully'
        ]);
    }

    public function updateVehicleTypeStatus($id)
    {
        $input = $this->request->getJSON(true);

        if (!isset($input['is_active'])) {
            return $this->response->setJSON([
                'status' => 404,
                'message' => 'is_active field is required'
            ]);
        }

        $record = $this->VehicleTypeMasterModel->find((int)$id);
        if (!$record) {
            return $this->response->setJSON(['status' => 404, 'message' => 'Record not found']);
        }

        $status = ($input['is_active'] == 1) ? 0 : 1;

        $this->VehicleTypeMasterModel->update((int)$id, [
            'is_active'  => $status, 
            'updated_by' => $input['updated_by'] ?? null,
        ]);

        return $this->response->setJSON([
            'status' => 200,
            'message' => 'Status updated successfully'
        ]);
    }


    //Broker CRUD---------------------------------------------------------------------------
    public function getAllBrokers()
    {
   
        $data = $this->PartnerBrokerModel->where('is_active', 1)->findAll();

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

    public function createBroker()
    {
        $input = $this->request->getJSON(true);

        if (empty($input['name'])) {
            return $this->response->setJSON(['status' => 404, 'message' => 'Value is required']);
        }

        // Duplicate check (case-insensitive)
        $exists = $this->PartnerBrokerModel
            ->where('LOWER(name)', strtolower($input['name']))
            // ->where('is_active', 1)
            ->first();

        if ($exists) {
            return $this->response->setJSON([
                'status' => 404,
                'message' => 'Broker name already exists'
            ]);
        }

        $data = [
            'name'      => $input['name'],
            'short_name'      => $input['short_name'],
            'is_active'  => 1,
            'created_by' => $input['created_by'] ?? null,
        ];

        $this->PartnerBrokerModel->insert($data);

        return $this->response->setJSON([
            'status' => 200,
            'message' => 'Broker name created successfully'
        ]);
    }

    public function updateBroker($id)
    {
        $input = $this->request->getJSON(true);

        if (!$this->PartnerBrokerModel->find((int)$id)) {
            return $this->response->setJSON(['status' => 404, 'message' => 'Record not found']);
        }

        // Duplicate name check (excluding current record)
        $checkDuplicate = $this->PartnerBrokerModel
            ->where('LOWER(name)', strtolower($input['name']))
            ->where('id !=', $id)
            // ->where('is_active', 1)
            ->first();

        if ($checkDuplicate) {
            return $this->response->setJSON([
                'status' => 404,
                'message' => 'Broker name already exists'
            ]);
        }

        $data = [
            'name'      => $input['name'] ,
            'short_name'=> $input['short_name'],
            'updated_by' => $input['updated_by'] ?? null,
        ];

        $this->PartnerBrokerModel->update($id, $data);

        return $this->response->setJSON([
            'status' => 200,
            'message' => 'Broker name updated successfully'
        ]);
    }

    public function updateBrokerStatus($id)
    {
        $input = $this->request->getJSON(true);

        if (!isset($input['is_active'])) {
            return $this->response->setJSON([
                'status' => 404,
                'message' => 'is_active field is required'
            ]);
        }

        $record = $this->PartnerBrokerModel->find((int)$id);
        if (!$record) {
            return $this->response->setJSON(['status' => 404, 'message' => 'Record not found']);
        }

        $status = ($input['is_active'] == 1) ? 0 : 1;

        $this->PartnerBrokerModel->update($id, [
            'is_active'  => $status, 
            'updated_by' => $input['updated_by'] ?? null,
        ]);

        return $this->response->setJSON([
            'status' => 200,
            'message' => 'Status updated successfully'
        ]);
    }
    //---------------------------------------------------------------------------------------


    //Payment Mode CRUD----------------------------------------------------------------------
    public function getAllPaymentModelist()
    {
        $data = $this->PaymentModeModel->where('is_active', 1)->orderBy('id', 'DESC')->findAll();

        return $this->response->setJSON(['status' => 200,'message' => 'success','data'   => $data]);
    }

    public function createPaymentMode()
    {
        $input = $this->request->getJSON(true);

        if (empty($input['value'])) {
            return $this->response->setJSON(['status' => 404, 'message' => 'Value is required']);
        }

        // Duplicate check (case-insensitive)
        $exists = $this->PaymentModeModel
            ->where('LOWER(value)', strtolower($input['value']))
            // ->where('is_active', 1)
            ->first();

        if ($exists) {
            return $this->response->setJSON([
                'status' => 404,
                'message' => 'Payment Mode already exists'
            ]);
        }

        $data = [
            'value'      => $input['value'],
            'is_active'  => 1,
            'created_by' => $input['created_by'] ?? null,
        ];

        $this->PaymentModeModel->insert($data);

        return $this->response->setJSON([
            'status' => 200,
            'message' => 'Payment mode created successfully'
        ]);
    }

    public function updatePaymentMode($id)
    {
        $input = $this->request->getJSON(true);

        if (!$this->PaymentModeModel->find((int)$id)) {
            return $this->response->setJSON(['status' => 404, 'message' => 'Record not found']);
        }

        // Duplicate name check (excluding current record)
        $checkDuplicate = $this->PaymentModeModel
            ->where('LOWER(value)', strtolower($input['value']))
            ->where('id !=', $id)
            // ->where('is_active', 1)
            ->first();

        if ($checkDuplicate) {
            return $this->response->setJSON([
                'status' => 404,
                'message' => 'Payment Mode already exists'
            ]);
        }

        $data = [
            'value'      => $input['value'] ?? null,
            'updated_by' => $input['updated_by'] ?? null,
        ];

        $this->PaymentModeModel->update($id, $data);

        return $this->response->setJSON([
            'status' => 200,
            'message' => 'Payment mode updated successfully'
        ]);
    }

    public function updatePaymentModeStatus($id)
    {
        $input = $this->request->getJSON(true);

        if (!isset($input['is_active'])) {
            return $this->response->setJSON([
                'status' => 404,
                'message' => 'is_active field is required'
            ]);
        }

        $record = $this->PaymentModeModel->find((int)$id);
        if (!$record) {
            return $this->response->setJSON(['status' => 404, 'message' => 'Record not found']);
        }

        $status = ($input['is_active'] == 1) ? 0 : 1;

        $this->PaymentModeModel->update($id, [
            'is_active'  => $status,
            'updated_by' => $input['updated_by'] ?? null,
        ]);

        return $this->response->setJSON([
            'status' => 200,
            'message' => 'Status updated successfully'
        ]);
    }
    //---------------------------------------------------------------------------------------


    //POS CRUD---------------------------------------------------------------------------
    public function getAllPOS()
    {

        $is_active = $this->request->getGet('is_active');
        $manager_id = $this->request->getGet('manager_id');

        $data = $this->PartnerPosModel->where('is_active', $is_active)->where('manager_id', $manager_id)->findAll();

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

    //---------------------------------------------------------------------------------------

    //Endorsement CRUD Copied As Per Broker CRUD line No 136 ---------------------------------
    
    public function getAllEndorsement()
    {
        $data = $this->EndorsementTypeModel->where('is_active', 1)->findAll();
        return $this->respond(['status' => 200,'message' => 'success','data' => $data]);
    }

    public function createEndorsement()
    {
        $input = $this->request->getJSON(true);

        if (empty($input['endorsement_type'])) {
            return $this->respond([
                'status'  => 404, 
                'message' => 'Endorsement type is required'
            ]);
        }

        // Duplicate check (Case-insensitive) on endorsement_type
        $exists = $this->EndorsementTypeModel
            ->where('LOWER(endorsement_type)', strtolower($input['endorsement_type']))
            // ->where('is_active', 1)
            ->first();

        if ($exists) {
            return $this->respond([
                'status'  => 404,
                'message' => 'Endorsement type already exists'
            ]);
        }

        $data = [
            'endorsement_type' => $input['endorsement_type'],
            'is_active'        => 1,
        ];

        $this->EndorsementTypeModel->insert($data);

        return $this->respond([
            'status'  => 200,
            'message' => 'Endorsement type created successfully'
        ]);
    }

    public function updateEndorsement($id)
    {
        $input = $this->request->getJSON(true);

        if (!$this->EndorsementTypeModel->find((int)$id)) {
            return $this->respond([
                'status'  => 404, 
                'message' => 'Record not found'
            ]);
        }

        // Duplicate check excluding current ID
        $checkDuplicate = $this->EndorsementTypeModel
            ->where('LOWER(endorsement_type)', strtolower($input['endorsement_type']))
            ->where('id !=', $id)
            // ->where('is_active', 1)
            ->first();

        if ($checkDuplicate) {
            return $this->respond([
                'status'  => 404,
                'message' => 'Endorsement type already exists'
            ]);
        }

        $data = [
            'endorsement_type' => $input['endorsement_type'],
        ];

        $this->EndorsementTypeModel->update($id, $data);

        return $this->respond([
            'status'  => 200,
            'message' => 'Endorsement type updated successfully'
        ]);
    }

    public function updateEndorsementStatus($id)
    {
        $input = $this->request->getJSON(true);

        if (!isset($input['is_active'])) {
            return $this->response->setJSON([
                'status' => 404,
                'message' => 'is_active field is required'
            ]);
        }

        $record = $this->EndorsementTypeModel->find((int)$id);
        if (!$record) {
            return $this->response->setJSON(['status' => 404, 'message' => 'Record not found']);
        }

        $status = ($input['is_active'] == 1) ? 0 : 1;

        $this->EndorsementTypeModel->update($id, [
            'is_active'  => $status, 
            'updated_by' => $input['updated_by'] ?? null,
        ]);

        return $this->response->setJSON([
            'status' => 200,
            'message' => 'Status updated successfully'
        ]);
    }
   
    //---------------------------------------------------------------------------------------


    public function getHistory()
    {
        $db = \Config\Database::connect();

        // -----------------------------
        // REQUEST VALIDATION
        // -----------------------------
        $tableName = $this->request->getGet('table_name');
        $pk        = $this->request->getGet('pk');

        if (!$tableName || !$pk) {
            return $this->response->setJSON([
                'status'  => 'failed',
                'message' => 'table_name and pk are required'
            ]);
        }

        // -----------------------------
        // QUERY
        // -----------------------------
        $history = $db->table('partner_audit_history pah')
            ->select("
                pah.column_name,
                pah.old_val,
                pah.new_val,
                pah.changed_on,
                ps.name AS changed_by
            ")
            ->join('partner_staff ps', 'ps.id = pah.user_id', 'left')
            ->where('pah.table_name', $tableName)
            ->where('pah.pk', $pk)
            ->orderBy('pah.changed_on', 'DESC')
            ->get()
            ->getResultArray();

        if (empty($history)) {
            return $this->response->setJSON([
                'status'  => 'success',
                'data'    => [],
                'message' => 'No audit history found'
            ]);
        }

        // -----------------------------
        // FORMAT RESPONSE (READABLE)
        // -----------------------------
        $result = [];

        foreach ($history as $row) {
            $result[] = [
                'column_name' => $row['column_name'],
                'message'     => "{$row['column_name']} data changed from "
                                . ($row['old_val'] ?? 'NULL')
                                . " to "
                                . ($row['new_val'] ?? 'NULL')
                                . " by "
                                . ($row['changed_by'] ?? 'System'),
                'changed_on'  => $row['changed_on'],
                'changed_by'  => $row['changed_by']
            ];
        }

        return $this->response->setJSON([
            'status' => 'success',
            'data'   => $result
        ]);
    }


}