From fd4cccef307739285b78862ec2ca3f950ee9aaab Mon Sep 17 00:00:00 2001
From: wangxianzhang <ZHANGYUGE6666>
Date: Tue, 25 Jan 2022 20:13:19 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=EF=BC=9A=201.=E5=B1=85?=
 =?UTF-8?q?=E6=B0=91=E4=BF=A1=E6=81=AF=E5=AF=BC=E5=85=A5=EF=BC=8C=E6=8E=92?=
 =?UTF-8?q?=E9=99=A4=E4=B8=8D=E5=BF=85=E8=A6=81=E7=9A=84=E5=88=97=E7=9A=84?=
 =?UTF-8?q?=E6=A0=A1=E9=AA=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/IcResiUserImportServiceImpl.java     | 39 +++++++++++++++----
 1 file changed, 31 insertions(+), 8 deletions(-)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserImportServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserImportServiceImpl.java
index 0b554c980e..c44cce4b73 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserImportServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserImportServiceImpl.java
@@ -85,6 +85,13 @@ public class IcResiUserImportServiceImpl implements IcResiUserImportService, Res
     @Autowired
     private IcResiUserDao icResiUserDao;
 
+    /**
+     * 字表中不需要的列
+     */
+    private List<String> subTableNeedlessColumns = Arrays.asList("GRID_ID", "VILLAGE_ID", "BUILD_ID", "UNIT_ID", "HOME_ID",
+            "IS_BDHJ", "NAME", "MOBILE", "GENDER", "ID_CARD",
+            "BIRTHDAY", "CONTACTS", "CONTACTS_MOBILE");
+
     /**
      * @description 列信息封装
      *
@@ -353,7 +360,7 @@ public class IcResiUserImportServiceImpl implements IcResiUserImportService, Res
 
             LinkedHashMap<String, String> columnAndValues = new LinkedHashMap<>();
             try {
-                convertColumnWrappers2Map4Persist(headerColumnWrapper, row, currUserAgencyId, checkBoxOptionColumnIdxAndLabel, columnAndValues);
+                convertColumnWrappers2Map4Persist(headerColumnWrapper, row, currUserAgencyId, checkBoxOptionColumnIdxAndLabel, columnAndValues, true);
 
                 columnAndValues.put("IS_ENSURE_HOUSE", "0");
                 columnAndValues.put("IS_OLD_PEOPLE", "0");
@@ -434,12 +441,16 @@ public class IcResiUserImportServiceImpl implements IcResiUserImportService, Res
         for (Map<Integer, String> row : dataRows) {
 
             try {
-                convertColumnWrappers2Map4Persist(headerColumnWrapper, row, currUserAgencyId, checkBoxOptionColumnIdxAndLabel, columnAndValues);
+                convertColumnWrappers2Map4Persist(headerColumnWrapper, row, currUserAgencyId, checkBoxOptionColumnIdxAndLabel, columnAndValues, false);
 
                 // 检验身份证号
                 String idCard = columnAndValues.get("ID_CARD");
                 if (StringUtils.isBlank(idCard)) {
-                    throw new RenException(EpmetErrorCode.IDCARDNO_ERROR.getCode(), String.format("用户【%s】身份证号未填写或格式错误", columnAndValues.get("NAME")));
+                    String resiName = columnAndValues.get("NAME");
+                    if (resiName == null) {
+                        resiName = "";
+                    }
+                    throw new RenException(EpmetErrorCode.IDCARDNO_ERROR.getCode(), String.format("用户【%s】身份证号未填写或格式错误", resiName));
                 }
 
                 // 检查用户是否存在
@@ -538,10 +549,11 @@ public class IcResiUserImportServiceImpl implements IcResiUserImportService, Res
      * @param currUserAgencyId 当前用户所属机构ID
      * @param checkBoxOptionColumnIdxAndLabel 复选框options列表。key:列号，value：复选框中文
      * @param target 要将数据放到哪个对象中
+     * @param isPrimaryTable 是否是主表
      */
     private void convertColumnWrappers2Map4Persist(Map<String, ColumnWrapper> headerColumnWrapper, Map<Integer, String> row,
                                                    String currUserAgencyId, Map<Integer, String> checkBoxOptionColumnIdxAndLabel,
-                                                   LinkedHashMap<String, String> target) {
+                                                   LinkedHashMap<String, String> target, boolean isPrimaryTable) {
 
         boolean interupt = false;
 
@@ -588,10 +600,21 @@ public class IcResiUserImportServiceImpl implements IcResiUserImportService, Res
                 columnWrapper.setColValue(checkBoxColValue);
             }
 
-            // requiredColumns中的值为必填项
-            if (columnWrapper.getRequired() == 1 && StringUtils.isBlank(columnWrapper.colValue)) {
-                interupt = true;
-                errorColumnNames.add(columnWrapper.combinedLabel);
+            // requiredColumns中的值不在排除字段中 && 是必填 && 未填写
+            if (isPrimaryTable) {
+                // 主表没有需要排除的列
+                if (columnWrapper.getRequired() == 1 && StringUtils.isBlank(columnWrapper.colValue)) {
+                    interupt = true;
+                    errorColumnNames.add(columnWrapper.combinedLabel);
+                }
+            } else {
+                // 从表需要排除掉一些不必要校验的列
+                if (!subTableNeedlessColumns.contains(columnWrapper.columnName)
+                        && columnWrapper.getRequired() == 1
+                        && StringUtils.isBlank(columnWrapper.colValue)) {
+                    interupt = true;
+                    errorColumnNames.add(columnWrapper.combinedLabel);
+                }
             }
 
             target.put(columnWrapper.columnName, columnWrapper.colValue);