newsletter.automated.inc in Newsletter 7.2

Contains NewsletterMail and NewsletterCustom that extend NewsletterBasic.

File

includes/newsletter.automated.inc

<?php

/**
 * @file
 *   Contains NewsletterMail and NewsletterCustom that extend NewsletterBasic.
 */

/**
 * Newsletter class that sends automated, non-custom newsletters
 * with dynamic content based on taxonomy terms.
 */
class NewsletterAutomated extends NewsletterBasic {
  protected $list;
  protected $subscribers;
  protected $template;
  protected $nodes;
  protected $newsletter;
  protected $customSendRate;
  protected $manualSendRate;
  protected $left;
  public function __construct($nlid) {
    parent::__construct();
    $this->left = variable_get('newsletter_for_next_cron', array());
    $this->list = newsletter_list_load($nlid);
    $template = field_get_items('newsletter_list', $this->list, 'field_newsletter_template');
    $this->template = newsletter_template_load($template[0]['target_id']);
    $this->subscribers = $this
      ->getSubscribers();
    $this->manualSendRate = (bool) ($this->list->send_rate == 'Manual');
    $this->customSendRate = (bool) is_numeric($this->list->send_rate);
    $this->nodes = $this
      ->getNodes();
    $this->newsletter = $this
      ->getNewsletterData();
    $this->left[$this->list->nlid] = array();
  }

  /**
   * Loads up current lists's subscribers.
   */
  protected function getSubscribers() {
    if (!empty($this->left[$this->list->nlid])) {
      return $this->left[$this->list->nlid];
    }
    else {
      return newsletter_subscribers_by_list($this->list->nlid);
    }
  }

  /**
   * Loads up current newsletter, or creates a new one.
   *
   * @return
   *   The newsletter object.
   */
  protected function getNewsletterData() {
    $newsletter_current = db_query('SELECT * FROM {newsletter_newsletter}
      WHERE title = :title AND send_id = (
        SELECT MAX(send_id) as send_id
        FROM {newsletter_newsletter}
        WHERE title = :title
      )', array(
      ':title' => $this->list->title,
    ))
      ->fetchObject();
    $last_sent = @($newsletter_current->last_sent !== '0' || !isset($newsletter_current->last_sent));
    if (empty($this->left[$this->list->nlid]) && $last_sent) {
      $newsletter = entity_get_controller('newsletter_newsletter')
        ->create($this->list->title, $this->template->ntid);
    }
    else {
      $newsletter = $newsletter_current;
    }
    return newsletter_newsletter_load($newsletter->nnid);
  }

  /**
   * Builds a dynamic query
   * that gets the current nodes to be sent with the current newsletter.
   */
  protected function getQuery() {
    $tids = newsletter_get_template_terms($this->template->ntid);
    $tids = array_keys($tids) ? array_keys($tids) : array(
      0,
    );
    $query = db_select('taxonomy_index', 'tax');
    $query
      ->fields('tax', array(
      'nid',
    ));
    $query
      ->join('newsletter_list', 'list', 'list.nlid = ' . (int) $this->list->nlid);
    $query
      ->join('node', 'node', 'tax.nid = node.nid');
    $query
      ->addField('node', 'created', 'created');
    $query
      ->condition('tax.tid', $tids, 'IN');
    $query
      ->where('(list.last_sent <= node.created) OR (list.last_sent IS NULL )');
    if (!$this->manualSendRate && !$this->customSendRate) {
      $query
        ->where('list.send_again = CURDATE() OR list.send_again IS NULL');
    }
    if ($this->customSendRate) {
      $query
        ->range(0, (int) $this->list->send_rate);
    }
    else {
      $query
        ->range(0, (int) variable_get('newsletter_node_limit', 50));
    }
    $query
      ->orderBy('created', 'DESC');
    $query
      ->distinct();
    return $query;
  }

  /**
   * Get this newsletter nodes if list is not exposed.
   *
   * @return
   *   Array containing node objects.
   */
  protected function getNodes() {
    $check_exposed = db_query('SELECT *
      FROM {field_data_field_newsletter_list}
      WHERE field_newsletter_list_target_id = :lid AND target_id_tids IS NOT NULL', array(
      ':lid' => $this->list->nlid,
    ))
      ->fetchAll();

    // If we get even one subscriber with custom terms
    // or left nodes from previous cron run
    // then no need to continue here.
    if (!empty($check_exposed) || isset($this->left[$this->list->nlid][0]->nodes)) {
      return 'exposed';
    }
    $nodes = $this
      ->getQuery()
      ->execute()
      ->fetchAll();
    foreach ($nodes as $node) {
      $newsletter_nodes[] = node_load($node->nid);
    }
    return isset($newsletter_nodes) ? $newsletter_nodes : array();
  }

  /**
   * Get this newsletter nodes if list is exposed.
   *
   * @param $subscriber
   *   The subscriber's object.
   *
   * @return
   *   Array containing node objects.
   */
  protected function getSubscriberNodes($subscriber) {
    if (isset($subscriber->nodes)) {
      return $subscriber->nodes;
    }
    $nodes = array();
    $newsletter_nodes = array();
    $tids = db_query('SELECT target_id_tids
      FROM {field_data_field_newsletter_list}
      WHERE entity_id = :sid AND field_newsletter_list_target_id = :lid', array(
      ':sid' => $subscriber->nsid,
      ':lid' => $this->list->nlid,
    ))
      ->fetchField();
    $tids = @unserialize($tids);
    if (is_array($tids)) {
      foreach ($tids as $tid) {
        $query = $this
          ->getQuery();
        $query
          ->condition('tax.tid', $tid);
        $nodes = array_merge($nodes, $query
          ->execute()
          ->fetchAll());
      }
    }
    foreach ($nodes as $node) {
      $newsletter_nodes[] = node_load($node->nid);
    }
    return $newsletter_nodes;
  }

  /**
   * Updates newsletter list after it is sent.
   *
   * @param $times_sent
   *   The number of subscribers the newsletter was sent to.
   *
   * @return
   *   Boolean depending on whether the update succeeded or not.
   */
  protected function updateStats($times_sent) {
    switch ($this->list->send_rate) {
      case 'Daily':
        $send_again = date('Y-m-d', strtotime('+1 day'));
        break;
      case 'Weekly':
        $send_again = date('Y-m-d', strtotime('+1 week'));
        break;
      case 'Monthly':
        $send_again = date('Y-m-d', strtotime('+1 month'));
        break;
      default:
        $send_again = NULL;
    }
    $updated_list = db_update('newsletter_list')
      ->fields(array(
      'last_sent' => REQUEST_TIME,
      'send_again' => $send_again,
    ))
      ->condition('nlid', $this->list->nlid)
      ->execute();
    $sent_so_far = db_query('SELECT subscribers_sent
      FROM {newsletter_newsletter} WHERE nnid = :id', array(
      ':id' => $this->newsletter->nnid,
    ))
      ->fetchField();
    $subscribers_sent = isset($sent_so_far) ? $sent_so_far + $times_sent : $times_sent;
    $updated_stats = db_update('newsletter_newsletter')
      ->fields(array(
      'last_sent' => REQUEST_TIME,
      'subscribers_sent' => $subscribers_sent,
    ))
      ->condition('nnid', $this->newsletter->nnid)
      ->execute();
    return isset($updated_list) && isset($updated_stats) ? TRUE : FALSE;
  }

  /**
   * Checkes whether current custom list reached its send rate.
   */
  public function checkCustom() {
    $result = $this
      ->getQuery()
      ->execute()
      ->fetchAll();
    $count = count($result);
    return (bool) ($count >= $this->list->send_rate);
  }

  /**
   * Replaces tokens and sends the current newsletter.
   */
  public function send() {
    $i = 0;
    $mails_to_send = variable_get('newsletter_cron_number', 500);
    $params = array(
      'template' => $this->template,
      'subscriber' => '',
      'list' => $this->list,
      'format' => $this->format,
      'newsletter' => $this->newsletter,
    );
    if (empty($this->subscribers)) {
      return array(
        'No subscribers',
      );
    }
    foreach ($this->subscribers as $subscriber) {
      $language = isset($subscriber->language) ? newsletter_language_list($subscriber->language) : $this->language;
      $nodes = $this->nodes == 'exposed' ? $this
        ->getSubscriberNodes($subscriber) : $this->nodes;
      if (empty($nodes)) {
        continue;
      }
      $params['nodes'] = $nodes;
      if ($i >= $mails_to_send) {
        $subscriber->nodes = $nodes;
        $this->left[$this->list->nlid][] = $subscriber;
        continue;
      }
      $params['subscriber'] = $subscriber;
      $message = drupal_mail('newsletter', 'automated', $subscriber->email, $language, $params, $this->from);
      if (!$message['result']) {
        newsletter_set_watchdog($this->newsletter->nnid, $this->list->title, $subscriber->email, $result);
      }
      $status[] = $message['result'];
      $i++;
    }
    variable_set('newsletter_for_next_cron', $this->left);
    if (empty($this->left[$this->list->nlid]) && isset($message)) {
      module_invoke_all('newsletter_list_sent', $message);
    }
    $this
      ->updateStats($i);
    return isset($status) ? $status : array(
      'No items',
    );
  }

}

Classes

Name	Description
NewsletterAutomated	Newsletter class that sends automated, non-custom newsletters with dynamic content based on taxonomy terms.