From 998e5a0a4f8d899061105d5991091284ca627247 Mon Sep 17 00:00:00 2001
From: zxc <1272811460@qq.com>
Date: Thu, 3 Nov 2022 14:11:43 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/epmet/dao/IcDangerAreaDao.java       | 5 ++++-
 .../com/epmet/service/impl/IcDangerAreaServiceImpl.java    | 4 ++++
 .../src/main/resources/mapper/IcDangerAreaDao.xml          | 7 +++++++
 3 files changed, 15 insertions(+), 1 deletion(-)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcDangerAreaDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcDangerAreaDao.java
index 40e8775635..e009c7e52e 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcDangerAreaDao.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcDangerAreaDao.java
@@ -3,6 +3,7 @@ package com.epmet.dao;
 import com.epmet.commons.mybatis.dao.BaseDao;
 import com.epmet.entity.IcDangerAreaEntity;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * 疫情风险地区
@@ -12,5 +13,7 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface IcDangerAreaDao extends BaseDao<IcDangerAreaEntity> {
-	
+
+    Integer delAllDangerArea(@Param("customerId")String customerId);
+
 }
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcDangerAreaServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcDangerAreaServiceImpl.java
index ab3cd225a4..b330196a1b 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcDangerAreaServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcDangerAreaServiceImpl.java
@@ -178,6 +178,10 @@ public class IcDangerAreaServiceImpl extends BaseServiceImpl<IcDangerAreaDao, Ic
     @Override
     @Async
     public void execAsyncExcelImport(Path fileSavePath, String taskId, String customerId, String userId) {
+        Integer size;
+        do {
+            size = baseDao.delAllDangerArea(customerId);
+        }while (size == NumConstant.ONE_THOUSAND);
         try {
             //获取当前登录用户所属组织id
             CustomerStaffInfoCacheResult staffInfo = CustomerStaffRedis.getStaffInfo(customerId, userId);
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/IcDangerAreaDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/IcDangerAreaDao.xml
index 65f889179a..b65a99872a 100644
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/IcDangerAreaDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/IcDangerAreaDao.xml
@@ -3,4 +3,11 @@
 
 <mapper namespace="com.epmet.dao.IcDangerAreaDao">
 
+    <update id="delAllDangerArea">
+        update ic_danger_area
+        set del_flag = 1,
+            updated_time = now()
+        where customer_id = #{customerId}
+        limit 1000
+    </update>
 </mapper>
\ No newline at end of file