物理删除试试

epmet-user/epmet-user-server/src/main/java/com/epmet/dao/IcStatsResiWarnDao.java

@@ -87,4 +87,6 @@ public interface IcStatsResiWarnDao extends BaseDao<IcStatsResiWarnEntity> {
     List<IcUserWarnNoticeResultDTO> queryUserWarnNotice(@Param("customerId") String customerId,
                                                         @Param("agencyId") String agencyId,
                                                         @Param("configIds") List<String> configIds);
+
+    int deleteByCustomerIdAndConfigId(@Param("configId") String configId, @Param("customerId")String customerId);
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/StatsResiWarnServiceImpl.java

@@ -306,7 +306,12 @@ public class StatsResiWarnServiceImpl implements StatsResiWarnService {
         //保存数据
         List<IcStatsResiWarnEntity> icStatsResiWarnEntities = new ArrayList<>();
         for (IcResiCategoryWarnConfigDTO item : icResiCategoryWarnConfigDTOList) {
-            icStatsResiWarnDao.delete(new QueryWrapper<IcStatsResiWarnEntity>().lambda().eq(IcStatsResiWarnEntity::getConfigId,item.getId()).eq(IcStatsResiWarnEntity::getCustomerId,customerId));
+            int deleteNum;
+            do {
+                // deleteNum = icStatsResiWarnDao.delete(new QueryWrapper<IcStatsResiWarnEntity>().lambda().eq(IcStatsResiWarnEntity::getConfigId,item.getId())
+                //         .eq(IcStatsResiWarnEntity::getCustomerId,customerId));
+                deleteNum = icStatsResiWarnDao.deleteByCustomerIdAndConfigId(item.getId(),customerId);
+            } while (deleteNum > NumConstant.ZERO);
 
 
             List<IcStatsResiWarnEntity> maps = icStatsResiWarnDao.resiWarn(customerId,item.getTableName(), item.getColumnName());

epmet-user/epmet-user-server/src/main/resources/mapper/IcStatsResiWarnDao.xml

@@ -206,4 +206,11 @@
                 </foreach>
             )
     </select>
+
+    <delete id="deleteByCustomerIdAndConfigId" parameterType="map">
+        DELETE FROM ic_stats_resi_warn
+       WHERE config_id = #{configId}
+         and customer_id = #{customerId}
+         limit 1000
+    </delete>
 </mapper>