删除

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);
+
 }

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);

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>