X-Git-Url: http://git.roojs.org/?a=blobdiff_plain;f=DataObjects%2FCore_watch.php;h=a88c5e47f22712072beb397ec70752b0f79a5fbc;hb=786913d45279746110847849a40e1d3c877d1f68;hp=750c518034e2d6745c5f763d057c420f55a41d1c;hpb=923d691aaad9c9a5f46dd97f74a7af5e7e41f4f5;p=Pman.Core diff --git a/DataObjects/Core_watch.php b/DataObjects/Core_watch.php index 750c5180..a88c5e47 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... /** @@ -153,8 +154,7 @@ class Pman_Core_DataObjects_Core_watch extends DB_DataObject $w->whereAdd('person_id != '. (int) $event->person_id); - - + $watches = $w->fetchAll(); //print_R($watches);exit; @@ -165,7 +165,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 +186,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;