下面列出了org.quartz.JobExecutionContext#getScheduledFireTime ( ) 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。
/**
* @return composite data
*/
public static CompositeData toCompositeData(JobExecutionContext jec)
throws SchedulerException {
try {
return new CompositeDataSupport(COMPOSITE_TYPE, ITEM_NAMES,
new Object[] {
jec.getScheduler().getSchedulerName(),
jec.getTrigger().getKey().getName(),
jec.getTrigger().getKey().getGroup(),
jec.getJobDetail().getKey().getName(),
jec.getJobDetail().getKey().getGroup(),
JobDataMapSupport.toTabularData(jec
.getMergedJobDataMap()),
jec.getTrigger().getCalendarName(),
jec.isRecovering(),
jec.getRefireCount(),
jec.getFireTime(), jec.getScheduledFireTime(),
jec.getPreviousFireTime(), jec.getNextFireTime(),
jec.getJobRunTime(),
jec.getFireInstanceId() });
} catch (OpenDataException e) {
throw new RuntimeException(e);
}
}
/**
* @return composite data
*/
public static CompositeData toCompositeData(JobExecutionContext jec)
throws SchedulerException {
try {
return new CompositeDataSupport(COMPOSITE_TYPE, ITEM_NAMES,
new Object[] {
jec.getScheduler().getSchedulerName(),
jec.getTrigger().getFullName(),
jec.getJobDetail().getFullName(),
JobDataMapSupport.toTabularData(jec
.getMergedJobDataMap()),
determineCalendarName(jec),
Boolean.valueOf(jec.isRecovering()),
Integer.valueOf(jec.getRefireCount()),
jec.getFireTime(), jec.getScheduledFireTime(),
jec.getPreviousFireTime(), jec.getNextFireTime(),
Long.valueOf(jec.getJobRunTime()) });
} catch (OpenDataException e) {
throw new RuntimeException(e);
}
}
public void execute(JobExecutionContext jobInfo) throws JobExecutionException {
loginToSakai("admin");
String jobName = jobInfo.getJobDetail().getKey().getName();
String triggerName = jobInfo.getTrigger().getKey().getName();
Date requestedFire = jobInfo.getScheduledFireTime();
Date actualfire = jobInfo.getFireTime();
StringBuffer whoAmI = new StringBuffer("AutoSubmitAssessmentsJob $");
whoAmI.append(" Job: ");
whoAmI.append(jobName);
whoAmI.append(" Trigger: ");
whoAmI.append(triggerName);
if (requestedFire != null) {
whoAmI.append(" Fire scheduled: ");
whoAmI.append(requestedFire.toString());
}
if (actualfire != null) {
whoAmI.append(" Fire actual: ");
whoAmI.append(actualfire.toString());
}
eventTrackingService.post(eventTrackingService.newEvent(SamigoConstants.EVENT_AUTO_SUBMIT_JOB, safeEventLength(whoAmI.toString()), true));
log.info("Start Job: {}", whoAmI);
GradingService gradingService = new GradingService();
int failures = gradingService.autoSubmitAssessments();
if (failures > 0)
{
samigoETSProvider.notifyAutoSubmitFailures(failures);
}
log.info("End Job: {} ({} failures)", whoAmI, failures);
logoutFromSakai();
}
public void execute(JobExecutionContext jobInfo) throws JobExecutionException {
loginToSakai("admin");
String jobName = jobInfo.getJobDetail().getKey().getName();
String triggerName = jobInfo.getTrigger().getKey().getName();
Date requestedFire = jobInfo.getScheduledFireTime();
Date actualfire = jobInfo.getFireTime();
StringBuffer whoAmI = new StringBuffer("AutoSubmitAssessmentsJob $");
whoAmI.append(" Job: ");
whoAmI.append(jobName);
whoAmI.append(" Trigger: ");
whoAmI.append(triggerName);
if (requestedFire != null) {
whoAmI.append(" Fire scheduled: ");
whoAmI.append(requestedFire.toString());
}
if (actualfire != null) {
whoAmI.append(" Fire actual: ");
whoAmI.append(actualfire.toString());
}
eventTrackingService.post(eventTrackingService.newEvent(SamigoConstants.EVENT_AUTO_SUBMIT_JOB, safeEventLength(whoAmI.toString()), true));
log.info("Start Job: {}", whoAmI);
GradingService gradingService = new GradingService();
int failures = gradingService.autoSubmitAssessments();
if (failures > 0)
{
samigoETSProvider.notifyAutoSubmitFailures(failures);
}
log.info("End Job: {} ({} failures)", whoAmI, failures);
logoutFromSakai();
}