X-Git-Url: http://git.roojs.org/?a=blobdiff_plain;f=DataObjects%2FCore_notify_recur.php;h=022460629ab8f8b719c5fe51ddc869d9cc7dc931;hb=e339cf3b3fb12ec4ad04a00af85bd498c603155a;hp=451efd467516e026df632c7e0abfe0520f19acfd;hpb=ccd933f5e36666dfef283188c241f09b5459a445;p=Pman.Core diff --git a/DataObjects/Core_notify_recur.php b/DataObjects/Core_notify_recur.php index 451efd46..02246062 100644 --- a/DataObjects/Core_notify_recur.php +++ b/DataObjects/Core_notify_recur.php @@ -12,7 +12,6 @@ class Pman_Core_DataObjects_Core_notify_recur extends DB_DataObject public $__table = 'core_notify_recur'; // table name public $id; // int(11) not_null primary_key auto_increment public $person_id; // int(11) not_null - public $recur_id; //INT(11) not_null public $dtstart; // datetime(19) not_null binary public $dtend; // datetime(19) not_null binary @@ -29,9 +28,14 @@ class Pman_Core_DataObjects_Core_notify_recur extends DB_DataObject public $onid; // int(11) not_null public $ontable; // string(128) not_null public $last_event_id; // int(11) - public $method; // string(128) not_null + public $method; // depricated. + public $method_id; // string(128) not_null + + public $recur_id; //INT(11) not_null + ###END_AUTOCODE + //NOTE recur_id and method are depricated. /* @@ -44,7 +48,19 @@ class Pman_Core_DataObjects_Core_notify_recur extends DB_DataObject * /* the code above is auto generated do not remove the tag below */ - + function applyFilters($q, $au, $roo) + { + + if (isset($q['query']['person_id_name']) ) { + $this->whereAdd( "join_person_id_id.name LIKE '{$this->escape($q['query']['person_id_name'])}%'"); + + } + + + + + + } function notifytimesRange($advance) { $start = date('Y-m-d H:i:s', max(strtotime("NOW"), strtotime($this->dtstart))); @@ -52,6 +68,13 @@ class Pman_Core_DataObjects_Core_notify_recur extends DB_DataObject } + function method() + { + $e = DB_DataObject::Factory('core_enum'); + $e->get($this->method_id); + return $e; + } + function notifytimes($advance) { @@ -132,6 +155,13 @@ class Pman_Core_DataObjects_Core_notify_recur extends DB_DataObject if (isset($old[$time])) { // we already have it... + + $oo = DB_DataObject::Factory('core_notify'); + $oo->get($old[$time]); + $oc = clone($oo); + $oo->evtype = $this->method()->name; + $oo->update($oc); + unset($old[$time]); continue; } @@ -150,7 +180,7 @@ class Pman_Core_DataObjects_Core_notify_recur extends DB_DataObject "person_id" => $this->person_id, "onid" => $this->onid, "ontable" => $this->ontable, - 'evtype' => $this->method, + 'evtype' => $this->method()->name, )); $add->insert(); } @@ -181,4 +211,45 @@ class Pman_Core_DataObjects_Core_notify_recur extends DB_DataObject // should delete old events that have not occurred... $n->delete(DB_DATAOBJECT_WHEREADD_ONLY); } + + function toRooSingleArray($authUser, $request) + { + $ret = $this->toArray(); + + if(!empty($ret['keyword_filters'])){ + $keywords = array_unique(array_filter(explode(',', $ret['keyword_filters']))); + + $clipping_keywords = DB_DataObject::factory('clipping_keywords'); + $clipping_keywords->whereAddIn('id', $keywords, 'int'); + + $li = array(); + + foreach ($clipping_keywords->fetchAll('id', 'keyword') as $k => $v){ + $li[] = array( + 'id' => $k, + 'keyword' => $v + ); + } + + $ret['keywords'] = json_encode($li); + } + + return $ret; + } + + function toRooArray($request) + { + $ret = $this->toArray(); + + if(!empty($ret['keyword_filters'])){ + $keywords = array_unique(array_filter(explode(',', $ret['keyword_filters']))); + + $clipping_keywords = DB_DataObject::factory('clipping_keywords'); + $clipping_keywords->whereAddIn('id', $keywords, 'int'); + + $ret['keywords'] = implode(',', $clipping_keywords->fetchAll('keyword')); + } + + return $ret; + } }