Newsletter.php

Go to the documentation of this file.

<?php

namespace Combu;

define ("NEWSLETTER_STATUS_READY", 0);
define ("NEWSLETTER_STATUS_SENT", 1);

class Newsletter extends DataClass {

    const TABLE_NAME = "Newsletter";

    public $Id = 0;
    public $IdAccount = 0;
    public $IdApp = 0;
    public $Subject = "";
    public $Body = "";
    public $IsHtml = 1;
    public $DateCreation = "";
    public $DateSent = "";
    public $Status = NEWSLETTER_STATUS_READY;
    public $LogMessage = "";

    public function __construct($src = null, $stripSlashes = false) {
        global $Database;
        if ($src == null)
            return;
        if (is_array($src)) {
            // Load by array
            $this->_loadByRow($src, $stripSlashes);
        } else if (is_numeric($src) && intval($src) > 0) {
            // Load by Id
            $this->_loadFilter(self::GetTableName(__CLASS__), "Id = " . intval($src));
        }
    }

    public static function Load ($idApp = 0, $limit = null, $offset = null, &$count = null, $returnArray = false) {
        $where = "";
        if ($idApp > 0) {
            $where = sprintf("IdApp = %d", $idApp);
        }
        return self::_load(self::GetTableName(__CLASS__), ($returnArray ? "" : __CLASS__), $where, NULL, $limit, $offset, $count);
    }

    public function Save() {
        global $Database;
        if ($this->Id > 0) {
            $query = sprintf("UPDATE %s SET Subject = '%s', Body = '%s', Status = %d, DateSent = %s, LogMessage = '%s' WHERE Id = %d",
                    self::GetTableName(__CLASS__),
                    $Database->Escape($this->Subject),
                    $Database->Escape($this->Body),
                    $this->Status,
                    $Database->EscapeDate($this->DateSent),
                    $Database->Escape($this->LogMessage),
                    $this->Id);
        } else {
            $this->DateCreation = date("Y-m-d H:i:s");
            $query = sprintf("INSERT INTO %s (IdAccount, IdApp, Subject, Body, IsHtml, DateCreation, Status, LogMessage) VALUES (%d, %d, '%s', '%s', %d, %s, %d, '{}')",
                    self::GetTableName(__CLASS__),
                    $this->IdAccount,
                    $this->IdApp,
                    $Database->Escape($this->Subject),
                    $Database->Escape($this->Body),
                    $this->IsHtml,
                    $Database->EscapeDate($this->DateCreation),
                    $this->Status);
        }
        //echo "<pre>".  htmlentities($query, ENT_QUOTES)."</pre>";
        if ($Database->Query($query)) {
            if ($this->Id < 1) {
                $this->Id = $Database->InsertedId();
            }
            return TRUE;
        }
        return FALSE;
    }

    public function Delete() {
        if ($this->Id > 0 && $this->_Delete(self::GetTableName(__CLASS__), sprintf("Id = %d", $this->Id))) {
            $this->_Delete(self::GetTableName(NewsletterLog::class), sprintf("IdNewsletter = %d", $this->Id));
            return TRUE;
        }
        return FALSE;
    }
    
    public static function Prune() {
        self::TruncateClass(__CLASS__);
        self::TruncateClass(NewsletterLog::class);
    }
    
    public function Send() {
        if ($this->Id > 0 && $this->Status != NEWSLETTER_STATUS_SENT) {
            $this->DateSent = date("Y-m-d H:i:s");
            $this->Status = NEWSLETTER_STATUS_SENT;
            $sent = 0;
            $skipped = 0;
            $errors = 0;
            $accounts = Account::LoadAny($this->IdApp);
            foreach ($accounts as $account) {
                if (empty($account->Email) || !$account->Enabled) {
                    $skipped++;
                } else {
                    $recordLog = new NewsletterLog();
                    $recordLog->IdNewsletter = $this->Id;
                    $recordLog->IdAccount = $account->Id;
                    $mail = new Mail();
                    $mail->prepare($this->Subject, $this->Body, $account->Email, NEWSLETTER_SENDER_ADDRESS, NEWSLETTER_SENDER_NAME);
                    if ($mail->Send()) {
                        $sent++;
                        $recordLog->Sent = TRUE;
                    } else {
                        $errors++;
                        $recordLog->Sent = FALSE;
                        $recordLog->Message = $mail->ErrorInfo;
                    }
                    $recordLog->Save();
                }
            }
            $this->LogMessage = json_encode(array( "sent" => $sent, "skipped" => $skipped, "errors" => $errors ));
            $this->Save();
            return TRUE;
        }
        return FALSE;
    }
}