From 2f2287033785bbb1f4e6e9959285bef454346f0f Mon Sep 17 00:00:00 2001
From: wxz <wangxianzhang1992@163.com>
Date: Fri, 7 Apr 2023 10:00:41 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E5=86=99=E6=B3=95=E8=B0=83?=
 =?UTF-8?q?=E6=95=B4=EF=BC=8C=E4=B8=8D=E9=87=8D=E8=A6=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/IcResiUserServiceImpl.java   | 29 +++++++------------
 1 file changed, 10 insertions(+), 19 deletions(-)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java
index f5416c714b..d8e5ea3c17 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java
@@ -181,6 +181,9 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
     @Autowired
     private IcVaccineRelationDao icVaccineRelationDao;
 
+    /**
+     * 组织字段，目前用于居民信息动态查询接口。将此条件从conditions中移除，单独生成固定的sql片段
+     */
     public static final List<String> ORG_FIELDS = Arrays.asList("AGENCY_IDS", "GRID_IDS", "AGENCY_ID", "GRID_ID");
 
     private QueryWrapper<IcResiUserEntity> getWrapper(Map<String, Object> params) {
@@ -928,7 +931,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
         Set<String> queryAgencyIdList = new HashSet<>();
         Set<String> queryGridIdList = new HashSet<>();
 
-        // 将以下几列单独提出来，组合起来，放入列表
+        // 将以下几列单独提出来，组合起来，放入集合，自动去重
         formDTO.getConditions().stream().forEach(c -> {
             if (IcResiUserConstant.IC_RESI_USER.equals(c.getTableName()) && CollectionUtils.isNotEmpty(c.getColumnValue())
                     && StringUtils.isNotBlank(c.getColumnValue().get(NumConstant.ZERO))) {
@@ -936,9 +939,9 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
                     queryAgencyIdList.addAll(c.getColumnValue());
                 } else if ("GRID_IDS".equals(c.getColumnName())) {
                     queryGridIdList.addAll(c.getColumnValue());
-                } else if ("AGENCY_ID".equals(c.getColumnName()) && ! queryAgencyIdList.contains(c.getColumnValue())) {
+                } else if ("AGENCY_ID".equals(c.getColumnName())) {
                     queryAgencyIdList.addAll(c.getColumnValue());
-                } else if ("GRID_ID".equals(c.getColumnName()) && ! queryGridIdList.contains(c.getColumnValue())) {
+                } else if ("GRID_ID".equals(c.getColumnName())) {
                     queryGridIdList.addAll(c.getColumnValue());
                 }
             }
@@ -955,13 +958,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
             CustomerStaffInfoCacheResult staffInfoCacheResult = CustomerStaffRedis.getStaffInfo(formDTO.getCustomerId(), formDTO.getStaffId());
             agencyIds = Arrays.asList(staffInfoCacheResult.getAgencyId());
 
-            String op;
-            if (StringUtils.isNotBlank(staffInfoCacheResult.getAgencyPIds()) && !NumConstant.ZERO_STR.equals(staffInfoCacheResult.getAgencyPIds())) {
-                op = staffInfoCacheResult.getAgencyPIds().concat(":").concat(staffInfoCacheResult.getAgencyId());
-            } else {
-                op = staffInfoCacheResult.getAgencyId();
-            }
-
+            String op = PidUtils.convertPid2OrgIdPath(staffInfoCacheResult.getAgencyId(), staffInfoCacheResult.getAgencyPIds());
             staffOrgPaths = Arrays.asList(op);
         } else {
             // 将组织id列表，转化为组织orgIdPath列表
@@ -3365,9 +3362,9 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
                     queryAgencyIdList.addAll(c.getColumnValue());
                 } else if ("GRID_IDS".equals(c.getColumnName())) {
                     queryGridIdList.addAll(c.getColumnValue());
-                } else if ("AGENCY_ID".equals(c.getColumnName()) && ! queryAgencyIdList.contains(c.getColumnValue())) {
+                } else if ("AGENCY_ID".equals(c.getColumnName())) {
                     queryAgencyIdList.addAll(c.getColumnValue());
-                } else if ("GRID_ID".equals(c.getColumnName()) && ! queryGridIdList.contains(c.getColumnValue())) {
+                } else if ("GRID_ID".equals(c.getColumnName())) {
                     queryGridIdList.addAll(c.getColumnValue());
                 }
             }
@@ -3384,13 +3381,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
             CustomerStaffInfoCacheResult staffInfoCacheResult = CustomerStaffRedis.getStaffInfo(formDTO.getCustomerId(), formDTO.getStaffId());
             agencyIds = Arrays.asList(staffInfoCacheResult.getAgencyId());
 
-            String op;
-            if (StringUtils.isNotBlank(staffInfoCacheResult.getAgencyPIds()) && !NumConstant.ZERO_STR.equals(staffInfoCacheResult.getAgencyPIds())) {
-                op = staffInfoCacheResult.getAgencyPIds().concat(":").concat(staffInfoCacheResult.getAgencyId());
-            } else {
-                op = staffInfoCacheResult.getAgencyId();
-            }
-
+            String op = PidUtils.convertPid2OrgIdPath(staffInfoCacheResult.getAgencyId(), staffInfoCacheResult.getAgencyPIds());
             staffOrgPaths = Arrays.asList(op);
         } else {
             // 将组织id列表，转化为组织orgIdPath列表