PAS/src/main/java/cn/cslg/pas/service/TaskAddJob.java

package cn.cslg.pas.service;

import cn.cslg.pas.domain.business.ImportTask;

import cn.cslg.pas.domain.business.ImportTaskCondition;
import cn.cslg.pas.service.business.ImportTaskService;
import cn.cslg.pas.service.importPatent.SchedulingTaskService;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import lombok.RequiredArgsConstructor;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.quartz.DisallowConcurrentExecution;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.scheduling.quartz.QuartzJobBean;

import java.util.Arrays;
import java.util.List;

/**
 * 定义任务
 */
@RequiredArgsConstructor
@DisallowConcurrentExecution
public class TaskAddJob extends QuartzJobBean {

    private static final Log logger = LogFactory.getLog(TaskAddJob.class);
    private boolean flag = true;
    private final ImportTaskService importTaskService;
    private final SchedulingTaskService schedulingTaskService;
    @Override
    public void executeInternal(JobExecutionContext context) throws JobExecutionException {
        JobDataMap jobDataMap = context.getTrigger().getJobDataMap();
        ImportTaskCondition taskCondition = (ImportTaskCondition) jobDataMap.get("taskCondition");
        ImportTask task = new ImportTask();
        //任务存入生产者任务队列并唤醒生产者线程
        schedulingTaskService.startTask();

        logger.info("添加任务" + "信息是" + task);
    }

}