X-Git-Url: http://git.roojs.org/?a=blobdiff_plain;f=DataObjects%2FCore_watch.php;h=7f798beba47e139f049b11f2a5bc90be2355529f;hb=ed2c5ba31b4cc78c2557cc6a616c3937df4bdf94;hp=5c77b3d984d530748ec899c03609b30f87ddc867;hpb=bc883ebef5f85e7f9e5f02b8b3b9fbeb9d6fd854;p=Pman.Core diff --git a/DataObjects/Core_watch.php b/DataObjects/Core_watch.php index 5c77b3d9..7f798beb 100644 --- a/DataObjects/Core_watch.php +++ b/DataObjects/Core_watch.php @@ -102,14 +102,15 @@ class Pman_Core_DataObjects_Core_watch extends DB_DataObject $nn->person_id = $w->person_id; $nf = clone($nn); - $nf->whereAdd('sent < act_when'); + $nf->whereAdd("sent > '2000-01-01'"); if ($nf->count()) { // we have a item in the queue for that waiting to be sent.. continue; } $nn->act_start( date("Y-m-d H:i:s", $when !== false ? strtotime($when) : time()) ); $nn->insert(); - } + } + } // static really... /** @@ -157,7 +158,7 @@ class Pman_Core_DataObjects_Core_watch extends DB_DataObject $watches = $w->fetchAll(); - print_R($watches);exit; + //print_R($watches);exit; $nn = DB_DataObject::Factory('core_notify'); $nn->ontable = $event->on_table; @@ -165,7 +166,7 @@ class Pman_Core_DataObjects_Core_watch extends DB_DataObject foreach($watches as $watch) { if (!$watch->person_id) { // no people??? bugs in watch table - $dom = explode(':',$watch->event); + $dom = explode(':',$watch->medium); if (count($dom) != 2) { continue; } @@ -186,7 +187,8 @@ class Pman_Core_DataObjects_Core_watch extends DB_DataObject // does this watch already have a flag... $nf = clone($n); - $nf->whereAdd('sent < act_when'); + $nf->whereAdd("sent > '2000-01-01'"); + //$nf->whereAdd('sent < act_when'); if ($nf->count()) { // we have a item in the queue for that waiting to be sent.. continue;