Metacat

/**

 *  '$RCSfile$'

 *    Purpose: a single workflow job that is schedulable 

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

 *             National Center for Ecological Analysis and Synthesis

 *    Authors: Michael Daigle

 *

 *   '$Author: daigle $'

 *     '$Date: 2008-07-06 21:25:34 -0700 (Sun, 06 Jul 2008) $'

 * '$Revision: 4080 $'

 *

 * 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.rmi.RemoteException;

import javax.xml.rpc.ServiceException;

import org.apache.log4j.Logger;

import org.quartz.InterruptableJob;

import org.quartz.JobDetail;

import org.quartz.JobDataMap;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

import org.kepler.executionWS.KeplerWebServiceLocator;

import org.kepler.executionWS.KeplerWebServicePortType;

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

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

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

public class WorkflowJob implements InterruptableJob {

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

	/**

	 * Required method that is called when the job is run by the scheduler.

	 * 

	 * @param executionContext

	 *            the context information for this job

	 */

	public void execute(JobExecutionContext executionContext) throws JobExecutionException {

		try {

			// have to be able to get the job detail

			JobDetail jobDetail = executionContext.getJobDetail();

			if (jobDetail == null) {

				throw new JobExecutionException("WorkflowJob.execute - Could not get job detail from execution context"); 

			}

			// have to be able to get the job data map from the job detail

			JobDataMap jobDataMap = jobDetail.getJobDataMap();

			if (jobDataMap == null) {

				throw new JobExecutionException("WorkflowJob.execute - Could not get job data map from job detail"); 

			}

			String jobName = jobDetail.getName();

			ScheduledJobAccess jobAccess = new ScheduledJobAccess();

			ScheduledJobDAO jobDAO = jobAccess.getJobByName(jobName);

			if(jobDAO == null) {

				String errorMessage = "WorkflowJob.execute - Could not retrieve job info from " 

					+ "database for job: " + jobName;

				logMetacat.error(errorMessage);

				throw new JobExecutionException(errorMessage);

			}

			// the kar lsid must be part of the job data map

			ScheduledJobParamDAO jobParamDAO = jobDAO.getAllJobParams().get("karid");

			if (jobParamDAO == null) {

				throw new JobExecutionException("WorkflowJob.execute - Could not get job param named karid from " 

						+ "job data map for job: " + jobName);

			}

			String karLSID = jobParamDAO.getValue();

			if (karLSID == null) {

				throw new JobExecutionException("WorkflowJob.execute - Could not get kar LSID for job: " + jobName);

			}

			// Locate service

			logMetacat.debug("WorkflowJob.execute - Getting kepler webservice Locator");

			KeplerWebServiceLocator serviceLocator = new KeplerWebServiceLocator();

			// get endpoint service

			logMetacat.debug("WorkflowJob.execute - Getting kepler webservice");

			KeplerWebServicePortType serviceEndpoint = serviceLocator.getKeplerWebServiceHttpSoap11Endpoint();

			// call execute against remote endpoint

			logMetacat.debug("WorkflowJob.execute - Executing with kar lsid:" + karLSID);

			String status = serviceEndpoint.execute(karLSID);		

			logMetacat.debug("WorkflowJob.execute - Status: " + status);

		} catch (RemoteException re) {

			String errorStr = "WorkflowJob.execute - Remote problem when trying to execute task: " + re.getMessage();

			logMetacat.error(errorStr);

			throw new JobExecutionException(errorStr); 

		} catch (ServiceException se) {

			String errorStr = "WorkflowJob.execute - Service problem when trying to execute task: " + se.getMessage();

			logMetacat.error(errorStr);

			throw new JobExecutionException(errorStr); 

		} catch (Exception e) {

			String errorStr = "WorkflowJob.execute - General problem when trying to execute task: " + e.getMessage();

			logMetacat.error(errorStr);

			throw new JobExecutionException(errorStr); 

		}

	}

	public void interrupt() {

	}

}