diff --git a/.env.sample b/.env.sample
index e834a822..ceb7085a 100755
--- a/.env.sample
+++ b/.env.sample
@@ -120,3 +120,4 @@ FHPL_USER_NAME =
FHPL_PASSWORD =
FHPL_GRANT_TYPE =
+METABASE_SECRET_KEY=
\ No newline at end of file
diff --git a/app/Config/Routes.php b/app/Config/Routes.php
index 7b40d4db..d9bb6ea9 100755
--- a/app/Config/Routes.php
+++ b/app/Config/Routes.php
@@ -22,6 +22,7 @@ $routes->get('/swagger', 'SwaggerController::index', ['filter' => 'authMVC']);
$routes->get('/fedeploy', 'DeployController::fedeploy_view', ['filter' => 'authMVC']);
$routes->post('/fedeploy', 'DeployController::fedeploy', ['filter' => 'authMVC']);
$routes->get('/visitOffBoardCheck', 'EmployeeController::visitOffBoardCheck');
+$routes->get('/metaDashboardDemo', 'TestingController::metaDashboardDemo');
// Reminder Mail Notification
@@ -36,7 +37,6 @@ $routes->get("view", "EmployeeController::viewECard/$1");
$routes->get("checkWellnessOnboardStatus/(:any)", "EmployeeController::checkWellnessOnboardStatus/$1");
$routes->get("initiateWellnessOnboard/(:any)", "EmployeeController::initiateWellnessOnboard/$1");
$routes->get("exportQCRandRFQ/(:any)", "LeadsController::exportQCRandRFQ/$1");
-$routes->get("smapletest", "ClientController::smapletest");
$routes->get("testMailAttachments", "ClientController::testMailAttachments");
$routes->get("updatePolicyTermsKey", "ClientController::updatePolicyTermsKey");
$routes->get("updateRemainderDate", "ClientController::updateRemainderDate");
@@ -216,6 +216,9 @@ $routes->group("/employee", ["filter" => "authMVC"], function ($routes) {
$routes->post("retail-endorsement-save", "EmployeeController::retailendorsementsave");
$routes->get("getTPADataVariationReport/(:num)", "EmployeeController::getTPADataVariationReport/$1");
$routes->get("bulkGenerateEcardAndStoreinS3", "EmployeeController::bulkGenerateEcardAndStoreinS3");
+ $routes->get('clearCdSession', 'EmployeeController::clearCdSession');
+ $routes->get('checkSessionStatus', 'EmployeeController::checkSessionStatus');
+
});
@@ -556,6 +559,10 @@ $routes->group("/api", ["filter" => [ 'ratelimit' , 'authJWT']], function ($rout
$routes->get("getSSORedirectUrl", "ApiServiceController::getSSORedirectUrl");
$routes->get("getEmployeePolicy", "EmployeeRestController::getEmployeePolicy");
+$routes->get("downloadCdSplitUpFile", "EmployeeRestController::downloadCdSplitUpFile");
+$routes->get("downloadFileTableFile/(:any)", "EmployeeController::downloadFileList/$1");
+
+
$routes->group("employeeRest", ['filter' => ['ratelimit' , 'appSignature'] ], function ($routes) {
@@ -600,7 +607,7 @@ $routes->group("employeeRest", ['filter' => ['ratelimit' , 'appSignature'] ], fu
});
-$routes->group("employeeRest", ["filter" => [ 'ratelimit' , 'appSignature' , 'authJWT']], function ($routes) {
+$routes->group("employeeRest", ["filter" => ['GlobalPostFileUploadGuard', 'ratelimit' , 'appSignature', 'authJWT']], function ($routes) {
$routes->post('logout', 'RestAuthenticationController::logout');
@@ -652,6 +659,7 @@ $routes->group("employeeRest", ["filter" => [ 'ratelimit' , 'appSignature' , 'au
$routes->get("hrFileDownload", "EmployeeRestController::hrFileDownload");
$routes->post("hrFileUpload", "EmployeeRestController::hrFileUpload");
$routes->post("updateHrFileUploadData", "EmployeeRestController::updateHrFileUploadData");
+ $routes->post("getHrDashboad", "EmployeeRestController::getHrDashboad");
//thz_master's
@@ -682,7 +690,10 @@ $routes->group("employeeRest", ["filter" => [ 'ratelimit' , 'appSignature' , 'au
// get insurer and policy type
$routes->get("getPolicyTypeAndInsurer", "EmployeeRestController::getPolicyTypeAndInsurer");
-
+ $routes->get("getExcelFileErrors/(:any)", "EmployeeController::getExcelFileErrors/$1");
+ $routes->get("getPolicyAndEndorsementFiles", "EmployeeRestController::getPolicyAndEndorsementFiles");
+ $routes->get("downloadPolicyFiles", "EmployeeRestController::downloadPolicyFiles");
+ $routes->post("bulkEcardDownloadAsZip", "EmployeeRestController::bulkEcardDownloadAsZip");
});
$routes->get("hrFileDownload", "EmployeeRestController::hrFileDownload");
diff --git a/app/Controllers/ClientController.php b/app/Controllers/ClientController.php
index c16c20eb..09f34f77 100755
--- a/app/Controllers/ClientController.php
+++ b/app/Controllers/ClientController.php
@@ -141,6 +141,7 @@ class ClientController extends AdminController
$isDuplicate = $this->clientModel->isDuplicateByClientBranch($value, $field, $clientId, $branchId);
return $this->response->setJSON(['isDuplicate' => $isDuplicate]);
}
+
public function checkDuplicateTableFieldValue()
{
$table = $this->request->getPost('table');
@@ -162,35 +163,6 @@ class ClientController extends AdminController
return $this->response->setJSON(['isDuplicate' => $isDuplicate]);
}
- public function smapletest()
- {
- $headers = [
- 'S.No',
- 'NAME OF EMP/DEP',
- 'EMP ID',
- // 'EMP/DEP TYPE',
- // 'RELATIONSHIP CODE',
- 'DOB',
- 'GENDER',
- 'PRE EXISTING AILMENTS',
- 'BASIC COVER SI',
- 'DATE OF COVERAGE',
- 'AGE',
- 'RELATIONSHIP',
- 'REMARKS',
- 'POLICY END DATE',
- 'NO OF DAYS',
- 'TPA ID',
- 'UHID',
- // 'PREMIUM',
- 'PRO RATA PREMIUM',
- 'GST',
- 'TOTAL AMOUNT'
- ];
- $filePath = generateExcelWithHeader($headers);
- echo "Excel file created at: $filePath";
- }
-
public function testMailAttachments($email = 'venkateshraman786@gmail.com')
{
$message = 'Dear {{RECIPIENT_NAME}}, We are reaching out to request a quotation for the following insurance coverage. Please review the details below and provide your quote at your earliest convenience.
RFQ Details Client name {{CLIENT_NAME}} Coverage Type {{POLICY_LONG_NAME}} Policy Start Date {{POLICY_START_DATE}} Policy Duration {{DURATION}}
Please note: Additional terms and details are included in the attachment for your reference.
Please feel free to reach out if you require any further information to prepare the quote. We look forward to receiving your proposal.
Best regards,
Nhance India Pvt Ltd
";
// print_r($data); die;
- $data['placeHolders'] = ['member_name', 'nhance_logo', 'tpa_id', 'ecard_download_link', 'client_logo', 'policy_no', 'member_summary', 'app_link', 'post_enrollment_app_link', 'client_name'];
+ $data['placeHolders'] = ['hr_name', 'member_name', 'nhance_logo', 'tpa_id', 'ecard_download_link', 'client_logo', 'policy_no', 'member_summary', 'app_link', 'post_enrollment_app_link', 'client_name'];
// dd($data['placeHolders']);
@@ -982,7 +952,7 @@ class ClientController extends AdminController
}, $rawList)) : [];
$editData['client_policy']['role'] = get_role_id();
$editData['notification'] = $this->notificationModel->select('template_name,enabled')->where('client_id', $id)->findAll();
- $editData['placeHolders'] = ['member_name', 'member_mobile', 'nhance_logo', 'tpa_id', 'ecard_download_link', 'client_logo', 'policy_no', 'member_summary', 'app_link', 'post_enrollment_app_link', 'client_name'];
+ $editData['placeHolders'] = ['hr_name', 'member_name', 'member_mobile', 'nhance_logo', 'tpa_id', 'ecard_download_link', 'client_logo', 'policy_no', 'member_summary', 'app_link', 'post_enrollment_app_link', 'client_name'];
$editData['api_data'] = $this->clientApi->where("client_id", $id)->where("is_active", 1)->first();
// dd($editData);
@@ -1641,7 +1611,7 @@ class ClientController extends AdminController
}
- public function createClientBranch()
+ public function createClientBranchNew()
{
$this->myLogger->logme('error', 'Client branch CREATE function called');
@@ -1826,7 +1796,7 @@ class ClientController extends AdminController
}
}
- public function editClientBranch()
+ public function editClientBranchNew()
{
$this->myLogger->logme('error', 'Client branch EDIT function called');
@@ -1946,11 +1916,9 @@ class ClientController extends AdminController
$level_contact_data = [];
if (!empty($level_contact_data_raw)) {
- $level_contact_data_decoded = json_decode($level_contact_data_raw, true);
+ $level_contact_data_decoded = json_decode($level_contact_data_raw ?? '{}', true);
- if (json_last_error() === JSON_ERROR_NONE && is_array($level_contact_data_decoded)) {
$level_contact_data = sanitizeInputArrayAdvanced($level_contact_data_decoded);
- }
}
if (!empty($level_contact_data)) {
@@ -1979,6 +1947,367 @@ class ClientController extends AdminController
}
}
+ public function saveLevelContactsNew($level_contact_data, $branch_id)
+ {
+ if (!empty($level_contact_data) && is_array($level_contact_data)) {
+ foreach ($level_contact_data as $value) {
+ if (!empty($value['id'])) {
+ $id = $value['id'];
+ unset($value['id']);
+ $this->levelContactModel->update($id, $value);
+ } else {
+ unset($value['id']);
+ $value['contact_type'] = "client";
+ $value['ref_id'] = $branch_id ?? null;
+ $this->levelContactModel->insert($value);
+ }
+ }
+ }
+ }
+
+ public function removeLevelContactsNew()
+ {
+ $id = $this->request->getGet('id');
+ try {
+ if (empty($id)) {
+ return $this->respond([
+ 'status' => false,
+ 'message' => 'Invalid ID provided. ID is empty',
+ 'data' => $id
+ ], 400);
+ }
+
+ $updated = $this->levelContactModel->update($id, ['is_active' => 0]);
+
+ if ($updated === false) {
+ return $this->respond([
+ 'status' => false,
+ 'message' => 'Failed to remove contact'
+ ], 500);
+ }
+
+ return $this->respond([
+ 'status' => true,
+ 'message' => 'Contact removed successfully'
+ ]);
+ } catch (\Exception $e) {
+ return $this->respond([
+ 'status' => false,
+ 'message' => 'An error occurred: ' . $e->getMessage()
+ ], 500);
+ }
+ }
+
+
+
+ public function createClientBranch()
+ {
+
+ $this->myLogger->logme('error', 'Client branch CREATE function called');
+
+ $rules = [
+ 'branch_name' => [
+ 'rules' => 'required',
+ 'errors' => [
+ 'required' => 'Branch Name is required',
+ ]
+ ],
+ 'branch_code' => [
+ 'rules' => 'required',
+ 'errors' => [
+ 'required' => 'Branch Code is required',
+ ]
+ ],
+ 'address1' => [
+ 'rules' => 'required',
+ 'errors' => [
+ 'required' => 'Address Line 1 is required',
+ ]
+ ],
+ 'state' => [
+ 'rules' => 'required',
+ 'errors' => [
+ 'required' => 'State is required',
+ ]
+ ],
+ 'district' => [
+ 'rules' => 'required',
+ 'errors' => [
+ 'required' => 'District is required.',
+ ]
+ ],
+ 'city' => [
+ 'rules' => 'required',
+ 'errors' => [
+ 'required' => 'City is required.',
+ ]
+ ],
+ 'pincode' => [
+ 'rules' => 'required',
+ 'errors' => [
+ 'required' => 'Pincode is required.',
+ ]
+ ],
+ 'gst' => [
+ 'rules' => 'required|regex_match[/^\d{2}[A-Z]{5}\d{4}[A-Z]{1}[A-Z\d]{1}Z[A-Z\d]{1}$/]',
+ 'errors' => [
+ 'required' => 'GST number is required',
+ 'regex_match' => 'Invalid GST Number. Example: 12ABCDE1234F5Z6'
+ ]
+ ],
+ 'name.*' => [
+ 'rules' => 'required|alpha_space',
+ 'errors' => [
+ 'required' => 'Contact name is required',
+ 'alpha_space' => 'Contact name may contain only letters and spaces'
+ ]
+ ],
+ 'designation.*' => [
+ 'rules' => 'required|alpha_space',
+ 'errors' => [
+ 'required' => 'Designation is required',
+ 'alpha_space' => 'Designation may contain only letters and spaces'
+ ]
+ ],
+ 'email.*' => [
+ 'rules' => 'required|valid_email',
+ 'errors' => [
+ 'required' => 'Email is required',
+ 'valid_email' => 'Please enter a valid email address'
+ ]
+ ],
+ 'mobile.*' => [
+ 'rules' => 'required|numeric|exact_length[10]',
+ 'errors' => [
+ 'required' => 'Mobile number is required',
+ 'numeric' => 'Mobile number must contain digits only',
+ 'exact_length' => 'Mobile number must be exactly 10 digits'
+ ]
+ ],
+ ];
+
+ if (!$this->validate($rules)) {
+ return $this->response->setStatusCode(400)->setJSON([
+ 'status' => false,
+ 'message' => 'Input validation failed',
+ 'code' => 400,
+ 'errors' => $this->validator->getErrors()
+ ]);
+ }
+
+ $data = $this->request->getPost();
+ $data = sanitizeInputArrayAdvanced($data);
+
+
+ if (!isset($data['sez'])) {
+ $data['sez'] = 0;
+ } elseif ($data['sez']) {
+ $data['sez'] = 1;
+ }
+
+ $units = json_decode($data['units'], true) ?? [];
+
+ if (!is_array($units) || empty($units)) {
+ $client_data = $this->clientModel->where('id', $data['client_id'])->first();
+ $default_unit = trim(($client_data['short_name'] ?? '') . '-' . ($data['branch_code'] ?? ''), '-');
+ $data['units'] = json_encode([$default_unit]);
+ }
+
+ $data['created_by'] = get_session_userid();
+
+
+ // before updating check if pre_branch_id is already existing in the current db
+
+ if(isset($data['pre_branch_id']) && !empty($data['pre_branch_id']))
+ {
+ $existing_pre_branch = $this->clientBranchModel
+ ->where('pre_branch_id',$data['pre_branch_id'])
+ //->where('id !=',$post_branch_id)
+ ->first();
+
+ if($existing_pre_branch)
+ {
+ return $this->respond([
+ 'status' => false,
+ 'code' => 409,
+ 'message' => 'The branch is already mapped with another branch. Please check.',
+ ], 409);
+ }
+ }
+
+
+
+ $insert = $this->clientBranchModel->insert($data);
+
+ $post_branch_id = $insert;
+
+ if ($insert) {
+ $level_contact_data = $this->request->getPost('level_contect_data');
+ $level_contact_data = !empty($level_contact_data) ? json_decode($level_contact_data, true) : null;
+ $this->saveLevelContacts($level_contact_data, $insert);
+ }
+
+ if($post_branch_id && isset($data['pre_branch_id']) && !empty($data['pre_branch_id']))
+ {
+ // need to update the client_branch in the pre
+ $result = $this->updatePreClientBranch($data['pre_branch_id'],$post_branch_id , "create");
+
+ log_message('error','Pre client_branch update result for pre_branch_id '.$data['pre_branch_id'].' and post_branch_id '.$post_branch_id.' is '.json_encode($result));
+ }
+
+ if ($insert) {
+ $branchData = $this->clientBranchModel->where('client_id', $this->request->getPost('client_id'))->findAll();
+ $branchData['role'] = get_role_id();
+ return $this->respond([
+ 'status' => true,
+ 'code' => 200,
+ 'data' => $branchData,
+ 'message' => 'Client branch created successfully',
+ ], 200);
+ } else {
+ return $this->respond([
+ 'status' => false,
+ 'code' => 404,
+ 'message' => 'Failed to create client branch ',
+ ], 200);
+ }
+ }
+
+ public function editClientBranch()
+ {
+
+ $this->myLogger->logme('error', 'Client branch EDIT function called');
+ $id = $this->request->getPost('branch_id_primarykey');
+ $client_id = $this->request->getPost('client_id');
+ $pre_branch_id = $this->request->getPost('pre_branch_id') ?? '';
+
+ $data = $this->request->getPost();
+ $data = sanitizeInputArrayAdvanced($data);
+ $data['pre_branch_id'] = $pre_branch_id;
+
+ $units = $this->request->getPost('units');
+
+ $emp_unit_count = 0;
+ $rr_unit_count = 0;
+ $rr_unit_count2 = 0;
+ $total_count = 0;
+
+ $list_of_branch_units = $this->clientBranchModel->find((int)$id);
+ $units = json_decode($list_of_branch_units['units']);
+
+ if (!is_array($units) || empty($units)) {
+ $client_data = $this->clientModel->where('id', $data['client_id'])->first();
+ $default_unit = trim(($client_data['short_name'] ?? '') . '-' . ($data['branch_code'] ?? ''), '-');
+ $data['units'] = json_encode([$default_unit]);
+ }
+
+ if (!empty($units)) {
+ foreach ($units as $unit) {
+ $emp_unit_count += $this->employeeModel->where('unit', $unit)->countAllResults();
+ $rr_unit_count += $this->policyPremium2Model->where('unit', $unit)->countAllResults();
+ $rr_unit_count2 += $this->policyPremium1Model->where('unit', $unit)->countAllResults();
+ }
+
+ $total_count = $emp_unit_count + $rr_unit_count + $rr_unit_count2;
+ }
+
+ $uncommonValues = [];
+
+ if ($total_count > 0) {
+ $units = (string) $this->request->getPost('units'); // Assuming 'units' is an array
+
+ $list_of_branch_units = $this->clientBranchModel->find((int)$id);
+ $branch_units = json_decode($list_of_branch_units['units'], true);
+ $units = json_decode($units);
+
+ $uncommonValues = array_diff($branch_units, $units);
+
+ if (count($uncommonValues) > 0) {
+
+ $branchData = $this->clientBranchModel->where('client_id', $client_id)->findAll();
+
+ return $this->respond([
+ 'status' => false,
+ 'code' => 404,
+ 'message' => "Deleted unit(s) in use. couldn't complete this operation.",
+ 'uncommonValues' => $uncommonValues,
+ 'data' => $branchData,
+ ], 200);
+ }
+ }
+
+ if (!isset($data['sez'])) {
+ $data['sez'] = 0;
+ } elseif ($data['sez']) {
+ $data['sez'] = 1;
+ }
+
+ $data['updated_by'] = get_session_userid();
+
+ $post_branch_id = $id;
+
+ // before updating check if pre_branch_id is already existing in the current db
+
+ if(isset($data['pre_branch_id']) && !empty($data['pre_branch_id']))
+ {
+ $existing_pre_branch = $this->clientBranchModel
+ ->where('pre_branch_id',$data['pre_branch_id'])
+ ->where('id !=',$post_branch_id)
+ ->first();
+
+ if($existing_pre_branch)
+ {
+ return $this->respond([
+ 'status' => false,
+ 'code' => 409,
+ 'message' => 'The branch is already mapped with another branch. Please check.',
+ ], 409);
+ }
+ }
+
+ $insert = $this->clientBranchModel->update($id, $data);
+
+
+
+ if($post_branch_id && isset($data['pre_branch_id']) && !empty($data['pre_branch_id']))
+ {
+ // need to update the client_branch in the pre
+ $result = $this->updatePreClientBranch($data['pre_branch_id'],$post_branch_id , "update");
+
+ log_message('error','Pre client_branch update result for pre_branch_id '.$data['pre_branch_id'].' and post_branch_id '.$post_branch_id.' is '.json_encode($result));
+ }
+
+
+ $this->myLogger->logme('error', 'Client branch EDITED by {data}', ['data' => get_session_userid()]);
+
+
+ if ($insert) {
+
+ $level_contact_data = $this->request->getPost('level_contect_data');
+ $level_contact_data = !empty($level_contact_data) ? json_decode($level_contact_data, true) : null;
+ $this->saveLevelContacts($level_contact_data, $id);
+ }
+
+ if ($insert) {
+ $branchData = $this->clientBranchModel->where('client_id', $client_id)->findAll();
+ return $this->respond([
+ 'status' => true,
+ 'code' => 200,
+ 'data' => $branchData,
+ 'emp_unit_count' => $emp_unit_count,
+ 'rr_unit_count' => $rr_unit_count,
+ 'list_of_branch_units' => $list_of_branch_units,
+ 'total_count' => $total_count,
+ 'uncommonValues' => $uncommonValues,
+ 'message' => 'Client branch updated successfully',
+ 'response_data' => $this->request->getPost()
+
+ ], 200);
+ } else {
+ return $this->respond(['status' => false, 'code' => 404, 'message' => 'Failed to update client branch'], 200);
+ }
+ }
+
public function saveLevelContacts($level_contact_data, $branch_id)
{
if (!empty($level_contact_data) && is_array($level_contact_data)) {
@@ -2088,6 +2417,7 @@ class ClientController extends AdminController
$sanitized_post_data['enrolment_visibility'] = $sanitized_post_data['enrolment_visibility'] ?? null ? 1 : 0;
$sanitized_post_data['is_lgbtq'] = $sanitized_post_data['is_lgbtq'] ?? null ? 1 : 0;
$sanitized_post_data['wellness_vendor_id'] = !empty($sanitized_post_data['wellness_vendor_id']) ? $sanitized_post_data['wellness_vendor_id'] : null;
+ $sanitized_post_data['cd_ac_pk'] = $sanitized_post_data['cd_ac_no'] ?? null;
if ($policy_type_id == 1 || $policy_type_id == 2 || $policy_type_id == 6 || $policy_type_id == 7) {
@@ -2126,6 +2456,8 @@ class ClientController extends AdminController
$insert = $this->clientPolicyModel->insert($sanitized_post_data);
if ($insert) {
+ // this function to create a policy transaction entry at the time of client policy create
+ $this->createPolicyTransactionInceptionEntry($insert, $sanitized_post_data);
$clientPoliceData = $this->clientPolicyModel->getClientPolicyByClientId($sanitized_post_data['client_id']);
$clientPoliceData['role'] = get_role_id();
return $this->respond(['status' => true, 'code' => 200, 'data' => $clientPoliceData, 'client_id' => $client_id, 'method' => 'CERATE', 'post_data' => $insert], 200);
@@ -2310,6 +2642,29 @@ class ClientController extends AdminController
}
}
+ public function createPolicyTransactionInceptionEntry($client_policy_id, $data)
+ {
+ $data['action_type'] = 'inception';
+ $data['client_policy_id'] = $client_policy_id;
+ $data['entry_from'] = 3;
+ $data['issuer_branch'] = 1;
+ $data['issuer'] = 2;
+ $data['status'] = 'completed';
+ $data['renewal_date'] = $data['policy_end_date'];
+ $data['bro_payable_by'] = 1;
+ $insert = $this->policyTransactionModel->insert($data);
+
+ if($insert){
+
+ $pcsd_data['pt_id'] = $insert;
+ $pcsd_data['insurer_id'] = $data['insurer_id'] ?? null;
+ $pcsd_data['insurer_branch_id'] = $data['insurer_branch_id'] ?? null;
+
+ $this->PTCOShareDetailsModel->insert($pcsd_data);
+ }
+ return $insert;
+ }
+
// Save Rack Rate function
@@ -2843,7 +3198,6 @@ class ClientController extends AdminController
}
}
-
private function updatePTCoShareTableEntry($policy_transaction_data, $old_client_policy_data, $data)
{
$updated_ids = [];
@@ -2889,9 +3243,6 @@ class ClientController extends AdminController
];
}
-
-
-
public function uploadVehicleFile($params = null)
{
$this->myLogger->logme('error', 'uploadVehicleFile function called');
@@ -3611,194 +3962,6 @@ class ClientController extends AdminController
}
}
- // public function enrollmentGMCDisplayValueTransform()
- // {
- // $data = [];
-
- // if ($this->request->getPost("waiverofpreexistingdiseases_display")) {
- // $data['Waiver of Pre-existing Diseases'] = $this->request->getPost("waiverofpreexistingdiseases");
- // }
-
- // if ($this->request->getPost("waiverof1234thyearexclusions_display")) {
- // $data['Waiver of 1, 2, 3 & 4th year Exclusions'] = $this->request->getPost("waiverof1,2,3&4thyearexclusions");
- // }
-
- // if ($this->request->getPost("waiverof30dayswaitingperiod_display")) {
- // $data['Waiver of 30 days waiting period'] = $this->request->getPost("waiverof30dayswaitingperiod");
- // }
-
- // if ($this->request->getPost("suminsuredenhancement_display")) {
- // $data['Sum Insured Enhancement'] = $this->request->getPost("suminsuredenhancement");
- // }
-
- // if ($this->request->getPost("waiver_of_90_days_waiting_period_display")) {
- // $data['Waiver of 90 Days Waiting Period'] = $this->request->getPost("waiver_of_90_days_waiting_period");
- // }
-
- // if ($this->request->getPost("waiver_of_other_waiting_periods_display")) {
- // $data['Waiver of Other Waiting Periods'] = $this->request->getPost("waiver_of_other_waiting_periods");
- // }
-
- // if ($this->request->getPost("maternity_benefit_display")) {
- // $data['Maternity Benefit'] = $this->request->getPost("maternity_benefit");
- // }
-
- // if ($this->request->getPost("9monthwaitingperiodwaived_display")) {
- // $data['9-month waiting Period - waived'] = $this->request->getPost("9monthwaitingperiodwaived");
- // }
-
- // if ($this->request->getPost("maternitycoverage_display")) {
- // $data['Maternity Coverage'] = $this->request->getPost("maternitycoverage");
- // }
-
- // if ($this->request->getPost("twindelivery_display")) {
- // $data['Twin Delivery'] = $this->request->getPost("twindelivery");
- // }
-
- // if ($this->request->getPost("well_baby_well_mother_expenses_display")) {
- // $data['Well baby / Well Mother Expenses'] = $this->request->getPost("well_baby_well_mother_expenses");
- // }
-
- // if ($this->request->getPost("preandpostnatal_display")) {
- // $data['Pre and Post natal'] = $this->request->getPost("preandpostnatal");
- // }
-
- // if ($this->request->getPost("infertility_treatment_coverage_display")) {
- // $data['Infertility Treatment Coverage'] = $this->request->getPost("infertility_treatment_coverage");
- // }
-
- // if ($this->request->getPost("babyday1cover_display")) {
- // $data['Baby Day 1 Cover'] = $this->request->getPost("babyday1cover");
- // }
-
- // if ($this->request->getPost("coverfromthedateofjoining_display")) {
- // $data['Cover from the date of Joining'] = $this->request->getPost("coverfromthedateofjoining");
- // }
-
- // if ($this->request->getPost("mid_term_addition_of_new_born_newly_wedded_spouse_display")) {
- // $data['Mid Term Addition of New Born / Newly Wedded Spouse'] = $this->request->getPost("mid_term_addition_of_new_born_newly_wedded_spouse");
- // }
-
- // if ($this->request->getPost("prehospitalizationcover_display")) {
- // $data['Pre Hospitalization Cover'] = $this->request->getPost("prehospitalizationcover");
- // }
-
- // if ($this->request->getPost("posthospitalizationcover_display")) {
- // $data['Post Hospitalization Cover'] = $this->request->getPost("posthospitalizationcover");
- // }
-
- // if ($this->request->getPost("congenitaldiseasesinternal_display")) {
- // $data['Congenital Diseases - Internal'] = $this->request->getPost("congenitaldiseasesinternal");
- // }
-
- // if ($this->request->getPost("congenitaldiseasesexternal_display")) {
- // $data['Congenital Diseases - External'] = $this->request->getPost("congenitaldiseasesexternal");
- // }
-
- // if ($this->request->getPost("copayzonewisecopay_display")) {
- // $data['Co-Pay/Zone wise Co Pay'] = $this->request->getPost("copayzonewisecopay");
- // }
-
- // if ($this->request->getPost("roomrentlimit_display")) {
- // $data['Room Rent Limit'] = $this->request->getPost("roomrentlimit");
- // }
-
- // if ($this->request->getPost("icu_limit_display")) {
- // $data['ICU Limit'] = $this->request->getPost("icu_limit");
- // }
-
- // if ($this->request->getPost("proportionatedeductionclause_display")) {
- // $data['Proportionate Deduction Clause'] = $this->request->getPost("proportionatedeductionclause");
- // }
-
- // if ($this->request->getPost("ailmentcapping_display")) {
- // $data['Ailment capping'] = $this->request->getPost("ailmentcapping");
- // }
-
- // if ($this->request->getPost("ailment_capping_details_display")) {
- // $data['Ailment capping Details'] = $this->request->getPost("ailment_capping_details");
- // }
-
- // if ($this->request->getPost("corporatebuffer_display")) {
- // $data['Corporate Buffer'] = $this->request->getPost("corporatebuffer");
- // }
-
- // if ($this->request->getPost("non_admissible_contingency_corporate_buffer_display")) {
- // $data['Non-Admissible / Contingency Corporate Buffer'] = $this->request->getPost("non_admissible_contingency_corporate_buffer");
- // }
-
- // if ($this->request->getPost("ambulancecharges_display")) {
- // $data['Ambulance Charges'] = $this->request->getPost("ambulancecharges");
- // }
-
- // if ($this->request->getPost("airambulance_display")) {
- // $data['Air Ambulance'] = $this->request->getPost("airambulance");
- // }
-
- // if ($this->request->getPost("reasonableandcustomarycharges_display")) {
- // $data['Reasonable and Customary Charges'] = $this->request->getPost("reasonableandcustomarycharges");
- // }
-
- // if ($this->request->getPost("daycaretreatment_display")) {
- // $data['Day Care Treatment'] = $this->request->getPost("daycaretreatment");
- // }
-
- // if ($this->request->getPost("lasiksurgery_display")) {
- // $data['Lasik Surgery'] = $this->request->getPost("lasiksurgery");
- // }
-
- // if ($this->request->getPost("ayushtreatmentcover_display")) {
- // $data['AYUSH treatment cover'] = $this->request->getPost("ayudhtreatmentcover");
- // }
-
- // if ($this->request->getPost("moderntreatmentsasperirdai_display")) {
- // $data['Modern treatments as per IRDAI'] = $this->request->getPost("moderntreatmentsasperirdai");
- // }
-
- // if ($this->request->getPost("opd_treatment_display")) {
- // $data['OPD Treatment'] = $this->request->getPost("opd_treatment");
- // }
-
- // if ($this->request->getPost("days_of_discharge_display")) {
- // $data['Claim Intimation Clause'] = $this->request->getPost("days_of_discharge");
- // }
-
- // if ($this->request->getPost("days_from_dod_display")) {
- // $data['Claim Submission'] = $this->request->getPost("days_from_dod");
- // }
-
- // if ($this->request->getPost("terrorism_display")) {
- // $data['Terrorism'] = $this->request->getPost("terrorism");
- // }
-
- // if ($this->request->getPost("widower_cover_display")) {
- // $data['Widower Cover'] = $this->request->getPost("widower_cover");
- // }
-
- // if ($this->request->getPost("breavement_cover_display")) {
- // $data['Breavement Cover'] = $this->request->getPost("breavement_cover");
- // }
-
- // if ($this->request->getPost("special_condition_display_value")) {
-
- // $specialConditionKeyValue = $this->request->getPost("special_condition_display_value") ?? [];
- // $specialConditionKeyValue = json_decode($specialConditionKeyValue, true);
-
- // if (is_array($specialConditionKeyValue) && count($specialConditionKeyValue) > 0) {
- // $mergedArray = array_merge(...array_map(fn($item) => (array) $item, $specialConditionKeyValue));
- // $data = array_merge($data, $mergedArray);
- // }
- // }
-
- // if(isset($data) && !empty($data)){
- // return $data;
- // }else{
- // $data = [];
- // return $data;
- // }
-
- // }
-
public function enrollmentGMCDisplayValueTransform()
{
$data = [];
@@ -3873,7 +4036,6 @@ class ClientController extends AdminController
return $data;
}
-
public function getterms()
{
$client_policy_id = $this->request->getVar('client_policy_id');
@@ -4034,94 +4196,6 @@ class ClientController extends AdminController
}
}
- // public function enrollmentGPADisplayValueTransform()
- // {
- // $data = [];
-
- // if ($this->request->getPost("accidentalDeathBenefit_display")) {
- // $data['Accidental Death Benefit'] = $this->request->getPost("accidentalDeathBenefit");
- // }
- // if ($this->request->getPost("permanentTotalDisablement_display")) {
- // $data['Permanent Total Disablement'] = $this->request->getPost("permanentTotalDisablement");
- // }
- // if ($this->request->getPost("permanentPartialDisablement_display")) {
- // $data['Permanent Partial Disablement'] = $this->request->getPost("permanentPartialDisablement");
- // }
- // if ($this->request->getPost("temporaryTotalDisablementBenefit_display")) {
- // $data['Temporary Total Disablement Benefit'] = $this->request->getPost("temporaryTotalDisablementBenefit");
- // }
- // if ($this->request->getPost("medical_expenses_medical_extension_display")) {
- // $data['Medical Expenses / Medical Extension (IPD)'] = $this->request->getPost("medical_expenses_medical_extension");
- // }
- // if ($this->request->getPost("opd_treatment_cover_display")) {
- // $data['OPD Treatment Cover'] = $this->request->getPost("opd_treatment_cover");
- // }
- // if ($this->request->getPost("ambulanceCharges_display")) {
- // $data['Ambulance Charges'] = $this->request->getPost("ambulanceCharges");
- // }
- // if ($this->request->getPost("repatriation_of_mortal_remains_display")) {
- // $data['Repatriation of Mortal Remains'] = $this->request->getPost("repatriation_of_mortal_remains");
- // }
- // if ($this->request->getPost("childrenEducationWelfareFund_display")) {
- // $data['Children Education Welfare Fund'] = $this->request->getPost("childrenEducationWelfareFund");
- // }
- // if ($this->request->getPost("terrorism_display")) {
- // $data['Terrorism'] = $this->request->getPost("terrorism");
- // }
- // if ($this->request->getPost("worldwideCover_display")) {
- // $data['Worldwide Cover'] = $this->request->getPost("worldwideCover");
- // }
- // if ($this->request->getPost("family_transportation_benefits_display")) {
- // $data['Family Transportation Benefits'] = $this->request->getPost("family_transportation_benefits");
- // }
- // if ($this->request->getPost("fractures_dislocation_burns_display")) {
- // $data['Fractures / Dislocation / Burns'] = $this->request->getPost("fractures_dislocation_burns");
- // }
- // if ($this->request->getPost("coma_display")) {
- // $data['Coma'] = $this->request->getPost("coma");
- // }
- // if ($this->request->getPost("carriageofDeadBody_display")) {
- // $data['Carriage of Dead Body'] = $this->request->getPost("carriageOfDeadBody");
- // }
- // if ($this->request->getPost("compassionateVisitExpenses_display")) {
- // $data['Compassionate Visit Expenses'] = $this->request->getPost("compassionateVisitExpenses");
- // }
- // if ($this->request->getPost("travel_expenses_for_medical_treatment_display")) {
- // $data['Travel expenses for Medical Treatment'] = $this->request->getPost("travel_expenses_for_medical_treatment");
- // }
- // if ($this->request->getPost("daily_cash_allowance_display")) {
- // $data['Daily cash Allowance'] = $this->request->getPost("daily_cash_allowance");
- // }
- // if ($this->request->getPost("artifical_limb_and_prosthesis_display")) {
- // $data['Artifical Limb and Prosthesis'] = $this->request->getPost("artifical_limb_and_prosthesis");
- // }
- // if ($this->request->getPost("animalSnakeInsectBite_display")) {
- // $data['Animal/Snake/Insect Bite'] = $this->request->getPost("animalSnakeInsectBite");
- // }
- // if ($this->request->getPost("air_ambulance_display")) {
- // $data['Air Ambulance'] = $this->request->getPost("air_ambulance");
- // }
-
- // if ($this->request->getPost("gpa_special_condition_display_value")) {
-
- // $specialConditionKeyValue = $this->request->getPost("gpa_special_condition_display_value") ?? [];
- // $specialConditionKeyValue = json_decode($specialConditionKeyValue, true);
-
- // if (is_array($specialConditionKeyValue) && count($specialConditionKeyValue) > 0) {
- // $mergedArray = array_merge(...array_map(fn($item) => (array) $item, $specialConditionKeyValue));
- // $data = array_merge($data, $mergedArray);
- // }
- // }
- // // print_r($data); die;
-
- // if (isset($data) && !empty($data)) {
- // return $data;
- // } else {
- // $data = [];
- // return $data;
- // }
- // }
-
public function enrollmentGPADisplayValueTransform()
{
$data = [];
@@ -6613,7 +6687,23 @@ class ClientController extends AdminController
}
public function sendextraparam()
- {
+ {
+ // $zipService = new \App\Libraries\ZipService();
+ // $source = WRITEPATH . 'uploads/hr_files';
+ // $destination = WRITEPATH . 'tmp/archive_' . date('Ymd') . '.zip';
+
+ // $result = $zipService->createLocalZip($source, $destination);
+
+ // if ($result['status']) {
+ // echo "File is ready at: " . $result['path'];
+ // } else {
+ // echo "Error creating zip: " . $result['message'];
+ // }
+
+ // die;
+
+ // $cd = $this->view_Deposit(2, 'rest', ['client_id' => 58, 'cd_ac_pk' => 94]);
+ // dd($cd);
// $return = db_connect()->table('jobs')->where('id', 1677)->get()->getRowArray();
// $return = $this->updatePolicyTransactionDataWhileClinetPolicyUpdate(json_decode($data['payload'], true));
// dd($return);
@@ -6626,7 +6716,10 @@ class ClientController extends AdminController
// $res = $medi_assist->MediAssistGetBenefDetails(['policy_no' => '97000034240400000030', 'file_id' => 389, 'return_type' => 'job', 'client_policy_id' => 6192 ]);
// dd($res);
- // $employeeController = new EmployeeController();
+ $employeeController = new EmployeeController();
+ // $response = $employeeController->getEmployeeEcardFromTmpFolderAndZipToS3(json_decode('{"batch_no":2,"last_emp_policy_id":"13218","folder_name":"bulk_ecards_IOCL-77448855996699885555_2026-02-05_09-32-22","processed_in_this_batch_data_count":7,"pdf_count":0,"hr_id":"1"}', true));
+ // $response = $employeeController->bulkEcardDownloadAsZipFromS3(json_decode('{"client_policy_id":"6066","hr_id":"1"}', true));
+ // dd($response);
// $employeeController->truncateFileData('633');
// $res = $this->getHrAccessData(4075); dd($res);
@@ -6644,8 +6737,10 @@ class ClientController extends AdminController
// $response = $ticketServiceController->tpaClaimDumpImporter(["file_id" => 48]); //vidal
// $response = $ticketServiceController->tpaClaimDumpImporter(["file_id" => 53]); //icici
// $response = $ticketServiceController->tpaClaimDumpImporter(["file_id" => 54]); //mediassist
- // $response = $ticketServiceController->tpaClaimDumpToTicketMasterImporters(["file_id" => 48]);
- // $response = $ticketServiceController->tpaClaimDumpToTicketMasterImporters(["file_id" => 48]);
+ // $response = $ticketServiceController->tpaClaimDumpToTicketMasterImporters(["file_id" => 48]); //vidal
+ // $response = $ticketServiceController->tpaClaimDumpToTicketMasterImporters(["file_id" => 54]); //mediassist
+
+ // $response = $ticketServiceController->tpaClaimDumpToTicketMasterImporters(["file_id" => 4]); //abhi
// dd($response);
// ---------- TICKET CONTROLLER --------------------------------------------------------------------------------
@@ -6738,7 +6833,7 @@ class ClientController extends AdminController
// $res = $EmpDataServiceController->importInceptionUpdateTPAandUHID(['file_id' => 310]); dd($res);//for live
// $res = $EmpDataServiceController->getInceptionBasePremium(["13332","13333","13334","13335","13336"]); dd($res);//for live
// $res = $EmpDataServiceController->getDeletionBasePremium(["13248","13250","13249","13247"], json_decode('{"employeeIds":["13248","13250","13249","13247"],"client_id":"3927","client_policy_id":"6183","client_branch_id":"1874","cd_ac_no":"CD9751909505","endorsement_no":"END1238","count":4,"event_name":"deletion","policy_name":"GMC","user_id":"48"}', true)); dd($res);//for live
- // $res = $EmpDataServiceController->makeEntryForBDSPolicyTransaction(json_decode('{"client_policy_id":"6187","endorsement_no":null,"emp_count":5,"action_type":"inception","no_of_insured":3,"no_of_dependent":0}', true)); dd($res);//for live
+ // $res = $EmpDataServiceController->makeEntryForBDSPolicyTransaction(json_decode('{"client_policy_id":"6187","endorsement_no":"000000001","emp_count":5,"action_type":"addition","no_of_insured":3,"no_of_dependent":0, "base_premium" : "1000", "gst" : "180", "policy_issue_date" : "2025-12-31"}', true)); dd($res);//for live
// $res = $EmpDataServiceController->sendMailForDownloadingECard(['ids' => $ids, 'client_policy_id' => $client_policy_id]);
// $res = $this->employeePolicyModel->getDeletionEmployeeDataForExportExcel($batch_data, 1); dd($result);
// $res = $this->employeePolicyModel->getSIEnhancementEmployeesDataForExportExcel($batch_data, 1);
@@ -8026,180 +8121,6 @@ class ClientController extends AdminController
$combinedHrAccessData = $this->constructHrAccessData($hrAccessData, $client_id ,$pre_client_data['id']);
return $combinedHrAccessData;
}
-
- // do not remove this commented items
- // public function constructHrAccessData($data, $client_id , $pre_client_id)
- // {
- // // print_rr($data);die;
-
- // $preHrs = $data['pre_hr_data'];
- // $postHrs = $data['post_hr_data'];
- // $hrAccessTableData = $data['hr_access_table_data'];
- // $merged = [];
-
- // // Merge based on mobile and email
- // foreach ($postHrs as $post) {
- // $found = false;
- // foreach ($preHrs as $index => $pre) {
-
- // if ( trim($post['hr_mobile']) == trim($pre['hr_mobile']) && trim($post['hr_mail']) == trim($pre['hr_mail']) ) {
-
- // $merged[] = [
- // 'pre_hr_id' => $pre['pre_hr_id'],
- // 'post_hr_id' => $post['post_hr_id'],
- // 'hr_name' => $post['hr_name'],
- // 'hr_mobile' => $post['hr_mobile'],
- // 'hr_mail' => $post['hr_mail'],
- // 'pre_branch_id' => $pre['pre_branch_id'] ?? null,
- // 'post_branch_id' => $post['post_branch_id'] ?? null,
- // 'post_branch_name' => $post['post_branch_name'] ?? null
- // ];
- // unset($preHrs[$index]); // remove matched pre_hr
- // $found = true;
- // break;
- // }
- // }
-
- // if (!$found) {
- // $merged[] = [
- // 'pre_hr_id' => null,
- // 'post_hr_id' => $post['post_hr_id'],
- // 'hr_name' => $post['hr_name'],
- // 'hr_mobile' => $post['hr_mobile'],
- // 'hr_mail' => $post['hr_mail'],
- // 'pre_branch_id' => $pre['pre_branch_id'] ?? null,
- // 'post_branch_id' => $post['post_branch_id'] ?? null ,
- // 'post_branch_name' => $post['post_branch_name'] ?? null
- // ];
- // }
- // }
-
- // // Remaining preHrs (not matched)
- // foreach ($preHrs as $pre) {
-
- // foreach ($merged as $value) {
- // if ( trim($pre['hr_mobile']) == trim($value['hr_mobile']) && trim($pre['hr_mail']) == trim($value['hr_mail']) ) {
- // continue 2; // Skip adding this pre_hr as it's already matched
- // }
- // }
-
- // $merged[] = [
- // 'pre_hr_id' => $pre['pre_hr_id'],
- // 'post_hr_id' => null,
- // 'hr_name' => $pre['hr_name'],
- // 'hr_mobile' => $pre['hr_mobile'],
- // 'hr_mail' => $pre['hr_mail'],
- // 'pre_branch_id' => $pre['pre_branch_id'] ?? null,
- // 'post_branch_id' => $post['post_branch_id'] ?? null ,
- // 'post_branch_name' => $post['post_branch_name'] ?? null
- // ];
- // }
-
- // // dd($merged);
-
- // $result = [];
-
- // if (empty($hrAccessTableData)) {
-
- // // No access data — fill result with hr data and other fields as null
- // foreach ($merged as $hr) {
- // $result[] = [
- // 'hr_access_table_pk' => null,
- // 'post_client_id' => $client_id ?? null,
- // 'pre_hr_id' => $hr['pre_hr_id'] ?? null,
- // 'post_hr_id' => $hr['post_hr_id'] ?? null,
- // 'allowed_pre_modules' => [],
- // 'allowed_post_modules' => [],
- // 'allowed_pre_policies' => [],
- // 'allowed_active_policies' => [],
- // 'allowed_cd' => [],
- // 'hr_name' => $hr['hr_name'] ?? null,
- // 'hr_mobile' => $hr['hr_mobile'] ?? null,
- // 'hr_mail' => $hr['hr_mail'] ?? null,
- // 'pre_branch_id' => $hr['pre_branch_id'] ?? null,
- // 'post_branch_id' => $hr['post_branch_id'] ?? null ,
- // 'post_branch_name' => $hr['post_branch_name'] ?? null ,
- // 'pre_client_id' => $pre_client_id ?? null
- // ];
- // }
- // } else {
- // // First create a map of HR data by post_hr_id for quick lookup
- // $hrMap = [];
- // foreach ($merged as $hr) {
- // $hrMap[$hr['post_hr_id']] = $hr;
- // }
-
- // // Process access data first
- // foreach ($hrAccessTableData as $access) {
- // $post_hr_id = $access['post_hr_id'];
-
- // // Check if this HR exists in our merged data
- // if (isset($hrMap[$post_hr_id])) {
- // $hr = $hrMap[$post_hr_id];
- // $temp_arr_key = $hr['hr_mobile'] . $hr['hr_mail'];
-
- // // Parse allowed modules
- // $allowed_modules = json_decode($access['allowed_modules'], true) ?? null;
- // $allowed_pre_modules = $allowed_modules['pre'] ?? [];
- // $allowed_post_modules = $allowed_modules['post'] ?? [];
-
- // $result[$temp_arr_key] = [
- // 'hr_access_table_pk' => $access['id'] ?? null,
- // 'post_client_id' => $access['post_client_id'] ?? null,
- // 'pre_hr_id' => $hr['pre_hr_id'] ?? null,
- // 'post_hr_id' => $hr['post_hr_id'] ?? null,
- // 'allowed_pre_modules' => $allowed_pre_modules,
- // 'allowed_post_modules' => $allowed_post_modules,
- // 'allowed_pre_policies' => json_decode($access['allowed_pre_policies'], true) ?? [],
- // 'allowed_active_policies' => json_decode($access['allowed_active_policies'], true) ?? [],
- // 'allowed_cd' => json_decode($access['allowed_cd'], true) ?? [],
- // 'hr_name' => $hr['hr_name'],
- // 'hr_mobile' => $hr['hr_mobile'],
- // 'hr_mail' => $hr['hr_mail'],
- // 'pre_branch_id' => $hr['pre_branch_id'] ?? null,
- // 'post_branch_id' => $hr['post_branch_id'] ?? null ,
- // 'post_branch_name' => $hr['post_branch_name'] ?? null ,
- // 'pre_client_id' => $pre_client_id ?? null
- // ];
-
- // // Remove from map so we know it's been processed
- // unset($hrMap[$post_hr_id]);
- // }
- // }
-
- // // Now process any remaining HRs that didn't have access records
- // foreach ($hrMap as $hr) {
- // $temp_arr_key = $hr['hr_mobile'] . $hr['hr_mail'];
-
- // $result[$temp_arr_key] = [
- // 'hr_access_table_pk' => null,
- // 'post_client_id' => $client_id ?? null,
- // 'pre_hr_id' => $hr['pre_hr_id'] ?? null,
- // 'post_hr_id' => $hr['post_hr_id'] ?? null,
- // 'allowed_pre_modules' => [],
- // 'allowed_post_modules' => [],
- // 'allowed_pre_policies' => [],
- // 'allowed_active_policies' => [],
- // 'allowed_cd' => [],
- // 'hr_name' => $hr['hr_name'] ?? null,
- // 'hr_mobile' => $hr['hr_mobile'] ?? null,
- // 'hr_mail' => $hr['hr_mail'] ?? null,
- // 'pre_branch_id' => $hr['pre_branch_id'] ?? null,
- // 'post_branch_id' => $hr['post_branch_id'] ?? null ,
- // 'post_branch_name' => $hr['post_branch_name'] ?? null ,
- // 'pre_client_id' => $pre_client_id ?? null
- // ];
- // }
- // }
-
-
- // $resultData['hr_access_data'] = array_values($result);
- // $resultData['pre_policy_data'] = $data['pre_policy_data'];
- // $resultData['post_policy_data'] = $data['post_policy_data'];
- // $resultData['post_cd_data'] = $data['post_cd_data'];
-
- // return $resultData;
- // }
public function constructHrAccessData($data, $client_id , $pre_client_id)
{
@@ -8455,7 +8376,180 @@ class ClientController extends AdminController
];
return ['status' => 'failed', 'code' => 500, 'message' => $th->getMessage(), 'error_data' => $errorData];
}
- }
+ }
+
+ public function constructHrAccessData_OLD($data, $client_id , $pre_client_id)
+ {
+ // print_rr($data);die;
+
+ $preHrs = $data['pre_hr_data'];
+ $postHrs = $data['post_hr_data'];
+ $hrAccessTableData = $data['hr_access_table_data'];
+ $merged = [];
+
+ // Merge based on mobile and email
+ foreach ($postHrs as $post) {
+ $found = false;
+ foreach ($preHrs as $index => $pre) {
+
+ if ( trim($post['hr_mobile']) == trim($pre['hr_mobile']) && trim($post['hr_mail']) == trim($pre['hr_mail']) ) {
+
+ $merged[] = [
+ 'pre_hr_id' => $pre['pre_hr_id'],
+ 'post_hr_id' => $post['post_hr_id'],
+ 'hr_name' => $post['hr_name'],
+ 'hr_mobile' => $post['hr_mobile'],
+ 'hr_mail' => $post['hr_mail'],
+ 'pre_branch_id' => $pre['pre_branch_id'] ?? null,
+ 'post_branch_id' => $post['post_branch_id'] ?? null,
+ 'post_branch_name' => $post['post_branch_name'] ?? null
+ ];
+ unset($preHrs[$index]); // remove matched pre_hr
+ $found = true;
+ break;
+ }
+ }
+
+ if (!$found) {
+ $merged[] = [
+ 'pre_hr_id' => null,
+ 'post_hr_id' => $post['post_hr_id'],
+ 'hr_name' => $post['hr_name'],
+ 'hr_mobile' => $post['hr_mobile'],
+ 'hr_mail' => $post['hr_mail'],
+ 'pre_branch_id' => $pre['pre_branch_id'] ?? null,
+ 'post_branch_id' => $post['post_branch_id'] ?? null ,
+ 'post_branch_name' => $post['post_branch_name'] ?? null
+ ];
+ }
+ }
+
+ // Remaining preHrs (not matched)
+ foreach ($preHrs as $pre) {
+
+ foreach ($merged as $value) {
+ if ( trim($pre['hr_mobile']) == trim($value['hr_mobile']) && trim($pre['hr_mail']) == trim($value['hr_mail']) ) {
+ continue 2; // Skip adding this pre_hr as it's already matched
+ }
+ }
+
+ $merged[] = [
+ 'pre_hr_id' => $pre['pre_hr_id'],
+ 'post_hr_id' => null,
+ 'hr_name' => $pre['hr_name'],
+ 'hr_mobile' => $pre['hr_mobile'],
+ 'hr_mail' => $pre['hr_mail'],
+ 'pre_branch_id' => $pre['pre_branch_id'] ?? null,
+ 'post_branch_id' => $post['post_branch_id'] ?? null ,
+ 'post_branch_name' => $post['post_branch_name'] ?? null
+ ];
+ }
+
+ // dd($merged);
+
+ $result = [];
+
+ if (empty($hrAccessTableData)) {
+
+ // No access data — fill result with hr data and other fields as null
+ foreach ($merged as $hr) {
+ $result[] = [
+ 'hr_access_table_pk' => null,
+ 'post_client_id' => $client_id ?? null,
+ 'pre_hr_id' => $hr['pre_hr_id'] ?? null,
+ 'post_hr_id' => $hr['post_hr_id'] ?? null,
+ 'allowed_pre_modules' => [],
+ 'allowed_post_modules' => [],
+ 'allowed_pre_policies' => [],
+ 'allowed_active_policies' => [],
+ 'allowed_cd' => [],
+ 'hr_name' => $hr['hr_name'] ?? null,
+ 'hr_mobile' => $hr['hr_mobile'] ?? null,
+ 'hr_mail' => $hr['hr_mail'] ?? null,
+ 'pre_branch_id' => $hr['pre_branch_id'] ?? null,
+ 'post_branch_id' => $hr['post_branch_id'] ?? null ,
+ 'post_branch_name' => $hr['post_branch_name'] ?? null ,
+ 'pre_client_id' => $pre_client_id ?? null
+ ];
+ }
+ } else {
+ // First create a map of HR data by post_hr_id for quick lookup
+ $hrMap = [];
+ foreach ($merged as $hr) {
+ $hrMap[$hr['post_hr_id']] = $hr;
+ }
+
+ // Process access data first
+ foreach ($hrAccessTableData as $access) {
+ $post_hr_id = $access['post_hr_id'];
+
+ // Check if this HR exists in our merged data
+ if (isset($hrMap[$post_hr_id])) {
+ $hr = $hrMap[$post_hr_id];
+ $temp_arr_key = $hr['hr_mobile'] . $hr['hr_mail'];
+
+ // Parse allowed modules
+ $allowed_modules = json_decode($access['allowed_modules'], true) ?? null;
+ $allowed_pre_modules = $allowed_modules['pre'] ?? [];
+ $allowed_post_modules = $allowed_modules['post'] ?? [];
+
+ $result[$temp_arr_key] = [
+ 'hr_access_table_pk' => $access['id'] ?? null,
+ 'post_client_id' => $access['post_client_id'] ?? null,
+ 'pre_hr_id' => $hr['pre_hr_id'] ?? null,
+ 'post_hr_id' => $hr['post_hr_id'] ?? null,
+ 'allowed_pre_modules' => $allowed_pre_modules,
+ 'allowed_post_modules' => $allowed_post_modules,
+ 'allowed_pre_policies' => json_decode($access['allowed_pre_policies'], true) ?? [],
+ 'allowed_active_policies' => json_decode($access['allowed_active_policies'], true) ?? [],
+ 'allowed_cd' => json_decode($access['allowed_cd'], true) ?? [],
+ 'hr_name' => $hr['hr_name'],
+ 'hr_mobile' => $hr['hr_mobile'],
+ 'hr_mail' => $hr['hr_mail'],
+ 'pre_branch_id' => $hr['pre_branch_id'] ?? null,
+ 'post_branch_id' => $hr['post_branch_id'] ?? null ,
+ 'post_branch_name' => $hr['post_branch_name'] ?? null ,
+ 'pre_client_id' => $pre_client_id ?? null
+ ];
+
+ // Remove from map so we know it's been processed
+ unset($hrMap[$post_hr_id]);
+ }
+ }
+
+ // Now process any remaining HRs that didn't have access records
+ foreach ($hrMap as $hr) {
+ $temp_arr_key = $hr['hr_mobile'] . $hr['hr_mail'];
+
+ $result[$temp_arr_key] = [
+ 'hr_access_table_pk' => null,
+ 'post_client_id' => $client_id ?? null,
+ 'pre_hr_id' => $hr['pre_hr_id'] ?? null,
+ 'post_hr_id' => $hr['post_hr_id'] ?? null,
+ 'allowed_pre_modules' => [],
+ 'allowed_post_modules' => [],
+ 'allowed_pre_policies' => [],
+ 'allowed_active_policies' => [],
+ 'allowed_cd' => [],
+ 'hr_name' => $hr['hr_name'] ?? null,
+ 'hr_mobile' => $hr['hr_mobile'] ?? null,
+ 'hr_mail' => $hr['hr_mail'] ?? null,
+ 'pre_branch_id' => $hr['pre_branch_id'] ?? null,
+ 'post_branch_id' => $hr['post_branch_id'] ?? null ,
+ 'post_branch_name' => $hr['post_branch_name'] ?? null ,
+ 'pre_client_id' => $pre_client_id ?? null
+ ];
+ }
+ }
+
+
+ $resultData['hr_access_data'] = array_values($result);
+ $resultData['pre_policy_data'] = $data['pre_policy_data'];
+ $resultData['post_policy_data'] = $data['post_policy_data'];
+ $resultData['post_cd_data'] = $data['post_cd_data'];
+
+ return $resultData;
+ }
public function saveHrAccessData()
{
@@ -9012,6 +9106,8 @@ class ClientController extends AdminController
$member_ecard_mail_template = $this->notificationModel->where('client_id', NULL)->where('template_name', 'member_ecard_mail')->get()->getResultArray()[0] ?? [];
$member_common_mail_template = $this->notificationModel->where('client_id', NULL)->where('template_name', 'member_common_mail')->get()->getResultArray()[0] ?? [];
+
+ $hr_cd_insufficient_balance_mail_template = $this->notificationModel->where('client_id', NULL)->where('template_name', 'hr_cd_insufficient_balance_mail')->get()->getResultArray()[0] ?? [];
$default_member_welcome_mail_template = [
'client_id' => $client_id,
@@ -9083,6 +9179,20 @@ class ClientController extends AdminController
'mail_content_copy' => null
];
+ $hr_cd_insufficient_balance_mail_template = [
+ 'client_id' => $client_id,
+ 'template_name' => 'hr_cd_insufficient_balance_mail',
+ 'subject' => $hr_cd_insufficient_balance_mail_template['subject'] ?? '',
+ 'mail_content' => $hr_cd_insufficient_balance_mail_template['mail_content'] ?? '',
+ 'mail_content_json' => $hr_cd_insufficient_balance_mail_template['mail_content_json'] ?? '',
+
+ 'created_by' => get_session_userid(),
+ 'created_at' => date('Y-m-d H:i:s'),
+ 'updated_by' => null,
+ 'updated_at' => date('Y-m-d H:i:s'),
+ 'mail_content_copy' => null
+ ];
+
$this->myLogger->logme('error', 'Default Mail Template Data ' . json_encode([
$default_member_welcome_mail_template,
$default_member_remainder_mail_template,
@@ -9096,24 +9206,14 @@ class ClientController extends AdminController
$default_member_remainder_mail_template,
$default_member_review_and_summary_mail_template,
$default_member_ecard_mail_template,
- $default_member_common_mail_template
+ $default_member_common_mail_template,
+ $hr_cd_insufficient_balance_mail_template,
]);
return $default_templates_inserted ? true : false;
}
- // public function downloadClientKycDocs_2()
- // {
-
- // $file = WRITEPATH . 'uploads/client_kyc_documents/' . $file_name; // Example file path
-
- // if (file_exists($file)) {
- // return $this->response->download($file, null)->setFileName($file_name);
- // } else {
- // return "File not found.";
- // }
- // }
public function downloadClientKycDocs_2($file_name = null)
{
if (!$file_name) {
diff --git a/app/Controllers/EmpDataServiceController.php b/app/Controllers/EmpDataServiceController.php
index 8d75b095..4a4e9faf 100755
--- a/app/Controllers/EmpDataServiceController.php
+++ b/app/Controllers/EmpDataServiceController.php
@@ -209,24 +209,23 @@ class EmpDataServiceController extends BaseController
//check CD amt insufficient only insurer, not tpa // DO NOT REMOVE THIS
if($export_data['insurer_or_tpa'] == 'insurer')
{
- if (!empty($cash_balance)) {
- clear_cd_balance_session();
- if ((int) $cash_balance['balance'] == (int) $totals) {
- $this->myLogger->logme('error', 'Inception export failed due to insufficient deposit amount.');
- $this->myLogger->logme('error', 'Inception export failed due to insufficient deposit amount. CASH BALANCE : {balance} and TOTAL AMOUNT : {total}', ['balance' => $cash_balance['balance'], 'total' => $totals]);
-
- $cd_session_data = json_encode(['cd_balance' => false, 'cd_amount' => $cash_balance['balance'], 'excel_file_amt' => $totals]);
- session()->set('cd_balance_info', $cd_session_data);
- session()->set('cd_balance', false);
-
- $hr_data = $this->getHrdataForInsufficientMailSend($export_data['client_branch_id']);
- $session_data = json_encode(['client_id' => $export_data['client_id'], 'hr_data' => $hr_data]);
- session()->set('hr_data', $session_data);
-
- }else{
- session()->set('cd_balance', true);
-
- }
+ if ((int) $cash_balance['balance'] < (int) $totals) {
+ clear_cd_balance_session(); // Clear old junk first
+
+ $cd_session_data = json_encode([
+ 'cd_balance' => false,
+ 'cd_amount' => $cash_balance['balance'],
+ 'excel_file_amt' => $totals
+ ]);
+
+ session()->set('cd_balance_info', $cd_session_data);
+ session()->set('cd_balance', 'insufficient'); // Use a string status for clarity
+
+ $hr_data = $this->getHrdataForInsufficientMailSend($export_data['client_branch_id']);
+ session()->set('hr_data', json_encode(['client_id' => $export_data['client_id'], 'hr_data' => $hr_data]));
+ }else{
+ session()->set('cd_balance', 'sufficient'); // Use a string status for clarity
+ session()->set('cd_balance_info', null);
}
}
@@ -735,17 +734,23 @@ class EmpDataServiceController extends BaseController
if($export_data['insurer_or_tpa'] == 'insurer')
{
if (!empty($cash_balance)) {
- if ((int) $cash_balance['balance'] < (int) $rounded_totals) {
- $this->myLogger->logme('error', 'Inception export failed due to insufficient deposit amount.');
- $this->myLogger->logme('error', 'Inception export failed due to insufficient deposit amount. CASH BALANCE : {balance} and TOTAL AMOUNT : {total}', ['balance' => $cash_balance['balance'], 'total' => $totals]);
- session()->set('cd_balance', false);
- session()->set('cd_amount', $cash_balance['balance']);
- session()->set('excel_file_amt', $rounded_totals);
+ if ((int) $cash_balance['balance'] < (int) $totals) {
+ clear_cd_balance_session(); // Clear old junk first
+
+ $cd_session_data = json_encode([
+ 'cd_balance' => false,
+ 'cd_amount' => $cash_balance['balance'],
+ 'excel_file_amt' => $totals
+ ]);
+
+ session()->set('cd_balance_info', $cd_session_data);
+ session()->set('cd_balance', 'insufficient'); // Use a string status for clarity
+
+ $hr_data = $this->getHrdataForInsufficientMailSend($export_data['client_branch_id']);
+ session()->set('hr_data', json_encode(['client_id' => $export_data['client_id'], 'hr_data' => $hr_data]));
}else{
- session()->set('cd_balance', true);
- session()->set('cd_amount', $cash_balance['balance']);
- session()->set('excel_file_amt', $rounded_totals);
-
+ session()->set('cd_balance', 'sufficient'); // Use a string status for clarity
+ session()->set('cd_balance_info', null);
}
}
}
@@ -1066,17 +1071,23 @@ class EmpDataServiceController extends BaseController
if($export_data['insurer_or_tpa'] != 'tpa')// check overal emp premium amt with cd balance only for insurer export, not tpa export
{
if (!empty($cash_balance)) {
- if ((int) $cash_balance['balance'] < (int) $totals) {
- $this->myLogger->logme('error', 'Inception export failed due to insufficient deposit amount.');
- $this->myLogger->logme('error', 'Inception export failed due to insufficient deposit amount. CASH BALANCE : {balance} and TOTAL AMOUNT : {total}', ['balance' => $cash_balance['balance'], 'total' => $totals]);
- session()->set('cd_balance', false);
- session()->set('cd_amount', $cash_balance['balance']);
- session()->set('excel_file_amt', $totals);
+ if ((int) $cash_balance['balance'] < (int) $totals) {
+ clear_cd_balance_session(); // Clear old junk first
+
+ $cd_session_data = json_encode([
+ 'cd_balance' => false,
+ 'cd_amount' => $cash_balance['balance'],
+ 'excel_file_amt' => $totals
+ ]);
+
+ session()->set('cd_balance_info', $cd_session_data);
+ session()->set('cd_balance', 'insufficient'); // Use a string status for clarity
+
+ $hr_data = $this->getHrdataForInsufficientMailSend($export_data['client_branch_id']);
+ session()->set('hr_data', json_encode(['client_id' => $export_data['client_id'], 'hr_data' => $hr_data]));
}else{
- session()->set('cd_balance', true);
- session()->set('cd_amount', $cash_balance['balance']);
- session()->set('excel_file_amt', $totals);
-
+ session()->set('cd_balance', 'sufficient'); // Use a string status for clarity
+ session()->set('cd_balance_info', null);
}
}
}
@@ -2195,6 +2206,7 @@ class EmpDataServiceController extends BaseController
'event_name' => $file['event_type'],
'policy_name' => $policy_name['policy_name'],
'user_id' => $user_id,
+ 'file_id' => $file_id,
]]);
$r = Jobs::addJob(['job_name' => 'makeEntryForBDSPolicyTransaction', 'payload' => [
@@ -2218,7 +2230,7 @@ class EmpDataServiceController extends BaseController
//send ecard mail if the event is tpa only
if ($file['insurer_or_tpa'] == 'tpa') {
- if ($get_policy_type['policy_type_id'] != 1) {
+ if (in_array($get_policy_type['policy_type_id'], [2, 3])) {
// generate e-card and store S3
$r = Jobs::addJob(['job_name' => 'bulkGenerateEcardAndStoreinS3', 'payload' => ['client_policy_id' => $client_policy_id]]);
@@ -2634,7 +2646,7 @@ class EmpDataServiceController extends BaseController
'status' => $status_val,
]);
- if($client_policy_data['policy_type_id'] != 1){
+ if(in_array($client_policy_data['policy_type_id'], [2, 3])){
// re-generate e-card and store S3
$r = Jobs::addJob(['job_name' => 'bulkGenerateEcardAndStoreinS3', 'payload' => ['client_policy_id' => $client_policy_id]]);
}
@@ -3378,6 +3390,7 @@ class EmpDataServiceController extends BaseController
'event_name' => $file['event_type'],
'policy_name' => $policy_name['policy_name'],
'user_id' => $user_id,
+ 'file_id' => $file_id,
]]);
$r = Jobs::addJob(['job_name' => 'makeEntryForBDSPolicyTransaction', 'payload' => [
@@ -3889,6 +3902,7 @@ class EmpDataServiceController extends BaseController
'event_name' => $file['event_type'],
'policy_name' => $policy_name['policy_name'],
'user_id' => $user_id,
+ 'file_id' => $file_id,
]]);
$r = Jobs::addJob(['job_name' => 'makeEntryForBDSPolicyTransaction', 'payload' => [
@@ -4373,7 +4387,8 @@ class EmpDataServiceController extends BaseController
'updated_by' => $arrayData['user_id'],
'event_name' => $arrayData['event_name'],
'is_active' => 1,
- 'cd_ac_pk' => $cd_ac_pk['cd_ac_pk']
+ 'cd_ac_pk' => $cd_ac_pk['cd_ac_pk'],
+ 'file_id' => $arrayData['file_id'],
];
$response = DepositHelper::saveDeposit($data, $arrayData['user_id']);
@@ -4510,7 +4525,8 @@ class EmpDataServiceController extends BaseController
'updated_by' => $arrayData['user_id'],
'event_name' => $arrayData['event_name'],
'is_active' => 1,
- 'cd_ac_pk' => $policy_data['cd_ac_pk']
+ 'cd_ac_pk' => $policy_data['cd_ac_pk'],
+ 'file_id' => $arrayData['file_id'],
];
DepositHelper::saveDeposit($data, $arrayData['user_id']);
@@ -4540,7 +4556,8 @@ class EmpDataServiceController extends BaseController
'updated_by' => $arrayData['user_id'],
'event_name' => $arrayData['event_name'],
'is_active' => 1,
- 'cd_ac_pk' => $policy_data['cd_ac_pk']
+ 'cd_ac_pk' => $policy_data['cd_ac_pk'],
+ 'file_id' => $arrayData['file_id'],
];
DepositHelper::saveDeposit($data, $arrayData['user_id']);
@@ -4652,7 +4669,8 @@ class EmpDataServiceController extends BaseController
'updated_by' => $arrayData['user_id'],
'event_name' => $arrayData['event_name'],
'is_active' => 1,
- 'cd_ac_pk' => $insurer_id['cd_ac_pk']
+ 'cd_ac_pk' => $insurer_id['cd_ac_pk'],
+ 'file_id' => $arrayData['file_id'],
];
$response = DepositHelper::saveDeposit($data, $arrayData['user_id']);
@@ -5418,7 +5436,7 @@ class EmpDataServiceController extends BaseController
$this->myLogger->logme("error", "Policy transaction inserted successfully: " . json_encode(['insert_id' => $insert_id]));
//do not remove this commented item
- $coShareDetails = $this->ConstructPTShareData($policy_data, $insert_id, $params, $lead_data);
+ $coShareDetails = $this->ConstructPTShareData($policy_data, $insert_id, $params, $lead_data, $params['action_type']);
$pt_co_share_id = $this->PTCOShareDetailsModel->insert($coShareDetails);
$this->myLogger->logme("error", "PT Co share data inserted successfully: " . json_encode(['pt_co_share_id' => $pt_co_share_id]));
@@ -5550,7 +5568,46 @@ class EmpDataServiceController extends BaseController
return $policyTransactionData;
}
- private function ConstructPTShareData($policy_data, $pt_id, $params, $lead_data)
+ private function ConstructPTShareData($policy_data, $pt_id, $params, $lead_data, $action_type)
+ {
+ $policyTypeModel = new PolicyTypeModel();
+ $policy_type_data = $policyTypeModel->where('is_active', 1)->where('id', $policy_data['policy_type_id'])->first();
+
+ // Determine if we should negate the values
+ $multiplier = (strtolower($action_type) === 'deletion') ? -1 : 1;
+
+ $coShareData = [
+ 'pt_id' => $pt_id,
+ 'insurer_id' => $policy_data['insurer_id'],
+ 'insurer_branch_id' => $policy_data['insurer_branch_id'],
+ 'bp_amt' => ($params['base_premium'] ?? 0) * $multiplier,
+ 'cop_amt' => ($params['base_premium'] ?? 0) * $multiplier,
+ 'bp_gst_amt' => ($params['gst'] ?? 0) * $multiplier,
+ 'bp_sgst' => 9, // Usually tax percentages remain positive, but multiply if this is an amount
+ 'bp_cgst' => 9,
+ 'co_share_type' => 1,
+ 'co_share_per' => 100,
+ 'standerd_bp_per' => $policy_type_data['ebp'],
+ 'pt_policy_issue_date' => $params['policy_issue_date'] ?? null,
+ 'amount' => (($params['base_premium'] ?? 0) + ($params['gst'] ?? 0)) * $multiplier,
+ ];
+
+ if(isset($policy_data['gst']) && $policy_data['gst'] != null){
+ $coShareData['bp_igst'] = $policy_data['gst'] ?? 0;
+ $coShareData['bp_sgst'] = 0;
+ $coShareData['bp_cgst'] = 0;
+ }
+
+ // Calculate exp_amt logic
+ $agreed_per = $lead_data['agreed_percentage'] ?? $policy_type_data['ebp'] ?? 0;
+ $coShareData['exp_amt'] = ((($params['base_premium'] ?? 0) * $agreed_per) / 100) * $multiplier;
+
+ $this->myLogger->logme("error", "Constructed PT co-share data: " . json_encode($coShareData));
+
+ return $coShareData;
+ }
+
+ private function ConstructPTShareDataOld($policy_data, $pt_id, $params, $lead_data, $action_type = null)
{
$policyTypeModel = new PolicyTypeModel();
$policy_type_data = $policyTypeModel->where('is_active', 1)->where('id', $policy_data['policy_type_id'])->first();
diff --git a/app/Controllers/EmployeeController.php b/app/Controllers/EmployeeController.php
index edcae43c..b279f1f2 100755
--- a/app/Controllers/EmployeeController.php
+++ b/app/Controllers/EmployeeController.php
@@ -31,6 +31,7 @@ use App\Models\UserModel;
use App\Models\PartnerEndorsementRequestModel;
use App\Models\TpaApiDataModel;
use App\Models\LevelContactModel;
+use App\Models\NotificationModel;
use App\Controllers\Jobs;
@@ -335,7 +336,7 @@ class EmployeeController extends AdminController
//endof validation process
if (isset($result['error_summary']) && count($result['error_summary'])) {
if(!empty($post_data)){
- return ['status' => true, 'message' => 'file rejected with errors', 'file_id' => $file_id];
+ return ['status' => false, 'message' => 'file rejected with errors', 'file_id' => $file_id];
}else{
return $this->respond(['dataStatus' => false, 'code' => 404, 'message' => 'file rejected with errors'], 200);
}
@@ -445,6 +446,7 @@ class EmployeeController extends AdminController
batch_files.amount,
batch_files.status,
batch_files.client_branch_id,
+ DATE_FORMAT(batch_files.policy_issue_date, '%d/%m/%Y') AS policy_issue_date,
CASE
WHEN batch_files.status IN ('partially success', 'in-progress-partially', 'failed-7')
@@ -483,7 +485,35 @@ class EmployeeController extends AdminController
}
public function getExcelFileErrors($file_id, $retun_type = null)
- {
+ {
+
+ $file_data = $this->fileModel->where('id', $file_id)->first();
+ $error = json_decode($file_data['reason'] ?? '{}', true);
+ if(!empty($error) && $retun_type == 'api'){
+ $send = isset($error['error_summary'][5]) || isset($error['error_summary'][6]) ? true : false;
+ if($send){
+
+
+ $string = $error['error_data'] ?? 'System error';
+
+ $errorMap = [
+ "Column order conflict" => "Invalid file format. Please use the sample file.",
+ ];
+
+ $message = $string; // Default to the original error
+
+ foreach ($errorMap as $keyword => $friendlyMessage) {
+ if (strpos($string, $keyword) !== false) {
+ $message = $friendlyMessage;
+ break; // Stop looking once we find a match
+ }
+ }
+
+
+ return $this->respond(['status' => false, 'code' => 404, 'message' => $message, 'data' => []], 200);
+ }
+ }
+
// $file_id = $this->request->uri->getSegment(3);
$empServiceController = new EmployeeServiceController();
@@ -4434,7 +4464,7 @@ class EmployeeController extends AdminController
* 4. SEQUENTIAL RE-QUEUE (SAFE)
* --------------------------------------------------------- */
if ($execution_mode === 'sequential' && $rowCount === $batch_size) {
- $this->myLogger->logme('info', "$log_search_context"."Re-queueing next batch - " . json_encode([
+ $this->myLogger->logme('error', "$log_search_context"."Re-queueing next batch - " . json_encode([
'next_batch' => $batch_no + 1,
'last_emp_id' => $new_last_emp_id
]));
@@ -4543,7 +4573,6 @@ class EmployeeController extends AdminController
}
}
-
public function insufficientCdBalanceHrMailSend()
{
$post_data = $this->request->getJson(true);
@@ -4554,29 +4583,38 @@ class EmployeeController extends AdminController
$client_data = $this->clientModel->where('is_active', 1)->where('id', $post_data['client_id'])->first();
- $common['mail_type'] = "insufficient_cd_balance_by_hr";
+ if(empty($client_data)){
+ return $this->respond(['status' => false, 'code' => 404, 'message' => 'No client found'], 200);
+ }
+
+ $notificationModal = new NotificationModel();
+ $notification_data = $notificationModal
+ ->where('client_id', $post_data['client_id'])
+ ->where('template_name', 'hr_cd_insufficient_balance_mail')
+ ->first();
+
+ if(empty($notification_data)){
+ return $this->respond(['status' => false, 'code' => 404, 'message' => 'No template found'], 200);
+ }
+
+ if(empty($notification_data['subject']) || empty($notification_data['mail_content'])){
+ return $this->respond(['status' => false, 'code' => 404, 'message' => 'Template subject or mail content is empty'], 200);
+ }
+
+ if(empty($notification_data['enabled']) || $notification_data['enabled'] != 1){
+ return $this->respond(['status' => false, 'code' => 404, 'message' => 'Template is disabled'], 200);
+
+ }
+
+ $common['mail_type'] = "hr_cd_insufficient_balance_mail";
$common['client_id'] = $post_data['client_id'];
- $subject = 'Insufficient CD Balance Notification';
- $mail_content = '
- Dear {{HR_NAME}},
-
- Greetings from Nhance.
-
- We would like to inform you that the CD balance for {{CLIENT_NAME}} is currently low / insufficient, which may impact further processing of insurance-related activities.
-
- Kindly request you to credit the required amount at the earliest to avoid any service disruption.
-
- Please let us know once the amount is credited, or if you need any clarification from our end.
-
- Thank you for your support and cooperation.
- ';
-
+ $subject = $notification_data['subject'];
+ $mail_content = $notification_data['mail_content'];
foreach ($post_data['mails'] as $hr_id => $hr_data) {
- $mail_content = str_ireplace('{{HR_NAME}}', $hr_data['name'], $mail_content);
- $mail_content = str_ireplace('{{CLIENT_NAME}}', $client_data['client_name'], $mail_content);
-
+ $mail_content = str_ireplace('{{hr_name}}', $hr_data['name'], $mail_content);
+ $mail_content = str_ireplace('{{client_name}}', $client_data['client_name'], $mail_content);
$res = MailHelper::send_email(['mail' => $hr_data['mail'], 'subject' => $subject, 'message' => $mail_content, 'common' => $common]);
}
@@ -4584,6 +4622,217 @@ class EmployeeController extends AdminController
}
+ public function clearCdSession()
+ {
+ clear_cd_balance_session();
+ return $this->response->setJSON(['status' => 'cleared']);
+ }
+ public function checkSessionStatus()
+ {
+ // Uses your existing get_cd_balance() helper
+ $data = get_cd_balance();
+
+ // Return as JSON so JavaScript can read it
+ return $this->response->setJSON($data);
+ }
+
+ public function bulkEcardDownloadAsZipFromS3($params)
+ {
+ try {
+ $limit = $params['limit'] ?? 100;
+ $batch_no = $params['batch_no'] ?? 1;
+ $last_id = $params['last_emp_policy_id'] ?? 0;
+
+ // Fetch batch data
+ $employee_data = $this->employeePolicyModel->getEmployeeDataWithPolicyUsingClientPolicyIdOrEmployeePolicyIds($params, $limit, $last_id);
+
+ if (empty($employee_data)) {
+
+ if(!empty($last_id)){
+ $this->myLogger->logme('error', "bulkEcardDownloadAsZipFromS3 - No more records after last_emp_policy_id: {$last_id}");
+ $this->myLogger->logme('error', "getEmployeeEcardFromTmpFolderAndZipToS3 - Queuing ZIP creation for folder: " . ($params['folder_name'] ?? 'N/A'));
+ $r = Jobs::addJob(['job_name' => 'getEmployeeEcardFromTmpFolderAndZipToS3', 'payload' => $params]);
+ }
+
+ return ['status' => true, 'message' => 'Proceeding to Zip'];
+ }
+
+ // Use a consistent folder name across batches (passed in params)
+ $folderName = $params['folder_name'] ?? 'bulk_ecards_' . $employee_data[0]['policy_no'] . '_' . date('Y-m-d_H-i-s');
+ $tempPath = FCPATH . 'tmp/' . $folderName . '/';
+
+ if (!is_dir($tempPath)) {
+ mkdir($tempPath, 0777, true);
+ }
+
+ $s3 = \Config\Services::getS3Service();
+ $pdf_count = 0;
+ $current_last_id = end($employee_data)['emp_policy_id'];
+
+ foreach ($employee_data as $emp_value) {
+ // Track the last ID in this batch
+ $current_last_id = $emp_value['emp_policy_id'];
+
+ $s3_key = 'ecard_' . $emp_value['name'] . '(' . $emp_value['emp_code'] . ')' . '_' . $emp_value['tpa_id'] . '.pdf';
+ $s3_key = $this->sanitizeFilePart($s3_key);
+
+ if ($s3->exists($s3_key)) {
+ $s3_url = $s3->getPresignedUrl($s3_key);
+ $pdf_content = file_get_contents($s3_url['url']);
+
+ if ($pdf_content !== false) {
+ file_put_contents($tempPath . $s3_key, $pdf_content);
+ $pdf_count++;
+ }
+ }
+ }
+
+ $hasMore = count($employee_data) == $limit;
+
+ $payload = [
+ 'batch_no' => $batch_no + 1,
+ 'last_emp_policy_id' => $current_last_id,
+ 'folder_name' => $folderName,
+ 'processed_in_this_batch_data_count' => count($employee_data),
+ 'pdf_count' => $pdf_count,
+ 'hr_id' => $params['hr_id'] ?? null
+ ];
+
+ if ($hasMore) {
+ $this->myLogger->logme('error', "bulkEcardDownloadAsZipFromS3 - Queuing next batch: " . json_encode($payload));
+ $r = Jobs::addJob(['job_name' => 'bulkEcardDownloadAsZipFromS3', 'payload' => $payload]);
+ $message = "Queuing next batch";
+ } else {
+ $this->myLogger->logme('error', "bulkEcardDownloadAsZipFromS3 - No more records after this batch. Next proceeding with getEmployeeEcardFromTmpFolderAndZipToS3");
+ $r = Jobs::addJob(['job_name' => 'getEmployeeEcardFromTmpFolderAndZipToS3', 'payload' => $payload]);
+ $message = "All batch completed. Next proceeding with getEmployeeEcardFromTmpFolderAndZipToS3";
+ }
+
+ return ['status' => true, 'message' => $message];
+
+ } catch (\Throwable $e) {
+
+ $mail_response = $this->sendMailToHrWithZipAttachments($params);
+
+ $context = [
+ 'error_message' => $e->getMessage(),
+ 'exception_class' => get_class($e),
+ 'file' => $e->getFile(),
+ 'line' => $e->getLine(),
+ 'trace' => $e->getTraceAsString(),
+ 'mail_response' => $mail_response,
+ 'params' => $params,
+ ];
+
+ // Log detailed context for debugging
+ $this->myLogger->logme('error', 'bulkEcardDownloadAsZipFromS3 - Exception' . json_encode($context, JSON_PRETTY_PRINT));
+
+ // Return a detailed, structured error response
+ return [
+ 'status' => false,
+ 'message' => 'Exception occurred during bulk e-card download and ZIP creation.',
+ 'error' => $context,
+ ];
+ }
+ }
+
+ public function getEmployeeEcardFromTmpFolderAndZipToS3($params)
+ {
+ try {
+
+ $zipService = new \App\Libraries\ZipService();
+
+ $source = FCPATH . 'tmp/' . $params['folder_name'];
+ $destination = '/';
+ $zipName = $params['folder_name'] . '.zip' ?? '';
+
+ $result = $zipService->zipAndUploadS3($source, $destination, $zipName);
+
+ if($result['status'] === false){
+ $this->myLogger->logme('error', "getEmployeeEcardFromTmpFolderAndZipToS3 - ZIP creation/upload failed: " . json_encode($result));
+ $params['url'] = null; // Indicate failure
+ }else{
+ $params['url'] = $result['presigned_url']['url'] ?? null;
+ }
+
+
+
+
+ $mail_response = $this->sendMailToHrWithZipAttachments($params);
+
+ return ['zip_responce' => $result, 'mail_response' => $mail_response];
+
+ } catch (\Throwable $e) {
+
+ $mail_response = $this->sendMailToHrWithZipAttachments($params);
+
+ $context = [
+ 'error_message' => $e->getMessage(),
+ 'exception_class' => get_class($e),
+ 'file' => $e->getFile(),
+ 'line' => $e->getLine(),
+ 'trace' => $e->getTraceAsString(),
+ 'mail_response' => $mail_response,
+ 'params' => $params,
+ ];
+
+ // Log detailed context for debugging
+ $this->myLogger->logme('error', 'getEmployeeEcardFromTmpFolderAndZipToS3 - Exception' . json_encode($context, JSON_PRETTY_PRINT));
+
+ // Return a detailed, structured error response
+ return [
+ 'status' => false,
+ 'message' => 'Exception occurred during bulk e-card download and ZIP creation.',
+ 'error' => $context,
+ ];
+
+ }
+ }
+
+ public function sendMailToHrWithZipAttachments($params)
+ {
+ $hr_id = $params['hr_id'] ?? null;
+ $url = $params['url'] ?? null;
+
+ if (empty($hr_id)) {
+ $this->myLogger->logme('error', "sendMailToHrWithZipAttachments - No HR ID provided.");
+ return ['status' => false, 'message' => 'No HR ID provided.'];
+ }
+
+ $hr_data = $this->LevelContactModel->where('id', $hr_id)->where('is_active', 1)->first();
+
+ if (empty($hr_data) || empty($hr_data['email'])) {
+ $this->myLogger->logme('error', "sendMailToHrWithZipAttachments - No valid HR data found for ID: {$hr_id}");
+ return ['status' => false, 'message' => 'No valid HR data found for ID: ' . $hr_id];
+ }
+
+ if(empty($url)){
+ $subject = "Employee Bulk E-Card Download Failed";
+ $message = "Dear {$hr_data['name']},Download E-Cards
Cancel
- Submit
+ Submit
@@ -884,7 +884,20 @@ table.dataTable tbody td {
+getFlashdata('error')) : ?>
+ getFlashdata('error') as $error) : ?>
+
+
+
+
+
+
+
+
+
+
+
+
+
+