CHANGE_ADD_LOG_CRONE_FUNCTIONS : RV

This commit is contained in:
VENKATESHWARAN 2025-04-04 10:34:53 +05:30
parent 4258c00f9f
commit 051c0ab51f
2 changed files with 49 additions and 11 deletions

View File

@ -492,6 +492,9 @@ $routes->post("sendEmail", "EmployeeRestController::send_email");
$routes->get("getBackToEnrolledDetails", "EmployeeRestController::getBackToEnrolledDetails");
// Ticketing System
//crone job
$routes->cli('cli/enrollOpendAndClose', 'DashboardController::updatePolicyEnrollmentStatus');
$routes->cli("cli/sendCroneRemainderMail", "DashboardController::sendCroneRemainderMail");
// Ticketing System End's
$routes->get('enrollOpendAndClose', 'DashboardController::updatePolicyEnrollmentStatus');
$routes->get("sendCroneRemainderMail", "DashboardController::sendCroneRemainderMail");

View File

@ -201,12 +201,15 @@ class DashboardController extends AdminController
return $this->respond(['status' => 'success']);
}
//--------------- FOR CRONE JOB -----------------------------------------------------------------------------------------
public function updatePolicyEnrollmentStatus()
{
$clientPolicyModel = new ClientPolicyModel();
$myLogger = \Config\Services::mylogger();
$myLogger->logme('error', 'update Policy Enrollment Status Function called');
$myLogger->logme('error', 'OPEN OR CLOSE FOR ENROLLMENT UPDATE START TIME {{ ' . date('d-m-Y H:i:s a') . ' }}');
$client_policy_data = $clientPolicyModel->getPolicyDetailsForEnrollment();
$myLogger->logme('error', 'Fetched client policy data for Enrollment Status update');
@ -226,17 +229,29 @@ class DashboardController extends AdminController
if ($currentDate == $openDate) {
$clientPolicyModel->update($id, ['open_for_enrollment' => 1]);
$openEnrollment[] = $id;
$myLogger->logme('error', 'Updated policy ID ' . $id . ' to open for enrollment.');
// $myLogger->logme('error', 'Updated policy ID ' . $id . ' to open for enrollment.');
}
if ($closeDate < $currentDate) {
$clientPolicyModel->update($id, ['open_for_enrollment' => 0]);
$closeEnrollment[] = $id;
$myLogger->logme('error', 'Updated policy ID ' . $id . ' to close for enrollment.');
// $myLogger->logme('error', 'Updated policy ID ' . $id . ' to close for enrollment.');
}
}
$myLogger->logme('error', 'enrollment_status function completed');
$this->myLogger->logme('info', 'Policy Enrollment Status Update: ' . json_encode([
'status' => true,
'message' => 'Updated Policy Enrollment Status',
'open_policy_count' => count($openEnrollment),
'close_policy_count' => count($closeEnrollment),
'open_policy_ids' => $openEnrollment,
'close_policy_ids' => $closeEnrollment,
], JSON_PRETTY_PRINT));
$myLogger->logme('error', 'update Policy Enrollment Status Function completed');
$myLogger->logme('error', 'OPEN OR CLOSE FOR ENROLLMENT UPDATE END TIME {{ ' . date('d-m-Y H:i:s a') . ' }}');
return $this->respond([
'status' => true,
'message' => 'updated Policy Enrollment Status',
@ -252,7 +267,9 @@ class DashboardController extends AdminController
{
$clientPolicyModel = new ClientPolicyModel();
$myLogger = \Config\Services::mylogger();
$myLogger->logme('error', 'SEND REMINDER MAIL FUNCTION START TIME {{ ' . date('d-m-Y H:i:s a') . ' }}');
$client_policy_data = $clientPolicyModel->getPolicyDetailsForRemainder();
$myLogger->logme('error', 'Fetched client policy data');
@ -262,6 +279,8 @@ class DashboardController extends AdminController
$result = $this->sendRemainderMail($client_policy_data, 'crone');
$myLogger->logme('error', 'sendCroneRemainderMail function completed');
$myLogger->logme('error', 'SEND REMINDER MAIL FUNCTION END TIME {{ ' . date('d-m-Y H:i:s a') . ' }}');
if($result){
return json_encode(['status' => true, 'message' => 'Mail send successfully']);
@ -270,6 +289,9 @@ class DashboardController extends AdminController
}
}
//--------------------------------------------------------------------------------------------------------
public function featch_dashboard_data($type)
{
$pendingActionsController = new PendingActionsController;
@ -308,7 +330,7 @@ class DashboardController extends AdminController
public function sendRemainderMail($client_policy_data, $send_mail_for_manual_or_crone = null)
{
// $this->myLogger->logme('error', 'sendRemainderMail function called');
$this->myLogger->logme('error', 'send Remainder Mail function called');
// dd($client_policy_data, $send_mail_for_manual_or_crone);
@ -508,7 +530,7 @@ class DashboardController extends AdminController
}
} else {
$this->myLogger->logme('error', "SEND REMAINDER CRONE --- Remainder date is empty()");
$this->myLogger->logme('error', "send Remainder crone --- Remainder date is empty()");
}
}
@ -519,24 +541,37 @@ class DashboardController extends AdminController
}
}
// dd($reminder_whole_mail);
// dd($reminder_whole_mail, count($reminder_whole_mail));
// print_rr($reminder_whole_mail); die;
// Process and queue bulk emails
if (!empty($reminder_whole_mail) && count($reminder_whole_mail) > 0) {
$this->myLogger->logme('error', 'Remainder mail count: ' . count($reminder_whole_mail));
$reminder_whole_mail = array_chunk($reminder_whole_mail, 20);
foreach ($reminder_whole_mail as $key => $value) {
// $job_details = new Jobs();
$r = Jobs::addJob(['job_name' => 'bulk_mail', 'payload' => $value]);
$this->myLogger->logme('error', 'Bulk mail upload jobs completed successfully. Total: ' . count($value));
}
$this->myLogger->logme('error', 'Remainder mails sent successfully');
}else{
$this->myLogger->logme('error', "No reminder mail sent.");
}
if (count($reminder_whole_mail) > 0) {
$this->myLogger->logme('error', 'send Remainder Mail function completed');
// dd($reminder_whole_mail);
$mailCount = count($reminder_whole_mail);
if ($mailCount > 0) {
return true;
} else {
return false;
}
}
public function sendManualReminder($client_id, $client_branch_id, $client_policy_id = null)