diff --git a/src/main/java/cn/chjyj/szwh/job/SzwhRevocationGoodsJob.java b/src/main/java/cn/chjyj/szwh/job/SzwhRevocationGoodsJob.java new file mode 100644 index 0000000..353ee94 --- /dev/null +++ b/src/main/java/cn/chjyj/szwh/job/SzwhRevocationGoodsJob.java @@ -0,0 +1,30 @@ +package cn.chjyj.szwh.job; + +import cn.chjyj.szwh.service.GoodsTaskService; +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.quartz.JobExecutionContext; +import org.quartz.JobExecutionException; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.quartz.QuartzJobBean; + +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; +import java.util.Calendar; + +public class SzwhRevocationGoodsJob extends QuartzJobBean { + private static Log log = LogFactory.getLog(SzwhRevocationGoodsJob.class); + + @Autowired + private GoodsTaskService goodsTaskService; + + @Override + protected void executeInternal(JobExecutionContext context) throws JobExecutionException { + Calendar cal = Calendar.getInstance(); + LocalDateTime localDateTime = LocalDateTime.now(); + String nowstr = localDateTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")); + log.info("获取撤销委托信息:"+nowstr); + // + goodsTaskService.getRevocationGoods(); + } +} diff --git a/src/main/java/cn/chjyj/szwh/task/TaskInit.java b/src/main/java/cn/chjyj/szwh/task/TaskInit.java index 38aac3a..2e7d2d5 100644 --- a/src/main/java/cn/chjyj/szwh/task/TaskInit.java +++ b/src/main/java/cn/chjyj/szwh/task/TaskInit.java @@ -1,6 +1,7 @@ package cn.chjyj.szwh.task; import cn.chjyj.szwh.job.SzwhJob; +import cn.chjyj.szwh.job.SzwhRevocationGoodsJob; import org.quartz.*; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.ApplicationArguments; @@ -37,5 +38,18 @@ public class TaskInit implements ApplicationRunner { .build(); // 手动将触发器与任务绑定到调度器内 scheduler.scheduleJob(jobDetail, trigger); + //获取商品的撤销状态 + JobDetail revojob = JobBuilder.newJob(SzwhRevocationGoodsJob.class) + .withIdentity(sid+"02") + .storeDurably() + .build(); + // 20s执行一次 + Trigger revoTrigger = TriggerBuilder.newTrigger() + .forJob(revojob) + .withIdentity(sid+"02Trigger") + .withSchedule(CronScheduleBuilder.cronSchedule("0/20 * * * * ? *")) + .startNow() + .build(); + scheduler.scheduleJob(revojob,revoTrigger); } }