File manager

File manager - Edit - /home/wwwroot/camplus.hk/master.camplus.hk/public_html/application/libraries/MY_Email.php

Back
<?php defined('BASEPATH') OR exit('No direct script access allowed'); /** * CodeIgniter Email Queue * * A CodeIgniter library to queue e-mails. * * @package CodeIgniter * @category Libraries * @author Thaynã Bruno Moretti * @link http://www.meau.com.br/ * @license http://www.opensource.org/licenses/mit-license.html * @github https://github.com/izn/codeigniter-mailqueue / class MY_Email extends CI_Email { // DB table private $table_email_queue = 'email_queue'; // Main controller private $main_controller = 'sys/queue_email/send_pending_emails'; // PHP Nohup command line private $phpcli = 'nohup php'; private $expiration = NULL; // Status (pending, sending, sent, failed) private $status; /* * Constructor / public function __construct($config = array()) { parent::__construct($config); log_message('debug', 'Email Queue Class Initialized'); $this->expiration = 605; $this->CI = & get_instance(); $this->CI->load->database('default'); } public function set_status($status) { $this->status = $status; return $this; } /** * Get * * Get queue emails. * @return mixed / public function get($limit = NULL, $offset = NULL) { if ($this->status != FALSE) $this->CI->db->where('status', $this->status); $query = $this->CI->db->get("{$this->table_email_queue}", $limit, $offset); return $query->result(); } /* * Save * * Add queue email to database. * @return mixed / public function send($skip_job = FALSE) { if ( $skip_job === TRUE ) { return parent::send(); } $date = date("Y-m-d H:i:s"); $to = is_array($this->_recipients) ? implode(", ", $this->_recipients) : $this->_recipients; $cc = implode(", ", $this->_cc_array); $bcc = implode(", ", $this->_bcc_array); $headers = serialize($this->_headers); //print_r($headers); $dbdata = array( 'to' => $to, 'cc' => $cc, 'bcc' => $bcc, 'message' => $this->_body, 'headers' => serialize($this->_headers), 'status' => 'pending', 'date' => $date ); return $this->CI->db->insert($this->table_email_queue, $dbdata); } /* * Start process * * Start php process to send emails * @return mixed / public function start_process() { $filename = FCPATH . 'index.php'; $exec = shell_exec("{$this->phpcli} {$filename} {$this->main_controller} > /dev/null &"); return $exec; } /* * Send queue * * Send queue emails. * @return void / public function send_queue() { $this->set_status('pending'); $emails = $this->get(); $this->CI->db->where('status', 'pending'); $this->CI->db->set('status', 'sending'); $this->CI->db->set('date', date("Y-m-d H:i:s")); $this->CI->db->update($this->table_email_queue); foreach ($emails as $email) { $recipients = explode(", ", $email->to); $cc = !empty($email->cc) ? explode(", ", $email->cc) : array(); $bcc = !empty($email->bcc) ? explode(", ", $email->bcc) : array(); $this->_headers = unserialize($email->headers); $this->to($recipients); $this->cc($cc); $this->bcc($bcc); $this->message($email->message); if ($this->send(TRUE)) { $status = 'sent'; } else { $status = 'failed'; //echo $this->print_debugger(); } $this->CI->db->where('id', $email->id); $this->CI->db->set('status', $status); $this->CI->db->set('date', date("Y-m-d H:i:s")); $this->CI->db->update($this->table_email_queue); } } /* * Retry failed emails * * Resend failed or expired emails * @return void */ public function retry_queue() { $expire = (time() - $this->expiration); $date_expire = date("Y-m-d H:i:s", $expire); $this->CI->db->set('status', 'pending'); $this->CI->db->where("(date < '{$date_expire}' AND status = 'sending')"); $this->CI->db->or_where("status = 'failed'"); $this->CI->db->update($this->table_email_queue); //echo 'reset queue' . PHP_EOL; log_message('debug', 'Email queue retrying...'); } }

| ver. 1.4 | Github | . | PHP 7.2.34 | Generation time: 0.17 | proxy | phpinfo | Settings