diff --git a/src/main/java/cn/com/tenlion/commonpopulation/service/basepopulationinfo/impl/BasePopulationInfoServiceImpl.java b/src/main/java/cn/com/tenlion/commonpopulation/service/basepopulationinfo/impl/BasePopulationInfoServiceImpl.java index cf94af8..75edb2d 100644 --- a/src/main/java/cn/com/tenlion/commonpopulation/service/basepopulationinfo/impl/BasePopulationInfoServiceImpl.java +++ b/src/main/java/cn/com/tenlion/commonpopulation/service/basepopulationinfo/impl/BasePopulationInfoServiceImpl.java @@ -652,10 +652,13 @@ public class BasePopulationInfoServiceImpl extends DefaultBaseService implements if(forIndex != 0 && forIndex % 5000 == 0){ System.out.println("================= PULL_COUNT_" + forIndex + " ================="); } - forIndex++; } catch (Exception e){ + Map params = new HashMap<>(8); + params.put("basePopulationInfoIds", Arrays.asList(item.getBasePopulationInfoId().split(","))); + basePopulationInfoDao.removeBasePopulationInfo(params); System.out.println(item); } + forIndex++; } }