jnpf-java-boot-v6x/jnpf-flowable/jnpf-flowable-biz/target/classes/jnpf/flowable/job/JobRunner.java

package jnpf.flowable.job;

import jnpf.flowable.model.time.FlowTimeModel;
import jnpf.flowable.util.TimeUtil;
import jnpf.util.JsonUtil;
import jnpf.util.RandomUtil;
import jnpf.util.RedisUtil;
import org.quartz.JobDataMap;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;

import java.util.Date;
import java.util.List;

/**
 * 类的描述
 *
 * @author JNPF@YinMai Info. Co., Ltd
 * @version 5.0.x
 * @since 2024/5/23 17:49
 */
//@Component
public class JobRunner implements ApplicationRunner {
    @Autowired
    private RedisUtil redisUtil;

    @Override
    public void run(ApplicationArguments args) throws Exception {
        // 获取缓存中定时相关信息
        List<FlowTimeModel> list = FlowJobUtil.getOperator(redisUtil);
        for (FlowTimeModel timeModel : list) {
            Date date = new Date();
            // 判断当前时间是否已经 超过了结束时间
            if (date.getTime() > timeModel.getEndDate().getTime()) {
                continue;
            }
            if (timeModel.getOn()) {
                timeModel.setId(RandomUtil.uuId());
                JobDataMap jobDataMap = new JobDataMap();
                jobDataMap.putAll(JsonUtil.entityToMap(timeModel));
                FlowJobUtil.insertModel(timeModel, redisUtil);
                TimeUtil.addJob(timeModel.getId(), timeModel.getDuring(), FlowTime.class, jobDataMap, timeModel.getStartDate(), timeModel.getEndDate());
            }
        }

    }
}