定时任务框架-quartz

依赖

                <!-- 定时任务jar -->
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.1.7</version>
        </dependency>            

任务调度类

/**
 * 
 * @作者 陈祥
 * @创建时间 2018年5月29日 
 * @功能描述 定时任务， 分配结算大小B 业务方法实现
 */
public class DistributeSettlementDateJobService  {
    
    //非大B分销商佣金结算 时间  每个月 20 号3点 触发
    private final String DATE_DISTRI = "0 0 3 20 * ?";
    // 大B  每天整点30分触发
    private final String DATE_B_DISTRI = "0 30 * * * ?";
    // 检查订单过期  每分钟触发
    private final String DATE_ORDER =  "30 * * * * ?";
    // 自动好评， 每天 4点触发
    private final String DATE_OrderEvaluate =  "0 0 4 * * ?";
    // 自动收货， 每天 2点触发
    private final String DATE_OrderTake =  "0 0 3 * * ?";
    
    public void DistributeSettlement() throws Exception {

        SchedulerFactory sf = new StdSchedulerFactory();
        Scheduler sched = sf.getScheduler();

        //结算小B 和 其他
        JobDetail job = newJob(DistributeSettlementDateJobAll.class).withIdentity("job1", "group1").build();
        Trigger trigger = newTrigger().withIdentity("trigger1", "group1").withSchedule(cronSchedule(DATE_DISTRI)).build();
        sched.scheduleJob(job, trigger);
        
        //检查订单是否过期任务
        job = newJob(OrderDateJob.class).withIdentity("job2", "group1").build();
        trigger = newTrigger().withIdentity("trigger2", "group1").withSchedule(cronSchedule(DATE_ORDER)).build();
        sched.scheduleJob(job, trigger);
        
        //结算大B
        job = newJob(DistributeSettlementDateJobFoB.class).withIdentity("job3", "group1").build();
        trigger = newTrigger().withIdentity("trigger3", "group1").withSchedule(cronSchedule(DATE_B_DISTRI)).build();
        sched.scheduleJob(job, trigger);

        // 自动好评
        job = newJob(OrderEvaluateDateJob.class).withIdentity("job4", "group1").build();
        trigger = newTrigger().withIdentity("trigger4", "group1").withSchedule(cronSchedule(DATE_OrderEvaluate)).build();
        sched.scheduleJob(job, trigger);
        
        // 自动收货
        job = newJob(OrderTakeDateJob.class).withIdentity("job5", "group1").build();
        trigger = newTrigger().withIdentity("trigger5", "group1").withSchedule(cronSchedule(DATE_OrderTake)).build();
        sched.scheduleJob(job, trigger);
        
        
        
        
        
        
        
        
        sched.start();
    }
    
}

任务实现类，实现 job 接口， 重写 execute() 方法即可

package eidolon.time.service;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

import bingosoft.metro.model.OrderModel;
import leap.orm.dao.Dao;
import utils.redis.RedisUtil;

/**
 * 
 * @作者 陈祥
 * @创建时间 2018年5月31日
 * @功能描述 定时检查是否有订单过期
 */
public class OrderDateJob implements Job {

    private final String mapName = "orderTime";

    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {

        RedisUtil redisUtil = RedisUtil.getRedisUtil();
        Map<String, String> mapAll = redisUtil.getMapAll(mapName);
        if (null != mapAll && mapAll.size() > 1) {

            ArrayList<String> ids = new ArrayList<>();
            // 当前时间
            long newTime = new Date().getTime();
            for (String key : mapAll.keySet()) {
                Long lowTime = Long.valueOf(mapAll.get(key));
                if (newTime > lowTime) {

                    ids.add(key);
                    System.err.println("删除过期：" + key);
                }
            }
            if(ids  !=  null &&  ids.size() > 0 ){
                HashMap<String, Object> params = new HashMap<>();
                params.put("orderId", ids);
                Dao.get().doTransaction((s) -> {
                    // 数据库修改状态
                    OrderModel.dao().executeNamedUpdate("orderDateJob-updateOrder", params);
                    // 删除缓存
                    for (String id : ids) {
                        redisUtil.delKeyAndValueForMap(mapName, id);
                    }

                });
            }
        } else {
            System.err.println("没有过期");
        }

    }
}