pipIrr-SV.git - Gitblit

New file
			@@ -0,0 +1,464 @@
			package com.dy.common.schedulerTask;


			import java.util.*;

			import org.quartz.*;


			public class SchedulerTaskSupport {

			private static Integer threadPoolMaxCount;
			private static Integer threadPoolPriority;

			public static void setThreadPoolPro(Integer threadPoolMaxCount, Integer threadPoolPriority){
			if(SchedulerTaskSupport.threadPoolMaxCount == null){
			SchedulerTaskSupport.threadPoolMaxCount = threadPoolMaxCount;
			}
			if(SchedulerTaskSupport.threadPoolPriority == null){
			SchedulerTaskSupport.threadPoolPriority = threadPoolPriority;
			}
			}

			/**
			* 添加每X秒钟重复工作一次的工作任务，
			* @param jobName 工作名称
			* @param jobGroupName 工作组名称
			* @param jobClass 工作类
			* @param futureSecond 延迟到将来时长(单位秒)以开始工作
			* @param intervalInSeconds 重复工作间隔时长(秒)
			* @param repeatCount 重复工作次数(如果小于0，将一直重复执行下去 , 如果是0执行一次，如果是1执行2次，依次类推)
			* @return 工作任务Key
			* @throws Exception
			*/
			@SuppressWarnings({"unchecked","rawtypes"})
			public static String addSecondlyJob(
			String jobName,
			String jobGroupName,
			Class jobClass ,
			HashMap<String , Object> jobDataMap ,
			int futureSecond,
			int intervalInSeconds ,
			int repeatCount) throws Exception {
			SchedulerTaskSupport.checkDelayStart(futureSecond) ;
			if(intervalInSeconds < 1){
			throw new Exception("重复工作间隔时长(单位秒)不能小于1秒)!") ;
			}
			Scheduler sched = SchedulerTaskFactory.getSingleScheduler(threadPoolMaxCount, threadPoolPriority) ;

			Date futureDate = DateBuilder.futureDate(futureSecond, DateBuilder.IntervalUnit.SECOND) ;
			Date startTime = DateBuilder.evenSecondDate(futureDate);

			JobDetail job = JobBuilder.newJob(jobClass)
			.withIdentity(jobName, jobGroupName)
			.build();
			SchedulerTaskSupport.setDataMap(job, jobDataMap) ;

			Trigger trigger = TriggerBuilder.newTrigger()
			.withIdentity(jobName + "_trigger", jobGroupName + "_trigger")
			.startAt(startTime)
			.withSchedule(SimpleScheduleBuilder.simpleSchedule()
			.withIntervalInSeconds(intervalInSeconds)
			.withRepeatCount(repeatCount))
			.build();

			sched.scheduleJob(job, trigger);
			sched.start();

			return job.getKey().toString() ;
			}
			/**
			* 添加每X分钟重复工作一次的工作任务，
			* @param jobName 工作名称
			* @param jobGroupName 工作组名称
			* @param jobClass 工作类
			* @param futureSecond 延迟到将来时长(单位秒)以开始工作
			* @param intervalInMinutes 重复工作间隔时长(分钟)
			* @param repeatCount 重复工作次数(如果小于0，将一直重复执行下去 , 如果是0执行一次，如果是1执行2次，依次类推)
			* @throws Exception
			*/
			@SuppressWarnings({"unchecked","rawtypes"})
			public static String addMinutelyJob(
			String jobName,
			String jobGroupName,
			Class jobClass ,
			HashMap<String , Object> jobDataMap ,
			int futureSecond,
			int intervalInMinutes ,
			int repeatCount) throws Exception {
			SchedulerTaskSupport.checkDelayStart(futureSecond) ;
			if(intervalInMinutes < 1){
			throw new Exception("重复工作间隔时长(单位分钟)不能小于1分钟)!") ;
			}

			Scheduler sched = SchedulerTaskFactory.getSingleScheduler(threadPoolMaxCount, threadPoolPriority) ;

			Date futureDate = DateBuilder.futureDate(futureSecond, DateBuilder.IntervalUnit.SECOND) ;
			Date startTime = DateBuilder.evenSecondDate(futureDate);

			JobDetail job = JobBuilder.newJob(jobClass)
			.withIdentity(jobName, jobGroupName)
			.build();
			SchedulerTaskSupport.setDataMap(job, jobDataMap) ;

			Trigger trigger = TriggerBuilder.newTrigger()
			.withIdentity(jobName + "_trigger", jobGroupName + "_trigger")
			.startAt(startTime)
			.withSchedule(SimpleScheduleBuilder.simpleSchedule()
			.withIntervalInMinutes(intervalInMinutes)
			.withRepeatCount(repeatCount))
			.build();

			sched.scheduleJob(job, trigger);
			sched.start();

			return job.getKey().toString() ;

			}
			/**
			* 添加每X小时重复工作一次的工作任务，
			* @param jobName 工作名称
			* @param jobGroupName 工作组名称
			* @param jobClass 工作类
			* @param futureSecond 延迟到将来时长(单位秒)以开始工作
			* @param intervalInHour 重复工作间隔时长(小时)
			* @param repeatCount 重复工作次数(如果小于0，将一直重复执行下去 , 如果是0执行一次，如果是1执行2次，依次类推)
			* @throws Exception
			*/
			@SuppressWarnings({"unchecked","rawtypes"})
			public static String addHourlyJob(
			String jobName,
			String jobGroupName,
			Class jobClass ,
			HashMap<String , Object> jobDataMap ,
			int futureSecond,
			int intervalInHour ,
			int repeatCount) throws Exception {
			SchedulerTaskSupport.checkDelayStart(futureSecond) ;
			if(intervalInHour < 1){
			throw new Exception("重复工作间隔时长(单位小时)不能小于1小时)!") ;
			}

			Scheduler sched = SchedulerTaskFactory.getSingleScheduler(threadPoolMaxCount, threadPoolPriority) ;

			Date futureDate = DateBuilder.futureDate(futureSecond, DateBuilder.IntervalUnit.SECOND) ;
			Date startTime = DateBuilder.evenSecondDate(futureDate);

			JobDetail job = JobBuilder.newJob(jobClass)
			.withIdentity(jobName, jobGroupName)
			.build();
			SchedulerTaskSupport.setDataMap(job, jobDataMap) ;

			Trigger trigger = TriggerBuilder.newTrigger()
			.withIdentity(jobName + "_trigger", jobGroupName + "_trigger")
			.startAt(startTime)
			.withSchedule(SimpleScheduleBuilder.simpleSchedule()
			.withIntervalInHours(intervalInHour)
			.withRepeatCount(repeatCount))
			.build();

			sched.scheduleJob(job, trigger);
			sched.start();

			return job.getKey().toString() ;
			}

			/**
			* 添加每天某时某分重复工作一次的工作任务，
			* @param jobName 工作名称
			* @param jobGroupName 工作组名称
			* @param jobClass 工作类
			* @param hour 某时(0-23之间(包括0与23))
			* @param minute 某分(0-59之间(包括0与59))
			* @throws Exception
			*/
			// 表达式意义
			// "0 0 12 * * ?" 每天中午12点触发
			// "0 15 10 ? * *" 每天上午10:15触发
			// "0 15 10 * * ?" 每天上午10:15触发
			// "0 15 10 * * ? *" 每天上午10:15触发
			// "0 15 10 * * ? 2005" 2005年的每天上午10:15触发
			// "0 * 14 * * ?" 在每天下午2点到下午2:59期间的每1分钟触发
			// "0 0/5 14 * * ?" 在每天下午2点到下午2:55期间的每5分钟触发
			// "0 0/5 14,18 * * ?" 在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发
			// "0 0-5 14 * * ?" 在每天下午2点到下午2:05期间的每1分钟触发
			// "0 10,44 14 ? 3 WED" 每年三月的星期三的下午2:10和2:44触发
			// "0 15 10 ? * MON-FRI" 周一至周五的上午10:15触发
			// "0 15 10 15 * ?" 每月15日上午10:15触发
			// "0 15 10 L * ?" 每月最后一日的上午10:15触发
			// "0 15 10 ? * 6L" 每月的最后一个星期五上午10:15触发
			// "0 15 10 ? * 6L 2002-2005" 2002年至2005年的每月的最后一个星期五上午10:15触发
			// "0 15 10 ? * 6#3" 每月的第三个星期五上午10:15触发
			@SuppressWarnings({"unchecked","rawtypes"})
			public static String addDailyJob(
			String jobName,
			String jobGroupName,
			Class jobClass ,
			HashMap<String , Object> jobDataMap ,
			int hour ,
			int minute) throws Exception {
			SchedulerTaskSupport.checkHour(hour) ;
			SchedulerTaskSupport.checkMinute(minute) ;

			Scheduler sched = SchedulerTaskFactory.getSingleScheduler(threadPoolMaxCount, threadPoolPriority) ;

			JobDetail job = JobBuilder.newJob(jobClass)
			.withIdentity(jobName, jobGroupName)
			.build();
			SchedulerTaskSupport.setDataMap(job, jobDataMap) ;

			Trigger trigger = TriggerBuilder.newTrigger()
			.withIdentity(jobName + "_trigger", jobGroupName + "_trigger")
			.withSchedule(CronScheduleBuilder.cronSchedule("0 " + minute + " " + hour + " * * ? *"))
			.build();

			sched.scheduleJob(job, trigger);
			sched.start();

			return job.getKey().toString() ;
			}

			/**
			* 添加每周一、周二、周三、周四、周五各重复工作一次的工作任务，
			* @param jobName 工作名称
			* @param jobGroupName 工作组名称
			* @param jobClass 工作类
			* @param hour 某时(0-23之间(包括0与23))
			* @param minute 某分(0-59之间(包括0与59))
			* @throws Exception
			*/
			@SuppressWarnings({"unchecked","rawtypes"})
			public static String addWorkingDayInWeekJob(
			String jobName,
			String jobGroupName,
			Class jobClass ,
			HashMap<String , Object> jobDataMap ,
			int hour ,
			int minute) throws Exception {
			SchedulerTaskSupport.checkHour(hour) ;
			SchedulerTaskSupport.checkMinute(minute) ;

			Scheduler sched = SchedulerTaskFactory.getSingleScheduler(threadPoolMaxCount, threadPoolPriority) ;

			JobDetail job = JobBuilder.newJob(jobClass)
			.withIdentity(jobName, jobGroupName)
			.build();
			SchedulerTaskSupport.setDataMap(job, jobDataMap) ;

			Trigger trigger = TriggerBuilder.newTrigger()
			.withIdentity(jobName + "_trigger", jobGroupName + "_trigger")
			.withSchedule(CronScheduleBuilder.cronSchedule("0 " + minute + " " + hour + " ? * MON-FRI" ))
			.build();

			sched.scheduleJob(job, trigger);
			sched.start();

			return job.getKey().toString() ;
			}
			/**
			* 添加每一周的某一天某时某分重复工作一次的工作任务，
			* @param jobName 工作名称
			* @param jobGroupName 工作组名称
			* @param jobClass 工作类
			* @param dayOfWeek 一周的某一天(1代表周一,依次类推)(取值1-7(包括1与7))
			* @param hour 某时(0-23之间(包括0与23))
			* @param minute 某分(0-59之间(包括0与59))
			* @throws Exception
			*/
			@SuppressWarnings({"unchecked","rawtypes"})
			public static String addWeeklyJob(
			String jobName,
			String jobGroupName,
			Class jobClass ,
			HashMap<String , Object> jobDataMap ,
			int dayOfWeek,
			int hour ,
			int minute) throws Exception {
			SchedulerTaskSupport.checkHour(hour) ;
			SchedulerTaskSupport.checkMinute(minute) ;
			dayOfWeek = SchedulerTaskSupport.checkDayOfWeek(dayOfWeek);

			Scheduler sched = SchedulerTaskFactory.getSingleScheduler(threadPoolMaxCount, threadPoolPriority) ;

			JobDetail job = JobBuilder.newJob(jobClass)
			.withIdentity(jobName, jobGroupName)
			.build();
			SchedulerTaskSupport.setDataMap(job, jobDataMap) ;

			Trigger trigger = TriggerBuilder.newTrigger()
			.withIdentity(jobName + "_trigger", jobGroupName + "_trigger")
			.withSchedule(CronScheduleBuilder.cronSchedule("0 " + minute + " " + hour + " ? * " + dayOfWeek ))
			.build();

			sched.scheduleJob(job, trigger);
			sched.start();

			return job.getKey().toString() ;
			}
			/**
			* 添加每月的某一天某时某分重复工作一次的工作任务，
			* @param jobName 工作名称
			* @param jobGroupName 工作组名称
			* @param jobClass 工作类
			* @param dayOfMonth 一月的某一天(1-31之间(包括1与31))
			* @param hour 某时(0-23之间(包括0与23))
			* @param minute 某分(0-59之间(包括0与59))
			* @throws Exception
			*/
			@SuppressWarnings({"unchecked","rawtypes"})
			public static String addMonthlyJob(
			String jobName,
			String jobGroupName,
			Class jobClass ,
			HashMap<String , Object> jobDataMap ,
			int dayOfMonth,
			int hour ,
			int minute) throws Exception {
			SchedulerTaskSupport.checkHour(hour) ;
			SchedulerTaskSupport.checkMinute(minute) ;
			SchedulerTaskSupport.checkDayOfMonth(dayOfMonth);

			Scheduler sched = SchedulerTaskFactory.getSingleScheduler(threadPoolMaxCount, threadPoolPriority) ;

			JobDetail job = JobBuilder.newJob(jobClass)
			.withIdentity(jobName, jobGroupName)
			.build();
			SchedulerTaskSupport.setDataMap(job, jobDataMap) ;

			Trigger trigger = TriggerBuilder.newTrigger()
			.withIdentity(jobName + "_trigger", jobGroupName + "_trigger")
			.withSchedule(CronScheduleBuilder.cronSchedule("0 " + minute + " " + hour + " " + dayOfMonth + " * ?"))
			.build();

			sched.scheduleJob(job, trigger);
			sched.start();

			return job.getKey().toString() ;
			}
			/**
			* 添加每月的最后一天某时某分重复工作一次的工作任务，
			* @param jobName 工作名称
			* @param jobGroupName 工作组名称
			* @param jobClass 工作类
			* @param hour 某时(0-23之间(包括0与23))
			* @param minute 某分(0-59之间(包括0与59))
			* @throws Exception
			*/
			@SuppressWarnings({"unchecked","rawtypes"})
			public static String addLastDateOfMonthJob(
			String jobName,
			String jobGroupName,
			Class jobClass ,
			HashMap<String , Object> jobDataMap ,
			int hour ,
			int minute) throws Exception {
			SchedulerTaskSupport.checkHour(hour) ;
			SchedulerTaskSupport.checkMinute(minute) ;

			Scheduler sched = SchedulerTaskFactory.getSingleScheduler(threadPoolMaxCount, threadPoolPriority) ;

			JobDetail job = JobBuilder.newJob(jobClass)
			.withIdentity(jobName, jobGroupName)
			.build();
			SchedulerTaskSupport.setDataMap(job, jobDataMap) ;

			Trigger trigger = TriggerBuilder.newTrigger()
			.withIdentity(jobName + "_trigger", jobGroupName + "_trigger")
			.withSchedule(CronScheduleBuilder.cronSchedule("0 " + minute + " " + hour + " L * ?"))
			.build();

			sched.scheduleJob(job, trigger);
			sched.start();

			return job.getKey().toString() ;
			}


			/**
			* 设置参数数据
			*/
			private static void setDataMap(JobDetail job , HashMap<String , Object> jobDataMap){
			if(jobDataMap != null && jobDataMap.size() > 0){
			JobDataMap map = job.getJobDataMap();
			Set<Map.Entry<String , Object>> set = jobDataMap.entrySet() ;
			Iterator<Map.Entry<String , Object>> it = set.iterator() ;
			Map.Entry<String , Object> entry = null ;
			String key = null ;
			Object value = null ;
			while(it.hasNext()){
			entry = it.next() ;
			key = entry.getKey() ;
			value = entry.getValue() ;
			map.put(key, value);
			}
			}
			}

			/**
			*
			* @param futureSecond
			*/
			private static void checkDelayStart(int futureSecond)throws Exception {
			if(futureSecond < 0){
			throw new Exception("延迟开始工作时长(单位秒)不能小于0!") ;
			}
			}

			/**
			*
			* @param hour
			* @throws Exception
			*/
			private static void checkHour(int hour)throws Exception {
			if(hour < 0 \|\| hour >= 24){
			throw new Exception("重复工作的小时时间点取值必须在0-23之间(包括0与23)!") ;
			}
			}
			/**
			*
			* @param minute
			* @throws Exception
			*/
			private static void checkMinute(int minute)throws Exception {
			if(minute < 0 \|\| minute >= 60){
			throw new Exception("重复工作的分钟时间点取值必须在0-59之间(包括0与59)!") ;
			}
			}
			/**
			*
			* @param dayOfWeek
			* @throws Exception
			*/
			private static int checkDayOfWeek(int dayOfWeek)throws Exception {
			if(dayOfWeek < 1 \|\| dayOfWeek > 7){
			throw new Exception("重复工作的一星期的某一天取值必须在1(周一)-7(周日)间(包括1与7)!") ;
			}
			int d = 0 ;
			if(dayOfWeek == 1){
			d = DateBuilder.MONDAY ;
			}else if(dayOfWeek == 2){
			d = DateBuilder.TUESDAY ;
			}else if(dayOfWeek == 3){
			d = DateBuilder.WEDNESDAY ;
			}else if(dayOfWeek == 4){
			d = DateBuilder.THURSDAY ;
			}else if(dayOfWeek == 5){
			d = DateBuilder.FRIDAY ;
			}else if(dayOfWeek == 6){
			d = DateBuilder.SATURDAY ;
			}else if(dayOfWeek == 7){
			d = DateBuilder.SUNDAY ;
			}
			return d ;
			}
			/**
			*
			* @param dayOfMonth
			* @throws Exception
			*/
			private static void checkDayOfMonth(int dayOfMonth)throws Exception {
			if(dayOfMonth < 1 \|\| dayOfMonth > 31){
			throw new Exception("重复工作一月某一天取值必须在1-31之间(包括1与31)!") ;
			}
			}
			}