From aa0f9381d424b98e86845c6da21e2fd8640fe056 Mon Sep 17 00:00:00 2001
From: wayne <wayne8692wayne8692@gmail.com>
Date: 星期一, 21 二月 2022 18:32:45 +0800
Subject: [PATCH] [update] 若顧問狀態非啟用時,則搜尋及推薦會找不到該顧問

---
 pamapi/src/main/java/com/pollex/pam/service/ConsultantQuerySpec.java |   80 ++++++++++++++++++++++++++--------------
 1 files changed, 52 insertions(+), 28 deletions(-)

diff --git a/pamapi/src/main/java/com/pollex/pam/service/ConsultantQuerySpec.java b/pamapi/src/main/java/com/pollex/pam/service/ConsultantQuerySpec.java
index bfefa21..cc9d20d 100644
--- a/pamapi/src/main/java/com/pollex/pam/service/ConsultantQuerySpec.java
+++ b/pamapi/src/main/java/com/pollex/pam/service/ConsultantQuerySpec.java
@@ -1,16 +1,16 @@
 package com.pollex.pam.service;
 
 import com.pollex.pam.domain.Consultant;
+import com.pollex.pam.enums.ConsultantStatusEnum;
 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.CriteriaBuilder;
-import javax.persistence.criteria.CriteriaQuery;
-import javax.persistence.criteria.Predicate;
-import javax.persistence.criteria.Root;
-import java.util.HashSet;
-import java.util.Set;
+import javax.persistence.criteria.*;
+import java.util.*;
+
+import static com.pollex.pam.consts.SeniorityQueryConst.*;
 
 public class ConsultantQuerySpec {
     private ConsultantQuerySpec() {
@@ -25,35 +25,59 @@
             public Predicate toPredicate(Root<Consultant> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
                 Set<Predicate> set = new HashSet<>();
 
-                if(!StringUtils.isEmpty(param.getCommunicationStyle())) {
-                    set.add(criteriaBuilder.like(root.get("concept"), "%" + param.getCommunicationStyle()));
+                set.add(criteriaBuilder.equal(root.get("status"), ConsultantStatusEnum.AVAILABLE));
+
+                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()));
                 }
 
-                set.add(criteriaBuilder.equal(root.get("gender"), param.getGender()));
-                set.add(criteriaBuilder.between(root.get("avgScore"), param.getAvgScore().intValue() - 1, param.getAvgScore().intValue() + 1));
+                if(Objects.nonNull(param.getAvgScore()) && param.getAvgScore().intValue() != 0) {
+                    set.add(criteriaBuilder.greaterThanOrEqualTo(root.get("avgScore"), param.getAvgScore().intValue()));
+                }
+
+                if(StringUtils.isNotEmpty(param.getSeniority()) && !StringUtils.equals(UNLIMITED, param.getSeniority())) {
+                    if(YOUNG.equals(param.getSeniority())) {
+                        set.add(criteriaBuilder.lessThanOrEqualTo(root.get("seniorityYear"), 5));
+                    }
+                    else if(SENIOR.equals(param.getSeniority())) {
+                        set.add(criteriaBuilder.greaterThan(root.get("seniorityYear"), 5));
+                    }
+                }
 
                 Predicate[] predicates = new Predicate[set.size()];
                 predicates = set.toArray(predicates);
-                return criteriaBuilder.or(predicates);
+                return criteriaBuilder.and(predicates);
             }
         };
     }
 
-//    public static Specification<Consultant> getStrictQuerySpec(StrictQueryConsultantParam param) {
-//        return new Specification<Consultant>() {
-//            @Override
-//            public Predicate toPredicate(Root<Consultant> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
-//                Set<Predicate> set = new HashSet<>();
-//
-//                set.add(criteriaBuilder.equal(root.get("gender"), param.getGender()));
-//                set.add(criteriaBuilder.between(root.get("avgScore"), param.getAvgScore().intValue() - 1, param.getAvgScore().intValue() + 1));
-//                set.add(criteriaBuilder.like(root.get("serve_area"),"%"+param.getArea()+"%"));
-//                set.add(root.get("").in(param.getRequirements()))
-//
-//                Predicate[] predicates = new Predicate[set.size()];
-//                predicates = set.toArray(predicates);
-//                return criteriaBuilder.or(predicates);
-//            }
-//        };
-//    }
+    public static Specification<Consultant> getStrictQuerySpec(StrictQueryConsultantParam param) {
+        return new Specification<Consultant>() {
+            @SuppressWarnings("FieldNameHidesFieldInSuperclass")
+            private static final long serialVersionUID = 664452413090316174L;
+
+            @Override
+            public Predicate toPredicate(Root<Consultant> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
+                Set<Predicate> set = new HashSet<>();
+
+                set.add(criteriaBuilder.equal(root.get("status"), ConsultantStatusEnum.AVAILABLE));
+
+                if(Objects.nonNull(param.getGender())) {
+                    set.add(criteriaBuilder.equal(root.get("gender"), param.getGender()));
+                }
+
+                if(StringUtils.isNotEmpty(param.getArea())) {
+                    set.add(criteriaBuilder.like(root.get("serveArea"), "%" + param.getArea() + "%"));
+                }
+
+                Predicate[] predicates = new Predicate[set.size()];
+                predicates = set.toArray(predicates);
+                return criteriaBuilder.and(predicates);
+            }
+        };
+    }
 }

--
Gitblit v1.8.0