quartz的工具类代码,Java代码库,德仔网

代码语言
代码分类
【Java】 quartz的工具类
作者:文华 / 发布于2017/1/11/ 787
cache类:

package com.sitech.message.base;
 
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
 
import org.quartz.Scheduler;
 
/**
 * 系统缓存，建议换redis
 * @author hb
 */
public class Cache {
    /**
     * scheduler 缓存
     */
    public static Map<String,Scheduler> scheduler_task = new ConcurrentHashMap<String,Scheduler>();
     
    /**
     * job 缓存
     */
    public static Map<String,String> scheduler_task_job = new ConcurrentHashMap<String,String>();
     
    /**
     * 获取规则
     *
     */
    public static Map<String,Object> task_size = new ConcurrentHashMap<String,Object>();
}





package com.sitech.message.controller.task;
 
import java.util.Calendar;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
 
import com.sitech.message.base.Cache;
import com.sitech.message.dao.BaseDao;
import com.sitech.message.dao.NameSpace;
import com.sitech.message.job.WarningDept;
import com.sitech.message.job.WarningQuestion;
import com.sitech.message.service.IQuartzTaskService;
 
/**
 * 预警
 * @author Administrator
 *
 */
@Component
public class JobWarningSchedular {
    private static final Logger logger = Logger.getLogger(JobWarningSchedular.class);
    @Autowired
    private BaseDao baseDao;
    @Autowired
    private IQuartzTaskService quartzTaskService;
    private boolean isFirst = true;
    /**
     * 预警扫描
     */
    @Scheduled(cron = "0 0/1 * * * ?")
    public void scan(){
        logger.debug("start scan... time:"+Calendar.getInstance().getTime());
        Map<String,String> paramMap = new HashMap<String,String>();
        if(!isFirst){
            paramMap.put("is_update", "1");
        }
        paramMap.put("type", "2");
        //从配置文件取数据
        List<Map<String,Object>> configs = baseDao.selectList(NameSpace.BS_JOB_WARNINGMapper, "selective",paramMap);
        System.out.println(configs.size());
         
        for(Map<String,Object> config : configs){
            String id = (String) config.get("ID");
            String type = (String)config.get("TYPE");
            String classify = (String)config.get("CLASSIFY");
            String job_dept = id+"_"+type+"_"+classify+"_dept";
            String job_question = id+"_"+type+"_"+classify+"_question";
            String is_warn = (String)config.get("IS_WARN");
            //扫描时间
            String cron_m0 = (String)config.get("CRON_M0");
            String cron_m1 = (String)config.get("CRON_M1");
            String cron_m2 = (String)config.get("CRON_M2");
             
            //如果是第一次扫描,全部扫描
            if(isFirst){
                //is_warn为0,执行预警扫描.
                if("0".equals(is_warn)){
                    //部门预警
                    if(StringUtils.isEmpty(Cache.scheduler_task_job.get(job_dept))){
                        JobDetail jobDetail = new JobDetail(job_dept, job_dept, WarningDept.class);
                        //如果部门为空,默认本地网cron_m0
                        if(StringUtils.isEmpty(cron_m1)){
                            cron_m1 = cron_m0;
                        }
                        JobDataMap map = new JobDataMap();
                        map.putAll(config);
                        jobDetail.setJobDataMap(map);
                        Cache.scheduler_task_job.put(job_dept, job_dept);
                        quartzTaskService.addJob(job_dept, jobDetail , WarningDept.class, cron_m1);
                    }
                    //整单预警
                    if(StringUtils.isEmpty(Cache.scheduler_task_job.get(job_question))){
                        JobDetail jobDetail = new JobDetail(job_question, job_question, WarningQuestion.class);
                        JobDataMap map = new JobDataMap();
                        map.putAll(config);
                        jobDetail.setJobDataMap(map);
                        Cache.scheduler_task_job.put(job_question, job_question);
                        quartzTaskService.addJob(job_question, jobDetail , WarningQuestion.class, cron_m2);
                    }
                }
                 
            }else{//专门用于更新扫描操作,两步操作
                //1.先删除预警线程,然后增加新的预警线程
                //部门预警的线程操作
                 
                if(job_dept.equals(Cache.scheduler_task_job.get(job_dept))){
                    logger.debug("delte job_dept....");
                    Cache.scheduler_task_job.remove(job_dept);
                    quartzTaskService.removeJob(job_dept);
                }
                //整单预警的线程操作
                if(job_question.equals(Cache.scheduler_task_job.get(job_question))){
                    logger.debug("delete job_question...");
                    Cache.scheduler_task_job.remove(job_question);
                    quartzTaskService.removeJob(job_question);
                }
                if("0".equals(is_warn)){
                    logger.debug("delte job_dept....");
                    JobDetail jobDetail = new JobDetail(job_dept, job_dept, WarningDept.class);
                    //如果部门为空,默认本地网cron_m0
                    if(StringUtils.isEmpty(cron_m1)){
                        cron_m1 = cron_m0;
                    }
                    JobDataMap map = new JobDataMap();
                    map.putAll(config);
                    jobDetail.setJobDataMap(map);
                    logger.debug("add new job_dept....");
                    Cache.scheduler_task_job.put(job_dept, job_dept);
                    quartzTaskService.addJob(job_dept, jobDetail , WarningDept.class, cron_m1);
                     
                    JobDetail jobDetail1 = new JobDetail(job_question, job_question, WarningQuestion.class);
                    jobDetail1.setJobDataMap(map);
                    logger.debug("add job_question...");
                    Cache.scheduler_task_job.put(job_question, job_question);
                    quartzTaskService.addJob(job_question, jobDetail1 , WarningQuestion.class, cron_m2);
                }
                try {
                    baseDao.update(NameSpace.BS_JOB_WARNINGMapper, "updateStatus", config);
                } catch (Exception e) {
                    logger.error("update bs_job_warning is failed ",e);
                }
            }
        }
        isFirst = false;
        logger.debug("end scan... time:"+Calendar.getInstance().getTime());
    }
     
}
试试其它关键字
同语言下
可能有用的
文华贡献的其它代码(11)