430 lines
19 KiB
PHP
430 lines
19 KiB
PHP
<?php
|
|
|
|
namespace App\Controllers;
|
|
|
|
use CodeIgniter\RESTful\ResourceController;
|
|
|
|
use App\Models\AgentModel;
|
|
use App\Models\EnquiryModel;
|
|
use App\Models\QuotationModel;
|
|
use App\Models\PolicyModel;
|
|
use DateTime;
|
|
class EnquiryController extends ResourceController
|
|
{
|
|
protected $db;
|
|
protected $enquiryModel;
|
|
protected $AgentModel;
|
|
protected $QuotationModel;
|
|
protected $PolicyModel;
|
|
|
|
public function __construct()
|
|
{
|
|
|
|
$this->db = db_connect();
|
|
$this->enquiryModel = new EnquiryModel();
|
|
$this->AgentModel = new AgentModel();
|
|
$this->QuotationModel = new QuotationModel();
|
|
$this->PolicyModel = new PolicyModel();
|
|
}
|
|
|
|
// List all enquiries
|
|
public function enquiryList()
|
|
{
|
|
try {
|
|
|
|
$agent_id = $this->request->getGet('agent_id');
|
|
$staff_id = $this->request->getGet('staff_id');
|
|
$enquiry_id = $this->request->getGet('enquiry_id');
|
|
$manager_id = $this->request->getGet('manager_id');
|
|
|
|
$from_date = $this->request->getGet('from_date');
|
|
$to_date = $this->request->getGet('to_date');
|
|
|
|
$status = $this->request->getGet('status');
|
|
|
|
$only_policy_data = $this->request->getGet('only_policy_data') ?? false;
|
|
|
|
|
|
// Date filter handling
|
|
if (empty($from_date) || empty($to_date)) {
|
|
// Default last 7 days
|
|
// $from_date = date('Y-m-d 00:00:00', strtotime('-7 days'));
|
|
// $to_date = date('Y-m-d 23:59:59');
|
|
$from_date = null;
|
|
$to_date = null;
|
|
} else {
|
|
// Convert d-m-Y → Y-m-d
|
|
$from_date = DateTime::createFromFormat('d-m-Y', $from_date)->format('Y-m-d 00:00:00');
|
|
$to_date = DateTime::createFromFormat('d-m-Y', $to_date)->format('Y-m-d 23:59:59');
|
|
}
|
|
|
|
if (!empty($staff_id) && !empty($manager_id)) {
|
|
$data = $this->enquiryModel->getEnquiry('STAFF&MANAGER', [$staff_id,$manager_id], $only_policy_data, $from_date, $to_date, $status);
|
|
} elseif (!empty($agent_id)) {
|
|
$data = $this->enquiryModel->getEnquiry('AGENT', $agent_id, $only_policy_data, $from_date, $to_date, $status);
|
|
} elseif (!empty($staff_id)) {
|
|
$data = $this->enquiryModel->getEnquiry('STAFF', $staff_id, $only_policy_data, $from_date, $to_date, $status);
|
|
} elseif (!empty($enquiry_id)) {
|
|
$data = $this->enquiryModel->getEnquiry('ENQUIRY',$enquiry_id, $only_policy_data);
|
|
} elseif (!empty($manager_id)) {
|
|
$data = $this->enquiryModel->getEnquiry('MANAGER',$manager_id, $only_policy_data, $from_date, $to_date, $status);
|
|
} else {
|
|
$data = $this->enquiryModel->getEnquiry('ALL');
|
|
}
|
|
|
|
|
|
foreach ($data as $key => $row) {
|
|
$data[$key]['created_on'] = date('d-m-Y h:i A', strtotime($row['created_on']));
|
|
$data[$key]['updated_on'] = date('d-m-Y h:i A', strtotime($row['updated_on']));
|
|
}
|
|
|
|
if (!empty($from_date) || empty(!$to_date)) {
|
|
$from_date = DateTime::createFromFormat('Y-m-d 00:00:00', $from_date)->format('d-m-Y');
|
|
$to_date = DateTime::createFromFormat('Y-m-d 23:59:59', $to_date)->format('d-m-Y');
|
|
}
|
|
|
|
return $this->respond(['status' => 'success', 'code' => 200, 'data' => $data , 'from_date' => $from_date , 'to_date' => $to_date ], 200);
|
|
|
|
} catch (\Exception $e) {
|
|
return $this->respond(['status' => 'failed', 'code' => 500, 'error' => $e->getMessage()], 500);
|
|
}
|
|
}
|
|
|
|
// List all enquiries
|
|
public function enquiryQuotePolicyView()
|
|
{
|
|
try {
|
|
|
|
$enquiry_id = $this->request->getGet('enquiry_id');
|
|
|
|
if (!$enquiry_id) {
|
|
return $this->respond(['status' => 'failed','code' => 400,'data' => 'enquiry_id is required'], 200);
|
|
}
|
|
|
|
//Get enquiry details
|
|
$enquiry = $this->enquiryModel->select('partner_enquiry.* , I.name as insurer_name , I.short_name , VT.vehicle_type as vehicle_type,pe.broker_id ,PB.name as broker_name ,PA.name as agent_name')
|
|
->join('insurers I', 'I.id = partner_enquiry.insurer_id', 'left')
|
|
->join('vehicle_type VT', 'VT.id = partner_enquiry.vehicle_type_id', 'left')
|
|
->join('partner_brokers PB', 'PB.id = partner_enquiry.broker_id', 'left')
|
|
->join('partner_agent PA', 'PA.id = partner_enquiry.agent_id', 'left')
|
|
->where('partner_enquiry.id', $enquiry_id)
|
|
->where('partner_enquiry.is_active', 1)
|
|
->first();
|
|
|
|
if (!$enquiry) {
|
|
return $this->respond(['status' => 'failed','code' => 404,'data' => 'Enquiry not found'], 200);
|
|
}
|
|
|
|
//Get related quotations
|
|
$quotations = $this->QuotationModel->select('partner_quotation.*, pe.reg_no , I.name as insurer_name, I.short_name , ipti.insurance_plan_type,pe.broker_id ,PB.name as broker_name,PA.name as agent_name' )
|
|
->join('partner_enquiry pe', 'pe.id = partner_quotation.enquiry_id', 'left')
|
|
->join('insurers I', 'I.id = partner_quotation.insurer_id', 'left')
|
|
->join('partner_insurance_plan_type_master ipti', 'ipti.id = partner_quotation.insurance_plan_type_id', 'left')
|
|
->join('partner_brokers PB', 'PB.id = pe.broker_id', 'left')
|
|
->join('partner_agent PA', 'PA.id = pe.agent_id', 'left')
|
|
->where('partner_quotation.enquiry_id', $enquiry_id)
|
|
->where('partner_quotation.is_active', 1)
|
|
->orderBy('partner_quotation.id', 'DESC')
|
|
->findAll();
|
|
|
|
//Get related policies
|
|
$policies = [];
|
|
if (!empty($quotations)) {
|
|
$quotationId = 0;
|
|
foreach ($quotations as $key => $value) {
|
|
if($value['status'] == 'Accepted') { $quotationId = $value['id']; }
|
|
}
|
|
|
|
$policies = $this->PolicyModel->select('partner_policy.*, pe.reg_no, I.name as insurer_name, I.short_name , pq.insured_declared_value, ipti.insurance_plan_type, pe.broker_id , PB.name as broker_name,PA.name as agent_name')
|
|
->join('partner_enquiry pe', 'pe.id = partner_policy.enquiry_id', 'left')
|
|
->join('partner_quotation pq', 'pq.id = partner_policy.quotation_id', 'left')
|
|
->join('insurers I', 'I.id = pq.insurer_id', 'left')
|
|
->join('partner_insurance_plan_type_master ipti', 'ipti.id = pq.insurance_plan_type_id', 'left')
|
|
->join('partner_brokers PB', 'PB.id = pe.broker_id', 'left')
|
|
->join('partner_agent PA', 'PA.id = pe.agent_id', 'left')
|
|
->where('partner_policy.quotation_id', $quotationId)
|
|
->where('partner_policy.is_active', 1)
|
|
->first();
|
|
if (!empty($policies)) {
|
|
$policies['issued_date'] = format_date_for_client($policies['issued_date'] ?? null);
|
|
$policies['start_date'] = format_date_for_client($policies['start_date'] ?? null);
|
|
$policies['end_date'] = format_date_for_client($policies['end_date'] ?? null);
|
|
}
|
|
|
|
|
|
}
|
|
|
|
// Final response
|
|
$data = [
|
|
'enquiry' => $enquiry,
|
|
'quotations' => $quotations,
|
|
'policies' => $policies
|
|
];
|
|
|
|
return $this->respond(['status' => 'success','code' => 200,'data' => $data], 200);
|
|
|
|
} catch (\Exception $e) {
|
|
return $this->respond(['status' => 'failed','code' => 500,'error' => $e->getMessage()], 500);
|
|
}
|
|
}
|
|
|
|
// CREATE enquiry
|
|
public function createEnquiry()
|
|
{
|
|
try {
|
|
$data = $this->request->getPost();
|
|
|
|
// handle file uploads
|
|
$idProofFile = $this->request->getFile('id_proof_file_name');
|
|
$rcFile = $this->request->getFile('rc_file_name');
|
|
$previousPolicy = $this->request->getFile('previous_policy_file_name');
|
|
|
|
$idProofFileName = null;
|
|
$rcFileName = null;
|
|
$previousPolicyFileName = null;
|
|
|
|
// ID proof upload
|
|
if ($idProofFile && $idProofFile->isValid()) {
|
|
$uploadPath = WRITEPATH . 'uploads/enquiry/id_proof/';
|
|
if (!is_dir($uploadPath)) mkdir($uploadPath, 0777, true);
|
|
$idProofFileName = time() . '_' . $idProofFile->getRandomName();
|
|
$idProofFile->move($uploadPath, $idProofFileName);
|
|
}
|
|
|
|
// RC upload
|
|
if ($rcFile && $rcFile->isValid()) {
|
|
$uploadPath = WRITEPATH . 'uploads/enquiry/rc/';
|
|
if (!is_dir($uploadPath)) mkdir($uploadPath, 0777, true);
|
|
$rcFileName = time() . '_' . $rcFile->getRandomName();
|
|
$rcFile->move($uploadPath, $rcFileName);
|
|
}
|
|
|
|
// Previous policy upload
|
|
if ($previousPolicy && $previousPolicy->isValid()) {
|
|
$uploadPath = WRITEPATH . 'uploads/enquiry/previous_policy/';
|
|
if (!is_dir($uploadPath)) mkdir($uploadPath, 0777, true);
|
|
$previousPolicyFileName = time() . '_' . $previousPolicy->getRandomName();
|
|
$previousPolicy->move($uploadPath, $previousPolicyFileName);
|
|
}
|
|
|
|
//get insurer_branch_id
|
|
if(isset($data['insurer_id']))
|
|
{
|
|
$query = $this->db->query("SELECT id FROM insurer_branch WHERE insurer_id = ? LIMIT 1", [$data['insurer_id']]);
|
|
$insurerBranchresult = $query->getRowArray();
|
|
}
|
|
|
|
|
|
$insertData = [
|
|
'agent_id' => $data['agent_id'],
|
|
'name' => $data['name'],
|
|
'mobile' => $data['mobile'],
|
|
'email' => $data['email'],
|
|
'reg_no' => $data['reg_no'],
|
|
'vehicle_type_id' => $data['vehicle_type_id'] ?? 0,
|
|
'rc_file_name' => $rcFileName,
|
|
'id_proof_file_name' => $idProofFileName,
|
|
'previous_policy_file_name' => $previousPolicyFileName,
|
|
'remarks' => $data['remarks'],
|
|
'manager_id' => $data['manager_id'] ,
|
|
'created_by' => $data['created_by'],
|
|
'is_data_created_by_handler' => $data['is_data_created_by_handler'] ?? 0 ,
|
|
|
|
'assigned_to' => $data['assigned_to'] ?? 0,
|
|
'insurer_id' => $data['insurer_id'] ?? 0,
|
|
'insurer_branch_id'=> $insurerBranchresult['id'] ?? 0,
|
|
'broker_id' => $data['broker_id'] ?? 0,
|
|
];
|
|
|
|
|
|
|
|
|
|
$enquiryId = $this->enquiryModel->insert($insertData , true);
|
|
|
|
// trigger_email('enquiry_created', ['enquiry_id' => $enquiryId]);
|
|
|
|
return $this->respond(['status' => 'success', 'code' => 200, 'message' => 'Enquiry created successfully'], 200);
|
|
|
|
} catch (\Exception $e) {
|
|
return $this->respond(['status' => 'failed', 'code' => 500, 'error' => $e->getMessage()], 500);
|
|
}
|
|
}
|
|
|
|
// UPDATE enquiry
|
|
public function updateEnquiry()
|
|
{
|
|
try {
|
|
$data = $this->request->getPost();
|
|
|
|
if (!isset($data['id'])) {
|
|
return $this->respond(['status' => 'failed', 'code' => 200, 'error' => 'ID Required'], 200);
|
|
}
|
|
|
|
$id = $data['id'];
|
|
$enquiry = $this->enquiryModel->find($id);
|
|
|
|
if (!$enquiry) {
|
|
return $this->respond(['status' => 'failed', 'code' => 200, 'error' => 'Data Not Found'], 200);
|
|
}
|
|
|
|
//get insurer_branch_id
|
|
if(isset($data['insurer_id']))
|
|
{
|
|
$query = $this->db->query("SELECT id FROM insurer_branch WHERE insurer_id = ? LIMIT 1", [$data['insurer_id']]);
|
|
$insurerBranchresult = $query->getRowArray();
|
|
}
|
|
|
|
|
|
|
|
$updateData = [
|
|
'agent_id' => $data['agent_id'] ?? $enquiry['agent_id'],
|
|
'name' => $data['name'] ?? $enquiry['name'],
|
|
'mobile' => $data['mobile'] ?? $enquiry['mobile'],
|
|
'email' => $data['email'] ?? $enquiry['email'],
|
|
'reg_no' => $data['reg_no'] ?? $enquiry['reg_no'],
|
|
'vehicle_type_id' => $data['vehicle_type_id'] ?? $enquiry['vehicle_type_id'],
|
|
'remarks' => $data['remarks'] ?? $enquiry['remarks'],
|
|
'updated_by' => $data['updated_by'] ?? null,
|
|
|
|
'assigned_to' => $data['assigned_to'] ?? $enquiry['assigned_to'],
|
|
'insurer_id' => $data['insurer_id'] ?? $enquiry['insurer_id'],
|
|
'insurer_branch_id'=> $insurerBranchresult['id'] ?? $enquiry['insurer_branch_id'],
|
|
'broker_id' => $data['broker_id'] ?? $enquiry['broker_id'],
|
|
];
|
|
|
|
// File updates
|
|
$idProofFile = $this->request->getFile('id_proof_file_name');
|
|
$rcFile = $this->request->getFile('rc_file_name');
|
|
$previousPolicy = $this->request->getFile('previous_policy_file_name');
|
|
|
|
if ($idProofFile && $idProofFile->isValid()) {
|
|
$uploadPath = WRITEPATH . 'uploads/enquiry/id_proof/';
|
|
if (!is_dir($uploadPath)) mkdir($uploadPath, 0777, true);
|
|
$idProofFileName = time() . '_' . $idProofFile->getRandomName();
|
|
$idProofFile->move($uploadPath, $idProofFileName);
|
|
$updateData['id_proof_file_name'] = $idProofFileName;
|
|
}
|
|
|
|
if ($rcFile && $rcFile->isValid()) {
|
|
$uploadPath = WRITEPATH . 'uploads/enquiry/rc/';
|
|
if (!is_dir($uploadPath)) mkdir($uploadPath, 0777, true);
|
|
$rcFileName = time() . '_' . $rcFile->getRandomName();
|
|
$rcFile->move($uploadPath, $rcFileName);
|
|
$updateData['rc_file_name'] = $rcFileName;
|
|
}
|
|
|
|
if ($previousPolicy && $previousPolicy->isValid()) {
|
|
$uploadPath = WRITEPATH . 'uploads/enquiry/previous_policy/';
|
|
if (!is_dir($uploadPath)) mkdir($uploadPath, 0777, true);
|
|
$previousPolicyFileName = time() . '_' . $previousPolicy->getRandomName();
|
|
$previousPolicy->move($uploadPath, $previousPolicyFileName);
|
|
$updateData['previous_policy_file_name'] = $previousPolicyFileName;
|
|
}
|
|
|
|
$this->enquiryModel->update($id, $updateData);
|
|
|
|
return $this->respond(['status' => 'success', 'code' => 200, 'message' => 'Enquiry updated successfully'], 200);
|
|
|
|
} catch (\Exception $e) {
|
|
return $this->respond(['status' => 'failed', 'code' => 500, 'error' => $e->getMessage()], 500);
|
|
}
|
|
}
|
|
|
|
//Assign to staff
|
|
public function enquiryAssignUpdate()
|
|
{
|
|
try {
|
|
|
|
$data = $this->request->getJSON(true);
|
|
|
|
if (!isset($data['id'])) {
|
|
return $this->respond(['status' => 'failed', 'code' => 200, 'error' => 'ID Required'], 200);
|
|
}
|
|
|
|
$id = $data['id'];
|
|
$enquiry = $this->enquiryModel->find($id);
|
|
|
|
if (!$enquiry) {
|
|
return $this->respond(['status' => 'failed', 'code' => 200, 'error' => 'Data Not Found'], 200);
|
|
}
|
|
|
|
//get insurer_branch_id
|
|
$query = $this->db->query("SELECT id FROM insurer_branch WHERE insurer_id = ? LIMIT 1", [$data['insurer_id']]);
|
|
$insurerBranchresult = $query->getRowArray();
|
|
|
|
$updateData = [
|
|
'assigned_to' => $data['assigned_to'],
|
|
'insurer_id' => $data['insurer_id'],
|
|
'insurer_branch_id'=> $insurerBranchresult['id'] ?? 0,
|
|
'broker_id' => $data['broker_id'] ?? 1,
|
|
];
|
|
|
|
$this->enquiryModel->update($id, $updateData);
|
|
|
|
// trigger_email('enquiry_assigned', ['enquiry_id' => $id]);
|
|
|
|
return $this->respond(['status' => 'success', 'code' => 200, 'message' => 'Enquiry updated successfully'], 200);
|
|
|
|
|
|
return $this->respond(['status' => 'success', 'code' => 200, 'data' => $data], 200);
|
|
|
|
} catch (\Exception $e) {
|
|
return $this->respond(['status' => 'failed', 'code' => 500, 'error' => $e->getMessage()], 500);
|
|
}
|
|
}
|
|
|
|
// Download enquiry file
|
|
public function downloadEnquiryFile()
|
|
{
|
|
try {
|
|
$enquiryId = $this->request->getGet('enquiry_id');
|
|
$fileType = $this->request->getGet('file_type'); // rc | id_proof | previous_policy
|
|
|
|
if (!$enquiryId || !$fileType) {
|
|
return $this->respond(['status' => 'failed','code' => 400,'data' => 'enquiry_id and file_type are required'], 200);
|
|
}
|
|
|
|
// Map file_type to DB column and folder
|
|
$fileMap = [
|
|
'rc' => ['column' => 'rc_file_name', 'folder' => 'rc'],
|
|
'id_proof' => ['column' => 'id_proof_file_name', 'folder' => 'id_proof'],
|
|
'previous_policy' => ['column' => 'previous_policy_file_name', 'folder' => 'previous_policy'],
|
|
];
|
|
|
|
if (!array_key_exists($fileType, $fileMap)) {
|
|
return $this->respond(['status' => 'failed','code' => 400,'data' => 'Invalid file_type'], 200);
|
|
}
|
|
|
|
$fileColumn = $fileMap[$fileType]['column'];
|
|
$folder = $fileMap[$fileType]['folder'];
|
|
|
|
// Fetch record from DB
|
|
$fileRecord = $this->enquiryModel->where('is_active', 1)->find($enquiryId);
|
|
|
|
if (!$fileRecord || empty($fileRecord[$fileColumn])) {
|
|
return $this->respond([ 'status' => 'failed','code' => 404,'data' => 'File not found in database'], 200);
|
|
}
|
|
|
|
$filePath = WRITEPATH . "uploads/enquiry/{$folder}/" . $fileRecord[$fileColumn];
|
|
|
|
if (!file_exists($filePath)) {
|
|
return $this->respond(['status' => 'failed','code' => 404,'data' => 'File missing on server'], 200);
|
|
}
|
|
|
|
// Force file download
|
|
return $this->response->download($filePath, null);
|
|
|
|
} catch (\Exception $e) {
|
|
return $this->respond(['status' => 'failed','code' => 500,'message' => $e->getMessage() ], 500);
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
}
|