BaseController.java 8.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170
  1. package com.izouma.awesomeAdmin.web;
  2. import com.izouma.awesomeAdmin.annotations.Searchable;
  3. import com.izouma.awesomeAdmin.dto.PageQuery;
  4. import com.izouma.awesomeAdmin.utils.DateTimeUtils;
  5. import lombok.extern.slf4j.Slf4j;
  6. import org.apache.commons.lang3.StringUtils;
  7. import org.springframework.data.domain.PageRequest;
  8. import org.springframework.data.domain.Sort;
  9. import org.springframework.data.jpa.domain.Specification;
  10. import javax.annotation.Nonnull;
  11. import javax.persistence.criteria.Predicate;
  12. import java.lang.reflect.Field;
  13. import java.time.LocalDate;
  14. import java.time.LocalDateTime;
  15. import java.util.ArrayList;
  16. import java.util.Collection;
  17. import java.util.List;
  18. import java.util.regex.Pattern;
  19. @SuppressWarnings("ALL")
  20. @Slf4j
  21. public class BaseController {
  22. public PageRequest toPageRequest(PageQuery pageQuery) {
  23. PageRequest pageRequest;
  24. if (StringUtils.isNotEmpty(pageQuery.getSort())) {
  25. List<Sort.Order> orders = new ArrayList<>();
  26. for (String sortStr : pageQuery.getSort().split(";")) {
  27. String direction = "asc";
  28. String prop = sortStr;
  29. if (sortStr.contains(",asc") || sortStr.contains(",desc")) {
  30. prop = sortStr.split(",")[0];
  31. direction = sortStr.split(",")[1];
  32. }
  33. orders.add("asc".equals(direction) ? Sort.Order.asc(prop) : Sort.Order.desc(prop));
  34. }
  35. pageRequest = PageRequest.of(pageQuery.getPage(), pageQuery.getSize(), Sort.by(orders));
  36. } else {
  37. pageRequest = PageRequest.of(pageQuery.getPage(), pageQuery.getSize());
  38. }
  39. return pageRequest;
  40. }
  41. public <T> Specification<T> toSpecification(PageQuery pageQuery, Class<?> queryClass) {
  42. return (Specification<T>) (root, criteriaQuery, criteriaBuilder) -> {
  43. List<Predicate> and = new ArrayList<>();
  44. pageQuery.getQuery().forEach((property, value) -> {
  45. if (value == null) {
  46. return;
  47. }
  48. if (String.class.equals(value.getClass())) {
  49. if (StringUtils.isEmpty((String) value)) {
  50. return;
  51. }
  52. }
  53. Field field = getDeclaredField(queryClass, property);
  54. if (field == null) return;
  55. Class fieldType = field.getType();
  56. if (Enum.class.isAssignableFrom(fieldType)) {
  57. if (value instanceof Collection) {
  58. if (!((Collection) value).isEmpty()) {
  59. List list = new ArrayList();
  60. for (Object o : ((Collection) value)) {
  61. list.add(Enum.valueOf(fieldType, String.valueOf(o)));
  62. }
  63. and.add(root.get(property).in(list));
  64. }
  65. } else if (value instanceof String && StringUtils.isNotEmpty((String) value)) {
  66. if (((String) value).contains(",")) {
  67. String[] arr = ((String) value).split(",");
  68. List list = new ArrayList();
  69. for (String s : arr) {
  70. list.add(Enum.valueOf(fieldType, s));
  71. }
  72. and.add(root.get(property).in(list));
  73. } else {
  74. and.add(criteriaBuilder.and(criteriaBuilder
  75. .equal(root.get(property), Enum.valueOf(fieldType, String.valueOf(value)))));
  76. }
  77. }
  78. } else if (LocalDateTime.class == fieldType) {
  79. if (value instanceof List) {
  80. List list = (List) value;
  81. if (list.size() == 1) {
  82. LocalDateTime start = DateTimeUtils
  83. .toLocalDateTime((String) list.get(0), "yyyy-MM-dd HH:mm:ss");
  84. and.add(criteriaBuilder.greaterThanOrEqualTo(root.get(property), start));
  85. } else if (list.size() == 2) {
  86. LocalDateTime end = DateTimeUtils
  87. .toLocalDateTime((String) list.get(1), "yyyy-MM-dd HH:mm:ss");
  88. and.add(criteriaBuilder.lessThanOrEqualTo(root.get(property), end));
  89. }
  90. } else if (value instanceof String && Pattern
  91. .matches("^\\d{4}-\\d{2}-\\d{2} \\d{2}:\\d{2}:\\d{2},\\d{4}-\\d{2}-\\d{2} \\d{2}:\\d{2}:\\d{2}$", (String) value)) {
  92. String[] arr = ((String) value).split(",");
  93. LocalDateTime start = DateTimeUtils.toLocalDateTime(arr[0], "yyyy-MM-dd HH:mm:ss");
  94. and.add(criteriaBuilder.greaterThanOrEqualTo(root.get(property), start));
  95. LocalDateTime end = DateTimeUtils.toLocalDateTime(arr[1], "yyyy-MM-dd HH:mm:ss");
  96. and.add(criteriaBuilder.lessThanOrEqualTo(root.get(property), end));
  97. } else {
  98. and.add(criteriaBuilder.and(criteriaBuilder.equal(root.get(property), DateTimeUtils
  99. .toLocalDateTime((String) value, "yyyy-MM-dd HH:mm:ss"))));
  100. }
  101. } else if (LocalDate.class == fieldType) {
  102. if (value instanceof List) {
  103. List list = (List) value;
  104. if (list.size() == 1) {
  105. LocalDate start = DateTimeUtils
  106. .toLocalDate((String) list.get(0), "yyyy-MM-dd");
  107. and.add(criteriaBuilder.greaterThanOrEqualTo(root.get(property), start));
  108. } else if (list.size() == 2) {
  109. LocalDate end = DateTimeUtils
  110. .toLocalDate((String) list.get(1), "yyyy-MM-dd");
  111. and.add(criteriaBuilder.lessThanOrEqualTo(root.get(property), end));
  112. }
  113. } else if (value instanceof String && Pattern
  114. .matches("^\\d{4}-\\d{2}-\\d{2},\\d{4}-\\d{2}-\\d{2}$", (String) value)) {
  115. String[] arr = ((String) value).split(",");
  116. LocalDate start = DateTimeUtils.toLocalDate(arr[0], "yyyy-MM-dd");
  117. and.add(criteriaBuilder.greaterThanOrEqualTo(root.get(property), start));
  118. LocalDate end = DateTimeUtils.toLocalDate(arr[1], "yyyy-MM-dd");
  119. and.add(criteriaBuilder.lessThanOrEqualTo(root.get(property), end));
  120. } else {
  121. and.add(criteriaBuilder.and(criteriaBuilder.equal(root.get(property), DateTimeUtils
  122. .toLocalDateTime((String) value, "yyyy-MM-dd"))));
  123. }
  124. } else {
  125. and.add(criteriaBuilder.and(criteriaBuilder.equal(root.get(property), value)));
  126. }
  127. });
  128. if (StringUtils.isNotEmpty(pageQuery.getSearch())) {
  129. Field[] fields = queryClass.getDeclaredFields();
  130. List<Predicate> or = new ArrayList<>();
  131. try {
  132. if (StringUtils.isNumeric(pageQuery.getSearch())) {
  133. or.add(criteriaBuilder.equal(root.get("id"), Long.parseLong(pageQuery.getSearch())));
  134. }
  135. } catch (Exception ignored) {
  136. }
  137. for (Field field : fields) {
  138. Searchable annotation = field.getAnnotation(Searchable.class);
  139. if (annotation == null) {
  140. continue;
  141. }
  142. if (!annotation.value()) {
  143. continue;
  144. }
  145. or.add(criteriaBuilder.like(root.get(field.getName()), "%" + pageQuery.getSearch() + "%"));
  146. }
  147. and.add(criteriaBuilder.or(or.toArray(new Predicate[0])));
  148. }
  149. return criteriaBuilder.and(and.toArray(new Predicate[0]));
  150. };
  151. }
  152. private Field getDeclaredField(Class<?> clazz, String property) {
  153. String className = clazz.getName();
  154. while (clazz != null && clazz != Object.class) {
  155. try {
  156. return clazz.getDeclaredField(property);
  157. } catch (NoSuchFieldException ignored) {
  158. }
  159. clazz = clazz.getSuperclass();
  160. }
  161. log.error("no such field [{}] in class [{}]", property, className);
  162. return null;
  163. }
  164. }