获取撤销信息定时任务

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();
+    }
+}

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);
     }
 }