From c6c33d25908e5b34dcdd774ca2b464ef02566123 Mon Sep 17 00:00:00 2001
From: wangxianzhang <ZHANGYUGE6666>
Date: Tue, 29 Mar 2022 18:32:50 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=EF=BC=9A=E6=A0=B8=E9=85=B8?=
 =?UTF-8?q?=E6=A3=80=E6=B5=8B=E4=BF=A1=E6=81=AFexcel=E5=AF=BC=E5=85=A5?=
 =?UTF-8?q?=EF=BC=8C=E5=A2=9E=E5=8A=A0=E5=8E=BB=E9=87=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/epmet/dao/IcNatDao.java  |  6 ++++++
 .../epmet/service/impl/IcNatServiceImpl.java   | 10 +++++++++-
 .../migration/V0.0.28__nat_add_uniquekey.sql   |  1 +
 .../src/main/resources/mapper/IcNatDao.xml     | 18 ++++++++++++++++++
 4 files changed, 34 insertions(+), 1 deletion(-)
 create mode 100644 epmet-user/epmet-user-server/src/main/resources/db/migration/V0.0.28__nat_add_uniquekey.sql

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcNatDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcNatDao.java
index 4ac7359f2e..97b365bb6f 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcNatDao.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcNatDao.java
@@ -36,4 +36,10 @@ public interface IcNatDao extends BaseDao<IcNatEntity> {
      * @Description 删除/取消同步操作--物理删除业务数据
      **/
     int delById(@Param("icNatId") String icNatId);
+
+    /**
+     * 插入或者更新
+     * @param e
+     */
+    void insertOrUpdate(IcNatEntity e);
 }
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 a7ef5cf7f4..dad0b433d5 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,6 +2,7 @@ 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.epmet.commons.mybatis.service.impl.BaseServiceImpl;
 import com.epmet.commons.tools.constant.AppClientConstant;
 import com.epmet.commons.tools.constant.NumConstant;
@@ -372,6 +373,13 @@ public class IcNatServiceImpl extends BaseServiceImpl<IcNatDao, IcNatEntity> imp
      * @param entities
      */
     public void batchPersist(List<IcNatEntity> entities) {
-        insertBatch(entities);
+        //insertBatch(entities);
+        String currentUserId = EpmetRequestHolder.getHeader(AppClientConstant.USER_ID);
+        entities.forEach(e -> {
+            String id = IdWorker.getIdStr(e);
+            e.setId(id);
+            e.setUpdatedBy(currentUserId);
+            baseDao.insertOrUpdate(e);
+        });
     }
 }
diff --git a/epmet-user/epmet-user-server/src/main/resources/db/migration/V0.0.28__nat_add_uniquekey.sql b/epmet-user/epmet-user-server/src/main/resources/db/migration/V0.0.28__nat_add_uniquekey.sql
new file mode 100644
index 0000000000..5cf24b3bec
--- /dev/null
+++ b/epmet-user/epmet-user-server/src/main/resources/db/migration/V0.0.28__nat_add_uniquekey.sql
@@ -0,0 +1 @@
+alter table ic_nat add index unq_nat(ID_CARD, NAT_TIME)
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/IcNatDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/IcNatDao.xml
index 1f325c92e3..28b4129229 100644
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/IcNatDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/IcNatDao.xml
@@ -67,4 +67,22 @@
         DELETE FROM ic_nat WHERE id = #{icNatId}
     </delete>
 
+    <insert id="insertOrUpdate">
+        INSERT INTO epmet_user.ic_nat
+        (ID, CUSTOMER_ID, AGENCY_ID, PIDS, USER_ID,
+         USER_TYPE, NAME, MOBILE, ID_CARD, NAT_TIME, NAT_RESULT, NAT_ADDRESS, FILE_NAME, ATTACHMENT_TYPE, ATTACHMENT_URL,
+         DEL_FLAG, REVISION, CREATED_BY, CREATED_TIME, UPDATED_BY, UPDATED_TIME)
+        VALUES (#{id}, #{customerId}, #{agencyId}, #{pids}, #{userId},
+                #{userType}, #{name}, #{mobile}, #{idCard}, #{natTime},
+                #{natResult}, #{natAddress}, #{fileName}, #{attachmentType}, #{attachmentUrl},
+                #{delFlag}, #{revision}, #{createdBy}, #{createdTime}, #{updatedBy},
+                #{updatedTime})
+        ON DUPLICATE KEY update
+            NAME=#{name},
+            MOBILE=#{mobile},
+            NAT_ADDRESS=#{natAddress},
+            NAT_RESULT=#{natResult},
+            UPDATED_BY=#{updatedBy},
+            UPDATED_TIME=NOW()
+    </insert>
 </mapper>