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') {
                    $logger->write($user_id .' is disabled', '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);
			
			// 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');
			$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']);
?>