Metacat

/**

 *  '$RCSfile$'

 *    Purpose: A Class that handles scheduling tasks 

 *  Copyright: 2009 Regents of the University of California and the

 *             National Center for Ecological Analysis and Synthesis

 *    Authors: Michael Daigle

 * 

 *   '$Author: daigle $'

 *     '$Date: 2009-03-25 13:41:15 -0800 (Wed, 25 Mar 2009) $'

 * '$Revision: 4861 $'

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 */

package edu.ucsb.nceas.metacat.workflow;

import java.text.DateFormat;

import java.text.ParseException;

import java.util.Calendar;

import java.util.Date;

import java.util.Enumeration;

import java.util.Hashtable;

import java.util.HashMap;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import org.apache.log4j.Logger;

import edu.ucsb.nceas.metacat.scheduler.BaseScheduler;

import edu.ucsb.nceas.metacat.scheduler.SchedulerService;

import edu.ucsb.nceas.metacat.scheduler.MetacatSchedulerException;

import edu.ucsb.nceas.metacat.service.ServiceException;

public class WorkflowScheduler extends BaseScheduler {

	private static WorkflowScheduler workflowScheduler = null;

	private static Logger logMetacat = Logger.getLogger(WorkflowScheduler.class);

	private static String SCHEDULED_JOB_GROUP = "workflow";

	private static String SCHEDULED_JOB_CLASS = "edu.ucsb.nceas.metacat.workflow.WorkflowJob";

	/**

	 * private constructor since this is a singleton

	 */

	private WorkflowScheduler()  {}

	/**

	 * Get the single instance of SchedulerService.

	 * 

	 * @return the single instance of SchedulerService

	 */

	public static WorkflowScheduler getInstance() {

		if (workflowScheduler == null) {

			workflowScheduler = new WorkflowScheduler();

		}

		return workflowScheduler;

	}

	public String scheduleJob(Hashtable<String, String[]> params,

			HttpServletRequest request, HttpServletResponse response, String username,

			String[] groups) throws MetacatSchedulerException {

		String delays[] = params.get("delay");

		String startTimes[] = params.get("starttime");

		HashMap<String, String> jobParams = new HashMap<String, String>();

		Calendar startCal = null;

		try {

			SchedulerService schedulerService = SchedulerService.getInstance();

			if (delays != null && delays.length > 0) {

				startCal = schedulerService.getStartDateFromDelay(delays[0]);

			} else if (startTimes != null && startTimes.length > 0) {

				Date startDate = DateFormat.getInstance().parse(startTimes[0]);

				startCal = Calendar.getInstance();

				startCal.setTime(startDate);

			} else {

				// if delay and starttime were not provided, set date to now.

				startCal = Calendar.getInstance();

			}

			String intervals[] = params.get("interval");

			if (intervals == null || intervals.length == 0) {

				throw new MetacatSchedulerException(

						"SchedulerService.scheduleHandler - Interval field must be populated "

								+ "in scheduler parameters when scheduling job.");

			}

			String interval = intervals[0];

			Enumeration<String> paramNames = params.keys();

			while (paramNames.hasMoreElements()) {

				String paramName = paramNames.nextElement();

				if (paramName.startsWith("jobparam_")) {

					jobParams.put(paramName.substring(9), params.get(paramName)[0]);

				}

			}

			String jobName = SCHEDULED_JOB_GROUP

					+ Calendar.getInstance().getTimeInMillis();

			return schedulerService.scheduleJob(jobName, startCal, interval,

					SCHEDULED_JOB_CLASS, SCHEDULED_JOB_GROUP, jobParams);

		} catch (ParseException pe) {

			throw new MetacatSchedulerException("WorkflowScheduler.scheduleHandler - Could not " + "schedule job  : " 

					+ pe.getMessage());

		} catch (ServiceException se) {

			throw new MetacatSchedulerException("WorkflowScheduler.scheduleHandler - Service issue scheduling job", se);

		}

	}

	public String unScheduleJob(Hashtable<String, String[]> params,

            HttpServletRequest request, HttpServletResponse response,

            String username, String[] groups) throws MetacatSchedulerException {

		return "";

	}

	public String deleteJob(Hashtable<String, String[]> params,

            HttpServletRequest request, HttpServletResponse response,

            String username, String[] groups) throws MetacatSchedulerException {

		return "";

	}

	public String getJobs(Hashtable<String, String[]> params,

            HttpServletRequest request, HttpServletResponse response,

            String username, String[] groups) throws MetacatSchedulerException {

		String groupName = null;

		String groupNames[] = params.get("groupName");

		if (groupNames != null && groupNames.length != 0) {

			groupName = groupNames[0];

		}

		try {

			return SchedulerService.getInstance().getJobsInfoXML(groupName);

		} catch (ServiceException se) {

			throw new MetacatSchedulerException("WorkflowScheduler.getJobs - Service issue getting jobs", se);

		}		

	}	

}