添加手动执行任务

Author: 令狐兄

src/main/java/org/linghuxiong/spring/batch/admin/controller/JobController.java

@@ -4,6 +4,11 @@
 import org.linghuxiong.spring.batch.admin.model.TriggerEntity;
 import org.linghuxiong.spring.batch.admin.service.JobService;
 import org.quartz.SchedulerException;
+import org.springframework.batch.core.JobParametersInvalidException;
+import org.springframework.batch.core.launch.NoSuchJobException;
+import org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;
+import org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException;
+import org.springframework.batch.core.repository.JobRestartException;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
@@ -58,4 +63,11 @@ public Page<JobEntity> loadTriggerPageable(@RequestParam(required = false) Integ
 
  }
 
+ @PostMapping("/launch")
+ public String launch(@RequestParam Long jobId) throws JobParametersInvalidException, JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException, NoSuchJobException {
+ jobService.launch(jobId);
+ return "success";
+ }
+
+
 }

src/main/java/org/linghuxiong/spring/batch/admin/service/JobService.java

@@ -3,6 +3,11 @@
 import org.linghuxiong.spring.batch.admin.model.JobEntity;
 import org.linghuxiong.spring.batch.admin.model.TriggerEntity;
 import org.quartz.SchedulerException;
+import org.springframework.batch.core.JobParametersInvalidException;
+import org.springframework.batch.core.launch.NoSuchJobException;
+import org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;
+import org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException;
+import org.springframework.batch.core.repository.JobRestartException;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 
@@ -16,4 +21,5 @@ public interface JobService {
  void delete(Long jobId);
  JobEntity toggleStatus(Long jobId,Integer status) throws SchedulerException;
  Page<JobEntity> loadJobPageable(Pageable pageable, String name,Integer type,Integer status,String triggerName,String springJobName);
+ void launch(Long jobId) throws NoSuchJobException, JobParametersInvalidException, JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException;
 }

src/main/java/org/linghuxiong/spring/batch/admin/service/impl/JobServiceImpl.java

@@ -6,6 +6,15 @@
 import org.quartz.JobKey;
 import org.quartz.Scheduler;
 import org.quartz.SchedulerException;
+import org.springframework.batch.core.JobParameters;
+import org.springframework.batch.core.JobParametersBuilder;
+import org.springframework.batch.core.JobParametersInvalidException;
+import org.springframework.batch.core.configuration.JobRegistry;
+import org.springframework.batch.core.launch.JobLauncher;
+import org.springframework.batch.core.launch.NoSuchJobException;
+import org.springframework.batch.core.repository.JobExecutionAlreadyRunningException;
+import org.springframework.batch.core.repository.JobInstanceAlreadyCompleteException;
+import org.springframework.batch.core.repository.JobRestartException;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
@@ -33,6 +42,12 @@ public class JobServiceImpl implements JobService {
  @Autowired
  private Scheduler scheduler ;
 
+ @Autowired
+ JobLauncher jobLauncher;
+
+ @Autowired
+ JobRegistry jobRegistry;
+
  @Override
  public Page<JobEntity> loadJobPageable(Pageable pageable, String name, Integer type, Integer status, String triggerName, String springJobName) {
  Specification<JobEntity> queryCondition = new Specification<JobEntity>() {
@@ -65,6 +80,12 @@ public Predicate toPredicate(Root<JobEntity> root, CriteriaQuery<?> criteriaQuer
  return jobDao.findAll(queryCondition, pageable);
  }
 
+ @Override
+ public void launch(Long jobId) throws NoSuchJobException, JobParametersInvalidException, JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException {
+ JobEntity jobEntity = jobDao.getOne(jobId);
+ jobLauncher.run(jobRegistry.getJob(jobEntity.getSpringJobName()),new JobParametersBuilder().addDate("#CURRENNCY",new Date()).toJobParameters());
+ }
+
  @Override
  public JobEntity save(JobEntity jobEntity) {
  jobEntity.setUpdatedAt(new Date());

src/main/resources/batch-data/2019072401.txt

@@ -1 +1 @@
-2019-07-25 16:33:52.708 INFO 11667 --- [ restartedMain] org.linghuxiong.batch.BatchApplication : Starting BatchApplication on ericdeMacBook-Pro.local with PID 11667 (/Users/eric/Documents/dev/linghuxiong/spring-boot-demo/batch/target/classes started by eric in /Users/eric/Documents/dev/linghuxiong/spring-boot-demo/batch)
+2019-07-25 16:33:52.708 INFO 11667 --- [ restartedMain] org.linghuxiong.batch.BatchApplication : Starting BatchApplication on