From e25868723fb5570480bf60bf86812a0ca31981f9 Mon Sep 17 00:00:00 2001
From: xyiege <xyiege@gmail.com>
Date: Mon, 26 Sep 2022 10:59:12 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=9A=E4=B8=AA=E5=AE=9A=E6=97=B6=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E8=AE=BE=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../chjyj/szwh/service/GoodsTaskService.java  | 11 +++++++++++
 .../service/impl/GoodsTaskServiceImpl.java    | 13 +++++++++++++
 .../cn/chjyj/szwh/task/SzwhScheduled.java     | 19 ++++++++++++++++---
 3 files changed, 40 insertions(+), 3 deletions(-)
 create mode 100644 src/main/java/cn/chjyj/szwh/service/GoodsTaskService.java
 create mode 100644 src/main/java/cn/chjyj/szwh/service/impl/GoodsTaskServiceImpl.java

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