From a5eec335b68c264697960fa71d5ca4b5b1d8eacc Mon Sep 17 00:00:00 2001
From: wangxianzhang <ZHANGYUGE6666>
Date: Sat, 2 Apr 2022 11:04:41 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=EF=BC=9A1.=E6=A0=B8=E9=85=B8?=
 =?UTF-8?q?=E6=A3=80=E6=B5=8B=E7=BB=93=E6=9E=9C=E5=A1=AB=E5=85=A5=E6=A0=B8?=
 =?UTF-8?q?=E9=85=B8=E6=A3=80=E6=B5=8B=E5=9C=B0=E5=9D=80=E5=AF=BC=E8=87=B4?=
 =?UTF-8?q?sql=E6=8A=A5=E9=94=99=E7=9A=84bug=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../excel/data/IcNatImportExcelData.java      |  3 ++-
 .../handler/IcNatExcelImportListener.java     |  5 ++++
 .../epmet/service/impl/IcNatServiceImpl.java  | 24 ++++++++++++-------
 3 files changed, 22 insertions(+), 10 deletions(-)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/excel/data/IcNatImportExcelData.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/excel/data/IcNatImportExcelData.java
index 266da5175a..385d02b171 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/excel/data/IcNatImportExcelData.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/excel/data/IcNatImportExcelData.java
@@ -2,8 +2,8 @@ package com.epmet.excel.data;
 
 import com.alibaba.excel.annotation.ExcelProperty;
 import com.alibaba.excel.annotation.write.style.ColumnWidth;
-import com.epmet.dto.form.AddIcNatFormDTO;
 import lombok.Data;
+import org.hibernate.validator.constraints.Length;
 
 import javax.validation.constraints.NotBlank;
 import javax.validation.constraints.NotNull;
@@ -25,6 +25,7 @@ public class IcNatImportExcelData {
 
     @NotBlank(message = "身份证号为必填项")
     @ExcelProperty("身份证号")
+    @Length(max = 18, message = "身份证号长度不正确，应小于18位")
     private String idCard;
 
     @NotNull(message = "检测时间为必填项")
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/excel/handler/IcNatExcelImportListener.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/excel/handler/IcNatExcelImportListener.java
index 854507d471..db24888b03 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/excel/handler/IcNatExcelImportListener.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/excel/handler/IcNatExcelImportListener.java
@@ -66,6 +66,11 @@ public class IcNatExcelImportListener implements ReadListener<IcNatImportExcelDa
             // 先校验数据
             ValidatorUtils.validateEntity(data);
 
+            data.setName(data.getName().trim());
+            data.setMobile(data.getMobile().trim());
+            data.setNatAddress(data.getNatAddress().trim());
+            data.setIdCard(data.getIdCard().trim());
+
             // 默认空，没有结果
             String natResult = "";
             String natResultZh = data.getNatResultZh();
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 e6281b9467..66feeb2bf1 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
@@ -2,12 +2,10 @@ package com.epmet.service.impl;
 
 import com.alibaba.excel.EasyExcel;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.toolkit.IdWorker;
 import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.constant.AppClientConstant;
 import com.epmet.commons.tools.constant.NumConstant;
-import com.epmet.commons.tools.constant.ServiceConstant;
 import com.epmet.commons.tools.dto.result.CustomerStaffInfoCacheResult;
 import com.epmet.commons.tools.exception.EpmetErrorCode;
 import com.epmet.commons.tools.exception.EpmetException;
@@ -38,6 +36,7 @@ import com.epmet.feign.EpmetUserOpenFeignClient;
 import com.epmet.feign.OssFeignClient;
 import com.epmet.service.IcNatService;
 import com.epmet.service.IcNoticeService;
+import com.epmet.service.UserService;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import lombok.extern.slf4j.Slf4j;
@@ -83,6 +82,8 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
     private IcNatRelationDao icNatRelationDao;
     @Autowired
     private IcResiUserDao icResiUserDao;
+    @Autowired
+    private UserService userService;
 
     /**
      * @Author sun
@@ -313,9 +314,7 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
             String app = EpmetRequestHolder.getHeader(AppClientConstant.APP);
             String client = EpmetRequestHolder.getHeader(AppClientConstant.CLIENT);
 
-            LoginUserDetailsFormDTO ludf = new LoginUserDetailsFormDTO(app, client, userId);
-            LoginUserDetailsResultDTO loginUserDetails = getResultDataOrThrowsException(epmetUserOpenFeignClient.getLoginUserDetails(ludf), ServiceConstant.EPMET_USER_SERVER,
-                    EpmetErrorCode.SERVER_ERROR.getCode(), "调用user出错", "");
+            LoginUserDetailsResultDTO loginUserDetails = userService.getLoginUserDetails(app, client, userId);
 
             String agencyId = loginUserDetails.getAgencyId();
 
@@ -513,7 +512,7 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
             // 检测地点和手机号先不提示，说需要提示再提示
             if (!natAddress.equals(resiNat.getNatAddress())) {
                 changedFieldNames.add("检测地点");
-                resiNat.setNatResult(natAddress);
+                resiNat.setNatAddress(natAddress);
                 needUpdate = true;
             }
 
@@ -537,6 +536,11 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
             if (needUpdate) {
                 resiNat.setUpdatedBy(currentUserId);
                 resiNat.setUpdatedTime(new Date());
+
+                IcResiUserEntity resi = getResi(customerId, idCard);
+                resiNat.setIsResiUser(resi != null ? "1" : "0");
+                resiNat.setUserId(resi != null ? resi.getId() : "");
+
                 baseDao.updateById(resiNat);
             }
 
@@ -547,7 +551,9 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
         }
 
         // 执行新增操作
-        e.setIsResiUser(isResi(customerId, idCard));
+        IcResiUserEntity resi = getResi(customerId, idCard);
+        e.setIsResiUser(resi != null ? "1" : "0");
+        e.setUserId(resi != null ? resi.getId() : "");
         e.setUserType("import");
 
         baseDao.insert(e);
@@ -564,11 +570,11 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
      * @param idCard
      * @return
      */
-    public String isResi(String customerId, String idCard) {
+    public IcResiUserEntity getResi(String customerId, String idCard) {
         LambdaQueryWrapper<IcResiUserEntity> query = new LambdaQueryWrapper();
         query.eq(IcResiUserEntity::getCustomerId, customerId);
         query.eq(IcResiUserEntity::getIdCard, idCard);
-        return icResiUserDao.selectCount(query) > 0 ? "1" : "0";
+        return icResiUserDao.selectOne(query);
     }
 
     /**