worm init done

Author: HiCooper

src/main/java/com/berry/oss/quartz/JobFactory.java

@@ -0,0 +1,32 @@
+package com.berry.oss.quartz;
+
+import org.quartz.spi.TriggerFiredBundle;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
+import org.springframework.scheduling.quartz.AdaptableJobFactory;
+import org.springframework.stereotype.Component;
+
+/**
+ * Created with IntelliJ IDEA.
+ *
+ * @author Berry_Cooper.
+ * @version 1.0
+ * @date 2020/12/22 12:57
+ * fileName：JobFactory
+ * Use：
+ */
+@Component
+public class JobFactory extends AdaptableJobFactory {
+
+    @Autowired
+    private AutowireCapableBeanFactory capableBeanFactory;
+
+    @Override
+    protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
+        // 调用父类的方法
+        Object jobInstance = super.createJobInstance(bundle);
+        // 进行注入
+        capableBeanFactory.autowireBean(jobInstance);
+        return jobInstance;
+    }
+}

src/main/java/com/berry/oss/quartz/QuartzConfig.java

@@ -3,8 +3,10 @@
 import com.berry.oss.common.utils.CsvUtils;
 import com.berry.oss.quartz.job.NonReferenceObjectCleanJob;
 import org.quartz.*;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.quartz.SchedulerFactoryBean;
 
 /**
  * Title QuartzConfig
@@ -16,6 +18,22 @@
 @Configuration
 public class QuartzConfig {
 
+    @Autowired
+    private JobFactory jobFactory;
+
+    @Bean
+    public SchedulerFactoryBean schedulerFactoryBean() {
+        SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
+        schedulerFactoryBean.setJobFactory(jobFactory);
+        return schedulerFactoryBean;
+    }
+
+    @Bean
+    public Scheduler scheduler() {
+        return schedulerFactoryBean().getScheduler();
+    }
+
+
     @Bean
     public JobDetail nonRefObjectCleanJob() {
         return JobBuilder.newJob(NonReferenceObjectCleanJob.class).withIdentity("non_ref_clean_job", "sys_job").storeDurably().build();

src/main/java/com/berry/oss/quartz/QuartzJobManagement.java

@@ -2,6 +2,9 @@
 
 import org.quartz.*;
 import org.quartz.impl.StdSchedulerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.scheduling.quartz.SchedulerFactoryBean;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.PostConstruct;
@@ -20,21 +23,13 @@
 public class QuartzJobManagement {
     private static final String JOB_GROUP_NAME = "WORM_CHECK_JOB_GROUP";
     private static final String TRIGGER_GROUP_NAME = "WORM_CHECK_TRIGGER_GROUP";
+
     /**
      * Quartz调度器
      */
+    @Autowired
     private Scheduler scheduler;
 
-    /**
-     * 初始化调度器
-     * @throws SchedulerException e
-     */
-    @PostConstruct
-    public void init() throws SchedulerException {
-        SchedulerFactory schedulerFactory = new StdSchedulerFactory();
-        scheduler = schedulerFactory.getScheduler();
-    }
-
     /**
      * 添加一个定时任务
      */

src/main/java/com/berry/oss/quartz/dynamic/WormCheckJob.java

@@ -33,6 +33,7 @@ public class WormCheckJob implements Job {
 
     private static final Logger logger = LoggerFactory.getLogger(WormCheckJob.class);
 
+    @Autowired
     private IWormStrategyDaoService wormStrategyDaoService;
 
     @Override
@@ -51,7 +52,7 @@ public void execute(JobExecutionContext context) throws JobExecutionException {
             return;
         }
         wormStrategy.setWormState(CommonConstant.WormState.Expired.name());
-        wormStrategyDaoService.save(wormStrategy);
+        wormStrategyDaoService.updateById(wormStrategy);
         logger.info("策略：【{}】使失效成功", jobName);
     }
 }

src/main/java/com/berry/oss/service/impl/WormStrategyServiceImpl.java

@@ -75,7 +75,7 @@ public WormStrategy initWormStrategy(String bucket, Integer days) {
         wormStrategy.setWormState(CommonConstant.WormState.InProgress.name());
         wormStrategy.setCreateTime(new Date());
         // 策略生效开始时间（在此之前 状态未提交锁定(Locked)，策略自动失效：Expired）
-        Date activeTime = DateTime.now().plusMinutes(1).toDate();
+        Date activeTime = DateTime.now().plusHours(24).toDate();
         wormStrategy.setActiveTime(activeTime);
         wormStrategyDaoService.save(wormStrategy);
         // 启动一个定时任务， 在 activeTime 检查状态， 如果不为 Locked ，则设置为 Expired