From 4259f9299a3bf734b7a867b27667a3906b37d068 Mon Sep 17 00:00:00 2001
From: wangxianzhang <ZHANGYUGE6666>
Date: Thu, 7 Apr 2022 22:37:36 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=EF=BC=9A=E6=A0=B8=E9=85=B8?=
 =?UTF-8?q?=E6=A3=80=E6=B5=8B&=E7=96=AB=E8=8B=97=E6=8E=A5=E7=A7=8D?=
 =?UTF-8?q?=EF=BC=8C=E5=BB=BA=E7=AB=8B=E5=85=B3=E7=B3=BB=E7=9A=84=E9=80=BB?=
 =?UTF-8?q?=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../epmet/service/impl/IcNatServiceImpl.java    | 13 +++++++------
 .../service/impl/IcVaccineServiceImpl.java      | 17 +++++++++--------
 2 files changed, 16 insertions(+), 14 deletions(-)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcNatServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcNatServiceImpl.java
index a7ef88d5ec..b6a82a1543 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcNatServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcNatServiceImpl.java
@@ -488,6 +488,9 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
         String natResult = e.getNatResult();
         String natAddress = e.getNatAddress();
 
+        // 居民信息
+        IcResiUserEntity resi = getResi(customerId, idCard, null);
+
         //1.先看客户下有没有这个人
         IcNatEntity resiNat = getResiNat(customerId, idCard, natTime);
         if (resiNat != null && !"import".equals(resiNat.getUserType())) {
@@ -547,7 +550,6 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
                 resiNat.setUpdatedBy(currentUserId);
                 resiNat.setUpdatedTime(new Date());
 
-                IcResiUserEntity resi = getResi(customerId, idCard, null);
                 resiNat.setIsResiUser(resi != null ? "1" : "0");
                 resiNat.setUserId(resi != null ? resi.getId() : "");
 
@@ -555,15 +557,14 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
             }
 
             // 还要创建关系。只有本辖区及下级居民，才建立关系
-            if (getResi(customerId, idCard, String.join(":", Arrays.asList(agencyPids, agencyId))) != null) {
-                createNatRelation(resiNat.getId(), listener.getCurrentAgencyId(), listener.getCurrentAgencyPids());
+            if (resi != null) {
+                createNatRelation(resiNat.getId(), resi.getAgencyId(), resi.getPids());
             }
 
             return;
         }
 
         // 执行新增操作
-        IcResiUserEntity resi = getResi(customerId, idCard, null);
         e.setIsResiUser(resi != null ? "1" : "0");
         e.setUserId(resi != null ? resi.getId() : "");
         e.setUserType("import");
@@ -571,8 +572,8 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
         baseDao.insert(e);
 
         // 还要创建关系。只有本辖区及下级居民，才建立关系
-        if (getResi(customerId, idCard, String.join(":", Arrays.asList(agencyPids, agencyId))) != null) {
-            createNatRelation(e.getId(), listener.getCurrentAgencyId(), listener.getCurrentAgencyPids());
+        if (resi != null) {
+            createNatRelation(e.getId(), resi.getAgencyId(), resi.getPids());
         }
     }
 
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcVaccineServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcVaccineServiceImpl.java
index c9ca6ee005..ec33974bf8 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcVaccineServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcVaccineServiceImpl.java
@@ -297,6 +297,9 @@ public class IcVaccineServiceImpl extends BaseServiceImpl<IcVaccineDao, IcVaccin
         Date inoculateTime = e.getInoculateTime();
         String inoculateAddress = e.getInoculateAddress();
 
+        // 居民信息
+        IcResiUserEntity resi = getResi(customerId, idCard, null);
+
         //1.先看客户下有没有这个人
         IcVaccineEntity resiVaccine = getResiVaccine(customerId, idCard, inoculateTime);
         if (resiVaccine != null && !"import".equals(resiVaccine.getUserType())) {
@@ -352,30 +355,28 @@ public class IcVaccineServiceImpl extends BaseServiceImpl<IcVaccineDao, IcVaccin
                 resiVaccine.setUpdatedBy(currentUserId);
                 resiVaccine.setUpdatedTime(new Date());
 
-                IcResiUserEntity resi = getResi(customerId, idCard, null);
                 resiVaccine.setIsResiUser(resi != null ? "1" : "0");
 
                 baseDao.updateById(resiVaccine);
             }
 
-            // 还要创建关系。只有本辖区及下级居民，才建立关系
-            if (getResi(customerId, idCard, String.join(":", Arrays.asList(agencyPids, agencyId))) != null) {
-                createVaccineRelation(resiVaccine.getId(), listener.getCurrentAgencyId(), listener.getCurrentAgencyPids());
+            // 建立关系
+            if (resi != null) {
+                createVaccineRelation(resiVaccine.getId(), resi.getAgencyId(), resi.getPids());
             }
 
             return;
         }
 
         // 执行新增操作
-        IcResiUserEntity resi = getResi(customerId, idCard, null);
         e.setIsResiUser(resi != null ? "1" : "0");
         e.setUserType("import");
 
         baseDao.insert(e);
 
-        // 还要创建关系。只有本辖区及下级居民，才建立关系
-        if (getResi(customerId, idCard, String.join(":", Arrays.asList(agencyPids, agencyId))) != null) {
-            createVaccineRelation(e.getId(), listener.getCurrentAgencyId(), listener.getCurrentAgencyPids());
+        // 只要是居民，就创建上关系
+        if (resi != null) {
+            createVaccineRelation(e.getId(), resi.getAgencyId(), resi.getPids());
         }
     }