'min' => 1,
'max' => 1,
),
+ 'only' => array(
+ 'desc' => 'list of actions only to report',
+ 'short' => 'O',
+ 'default' => '',
+ 'min' => 1,
+ 'max' => 1,
+ ),
+ 'uid' => array(
+ 'desc' => 'Unique identifier - eg. FAILREPORT',
+ 'short' => 'U',
+ 'default' => '',
+ 'min' => 1,
+ 'max' => 1,
+ ),
'subject' => array(
'desc' => 'email subject',
'short' => 's',
),
'host' => array(
'desc' => 'mail host to use',
- 'short' => 'h',
+ 'short' => 'o',
+ 'default' => '',
+ 'min' => 1,
+ 'max' => 1,
+ ),
+
+ 'list' => array(
+ 'desc' => 'list the current actions in the database',
+ 'short' => 'L',
'default' => '',
'min' => 1,
'max' => 1,
{
$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');
+
if(empty($rcpts)){
$this->jerr("{$this->opts['group']} does not has any memeber");
}
+ // see the last date of notification to these users...
+ $rcpt_ids = DB_DataObject::factory('groups')->lookupMembers("{$this->opts['group']}",'id');
+
+ $min = 0;
+ if (!empty($this->opts['uid'])) {}
+ $events = DB_DataObject::factory('Events');
+ $events->action = 'ERROR-REPORT-' . $this->opts['uid'];
+ $events->orderBy('id DESC');
+ $events->limit(1);
+
+ if ($events->find(true)) {
+ $min = $events->id;
+ }
+ }
+
$events = DB_DataObject::factory('Events');
$events->selectAdd();
DISTINCT(Events.action) AS action,
COUNT(Events.id) AS total
");
+ $events->whereAdd('id > '. $min);
$events->whereAdd("Events.event_when > NOW() - INTERVAL 1 DAY");
$events->whereAddIn('!Events.action', $exclude, 'string');
}
}
+ if(!empty($this->opts['only'])){
+ $only= array_unique(array_filter(array_map('trim', explode(',', $this->opts['only']))));
+
+ if(!empty($only)){
+ $events->whereAddIn('Events.action', $only, 'string');
+ }
+ }
+
$events->groupBy('Events.action');
$events->orderBy('Events.action ASC');
$summary = $events->fetchAll('action', 'total');
if(empty($summary)){
- $this->jerr('Nothing to be sent');
+ $this->jerror('ERROR-REPORT', 'Nothing to be sent');
}
+ $e = DB_DataObject::factory('Events');
+ $e->init('ERROR-REPORT',false,"Sending");
+ $e->event_when = date('Y-m-d H:i:s');
+ $eid = $e->insert();
+
$subject = array();
foreach ($summary as $k => $v){
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
+ Events.remarks AS remarks
+
");
+ $events->selectAddPersonEmail();
$events->whereAdd("Events.event_when > NOW() - INTERVAL 1 DAY");
$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'];
}
- if(!empty($this->opts['host'])){
- HTML_FlexyFramework::get()->Mail['host'] = $this->opts['host'];
- }
+
$content = array(
'template' => 'EVENT_ERRORS_REPORT',
}
+ function listTypes()
+ {
+ $events = DB_DataObject::factory('Events');
+ $events->selectAdd();
+ $events->selectAdd("
+ DISTINCT(Events.action) AS action
+ ");
+ $events->whereAdd("action != ''");
+ $ar = $events->fetchAll('action');
+ echo implode(",", $ar);
+ echo "\n";
+ exit;
+
+ }
+
}
\ No newline at end of file