PAS/src/main/java/cn/cslg/pas/service/quartzService/ImportPatentJobService.java

package cn.cslg.pas.service.quartzService;

import cn.cslg.pas.domain.business.ImportTaskCondition;
import cn.cslg.pas.service.business.ImportTaskConditionService;
import cn.cslg.pas.service.business.ImportTaskService;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import lombok.RequiredArgsConstructor;
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.List;


@DisallowConcurrentExecution
@RequiredArgsConstructor
public class ImportPatentJobService extends QuartzJobBean {
private final ImportTaskConditionService  importTaskConditionService;
private final ImportTaskService importTaskService;
    @Override
    public void executeInternal(JobExecutionContext context) throws JobExecutionException {
        JobDataMap jobDataMap = context.getTrigger().getJobDataMap();
        QrtzTaskDTO qrtzTask = (QrtzTaskDTO) jobDataMap.get("qrtzTask");
             Integer projectId =qrtzTask.getId();
             //根据id查询检索条件
        LambdaQueryWrapper<ImportTaskCondition> queryWrapper =new LambdaQueryWrapper<>();
        queryWrapper.eq(ImportTaskCondition::getProjectId,projectId);
        queryWrapper.eq(ImportTaskCondition::getIfCycle,true)
                    .eq(ImportTaskCondition::getIfUpdate,true);
        List<ImportTaskCondition> importTaskConditions =importTaskConditionService.list(queryWrapper);
            importTaskConditions.forEach(item->{
                importTaskService.addImportTaskByCondition(item);
            });

    }
}