process_event_stack.php

<?php
/******************************************************************************
 BATCH PROCESS EVENT STACK

 Processes events from table event_stack
 
 1 - Groups events by 
    * Recipient
    * Event

 2 - Merge template for each recipient / event
 
 3 - Prepare e-mail and add to e-mail stack
 
******************************************************************************/

/* begin */
// load the config and prepare to process
include('load_process_event_stack.php');
$state = 'LOAD_NOTIFICATIONS';
while ($state <> 'END') {
    if (isset($logger)) {
        $logger->write('STATE:' . $state, 'INFO');
    }
    switch ($state) {
 
    /**********************************************************************/
    /*                          LOAD_NOTIFICATIONS                        */
    /* Load notification defsidentified with notification id              */
    /**********************************************************************/
    case 'LOAD_NOTIFICATIONS' :
        $logger->write("Loading configuration for notification id " . $notificationId, 'INFO');
        $notification = $notifications_controler->getByNotificationId($notificationId);
        if ($notification === FALSE) {
            Bt_exitBatch(1, "Notification '".$notificationId."' not found");
        }
        if ($notification->is_enabled === 'N') {
            Bt_exitBatch(100, "Notification '".$notificationId."' is disabled");
        }
        $state = 'LOAD_EVENTS';
        break;
        
    /**********************************************************************/
    /*                          LOAD_EVENTS                               */
    /* Checking if the stack has notifications to proceed                 */
    /**********************************************************************/
    case 'LOAD_EVENTS' :
        $logger->write("Loading events for notification sid " . $notification->notification_sid, 'INFO');
        $events = $events_controler->getEventsByNotificationSid($notification->notification_sid);
        $totalEventsToProcess = count($events);
        $currentEvent = 0;
        if ($totalEventsToProcess === 0) {
            Bt_exitBatch(0, 'No event to process');
        }
        $logger->write($totalEventsToProcess . ' events to process', 'INFO');
        $tmpNotifs = array();
        $state = 'MERGE_EVENT';
        break;
        
    /**********************************************************************/
    /*                  MERGE_EVENT                                       */
    /* Process event stack to get recipients                              */
    /**********************************************************************/
    case 'MERGE_EVENT' :
        foreach($events as $event) {
            $logger->write("Getting recipients using diffusion type '" .$notification->diffusion_type . "'", 'INFO');
            // Diffusion type specific recipients
            $recipients = array();
            $recipients = $diffusion_type_controler->getRecipients($notification, $event);
            
            // Diffusion type specific res_id
            $logger->write("Getting document ids using diffusion type '" .$notification->diffusion_type . "'", 'INFO');
            $res_id = false;
            if($event->table_name == $coll_table || $event->table_name == $coll_view) {
                $res_id = $event->record_id;
            } else {
                $res_id = $diffusion_type_controler->getResId($notification, $event);
            } 
            $event->res_id = $res_id;
            
            $nbRecipients = count($recipients);
            
            $logger->write($nbRecipients .' recipients found, checking active and absences', 'INFO');
            for($i=0; $i<$nbRecipients; $i++) {
                $recipient = $recipients[$i];
                $user_id = $recipient->user_id;              
                $logger->write('Recipient ' . $user_id, 'INFO');
                if($recipient->enabled == 'N' || $recipient->status == 'DEL') {
                    $logger->write($user_id .' is disabled or deleted, this notification will not sent', 'INFO');
                    unset($recipients[$i]);
                    continue;
                }
                
                if($recipient->status == 'ABS') {
                    $logger->write($user_id .' is absent, routing to replacent', 'INFO');
                    unset($recipients[$i]);
                    $query = "select us.* FROM users us"
                        . " JOIN user_abs abs ON us.user_id = abs.new_user "
                        . " WHERE abs.user_abs = '".$user_id."' AND us.enabled='Y'";
                    $dbAbs = new dbquery();
                    $dbAbs->connect();
                    $dbAbs->query($query);
                    if($dbAbs->nb_result() > 0) {
                        $recipient = $dbAbs->fetch_object();
                        $user_id = $recipient->user_id;
                        $logger->write($user_id .' is the replacent', 'INFO');
                        $recipients[] = $recipient;
                    } else {
                        $logger->write('No replacent found (probably disabled)', 'INFO');
                        continue;
                    }
                }
                if(!isset($tmpNotifs[$user_id])) {
                    $tmpNotifs[$user_id]['recipient'] = $recipient;
                    $tmpNotifs[$user_id]['attach'] = $diffusion_type_controler->getAttachFor($notification, $user_id);
                    $logger->write('Checking if attachment required for ' . $user_id . ': ' . $tmpNotifs[$user_id]['attach'], 'INFO');
                }
                $tmpNotifs[$user_id]['events'][] = $event;
            }
            
            if (count($recipients) === 0) {
                $logger->write('No recipient found' , 'WARNING');
                $events_controler->commitEvent($event->event_stack_sid, "FAILED: no recipient found");
            }            
        } 
        $totalNotificationsToProcess = count($tmpNotifs);
        $logger->write($totalNotificationsToProcess .' notifications to process', 'INFO');
        switch($notification->notification_mode) {
        case 'EMAIL':
            $state = 'FILL_EMAIL_STACK';
            break;
        case 'RSS':
            $state = 'FILL_RSS_STACK';
            break;
        }
        break;
        
        
    /**********************************************************************/
    /*                      FILL_EMAIL_STACK                              */
    /* Merge template and fill notif_email_stack                          */
    /**********************************************************************/
    case 'FILL_EMAIL_STACK' :
        foreach($tmpNotifs as $user_id => $tmpNotif) {
            // Merge template with data and style
            $logger->write('Merging template #' . $notification->template_id 
                . ' ('.count($tmpNotif['events']).' events) for user ' . $user_id, 'INFO');
            
            $params = array(
                'recipient' => $tmpNotif['recipient'],
                'events' => $tmpNotif['events'],
                'notification' => $notification,
                'maarchUrl' => $maarchUrl,
                'maarchApps' => $maarchApps,
                'coll_id' => $coll_id,
                'res_table' => $coll_table,
                'res_view' => $coll_view
            );
            $html = $templates_controler->merge($notification->template_id, $params, 'content');
            if(strlen($html) === 0) {
                foreach($tmpNotif['events'] as $event) {
                    $events_controler->commitEvent($event->event_stack_sid, "FAILED: Error when merging template");
                }
                Bt_exitBatch(8, "Could not merge template with the data");
            }
            
            // Prepare e-mail for stack
            $sender = $func->protect_string_db((string)$mailerParams->mailfrom);
            $recipient_mail = $tmpNotif['recipient']->mail;
            $subject = $func->protect_string_db($notification->description);
            $html = $func->protect_string_db($html);
            $html = str_replace('&amp;', '&', $html);
            $html = str_replace('&', '#and#', $html);
            
            // Attachments
            $attachments = array();
            if($tmpNotif['attach']) {   
                $logger->write('Adding attachments', 'INFO');
                foreach($tmpNotif['events'] as $event) {
                    // Check if event is related to document in collection
                    if($event->res_id != '') {
                        $query = "SELECT "
                            . "ds.path_template ,"
                            . "mlb.path, "
                            . "mlb.filename " 
                            . "FROM ".$coll_view." mlb LEFT JOIN docservers ds ON mlb.docserver_id = ds.docserver_id "
                            . "WHERE mlb.res_id = " . $event->res_id;
                        Bt_doQuery($db, $query);
                        $path_parts = $db->fetch_object();
                        $path = $path_parts->path_template . str_replace('#', '/', $path_parts->path) . $path_parts->filename;
                        $path = str_replace('//', '/', $path);
                        $path = str_replace('\\', '/', $path);
                        $attachments[] = $path;
                    }
                }
                $logger->write(count($attachments) . ' attachment(s) added', 'INFO');
            }
            
            $logger->write('Adding e-mail to email stack', 'INFO');
            if ($_SESSION['config']['databasetype'] == 'ORACLE') {
                $query = "DECLARE
  vString notif_email_stack.html_body%type;
BEGIN
  vString := '" . $html ."';
  INSERT INTO " . _NOTIF_EMAIL_STACK_TABLE_NAME . "
  (sender, recipient, subject, html_body, charset, attachments, module) 
  VALUES ('".$sender."', 
  '".$recipient_mail."', 
  '".$subject."', 
  vString,  
  '".(string)$mailerParams->charset."', 
  '".implode(',', $attachments)."', 
  'notifications');
END;";
            } else {
                $query = "INSERT INTO " . _NOTIF_EMAIL_STACK_TABLE_NAME 
                        . " (sender, recipient, subject, html_body, charset, attachments, module) "
                        . "VALUES ('".$sender."', "
                        . "'".$recipient_mail."', "
                        . "'".$subject."', "
                        . "'" . $html . "', " 
                        . "'".(string)$mailerParams->charset."', "
                        . "'".implode(',', $attachments)."', "
                        . "'notifications')";
            }
            //$logger->write('SQL query:' . $query, 'DEBUG');
            $db2 = new dbquery();
            $db2->connect();
            $db2->query($query, false, true);
            
            foreach($tmpNotif['events'] as $event) {
                $events_controler->commitEvent($event->event_stack_sid, "SUCCESS");
            }
        } 
        $state = 'END';
        break;
    
    /**********************************************************************/
    /*                      FILL_EMAIL_STACK                              */
    /* Merge template and fill notif_email_stack                          */
    /**********************************************************************/
    case 'FILL_RSS_STACK' :
        foreach($tmpNotifs as $user_id => $tmpNotif) {
            // Merge template with data and style
            $logger->write('Adding RSS item ('.count($tmpNotif['events']).' events) for user ' . $user_id, 'INFO');
            
            foreach($tmpNotif['events'] as $event) {
                // Get dynamic url
                $url = str_replace('$id', $event->record_id, $notification->rss_url_template);

                // Inser into stack
                $query = "INSERT INTO " . _NOTIF_RSS_STACK_TABLE_NAME 
                    . " (rss_user_id, rss_event_stack_sid, rss_event_url) "
                    . "VALUES ('".$user_id."', "
                    . "".$event->event_stack_sid.", "
                    . "'".$url."')";
                //$logger->write('SQL query:' . $query, 'DEBUG');
                $db2 = new dbquery();
                $db2->connect();
                $db2->query($query, false, true);
                $events_controler->commitEvent($event->event_stack_sid, "SUCCESS");
            }
            
            
        } 
        $state = 'END';
        break;
    }

}

$logger->write('End of process', 'INFO');
Bt_logInDataBase(
    $totalEventsToProcess, 0, 'process without error'
);  
//$db->disconnect();
//unlink($GLOBALS['lckFile']);
exit($GLOBALS['exitCode']);
?>