package com.pollex.pam.service; import com.pollex.pam.domain.Consultant; import com.pollex.pam.service.dto.FastQueryConsultantParam; import com.pollex.pam.service.dto.StrictQueryConsultantParam; import org.apache.commons.lang3.StringUtils; import org.springframework.data.jpa.domain.Specification; import javax.persistence.criteria.*; import java.util.*; public class ConsultantQuerySpec { private ConsultantQuerySpec() { } public static Specification getFastQuerySpec(FastQueryConsultantParam param) { return new Specification() { @SuppressWarnings("FieldNameHidesFieldInSuperclass") private static final long serialVersionUID = 6644524130903161741L; @Override public Predicate toPredicate(Root root, CriteriaQuery query, CriteriaBuilder criteriaBuilder) { Set set = new HashSet<>(); param.getCommunicationStyles().forEach((communicationStyle) -> { set.add(criteriaBuilder.like(root.get("communicationStyle"), "%" + communicationStyle + "%")); }); if(Objects.nonNull(param.getGender())) { set.add(criteriaBuilder.equal(root.get("gender"), param.getGender())); } if(Objects.nonNull(param.getAvgScore()) && param.getAvgScore().intValue() != 0) { set.add(criteriaBuilder.equal(root.get("avgScore"), param.getAvgScore())); } Predicate[] predicates = new Predicate[set.size()]; predicates = set.toArray(predicates); return criteriaBuilder.and(predicates); } }; } public static Specification getStrictQuerySpec(StrictQueryConsultantParam param) { return new Specification() { @SuppressWarnings("FieldNameHidesFieldInSuperclass") private static final long serialVersionUID = 664452413090316174L; @Override public Predicate toPredicate(Root root, CriteriaQuery query, CriteriaBuilder criteriaBuilder) { Set set = new HashSet<>(); if(Objects.nonNull(param.getGender())) { set.add(criteriaBuilder.equal(root.get("gender"), param.getGender())); } if(Objects.nonNull(param.getAvgScore()) && param.getAvgScore().intValue() != 0) { set.add(criteriaBuilder.equal(root.get("avgScore"), param.getAvgScore())); } if(StringUtils.isNotEmpty(param.getArea())) { Predicate predicate1 = criteriaBuilder.like(root.get("serveArea"), "%" + param.getArea() + "%"); Predicate predicate2 = criteriaBuilder.like(root.get("serveArea"), "%全台%"); Predicate finalPredicate = criteriaBuilder.or(predicate1, predicate2); set.add(finalPredicate); } List allRequirements = Objects.nonNull(param.getRequirements()) ? param.getRequirements() : new ArrayList<>(); if(StringUtils.isNotEmpty(param.getOtherPopularTags())) { allRequirements.add(param.getOtherRequirement()); } allRequirements.forEach(requirement -> set.add(criteriaBuilder.like(root.get("expertise"), "%" + requirement + "%"))); List allPopularTags = Objects.nonNull(param.getPopularTags()) ? param.getPopularTags() : new ArrayList<>(); if(StringUtils.isNotEmpty(param.getOtherPopularTags())) { allPopularTags.add(param.getOtherPopularTags()); } allPopularTags.forEach(popularTag -> set.add(criteriaBuilder.like(root.get("concept"), "%" + popularTag + "%"))); Predicate[] predicates = new Predicate[set.size()]; predicates = set.toArray(predicates); return criteriaBuilder.and(predicates); } }; } }