";
@@ -4946,4 +4973,193 @@ class LeadsController extends BaseController
return $html;
}
+
+ // function for insurer remainder mail cron job
+ public function remainderForQcr()
+ {
+ $lead_data = $this->leadsModel
+ ->select(
+ 'leads.*,
+ user_profiles.email as created_person_email,
+ policy_type.policy_type,
+ policy_type.long_name
+ ')
+ ->join('policy_type', 'leads.policy_type_id = policy_type.id')
+ ->join('user_profiles', 'leads.created_by = user_profiles.id', 'left')
+ ->where('leads.is_active', 1)
+ ->where('user_profiles.is_active', 1)
+ ->where('leads.status', 'rfq_sent')
+ ->where('leads.next_reminder_date', date('Y-m-d'))
+ ->findAll();
+
+ // dd($lead_data);
+
+ if (count($lead_data) == 0) {
+ $this->myLogger->logme("info", "No leads found for reminder mail at " . date('Y-m-d H:i:s'));
+ print_r(["status" => true, "message" => "There is no data to send reminder mail"]);
+ return ["status" => true, "message" => "There is no data to send reminder mail"];
+
+ }
+
+ $from_mail = "im@nhanceindia.in";
+ $subject = "Reminder for RFQ";
+ $content = `
+ Dear Sir,
+ Greetings from Nhance India!
+ This is a gentle reminder regarding our earlier mail about the RFQ for the {{POLICY_TYPE}} policy pertaining to {{CLIENT_NAME}}.
+ We kindly request you to share the competitive quotes at the earliest possible convenience.
+ In case of any clarification, please feel free to contact us.
+ Thank you for your prompt attention to this matter.
+ Best regards,
+ Nhance India
+
+ `;
+
+ $reminder_sended_lead = [];
+
+ foreach ($lead_data as $lead) {
+
+ $leadId = $lead['id'];
+ $reply_to = $lead['created_person_email'] ?? "";
+
+ if (isset($lead['policy_end_date']) && $lead['policy_end_date'] != null) {
+ $subject = "{{CLIENT_NAME}} _ {{POLICY_TYPE}} _ {{RFQ_OR_QCR}} _ {{POLICY_YEAR}} {{POLICY_END_DATE}}";
+ } else {
+ $subject = "{{CLIENT_NAME}} _ {{POLICY_TYPE}} _ {{RFQ_OR_QCR}} _ {{POLICY_YEAR}}";
+ }
+
+ $mail_content = $this->transformMailContent($lead, $content, "RFQ");
+ $mail_subject = $this->transformMailContent($lead, $subject, "RFQ");
+
+
+ $this->myLogger->logme("info", "Processing lead_id={$leadId} for reminder mails");
+
+ // get sales person + created_by emails
+ $sales_person_emails = $this->userModel
+ ->select('email')
+ ->where('is_active', 1)
+ ->whereIn('id', json_decode($lead['salse_person_id'] ?? "[]", true))
+ ->findAll();
+
+ $email_list = array_column($sales_person_emails, 'email');
+ if (!empty($reply_to)) {
+ $email_list[] = $reply_to;
+ }
+ $email_list = array_filter(array_unique($email_list));
+ $email_string = implode(',', $email_list);
+
+ // Get latest sent mail timestamp
+ $createdAtRow = $this->gmailSentHistoryModel
+ ->select("DATE_FORMAT(created_at, '%Y-%m-%d %H:%i') as created_at", false)
+ ->where('isactive', 1)
+ ->where('mail_type', 'insurer')
+ ->where('pk', $leadId)
+ ->orderBy('id', 'desc')
+ ->first();
+
+ if (!$createdAtRow) {
+ $this->myLogger->logme("warning", "No sent history found for lead_id={$leadId}, skipping...");
+ continue;
+ }
+
+ $createdAt = $createdAtRow['created_at'];
+
+ // Fetch mail data for that timestamp
+ $mail_datas = $this->gmailSentHistoryModel
+ ->where('isactive', 1)
+ ->where('mail_type', "insurer")
+ ->where('pk', $leadId)
+ ->where("DATE_FORMAT(created_at, '%Y-%m-%d %H:%i')", $createdAt)
+ ->findAll();
+
+ if (empty($mail_datas)) {
+ $this->myLogger->logme("warning", "No mail data found for lead_id={$leadId} at created_at={$createdAt}");
+ continue;
+ }
+
+ // Filter only pending insurers
+ $quote_received_insurer = json_decode($lead['quote_received_insurer'] ?? "[]", true);
+ $reminder_mail_data = [];
+
+ if (empty($quote_received_insurer)) {
+ $reminder_mail_data = $mail_datas;
+ } else {
+ foreach ($mail_datas as $mail_value) {
+ $insurer_id = $mail_value['common'] ?? "";
+ if (!in_array($insurer_id, $quote_received_insurer)) {
+ $reminder_mail_data[] = $mail_value;
+ }
+ }
+ }
+
+ if (empty($reminder_mail_data)) {
+ $this->myLogger->logme("info", "All insurers already responded for lead_id={$leadId}, no reminder needed");
+ continue;
+ }
+
+ $this->myLogger->logme("info", "Sending " . count($reminder_mail_data) . " reminder mail(s) for lead_id={$leadId}");
+
+ $common = ['module' => "leads", 'pk' => $leadId, 'mail_type' => "remainder", 'common' => null];
+
+ foreach ($reminder_mail_data as $content) {
+ $insurerId = $content['common'] ?? null;
+ $common['common'] = $insurerId;
+
+ try {
+
+ if ($lead['is_insurer_auto_mail'] == 1) {
+ // send reminder to insurer
+ $res = MailHelper::send_email([
+ 'from_mail' => $from_mail,
+ 'mail' => $content['mail'] ?? "",
+ 'cc' => json_decode($content['cc'] ?? "", true) ?? "",
+ 'subject' => $mail_subject ?? "",
+ 'message' => $mail_content ?? "",
+ 'reply_to' => $reply_to,
+ 'bcc' => json_decode($content["bcc"] ?? "", true) ?? "",
+ 'common' => $common
+ ]);
+ $this->myLogger->logme("info", "Reminder mail sent to the insurer | lead_id={$leadId}, insurer_id={$insurerId}, response=" . json_encode($res));
+ }
+
+ $reminder_sended_lead[] = [
+ 'lead_id' => $leadId,
+ 'insurer_id' => $insurerId,
+ 'response' => $res
+ ];
+
+ } catch (\Throwable $e) {
+ $errorDetails = [
+ 'error_message' => $e->getMessage(),
+ 'file' => $e->getFile(),
+ 'line' => $e->getLine(),
+ 'stack_trace' => $e->getTraceAsString(),
+ ];
+ $this->myLogger->logme("error", "Exception while sending reminder | lead_id={$leadId}, insurer_id={$insurerId}, error=" . json_encode($errorDetails));
+ $reminder_sended_lead[] = [
+ 'lead_id' => $leadId,
+ 'insurer_id' => $insurerId,
+ 'response' => ['status' => false, 'error' => $errorDetails]
+ ];
+ }
+
+ // send reminder to sales person / creator only
+ $internal_mail_response = MailHelper::send_email([
+ 'mail' => $from_mail,
+ 'cc' => $email_string,
+ 'subject' => $mail_subject ?? "",
+ 'message' => $mail_content ?? "",
+ 'common' => $common
+ ]);
+
+ $this->myLogger->logme("info", "Reminder mail sent to sales persons | lead_id={$leadId}, recipients={$email_string}, response=" . json_encode($internal_mail_response));
+
+
+ }
+ }
+
+ return ['status' => true, "data" => $reminder_sended_lead];
+ }
+
+
}