package com.ydtech.modules.ttqf; import cn.hutool.extra.spring.SpringUtil; import lombok.extern.slf4j.Slf4j; import org.quartz.*; @Slf4j public class QuartzUserSign implements Job { @Override public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { try { if ((boolean) QuartzManager.getInstance().getContext().get("flag")){ JobDataMap mergedJobDataMap = jobExecutionContext.getMergedJobDataMap(); String idCardNo = String.valueOf(mergedJobDataMap.get("idCardNo")); log.info("用户签约状态查询入参:{}",idCardNo); if (SpringUtil.getBean(RetrieveTTQFApi.class).queryPressing(idCardNo)){ log.info("用户签约状态查询成功"); QuartzManager.getInstance().removeJob(jobExecutionContext); } log.info("当前线程+++++++++++++{}",Thread.currentThread().getId()); }else { log.info("获取天天企赋状态退出",jobExecutionContext.getJobDetail().getKey().getName()); QuartzManager.getInstance().removeJob(jobExecutionContext); } } catch (SchedulerException e) { throw new RuntimeException(e); } } }