切换JobExecutionHistory api到后台

Author: 令狐兄

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

@@ -0,0 +1,41 @@
+package org.linghuxiong.spring.batch.admin.controller;
+
+import com.alibaba.fastjson.JSONObject;
+import org.linghuxiong.spring.batch.admin.model.JobExecutionHistoryEntity;
+import org.linghuxiong.spring.batch.admin.service.JobExecutionHistoryService;
+import org.linghuxiong.spring.batch.admin.service.QuartzService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.web.bind.annotation.*;
+
+/**
+ * @author linghuxiong
+ * @date 2019/11/8 1:48 下午
+ */
+@RestController
+@RequestMapping("/jobHistory")
+public class JobExecutionHistoryController {
+
+ @Autowired
+ JobExecutionHistoryService jobExecutionHistoryService;
+
+ @GetMapping("/load")
+ public Page<JobExecutionHistoryEntity> loadQuartzPageable(@RequestParam(required = false) Integer currentPage, @RequestParam(required = false) Integer pageSize,
+ @RequestParam(required = false) Integer status,
+ @RequestParam(required = false) String userName,
+ @RequestParam(required = false) String jobName,
+ @RequestParam(required = false) Long runId) {
+ if(currentPage == null){
+ currentPage = Integer.valueOf(1);
+ }
+
+ if(pageSize == null){
+ pageSize = Integer.valueOf(10);
+ }
+
+ Pageable pageable = PageRequest.of(currentPage-1, pageSize);
+ return jobExecutionHistoryService.loadJobHistoryPageable(pageable,jobName,userName,status,runId);
+ }
+}

src/main/java/org/linghuxiong/spring/batch/admin/dao/JobExecutionHistoryDao.java

@@ -0,0 +1,25 @@
+package org.linghuxiong.spring.batch.admin.dao;
+
+import org.linghuxiong.spring.batch.admin.model.JobEntity;
+import org.linghuxiong.spring.batch.admin.model.JobExecutionHistoryEntity;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.domain.Specification;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+/**
+ * @author linghuxiong
+ * @date 2019/11/8 4:34 下午
+ */
+@Repository
+public interface JobExecutionHistoryDao extends JpaRepository<JobExecutionHistoryEntity,Long> {
+
+ /**
+ *
+ * @param queryCondition
+ * @param pageable
+ * @return
+ */
+ Page<JobExecutionHistoryEntity> findAll(Specification<JobExecutionHistoryEntity> queryCondition, Pageable pageable);
+}

src/main/java/org/linghuxiong/spring/batch/admin/model/JobExecutionHistoryEntity.java

@@ -0,0 +1,52 @@
+package org.linghuxiong.spring.batch.admin.model;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.util.Date;
+
+/**
+ * @author linghuxiong
+ * @date 2019/11/13 10:31 下午
+ */
+@Data
+@Table(name = "T_JOB_EXECUTION_HISTORY")
+@Entity
+public class JobExecutionHistoryEntity {
+
+ @Id
+ @GeneratedValue(strategy = GenerationType.IDENTITY)
+ @Column(name = "ID")
+ private Long id;
+
+ @Column(name = "JOB_NAME")
+ private String jobName;
+
+ @Column(name = "RUN_ID")
+ private Long runId;
+
+ @Column(name = "EXIT_CODE")
+ private String exitCode;
+
+ @Column(name = "EXIT_MESSAGE")
+ private String exitMessage;
+
+ @Column(name = "STATUS")
+ private Integer status;
+
+ @Column(name = "USER_NAME")
+ private String userName;
+
+ @Column(name = "START_TIME")
+ private Date startAt;
+
+ @Column(name = "END_TIME")
+ private Date endAt;
+
+ @Column(name = "UPDATE_TIME")
+ private Date updatedAt;
+
+ @Column(name = "INSERT_TIME")
+ private Date createdAt;
+
+}

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

@@ -0,0 +1,14 @@
+package org.linghuxiong.spring.batch.admin.service;
+
+import org.linghuxiong.spring.batch.admin.model.JobExecutionHistoryEntity;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+
+/**
+ * @author linghuxiong
+ * @date 2019/11/13 10:46 下午
+ */
+public interface JobExecutionHistoryService {
+
+ Page<JobExecutionHistoryEntity> loadJobHistoryPageable(Pageable pageable, String jobName, String userName, Integer status, Long runId);
+}

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

@@ -0,0 +1,58 @@
+package org.linghuxiong.spring.batch.admin.service.impl;
+
+import org.linghuxiong.spring.batch.admin.dao.JobExecutionHistoryDao;
+import org.linghuxiong.spring.batch.admin.model.JobExecutionHistoryEntity;
+import org.linghuxiong.spring.batch.admin.model.TriggerEntity;
+import org.linghuxiong.spring.batch.admin.service.JobExecutionHistoryService;
+import org.springframework.batch.core.repository.dao.JobExecutionDao;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.domain.Specification;
+import org.springframework.stereotype.Service;
+
+import javax.persistence.criteria.CriteriaBuilder;
+import javax.persistence.criteria.CriteriaQuery;
+import javax.persistence.criteria.Predicate;
+import javax.persistence.criteria.Root;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author linghuxiong
+ * @date 2019/11/13 10:48 下午
+ */
+@Service
+public class JobExecutionHistoryServiceImpl implements JobExecutionHistoryService {
+
+ @Autowired
+ JobExecutionHistoryDao jobExecutionHistoryDao;
+
+ @Override
+ public Page<JobExecutionHistoryEntity> loadJobHistoryPageable(Pageable pageable, String jobName, String userName, Integer status, Long runId) {
+ Specification<JobExecutionHistoryEntity> queryCondition = new Specification<JobExecutionHistoryEntity>() {
+ @Override
+ public Predicate toPredicate(Root<JobExecutionHistoryEntity> root, CriteriaQuery<?> criteriaQuery, CriteriaBuilder criteriaBuilder) {
+ List<Predicate> predicateList = new ArrayList<>();
+ if (jobName != null) {
+ predicateList.add(criteriaBuilder.like(criteriaBuilder.upper(root.get("jobName")), "%"+jobName.toUpperCase()+"%"));
+ }
+
+ if (userName != null) {
+ predicateList.add(criteriaBuilder.like(criteriaBuilder.upper(root.get("userName")), "%"+userName.toUpperCase()+"%"));
+ }
+
+ if (status != null) {
+ predicateList.add(criteriaBuilder.equal(root.get("status"), status));
+ }
+
+ if (runId != null) {
+ predicateList.add(criteriaBuilder.equal(root.get("runId"), runId));
+ }
+
+ return criteriaBuilder.and(predicateList.toArray(new Predicate[predicateList.size()]));
+ }
+ };
+ return jobExecutionHistoryDao.findAll(queryCondition,pageable);
+ }
+}