From ccf2d41974f84d7c2c3a39d5913cbd4b076d27bf Mon Sep 17 00:00:00 2001
From: LegnaYet <1023868505@qq.com>
Date: Tue, 19 May 2020 20:17:23 +0800
Subject: [PATCH] =?UTF-8?q?=E9=97=A8=E5=BA=97=E5=8F=B7=E7=AE=A1=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ic/config/ScheduledTaskConfiguration.java | 25 +++++++++++++++++++
 .../job/behavior/StorePromotionDataJob.java   |  4 +--
 .../ic/job/count/SyncCountJobService.java     |  4 +--
 3 files changed, 29 insertions(+), 4 deletions(-)
 create mode 100644 src/main/java/com/kiisoo/ic/config/ScheduledTaskConfiguration.java

diff --git a/src/main/java/com/kiisoo/ic/config/ScheduledTaskConfiguration.java b/src/main/java/com/kiisoo/ic/config/ScheduledTaskConfiguration.java
new file mode 100644
index 0000000..553414a
--- /dev/null
+++ b/src/main/java/com/kiisoo/ic/config/ScheduledTaskConfiguration.java
@@ -0,0 +1,25 @@
+package com.kiisoo.ic.config;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.SchedulingConfigurer;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+import org.springframework.scheduling.config.ScheduledTaskRegistrar;
+
+@Configuration
+public class ScheduledTaskConfiguration implements SchedulingConfigurer {
+
+    /**
+     * Callback allowing a {@link TaskScheduler
+     * TaskScheduler} and specific {@link Task Task}
+     * instances to be registered against the given the {@link ScheduledTaskRegistrar}
+     *
+     * @param taskRegistrar the registrar to be configured.
+     */
+    @Override
+    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
+        final ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
+        taskScheduler.setPoolSize(2);
+        taskScheduler.initialize();
+        taskRegistrar.setTaskScheduler(taskScheduler);
+    }
+}
diff --git a/src/main/java/com/kiisoo/ic/job/behavior/StorePromotionDataJob.java b/src/main/java/com/kiisoo/ic/job/behavior/StorePromotionDataJob.java
index 20ea496..11d0bfd 100644
--- a/src/main/java/com/kiisoo/ic/job/behavior/StorePromotionDataJob.java
+++ b/src/main/java/com/kiisoo/ic/job/behavior/StorePromotionDataJob.java
@@ -7,7 +7,7 @@ import com.kiisoo.ic.utils.DateUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Service;
+import org.springframework.stereotype.Component;
 
 import java.text.SimpleDateFormat;
 import java.util.Date;
@@ -21,7 +21,7 @@ import static com.kiisoo.ic.system.constant.SysTaskConstant.*;
  * @company kiisoo
  * @details 获取联系客户统计数据定时任务 job 0 0 1 * * ?
  */
-@Service
+@Component
 @Slf4j
 public class StorePromotionDataJob {
 
diff --git a/src/main/java/com/kiisoo/ic/job/count/SyncCountJobService.java b/src/main/java/com/kiisoo/ic/job/count/SyncCountJobService.java
index 997ac82..43c67bc 100644
--- a/src/main/java/com/kiisoo/ic/job/count/SyncCountJobService.java
+++ b/src/main/java/com/kiisoo/ic/job/count/SyncCountJobService.java
@@ -6,7 +6,7 @@ import com.kiisoo.ic.system.mapper.SysTaskDOMapper;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Service;
+import org.springframework.stereotype.Component;
 
 import java.text.SimpleDateFormat;
 import java.util.Date;
@@ -14,7 +14,7 @@ import java.util.Random;
 
 import static com.kiisoo.ic.system.constant.SysTaskConstant.*;
 
-@Service
+@Component
 @Slf4j
 public class SyncCountJobService {
     @Autowired