575 lines
22 KiB
PHP
575 lines
22 KiB
PHP
<?php
|
|
|
|
namespace App\Controllers;
|
|
|
|
use App\Models\ClaimModel;
|
|
use App\Models\ClaimFilesModel;
|
|
use App\Models\PolicyModel;
|
|
use App\Models\EnquiryModel;
|
|
use App\Models\QuotationModel;
|
|
use App\Models\ClaimStatusModel;
|
|
use CodeIgniter\RESTful\ResourceController;
|
|
|
|
class ClaimController extends ResourceController
|
|
{
|
|
protected $db;
|
|
protected $ClaimModel;
|
|
protected $ClaimFilesModel;
|
|
protected $PolicyModel;
|
|
protected $QuotationModel;
|
|
protected $EnquiryModel;
|
|
protected $ClaimStatusModel;
|
|
|
|
private const CLAIM_UPLOAD_DIR = 'uploads/claims/';
|
|
private const CLAIM_TICKET_TYPE = 8;
|
|
|
|
public function __construct()
|
|
{
|
|
$this->db = db_connect();
|
|
$this->ClaimModel = new ClaimModel();
|
|
$this->ClaimFilesModel = new ClaimFilesModel();
|
|
$this->PolicyModel = new PolicyModel();
|
|
$this->QuotationModel = new QuotationModel();
|
|
$this->EnquiryModel = new EnquiryModel();
|
|
$this->ClaimStatusModel = new ClaimStatusModel();
|
|
}
|
|
|
|
public function claimStatusList()
|
|
{
|
|
try {
|
|
$data = $this->ClaimStatusModel
|
|
->select('id, claim_status, allowed_status, ticket_type, trigger_type')
|
|
->where('ticket_type', self::CLAIM_TICKET_TYPE)
|
|
->where('is_active', 1)
|
|
->orderBy('id', 'ASC')
|
|
->findAll();
|
|
|
|
return $this->respond(['status' => 'success', 'code' => 200, 'data' => $data], 200);
|
|
} catch (\Exception $e) {
|
|
return $this->respond(['status' => 'failed', 'code' => 500, 'data' => $e->getMessage()], 500);
|
|
}
|
|
}
|
|
|
|
public function ClaimList()
|
|
{
|
|
try {
|
|
$id = $this->request->getGet('id');
|
|
$manager_id = $this->request->getGet('manager_id');
|
|
$agent_id = $this->request->getGet('agent_id');
|
|
$policy_number = $this->request->getGet('policy_number');
|
|
$claim_type_id = $this->request->getGet('claim_type_id');
|
|
$claim_status_id = $this->request->getGet('claim_status_id');
|
|
$insurer_id = $this->request->getGet('insurer_id');
|
|
$from_date = $this->request->getGet('from_date');
|
|
$to_date = $this->request->getGet('to_date');
|
|
|
|
$builder = $this->db->table('partner_claims pc')
|
|
->select('pc.*,
|
|
i.name as insurer_name,
|
|
i.short_name as insurer_short_name,
|
|
pct.claim_type as claim_type_value,
|
|
pa.name as agent_name,
|
|
tcs.claim_status as claim_status_value,
|
|
pp.start_date as policy_start_date,
|
|
pp.end_date as policy_end_date,
|
|
v.vehicle_no as reg_no')
|
|
->join('insurers i', 'i.id = pc.insurer_id', 'left')
|
|
->join('partner_claim_type_master pct', 'pct.id = pc.claim_type', 'left')
|
|
->join('partner_agent pa', 'pa.id = pc.agent_id', 'left')
|
|
->join('ticket_claim_status tcs', 'tcs.id = pc.claim_status_id AND tcs.ticket_type = ' . self::CLAIM_TICKET_TYPE, 'left')
|
|
->join('partner_policy pp', 'pp.id = pc.policy_id', 'left')
|
|
->join('vehicle v', 'v.id = pp.vehicle_id', 'left')
|
|
->where('pc.is_active', 1);
|
|
|
|
if (!empty($id)) {
|
|
$builder->where('pc.id', $id);
|
|
$claim = $builder->get()->getRowArray();
|
|
|
|
if (!$claim) {
|
|
return $this->respond(['status' => 'failed', 'code' => 404, 'data' => 'Not Found'], 404);
|
|
}
|
|
|
|
$claim = $this->formatClaimRow($claim);
|
|
$claim['files'] = $this->decorateFilesWithUrls($this->getClaimFiles((int) $claim['id']));
|
|
|
|
return $this->respond(['status' => 'success', 'code' => 200, 'data' => $claim], 200);
|
|
}
|
|
|
|
if (!empty($manager_id)) {
|
|
$builder->where('pc.manager_id', $manager_id);
|
|
}
|
|
|
|
if (!empty($agent_id)) {
|
|
$builder->where('pc.agent_id', $agent_id);
|
|
}
|
|
|
|
if (!empty($policy_number)) {
|
|
$builder->where('pc.policy_no', $policy_number);
|
|
}
|
|
|
|
if (!empty($claim_type_id)) {
|
|
$builder->where('pc.claim_type', $claim_type_id);
|
|
}
|
|
|
|
if (!empty($claim_status_id)) {
|
|
$builder->where('pc.claim_status_id', $claim_status_id);
|
|
}
|
|
|
|
if (!empty($insurer_id)) {
|
|
$builder->where('pc.insurer_id', $insurer_id);
|
|
}
|
|
|
|
if (!empty($from_date) && !empty($to_date)) {
|
|
$builder->where('pc.created_at >=', $from_date . ' 00:00:00')
|
|
->where('pc.created_at <=', $to_date . ' 23:59:59');
|
|
}
|
|
|
|
$data = $builder->orderBy('pc.id', 'DESC')->get()->getResultArray();
|
|
$filesByClaim = $this->getClaimFilesGrouped(array_column($data, 'id'));
|
|
|
|
foreach ($data as $key => $row) {
|
|
$data[$key] = $this->formatClaimRow($row);
|
|
$data[$key]['files'] = $this->decorateFilesWithUrls($filesByClaim[$row['id']] ?? []);
|
|
}
|
|
|
|
return $this->respond(['status' => 'success', 'code' => 200, 'data' => $data], 200);
|
|
} catch (\Exception $e) {
|
|
return $this->respond(['status' => 'failed', 'code' => 500, 'data' => $e->getMessage()], 500);
|
|
}
|
|
}
|
|
|
|
public function createClaim()
|
|
{
|
|
try {
|
|
$reqData = $this->request->getPost();
|
|
|
|
if (empty($reqData['policy_number']) || empty($reqData['claim_description']) || empty($reqData['claim_type'])) {
|
|
return $this->respond([
|
|
'status' => 'failed',
|
|
'code' => 400,
|
|
'data' => 'policy_number, claim_description and claim_type are required',
|
|
], 400);
|
|
}
|
|
|
|
$policy = $this->PolicyModel
|
|
->select('partner_policy.*, Q.insurer_id, E.mobile as client_mobile, E.email as client_email')
|
|
->join('partner_quotation Q', 'Q.id = partner_policy.quotation_id AND Q.status = "Accepted"', 'left')
|
|
->join('partner_enquiry E', 'E.id = partner_policy.enquiry_id', 'left')
|
|
->where('partner_policy.policy_number', $reqData['policy_number'])
|
|
->first();
|
|
|
|
if (empty($policy)) {
|
|
return $this->respond(['status' => 'failed', 'code' => 404, 'data' => 'Policy not found'], 404);
|
|
}
|
|
|
|
$status = $this->ClaimStatusModel
|
|
->where('ticket_type', self::CLAIM_TICKET_TYPE)
|
|
->where('is_active', 1)
|
|
->orderBy('id', 'ASC')
|
|
->first();
|
|
|
|
if (empty($status)) {
|
|
return $this->respond(['status' => 'failed', 'code' => 404, 'data' => 'Default claim status not found'], 404);
|
|
}
|
|
|
|
$claimData = [
|
|
'claim_status_id' => $reqData['claim_status_id'] ?? $status['id'],
|
|
'policy_id' => $policy['id'],
|
|
'policy_no' => $policy['policy_number'],
|
|
'insurer_id' => $policy['insurer_id'] ?? null,
|
|
'insured_name' => $reqData['insured_name'] ?? $policy['insured_name'] ?? null,
|
|
'mobile' => $reqData['mobile'] ?? $policy['client_mobile'] ?? null,
|
|
'mail' => $reqData['mail'] ?? $policy['client_email'] ?? null,
|
|
'manager_id' => $policy['manager_id'] ?? $reqData['manager_id'] ?? null,
|
|
'agent_id' => $policy['agent_id'] ?? $reqData['agent_id'] ?? null,
|
|
'claim_type' => $reqData['claim_type'],
|
|
'date_of_incident' => format_date_for_database($reqData['date_of_incident'] ?? null),
|
|
'place_of_incident' => $reqData['place_of_incident'] ?? null,
|
|
'claim_description' => $reqData['claim_description'],
|
|
'spot_surveyor_name' => $reqData['spot_surveyor_name'] ?? null,
|
|
'spot_surveyor_contact' => $reqData['spot_surveyor_contact'] ?? null,
|
|
'workshop_surveyor_name' => $reqData['workshop_surveyor_name'] ?? null,
|
|
'workshop_surveyor_contact'=> $reqData['workshop_surveyor_contact'] ?? null,
|
|
'is_active' => 1,
|
|
'created_by' => $reqData['created_by'] ?? null,
|
|
];
|
|
|
|
$this->db->transStart();
|
|
|
|
if (!$this->ClaimModel->insert($claimData)) {
|
|
$this->db->transRollback();
|
|
return $this->respond(['status' => 'failed', 'code' => 422, 'data' => $this->ClaimModel->errors()], 422);
|
|
}
|
|
|
|
$claimId = (int) $this->ClaimModel->getInsertID();
|
|
$fileResult = $this->saveClaimFiles($claimId, $reqData['created_by'] ?? null);
|
|
|
|
if ($fileResult['attempted'] > 0 && empty($fileResult['saved'])) {
|
|
$this->db->transRollback();
|
|
return $this->respond([
|
|
'status' => 'failed',
|
|
'code' => 422,
|
|
'data' => !empty($fileResult['errors']) ? $fileResult['errors'] : 'Failed to upload claim files',
|
|
], 422);
|
|
}
|
|
|
|
if ($this->db->transStatus() === false) {
|
|
return $this->respond(['status' => 'failed', 'code' => 500, 'data' => 'Failed to create claim'], 500);
|
|
}
|
|
|
|
$this->db->transComplete();
|
|
|
|
return $this->respond([
|
|
'status' => 'success',
|
|
'code' => 200,
|
|
'data' => [
|
|
'claim_id' => $claimId,
|
|
'uploaded_files' => $fileResult['saved'],
|
|
'files' => $this->decorateFilesWithUrls($this->getClaimFiles($claimId)),
|
|
],
|
|
], 200);
|
|
} catch (\Exception $e) {
|
|
return $this->respond(['status' => 'failed', 'code' => 500, 'data' => $e->getMessage()], 500);
|
|
}
|
|
}
|
|
|
|
public function updateClaim()
|
|
{
|
|
try {
|
|
$claimId = $this->request->getPost('id');
|
|
|
|
if (empty($claimId)) {
|
|
return $this->respond(['status' => 'failed', 'code' => 400, 'data' => 'id is required'], 400);
|
|
}
|
|
|
|
$reqData = $this->request->getPost();
|
|
$claim = $this->ClaimModel->where('is_active', 1)->find((int) $claimId);
|
|
|
|
if (!$claim) {
|
|
return $this->respond(['status' => 'failed', 'code' => 404, 'data' => 'Claim not found'], 404);
|
|
}
|
|
|
|
$updateData = [];
|
|
$allowedUpdateFields = [
|
|
'claim_status_id',
|
|
'insurer_id',
|
|
'policy_id',
|
|
'policy_no',
|
|
'insured_name',
|
|
'mobile',
|
|
'mail',
|
|
'manager_id',
|
|
'agent_id',
|
|
'claim_type',
|
|
'place_of_incident',
|
|
'claim_description',
|
|
'spot_surveyor_name',
|
|
'spot_surveyor_contact',
|
|
'workshop_surveyor_name',
|
|
'workshop_surveyor_contact',
|
|
'is_active',
|
|
];
|
|
|
|
foreach ($allowedUpdateFields as $field) {
|
|
if (array_key_exists($field, $reqData)) {
|
|
$updateData[$field] = $reqData[$field];
|
|
}
|
|
}
|
|
|
|
if (array_key_exists('date_of_incident', $reqData)) {
|
|
$updateData['date_of_incident'] = format_date_for_database($reqData['date_of_incident']);
|
|
}
|
|
|
|
if (!empty($reqData['policy_number'])) {
|
|
$policy = $this->PolicyModel
|
|
->select('partner_policy.*, Q.insurer_id')
|
|
->join('partner_quotation Q', 'Q.id = partner_policy.quotation_id', 'left')
|
|
->where('partner_policy.policy_number', $reqData['policy_number'])
|
|
->first();
|
|
|
|
if ($policy) {
|
|
$updateData['policy_id'] = $policy['id'];
|
|
$updateData['policy_no'] = $policy['policy_number'];
|
|
if (!array_key_exists('insurer_id', $updateData)) {
|
|
$updateData['insurer_id'] = $policy['insurer_id'] ?? null;
|
|
}
|
|
}
|
|
}
|
|
|
|
if (isset($reqData['updated_by'])) {
|
|
$updateData['updated_by'] = $reqData['updated_by'];
|
|
}
|
|
|
|
if (!empty($updateData) && !$this->ClaimModel->update((int) $claimId, $updateData)) {
|
|
return $this->respond(['status' => 'failed', 'code' => 422, 'data' => $this->ClaimModel->errors()], 422);
|
|
}
|
|
|
|
$fileResult = $this->saveClaimFiles((int) $claimId, $reqData['updated_by'] ?? $reqData['created_by'] ?? null);
|
|
|
|
if ($fileResult['attempted'] > 0 && empty($fileResult['saved'])) {
|
|
return $this->respond([
|
|
'status' => 'failed',
|
|
'code' => 422,
|
|
'data' => !empty($fileResult['errors']) ? $fileResult['errors'] : 'Failed to upload claim files',
|
|
], 422);
|
|
}
|
|
|
|
return $this->respond([
|
|
'status' => 'success',
|
|
'code' => 200,
|
|
'data' => [
|
|
'claim_id' => (int) $claimId,
|
|
'uploaded_files' => $fileResult['saved'],
|
|
'files' => $this->decorateFilesWithUrls($this->getClaimFiles((int) $claimId)),
|
|
],
|
|
], 200);
|
|
} catch (\Exception $e) {
|
|
return $this->respond(['status' => 'failed', 'code' => 500, 'data' => $e->getMessage()], 500);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Fetch a single claim by primary id with related lookups and file preview URLs.
|
|
* Used to populate the edit form when the user clicks the edit button on a row.
|
|
*/
|
|
public function getClaimById()
|
|
{
|
|
try {
|
|
$id = $this->request->getGet('id');
|
|
|
|
if (empty($id)) {
|
|
return $this->respond(['status' => 'failed', 'code' => 400, 'data' => 'id is required'], 400);
|
|
}
|
|
|
|
$claim = $this->db->table('partner_claims pc')
|
|
->select('pc.*,
|
|
i.name as insurer_name,
|
|
i.short_name as insurer_short_name,
|
|
pct.claim_type as claim_type_value,
|
|
pa.name as agent_name,
|
|
tcs.claim_status as claim_status_value,
|
|
pp.start_date as policy_start_date,
|
|
pp.end_date as policy_end_date,
|
|
v.vehicle_no as reg_no')
|
|
->join('insurers i', 'i.id = pc.insurer_id', 'left')
|
|
->join('partner_claim_type_master pct', 'pct.id = pc.claim_type', 'left')
|
|
->join('partner_agent pa', 'pa.id = pc.agent_id', 'left')
|
|
->join('ticket_claim_status tcs', 'tcs.id = pc.claim_status_id AND tcs.ticket_type = ' . self::CLAIM_TICKET_TYPE, 'left')
|
|
->join('partner_policy pp', 'pp.id = pc.policy_id', 'left')
|
|
->join('vehicle v', 'v.id = pp.vehicle_id', 'left')
|
|
->where('pc.id', (int) $id)
|
|
->where('pc.is_active', 1)
|
|
->get()
|
|
->getRowArray();
|
|
|
|
if (!$claim) {
|
|
return $this->respond(['status' => 'failed', 'code' => 404, 'data' => 'Claim not found'], 404);
|
|
}
|
|
|
|
$claim = $this->formatClaimRow($claim);
|
|
$claim['files'] = $this->decorateFilesWithUrls($this->getClaimFiles((int) $claim['id']));
|
|
|
|
return $this->respond(['status' => 'success', 'code' => 200, 'data' => $claim], 200);
|
|
} catch (\Exception $e) {
|
|
return $this->respond(['status' => 'failed', 'code' => 500, 'data' => $e->getMessage()], 500);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Stream a single claim file inline (used as preview / download URL).
|
|
*/
|
|
public function downloadClaimFile()
|
|
{
|
|
try {
|
|
$fileId = $this->request->getGet('file_id');
|
|
|
|
if (empty($fileId)) {
|
|
return $this->respond(['status' => 'failed', 'code' => 400, 'data' => 'file_id is required'], 400);
|
|
}
|
|
|
|
$file = $this->ClaimFilesModel
|
|
->where('id', (int) $fileId)
|
|
->where('is_active', 1)
|
|
->first();
|
|
|
|
if (!$file) {
|
|
return $this->respond(['status' => 'failed', 'code' => 404, 'data' => 'File not found'], 404);
|
|
}
|
|
|
|
$relativePath = ltrim((string) ($file['file_path'] ?? ''), '/');
|
|
$filePath = WRITEPATH . $relativePath;
|
|
|
|
if (empty($relativePath) || !file_exists($filePath)) {
|
|
return $this->respond(['status' => 'failed', 'code' => 404, 'data' => 'File missing on server'], 404);
|
|
}
|
|
|
|
$mime = $file['file_mime_type'] ?? mime_content_type($filePath) ?? 'application/octet-stream';
|
|
$downloadName = $file['file_name'] ?: basename($filePath);
|
|
|
|
return $this->response
|
|
->setHeader('Content-Type', $mime)
|
|
->setHeader('Content-Disposition', 'inline; filename="' . $downloadName . '"')
|
|
->setBody(file_get_contents($filePath));
|
|
} catch (\Exception $e) {
|
|
return $this->respond(['status' => 'failed', 'code' => 500, 'data' => $e->getMessage()], 500);
|
|
}
|
|
}
|
|
|
|
private function formatClaimRow(array $row): array
|
|
{
|
|
if (!empty($row['created_at'])) {
|
|
$row['created_at'] = date('d-m-Y h:i A', strtotime($row['created_at']));
|
|
}
|
|
|
|
if (!empty($row['updated_at'])) {
|
|
$row['updated_at'] = date('d-m-Y h:i A', strtotime($row['updated_at']));
|
|
}
|
|
|
|
if (!empty($row['date_of_incident']) && $row['date_of_incident'] !== '0000-00-00') {
|
|
$row['date_of_incident'] = date('d-m-Y', strtotime($row['date_of_incident']));
|
|
} else {
|
|
$row['date_of_incident'] = null;
|
|
}
|
|
|
|
$row['policy_start_date'] = (!empty($row['policy_start_date']) && $row['policy_start_date'] !== '0000-00-00')
|
|
? date('d-m-Y', strtotime($row['policy_start_date']))
|
|
: null;
|
|
|
|
$row['policy_end_date'] = (!empty($row['policy_end_date']) && $row['policy_end_date'] !== '0000-00-00')
|
|
? date('d-m-Y', strtotime($row['policy_end_date']))
|
|
: null;
|
|
|
|
return $row;
|
|
}
|
|
|
|
private function getClaimFiles(int $claimId): array
|
|
{
|
|
return $this->ClaimFilesModel
|
|
->where('claim_id', $claimId)
|
|
->where('is_active', 1)
|
|
->orderBy('id', 'ASC')
|
|
->findAll();
|
|
}
|
|
|
|
/**
|
|
* Add preview_url and download_url to each claim file row.
|
|
*/
|
|
private function decorateFilesWithUrls(array $files): array
|
|
{
|
|
foreach ($files as $key => $file) {
|
|
$fileId = $file['id'] ?? null;
|
|
$url = $fileId ? base_url('api/claim/downloadClaimFile?file_id=' . $fileId) : null;
|
|
|
|
$files[$key]['preview_url'] = $url;
|
|
$files[$key]['download_url'] = $url;
|
|
}
|
|
|
|
return $files;
|
|
}
|
|
|
|
private function getClaimFilesGrouped(array $claimIds): array
|
|
{
|
|
$claimIds = array_values(array_filter(array_map('intval', $claimIds)));
|
|
|
|
if (empty($claimIds)) {
|
|
return [];
|
|
}
|
|
|
|
$files = $this->ClaimFilesModel
|
|
->whereIn('claim_id', $claimIds)
|
|
->where('is_active', 1)
|
|
->orderBy('id', 'ASC')
|
|
->findAll();
|
|
|
|
$grouped = [];
|
|
foreach ($files as $file) {
|
|
$grouped[$file['claim_id']][] = $file;
|
|
}
|
|
|
|
return $grouped;
|
|
}
|
|
|
|
/**
|
|
* Collect uploaded files from claim_files field (single or multiple).
|
|
*/
|
|
private function collectClaimUploadFiles(): array
|
|
{
|
|
$filesToProcess = [];
|
|
|
|
$multiple = $this->request->getFileMultiple('claim_files');
|
|
if (!empty($multiple)) {
|
|
foreach ($multiple as $uploadedFile) {
|
|
if ($this->isValidUploadFile($uploadedFile)) {
|
|
$filesToProcess[] = $uploadedFile;
|
|
}
|
|
}
|
|
return $filesToProcess;
|
|
}
|
|
|
|
$single = $this->request->getFile('claim_files');
|
|
if ($this->isValidUploadFile($single)) {
|
|
$filesToProcess[] = $single;
|
|
}
|
|
|
|
return $filesToProcess;
|
|
}
|
|
|
|
private function isValidUploadFile($uploadedFile): bool
|
|
{
|
|
return $uploadedFile
|
|
&& method_exists($uploadedFile, 'isValid')
|
|
&& $uploadedFile->isValid()
|
|
&& !$uploadedFile->hasMoved();
|
|
}
|
|
|
|
private function saveClaimFiles(int $claimId, $createdBy = null): array
|
|
{
|
|
$uploadPath = WRITEPATH . self::CLAIM_UPLOAD_DIR;
|
|
if (!is_dir($uploadPath)) {
|
|
mkdir($uploadPath, 0777, true);
|
|
}
|
|
|
|
$result = [
|
|
'saved' => [],
|
|
'errors' => [],
|
|
'attempted' => 0,
|
|
];
|
|
|
|
$filesToProcess = $this->collectClaimUploadFiles();
|
|
$result['attempted'] = count($filesToProcess);
|
|
|
|
foreach ($filesToProcess as $file) {
|
|
try {
|
|
$storedName = time() . '_' . $file->getRandomName();
|
|
|
|
if (!$file->move($uploadPath, $storedName)) {
|
|
$result['errors'][] = $file->getErrorString() ?: 'Unable to move uploaded file';
|
|
continue;
|
|
}
|
|
|
|
if (!$this->ClaimFilesModel->insert([
|
|
'claim_id' => $claimId,
|
|
'file_name' => $file->getClientName() ?: $storedName,
|
|
'file_path' => self::CLAIM_UPLOAD_DIR . $storedName,
|
|
'file_extension' => $file->getClientExtension(),
|
|
'file_mime_type' => $file->getClientMimeType(),
|
|
'is_active' => 1,
|
|
'created_by' => $createdBy,
|
|
])) {
|
|
if (is_file($uploadPath . $storedName)) {
|
|
unlink($uploadPath . $storedName);
|
|
}
|
|
$result['errors'][] = $this->ClaimFilesModel->errors() ?: 'Failed to save file record';
|
|
continue;
|
|
}
|
|
|
|
$result['saved'][] = $storedName;
|
|
} catch (\Exception $e) {
|
|
$result['errors'][] = $e->getMessage();
|
|
}
|
|
}
|
|
|
|
return $result;
|
|
}
|
|
}
|