FIX_PARENT_POLICY_WELCOME_MAIL_ISSE__AND_OPEN_CLOSE_DATE_FORMAT_ISSUE

This commit is contained in:
VENKATESHWARAN 2025-12-24 12:29:13 +05:30
parent 3a129f036d
commit a5dd2e76d9
2 changed files with 234 additions and 210 deletions

View File

@ -4623,7 +4623,7 @@ class ClientController extends AdminController
// $res = $employeeRestController->getExcelErrorData(['file_id' => 897]); // $res = $employeeRestController->getExcelErrorData(['file_id' => 897]);
// $employeeRestController->employeesOnboardPreprocess(['file_id' => 644]); // $employeeRestController->employeesOnboardPreprocess(['file_id' => 644]);
// $employeeRestController->employeesOnboardProcess(['file_id' => 835]); // $employeeRestController->employeesOnboardProcess(['file_id' => 835]);
// $res = $employeeRestController->employeesEnrollmentInsert(['file_id' => 1137]); // $res = $employeeRestController->employeesEnrollmentInsert(['file_id' => 1138]);
// $r = Jobs::addJob(['job_name' => 'employeesEnrollmentInsert','payload' => ['file_id' => 721]]); // $r = Jobs::addJob(['job_name' => 'employeesEnrollmentInsert','payload' => ['file_id' => 721]]);
// dd($res); // dd($res);

View File

@ -1987,21 +1987,19 @@ public function getFileMetaDataByFileId($file_id, $status = 'success'){
$file = $this->fileModel->find($file_id); $file = $this->fileModel->find($file_id);
// dd($file); // dd($file);
$return = []; $return = [];
if(!isset($file)) if (!isset($file)) {
{
//file not found in DB //file not found in DB
return array('status' => false, 'msg' => 'file not found in DB'); return array('status' => false, 'msg' => 'file not found in DB');
} }
$file_name_with_path = WRITEPATH."/uploads/excel/".$file['file_name']; $file_name_with_path = WRITEPATH . "/uploads/excel/" . $file['file_name'];
//check physical file //check physical file
if(!file_exists($file_name_with_path)) if (!file_exists($file_name_with_path)) {
{
//file not found update status and reason //file not found update status and reason
$message = "Physical file not found"; $message = "Physical file not found";
// echo $message; // echo $message;
$this->myLogger->logme('error',($message . ' for file id ' . $file_id)); $this->myLogger->logme('error', ($message . ' for file id ' . $file_id));
$this->fileModel->where('id', $file_id)->set(['status' => 'failed','reason' => json_encode(['error_summary' => array_count_values([5]),'error_data' => $message])])->update(); $this->fileModel->where('id', $file_id)->set(['status' => 'failed', 'reason' => json_encode(['error_summary' => array_count_values([5]), 'error_data' => $message])])->update();
return array('error_summary' => [5], 'error_data' => $message); return array('error_summary' => [5], 'error_data' => $message);
} }
@ -2010,21 +2008,21 @@ public function getFileMetaDataByFileId($file_id, $status = 'success'){
$sheet = $spreadsheet->getActiveSheet(); $sheet = $spreadsheet->getActiveSheet();
$highestRowAndColumn = $sheet->getHighestRowAndColumn(); $highestRowAndColumn = $sheet->getHighestRowAndColumn();
$result = ['error_type' => 2,'error_summary' => [], 'error_data' => [] ]; $result = ['error_type' => 2, 'error_summary' => [], 'error_data' => []];
$columns_to_check = $this->enrollment_excel_columns; $columns_to_check = $this->enrollment_excel_columns;
$keys = array_keys($columns_to_check); $keys = array_keys($columns_to_check);
$allowedHighestColumn = end($columns_to_check); $allowedHighestColumn = end($columns_to_check);
$excel_data = $sheet->rangeToArray('A1:' . $allowedHighestColumn['col_cell_name'] . $highestRowAndColumn['row']); $excel_data = $sheet->rangeToArray('A1:' . $allowedHighestColumn['col_cell_name'] . $highestRowAndColumn['row']);
// print_r($keys);die(); // print_r($keys);die();
//get existing units in the current branch //get existing units in the current branch
$existing_units = $this->clientBranchModel->getExisitingUnits(client_id: $file['client_id'],client_branch_id: $file['client_branch_id']); $existing_units = $this->clientBranchModel->getExisitingUnits(client_id: $file['client_id'], client_branch_id: $file['client_branch_id']);
//remove header //remove header
unset($excel_data[0]); unset($excel_data[0]);
// dd($excel_data); // dd($excel_data);
$emp_emails = []; $emp_emails = [];
//check is welcome notification enabled //check is welcome notification enabled
$notification = $this->notificationModel->where('client_id',$file['client_id'])->where('template_name','member_welcome_mail')->first(); $notification = $this->notificationModel->where('client_id', $file['client_id'])->where('template_name', 'member_welcome_mail')->first();
// dd($notification); // dd($notification);
$client_details = $this->clientModel->where('id', $file['client_id'])->first(); $client_details = $this->clientModel->where('id', $file['client_id'])->first();
$policy_details = $this->clientPolicyModel->where('id', $file['policy_id'])->first(); $policy_details = $this->clientPolicyModel->where('id', $file['policy_id'])->first();
@ -2034,27 +2032,24 @@ public function getFileMetaDataByFileId($file_id, $status = 'success'){
//get policy slab rates //get policy slab rates
// $slab_details = $this->policiesModel->getPolicySlabRatesForEmpOnboard($file['policy_id'],$file['client_id']); // $slab_details = $this->policiesModel->getPolicySlabRatesForEmpOnboard($file['policy_id'],$file['client_id']);
// dd($slab_details); // dd($slab_details);
$parent_policy_mail_sended_emp_code = [];
foreach ($excel_data as $key => $row) foreach ($excel_data as $key => $row) {
{
$is_row_empty = check_row_is_empty_or_null($row); $is_row_empty = check_row_is_empty_or_null($row);
if(!$is_row_empty) if (!$is_row_empty) {
{
$value = []; $value = [];
$policy_data = []; $policy_data = [];
$temp_unit = ''; $temp_unit = '';
if(empty($row[12])) if (empty($row[12])) {
{
$temp_unit = $existing_units[0]; $temp_unit = $existing_units[0];
} }
$value['emp_code'] = $row[1]; $value['emp_code'] = $row[1];
$value['name'] = $row[2]; $value['name'] = $row[2];
$value['doj'] = (!empty($row[3]) ? change_date_format($row[3],'d-M-Y','Y-m-d') : null ); $value['doj'] = (!empty($row[3]) ? change_date_format($row[3], 'd-M-Y', 'Y-m-d') : null);
$value['gender'] = $row[4]; $value['gender'] = $row[4];
$value['relationship'] = ucfirst(trim($row[5])); $value['relationship'] = ucfirst(trim($row[5]));
$value['dob'] = change_date_format($row[6],'d-M-Y','Y-m-d'); $value['dob'] = change_date_format($row[6], 'd-M-Y', 'Y-m-d');
$value['email_corporate'] = $row[7]; $value['email_corporate'] = $row[7];
$value['mobile'] = $row[8]; $value['mobile'] = $row[8];
$value['band'] = $row[10]; $value['band'] = $row[10];
@ -2069,50 +2064,48 @@ public function getFileMetaDataByFileId($file_id, $status = 'success'){
$value['temp']['emp_id'] = null; // dummy value for using exisitng funciton in model $value['temp']['emp_id'] = null; // dummy value for using exisitng funciton in model
if (strtolower(trim($value['relationship'])) === 'mother' || strtolower(trim($value['relationship'])) === 'father') { if (strtolower(trim($value['relationship'])) === 'mother' || strtolower(trim($value['relationship'])) === 'father') {
$relation = 'parent'; $relation = 'parent';
} else if(strtolower(trim($value['relationship'])) === 'son' || strtolower(trim($value['relationship'])) === 'daughter'){ } else if (strtolower(trim($value['relationship'])) === 'son' || strtolower(trim($value['relationship'])) === 'daughter') {
$relation = 'child'; $relation = 'child';
}else if((strtolower(trim($value['relationship'])) === 'father in law' || strtolower(trim($value['relationship'])) === 'mother in law') || (strtolower(trim($value['relationship'])) === 'father-in-law' || strtolower(trim($value['relationship'])) === 'mother-in-law')){ } else if ((strtolower(trim($value['relationship'])) === 'father in law' || strtolower(trim($value['relationship'])) === 'mother in law') || (strtolower(trim($value['relationship'])) === 'father-in-law' || strtolower(trim($value['relationship'])) === 'mother-in-law')) {
$relation = 'parent_in_law'; $relation = 'parent_in_law';
}else if(strtolower(trim($value['relationship'])) === 'spouse'){ } else if (strtolower(trim($value['relationship'])) === 'spouse') {
$relation = 'spouse'; $relation = 'spouse';
}else if(strtolower(trim($value['relationship'])) === 'self'){ } else if (strtolower(trim($value['relationship'])) === 'self') {
$relation = 'self'; $relation = 'self';
}else { } else {
$relation = ''; $relation = '';
} }
$value['family_floater_key'] = $relation; $value['family_floater_key'] = $relation;
$policy_data['basic_cover_si'] = $row[9]; $policy_data['basic_cover_si'] = $row[9];
$policy_data['date_coverage'] = $row[13] != "" && $row[13] != null ? change_date_format($row[13],'d-M-Y','Y-m-d') : null; $policy_data['date_coverage'] = $row[13] != "" && $row[13] != null ? change_date_format($row[13], 'd-M-Y', 'Y-m-d') : null;
$policy_data['client_policy_id'] = $file['policy_id']; $policy_data['client_policy_id'] = $file['policy_id'];
$policy_data['enrollment_open_date'] = $file['enrollment_open_date'] ?? null; $policy_data['enrollment_open_date'] = $file['enrollment_open_date'] ?? null;
$policy_data['enrollment_close_date'] = $file['enrollment_close_date'] ?? null; $policy_data['enrollment_close_date'] = $file['enrollment_close_date'] ?? null;
$employee = $this->employeeModel->checkExistingEmployee($value,$file['client_branch_id']); $employee = $this->employeeModel->checkExistingEmployee($value, $file['client_branch_id']);
unset($value['temp']); unset($value['temp']);
//save employee table //save employee table
// dd($employee['id']); // dd($employee['id']);
if($employee !== null) if ($employee !== null) {
{
$value['updated_by'] = $file['created_by']; $value['updated_by'] = $file['created_by'];
$value['id'] = $employee['id']; $value['id'] = $employee['id'];
$value['emp_status'] = 'draft'; $value['emp_status'] = 'draft';
$log_message = 'Enrollment Update Employee - '.$employee['name'].'('.$employee['emp_code'].') with PK '.$employee['id']; $log_message = 'Enrollment Update Employee - ' . $employee['name'] . '(' . $employee['emp_code'] . ') with PK ' . $employee['id'];
} } else {
else
{
$value['emp_status'] = 'draft'; $value['emp_status'] = 'draft';
$value['created_by'] = $file['created_by']; $value['created_by'] = $file['created_by'];
$log_message = 'Enrollment Insert Employee- '.$value['name'] .'('.$value['emp_code'] .') with PK '; $log_message = 'Enrollment Insert Employee- ' . $value['name'] . '(' . $value['emp_code'] . ') with PK ';
} }
$value = ExcelSanitizeHelper::sanitizeArrayData($value); $value = ExcelSanitizeHelper::sanitizeArrayData($value);
$this->employeeModel->save($value); $this->employeeModel->save($value);
if (isset($value['id'])) if (isset($value['id'])) {
{ $emp_id = $value['id']; } $emp_id = $value['id'];
else { $emp_id = $this->employeeModel->getInsertID(); } else {
$emp_id = $this->employeeModel->getInsertID();
$log_message .= $emp_id; $log_message .= $emp_id;
} }
@ -2120,47 +2113,42 @@ public function getFileMetaDataByFileId($file_id, $status = 'success'){
// if($emp_id != 0){ $log_message .= $emp_id; } // if($emp_id != 0){ $log_message .= $emp_id; }
// else{ $emp_id = $employee['id']; } // else{ $emp_id = $employee['id']; }
$this->myLogger->logme('error',$log_message); $this->myLogger->logme('error', $log_message);
//save policy table //save policy table
$employee_policy = $this->employeePolicyModel->checkExistingEmpPolicy(['employee_id' => $emp_id,'client_policy_id' => $file['policy_id']]); $employee_policy = $this->employeePolicyModel->checkExistingEmpPolicy(['employee_id' => $emp_id, 'client_policy_id' => $file['policy_id']]);
if(count($employee_policy)) if (count($employee_policy)) {
{
$policy_data['updated_by'] = $file['created_by']; $policy_data['updated_by'] = $file['created_by'];
$policy_data['id'] = $employee_policy[0]['id']; $policy_data['id'] = $employee_policy[0]['id'];
$policy_data['status'] = 'draft'; $policy_data['status'] = 'draft';
$policy_data['payable_employee'] = check_pay_by_employee_or_company($policy_details['policy_terms'], $value['relationship']); $policy_data['payable_employee'] = check_pay_by_employee_or_company($policy_details['policy_terms'], $value['relationship']);
$policy_data['file_id'] = isset($employee_policy[0]['file_id']) && $employee_policy[0]['file_id'] != '' ? $employee_policy[0]['file_id'] : $file_id ; $policy_data['file_id'] = isset($employee_policy[0]['file_id']) && $employee_policy[0]['file_id'] != '' ? $employee_policy[0]['file_id'] : $file_id;
$log_message = 'Update Employee Policy for '. $value['name'].'('. $value['emp_code'].') with PK- ' . $employee_policy[0]['id'] .' client policy ID '.$employee_policy[0]['client_policy_id'].' with SI '.$policy_data['basic_cover_si']; $log_message = 'Update Employee Policy for ' . $value['name'] . '(' . $value['emp_code'] . ') with PK- ' . $employee_policy[0]['id'] . ' client policy ID ' . $employee_policy[0]['client_policy_id'] . ' with SI ' . $policy_data['basic_cover_si'];
// echo 'insert policy'; // echo 'insert policy';
} } else {
else
{
$policy_data['employee_id'] = $emp_id; $policy_data['employee_id'] = $emp_id;
$policy_data['client_policy_id'] = $file['policy_id']; $policy_data['client_policy_id'] = $file['policy_id'];
$policy_data['created_by'] = $file['created_by']; $policy_data['created_by'] = $file['created_by'];
$policy_data['status'] = 'draft'; $policy_data['status'] = 'draft';
$policy_data['payable_employee'] = check_pay_by_employee_or_company($policy_details['policy_terms'], $value['relationship']); $policy_data['payable_employee'] = check_pay_by_employee_or_company($policy_details['policy_terms'], $value['relationship']);
$policy_data['file_id'] = $file_id; $policy_data['file_id'] = $file_id;
$log_message = 'Insert Employee Policy for '. $value['name'].'('. $value['emp_code'].') - client policy id -'. $file['policy_id'].' - with SI '.$policy_data['basic_cover_si']; $log_message = 'Insert Employee Policy for ' . $value['name'] . '(' . $value['emp_code'] . ') - client policy id -' . $file['policy_id'] . ' - with SI ' . $policy_data['basic_cover_si'];
// echo 'update policy'; // echo 'update policy';
} }
log_message('error',json_encode($policy_data)); log_message('error', json_encode($policy_data));
// dd($policy_data); // dd($policy_data);
$this->employeePolicyModel->save($policy_data); $this->employeePolicyModel->save($policy_data);
$emp_policy_id = $this->employeePolicyModel->getInsertID(); $emp_policy_id = $this->employeePolicyModel->getInsertID();
$this->myLogger->logme('error',$log_message); $this->myLogger->logme('error', $log_message);
$employeeRestController = new EmployeeRestController(); $employeeRestController = new EmployeeRestController();
$employeeRestController->updatePremiumAmount($file['policy_id'], $value['emp_code'], $file['client_branch_id']); $employeeRestController->updatePremiumAmount($file['policy_id'], $value['emp_code'], $file['client_branch_id']);
//save email of self for send mail later //save email of self for send mail later
if (isset($notification) && $notification['enabled'] == 1 && $notification['mail_content'] != '') if (isset($notification) && $notification['enabled'] == 1 && $notification['mail_content'] != '') {
{ if (strtolower($value['relationship']) == 'self' && $value['email_corporate'] != "") {
if(strtolower($value['relationship']) == 'self' && $value['email_corporate'] != "")
{
$params['dataToInsert'] = $value; //holds employee master data $params['dataToInsert'] = $value; //holds employee master data
$params['notification'] = $notification; $params['notification'] = $notification;
$params['client_data'] = $client_details; $params['client_data'] = $client_details;
@ -2177,9 +2165,45 @@ public function getFileMetaDataByFileId($file_id, $status = 'success'){
//store email and mail content via helper to send notification //store email and mail content via helper to send notification
$emp_emails[] = sendMailNotification::sendMailNotification('member_welcome_mail', $params); $emp_emails[] = sendMailNotification::sendMailNotification('member_welcome_mail', $params);
} else if ($policy_details['policy_type_id'] == 3 && $policy_details['is_addon'] == 3 && !in_array($row[1], $parent_policy_mail_sended_emp_code)) {
$sefData = $this->employeeModel
->where('is_active', 1)
->whereIn('emp_status', ['draft', 'enrolled'])
->where('family_floater_key', 'self')
->where('emp_code', $row[1])
->where('client_id', $file['client_id'])
->where('client_branch_id', $file['client_branch_id'])
->where('email_corporate is not null')
->first();
if (!empty($sefData)) {
$value['email_corporate'] = $sefData['email_corporate'];
$value['name'] = $sefData['name'];
$value['mobile'] = $sefData['mobile'];
$params['dataToInsert'] = $value; //holds employee master data
$params['notification'] = $notification;
$params['client_data'] = $client_details;
$params['common'] = [
'client_id' => $file['client_id'],
'client_branch_id' => $file['client_branch_id'],
'client_policy_id' => $file['policy_id'],
'employee_policy_id' => $emp_policy_id ?? null,
'employee_id' => $emp_id,
'mail_type' => 'member_welcome_mail',
];
$params['enrollment_open_date'] = $file['enrollment_open_date'] ?? null;
$params['enrollment_close_date'] = $file['enrollment_close_date'] ?? null;
//store email and mail content via helper to send notification
$emp_emails[] = sendMailNotification::sendMailNotification('member_welcome_mail', $params);
$parent_policy_mail_sended_emp_code[] = $row[1];
} }
} }
}// endof if row is empty check }
} // endof if row is empty check
} //end of for loop } //end of for loop
// dd($emp_emails); // dd($emp_emails);
@ -2195,13 +2219,13 @@ public function getFileMetaDataByFileId($file_id, $status = 'success'){
} }
} }
$this->fileModel->where('id', $file_id)->set(['status' => 'success','reason' => ''])->update(); $this->fileModel->where('id', $file_id)->set(['status' => 'success', 'reason' => ''])->update();
$this->myLogger->logme("error",'{file_id} uploaded success',['file_id' => $file_id]); $this->myLogger->logme("error", '{file_id} uploaded success', ['file_id' => $file_id]);
$this->setPullNotification($this->getFileMetaDataByFileId($file_id,'success')); $this->setPullNotification($this->getFileMetaDataByFileId($file_id, 'success'));
return true; return true;
}//end of employeesEnrollmentInsert } //end of employeesEnrollmentInsert
} }