update

distributed-print-task/src/main/java/com/qmth/distributed/print/task/enums/JobEnum.java

@@ -11,10 +11,6 @@ import java.util.Objects;
  */
 public enum JobEnum {
 
-    TEST_JOB("测试job"),
-
-    TEST_JOB_GROUP("测试job组"),
-
     TIMED_SYNC_SCHOOL_JOB("学校信息同步定时任务"),
 
     TIMED_TASK_JOB_GROUP("定时任务job组");

distributed-print-task/src/main/java/com/qmth/distributed/print/task/job/TestJob.java

@@ -1,26 +0,0 @@
-package com.qmth.distributed.print.task.job;
-
-import com.qmth.distributed.print.task.job.service.JobService;
-import org.quartz.JobExecutionContext;
-import org.quartz.JobExecutionException;
-import org.springframework.scheduling.quartz.QuartzJobBean;
-
-import javax.annotation.Resource;
-
-/**
- * @Description: 测试job
- * @Param:
- * @return:
- * @Author: wangliang
- * @Date: 2021/3/31
- */
-public class TestJob extends QuartzJobBean {
-
-    @Resource
-    JobService jobService;
-
-    @Override
-    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
-        jobService.testJob();
-    }
-}

distributed-print-task/src/main/java/com/qmth/distributed/print/task/job/service/JobService.java

@@ -11,8 +11,6 @@ import java.io.IOException;
 */ 
 public interface JobService {
 
-    public void testJob();
-
     /**
      * 同步学校信息
      */

distributed-print-task/src/main/java/com/qmth/distributed/print/task/job/service/impl/JobServiceImpl.java

@@ -1,8 +1,6 @@
 package com.qmth.distributed.print.task.job.service.impl;
 
-import com.qmth.distributed.print.business.service.CacheService;
 import com.qmth.distributed.print.business.service.OrgCenterDataDisposeService;
-import com.qmth.distributed.print.common.util.JacksonUtil;
 import com.qmth.distributed.print.task.job.service.JobService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -22,16 +20,9 @@ import java.io.IOException;
 public class JobServiceImpl implements JobService {
     private final static Logger log = LoggerFactory.getLogger(JobServiceImpl.class);
 
-    @Resource
-    CacheService cacheService;
     @Resource
     OrgCenterDataDisposeService orgCenterDataDisposeService;
 
-    @Override
-    public void testJob() {
-        log.info("testJob user info:{}", JacksonUtil.parseJson(cacheService.userCache(1L)));
-    }
-
     @Override
     public void updateSchoolInfo() throws IOException {
         orgCenterDataDisposeService.updateSchoolInfo();

distributed-print/src/main/java/com/qmth/distributed/print/start/StartRunning.java

@@ -3,7 +3,6 @@ package com.qmth.distributed.print.start;
 import com.qmth.distributed.print.business.service.OrgCenterDataDisposeService;
 import com.qmth.distributed.print.common.contant.SystemConstant;
 import com.qmth.distributed.print.task.enums.JobEnum;
-import com.qmth.distributed.print.task.job.TestJob;
 import com.qmth.distributed.print.task.job.TimedSyncSchoolJob;
 import com.qmth.distributed.print.task.service.QuartzService;
 import org.slf4j.Logger;
@@ -38,23 +37,14 @@ public class StartRunning implements CommandLineRunner {
         SystemConstant.initTempFiles();
         orgCenterDataDisposeService.updateSchoolInfo();
 
-//        log.info("增加test job start");
-//        Map testJobMap = new HashMap();
-//        testJobMap.computeIfAbsent("name", v -> TestJob.class.getName());
-//        quartzService.deleteJob(JobEnum.TEST_JOB.name(), JobEnum.TEST_JOB_GROUP.name());
-//        quartzService.addJob(TestJob.class, JobEnum.TEST_JOB.name(), JobEnum.TEST_JOB_GROUP.name(), "0/10 * * * * ?", testJobMap);
-//        log.info("增加test job end");
-
         log.info("增加学校信息同步定时任务 start");
         Map schoolJobMap = new HashMap();
         schoolJobMap.computeIfAbsent("name", v -> TimedSyncSchoolJob.class.getName());
         quartzService.deleteJob(JobEnum.TIMED_SYNC_SCHOOL_JOB.name(), JobEnum.TIMED_TASK_JOB_GROUP.name());
         // 每天0点定时任务
-        String jobTime = "0 0 0 * * ?";
-        quartzService.addJob(TimedSyncSchoolJob.class, JobEnum.TIMED_SYNC_SCHOOL_JOB.name(), JobEnum.TIMED_TASK_JOB_GROUP.name(), jobTime, schoolJobMap);
+        quartzService.addJob(TimedSyncSchoolJob.class, JobEnum.TIMED_SYNC_SCHOOL_JOB.name(), JobEnum.TIMED_TASK_JOB_GROUP.name(), "0 0 0 * * ?", schoolJobMap);
         log.info("增加学校信息同步定时任务 end");
 
-
         log.info("服务器启动时执行 end");
     }
 }