Metacat

/**

 *  '$RCSfile$'

 *             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.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.ScheduledJobDAO;

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

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

import edu.ucsb.nceas.metacat.util.ResponseUtil;

import edu.ucsb.nceas.utilities.UtilException;

 * @author daigle

 *

 */

	private static WorkflowScheduler workflowScheduler = null;

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

	private static String WORKFLOW_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;

	}

	 * Scheduling a workflow

	 *

	 * @param request

	 *            the servlet request object

	 * @param response

	 *            the servlet response object

	 * @param params

	 *            the request parameters

	 * @param username

	 *            the user

	 * @param groups

	 *            the user's group

	 */

			Hashtable<String, String[]> params, String username,

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

		Calendar startCal = null;

		try {

			SchedulerService schedulerService = SchedulerService.getInstance();

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

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

				startCal = Calendar.getInstance();

			}

			// get end time.  null is fine.

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

				endCal = DateUtil.humanReadableToCalendar(endTimes[0], "MM/dd/yyyy HH:mm:ss");

			}

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

				throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - intervalvalue field must be populated "

			}

			int intervalValue = Integer.parseInt(intervalStrValue);

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

				throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - intervalunit field must be populated "

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

			}

			String intervalUnit = intervalUnits[0];

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

				throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - workflowid field must be populated "

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

			// kar id must exist.  Add to job params

			String karids[] = params.get("karid");

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

				throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - karid field must be populated "

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

			}

			jobParams.put("karid", karids[0]);

			// workflow name unit must exist.  Add to job params

			String workflownames[] = params.get("workflowname");

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

				throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - workflowname field must be populated "

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

			}

			jobParams.put("workflowname", workflownames[0]);

					+ "Utility issue when scheduling job: " + ue.getMessage());

					+ "Service issue when scheduling job", se);

					+ "Issue sending error when scheduling job: " + esee.getMessage());

	}

	 * Unschedule a job

	 *

	 * @param request

	 *            the servlet request object

	 * @param response

	 *            the servlet response object

	 * @param params

	 *            the request parameters

	 * @param username

	 *            the user

	 * @param groups

	 *            the user's group

	 */

			Hashtable<String, String[]> params, String username, String[] groups)

			throws MetacatSchedulerException {

		try {

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

				throw new MetacatSchedulerException("SchedulerService.unScheduleJob - workflowjobid "

						+ "field must be populated in scheduler parameters when unscheduling job.");

			}

			String jobName = jobNames[0];

			String xmlResult = schedulerService.unScheduleJob(jobName, username, groups);

			ResponseUtil.sendSuccessXML(response, xmlResult);

					+ "Service issue unscheduling job", se);

					+ "Generic issue unscheduling job: " + e.getMessage());

	 * reschedule job

	 *

	 * @param request

	 *            the servlet request object

	 * @param response

	 *            the servlet response object

	 * @param params

	 *            the request parameters

	 * @param username

	 *            the user

	 * @param groups

	 *            the user's group

	 */

			Hashtable<String, String[]> params, String username,

			String[] groups) throws MetacatSchedulerException {

		try {

			String jobNames[] = params.get("workflowjobid");

				throw new MetacatSchedulerException("WorkflowScheduler.reScheduleJob - workflowjobid field must be populated "

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

			ScheduledJobAccess jobAccess = new ScheduledJobAccess();

			ScheduledJobDAO jobDAO = jobAccess.getJobByName(jobName);

			String result = schedulerService.rescheduleJob(jobDAO, username, groups);

		} catch (AccessException ae) {

					+ "DB access issue when scheduling job  : ", ae);

					+ "Service issue scheduling job", se);

					+ "Issue sending erro when scheduling job: " + esee.getMessage());

	 * delete job - to be implemented

	 */

			Hashtable<String, String[]> params, String username, String[] groups) throws MetacatSchedulerException {

			String jobNames[] = params.get("workflowjobid");

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

				throw new MetacatSchedulerException(

						"WorkflowScheduler.deleteJob - workflowname field must be populated "

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

			}

			String jobName = jobNames[0];

			ScheduledJobDAO jobDAO = jobAccess.getJobByName(jobName);

			// delete the job

			SchedulerService schedulerService = SchedulerService.getInstance();

			String result = schedulerService.deleteJob(jobDAO, username, groups);

					+ "DB access issue when deleting job  : ", ae);

					+ "Service issue deleting job", se);

					+ "Issue sending erro when deleting job: " + esee.getMessage());

	 * get job information for a given workflow in xml format

	 *

	 * @param request

	 *            the servlet request object

	 * @param response

	 *            the servlet response object

	 * @param params

	 *            the request parameters

	 * @param username

	 *            the user

	 * @param groups

	 *            the user's group

	 */

			Hashtable<String, String[]> params, String username, String[] groups) throws MetacatSchedulerException {

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

			workflowId = workflowIds[0];

			SchedulerService.getInstance().getJobsInfoXML(WORKFLOW_JOB_GROUP,

					"workflowid", workflowId, out);

		} catch (ServiceException se) {

			throw new MetacatSchedulerException("WorkflowScheduler.getJobs - "

					+ "Service error when transforming XML for workflow id: "

					+ workflowId + " : " + se.getMessage());

		} catch (IOException ioe) {

			throw new MetacatSchedulerException("WorkflowScheduler.getJobs - "

					+ "I/O error when transforming XML for workflow id: "

					+ workflowId + " : " + ioe.getMessage());

		} finally {

			if (out != null) {

				out.close();

	}