From 521801849f9412676d28302741e24966f52c3e7e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=92=B1=E6=B6=9B?= <15850646081@163.com>
Date: Sat, 8 Oct 2022 09:14:13 +0800
Subject: [PATCH] =?UTF-8?q?=E5=85=BC=E5=AE=B95.7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../TaxDeclarationDetailMapper.xml            |  2 +-
 .../impl/TaxDeclarationDetailServiceImpl.java | 11 +++++++--
 .../engine/salary/util/SalaryEntityUtil.java  | 24 +++++++++++++++++++
 3 files changed, 34 insertions(+), 3 deletions(-)

diff --git a/src/com/engine/salary/mapper/taxdeclaration/TaxDeclarationDetailMapper.xml b/src/com/engine/salary/mapper/taxdeclaration/TaxDeclarationDetailMapper.xml
index aad0c3ac8..46b92f419 100644
--- a/src/com/engine/salary/mapper/taxdeclaration/TaxDeclarationDetailMapper.xml
+++ b/src/com/engine/salary/mapper/taxdeclaration/TaxDeclarationDetailMapper.xml
@@ -39,7 +39,7 @@
     </resultMap>
 
     <select id="listPage4EmployeeId" resultMap="resultMap">
-        SELECT DISTINCT employee_type, employee_id
+        SELECT  employee_type, employee_id
         FROM hrsa_tax_declaration_detail t
         LEFT JOIN hrmresource e ON e.id = t.employee_id
         LEFT JOIN hrmdepartment d ON d.id = e.DEPARTMENTID
diff --git a/src/com/engine/salary/service/impl/TaxDeclarationDetailServiceImpl.java b/src/com/engine/salary/service/impl/TaxDeclarationDetailServiceImpl.java
index 4f1e9d4cb..7524ea9c3 100644
--- a/src/com/engine/salary/service/impl/TaxDeclarationDetailServiceImpl.java
+++ b/src/com/engine/salary/service/impl/TaxDeclarationDetailServiceImpl.java
@@ -85,9 +85,16 @@ public class TaxDeclarationDetailServiceImpl extends Service implements TaxDecla
         OrderRuleVO orderRule = getSalarySysConfService(user).orderRule();
         queryParam.setOrderRule(orderRule);
 
-        SalaryPageUtil.start(queryParam.getCurrent(), queryParam.getPageSize());
+//        SalaryPageUtil.start(queryParam.getCurrent(), queryParam.getPageSize());
         List<TaxDeclarationEmployeeDTO> taxDeclarationEmployeeDTOS = getTaxDeclarationDetailMapper().listPage4EmployeeId(queryParam);
-        return new PageInfo<>(taxDeclarationEmployeeDTOS, TaxDeclarationEmployeeDTO.class);
+        taxDeclarationEmployeeDTOS = taxDeclarationEmployeeDTOS.stream().filter(SalaryEntityUtil.distinctByKey(TaxDeclarationEmployeeDTO::getEmployeeId)).collect(Collectors.toList());
+
+        List<TaxDeclarationEmployeeDTO> list = SalaryPageUtil.subList(queryParam.getCurrent(), queryParam.getPageSize(), taxDeclarationEmployeeDTOS);
+        PageInfo<TaxDeclarationEmployeeDTO> pageInfo = new PageInfo<>(list, TaxDeclarationEmployeeDTO.class);
+        pageInfo.setPageNum(queryParam.getCurrent());
+        pageInfo.setPageSize(queryParam.getPageSize());
+        pageInfo.setTotal(taxDeclarationEmployeeDTOS.size());
+        return pageInfo;
     }
 
     @Override
diff --git a/src/com/engine/salary/util/SalaryEntityUtil.java b/src/com/engine/salary/util/SalaryEntityUtil.java
index 8329eff0d..6a38480f1 100644
--- a/src/com/engine/salary/util/SalaryEntityUtil.java
+++ b/src/com/engine/salary/util/SalaryEntityUtil.java
@@ -12,7 +12,9 @@ import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.text.DecimalFormat;
 import java.util.*;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.function.Function;
+import java.util.function.Predicate;
 import java.util.stream.Collector;
 import java.util.stream.Collectors;
 
@@ -152,6 +154,28 @@ public class SalaryEntityUtil {
                         Collectors.collectingAndThen(Collectors.toList(), e -> e.stream().map(valueMapper).collect(Collectors.toList()))));
     }
 
+    /**
+     * LinkedHashMap有序去重
+     * @param keyExtractor
+     * @param <T>
+     * @return
+     */
+    public static <T> Predicate<T> distinctByKey(Function<? super T, Object> keyExtractor) {
+        LinkedHashMap<Object, Boolean> map = new LinkedHashMap<>();
+        return t -> map.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;
+    }
+
+    /**
+     * ConcurrentHashMap无序去重
+     * @param keyExtractor
+     * @param <T>
+     * @return
+     */
+    public static <T> Predicate<T> distinctByKeyMap(Function<? super T, Object> keyExtractor) {
+        ConcurrentHashMap<Object, Boolean> map = new ConcurrentHashMap<>();
+        return t -> map.putIfAbsent(keyExtractor.apply(t), Boolean.TRUE) == null;
+    }
+
     public static <T> BigDecimal reduce(Collection<T> objs, Function<T, BigDecimal> function) {
         if (CollectionUtils.isEmpty(objs)) {
             return BigDecimal.ZERO;