Report/SendEventErrors.php

[Pman.Admin] / Report / SendEventErrors.php

diff --git a/Report/SendEventErrors.php b/Report/SendEventErrors.php
index 65fbdc1..b22f97c 100644 (file)
--- a/Report/SendEventErrors.php
+++ b/Report/SendEventErrors.php
@@ -7,7 +7,49 @@ class Pman_Admin_Report_SendEventErrors extends Pman_Roo
     static $cli_desc = "Send event errors occured in the last 24 hours";
     
     static $cli_opts = array(
-        
+        'group' => array(
+            'desc' => 'group to send to',
+            'short' => 't',
+            'default' => '',
+            'min' => 1,
+            'max' => 1,
+        ),
+        'exclude' => array(
+            'desc' => 'list of actions to exclude from report',
+            'short' => 'e',
+            'default' => '',
+            'min' => 1,
+            'max' => 1,
+        ),
+        'subject' => array(
+            'desc' => 'email subject',
+            'short' => 's',
+            'default' => '',
+            'min' => 1,
+            'max' => 1,
+        ),
+        'helo' => array(
+            'desc' => 'mail helo to use',
+            'short' => 'l',
+            'default' => '',
+            'min' => 1,
+            'max' => 1,
+        ),
+        'host' => array(
+            'desc' => 'mail host to use',
+            'short' => 'o',
+            'default' => '',
+            'min' => 1,
+            'max' => 1,
+        ),
+     
+        'list' => array(
+            'desc' => 'list the current actions in the database',
+            'short' => 'L',
+            'default' => '',
+            'min' => 1,
+            'max' => 1,
+        )
     );
     
     function getAuth()
@@ -23,17 +65,134 @@ class Pman_Admin_Report_SendEventErrors extends Pman_Roo
     
     function get($args, $opts)
     {
-        print_r($args);exit;
+        $this->opts = $opts;
+        
+          
+        if(!empty($this->opts['list'])){
+            $this->listTypes();
+        }
+        
+        if(empty($this->opts['group'])){
+            $this->jerr('Missing group - try add [-t {group name}]');
+        }
+        
+        $rcpts = DB_DataObject::factory('groups')->lookupMembers("{$this->opts['group']}",'email');
         
-        $this->transObj = DB_DataObject::Factory('core_enum');
+        if(empty($rcpts)){
+            $this->jerr("{$this->opts['group']} does not has any memeber");
+        }
+        
+        $events = DB_DataObject::factory('Events');
+        $events->selectAdd();
+        $events->selectAdd("
+            DISTINCT(Events.action) AS action,
+            COUNT(Events.id) AS total
+        ");
+        
+        $events->whereAdd("Events.event_when > NOW() - INTERVAL 1 DAY");
+        
+        if(!empty($this->opts['exclude'])){
+            $exclude = array_unique(array_filter(array_map('trim', explode(',', $this->opts['exclude']))));
+            
+            if(!empty($exclude)){
+                $events->whereAddIn('!Events.action', $exclude, 'string');
+            }
+        }
+        
+        $events->groupBy('Events.action');
+        $events->orderBy('Events.action ASC');
+        
+        $summary = $events->fetchAll('action', 'total');
+        
+        if(empty($summary)){
+            $this->jerr('Nothing to be sent');
+        }
+        
+        $subject = array();
+        
+        foreach ($summary as $k => $v){
+            $subject[] = "{$v} {$k}";
+        }
+        
+        $subject = implode(', ', $subject);
+        
+        if(!empty($this->opts['subject'])){
+            $subject = "{$this->opts['subject']} $subject";
+        }
         
-        $this->transObj->query('BEGIN');
+        $events = DB_DataObject::factory('Events');
+        $events->autoJoin();
         
-        PEAR::setErrorHandling(PEAR_ERROR_CALLBACK, array($this, 'onPearError'));
+        $events->selectAdd();
+        $events->selectAdd("
+            Events.id AS id,
+            Events.event_when AS event_when,
+            Events.action AS action,
+            Events.remarks AS remarks,
+            CASE WHEN Events.person_id != 0 THEN
+                join_person_id_id.email
+            WHEN Events.hydra_person_id != 0 THEN
+                join_hydra_person_id_id.email
+            ELSE
+                ''
+            END AS email
+        ");
         
-        print_r('run');exit;
+        $events->whereAdd("Events.event_when > NOW() - INTERVAL 1 DAY");
         
-        $this->jok("Done");
+        $exclude = array_unique(array_filter(array_map('trim', explode(',', $this->opts['exclude']))));
+        
+        if(!empty($exclude)){
+            $events->whereAddIn('!Events.action', $exclude, 'string');
+        }
+        
+        if(!$events->count()){
+            $this->jerr('Nothing to be sent');
+        }
+        
+        $errors = $events->fetchAll();
+        
+        if(!empty($this->opts['host'])){
+            // reset the mail settings..
+            HTML_FlexyFramework::get()->Mail = array(
+                                        'host' => $this->opts['host']
+            );
+        }
+        
+        if(!empty($this->opts['helo'])){
+            HTML_FlexyFramework::get()->Mail['helo'] = $this->opts['helo'];
+        }
+        
+        
+        
+        $content = array(
+            'template'      => 'EVENT_ERRORS_REPORT',
+            'rcpts'         => $rcpts,
+            'errors'        => $errors,
+            'subject'       => $subject
+        );
+
+        $sent = DB_DataObject::factory('core_email')->send($content);
+        
+        if(!is_object($sent)){
+            $this->jok("Done");
+        }
+        
+        $this->jerr($sent);
+        
+    }
+    
+    function listTypes()
+    {
+         $events = DB_DataObject::factory('Events');
+        $events->selectAdd();
+        $events->selectAdd("
+            DISTINCT(Events.action) AS action
+        ");
+        $ar = $events->fetchAll('action');
+        echo implode("\n", $ar);
+        echo "\n";
+        exit;
         
     }