spring监听器

public class SchedulerInitListener implements ApplicationListener<ContextRefreshedEvent>{
    
    // 在任务表中，加入状态字段，其中值为 Y 或 N
    private static final String STATUS_USABLE = "Y";
    // 拼接要执行的类
    private static final String PACKAGE = "com.flyme.job.";
    private static final Logger log = LoggerFactory.getLogger(SchedulerInitListener.class);

    @Autowired
    private IAuditScheduleJobService auditScheduleService;
    
    /** 
     * @param jobName 任务名 
     * @param jobGroupName  任务组名 
     * @param triggerName 触发器名 
     * @param triggerGroupName 触发器组名 
     * @param jobClass  class
     * @param cron   时间设置  
     */  
    @Override
    public void onApplicationEvent(ContextRefreshedEvent event) {
        //只执行一次
        if(event.getApplicationContext().getParent() ==null){
            List<Map<String, Object>>
            // 进行查询数据库，返回list对象
            scheduleList=auditScheduleService.queryAuditSchedule();
            if(scheduleList.size()>0){
                for(Map<String, Object> map:scheduleList){
                    //启动所有可用的定时调度任务
                    if(STATUS_USABLE.equals(map.get("STATUS"))){
                        try {
                            //反射获取指定要运作的class
                            Class<String> schedulerClass=(Class<String>) Class.forName(PACKAGE+(String)map.get("JOB_CLASS"));
                            SchedulerManager.addJob((String)map.get("JOB_NAME"),
                                    (String)map.get("JOB_GROUP_NAME"), (String)map.get("TRIGGER_NAME"),
                                    (String)map.get("TRIGGER_GROUP_NAME"), schedulerClass, (String)map.get("CRON"));
                        } catch (Exception e) {
                            log.error("任务:"+(String)map.get("JOB_NAME")+"启动失败,失败原因是:"+e.getMessage(),e);
                        }
                    }
                }
            }
        }
    }

}

<!-- 当Spring容器启动完成后执行下面的这个Bean -->
<bean class="com.flyme.listener.SchedulerInitListener"></bean>