X-Git-Url: http://git.roojs.org/?p=Pman.Core;a=blobdiff_plain;f=Notify.php;h=fd582092af5a14fa15dae313ff2f70dba6e54320;hp=95a6031212959473d6cd00c642589f028cd7db5d;hb=1524f8b36295809a3eedd6da3c6494f8aa0d86f5;hpb=798e878386e4e467895aeace1a197463aa368524 diff --git a/Notify.php b/Notify.php index 95a60312..fd582092 100644 --- a/Notify.php +++ b/Notify.php @@ -42,7 +42,7 @@ class Pman_Core_Notify extends Pman ), 'old' => array( - 'desc' => 'Show old messages..', + 'desc' => 'Show old messages.. (and new messages...)', 'default' => 0, 'short' => 'o', 'min' => 0, @@ -56,13 +56,11 @@ class Pman_Core_Notify extends Pman 'min' => 0, 'max' => 0, ), - 'generate' => array( - 'desc' => 'Generate notifications for a table, eg. cash_invoice', - 'default' => '', - 'short' => 'g', - 'min' => 0, - 'max' => 1, + /* removed - use GenerateNotifcations.php hooked classes + 'generate' => 'Generate notifications for a table, eg. cash_invoice', + ), + */ 'limit' => array( 'desc' => 'Limit search for no. to send to ', 'default' => 1000, @@ -98,6 +96,11 @@ class Pman_Core_Notify extends Pman */ var $max_to_domain = 10; + /** + * @var $maxruntime - maximum time a child is allowed to run - defaut 2 minutes + */ + var $maxruntime = 120; + var $table = 'core_notify'; var $target = 'Core/NotifySend'; var $evtype = ''; // any notification... @@ -109,14 +112,13 @@ class Pman_Core_Notify extends Pman if (!$ff->cli) { die("access denied"); } - HTML_FlexyFramework::ensureSingle(__FILE__, $this); + HTML_FlexyFramework::ensureSingle($_SERVER["SCRIPT_NAME"] .'|'. __FILE__, $this); return true; - } var $pool = array(); - function get($r,$opts) + function parseArgs(&$opts) { if ($opts['debug']) { DB_DataObject::debugLevel($opts['debug']); @@ -130,9 +132,7 @@ class Pman_Core_Notify extends Pman if (empty($opts['limit'])) { $opts['limit'] = '1000'; // not sure why it's not picking up the defautl.. } - //date_default_timezone_set('UTC'); - // phpinfo();exit; - $showold = !empty($opts['old']); + if (!empty($opts['old'])) { $opts['list'] = 1; // force listing.. } @@ -142,27 +142,30 @@ class Pman_Core_Notify extends Pman if (!empty($opts['send-to'])) { $this->send_to = $opts['send-to']; } - + } + + + function get($r,$opts=array()) + { + $this->parseArgs($opts); + + //date_default_timezone_set('UTC'); - $w = DB_DataObject::factory('core_notify_recur'); - if (is_a($w, 'DB_DataObject')) { - $w->generateNotifications(); - } - if (!empty($opts['generate'])) { - $w = DB_DataObject::factory($opts['generate']); - if (is_a($w, 'DB_DataObject')) { - $w->generateNotifications(); - } - exit; - - - } - + + $this->generateNotifications(); + + //DB_DataObject::debugLevel(1); $w = DB_DataObject::factory($this->table); + $total = 0; - if (!$showold) { + if (!empty($opts['old'])) { + // show old and new... + $w->orderBy('act_when DESC'); // latest first + $w->limit($opts['limit']); // we can run + $total = min($w->count(), $opts['limit']); + } else { // standard //$w->whereAdd('act_when > sent'); // eg.. sent is not valid.. @@ -174,33 +177,30 @@ class Pman_Core_Notify extends Pman } $w->orderBy('act_when ASC'); // oldest first. + $total = min($w->count(), $opts['limit']); + $this->logecho("QUEUE is {$w->count()} only running " . ((int) $opts['limit'])); - echo "QUEUE is {$w->count()}\n"; - - $w->limit($opts['limit']); // we can run 1000 ... - } else { - $w->orderBy('act_when DESC'); // latest first $w->limit($opts['limit']); // we can run 1000 ... } + if (!empty($this->evtype)) { $w->evtype = $this->evtype; } $w->autoJoin(); + $w->find(); - - $ar = $w->fetchAll(); + $ar = array(); // $w->fetchAll(); if (!empty($opts['list'])) { - if (empty($ar)) { - die("Nothing in Queue\n"); - } - foreach($ar as $w) { + + + while ($w->fetch()) { $o = $w->object(); - echo "$w->id : $w->person_id_email email : ". - $o->toEventString()." ". $w->status() . "\n"; + $this->logecho("{$w->id} : {$w->person()->email} email : ". + $o->toEventString()." ". $w->status() ); } exit; } @@ -209,12 +209,15 @@ class Pman_Core_Notify extends Pman $pushed = array(); $requeue = array(); while (true) { + if ($w->fetch()) { + $ar[] = clone($w); + $total--; + } - - echo "BATCH SIZE: ". count($ar) . "\n"; + $this->logecho("BATCH SIZE: ". (count($ar) + $total) ); if (empty($ar)) { - echo "COMPLETED MAIN QUEUE - running delated\n"; + $this->logecho("COMPLETED MAIN QUEUE - running deleted"); if (empty($pushed)) { break; @@ -231,7 +234,9 @@ class Pman_Core_Notify extends Pman sleep(3); continue; } - if ($this->poolHasDomain($p->person_id_email) > $this->max_to_domain) { + $email = $p->person() ? $p->person()->email : $p->to_email; + + if ($this->poolHasDomain($email) > $this->max_to_domain) { if ($pushed === false) { // we only try once to requeue.. @@ -246,7 +251,7 @@ class Pman_Core_Notify extends Pman } - $this->run($p->id,$p->person_id_email); + $this->run($p->id,$email); @@ -266,10 +271,46 @@ class Pman_Core_Notify extends Pman } + $this->logecho("DONE"); + exit; + } + + function generateNotifications() + { + // this should check each module for 'GenerateNotifications.php' class.. + //and run it if found.. + $ff = HTML_FlexyFramework::get(); + + $disabled = explode(',', $ff->disable); + + $modules = array_reverse($this->modulesList()); - die("DONE\n"); + // move 'project' one to the end... + + foreach ($modules as $module){ + if(in_array($module, $disabled)){ + continue; + } + $file = $this->rootDir. "/Pman/$module/GenerateNotifications.php"; + if(!file_exists($file)){ + continue; + } + + require_once $file; + $class = "Pman_{$module}_GenerateNotifications"; + $x = new $class; + if(!method_exists($x, 'generate')){ + continue; + }; + //echo "$module\n"; + $x->generate($this); + } + + } + + function run($id, $email, $cmdOpts="") { @@ -280,7 +321,9 @@ class Pman_Core_Notify extends Pman } // phpinfo();exit; - $tn = tempnam(ini_get('session.save_path'),'stdout') . '.stdout'; + $tnx = tempnam(ini_get('session.save_path'),'stdout'); + unlink($tnx); + $tn = $tnx . '.stdout'; $descriptorspec = array( 0 => array("pipe", 'r'), // stdin is a pipe that the child will read from 1 => array("file", $tn, 'w'), // stdout is a pipe that the child will write to @@ -307,7 +350,7 @@ class Pman_Core_Notify extends Pman $pipe = array(); - echo "call proc_open $cmd\n"; + $this->logecho("call proc_open $cmd"); if ($this->max_pool_size === 1) { @@ -317,7 +360,7 @@ class Pman_Core_Notify extends Pman if (!empty($this->opts['dryrun'])) { - echo "DRY RUN\n"; + $this->logecho("DRY RUN"); return; } @@ -335,19 +378,19 @@ class Pman_Core_Notify extends Pman 'cmd' => $cmd, 'email' => $email, 'pipes' => $pipes, + 'notify_id' => $id, 'started' => time() ); - echo "RUN ({$info['pid']}) $cmd \n"; + $this->logecho("RUN ({$info['pid']}) $cmd "); } function poolfree() { $pool = array(); clearstatcache(); - $maxruntime = 2 * 60; // 2 minutes.. ?? should be long enoguh - + foreach($this->pool as $p) { //echo "CHECK PID: " . $p['pid'] . "\n"; @@ -356,7 +399,7 @@ class Pman_Core_Notify extends Pman // update if necessday. if ($info['pid'] && $p['pid'] != $info['pid']) { - echo "CHANING PID FROM " . $p['pid'] . " TO ". $info['pid']. "\n"; + $this->logecho("CHANING PID FROM " . $p['pid'] . " TO ". $info['pid']); $p['pid'] = $info['pid']; } @@ -367,15 +410,23 @@ class Pman_Core_Notify extends Pman //if (file_exists('/proc/'.$p['pid'])) { $runtime = time() - $p['started']; //echo "RUNTIME ({$p['pid']}): $runtime\n"; - if ($runtime > $maxruntime) { + if ($runtime > $this->maxruntime) { proc_terminate($p['proc'], 9); //fclose($p['pipes'][1]); fclose($p['pipes'][0]); fclose($p['pipes'][2]); - echo "\nTERMINATING: ({$p['pid']}) " . $p['cmd'] . " : " . file_get_contents($p['out']) . "\n"; + $this->logecho("TERMINATING: ({$p['pid']}) " . $p['cmd'] . " : " . file_get_contents($p['out'])); @unlink($p['out']); + $w = DB_DataObject::factory($this->table); + $w->get($p['notify_id']); + $ww = clone($w); + $this->addEvent('NOTIFY', $w, 'TERMINATED - TIMEOUT'); + $w->act_when = date('Y-m-d H:i:s', strtotime('NOW + 30 MINUTES')); + $w->update($ww); + + continue; } @@ -395,11 +446,11 @@ class Pman_Core_Notify extends Pman // $pool[] = $p; // continue; //} - echo "\nENDED: ({$p['pid']}) " . $p['cmd'] . " : " . file_get_contents($p['out']) . "\n"; + $this->logecho("ENDED: ({$p['pid']}) " . $p['cmd'] . " : " . file_get_contents($p['out']) ); @unlink($p['out']); //unlink($p['out']); } - echo "POOL SIZE: ". count($pool) ."\n"; + $this->logecho("POOL SIZE: ". count($pool) ); $this->pool = $pool; if (count($pool) < $this->max_pool_size) { return true; @@ -428,6 +479,11 @@ class Pman_Core_Notify extends Pman function output() { - die("Done\n"); + $this->logecho("DONE"); + exit; + } + function logecho($str) + { + echo date("Y-m-d H:i:s - ") . $str . "\n"; } } \ No newline at end of file