/ - Diff - Metacat - Ecoinformatics Redmine

+    }
     .field-suffix {
     	margin: 0px 0px 0px 15px;
     	margin: 0px 0px 0px 5px;
     	padding: 0px 7px 0px 0px;
     	width: 125px;
     	display: inline;

     <%@ page    language="java" %>
     <%@ page import="java.util.TimeZone" %>
     <%
     /*
     *  '$RCSfile$'
-...
     					<div class="form-input-row">
     						<div class="field-label" id='start-time-label' >Start Time: </div>
     						<input class="date-input" name='starttime' id='starttime' />
     						<div class="field-suffix"> (mm/dd/yyyy hh:mm:ss z)</div>
     						<div class="field-suffix"><%= TimeZone.getDefault().getDisplayName(true, TimeZone.SHORT) %> &nbsp;&nbsp;(mm/dd/yyyy hh:mm:ss)</div>
     					</div>
     					<div class="form-input-row">
     						<div class="field-label" id='interval-label' >Interval: </div>

     package edu.ucsb.nceas.metacat.workflow;
     import java.io.IOException;
     import java.text.SimpleDateFormat;
     import java.text.ParseException;
     import java.util.Calendar;
     import java.util.Date;
     import java.util.Hashtable;
     import java.util.HashMap;
-...
     import edu.ucsb.nceas.metacat.util.ResponseUtil;
     import edu.ucsb.nceas.metacat.util.RequestUtil;
     import edu.ucsb.nceas.shared.AccessException;
     import edu.ucsb.nceas.utilities.DateUtil;
     import edu.ucsb.nceas.utilities.UtilException;
     /**
      * @author daigle
-...
     		try {
     			SchedulerService schedulerService = SchedulerService.getInstance();
     			// get start time or delay.  Start time takes precidence if both exist.
     			// get start time or delay.  Start time takes precedence if both exist.
     			if (startTimes != null && startTimes.length > 0) {
     				SimpleDateFormat dateFormat = new SimpleDateFormat("MM/dd/yyyy HH:mm:ss z");
     				Date startDate = dateFormat.parse(startTimes[0]);
     				startCal = Calendar.getInstance();
     				startCal.setTime(startDate);
     				startCal = DateUtil.humanReadableToCalendar(startTimes[0], "MM/dd/yyyy HH:mm:ss z");
     			} else if (delays != null && delays.length > 0) {
     				startCal = schedulerService.getStartDateFromDelay(delays[0]);
     			} else {
-...
     				ResponseUtil.sendSuccessXML(response, xmlResult);
+    			}
     		} catch (ParseException pe) {
     			throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - Could not " + "schedule job  : "
     					+ pe.getMessage());
     		} catch (UtilException ue) {
     			throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - Utility issue when scheduling job: " + ue.getMessage());
     		} catch (ServiceException se) {
     			throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - Service issue scheduling job", se);
     			throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - Service issue when scheduling job", se);
     		} catch (IOException ioe) {
     			throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - I/O issue scheduling job: " + ioe.getMessage());
     			throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - I/O issue when scheduling job: " + ioe.getMessage());
     		} catch (ServletException se) {
     			throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - Servlet issue scheduling job: " + se.getMessage());
     			throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - Servlet issue when scheduling job: " + se.getMessage());
     		} catch (ErrorSendingErrorException esee) {
     			throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - Issue sending erro when scheduling job: " + esee.getMessage());
     			throw new MetacatSchedulerException("WorkflowScheduler.scheduleJob - Issue sending error when scheduling job: " + esee.getMessage());
+    		}
+    	}

     import edu.ucsb.nceas.metacat.service.BaseService;
     import edu.ucsb.nceas.metacat.service.ServiceException;
     import edu.ucsb.nceas.shared.AccessException;
     import edu.ucsb.nceas.utilities.DateUtil;
     import edu.ucsb.nceas.utilities.StatusUtil;
     import edu.ucsb.nceas.utilities.UtilException;
     public class SchedulerService extends BaseService {
-...
     			String username, String[] groups) throws ServiceException {
             Class<Job> jobClass = null;
             try {
             	jobClass = (Class<Job>)Class.forName(jobClassName);
             } catch (ClassNotFoundException cnfe) {
             	throw new ServiceException("SchedulerService.scheduleJob - Could not find class with name: "
             			+ jobClassName + " : " + cnfe.getMessage());
+            }
             logMetacat.info("SchedulerService.scheduleJob - Scheduling job -- name: " + jobName + ", class: " + jobClassName
             		+ ", start time: " + startCal.toString() + ", interval value: " + intervalValue
             		+ ", interval unit: " + intervalUnit);
             // start the job in the job scheduler
     		startJob(jobName, startCal, intervalValue, intervalUnit, jobClass, jobGroup, jobParams);
     		// get a database access object and create the job in the database
     		try {
             try {
     			jobClass = (Class<Job>) Class.forName(jobClassName);
     			String startTimeStr = DateUtil.getHumanReadable(startCal, true);
     			logMetacat.info("SchedulerService.scheduleJob - Scheduling job -- name: "
     					+ jobName + ", class: " + jobClassName + ", start time: "
     					+ startTimeStr + ", interval value: " + intervalValue
     					+ ", interval unit: " + intervalUnit);
     			// start the job in the job scheduler
     			startJob(jobName, startCal, intervalValue, intervalUnit, jobClass, jobGroup,
     					jobParams);
     			// get a database access object and create the job in the database
     			ScheduledJobAccess jobAccess = new ScheduledJobAccess();
     			jobAccess.createJob(jobName, jobName, jobGroup, jobClass, startCal, intervalValue, intervalUnit, jobParams);
     			jobAccess.createJob(jobName, jobName, jobGroup, jobClass, startCal,
     					intervalValue, intervalUnit, jobParams);
     		} catch (AccessException ae) {
     			try {
     				deleteJob(jobName, username, groups);
     			} catch (Exception e) {
     				// Not much we can do here but log this
     				logMetacat.error("SchedulerService.scheduleJob - An access exception was thrown when writing job: " + jobName
     						+ "to the db, and another exception was thrown when trying to remove the "
     				logMetacat.error("SchedulerService.scheduleJob - An access exception was thrown when writing job: "
     						+ jobName + "to the db, and another exception was thrown when trying to remove the "
     						+ "job from the scheduler.  The db and scheduler may be out of sync: " + e.getMessage());
+    			}
     			throw new ServiceException("SchedulerService.scheduleJob - Error accessing db: ", ae);
     		} catch (ClassNotFoundException cnfe) {
     			throw new ServiceException("SchedulerService.scheduleJob - Could not find class with name: "
     							+ jobClassName + " : " + cnfe.getMessage());
     		} catch (UtilException ue) {
     			throw new ServiceException("SchedulerService.scheduleJob - Could not schedule "
     							+ "job due to a utility issue: " + ue.getMessage());
+    		}
     		return "Scheduled: " + jobName;
-...
     	        			+ jobDAO.getClassName() + " : " + cnfe.getMessage());
+    	        }
     	        String startTimeStr = DateUtil.getHumanReadable(startCal, true);
     	        logMetacat.info("SchedulerService.rescheduleJob - name: " + jobDAO.getName() + ", class: " + jobClassName
     	        		+ ", start time: " + startCal.toString() + ", interval value: " + jobDAO.getIntervalValue()
     	        		+ ", start time: " + startTimeStr + ", interval value: " + jobDAO.getIntervalValue()
     	        		+ ", interval unit: " + jobDAO.getIntervalUnit());
     	        // start the job in the scheduler
-...
     		} catch (AccessException ae) {
     			throw new ServiceException("SchedulerService.reScheduleJob - Could not reschedule "
     					+ "job because of db access issue: ", ae);
     		} catch (UtilException ue) {
     			throw new ServiceException("SchedulerService.reScheduleJob - Could not reschedule "
     					+ "job due to a utility issue: " + ue.getMessage());
+    		}
     		return "Resheduled: " + jobDAO.getName();
-...
     			jobXML += "<triggerName>" + scheduledJobDAO.getName() + "</triggerName>";
     			jobXML += "<groupName>" + scheduledJobDAO.getGroupName() + "</groupName>";
     			jobXML += "<className>" + scheduledJobDAO.getClassName() + "</className>";
     			jobXML += "<startTime>" + scheduledJobDAO.getStartTime().toString()
     			String startTimeString = null;
     			try {
     				startTimeString =
     					DateUtil.getHumanReadable(scheduledJobDAO.getStartTime(), true);
     			} catch (UtilException ue) {
     				throw new ServiceException("SchedulerService.jobToXML - error getting human readable date for job: "
     						+ scheduledJobDAO.getId() + " ; " + ue.getMessage());
+    			}
     			jobXML += "<startTime>" + startTimeString
     					+ "</startTime>";
     			jobXML += "<intervalValue>" + scheduledJobDAO.getIntervalValue()
     					+ "</intervalValue>";

Project

General

Profile

Metacat

Revision 5005

Added by daigle over 15 years ago