diff --git a/src/main/java/cn/chjyj/szwh/service/GoodsTaskService.java b/src/main/java/cn/chjyj/szwh/service/GoodsTaskService.java new file mode 100644 index 0000000..e808cd9 --- /dev/null +++ b/src/main/java/cn/chjyj/szwh/service/GoodsTaskService.java @@ -0,0 +1,11 @@ +package cn.chjyj.szwh.service; + +/** + * 商品定时任务接口 + */ +public interface GoodsTaskService { + /** + * 获取撤销委托信息 + */ + public void getRevocationGoods(); +} diff --git a/src/main/java/cn/chjyj/szwh/service/impl/GoodsTaskServiceImpl.java b/src/main/java/cn/chjyj/szwh/service/impl/GoodsTaskServiceImpl.java new file mode 100644 index 0000000..596f96f --- /dev/null +++ b/src/main/java/cn/chjyj/szwh/service/impl/GoodsTaskServiceImpl.java @@ -0,0 +1,13 @@ +package cn.chjyj.szwh.service.impl; + +import cn.chjyj.szwh.service.GoodsTaskService; +import org.springframework.stereotype.Service; + +@Service +public class GoodsTaskServiceImpl implements GoodsTaskService { + @Override + public void getRevocationGoods() { + String st="同步被撤销商品信息"; + System.out.println(st); + } +} diff --git a/src/main/java/cn/chjyj/szwh/task/SzwhScheduled.java b/src/main/java/cn/chjyj/szwh/task/SzwhScheduled.java index 18eb19c..5011b5a 100644 --- a/src/main/java/cn/chjyj/szwh/task/SzwhScheduled.java +++ b/src/main/java/cn/chjyj/szwh/task/SzwhScheduled.java @@ -1,5 +1,6 @@ package cn.chjyj.szwh.task; +import cn.chjyj.szwh.service.GoodsTaskService; import org.springframework.context.annotation.Bean; import org.springframework.scheduling.TaskScheduler; import org.springframework.scheduling.annotation.EnableScheduling; @@ -13,8 +14,18 @@ import java.time.LocalDateTime; * 多个定时任务启动 */ @Component -@EnableScheduling +//@EnableScheduling public class SzwhScheduled { + private GoodsTaskService goodsTaskService; + + public GoodsTaskService getGoodsTaskService() { + return goodsTaskService; + } + + public void setGoodsTaskService(GoodsTaskService goodsTaskService) { + this.goodsTaskService = goodsTaskService; + } + @Bean public TaskScheduler taskScheduler(){ ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler(); @@ -25,18 +36,20 @@ public class SzwhScheduled { /** * 查询查询撤销商品的信息 */ - @Scheduled(cron = "0/20 * * * * ?") + //@Scheduled(cron = "0/20 * * * * ?") public void queryRevocationGoods(){ String curName = Thread.currentThread().getName() ; System.out.println("当前时间:"+ LocalDateTime.now()+" 任务queryRevocationGoods对应的线程名: "+curName); + try { + goodsTaskService.getRevocationGoods(); Thread.sleep(1000); } catch (Exception e) { e.printStackTrace(); } } - @Scheduled(cron = "0/5 * * * * ?") + //@Scheduled(cron = "0/5 * * * * ?") public void execute2(){ String curName = Thread.currentThread().getName() ; System.out.println("当前时间:"+LocalDateTime.now()+" 任务execute2对应的线程名: "+curName);