Scrollset.php

<?php
class Dsao_Scrollset extends ArrayObject
{
  protected $_sqlSelect = null;

  public function __construct(array $scrolls = array())
  {
    // Uebergebene Daten anhaengen
    $this->appendArray($scrolls);
  }

  public function appendScroll(Dsao_Scroll $scroll)
  {
    // Falls eine ID vorhanden
    if ($scroll->id)
    {
      $this->offsetSet($scroll->id, $scroll);
    }

    return $this;
  }

  public function appendArray(array $scrolls)
  {
    foreach ($scrolls as $scroll)
    {
      $this->appendScroll($scroll);
    }

    return $this;
  }

  public static function compareThreads($thread1, $thread2)
  {
    // array, Die letzten Schriftrollen der Threads
    $lastScroll1 = array_pop($thread1);
    $lastScroll2 = array_pop($thread2);

    // Erstellungszeit der letzten Schriftrollen vergleichen
    if ($lastScroll1['timestamp'] == $lastScroll2['timestamp'])
    {
      return 0;
    }

    return ($lastScroll1['timestamp'] > $lastScroll2['timestamp'] ? -1 : 1);
  }

  public function delete($idUser = 0)
  {
    // Durchgehen und löschen
    foreach ($this->getIterator() as $scroll)
    {
      $scroll->delete($idUser);
    }

    return $this;
  }

  public function fetchScrolls(array $sqlWhere = array(), $loadContents = true, $reset = true)
  {
    // Falls Select-Statement noch nicht vorbereitet wurde
    if (null === $this->_sqlSelect)
    {
      $this->_sqlSelect = Dsao_Registry::get('db')->select()
        ->from('scroll_header');

      if ($loadContents)
      {
        $this->_sqlSelect->joinUsing('scroll_content', 'id', 'content');
      }
    }
    // WHERE-Klausel zuruecksetzen, falls neue uebergeben wurde
    else if (!empty($sqlWhere))
    {
      $this->_sqlSelect->reset('WHERE');
    }

    // WHERE-Klausel erzeugen
    foreach ($sqlWhere as $condition => $value)
    {
      // Falls kein assoziativer Array
      if (is_int($condition))
      {
        $this->_sqlSelect->where($value);
      }
      else
      {
        $this->_sqlSelect->where($condition, $value);
      }
    }

    // Ggf. bisherige Schriftrollen loeschen
    if ($reset)
    {
      // Daten zuruecksetzen
      $this->exchangeArray(array());
    }

    // Zeilen laden
    $scrolls = Dsao_Registry::get('db')->fetchAll($this->_sqlSelect);

    // Objekte mit Daten fuellen
    foreach ($scrolls as $scroll)
    {
      $this->offsetSet($scroll['id'], new Dsao_Scroll($scroll, false, true));
    }

    return $this;
  }

  public function getScroll($idScroll)
  {
    // Falls Schriftrolle vorhanden
    if ($this->offsetExists($idScroll))
    {
      return $this->offsetGet($idScroll);
    }

    // Leere Schriftrolle zurueckgeben
    return new Dsao_Scroll(array('id' => $idScroll));
  }

  public function getThreads($toArrayDecoded = false)
  {
    // array, Die enthaltenen Schriftrollen, nach Threads sortiert
    $threads = array();

    foreach ($this->getIterator() as $idScroll => $scroll)
    {
      // Falls dekodierte Arrays zurueck gegeben werden sollen
      if ($toArrayDecoded)
      {
        $scrollReturn = $scroll->toArrayDecoded();
      }
      else
      {
        $scrollReturn = $scroll;
      }

      // Falls die Thread-ID = 0 ist, ist dies die erste SR eines Threads
      if (0 == $scroll->idThread)
      {
        $threads[$scroll->id][0] = $scrollReturn;

        continue;
      }

      // Ansonsten ist dies keine Start-SR und es sollte eigentlich schon eine
      // Start-SR vorhanden sein, dies aber sicherheitshalber pruefen
      if (!isset($threads[$scroll->idThread]))
      {
        // Einfach das erste Feld leer lassen fuer die Start-SR
        $threads[$scroll->idThread][1] = $scrollReturn;
      }
      else
      {
        // Sonst einfach anhaengen
        $threads[$scroll->idThread][] = $scrollReturn;
      }
    }

    // Sortieren
    uasort($threads, 'Dsao_Scrollset::compareThreads');

    // Threads zurueckgeben
    return $threads;
  }

  public function isRead()
  {
    foreach ($this->getIterator() as $scroll)
    {
      // Falls Schriftrolle ungelesen
      if (!$scroll->isRead())
      {
        return false;
      }
    }

    return true;
  }

  public function markRead($idUser = 0, $read = true)
  {
    foreach ($this->getIterator() as $scroll)
    {
      $scroll->markRead($idUser, $read);
    }
  }

  public function refresh($reset = true)
  {
    // Falls Schriftrollen vorher bereits ausgelesen wurden
    if (null != $this->_sqlSelect)
    {
      // Neu laden
      $this->fetchScrolls(array(), $reset);
    }

    return $this;
  }

  public function toArrayDecoded()
  {
    $scrollsArray = array();

    foreach ($this as $scroll)
    {
      $scrollsArray[] = $scroll->toArrayDecoded();
    }

    return $scrollsArray;
  }
}