. */ namespace Volkszaehler\Controller; /** * Aggregator controller * * @author Steffen Vogel (info@steffenvogel.de) * @package default */ use Volkszaehler\Definition; use Volkszaehler\Model; class AggregatorController extends EntityController { /** * Get aggregator */ public function get($identifier = NULL) { $aggregator = parent::get($identifier); if (is_array($aggregator)) { // filter public entities return array('channels' => array_values(array_filter($aggregator['entities'], function($agg) { return ($agg instanceof Model\Aggregator); }))); } else if ($aggregator instanceof Model\Aggregator) { return $aggregator; } else { throw new \Exception($identifier . ' is not a group'); } } /** * Create new aggregator or add entity to aggregator */ public function add($identifier = NULL) { if (isset($identifier)) { // add entity to aggregator $aggregator = $this->get($identifier); if ($uuid = $this->view->request->getParameter('uuid')) { $ec = new EntityController($this->view, $this->em); $aggregator->addChild($ec->get($uuid)); } else { throw new \Exception('You have to specifiy a uuid to add'); } } else { // create new aggregator $type = $this->view->request->getParameter('type'); if (!isset($ype)) { $type = 'group'; } $aggregator = new Model\Aggregator($type); $this->setProperties($aggregator, $this->view->request->getParameters()); $this->em->persist($aggregator); } $this->em->flush(); return $aggregator; } /** * Delete Aggregator or remove entity from aggregator */ public function delete($identifier) { if (isset($identifier) && $uuid = $this->view->request->getParameter('uuid')) { // remove entity from aggregator $aggregator = $this->get($identifier); if ($uuid) { $ec = new EntityController($this->view, $this->em); $aggregator->removeChild($ec->get($uuid)); $this->em->flush(); } else { throw new \Exception('You have to specifiy a uuid to remove'); } } else { // remove aggregator parent::delete($identifier); } return $aggregator; } } ?>