Quartz 定时器初始化代码

[java]代码库

    /**
     * Quartz Cron 表达式支持到七个域 名称 是否必须 允许值 特殊字符 秒 是 0-59 , - * / 分 是 0-59 , - * /
     * 时 是 0-23 , - * / 日 是 1-31 , - * ? / L W C 月 是 1-12或 JAN-DEC , - * / 周 是
     * 1-7 或 SUN-SAT , - * ? / L C # 年 否 空 或 1970-2099 , - * /
     * 
     * @param Properties
     */
    private boolean initTimePaln() {
        Properties prams = Config.getInstance().getMqPrams();
        if (prams == null) {
            logger.error("MQ配置信息为空");
        }
        int timePlan = Integer.parseInt(prams.getProperty("PLANTIME"));

        int timePlan_refreshCache = Integer.parseInt(prams
                .getProperty("TIMEPLAN_REFRESHCACHE"));

        try {
            Properties props = new Properties();
            props.put(StdSchedulerFactory.PROP_THREAD_POOL_CLASS,
                    "org.quartz.simpl.SimpleThreadPool");
            props.put("org.quartz.threadPool.threadCount", "3");
            SchedulerFactory sf = new StdSchedulerFactory(props);
            if (timePlan != -1) {
                CronTrigger trigger = newTrigger()
                        .withIdentity("TimePlanTrigger", "group1")
                        .withSchedule(
                                cronSchedule("0 1 " + timePlan + " * * ?"))
                        .build();
                JobDetail job = newJob(CallDataTramsfromTask.class)
                        .withIdentity("TimpPlanJob", "group1").build();
                scheduler_TimePlan = sf.getScheduler();
                Date ft = scheduler_TimePlan.scheduleJob(job, trigger);
                logger.info(job.getKey() + "在" + ft + "开始调度执行，调度周期为"
                        + trigger.getCronExpression());
            }

            if (timePlan_refreshCache != -1) {
                CronTrigger trigger_refreshCachfe = newTrigger()
                        .withIdentity("TimePlanTrigger_refreshCache",
                                "group3")
                        .withSchedule(
                                cronSchedule("0 1 " + timePlan_refreshCache
                                        + " * * ?")).build();
                JobDetail job__refreshCachfe = newJob(RefreshCacheTask.class)
                        .withIdentity("TimpPlanJob_refreshCache", "group3")
                        .build();
                Date ft = scheduler_TimePlan.scheduleJob(job__refreshCachfe,
                        trigger_refreshCachfe);
                logger.info(job__refreshCachfe.getKey() + "在" + ft
                        + "开始调度执行(刷新缓存)，调度周期为"
                        + trigger_refreshCachfe.getCronExpression());
            }

        } catch (SchedulerException e) {
            logger.error("初始化定时调度器异常" + e.getMessage());
            return false;
        }
        return true;
    }