diff --git a/src/main/java/com/glxp/api/service/sync/HeartService.java b/src/main/java/com/glxp/api/service/sync/HeartService.java index 417daedc4..cfc97c9eb 100644 --- a/src/main/java/com/glxp/api/service/sync/HeartService.java +++ b/src/main/java/com/glxp/api/service/sync/HeartService.java @@ -1874,12 +1874,20 @@ public class HeartService { }); } if (CollectionUtil.isNotEmpty(productsList)) { - BasicProductsEntity basicProductsEntity = productsList.get(0); - List basicProductsEntities = basicProductsDao.selectList(new LambdaQueryWrapper().eq(BasicProductsEntity::getUuid, basicProductsEntity.getUuid())); - if (CollectionUtil.isNotEmpty(basicProductsEntities)){ - for (BasicProductsEntity basicProductsEntity1 : basicProductsEntities){ - if (basicProductsEntity1.getNameCode() == null){ - basicProductsDao.deleteById(basicProductsEntity1); + //过来500 条 数据 过滤掉uuid一样的 100个产品 + List uniqueUuidProducts = productsList.stream() + .collect(Collectors.groupingBy(BasicProductsEntity::getUuid)) + .values() + .stream() + .map(list -> list.get(0)) + .collect(Collectors.toList()); + for (BasicProductsEntity basicProductsEntity : uniqueUuidProducts){ + List basicProductsEntities = basicProductsDao.selectList(new LambdaQueryWrapper().eq(BasicProductsEntity::getUuid, basicProductsEntity.getUuid())); + if (CollectionUtil.isNotEmpty(basicProductsEntities)){ + for (BasicProductsEntity basicProductsEntity1 : basicProductsEntities){ + if (basicProductsEntity1.getNameCode() == null){ + basicProductsDao.deleteById(basicProductsEntity1); + } } } }