*
* | Property |
* Description |
* Default |
* Required |
*
*
* | notification.return_email |
* The email address used for the from address. |
* |
* Yes |
*
*
* | notification.smtp |
* The SMTP host for all outbound emails. |
* |
* Yes |
*
*
* | notification.subject |
* The subject of the emails sent to users. |
* Bodington System Events |
* No |
*
*
* | notification.preamble |
* The introduction at the start of the email send to users. |
* This Email is to notify you of events that have taken place in a
* Bodington System web site |
* No |
*
*
* | buildingservlet.server |
* The server through which the Bodington website is accessed. |
* |
* Yes |
*
*
* | buildingservlet.http.port |
* The port on which the http protocol is listening. |
* 80 |
* No |
*
*
* | buildingservlet.servlet |
* The path to the Bodington Site servlet. |
* /bodington/site |
* No |
*
*
*/
public class EventMailer implements org.bodington.server.JobSession
{
private static Logger log = Logger.getLogger(EventMailer.class);
private Session mail_session;
private boolean warnedInvalidConfig = false;
private BodingtonURL bodingtonURL;
private String subject;
private String preamble;
/**
* Create an EventMailer for sending out emails to users of events in Bodington.
*/
public EventMailer()
{
Properties props = new Properties();
String returns = BuildingContext.getProperty( "notification.return_email" );
String host = BuildingContext.getProperty( "notification.smtp" );
subject = BuildingContext.getProperty( "notification.subject", "Bodington System Events" );
preamble = BuildingContext.getProperty( "notification.preamble", "This Email is to notify you of events that have taken place in a Bodington System web site." );
if ( returns == null || returns.length()==0 || host==null || host.length()==0 )
mail_session = null;
else
{
String servlet = BuildingContext.getProperty("buildingservlet.servlet");
if (servlet == null || servlet.trim().length() == 0)
{
log.warn("Property buildingservlet.servlet isn't set. Defaulting to /bodington/site");
servlet = "/bodington/site";
}
int port = BuildingContext.getProperty("buildingservlet.port.http", 80, true);
String server = BuildingContext.getProperty("buildingservlet.server");
if(server == null || server.trim().length() == 0)
{
log.error("Property buildingservlet.server isn't set. Can't send event emails");
}
else
{
bodingtonURL = new BodingtonURL("http", server, port, servlet);
props.put( "mail.smtp.from", returns );
props.put( "mail.smtp.user", returns );
props.put( "mail.smtp.host", host );
mail_session = Session.getDefaultInstance(props, null);
}
}
}
public void sendEventMail( String parameter )
throws BuildingServerException
{
log.debug( "EMAIL DEBUG: Sending Email notification..." );
if ( mail_session == null )
{
if (!warnedInvalidConfig)
{
log.error("Bodington is not configured for outgoing email. None will be sent");
warnedInvalidConfig = true;
}
return;
}
User user = (User)BuildingContext.getContext().getUser();
if ( user==null )
throw new BuildingServerException( "Unable to determine who to send Email to." );
log.debug( "EMAIL DEBUG: user_id = " + user.getUserId() );
CharArrayWriter buffer = new CharArrayWriter( 2048 );
Calendar calendar = Calendar.getInstance();
calendar.setTime( new java.util.Date() );
calendar.add( Calendar.DATE, -1 );
java.sql.Timestamp since=new java.sql.Timestamp( calendar.getTime().getTime() );
calendar.setTime( new java.util.Date() );
calendar.add( Calendar.DATE, -7 );
java.sql.Timestamp weeksince=new java.sql.Timestamp( calendar.getTime().getTime() );
UserEventSetup ues;
UserDetail detail;
String address;
JobResult job_result = BuildingContext.getContext().getJobResult();
BigString output_message=null;
if ( job_result != null )
output_message = job_result.getBigString();
try
{
ues = UserEventSetup.findUserEventSetup( "user_id = " + user.getUserId() );
detail = UserDetail.findUserDetail( "user_id = " + user.getUserId() );
if ( detail == null || ues==null )
return;
address = detail.getEMailAddress();
if ( address == null )
return;
if ( output_message!=null )
{
output_message.setString( "Composing notification Email." );
output_message.save();
}
buffer = composeEMail( ues );
if ( buffer !=null )
{
log.debug( "EMAIL DEBUG: Email Text Complete " + buffer.size() + " chars." );
if ( output_message!=null )
{
output_message.setString( output_message.getString() + "\nSending notification Email." );
output_message.save();
}
sendemail( address, buffer );
if ( output_message!=null )
{
output_message.setString( output_message.getString() + "\nNotification Email sent." );
output_message.save();
}
log.debug( "EMAIL DEBUG: Email sent." );
}
else
{
output_message.setString( output_message.getString() + "\nNothing to notify about, no Email sent." );
output_message.save();
log.debug( "EMAIL DEBUG: No Email sent." );
}
ues.setEMailCutoffTime( new java.sql.Timestamp( System.currentTimeMillis() ) );
ues.save();
}
catch ( IOException ioex )
{
log.error(ioex.getMessage(), ioex );
throw new BuildingServerException( "Problem composing Email." );
}
}
private synchronized CharArrayWriter composeEMail( UserEventSetup ues )
throws IOException, BuildingServerException
{
int r, e, n;
CharArrayWriter buffer = new CharArrayWriter();
PrintWriter out = new PrintWriter( buffer );
int interval = ues.getEMailFrequency();
//long s = System.currentTimeMillis() - (interval*24L*60L*60L*1000L);
Timestamp since = ues.getEMailCutoffTime();
// if lcutoff date is more the 1 and an 8th before the interval
// bring it forward. (In case emails haven't been sent for a long
// time - avoid sending a batch of very long Emails.
long allowance = (long)ues.getEMailFrequency()*24L*60L*60L*1000L;
allowance += allowance/8;
allowance = System.currentTimeMillis() - allowance;
if ( since.getTime() < allowance )
since = new java.sql.Timestamp( allowance );
Resource resource;
Event event;
Enumeration resources = ues.findResources();
Enumeration events;
boolean sampled;
Vector all_events=new Vector();
out.println( preamble );
out.print( "This Email was requested by and is intended for " );
out.print( ues.getUser().getName() );
out.println( "." );
out.println( "The following summarises events that have occurred since " );
DateFormatter.outputDate( out, since, 2 );
out.println( ". Only events for locations on your personal list are included." );
out.println( "(You add locations to your personal list by navigating to them " );
out.println( "and clicking on the 'Notify is off' link when you get there.)" );
out.println( "If there are a large number of events for a particular resource " );
out.println( "a sample of fifty will be listed in this message. A full list " );
out.println( " can be seen by visiting the notification tool on the web site." );
out.println( "" );
n=0;
for ( r=0; resources.hasMoreElements(); r++ )
{
resource = (Resource) resources.nextElement();
log.debug( "EMAIL DEBUG: Starting another resource. resource_id = " + resource.getResourceId() + " Message = " + buffer.size() + " chars." );
events = ues.findEventsForResource( resource, since );
all_events.clear();
for ( e=0; events.hasMoreElements(); )
{
event = (Event)events.nextElement();
if ( !event.checkPermission() )
continue;
all_events.addElement( event );
}
// send no more than fifty events
sampled=false;
if ( all_events.size() > 50 )
{
sampled = true;
// start by weeding out more detailed events
for ( e=0; e